celeriac

type Event struct {
	// Type is the Celery event type. See supported events listed in "constants.go"
	Type string `json:"type"`

	// Hostname is the name of the host on which the Celery worker is operating
	Hostname string `json:"hostname"`

	// Timestamp is the current time of the event
	Timestamp float32 `json:"timestamp"`

	// PID is the process ID
	PID int `json:"pid"`

	// Clock is the current clock time
	Clock int `json:"clock"`

	// UTCOffset is the offset from UTC for the time when this event is valid
	UTCOffset int `json:"utcoffset"`

	// Data is a property allowing extra data to be sent through for custom events from a Celery worker
	Data interface{} `json:"data, omitempty"`
}

type PingCmd struct {
	// contains filtered or unexported fields
}

type RateLimitTaskCmd struct {
	Arguments rateLimitTaskArgs `json:"arguments"`
	// contains filtered or unexported fields
}

type RevokeTaskCmd struct {
	Arguments revokeTaskArgs `json:"arguments"`
	// contains filtered or unexported fields
}

type Task struct {
	// TaskName is the name of the task
	TaskName string `json:"task"`

	// ID is the task UUID
	ID string `json:"id"`

	// Args are task arguments (optional)
	Args []string `json:"args, omitempty"`

	// KWArgs are keyword arguments (optional)
	KWArgs map[string]interface{} `json:"kwargs, omitempty"`

	// Retries is a number of retries to perform if an error occurs (optional)
	Retries int `json:"retries, omitempty"`

	// ETA is the estimated completion time (optional)
	ETA *time.Time `json:"eta, omitempty"`

	// Expires is the time when this task will expire (optional)
	Expires *time.Time `json:"expires, omitempty"`
}

type TaskEvent struct {
	Type      string  `json:"type"`
	Hostname  string  `json:"hostname"`
	Timestamp float32 `json:"timestamp"`
	PID       int     `json:"pid"`
	Clock     int     `json:"clock"`
	UTCOffset int     `json:"utcoffset"`

	// UUID is the id of the task
	UUID string `json:"uuid"`

	// Name is the textual name of the task executed
	Name string `json:"name, omitempty"`

	// Args is a string of the arguments passed to the task
	Args string `json:"args, omitempty"`

	// Kwargs is a string of the key-word arguments passed to the task
	Kwargs string `json:"kwargs, omitempty"`

	// Result is a string containing the result of a completed task
	Result string `json:"result, omitempty"`

	// Runtime is the execution time
	Runtime float32 `json:"runtime, omitempty"`

	// Retries is the number of re-tries this task has performed
	Retries int `json:"retries, omitempty"`

	// ETA is the explicit time and date to run the retry at.
	ETA interface{} `json:"eta, omitempty"`

	// Expires is the datetime or seconds in the future for the task should expire
	Expires interface{} `json:"expires, omitempty"`

	// Exception is a string containing error/exception information
	Exception string `json:"exception, omitempty"`

	// Traceback is a string containing extended error information
	Traceback string `json:"traceback, omitempty"`

	// Terminated is a flag indicating whether the task has been terminated
	Terminated bool `json:"terminated, omitempty"`

	// Signum is the signal number
	Signum interface{} `json:"signum, omitempty"`

	// Expired is a flag indicating whether the task has expired due to factors
	Expired bool `json:"expired, omitempty"`
}

type TaskEventsList []TaskEvent

type TaskMonitor struct {

	// Public channel on which events are piped
	EventsChannel chan interface{}
	// contains filtered or unexported fields
}

type TaskQueueMgr struct {
	Monitor *TaskMonitor
	// contains filtered or unexported fields
}

type TimeLimitTaskCmd struct {
	Arguments timeLimitTaskArgs `json:"arguments"`
	// contains filtered or unexported fields
}

type WorkerEvent struct {
	Type      string  `json:"type"`
	Hostname  string  `json:"hostname"`
	Timestamp float32 `json:"timestamp"`
	PID       int     `json:"pid"`
	Clock     int     `json:"clock"`
	UTCOffset int     `json:"utcoffset"`

	// SWSystem is the software system being used
	SWSystem string `json:"sw_sys"`

	// SWVersion is the software version being used
	SWVersion string `json:"sw_ver"`

	// LoadAverage is an array of average CPU loadings for the worker
	LoadAverage []float32 `json:"loadavg"`

	// Freq is the worker frequency use
	Freq float32 `json:"freq"`

	// SWIdentity is the software identity
	SWIdentity string `json:"sw_ident"`

	// Processed is the number of items processed
	Processed int `json:"processed, omitempt"`

	// Active is the active number of workers
	Active int `json:"active, omitempty"`
}