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
MethodDeleteNamespaceAntiAffinityGroupWithContext
DeleteNamespaceAntiAffinityGroupWithContext deletes anti-affinity group name for a namespace
pulsaradmin/pkg/admin/namespace.go:419
MethodDeleteNamespaceBundle
DeleteNamespaceBundle deletes an existing bundle in a namespace
pulsaradmin/pkg/admin/namespace.go:80
MethodDeleteNamespaceBundle
(namespace string, bundleRange string)
pulsaradmin/pkg/admin/namespace.go:888
MethodDeleteNamespaceBundleWithContext
DeleteNamespaceBundleWithContext deletes an existing bundle in a namespace
pulsaradmin/pkg/admin/namespace.go:83
MethodDeleteNamespaceIsolationPolicy
DeleteNamespaceIsolationPolicy deletes a namespace isolation policy for a cluster
pulsaradmin/pkg/admin/ns_isolation_policy.go:39
MethodDeleteNamespaceIsolationPolicy
(cluster, policyName string)
pulsaradmin/pkg/admin/ns_isolation_policy.go:114
MethodDeleteNamespaceIsolationPolicyWithContext
DeleteNamespaceIsolationPolicyWithContext deletes a namespace isolation policy for a cluster
pulsaradmin/pkg/admin/ns_isolation_policy.go:42
MethodDeleteNamespaceWithContext
DeleteNamespaceWithContext deletes an existing namespace
pulsaradmin/pkg/admin/namespace.go:77
MethodDeleteSchema
(topic string)
pulsaradmin/pkg/admin/schema.go:178
MethodDeleteSink
DeleteSink deletes an existing sink
pulsaradmin/pkg/admin/sinks.go:87
MethodDeleteSink
(tenant, namespace, sink string)
pulsaradmin/pkg/admin/sinks.go:476
MethodDeleteSinkWithContext
DeleteSinkWithContext deletes an existing sink
pulsaradmin/pkg/admin/sinks.go:90
MethodDeleteSource
DeleteSource deletes an existing source
pulsaradmin/pkg/admin/sources.go:86
MethodDeleteSource
(tenant, namespace, source string)
pulsaradmin/pkg/admin/sources.go:477
MethodDeleteSourceWithContext
DeleteSource deletes an existing source
pulsaradmin/pkg/admin/sources.go:89
MethodDeleteWithContext
DeleteWithContext deletes a persistent subscription from a topic. There should not be any active consumers on the subscription
pulsaradmin/pkg/admin/subscription.go:49
MethodDeleteWithQueryParams
(endpoint string, params map[string]string)
pulsaradmin/pkg/rest/client.go:338
MethodDescriptor
Deprecated: Use HiContent.ProtoReflect.Descriptor instead.
integration-tests/pb/hi.pb.go:78
MethodDescriptor
Deprecated: Use Test.ProtoReflect.Descriptor instead.
integration-tests/pb/hello.pb.go:80
MethodDescriptor
Deprecated: Use Foo.ProtoReflect.Descriptor instead.
integration-tests/pb/hello.pb.go:150
MethodDescriptor
Deprecated: Use MessageIdData.ProtoReflect.Descriptor instead.
pulsar/internal/pulsar_proto/PulsarApi.pb.go:1517
MethodDescriptor
Deprecated: Use KeyValue.ProtoReflect.Descriptor instead.
pulsar/internal/pulsar_proto/PulsarApi.pb.go:1607
MethodDescriptor
Deprecated: Use KeyLongValue.ProtoReflect.Descriptor instead.
pulsar/internal/pulsar_proto/PulsarApi.pb.go:1662
MethodDescriptor
Deprecated: Use IntRange.ProtoReflect.Descriptor instead.
pulsar/internal/pulsar_proto/PulsarApi.pb.go:1717
MethodDescriptor
Deprecated: Use EncryptionKeys.ProtoReflect.Descriptor instead.
pulsar/internal/pulsar_proto/PulsarApi.pb.go:1773
MethodDescriptor
Deprecated: Use MessageMetadata.ProtoReflect.Descriptor instead.
pulsar/internal/pulsar_proto/PulsarApi.pb.go:1895
MethodDescriptor
Deprecated: Use SingleMessageMetadata.ProtoReflect.Descriptor instead.
pulsar/internal/pulsar_proto/PulsarApi.pb.go:2155
MethodDescriptor
Deprecated: Use BrokerEntryMetadata.ProtoReflect.Descriptor instead.
pulsar/internal/pulsar_proto/PulsarApi.pb.go:2267
MethodDescriptor
Deprecated: Use CommandConnect.ProtoReflect.Descriptor instead.
pulsar/internal/pulsar_proto/PulsarApi.pb.go:2344
MethodDescriptor
Deprecated: Use FeatureFlags.ProtoReflect.Descriptor instead.
pulsar/internal/pulsar_proto/PulsarApi.pb.go:2465
MethodDescriptor
Deprecated: Use CommandConnected.ProtoReflect.Descriptor instead.
pulsar/internal/pulsar_proto/PulsarApi.pb.go:2541
MethodDescriptor
Deprecated: Use CommandAuthResponse.ProtoReflect.Descriptor instead.
pulsar/internal/pulsar_proto/PulsarApi.pb.go:2616
MethodDescriptor
Deprecated: Use CommandAuthChallenge.ProtoReflect.Descriptor instead.
pulsar/internal/pulsar_proto/PulsarApi.pb.go:2684
MethodDescriptor
Deprecated: Use AuthData.ProtoReflect.Descriptor instead.
pulsar/internal/pulsar_proto/PulsarApi.pb.go:2747
MethodDescriptor
Deprecated: Use KeySharedMeta.ProtoReflect.Descriptor instead.
pulsar/internal/pulsar_proto/PulsarApi.pb.go:2808
MethodDescriptor
Deprecated: Use CommandSubscribe.ProtoReflect.Descriptor instead.
pulsar/internal/pulsar_proto/PulsarApi.pb.go:2914
MethodDescriptor
Deprecated: Use CommandPartitionedTopicMetadata.ProtoReflect.Descriptor instead.
pulsar/internal/pulsar_proto/PulsarApi.pb.go:3096
MethodDescriptor
Deprecated: Use CommandPartitionedTopicMetadataResponse.ProtoReflect.Descriptor instead.
pulsar/internal/pulsar_proto/PulsarApi.pb.go:3175
MethodDescriptor
Deprecated: Use CommandLookupTopic.ProtoReflect.Descriptor instead.
pulsar/internal/pulsar_proto/PulsarApi.pb.go:3268
MethodDescriptor
Deprecated: Use CommandLookupTopicResponse.ProtoReflect.Descriptor instead.
pulsar/internal/pulsar_proto/PulsarApi.pb.go:3380
MethodDescriptor
Deprecated: Use CommandProducer.ProtoReflect.Descriptor instead.
pulsar/internal/pulsar_proto/PulsarApi.pb.go:3515
MethodDescriptor
Deprecated: Use CommandSend.ProtoReflect.Descriptor instead.
pulsar/internal/pulsar_proto/PulsarApi.pb.go:3667
MethodDescriptor
Deprecated: Use CommandSendReceipt.ProtoReflect.Descriptor instead.
pulsar/internal/pulsar_proto/PulsarApi.pb.go:3778
MethodDescriptor
Deprecated: Use CommandSendError.ProtoReflect.Descriptor instead.
pulsar/internal/pulsar_proto/PulsarApi.pb.go:3849
MethodDescriptor
Deprecated: Use CommandMessage.ProtoReflect.Descriptor instead.
pulsar/internal/pulsar_proto/PulsarApi.pb.go:3926
MethodDescriptor
Deprecated: Use CommandAck.ProtoReflect.Descriptor instead.
pulsar/internal/pulsar_proto/PulsarApi.pb.go:4015
MethodDescriptor
Deprecated: Use CommandAckResponse.ProtoReflect.Descriptor instead.
pulsar/internal/pulsar_proto/PulsarApi.pb.go:4122
MethodDescriptor
Deprecated: Use CommandActiveConsumerChange.ProtoReflect.Descriptor instead.
pulsar/internal/pulsar_proto/PulsarApi.pb.go:4211
MethodDescriptor
Deprecated: Use CommandFlow.ProtoReflect.Descriptor instead.
pulsar/internal/pulsar_proto/PulsarApi.pb.go:4268
MethodDescriptor
Deprecated: Use CommandUnsubscribe.ProtoReflect.Descriptor instead.
pulsar/internal/pulsar_proto/PulsarApi.pb.go:4329
MethodDescriptor
Deprecated: Use CommandSeek.ProtoReflect.Descriptor instead.
pulsar/internal/pulsar_proto/PulsarApi.pb.go:4394
MethodDescriptor
Deprecated: Use CommandReachedEndOfTopic.ProtoReflect.Descriptor instead.
pulsar/internal/pulsar_proto/PulsarApi.pb.go:4465
MethodDescriptor
Deprecated: Use CommandTopicMigrated.ProtoReflect.Descriptor instead.
pulsar/internal/pulsar_proto/PulsarApi.pb.go:4515
MethodDescriptor
Deprecated: Use CommandCloseProducer.ProtoReflect.Descriptor instead.
pulsar/internal/pulsar_proto/PulsarApi.pb.go:4586
MethodDescriptor
Deprecated: Use CommandCloseConsumer.ProtoReflect.Descriptor instead.
pulsar/internal/pulsar_proto/PulsarApi.pb.go:4657
MethodDescriptor
Deprecated: Use CommandRedeliverUnacknowledgedMessages.ProtoReflect.Descriptor instead.
pulsar/internal/pulsar_proto/PulsarApi.pb.go:4727
MethodDescriptor
Deprecated: Use CommandSuccess.ProtoReflect.Descriptor instead.
pulsar/internal/pulsar_proto/PulsarApi.pb.go:4789
MethodDescriptor
Deprecated: Use CommandProducerSuccess.ProtoReflect.Descriptor instead.
pulsar/internal/pulsar_proto/PulsarApi.pb.go:4862
MethodDescriptor
Deprecated: Use CommandError.ProtoReflect.Descriptor instead.
pulsar/internal/pulsar_proto/PulsarApi.pb.go:4946
MethodDescriptor
Deprecated: Use CommandPing.ProtoReflect.Descriptor instead.
pulsar/internal/pulsar_proto/PulsarApi.pb.go:5008
MethodDescriptor
Deprecated: Use CommandPong.ProtoReflect.Descriptor instead.
pulsar/internal/pulsar_proto/PulsarApi.pb.go:5046
MethodDescriptor
Deprecated: Use CommandConsumerStats.ProtoReflect.Descriptor instead.
pulsar/internal/pulsar_proto/PulsarApi.pb.go:5089
MethodDescriptor
Deprecated: Use CommandConsumerStatsResponse.ProtoReflect.Descriptor instead.
pulsar/internal/pulsar_proto/PulsarApi.pb.go:5171
MethodDescriptor
Deprecated: Use CommandGetLastMessageId.ProtoReflect.Descriptor instead.
pulsar/internal/pulsar_proto/PulsarApi.pb.go:5324
MethodDescriptor
Deprecated: Use CommandGetLastMessageIdResponse.ProtoReflect.Descriptor instead.
pulsar/internal/pulsar_proto/PulsarApi.pb.go:5380
MethodDescriptor
Deprecated: Use CommandGetTopicsOfNamespace.ProtoReflect.Descriptor instead.
pulsar/internal/pulsar_proto/PulsarApi.pb.go:5450
MethodDescriptor
Deprecated: Use CommandGetTopicsOfNamespaceResponse.ProtoReflect.Descriptor instead.
pulsar/internal/pulsar_proto/PulsarApi.pb.go:5538
MethodDescriptor
Deprecated: Use CommandWatchTopicList.ProtoReflect.Descriptor instead.
pulsar/internal/pulsar_proto/PulsarApi.pb.go:5618
MethodDescriptor
Deprecated: Use CommandWatchTopicListSuccess.ProtoReflect.Descriptor instead.
pulsar/internal/pulsar_proto/PulsarApi.pb.go:5696
MethodDescriptor
Deprecated: Use CommandWatchTopicUpdate.ProtoReflect.Descriptor instead.
pulsar/internal/pulsar_proto/PulsarApi.pb.go:5767
MethodDescriptor
Deprecated: Use CommandWatchTopicListClose.ProtoReflect.Descriptor instead.
pulsar/internal/pulsar_proto/PulsarApi.pb.go:5836
MethodDescriptor
Deprecated: Use CommandGetSchema.ProtoReflect.Descriptor instead.
pulsar/internal/pulsar_proto/PulsarApi.pb.go:5892
MethodDescriptor
Deprecated: Use CommandGetSchemaResponse.ProtoReflect.Descriptor instead.
pulsar/internal/pulsar_proto/PulsarApi.pb.go:5957
MethodDescriptor
Deprecated: Use CommandGetOrCreateSchema.ProtoReflect.Descriptor instead.
pulsar/internal/pulsar_proto/PulsarApi.pb.go:6034
MethodDescriptor
Deprecated: Use CommandGetOrCreateSchemaResponse.ProtoReflect.Descriptor instead.
pulsar/internal/pulsar_proto/PulsarApi.pb.go:6098
MethodDescriptor
Deprecated: Use CommandTcClientConnectRequest.ProtoReflect.Descriptor instead.
pulsar/internal/pulsar_proto/PulsarApi.pb.go:6172
MethodDescriptor
Deprecated: Use CommandTcClientConnectResponse.ProtoReflect.Descriptor instead.
pulsar/internal/pulsar_proto/PulsarApi.pb.go:6228
MethodDescriptor
Deprecated: Use CommandNewTxn.ProtoReflect.Descriptor instead.
pulsar/internal/pulsar_proto/PulsarApi.pb.go:6297
MethodDescriptor
Deprecated: Use CommandNewTxnResponse.ProtoReflect.Descriptor instead.
pulsar/internal/pulsar_proto/PulsarApi.pb.go:6368
MethodDescriptor
Deprecated: Use CommandAddPartitionToTxn.ProtoReflect.Descriptor instead.
pulsar/internal/pulsar_proto/PulsarApi.pb.go:6452
MethodDescriptor
Deprecated: Use CommandAddPartitionToTxnResponse.ProtoReflect.Descriptor instead.
pulsar/internal/pulsar_proto/PulsarApi.pb.go:6530
MethodDescriptor
Deprecated: Use Subscription.ProtoReflect.Descriptor instead.
pulsar/internal/pulsar_proto/PulsarApi.pb.go:6606
MethodDescriptor
Deprecated: Use CommandAddSubscriptionToTxn.ProtoReflect.Descriptor instead.
pulsar/internal/pulsar_proto/PulsarApi.pb.go:6669
MethodDescriptor
Deprecated: Use CommandAddSubscriptionToTxnResponse.ProtoReflect.Descriptor instead.
pulsar/internal/pulsar_proto/PulsarApi.pb.go:6747
MethodDescriptor
Deprecated: Use CommandEndTxn.ProtoReflect.Descriptor instead.
pulsar/internal/pulsar_proto/PulsarApi.pb.go:6831
MethodDescriptor
Deprecated: Use CommandEndTxnResponse.ProtoReflect.Descriptor instead.
pulsar/internal/pulsar_proto/PulsarApi.pb.go:6909
MethodDescriptor
Deprecated: Use CommandEndTxnOnPartition.ProtoReflect.Descriptor instead.
pulsar/internal/pulsar_proto/PulsarApi.pb.go:6995
MethodDescriptor
Deprecated: Use CommandEndTxnOnPartitionResponse.ProtoReflect.Descriptor instead.
pulsar/internal/pulsar_proto/PulsarApi.pb.go:7087
MethodDescriptor
Deprecated: Use CommandEndTxnOnSubscription.ProtoReflect.Descriptor instead.
pulsar/internal/pulsar_proto/PulsarApi.pb.go:7173
MethodDescriptor
Deprecated: Use CommandEndTxnOnSubscriptionResponse.ProtoReflect.Descriptor instead.
pulsar/internal/pulsar_proto/PulsarApi.pb.go:7265
MethodDescriptor
Deprecated: Use BaseCommand.ProtoReflect.Descriptor instead.
pulsar/internal/pulsar_proto/PulsarApi.pb.go:7399
MethodDo
(_ *http.Request)
oauth2/authorization_tokenretriever_test.go:40
MethodDownload
Download downloads Function/Connector Package @param destinationFile file where data should be downloaded to @param packageURL the package URL
pulsaradmin/pkg/admin/packages.go:45
MethodDownload
(packageURL, destinationFile string)
pulsaradmin/pkg/admin/packages.go:148
MethodDownloadFunction
Download Function Code @param destinationFile file where data should be downloaded to @param path Path where data is located
pulsaradmin/pkg/admin/functions.go:92
MethodDownloadFunction
(path, destinationFile string)
pulsaradmin/pkg/admin/functions.go:444
MethodDownloadFunctionByNs
Download Function Code @param destinationFile file where data should be downloaded to @param tenant Tenant name @param namespace Namespace name @param
pulsaradmin/pkg/admin/functions.go:112
MethodDownloadFunctionByNs
(destinationFile, tenant, namespace, function string)
pulsaradmin/pkg/admin/functions.go:472
MethodDownloadFunctionByNsWithContext
Download Function Code @param ctx context used for the request @param destinationFile file where data should be downloaded to @param tenant Tenant nam
pulsaradmin/pkg/admin/functions.go:125
MethodDownloadFunctionWithContext
Download Function Code @param ctx context used for the request @param destinationFile file where data should be downloaded to @param path Path where d
pulsaradmin/pkg/admin/functions.go:101
← previousnext →2,001–2,100 of 5,094, ranked by callers