scheduler

type Callback struct {
	URL          string
	Method       string
	Headers      map[string]string
	Timeout      time.Duration
	MaxBodyBytes int
}

type CallbackPayload struct {
	JobID        string    `json:"job_id"`
	ScheduledAt  time.Time `json:"scheduled_at"`
	StartedAt    time.Time `json:"started_at"`
	FinishedAt   time.Time `json:"finished_at"`
	Attempts     int       `json:"attempts"`
	Success      bool      `json:"success"`
	StatusCode   int       `json:"status_code,omitempty"`
	Error        string    `json:"error,omitempty"`
	ResponseBody string    `json:"response_body,omitempty"`
}

type Job struct {
	ID          string
	Schedule    Schedule
	Request     Request
	Callback    Callback
	RetryPolicy RetryPolicy
}

type Option func(*Scheduler)

type Request struct {
	Method  string
	URL     string
	Headers map[string]string
	Body    []byte
	Timeout time.Duration
}

type RetryPolicy struct {
	Retrier          *again.Retrier
	TemporaryErrors  []error
	RetryStatusCodes []int
}

type Schedule struct {
	Every   time.Duration
	StartAt time.Time
	EndAt   time.Time
	MaxRuns int
}

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

type StatusError struct {
	StatusCode int
}