Enum EgressEndpointConfig 

pub enum EgressEndpointConfig {
    Line {
        name: String,
        path: String,
    },
    Http {
        name: String,
        url: String,
        method: String,
        headers: Vec<(String, String)>,
        timeout_ms: u64,
        max_retries: usize,
    },
    Grpc {
        name: String,
        endpoint: String,
        timeout_ms: u64,
    },
    WebSocket {
        name: String,
        url: String,
        headers: Vec<(String, String)>,
        connect_timeout_ms: u64,
        max_retries: usize,
    },
    Kafka {
        name: String,
        brokers: String,
        topic: String,
        flush_timeout_ms: u64,
    },
    Nats {
        name: String,
        server_url: String,
        subject: String,
    },
    RedisStreams {
        name: String,
        redis_url: String,
        stream: String,
    },
    RabbitMqStreams {
        name: String,
        server_url: String,
        stream: String,
        publisher_name: Option<String>,
        flush_timeout_ms: u64,
    },
    S3 {
        name: String,
        bucket: String,
        prefix: Option<String>,
        region: String,
        endpoint: Option<String>,
        content_type: Option<String>,
    },
    Postgres {
        name: String,
        dsn: String,
        table: String,
        mode: String,
        conflict_key: Option<String>,
    },
}

Variants

Line

Fields

name: String

path: String

Http

Fields

name: String

url: String

method: String

headers: Vec<(String, String)>

timeout_ms: u64

max_retries: usize

Grpc

Fields

name: String

endpoint: String

timeout_ms: u64

WebSocket

Fields

name: String

url: String

headers: Vec<(String, String)>

connect_timeout_ms: u64

max_retries: usize

Kafka

Fields

name: String

brokers: String

topic: String

flush_timeout_ms: u64

Nats

Fields

name: String

server_url: String

subject: String

RedisStreams

Fields

name: String

redis_url: String

stream: String

RabbitMqStreams

Fields

name: String

server_url: String

stream: String

publisher_name: Option<String>

flush_timeout_ms: u64

S3

Fields

name: String

bucket: String

prefix: Option<String>

region: String

endpoint: Option<String>

content_type: Option<String>

Postgres

Fields

name: String

dsn: String

table: String

mode: String

conflict_key: Option<String>

Implementations

impl EgressEndpointConfig

pub fn label(&self) -> String

Trait Implementations

impl Clone for EgressEndpointConfig

fn clone(&self) -> EgressEndpointConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for EgressEndpointConfig

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

Formats the value using the given formatter.

impl PartialEq for EgressEndpointConfig

fn eq(&self, other: &EgressEndpointConfig) -> 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 Eq for EgressEndpointConfig

impl StructuralPartialEq for EgressEndpointConfig