queue

Documentation

Index

• type EventQueue
  • func (eq *EventQueue) Dequeue()
  • func (eq *EventQueue) Enqueue(evt event.NormalizedEvent)
  • func (eq *EventQueue) GetReporter() func(time.Duration)
  • func (eq *EventQueue) Init(target []event.Channel, maxQueueLength int, eps int)
• type Reporter
  • func (r *Reporter) Init(nChans int, maxWait, maxDequeueDuration time.Duration, eps int, ...)
  • func (r *Reporter) PrintReport(interval time.Duration)

Types

type EventQueue

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

EventQueue represents queue obj for Normalized Events

func (*EventQueue) Dequeue

func (eq *EventQueue) Dequeue()

Dequeue reads event from queue

func (*EventQueue) Enqueue

func (eq *EventQueue) Enqueue(evt event.NormalizedEvent)

Enqueue writes event to queue

func (*EventQueue) GetReporter

func (eq *EventQueue) GetReporter() func(time.Duration)

GetReporter return the function to print reports

func (*EventQueue) Init

func (eq *EventQueue) Init(target []event.Channel, maxQueueLength int, eps int)

Init setup the eventqueue

type Reporter

type Reporter struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

Reporter represent reporter object

func (*Reporter) Init

func (r *Reporter) Init(nChans int, maxWait, maxDequeueDuration time.Duration, eps int, queueLengthFunc func() int)

Init initialises Reporter

func (*Reporter) PrintReport

func (r *Reporter) PrintReport(interval time.Duration)

PrintReport regularly prints report content