Versions in this module Expand all Collapse all v0 v0.2.0 Aug 6, 2018 Changes in this version + type Info struct + AppName string + ConsumerStats *info.Consumer + LauncherStats task.LauncherStats + ProducerStats *info.Producer + type NewRunner func(*TaskMaster) Runner + type Runner interface + Info func() interface{} + Run func(ctx context.Context) error + type TaskMaster struct + func NewTaskMaster(appName string, initFn NewRunner, options Validator) *TaskMaster + func (tm *TaskMaster) AppName() string + func (tm *TaskMaster) AppOpt() interface{} + func (tm *TaskMaster) Description(description string) *TaskMaster + func (tm *TaskMaster) FileOpts() *TaskMaster + func (tm *TaskMaster) GetFileOpts() *file.Options + func (tm *TaskMaster) HandleRequest(w http.ResponseWriter, r *http.Request) + func (tm *TaskMaster) HttpPort() int + func (tm *TaskMaster) Initialize() *TaskMaster + func (tm *TaskMaster) Log(format string, v ...interface{}) + func (tm *TaskMaster) Logger() *log.Logger + func (tm *TaskMaster) MySQLDB() *sql.DB + func (tm *TaskMaster) MySQLOpts() *TaskMaster + func (tm *TaskMaster) NewConsumer() bus.Consumer + func (tm *TaskMaster) NewProducer() bus.Producer + func (tm *TaskMaster) PostgresDB() *sql.DB + func (tm *TaskMaster) PostgresOpts() *TaskMaster + func (tm *TaskMaster) Run() + func (tm *TaskMaster) SetLogger(lgr *log.Logger) *TaskMaster + func (tm *TaskMaster) Version(version string) *TaskMaster + type Utility struct + func NewUtility(name string, config interface{}) *Utility + func (u *Utility) Description(description string) *Utility + func (u *Utility) Initialize() + func (u *Utility) Version(version string) *Utility + type Worker struct + func (w *Worker) Description(description string) *Worker + func (w *Worker) FileOpts() *Worker + func (w *Worker) GetFileOpts() *file.Options + func (w *Worker) HandleRequest(wr http.ResponseWriter, r *http.Request) + func (w *Worker) HttpPort() int + func (w *Worker) InfoStats() Info + func (w *Worker) Initialize() *Worker + func (w *Worker) Log(format string, v ...interface{}) + func (w *Worker) Logger() *log.Logger + func (w *Worker) MySQLDB() *sql.DB + func (w *Worker) MySQLOpts() *Worker + func (w *Worker) NewConsumer(topic, channel string) bus.Consumer + func (w *Worker) NewProducer() bus.Producer + func (w *Worker) PostgresDB() *sql.DB + func (w *Worker) PostgresOpts() *Worker + func (w *Worker) Run() + func (w *Worker) SetLogger(lgr *log.Logger) *Worker + func (w *Worker) TaskType() string + func (w *Worker) Version(version string) *Worker v0.1.0 Apr 18, 2018 Changes in this version + type DBOptions struct + DBName string + Host string + Password string + Username string + type Duration struct + func (d *Duration) MarshalTOML() ([]byte, error) + func (d *Duration) UnmarshalText(text []byte) error + type NilValidator struct + func (v *NilValidator) Validate() error + type Validator interface + Validate func() error + type WorkerApp struct + func NewWorkerApp(tskType string, newWkr task.NewWorker, options Validator) *WorkerApp + func (a *WorkerApp) Description(description string) *WorkerApp + func (a *WorkerApp) FileOpts() *WorkerApp + func (a *WorkerApp) GetFileOpts() *file.Options + func (a *WorkerApp) Initialize() + func (a *WorkerApp) Log(format string, v ...interface{}) + func (a *WorkerApp) Logger() *log.Logger + func (a *WorkerApp) MySQLDB() *sql.DB + func (a *WorkerApp) MySQLOpts() *WorkerApp + func (a *WorkerApp) NewConsumer(topic, channel string) bus.Consumer + func (a *WorkerApp) NewProducer() bus.Producer + func (a *WorkerApp) PostgresDB() *sql.DB + func (a *WorkerApp) PostgresOpts() *WorkerApp + func (a *WorkerApp) Run() + func (a *WorkerApp) SetLogger(lgr *log.Logger) *WorkerApp + func (a *WorkerApp) TaskType() string + func (a *WorkerApp) Version(version string) *WorkerApp
Go to main page