Skip to content

Ruby API Reference

Ruby API Reference v0.17.0-rc.4

Functions

schema_query_only()

Create a simple schema configuration with only Query type.

This is a convenience function for schemas that only have queries.

Returns:

A QueryOnlyConfig with default settings

Signature:

def self.schema_query_only()

Example:

result = schema_query_only()

Returns: QueryOnlyConfig


schema_query_mutation()

Create a schema configuration with Query and Mutation types.

This is a convenience function for schemas with queries and mutations but no subscriptions.

Returns:

A QueryMutationConfig with default settings

Signature:

def self.schema_query_mutation()

Example:

result = schema_query_mutation()

Returns: QueryMutationConfig


schema_full()

Create a schema configuration with all three root types.

This is a convenience function for fully-featured schemas.

Returns:

A FullSchemaConfig with default settings

Signature:

def self.schema_full()

Example:

result = schema_full()

Returns: FullSchemaConfig


Types

ApiKeyConfig

API Key authentication configuration

Field Type Default Description
keys Array<String> Valid API keys
header_name String serde(default = "default_api_key_header") Header name to check (e.g., "X-API-Key")

AsyncApiConfig

AsyncAPI HTTP endpoint configuration

Field Type Default Description
enabled Boolean Enable AsyncAPI endpoints (default: false)
spec Object? nil Pre-registered AsyncAPI spec to serve from GET /asyncapi.json

BackgroundJobMetadata

Field Type Default Description
name String The name
request_id String? nil Request id
Methods
default()

Signature:

def self.default()

Example:

result = BackgroundJobMetadata.default()

Returns: BackgroundJobMetadata


BackgroundTaskConfig

Configuration for in-process background task execution.

Field Type Default Description
max_queue_size Integer 1024 Maximum queue size
max_concurrent_tasks Integer 128 Maximum concurrent tasks
drain_timeout_secs Integer 30 Drain timeout secs
Methods
default()

Signature:

def self.default()

Example:

result = BackgroundTaskConfig.default()

Returns: BackgroundTaskConfig


CompressionConfig

Compression configuration shared across runtimes

Field Type Default Description
gzip Boolean true Enable gzip compression
brotli Boolean true Enable brotli compression
min_size Integer Minimum response size to compress (bytes)
quality Integer Compression quality (0-11 for brotli, 0-9 for gzip)
Methods
default()

Signature:

def self.default()

Example:

result = CompressionConfig.default()

Returns: CompressionConfig


ContactInfo

Contact information

Field Type Default Description
name String? nil Name of the contact person or organisation.
email String? nil Contact email address.
url String? nil URL pointing to the contact information page.

CorsConfig

CORS configuration for a route

Field Type Default Description
allowed_origins Array<String> \[\] Allowed origins
allowed_methods Array<String> \[\] Allowed methods
allowed_headers Array<String> \[\] Allowed headers
expose_headers Array<String>? nil Expose headers
max_age Integer? nil Maximum age
allow_credentials Boolean? nil Allow credentials
Methods
allowed_methods_joined()

Get the cached joined methods string for preflight responses

Signature:

def allowed_methods_joined()

Example:

result = instance.allowed_methods_joined()

Returns: String

allowed_headers_joined()

Get the cached joined headers string for preflight responses

Signature:

def allowed_headers_joined()

Example:

result = instance.allowed_headers_joined()

Returns: String

is_origin_allowed()

Check if an origin is allowed (O(1) with wildcard, O(n) for exact match)

Signature:

def is_origin_allowed(origin)

Example:

result = instance.is_origin_allowed("value")

Parameters:

Name Type Required Description
origin String Yes The origin

Returns: Boolean

is_method_allowed()

Check if a method is allowed (O(1) with wildcard, O(n) for exact match)

Signature:

def is_method_allowed(method)

Example:

result = instance.is_method_allowed("value")

Parameters:

Name Type Required Description
method String Yes The method

Returns: Boolean

default()

Signature:

def self.default()

Example:

result = CorsConfig.default()

Returns: CorsConfig


DynamicSchemaConfig

Configuration for building and executing a dynamic-SDL schema.

