Struct HttpOutputConfig 

pub struct HttpOutputConfig {
    pub backpressure: bool,
}

Configuration for data output via HTTP.

HTTP output adapters cannot be usefully configured as part of pipeline configuration. Instead, instantiate them through the REST API as /pipelines/{pipeline_name}/egress.

Fields

backpressure: bool

Apply backpressure on the pipeline when the HTTP client cannot receive data fast enough.

When this flag is set to false (the default), the HTTP connector drops data chunks if the client is not keeping up with its output. This prevents a slow HTTP client from slowing down the entire pipeline.

When the flag is set to true, the connector waits for the client to receive each chunk and blocks the pipeline if the client cannot keep up.

Trait Implementations

impl Clone for HttpOutputConfig

fn clone(&self) -> HttpOutputConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for HttpOutputConfig

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

Formats the value using the given formatter.

impl Default for HttpOutputConfig

fn default() -> HttpOutputConfig

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for HttpOutputConfig

where HttpOutputConfig: Default,

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for HttpOutputConfig

fn eq(&self, other: &HttpOutputConfig) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Serialize for HttpOutputConfig

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

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl<'__s> ToSchema<'__s> for HttpOutputConfig

fn schema() -> (&'__s str, RefOr<Schema>)

Return a tuple of name and schema or reference to a schema that can be referenced by the name or inlined directly to responses, request bodies or parameters.

fn aliases() -> Vec<(&'__s str, Schema)>

Optional set of alias schemas for the ToSchema::schema.

impl Eq for HttpOutputConfig

impl StructuralPartialEq for HttpOutputConfig