Class ArvoOrchestrator

constructor

• new ArvoOrchestrator(params): ArvoOrchestrator

• Creates a new orchestrator instance

  Parameters

  • params: IArvoOrchestrator

    Configuration parameters

  Returns ArvoOrchestrator

  Throws

  Error if machines in registry have different sources

ReadonlyexecutionEngine

Readonlyexecutionunits

Readonlymemory

Readonlyregistry

ReadonlyrequiresResourceLocking

source

• get source(): any

• Gets the source identifier for this orchestrator

  Returns any

systemErrorSchema

• get systemErrorSchema(): ArvoContractRecord

• Gets the error schema for this orchestrator

  Returns ArvoContractRecord

execute

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

• Core orchestration method that executes state machines in response to events. Manages the complete event lifecycle:

  1. Acquires lock and state
  2. Validates events and contracts
  3. Executes state machine
  4. Persists new state
  5. Generates response events with domain-based segregation

  Parameters

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

    Event triggering the execution
  • opentelemetry: ArvoEventHandlerOpenTelemetryOptions = ...

    OpenTelemetry configuration

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

  Object containing default domained events, all event domains, and domain-segregated event buckets

  Throws

  Lock/state operations failed

  Throws

  Invalid event structure/flow

  Throws

  Schema/contract mismatch

  Throws

  Missing/invalid machine version