Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type EventQueue ¶
type EventQueue struct {
// contains filtered or unexported fields
}
EventQueue represents queue obj for Normalized Events
func (*EventQueue) Enqueue ¶
func (eq *EventQueue) Enqueue(evt event.NormalizedEvent)
Enqueue writes event to queue
func (*EventQueue) Init ¶
func (eq *EventQueue) Init(target []event.Channel, maxQueueLength int, eps int)
Init setup the eventqueue
func (*EventQueue) Reporter ¶
func (eq *EventQueue) Reporter(d time.Duration)
Reporter regularly prints out queue overview
Click to show internal directories.
Click to hide internal directories.