controlcommunication

type AbstractControlMessageBroker struct {
	Consumers []*ControlConsumer
	// contains filtered or unexported fields
}

type ControlConsumer struct {
	// contains filtered or unexported fields
}

type ControlMessage struct {
	Kind       ControlMessageKind
	Attributes map[string]interface{}
}

type ControlMessageAttributesExplicitAck struct {
	Topic     string `json:"topic"`
	Partition int32  `json:"partition"`
	Offset    int64  `json:"offset"`
}

type ControlMessageBroker interface {

	// WriteControlMessage writes a control message to the control communication
	WriteControlMessage(message *ControlMessage) error

	// ReadControlMessage reads a control message from the control communication
	ReadControlMessage(reader *bufio.Reader) (*ControlMessage, error)

	// SendToConsumers sends a control message to all consumers
	SendToConsumers(message *ControlMessage) error

	// Subscribe subscribes channel to a control message kind
	Subscribe(kind ControlMessageKind, channel chan *ControlMessage) error

	// Unsubscribe unsubscribes channel from a control message kind
	Unsubscribe(kind ControlMessageKind, channel chan *ControlMessage) error
}

type ControlMessageEvent struct {
	nuclio.AbstractEvent
	// contains filtered or unexported fields
}

type ControlMessageKind string