monitor

Documentation

Index

• type EventInfo
• type EventMonitor
  • func NewEventMonitor(logger *logrus.Logger, eventsToMonitor []string, eventSignal chan *EventInfo) (EventMonitor, error)
  • func NewEventMonitorForQueue(logger *logrus.Logger, queueName string, eventsToMonitor []string, ...) (EventMonitor, error)

Types

type EventInfo

type EventInfo struct {
	RawToken string
	Name     string
	Payload  string
}

EventInfo represents the message received from queu

type EventMonitor

type EventMonitor interface {
	Start()
	Stop()
	// contains filtered or unexported methods
}

EventMonitor represents an interface used to monitor Events

func NewEventMonitor

func NewEventMonitor(logger *logrus.Logger, eventsToMonitor []string, eventSignal chan *EventInfo) (EventMonitor, error)

NewEventMonitor creates a new eventMonitor that publishes received events to the specified channel

func NewEventMonitorForQueue

func NewEventMonitorForQueue(logger *logrus.Logger, queueName string, eventsToMonitor []string, eventSignal chan *EventInfo) (EventMonitor, error)