Struct HttpSinkDriver 

pub struct HttpSinkDriver<D> { /* private fields */ }

An HttpDriver as a SinkDriver.

Per record: the whole-page write stops at the first failed request; the per-row write sends every record and reports each. As arrays: requests go out in order; the whole-page write stops at the first failure, and the per-row write reports the rows of every request after a delivered one as failed, so a delivered row is never reported failed — and a page none of whose requests was delivered fails as a whole.

Implementations

impl<D: HttpDriver> HttpSinkDriver<D>

pub fn new(driver: D) -> Self

The sink driver over driver.

pub fn driver(&self) -> &D

The HTTP driver.

pub fn driver_mut(&mut self) -> &mut D

The HTTP driver, mutably.

Trait Implementations

impl<D: HttpDriver> SinkDriver for HttpSinkDriver<D>

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

The connector’s name, the connector metric label.

fn config_schema(&self) -> Value

The JSON Schema of the connector’s config.

fn dataset_uri(&self) -> String

The dataset this sink writes, for lineage (credential-free).

fn call_context(&self) -> CallContext

The connector’s own call defaults (timeout, retry). The run’s context is layered over it.

fn check<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, calls: &'life1 CallSlot, ctx: &'life2 CheckContext, ) -> Pin<Box<dyn Future<Output = Result<CheckReport, FaucetError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

A non-mutating preflight probe.

fn batch_atomicity(&self) -> BatchAtomicity

What a failed write leaves behind.

fn write<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, calls: &'life1 CallSlot, rows: &'life2 [Value], policy: RowPolicy, ) -> Pin<Box<dyn Future<Output = Result<PageWrite, FaucetError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Write one page. Under RowPolicy::PerRow, report the rows that failed on their own in PageWrite::failed; an Err means no row of the call was written.

fn flush<'life0, 'life1, 'async_trait>( &'life0 self, calls: &'life1 CallSlot, ) -> Pin<Box<dyn Future<Output = Result<(), FaucetError>> + Send + 'async_trait>>

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

Make buffered writes durable.

fn write_modes(&self) -> &'static [WriteMode]

The write modes this instance applies. Must include WriteMode::Overwrite exactly when staging is Some (DriverSink::check_declarations).

fn dedups_by_key(&self) -> bool

Whether this instance is configured to merge rows by key (write_mode: upsert|delete with a key).

fn write_is_replay_safe(&self) -> bool

Whether replaying a page after an ambiguous failure converges.

fn staged_load(&self) -> bool

Whether the destination bulk-loads through an object-store stage.

fn capabilities(&self, derived: Capabilities) -> Capabilities

Adjust the capabilities DriverSink derived, for a fact no primitive expresses (how unknown fields are treated, scoped overwrite). Default: unchanged.

fn sink_guarantee(&self, derived: SinkGuarantee) -> SinkGuarantee

Adjust the delivery guarantee DriverSink derived (an external target whose keyed convergence faucet cannot vouch for). Default: unchanged.

fn staging(&self) -> Option<&dyn StagingDriver>

The overwrite primitives.

fn commit_tokens(&self) -> Option<&dyn CommitTokenDriver>

The exactly-once primitives.

fn cleanup(&self) -> Option<&dyn CleanupDriver>

The scoped-cleanup primitive.

fn schema(&self) -> Option<&dyn SchemaDriver>

The schema primitives.

fn rollback(&self) -> Option<&dyn RollbackDriver>

The rollback primitives.

fn columnar(&self) -> Option<&dyn ColumnarDriver>

Available on crate feature arrow only.

The columnar write primitive.

fn readback_source(&self) -> Option<(String, Value)>

A (kind, config) source that reads the destination back.

fn complete_run<'life0, 'life1, 'async_trait>( &'life0 self, calls: &'life1 CallSlot, ) -> Pin<Box<dyn Future<Output = Result<(), FaucetError>> + Send + 'async_trait>>

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

Finalize a successful, uncancelled run (after the terminal flush).

fn local_outputs<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Vec<LocalOutput>> + Send + 'async_trait>>

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

The local files this instance created.

fn set_call_context(&self, ctx: CallContext)

The run’s call context, for a driver whose clients hold their own (a storage backend). Most drivers use the slot they are handed.

fn set_roundtrip_recorder(&self, recorder: Arc<RoundtripRecorder>)

The run’s round-trip recorder, for a driver whose clients hold their own.