resources

type APIKey struct {
	ID             string    `json:"id"`
	OrganizationID *string   `json:"organization_id,omitempty"`
	Name           string    `json:"name"`
	KeyPrefix      *string   `json:"key_prefix,omitempty"`
	Queues         []string  `json:"queues,omitempty"`
	RateLimit      *int      `json:"rate_limit,omitempty"`
	IsActive       bool      `json:"is_active"`
	CreatedAt      time.Time `json:"created_at"`
	// LastUsed is coarse: the server records it at most once per key per five
	// minutes, not once per request, so it can trail real usage by that much
	// and stays nil for a key first used moments ago. Do not treat it as a
	// live timestamp or use it to confirm an individual request.
	LastUsed  *time.Time `json:"last_used,omitempty"`
	ExpiresAt *time.Time `json:"expires_at,omitempty"`
}

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

type AddDependenciesRequest struct {
	DependsOn      []string        `json:"depends_on"`
	DependencyMode *DependencyMode `json:"dependency_mode,omitempty"`
}

type AddDependenciesResponse struct {
	DependenciesAdded int      `json:"dependencies_added"`
	DependenciesMet   bool     `json:"dependencies_met"`
	Success           bool     `json:"success"`
	Dependencies      []string `json:"dependencies,omitempty"`
}

type AdminCreateAPIKeyRequest struct {
	Name      string     `json:"name"`
	Queues    []string   `json:"queues,omitempty"`
	RateLimit *int       `json:"rate_limit,omitempty"`
	ExpiresAt *time.Time `json:"expires_at,omitempty"`
}

type AdminCreateOrganizationRequest struct {
	Name         string         `json:"name"`
	Slug         string         `json:"slug"`
	PlanTier     *PlanTier      `json:"plan_tier,omitempty"`
	BillingEmail *string        `json:"billing_email,omitempty"`
	CustomLimits map[string]any `json:"custom_limits,omitempty"`
}

type AdminJobStats struct {
	TotalActive  int `json:"total_active"`
	Pending      int `json:"pending"`
	Processing   int `json:"processing"`
	Completed24h int `json:"completed_24h"`
	Failed24h    int `json:"failed_24h"`
}

type AdminOrgStats struct {
	Total           int              `json:"total"`
	ByPlan          []AdminPlanCount `json:"by_plan"`
	CreatedToday    int              `json:"created_today"`
	CreatedThisWeek int              `json:"created_this_week"`
}

type AdminOrganizationList struct {
	Organizations []Organization `json:"organizations"`
	Total         int            `json:"total"`
	Limit         int            `json:"limit"`
	Offset        int            `json:"offset"`
}

type AdminPlanCount struct {
	Plan  string `json:"plan"`
	Count int    `json:"count"`
}

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

type AdminStats struct {
	Organizations AdminOrgStats    `json:"organizations"`
	Jobs          AdminJobStats    `json:"jobs"`
	Workers       AdminWorkerStats `json:"workers"`
	System        AdminSystemStats `json:"system"`
}

type AdminSystemStats struct {
	APIVersion    string `json:"api_version"`
	UptimeSeconds int64  `json:"uptime_seconds"`
}

type AdminUpdateOrganizationRequest struct {
	Name         *string        `json:"name,omitempty"`
	PlanTier     *PlanTier      `json:"plan_tier,omitempty"`
	BillingEmail *string        `json:"billing_email,omitempty"`
	CustomLimits map[string]any `json:"custom_limits,omitempty"`
	IsActive     *bool          `json:"is_active,omitempty"`
}

type AdminWorkerStats struct {
	Total    int `json:"total"`
	Healthy  int `json:"healthy"`
	Degraded int `json:"degraded"`
}

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

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

type BatchJobStatus struct {
	ID          string     `json:"id"`
	Status      JobStatus  `json:"status"`
	QueueName   string     `json:"queue_name"`
	RetryCount  int        `json:"retry_count"`
	CreatedAt   time.Time  `json:"created_at"`
	CompletedAt *time.Time `json:"completed_at,omitempty"`
}

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

type BillingStatus struct {
	PlanTier                 PlanTier   `json:"plan_tier"`
	StripeSubscriptionID     *string    `json:"stripe_subscription_id,omitempty"`
	StripeSubscriptionStatus *string    `json:"stripe_subscription_status,omitempty"`
	StripeCurrentPeriodEnd   *time.Time `json:"stripe_current_period_end,omitempty"`
	StripeCancelAtPeriodEnd  *bool      `json:"stripe_cancel_at_period_end,omitempty"`
	HasStripeCustomer        bool       `json:"has_stripe_customer"`
}

type BoostPriorityRequest struct {
	Priority int `json:"priority"`
}

type BoostPriorityResponse struct {
	JobID       string `json:"job_id"`
	OldPriority int    `json:"old_priority"`
	NewPriority int    `json:"new_priority"`
}

type BulkEnqueueRequest struct {
	QueueName             string        `json:"queue_name"`
	Jobs                  []BulkJobItem `json:"jobs"`
	DefaultPriority       *int          `json:"default_priority,omitempty"`
	DefaultMaxRetries     *int          `json:"default_max_retries,omitempty"`
	DefaultTimeoutSeconds *int          `json:"default_timeout_seconds,omitempty"`
}

type BulkEnqueueResponse struct {
	Succeeded    []BulkJobSuccess `json:"succeeded"`
	Failed       []BulkJobFailure `json:"failed"`
	Total        int              `json:"total"`
	SuccessCount int              `json:"success_count"`
	FailureCount int              `json:"failure_count"`
}

type BulkJobFailure struct {
	Index int    `json:"index"`
	Error string `json:"error"`
}

type BulkJobItem struct {
	Payload        any        `json:"payload"`
	Priority       *int       `json:"priority,omitempty"`
	IdempotencyKey *string    `json:"idempotency_key,omitempty"`
	ScheduledAt    *time.Time `json:"scheduled_at,omitempty"`
}

type BulkJobSuccess struct {
	Index   int    `json:"index"`
	JobID   string `json:"job_id"`
	Created bool   `json:"created"`
}

