Function NewEventPool

controller/pool.go:135–137

(name string, size int)

}

func NewEventPool(name string, size int) *EventPool {
	return &EventPool{name, make(chan *QueueEvent, size), time.Now(), false}
}

func (ep *EventPool) putQueueEvent(event *QueueEvent) error {
	select {