Field Type Default Description
introspection_enabled Boolean Whether introspection queries (__schema, __type) are permitted.
max_complexity Integer? nil Maximum query complexity (nil = unlimited).
max_depth Integer? nil Maximum query depth (nil = unlimited).
field_errors Array<FieldErrorSpec> \[\] Field-level errors to inject at specific response paths.

FieldErrorSpec

A field-level error to inject at a specific response path.

path is the dot-separated sequence of field names from the operation root to the field that should fail, e.g. "user" for a top-level field or "order.customer" for a nested one.

Field Type Default Description
path String Dot-separated path to the field that should error.
message String The error message to surface for that field.

FullSchemaConfig

Configuration for fully-featured schemas with Query, Mutation, and Subscription types

Field Type Default Description
introspection_enabled Boolean true Enable introspection queries
complexity_limit Integer? nil Maximum query complexity (None = unlimited)
depth_limit Integer? nil Maximum query depth (None = unlimited)
Methods
default()

Signature:

def self.default()

Example:

result = FullSchemaConfig.default()

Returns: FullSchemaConfig


GraphQlRouteConfig

Configuration for GraphQL routes

Provides a builder pattern for configuring GraphQL route parameters for the Spikard HTTP server's routing system.

Methods
new()

Create a new GraphQL route configuration with defaults

Default values:

  • path: "/graphql"
  • method: "POST"
  • enable_playground: false

Signature:

def self.new()

Example:

result = GraphQlRouteConfig.new()

Returns: GraphQlRouteConfig

path()

Set the HTTP path for the GraphQL endpoint

Signature:

def path(path)

Example:

result = instance.path("value")

Parameters:

Name Type Required Description
path String Yes The URL path (e.g., "/graphql", "/api/graphql")

Returns: GraphQlRouteConfig

method()

Set the HTTP method for the GraphQL endpoint

Signature:

def method(method)

Example:

result = instance.method("value")

Parameters:

Name Type Required Description
method String Yes The HTTP method (typically "POST")

Returns: GraphQlRouteConfig

enable_playground()

Enable or disable the GraphQL Playground UI

Signature:

def enable_playground(enable)

Example:

result = instance.enable_playground(true)

Parameters:

Name Type Required Description
enable Boolean Yes Whether to enable playground

Returns: GraphQlRouteConfig

description()

Set a custom description for documentation

Signature:

def description(description)

Example:

result = instance.description("value")

Parameters:

Name Type Required Description
description String Yes Documentation string

Returns: GraphQlRouteConfig

get_path()

Get the configured path

Signature:

def get_path()

Example:

result = instance.get_path()

Returns: String

get_method()

Get the configured method

Signature:

def get_method()

Example:

result = instance.get_method()

Returns: String

is_playground_enabled()

Check if playground is enabled

Signature:

def is_playground_enabled()

Example:

result = instance.is_playground_enabled()

Returns: Boolean

get_description()

Get the description if set

Signature:

def get_description()

Example:

result = instance.get_description()

Returns: String?

default()

Signature:

def self.default()

Example:

result = GraphQlRouteConfig.default()

Returns: GraphQlRouteConfig


GraphQlSubscriptionSnapshot

Snapshot of a GraphQL subscription exchange over WebSocket.

Field Type Default Description
operation_id String Operation id used for the subscription request.
acknowledged Boolean Whether the server acknowledged the GraphQL WebSocket connection.
event Object? nil First next.payload received for this subscription, if any.
errors Array<Object> GraphQL protocol errors emitted by the server.
complete_received Boolean Whether a complete frame was observed for this operation.

GrpcConfig

Configuration for gRPC support

Controls how the server handles gRPC requests, including compression, timeouts, and protocol settings.

Stream Limits

This configuration enforces message-level size limits but delegates concurrent stream limiting to the HTTP/2 transport layer:

  • Message Size Limits: The max_message_size field is enforced per individual message (request or response) in both unary and streaming RPCs. When a single message exceeds this limit, the request is rejected with PAYLOAD_TOO_LARGE (HTTP 413).

  • Concurrent Stream Limits: The max_concurrent_streams is an advisory configuration passed to the HTTP/2 layer for connection-level stream negotiation. The HTTP/2 transport automatically enforces this limit and returns GOAWAY frames when exceeded. Applications should not rely on custom enforcement of this limit.

  • Stream Response Size Limits: The max_stream_response_bytes field caps the total encoded bytes emitted across a server-streaming or bidi-streaming response. When the cumulative size exceeds the limit, the stream is terminated with tonic.Status.resource_exhausted. Defaults to nil (unbounded).

