internal/

Package sns provides helper functions for verifying and processing Amazon AWS SNS HTTP POST payloads.

Package claimer hosts the operators a dispatcher claims.

Package hostinproc is the in-process operator host: it implements pkg/operator.Host inside the dispatcher process over internal/services/operatorsvc, the same session logic the OperatorService handlers serve to operators that run outside the engine.

Package grpcoperator serves v1.OperatorService, the engine API for operators that run outside the engine process (kind = GRPC in v1_operator).

Package operatorsvc holds the engine-side logic of an operator session: registering the operator and its worker, opening and closing the session that makes the worker live, applying action set deltas, authorizing an operator and its workers, and opening durable invocations.

Package operatorsvctest holds in-memory doubles for the stores and the dispatcher an operator session talks to.

Package rpcstream holds helpers shared by the engine's streaming RPC handlers.