eventRouting

Documentation

Index

• func GetListAuthorizedEventEvents() (authorizedEvents string)
• type EventRouting
  • func NewEventRouting(caching caching.Caching, logging logging.Logging) *EventRouting
  • func (e *EventRouting) GetSelectedEvents() map[string]bool
  • func (e *EventRouting) GetSelectedEventsCount() map[string]uint64
  • func (e *EventRouting) GetTotalCountOfSelectedEvents() uint64
  • func (e *EventRouting) LogEventTotals(logTotalsTime time.Duration)
  • func (e *EventRouting) RouteEvent(msg *events.Envelope)
  • func (e *EventRouting) SetExtraFields(extraEventsString string)
  • func (e *EventRouting) SetupEventRouting(wantedEvents string) error

Functions

func GetListAuthorizedEventEvents

func GetListAuthorizedEventEvents() (authorizedEvents string)

Types

type EventRouting

type EventRouting struct {
	CachingClient caching.Caching

	ExtraFields map[string]string
	// contains filtered or unexported fields
}

func NewEventRouting

func NewEventRouting(caching caching.Caching, logging logging.Logging) *EventRouting

func (*EventRouting) GetSelectedEvents

func (e *EventRouting) GetSelectedEvents() map[string]bool

func (*EventRouting) GetSelectedEventsCount

func (e *EventRouting) GetSelectedEventsCount() map[string]uint64

func (*EventRouting) GetTotalCountOfSelectedEvents

func (e *EventRouting) GetTotalCountOfSelectedEvents() uint64

func (*EventRouting) LogEventTotals

func (e *EventRouting) LogEventTotals(logTotalsTime time.Duration)

func (*EventRouting) RouteEvent

func (e *EventRouting) RouteEvent(msg *events.Envelope)

func (*EventRouting) SetExtraFields

func (e *EventRouting) SetExtraFields(extraEventsString string)

func (*EventRouting) SetupEventRouting

func (e *EventRouting) SetupEventRouting(wantedEvents string) error