Functions — github.com/apache/pulsar-client-go

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

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

⨍ Functions 5,094◇ Types & classes 637

MethodUnlock

()

pulsar/producer_test.go:2579

MethodUnmarshalJSON

Deprecated: Do not use.

pulsar/internal/pulsar_proto/PulsarApi.pb.go:93

MethodUnmarshalJSON

Deprecated: Do not use.

pulsar/internal/pulsar_proto/PulsarApi.pb.go:155

MethodUnmarshalJSON

Deprecated: Do not use.

pulsar/internal/pulsar_proto/PulsarApi.pb.go:284

MethodUnmarshalJSON

Deprecated: Do not use.

pulsar/internal/pulsar_proto/PulsarApi.pb.go:343

MethodUnmarshalJSON

Deprecated: Do not use.

pulsar/internal/pulsar_proto/PulsarApi.pb.go:461

MethodUnmarshalJSON

Deprecated: Do not use.

pulsar/internal/pulsar_proto/PulsarApi.pb.go:517

MethodUnmarshalJSON

Deprecated: Do not use.

pulsar/internal/pulsar_proto/PulsarApi.pb.go:573

MethodUnmarshalJSON

Deprecated: Do not use.

pulsar/internal/pulsar_proto/PulsarApi.pb.go:686

MethodUnmarshalJSON

Deprecated: Do not use.

pulsar/internal/pulsar_proto/PulsarApi.pb.go:748

MethodUnmarshalJSON

Deprecated: Do not use.

pulsar/internal/pulsar_proto/PulsarApi.pb.go:804

MethodUnmarshalJSON

Deprecated: Do not use.

pulsar/internal/pulsar_proto/PulsarApi.pb.go:860

MethodUnmarshalJSON

Deprecated: Do not use.

pulsar/internal/pulsar_proto/PulsarApi.pb.go:919

MethodUnmarshalJSON

Deprecated: Do not use.

pulsar/internal/pulsar_proto/PulsarApi.pb.go:975

MethodUnmarshalJSON

Deprecated: Do not use.

pulsar/internal/pulsar_proto/PulsarApi.pb.go:1043

MethodUnmarshalJSON

Deprecated: Do not use.

pulsar/internal/pulsar_proto/PulsarApi.pb.go:1099

MethodUnmarshalJSON

Deprecated: Do not use.

pulsar/internal/pulsar_proto/PulsarApi.pb.go:1158

MethodUnmarshalJSON

Deprecated: Do not use.

pulsar/internal/pulsar_proto/PulsarApi.pb.go:1383

MethodUnregisterListener

(_ uint64)

pulsar/consumer_multitopic_test.go:342

MethodUnregisterListener

(id uint64)

pulsar/internal/connection.go:1014

MethodUnsubscribe

()

pulsar/consumer_regex.go:122

MethodUnsubscribe

()

pulsar/consumer_multitopic.go:121

MethodUnsubscribe

()

pulsar/consumer_impl.go:498

MethodUnsubscribe

()

pulsar/consumer_zero_queue.go:96

MethodUnsubscribe

()

pulsar/internal/pulsartracing/consumer_interceptor_test.go:59

MethodUnsubscribeForce

()

pulsar/consumer_regex.go:137

MethodUnsubscribeForce

()

pulsar/consumer_multitopic.go:133

MethodUnsubscribeForce

()

pulsar/consumer_impl.go:502

MethodUnsubscribeForce

()

pulsar/consumer_zero_queue.go:100

MethodUnsubscribeForce

()

pulsar/internal/pulsartracing/consumer_interceptor_test.go:62

MethodUnsubscribeNamespace

UnsubscribeNamespace unsubscribe the given subscription on all topics on a namespace

pulsaradmin/pkg/admin/namespace.go:554

MethodUnsubscribeNamespace

(namespace utils.NameSpaceName, sName string)

pulsaradmin/pkg/admin/namespace.go:1787

MethodUnsubscribeNamespaceBundle

UnsubscribeNamespaceBundle unsubscribe the given subscription on all topics on a namespace bundle

pulsaradmin/pkg/admin/namespace.go:560

MethodUnsubscribeNamespaceBundle

