AxInMemoryEventStore

Defined in: https://github.com/ax-llm/ax/blob/3d5aa8dac28a2637e4150f022dcd02e6fc3309f0/src/ax/event/memoryStore.ts#L31

Implements

AxEventStore

Constructors

Constructor

TypeScript

new AxInMemoryEventStore(options: Readonly<AxInMemoryEventStoreOptions>): AxInMemoryEventStore;

Defined in: https://github.com/ax-llm/ax/blob/3d5aa8dac28a2637e4150f022dcd02e6fc3309f0/src/ax/event/memoryStore.ts#L62

Parameters

Parameter	Type
`options`	`Readonly`<`AxInMemoryEventStoreOptions`>

Returns

AxInMemoryEventStore

Properties

Property	Modifier	Type
`capabilities`	`readonly`	`object`
`capabilities.compareAndSet`	`readonly`	`false`
`capabilities.coordination`	`readonly`	`"single-worker"`
`capabilities.durability`	`readonly`	`"volatile"`
`capabilities.leases`	`readonly`	`false`
`capabilities.outputPersistence`	`readonly`	`true`
`capabilities.transactions`	`readonly`	`false`

Methods

addDeadLetter()

TypeScript

addDeadLetter(deadLetter: Readonly<AxEventDeadLetter>): Promise<void>;

Defined in: https://github.com/ax-llm/ax/blob/3d5aa8dac28a2637e4150f022dcd02e6fc3309f0/src/ax/event/memoryStore.ts#L318

Parameters

Parameter	Type
`deadLetter`	`Readonly`<`AxEventDeadLetter`>

Returns

Promise<void>

Implementation of

AxEventStore.addDeadLetter

claim()

TypeScript

claim(
   workerId: string, 
   now: number, 
leaseMs: number): Promise<AxEventDelivery | undefined>;

Defined in: https://github.com/ax-llm/ax/blob/3d5aa8dac28a2637e4150f022dcd02e6fc3309f0/src/ax/event/memoryStore.ts#L182

Parameters

Parameter	Type	Default value
`workerId`	`string`	`undefined`
`now`	`number`	`undefined`
`leaseMs`	`number`	`30_000`

Returns

Promise<AxEventDelivery | undefined>

Implementation of

AxEventStore.claim

close()

TypeScript

close(): Promise<void>;

Defined in: https://github.com/ax-llm/ax/blob/3d5aa8dac28a2637e4150f022dcd02e6fc3309f0/src/ax/event/memoryStore.ts#L407

Returns

Promise<void>

Implementation of

AxEventStore.close

completeContinuation()

TypeScript

completeContinuation(id: string): Promise<void>;

Defined in: https://github.com/ax-llm/ax/blob/3d5aa8dac28a2637e4150f022dcd02e6fc3309f0/src/ax/event/memoryStore.ts#L303

Parameters

Parameter	Type
`id`	`string`

Returns

Promise<void>

Implementation of

AxEventStore.completeContinuation

enqueue()

TypeScript

enqueue(request: Readonly<AxEventEnqueueRequest>, signal?: AbortSignal): Promise<AxEventPublishReceipt>;

Defined in: https://github.com/ax-llm/ax/blob/3d5aa8dac28a2637e4150f022dcd02e6fc3309f0/src/ax/event/memoryStore.ts#L69

Parameters

Parameter	Type
`request`	`Readonly`<`AxEventEnqueueRequest`>
`signal?`	`AbortSignal`

Returns

Promise<AxEventPublishReceipt>

Implementation of

AxEventStore.enqueue

findContinuation()

TypeScript

findContinuation(
   identityScope: string, 
   correlation: Readonly<AxEventCorrelationKey>, 
   now: number): Promise<
  | Readonly<AxEventContinuation>
| undefined>;

Defined in: https://github.com/ax-llm/ax/blob/3d5aa8dac28a2637e4150f022dcd02e6fc3309f0/src/ax/event/memoryStore.ts#L282

Parameters

Parameter	Type
`identityScope`	`string`
`correlation`	`Readonly`<`AxEventCorrelationKey`>
`now`	`number`

Returns

Promise< | Readonly<AxEventContinuation> | undefined>

Implementation of

AxEventStore.findContinuation

getDeadLetter()

TypeScript

getDeadLetter(id: string): Promise<
  | Readonly<AxEventDeadLetter>
| undefined>;

Defined in: https://github.com/ax-llm/ax/blob/3d5aa8dac28a2637e4150f022dcd02e6fc3309f0/src/ax/event/memoryStore.ts#L322

Parameters

Parameter	Type
`id`	`string`

Returns

Promise< | Readonly<AxEventDeadLetter> | undefined>

Implementation of

AxEventStore.getDeadLetter

getDelivery()

TypeScript

getDelivery(deliveryId: string): Promise<
  | Readonly<AxEventDelivery>
| undefined>;

Defined in: https://github.com/ax-llm/ax/blob/3d5aa8dac28a2637e4150f022dcd02e6fc3309f0/src/ax/event/memoryStore.ts#L222

Parameters

Parameter	Type
`deliveryId`	`string`

