Struct mockKV

kv/etcd/mock.go:70–84

mockKV is an in-memory implementation of an Etcd client. This implementation has many limitations compared to the real client since it only exists to be used by the Etcd kv.Client implementation during unit tests. As such some behavior may be missing or incorrect compared to the real client. This i

//   - There may be inconsistencies with how various version numbers are adjusted
//     but none that are exposed by kv.Client unit tests
type mockKV struct {
	// Key-value pairs created by put calls or transactions
	values    map[string]mvccpb.KeyValue
	valuesMtx sync.Mutex

	// Channel for stopping all running watch goroutines and closing
	// and cleaning up all channels used for sending events to watchers
	close chan struct{}

	// Channels that should receive events in response to Put or Delete
	// calls. These channels are in turn read by goroutines that apply
	// filtering before sending watch responses to their callers.
	events    map[chan clientv3.Event]struct{}
	eventsMtx sync.Mutex
}

// Watch implements the Clientv3Facade interface
func (m *mockKV) Watch(ctx context.Context, key string, opts ...clientv3.OpOption) clientv3.WatchChan {