eventRouting

package
v0.0.0-...-85af8dd Latest Latest
Warning

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

Go to latest
Published: Jul 27, 2017 License: MIT Imports: 12 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)
	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

Jump to

Keyboard shortcuts

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