Documentation
¶
Overview ¶
Package topickey defines SubmitQueue pipeline stage identifiers.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type TopicKey ¶
TopicKey is the shared pipeline stage identifier type.
const ( // TopicKeyStart is the pipeline stage where new requests arrive from the gateway. TopicKeyStart TopicKey = "start" // TopicKeyCancel is the pipeline stage where cancellation requests arrive from the gateway. TopicKeyCancel TopicKey = "cancel" // TopicKeyValidate is the pipeline stage where requests are published for validation. TopicKeyValidate TopicKey = "validate" // TopicKeyBatch is the pipeline stage where validated requests are published for batching. TopicKeyBatch TopicKey = "batch" // TopicKeyScore is the pipeline stage where batches are published for scoring. TopicKeyScore TopicKey = "score" // TopicKeySpeculate is the pipeline stage where scored batches are published for speculation. TopicKeySpeculate TopicKey = "speculate" // TopicKeyPrioritize is the queue-wide reconcile stage that rations the // build budget across every in-flight batch of a queue. Each message // carries a QueueID; the consumer loads every Speculating batch's tree, // runs the queue's Prioritizer over the candidate paths, applies the // resulting decisions — promoting paths into the build budget, or // cancelling in-flight paths a preemptive policy evicts — and republishes // to TopicKeyBuild for any path cleared to run. TopicKeyPrioritize TopicKey = "prioritize" // TopicKeyBuild is the pipeline stage where speculated batches are published for builds. TopicKeyBuild TopicKey = "build" // TopicKeyBuildSignal is the polling stage for triggered builds. Each // message carries a Build; the consumer calls BuildRunner.Status, // persists the latest status, publishes the batch ID to TopicKeySpeculate // so the state machine re-evaluates, and re-publishes itself via // PublishAfter when the build has not yet reached a terminal state. TopicKeyBuildSignal TopicKey = "buildsignal" // TopicKeyMerge is the pipeline stage where speculated batches are published for merging. TopicKeyMerge TopicKey = "submitqueue-merge" // TopicKeyConclude is the pipeline stage where merged requests are published for conclusion. TopicKeyConclude TopicKey = "conclude" // TopicKeyLog is the pipeline stage where per-request logs are written. TopicKeyLog TopicKey = "log" )
Click to show internal directories.
Click to hide internal directories.