Constructs a new JobManager with the given options.
Optionaloptions: JobManagerOptionsConfiguration options for the manager
Aborts a job by ID, removing it from the queue and signaling cancellation.
The job ID
Optionalreason: stringOptional reason for aborting
Adds a new job to the manager. Throws if the job ID already exists.
The job to add
Retrieves a job by its ID.
The job ID
The job, or undefined if not found
Gets the maximum number of jobs that can run concurrently.
Gets the maximum number of jobs allowed in the queue.
Gets the maximum number of raw bytes to store per job.
Gets the maximum number of response chunks stored per job.
Gets the current number of jobs in the queue.
Gets the current number of jobs running.
Gets whether raw responses are stored for jobs.
Gets whether binary-heavy fields are stripped from snapshots and timeline artifacts.
Lists all jobs managed by this instance as snapshots.
Array of job snapshots
Resets and reruns a job by ID. Throws if not found or already running.
The job ID
The execution context
OptionalonChunk: (chunk: JobChunk<TOutput>) => voidOptional callback for progress chunks
The job instance
Queues a job for execution. Throws if already running, queued, or not found.
The job ID
The execution context
OptionalonChunk: (chunk: JobChunk<TOutput>) => voidOptional callback for progress chunks
The job instance
Sets the maximum number of jobs that can run concurrently.
The new concurrency limit
Sets the maximum number of jobs allowed in the queue.
The new queue size limit
Sets the maximum number of raw bytes to store per job.
The new byte limit
Sets the maximum number of response chunks stored per job.
The new chunk limit
Sets whether raw responses are stored for jobs.
True to store raw responses
Sets whether binary-heavy fields are stripped from snapshots and timeline artifacts.
True to strip binary-heavy fields
Subscribes to status updates for a specific job.
The job ID
The callback to invoke on updates
Unsubscribe function
Description
Implementation class for JobManager.