Documentation
¶
Overview ¶
Package core groups infrastructure shared across SubmitQueue's own services (gateway and orchestrator) — the SubmitQueue-scoped analogue of the repo-level core/. Cross-domain infrastructure lives in the top-level core/; this package is for plumbing private to SubmitQueue. Subpackages: core/consumer (queue consumption framework) and core/request (request lifecycle shared by gateway and orchestrator).
Directories
¶
| Path | Synopsis |
|---|---|
|
Package batch provides the shared primitives for moving a batch through its lifecycle states while keeping the queue's per-state membership records (entity.QueueBatchState) in step.
|
Package batch provides the shared primitives for moving a batch through its lifecycle states while keeping the queue's per-state membership records (entity.QueueBatchState) in step. |
|
Package changeset resolves batch identity into the changes a batch contains.
|
Package changeset resolves batch identity into the changes a batch contains. |
|
fake
Package fake provides an in-memory changeset.Resolver for tests and examples.
|
Package fake provides an in-memory changeset.Resolver for tests and examples. |
|
mock
Package mock is a generated GoMock package.
|
Package mock is a generated GoMock package. |
|
Package messagequeue holds SubmitQueue's internal message-queue contract: the wire payloads for the pipeline queues SubmitQueue owns, defined by the proto files in proto/ and generated into protopb/.
|
Package messagequeue holds SubmitQueue's internal message-queue contract: the wire payloads for the pipeline queues SubmitQueue owns, defined by the proto files in proto/ and generated into protopb/. |
|
Package topickey re-exports SubmitQueue pipeline stage identifiers from submitqueue/core/messagequeue, the package that owns the topic-key constants and the payloads bound to them.
|
Package topickey re-exports SubmitQueue pipeline stage identifiers from submitqueue/core/messagequeue, the package that owns the topic-key constants and the payloads bound to them. |
Click to show internal directories.
Click to hide internal directories.