kubernetes/vendor/go.etcd.io/etcd/client/v3/concurrency/key.go

func waitDelete(ctx context.Context, client *v3.Client, key string, rev int64) error { … }

// waitDeletes efficiently waits until all keys matching the prefix and no greater
// than the create revision.
func waitDeletes(ctx context.Context, client *v3.Client, pfx string, maxCreateRev int64) (*pb.ResponseHeader, error) { … }