Documentation ¶
Index ¶
- func GetListAuthorizedEventEvents() (authorizedEvents string)
- func IsAuthorizedEvent(wantedEvent string) bool
- type EventRouting
- type EventRoutingDefault
- func (e *EventRoutingDefault) GetSelectedEvents() map[string]bool
- func (e *EventRoutingDefault) GetSelectedEventsCount() map[string]uint64
- func (e *EventRoutingDefault) GetTotalCountOfSelectedEvents() uint64
- func (e *EventRoutingDefault) LogEventTotals(logTotalsTime time.Duration)
- func (e *EventRoutingDefault) RouteEvent(msg *events.Envelope)
- func (e *EventRoutingDefault) SetExtraFields(extraEventsString string)
- func (e *EventRoutingDefault) SetupEventRouting(wantedEvents string) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func GetListAuthorizedEventEvents ¶
func GetListAuthorizedEventEvents() (authorizedEvents string)
func IsAuthorizedEvent ¶
Types ¶
type EventRouting ¶
type EventRouting interface { GetSelectedEvents() map[string]bool RouteEvent(msg *events.Envelope) SetupEventRouting(wantedEvents string) error SetExtraFields(extraEventsString string) GetTotalCountOfSelectedEvents() uint64 GetSelectedEventsCount() map[string]uint64 LogEventTotals(logTotalsTime time.Duration) }
func NewEventRouting ¶
func NewEventRouting(caching caching.Caching, logging logging.Logging) EventRouting
type EventRoutingDefault ¶
type EventRoutingDefault struct { CachingClient caching.Caching ExtraFields map[string]string // contains filtered or unexported fields }
func (*EventRoutingDefault) GetSelectedEvents ¶
func (e *EventRoutingDefault) GetSelectedEvents() map[string]bool
func (*EventRoutingDefault) GetSelectedEventsCount ¶
func (e *EventRoutingDefault) GetSelectedEventsCount() map[string]uint64
func (*EventRoutingDefault) GetTotalCountOfSelectedEvents ¶
func (e *EventRoutingDefault) GetTotalCountOfSelectedEvents() uint64
func (*EventRoutingDefault) LogEventTotals ¶
func (e *EventRoutingDefault) LogEventTotals(logTotalsTime time.Duration)
func (*EventRoutingDefault) RouteEvent ¶
func (e *EventRoutingDefault) RouteEvent(msg *events.Envelope)
func (*EventRoutingDefault) SetExtraFields ¶
func (e *EventRoutingDefault) SetExtraFields(extraEventsString string)
func (*EventRoutingDefault) SetupEventRouting ¶
func (e *EventRoutingDefault) SetupEventRouting(wantedEvents string) error
Click to show internal directories.
Click to hide internal directories.