type CheckEmailResponse struct {
	Available     bool `json:"available"`
	Exists        bool `json:"exists"`
	SignupEnabled bool `json:"signup_enabled"`
}

type CheckSlugResponse struct {
	Available  bool    `json:"available"`
	Valid      bool    `json:"valid"`
	Error      *string `json:"error,omitempty"`
	Suggestion *string `json:"suggestion,omitempty"`
}

type ClaimJobsRequest struct {
	QueueName        string `json:"queue_name"`
	WorkerID         string `json:"worker_id"`
	Limit            *int   `json:"limit,omitempty"`
	LeaseDurationSec *int   `json:"lease_duration_secs,omitempty"`
}

type ClaimJobsResponse struct {
	Jobs []ClaimedJob `json:"jobs"`
}

type ClaimedJob struct {
	ID             string     `json:"id"`
	QueueName      string     `json:"queue_name"`
	Payload        any        `json:"payload"`
	RetryCount     int        `json:"retry_count"`
	MaxRetries     int        `json:"max_retries"`
	TimeoutSeconds int        `json:"timeout_seconds"`
	LeaseExpiresAt *time.Time `json:"lease_expires_at,omitempty"`
	// LeaseID is the lease fencing token issued by the server for this claim.
	// Echo it back on Complete, Fail, Heartbeat and RenewLease: the API
	// requires it there (422 VALIDATION_ERROR without it) and applies the call
	// only to the lease this worker actually holds.
	LeaseID *string `json:"lease_id,omitempty"`
}

type CompleteJobRequest struct {
	WorkerID string `json:"worker_id"`
	Result   any    `json:"result,omitempty"`
	// LeaseID is the lease fencing token from the claimed job
	// (ClaimedJob.LeaseID). It is required: the API answers a complete without
	// it with 422 VALIDATION_ERROR ("Field `lease_id` is required"), and one
	// that does not match the job's current lease with 409. It is a pointer
	// only for compatibility; always set it.
	LeaseID *string `json:"lease_id,omitempty"`
}

type CreateAPIKeyRequest struct {
	Name      string     `json:"name"`
	Queues    []string   `json:"queues,omitempty"`
	RateLimit *int       `json:"rate_limit,omitempty"`
	ExpiresAt *time.Time `json:"expires_at,omitempty"`
}

type CreateAPIKeyResponse struct {
	ID        string     `json:"id"`
	Key       string     `json:"key"` // Raw key - only shown once!
	Name      string     `json:"name"`
	CreatedAt time.Time  `json:"created_at"`
	ExpiresAt *time.Time `json:"expires_at,omitempty"`
}

type CreateJobRequest struct {
	QueueName         string     `json:"queue_name"`
	Payload           any        `json:"payload"`
	Priority          *int       `json:"priority,omitempty"`
	MaxRetries        *int       `json:"max_retries,omitempty"`
	TimeoutSeconds    *int       `json:"timeout_seconds,omitempty"`
	ScheduledAt       *time.Time `json:"scheduled_at,omitempty"`
	ExpiresAt         *time.Time `json:"expires_at,omitempty"`
	IdempotencyKey    *string    `json:"idempotency_key,omitempty"`
	Tags              any        `json:"tags,omitempty"`
	ParentJobID       *string    `json:"parent_job_id,omitempty"`
	CompletionWebhook *string    `json:"completion_webhook,omitempty"`
}

type CreateJobResponse struct {
	ID      string `json:"id"`
	Created bool   `json:"created"`
}

type CreateOrganizationRequest struct {
	Name         string  `json:"name"`
	Slug         string  `json:"slug"`
	BillingEmail *string `json:"billing_email,omitempty"`
}

type CreateOrganizationResponse struct {
	Organization Organization         `json:"organization"`
	APIKey       CreateAPIKeyResponse `json:"api_key"`
}

type CreateOutgoingWebhookRequest struct {
	Name    string         `json:"name"`
	URL     string         `json:"url"`
	Events  []WebhookEvent `json:"events"`
	Secret  *string        `json:"secret,omitempty"`
	Enabled *bool          `json:"enabled,omitempty"`
	// Format is the delivery body (json, slack, discord or teams). Nil sends
	// nothing and the server uses json. An unknown value is a 400.
	Format *WebhookFormat `json:"format,omitempty"`
}

type CreatePortalRequest struct {
	ReturnURL string `json:"return_url"`
}

type CreatePortalResponse struct {
	URL string `json:"url"`
}

type CreateScheduleRequest struct {
	Name            string  `json:"name"`
	Description     *string `json:"description,omitempty"`
	CronExpression  string  `json:"cron_expression"`
	Timezone        *string `json:"timezone,omitempty"`
	QueueName       string  `json:"queue_name"`
	PayloadTemplate any     `json:"payload_template"`
	Priority        *int    `json:"priority,omitempty"`
	MaxRetries      *int    `json:"max_retries,omitempty"`
	TimeoutSeconds  *int    `json:"timeout_seconds,omitempty"`
	Tags            any     `json:"tags,omitempty"`
	Metadata        any     `json:"metadata,omitempty"`
}

type CreateWorkflowRequest struct {
	Name        string                  `json:"name"`
	Description *string                 `json:"description,omitempty"`
	Jobs        []WorkflowJobDefinition `json:"jobs"`
	Metadata    map[string]any          `json:"metadata,omitempty"`
}

type CreateWorkflowResponse struct {
	WorkflowID string               `json:"workflow_id"`
	JobIDs     []WorkflowJobMapping `json:"job_ids"`
}

type CustomWebhookRequest struct {
	QueueName      string         `json:"queue_name"`
	EventType      *string        `json:"event_type,omitempty"`
	Payload        map[string]any `json:"payload"`
	IdempotencyKey *string        `json:"idempotency_key,omitempty"`
	Priority       *int           `json:"priority,omitempty"`
	// WebhookToken is the organization's webhook token, sent as the
	// X-Webhook-Token header (never in the body). Ingest().Custom requires it;
	// CustomWithToken takes the token as an argument instead.
	WebhookToken string `json:"-"`
}

type CustomWebhookResponse struct {
	JobID     string `json:"job_id"`
	QueueName string `json:"queue_name"`
	Status    string `json:"status"`
}

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

