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
RevokeNamespacePermission
RevokeNamespacePermission revokes permissions on a namespace.
pulsaradmin/pkg/admin/namespace.go:514
Method
RevokeNamespacePermission
(namespace utils.NameSpaceName, role string)
pulsaradmin/pkg/admin/namespace.go:1704
Method
RevokeNamespacePermissionWithContext
RevokeNamespacePermissionWithContext revokes permissions on a namespace.
pulsaradmin/pkg/admin/namespace.go:517
Method
RevokePermission
RevokePermission revokes permissions to a client role on a single topic. If the permission was not set at the topic level, but rather at the namespace
pulsaradmin/pkg/admin/topic.go:204
Method
RevokePermission
(topic utils.TopicName, role string)
pulsaradmin/pkg/admin/topic.go:1336
Method
RevokePermissionWithContext
RevokePermissionWithContext revokes permissions to a client role on a single topic. If the permission was not set at the topic level, but rather at th
pulsaradmin/pkg/admin/topic.go:216
Method
RevokeSubPermission
(namespace utils.NameSpaceName, sName, role string)
pulsaradmin/pkg/admin/namespace.go:1732
Method
RevokeSubPermissionWithContext
RevokeSubPermissionWithContext revoke permissions on a subscription's admin-api access
pulsaradmin/pkg/admin/namespace.go:529
Method
RoundTrip
(_ *http.Request)
pulsar/auth/disabled.go:52
Method
RoundTrip
(req *http.Request)
pulsar/auth/oauth2.go:125
Method
RoundTrip
(req *http.Request)
pulsar/auth/oauth2.go:147
Method
RoundTrip
(req *http.Request)
pulsar/auth/basic.go:72
Method
RoundTrip
(req *http.Request)
pulsar/auth/athenz.go:259
Method
RoundTrip
(req *http.Request)
pulsar/auth/tls.go:80
Method
RoundTrip
(req *http.Request)
pulsar/auth/token.go:111
Method
RoundTrip
(_ *http.Request)
pulsaradmin/pkg/admin/admin_test.go:64
Method
RoundTrip
(req *http.Request)
pulsaradmin/pkg/admin/auth/provider.go:45
Method
RoundTrip
(req *http.Request)
pulsaradmin/pkg/admin/auth/oauth2.go:140
Method
RoundTrip
(req *http.Request)
pulsaradmin/pkg/admin/auth/oauth2.go:157
Method
RoundTrip
(req *http.Request)
pulsaradmin/pkg/admin/auth/tls.go:88
Method
RoundTrip
(req *http.Request)
pulsaradmin/pkg/admin/auth/token.go:93
Method
SaveTokens
(identifier, accessToken, refreshToken string)
oauth2/config_tokenprovider_test.go:39
Method
SchemaVersion
()
pulsar/impl_message.go:384
Method
SchemaVersion
()
pulsar/negative_acks_tracker_test.go:248
Method
SchemaVersion
()
pulsar/negative_acks_tracker_test.go:324
Method
SchemaVersion
()
pulsar/internal/pulsartracing/message_carrier_util_test.go:127
Method
Schemas
Schemas is used to access the schemas endpoints
pulsaradmin/pkg/admin/schema.go:74
Method
Seek
Seek resets the subscription associated with this consumer to a specific message id. The message id can either be a specific message or represent the
pulsar/consumer.go:423
Method
Seek
(_ MessageID)
pulsar/consumer_regex.go:338
Method
Seek
(_ MessageID)
pulsar/consumer_multitopic.go:351
Method
Seek
(msgID MessageID)
pulsar/consumer_partition.go:1051
Method
Seek
(msgID MessageID)
pulsar/reader_impl.go:199
Method
Seek
(msgID MessageID)
pulsar/consumer_impl.go:740
Method
Seek
(msgID MessageID)
pulsar/consumer_zero_queue.go:285
Method
Seek
(_ pulsar.MessageID)
pulsar/internal/pulsartracing/consumer_interceptor_test.go:106
Method
SeekByTime
SeekByTime resets the subscription associated with this consumer to a specific message publish time. @param time the message publish time when to rep
pulsar/consumer.go:430
Method
SeekByTime
(_ time.Time)
pulsar/consumer_regex.go:342
Method
SeekByTime
(_ time.Time)
pulsar/consumer_multitopic.go:355
Method
SeekByTime
(time time.Time)
pulsar/consumer_partition.go:1129
Method
SeekByTime
(time time.Time)
pulsar/reader_impl.go:219
Method
SeekByTime
(time time.Time)
pulsar/consumer_impl.go:760
Method
SeekByTime
(time time.Time)
pulsar/consumer_zero_queue.go:305
Method
SeekByTime
(_ time.Time)
pulsar/internal/pulsartracing/consumer_interceptor_test.go:110
Method
Send
(ctx context.Context, msg *ProducerMessage)
pulsar/producer_impl.go:292
Method
Send
(ctx context.Context, msg *ProducerMessage)
pulsar/producer_partition.go:1113
Method
Send
(context.Context, *pulsar.ProducerMessage)
pulsar/internal/pulsartracing/producer_interceptor_test.go:54
Method
SendAsync
(ctx context.Context, msg *ProducerMessage, callback func(MessageID, *ProducerMessage, error))
pulsar/producer_impl.go:296
Method
SendAsync
(ctx context.Context, msg *ProducerMessage, callback func(MessageID, *ProducerMessage, error))
pulsar/producer_partition.go:1139
Method
SendAsync
(context.Context, *pulsar.ProducerMessage, func(pulsar.MessageID, *pulsar.ProducerMessage, error))
pulsar/internal/pulsartracing/producer_interceptor_test.go:58
Method
SendRequest
(_ uint64, _ *pb.BaseCommand, _ func(*pb.BaseCommand, error))
pulsar/consumer_multitopic_test.go:328
Method
SendRequest
(requestID uint64, req *pb.BaseCommand, callback func(*pb.BaseCommand, error))
pulsar/producer_test.go:2752
Method
SendRequest
(requestID uint64, req *pb.BaseCommand, callback func(command *pb.BaseCommand, err error))
pulsar/internal/connection.go:666
Method
SendRequestNoWait
(_ *pb.BaseCommand)
pulsar/consumer_multitopic_test.go:331
Method
SendRequestNoWait
(req *pb.BaseCommand)
pulsar/internal/connection.go:686
Method
Serialize
()
pulsar/reader_test.go:567
Method
Serialize
()
pulsar/impl_message.go:164
Method
Serialize
()
pulsar/impl_message.go:507
Method
Serialize
()
pulsar/impl_message.go:529
Method
ServiceNameResolver
()
pulsar/internal/lookup_service.go:286
Method
ServiceNameResolver
()
pulsar/internal/lookup_service.go:440
Method
Set
(_, _ string)
pulsar/internal/pulsartracing/message_carrier_adaptors.go:41
Method
Set
(_, _ string)
pulsar/internal/pulsartracing/message_carrier_adaptors.go:71
Method
Set
(key, val string)
pulsar/internal/pulsartracing/message_carrier_adaptors.go:82
Method
SetAutoSubscriptionCreation
(context.Context, utils.TopicName, utils.AutoSubscriptionCreationOverride)
pulsaradmin/pkg/admin/topic_policies.go:129
Method
SetAutoSubscriptionCreation
( ctx context.Context, topic utils.TopicName, autoSubCreation utils.AutoSubscriptionCreationOverride, )
pulsaradmin/pkg/admin/topic_policies.go:888
Method
SetAutoSubscriptionCreation
(topic utils.TopicName, autoSubCreation utils.AutoSubscriptionCreationOverride)
pulsaradmin/pkg/admin/topic.go:2323
Method
SetAutoSubscriptionCreationWithContext
SetAutoSubscriptionCreationWithContext sets auto subscription creation override for a topic
pulsaradmin/pkg/admin/topic.go:1028
Method
SetBacklogQuota
(context.Context, utils.TopicName, utils.BacklogQuota, utils.BacklogQuotaType)
pulsaradmin/pkg/admin/topic_policies.go:81
Method
SetBacklogQuota
( ctx context.Context, topic utils.TopicName, backlogQuota utils.BacklogQuota, backlogQuotaType utils.Back
pulsaradmin/pkg/admin/topic_policies.go:568
Method
SetBacklogQuota
(topic utils.TopicName, backlogQuota utils.BacklogQuota, backlogQuotaType utils.BacklogQuotaType)
pulsaradmin/pkg/admin/topic.go:1955
Method
SetBacklogQuota
SetBacklogQuota sets a backlog quota for all the topics on a namespace
pulsaradmin/pkg/admin/namespace.go:133
Method
SetBacklogQuota
(namespace string, backlogQuota utils.BacklogQuota, backlogQuotaType utils.BacklogQuotaType)
pulsaradmin/pkg/admin/namespace.go:1009
Method
SetBacklogQuotaWithContext
SetBacklogQuotaWithContext sets a backlog quota for a topic
pulsaradmin/pkg/admin/topic.go:767
Method
SetBacklogQuotaWithContext
SetBacklogQuotaWithContext sets a backlog quota for all the topics on a namespace
pulsaradmin/pkg/admin/namespace.go:136
Method
SetBookieAffinityGroup
(namespace string, bookieAffinityGroup utils.BookieAffinityGroupData)
pulsaradmin/pkg/admin/namespace.go:1553
Method
SetBookieAffinityGroupWithContext
SetBookieAffinityGroupWithContext sets bookie affinity group for a namespace to isolate namespace write to bookies that are part of given affinity gro
pulsaradmin/pkg/admin/namespace.go:455
Method
SetCompactionThreshold
(context.Context, utils.TopicName, int64)
pulsaradmin/pkg/admin/topic_policies.go:77
Method
SetCompactionThreshold
( ctx context.Context, topic utils.TopicName, threshold int64, )
pulsaradmin/pkg/admin/topic_policies.go:539
Method
SetCompactionThreshold
(topic utils.TopicName, threshold int64)
pulsaradmin/pkg/admin/topic.go:1921
Method
SetCompactionThreshold
SetCompactionThreshold sets the compactionThreshold for a namespace
pulsaradmin/pkg/admin/namespace.go:277
Method
SetCompactionThreshold
(namespace utils.NameSpaceName, threshold int64)
pulsaradmin/pkg/admin/namespace.go:1340
Method
SetCompactionThresholdWithContext
SetCompactionThresholdWithContext sets the compaction threshold for a topic @param ctx context used for the request @param topic topicName struct @pa
pulsaradmin/pkg/admin/topic.go:731
Method
SetCompactionThresholdWithContext
SetCompactionThresholdWithContext sets the compactionThreshold for a namespace
pulsaradmin/pkg/admin/namespace.go:280
Method
SetDeduplicationSnapshotInterval
(context.Context, utils.TopicName, int)
pulsaradmin/pkg/admin/topic_policies.go:117
Method
SetDeduplicationSnapshotInterval
( ctx context.Context, topic utils.TopicName, interval int, )
pulsaradmin/pkg/admin/topic_policies.go:810
Method
SetDeduplicationSnapshotInterval
(topic utils.TopicName, interval int)
pulsaradmin/pkg/admin/topic.go:2257
Method
SetDeduplicationSnapshotIntervalWithContext
SetDeduplicationSnapshotIntervalWithContext sets deduplication snapshot interval for a topic
pulsaradmin/pkg/admin/topic.go:964
Method
SetDeduplicationStatus
(context.Context, utils.TopicName, bool)
pulsaradmin/pkg/admin/topic_policies.go:69
Method
SetDeduplicationStatus
( ctx context.Context, topic utils.TopicName, enabled bool, )
pulsaradmin/pkg/admin/topic_policies.go:491
Method
SetDeduplicationStatus
SetDeduplicationStatus sets the deduplication policy for a topic @param topic topicName struct @param enabled set enable or disable deduplication of
pulsaradmin/pkg/admin/topic.go:639
Method
SetDeduplicationStatus
(topic utils.TopicName, enabled bool)
pulsaradmin/pkg/admin/topic.go:1853
Method
SetDeduplicationStatus
SetDeduplicationStatus sets the deduplication status for all topics within a namespace When deduplication is enabled, the broker will prevent to store
pulsaradmin/pkg/admin/namespace.go:423
Method
SetDeduplicationStatus
(namespace string, enableDeduplication bool)
pulsaradmin/pkg/admin/namespace.go:1506
Method
SetDeduplicationStatusWithContext
SetDeduplicationStatusWithContext sets the deduplication policy for a topic @param ctx context used for the request @param topic topicName struct @pa
pulsaradmin/pkg/admin/topic.go:649
Method
SetDeduplicationStatusWithContext
SetDeduplicationStatusWithContext sets the deduplication status for all topics within a namespace When deduplication is enabled, the broker will preve
pulsaradmin/pkg/admin/namespace.go:427
Method
SetDefaultResourceQuota
SetDefaultResourceQuota sets default resource quota for new namespace bundles.
pulsaradmin/pkg/admin/resource_quotas.go:34
Method
SetDefaultResourceQuota
(quota utils.ResourceQuota)
pulsaradmin/pkg/admin/resource_quotas.go:89
Method
SetDefaultResourceQuotaWithContext
SetDefaultResourceQuotaWithContext sets default resource quota for new namespace bundles.
pulsaradmin/pkg/admin/resource_quotas.go:37
Method
SetDelayedDelivery
(context.Context, utils.TopicName, utils.DelayedDeliveryData)
pulsaradmin/pkg/admin/topic_policies.go:57
Method
SetDelayedDelivery
( ctx context.Context, topic utils.TopicName, delayedDeliveryData utils.DelayedDeliveryData, )
pulsaradmin/pkg/admin/topic_policies.go:419
← previous
next →
3,801–3,900 of 5,094, ranked by callers