Class WorkflowEmitter

new WorkflowEmitter(): WorkflowEmitter

emitSignal(
    type: "signal:received" | "signal:timeout",
    executionId: string,
    workflowName: string,
    event: string,
    payload?: unknown,
): void

emitStep(
    type:
        | "step:started"
        | "step:completed"
        | "step:failed"
        | "step:retry"
        | "compensation:started"
        | "compensation:completed"
        | "compensation:failed"
        | "compensation:skipped",
    executionId: string,
    workflowName: string,
    stepName: string,
    extra?: Partial<
        Omit<
            StepEvent,
            "timestamp"
            | "type"
            | "executionId"
            | "workflowName"
            | "stepName",
        >,
    >,
): void

emitWorkflow(
    type:
        | "workflow:started"
        | "workflow:completed"
        | "workflow:failed"
        | "workflow:compensating"
        | "workflow:waiting",
    executionId: string,
    workflowName: string,
    state: ExecutionState,
    extra?: Partial<
        Omit<
            WorkflowLifecycleEvent,
            "timestamp"
            | "type"
            | "executionId"
            | "workflowName"
            | "state",
        >,
    >,
): void

off(type: WorkflowEventType, listener: WorkflowEventListener): this

offAny(listener: WorkflowEventListener): this

on(type: WorkflowEventType, listener: WorkflowEventListener): this

onAny(listener: WorkflowEventListener): this

removeAllListeners(): void