/** * Centralized log definitions for the Durable Task Worker. * * Event IDs and message templates are aligned with the .NET Durable Task SDK * (see: https://github.com/microsoft/durabletask-dotnet/blob/main/src/Worker/Core/Logs.cs). * * Event ID ranges: * - 15: Entity operation errors (from .NET) * - 55: Retry handler evaluation (from .NET) * - 600–605: Core orchestration/activity lifecycle (from .NET) * - 700–799: JS-specific worker lifecycle events */ import { Logger } from "../types/logger.type"; /** @internal */ export declare const EVENT_RETRYING_TASK = 55; /** @internal */ export declare const EVENT_ORCHESTRATION_STARTED = 600; /** @internal */ export declare const EVENT_ORCHESTRATION_COMPLETED = 601; /** @internal */ export declare const EVENT_ORCHESTRATION_FAILED = 602; /** @internal */ export declare const EVENT_ACTIVITY_STARTED = 603; /** @internal */ export declare const EVENT_ACTIVITY_COMPLETED = 604; /** @internal */ export declare const EVENT_ACTIVITY_FAILED = 605; /** @internal */ export declare const EVENT_WORKER_CONNECTED = 700; /** @internal */ export declare const EVENT_WORKER_ERROR = 701; /** @internal */ export declare const EVENT_STREAM_ENDED = 702; /** @internal */ export declare const EVENT_STREAM_RETRY = 703; /** @internal */ export declare const EVENT_STREAM_ERROR = 704; /** @internal */ export declare const EVENT_WORK_ITEM_RECEIVED = 705; /** @internal */ export declare const EVENT_SHUTDOWN_WAITING = 706; /** @internal */ export declare const EVENT_SHUTDOWN_COMPLETED = 707; /** @internal */ export declare const EVENT_SHUTDOWN_TIMEOUT = 708; /** @internal */ export declare const EVENT_CONNECTION_RETRY = 709; /** @internal */ export declare const EVENT_ORCHESTRATION_REBUILDING = 710; /** @internal */ export declare const EVENT_ORCHESTRATION_PROCESSING = 711; /** @internal */ export declare const EVENT_ORCHESTRATION_WAITING = 712; /** @internal */ export declare const EVENT_ORCHESTRATION_RETURNING_ACTIONS = 713; /** @internal */ export declare const EVENT_ORCHESTRATION_SUSPENDED = 714; /** @internal */ export declare const EVENT_ORCHESTRATION_TERMINATED = 715; /** @internal */ export declare const EVENT_ORCHESTRATION_EVENT_RAISED = 716; /** @internal */ export declare const EVENT_ORCHESTRATION_EVENT_BUFFERED = 717; /** @internal */ export declare const EVENT_ORCHESTRATION_NO_TASKS = 718; /** @internal */ export declare const EVENT_ORCHESTRATION_PROCESSING_EVENT = 719; /** @internal */ export declare const EVENT_ORCHESTRATION_SUSPENDED_BUFFERING = 720; /** @internal */ export declare const EVENT_ORCHESTRATION_UNKNOWN_EVENT = 721; /** @internal */ export declare const EVENT_ORCHESTRATION_EVENT_ERROR = 722; /** @internal */ export declare const EVENT_ORCHESTRATION_UNEXPECTED_EVENT = 723; /** @internal */ export declare const EVENT_UNKNOWN_WORK_ITEM = 724; /** @internal */ export declare const EVENT_VERSION_MISMATCH_FAIL = 730; /** @internal */ export declare const EVENT_VERSION_MISMATCH_ABANDON = 731; /** @internal */ export declare const EVENT_EXECUTION_ERROR = 732; /** @internal */ export declare const EVENT_COMPLETION_ERROR = 733; /** @internal */ export declare const EVENT_ACTIVITY_EXECUTION_ERROR = 734; /** @internal */ export declare const EVENT_ACTIVITY_RESPONSE_ERROR = 735; /** @internal */ export declare const EVENT_STREAM_ERROR_INFO = 736; /** @internal */ export declare const EVENT_RETRY_HANDLER_EXCEPTION = 737; /** @internal */ export declare const EVENT_ENTITY_REQUEST_RECEIVED = 800; /** @internal */ export declare const EVENT_ENTITY_INSTANCE_ID_PARSE_ERROR = 801; /** @internal */ export declare const EVENT_ENTITY_NOT_FOUND = 802; /** @internal */ export declare const EVENT_ENTITY_EXECUTION_FAILED = 803; /** @internal */ export declare const EVENT_ENTITY_RESPONSE_DELIVERY_FAILED = 804; /** @internal */ export declare const EVENT_ENTITY_UNKNOWN_OPERATION_EVENT = 805; /** @internal */ export declare const EVENT_ENTITY_EVENT_IGNORED = 806; /** * Logs that an orchestration has started execution. * Matches .NET EventId 600: "'{Name}' orchestration with ID '{InstanceId}' started." */ export declare function orchestrationStarted(logger: Logger, instanceId: string, name: string): void; /** * Logs that an orchestration has completed execution. * Matches .NET EventId 601: "'{Name}' orchestration with ID '{InstanceId}' completed." */ export declare function orchestrationCompleted(logger: Logger, instanceId: string, name: string): void; /** * Logs that an orchestration has failed. * Matches .NET EventId 602: "'{Name}' orchestration with ID '{InstanceId}' failed." */ export declare function orchestrationFailed(logger: Logger, instanceId: string, name: string, error?: Error): void; /** * Logs that an activity has started execution. * Matches .NET EventId 603: "'{Name}' activity of orchestration ID '{InstanceId}' started." */ export declare function activityStarted(logger: Logger, instanceId: string, name: string): void; /** * Logs that an activity has completed execution. * Matches .NET EventId 604: "'{Name}' activity of orchestration ID '{InstanceId}' completed." */ export declare function activityCompleted(logger: Logger, instanceId: string, name: string): void; /** * Logs that an activity has failed. * Matches .NET EventId 605: "'{Name}' activity of orchestration ID '{InstanceId}' failed." */ export declare function activityFailed(logger: Logger, instanceId: string, name: string, error?: Error): void; /** * Logs that a failed task is being retried. * Matches .NET EventId 55: "{instanceId}: Evaluating custom retry handler for failed '{name}' task. Attempt = {attempt}." */ export declare function retryingTask(logger: Logger, instanceId: string, name: string, attempt: number): void; /** * Logs that a retry handler or handleFailure predicate threw an exception. * The task will not be retried and will fail with its original error. */ export declare function retryHandlerException(logger: Logger, instanceId: string, name: string, error: unknown): void; export declare function workerConnected(logger: Logger, hostAddress: string): void; export declare function workerError(logger: Logger, error: unknown): void; export declare function streamEnded(logger: Logger): void; export declare function streamRetry(logger: Logger, delayMs: number): void; export declare function streamError(logger: Logger, error: unknown): void; export declare function connectionRetry(logger: Logger, delayMs: number): void; export declare function workItemReceived(logger: Logger, type: string, instanceId?: string): void; export declare function unknownWorkItem(logger: Logger): void; export declare function shutdownWaiting(logger: Logger, pendingCount: number): void; export declare function shutdownCompleted(logger: Logger): void; export declare function shutdownTimeout(logger: Logger, message: string): void; export declare function versionMismatchFail(logger: Logger, instanceId: string, errorType: string, errorMessage: string): void; export declare function versionMismatchAbandon(logger: Logger, instanceId: string, errorType: string, errorMessage: string): void; export declare function executionError(logger: Logger, instanceId: string, error: unknown): void; export declare function completionError(logger: Logger, instanceId: string, error: unknown): void; export declare function activityExecutionError(logger: Logger, activityName: string, error: unknown): void; export declare function activityResponseError(logger: Logger, activityName: string, taskId: number, instanceId: string, error: unknown): void; export declare function orchestrationRebuilding(logger: Logger, instanceId: string, eventCount: number): void; export declare function orchestrationProcessing(logger: Logger, instanceId: string, eventCount: number, summary: string): void; export declare function orchestrationWaiting(logger: Logger, instanceId: string, taskCount: number, eventCount: number): void; export declare function orchestrationReturningActions(logger: Logger, instanceId: string, actionCount: number): void; export declare function orchestrationSuspended(logger: Logger, instanceId: string): void; export declare function orchestrationTerminated(logger: Logger, instanceId: string): void; export declare function orchestrationEventRaised(logger: Logger, instanceId: string, eventName: string): void; export declare function orchestrationEventBuffered(logger: Logger, instanceId: string, eventName: string): void; export declare function orchestrationNoTasks(logger: Logger, resultType: string): void; export declare function orchestrationProcessingEvent(logger: Logger, eventTypeName: string, eventType: number): void; export declare function orchestrationSuspendedBuffering(logger: Logger): void; export declare function orchestrationUnknownEvent(logger: Logger, eventTypeName: string, eventType: number): void; export declare function orchestrationEventError(logger: Logger, eventTypeName: string, error: unknown): void; export declare function orchestrationUnexpectedEvent(logger: Logger, instanceId: string, eventType: string, eventId?: number): void; export declare function streamErrorInfo(logger: Logger, error: unknown): void; export declare function entityRequestReceived(logger: Logger, instanceId: string, requestType: string): void; export declare function entityInstanceIdParseError(logger: Logger, instanceId: string, error: unknown): void; export declare function entityNotFound(logger: Logger, entityName: string): void; export declare function entityExecutionFailed(logger: Logger, entityName: string, error: unknown): void; export declare function entityResponseDeliveryFailed(logger: Logger, error: unknown): void; export declare function entityUnknownOperationEventType(logger: Logger, eventType: string): void; export declare function entityEventIgnored(logger: Logger, instanceId: string, eventType: string, reason: string): void;