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

Method putQueueEvent

controller/pool.go:139–146  ·  view source on GitHub ↗
(event *QueueEvent)

Source from the content-addressed store, hash-verified

137}
138
139func (ep *EventPool) putQueueEvent(event *QueueEvent) error {
140 select {
141 case ep.events <- event:
142 return nil
143 default:
144 return ErrEventPoolFull
145 }
146}
147
148func (ep *EventPool) getQueueEvent() *QueueEvent {
149 select {

Callers 2

processResultMethod · 0.80
processSingleQueueFunction · 0.80

Calls

no outgoing calls

Tested by

no test coverage detected