Versions in this module Expand all Collapse all v0 v0.2.1 Oct 31, 2013 Changes in this version + func AddConveyor(conveyorID string, config *Config) error + func GobDecode(buf []byte, res interface{}) error + func GobEncode(v interface{}) ([]byte, error) + func RemoveConveyor(conveyorId string) error + func StartManager(dbFilepath string) error + type Config struct + LogSize int32 + NWorker int32 + TaskMaxTries int32 + TaskTLimit int32 + Throttle int32 + type Conveyor struct + Changed time.Time + Config Config + Created time.Time + ID string + Object string + Paused bool + func GetAllConveyor() ([]*Conveyor, error) + func GetConveyor(conveyorID string) (*Conveyor, error) + func NewConveyor(conveyorID string, config *Config) *Conveyor + func (conv *Conveyor) Add(target, payload string, scheduled, recurring int64) (*Task, error) + func (conv *Conveyor) Flush() error + func (conv *Conveyor) Init() *Conveyor + func (conv *Conveyor) Pause() + func (conv *Conveyor) Resume() + func (conv *Conveyor) Start() error + func (conv *Conveyor) Stats() (*Statistic, error) + func (conv *Conveyor) Stop() + func (conv *Conveyor) Tasks() ([]*Task, error) + type Manager struct + Conveyors map[string]*Conveyor + type Scheduler struct + Conveyor *Conveyor + Rate time.Duration + ScheduleId string + ScheduleList string + func NewScheduler(conveyor *Conveyor) *Scheduler + func (sched *Scheduler) Add(taskId string, task []byte, time int64) error + func (sched *Scheduler) Reschedule(task *Task) (int32, error) + func (sched *Scheduler) Start() + type Statistic struct + AvgTime time.Duration + AvgTimeRecent time.Duration + InProcessing int64 + InQueue int64 + InScheduled int64 + Object string + TotalProcessed int + TotalProcessedError int + TotalProcessedOK int + TotalProcessedRescheduled int + type Task struct + Delay int32 + ID string + Object string + Payload string + Recurring int32 + Target string + Tries int32