minion

Documentation

Index

• Variables
• type InitStrategy
• type Minion
  • func New(name string, fnWorkload delegate.Handler, opts ...Option) Minion
• type Option
  • func WithErrorHandler(fn func(err error)) Option
  • func WithInitStrategy(strategy InitStrategy) Option
  • func WithProcPrinter(fn func(w Minion, str string, round int64)) Option
  • func WithTickDuration(duration time.Duration) Option

Variables

var DefaultConf = conf{
	TickDuration: time.Second,
	InitStrategy: InitAtLeastOnce,
	ErrorHandler: func(err error) {},
	ProcPrinter:  func(w Minion, str string, round int64) {},
}

Types

type InitStrategy

type InitStrategy byte

const (
	InitAtLeastOnce InitStrategy = 0
	InitAsync       InitStrategy = 1
)

type Minion

type Minion interface {
	Name() string
	ID() string
	Close()
	IsFinished() bool
}

func New

func New(name string, fnWorkload delegate.Handler, opts ...Option) Minion

type Option

type Option func(c conf) conf

func WithErrorHandler

func WithErrorHandler(fn func(err error)) Option

func WithInitStrategy

func WithInitStrategy(strategy InitStrategy) Option

func WithProcPrinter

func WithProcPrinter(fn func(w Minion, str string, round int64)) Option

func WithTickDuration

func WithTickDuration(duration time.Duration) Option