IPipelineSchema

Defines the schema for a pipeline, including execution logic and optional callbacks.

Properties

pipelineName

pipelineName: string
Copy

The name of the pipeline.

execute

execute: <T = any>(clientId: string, agentName: string, payload: Payload) => Promise<void | T>
Copy

Function to execute the pipeline logic.

callbacks

callbacks: Partial<IPipelineCallbacks<Payload>>
Copy

Optional callbacks for pipeline lifecycle events. Provides hooks for monitoring pipeline execution, handling errors, and customizing behavior.