Struct Endpoint 

pub struct Endpoint {
    pub middlewares: Vec<Middleware>,
    pub endpoint_type: EndpointType,
    pub handler: Option<Arc<dyn Handler>>,
}

Represents a connection point for messages, which can be a source (input) or a sink (output).

Fields

middlewares: Vec<Middleware>

(Optional) A list of middlewares to apply to the endpoint.

endpoint_type: EndpointType

The specific endpoint implementation, determined by the configuration key (e.g., “kafka”, “nats”).

handler: Option<Arc<dyn Handler>>

Internal handler for processing messages (not serialized).

Implementations

impl Endpoint

pub fn new(endpoint_type: EndpointType) -> Self

pub fn new_memory(topic: &str, capacity: usize) -> Self

Creates a new in-memory endpoint with the specified topic and capacity.

Examples

use mq_bridge::models::Endpoint;
let endpoint = Endpoint::new_memory("my_topic", 100);

pub fn new_response() -> Self

pub fn add_middleware(self, middleware: Middleware) -> Self

pub fn add_middlewares(self, middlewares: Vec<Middleware>) -> Self

pub fn channel(&self) -> Result<MemoryChannel>

Returns a reference to the in-memory channel associated with this Endpoint. This function will only succeed if the Endpoint is of type EndpointType::Memory. If the Endpoint is not a memory endpoint, this function will return an error. This function is primarily used for testing purposes where a Queue is needed.

pub fn null() -> Self

pub async fn create_consumer( &self, route_name: &str, ) -> Result<Box<dyn MessageConsumer>>

pub async fn create_publisher(&self, _route_name: &str) -> Result<Publisher>

pub fn check_consumer( &self, route_name: &str, allowed_endpoints: Option<&[&str]>, ) -> Result<()>

pub fn check_publisher( &self, route_name: &str, allowed_endpoints: Option<&[&str]>, ) -> Result<()>

Trait Implementations

impl Clone for Endpoint

fn clone(&self) -> Endpoint

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Endpoint

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

Formats the value using the given formatter.

impl Default for Endpoint

fn default() -> Endpoint

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for Endpoint

fn deserialize<D>(deserializer: D) -> Result<Self, D::Error>

where D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for Endpoint

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

where __S: Serializer,

Serialize this value into the given Serde serializer.