Field Type Default Description
enabled Boolean true Enable gRPC support
max_message_size Integer Maximum message size in bytes (for both sending and receiving) This limit applies to individual messages in both unary and streaming RPCs. When a single message exceeds this size, the request is rejected with HTTP 413 (Payload Too Large). Default: 4MB (4194304 bytes) Note: This limit does NOT apply to the total response size in streaming RPCs. For multi-message streams, the total response can exceed this limit as long as each individual message stays within the limit.
enable_compression Boolean true Enable gzip compression for gRPC messages
request_timeout Integer? nil Timeout for gRPC requests in seconds (None = no timeout)
max_concurrent_streams Integer Maximum number of concurrent streams per connection (HTTP/2 advisory) This value is communicated to HTTP/2 clients as the server's flow control limit. The HTTP/2 transport layer enforces this limit automatically via SETTINGS frames and GOAWAY responses. Applications should NOT implement custom enforcement. Default: 100 streams per connection # Stream Limiting Strategy - Per Connection: This limit applies per HTTP/2 connection, not globally - Transport Enforcement: HTTP/2 handles all stream limiting; applications need not implement custom checks - Streaming Requests: In server streaming or bidi streaming, each logical RPC consumes one stream slot. Message ordering within a stream follows HTTP/2 frame ordering.
enable_keepalive Boolean true Enable HTTP/2 keepalive
keepalive_interval Integer HTTP/2 keepalive interval in seconds
keepalive_timeout Integer HTTP/2 keepalive timeout in seconds
max_stream_response_bytes Integer? nil Total byte cap across an entire streaming response. When Some(n), the streaming adapter aborts the stream with tonic.Status.resource_exhausted once the cumulative encoded message bytes exceed n. The stream yields the error item and then terminates. Per-message cap remains max_message_size. This limit applies to server-streaming and bidirectional-streaming RPCs only; unary RPCs are governed solely by max_message_size. Default: nil (unbounded total response size).
Methods
default()

Signature:

def self.default()

Example:

result = GrpcConfig.default()

Returns: GrpcConfig


IntoHandler

Convert user-facing handler functions into the low-level Handler trait.

Methods
into_handler()

Convert this value into a shared request handler.

Signature:

def into_handler()

Example:

result = instance.into_handler()

Returns: Handler


JsonRpcConfig

JSON-RPC server configuration

Field Type Default Description
enabled Boolean true Enable JSON-RPC endpoint
endpoint_path String HTTP endpoint path for JSON-RPC requests (default: "/rpc")
enable_batch Boolean Enable batch request processing (default: true)
max_batch_size Integer Maximum number of requests in a batch (default: 100)
Methods
default()

Signature:

def self.default()

Example:

result = JsonRpcConfig.default()

Returns: JsonRpcConfig


JsonRpcMethodInfo

JSON-RPC method metadata for routes that support JSON-RPC

This struct captures the metadata needed to expose HTTP routes as JSON-RPC methods, enabling discovery and documentation of RPC-compatible endpoints.

Field Type Default Description
method_name String The JSON-RPC method name (e.g., "user.create")
description String? nil Optional description of what the method does
params_schema Object? nil Optional JSON Schema for method parameters
result_schema Object? nil Optional JSON Schema for the result
deprecated Boolean /* serde(default) */ Whether this method is deprecated
tags Array<String> /* serde(default) */ Tags for categorizing and grouping methods

JwtConfig

JWT authentication configuration

Field Type Default Description
secret String Secret key for JWT verification
algorithm String serde(default = "default_jwt_algorithm") Required algorithm (HS256, HS384, HS512, RS256, etc.)
audience Array<String>? nil Required audience claim
issuer String? nil Required issuer claim
leeway Integer /* serde(default) */ Leeway for expiration checks (seconds)

LicenseInfo

License information

