Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type API ¶
type API struct {
// contains filtered or unexported fields
}
func NewAPI ¶
func NewAPI( cfg *config.Config, db *postgres.DB, tenantRepo *postgres.TenantRepo, jobRepo *postgres.JobRepo, scheduleRepo *postgres.ScheduleRepo, workerRepo *postgres.WorkerRepo, metrics *observability.Metrics, ) *API
type BatchEnqueueRequest ¶
type BatchEnqueueRequest struct {
Jobs []EnqueueRequest `json:"jobs"`
}
BatchEnqueueRequest is the body of POST /v1/jobs/batch.
type CreateScheduleRequest ¶
type CreateScheduleRequest struct {
Name string `json:"name"`
Queue string `json:"queue"`
TaskType string `json:"task_type"`
Payload json.RawMessage `json:"payload"`
CronExpression string `json:"cron_expression"`
Timezone string `json:"timezone"`
Priority *int16 `json:"priority"`
MaxAttempts *int `json:"max_attempts"`
TimeoutSeconds *int `json:"timeout_seconds"`
MisfirePolicy string `json:"misfire_policy"`
}
type EnqueueRequest ¶
Click to show internal directories.
Click to hide internal directories.