API Reference

cqrsWorkQueueDispositionCommand()

Creates a CQRS work queue disposition command.

Import

import { cqrsWorkQueueDispositionCommand } from "@graphrefly/ts/cqrs/work-queue";

Signature

function cqrsWorkQueueDispositionCommand(
	attempt: CqrsWorkQueueAttempt<TCommand>,
	outcome: CqrsWorkQueueOutcome,
	policy?: CqrsWorkQueuePolicy,
): WorkQueueCommand<CqrsQueuedCommandPayload<TCommand>>

Parameters

Parameter	Type	Description
`attempt`	`CqrsWorkQueueAttempt<TCommand>`	attempt value used by the helper.
`outcome`	`CqrsWorkQueueOutcome`	Outcome value to record or index.
`policy`	`CqrsWorkQueuePolicy`	Policy object used to admit, retry, or route work.

Returns

The CQRS work queue disposition command result.

Example

import { cqrsWorkQueueDispositionCommand } from "@graphrefly/ts/cqrs/work-queue";

Source

packages/ts/src/cqrs/work-queue.ts