api

type APIKeyId = openapi_types.UUID

type APIKeyInfo struct {
	CreatedAt  time.Time          `json:"created_at"`
	Enabled    bool               `json:"enabled"`
	Id         openapi_types.UUID `json:"id"`
	Label      string             `json:"label"`
	LastUsedAt *time.Time         `json:"last_used_at,omitempty"`
	Namespace  string             `json:"namespace"`
}

type AckExecution204Response struct {
}

type AckExecution404JSONResponse Error

type AckExecutionRequestObject struct {
	Id ExecutionId `json:"id"`
}

type AckExecutionResponseObject interface {
	VisitAckExecutionResponse(w http.ResponseWriter) error
}

type CreateAPIKey201JSONResponse CreateAPIKeyResponse

type CreateAPIKeyJSONRequestBody = CreateAPIKeyRequest

type CreateAPIKeyRequest struct {
	Label     string `json:"label"`
	Namespace string `json:"namespace"`
}

type CreateAPIKeyRequestObject struct {
	Body *CreateAPIKeyJSONRequestBody
}

type CreateAPIKeyResponse struct {
	CreatedAt time.Time          `json:"created_at"`
	Id        openapi_types.UUID `json:"id"`
	Label     string             `json:"label"`
	Namespace string             `json:"namespace"`

	// Token Plaintext token. Only returned on creation.
	Token string `json:"token"`
}

type CreateAPIKeyResponseObject interface {
	VisitCreateAPIKeyResponse(w http.ResponseWriter) error
}

type CreateJob201JSONResponse JobDetail

type CreateJob422JSONResponse Error

type CreateJobJSONRequestBody = CreateJobRequest

type CreateJobRequest struct {
	Analytics *struct {
		RetentionSeconds *int `json:"retention_seconds,omitempty"`
	} `json:"analytics,omitempty"`
	CronExpression string `json:"cron_expression"`
	Name           string `json:"name"`

	// Tags Key-value tag pairs
	Tags                  *Tag    `json:"tags,omitempty"`
	Timezone              string  `json:"timezone"`
	WebhookSecret         *string `json:"webhook_secret,omitempty"`
	WebhookTimeoutSeconds *int    `json:"webhook_timeout_seconds,omitempty"`
	WebhookUrl            string  `json:"webhook_url"`
}

type CreateJobRequestObject struct {
	Body *CreateJobJSONRequestBody
}

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

type DeleteAPIKey204Response struct {
}

type DeleteAPIKey404JSONResponse Error

type DeleteAPIKeyRequestObject struct {
	Id APIKeyId `json:"id"`
}

type DeleteAPIKeyResponseObject interface {
	VisitDeleteAPIKeyResponse(w http.ResponseWriter) error
}

type DeleteJob204Response struct {
}

type DeleteJob404JSONResponse Error

type DeleteJobRequestObject struct {
	Id JobId `json:"id"`
}

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

type Error struct {
	Error struct {
		Code    string                  `json:"code"`
		Details *map[string]interface{} `json:"details,omitempty"`
		Message string                  `json:"message"`
	} `json:"error"`
}

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

type Execution struct {
	AcknowledgedAt *time.Time           `json:"acknowledged_at,omitempty"`
	CreatedAt      time.Time            `json:"created_at"`
	FiredAt        time.Time            `json:"fired_at"`
	Id             openapi_types.UUID   `json:"id"`
	JobId          openapi_types.UUID   `json:"job_id"`
	ScheduledAt    time.Time            `json:"scheduled_at"`
	Status         ExecutionStatus      `json:"status"`
	TriggerType    ExecutionTriggerType `json:"trigger_type"`
}

type ExecutionId = openapi_types.UUID

type ExecutionStatus string

type ExecutionTriggerType string

type GetExecution200JSONResponse Execution

type GetExecution404JSONResponse Error

type GetExecutionRequestObject struct {
	Id ExecutionId `json:"id"`
}

type GetExecutionResponseObject interface {
	VisitGetExecutionResponse(w http.ResponseWriter) error
}

type GetHealth200JSONResponse HealthResponse

type GetHealth503JSONResponse HealthResponse

type GetHealthParams struct {
	Verbose *bool `form:"verbose,omitempty" json:"verbose,omitempty"`
}

type GetHealthRequestObject struct {
	Params GetHealthParams
}

type GetHealthResponseObject interface {
	VisitGetHealthResponse(w http.ResponseWriter) error
}

type GetJob200JSONResponse JobDetail

type GetJob404JSONResponse Error

type GetJobRequestObject struct {
	Id JobId `json:"id"`
}

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

type GetNextRun200JSONResponse NextRunResponse

type GetNextRun404JSONResponse Error

type GetNextRunRequestObject struct {
	Id JobId `json:"id"`
}