Field Type Default Description
name String SPDX license identifier or display name (e.g. "MIT").
url String? nil URL to the full license text.

OpenApiConfig

OpenAPI configuration

Field Type Default Description
enabled Boolean false Enable OpenAPI generation (default: false for zero overhead)
title String "API" API title
version String "1.0.0" API version
description String? nil API description (supports markdown)
swagger_ui_path String Path to serve Swagger UI (default: "/docs")
redoc_path String Path to serve Redoc (default: "/redoc")
openapi_json_path String Path to serve OpenAPI JSON spec (default: "/openapi.json")
contact ContactInfo? nil Contact information
license LicenseInfo? nil License information
servers Array<ServerInfo> \[\] Server definitions
security_schemes Hash{String=>SecuritySchemeInfo} {} Security schemes (auto-detected from middleware if not provided)
Methods
default()

Signature:

def self.default()

Example:

result = OpenApiConfig.default()

Returns: OpenApiConfig


ParseRequest

Request body for POST /asyncapi/parse

Field Type Default Description
spec Object Spec

ParseResult

Full parse result returned by POST /asyncapi/parse

Field Type Default Description
spec_version String Spec version
title String Title
api_version String Api version
channels Array<ParsedChannel> Channels
operations Array<ParsedOperation> Operations
messages Array<ParsedMessage> Messages

ParsedChannel

A single channel extracted from an AsyncAPI spec

Field Type Default Description
name String Channel key from the spec (e.g. "chat/messages")
address String Channel address / path
messages Array<String> Message names declared on this channel
bindings Object? nil Bindings (ws / http / amqp / …) as raw JSON for forward-compatibility

ParsedMessage

A resolved message (name + JSON Schema)

Field Type Default Description
name String Message name
schema Object? nil Resolved JSON Schema for the message payload, if available

ParsedOperation

A single operation extracted from an AsyncAPI spec

Field Type Default Description
name String Operation name
action String Operation action: "send" or "receive"
channel String Channel reference (resolved to the channel name)

ProblemDetails

RFC 9457 Problem Details for HTTP APIs

A machine-readable format for specifying errors in HTTP API responses. Per RFC 9457, all fields are optional. The type field defaults to "about:blank" if not specified.

Content-Type

Responses using this struct should set:

Content-Type: application/problem+json
{
  "type": "<https://spikard.dev/errors/validation-error",>
  "title": "Request Validation Failed",
  "status": 422,
  "detail": "2 validation errors in request body",
  "errors": [...]
}
Field Type Default Description
type_uri String A URI reference that identifies the problem type. Defaults to "about:blank" when absent. Should be a stable, human-readable identifier for the problem type.
title String A short, human-readable summary of the problem type. Should not change from occurrence to occurrence of the problem.
status Integer The HTTP status code generated by the origin server. This is advisory; the actual HTTP status code takes precedence.
detail String? nil A human-readable explanation specific to this occurrence of the problem.
instance String? nil A URI reference that identifies the specific occurrence of the problem. It may or may not yield further information if dereferenced.
extensions Hash{String=>Object} Extension members - problem-type-specific data. For validation errors, this typically contains an "errors" array.
Methods
with_detail()

Set the detail field

Signature:

def with_detail(detail)

Example:

result = instance.with_detail("value")

Parameters:

Name Type Required Description
detail String Yes The detail

Returns: ProblemDetails

with_instance()

Set the instance field

Signature:

def with_instance(instance)

Example:

result = instance.with_instance("value")

Parameters:

Name Type Required Description
instance String Yes The instance

Returns: ProblemDetails

not_found()

Create a not found error

Signature:

def self.not_found(detail)

Example:

result = ProblemDetails.not_found("value")

Parameters:

Name Type Required Description
detail String Yes The detail

Returns: ProblemDetails

method_not_allowed()

Create a method not allowed error

Signature:

def self.method_not_allowed(detail)

Example:

result = ProblemDetails.method_not_allowed("value")

Parameters:

Name Type Required Description
detail String Yes The detail

Returns: ProblemDetails

internal_server_error()

Create an internal server error

Signature:

def self.internal_server_error(detail)

Example:

result = ProblemDetails.internal_server_error("value")

Parameters:

Name Type Required Description
detail String Yes The detail