type DashboardData struct {
	System         SystemInfo        `json:"system"`
	Jobs           JobSummaryStats   `json:"jobs"`
	Queues         []QueueSummary    `json:"queues"`
	Workers        WorkerSummaryInfo `json:"workers"`
	RecentActivity RecentActivity    `json:"recent_activity"`
}

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

type DependencyInfo struct {
	JobID     string `json:"job_id"`
	QueueName string `json:"queue_name"`
	Status    string `json:"status"`
}

type DependencyMode string

type FailJobRequest struct {
	WorkerID string `json:"worker_id"`
	Error    string `json:"error"`
	// LeaseID is the lease fencing token from the claimed job
	// (ClaimedJob.LeaseID). It is required: the API answers a fail without it
	// with 422 VALIDATION_ERROR ("Field `lease_id` is required"), and one that
	// does not match the job's current lease with 409. It is a pointer only for
	// compatibility; always set it.
	LeaseID *string `json:"lease_id,omitempty"`
}

type FailJobResponse struct {
	Success bool `json:"success"`
	// WillRetry and NextRetryDelaySec are filled only when the API sends them.
	// POST /jobs/{id}/fail on Spooled Cloud currently answers {"success":true}
	// alone, so both are nil there: decide from the claimed job instead (it is
	// retried while RetryCount < MaxRetries), or fail over gRPC, whose
	// FailWithResponse returns the server's decision.
	WillRetry         *bool `json:"will_retry,omitempty"`
	NextRetryDelaySec *int  `json:"next_retry_delay_secs,omitempty"`
}

type GenerateSlugResponse struct {
	Slug string `json:"slug"`
}

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

type HealthResponse struct {
	Status    string `json:"status"`
	Database  bool   `json:"database"`
	Cache     bool   `json:"cache"`
	Timestamp string `json:"timestamp,omitempty"`
}

type HeartbeatRequest struct {
	WorkerID         string `json:"worker_id"`
	LeaseDurationSec *int   `json:"lease_duration_secs,omitempty"`
	// LeaseID is the lease fencing token from the claimed job
	// (ClaimedJob.LeaseID). It is required: the API answers a heartbeat without
	// it with 422 VALIDATION_ERROR, and one that does not match the job's
	// current lease with 409. It is a pointer only for compatibility; always
	// set it.
	LeaseID *string `json:"lease_id,omitempty"`
}

type InboundDeliveryStatus string

type InboundWebhookDelivery struct {
	ID        string `json:"id"`
	Provider  string `json:"provider"`
	EventType string `json:"event_type"`
	// MatchedQueue is the queue the job went to.
	MatchedQueue *string `json:"matched_queue,omitempty"`
	// JobID is the job the request created or matched. Nil for entries
	// recorded before API 0.1.122.
	JobID *string `json:"job_id,omitempty"`
	// Status is InboundDeliveryCreated or InboundDeliveryDuplicate. Nil for
	// entries recorded before API 0.1.122.
	Status    *InboundDeliveryStatus `json:"status,omitempty"`
	CreatedAt time.Time              `json:"created_at"`
}

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

type Job struct {
	ID             string    `json:"id"`
	OrganizationID string    `json:"organization_id"`
	QueueName      string    `json:"queue_name"`
	Status         JobStatus `json:"status"`
	// Payload/Result/Tags are JSON values (object, array, string, bool, …).
	Payload any `json:"payload"`
	Result  any `json:"result,omitempty"`
	// JobType is payload.job_type on list summaries; GET /jobs/{id} has no
	// column and UnmarshalJSON copies it from payload when present.
	JobType           string     `json:"job_type,omitempty"`
	RetryCount        int        `json:"retry_count"`
	MaxRetries        int        `json:"max_retries"`
	LastError         *string    `json:"last_error,omitempty"`
	CreatedAt         time.Time  `json:"created_at"`
	ScheduledAt       *time.Time `json:"scheduled_at,omitempty"`
	StartedAt         *time.Time `json:"started_at,omitempty"`
	CompletedAt       *time.Time `json:"completed_at,omitempty"`
	ExpiresAt         *time.Time `json:"expires_at,omitempty"`
	Priority          int        `json:"priority"`
	Tags              any        `json:"tags,omitempty"`
	TimeoutSeconds    int        `json:"timeout_seconds"`
	ParentJobID       *string    `json:"parent_job_id,omitempty"`
	CompletionWebhook *string    `json:"completion_webhook,omitempty"`
	AssignedWorkerID  *string    `json:"assigned_worker_id,omitempty"`
	LeaseID           *string    `json:"lease_id,omitempty"`
	LeaseExpiresAt    *time.Time `json:"lease_expires_at,omitempty"`
	IdempotencyKey    *string    `json:"idempotency_key,omitempty"`
	UpdatedAt         time.Time  `json:"updated_at"`
	WorkflowID        *string    `json:"workflow_id,omitempty"`
	DependencyMode    *string    `json:"dependency_mode,omitempty"`
	DependenciesMet   *bool      `json:"dependencies_met,omitempty"`
}

type JobHistoryEvent struct {
	ID    string `json:"id"`
	JobID string `json:"job_id"`
	// EventType names the event, such as "created", "claimed", "completed" or
	// "failed". Compare it as a string: the API can add event types.
	EventType string `json:"event_type"`
	// WorkerID is the worker involved, when there was one.
	WorkerID *string `json:"worker_id,omitempty"`
	// Details is the event's JSON details (any JSON value).
	Details   any       `json:"details,omitempty"`
	CreatedAt time.Time `json:"created_at"`
}

type JobHistoryPage struct {
	Events []JobHistoryEvent
	// HasMore is the API's X-Has-More header: true when more events follow.
	HasMore bool
}

type JobHistoryParams struct {
	// Order is "asc" (default, oldest event first) or "desc" (newest first).
	Order *string `json:"order_dir,omitempty"`
	// Limit is the page size, 1-500 (API default 100).
	Limit  *int `json:"limit,omitempty"`
	Offset *int `json:"offset,omitempty"`
}