type GetNextRunResponseObject interface {
	VisitGetNextRunResponse(w http.ResponseWriter) error
}

type HealthChecker interface {
	PingContext(ctx context.Context) error
}

type HealthResponse struct {
	Database *string `json:"database,omitempty"`
	Status   string  `json:"status"`
}

type InvalidParamFormatError struct {
	ParamName string
	Err       error
}

type Job struct {
	CreatedAt      time.Time          `json:"created_at"`
	CronExpression string             `json:"cron_expression"`
	Enabled        bool               `json:"enabled"`
	Id             openapi_types.UUID `json:"id"`
	Name           string             `json:"name"`
	Namespace      string             `json:"namespace"`

	// Tags Key-value tag pairs
	Tags       *Tag      `json:"tags,omitempty"`
	Timezone   string    `json:"timezone"`
	UpdatedAt  time.Time `json:"updated_at"`
	WebhookUrl string    `json:"webhook_url"`
}

type JobDetail struct {
	CreatedAt        time.Time          `json:"created_at"`
	CronExpression   string             `json:"cron_expression"`
	Enabled          bool               `json:"enabled"`
	Id               openapi_types.UUID `json:"id"`
	Name             string             `json:"name"`
	Namespace        string             `json:"namespace"`
	RecentExecutions *[]Execution       `json:"recent_executions,omitempty"`

	// Tags Key-value tag pairs
	Tags       *Tag      `json:"tags,omitempty"`
	Timezone   string    `json:"timezone"`
	UpdatedAt  time.Time `json:"updated_at"`
	WebhookUrl string    `json:"webhook_url"`
}

type JobId = openapi_types.UUID

type LimitParam = int

type ListAPIKeys200JSONResponse struct {
	Keys []APIKeyInfo `json:"keys"`
}

type ListAPIKeysParams struct {
	Limit  *LimitParam  `form:"limit,omitempty" json:"limit,omitempty"`
	Offset *OffsetParam `form:"offset,omitempty" json:"offset,omitempty"`
}

type ListAPIKeysRequestObject struct {
	Params ListAPIKeysParams
}

type ListAPIKeysResponseObject interface {
	VisitListAPIKeysResponse(w http.ResponseWriter) error
}

type ListExecutions200JSONResponse struct {
	Executions []Execution `json:"executions"`
}

type ListExecutionsParams struct {
	Limit       *LimitParam                      `form:"limit,omitempty" json:"limit,omitempty"`
	Offset      *OffsetParam                     `form:"offset,omitempty" json:"offset,omitempty"`
	Status      *ListExecutionsParamsStatus      `form:"status,omitempty" json:"status,omitempty"`
	TriggerType *ListExecutionsParamsTriggerType `form:"trigger_type,omitempty" json:"trigger_type,omitempty"`
	Since       *time.Time                       `form:"since,omitempty" json:"since,omitempty"`
	Until       *time.Time                       `form:"until,omitempty" json:"until,omitempty"`
}

type ListExecutionsParamsStatus string

type ListExecutionsParamsTriggerType string

type ListExecutionsRequestObject struct {
	Id     JobId `json:"id"`
	Params ListExecutionsParams
}

type ListExecutionsResponseObject interface {
	VisitListExecutionsResponse(w http.ResponseWriter) error
}

type ListJobs200JSONResponse struct {
	Jobs []Job `json:"jobs"`
}

type ListJobsParams struct {
	Limit  *LimitParam  `form:"limit,omitempty" json:"limit,omitempty"`
	Offset *OffsetParam `form:"offset,omitempty" json:"offset,omitempty"`

	// Tag Filter by tag (key:value format, repeatable, AND semantics)
	Tag     *[]string `form:"tag,omitempty" json:"tag,omitempty"`
	Enabled *bool     `form:"enabled,omitempty" json:"enabled,omitempty"`

	// Name Substring match on job name
	Name *string `form:"name,omitempty" json:"name,omitempty"`
}

type ListJobsRequestObject struct {
	Params ListJobsParams
}

type ListJobsResponseObject interface {
	VisitListJobsResponse(w http.ResponseWriter) error
}

type ListPendingAck200JSONResponse struct {
	Executions []Execution `json:"executions"`
}

type ListPendingAckParams struct {
	Limit *LimitParam         `form:"limit,omitempty" json:"limit,omitempty"`
	JobId *openapi_types.UUID `form:"job_id,omitempty" json:"job_id,omitempty"`
}

type ListPendingAckRequestObject struct {
	Params ListPendingAckParams
}

type ListPendingAckResponseObject interface {
	VisitListPendingAckResponse(w http.ResponseWriter) error
}

type MiddlewareFunc func(http.Handler) http.Handler

