messaging

type Command struct {
	CommandId string `json:"command_id"`
	Data      string `json:"data"`
}

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

type Correlation interface {
	Get(id string) (messages.ProtocolMsg, error)
	Set(id string, element messages.ProtocolMsg) error
}

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

type Factory struct {
	Config      configuration.Config
	Correlation Correlation
	IdProvider  func() string
}

type Incidents interface {
	Handle(command messages.KafkaIncidentsCommand) error
}

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