type JobMetrics struct {
	TotalCreated    int64   `json:"total_created"`
	TotalCompleted  int64   `json:"total_completed"`
	TotalFailed     int64   `json:"total_failed"`
	AvgWaitTimeMs   float64 `json:"avg_wait_time_ms"`
	AvgProcessingMs float64 `json:"avg_processing_ms"`
}

type JobStats struct {
	Pending    int `json:"pending"`
	Scheduled  int `json:"scheduled"`
	Processing int `json:"processing"`
	Completed  int `json:"completed"`
	Failed     int `json:"failed"`
	Deadletter int `json:"deadletter"`
	Cancelled  int `json:"cancelled"`
	Total      int `json:"total"`
}

type JobStatus string

type JobSummaryStats struct {
	Total               int      `json:"total"`
	Pending             int      `json:"pending"`
	Processing          int      `json:"processing"`
	Completed24h        int      `json:"completed_24h"`
	Failed24h           int      `json:"failed_24h"`
	Deadletter          int      `json:"deadletter"`
	AvgWaitTimeMs       *float64 `json:"avg_wait_time_ms,omitempty"`
	AvgProcessingTimeMs *float64 `json:"avg_processing_time_ms,omitempty"`
}

type JobWithDependencies struct {
	JobID           string           `json:"job_id"`
	Dependencies    []DependencyInfo `json:"dependencies"`
	Dependents      []DependencyInfo `json:"dependents"`
	DependenciesMet bool             `json:"dependencies_met"`
}

type JobsPage struct {
	Jobs []Job
	// HasMore is the API's X-Has-More header: true when this page is full and
	// at least one more job matches. Ask for the next page with Offset
	// advanced by len(Jobs).
	HasMore bool
}

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

type ListDLQParams struct {
	QueueName *string `json:"queue_name,omitempty"`
	Limit     *int    `json:"limit,omitempty"`
	Offset    *int    `json:"offset,omitempty"`
	// Tag keeps jobs with this tag.
	Tag *string `json:"tag,omitempty"`
	// Q is the same search as ListJobsParams.Q.
	Q *string `json:"q,omitempty"`
	// JobType keeps jobs whose payload job_type is exactly this value.
	JobType *string `json:"job_type,omitempty"`
	// CreatedAfter keeps jobs created at or after this instant.
	CreatedAfter *time.Time `json:"created_after,omitempty"`
	// CreatedBefore keeps jobs created before this instant.
	CreatedBefore *time.Time `json:"created_before,omitempty"`
}

type ListDeliveriesParams struct {
	Status *WebhookDeliveryStatus `json:"status,omitempty"`
	Limit  *int                   `json:"limit,omitempty"`
	Offset *int                   `json:"offset,omitempty"`
}

type ListInboundDeliveriesParams struct {
	// Status keeps entries with this status. An unknown value is a 400.
	Status *InboundDeliveryStatus `json:"status,omitempty"`
	// Since keeps entries received at or after this instant.
	Since *time.Time `json:"since,omitempty"`
	// QueueName keeps entries whose job went to this queue.
	QueueName *string `json:"queue_name,omitempty"`
	// Limit is the page size, 1-100 (API default 50).
	Limit  *int `json:"limit,omitempty"`
	Offset *int `json:"offset,omitempty"`
}

type ListJobsParams struct {
	QueueName *string `json:"queue_name,omitempty"`
	// Status filters by one status. Statuses filters by several; when both are
	// set the job may have any of them.
	Status *JobStatus `json:"status,omitempty"`
	Tag    *string    `json:"tag,omitempty"` // Filter by a single tag
	Limit  *int       `json:"limit,omitempty"`
	Offset *int       `json:"offset,omitempty"`
	// Statuses keeps jobs in any of these statuses. It is sent as one
	// comma-separated status parameter (status=failed,deadletter).
	Statuses []JobStatus `json:"statuses,omitempty"`
	// Q is a case-insensitive search: a job matches when its ID starts with
	// it, or its queue name or payload job_type contains it. Payloads are not
	// searched.
	Q *string `json:"q,omitempty"`
	// JobType keeps jobs whose payload job_type is exactly this value.
	JobType *string `json:"job_type,omitempty"`
	// CreatedAfter keeps jobs created at or after this instant.
	CreatedAfter *time.Time `json:"created_after,omitempty"`
	// CreatedBefore keeps jobs created before this instant.
	CreatedBefore *time.Time `json:"created_before,omitempty"`
	// OrderBy is the sort column: created_at (default), updated_at,
	// scheduled_at, completed_at, priority, status, queue_name or retry_count.
	OrderBy *string `json:"order_by,omitempty"`
	// OrderDir is "desc" (default) or "asc".
	OrderDir *string `json:"order_dir,omitempty"`
}

type ListOrganizationsParams struct {
	PlanTier *PlanTier `json:"plan_tier,omitempty"`
	Search   *string   `json:"search,omitempty"`
	Limit    *int      `json:"limit,omitempty"`
	Offset   *int      `json:"offset,omitempty"`
}

type ListSchedulesParams struct {
	QueueName *string `json:"queue_name,omitempty"`
	IsActive  *bool   `json:"is_active,omitempty"`
	Limit     *int    `json:"limit,omitempty"`
	Offset    *int    `json:"offset,omitempty"`
}

type ListWorkflowsParams struct {
	Status *WorkflowStatus `json:"status,omitempty"`
	Limit  *int            `json:"limit,omitempty"`
	Offset *int            `json:"offset,omitempty"`
}

type LoginRequest struct {
	APIKey string `json:"api_key"`
}

type LoginResponse struct {
	AccessToken      string `json:"access_token"`
	RefreshToken     string `json:"refresh_token"`
	TokenType        string `json:"token_type"`
	ExpiresIn        int    `json:"expires_in"`
	RefreshExpiresIn int    `json:"refresh_expires_in"`
}

type LogoutRequest struct {
	RefreshToken string `json:"refresh_token,omitempty"`
}

type MeResponse struct {
	OrganizationID string    `json:"organization_id"`
	APIKeyID       string    `json:"api_key_id"`
	Queues         []string  `json:"queues"`
	IssuedAt       time.Time `json:"issued_at"`
	ExpiresAt      time.Time `json:"expires_at"`
}

