eventrouting

Documentation

Index

• type EventRouter
  • func NewEventRouter(processor *eventdata.EventProcessor) *EventRouter
  • func (er *EventRouter) Clear()
  • func (er *EventRouter) GetEventCount() uint64
  • func (er *EventRouter) GetEventRate() int
  • func (er *EventRouter) GetEventRatePeak() int
  • func (er *EventRouter) GetProcessor() *eventdata.EventProcessor
  • func (er *EventRouter) GetStartTime() time.Time
  • func (er *EventRouter) Route(instanceId int, msg *events.Envelope)

Types

type EventRouter

type EventRouter struct {
	// contains filtered or unexported fields
}

func NewEventRouter

func NewEventRouter(processor *eventdata.EventProcessor) *EventRouter

func (*EventRouter) Clear

func (er *EventRouter) Clear()

func (*EventRouter) GetEventCount

func (er *EventRouter) GetEventCount() uint64

func (*EventRouter) GetEventRate

func (er *EventRouter) GetEventRate() int

func (*EventRouter) GetEventRatePeak

func (er *EventRouter) GetEventRatePeak() int

func (*EventRouter) GetProcessor

func (er *EventRouter) GetProcessor() *eventdata.EventProcessor

func (*EventRouter) GetStartTime

func (er *EventRouter) GetStartTime() time.Time

func (*EventRouter) Route

func (er *EventRouter) Route(instanceId int, msg *events.Envelope)