MCPcopy
hub / github.com/kubernetes/client-go / push

Method push

tools/watch/informerwatcher.go:82–87  ·  view source on GitHub ↗
(event watch.Event)

Source from the content-addressed store, hash-verified

80}
81
82func (e *eventProcessor) push(event watch.Event) {
83 e.cond.L.Lock()
84 defer e.cond.L.Unlock()
85 defer e.cond.Signal()
86 e.buff = append(e.buff, event)
87}
88
89func (e *eventProcessor) stopped() bool {
90 select {

Callers 3

TestEventProcessorExitFunction · 0.80

Calls

no outgoing calls

Tested by 2

TestEventProcessorExitFunction · 0.64