(namespace utils.NameSpaceName, bundle, sName string)

pulsaradmin/pkg/admin/namespace.go:1800

MethodUnsubscribeNamespaceBundleWithContext

UnsubscribeNamespaceBundleWithContext unsubscribe the given subscription on all topics on a namespace bundle

pulsaradmin/pkg/admin/namespace.go:563

MethodUnsubscribeNamespaceWithContext

UnsubscribeNamespaceWithContext unsubscribe the given subscription on all topics on a namespace

pulsaradmin/pkg/admin/namespace.go:557

MethodUpdate

Update updates the admins for a tenant

pulsaradmin/pkg/admin/tenant.go:41

MethodUpdate

(data utils.TenantData)

pulsaradmin/pkg/admin/tenant.go:90

MethodUpdate

(topic utils.TopicName, partitions int)

pulsaradmin/pkg/admin/topic.go:1219

MethodUpdate

Update the configuration for a cluster

pulsaradmin/pkg/admin/cluster.go:53

MethodUpdate

(cdata utils.ClusterData)

pulsaradmin/pkg/admin/cluster.go:153

MethodUpdateDynamicConfiguration

(configName, configValue string)

pulsaradmin/pkg/admin/brokers.go:185

MethodUpdateDynamicConfigurationWithContext

UpdateDynamicConfigurationWithContext updates dynamic configuration value in to Zk that triggers watch on brokers and all brokers can update {@link Se

pulsaradmin/pkg/admin/brokers.go:65

MethodUpdateFailureDomain

UpdateFailureDomain updates a domain into cluster

pulsaradmin/pkg/admin/cluster.go:95

MethodUpdateFailureDomain

(data utils.FailureDomainData)

pulsaradmin/pkg/admin/cluster.go:231

MethodUpdateFailureDomainWithContext

UpdateFailureDomain updates a domain into cluster

pulsaradmin/pkg/admin/cluster.go:98

MethodUpdateFunction

UpdateFunction updates the configuration for a function.

pulsaradmin/pkg/admin/functions.go:228

MethodUpdateFunction

(functionConfig *utils.FunctionConfig, fileName string, updateOptions *utils.UpdateOptions)

pulsaradmin/pkg/admin/functions.go:583

MethodUpdateFunctionWithContext

UpdateFunctionWithContext updates the configuration for a function.

pulsaradmin/pkg/admin/functions.go:231

MethodUpdateFunctionWithURL

UpdateFunctionWithURL updates the configuration for a function. Update a function by providing url from which fun-pkg can be downloaded. supported ur

pulsaradmin/pkg/admin/functions.go:244

MethodUpdateFunctionWithURL

(functionConfig *utils.FunctionConfig, pkgURL string, updateOptions *utils.UpdateOptions)

pulsaradmin/pkg/admin/functions.go:668

MethodUpdateFunctionWithURLWithContext

UpdateFunctionWithURLWithContext updates the configuration for a function. Update a function by providing url from which fun-pkg can be downloaded. s

pulsaradmin/pkg/admin/functions.go:252

MethodUpdateMetadata

UpdateMetadata updates a package metadata information

pulsaradmin/pkg/admin/packages.go:116

MethodUpdateMetadata

(packageURL, description, contact string, properties map[string]string)

pulsaradmin/pkg/admin/packages.go:325

MethodUpdateMetadataWithContext

UpdateMetadataWithContext updates a package metadata information

pulsaradmin/pkg/admin/packages.go:119

MethodUpdatePeerClusters

UpdatePeerClusters updates peer cluster names.

pulsaradmin/pkg/admin/cluster.go:59

MethodUpdatePeerClusters

(cluster string, peerClusters []string)

pulsaradmin/pkg/admin/cluster.go:173

MethodUpdatePeerClustersWithContext

UpdatePeerClustersWithContext updates peer cluster names.

pulsaradmin/pkg/admin/cluster.go:62

MethodUpdateProperties

(topic utils.TopicName, properties map[string]string)

pulsaradmin/pkg/admin/topic.go:1182

MethodUpdateProperties

UpdateProperties updates the properties of a namespace

pulsaradmin/pkg/admin/namespace.go:745

MethodUpdateProperties

(namespace utils.NameSpaceName, properties map[string]string)

pulsaradmin/pkg/admin/namespace.go:2097

MethodUpdatePropertiesWithContext

UpdatePropertiesWithContext updates the properties of a topic

pulsaradmin/pkg/admin/topic.go:92

MethodUpdatePropertiesWithContext

UpdatePropertiesWithContext updates the properties of a namespace

pulsaradmin/pkg/admin/namespace.go:748

MethodUpdateSink

UpdateSink updates the configuration for a sink.

pulsaradmin/pkg/admin/sinks.go:63

MethodUpdateSink

(config *utils.SinkConfig, fileName string, updateOptions *utils.UpdateOptions)

pulsaradmin/pkg/admin/sinks.go:319

MethodUpdateSinkWithContext

UpdateSinkWithContext updates the configuration for a sink.

pulsaradmin/pkg/admin/sinks.go:66

MethodUpdateSinkWithURL

UpdateSinkWithURL updates a sink by providing url from which fun-pkg can be downloaded. Supported url: http/file

pulsaradmin/pkg/admin/sinks.go:75

MethodUpdateSinkWithURL

(config *utils.SinkConfig, pkgURL string, updateOptions *utils.UpdateOptions)

pulsaradmin/pkg/admin/sinks.go:403

MethodUpdateSinkWithURLWithContext

UpdateSinkWithURLWithContext updates a sink by providing url from which fun-pkg can be downloaded. Supported url: http/file

pulsaradmin/pkg/admin/sinks.go:79

MethodUpdateSource

UpdateSource updates the configuration for a source.

pulsaradmin/pkg/admin/sources.go:64

MethodUpdateSource

(config *utils.SourceConfig, fileName string, updateOptions *utils.UpdateOptions)

pulsaradmin/pkg/admin/sources.go:323

MethodUpdateSourceWithContext

UpdateSource updates the configuration for a source.

pulsaradmin/pkg/admin/sources.go:67

MethodUpdateSourceWithURL

UpdateSourceWithURL updates a source by providing url from which fun-pkg can be downloaded. supported url: http/file

pulsaradmin/pkg/admin/sources.go:75

MethodUpdateSourceWithURL

(config *utils.SourceConfig, pkgURL string, updateOptions *utils.UpdateOptions)

pulsaradmin/pkg/admin/sources.go:407

MethodUpdateSourceWithURLWithContext

UpdateSourceWithURL updates a source by providing url from which fun-pkg can be downloaded. supported url: http/file

pulsaradmin/pkg/admin/sources.go:78

MethodUpdateWithContext

UpdateWithContext updates the admins for a tenant

pulsaradmin/pkg/admin/tenant.go:44

MethodUpdateWithContext

UpdateWithContext updates number of partitions of a non-global partitioned topic It requires partitioned-topic to be already exist and number of new p

pulsaradmin/pkg/admin/topic.go:144

MethodUpdateWithContext

UpdateWithContext updates the configuration for a cluster

pulsaradmin/pkg/admin/cluster.go:56

MethodUpload

Upload uploads Function/Connector Package @param filePath file where data should be uploaded to @param packageURL type://tenant/namespace/packageName@

pulsaradmin/pkg/admin/packages.go:67

MethodUpload

(packageURL, filePath, description, contact string, properties map[string]string)

pulsaradmin/pkg/admin/packages.go:187

MethodUpload

Upload function to Pulsar

pulsaradmin/pkg/admin/functions.go:260

MethodUpload

(sourceFile, path string)

pulsaradmin/pkg/admin/functions.go:951

MethodUploadWithContext

UploadWithContext uploads Function/Connector Package @param ctx context used for the request @param filePath file where data should be uploaded to @pa

pulsaradmin/pkg/admin/packages.go:82

MethodUploadWithContext

UploadWithContext function to Pulsar

pulsaradmin/pkg/admin/functions.go:263

MethodUpsertEncryptionKey

(keyInfo EncryptionKeyInfo)

pulsar/crypto/message_metadata.go:61

pulsar/consumer_multitopic_test.go:363

MethodWaitForClose

()

pulsar/internal/connection.go:1050

← previous next →4,901–5,000 of 5,094, ranked by callers