Skip to main content

RestStreamConfig

Struct RestStreamConfig 

Source
pub struct RestStreamConfig {
Show 25 fields pub base_url: String, pub path: String, pub method: Method, pub auth: AuthSpec<Auth>, pub headers: HeaderMap, pub query_params: HashMap<String, String>, pub body: Option<Value>, pub pagination: PaginationStyle, pub records_path: Option<String>, pub max_pages: Option<usize>, pub request_delay: Option<Duration>, pub timeout: Option<Duration>, pub max_retries: u32, pub retry_backoff: Duration, pub tolerated_http_errors: Vec<u16>, pub replication_method: ReplicationMethod, pub replication_key: Option<String>, pub start_replication_value: Option<Value>, pub state_key: Option<String>, pub name: Option<String>, pub primary_keys: Vec<String>, pub schema: Option<Value>, pub schema_sample_size: usize, pub partitions: Vec<HashMap<String, Value>>, pub partition_concurrency: Option<usize>,
}
Expand description

Configuration for a RestStream.

Fields§

§base_url: String§path: String

URL path, relative to base_url. May contain {key} placeholders that are substituted per-partition (e.g. "/orgs/{org_id}/users").

§method: Method§auth: AuthSpec<Auth>

Authentication: either inline ({ type, config }) or a { ref: <name> } pointer to a shared provider in the CLI’s top-level auth: catalog.

§headers: HeaderMap§query_params: HashMap<String, String>§body: Option<Value>§pagination: PaginationStyle§records_path: Option<String>§max_pages: Option<usize>§request_delay: Option<Duration>§timeout: Option<Duration>§max_retries: u32§retry_backoff: Duration§tolerated_http_errors: Vec<u16>

HTTP status codes that should not cause an error. Responses with these codes are treated as empty pages (no records, no further pages).

§replication_method: ReplicationMethod§replication_key: Option<String>

Field name (not a JSONPath) used for incremental replication bookmarking.

§start_replication_value: Option<Value>

Bookmark value: records where record[replication_key] <= start_replication_value are filtered out when replication_method is Incremental.

§state_key: Option<String>

Opt-in identifier used by Pipeline::with_state_store to persist this stream’s bookmark across runs. When set, the pipeline will load any previously-stored bookmark before fetching and write the new bookmark only after the sink confirms the batch.

Keys must satisfy faucet_core::state::validate_state_key.

§name: Option<String>

Human-readable stream name (used in logging and Singer SCHEMA messages).

§primary_keys: Vec<String>

Field names that uniquely identify a record (Singer key_properties).

§schema: Option<Value>

JSON Schema describing the structure of each record.

§schema_sample_size: usize

Maximum number of records to sample when inferring the schema via crate::stream::RestStream::infer_schema. 0 means sample all available records (up to max_pages). Defaults to 100.

§partitions: Vec<HashMap<String, Value>>

Each entry is a context map whose values are substituted into path placeholders. The stream is executed once per partition and results are concatenated. Empty means run once with no substitution.

§partition_concurrency: Option<usize>

Maximum number of partitions to fetch concurrently. None means sequential processing (backward compatible default).

Implementations§

Source§

impl RestStreamConfig

Source

pub fn new(base_url: &str, path: &str) -> Self

Source

pub fn method(self, m: Method) -> Self

Source

pub fn auth(self, a: Auth) -> Self

Source

pub fn header(self, k: &str, v: &str) -> Self

Source

pub fn query(self, k: &str, v: &str) -> Self

Source

pub fn body(self, b: Value) -> Self

Source

pub fn pagination(self, p: PaginationStyle) -> Self

Source

pub fn records_path(self, p: &str) -> Self

Source

pub fn max_pages(self, n: usize) -> Self

Source

pub fn request_delay(self, d: Duration) -> Self

Source

pub fn timeout(self, d: Duration) -> Self

Source

pub fn max_retries(self, n: u32) -> Self

Source

pub fn retry_backoff(self, d: Duration) -> Self

Source

pub fn tolerate_http_error(self, status: u16) -> Self

HTTP status codes that should be silently ignored (treated as empty pages).

Source

pub fn replication_method(self, m: ReplicationMethod) -> Self

Source

pub fn replication_key(self, key: &str) -> Self

Field name (not JSONPath) used as the incremental replication bookmark.

Source

pub fn start_replication_value(self, v: Value) -> Self