type NextRunResponse struct {
	CronExpression string      `json:"cron_expression"`
	NextRunAt      time.Time   `json:"next_run_at"`
	NextRuns       []time.Time `json:"next_runs"`
	Timezone       string      `json:"timezone"`
}

type OffsetParam = int

type PauseJob200JSONResponse Job

type PauseJob404JSONResponse Error

type PauseJobRequestObject struct {
	Id JobId `json:"id"`
}

type PauseJobResponseObject interface {
	VisitPauseJobResponse(w http.ResponseWriter) error
}

type RequiredHeaderError struct {
	ParamName string
	Err       error
}

type RequiredParamError struct {
	ParamName string
}

type ResolveSchedule200JSONResponse ResolveScheduleResponse

type ResolveSchedule422JSONResponse Error

type ResolveScheduleJSONRequestBody = ResolveScheduleRequest

type ResolveScheduleRequest struct {
	// Description Natural language schedule or cron expression
	Description string  `json:"description"`
	Timezone    *string `json:"timezone,omitempty"`
}

type ResolveScheduleRequestObject struct {
	Body *ResolveScheduleJSONRequestBody
}

type ResolveScheduleResponse struct {
	CronExpression string      `json:"cron_expression"`
	Description    string      `json:"description"`
	NextRuns       []time.Time `json:"next_runs"`
	Timezone       string      `json:"timezone"`
}

type ResolveScheduleResponseObject interface {
	VisitResolveScheduleResponse(w http.ResponseWriter) error
}

type ResumeJob200JSONResponse Job

type ResumeJob404JSONResponse Error

type ResumeJobRequestObject struct {
	Id JobId `json:"id"`
}

type ResumeJobResponseObject interface {
	VisitResumeJobResponse(w http.ResponseWriter) error
}

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

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

