bodhi-realtime-agent / RuntimeObserver

Class: RuntimeObserver

Defined in: src/runtime/observability.ts:61

RuntimeObserver collects observability data from the actor runtime.

Designed to be zero-overhead when no listener is attached.

Constructors

Constructor

new RuntimeObserver(): RuntimeObserver

Returns

RuntimeObserver

Accessors

deadLetterCount

Get Signature

get deadLetterCount(): number

Defined in: src/runtime/observability.ts:183

Get total dead letter count.

Returns

number

Methods

getFailureCount()

getFailureCount(actorId): number

Defined in: src/runtime/observability.ts:178

Get total failure count for an actor.

Parameters

actorId

string

Returns

number

---

getMessagesProcessed()

getMessagesProcessed(actorId): number

Defined in: src/runtime/observability.ts:173

Get total messages processed by an actor.

Parameters

actorId

string

Returns

number

---

getMetrics()

getMetrics(getMailboxDepth, actorIds): RuntimeMetrics

Defined in: src/runtime/observability.ts:157

Get current metrics snapshot.

Parameters

getMailboxDepth

(actorId) => number

actorIds

string[]

Returns

RuntimeMetrics

---

recordDeadLetter()

recordDeadLetter(envelope): void

Defined in: src/runtime/observability.ts:110

Record a dead letter.

Parameters

envelope

Envelope

Returns

void

---

recordFailure()

recordFailure(actorId, error, envelope): void

Defined in: src/runtime/observability.ts:90

Record an actor failure.

Parameters

actorId

string

error

unknown

envelope

Envelope

Returns

void

---

recordLifecycle()

recordLifecycle(actorId, event): void

Defined in: src/runtime/observability.ts:145

Record an actor lifecycle event.

Parameters

actorId

string

event

"stopped" | "started" | "restarted"

Returns

void

---

recordMessageProcessed()

recordMessageProcessed(actorId, envelope): void

Defined in: src/runtime/observability.ts:73

Record a message being processed by an actor.

Parameters

actorId

string

envelope

Envelope

Returns

void

---

recordWorkflowTransition()

recordWorkflowTransition(actorId, workflowId, fromState, toState, toolCallId?): void

Defined in: src/runtime/observability.ts:125

Record a workflow transition.

Parameters

actorId

string

workflowId

string

fromState

string

toState

string

toolCallId?

string

Returns

void

---

reset()

reset(): void

Defined in: src/runtime/observability.ts:188

Reset all counters.

Returns

void

---

setListener()

setListener(listener): void

Defined in: src/runtime/observability.ts:68

Set the observability listener.

Parameters

listener

ObservabilityListener

Returns

void