Function NewQueue

pkg/event/queue.go:54–63

NewQueue constructs a new queue with the given channel size.

(size int, stackEnrichment bool, enqueueAlways bool)

// NewQueue constructs a new queue with the given channel size.
func NewQueue(size int, stackEnrichment bool, enqueueAlways bool) *Queue {
	q := &Queue{
		q:               make(chan *Event, size),
		listeners:       make([]Listener, 0),
		stackEnrichment: stackEnrichment,
		enqueueAlways:   enqueueAlways,
	}
	q.decorator = NewStackwalkDecorator(q)
	return q
}

// NewQueueWithChannel constructs a new queue with a custom channel.
func NewQueueWithChannel(ch chan *Event, stackEnrichment bool, enqueueAlways bool) *Queue {