Returns: ProblemDetails

bad_request()

Create a bad request error

Signature:

def self.bad_request(detail)

Example:

result = ProblemDetails.bad_request("value")

Parameters:

Name Type Required Description
detail String Yes The detail

Returns: ProblemDetails

to_json()

Serialize to JSON string

Errors: Returns an error if the serialization fails.

Signature:

def to_json()

Example:

result = instance.to_json()

Returns: String

Errors: Raises Error.

to_json_pretty()

Serialize to pretty JSON string

Errors: Returns an error if the serialization fails.

Signature:

def to_json_pretty()

Example:

result = instance.to_json_pretty()

Returns: String

Errors: Raises Error.


QueryMutationConfig

Configuration for schemas with Query and Mutation types

Field Type Default Description
introspection_enabled Boolean true Enable introspection queries
complexity_limit Integer? nil Maximum query complexity (None = unlimited)
depth_limit Integer? nil Maximum query depth (None = unlimited)
Methods
default()

Signature:

def self.default()

Example:

result = QueryMutationConfig.default()

Returns: QueryMutationConfig


QueryOnlyConfig

Configuration for schemas with only Query type

Field Type Default Description
introspection_enabled Boolean true Enable introspection queries
complexity_limit Integer? nil Maximum query complexity (None = unlimited)
depth_limit Integer? nil Maximum query depth (None = unlimited)
Methods
default()

Signature:

def self.default()

Example:

result = QueryOnlyConfig.default()

Returns: QueryOnlyConfig


RateLimitConfig

Rate limiting configuration shared across runtimes

Field Type Default Description
per_second Integer 100 Requests per second
burst Integer 200 Burst allowance
ip_based Boolean true Use IP-based rate limiting
Methods
default()

Signature:

def self.default()

Example:

result = RateLimitConfig.default()

Returns: RateLimitConfig


Response

HTTP Response with custom status code, headers, and content

Field Type Default Description
content Object? nil Response body content
status_code Integer HTTP status code (defaults to 200)
headers Hash{String=>String} {} Response headers
Methods
set_header()

Set a header

Signature:

def set_header(key, value)

Example:

instance.set_header("value", "value")

Parameters:

Name Type Required Description
key String Yes The key
value String Yes The value

Returns: No return value.

Set a cookie in the response

Signature:

def set_cookie(key, value, secure, http_only, max_age, domain, path, same_site)

Example:

instance.set_cookie("value", "value", true, true, max_age: 42, domain: "value", path: "value", same_site: "value")

Parameters:

Name Type Required Description
key String Yes The key
value String Yes The value
secure Boolean Yes The secure
http_only Boolean Yes The http only
max_age Integer? No The max age
domain String? No The domain
path String? No Path to the file
same_site String? No The same site

Returns: No return value.

default()

Signature:

def self.default()

Example:

result = Response.default()

Returns: Response


ResponseSnapshot

Snapshot of an Axum response used by higher-level language bindings.

Field Type Default Description
status Integer HTTP status code.
headers Hash{String=>String} Response headers (lowercase keys for predictable lookups).
body String Response body bytes (decoded for supported encodings).
Methods
text()

Return response body as UTF-8 string.

Signature:

def text()

Example:

result = instance.text()

Returns: String

Errors: Raises FromUtf8Error.

Lookup header by case-insensitive name.

Signature:

def header(name)

Example:

result = instance.header("value")

Parameters:

Name Type Required Description
name String Yes The name

Returns: String?


RouteBuilder

Builder for defining a route.

Methods
new()

Create a new builder for the provided HTTP method and path.

Signature:

def self.new(method, path)

Example:

result = RouteBuilder.new(Method.new, "value")

Parameters:

Name Type Required Description
method Method Yes The method
path String Yes Path to the file

Returns: RouteBuilder

handler_name()

Assign an explicit handler name.

Signature:

def handler_name(name)

Example:

result = instance.handler_name("value")

Parameters:

Name Type Required Description
name String Yes The name

Returns: RouteBuilder

request_schema_json()

Provide a raw JSON schema for the request body.

Signature:

def request_schema_json(schema)

Example:

result = instance.request_schema_json([])

Parameters:

