eventmgt

Documentation

Index

• func InitEventMgt(influxDBCfg *InternalInflux.Config, rabbitMQConfig *InternalRabbitMQ.Config)
• func ListEvents(in *ApiEvents.ListEventsRequest) ([]*ApiEvents.Event, error)
• func PostEvents(in *ApiEvents.CreateEventsRequest) error
• type EventMgt
  • func NewEventMgt(influxDBCfg *InternalInflux.Config, rabbitMQConfig *InternalRabbitMQ.Config) *EventMgt
  • func (e *EventMgt) ListEvents(in *ApiEvents.ListEventsRequest) ([]*ApiEvents.Event, error)
  • func (e *EventMgt) PostEvents(in *ApiEvents.CreateEventsRequest) error

Functions

func InitEventMgt

func InitEventMgt(influxDBCfg *InternalInflux.Config, rabbitMQConfig *InternalRabbitMQ.Config)

func ListEvents

func ListEvents(in *ApiEvents.ListEventsRequest) ([]*ApiEvents.Event, error)

func PostEvents

func PostEvents(in *ApiEvents.CreateEventsRequest) error

Types

type EventMgt

type EventMgt struct {
	RabbitMQConfig *InternalRabbitMQ.Config
	// contains filtered or unexported fields
}

func NewEventMgt

func NewEventMgt(influxDBCfg *InternalInflux.Config, rabbitMQConfig *InternalRabbitMQ.Config) *EventMgt

func (*EventMgt) ListEvents

func (e *EventMgt) ListEvents(in *ApiEvents.ListEventsRequest) ([]*ApiEvents.Event, error)

func (*EventMgt) PostEvents

func (e *EventMgt) PostEvents(in *ApiEvents.CreateEventsRequest) error