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.

JSON schema

{
 "description": "Configuration for data output via HTTP.\n\nHTTP output adapters cannot be usefully configured as part of pipeline\nconfiguration.  Instead, instantiate them through the REST API as\n`/pipelines/{pipeline_name}/egress`.",
 "type": "object",
 "properties": {
   "backpressure": {
     "description": "Apply backpressure on the pipeline when the HTTP client cannot receive\ndata fast enough.\n\nWhen this flag is set to false (the default), the HTTP connector drops data\nchunks if the client is not keeping up with its output.  This prevents\na slow HTTP client from slowing down the entire pipeline.\n\nWhen the flag is set to true, the connector waits for the client to receive\neach chunk and blocks the pipeline if the client cannot keep up.",
     "default": false,
     "type": "boolean"
   }
 }
}

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.

Implementations

impl HttpOutputConfig

pub fn builder() -> HttpOutputConfig

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<'de> Deserialize<'de> for HttpOutputConfig

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl From<&HttpOutputConfig> for HttpOutputConfig

fn from(value: &HttpOutputConfig) -> Self

Converts to this type from the input type.

impl From<HttpOutputConfig> for HttpOutputConfig

fn from(value: HttpOutputConfig) -> Self

Converts to this type from the input type.

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 TryFrom<HttpOutputConfig> for HttpOutputConfig

type Error = ConversionError

The type returned in the event of a conversion error.

fn try_from(value: HttpOutputConfig) -> Result<Self, ConversionError>

Performs the conversion.