ObservabilityAdapter
ObservabilityAdapter =
object
Defined in: packages/core/src/observability-adapter/observability-adapter.ts:136
Adapter for structured logging, metrics, and distributed tracing. All methods are synchronous — side effects are buffered via transaction hooks and flushed after commit.
Properties
Section titled “Properties”chainCompleted
Section titled “chainCompleted”chainCompleted: (
data) =>void
Defined in: packages/core/src/observability-adapter/observability-adapter.ts:145
Parameters
Section titled “Parameters”ChainBasicData & object
Returns
Section titled “Returns”void
chainCreated
Section titled “chainCreated”chainCreated: (
data) =>void
Defined in: packages/core/src/observability-adapter/observability-adapter.ts:144
Parameters
Section titled “Parameters”ChainBasicData & object
Returns
Section titled “Returns”void
chainDeleted
Section titled “chainDeleted”chainDeleted: (
data) =>void
Defined in: packages/core/src/observability-adapter/observability-adapter.ts:146
Parameters
Section titled “Parameters”ChainBasicData
Returns
Section titled “Returns”void
chainDuration
Section titled “chainDuration”chainDuration: (
data) =>void
Defined in: packages/core/src/observability-adapter/observability-adapter.ts:180
Parameters
Section titled “Parameters”ChainBasicData & object
Returns
Section titled “Returns”void
completeBlockerSpan
Section titled “completeBlockerSpan”completeBlockerSpan: (
data) =>void
Defined in: packages/core/src/observability-adapter/observability-adapter.ts:191
Parameters
Section titled “Parameters”CompleteBlockerSpanData
Returns
Section titled “Returns”void
completeJobSpan
Section titled “completeJobSpan”completeJobSpan: (
data) =>void
Defined in: packages/core/src/observability-adapter/observability-adapter.ts:193
Parameters
Section titled “Parameters”CompleteJobSpanInputData
Returns
Section titled “Returns”void
jobAttemptAlreadyCompleted
Section titled “jobAttemptAlreadyCompleted”jobAttemptAlreadyCompleted: (
data) =>void
Defined in: packages/core/src/observability-adapter/observability-adapter.ts:164
Parameters
Section titled “Parameters”JobProcessingData & WorkerBasicData & object
Returns
Section titled “Returns”void
jobAttemptCompleted
Section titled “jobAttemptCompleted”jobAttemptCompleted: (
data) =>void
Defined in: packages/core/src/observability-adapter/observability-adapter.ts:170
Parameters
Section titled “Parameters”JobCompletionData & WorkerBasicData
Returns
Section titled “Returns”void
jobAttemptDuration
Section titled “jobAttemptDuration”jobAttemptDuration: (
data) =>void
Defined in: packages/core/src/observability-adapter/observability-adapter.ts:182
Parameters
Section titled “Parameters”JobProcessingData & WorkerBasicData & object
Returns
Section titled “Returns”void
jobAttemptExpired
Section titled “jobAttemptExpired”jobAttemptExpired: (
data) =>void
Defined in: packages/core/src/observability-adapter/observability-adapter.ts:167
Parameters
Section titled “Parameters”JobAttemptData & WorkerBasicData
Returns
Section titled “Returns”void
jobAttemptExtended
Section titled “jobAttemptExtended”jobAttemptExtended: (
data) =>void
Defined in: packages/core/src/observability-adapter/observability-adapter.ts:168
Parameters
Section titled “Parameters”JobAttemptData & WorkerBasicData
Returns
Section titled “Returns”void
jobAttemptFailed
Section titled “jobAttemptFailed”jobAttemptFailed: (
data) =>void
Defined in: packages/core/src/observability-adapter/observability-adapter.ts:169
Parameters
Section titled “Parameters”JobProcessingData & WorkerBasicData & object
Returns
Section titled “Returns”void
jobAttemptReclaimed
Section titled “jobAttemptReclaimed”jobAttemptReclaimed: (
data) =>void
Defined in: packages/core/src/observability-adapter/observability-adapter.ts:171
Parameters
Section titled “Parameters”JobAttemptData & WorkerBasicData
Returns
Section titled “Returns”void
jobAttemptStarted
Section titled “jobAttemptStarted”jobAttemptStarted: (
data) =>void
Defined in: packages/core/src/observability-adapter/observability-adapter.ts:162
Parameters
Section titled “Parameters”JobProcessingData & WorkerBasicData
Returns
Section titled “Returns”void
jobAttemptTakenByAnotherWorker
Section titled “jobAttemptTakenByAnotherWorker”jobAttemptTakenByAnotherWorker: (
data) =>void
Defined in: packages/core/src/observability-adapter/observability-adapter.ts:163
Parameters
Section titled “Parameters”JobAttemptData & WorkerBasicData
Returns
Section titled “Returns”void
jobBlocked
Section titled “jobBlocked”jobBlocked: (
data) =>void
Defined in: packages/core/src/observability-adapter/observability-adapter.ts:158
Parameters
Section titled “Parameters”JobBasicData & object
Returns
Section titled “Returns”void
jobCompleted
Section titled “jobCompleted”jobCompleted: (
data) =>void
Defined in: packages/core/src/observability-adapter/observability-adapter.ts:156
Parameters
Section titled “Parameters”JobCompletionData
Returns
Section titled “Returns”void
jobCreated
Section titled “jobCreated”jobCreated: (
data) =>void
Defined in: packages/core/src/observability-adapter/observability-adapter.ts:149
Parameters
Section titled “Parameters”JobBasicData & object
Returns
Section titled “Returns”void
jobDuration
Section titled “jobDuration”jobDuration: (
data) =>void
Defined in: packages/core/src/observability-adapter/observability-adapter.ts:181
Parameters
Section titled “Parameters”JobProcessingData & object
Returns
Section titled “Returns”void
jobRescheduled
Section titled “jobRescheduled”jobRescheduled: (
data) =>void
Defined in: packages/core/src/observability-adapter/observability-adapter.ts:157
Parameters
Section titled “Parameters”JobBasicData & object
Returns
Section titled “Returns”void
jobTypeIdleChange
Section titled “jobTypeIdleChange”jobTypeIdleChange: (
data) =>void
Defined in: packages/core/src/observability-adapter/observability-adapter.ts:185
Parameters
Section titled “Parameters”WorkerBasicData & object
Returns
Section titled “Returns”void
jobTypeProcessingChange
Section titled “jobTypeProcessingChange”jobTypeProcessingChange: (
data) =>void
Defined in: packages/core/src/observability-adapter/observability-adapter.ts:186
Parameters
Section titled “Parameters”WorkerBasicData & object
Returns
Section titled “Returns”void
jobUnblocked
Section titled “jobUnblocked”jobUnblocked: (
data) =>void
Defined in: packages/core/src/observability-adapter/observability-adapter.ts:159
Parameters
Section titled “Parameters”JobBasicData & object
Returns
Section titled “Returns”void
notifyAdapterError
Section titled “notifyAdapterError”notifyAdapterError: (
data) =>void
Defined in: packages/core/src/observability-adapter/observability-adapter.ts:174
Parameters
Section titled “Parameters”unknown
operation
Section titled “operation”keyof NotifyAdapter
Returns
Section titled “Returns”void
startAttemptSpan
Section titled “startAttemptSpan”startAttemptSpan: (
data) =>JobAttemptSpanHandle|undefined
Defined in: packages/core/src/observability-adapter/observability-adapter.ts:192
Parameters
Section titled “Parameters”JobAttemptSpanInputData
Returns
Section titled “Returns”JobAttemptSpanHandle | undefined
startBlockerSpan
Section titled “startBlockerSpan”startBlockerSpan: (
data) =>BlockerSpanHandle|undefined
Defined in: packages/core/src/observability-adapter/observability-adapter.ts:190
Parameters
Section titled “Parameters”BlockerSpanInputData
Returns
Section titled “Returns”BlockerSpanHandle | undefined
startJobSpan
Section titled “startJobSpan”startJobSpan: (
data) =>JobSpanHandle|undefined
Defined in: packages/core/src/observability-adapter/observability-adapter.ts:189
Parameters
Section titled “Parameters”JobSpanInputData
Returns
Section titled “Returns”JobSpanHandle | undefined
stateAdapterError
Section titled “stateAdapterError”stateAdapterError: (
data) =>void
Defined in: packages/core/src/observability-adapter/observability-adapter.ts:177
Parameters
Section titled “Parameters”unknown
operation
Section titled “operation”keyof StateAdapter<any, any>
Returns
Section titled “Returns”void
workerError
Section titled “workerError”workerError: (
data) =>void
Defined in: packages/core/src/observability-adapter/observability-adapter.ts:139
Parameters
Section titled “Parameters”WorkerBasicData & object
Returns
Section titled “Returns”void
workerStarted
Section titled “workerStarted”workerStarted: (
data) =>void
Defined in: packages/core/src/observability-adapter/observability-adapter.ts:138
Parameters
Section titled “Parameters”WorkerBasicData & object
Returns
Section titled “Returns”void
workerStopped
Section titled “workerStopped”workerStopped: (
data) =>void
Defined in: packages/core/src/observability-adapter/observability-adapter.ts:141
Parameters
Section titled “Parameters”WorkerBasicData
Returns
Section titled “Returns”void
workerStopping
Section titled “workerStopping”workerStopping: (
data) =>void
Defined in: packages/core/src/observability-adapter/observability-adapter.ts:140
Parameters
Section titled “Parameters”WorkerBasicData
Returns
Section titled “Returns”void