Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ErrStopLoop = errors.New("stop run loop")
Functions ¶
This section is empty.
Types ¶
type Wrapper ¶
type Wrapper interface {
RunLoop(run.Fn) run.Fn
Run(run.Fn) run.Fn
Close(run.Fn) run.Fn
IsClosed(...context.Context) bool
}
func NewWrapper ¶
func NewWrapper(opts ...WrapperOption) (Wrapper, error)
type WrapperOption ¶
func WithWrapperLogger ¶
func WithWrapperLogger(logger *zap.Logger) WrapperOption
Click to show internal directories.
Click to hide internal directories.