Bookmark start value: records at or before this value are filtered out when using ReplicationMethod::Incremental.

Source

pub fn state_key(self, key: &str) -> Self

Opt the stream into resumable runs by giving it a stable state key. When this is set and the Pipeline is configured with a state store, the previously persisted bookmark is applied to the stream before fetching.

Source

pub fn name(self, n: &str) -> Self

Human-readable stream name.

Source

pub fn primary_keys(self, keys: Vec<String>) -> Self

Field names that uniquely identify a record (Singer key_properties).

Source

pub fn schema(self, s: Value) -> Self

JSON Schema for the stream’s records.

Source

pub fn schema_sample_size(self, n: usize) -> Self

Maximum records to sample for schema inference (0 = unlimited).

Source

pub fn add_partition(self, ctx: HashMap<String, Value>) -> Self

Add a partition context. The stream will execute once for each partition, substituting {key} placeholders in path with values from the context.

Source

pub fn partition_concurrency(self, concurrency: Option<usize>) -> Self

Set the maximum number of partitions to fetch concurrently. None (default) means sequential processing.

Trait Implementations§

Source§

impl Clone for RestStreamConfig

Source§

fn clone(&self) -> RestStreamConfig

Returns a duplicate of the value. Read more
1.0.0 (const: unstable) · Source§

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

Performs copy-assignment from source. Read more
Source§

impl Debug for RestStreamConfig

Source§

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter. Read more
Source§

impl Default for RestStreamConfig

Source§

fn default() -> Self

Returns the “default value” for a type. Read more
Source§

impl<'de> Deserialize<'de> for RestStreamConfig

Source§

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>
where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer. Read more
Source§

impl JsonSchema for RestStreamConfig

Source§

fn schema_name() -> Cow<'static, str>

The name of the generated JSON Schema. Read more
Source§

fn schema_id() -> Cow<'static, str>

Returns a string that uniquely identifies the schema produced by this type. Read more
Source§

fn json_schema(generator: &mut SchemaGenerator) -> Schema

Generates a JSON Schema for this type. Read more
Source§

fn inline_schema() -> bool

Whether JSON Schemas generated for this type should be included directly in parent schemas, rather than being re-used where possible using the $ref keyword. Read more
Source§

impl Serialize for RestStreamConfig

Source§

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>
where __S: Serializer,

Serialize this value into the given Serde serializer. Read more

Auto Trait Implementations§

Blanket Implementations§

Source§

impl<T> Any for T
where T: 'static + ?Sized,

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

impl<T> Borrow<T> for T
where T: ?Sized,

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

Source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
Source§

impl<T> CloneToUninit for T
where T: Clone,

Source§

unsafe fn clone_to_uninit(&self, dest: *mut u8)

🔬This is a nightly-only experimental API. (clone_to_uninit)
Performs copy-assignment from self to dest. Read more
Source§

impl<T> DynClone for T
where T: Clone,

Source§

fn __clone_box(&self, _: Private) -> *mut ()

Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

Source§

impl<T> Instrument for T

Source§

fn instrument(self, span: Span) -> Instrumented<Self>

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more
Source§

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more
Source§

impl<T, U> Into<U> for T
where U: From<T>,

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

impl<T> PolicyExt for T
where T: ?Sized,

Source§

fn and<P, B, E>(self, other: P) -> And<T, P>
where T: Policy<B, E>, P: Policy<B, E>,

Create a new Policy that returns Action::Follow only if self and other return Action::Follow. Read more
Source§

fn or<P, B, E>(self, other: P) -> Or<T, P>
where T: Policy<B, E>, P: Policy<B, E>,

Create a new Policy that returns Action::Follow if either self or other returns Action::Follow. Read more
Source§

impl<T> ToOwned for T
where T: Clone,

Source§

type Owned = T

The resulting type after obtaining ownership.
Source§

fn to_owned(&self) -> T

Creates owned data from borrowed data, usually by cloning. Read more
Source§

fn clone_into(&self, target: &mut T)

Uses borrowed data to replace owned data, usually by cloning. Read more
Source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

Source§

type Error = Infallible

The type returned in the event of a conversion error.
Source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
Source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

Source§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
Source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.
Source§

impl<T> WithSubscriber for T

Source§

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more
Source§

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more
Source§

impl<T> DeserializeOwned for T
where T: for<'de> Deserialize<'de>,