task

Mar 19, 2025

Changes in this version

type Launcher

+ func (l *Launcher) Start(ctx context.Context)

Jan 5, 2023

Changes in this version

type Result

+ const AlertResult

+ const WarnResult

+ func Alert(format string, a ...interface{}) (Result, string)

+ func Warn(format string, a ...interface{}) (Result, string)

type Task

+ Job string

Jan 3, 2020

Changes in this version

+ type Meta map[string][]string

+ func NewMeta() Meta

+ func (m Meta) GetMeta() url.Values

+ func (m Meta) SetMeta(key string, value ...string)

Dec 9, 2019

Changes in this version

type Task

+ ID string

+ Meta string

+ func NewWithID(tskType, info, id string) *Task

Jun 3, 2019

Changes in this version

+ func IsZero(t Task) bool

type Launcher

+ func (l *Launcher) Stats() LauncherStats

+ type LauncherStats struct

+ Consumer info.Consumer

+ MeanTaskTime string

+ Producer info.Producer

+ RunTime string

+ TasksConsumed int64

+ TasksRunning int64

Apr 24, 2018

Changes in this version

+ func IsDone(ctx context.Context) bool

+ func IsInvalidWorker(w Worker) (bool, string)

+ func NewBus(conf *bus.Options) (*bus.Bus, error)

+ func NewBusOptions(busType string) *bus.Options

+ func NewConsumer(conf *bus.Options) (bus.Consumer, error)

+ func NewProducer(conf *bus.Options) (bus.Producer, error)

+ type Launcher struct

+ func NewLauncher(newWkr NewWorker, opt *LauncherOptions, bOpt *bus.Options) (*Launcher, error)

+ func NewLauncherFromBus(newWkr NewWorker, c bus.Consumer, p bus.Producer, opt *LauncherOptions) *Launcher

+ func (l *Launcher) DoTasks() (doneCtx context.Context, stopCncl context.CancelFunc)

+ func (l *Launcher) Err() error

+ type LauncherOptions struct

+ DoneTopic string

+ IgnoreBadType bool

+ LifetimeWorkers uint

+ Logger *log.Logger

+ MaxInProgress uint

+ RejectBadType bool

+ TaskType string

+ WorkerKillTime time.Duration

+ func NewLauncherOptions(tskType string) *LauncherOptions

+ type NewWorker func(info string) Worker

+ type Result string

+ const CompleteResult

+ const ErrResult

+ func Completed(format string, a ...interface{}) (Result, string)

+ func Failed(err error) (Result, string)

+ func Failf(format string, a ...interface{}) (Result, string)

+ func Interrupted() (Result, string)

+ type Task struct

+ Created string

+ Ended string

+ Info string

+ Msg string

+ Result Result

+ Started string

+ Type string

+ func New(tskType, info string) *Task

+ func NewFromBytes(b []byte) (*Task, error)

+ func (t *Task) End(r Result, msg string) time.Time

+ func (t *Task) JSONBytes() []byte

+ func (t *Task) JSONString() string

+ func (t *Task) Start() time.Time

+ type Worker interface

+ DoTask func(context.Context) (Result, string)

+ func InvalidWorker(format string, a ...interface{}) Worker