Versions in this module Expand all Collapse all v1 v1.14.2 Feb 25, 2025 Changes in this version + type AbstractControlMessageBroker struct + Consumers []*ControlConsumer + func NewAbstractControlMessageBroker() *AbstractControlMessageBroker + func (acmb *AbstractControlMessageBroker) ReadControlMessage(reader *bufio.Reader) (*ControlMessage, error) + func (acmb *AbstractControlMessageBroker) SendToConsumers(message *ControlMessage) error + func (acmb *AbstractControlMessageBroker) Subscribe(kind ControlMessageKind, channel chan *ControlMessage) error + func (acmb *AbstractControlMessageBroker) Unsubscribe(kind ControlMessageKind, channel chan *ControlMessage) error + func (acmb *AbstractControlMessageBroker) WriteControlMessage(message *ControlMessage) error + type ControlConsumer struct + func NewControlConsumer(kind ControlMessageKind) *ControlConsumer + func (c *ControlConsumer) GetKind() ControlMessageKind + func (c *ControlConsumer) Send(message *ControlMessage) error + type ControlMessage struct + Attributes map[string]interface{} + Kind ControlMessageKind + type ControlMessageAttributesExplicitAck struct + Offset int64 + Partition int32 + Topic string + type ControlMessageBroker interface + ReadControlMessage func(reader *bufio.Reader) (*ControlMessage, error) + SendToConsumers func(message *ControlMessage) error + Subscribe func(kind ControlMessageKind, channel chan *ControlMessage) error + Unsubscribe func(kind ControlMessageKind, channel chan *ControlMessage) error + WriteControlMessage func(message *ControlMessage) error + type ControlMessageEvent struct + func NewControlMessageEvent(message *ControlMessage) *ControlMessageEvent + func (cme *ControlMessageEvent) GetBodyObject() interface{} + func (cme *ControlMessageEvent) GetID() nuclio.ID + type ControlMessageKind string + const StreamMessageAckKind
Go to main page