monitor

Documentation

Index

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

Types

type EventInfo

type EventInfo struct {
	RawToken     string
	CorelationID 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 *zerolog.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 *zerolog.Logger, queueName string, eventsToMonitor []string, eventSignal chan *EventInfo) (EventMonitor, error)

NewEventMonitorForQueue creates a new eventMonitor that publishes received events from a named queue to the specified channel