taskqueueworker

type AddJobInputResolver struct {
	TaskName      string
	MaxRetry      int
	Args          string
	RetryInterval *string
}

type AddJobRequest struct {
	TaskName      string        `json:"task_name"`
	MaxRetry      int           `json:"max_retry"`
	Args          []byte        `json:"args"`
	RetryInterval time.Duration `json:"retry_interval"`
	// contains filtered or unexported fields
}

type ClientSubscriber struct {
	ClientID      string
	SubscribeList struct {
		TaskDashboard bool
		JobDetailID   string
		JobList       *Filter
	}
}

type ConfigResolver struct {
	WithPersistent bool
}

type Filter struct {
	Page, Limit        int
	Sort               string
	TaskName           string
	TaskNameList       []string
	Search, JobID      *string
	Status             *string
	Statuses           []string
	ExcludeStatus      []string
	ShowAll            bool
	ShowHistories      *bool
	StartDate, EndDate time.Time
}

type Job struct {
	ID             string         `bson:"_id" json:"_id"`
	TaskName       string         `bson:"task_name" json:"task_name"`
	Arguments      string         `bson:"arguments" json:"arguments"`
	Retries        int            `bson:"retries" json:"retries"`
	MaxRetry       int            `bson:"max_retry" json:"max_retry"`
	Interval       string         `bson:"interval" json:"interval"`
	CreatedAt      time.Time      `bson:"created_at" json:"created_at"`
	FinishedAt     time.Time      `bson:"finished_at" json:"finished_at"`
	Status         string         `bson:"status" json:"status"`
	Error          string         `bson:"error" json:"error"`
	ErrorStack     string         `bson:"-" json:"error_stack"`
	TraceID        string         `bson:"trace_id" json:"trace_id"`
	RetryHistories []RetryHistory `bson:"retry_histories" json:"retry_histories"`
	NextRetryAt    string         `bson:"-" json:"-"`
	// contains filtered or unexported fields
}

type JobListResolver struct {
	Meta MetaJobList
	Data []Job
}

type JobStatusEnum string

type MemstatsResolver struct {
	Alloc         string
	TotalAlloc    string
	NumGC         int
	NumGoroutines int
}

type MetaJobList struct {
	Page           int
	Limit          int
	TotalRecords   int
	TotalPages     int
	IsCloseSession bool
	IsLoading      bool
	Detail         SummaryDetail
}

type MetaTaskResolver struct {
	Page                  int
	Limit                 int
	TotalRecords          int
	TotalPages            int
	IsCloseSession        bool
	TotalClientSubscriber int
}

type OptionFunc func(*option)

type Persistent interface {
	SetSummary(Summary)
	Summary() Summary
	FindAllJob(ctx context.Context, filter *Filter) (jobs []Job)
	FindJobByID(ctx context.Context, id string, excludeFields ...string) (job Job, err error)
	CountAllJob(ctx context.Context, filter *Filter) int
	AggregateAllTaskJob(ctx context.Context, filter *Filter) (result []TaskSummary)
	SaveJob(ctx context.Context, job *Job, retryHistories ...RetryHistory)
	UpdateJob(ctx context.Context, filter *Filter, updated map[string]interface{}, retryHistories ...RetryHistory) (matchedCount, affectedRow int64, err error)
	CleanJob(ctx context.Context, filter *Filter) (affectedRow int64)
	DeleteJob(ctx context.Context, id string) (job Job, err error)
}

type QueueStorage interface {
	PushJob(ctx context.Context, job *Job)
	PopJob(ctx context.Context, taskName string) (jobID string)
	NextJob(ctx context.Context, taskName string) (jobID string)
	Clear(ctx context.Context, taskName string)
}

type RetryHistory struct {
	ErrorStack string    `bson:"error_stack" json:"error_stack"`
	Status     string    `bson:"status" json:"status"`
	Error      string    `bson:"error" json:"error"`
	TraceID    string    `bson:"trace_id" json:"trace_id"`
	StartAt    time.Time `bson:"start_at" json:"start_at"`
	EndAt      time.Time `bson:"end_at" json:"end_at"`
}

type Summary interface {
	FindAllSummary(ctx context.Context, filter *Filter) (result []TaskSummary)
	FindDetailSummary(ctx context.Context, taskName string) (result TaskSummary)
	UpdateSummary(ctx context.Context, taskName string, updated map[string]interface{})
	IncrementSummary(ctx context.Context, taskName string, incr map[string]interface{})
}

type SummaryDetail struct {
	Failure, Retrying, Success, Queueing, Stopped int
}

type TaglineResolver struct {
	Banner                    string
	Tagline                   string
	Version                   string
	GoVersion                 string
	StartAt                   string
	BuildNumber               string
	Config                    ConfigResolver
	TaskListClientSubscribers []string
	JobListClientSubscribers  []string
	MemoryStatistics          MemstatsResolver
}

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

type TaskListResolver struct {
	Meta MetaTaskResolver
	Data []TaskResolver
}

type TaskResolver struct {
	Name       string
	ModuleName string
	TotalJobs  int
	IsLoading  bool
	Detail     SummaryDetail
}

type TaskSummary struct {
	ID        string `bson:"_id"`
	TaskName  string `bson:"task_name"`
	Success   int    `bson:"success"`
	Queueing  int    `bson:"queueing"`
	Retrying  int    `bson:"retrying"`
	Failure   int    `bson:"failure"`
	Stopped   int    `bson:"stopped"`
	IsLoading bool   `bson:"is_loading"`
}