Name Type Required Description
schema Object Yes The schema

Returns: RouteBuilder

response_schema_json()

Provide a raw JSON schema for the response body.

Signature:

def response_schema_json(schema)

Example:

result = instance.response_schema_json([])

Parameters:

Name Type Required Description
schema Object Yes The schema

Returns: RouteBuilder

params_schema_json()

Provide a raw JSON schema for request parameters.

Signature:

def params_schema_json(schema)

Example:

result = instance.params_schema_json([])

Parameters:

Name Type Required Description
schema Object Yes The schema

Returns: RouteBuilder

file_params_json()

Provide multipart file parameter configuration.

Signature:

def file_params_json(schema)

Example:

result = instance.file_params_json([])

Parameters:

Name Type Required Description
schema Object Yes The schema

Returns: RouteBuilder

cors()

Attach a CORS configuration for this route.

Signature:

def cors(cors)

Example:

result = instance.cors(CorsConfig.new)

Parameters:

Name Type Required Description
cors CorsConfig Yes The cors config

Returns: RouteBuilder

compression()

Attach a compression configuration for this route.

Signature:

def compression(compression)

Example:

result = instance.compression(CompressionConfig.new)

Parameters:

Name Type Required Description
compression CompressionConfig Yes The compression config

Returns: RouteBuilder

body_limit()

Attach a per-route maximum request body size in bytes, overriding the server-global default.

Signature:

def body_limit(max_bytes)

Example:

result = instance.body_limit(42)

Parameters:

Name Type Required Description
max_bytes Integer Yes The max bytes

Returns: RouteBuilder

request_timeout()

Attach a per-route request timeout in seconds, overriding the server-global default.

Signature:

def request_timeout(seconds)

Example:

result = instance.request_timeout(42)

Parameters:

Name Type Required Description
seconds Integer Yes The seconds

Returns: RouteBuilder

sync()

Mark the route as synchronous.

Signature:

def sync()

Example:

result = instance.sync()

Returns: RouteBuilder

handler_dependencies()

Declare the dependency keys that must be resolved before this handler runs.

Signature:

def handler_dependencies(dependencies)

Example:

result = instance.handler_dependencies([])

Parameters:

Name Type Required Description
dependencies Array<String> Yes The dependencies

Returns: RouteBuilder


SchemaConfig

Configuration for GraphQL schema building.

Encapsulates all schema-level configuration options including introspection control, complexity limits, and depth limits.

Field Type Default Description
introspection_enabled Boolean true Enable introspection queries
complexity_limit Integer? nil Maximum query complexity (None = unlimited)
depth_limit Integer? nil Maximum query depth (None = unlimited)
Methods
default()

Signature:

def self.default()

Example:

result = SchemaConfig.default()

Returns: SchemaConfig


ServerConfig

Server configuration

Field Type Default Description
host String "127.0.0.1" Host to bind to
port Integer 8000 Port to bind to
workers Integer 1 Number of Tokio runtime worker threads used by binding-managed server runtimes
enable_request_id Boolean false Enable request ID generation and propagation
max_body_size Integer? 10485760 Maximum request body size in bytes (None = unlimited, not recommended)
request_timeout Integer? nil Request timeout in seconds (None = no timeout)
compression CompressionConfig? nil Enable compression middleware
rate_limit RateLimitConfig? nil Enable rate limiting
jwt_auth JwtConfig? nil JWT authentication configuration
api_key_auth ApiKeyConfig? nil API Key authentication configuration
static_files Array<StaticFilesConfig> \[\] Static file serving configuration
graceful_shutdown Boolean true Enable graceful shutdown on SIGTERM/SIGINT
shutdown_timeout Integer 30 Graceful shutdown timeout (seconds)
asyncapi AsyncApiConfig? nil AsyncAPI HTTP endpoint configuration
openapi OpenApiConfig? nil OpenAPI documentation configuration
jsonrpc JsonRpcConfig? nil JSON-RPC configuration
grpc GrpcConfig? nil gRPC configuration
background_tasks BackgroundTaskConfig Background task executor configuration
enable_http_trace Boolean false Enable per-request HTTP tracing (tower-http TraceLayer)
Methods
default()

Signature:

def self.default()

