MCPcopy Create free account
hub / github.com/apache/pulsar-client-go / GetMaxSubscriptionsPerTopic

Method GetMaxSubscriptionsPerTopic

pulsaradmin/pkg/admin/topic.go:2177–2179  ·  view source on GitHub ↗
(topic utils.TopicName)

Source from the content-addressed store, hash-verified

2175}
2176
2177func (t *topics) GetMaxSubscriptionsPerTopic(topic utils.TopicName) (int, error) {
2178 return t.GetMaxSubscriptionsPerTopicWithContext(context.Background(), topic)
2179}
2180
2181func (t *topics) GetMaxSubscriptionsPerTopicWithContext(ctx context.Context, topic utils.TopicName) (int, error) {
2182 maxSubscriptions, err := t.localTopicPolicies().GetMaxSubscriptionsPerTopic(ctx, topic, false)

Callers

nothing calls this directly

Tested by

no test coverage detected