AxInMemoryEventStore

Defined in: https://github.com/ax-llm/ax/blob/e4219a44b7581a55a40d9dd62d2c281062ff078d/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/e4219a44b7581a55a40d9dd62d2c281062ff078d/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/e4219a44b7581a55a40d9dd62d2c281062ff078d/src/ax/event/memoryStore.ts#L307

Parameters

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

Returns

Promise<void>

Implementation of

AxEventStore.addDeadLetter

claim()

TypeScript

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

Defined in: https://github.com/ax-llm/ax/blob/e4219a44b7581a55a40d9dd62d2c281062ff078d/src/ax/event/memoryStore.ts#L171

Parameters

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

Returns

Promise<undefined | AxEventDelivery>

Implementation of

AxEventStore.claim

close()

TypeScript

close(): Promise<void>;

Defined in: https://github.com/ax-llm/ax/blob/e4219a44b7581a55a40d9dd62d2c281062ff078d/src/ax/event/memoryStore.ts#L387

Returns

Promise<void>

Implementation of

AxEventStore.close

completeContinuation()

TypeScript

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

Defined in: https://github.com/ax-llm/ax/blob/e4219a44b7581a55a40d9dd62d2c281062ff078d/src/ax/event/memoryStore.ts#L292

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/e4219a44b7581a55a40d9dd62d2c281062ff078d/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<
  | undefined
| Readonly<AxEventContinuation>>;

Defined in: https://github.com/ax-llm/ax/blob/e4219a44b7581a55a40d9dd62d2c281062ff078d/src/ax/event/memoryStore.ts#L271

Parameters

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

Returns

Promise< | undefined | Readonly<AxEventContinuation>>

Implementation of

AxEventStore.findContinuation

getDeadLetter()

TypeScript

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

Defined in: https://github.com/ax-llm/ax/blob/e4219a44b7581a55a40d9dd62d2c281062ff078d/src/ax/event/memoryStore.ts#L311

Parameters

Parameter	Type
`id`	`string`

Returns

Promise< | undefined | Readonly<AxEventDeadLetter>>

Implementation of

AxEventStore.getDeadLetter

getDelivery()

TypeScript

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

Defined in: https://github.com/ax-llm/ax/blob/e4219a44b7581a55a40d9dd62d2c281062ff078d/src/ax/event/memoryStore.ts#L211

Parameters

Parameter	Type
`deliveryId`	`string`

Returns

Promise< | undefined | Readonly<AxEventDelivery>>

Implementation of

AxEventStore.getDelivery

getRun()

TypeScript

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

Defined in: https://github.com/ax-llm/ax/blob/e4219a44b7581a55a40d9dd62d2c281062ff078d/src/ax/event/memoryStore.ts#L237

Parameters

Parameter	Type
`runId`	`string`

Returns

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

Implementation of

AxEventStore.getRun

isIdle()

TypeScript

isIdle(): Promise<boolean>;

Defined in: https://github.com/ax-llm/ax/blob/e4219a44b7581a55a40d9dd62d2c281062ff078d/src/ax/event/memoryStore.ts#L383

Returns

Promise<boolean>

Implementation of

AxEventStore.isIdle

listDeadLetters()

TypeScript

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

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

Returns

Promise<readonly Readonly<AxEventDeadLetter>[]>

Implementation of

AxEventStore.listDeadLetters

nextAvailableAt()

TypeScript

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

Defined in: https://github.com/ax-llm/ax/blob/e4219a44b7581a55a40d9dd62d2c281062ff078d/src/ax/event/memoryStore.ts#L349

Parameters

Parameter	Type
`_now`	`number`

Returns

Promise<undefined | number>

Implementation of

AxEventStore.nextAvailableAt

redriveDelivery()

TypeScript

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

Defined in: https://github.com/ax-llm/ax/blob/e4219a44b7581a55a40d9dd62d2c281062ff078d/src/ax/event/memoryStore.ts#L328

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/e4219a44b7581a55a40d9dd62d2c281062ff078d/src/ax/event/memoryStore.ts#L242

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/e4219a44b7581a55a40d9dd62d2c281062ff078d/src/ax/event/memoryStore.ts#L318

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/e4219a44b7581a55a40d9dd62d2c281062ff078d/src/ax/event/memoryStore.ts#L194

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/e4219a44b7581a55a40d9dd62d2c281062ff078d/src/ax/event/memoryStore.ts#L218

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/e4219a44b7581a55a40d9dd62d2c281062ff078d/src/ax/event/memoryStore.ts#L233

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/e4219a44b7581a55a40d9dd62d2c281062ff078d/src/ax/event/memoryStore.ts#L360

Parameters

Parameter	Type
`signal?`	`AbortSignal`

Returns

Promise<void>

Implementation of

AxEventStore.waitForWork