Example:

result = ServerConfig.default()

Returns: ServerConfig


ServerInfo

Server information

Field Type Default Description
url String Base URL of the server (e.g. "<https://api.example.com/v1">).
description String? nil Optional human-readable description of the server environment.

SseEvent

An individual SSE event

Represents a single Server-Sent Event to be sent to a connected client. Events can have an optional type, ID, and retry timeout for advanced scenarios.

SSE Format

Events are serialized to the following text format:

event: event_type
data: {"json":"value"}
id: event-123
retry: 3000
Field Type Default Description
event_type String? nil Event type (optional)
data Object Event data (JSON value)
id String? nil Event ID (optional, for client-side reconnection)
retry Integer? nil Retry timeout in milliseconds (optional)
Methods
with_id()

Set the event ID for client-side reconnection support

Sets an ID that clients can use to resume from this point if they disconnect. The client sends this ID back in the Last-Event-ID header when reconnecting.

Signature:

def with_id(id)

Example:

result = instance.with_id("value")

Parameters:

Name Type Required Description
id String Yes Unique identifier for this event

Returns: SseEvent

with_retry()

Set the retry timeout for client reconnection

Sets the time in milliseconds clients should wait before attempting to reconnect if the connection is lost. The client browser will automatically handle reconnection.

Signature:

def with_retry(retry_ms)

Example:

result = instance.with_retry(42)

Parameters:

Name Type Required Description
retry_ms Integer Yes Retry timeout in milliseconds

Returns: SseEvent


StaticFilesConfig

Static file serving configuration

Field Type Default Description
directory String Directory path to serve
route_prefix String URL path prefix (e.g., "/static")
index_file Boolean serde(default = "default_true") Fallback to index.html for directories
cache_control String? nil Cache-Control header value

TestClient

Core test client for making HTTP requests to a Spikard application.

This struct wraps axum-test's TestServer and provides a language-agnostic interface for making HTTP requests, sending WebSocket connections, and handling Server-Sent Events. Language bindings wrap this to provide native API surfaces.

Methods
graphql_at()

Send a GraphQL query/mutation to a custom endpoint

Signature:

def graphql_at(endpoint, query, variables, operation_name)

Example:

result = instance.graphql_at("value", "value", variables: [], operation_name: "value")

Parameters:

Name Type Required Description
endpoint String Yes The endpoint
query String Yes The query
variables Object? No The variables
operation_name String? No The operation name

Returns: ResponseSnapshot

Errors: Raises SnapshotError.

graphql()

Send a GraphQL query/mutation

Signature:

def graphql(query, variables, operation_name)

Example:

result = instance.graphql("value", variables: [], operation_name: "value")

Parameters:

Name Type Required Description
query String Yes The query
variables Object? No The variables
operation_name String? No The operation name

Returns: ResponseSnapshot

Errors: Raises SnapshotError.

graphql_subscription_at()

Send a GraphQL subscription (WebSocket) to a custom endpoint.

Uses the graphql-transport-ws protocol and captures the first next payload. After the first payload is received, this client sends complete to unsubscribe.

Signature:

def graphql_subscription_at(endpoint, query, variables, operation_name)

Example:

result = instance.graphql_subscription_at("value", "value", variables: [], operation_name: "value")

Parameters:

Name Type Required Description
endpoint String Yes The endpoint
query String Yes The query
variables Object? No The variables
operation_name String? No The operation name

Returns: GraphQlSubscriptionSnapshot

Errors: Raises SnapshotError.

graphql_subscription()

Send a GraphQL subscription (WebSocket).

Uses /graphql as the default subscription endpoint.

Signature:

def graphql_subscription(query, variables, operation_name)

Example:

result = instance.graphql_subscription("value", variables: [], operation_name: "value")

Parameters:

Name Type Required Description
query String Yes The query
variables Object? No The variables
operation_name String? No The operation name

Returns: GraphQlSubscriptionSnapshot

Errors: Raises SnapshotError.


TestingSseEvent

A single Server-Sent Event.

Field Type Default Description
data String The data field of the event.

UploadFile

Represents an uploaded file from multipart/form-data requests.

This struct provides efficient access to file content with automatic base64 decoding and implements standard I/O traits for compatibility.

