MCPcopy Create free account

hub / github.com/apache/pulsar-client-go / functions

Functions5,094 in github.com/apache/pulsar-client-go

MethodSetDelayedDelivery
(topic utils.TopicName, delayedDeliveryData utils.DelayedDeliveryData)
pulsaradmin/pkg/admin/topic.go:1756
MethodSetDelayedDeliveryWithContext
SetDelayedDeliveryWithContext sets the delayed delivery policy on a topic
pulsaradmin/pkg/admin/topic.go:579
MethodSetDispatchRate
(context.Context, utils.TopicName, utils.DispatchRateData)
pulsaradmin/pkg/admin/topic_policies.go:61
MethodSetDispatchRate
( ctx context.Context, topic utils.TopicName, dispatchRateData utils.DispatchRateData, )
pulsaradmin/pkg/admin/topic_policies.go:443
MethodSetDispatchRate
(topic utils.TopicName, dispatchRateData utils.DispatchRateData)
pulsaradmin/pkg/admin/topic.go:1789
MethodSetDispatchRate
SetDispatchRate sets Message-dispatch-rate (topics under this namespace can dispatch this many messages per second)
pulsaradmin/pkg/admin/namespace.go:651
MethodSetDispatchRate
(namespace utils.NameSpaceName, rate utils.DispatchRate)
pulsaradmin/pkg/admin/namespace.go:1943
MethodSetDispatchRateWithContext
SetDispatchRateWithContext sets message dispatch rate for a topic
pulsaradmin/pkg/admin/topic.go:599
MethodSetDispatchRateWithContext
SetDispatchRateWithContext sets Message-dispatch-rate (topics under this namespace can dispatch this many messages per second)
pulsaradmin/pkg/admin/namespace.go:655
MethodSetEncryptionParam
(param []byte)
pulsar/crypto/message_metadata.go:85
MethodSetEncryptionRequiredStatus
SetEncryptionRequiredStatus sets the encryption required status for all topics within a namespace
pulsaradmin/pkg/admin/namespace.go:548
MethodSetEncryptionRequiredStatus
(namespace utils.NameSpaceName, encrypt bool)
pulsaradmin/pkg/admin/namespace.go:1774
MethodSetEncryptionRequiredStatusWithContext
SetEncryptionRequiredStatusWithContext sets the encryption required status for all topics within a namespace
pulsaradmin/pkg/admin/namespace.go:551
MethodSetExpiration
(_ time.Duration)
pulsar/auth/athenz_test.go:52
MethodSetHostname
(_ string)
pulsar/auth/athenz_test.go:54
MethodSetIPAddress
(_ string)
pulsar/auth/athenz_test.go:56
MethodSetInactiveTopicPolicies
(context.Context, utils.TopicName, utils.InactiveTopicPolicies)
pulsaradmin/pkg/admin/topic_policies.go:85
MethodSetInactiveTopicPolicies
( ctx context.Context, topic utils.TopicName, data utils.InactiveTopicPolicies, )
pulsaradmin/pkg/admin/topic_policies.go:601
MethodSetInactiveTopicPolicies
SetInactiveTopicPolicies sets the inactive topic policies on a topic
pulsaradmin/pkg/admin/topic.go:806
MethodSetInactiveTopicPolicies
(topic utils.TopicName, data utils.InactiveTopicPolicies)
pulsaradmin/pkg/admin/topic.go:2011
MethodSetInactiveTopicPolicies
SetInactiveTopicPolicies sets the inactive topic policies on a namespace
pulsaradmin/pkg/admin/namespace.go:711
MethodSetInactiveTopicPolicies
(namespace utils.NameSpaceName, data utils.InactiveTopicPolicies)
pulsaradmin/pkg/admin/namespace.go:2046
MethodSetInactiveTopicPoliciesWithContext
SetInactiveTopicPoliciesWithContext sets the inactive topic policies on a topic
pulsaradmin/pkg/admin/topic.go:809
MethodSetInactiveTopicPoliciesWithContext
SetInactiveTopicPoliciesWithContext sets the inactive topic policies on a namespace
pulsaradmin/pkg/admin/namespace.go:714
MethodSetIsAllowAutoUpdateSchema
SetIsAllowAutoUpdateSchema sets whether to allow auto update schema on a namespace
pulsaradmin/pkg/admin/namespace.go:680
MethodSetIsAllowAutoUpdateSchema
(namespace utils.NameSpaceName, isAllowAutoUpdateSchema bool)
pulsaradmin/pkg/admin/namespace.go:1996
MethodSetIsAllowAutoUpdateSchemaWithContext
SetIsAllowAutoUpdateSchemaWithContext sets whether to allow auto update schema on a namespace
pulsaradmin/pkg/admin/namespace.go:683
MethodSetKeyService
(_ string)
pulsar/auth/athenz_test.go:58
MethodSetMaxConsumers
(context.Context, utils.TopicName, int)
pulsaradmin/pkg/admin/topic_policies.go:41
MethodSetMaxConsumers
(ctx context.Context, topic utils.TopicName, maxConsumers int)
pulsaradmin/pkg/admin/topic_policies.go:321
MethodSetMaxConsumers
(topic utils.TopicName, maxConsumers int)
pulsaradmin/pkg/admin/topic.go:1624
MethodSetMaxConsumersPerSubscription
(context.Context, utils.TopicName, int)
pulsaradmin/pkg/admin/topic_policies.go:101
MethodSetMaxConsumersPerSubscription
( ctx context.Context, topic utils.TopicName, maxConsumers int, )
pulsaradmin/pkg/admin/topic_policies.go:705
MethodSetMaxConsumersPerSubscription
(topic utils.TopicName, maxConsumers int)
pulsaradmin/pkg/admin/topic.go:2125
MethodSetMaxConsumersPerSubscription
SetMaxConsumersPerSubscription sets maxConsumersPerSubscription for a namespace. nolint: revive // It's ok here to use a built-in function name (max)
pulsaradmin/pkg/admin/namespace.go:290
MethodSetMaxConsumersPerSubscription
nolint: revive // It's ok here to use a built-in function name (max)
pulsaradmin/pkg/admin/namespace.go:1208
MethodSetMaxConsumersPerSubscriptionWithContext
SetMaxConsumersPerSubscriptionWithContext sets max consumers per subscription for a topic
pulsaradmin/pkg/admin/topic.go:891
MethodSetMaxConsumersPerSubscriptionWithContext
SetMaxConsumersPerSubscriptionWithContext sets maxConsumersPerSubscription for a namespace. nolint: revive // It's ok here to use a built-in function
pulsaradmin/pkg/admin/namespace.go:294
MethodSetMaxConsumersPerTopic
nolint: revive // It's ok here to use a built-in function name (max)
pulsaradmin/pkg/admin/namespace.go:1300
MethodSetMaxConsumersPerTopicWithContext
SetMaxConsumersPerTopicWithContext sets maxConsumersPerTopic for a namespace. nolint: revive // It's ok here to use a built-in function name (max)
pulsaradmin/pkg/admin/namespace.go:317
MethodSetMaxConsumersWithContext
SetMaxConsumersWithContext sets max number of consumers for a topic @param ctx context used for the request @param topic topicName struct @param maxC
pulsaradmin/pkg/admin/topic.go:476
MethodSetMaxMessageSize
(context.Context, utils.TopicName, int)
pulsaradmin/pkg/admin/topic_policies.go:105
MethodSetMaxMessageSize
( ctx context.Context, topic utils.TopicName, maxMessageSize int, )
pulsaradmin/pkg/admin/topic_policies.go:732
MethodSetMaxMessageSize
(topic utils.TopicName, maxMessageSize int)
pulsaradmin/pkg/admin/topic.go:2159
MethodSetMaxMessageSizeWithContext
SetMaxMessageSizeWithContext sets max message size for a topic
pulsaradmin/pkg/admin/topic.go:909
MethodSetMaxProducers
(context.Context, utils.TopicName, int)
pulsaradmin/pkg/admin/topic_policies.go:37
MethodSetMaxProducers
(ctx context.Context, topic utils.TopicName, maxProducers int)
pulsaradmin/pkg/admin/topic_policies.go:301
MethodSetMaxProducers
(topic utils.TopicName, maxProducers int)
pulsaradmin/pkg/admin/topic.go:1592
MethodSetMaxProducersPerTopic
nolint: revive // It's ok here to use a built-in function name (max)
pulsaradmin/pkg/admin/namespace.go:1368
MethodSetMaxProducersPerTopicWithContext
SetMaxProducersPerTopicWithContext sets maxProducersPerTopic for a namespace. nolint: revive // It's ok here to use a built-in function name (max)
pulsaradmin/pkg/admin/namespace.go:339
MethodSetMaxProducersWithContext
SetMaxProducersWithContext sets max number of producers for a topic @param ctx context used for the request @param topic topicName struct @param maxP
pulsaradmin/pkg/admin/topic.go:446
MethodSetMaxSubscriptionsPerTopic
(context.Context, utils.TopicName, int)
pulsaradmin/pkg/admin/topic_policies.go:109
MethodSetMaxSubscriptionsPerTopic
( ctx context.Context, topic utils.TopicName, maxSubscriptions int, )
pulsaradmin/pkg/admin/topic_policies.go:756
MethodSetMaxSubscriptionsPerTopic
(topic utils.TopicName, maxSubscriptions int)
pulsaradmin/pkg/admin/topic.go:2189
MethodSetMaxSubscriptionsPerTopicWithContext
SetMaxSubscriptionsPerTopicWithContext sets max subscriptions per topic
pulsaradmin/pkg/admin/topic.go:927
MethodSetMaxTopicsPerNamespace
nolint: revive // It's ok here to use a built-in function name (max)
pulsaradmin/pkg/admin/namespace.go:2134
MethodSetMaxTopicsPerNamespaceWithContext
SetMaxTopicsPerNamespaceWithContext sets maxTopicsPerNamespace for a namespace. nolint: revive // It's ok here to use a built-in function name (max)
pulsaradmin/pkg/admin/namespace.go:361
MethodSetMaxUnackMessagesPerConsumer
(context.Context, utils.TopicName, int)
pulsaradmin/pkg/admin/topic_policies.go:45
MethodSetMaxUnackMessagesPerConsumer
( ctx context.Context, topic utils.TopicName, maxUnackedNum int, )
pulsaradmin/pkg/admin/topic_policies.go:341
MethodSetMaxUnackMessagesPerConsumer
(topic utils.TopicName, maxUnackedNum int)
pulsaradmin/pkg/admin/topic.go:1656
MethodSetMaxUnackMessagesPerConsumerWithContext
SetMaxUnackMessagesPerConsumerWithContext sets max unacked messages policy on consumer for a topic @param ctx context used for the request @param top
pulsaradmin/pkg/admin/topic.go:507
MethodSetMaxUnackMessagesPerSubscription
(context.Context, utils.TopicName, int)
pulsaradmin/pkg/admin/topic_policies.go:49
MethodSetMaxUnackMessagesPerSubscription
( ctx context.Context, topic utils.TopicName, maxUnackedNum int, )
pulsaradmin/pkg/admin/topic_policies.go:368
MethodSetMaxUnackMessagesPerSubscription
(topic utils.TopicName, maxUnackedNum int)
pulsaradmin/pkg/admin/topic.go:1693
MethodSetMaxUnackMessagesPerSubscriptionWithContext
SetMaxUnackMessagesPerSubscriptionWithContext sets max unacked messages policy on subscription for a topic @param ctx context used for the request @p
pulsaradmin/pkg/admin/topic.go:539
MethodSetMessageTTL
(context.Context, utils.TopicName, int)
pulsaradmin/pkg/admin/topic_policies.go:33
MethodSetMessageTTL
(ctx context.Context, topic utils.TopicName, messageTTL int)
pulsaradmin/pkg/admin/topic_policies.go:277
MethodSetMessageTTL
(topic utils.TopicName, messageTTL int)
pulsaradmin/pkg/admin/topic.go:1556
MethodSetMessageTTLWithContext
SetMessageTTLWithContext sets the message TTL for a topic @param ctx context used for the request @param topic topicName struct @param messageTTL Mes
pulsaradmin/pkg/admin/topic.go:416
MethodSetNamespaceAntiAffinityGroup
SetNamespaceAntiAffinityGroup sets anti-affinity group name for a namespace
pulsaradmin/pkg/admin/namespace.go:390
MethodSetNamespaceAntiAffinityGroup
(namespace string, namespaceAntiAffinityGroup string)
pulsaradmin/pkg/admin/namespace.go:1443
MethodSetNamespaceAntiAffinityGroupWithContext
SetNamespaceAntiAffinityGroupWithContext sets anti-affinity group name for a namespace
pulsaradmin/pkg/admin/namespace.go:393
MethodSetNamespaceBundleResourceQuota
SetNamespaceBundleResourceQuota sets resource quota for a namespace bundle.
pulsaradmin/pkg/admin/resource_quotas.go:46
MethodSetNamespaceBundleResourceQuota
(namespace, bundle string, quota utils.ResourceQuota)
pulsaradmin/pkg/admin/resource_quotas.go:116
MethodSetNamespaceBundleResourceQuotaWithContext
SetNamespaceBundleResourceQuotaWithContext sets resource quota for a namespace bundle.
pulsaradmin/pkg/admin/resource_quotas.go:49
MethodSetNamespaceMessageTTL
(namespace string, ttlInSeconds int)
pulsaradmin/pkg/admin/namespace.go:916
MethodSetNamespaceMessageTTLWithContext
SetNamespaceMessageTTLWithContext sets the messages Time to Live for all the topics within a namespace
pulsaradmin/pkg/admin/namespace.go:89
MethodSetNamespaceReplicationClusters
SetNamespaceReplicationClusters returns the replication clusters for a namespace
pulsaradmin/pkg/admin/namespace.go:384
MethodSetNamespaceReplicationClusters
(namespace string, clusterIDs []string)
pulsaradmin/pkg/admin/namespace.go:1426
MethodSetNamespaceReplicationClustersWithContext
SetNamespaceReplicationClustersWithContext returns the replication clusters for a namespace
pulsaradmin/pkg/admin/namespace.go:387
MethodSetOffloadDeleteLag
(namespace utils.NameSpaceName, timeMs int64)
pulsaradmin/pkg/admin/namespace.go:1183
MethodSetOffloadDeleteLagWithContext
SetOffloadDeleteLagWithContext sets the offload deletion lag for a namespace
pulsaradmin/pkg/admin/namespace.go:243
MethodSetOffloadPolicies
(context.Context, utils.TopicName, utils.OffloadPolicies)
pulsaradmin/pkg/admin/topic_policies.go:125
MethodSetOffloadPolicies
( ctx context.Context, topic utils.TopicName, offloadPolicies utils.OffloadPolicies, )
pulsaradmin/pkg/admin/topic_policies.go:864
MethodSetOffloadPolicies
(topic utils.TopicName, offloadPolicies utils.OffloadPolicies)
pulsaradmin/pkg/admin/topic.go:2413
MethodSetOffloadPoliciesWithContext
SetOffloadPoliciesWithContext sets offload policies for a topic
pulsaradmin/pkg/admin/topic.go:1004
MethodSetOffloadThreshold
SetOffloadThreshold sets the offloadThreshold for a namespace
pulsaradmin/pkg/admin/namespace.go:253
MethodSetOffloadThreshold
(namespace utils.NameSpaceName, threshold int64)
pulsaradmin/pkg/admin/namespace.go:1248
MethodSetOffloadThresholdInSeconds
(namespace utils.NameSpaceName, threshold int64)
pulsaradmin/pkg/admin/namespace.go:1272
MethodSetOffloadThresholdInSecondsWithContext
SetOffloadThresholdInSecondsWithContext sets the offloadThresholdInSeconds for a namespace
pulsaradmin/pkg/admin/namespace.go:268
MethodSetOffloadThresholdWithContext
SetOffloadThresholdWithContext sets the offloadThreshold for a namespace
pulsaradmin/pkg/admin/namespace.go:256
MethodSetPersistence
(context.Context, utils.TopicName, utils.PersistenceData)
pulsaradmin/pkg/admin/topic_policies.go:53
MethodSetPersistence
( ctx context.Context, topic utils.TopicName, persistenceData utils.PersistenceData, )
pulsaradmin/pkg/admin/topic_policies.go:395
MethodSetPersistence
(topic utils.TopicName, persistenceData utils.PersistenceData)
pulsaradmin/pkg/admin/topic.go:1723
MethodSetPersistence
SetPersistence sets the persistence configuration for all the topics on a namespace
pulsaradmin/pkg/admin/namespace.go:430
MethodSetPersistence
(namespace string, persistence utils.PersistencePolicies)
pulsaradmin/pkg/admin/namespace.go:1523
MethodSetPersistenceWithContext
SetPersistenceWithContext sets the persistence policies for a topic
pulsaradmin/pkg/admin/topic.go:559
MethodSetPersistenceWithContext
SetPersistenceWithContext sets the persistence configuration for all the topics on a namespace
pulsaradmin/pkg/admin/namespace.go:433
MethodSetPublishRate
(context.Context, utils.TopicName, utils.PublishRateData)
pulsaradmin/pkg/admin/topic_policies.go:65
MethodSetPublishRate
( ctx context.Context, topic utils.TopicName, publishRateData utils.PublishRateData, )
pulsaradmin/pkg/admin/topic_policies.go:467
← previousnext →3,901–4,000 of 5,094, ranked by callers