uwe

Jun 28, 2020

Changes in this version

+ func STDLogEventHandler() func(event Event)

type EventHandler

+ func LogrusEventHandler(entry *logrus.Entry) EventHandler

Feb 9, 2020

Changes in this version

+ const PingAction

+ const StatusAction

+ func CliCheckCommand(app AppInfo, workerListProvider func(c *cli.Context) []WorkerName) cli.Command

+ type AppInfo struct

+ Build string

+ Name string

+ Tag string

+ Version string

+ func (app AppInfo) SocketName() string

type Chief

+ EnableServiceSocket func(app AppInfo, actions ...socket.Action)

+ GetWorkersStates func() map[WorkerName]sam.State

+ type StateInfo struct

+ App AppInfo

+ Workers map[WorkerName]sam.State

+ func ParseStateInfo(data interface{}) (*StateInfo, error)

Nov 19, 2019

Changes in this version

+ const DefaultForceStopTimeout

+ const WStateFailed

+ const WStateInitialized

+ const WStateNew

+ const WStateNotExists

+ const WStateRun

+ const WStateStopped

+ var ErrWorkerNotExist = func(name WorkerName) error

+ type Chief interface

+ AddWorker func(WorkerName, Worker)

+ AddWorkers func(map[WorkerName]Worker)

+ Event func() <-chan Event

+ Run func()

+ SetContext func(context.Context)

+ SetEventHandler func(EventHandler)

+ SetLocker func(Locker)

+ SetRecover func(Recover)

+ SetShutdown func(Shutdown)

+ Shutdown func()

+ UseDefaultRecover func()

+ func NewChief() Chief

+ type Context interface

+ func NewContext() Context

+ type Event struct

+ Fields map[string]interface{}

+ Level EventLevel

+ Message string

+ Worker WorkerName

+ func ErrorEvent(msg string) Event

+ func (e Event) IsError() bool

+ func (e Event) IsFatal() bool

+ func (e Event) SetField(key string, value interface{}) Event

+ func (e Event) SetWorker(name WorkerName) Event

+ func (e Event) ToError() error

+ type EventHandler func(Event)

+ type EventLevel string

+ const LvlError

+ const LvlFatal

+ const LvlInfo

+ type Locker func()

+ type Recover func()

+ type Shutdown func()

+ type Worker interface

+ Init func() error

+ Run func(Context) error

+ type WorkerExistRule struct

+ AvailableWorkers map[WorkerName]struct{}

+ func (r *WorkerExistRule) Error(message string) *WorkerExistRule

+ func (r *WorkerExistRule) Validate(value interface{}) error

+ type WorkerName string

+ type WorkerPool struct

+ func (p *WorkerPool) FailWorker(name WorkerName) error

+ func (p *WorkerPool) GetState(name WorkerName) sam.State

+ func (p *WorkerPool) GetWorkersStates() map[WorkerName]sam.State

+ func (p *WorkerPool) InitWorker(name WorkerName) error

+ func (p *WorkerPool) IsRun(name WorkerName) bool

+ func (p *WorkerPool) ReplaceWorker(name WorkerName, worker Worker)

+ func (p *WorkerPool) RunWorkerExec(ctx Context, name WorkerName) (err error)

+ func (p *WorkerPool) SetState(name WorkerName, state sam.State) error

+ func (p *WorkerPool) SetWorker(name WorkerName, worker Worker) error

+ func (p *WorkerPool) StartWorker(name WorkerName) error

+ func (p *WorkerPool) StopWorker(name WorkerName) error