Enum EndpointType 

pub enum EndpointType {
    Aws(AwsConfig),
    Kafka(KafkaConfig),
    Nats(NatsConfig),
    File(FileConfig),
    Static(String),
    Ref(String),
    Memory(MemoryConfig),
    Sled(SledConfig),
    Amqp(AmqpConfig),
    MongoDb(MongoDbConfig),
    Mqtt(MqttConfig),
    Http(HttpConfig),
    IbmMq(IbmMqConfig),
    ZeroMq(ZeroMqConfig),
    Grpc(GrpcConfig),
    Sqlx(SqlxConfig),
    Fanout(Vec<Endpoint>),
    Switch(SwitchConfig),
    Response(ResponseConfig),
    Reader(Box<Endpoint>),
    Custom {
        name: String,
        config: Value,
    },
    Null,
}

An enumeration of all supported endpoint types. #[serde(rename_all = "lowercase")] ensures that the keys in the config (e.g., “kafka”) match the enum variants.

Examples

Configuring a Fanout endpoint in YAML:

use mq_bridge::models::{Endpoint, EndpointType};

let yaml = r#"
fanout:
  - memory: { topic: "out1" }
  - memory: { topic: "out2" }
"#;

let endpoint: Endpoint = serde_yaml_ng::from_str(yaml).unwrap();
if let EndpointType::Fanout(targets) = endpoint.endpoint_type {
    assert_eq!(targets.len(), 2);
}

Variants

Aws(AwsConfig)

Kafka(KafkaConfig)

Nats(NatsConfig)

File(FileConfig)

Static(String)

Ref(String)

Memory(MemoryConfig)

Sled(SledConfig)

Amqp(AmqpConfig)

MongoDb(MongoDbConfig)

Mqtt(MqttConfig)

Http(HttpConfig)

IbmMq(IbmMqConfig)

ZeroMq(ZeroMqConfig)

Grpc(GrpcConfig)

Sqlx(SqlxConfig)

Fanout(Vec<Endpoint>)

Switch(SwitchConfig)

Response(ResponseConfig)

Reader(Box<Endpoint>)

Custom

Fields

name: String

config: Value

Null

Implementations

impl EndpointType

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

pub fn is_core(&self) -> bool

Trait Implementations

impl Clone for EndpointType

fn clone(&self) -> EndpointType

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for EndpointType

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

Formats the value using the given formatter.

impl Default for EndpointType

fn default() -> EndpointType

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for EndpointType

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl SecretExtractor for EndpointType

fn extract_secrets( &mut self, prefix: &str, secrets: &mut HashMap<String, String>, )

Extracts secrets into the provided map using the given prefix, and clears them from self.

impl Serialize for EndpointType

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

where __S: Serializer,

Serialize this value into the given Serde serializer.