task

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

type PersistedTaskData struct {
	Id         string `json:"id"`
	Queue      string `json:"queue"`
	RetryTimes uint   `json:"retry_times"`
	// This doesn't map to the domain model 1:1 because storing _attempts_ instead of retires
	// allows us to not need to adjust the counts for timeouts, and instead issue a simple update-by-query
	RemainingAttempts uint                     `json:"remaining_attempts"`
	Kind              string                   `json:"kind"`
	State             task.State               `json:"state"`
	RunAt             time.Time                `json:"run_at"`
	ProcessingTimeout time.Duration            `json:"processing_timeout"`
	Priority          int                      `json:"priority"`
	Args              *jsonObjMap              `json:"args,omitempty"`
	Context           *jsonObjMap              `json:"context,omitempty"`
	LastEnqueuedAt    time.Time                `json:"last_enqueued_at"`
	LastClaimed       *persistedLastClaimed    `json:"last_claimed,omitempty"`
	Metadata          common.PersistedMetadata `json:"metadata"`
	RecurringTaskId   *string                  `json:"recurring_task_id,omitempty"`
}