type Metrics struct {
	Jobs    JobMetrics    `json:"jobs"`
	Workers WorkerMetrics `json:"workers"`
	Queues  QueueMetrics  `json:"queues"`
	System  SystemMetrics `json:"system"`
}

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

type Organization struct {
	ID                       string         `json:"id"`
	Name                     string         `json:"name"`
	Slug                     string         `json:"slug"`
	PlanTier                 PlanTier       `json:"plan_tier"`
	BillingEmail             *string        `json:"billing_email,omitempty"`
	Settings                 map[string]any `json:"settings"`
	CustomLimits             map[string]any `json:"custom_limits,omitempty"`
	StripeCustomerID         *string        `json:"stripe_customer_id,omitempty"`
	StripeSubscriptionID     *string        `json:"stripe_subscription_id,omitempty"`
	StripeSubscriptionStatus *string        `json:"stripe_subscription_status,omitempty"`
	StripeCurrentPeriodEnd   *time.Time     `json:"stripe_current_period_end,omitempty"`
	StripeCancelAtPeriodEnd  *bool          `json:"stripe_cancel_at_period_end,omitempty"`
	CreatedAt                time.Time      `json:"created_at"`
	UpdatedAt                time.Time      `json:"updated_at"`
}

type OrganizationMember struct {
	ID        string    `json:"id"`
	UserID    string    `json:"user_id"`
	Email     string    `json:"email"`
	Name      string    `json:"name"`
	Role      string    `json:"role"`
	JoinedAt  time.Time `json:"joined_at"`
	InvitedBy *string   `json:"invited_by,omitempty"`
}

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

type OutgoingWebhook struct {
	ID             string         `json:"id"`
	OrganizationID string         `json:"organization_id"`
	Name           string         `json:"name"`
	URL            string         `json:"url"`
	Events         []WebhookEvent `json:"events"`
	// Format is the delivery body: json (the default), slack, discord or
	// teams. Empty from servers older than 0.1.122, which only send JSON.
	Format WebhookFormat `json:"format,omitempty"`
	// Enabled turns false on its own after 20 consecutive failed deliveries:
	// the server auto-disables the webhook and it stops receiving events.
	// Re-enable it with Update and Enabled set to true - that counts against
	// the plan webhook cap, so it can fail with 429 QUOTA_EXCEEDED.
	Enabled bool `json:"enabled"`
	// FailureCount counts consecutive failed deliveries, one per delivery
	// rather than one per retry attempt, so it is roughly five times smaller
	// than a per-attempt count for the same real-world failures. A successful
	// delivery resets it to 0, including a successful manual RetryDelivery.
	FailureCount    int        `json:"failure_count"`
	LastTriggeredAt *time.Time `json:"last_triggered_at,omitempty"`
	// LastStatus is "success", "failed" or "auto_disabled". The last of those
	// means the webhook hit 20 consecutive failed deliveries and was disabled.
	LastStatus *string   `json:"last_status,omitempty"`
	CreatedAt  time.Time `json:"created_at"`
	UpdatedAt  time.Time `json:"updated_at"`
}

type OutgoingWebhookDelivery struct {
	ID           string                `json:"id"`
	WebhookID    string                `json:"webhook_id"`
	Event        WebhookEvent          `json:"event"`
	Payload      map[string]any        `json:"payload"`
	Status       WebhookDeliveryStatus `json:"status"`
	StatusCode   *int                  `json:"status_code,omitempty"`
	ResponseBody *string               `json:"response_body,omitempty"`
	Error        *string               `json:"error,omitempty"`
	Attempts     int                   `json:"attempts"`
	CreatedAt    time.Time             `json:"created_at"`
	DeliveredAt  *time.Time            `json:"delivered_at,omitempty"`
}

type PauseQueueRequest struct {
	Reason *string `json:"reason,omitempty"`
}

type PauseQueueResponse struct {
	QueueName string    `json:"queue_name"`
	Paused    bool      `json:"paused"`
	PausedAt  time.Time `json:"paused_at"`
	Reason    *string   `json:"reason,omitempty"`
}

type PlanInfo struct {
	Tier        PlanTier   `json:"tier"`
	DisplayName string     `json:"display_name"`
	Description string     `json:"description"`
	Limits      PlanLimits `json:"limits"`
	Price       *PlanPrice `json:"price,omitempty"`
}

type PlanLimits struct {
	Tier                       string `json:"tier"`
	DisplayName                string `json:"display_name"`
	MaxJobsPerDay              *int   `json:"max_jobs_per_day,omitempty"`
	MaxActiveJobs              *int   `json:"max_active_jobs,omitempty"`
	MaxQueues                  *int   `json:"max_queues,omitempty"`
	MaxWorkers                 *int   `json:"max_workers,omitempty"`
	MaxAPIKeys                 *int   `json:"max_api_keys,omitempty"`
	MaxSchedules               *int   `json:"max_schedules,omitempty"`
	MaxWorkflows               *int   `json:"max_workflows,omitempty"`
	MaxWebhooks                *int   `json:"max_webhooks,omitempty"`
	MaxPayloadSizeBytes        int    `json:"max_payload_size_bytes"`
	RateLimitRequestsPerSecond int    `json:"rate_limit_requests_per_second"`
	RateLimitBurst             int    `json:"rate_limit_burst"`
	JobRetentionDays           int    `json:"job_retention_days"`
	HistoryRetentionDays       int    `json:"history_retention_days"`
}

type PlanPrice struct {
	MonthlyUSD int    `json:"monthly_usd"`
	YearlyUSD  int    `json:"yearly_usd"`
	Currency   string `json:"currency"`
}

type PlanTier string

type PurgeDLQRequest struct {
	QueueName *string `json:"queue_name,omitempty"`
	// OlderThan purges only jobs created before this time.
	OlderThan *time.Time `json:"older_than,omitempty"`
	// Limit caps how many jobs one call purges (API default and max: 10000).
	Limit *int `json:"limit,omitempty"`
	// Confirm must be true: the API rejects a purge without it. Purge sets it,
	// since calling Purge is the confirmation.
	Confirm bool `json:"confirm"`
}

type PurgeDLQResponse struct {
	PurgedCount int `json:"purged_count"`
}

