Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

uwe

package module

Go to main page

Versions in this module

v1

v1.2.0

Dec 3, 2019

v1.1.0

Nov 19, 2019

v1.0.1

Aug 9, 2019

v1.0.0

Aug 9, 2019

Changes in this version

+ const WStateDisabled

+ const WStateEnabled

+ const WStateFailed

+ const WStateInitialized

+ const WStateRun

+ const WStateStopped

+ var ErrWorkerNotExist = func(name WorkerName) error

+ var ForceStopTimeout = 45 * time.Second

+ var WorkersStates = map[sam.State]struct

+ type Chief struct

+ AppName string

+ EnableByDefault bool

+ func NewChief(name string, enableByDefault bool, logger *logrus.Entry) *Chief

+ func (chief *Chief) AddValueToContext(key, value interface{})

+ func (chief *Chief) AddWorker(name WorkerName, worker Worker)

+ func (chief *Chief) EnableWorker(name WorkerName) error

+ func (chief *Chief) EnableWorkers(names ...WorkerName) (err error)

+ func (chief *Chief) GetContext() context.Context

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

+ func (chief *Chief) Init(logger *logrus.Entry) *Chief

+ func (chief *Chief) IsEnabled(name WorkerName) bool

+ func (chief *Chief) Run(workers ...WorkerName) error

+ func (chief *Chief) RunWithContext(ctx context.Context, workers ...WorkerName) error

+ func (chief *Chief) RunWithLocker(locker func(), workers ...WorkerName) (err error)

+ func (chief *Chief) StartPool(parentCtx context.Context) int

+ type CtxKey string

+ const CtxKeyLog

+ type ExitCode int

+ const ExitCodeFailed

+ const ExitCodeInterrupted

+ const ExitCodeOk

+ const ExitReinitReq

+ type Message struct

+ Data interface{}

+ Sender WorkerName

+ Target WorkerName

+ UID int64

+ type WContext interface

+ MessageBus func() <-chan *Message

+ SendMessage func(target WorkerName, data interface{}) error

+ func NewContext(name WorkerName, ctx context.Context, in, out chan *Message) WContext

+ type Worker interface

+ Init func(ctx context.Context) Worker

+ RestartOnFail func() bool

+ Run func(ctx WContext) ExitCode

+ 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 (pool *WorkerPool) DisableWorker(name WorkerName) error

+ func (pool *WorkerPool) EnableWorker(name WorkerName) error

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

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

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

+ func (pool *WorkerPool) InitWorker(name WorkerName, ctx context.Context) error

+ func (pool *WorkerPool) IsDisabled(name WorkerName) bool

+ func (pool *WorkerPool) IsEnabled(name WorkerName) bool

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

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

+ func (pool *WorkerPool) RunWorkerExec(name WorkerName, ctx WContext) (err error)

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

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

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

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

Other modules containing this package

github.com/lancer-kit/uwe/v2

github.com/lancer-kit/uwe/v3