Documentation
¶
Overview ¶
Package process holds the process-stage queue controller. It consumes request ids from ingest, reloads the Request from storage, coalesces older heads, and (in later changes) gates concurrency, decides build strategy, and admits winners to build.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Controller ¶
type Controller struct {
// contains filtered or unexported fields
}
Controller consumes ProcessRequest messages from the process stage, reloads the referenced Request from storage, and coalesces older heads. Implements consumer.Controller.
func NewController ¶
func NewController( logger *zap.SugaredLogger, scope tally.Scope, store storage.Storage, topicKey consumer.TopicKey, consumerGroup string, ) *Controller
NewController creates a new process controller.
func (*Controller) ConsumerGroup ¶
func (c *Controller) ConsumerGroup() string
ConsumerGroup returns the consumer group for offset tracking.
func (*Controller) Name ¶
func (c *Controller) Name() string
Name returns the controller name for logging and metrics.
func (*Controller) Process ¶
Process reloads the request referenced by the delivery and coalesces older heads. Returns nil to ack (success) or an error to nack (retry).
func (*Controller) TopicKey ¶
func (c *Controller) TopicKey() consumer.TopicKey
TopicKey returns the topic key this controller subscribes to.
Source Files