eventRouting

Documentation

Index

• func GetListAuthorizedEventEvents() (authorizedEvents string)
• func IsAuthorizedEvent(wantedEvent string) bool
• type EventRouting
  • func NewEventRouting(caching caching.Caching, logging logging.Logging, stats *stats.Stats) EventRouting
• type EventRoutingDefault
  • func (e *EventRoutingDefault) GetSelectedEvents() map[string]bool
  • func (e *EventRoutingDefault) RouteEvent(msg *events.Envelope)
  • func (e *EventRoutingDefault) SetExtraFields(extraEventsString string)
  • func (e *EventRoutingDefault) SetupEventRouting(wantedEvents string) error

Functions

func GetListAuthorizedEventEvents

func GetListAuthorizedEventEvents() (authorizedEvents string)

func IsAuthorizedEvent

func IsAuthorizedEvent(wantedEvent string) bool

Types

type EventRouting

type EventRouting interface {
	GetSelectedEvents() map[string]bool
	RouteEvent(msg *events.Envelope)
	SetupEventRouting(wantedEvents string) error
	SetExtraFields(extraEventsString string)
}

func NewEventRouting

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

type EventRoutingDefault

type EventRoutingDefault struct {
	CachingClient caching.Caching

	Stats *stats.Stats

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

func (*EventRoutingDefault) GetSelectedEvents

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

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