Enum ExternalSystemType 

pub enum ExternalSystemType {
    Kafka {
        brokers: Vec<String>,
        topics: Vec<String>,
        consumer_group: Option<String>,
    },
    RabbitMQ {
        url: String,
        exchange: String,
        routing_key: String,
        queue: Option<String>,
    },
    AmazonSQS {
        region: String,
        queue_url: String,
        credentials: AwsCredentials,
    },
    AzureServiceBus {
        connection_string: String,
        queue_name: String,
    },
    GooglePubSub {
        project_id: String,
        topic: String,
        subscription: Option<String>,
    },
    Pulsar {
        service_url: String,
        topics: Vec<String>,
        subscription: Option<String>,
    },
    RedisPubSub {
        url: String,
        channels: Vec<String>,
    },
    HttpRest {
        base_url: String,
        endpoints: HashMap<String, String>,
        headers: HashMap<String, String>,
    },
    WebSocket {
        url: String,
        protocols: Vec<String>,
    },
    FileSystem {
        directory: String,
        pattern: String,
        watch_mode: bool,
    },
}

External system types

Variants

Kafka

Apache Kafka

Fields

brokers: Vec<String>

topics: Vec<String>

consumer_group: Option<String>

RabbitMQ

RabbitMQ

Fields

url: String

exchange: String

routing_key: String

queue: Option<String>

AmazonSQS

Amazon SQS

Fields

region: String

queue_url: String

credentials: AwsCredentials

AzureServiceBus

Azure Service Bus

Fields

connection_string: String

queue_name: String

GooglePubSub

Google Cloud Pub/Sub

Fields

project_id: String

topic: String

subscription: Option<String>

Pulsar

Apache Pulsar

Fields

service_url: String

topics: Vec<String>

subscription: Option<String>

RedisPubSub

Redis Pub/Sub

Fields

url: String

channels: Vec<String>

HttpRest

HTTP REST API

Fields

base_url: String

endpoints: HashMap<String, String>

headers: HashMap<String, String>

WebSocket

WebSocket

Fields

url: String

protocols: Vec<String>

FileSystem

File system

Fields

directory: String

pattern: String

watch_mode: bool

Trait Implementations

impl Clone for ExternalSystemType

fn clone(&self) -> ExternalSystemType

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ExternalSystemType

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for ExternalSystemType

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for ExternalSystemType

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

where __S: Serializer,

Serialize this value into the given Serde serializer.