Class MultiArvoEventHandler

MultiArvoEventHandler processes multiple event types without being bound to specific contracts. Manages event execution, telemetry tracking, and error handling for diverse event streams.

Example

const handler = createMultiArvoEventHandler({
  source: "order.handler",
  executionunits: 1,
  handler: async ({ event }) => {
    // Handle multiple event types
  }
});

Hierarchy (view full)

Constructors

constructor

Properties

executionunits handler source spanOptions

Accessors

systemErrorSchema

Methods

execute

Constructors

constructor

Properties

Readonlyexecutionunits

executionunits: number

Computational cost metric for handler operations

Readonlyhandler

handler: MultiArvoEventHandlerFunction

Event processing function

Readonlysource

source: string

Source identifier for event routing

ReadonlyspanOptions

spanOptions: SpanOptions

OpenTelemetry configuration

Accessors

systemErrorSchema

  • get systemErrorSchema(): {
        schema: ZodObject<{
            errorMessage: ZodString;
            errorName: ZodString;
            errorStack: ZodNullable<ZodString>;
        }, "strip", ZodTypeAny, {
            errorMessage: string;
            errorName: string;
            errorStack: null | string;
        }, {
            errorMessage: string;
            errorName: string;
            errorStack: null | string;
        }>;
        type: string;
    }

  • System error schema configuration. Error events follow format: sys..error

    Returns {
        schema: ZodObject<{
            errorMessage: ZodString;
            errorName: ZodString;
            errorStack: ZodNullable<ZodString>;
        }, "strip", ZodTypeAny, {
            errorMessage: string;
            errorName: string;
            errorStack: null | string;
        }, {
            errorMessage: string;
            errorName: string;
            errorStack: null | string;
        }>;
        type: string;
    }

    • schema: ZodObject<{
          errorMessage: ZodString;
          errorName: ZodString;
          errorStack: ZodNullable<ZodString>;
      }, "strip", ZodTypeAny, {
          errorMessage: string;
          errorName: string;
          errorStack: null | string;
      }, {
          errorMessage: string;
          errorName: string;
          errorStack: null | string;
      }>
    • type: string

Methods

execute

  • execute(event, opentelemetry?): Promise<{
        events: ArvoEvent<Record<string, any>, Record<string,
            | null
            | string
            | number
            | boolean>, string>[];
    }>

  • Processes an event through configured handler function. Creates telemetry span, validates event destination, executes handler, and manages errors.

    Parameters

    • event: ArvoEvent<Record<string, any>, Record<string,
          | null
          | string
          | number
          | boolean>, string>

      Event to process

    • opentelemetry: ArvoEventHandlerOpenTelemetryOptions = ...

      Telemetry context configuration

    Returns Promise<{
        events: ArvoEvent<Record<string, any>, Record<string,
            | null
            | string
            | number
            | boolean>, string>[];
    }>

    Resulting events or error events

    Throws

    When event destination does not match handler source

    Throws

    Other Violation error which are thrown by the event handler function

Settings

Member Visibility

On This Page

Constructors
Properties
Accessors
Methods