ForkedCaptureHandler
Defined in: packages/core/src/capture/forked/forked-capture.ts:48
A capture handler that runs jobs in a forked child.
Extends
Section titled “Extends”Properties
Section titled “Properties”backoff?
Section titled “backoff?”
optionalbackoff?:object
Defined in: packages/core/src/capture/consumer/types.ts:40
Retry delay of this kind: baseMs * 2^n capped at maxMs; defaults to the consumer’s.
baseMs
Section titled “baseMs”baseMs:
number
maxMs:
number
Inherited from
Section titled “Inherited from”tripped
Section titled “tripped”
readonlytripped:boolean
Defined in: packages/core/src/capture/forked/forked-capture.ts:50
Whether forking was given up and jobs run in-process.
Methods
Section titled “Methods”accepts()?
Section titled “accepts()?”
optionalaccepts(job):boolean
Defined in: packages/core/src/capture/consumer/types.ts:38
Whether the job is well-formed; a job that is not is failed without retries.
Parameters
Section titled “Parameters”Returns
Section titled “Returns”boolean
Inherited from
Section titled “Inherited from”cancel()?
Section titled “cancel()?”
optionalcancel(job):Promise<void>
Defined in: packages/core/src/capture/consumer/types.ts:42
Stop a running job (lease lost or cancelled); must tolerate a job that already ended.
Parameters
Section titled “Parameters”Returns
Section titled “Returns”Promise<void>
Inherited from
Section titled “Inherited from”close()
Section titled “close()”close():
Promise<void>
Defined in: packages/core/src/capture/forked/forked-capture.ts:52
Stop the child (SIGTERM, escalating to SIGKILL). Call after the consumer has drained.
Returns
Section titled “Returns”Promise<void>
run(
job,context):Promise<void>
Defined in: packages/core/src/capture/consumer/types.ts:36
Run the job; resolve to ack it, reject to retry (or fail it on its last attempt).
Parameters
Section titled “Parameters”context
Section titled “context”Returns
Section titled “Returns”Promise<void>