Function createArvoResumable

Parameters

• param: {
      contracts: {
          self: TSelfContract;
          services: TServiceContract;
      };
      executionunits?: number;
      handler: ArvoResumableHandler<ArvoResumableState<TMemory>, TSelfContract, TServiceContract>;
      memory: IMachineMemory<Record<string, any>>;
      requiresResourceLocking?: boolean;
      systemErrorDomain?: (null | string)[];
      types?: {
          context?: Partial<TMemory>;
      };
  }

  Configuration object for the orchestrator

  • contracts: {
        self: TSelfContract;
        services: TServiceContract;
    }

    Contract definitions for the orchestrator and its services

    • self: TSelfContract

    • services: TServiceContract

  • Optionalexecutionunits?: number

    Resource allocation cost for this orchestrator's execution (default: 0)

  • handler: ArvoResumableHandler<ArvoResumableState<TMemory>, TSelfContract, TServiceContract>

    Versioned orchestration logic handlers mapped by semantic version

  • memory: IMachineMemory<Record<string, any>>

    Generic memory interface for state persistence, locking, and retrieval operations

  • OptionalrequiresResourceLocking?: boolean

    Enable distributed locking for concurrent safety (default: auto-determined by service count)

  • OptionalsystemErrorDomain?: (null | string)[]

    The domain override of the system error events. (default [event.domain, self.contract.domain, null])

  • Optionaltypes?: {
        context?: Partial<TMemory>;
    }

    Optional type hints for better TypeScript inference

    • Optionalcontext?: Partial<TMemory>