IPipelineCallbacks

onStart: (clientId: string, pipelineName: string, payload: Payload) => void
onEnd: (clientId: string, pipelineName: string, payload: Payload, isError: boolean) => void
onError: (clientId: string, pipelineName: string, payload: Payload, error: Error) => void