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
↓ 1 callersMethodCompactStatusWithContext
( ctx context.Context, topic utils.TopicName, )
pulsaradmin/pkg/admin/topic.go:1534
↓ 1 callersMethodCompactWithContext
(ctx context.Context, topic utils.TopicName)
pulsaradmin/pkg/admin/topic.go:1525
↓ 1 callersFunctionConvertSchemaDataToStringLegacy
(schemaInfo SchemaInfo)
pulsaradmin/pkg/utils/schema_util.go:73
↓ 1 callersMethodCreateFailureDomainWithContext
(ctx context.Context, data utils.FailureDomainData)
pulsaradmin/pkg/admin/cluster.go:186
↓ 1 callersMethodCreateFuncWithContext
(ctx context.Context, funcConf *utils.FunctionConfig, fileName string)
pulsaradmin/pkg/admin/functions.go:297
↓ 1 callersMethodCreateFuncWithURLWithContext
( ctx context.Context, funcConf *utils.FunctionConfig, pkgURL string, )
pulsaradmin/pkg/admin/functions.go:360
↓ 1 callersMethodCreateNamespaceIsolationPolicyWithContext
(ctx context.Context, cluster, policyName string, namespaceIsolationData utils.NamespaceIsolationData)
pulsaradmin/pkg/admin/ns_isolation_policy.go:103
↓ 1 callersMethodCreateNamespaceWithContext
(ctx context.Context, namespace string)
pulsaradmin/pkg/admin/namespace.go:866
↓ 1 callersMethodCreateNsWithNumBundlesWithContext
(ctx context.Context, namespace string, numBundles int)
pulsaradmin/pkg/admin/namespace.go:821
↓ 1 callersMethodCreateNsWithPolicesWithContext
( ctx context.Context, namespace string, policies utils.Policies, )
pulsaradmin/pkg/admin/namespace.go:829
↓ 1 callersMethodCreateSchemaBySchemaInfo
CreateSchemaBySchemaInfo creates a schema for a given <tt>topic</tt>
pulsaradmin/pkg/admin/schema.go:52
↓ 1 callersMethodCreateSchemaBySchemaInfoWithContext
( ctx context.Context, topic string, schemaInfo utils.SchemaInfo, )
pulsaradmin/pkg/admin/schema.go:233
↓ 1 callersMethodCreateSinkWithContext
(ctx context.Context, config *utils.SinkConfig, fileName string)
pulsaradmin/pkg/admin/sinks.go:212
↓ 1 callersMethodCreateSinkWithURLWithContext
(ctx context.Context, config *utils.SinkConfig, pkgURL string)
pulsaradmin/pkg/admin/sinks.go:274
↓ 1 callersMethodCreateSourceWithContext
(ctx context.Context, config *utils.SourceConfig, fileName string)
pulsaradmin/pkg/admin/sources.go:216
↓ 1 callersMethodCreateSourceWithURLWithContext
(ctx context.Context, config *utils.SourceConfig, pkgURL string)
pulsaradmin/pkg/admin/sources.go:278
↓ 1 callersMethodCreateWithContext
(ctx context.Context, data utils.TenantData)
pulsaradmin/pkg/admin/tenant.go:76
↓ 1 callersMethodCreateWithContext
( ctx context.Context, topic utils.TopicName, sName string, messageID utils.MessageID, )
pulsaradmin/pkg/admin/subscription.go:153
↓ 1 callersMethodCreateWithContext
(ctx context.Context, topic utils.TopicName, partitions int)
pulsaradmin/pkg/admin/topic.go:1142
↓ 1 callersMethodCreateWithContext
(ctx context.Context, cdata utils.ClusterData)
pulsaradmin/pkg/admin/cluster.go:139
↓ 1 callersMethodCreateWithProperties
CreateWithProperties creates a partitioned or non-partitioned topic with specific properties @param topic topicName struct @param partitions number o
pulsaradmin/pkg/admin/topic.go:62
↓ 1 callersMethodDebugf
(format string, args ...interface{})
pulsar/log/logger.go:47
↓ 1 callersMethodDecode
(data []byte, v interface{})
pulsar/schema.go:167
↓ 1 callersMethodDecode
(data []byte, v interface{})
pulsar/schema.go:217
↓ 1 callersMethodDecode
(data []byte, v interface{})
pulsar/schema.go:295
↓ 1 callersMethodDecode
(data []byte, v interface{})
pulsar/schema.go:350
↓ 1 callersMethodDecode
Decode convert from byte slice to string without allocating a new string
pulsar/schema.go:385
↓ 1 callersMethodDecode
(data []byte, v interface{})
pulsar/schema.go:416
↓ 1 callersMethodDecompress
(msgMeta *pb.MessageMetadata, payload internal.Buffer)
pulsar/consumer_partition.go:2463
↓ 1 callersMethodDecrypt
Decrypt the payload using the data key. Keys used to encrypt the data key can be retrieved from msgMetadata
pulsar/crypto/message_crypto.go:38
↓ 1 callersMethodDecrypt
(payload []byte, msgID *pb.MessageIdData, msgMetadata *pb.MessageMetadata)
pulsar/internal/crypto/decryptor.go:26
↓ 1 callersMethodDeleteBookieAffinityGroup
DeleteBookieAffinityGroup deletes bookie affinity group configured for a namespace
pulsaradmin/pkg/admin/namespace.go:462
↓ 1 callersMethodDeleteBookieAffinityGroupWithContext
(ctx context.Context, namespace string)
pulsaradmin/pkg/admin/namespace.go:1574
↓ 1 callersMethodDeleteConsumeHandler
(id uint64)
pulsar/internal/connection.go:1183
↓ 1 callersMethodDeleteDynamicConfigurationWithContext
(ctx context.Context, configName string)
pulsaradmin/pkg/admin/brokers.go:199
↓ 1 callersMethodDeleteFailureDomainWithContext
(ctx context.Context, data utils.FailureDomainData)
pulsaradmin/pkg/admin/cluster.go:226
↓ 1 callersMethodDeleteFunctionWithContext
(ctx context.Context, tenant, namespace, name string)
pulsaradmin/pkg/admin/functions.go:439
↓ 1 callersMethodDeleteNamespace
DeleteNamespace deletes an existing namespace
pulsaradmin/pkg/admin/namespace.go:74
↓ 1 callersMethodDeleteNamespaceAntiAffinityGroupWithContext
(ctx context.Context, namespace string)
pulsaradmin/pkg/admin/namespace.go:1497
↓ 1 callersMethodDeleteNamespaceBundleWithContext
(ctx context.Context, namespace string, bundleRange string)
pulsaradmin/pkg/admin/namespace.go:892
↓ 1 callersMethodDeleteNamespaceIsolationPolicyWithContext
( ctx context.Context, cluster, policyName string, )
pulsaradmin/pkg/admin/ns_isolation_policy.go:118
↓ 1 callersMethodDeleteNamespaceWithContext
(ctx context.Context, namespace string)
pulsaradmin/pkg/admin/namespace.go:879
↓ 1 callersMethodDeleteSchema
DeleteSchema deletes the schema associated with a given <tt>topic</tt>
pulsaradmin/pkg/admin/schema.go:43
↓ 1 callersMethodDeleteSchemaWithContext
(ctx context.Context, topic string)
pulsaradmin/pkg/admin/schema.go:182
↓ 1 callersMethodDeleteSinkWithContext
(ctx context.Context, tenant, namespace, sink string)
pulsaradmin/pkg/admin/sinks.go:480
↓ 1 callersMethodDeleteSourceWithContext
(ctx context.Context, tenant, namespace, source string)
pulsaradmin/pkg/admin/sources.go:481
↓ 1 callersMethodDeleteWithContext
(ctx context.Context, endpoint string)
pulsaradmin/pkg/rest/client.go:334
↓ 1 callersMethodDeleteWithContext
DeleteWithContext deletes the specified package
pulsaradmin/pkg/admin/packages.go:107
↓ 1 callersMethodDeleteWithContext
(ctx context.Context, packageURL string)
pulsaradmin/pkg/admin/packages.go:298
↓ 1 callersMethodDeleteWithContext
DeleteWithContext deletes an existing tenant
pulsaradmin/pkg/admin/tenant.go:38
↓ 1 callersMethodDeleteWithContext
(ctx context.Context, name string)
pulsaradmin/pkg/admin/tenant.go:85
↓ 1 callersMethodDeleteWithContext
(ctx context.Context, topic utils.TopicName, sName string)
pulsaradmin/pkg/admin/subscription.go:174
↓ 1 callersMethodDeleteWithContext
(ctx context.Context, topic utils.TopicName, force bool, nonPartitioned bool)
pulsaradmin/pkg/admin/topic.go:1208
↓ 1 callersMethodDeleteWithContext
(ctx context.Context, name string)
pulsaradmin/pkg/admin/cluster.go:148
↓ 1 callersMethodDownloadFunctionByNsWithContext
( ctx context.Context, destinationFile, tenant, namespace, function string, )
pulsaradmin/pkg/admin/functions.go:476
↓ 1 callersMethodDownloadFunctionWithContext
(ctx context.Context, path, destinationFile string)
pulsaradmin/pkg/admin/functions.go:448
↓ 1 callersMethodDownloadWithContext
(ctx context.Context, packageURL, destinationFile string)
pulsaradmin/pkg/admin/packages.go:152
↓ 1 callersMethodEntries
Entries returns a map view of the mappings contained in this TableView.
pulsar/table_view.go:63
↓ 1 callersMethodExchangeClientCredentials
(req ClientCredentialsExchangeRequest)
oauth2/client_credentials_flow.go:46
↓ 1 callersMethodExchangeRefreshToken
(req RefreshTokenExchangeRequest)
oauth2/device_code_flow.go:50
↓ 1 callersMethodExpireAllMessagesWithContext
(ctx context.Context, topic utils.TopicName, expire int64)
pulsaradmin/pkg/admin/subscription.go:271
↓ 1 callersMethodExpireMessagesWithContext
( ctx context.Context, topic utils.TopicName, sName string, expire int64, )
pulsaradmin/pkg/admin/subscription.go:256
↓ 1 callersMethodFloat32
(buf []byte)
pulsar/primitiveSerDe.go:108
↓ 1 callersMethodFlush
Deprecated: Use `FlushWithCtx()` instead.
pulsar/producer.go:261
↓ 1 callersMethodFlush
Flush all the messages buffered in the client and wait until all messages have been successfully persisted.
pulsar/internal/batch_builder.go:56
↓ 1 callersMethodFlushWithCtx
(ctx context.Context)
pulsar/producer_impl.go:343
↓ 1 callersMethodFlushWithCtx
(ctx context.Context)
pulsar/producer_partition.go:1556
↓ 1 callersMethodForEach
(action func(string, interface{}) error)
pulsar/table_view_impl.go:210
↓ 1 callersMethodForEachAndListen
ForEachAndListen performs the given action for each entry in this map until all entries have been processed or the action returns an error. The given
pulsar/table_view.go:74
↓ 1 callersMethodForceDeleteSchemaWithContext
(ctx context.Context, topic string)
pulsaradmin/pkg/admin/schema.go:190
↓ 1 callersMethodForceDeleteWithContext
(ctx context.Context, topic utils.TopicName, sName string)
pulsaradmin/pkg/admin/subscription.go:182
↓ 1 callersMethodGetAckResponse
()
pulsar/internal/pulsar_proto/PulsarApi.pb.go:7662
↓ 1 callersMethodGetActiveBrokersWithContext
(ctx context.Context, cluster string)
pulsaradmin/pkg/admin/brokers.go:129
↓ 1 callersMethodGetActiveConsumerChange
()
pulsar/internal/pulsar_proto/PulsarApi.pb.go:7613
↓ 1 callersMethodGetAllDynamicConfigurations
GetAllDynamicConfigurations returns values of all overridden dynamic-configs
pulsaradmin/pkg/admin/brokers.go:88
↓ 1 callersMethodGetAllDynamicConfigurationsWithContext
(ctx context.Context)
pulsaradmin/pkg/admin/brokers.go:238
↓ 1 callersMethodGetAllSchemas
GetAllSchemas retrieves all schemas of a topic
pulsaradmin/pkg/admin/schema.go:40
↓ 1 callersMethodGetAllSchemasWithContext
(ctx context.Context, topic string)
pulsaradmin/pkg/admin/schema.go:160
↓ 1 callersMethodGetAllocatorStatsWithContext
( ctx context.Context, allocatorName string, )
pulsaradmin/pkg/admin/broker_stats.go:134
↓ 1 callersMethodGetAntiAffinityNamespacesWithContext
( ctx context.Context, tenant, cluster, namespaceAntiAffinityGroup string, )
pulsaradmin/pkg/admin/namespace.go:1464
↓ 1 callersMethodGetAssignmentsWithContext
(ctx context.Context)
pulsaradmin/pkg/admin/functions_worker.go:132
↓ 1 callersMethodGetAuthChallenge
()
pulsar/internal/pulsar_proto/PulsarApi.pb.go:7648
↓ 1 callersMethodGetAuthMethodName
()
pulsar/internal/pulsar_proto/PulsarApi.pb.go:2751
↓ 1 callersMethodGetAutoSubscriptionCreationWithContext
( ctx context.Context, topic utils.TopicName, )
pulsaradmin/pkg/admin/topic.go:2316
↓ 1 callersMethodGetBacklogQuotaMapWithContext
( ctx context.Context, topic utils.TopicName, applied bool, )
pulsaradmin/pkg/admin/topic.go:1946
↓ 1 callersMethodGetBacklogQuotaMapWithContext
( ctx context.Context, namespace string, )
pulsaradmin/pkg/admin/namespace.go:995
↓ 1 callersFunctionGetBatcherBuilderProvider
(typ BatcherBuilderType)
pulsar/batcher_builder.go:31
↓ 1 callersMethodGetBookieAffinityGroupWithContext
( ctx context.Context, namespace string, )
pulsaradmin/pkg/admin/namespace.go:1587
↓ 1 callersMethodGetBrokerAddress
(brokerServiceURL string, _ bool)
pulsar/internal/lookup_service.go:320
↓ 1 callersMethodGetBrokerWithNamespaceIsolationPolicyWithContext
(ctx context.Context, cluster, broker string)
pulsaradmin/pkg/admin/ns_isolation_policy.go:180
↓ 1 callersMethodGetBrokersWithNamespaceIsolationPolicyWithContext
(ctx context.Context, cluster string)
pulsaradmin/pkg/admin/ns_isolation_policy.go:164
↓ 1 callersMethodGetBuiltInSinksWithContext
(ctx context.Context)
pulsaradmin/pkg/admin/sinks.go:589
↓ 1 callersMethodGetBuiltInSourcesWithContext
(ctx context.Context)
pulsaradmin/pkg/admin/sources.go:598
↓ 1 callersMethodGetBundleRangeWithContext
(ctx context.Context, topic utils.TopicName)
pulsaradmin/pkg/admin/topic.go:1360
↓ 1 callersMethodGetChallenge
()
pulsar/internal/pulsar_proto/PulsarApi.pb.go:2695
↓ 1 callersMethodGetCloseConsumer
()
pulsar/internal/pulsar_proto/PulsarApi.pb.go:7508
↓ 1 callersMethodGetCloseProducer
()
pulsar/internal/pulsar_proto/PulsarApi.pb.go:7501
↓ 1 callersMethodGetClusterLeaderWithContext
(ctx context.Context)
pulsaradmin/pkg/admin/functions_worker.go:118
↓ 1 callersMethodGetClusterWithContext
(ctx context.Context)
pulsaradmin/pkg/admin/functions_worker.go:104
↓ 1 callersMethodGetCode
(audience string, additionalScopes ...string)
oauth2/device_code_flow.go:44
← previousnext →901–1,000 of 5,094, ranked by callers