MCPcopy Create free account

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

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

MethodCreateFunc
CreateFunc create a new function.
pulsaradmin/pkg/admin/functions.go:38
MethodCreateFunc
(funcConf *utils.FunctionConfig, fileName string)
pulsaradmin/pkg/admin/functions.go:293
MethodCreateFuncWithContext
CreateFuncWithContext create a new function.
pulsaradmin/pkg/admin/functions.go:41
MethodCreateFuncWithURL
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
MethodCreateFuncWithURL
(funcConf *utils.FunctionConfig, pkgURL string)
pulsaradmin/pkg/admin/functions.go:356
MethodCreateFuncWithURLWithContext
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
MethodCreateNamespace
(namespace string)
pulsaradmin/pkg/admin/namespace.go:862
FunctionCreateNamespaceIsolationData
(namespaces, primary, secondry []string, autoFailoverPolicyTypeName string, autoFailoverPolicyParams map[stri
pulsaradmin/pkg/utils/ns_isolation_data.go:51
MethodCreateNamespaceIsolationPolicy
CreateNamespaceIsolationPolicy creates a namespace isolation policy for a cluster
pulsaradmin/pkg/admin/ns_isolation_policy.go:28
MethodCreateNamespaceIsolationPolicy
(cluster, policyName string, namespaceIsolationData utils.NamespaceIsolationData)
pulsaradmin/pkg/admin/ns_isolation_policy.go:98
MethodCreateNamespaceIsolationPolicyWithContext
CreateNamespaceIsolationPolicyWithContext creates a namespace isolation policy for a cluster
pulsaradmin/pkg/admin/ns_isolation_policy.go:31
MethodCreateNamespaceWithContext
CreateNamespaceWithContext creates a new empty namespace with no policies attached
pulsaradmin/pkg/admin/namespace.go:53
MethodCreateNsWithBundlesData
CreateNsWithBundlesData creates a new empty namespace with no policies attached
pulsaradmin/pkg/admin/namespace.go:68
MethodCreateNsWithBundlesData
(namespace string, bundleData *utils.BundlesData)
pulsaradmin/pkg/admin/namespace.go:842
MethodCreateNsWithBundlesDataWithContext
CreateNsWithBundlesDataWithContext creates a new empty namespace with no policies attached
pulsaradmin/pkg/admin/namespace.go:71
MethodCreateNsWithNumBundles
CreateNsWithNumBundles creates a new empty namespace with no policies attached
pulsaradmin/pkg/admin/namespace.go:56
MethodCreateNsWithNumBundles
(namespace string, numBundles int)
pulsaradmin/pkg/admin/namespace.go:817
MethodCreateNsWithNumBundlesWithContext
CreateNsWithNumBundlesWithContext creates a new empty namespace with no policies attached
pulsaradmin/pkg/admin/namespace.go:59
MethodCreateNsWithPolices
CreateNsWithPolices creates a new namespace with the specified policies
pulsaradmin/pkg/admin/namespace.go:62
MethodCreateNsWithPolices
(namespace string, policies utils.Policies)
pulsaradmin/pkg/admin/namespace.go:825
MethodCreateNsWithPolicesWithContext
CreateNsWithPolicesWithContext creates a new namespace with the specified policies
pulsaradmin/pkg/admin/namespace.go:65
MethodCreateProducer
(options ProducerOptions)
pulsar/client_impl.go:213
MethodCreateReader
(options ReaderOptions)
pulsar/client_impl.go:230
MethodCreateSchemaByPayload
(topic string, schemaPayload utils.PostSchemaPayload)
pulsaradmin/pkg/admin/schema.go:209
MethodCreateSchemaBySchemaInfo
(topic string, schemaInfo utils.SchemaInfo)
pulsaradmin/pkg/admin/schema.go:229
MethodCreateSink
CreateSink creates a new sink
pulsaradmin/pkg/admin/sinks.go:50
MethodCreateSink
(config *utils.SinkConfig, fileName string)
pulsaradmin/pkg/admin/sinks.go:208
MethodCreateSinkWithContext
CreateSinkWithContext creates a new sink
pulsaradmin/pkg/admin/sinks.go:53
MethodCreateSinkWithURL
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
MethodCreateSinkWithURL
(config *utils.SinkConfig, pkgURL string)
pulsaradmin/pkg/admin/sinks.go:270
MethodCreateSinkWithURLWithContext
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
MethodCreateSource
CreateSource creates a new source
pulsaradmin/pkg/admin/sources.go:50
MethodCreateSource
(config *utils.SourceConfig, fileName string)
pulsaradmin/pkg/admin/sources.go:212
MethodCreateSourceWithContext
CreateSource creates a new source
pulsaradmin/pkg/admin/sources.go:53
MethodCreateSourceWithURL
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
MethodCreateSourceWithURL
(config *utils.SourceConfig, pkgURL string)
pulsaradmin/pkg/admin/sources.go:274
MethodCreateSourceWithURLWithContext
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
FunctionCreateSpanFromMessage
(cm *pulsar.ConsumerMessage, tracer opentracing.Tracer, label string)
pulsar/internal/pulsartracing/message_carrier_util.go:80
MethodCreateTableView
(options TableViewOptions)
pulsar/client_impl.go:239
MethodCreateWithContext
CreateWithContext creates a new tenant
pulsaradmin/pkg/admin/tenant.go:32
MethodCreateWithContext
CreateWithContext creates a new subscription on a topic
pulsaradmin/pkg/admin/subscription.go:42
MethodCreateWithContext
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
MethodCreateWithContext
CreateWithContext creates a new cluster
pulsaradmin/pkg/admin/cluster.go:44
MethodCreateWithProperties
(topic utils.TopicName, partitions int, meta map[string]string)
pulsaradmin/pkg/admin/topic.go:1146
MethodCreateWithPropertiesWithContext
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
MethodCurrentUsage
()
pulsar/internal/memory_limit_controller.go:118
MethodCurrentUsagePercent
()
pulsar/internal/memory_limit_controller.go:122
MethodDebug
(args ...interface{})
pulsar/log/wrapper_logrus.go:62
MethodDebug
(args ...interface{})
pulsar/log/wrapper_logrus.go:110
MethodDebug
(args ...interface{})
pulsar/log/logger.go:42
MethodDebug
(args ...any)
pulsar/log/wrapper_slog.go:32
MethodDebug
(_ ...interface{})
pulsar/log/log.go:31
MethodDebug
(_ ...interface{})
pulsar/log/log.go:45
MethodDebugf
(format string, args ...interface{})
pulsar/log/wrapper_logrus.go:78
MethodDebugf
(format string, args ...interface{})
pulsar/log/wrapper_logrus.go:126
MethodDebugf
(format string, args ...any)
pulsar/log/wrapper_slog.go:60
MethodDebugf
(_ string, _ ...interface{})
pulsar/log/log.go:35
MethodDebugf
(_ string, _ ...interface{})
pulsar/log/log.go:49
MethodDecode
(data []byte, v interface{})
pulsar/schema.go:448
MethodDecode
(data []byte, v interface{})
pulsar/schema.go:483
MethodDecode
(data []byte, v interface{})
pulsar/schema.go:518
MethodDecode
(data []byte, v interface{})
pulsar/schema.go:553
MethodDecode
(data []byte, v interface{})
pulsar/schema.go:586
MethodDecode
(data []byte, v interface{})
pulsar/schema.go:624
MethodDecompress
(dst, src []byte, originalSize int)
pulsar/internal/compression/lz4.go:89
MethodDecompress
(dst, src []byte, _ int)
pulsar/internal/compression/noop.go:45
MethodDecompress
(dst, src []byte, _ int)
pulsar/internal/compression/zstd_cgo.go:78
MethodDecompress
(dst, src []byte, originalSize int)
pulsar/internal/compression/zlib.go:53
MethodDecompress
(dst, src []byte, _ int)
pulsar/internal/compression/snappy.go:40
MethodDecompress
(dst, src []byte, _ int)
pulsar/internal/compression/zstd_go.go:61
MethodDecrypt
(payload []byte, _ *pb.MessageIdData, msgMetadata *pb.MessageMetadata)
pulsar/internal/crypto/consumer_decryptor.go:44
MethodDecrypt
Decrypt noop decryptor
pulsar/internal/crypto/noop_decryptor.go:33
MethodDel
(key string)
pulsar/internal/key_based_batch_builder.go:72
MethodDelete
(endpoint string)
pulsaradmin/pkg/rest/client.go:330
MethodDelete
Delete deletes the specified package
pulsaradmin/pkg/admin/packages.go:104
MethodDelete
(packageURL string)
pulsaradmin/pkg/admin/packages.go:294
MethodDelete
Delete deletes an existing tenant
pulsaradmin/pkg/admin/tenant.go:35
MethodDelete
(name string)
pulsaradmin/pkg/admin/tenant.go:81
MethodDelete
Delete deletes a persistent subscription from a topic. There should not be any active consumers on the subscription
pulsaradmin/pkg/admin/subscription.go:45
MethodDelete
(topic utils.TopicName, sName string)
pulsaradmin/pkg/admin/subscription.go:170
MethodDelete
(topic utils.TopicName, force bool, nonPartitioned bool)
pulsaradmin/pkg/admin/topic.go:1204
MethodDelete
Delete an existing cluster
pulsaradmin/pkg/admin/cluster.go:47
MethodDelete
(name string)
pulsaradmin/pkg/admin/cluster.go:144
MethodDeleteBookieAffinityGroup
(namespace string)
pulsaradmin/pkg/admin/namespace.go:1570
MethodDeleteBookieAffinityGroupWithContext
DeleteBookieAffinityGroupWithContext deletes bookie affinity group configured for a namespace
pulsaradmin/pkg/admin/namespace.go:465
MethodDeleteConsumeHandler
(id uint64)
pulsar/consumer_test.go:6169
MethodDeleteConsumeHandler
(_ uint64)
pulsar/consumer_multitopic_test.go:349
MethodDeleteConsumeHandler
(_ uint64)
pulsar/consumer_partition_test.go:652
MethodDeleteDynamicConfiguration
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
MethodDeleteDynamicConfiguration
(configName string)
pulsaradmin/pkg/admin/brokers.go:195
MethodDeleteDynamicConfigurationWithContext
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
MethodDeleteFailureDomain
DeleteFailureDomain deletes a domain in cluster
pulsaradmin/pkg/admin/cluster.go:89
MethodDeleteFailureDomain
(data utils.FailureDomainData)
pulsaradmin/pkg/admin/cluster.go:222
MethodDeleteFailureDomainWithContext
DeleteFailureDomain deletes a domain in cluster
pulsaradmin/pkg/admin/cluster.go:92
MethodDeleteFunction
DeleteFunction deletes an existing function
pulsaradmin/pkg/admin/functions.go:82
MethodDeleteFunction
(tenant, namespace, name string)
pulsaradmin/pkg/admin/functions.go:435
MethodDeleteFunctionWithContext
DeleteFunctionWithContext deletes an existing function
pulsaradmin/pkg/admin/functions.go:85
MethodDeleteNamespace
(namespace string)
pulsaradmin/pkg/admin/namespace.go:875
MethodDeleteNamespaceAntiAffinityGroup
DeleteNamespaceAntiAffinityGroup deletes anti-affinity group name for a namespace
pulsaradmin/pkg/admin/namespace.go:416
MethodDeleteNamespaceAntiAffinityGroup
(namespace string)
pulsaradmin/pkg/admin/namespace.go:1493
← previousnext →1,901–2,000 of 5,094, ranked by callers