kubernetes/staging/src/k8s.io/apiserver/pkg/storage/etcd3/latency_tracker.go

// NewETCDLatencyTracker returns an implementation of
// clientv3.KV that times the calls from the specified
// 'delegate' KV instance in order to track latency incurred.
func NewETCDLatencyTracker(delegate clientv3.KV) clientv3.KV { … }

type clientV3KVLatencyTracker …

func (c *clientV3KVLatencyTracker) Put(ctx context.Context, key, val string, opts ...clientv3.OpOption) (*clientv3.PutResponse, error) { … }

func (c *clientV3KVLatencyTracker) Get(ctx context.Context, key string, opts ...clientv3.OpOption) (*clientv3.GetResponse, error) { … }

func (c *clientV3KVLatencyTracker) Delete(ctx context.Context, key string, opts ...clientv3.OpOption) (*clientv3.DeleteResponse, error) { … }

func (c *clientV3KVLatencyTracker) Do(ctx context.Context, op clientv3.Op) (clientv3.OpResponse, error) { … }

func (c *clientV3KVLatencyTracker) Txn(ctx context.Context) clientv3.Txn { … }

type clientV3TxnTracker …

func (t *clientV3TxnTracker) Commit() (*clientv3.TxnResponse, error) { … }