http

type BadRequest = Error

type BadRequestJSONResponse Error

type CreateJob200JSONResponse JobResponse

type CreateJob400JSONResponse struct{ BadRequestJSONResponse }

type CreateJob500JSONResponse struct{ ErrorJSONResponse }

type CreateJobJSONRequestBody = CreateJobRequest

type CreateJobRequest struct {
	// Delay Optional delay before the job becomes ready, as a Go duration string (e.g. "10s", "1m30s").
	Delay duration `json:"delay,omitempty"`

	// ID Optional job id. If set and already present, the existing job is returned instead of enqueuing a duplicate.
	ID string `json:"id,omitempty"`

	// Namespace Queue namespace.
	Namespace string `json:"namespace"`

	// Payload Opaque job payload as base64-encoded bytes.
	Payload []byte `json:"payload,omitempty"`

	// QueueID Queue id within the namespace.
	QueueID string `json:"queue_id"`
}

type CreateJobRequestObject struct {
	Body *CreateJobJSONRequestBody
}

type CreateJobResponseObject interface {
	VisitCreateJobResponse(w http.ResponseWriter) error
}

type DeleteJob200JSONResponse JobResponse

type DeleteJob400JSONResponse struct{ BadRequestJSONResponse }

type DeleteJob404Response = NotSupportedResponse

type DeleteJob500JSONResponse struct{ ErrorJSONResponse }

type DeleteJobParams struct {
	// Namespace Queue namespace.
	Namespace Namespace `form:"namespace" json:"namespace"`

	// QueueID Queue id within the namespace.
	QueueID QueueID `form:"queue_id" json:"queue_id"`

	// JobID Job id.
	JobID JobID `form:"job_id" json:"job_id"`
}

type DeleteJobRequestObject struct {
	Params DeleteJobParams
}

type DeleteJobResponseObject interface {
	VisitDeleteJobResponse(w http.ResponseWriter) error
}

type Error struct {
	Error string `json:"error"`
}

type ErrorJSONResponse Error

type GetJob200JSONResponse JobStatusResponse

type GetJob400JSONResponse struct{ BadRequestJSONResponse }

type GetJob404Response = NotSupportedResponse

type GetJob500JSONResponse struct{ ErrorJSONResponse }

type GetJobParams struct {
	// Namespace Queue namespace.
	Namespace Namespace `form:"namespace" json:"namespace"`

	// JobID Job id.
	JobID JobID `form:"job_id" json:"job_id"`
}

type GetJobRequestObject struct {
	Params GetJobParams
}

type GetJobResponseObject interface {
	VisitGetJobResponse(w http.ResponseWriter) error
}

type GetMetrics200JSONResponse QueueMetricsResponse

type GetMetrics400JSONResponse struct{ BadRequestJSONResponse }

type GetMetrics404Response = NotSupportedResponse

type GetMetrics500JSONResponse struct{ ErrorJSONResponse }

type GetMetricsParams struct {
	// Namespace Queue namespace.
	Namespace Namespace `form:"namespace" json:"namespace"`

	// QueueID Queue id within the namespace.
	QueueID QueueID `form:"queue_id" json:"queue_id"`
}

type GetMetricsRequestObject struct {
	Params GetMetricsParams
}

type GetMetricsResponseObject interface {
	VisitGetMetricsResponse(w http.ResponseWriter) error
}

type InvalidParamFormatError struct {
	ParamName string
	Err       error
}

type Job struct {
	// CreatedAt When the job was first created.
	CreatedAt time.Time `json:"created_at"`

	// EnqueuedAt When the job will be executed next.
	EnqueuedAt time.Time `json:"enqueued_at"`

	// ID Unique id of the job.
	ID string `json:"id"`

	// LastError Error string from the most recent failure, if any.
	LastError string `json:"last_error"`

	// Payload Opaque job payload as base64-encoded bytes; null when empty.
	Payload *[]byte `json:"payload"`

	// Retries Number of times the job has failed and been retried.
	Retries int64 `json:"retries"`

	// UpdatedAt When the job was last executed.
	UpdatedAt time.Time `json:"updated_at"`
}

