runner

Documentation

Index

• Variables
• func Init(r Runner) error
• func Start(r Runner)
• func StartBG(r Runner)
• func Stop(r Runner)
• type Runner

Variables

var Create = newBase // allow to override

Functions

func Init

func Init(r Runner) error

func Start

func Start(r Runner)

func StartBG

func StartBG(r Runner)

func Stop

func Stop(r Runner)

Types

type Runner

type Runner interface {
	kvs.KVS

	Init() error
	Start() error
	Stop() error

	Name() string
	SetName(string)
	Ctx() context.Context
	SetCtx(context.Context)
	Cancel()

	Inherit(Runner)

	Started() <-chan struct{}
	Stopping() <-chan struct{}
	StopDone() <-chan struct{}
	Done() <-chan struct{}

	GetChild(string) Runner
	Children() []Runner
	AppendRunner(Runner) bool
	WaitChildrenDone()
	SetParent(Runner)
	Parent() Runner
	OnChildDone(Runner) error

	AppendError(err ...error)
	Err() error
	SelfErr() error
	ChildrenErr() error

	WithLoggerFrom(r Runner, kvs ...any)
	WithLoggerFields(kvs ...any)
	Debug(msg string, kvs ...any)
	Info(msg string, kvs ...any)
	Warn(msg string, kvs ...any)
	Error(msg string, err error, kvs ...any)
	// contains filtered or unexported methods
}