faucet-source-rest 1.6.0

REST API source connector for the faucet-stream ecosystem
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35

#![cfg_attr(docsrs, feature(doc_cfg))]

//! # faucet-source-rest
//!
//! A declarative, config-driven REST API client with pluggable authentication,
//! pagination, schema inference, and incremental replication.

pub mod async_job;
pub mod auth;
pub mod config;
pub mod decode;
pub mod extract;
pub mod format;
pub mod odata;
pub mod pagination;
pub mod retry;
pub mod serde_helpers;
pub mod stream;

// Re-export core types so users don't need a separate faucet-core dependency.
pub use faucet_core::{
    FaucetError, RecordTransform, ReplicationMethod, Sink, Source, WindowBind, WindowSpec,
    replication, schema, transform,
};

pub use async_job::{AsyncJobConfig, JobRequest, JobStatus, PollSpec};
pub use auth::oauth2::DEFAULT_EXPIRY_RATIO;
pub use auth::token_endpoint::DEFAULT_TOKEN_ENDPOINT_EXPIRY_RATIO;
pub use auth::{Auth, ResponseValidator, fetch_oauth2_token, fetch_token_from_endpoint};
pub use config::{
    ODataConfig, ODataVersion, RecordsMultiSpec, ResponseFormat, RestStreamConfig, TlsClientConfig,
};
pub use decode::{DecodeStep, ParseFormat, ParseSpec, SimpleStep, UnzipSpec};
pub use pagination::PaginationStyle;
pub use stream::RestStream;