astiworker

Dec 4, 2019

Changes in this version

+ const StatusCrashed

+ const StatusRunning

+ const StatusStopped

+ type ExecOptions struct

+ Args []string

+ CmdAdapter func(cmd *exec.Cmd, h ExecHandler) error

+ Name string

+ StopFunc func(cmd *exec.Cmd) error

+ type SignalHandler func(s os.Signal)

+ func TermSignalHandler(f func()) SignalHandler

type Task

+ func (t *Task) Do(f func())

Sep 17, 2019

Changes in this version

+ type TaskFunc func() *Task

Aug 9, 2019

Changes in this version

+ type DialOptions struct

+ Addr string

+ Client *astiws.Client

+ Header http.Header

+ OnDial func() error

+ OnReadError func(err error)

type Worker

+ func (w *Worker) Dial(o DialOptions)

Dec 15, 2018

Changes in this version

+ const ExecHandlerStatusCrashed

+ const ExecHandlerStatusRunning

+ const ExecHandlerStatusStopped

+ type ConfigurationConsumer struct

+ AMQP astiamqp.ConfigurationConsumer

+ WorkerCount int

+ type ExecHandler interface

+ Status func() string

+ Stop func()

+ type Task struct

+ func (t *Task) Done()

+ func (t *Task) NewSubTask() *Task

+ func (t *Task) Wait()

+ type Worker struct

+ func NewWorker() (w *Worker)

+ func (w *Worker) Consume(a *astiamqp.AMQP, cs ...ConfigurationConsumer) (err error)

+ func (w *Worker) Context() context.Context

+ func (w *Worker) Exec(name string, args ...string) (ExecHandler, error)

+ func (w *Worker) HandleSignals()

+ func (w *Worker) NewTask() *Task

+ func (w *Worker) Serve(addr string, h http.Handler)

+ func (w *Worker) Stop()

+ func (w *Worker) Wait()