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
CreateFunc
CreateFunc create a new function.
pulsaradmin/pkg/admin/functions.go:38
Method
CreateFunc
(funcConf *utils.FunctionConfig, fileName string)
pulsaradmin/pkg/admin/functions.go:293
Method
CreateFuncWithContext
CreateFuncWithContext create a new function.
pulsaradmin/pkg/admin/functions.go:41
Method
CreateFuncWithURL
CreateFuncWithURL creates a new function by providing url from which fun-pkg can be downloaded. Supported url: http/file eg: File: file:/dir/fileName.
pulsaradmin/pkg/admin/functions.go:53
Method
CreateFuncWithURL
(funcConf *utils.FunctionConfig, pkgURL string)
pulsaradmin/pkg/admin/functions.go:356
Method
CreateFuncWithURLWithContext
CreateFuncWithURLWithContext creates a new function by providing url from which fun-pkg can be downloaded. Supported url: http/file eg: File: file:/di
pulsaradmin/pkg/admin/functions.go:67
Method
CreateNamespace
(namespace string)
pulsaradmin/pkg/admin/namespace.go:862
Function
CreateNamespaceIsolationData
(namespaces, primary, secondry []string, autoFailoverPolicyTypeName string, autoFailoverPolicyParams map[stri
pulsaradmin/pkg/utils/ns_isolation_data.go:51
Method
CreateNamespaceIsolationPolicy
CreateNamespaceIsolationPolicy creates a namespace isolation policy for a cluster
pulsaradmin/pkg/admin/ns_isolation_policy.go:28
Method
CreateNamespaceIsolationPolicy
(cluster, policyName string, namespaceIsolationData utils.NamespaceIsolationData)
pulsaradmin/pkg/admin/ns_isolation_policy.go:98
Method
CreateNamespaceIsolationPolicyWithContext
CreateNamespaceIsolationPolicyWithContext creates a namespace isolation policy for a cluster
pulsaradmin/pkg/admin/ns_isolation_policy.go:31
Method
CreateNamespaceWithContext
CreateNamespaceWithContext creates a new empty namespace with no policies attached
pulsaradmin/pkg/admin/namespace.go:53
Method
CreateNsWithBundlesData
CreateNsWithBundlesData creates a new empty namespace with no policies attached
pulsaradmin/pkg/admin/namespace.go:68
Method
CreateNsWithBundlesData
(namespace string, bundleData *utils.BundlesData)
pulsaradmin/pkg/admin/namespace.go:842
Method
CreateNsWithBundlesDataWithContext
CreateNsWithBundlesDataWithContext creates a new empty namespace with no policies attached
pulsaradmin/pkg/admin/namespace.go:71
Method
CreateNsWithNumBundles
CreateNsWithNumBundles creates a new empty namespace with no policies attached
pulsaradmin/pkg/admin/namespace.go:56
Method
CreateNsWithNumBundles
(namespace string, numBundles int)
pulsaradmin/pkg/admin/namespace.go:817
Method
CreateNsWithNumBundlesWithContext
CreateNsWithNumBundlesWithContext creates a new empty namespace with no policies attached
pulsaradmin/pkg/admin/namespace.go:59
Method
CreateNsWithPolices
CreateNsWithPolices creates a new namespace with the specified policies
pulsaradmin/pkg/admin/namespace.go:62
Method
CreateNsWithPolices
(namespace string, policies utils.Policies)
pulsaradmin/pkg/admin/namespace.go:825
Method
CreateNsWithPolicesWithContext
CreateNsWithPolicesWithContext creates a new namespace with the specified policies
pulsaradmin/pkg/admin/namespace.go:65
Method
CreateProducer
(options ProducerOptions)
pulsar/client_impl.go:213
Method
CreateReader
(options ReaderOptions)
pulsar/client_impl.go:230
Method
CreateSchemaByPayload
(topic string, schemaPayload utils.PostSchemaPayload)
pulsaradmin/pkg/admin/schema.go:209
Method
CreateSchemaBySchemaInfo
(topic string, schemaInfo utils.SchemaInfo)
pulsaradmin/pkg/admin/schema.go:229
Method
CreateSink
CreateSink creates a new sink
pulsaradmin/pkg/admin/sinks.go:50
Method
CreateSink
(config *utils.SinkConfig, fileName string)
pulsaradmin/pkg/admin/sinks.go:208
Method
CreateSinkWithContext
CreateSinkWithContext creates a new sink
pulsaradmin/pkg/admin/sinks.go:53
Method
CreateSinkWithURL
CreateSinkWithURL creates a new sink by providing url from which fun-pkg can be downloaded. supported url: http/file
pulsaradmin/pkg/admin/sinks.go:56
Method
CreateSinkWithURL
(config *utils.SinkConfig, pkgURL string)
pulsaradmin/pkg/admin/sinks.go:270
Method
CreateSinkWithURLWithContext
CreateSinkWithURLWithContext creates a new sink by providing url from which fun-pkg can be downloaded. Supported url: http/file
pulsaradmin/pkg/admin/sinks.go:60
Method
CreateSource
CreateSource creates a new source
pulsaradmin/pkg/admin/sources.go:50
Method
CreateSource
(config *utils.SourceConfig, fileName string)
pulsaradmin/pkg/admin/sources.go:212
Method
CreateSourceWithContext
CreateSource creates a new source
pulsaradmin/pkg/admin/sources.go:53
Method
CreateSourceWithURL
CreateSourceWithURL creates a new source by providing url from which fun-pkg can be downloaded. Supported url: http/file
pulsaradmin/pkg/admin/sources.go:57
Method
CreateSourceWithURL
(config *utils.SourceConfig, pkgURL string)
pulsaradmin/pkg/admin/sources.go:274
Method
CreateSourceWithURLWithContext
CreateSourceWithURL creates a new source by providing url from which fun-pkg can be downloaded. Supported url: http/file
pulsaradmin/pkg/admin/sources.go:61
Function
CreateSpanFromMessage
(cm *pulsar.ConsumerMessage, tracer opentracing.Tracer, label string)
pulsar/internal/pulsartracing/message_carrier_util.go:80
Method
CreateTableView
(options TableViewOptions)
pulsar/client_impl.go:239
Method
CreateWithContext
CreateWithContext creates a new tenant
pulsaradmin/pkg/admin/tenant.go:32
Method
CreateWithContext
CreateWithContext creates a new subscription on a topic
pulsaradmin/pkg/admin/subscription.go:42
Method
CreateWithContext
CreateWithContext creates a partitioned or non-partitioned topic @param ctx context used for the request @param topic topicName struct @param partiti
pulsaradmin/pkg/admin/topic.go:51
Method
CreateWithContext
CreateWithContext creates a new cluster
pulsaradmin/pkg/admin/cluster.go:44
Method
CreateWithProperties
(topic utils.TopicName, partitions int, meta map[string]string)
pulsaradmin/pkg/admin/topic.go:1146
Method
CreateWithPropertiesWithContext
CreateWithPropertiesWithContext creates a partitioned or non-partitioned topic with specific properties @param ctx context used for the request @para
pulsaradmin/pkg/admin/topic.go:75
Method
CurrentUsage
()
pulsar/internal/memory_limit_controller.go:118
Method
CurrentUsagePercent
()
pulsar/internal/memory_limit_controller.go:122
Method
Debug
(args ...interface{})
pulsar/log/wrapper_logrus.go:62
Method
Debug
(args ...interface{})
pulsar/log/wrapper_logrus.go:110
Method
Debug
(args ...interface{})
pulsar/log/logger.go:42
Method
Debug
(args ...any)
pulsar/log/wrapper_slog.go:32
Method
Debug
(_ ...interface{})
pulsar/log/log.go:31
Method
Debug
(_ ...interface{})
pulsar/log/log.go:45
Method
Debugf
(format string, args ...interface{})
pulsar/log/wrapper_logrus.go:78
Method
Debugf
(format string, args ...interface{})
pulsar/log/wrapper_logrus.go:126
Method
Debugf
(format string, args ...any)
pulsar/log/wrapper_slog.go:60
Method
Debugf
(_ string, _ ...interface{})
pulsar/log/log.go:35
Method
Debugf
(_ string, _ ...interface{})
pulsar/log/log.go:49
Method
Decode
(data []byte, v interface{})
pulsar/schema.go:448
Method
Decode
(data []byte, v interface{})
pulsar/schema.go:483
Method
Decode
(data []byte, v interface{})
pulsar/schema.go:518
Method
Decode
(data []byte, v interface{})
pulsar/schema.go:553
Method
Decode
(data []byte, v interface{})
pulsar/schema.go:586
Method
Decode
(data []byte, v interface{})
pulsar/schema.go:624
Method
Decompress
(dst, src []byte, originalSize int)
pulsar/internal/compression/lz4.go:89
Method
Decompress
(dst, src []byte, _ int)
pulsar/internal/compression/noop.go:45
Method
Decompress
(dst, src []byte, _ int)
pulsar/internal/compression/zstd_cgo.go:78
Method
Decompress
(dst, src []byte, originalSize int)
pulsar/internal/compression/zlib.go:53
Method
Decompress
(dst, src []byte, _ int)
pulsar/internal/compression/snappy.go:40
Method
Decompress
(dst, src []byte, _ int)
pulsar/internal/compression/zstd_go.go:61
Method
Decrypt
(payload []byte, _ *pb.MessageIdData, msgMetadata *pb.MessageMetadata)
pulsar/internal/crypto/consumer_decryptor.go:44
Method
Decrypt
Decrypt noop decryptor
pulsar/internal/crypto/noop_decryptor.go:33
Method
Del
(key string)
pulsar/internal/key_based_batch_builder.go:72
Method
Delete
(endpoint string)
pulsaradmin/pkg/rest/client.go:330
Method
Delete
Delete deletes the specified package
pulsaradmin/pkg/admin/packages.go:104
Method
Delete
(packageURL string)
pulsaradmin/pkg/admin/packages.go:294
Method
Delete
Delete deletes an existing tenant
pulsaradmin/pkg/admin/tenant.go:35
Method
Delete
(name string)
pulsaradmin/pkg/admin/tenant.go:81
Method
Delete
Delete deletes a persistent subscription from a topic. There should not be any active consumers on the subscription
pulsaradmin/pkg/admin/subscription.go:45
Method
Delete
(topic utils.TopicName, sName string)
pulsaradmin/pkg/admin/subscription.go:170
Method
Delete
(topic utils.TopicName, force bool, nonPartitioned bool)
pulsaradmin/pkg/admin/topic.go:1204
Method
Delete
Delete an existing cluster
pulsaradmin/pkg/admin/cluster.go:47
Method
Delete
(name string)
pulsaradmin/pkg/admin/cluster.go:144
Method
DeleteBookieAffinityGroup
(namespace string)
pulsaradmin/pkg/admin/namespace.go:1570
Method
DeleteBookieAffinityGroupWithContext
DeleteBookieAffinityGroupWithContext deletes bookie affinity group configured for a namespace
pulsaradmin/pkg/admin/namespace.go:465
Method
DeleteConsumeHandler
(id uint64)
pulsar/consumer_test.go:6169
Method
DeleteConsumeHandler
(_ uint64)
pulsar/consumer_multitopic_test.go:349
Method
DeleteConsumeHandler
(_ uint64)
pulsar/consumer_partition_test.go:652
Method
DeleteDynamicConfiguration
DeleteDynamicConfiguration deletes dynamic configuration value in to Zk. It will not impact current value in broker but next time when broker restarts
pulsaradmin/pkg/admin/brokers.go:69
Method
DeleteDynamicConfiguration
(configName string)
pulsaradmin/pkg/admin/brokers.go:195
Method
DeleteDynamicConfigurationWithContext
DeleteDynamicConfigurationWithContext deletes dynamic configuration value in to Zk. It will not impact current value in broker but next time when brok
pulsaradmin/pkg/admin/brokers.go:73
Method
DeleteFailureDomain
DeleteFailureDomain deletes a domain in cluster
pulsaradmin/pkg/admin/cluster.go:89
Method
DeleteFailureDomain
(data utils.FailureDomainData)
pulsaradmin/pkg/admin/cluster.go:222
Method
DeleteFailureDomainWithContext
DeleteFailureDomain deletes a domain in cluster
pulsaradmin/pkg/admin/cluster.go:92
Method
DeleteFunction
DeleteFunction deletes an existing function
pulsaradmin/pkg/admin/functions.go:82
Method
DeleteFunction
(tenant, namespace, name string)
pulsaradmin/pkg/admin/functions.go:435
Method
DeleteFunctionWithContext
DeleteFunctionWithContext deletes an existing function
pulsaradmin/pkg/admin/functions.go:85
Method
DeleteNamespace
(namespace string)
pulsaradmin/pkg/admin/namespace.go:875
Method
DeleteNamespaceAntiAffinityGroup
DeleteNamespaceAntiAffinityGroup deletes anti-affinity group name for a namespace
pulsaradmin/pkg/admin/namespace.go:416
Method
DeleteNamespaceAntiAffinityGroup
(namespace string)
pulsaradmin/pkg/admin/namespace.go:1493
← previous
next →
1,901–2,000 of 5,094, ranked by callers