Returns

Promise< | Readonly<AxEventDelivery> | undefined>

Implementation of

AxEventStore.getDelivery

getRun()

TypeScript

getRun(runId: string): Promise<
  | Readonly<AxEventRun<unknown>>
| undefined>;

Defined in: https://github.com/ax-llm/ax/blob/3d5aa8dac28a2637e4150f022dcd02e6fc3309f0/src/ax/event/memoryStore.ts#L248

Parameters

Parameter	Type
`runId`	`string`

Returns

Promise< | Readonly<AxEventRun<unknown>> | undefined>

Implementation of

AxEventStore.getRun

isIdle()

TypeScript

isIdle(): Promise<boolean>;

Defined in: https://github.com/ax-llm/ax/blob/3d5aa8dac28a2637e4150f022dcd02e6fc3309f0/src/ax/event/memoryStore.ts#L403

Returns

Promise<boolean>

Implementation of

AxEventStore.isIdle

listDeadLetters()

TypeScript

listDeadLetters(): Promise<readonly Readonly<AxEventDeadLetter>[]>;

Defined in: https://github.com/ax-llm/ax/blob/3d5aa8dac28a2637e4150f022dcd02e6fc3309f0/src/ax/event/memoryStore.ts#L333

Returns

Promise<readonly Readonly<AxEventDeadLetter>[]>

Implementation of

AxEventStore.listDeadLetters

nextAvailableAt()

TypeScript

nextAvailableAt(_now: number): Promise<number | undefined>;

Defined in: https://github.com/ax-llm/ax/blob/3d5aa8dac28a2637e4150f022dcd02e6fc3309f0/src/ax/event/memoryStore.ts#L360

Parameters

Parameter	Type
`_now`	`number`

Returns

Promise<number | undefined>

Implementation of

AxEventStore.nextAvailableAt

redriveDelivery()

TypeScript

redriveDelivery(deliveryId: string, now: number): Promise<void>;

Defined in: https://github.com/ax-llm/ax/blob/3d5aa8dac28a2637e4150f022dcd02e6fc3309f0/src/ax/event/memoryStore.ts#L339

Parameters

Parameter	Type
`deliveryId`	`string`
`now`	`number`

Returns

Promise<void>

Implementation of

AxEventStore.redriveDelivery

registerContinuation()

TypeScript

registerContinuation(continuation: Readonly<AxEventContinuation>): Promise<void>;

Defined in: https://github.com/ax-llm/ax/blob/3d5aa8dac28a2637e4150f022dcd02e6fc3309f0/src/ax/event/memoryStore.ts#L253

Parameters

Parameter	Type
`continuation`	`Readonly`<`AxEventContinuation`>

Returns

Promise<void>

Implementation of

AxEventStore.registerContinuation

removeDeadLetter()

TypeScript

removeDeadLetter(id: string): Promise<void>;

Defined in: https://github.com/ax-llm/ax/blob/3d5aa8dac28a2637e4150f022dcd02e6fc3309f0/src/ax/event/memoryStore.ts#L329

Parameters

Parameter	Type
`id`	`string`

Returns

Promise<void>

Implementation of

AxEventStore.removeDeadLetter

renewClaim()

TypeScript

renewClaim(
   deliveryId: string, 
   workerId: string, 
   fencingToken: number, 
leaseExpiresAt: number): Promise<void>;

Defined in: https://github.com/ax-llm/ax/blob/3d5aa8dac28a2637e4150f022dcd02e6fc3309f0/src/ax/event/memoryStore.ts#L205

Parameters

Parameter	Type
`deliveryId`	`string`
`workerId`	`string`
`fencingToken`	`number`
`leaseExpiresAt`	`number`

Returns

Promise<void>

Implementation of

AxEventStore.renewClaim

saveDelivery()

TypeScript

saveDelivery(delivery: Readonly<AxEventDelivery>): Promise<void>;

Defined in: https://github.com/ax-llm/ax/blob/3d5aa8dac28a2637e4150f022dcd02e6fc3309f0/src/ax/event/memoryStore.ts#L229

Parameters

Parameter	Type
`delivery`	`Readonly`<`AxEventDelivery`>

Returns

Promise<void>

Implementation of

AxEventStore.saveDelivery

saveRun()

TypeScript

saveRun(run: Readonly<AxEventRun>): Promise<void>;

Defined in: https://github.com/ax-llm/ax/blob/3d5aa8dac28a2637e4150f022dcd02e6fc3309f0/src/ax/event/memoryStore.ts#L244

Parameters

Parameter	Type
`run`	`Readonly`<`AxEventRun`>

Returns

Promise<void>

Implementation of

AxEventStore.saveRun

waitForWork()

TypeScript

waitForWork(signal?: AbortSignal): Promise<void>;

Defined in: https://github.com/ax-llm/ax/blob/3d5aa8dac28a2637e4150f022dcd02e6fc3309f0/src/ax/event/memoryStore.ts#L371

Parameters

Parameter	Type
`signal?`	`AbortSignal`

Returns

Promise<void>

Implementation of

AxEventStore.waitForWork