queue

type Config struct {
	NWorker      int32 `json:"n_worker"`       // Number of simultaneous workers processing tasks.
	Throttle     int32 `json:"throttle"`       // Number of maxium task invocations from queue per second.
	TaskTLimit   int32 `json:"task_t_limit"`   // Duration allowed per task to complete in seconds.
	TaskMaxTries int32 `json:"task_max_tries"` // Number of tries per task before giving up. Set 0 for unlimited retries.
	LogSize      int32 `json:"log_size"`       // Number of max log entries.
}

type Conveyor struct {
	Object  string    `json:"object"`  // Define resource.
	ID      string    `json:"id"`      // Conveyor identification.
	Created time.Time `json:"created"` // Conveyor created timestamp.
	Changed time.Time `json:"changed"` // Conveyor changed timestamp.
	Paused  bool      `json:"paused"`  // Conveyor is in pause state.
	Config  Config    `json:"config"`  // Conveyor configurations.
	// contains filtered or unexported fields
}

type Manager struct {
	Conveyors map[string]*Conveyor
}

type Scheduler struct {
	// Conveyor.
	Conveyor *Conveyor `json:"-"`

	// Conveyor scheduler id name.
	ScheduleId string `json:"schedule_id"`

	// Conveyor scheduler list name.
	ScheduleList string `json:"schedule_list"`

	// How often scheduler checks schedule list in seconds.
	Rate time.Duration `json:"rate"`
	// contains filtered or unexported fields
}

type Statistic struct {
	Object                    string        `json:"object"`
	InQueue                   int64         `json:"in_queue"`
	InProcessing              int64         `json:"in_processing"`
	InScheduled               int64         `json:"in_scheduled"`
	TotalProcessed            int           `json:"total_processed"`
	TotalProcessedOK          int           `json:"total_processed_ok"`
	TotalProcessedError       int           `json:"total_processed_error"`
	TotalProcessedRescheduled int           `json:"total_processed_rescheduled"`
	AvgTime                   time.Duration `json:"avg_time"`
	AvgTimeRecent             time.Duration `json:"avg_time_recent"`
}

type Task struct {
	Object    string `json:"object"`
	ID        string `json:"id"`
	Target    string `json:"target"`
	Payload   string `json:"payload"`
	Tries     int32  `json:"tries"`
	Delay     int32  `json:"delay"`
	Recurring int32  `json:"recurring"`
}