Field Type Default Description
filename String Original filename from the client
content_type String? nil MIME type of the uploaded file
size Integer? nil Size of the file in bytes
content String File content (may be base64 encoded)
content_encoding String? nil Content encoding type
Methods
as_bytes()

Get the raw file content as bytes.

This provides zero-copy access to the underlying buffer.

Signature:

def as_bytes()

Example:

result = instance.as_bytes()

Returns: String

read_to_string()

Read the file content as a UTF-8 string.

Errors:

Returns an error if the content is not valid UTF-8.

Signature:

def read_to_string()

Example:

result = instance.read_to_string()

Returns: String

Errors: Raises Error.

content_type_or_default()

Get the content type, defaulting to "application/octet-stream".

Signature:

def content_type_or_default()

Example:

result = instance.content_type_or_default()

Returns: String


ValidateRequest

Request body for POST /asyncapi/validate

Field Type Default Description
spec Object Spec
channel String Channel
message String Message
payload Object Payload

ValidationResponse

Response body for POST /asyncapi/validate

Field Type Default Description
valid Boolean Valid
errors Array<String> Errors

Enums

Method

HTTP method

Value Description
get Get
post Post
put Put
patch Patch
delete Delete
head Head
options Options
connect Connect
trace Trace

SecuritySchemeInfo

Security scheme types

Value Description
http Http — Fields: scheme: String, bearer_format: String
api_key Api key — Fields: location: String, name: String

SnapshotError

Possible errors while converting an Axum response into a snapshot.

Value Description
invalid_header Response header could not be decoded to UTF-8. — Fields: 0: String
decompression Body decompression failed. — Fields: 0: String

WebSocketMessage

A WebSocket message that can be text or binary.

Value Description
text A text message. — Fields: 0: String
binary A binary message. — Fields: 0: String
close A close message with a numeric close code (RFC 6455) and optional reason text. Common codes: 1000 Normal Closure, 1001 Going Away, 1005 No Status Received, 1006 Abnormal Closure. — Fields: code: Integer, reason: String
ping A ping message. — Fields: 0: String
pong A pong message. — Fields: 0: String

Errors

AppError

Error type for application builder operations.

Variant Description
route Route registration failed.
server Server/router construction failed.
decode Failed to extract DTO from the request context.
graph_ql GraphQL route registration failed (e.g. an unrecognized schema_type).

GraphQlError

Errors that can occur during GraphQL operations

These errors are compatible with async-graphql error handling and can be converted to structured HTTP responses matching the project's error fixtures.

Variant Description
execution_error Error during schema execution Occurs when the GraphQL executor encounters a runtime error during query execution.
schema_build_error Error during schema building Occurs when schema construction fails due to invalid definitions or conflicts.
request_handling_error Error during request handling Occurs when the HTTP request cannot be properly handled or parsed.
serialization_error Serialization error Occurs during JSON serialization/deserialization of GraphQL values.
json_error JSON parsing error Occurs when JSON input cannot be parsed.
validation_error GraphQL validation error Occurs when a GraphQL query fails schema validation.
parse_error GraphQL parse error Occurs when the GraphQL query string cannot be parsed.
authentication_error Authentication error Occurs when request authentication fails.
authorization_error Authorization error Occurs when user lacks required permissions.
not_found Not found error Occurs when a requested resource is not found.
rate_limit_exceeded Rate limit error Occurs when rate limit is exceeded.
invalid_input Invalid input error with validation details Occurs during input validation with detailed error information.
complexity_limit_exceeded Query complexity limit exceeded Occurs when a GraphQL query exceeds the configured complexity limit.
depth_limit_exceeded Query depth limit exceeded Occurs when a GraphQL query exceeds the configured depth limit.
introspection_disabled Introspection query rejected because introspection is disabled Occurs when a query selects __schema or __type while the schema was configured with introspection disabled.
internal_error Internal server error Occurs when an unexpected internal error happens.

SchemaError

Error type for schema building operations

Variant Description
building_failed Generic schema building error
validation_error Configuration validation error
complexity_limit_exceeded Complexity limit exceeded
depth_limit_exceeded Depth limit exceeded

Edit this page on GitHub