pub struct ChannelBuilder { /* private fields */ }
Expand description
ChannelBuilder validates a connection string based on the requirements from Spark Documentation
Implementations§
Source§impl ChannelBuilder
impl ChannelBuilder
pub fn new() -> Self
pub fn endpoint(&self) -> String
pub fn token(&self) -> Option<String>
pub fn headers(&self) -> Option<MetadataMap>
pub fn parse_connection_string( connection: &str, ) -> Result<(String, u16, Option<HashMap<String, String>>), SparkError>
pub fn parse_headers(url: Url) -> Option<HashMap<String, String>>
Sourcepub fn create(connection: &str) -> Result<ChannelBuilder, SparkError>
pub fn create(connection: &str) -> Result<ChannelBuilder, SparkError>
Create and validate a connnection string
Trait Implementations§
Source§impl Clone for ChannelBuilder
impl Clone for ChannelBuilder
Source§fn clone(&self) -> ChannelBuilder
fn clone(&self) -> ChannelBuilder
Returns a copy of the value. Read more
1.0.0 · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source
. Read moreSource§impl Debug for ChannelBuilder
impl Debug for ChannelBuilder
Auto Trait Implementations§
impl Freeze for ChannelBuilder
impl RefUnwindSafe for ChannelBuilder
impl Send for ChannelBuilder
impl Sync for ChannelBuilder
impl Unpin for ChannelBuilder
impl UnwindSafe for ChannelBuilder
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
Source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T
in a tonic::Request