type ServerInterface interface {
	// List API keys in caller's namespace
	// (GET /api-keys)
	ListAPIKeys(w http.ResponseWriter, r *http.Request, params ListAPIKeysParams)
	// Create a new API key
	// (POST /api-keys)
	CreateAPIKey(w http.ResponseWriter, r *http.Request)
	// Revoke an API key
	// (DELETE /api-keys/{id})
	DeleteAPIKey(w http.ResponseWriter, r *http.Request, id APIKeyId)
	// List unacknowledged completed/failed executions
	// (GET /executions/pending-ack)
	ListPendingAck(w http.ResponseWriter, r *http.Request, params ListPendingAckParams)
	// Get execution detail with delivery attempts
	// (GET /executions/{id})
	GetExecution(w http.ResponseWriter, r *http.Request, id ExecutionId)
	// Acknowledge an execution result
	// (POST /executions/{id}/ack)
	AckExecution(w http.ResponseWriter, r *http.Request, id ExecutionId)
	// Health check
	// (GET /health)
	GetHealth(w http.ResponseWriter, r *http.Request, params GetHealthParams)
	// List jobs in caller's namespace
	// (GET /jobs)
	ListJobs(w http.ResponseWriter, r *http.Request, params ListJobsParams)
	// Create a new cron job
	// (POST /jobs)
	CreateJob(w http.ResponseWriter, r *http.Request)
	// Delete a job and its data
	// (DELETE /jobs/{id})
	DeleteJob(w http.ResponseWriter, r *http.Request, id JobId)
	// Get job detail with recent executions
	// (GET /jobs/{id})
	GetJob(w http.ResponseWriter, r *http.Request, id JobId)
	// Partial update a job
	// (PATCH /jobs/{id})
	UpdateJob(w http.ResponseWriter, r *http.Request, id JobId)
	// List executions for a job
	// (GET /jobs/{id}/executions)
	ListExecutions(w http.ResponseWriter, r *http.Request, id JobId, params ListExecutionsParams)
	// Get next scheduled run time
	// (GET /jobs/{id}/next-run)
	GetNextRun(w http.ResponseWriter, r *http.Request, id JobId)
	// Pause a job (set enabled=false)
	// (POST /jobs/{id}/pause)
	PauseJob(w http.ResponseWriter, r *http.Request, id JobId)
	// Resume a paused job (set enabled=true)
	// (POST /jobs/{id}/resume)
	ResumeJob(w http.ResponseWriter, r *http.Request, id JobId)
	// Trigger immediate execution
	// (POST /jobs/{id}/trigger)
	TriggerJob(w http.ResponseWriter, r *http.Request, id JobId)
	// Resolve natural language to cron expression
	// (POST /schedules/resolve)
	ResolveSchedule(w http.ResponseWriter, r *http.Request)
}

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

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 {
	// List API keys in caller's namespace
	// (GET /api-keys)
	ListAPIKeys(ctx context.Context, request ListAPIKeysRequestObject) (ListAPIKeysResponseObject, error)
	// Create a new API key
	// (POST /api-keys)
	CreateAPIKey(ctx context.Context, request CreateAPIKeyRequestObject) (CreateAPIKeyResponseObject, error)
	// Revoke an API key
	// (DELETE /api-keys/{id})
	DeleteAPIKey(ctx context.Context, request DeleteAPIKeyRequestObject) (DeleteAPIKeyResponseObject, error)
	// List unacknowledged completed/failed executions
	// (GET /executions/pending-ack)
	ListPendingAck(ctx context.Context, request ListPendingAckRequestObject) (ListPendingAckResponseObject, error)
	// Get execution detail with delivery attempts
	// (GET /executions/{id})
	GetExecution(ctx context.Context, request GetExecutionRequestObject) (GetExecutionResponseObject, error)
	// Acknowledge an execution result
	// (POST /executions/{id}/ack)
	AckExecution(ctx context.Context, request AckExecutionRequestObject) (AckExecutionResponseObject, error)
	// Health check
	// (GET /health)
	GetHealth(ctx context.Context, request GetHealthRequestObject) (GetHealthResponseObject, error)
	// List jobs in caller's namespace
	// (GET /jobs)
	ListJobs(ctx context.Context, request ListJobsRequestObject) (ListJobsResponseObject, error)
	// Create a new cron job
	// (POST /jobs)
	CreateJob(ctx context.Context, request CreateJobRequestObject) (CreateJobResponseObject, error)
	// Delete a job and its data
	// (DELETE /jobs/{id})
	DeleteJob(ctx context.Context, request DeleteJobRequestObject) (DeleteJobResponseObject, error)
	// Get job detail with recent executions
	// (GET /jobs/{id})
	GetJob(ctx context.Context, request GetJobRequestObject) (GetJobResponseObject, error)
	// Partial update a job
	// (PATCH /jobs/{id})
	UpdateJob(ctx context.Context, request UpdateJobRequestObject) (UpdateJobResponseObject, error)
	// List executions for a job
	// (GET /jobs/{id}/executions)
	ListExecutions(ctx context.Context, request ListExecutionsRequestObject) (ListExecutionsResponseObject, error)
	// Get next scheduled run time
	// (GET /jobs/{id}/next-run)
	GetNextRun(ctx context.Context, request GetNextRunRequestObject) (GetNextRunResponseObject, error)
	// Pause a job (set enabled=false)
	// (POST /jobs/{id}/pause)
	PauseJob(ctx context.Context, request PauseJobRequestObject) (PauseJobResponseObject, error)
	// Resume a paused job (set enabled=true)
	// (POST /jobs/{id}/resume)
	ResumeJob(ctx context.Context, request ResumeJobRequestObject) (ResumeJobResponseObject, error)
	// Trigger immediate execution
	// (POST /jobs/{id}/trigger)
	TriggerJob(ctx context.Context, request TriggerJobRequestObject) (TriggerJobResponseObject, error)
	// Resolve natural language to cron expression
	// (POST /schedules/resolve)
	ResolveSchedule(ctx context.Context, request ResolveScheduleRequestObject) (ResolveScheduleResponseObject, error)
}

type Tag map[string]string

type TooManyValuesForParamError struct {
	ParamName string
	Count     int
}

type TriggerJob201JSONResponse Execution

type TriggerJob404JSONResponse Error

type TriggerJob409JSONResponse Error

type TriggerJobRequestObject struct {
	Id JobId `json:"id"`
}

type TriggerJobResponseObject interface {
	VisitTriggerJobResponse(w http.ResponseWriter) error
}

type UnescapedCookieParamError struct {
	ParamName string
	Err       error
}

type UnmarshalingParamError struct {
	ParamName string
	Err       error
}

type UpdateJob200JSONResponse JobDetail

type UpdateJob404JSONResponse Error

type UpdateJob422JSONResponse Error

type UpdateJobJSONRequestBody = UpdateJobRequest

type UpdateJobRequest struct {
	CronExpression *string `json:"cron_expression,omitempty"`
	Enabled        *bool   `json:"enabled,omitempty"`
	Name           *string `json:"name,omitempty"`

	// Tags Key-value tag pairs
	Tags                  *Tag    `json:"tags,omitempty"`
	Timezone              *string `json:"timezone,omitempty"`
	WebhookSecret         *string `json:"webhook_secret,omitempty"`
	WebhookTimeoutSeconds *int    `json:"webhook_timeout_seconds,omitempty"`
	WebhookUrl            *string `json:"webhook_url,omitempty"`
}

type UpdateJobRequestObject struct {
	Id   JobId `json:"id"`
	Body *UpdateJobJSONRequestBody
}

type UpdateJobResponseObject interface {
	VisitUpdateJobResponse(w http.ResponseWriter) error
}