eventRouting

package
v0.0.0-...-e4f4464 Latest Latest
Warning

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

Go to latest
Published: Jun 7, 2019 License: MIT Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

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

Jump to

Keyboard shortcuts

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