kubernetes/vendor/go.etcd.io/etcd/pkg/v3/wait/wait.go

const defaultListElementLength …

type Wait …

type list …

type listElement …

// New creates a Wait.
func New() Wait { … }

func (w *list) Register(id uint64) <-chan interface{ … }

func (w *list) Trigger(id uint64, x interface{ … }

func (w *list) IsRegistered(id uint64) bool { … }

type waitWithResponse …

func NewWithResponse(ch <-chan interface{ … }

func (w *waitWithResponse) Register(id uint64) <-chan interface{ … }

func (w *waitWithResponse) Trigger(id uint64, x interface{ … }

func (w *waitWithResponse) IsRegistered(id uint64) bool { … }