IPipelineCallbacks

Defines callback functions for pipeline lifecycle events.

onStart: (clientId: string, pipelineName: string, payload: Payload) => void

Called when the pipeline execution starts.

onEnd: (clientId: string, pipelineName: string, payload: Payload, isError: boolean) => void

Called when the pipeline execution ends, indicating success or failure.

onError: (clientId: string, pipelineName: string, payload: Payload, error: Error) => void

Called when an error occurs during pipeline execution. Provides error handling capabilities for pipeline failures and debugging.