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

type event …

// parseKV converts a KeyValue retrieved from an initial sync() listing to a synthetic isCreated event.
func parseKV(kv *mvccpb.KeyValue) *event { … }

func parseEvent(e *clientv3.Event) (*event, error) { … }

func progressNotifyEvent(rev int64) *event { … }