Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var Create = newBase // allow to override
Functions ¶
func Stop ¶
func Stop(r Runner)
Stop runner, in most scenario, Stop is notification action to notify the Runner to stop.
func StopAndWait ¶ added in v0.9.17
func StopAndWait(r Runner)
StopAndWait notify Runner to stop and wait it done.
Types ¶
type Runner ¶
type Runner interface {
kvs.NoErrKVS
log.Logger
Init() error
Start() error
Stop() error
Name() string
SetName(string)
Ctx() context.Context
SetCtx(context.Context)
Cancel()
Inherit(Runner)
Parent() Runner
MarkStarted() bool
MarkStopping() bool
MarkStopDone() bool
MarkDone() bool
Started() <-chan struct{}
Stopping() <-chan struct{}
StopDone() <-chan struct{}
Done() <-chan struct{}
AppendError(err ...error)
Err() error
WithLoggerFrom(r Runner, kvs ...any)
}
Click to show internal directories.
Click to hide internal directories.