incidents

Documentation

Index

• type Incidents
  • func New(config configuration.Config) (result *Incidents)
  • func NewWithMqttClient(config configuration.Config, client paho.Client) (result *Incidents)
  • func (this *Incidents) Handle(command messages.KafkaIncidentsCommand) error
• type NameWrapper

Types

type Incidents

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

func New

func New(config configuration.Config) (result *Incidents)

func NewWithMqttClient

func NewWithMqttClient(config configuration.Config, client paho.Client) (result *Incidents)

func (*Incidents) Handle

func (this *Incidents) Handle(command messages.KafkaIncidentsCommand) error

type NameWrapper

type NameWrapper struct {
	Name string `json:"name"`
}