type JobID = string

type JobResponse struct {
	Job       Job    `json:"job"`
	Namespace string `json:"namespace"`
	QueueID   string `json:"queue_id"`
}

type JobStatus string

type JobStatusResponse struct {
	Job       Job    `json:"job"`
	Namespace string `json:"namespace"`

	// Status Derived from EnqueuedAt — `completed` when unset, `scheduled` when in the future, `ready` when due.
	Status JobStatus `json:"status"`
}

type MiddlewareFunc func(http.Handler) http.Handler

type Namespace = string

type NotSupportedResponse struct {
}

type QueueID = string

type QueueMetricsResponse struct {
	// Latency Processing delay from the oldest ready job, in nanoseconds.
	Latency   time.Duration `json:"latency"`
	Namespace string        `json:"namespace"`
	QueueID   string        `json:"queue_id"`

	// ReadyTotal Jobs that can be executed right now.
	ReadyTotal int64 `json:"ready_total"`

	// ScheduledTotal Jobs scheduled to run in the future.
	ScheduledTotal int64 `json:"scheduled_total"`

	// Total ready_total + scheduled_total.
	Total int64 `json:"total"`
}

type RequiredHeaderError struct {
	ParamName string
	Err       error
}

type RequiredParamError struct {
	ParamName string
}

type ServeMux interface {
	HandleFunc(pattern string, handler func(http.ResponseWriter, *http.Request))
	http.Handler
}

type ServerInterface interface {
	// Delete a job
	// (DELETE /jobs)
	DeleteJob(w http.ResponseWriter, r *http.Request, params DeleteJobParams)
	// Get job status
	// (GET /jobs)
	GetJob(w http.ResponseWriter, r *http.Request, params GetJobParams)
	// Create (enqueue) a job
	// (POST /jobs)
	CreateJob(w http.ResponseWriter, r *http.Request)
	// Get queue metrics
	// (GET /metrics)
	GetMetrics(w http.ResponseWriter, r *http.Request, params GetMetricsParams)
}

type ServerInterfaceWrapper struct {
	Handler            ServerInterface
	HandlerMiddlewares []MiddlewareFunc
	ErrorHandlerFunc   func(w http.ResponseWriter, r *http.Request, err error)
}

type ServerOptions struct {
	Queue work.Queue
}

type StdHTTPServerOptions struct {
	BaseURL          string
	BaseRouter       ServeMux
	Middlewares      []MiddlewareFunc
	ErrorHandlerFunc func(w http.ResponseWriter, r *http.Request, err error)
}

type StrictHTTPServerOptions struct {
	RequestErrorHandlerFunc  func(w http.ResponseWriter, r *http.Request, err error)
	ResponseErrorHandlerFunc func(w http.ResponseWriter, r *http.Request, err error)
}

type StrictHandlerFunc func(ctx context.Context, w http.ResponseWriter, r *http.Request, request any) (any, error)

type StrictMiddlewareFunc func(f StrictHandlerFunc, operationID string) StrictHandlerFunc

type StrictServerInterface interface {
	// Delete a job
	// (DELETE /jobs)
	DeleteJob(ctx context.Context, request DeleteJobRequestObject) (DeleteJobResponseObject, error)
	// Get job status
	// (GET /jobs)
	GetJob(ctx context.Context, request GetJobRequestObject) (GetJobResponseObject, error)
	// Create (enqueue) a job
	// (POST /jobs)
	CreateJob(ctx context.Context, request CreateJobRequestObject) (CreateJobResponseObject, error)
	// Get queue metrics
	// (GET /metrics)
	GetMetrics(ctx context.Context, request GetMetricsRequestObject) (GetMetricsResponseObject, error)
}

type TooManyValuesForParamError struct {
	ParamName string
	Count     int
}

type UnescapedCookieParamError struct {
	ParamName string
	Err       error
}

type UnmarshalingParamError struct {
	ParamName string
	Err       error
}