Documentation
¶
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 handles validate queue messages. It consumes requests, performs validation checks (merge conflicts, duplicate requests, etc.), and publishes to the batch stage. Validation logic is extensible to support additional checks. Implements consumer.Controller interface for integration with the consumer.
func NewController ¶
func NewController( logger *zap.SugaredLogger, scope tally.Scope, store storage.Storage, registry consumer.TopicRegistry, mergeChecker mergechecker.MergeChecker, changeProvider changeprovider.ChangeProvider, topicKey consumer.TopicKey, consumerGroup string, ) *Controller
NewController creates a new validate controller for the orchestrator.
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 processes a validate delivery from the queue. Deserializes the request and publishes to the batch topic. Returns nil to ack (success), or error to nack (retry).
func (*Controller) TopicKey ¶
func (c *Controller) TopicKey() consumer.TopicKey
TopicKey returns the topic key this controller subscribes to.
Source Files