runner

Documentation

Index

• func Inherit(to Runner, from Runner)
• func Init(r Runner) error
• func Start(r Runner)
• func StartBG(r Runner)
• func Stop(r Runner)
• type Runner
  • func NewBase(name string) Runner

Functions

func Inherit

func Inherit(to Runner, from Runner)

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 {
	Init() error
	Start() error
	Stop() error

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

	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
}

func NewBase

func NewBase(name string) Runner