Type Alias dapr::appcallback::TopicSubscription

pub type TopicSubscription = TopicSubscription;

TopicSubscription represents a topic and it’s metadata (session id etc.)

Aliased Type

struct TopicSubscription {
    pub pubsub_name: String,
    pub topic: String,
    pub metadata: HashMap<String, String>,
    pub routes: Option<TopicRoutes>,
    pub dead_letter_topic: String,
    pub bulk_subscribe: Option<BulkSubscribeConfig>,
}

Fields

pubsub_name: String

Required. The name of the pubsub containing the topic below to subscribe to.

topic: String

Required. The name of topic which will be subscribed

metadata: HashMap<String, String>

The optional properties used for this topic’s subscription e.g. session id

routes: Option<TopicRoutes>

The optional routing rules to match against. In the gRPC interface, OnTopicEvent is still invoked but the matching path is sent in the TopicEventRequest.

dead_letter_topic: String

The optional dead letter queue for this topic to send events to.

bulk_subscribe: Option<BulkSubscribeConfig>

The optional bulk subscribe settings for this topic.

Implementations

impl TopicSubscription

pub fn new( pubsub_name: String, topic: String, metadata: Option<HashMap<String, String>> ) -> Self

Create a new TopicSubscription for a give topic.