Class AgentJournal

Independent durable journal. No queue/workflow database or engine internals are used.

Index

Constructors

Methods

append checkpointSession claimEffect close completeEffect getEffect getSession replacePending replay

Constructors

constructor

new AgentJournal(path: string, options?: AgentJournalOptions): AgentJournal
Parameters
- path: string
- options: AgentJournalOptions = {}
Returns AgentJournal
- Defined in agents/journal.ts:25

Methods

append

append(executionId: string, stepId: string, event: AgentEvent): number
Parameters
- executionId: string
- stepId: string
- event: AgentEvent
Returns number
- Defined in agents/journal.ts:46

checkpointSession

checkpointSession(executionId: string, stepId: string, sessionId: string): void
Parameters
- executionId: string
- stepId: string
- sessionId: string
Returns void
- Defined in agents/journal.ts:31

claimEffect

claimEffect(run: AgentRunIdentity, callId: string, token: string): boolean
Atomic durable pending claim. The callback is always invoked outside SQLite transactions.
Parameters
- run: AgentRunIdentity
- callId: string
- token: string
Returns boolean
- Defined in agents/journal.ts:105

close

close(): void
Returns void
- Defined in agents/journal.ts:151

completeEffect

completeEffect(
    run: AgentRunIdentity,
    callId: string,
    token: string,
    result: unknown,
): boolean
Parameters
- run: AgentRunIdentity
- callId: string
- token: string
- result: unknown
Returns boolean
- Defined in agents/journal.ts:139

getEffect

getEffect(run: AgentRunIdentity, callId: string): EffectRecord | null
Parameters
- run: AgentRunIdentity
- callId: string
Returns EffectRecord | null
- Defined in agents/journal.ts:114

getSession

getSession(executionId: string, stepId: string): string | null
Parameters
- executionId: string
- stepId: string
Returns string | null
- Defined in agents/journal.ts:39

replacePending

replacePending(
    run: AgentRunIdentity,
    callId: string,
    priorToken: string,
    nextToken: string,
): boolean
Parameters
- run: AgentRunIdentity
- callId: string
- priorToken: string
- nextToken: string
Returns boolean
- Defined in agents/journal.ts:125

replay

replay(
executionId: string,
options?: { after?: number; limit?: number },
): AgentReplay
Parameters
- executionId: string
- options: { after?: number; limit?: number } = {}
Returns AgentReplay
- Defined in agents/journal.ts:74