Struct ockam_api::nodes::models::services::StartKafkaDirectRequest

pub struct StartKafkaDirectRequest { /* private fields */ }

Implementations

impl StartKafkaDirectRequest

pub fn new( bind_address: SocketAddr, bootstrap_server_addr: SocketAddr, brokers_port_range: impl Into<(u16, u16)>, consumer_route: Option<MultiAddr> ) -> Self

pub fn bind_address(&self) -> SocketAddr

pub fn bootstrap_server_addr(&self) -> &SocketAddr

pub fn brokers_port_range(&self) -> (u16, u16)

pub fn consumer_route(&self) -> Option<String>

Trait Implementations

impl Clone for StartKafkaDirectRequest

fn clone(&self) -> StartKafkaDirectRequest

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for StartKafkaDirectRequest

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

Formats the value using the given formatter.

impl<'bytes, Ctx> Decode<'bytes, Ctx> for StartKafkaDirectRequest

fn decode( __d777: &mut Decoder<'bytes>, __ctx777: &mut Ctx ) -> Result<StartKafkaDirectRequest, Error>

Decode a value using the given Decoder.

fn nil() -> Option<Self>

If possible, return a nil value of Self.

impl<Ctx> Encode<Ctx> for StartKafkaDirectRequest

fn encode<__W777>( &self, __e777: &mut Encoder<__W777>, __ctx777: &mut Ctx ) -> Result<(), Error<__W777::Error>>where __W777: Write,

Encode a value of this type using the given Encoder.

fn is_nil(&self) -> bool

Is this value of Self a nil value?