pub struct EventHubConsumerClientBuilder<RP> { /* private fields */ }Expand description
A builder for creating an EventHubConsumerClient.
Implementations§
source§impl<RP> EventHubConsumerClientBuilder<RP>
impl<RP> EventHubConsumerClientBuilder<RP>
sourcepub async fn new_from_connection_string(
self,
consumer_group: impl Into<String>,
connection_string: impl Into<String>,
event_hub_name: impl Into<Option<String>>,
client_options: EventHubConsumerClientOptions
) -> Result<EventHubConsumerClient<RP>, Error>where
RP: EventHubsRetryPolicy + Send,
pub async fn new_from_connection_string( self, consumer_group: impl Into<String>, connection_string: impl Into<String>, event_hub_name: impl Into<Option<String>>, client_options: EventHubConsumerClientOptions ) -> Result<EventHubConsumerClient<RP>, Error>where RP: EventHubsRetryPolicy + Send,
Creates a new EventHubConsumerClient from an existing connection.
sourcepub async fn from_connection_string(
self,
consumer_group: impl Into<String>,
connection_string: impl Into<String>,
event_hub_name: impl Into<Option<String>>,
client_options: EventHubConsumerClientOptions
) -> Result<EventHubConsumerClient<RP>, Error>where
RP: EventHubsRetryPolicy + Send,
👎Deprecated since 0.14.1: Please use new_from_connection_string instead
pub async fn from_connection_string( self, consumer_group: impl Into<String>, connection_string: impl Into<String>, event_hub_name: impl Into<Option<String>>, client_options: EventHubConsumerClientOptions ) -> Result<EventHubConsumerClient<RP>, Error>where RP: EventHubsRetryPolicy + Send,
new_from_connection_string insteadCreates a new EventHubConsumerClient from an existing connection.
sourcepub async fn new_from_credential(
self,
consumer_group: impl Into<String>,
fully_qualified_namespace: impl Into<String>,
event_hub_name: impl Into<String>,
credential: impl Into<EventHubTokenCredential>,
client_options: EventHubConsumerClientOptions
) -> Result<EventHubConsumerClient<RP>, Error>where
RP: EventHubsRetryPolicy + Send,
pub async fn new_from_credential( self, consumer_group: impl Into<String>, fully_qualified_namespace: impl Into<String>, event_hub_name: impl Into<String>, credential: impl Into<EventHubTokenCredential>, client_options: EventHubConsumerClientOptions ) -> Result<EventHubConsumerClient<RP>, Error>where RP: EventHubsRetryPolicy + Send,
Creates a new EventHubConsumerClient from a namespace and credential.
sourcepub async fn from_namespace_and_credential(
self,
consumer_group: impl Into<String>,
fully_qualified_namespace: impl Into<String>,
event_hub_name: impl Into<String>,
credential: impl Into<EventHubTokenCredential>,
client_options: EventHubConsumerClientOptions
) -> Result<EventHubConsumerClient<RP>, Error>where
RP: EventHubsRetryPolicy + Send,
👎Deprecated since 0.14.1: Please use new_from_credential instead
pub async fn from_namespace_and_credential( self, consumer_group: impl Into<String>, fully_qualified_namespace: impl Into<String>, event_hub_name: impl Into<String>, credential: impl Into<EventHubTokenCredential>, client_options: EventHubConsumerClientOptions ) -> Result<EventHubConsumerClient<RP>, Error>where RP: EventHubsRetryPolicy + Send,
new_from_credential insteadCreates a new EventHubConsumerClient from a namespace and credential.
sourcepub async fn new_from_named_key_credential(
self,
consumer_group: impl Into<String>,
fully_qualified_namespace: impl Into<String>,
event_hub_name: impl Into<String>,
credential: AzureNamedKeyCredential,
client_options: EventHubConsumerClientOptions
) -> Result<EventHubConsumerClient<RP>, Error>where
RP: EventHubsRetryPolicy + Send,
pub async fn new_from_named_key_credential( self, consumer_group: impl Into<String>, fully_qualified_namespace: impl Into<String>, event_hub_name: impl Into<String>, credential: AzureNamedKeyCredential, client_options: EventHubConsumerClientOptions ) -> Result<EventHubConsumerClient<RP>, Error>where RP: EventHubsRetryPolicy + Send,
Creates a new EventHubConsumerClient from a namespace and a AzureNamedKeyCredential.
sourcepub async fn from_namespace_and_named_key_credential(
self,
consumer_group: impl Into<String>,
fully_qualified_namespace: impl Into<String>,
event_hub_name: impl Into<String>,
credential: AzureNamedKeyCredential,
client_options: EventHubConsumerClientOptions
) -> Result<EventHubConsumerClient<RP>, Error>where
RP: EventHubsRetryPolicy + Send,
👎Deprecated since 0.14.1: Please use new_from_named_key_credential instead
pub async fn from_namespace_and_named_key_credential( self, consumer_group: impl Into<String>, fully_qualified_namespace: impl Into<String>, event_hub_name: impl Into<String>, credential: AzureNamedKeyCredential, client_options: EventHubConsumerClientOptions ) -> Result<EventHubConsumerClient<RP>, Error>where RP: EventHubsRetryPolicy + Send,
new_from_named_key_credential insteadCreates a new EventHubConsumerClient from a namespace and a AzureNamedKeyCredential.
sourcepub async fn new_from_sas_credential(
self,
consumer_group: impl Into<String>,
fully_qualified_namespace: impl Into<String>,
event_hub_name: impl Into<String>,
credential: AzureSasCredential,
client_options: EventHubConsumerClientOptions
) -> Result<EventHubConsumerClient<RP>, Error>where
RP: EventHubsRetryPolicy + Send,
pub async fn new_from_sas_credential( self, consumer_group: impl Into<String>, fully_qualified_namespace: impl Into<String>, event_hub_name: impl Into<String>, credential: AzureSasCredential, client_options: EventHubConsumerClientOptions ) -> Result<EventHubConsumerClient<RP>, Error>where RP: EventHubsRetryPolicy + Send,
Creates a new EventHubConsumerClient from a namespace and a AzureSasCredential.
sourcepub async fn from_namespace_and_sas_credential(
self,
consumer_group: impl Into<String>,
fully_qualified_namespace: impl Into<String>,
event_hub_name: impl Into<String>,
credential: AzureSasCredential,
client_options: EventHubConsumerClientOptions
) -> Result<EventHubConsumerClient<RP>, Error>where
RP: EventHubsRetryPolicy + Send,
👎Deprecated since 0.14.1: Please use new_from_sas_credential instead
pub async fn from_namespace_and_sas_credential( self, consumer_group: impl Into<String>, fully_qualified_namespace: impl Into<String>, event_hub_name: impl Into<String>, credential: AzureSasCredential, client_options: EventHubConsumerClientOptions ) -> Result<EventHubConsumerClient<RP>, Error>where RP: EventHubsRetryPolicy + Send,
new_from_sas_credential insteadCreates a new EventHubConsumerClient from a namespace and a AzureSasCredential.
sourcepub fn with_connection(
self,
consumer_group: impl Into<String>,
connection: &mut EventHubConnection,
client_options: EventHubConsumerClientOptions
) -> EventHubConsumerClient<RP>
pub fn with_connection( self, consumer_group: impl Into<String>, connection: &mut EventHubConnection, client_options: EventHubConsumerClientOptions ) -> EventHubConsumerClient<RP>
Creates a new EventHubConsumerClient from an existing EventHubConnection.
Trait Implementations§
Auto Trait Implementations§
impl<RP> RefUnwindSafe for EventHubConsumerClientBuilder<RP>where RP: RefUnwindSafe,
impl<RP> Send for EventHubConsumerClientBuilder<RP>where RP: Send,
impl<RP> Sync for EventHubConsumerClientBuilder<RP>where RP: Sync,
impl<RP> Unpin for EventHubConsumerClientBuilder<RP>where RP: Unpin,
impl<RP> UnwindSafe for EventHubConsumerClientBuilder<RP>where RP: UnwindSafe,
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