MCPcopy Create free account

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

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

⨍ Functions 5,094◇ Types & classes 637
MethodChan
()
pulsar/internal/pulsartracing/consumer_interceptor_test.go:70
MethodClear
()
pulsar/internal/buffer.go:299
MethodClearBacklog
ClearBacklog skips all messages on a topic subscription
pulsaradmin/pkg/admin/subscription.go:84
MethodClearBacklog
(topic utils.TopicName, sName string)
pulsaradmin/pkg/admin/subscription.go:226
MethodClearBacklogWithContext
ClearBacklogWithContext skips all messages on a topic subscription
pulsaradmin/pkg/admin/subscription.go:87
MethodClearNamespaceBacklog
ClearNamespaceBacklog clears backlog for all topics on a namespace
pulsaradmin/pkg/admin/namespace.go:591
MethodClearNamespaceBacklog
(namespace utils.NameSpaceName)
pulsaradmin/pkg/admin/namespace.go:1853
MethodClearNamespaceBacklogForSubscription
ClearNamespaceBacklogForSubscription clears backlog for a given subscription on all topics on a namespace
pulsaradmin/pkg/admin/namespace.go:585
MethodClearNamespaceBacklogForSubscription
(namespace utils.NameSpaceName, sName string)
pulsaradmin/pkg/admin/namespace.go:1840
MethodClearNamespaceBacklogForSubscriptionWithContext
ClearNamespaceBacklogForSubscriptionWithContext clears backlog for a given subscription on all topics on a namespace
pulsaradmin/pkg/admin/namespace.go:588
MethodClearNamespaceBacklogWithContext
ClearNamespaceBacklogWithContext clears backlog for all topics on a namespace
pulsaradmin/pkg/admin/namespace.go:594
MethodClearNamespaceBundleBacklog
ClearNamespaceBundleBacklog clears backlog for all topics on a namespace bundle
pulsaradmin/pkg/admin/namespace.go:579
MethodClearNamespaceBundleBacklog
(namespace utils.NameSpaceName, bundle string)
pulsaradmin/pkg/admin/namespace.go:1827
MethodClearNamespaceBundleBacklogForSubscription
ClearNamespaceBundleBacklogForSubscription clears backlog for a given subscription on all topics on a namespace bundle
pulsaradmin/pkg/admin/namespace.go:567
MethodClearNamespaceBundleBacklogForSubscription
(namespace utils.NameSpaceName, bundle, sName string)
pulsaradmin/pkg/admin/namespace.go:1814
MethodClearNamespaceBundleBacklogForSubscriptionWithContext
ClearNamespaceBundleBacklogForSubscriptionWithContext clears backlog for a given subscription on all topics on a namespace bundle
pulsaradmin/pkg/admin/namespace.go:571
MethodClearNamespaceBundleBacklogWithContext
ClearNamespaceBundleBacklogWithContext clears backlog for all topics on a namespace bundle
pulsaradmin/pkg/admin/namespace.go:582
MethodClearOffloadDeleteLag
ClearOffloadDeleteLag clears the offload deletion lag for a namespace.
pulsaradmin/pkg/admin/namespace.go:234
MethodClearOffloadDeleteLag
(namespace utils.NameSpaceName)
pulsaradmin/pkg/admin/namespace.go:1174
MethodClearOffloadDeleteLagWithContext
ClearOffloadDeleteLagWithContext clears the offload deletion lag for a namespace.
pulsaradmin/pkg/admin/namespace.go:237
MethodClone
()
pulsar/internal/compression/lz4.go:103
MethodClone
()
pulsar/internal/compression/noop.go:59
MethodClone
()
pulsar/internal/compression/zstd_cgo.go:88
MethodClone
()
pulsar/internal/compression/zlib.go:75
MethodClone
()
pulsar/internal/compression/snappy.go:48
MethodClone
()
pulsar/internal/compression/zstd_go.go:70
MethodClose
()
pulsar/producer_impl.go:353
MethodClose
()
pulsar/consumer_test.go:6150
MethodClose
Close closes the table view and releases resources allocated.
pulsar/table_view.go:77
MethodClose
()
pulsar/consumer_regex.go:316
MethodClose
()
pulsar/table_view_impl.go:233
MethodClose
()
pulsar/consumer_multitopic.go:333
MethodClose
()
pulsar/consumer_multitopic_test.go:360
MethodClose
()
pulsar/producer_partition.go:1599
MethodClose
()
pulsar/consumer_partition.go:2808
MethodClose
()
pulsar/negative_acks_tracker.go:197
MethodClose
()
pulsar/reader_impl.go:193
MethodClose
()
pulsar/client_impl.go:272
MethodClose
()
pulsar/consumer_zero_queue.go:263
MethodClose
()
pulsar/auth/disabled.go:48
MethodClose
()
pulsar/auth/oauth2.go:116
MethodClose
()
pulsar/auth/basic.go:68
MethodClose
()
pulsar/auth/athenz.go:207
MethodClose
()
pulsar/auth/tls.go:76
MethodClose
()
pulsar/auth/token.go:107
MethodClose
()
pulsar/internal/lookup_service_test.go:590
MethodClose
()
pulsar/internal/batch_builder.go:304
MethodClose
()
pulsar/internal/http_client.go:51
MethodClose
()
pulsar/internal/connection_pool.go:154
MethodClose
()
pulsar/internal/rpc_client.go:264
MethodClose
()
pulsar/internal/key_based_batch_builder.go:226
MethodClose
()
pulsar/internal/lookup_service.go:284
MethodClose
()
pulsar/internal/lookup_service.go:444
MethodClose
()
pulsar/internal/pulsartracing/producer_interceptor_test.go:74
MethodClose
()
pulsar/internal/pulsartracing/consumer_interceptor_test.go:104
MethodClose
()
pulsar/internal/compression/lz4.go:99
MethodClose
()
pulsar/internal/compression/noop.go:55
MethodClose
()
pulsar/internal/compression/zstd_cgo.go:84
MethodClose
()
pulsar/internal/compression/zlib.go:79
MethodClose
()
pulsar/internal/compression/snappy.go:44
MethodClose
()
pulsar/internal/compression/zstd_go.go:65
MethodClusters
Clusters is used to access the cluster endpoints.
pulsaradmin/pkg/admin/cluster.go:107
MethodCommit
(ctx context.Context)
pulsar/transaction_impl.go:89
MethodCompact
Compact triggers compaction to run for a topic. A single topic can only have one instance of compaction running at any time. Any attempt to trigger an
pulsaradmin/pkg/admin/topic.go:382
MethodCompact
(topic utils.TopicName)
pulsaradmin/pkg/admin/topic.go:1521
MethodCompactStatus
CompactStatus checks the status of an ongoing compaction for a topic
pulsaradmin/pkg/admin/topic.go:389
MethodCompactStatus
(topic utils.TopicName)
pulsaradmin/pkg/admin/topic.go:1530
MethodCompactStatusWithContext
CompactStatusWithContext checks the status of an ongoing compaction for a topic
pulsaradmin/pkg/admin/topic.go:392
MethodCompactWithContext
CompactWithContext triggers compaction to run for a topic. A single topic can only have one instance of compaction running at any time. Any attempt to
pulsaradmin/pkg/admin/topic.go:386
MethodCompareAndPoll
(compare func(interface{}) bool)
pulsar/producer_test.go:2551
MethodCompareAndPoll
(compare func(interface{}) bool)
pulsar/internal/blocking_queue.go:152
MethodCompareTo
(o *ResourceUsage)
pulsaradmin/pkg/utils/load_manage_report.go:122
MethodCompress
(dst, data []byte)
pulsar/internal/compression/lz4.go:50
MethodCompress
(dst, src []byte)
pulsar/internal/compression/noop.go:35
MethodCompress
(dst, src []byte)
pulsar/internal/compression/zstd_cgo.go:67
MethodCompress
(dst, src []byte)
pulsar/internal/compression/zlib.go:39
MethodCompress
(dst, src []byte)
pulsar/internal/compression/snappy.go:36
MethodCompress
(dst, src []byte)
pulsar/internal/compression/zstd_go.go:57
MethodCompressMaxSize
(originalSize int)
pulsar/internal/compression/lz4.go:41
MethodCompressMaxSize
(originalSize int)
pulsar/internal/compression/noop.go:31
MethodCompressMaxSize
Return the max possible size for a compressed buffer given the uncompressed data size
pulsar/internal/compression/compression.go:33
MethodCompressMaxSize
(originalSize int)
pulsar/internal/compression/zstd_cgo.go:63
MethodCompressMaxSize
(originalSize int)
pulsar/internal/compression/zlib.go:33
MethodCompressMaxSize
(srcSize int)
pulsar/internal/compression/snappy.go:32
MethodCompressMaxSize
(srcSize int)
pulsar/internal/compression/zstd_go.go:46
MethodConnectionClosed
(closeProducer *pb.CommandCloseProducer)
pulsar/producer_partition.go:420
MethodConnectionClosed
(closeConsumer *pb.CommandCloseConsumer)
pulsar/consumer_partition.go:1752
MethodConnectionClosed
ConnectionClosed close the TCP connection.
pulsar/internal/connection.go:72
MethodContainsKey
ContainsKey returns true if this TableView contains a mapping for the specified key.
pulsar/table_view.go:57
MethodContainsKey
(key string)
pulsar/table_view_impl.go:175
MethodCreate
Create creates a new tenant
pulsaradmin/pkg/admin/tenant.go:29
MethodCreate
(data utils.TenantData)
pulsaradmin/pkg/admin/tenant.go:72
MethodCreate
Create creates a new subscription on a topic
pulsaradmin/pkg/admin/subscription.go:39
MethodCreate
(topic utils.TopicName, sName string, messageID utils.MessageID)
pulsaradmin/pkg/admin/subscription.go:149
MethodCreate
(topic utils.TopicName, partitions int)
pulsaradmin/pkg/admin/topic.go:1138
MethodCreate
Create a new cluster
pulsaradmin/pkg/admin/cluster.go:41
MethodCreate
(cdata utils.ClusterData)
pulsaradmin/pkg/admin/cluster.go:135
MethodCreateFailureDomain
CreateFailureDomain creates a domain into cluster
pulsaradmin/pkg/admin/cluster.go:71
MethodCreateFailureDomain
(data utils.FailureDomainData)
pulsaradmin/pkg/admin/cluster.go:182
MethodCreateFailureDomainWithContext
CreateFailureDomain creates a domain into cluster
pulsaradmin/pkg/admin/cluster.go:74
← previousnext →1,801–1,900 of 5,094, ranked by callers