eventRouting

Documentation

Index

• func GetListAuthorizedEventEvents() (authorizedEvents string)
• func HasIgnoreField(event *fevents.Event) bool
• func IsAuthorizedEvent(wantedEvent string) bool
• type EventFilter
  • func NotInCertainOrgs(orgFilters string) EventFilter
• 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 HasIgnoreField

func HasIgnoreField(event *fevents.Event) bool

HasIgnoreField Filter out the event has ignored app filed

func IsAuthorizedEvent

func IsAuthorizedEvent(wantedEvent string) bool

Types

type EventFilter

type EventFilter func(*fevents.Event) bool

EventFilter Given an Event Filter out unwanted event

func NotInCertainOrgs

func NotInCertainOrgs(orgFilters string) EventFilter

NotInCertainOrgs Filter out events not in certain orgs

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, filters []EventFilter) 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