type QueueConfig struct {
	ID             string         `json:"id"`
	OrganizationID string         `json:"organization_id"`
	QueueName      string         `json:"queue_name"`
	MaxRetries     int            `json:"max_retries"`
	DefaultTimeout int            `json:"default_timeout"`
	RateLimit      *int           `json:"rate_limit,omitempty"`
	Enabled        bool           `json:"enabled"`
	Settings       map[string]any `json:"settings"`
	CreatedAt      time.Time      `json:"created_at"`
	UpdatedAt      time.Time      `json:"updated_at"`
}

type QueueListItem struct {
	QueueName      string `json:"queue_name"`
	MaxRetries     int    `json:"max_retries"`
	DefaultTimeout int    `json:"default_timeout"`
	RateLimit      *int   `json:"rate_limit,omitempty"`
	Enabled        bool   `json:"enabled"`
}

type QueueMetrics struct {
	TotalQueues     int `json:"total_queues"`
	TotalPaused     int `json:"total_paused"`
	TotalPending    int `json:"total_pending"`
	TotalProcessing int `json:"total_processing"`
}

type QueueStats struct {
	QueueName        string `json:"queue_name"`
	PendingJobs      int    `json:"pending_jobs"`
	ProcessingJobs   int    `json:"processing_jobs"`
	CompletedJobs24h int    `json:"completed_jobs_24h"`
	FailedJobs24h    int    `json:"failed_jobs_24h"`
	// AvgProcessingTimeMs is fractional (the API averages in floating point,
	// e.g. 1523.456); decoding it into an int failed the whole response.
	AvgProcessingTimeMs *float64 `json:"avg_processing_time_ms,omitempty"`
	MaxJobAgeSeconds    *int     `json:"max_job_age_seconds,omitempty"`
	ActiveWorkers       int      `json:"active_workers"`
}

type QueueSummary struct {
	Name       string `json:"name"`
	Pending    int    `json:"pending"`
	Processing int    `json:"processing"`
	Paused     bool   `json:"paused"`
}

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

type RecentActivity struct {
	JobsCreated1h   int `json:"jobs_created_1h"`
	JobsCompleted1h int `json:"jobs_completed_1h"`
	JobsFailed1h    int `json:"jobs_failed_1h"`
}

type RefreshRequest struct {
	RefreshToken string `json:"refresh_token"`
}

type RefreshResponse struct {
	AccessToken string `json:"access_token"`
	TokenType   string `json:"token_type"`
	ExpiresIn   int    `json:"expires_in"`
}

type RegisterWorkerRequest struct {
	// WorkerID is an optional stable worker identity: 1-128 characters from
	// [A-Za-z0-9._-]. Supplying the same value across restarts makes
	// registration an upsert, so the process reuses one worker row. Leave it
	// nil and the server mints a UUID instead, which means every restart
	// leaves the previous row counting against the plan worker cap until the
	// stale-worker reaper clears it (roughly two minutes) - enough for a
	// crash-looping worker on a tight plan to 429 itself out of registering.
	// Re-registering an ID this organization already owns is not charged
	// against the cap; an ID owned by a different organization returns 409.
	WorkerID       *string        `json:"worker_id,omitempty"`
	QueueName      string         `json:"queue_name"`
	Hostname       string         `json:"hostname"`
	WorkerType     *string        `json:"worker_type,omitempty"`
	MaxConcurrency *int           `json:"max_concurrency,omitempty"`
	Metadata       map[string]any `json:"metadata,omitempty"`
	Version        *string        `json:"version,omitempty"`
}

type RegisterWorkerResponse struct {
	ID                   string `json:"id"`
	QueueName            string `json:"queue_name"`
	LeaseDurationSecs    int    `json:"lease_duration_secs"`
	HeartbeatIntervalSec int    `json:"heartbeat_interval_secs"`
}

type RenewLeaseRequest struct {
	WorkerID         string `json:"worker_id"`
	LeaseDurationSec int    `json:"lease_duration_secs,omitempty"`
	// LeaseID is the lease fencing token from the claimed job
	// (ClaimedJob.LeaseID). It is required: RenewLease sends a job heartbeat,
	// which the API answers with 422 VALIDATION_ERROR without it. It is a
	// pointer only for compatibility; always set it.
	LeaseID *string `json:"lease_id,omitempty"`
}

type RenewLeaseResponse struct {
	Success        bool       `json:"success"`
	LeaseExpiresAt *time.Time `json:"lease_expires_at,omitempty"`
}

type ResourceUsage struct {
	JobsToday  UsageItem `json:"jobs_today"`
	ActiveJobs UsageItem `json:"active_jobs"`
	Queues     UsageItem `json:"queues"`
	Workers    UsageItem `json:"workers"`
	APIKeys    UsageItem `json:"api_keys"`
	Schedules  UsageItem `json:"schedules"`
	Workflows  UsageItem `json:"workflows"`
	Webhooks   UsageItem `json:"webhooks"`
}

type ResumeQueueResponse struct {
	QueueName          string `json:"queue_name"`
	Resumed            bool   `json:"resumed"`
	PausedDurationSecs int    `json:"paused_duration_secs"`
}

type RetryDLQRequest struct {
	QueueName *string  `json:"queue_name,omitempty"`
	JobIDs    []string `json:"job_ids,omitempty"`
}

type RetryDLQResponse struct {
	RetriedCount int      `json:"retried_count"`
	RetriedJobs  []string `json:"retried_jobs,omitempty"`
}

type RetryDeliveryResponse struct {
	Success bool    `json:"success"`
	Message *string `json:"message,omitempty"`
	Error   *string `json:"error,omitempty"`
}

type Schedule struct {
	ID              string     `json:"id"`
	OrganizationID  string     `json:"organization_id"`
	Name            string     `json:"name"`
	Description     *string    `json:"description,omitempty"`
	CronExpression  string     `json:"cron_expression"`
	Timezone        string     `json:"timezone"`
	QueueName       string     `json:"queue_name"`
	PayloadTemplate any        `json:"payload_template"`
	Priority        int        `json:"priority"`
	MaxRetries      int        `json:"max_retries"`
	TimeoutSeconds  int        `json:"timeout_seconds"`
	IsActive        bool       `json:"is_active"`
	LastRunAt       *time.Time `json:"last_run_at,omitempty"`
	NextRunAt       *time.Time `json:"next_run_at,omitempty"`
	RunCount        int        `json:"run_count"`
	Tags            any        `json:"tags,omitempty"`
	Metadata        any        `json:"metadata,omitempty"`
	CreatedAt       time.Time  `json:"created_at"`
	UpdatedAt       time.Time  `json:"updated_at"`
}

