Struct HttpSink 

pub struct HttpSink { /* private fields */ }

Implementations

impl HttpSink

pub fn new( endpoint: impl AsRef<str>, bearer_token: Option<String>, ) -> Result<Self>

Creates an HTTP sync sink.

Errors

Returns an error when endpoint is not an http:// or https:// URL.

pub fn send_with_ack(&self, batch: &SyncBatch) -> Result<SyncAck>

Sends a batch and returns the server acknowledgement.

Errors

Returns an error if the endpoint rejects the batch, the connection fails, or the response is not a supported sync acknowledgement.

Trait Implementations

impl Clone for HttpSink

fn clone(&self) -> HttpSink

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for HttpSink

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

Formats the value using the given formatter.

impl SyncSink for HttpSink

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

fn send(&self, batch: &SyncBatch) -> Result<()>