Method sendEvent

kv/etcd/mock.go:155–165

sendEvent writes an event to all currently registered events. The consumer channels are each read by a goroutine that filters the event and sends it to the caller of the Watch method.

(e clientv3.Event)

// channels are each read by a goroutine that filters the event and sends it to
// the caller of the Watch method.
func (m *mockKV) sendEvent(e clientv3.Event) {
	m.eventsMtx.Lock()
	for ch := range m.events {
		// non-blocking send
		select {
		case ch <- e:
		default:
		}
	}
	m.eventsMtx.Unlock()
}

// RequestProgress implements the Clientv3Facade interface
func (m *mockKV) RequestProgress(context.Context) error {