spooled

type APIError struct {
	// StatusCode is the HTTP status code.
	StatusCode int `json:"status_code,omitempty"`
	// Code is the error code from the API.
	Code string `json:"code,omitempty"`
	// Message is the human-readable error message.
	Message string `json:"message,omitempty"`
	// Details contains additional error details.
	Details map[string]any `json:"details,omitempty"`
	// RequestID is the request ID for debugging.
	RequestID string `json:"request_id,omitempty"`
	// RawBody is the raw response body.
	RawBody []byte `json:"-"`
	// Err is the underlying error, if any.
	Err error `json:"-"`
}

type AuthenticationError struct {
	*APIError
}

type AuthorizationError struct {
	*APIError
}

type CircuitBreakerConfig struct {
	// Enabled determines if circuit breaker is active.
	Enabled bool
	// FailureThreshold is the number of failures before opening the circuit.
	FailureThreshold int
	// SuccessThreshold is the number of successes needed to close the circuit.
	SuccessThreshold int
	// Timeout is the duration the circuit stays open before allowing a test request.
	Timeout time.Duration
}

type CircuitBreakerOpenError struct {
	*APIError
}

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

type Config struct {
	// APIKey is the API key for authentication (production keys start with sk_live_, sk_test_).
	APIKey string
	// AccessToken is a JWT access token (alternative to API key).
	AccessToken string
	// RefreshToken is a JWT refresh token for automatic token renewal.
	RefreshToken string
	// AdminKey is the admin API key (for /api/v1/admin/* endpoints; uses X-Admin-Key header).
	AdminKey string

	// BaseURL is the base URL for the REST API.
	BaseURL string
	// WSURL is the WebSocket URL for realtime events.
	WSURL string
	// GRPCAddress is the gRPC server address.
	GRPCAddress string

	// Timeout is the request timeout.
	Timeout time.Duration
	// Retry is the retry configuration.
	Retry RetryConfig
	// CircuitBreaker is the circuit breaker configuration.
	CircuitBreaker CircuitBreakerConfig

	// Headers are additional headers to include in all requests.
	Headers map[string]string
	// UserAgent is the custom user agent string.
	UserAgent string
	// Logger is the debug logger.
	Logger Logger
	// AutoRefreshToken enables automatic token refresh.
	AutoRefreshToken bool
}

type ConflictError struct {
	*APIError
}

type Logger interface {
	Debug(msg string, keysAndValues ...any)
}

type LoggerFunc func(msg string, keysAndValues ...any)

type NetworkError struct {
	*APIError
}

type NotFoundError struct {
	*APIError
}

type Option func(*Config)

type PayloadTooLargeError struct {
	*APIError
}

type RateLimitError struct {
	*APIError
	// RetryAfter is the duration to wait before retrying.
	RetryAfter time.Duration
	// Limit is the rate limit.
	Limit int
	// Remaining is the remaining requests.
	Remaining int
	// Reset is the time when the rate limit resets.
	Reset time.Time
}

type RetryConfig struct {
	// MaxRetries is the maximum number of retry attempts.
	MaxRetries int
	// BaseDelay is the initial delay before the first retry.
	BaseDelay time.Duration
	// MaxDelay is the maximum delay between retries.
	MaxDelay time.Duration
	// Factor is the exponential backoff multiplier.
	Factor float64
	// Jitter enables randomized jitter on retry delays.
	Jitter bool
}

type ServerError struct {
	*APIError
}

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

type SpooledWorkerOptions struct {
	// QueueName is the name of the queue to process jobs from.
	QueueName string
	// Concurrency is the maximum number of jobs to process concurrently (default: 5).
	Concurrency int
	// PollInterval is how often to poll for new jobs (default: 1s).
	PollInterval time.Duration
	// LeaseDuration is the job lease duration in seconds (default: 30).
	LeaseDuration int
	// Hostname is the worker hostname (default: auto-detected).
	Hostname string
	// WorkerType identifies the type of worker (default: "go").
	WorkerType string
	// Version is the worker version (default: SDK version).
	Version string
	// Metadata contains additional worker metadata.
	Metadata map[string]string
	// contains filtered or unexported fields
}

type TimeoutError struct {
	*APIError
	// TimeoutSeconds is the timeout duration in seconds.
	TimeoutSeconds float64
}

type ValidationError struct {
	*APIError
}