type ScheduleRun struct {
	ID           string            `json:"id"`
	ScheduleID   string            `json:"schedule_id"`
	JobID        *string           `json:"job_id,omitempty"`
	Status       ScheduleRunStatus `json:"status"`
	ErrorMessage *string           `json:"error_message,omitempty"`
	StartedAt    time.Time         `json:"started_at"`
	CompletedAt  *time.Time        `json:"completed_at,omitempty"`
}

type ScheduleRunStatus string

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

type StartEmailLoginRequest struct {
	Email string `json:"email"`
}

type StartEmailLoginResponse struct {
	Message     string `json:"message"`
	EmailSentTo string `json:"email_sent_to"`
}

type SystemInfo struct {
	Version        string `json:"version"`
	UptimeSeconds  int64  `json:"uptime_seconds"`
	StartedAt      string `json:"started_at"`
	DatabaseStatus string `json:"database_status"`
	CacheStatus    string `json:"cache_status"`
	Environment    string `json:"environment"`
}

type SystemMetrics struct {
	UptimeSeconds  int64   `json:"uptime_seconds"`
	RequestsPerSec float64 `json:"requests_per_sec"`
	ErrorRate      float64 `json:"error_rate"`
	AvgLatencyMs   float64 `json:"avg_latency_ms"`
}

type TestWebhookResponse struct {
	Success        bool    `json:"success"`
	StatusCode     *int    `json:"status_code,omitempty"`
	ResponseTimeMs int     `json:"response_time_ms"`
	Error          *string `json:"error,omitempty"`
}

type TriggerScheduleResponse struct {
	JobID       string    `json:"job_id"`
	TriggeredAt time.Time `json:"triggered_at"`
}

type UnsupportedError struct {
	// Operation names the SDK call, e.g. "Jobs.UpdateProgress".
	Operation string
	// Reason says what to do instead.
	Reason string
}

type UpdateAPIKeyRequest struct {
	Name      *string  `json:"name,omitempty"`
	Queues    []string `json:"queues,omitempty"`
	RateLimit *int     `json:"rate_limit,omitempty"`
	IsActive  *bool    `json:"is_active,omitempty"`
}

type UpdateOrganizationRequest struct {
	Name         *string        `json:"name,omitempty"`
	BillingEmail *string        `json:"billing_email,omitempty"`
	Settings     map[string]any `json:"settings,omitempty"`
}

type UpdateOutgoingWebhookRequest struct {
	Name   *string         `json:"name,omitempty"`
	URL    *string         `json:"url,omitempty"`
	Events *[]WebhookEvent `json:"events,omitempty"`
	// Secret replaces the HMAC signing secret. Leave it nil to keep whatever
	// secret the webhook already has.
	Secret *string `json:"secret,omitempty"`
	// ClearSecret sends an explicit null secret, which DELETES the signing
	// secret: deliveries then go out unsigned, with no X-Spooled-Signature
	// header for the receiver to verify. Nothing restores the old value, so
	// set a new Secret to sign again. Setting Secret and ClearSecret together
	// is an error.
	ClearSecret bool `json:"-"`
	// Enabled is how an auto-disabled webhook is brought back: send true after
	// the server disabled it for 20 consecutive failed deliveries. The
	// re-enable counts against the plan webhook cap and can fail with 429
	// QUOTA_EXCEEDED.
	Enabled *bool `json:"enabled,omitempty"`
	// Format changes the delivery body (json, slack, discord or teams). Nil
	// keeps the current format.
	Format *WebhookFormat `json:"format,omitempty"`
}

type UpdateQueueConfigRequest struct {
	MaxRetries     *int  `json:"max_retries,omitempty"`
	DefaultTimeout *int  `json:"default_timeout,omitempty"`
	RateLimit      *int  `json:"rate_limit,omitempty"`
	Enabled        *bool `json:"enabled,omitempty"`
}

type UpdateScheduleRequest struct {
	Name           *string `json:"name,omitempty"`
	Description    *string `json:"description,omitempty"`
	CronExpression *string `json:"cron_expression,omitempty"`
	Timezone       *string `json:"timezone,omitempty"`
	// QueueName is not part of the API's update request, so the server ignores
	// it: a schedule's queue cannot be changed. Delete and recreate the schedule
	// to move it to another queue.
	//
	// Deprecated: has no effect.
	QueueName       *string `json:"queue_name,omitempty"`
	PayloadTemplate any     `json:"payload_template,omitempty"`
	Priority        *int    `json:"priority,omitempty"`
	MaxRetries      *int    `json:"max_retries,omitempty"`
	TimeoutSeconds  *int    `json:"timeout_seconds,omitempty"`
	IsActive        *bool   `json:"is_active,omitempty"`
	Tags            any     `json:"tags,omitempty"`
	Metadata        any     `json:"metadata,omitempty"`
}

type UsageInfo struct {
	Plan            string         `json:"plan"`
	PlanDisplayName string         `json:"plan_display_name"`
	Limits          PlanLimits     `json:"limits"`
	Usage           ResourceUsage  `json:"usage"`
	Warnings        []UsageWarning `json:"warnings,omitempty"`
}

type UsageItem struct {
	Current    int      `json:"current"`
	Limit      *int     `json:"limit,omitempty"`
	Percentage *float64 `json:"percentage,omitempty"`
	IsDisabled bool     `json:"is_disabled"`
}

type UsageWarning struct {
	Resource string `json:"resource"`
	Message  string `json:"message"`
	Severity string `json:"severity"`
}

type ValidateRequest struct {
	Token string `json:"token"`
}

