eventRouting

package
v0.0.0-...-232336a Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jun 8, 2018 License: MIT Imports: 10 Imported by: 17

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL