Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/apache/pulsar-client-go
/ functions
Functions
5,094 in github.com/apache/pulsar-client-go
⨍
Functions
5,094
◇
Types & classes
637
Method
SetDelayedDelivery
(topic utils.TopicName, delayedDeliveryData utils.DelayedDeliveryData)
pulsaradmin/pkg/admin/topic.go:1756
Method
SetDelayedDeliveryWithContext
SetDelayedDeliveryWithContext sets the delayed delivery policy on a topic
pulsaradmin/pkg/admin/topic.go:579
Method
SetDispatchRate
(context.Context, utils.TopicName, utils.DispatchRateData)
pulsaradmin/pkg/admin/topic_policies.go:61
Method
SetDispatchRate
( ctx context.Context, topic utils.TopicName, dispatchRateData utils.DispatchRateData, )
pulsaradmin/pkg/admin/topic_policies.go:443
Method
SetDispatchRate
(topic utils.TopicName, dispatchRateData utils.DispatchRateData)
pulsaradmin/pkg/admin/topic.go:1789
Method
SetDispatchRate
SetDispatchRate sets Message-dispatch-rate (topics under this namespace can dispatch this many messages per second)
pulsaradmin/pkg/admin/namespace.go:651
Method
SetDispatchRate
(namespace utils.NameSpaceName, rate utils.DispatchRate)
pulsaradmin/pkg/admin/namespace.go:1943
Method
SetDispatchRateWithContext
SetDispatchRateWithContext sets message dispatch rate for a topic
pulsaradmin/pkg/admin/topic.go:599
Method
SetDispatchRateWithContext
SetDispatchRateWithContext sets Message-dispatch-rate (topics under this namespace can dispatch this many messages per second)
pulsaradmin/pkg/admin/namespace.go:655
Method
SetEncryptionParam
(param []byte)
pulsar/crypto/message_metadata.go:85
Method
SetEncryptionRequiredStatus
SetEncryptionRequiredStatus sets the encryption required status for all topics within a namespace
pulsaradmin/pkg/admin/namespace.go:548
Method
SetEncryptionRequiredStatus
(namespace utils.NameSpaceName, encrypt bool)
pulsaradmin/pkg/admin/namespace.go:1774
Method
SetEncryptionRequiredStatusWithContext
SetEncryptionRequiredStatusWithContext sets the encryption required status for all topics within a namespace
pulsaradmin/pkg/admin/namespace.go:551
Method
SetExpiration
(_ time.Duration)
pulsar/auth/athenz_test.go:52
Method
SetHostname
(_ string)
pulsar/auth/athenz_test.go:54
Method
SetIPAddress
(_ string)
pulsar/auth/athenz_test.go:56
Method
SetInactiveTopicPolicies
(context.Context, utils.TopicName, utils.InactiveTopicPolicies)
pulsaradmin/pkg/admin/topic_policies.go:85
Method
SetInactiveTopicPolicies
( ctx context.Context, topic utils.TopicName, data utils.InactiveTopicPolicies, )
pulsaradmin/pkg/admin/topic_policies.go:601
Method
SetInactiveTopicPolicies
SetInactiveTopicPolicies sets the inactive topic policies on a topic
pulsaradmin/pkg/admin/topic.go:806
Method
SetInactiveTopicPolicies
(topic utils.TopicName, data utils.InactiveTopicPolicies)
pulsaradmin/pkg/admin/topic.go:2011
Method
SetInactiveTopicPolicies
SetInactiveTopicPolicies sets the inactive topic policies on a namespace
pulsaradmin/pkg/admin/namespace.go:711
Method
SetInactiveTopicPolicies
(namespace utils.NameSpaceName, data utils.InactiveTopicPolicies)
pulsaradmin/pkg/admin/namespace.go:2046
Method
SetInactiveTopicPoliciesWithContext
SetInactiveTopicPoliciesWithContext sets the inactive topic policies on a topic
pulsaradmin/pkg/admin/topic.go:809
Method
SetInactiveTopicPoliciesWithContext
SetInactiveTopicPoliciesWithContext sets the inactive topic policies on a namespace
pulsaradmin/pkg/admin/namespace.go:714
Method
SetIsAllowAutoUpdateSchema
SetIsAllowAutoUpdateSchema sets whether to allow auto update schema on a namespace
pulsaradmin/pkg/admin/namespace.go:680
Method
SetIsAllowAutoUpdateSchema
(namespace utils.NameSpaceName, isAllowAutoUpdateSchema bool)
pulsaradmin/pkg/admin/namespace.go:1996
Method
SetIsAllowAutoUpdateSchemaWithContext
SetIsAllowAutoUpdateSchemaWithContext sets whether to allow auto update schema on a namespace
pulsaradmin/pkg/admin/namespace.go:683
Method
SetKeyService
(_ string)
pulsar/auth/athenz_test.go:58
Method
SetMaxConsumers
(context.Context, utils.TopicName, int)
pulsaradmin/pkg/admin/topic_policies.go:41
Method
SetMaxConsumers
(ctx context.Context, topic utils.TopicName, maxConsumers int)
pulsaradmin/pkg/admin/topic_policies.go:321
Method
SetMaxConsumers
(topic utils.TopicName, maxConsumers int)
pulsaradmin/pkg/admin/topic.go:1624
Method
SetMaxConsumersPerSubscription
(context.Context, utils.TopicName, int)
pulsaradmin/pkg/admin/topic_policies.go:101
Method
SetMaxConsumersPerSubscription
( ctx context.Context, topic utils.TopicName, maxConsumers int, )
pulsaradmin/pkg/admin/topic_policies.go:705
Method
SetMaxConsumersPerSubscription
(topic utils.TopicName, maxConsumers int)
pulsaradmin/pkg/admin/topic.go:2125
Method
SetMaxConsumersPerSubscription
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
Method
SetMaxConsumersPerSubscription
nolint: revive // It's ok here to use a built-in function name (max)
pulsaradmin/pkg/admin/namespace.go:1208
Method
SetMaxConsumersPerSubscriptionWithContext
SetMaxConsumersPerSubscriptionWithContext sets max consumers per subscription for a topic
pulsaradmin/pkg/admin/topic.go:891
Method
SetMaxConsumersPerSubscriptionWithContext
SetMaxConsumersPerSubscriptionWithContext sets maxConsumersPerSubscription for a namespace. nolint: revive // It's ok here to use a built-in function
pulsaradmin/pkg/admin/namespace.go:294
Method
SetMaxConsumersPerTopic
nolint: revive // It's ok here to use a built-in function name (max)
pulsaradmin/pkg/admin/namespace.go:1300
Method
SetMaxConsumersPerTopicWithContext
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
Method
SetMaxConsumersWithContext
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
Method
SetMaxMessageSize
(context.Context, utils.TopicName, int)
pulsaradmin/pkg/admin/topic_policies.go:105
Method
SetMaxMessageSize
( ctx context.Context, topic utils.TopicName, maxMessageSize int, )
pulsaradmin/pkg/admin/topic_policies.go:732
Method
SetMaxMessageSize
(topic utils.TopicName, maxMessageSize int)
pulsaradmin/pkg/admin/topic.go:2159
Method
SetMaxMessageSizeWithContext
SetMaxMessageSizeWithContext sets max message size for a topic
pulsaradmin/pkg/admin/topic.go:909
Method
SetMaxProducers
(context.Context, utils.TopicName, int)
pulsaradmin/pkg/admin/topic_policies.go:37
Method
SetMaxProducers
(ctx context.Context, topic utils.TopicName, maxProducers int)
pulsaradmin/pkg/admin/topic_policies.go:301
Method
SetMaxProducers
(topic utils.TopicName, maxProducers int)
pulsaradmin/pkg/admin/topic.go:1592
Method
SetMaxProducersPerTopic
nolint: revive // It's ok here to use a built-in function name (max)
pulsaradmin/pkg/admin/namespace.go:1368
Method
SetMaxProducersPerTopicWithContext
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
Method
SetMaxProducersWithContext
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
Method
SetMaxSubscriptionsPerTopic
(context.Context, utils.TopicName, int)
pulsaradmin/pkg/admin/topic_policies.go:109
Method
SetMaxSubscriptionsPerTopic
( ctx context.Context, topic utils.TopicName, maxSubscriptions int, )
pulsaradmin/pkg/admin/topic_policies.go:756
Method
SetMaxSubscriptionsPerTopic
(topic utils.TopicName, maxSubscriptions int)
pulsaradmin/pkg/admin/topic.go:2189
Method
SetMaxSubscriptionsPerTopicWithContext
SetMaxSubscriptionsPerTopicWithContext sets max subscriptions per topic
pulsaradmin/pkg/admin/topic.go:927
Method
SetMaxTopicsPerNamespace
nolint: revive // It's ok here to use a built-in function name (max)
pulsaradmin/pkg/admin/namespace.go:2134
Method
SetMaxTopicsPerNamespaceWithContext
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
Method
SetMaxUnackMessagesPerConsumer
(context.Context, utils.TopicName, int)
pulsaradmin/pkg/admin/topic_policies.go:45
Method
SetMaxUnackMessagesPerConsumer
( ctx context.Context, topic utils.TopicName, maxUnackedNum int, )
pulsaradmin/pkg/admin/topic_policies.go:341
Method
SetMaxUnackMessagesPerConsumer
(topic utils.TopicName, maxUnackedNum int)
pulsaradmin/pkg/admin/topic.go:1656
Method
SetMaxUnackMessagesPerConsumerWithContext
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
Method
SetMaxUnackMessagesPerSubscription
(context.Context, utils.TopicName, int)
pulsaradmin/pkg/admin/topic_policies.go:49
Method
SetMaxUnackMessagesPerSubscription
( ctx context.Context, topic utils.TopicName, maxUnackedNum int, )
pulsaradmin/pkg/admin/topic_policies.go:368
Method
SetMaxUnackMessagesPerSubscription
(topic utils.TopicName, maxUnackedNum int)
pulsaradmin/pkg/admin/topic.go:1693
Method
SetMaxUnackMessagesPerSubscriptionWithContext
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
Method
SetMessageTTL
(context.Context, utils.TopicName, int)
pulsaradmin/pkg/admin/topic_policies.go:33
Method
SetMessageTTL
(ctx context.Context, topic utils.TopicName, messageTTL int)
pulsaradmin/pkg/admin/topic_policies.go:277
Method
SetMessageTTL
(topic utils.TopicName, messageTTL int)
pulsaradmin/pkg/admin/topic.go:1556
Method
SetMessageTTLWithContext
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
Method
SetNamespaceAntiAffinityGroup
SetNamespaceAntiAffinityGroup sets anti-affinity group name for a namespace
pulsaradmin/pkg/admin/namespace.go:390
Method
SetNamespaceAntiAffinityGroup
(namespace string, namespaceAntiAffinityGroup string)
pulsaradmin/pkg/admin/namespace.go:1443
Method
SetNamespaceAntiAffinityGroupWithContext
SetNamespaceAntiAffinityGroupWithContext sets anti-affinity group name for a namespace
pulsaradmin/pkg/admin/namespace.go:393
Method
SetNamespaceBundleResourceQuota
SetNamespaceBundleResourceQuota sets resource quota for a namespace bundle.
pulsaradmin/pkg/admin/resource_quotas.go:46
Method
SetNamespaceBundleResourceQuota
(namespace, bundle string, quota utils.ResourceQuota)
pulsaradmin/pkg/admin/resource_quotas.go:116
Method
SetNamespaceBundleResourceQuotaWithContext
SetNamespaceBundleResourceQuotaWithContext sets resource quota for a namespace bundle.
pulsaradmin/pkg/admin/resource_quotas.go:49
Method
SetNamespaceMessageTTL
(namespace string, ttlInSeconds int)
pulsaradmin/pkg/admin/namespace.go:916
Method
SetNamespaceMessageTTLWithContext
SetNamespaceMessageTTLWithContext sets the messages Time to Live for all the topics within a namespace
pulsaradmin/pkg/admin/namespace.go:89
Method
SetNamespaceReplicationClusters
SetNamespaceReplicationClusters returns the replication clusters for a namespace
pulsaradmin/pkg/admin/namespace.go:384
Method
SetNamespaceReplicationClusters
(namespace string, clusterIDs []string)
pulsaradmin/pkg/admin/namespace.go:1426
Method
SetNamespaceReplicationClustersWithContext
SetNamespaceReplicationClustersWithContext returns the replication clusters for a namespace
pulsaradmin/pkg/admin/namespace.go:387
Method
SetOffloadDeleteLag
(namespace utils.NameSpaceName, timeMs int64)
pulsaradmin/pkg/admin/namespace.go:1183
Method
SetOffloadDeleteLagWithContext
SetOffloadDeleteLagWithContext sets the offload deletion lag for a namespace
pulsaradmin/pkg/admin/namespace.go:243
Method
SetOffloadPolicies
(context.Context, utils.TopicName, utils.OffloadPolicies)
pulsaradmin/pkg/admin/topic_policies.go:125
Method
SetOffloadPolicies
( ctx context.Context, topic utils.TopicName, offloadPolicies utils.OffloadPolicies, )
pulsaradmin/pkg/admin/topic_policies.go:864
Method
SetOffloadPolicies
(topic utils.TopicName, offloadPolicies utils.OffloadPolicies)
pulsaradmin/pkg/admin/topic.go:2413
Method
SetOffloadPoliciesWithContext
SetOffloadPoliciesWithContext sets offload policies for a topic
pulsaradmin/pkg/admin/topic.go:1004
Method
SetOffloadThreshold
SetOffloadThreshold sets the offloadThreshold for a namespace
pulsaradmin/pkg/admin/namespace.go:253
Method
SetOffloadThreshold
(namespace utils.NameSpaceName, threshold int64)
pulsaradmin/pkg/admin/namespace.go:1248
Method
SetOffloadThresholdInSeconds
(namespace utils.NameSpaceName, threshold int64)
pulsaradmin/pkg/admin/namespace.go:1272
Method
SetOffloadThresholdInSecondsWithContext
SetOffloadThresholdInSecondsWithContext sets the offloadThresholdInSeconds for a namespace
pulsaradmin/pkg/admin/namespace.go:268
Method
SetOffloadThresholdWithContext
SetOffloadThresholdWithContext sets the offloadThreshold for a namespace
pulsaradmin/pkg/admin/namespace.go:256
Method
SetPersistence
(context.Context, utils.TopicName, utils.PersistenceData)
pulsaradmin/pkg/admin/topic_policies.go:53
Method
SetPersistence
( ctx context.Context, topic utils.TopicName, persistenceData utils.PersistenceData, )
pulsaradmin/pkg/admin/topic_policies.go:395
Method
SetPersistence
(topic utils.TopicName, persistenceData utils.PersistenceData)
pulsaradmin/pkg/admin/topic.go:1723
Method
SetPersistence
SetPersistence sets the persistence configuration for all the topics on a namespace
pulsaradmin/pkg/admin/namespace.go:430
Method
SetPersistence
(namespace string, persistence utils.PersistencePolicies)
pulsaradmin/pkg/admin/namespace.go:1523
Method
SetPersistenceWithContext
SetPersistenceWithContext sets the persistence policies for a topic
pulsaradmin/pkg/admin/topic.go:559
Method
SetPersistenceWithContext
SetPersistenceWithContext sets the persistence configuration for all the topics on a namespace
pulsaradmin/pkg/admin/namespace.go:433
Method
SetPublishRate
(context.Context, utils.TopicName, utils.PublishRateData)
pulsaradmin/pkg/admin/topic_policies.go:65
Method
SetPublishRate
( ctx context.Context, topic utils.TopicName, publishRateData utils.PublishRateData, )
pulsaradmin/pkg/admin/topic_policies.go:467
← previous
next →
3,901–4,000 of 5,094, ranked by callers