type ValidateResponse struct {
	Valid          bool       `json:"valid"`
	Error          *string    `json:"error,omitempty"`
	OrganizationID *string    `json:"organization_id,omitempty"`
	APIKeyID       *string    `json:"api_key_id,omitempty"`
	Queues         []string   `json:"queues,omitempty"`
	ExpiresAt      *time.Time `json:"expires_at,omitempty"`
}

type VerifyEmailRequest struct {
	Email string `json:"email"`
	Code  string `json:"code"`
}

type VerifyEmailResponse struct {
	Type             string `json:"type"`
	AccessToken      string `json:"access_token,omitempty"`
	RefreshToken     string `json:"refresh_token,omitempty"`
	TokenType        string `json:"token_type,omitempty"`
	ExpiresIn        int    `json:"expires_in,omitempty"`
	RefreshExpiresIn int    `json:"refresh_expires_in,omitempty"`
	SignupToken      string `json:"signup_token,omitempty"`
	Email            string `json:"email,omitempty"`
}

type WebhookDeliveryStatus string

type WebhookEvent string

type WebhookFormat string

type WebhookTokenResponse struct {
	WebhookToken *string `json:"webhook_token,omitempty"`
	WebhookURL   *string `json:"webhook_url,omitempty"`
}

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

type Worker struct {
	ID             string         `json:"id"`
	OrganizationID string         `json:"organization_id"`
	QueueName      string         `json:"queue_name"`
	QueueNames     []string       `json:"queue_names,omitempty"`
	Hostname       string         `json:"hostname"`
	WorkerType     *string        `json:"worker_type,omitempty"`
	MaxConcurrency int            `json:"max_concurrency"`
	CurrentJobs    int            `json:"current_jobs"`
	Status         WorkerStatus   `json:"status"`
	LastHeartbeat  time.Time      `json:"last_heartbeat"`
	Metadata       map[string]any `json:"metadata"`
	Version        *string        `json:"version,omitempty"`
	RegisteredAt   time.Time      `json:"registered_at"`
	UpdatedAt      time.Time      `json:"updated_at"`
	// JobsProcessed counts the jobs this worker completed (API 0.1.122 or
	// later; 0 from older servers).
	JobsProcessed int64 `json:"jobs_processed"`
	// JobsFailed counts the failures this worker reported, each retry it
	// scheduled or dead-letter it caused. Jobs released because a lease
	// expired or the worker went offline are not counted.
	JobsFailed int64 `json:"jobs_failed"`
}

type WorkerHeartbeatRequest struct {
	CurrentJobs int            `json:"current_jobs"`
	Status      *string        `json:"status,omitempty"`
	Metadata    map[string]any `json:"metadata,omitempty"`
}

type WorkerMetrics struct {
	TotalRegistered int `json:"total_registered"`
	TotalActive     int `json:"total_active"`
	TotalIdle       int `json:"total_idle"`
}

type WorkerStatus string

type WorkerSummary struct {
	ID             string       `json:"id"`
	QueueName      string       `json:"queue_name"`
	Hostname       string       `json:"hostname"`
	Status         WorkerStatus `json:"status"`
	CurrentJobs    int          `json:"current_jobs"`
	MaxConcurrency int          `json:"max_concurrency"`
	LastHeartbeat  time.Time    `json:"last_heartbeat"`
	// JobsProcessed counts the jobs this worker completed (see Worker).
	JobsProcessed int64 `json:"jobs_processed"`
	// JobsFailed counts the failures this worker reported (see Worker).
	JobsFailed int64 `json:"jobs_failed"`
}

type WorkerSummaryInfo struct {
	Total     int `json:"total"`
	Healthy   int `json:"healthy"`
	Unhealthy int `json:"unhealthy"`
}

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

type Workflow struct {
	ID             string         `json:"id"`
	OrganizationID string         `json:"organization_id"`
	Name           string         `json:"name"`
	Description    *string        `json:"description,omitempty"`
	Status         WorkflowStatus `json:"status"`
	TotalJobs      int            `json:"total_jobs"`
	CompletedJobs  int            `json:"completed_jobs"`
	FailedJobs     int            `json:"failed_jobs"`
	CreatedAt      time.Time      `json:"created_at"`
	StartedAt      *time.Time     `json:"started_at,omitempty"`
	CompletedAt    *time.Time     `json:"completed_at,omitempty"`
	Metadata       map[string]any `json:"metadata,omitempty"`
}

type WorkflowJob struct {
	ID string `json:"id"`
	// Key is the key the job was defined with. The API does not return it on
	// workflow details, so it is empty when read through Jobs().ListJobs or
	// Jobs().GetJob; fill it from the create response with
	// CreateWorkflowResponse.ApplyKeys (or KeyByJobID).
	Key            string     `json:"key,omitempty"`
	QueueName      string     `json:"queue_name"`
	Status         JobStatus  `json:"status"`
	DependsOn      []string   `json:"depends_on,omitempty"`
	DependencyMode *string    `json:"dependency_mode,omitempty"`
	CreatedAt      time.Time  `json:"created_at"`
	StartedAt      *time.Time `json:"started_at,omitempty"`
	CompletedAt    *time.Time `json:"completed_at,omitempty"`
}

type WorkflowJobDefinition struct {
	Key            string          `json:"key"`
	QueueName      string          `json:"queue_name"`
	Payload        any             `json:"payload"`
	DependsOn      []string        `json:"depends_on,omitempty"`
	DependencyMode *DependencyMode `json:"dependency_mode,omitempty"`
	Priority       *int            `json:"priority,omitempty"`
	MaxRetries     *int            `json:"max_retries,omitempty"`
	TimeoutSeconds *int            `json:"timeout_seconds,omitempty"`
}

type WorkflowJobMapping struct {
	Key   string `json:"key"`
	JobID string `json:"job_id"`
}

type WorkflowJobStatus struct {
	// Key is empty unless the API returns job keys, which it currently does
	// not; map JobID back to a key with CreateWorkflowResponse.KeyByJobID.
	Key       string    `json:"key,omitempty"`
	JobID     string    `json:"job_id"`
	Status    JobStatus `json:"status"`
	DependsOn []string  `json:"depends_on,omitempty"`
}

type WorkflowJobStatusResponse struct {
	Jobs []WorkflowJobStatus `json:"jobs"`
}

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

type WorkflowStatus string

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