draincommand

package

v3.0.0-beta10 Latest Latest Go to latest Published: Dec 12, 2025 License: Apache-2.0 Imports: 2 Imported by: 0

Details

Package draincommand is a helper for daemon drain commands

This section is empty.

View Source

var (
	ErrDrained = errors.New("drained command")
)

func Do(c <-chan any, duration time.Duration)

Do drains the command chan c If pending command is an ErrorSetter, it set cmd error to ErrDrained

type ErrC chan<- error

ErrC defines error channel for command

func (c ErrC) SetError(err error)

type ErrorSetter interface {
	SetError(error)
}