Documentation ¶ Index ¶ Variables type WaitState func (w *WaitState) Close() func (w *WaitState) Get(ctx context.Context, ...) (uint64, interface{}, error) func (w *WaitState) GetNewer(ctx context.Context, lastCount uint64) (uint64, interface{}, error) func (w *WaitState) Set(new interface{}) Constants ¶ This section is empty. Variables ¶ View Source var ErrorClosed = errors.New("WaitState is closed") Functions ¶ This section is empty. Types ¶ type WaitState ¶ type WaitState struct { sync.Mutex // contains filtered or unexported fields } func (*WaitState) Close ¶ func (w *WaitState) Close() func (*WaitState) Get ¶ func (w *WaitState) Get(ctx context.Context, checkFunc func(updateCount uint64, value interface{}) bool) (uint64, interface{}, error) func (*WaitState) GetNewer ¶ func (w *WaitState) GetNewer(ctx context.Context, lastCount uint64) (uint64, interface{}, error) func (*WaitState) Set ¶ func (w *WaitState) Set(new interface{}) Source Files ¶ View all Source files waitstate.go Click to show internal directories. Click to hide internal directories.