Crate faucet_source_rest 

faucet-source-rest

A declarative, config-driven REST API client with pluggable authentication, pagination, record transforms, schema inference, and incremental replication.

Re-exports

pub use auth::oauth2::DEFAULT_EXPIRY_RATIO;

pub use auth::token_endpoint::DEFAULT_TOKEN_ENDPOINT_EXPIRY_RATIO;

pub use auth::Auth;

pub use auth::ResponseValidator;

pub use auth::fetch_oauth2_token;

pub use auth::fetch_token_from_endpoint;

pub use config::RestStreamConfig;

pub use pagination::PaginationStyle;

pub use stream::RestStream;

Modules

auth

Authentication strategies for REST APIs.

config

Stream configuration and builder.

extract

Record extraction from API responses.

pagination

Pagination strategies for REST APIs.

replication

Incremental replication support.

retry

Retry logic with exponential backoff.

schema

JSON Schema inference from record samples.

serde_helpers

Serde helper modules for types that don’t implement Serialize/Deserialize natively.

stream

The main REST stream executor.

transform

Record transformation pipeline.

Enums

FaucetError

All possible errors returned by faucet-stream.

RecordTransform

A transformation applied to every record fetched by a [crate::stream::RestStream].

ReplicationMethod

Determines how records are replicated from the source.

Traits

Sink

A sink writes records to an external system.

Source

A source fetches records from an external system.