Documentation
¶
Overview ¶
Package mergeconflictcheck consumes dry-run merge-conflict check requests from Runway's merge-conflict-check queue. A request asks whether an ordered sequence of merge steps applies cleanly onto the target branch without committing.
Currently a parse-and-log stub: it deserializes the MergeRequest off the queue and logs it. The real check (attempt the merge without committing and publish a MergeResult to the merge-conflict-check-signal queue) is not wired yet.
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 merge-conflict-check queue messages.
func NewController ¶
func NewController(p Params) *Controller
NewController creates a new merge-conflict-check controller for the runway service.
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 deserializes the merge request and logs it. Returns nil to ack, or an error to nack.
func (*Controller) TopicKey ¶
func (c *Controller) TopicKey() consumer.TopicKey
TopicKey returns the topic key this controller subscribes to.