Package-level declarations

A single operation admitted by RuntimeContext.

Complete lifecycle contract owned by WowRuntime.

Public collaboration boundary for components managed by a Wow runtime.

A storage or transport resource that holds accepted work: a batch writer's pending windows, a broker producer's buffered records. The runtime flushes it after every component has stopped, within the same shutdown deadline (RuntimeResources), so the work the dispatchers accepted is written before the process exits.

The runtime component that owns the RuntimeResources. Register it first, so it prepares first and stops last: the runtime stops components in reverse order, so the resources are flushed after every dispatcher has drained, under the runtime's one shutdownTimeout. The resources are resolved when the runtime prepares, and flushed concurrently.

High-level owner and lifecycle orchestrator for the complete Wow runtime.