Directories
¶
| Path | Synopsis |
|---|---|
|
Package actors implements the coordination layer of conveyord: the queue grains that dispatch work, the scheduler and reaper maintenance actors, and the engine that assembles them on a GoAkt actor system.
|
Package actors implements the coordination layer of conveyord: the queue grains that dispatch work, the scheduler and reaper maintenance actors, and the engine that assembles them on a GoAkt actor system. |
|
Package backoff computes retry delays for failed task executions.
|
Package backoff computes retry delays for failed task executions. |
|
Package broker defines the durable task log: the only stateful layer of the system and the source of truth every other component rebuilds from.
|
Package broker defines the durable task log: the only stateful layer of the system and the source of truth every other component rebuilds from. |
|
brokertest
Package brokertest is the conformance suite every Broker implementation must pass.
|
Package brokertest is the conformance suite every Broker implementation must pass. |
|
encrypted
Package encrypted wraps a Broker so task payloads and results are encrypted at rest: the storage engine holds only ciphertext, while callers above the broker keep working with plaintext.
|
Package encrypted wraps a Broker so task payloads and results are encrypted at rest: the storage engine holds only ciphertext, while callers above the broker keep working with plaintext. |
|
memory
Package memory provides the in-memory Broker used for development, tests, and the embedded dev mode.
|
Package memory provides the in-memory Broker used for development, tests, and the embedded dev mode. |
|
postgres
Package postgres provides the durable Postgres Broker, the production source of truth.
|
Package postgres provides the durable Postgres Broker, the production source of truth. |
|
Package clock provides the injectable time source used across the codebase.
|
Package clock provides the injectable time source used across the codebase. |
|
Package cron turns persisted cron entries into materialized tasks: it parses quartz cron specs, computes fire times, and builds the task for one fire slot with a deterministic per-slot uniqueness key.
|
Package cron turns persisted cron entries into materialized tasks: it parses quartz cron specs, computes fire times, and builds the task for one fire slot with a deterministic per-slot uniqueness key. |
|
Package dynaport reserves free loopback ports for components that must be told their port up front (cluster remoting, gossip, peers) instead of binding :0 themselves.
|
Package dynaport reserves free loopback ports for components that must be told their port up front (cluster remoting, gossip, peers) instead of binding :0 themselves. |
|
Package events is the in-process task lifecycle event fan-out: a bounded, non-blocking bus that brokers emit transitions into and that the WatchEvents stream and the webhook sink read from.
|
Package events is the in-process task lifecycle event fan-out: a bounded, non-blocking bus that brokers emit transitions into and that the WatchEvents stream and the webhook sink read from. |
|
Package metrics holds the engine's synchronous OpenTelemetry instruments — the per-task timing histograms and the maintenance canaries — behind a small record API.
|
Package metrics holds the engine's synchronous OpenTelemetry instruments — the per-task timing histograms and the maintenance canaries — behind a small record API. |
|
proto
|
|
|
Package webhook implements the JSON-RPC 2.0 delivery protocol the server speaks to webhook workers: envelope types, response classification, and the HTTP client that carries them.
|
Package webhook implements the JSON-RPC 2.0 delivery protocol the server speaks to webhook workers: envelope types, response classification, and the HTTP client that carries them. |
|
Package wire holds the ConnectRPC plumbing shared by every Conveyor wire client — the SDK transport and the CLI's admin client — so the HTTP protocol setup and bearer-token injection exist exactly once.
|
Package wire holds the ConnectRPC plumbing shared by every Conveyor wire client — the SDK transport and the CLI's admin client — so the HTTP protocol setup and bearer-token injection exist exactly once. |
Click to show internal directories.
Click to hide internal directories.