Versions in this module Expand all Collapse all v0 v0.0.2 Mar 16, 2022 v0.0.1 Mar 10, 2022 Changes in this version + const TaskTypeFailing + const TaskTypeParser + const TaskTypeRandom + type CreateTaskArgs struct + Active bool + Args json.RawMessage + Category string + Code string + Description string + Display bool + ID int + Schedule string + Tags []string + Title string + Type string + type Dimension struct + ID int + Meta map[string]interface{} + MetricID int + Title string + Value string + type Item struct + Dimensions []*Dimension + ID int + Meta map[string]interface{} + Metric *Metric + TaskInstanceID int + Timestamp time.Time + Value float64 + type Metric struct + Description string + ID int + Meta map[string]interface{} + TaskID int + Title string + type SystemSymmary struct + ActiveTasks int + AvgItemsPerMetric float64 + AvgItemsPerTask float64 + AvgItemsPerTaskInstance float64 + CollectedItems int + CompletedTasks int + CreateTime time.Time + FailedTasks int + ID int + Metrics int + RunningTasks int + Tasks int + type Task struct + Active bool + Args TaskArgs + Category *TaskCategory + Code string + Description string + Display bool + ID int + Metrics []*Metric + ResolveFn func(context.Context, *Task, *TaskInstance) (*TaskInstance, error) + Schedule string + Tags []*TaskTag + Title string + Type string + func (t *Task) GetMetric(title string) (*Metric, bool) + func (t *Task) JSONString() string + type TaskArgs interface + Get func(string) (interface{}, bool) + GetFloat func(string) (float64, bool) + GetInt func(string) (int, bool) + GetString func(string) (string, bool) + ToJSON func() json.RawMessage + ToMap func() map[string]interface{} + type TaskCategory struct + Description string + Display bool + ID int + Meta map[string]interface{} + Title string + type TaskInstance struct + Attempt int + EndTime time.Time + Error error + ID int + Items []*Item + Meta map[string]interface{} + Running bool + StartTime time.Time + Success bool + TaskID int + func InitTaskInstance(taskID int, attempt int) *TaskInstance + func (ti *TaskInstance) WithError(err error, items []*Item) *TaskInstance + func (ti *TaskInstance) WithSuccess(items []*Item) *TaskInstance + type TaskTag struct + Description string + Display bool + ID int + Meta map[string]interface{} + Title string