pub struct Topic { /* private fields */ }Expand description
Topic is a reference to a PubSub topic.
The methods of Topic are safe for use by multiple tasks.
Implementations§
Source§impl Topic
impl Topic
Sourcepub fn fully_qualified_name(&self) -> &str
pub fn fully_qualified_name(&self) -> &str
fully_qualified_name returns the printable globally unique name for the topic.
pub fn new_publisher(&self, config: Option<PublisherConfig>) -> Publisher
Sourcepub async fn create(
&self,
cfg: Option<TopicConfig>,
retry: Option<RetrySetting>,
) -> Result<(), Status>
pub async fn create( &self, cfg: Option<TopicConfig>, retry: Option<RetrySetting>, ) -> Result<(), Status>
create creates the topic.
Sourcepub async fn delete(&self, retry: Option<RetrySetting>) -> Result<(), Status>
pub async fn delete(&self, retry: Option<RetrySetting>) -> Result<(), Status>
delete deletes the topic.
Sourcepub async fn exists(&self, retry: Option<RetrySetting>) -> Result<bool, Status>
pub async fn exists(&self, retry: Option<RetrySetting>) -> Result<bool, Status>
exists reports whether the topic exists on the server.
Sourcepub async fn subscriptions(
&self,
retry: Option<RetrySetting>,
) -> Result<Vec<Subscription>, Status>
pub async fn subscriptions( &self, retry: Option<RetrySetting>, ) -> Result<Vec<Subscription>, Status>
Subscriptions returns an iterator which returns the subscriptions for this topic.
Trait Implementations§
Auto Trait Implementations§
impl Freeze for Topic
impl !RefUnwindSafe for Topic
impl Send for Topic
impl Sync for Topic
impl Unpin for Topic
impl !UnwindSafe for Topic
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