Struct OpenApiAdapter 

pub struct OpenApiAdapter { /* private fields */ }

OpenAPI 3.x introspection adapter.

Thread-safe and cheaply cloneable — the inner reqwest::Client and the spec cache both use Arc internally. Build once, share across tasks.

Example

use stygian_graph::adapters::openapi::OpenApiAdapter;

let adapter = OpenApiAdapter::new();

Implementations

impl OpenApiAdapter

pub fn new() -> Self

Create a new adapter with default configuration.

Example

use stygian_graph::adapters::openapi::OpenApiAdapter;
let adapter = OpenApiAdapter::new();

pub fn with_config(config: OpenApiConfig) -> Self

Create an adapter with custom configuration.

Panics

Panics only if TLS is unavailable on the host (extremely rare).

Example

use stygian_graph::adapters::openapi::{OpenApiAdapter, OpenApiConfig};
use stygian_graph::adapters::rest_api::RestApiConfig;
use std::time::Duration;

let adapter = OpenApiAdapter::with_config(OpenApiConfig {
    rest: RestApiConfig {
        timeout: Duration::from_secs(10),
        ..Default::default()
    },
});

Trait Implementations

impl Clone for OpenApiAdapter

fn clone(&self) -> OpenApiAdapter

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Default for OpenApiAdapter

fn default() -> Self

Returns the “default value” for a type.

impl ScrapingService for OpenApiAdapter

fn execute<'life0, 'async_trait>( &'life0 self, input: ServiceInput, ) -> Pin<Box<dyn Future<Output = Result<ServiceOutput>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Execute an OpenAPI operation and return the result.

ServiceInput.url

URL of the OpenAPI specification document (.json or .yaml).

ServiceInput.params contract

{
  "operation": "listPets",
  "args": {
    "status":  "available",
    "petId":   42
  },
  "auth": {
    "type":   "api_key_header",
    "header": "api_key",
    "key":    "my-secret"
  },
  "server": {
    "url": "https://override.example.com/v1"
  },
  "rate_limit": {
    "max_requests": 100,
    "window_secs":  60,
    "strategy":     "token_bucket"
  }
}

Rate limiting

Two independent layers operate simultaneously:

1. Proactive — params.rate_limit (optional, token-bucket or sliding-window). Enforced before each request by sleeping until a slot is available.
2. Reactive — inherited from the inner RestApiAdapter. A 429 response with a Retry-After header causes an automatic sleep and retry.

fn name(&self) -> &'static str

Service name for identification in logs and metrics