MCPcopy Create free account
hub / github.com/TalkingData/owl / getQueueEvent

Method getQueueEvent

controller/pool.go:148–153  ·  view source on GitHub ↗
()

Source from the content-addressed store, hash-verified

146}
147
148func (ep *EventPool) getQueueEvent() *QueueEvent {
149 select {
150 case qEvent := <-ep.events:
151 return qEvent
152 }
153}
154
155func (ep *EventPool) cap() int {
156 return cap(ep.events)

Callers 1

processSingleQueueFunction · 0.80

Calls

no outgoing calls

Tested by

no test coverage detected