MCPcopy Create free account

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

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

↓ 1 callersMethodGetRetentionWithContext
( ctx context.Context, topic utils.TopicName, applied bool, )
pulsaradmin/pkg/admin/topic.go:1875
↓ 1 callersMethodGetRetentionWithContext
(ctx context.Context, namespace string)
pulsaradmin/pkg/admin/namespace.go:964
↓ 1 callersMethodGetRuntimeConfigurationsWithContext
(ctx context.Context)
pulsaradmin/pkg/admin/brokers.go:208
↓ 1 callersMethodGetSchema
GetSchema returns schema for a given version.
pulsar/internal/lookup_service.go:74
↓ 1 callersMethodGetSchemaAutoUpdateCompatibilityStrategyWithContext
( ctx context.Context, namespace utils.NameSpaceName, )
pulsaradmin/pkg/admin/namespace.go:1127
↓ 1 callersMethodGetSchemaCompatibilityStrategyApplied
( topic utils.TopicName, applied bool, )
pulsaradmin/pkg/admin/topic.go:2354
↓ 1 callersMethodGetSchemaCompatibilityStrategyAppliedWithContext
GetSchemaCompatibilityStrategyAppliedWithContext returns schema compatibility strategy for a topic. @param ctx context used for the request @param to
pulsaradmin/pkg/admin/topic.go:1061
↓ 1 callersMethodGetSchemaCompatibilityStrategyWithContext
(ctx context.Context, namespace utils.NameSpaceName)
pulsaradmin/pkg/admin/namespace.go:1160
↓ 1 callersMethodGetSchemaInfoByVersionWithContext
( ctx context.Context, topic string, version int64, )
pulsaradmin/pkg/admin/schema.go:133
↓ 1 callersMethodGetSchemaInfoWithContext
(ctx context.Context, topic string)
pulsaradmin/pkg/admin/schema.go:85
↓ 1 callersMethodGetSchemaInfoWithVersionWithContext
( ctx context.Context, topic string, )
pulsaradmin/pkg/admin/schema.go:107
↓ 1 callersMethodGetSchemaValidationEnforcedWithContext
(ctx context.Context, topic utils.TopicName)
pulsaradmin/pkg/admin/topic.go:2215
↓ 1 callersMethodGetSchemaValidationEnforcedWithContext
( ctx context.Context, namespace utils.NameSpaceName, )
pulsaradmin/pkg/admin/namespace.go:1098
↓ 1 callersMethodGetSendError
()
pulsar/internal/pulsar_proto/PulsarApi.pb.go:7452
↓ 1 callersMethodGetSendReceipt
()
pulsar/internal/pulsar_proto/PulsarApi.pb.go:7445
↓ 1 callersMethodGetSinkStatusWithContext
( ctx context.Context, tenant, namespace, sink string, )
pulsaradmin/pkg/admin/sinks.go:489
↓ 1 callersMethodGetSinkStatusWithIDWithContext
( ctx context.Context, tenant, namespace, sink string, id int, )
pulsaradmin/pkg/admin/sinks.go:505
↓ 1 callersMethodGetSinkWithContext
(ctx context.Context, tenant, namespace, sink string)
pulsaradmin/pkg/admin/sinks.go:201
↓ 1 callersMethodGetSourceStatusWithContext
( ctx context.Context, tenant, namespace, source string, )
pulsaradmin/pkg/admin/sources.go:490
↓ 1 callersMethodGetSourceStatusWithIDWithContext
(ctx context.Context, tenant, namespace, source string, id int)
pulsaradmin/pkg/admin/sources.go:507
↓ 1 callersMethodGetSourceWithContext
( ctx context.Context, tenant, namespace, source string, )
pulsaradmin/pkg/admin/sources.go:200
↓ 1 callersMethodGetStatsWithContext
(ctx context.Context, topic utils.TopicName)
pulsaradmin/pkg/admin/topic.go:1396
↓ 1 callersMethodGetStatsWithOption
GetStatsWithOption returns the stats for the topic All the rates are computed over a 1-minute window and are relative the last completed 1-minute per
pulsaradmin/pkg/admin/topic.go:272
↓ 1 callersMethodGetStatsWithOptionWithContext
( ctx context.Context, topic utils.TopicName, option utils.GetStatsOptions, )
pulsaradmin/pkg/admin/topic.go:1407
↓ 1 callersMethodGetSubPermissionsWithContext
( ctx context.Context, namespace utils.NameSpaceName, )
pulsaradmin/pkg/admin/namespace.go:1751
↓ 1 callersMethodGetSubscribeRateWithContext
(ctx context.Context, topic utils.TopicName)
pulsaradmin/pkg/admin/topic.go:2054
↓ 1 callersMethodGetSubscribeRateWithContext
( ctx context.Context, namespace utils.NameSpaceName, )
pulsaradmin/pkg/admin/namespace.go:1933
↓ 1 callersMethodGetSubscriptionDispatchRateWithContext
( ctx context.Context, topic utils.TopicName, )
pulsaradmin/pkg/admin/topic.go:2084
↓ 1 callersMethodGetSubscriptionDispatchRateWithContext
( ctx context.Context, namespace utils.NameSpaceName, )
pulsaradmin/pkg/admin/namespace.go:1906
↓ 1 callersMethodGetSubscriptionExpirationTimeWithContext
( ctx context.Context, namespace utils.NameSpaceName, )
pulsaradmin/pkg/admin/namespace.go:2063
↓ 1 callersMethodGetTLSCertificate
GetTLSCertificate returns a client certificate chain, or nil if the data are not available
pulsar/auth/provider.go:37
↓ 1 callersMethodGetTLSCertificate
()
pulsaradmin/pkg/admin/auth/tls.go:83
↓ 1 callersMethodGetTopicAutoCreationWithContext
( ctx context.Context, namespace utils.NameSpaceName, )
pulsaradmin/pkg/admin/namespace.go:1046
↓ 1 callersMethodGetTopicEpoch
()
pulsar/internal/pulsar_proto/PulsarApi.pb.go:3589
↓ 1 callersMethodGetTopicMigrated
()
pulsar/internal/pulsar_proto/PulsarApi.pb.go:7809
↓ 1 callersMethodGetTopicsWithContext
(ctx context.Context)
pulsaradmin/pkg/admin/broker_stats.go:106
↓ 1 callersMethodGetTopicsWithContext
(ctx context.Context, namespace string)
pulsaradmin/pkg/admin/namespace.go:791
↓ 1 callersMethodGetVersionByPayload
GetVersionByPayload gets the version of a schema
pulsaradmin/pkg/admin/schema.go:58
↓ 1 callersMethodGetVersionBySchemaInfo
GetVersionBySchemaInfo gets the version of a schema
pulsaradmin/pkg/admin/schema.go:55
↓ 1 callersMethodGetVersionBySchemaInfoWithContext
( ctx context.Context, topic string, schemaInfo utils.SchemaInfo, )
pulsaradmin/pkg/admin/schema.go:246
↓ 1 callersMethodGetWithContext
(ctx context.Context, endpoint string, obj interface{})
pulsaradmin/pkg/rest/client.go:139
↓ 1 callersMethodGetWithContext
(ctx context.Context, name string)
pulsaradmin/pkg/admin/tenant.go:114
↓ 1 callersMethodGetWithContext
(ctx context.Context, name string)
pulsaradmin/pkg/admin/cluster.go:128
↓ 1 callersMethodGetWithOptions
nolint:bodyclose // false positive
pulsar/internal/http_client.go:180
↓ 1 callersMethodGetWithQueryParams
(endpoint string, obj interface{}, params map[string]string, decode bool)
pulsar/internal/http_client.go:174
↓ 1 callersMethodGrantNamespacePermissionWithContext
( ctx context.Context, namespace utils.NameSpaceName, role string, action []utils.AuthAction)
pulsaradmin/pkg/admin/namespace.go:1691
↓ 1 callersMethodGrantPermissionWithContext
( ctx context.Context, topic utils.TopicName, role string, action []utils.AuthAction, )
pulsaradmin/pkg/admin/topic.go:1322
↓ 1 callersMethodGrantSubPermission
GrantSubPermission grants permission to role to access subscription's admin-api
pulsaradmin/pkg/admin/namespace.go:520
↓ 1 callersMethodGrantSubPermissionWithContext
( ctx context.Context, namespace utils.NameSpaceName, sName string, roles []string, )
pulsaradmin/pkg/admin/namespace.go:1721
↓ 1 callersMethodHealthCheck
Deprecated: Use HealthCheckWithTopicVersion instead
pulsaradmin/pkg/admin/brokers.go:94
↓ 1 callersMethodHealthCheckWithContext
(ctx context.Context)
pulsaradmin/pkg/admin/brokers.go:252
↓ 1 callersFunctionHomeDir
HomeDir returns the home directory for the current user. On Windows: 1. the first of %HOME%, %HOMEDRIVE%%HOMEPATH%, %USERPROFILE% containing a `.pulsa
pulsaradmin/pkg/utils/home_dir.go:36
↓ 1 callersMethodID
()
pulsar/internal/connection.go:87
↓ 1 callersMethodIsMemoryLimited
()
pulsar/internal/memory_limit_controller.go:126
↓ 1 callersMethodIsMultiBatches
Return the batch container batch message in multiple batches.
pulsar/internal/batch_builder.go:63
↓ 1 callersMethodIsProxied
()
pulsar/internal/connection.go:361
↓ 1 callersFunctionJavaStringHash
JavaStringHash and Java String.hashCode() equivalent
pulsar/internal/hash.go:23
↓ 1 callersMethodList
List returns the list of topics under a namespace
pulsaradmin/pkg/admin/topic.go:153
↓ 1 callersMethodListFailureDomainsWithContext
( ctx context.Context, clusterName string, )
pulsaradmin/pkg/admin/cluster.go:212
↓ 1 callersMethodListSinksWithContext
(ctx context.Context, tenant, namespace string)
pulsaradmin/pkg/admin/sinks.go:190
↓ 1 callersMethodListSourcesWithContext
(ctx context.Context, tenant, namespace string)
pulsaradmin/pkg/admin/sources.go:189
↓ 1 callersMethodListVersionsWithContext
(ctx context.Context, packageURL string)
pulsaradmin/pkg/admin/packages.go:282
↓ 1 callersMethodListWithContext
(ctx context.Context, typeName, namespace string)
pulsaradmin/pkg/admin/packages.go:271
↓ 1 callersMethodListWithContext
(ctx context.Context)
pulsaradmin/pkg/admin/tenant.go:103
↓ 1 callersMethodListWithContext
(ctx context.Context, topic utils.TopicName)
pulsaradmin/pkg/admin/subscription.go:190
↓ 1 callersMethodListWithContext
(ctx context.Context, namespace utils.NameSpaceName)
pulsaradmin/pkg/admin/topic.go:1246
↓ 1 callersMethodListWithContext
(ctx context.Context)
pulsaradmin/pkg/admin/cluster.go:118
↓ 1 callersMethodLock
()
pulsar/internal/blocking_queue.go:225
↓ 1 callersMethodLookupService
(URL string)
pulsar/internal/rpc_client.go:224
↓ 1 callersMethodLookupWithContext
(ctx context.Context, topic utils.TopicName)
pulsaradmin/pkg/admin/topic.go:1349
↓ 1 callersMethodMoveToFront
MoveToFront copy the available portion of data at the beginning of the buffer
pulsar/internal/buffer.go:60
↓ 1 callersFunctionMurmur3_32Hash
Murmur3_32Hash use Murmur3 hashing function
pulsar/internal/hash.go:33
↓ 1 callersMethodNackID
(msgID MessageID)
pulsar/consumer_regex.go:300
↓ 1 callersMethodNackID
(msgID MessageID)
pulsar/consumer_multitopic.go:318
↓ 1 callersMethodNackID
(msgID MessageID)
pulsar/consumer_partition.go:960
↓ 1 callersMethodNackID
(id MessageID)
pulsar/consumer_impl.go:48
↓ 1 callersMethodNackID
(msgID MessageID)
pulsar/consumer_impl.go:702
↓ 1 callersMethodNackID
(msgID MessageID)
pulsar/consumer_zero_queue.go:256
↓ 1 callersFunctionNewAuthPolicies
()
pulsaradmin/pkg/utils/auth_polices.go:26
↓ 1 callersFunctionNewAuthenticationBasicWithParams
(params map[string]string)
pulsar/auth/basic.go:48
↓ 1 callersFunctionNewAuthenticationFromTLSCertSupplier
(tlsCertSupplier func() (*tls.Certificate, error))
pulsar/auth/tls.go:48
↓ 1 callersFunctionNewAuthenticationOAuth2
( issuer oauth2.Issuer, flow *oauth2.ClientCredentialsFlow)
pulsar/auth/oauth2.go:76
↓ 1 callersFunctionNewAuthenticationOAuth2WithDefaultFlow
NewAuthenticationOAuth2WithDefaultFlow uses memory to save the grant
pulsaradmin/pkg/admin/auth/oauth2.go:53
↓ 1 callersFunctionNewAuthenticationTLSFromAuthParams
(encodedAuthParams string, transport http.RoundTripper)
pulsaradmin/pkg/admin/auth/tls.go:57
↓ 1 callersFunctionNewAuthenticationTLSWithParams
NewAuthenticationTLSWithParams initialize the authentication provider with map param.
pulsar/auth/tls.go:33
↓ 1 callersFunctionNewAuthenticationTokenFromAuthParams
(encodedAuthParam string, transport http.RoundTripper)
pulsaradmin/pkg/admin/auth/token.go:65
↓ 1 callersFunctionNewAuthenticationTokenFromSupplier
NewAuthenticationTokenFromSupplier returns a token auth provider that get the token data from a user supplied function. The function is invoked each t
pulsar/auth/token.go:61
↓ 1 callersFunctionNewAuthenticationTokenWithParams
NewAuthenticationTokenWithParams return a interface of Provider with string map.
pulsar/auth/token.go:36
↓ 1 callersFunctionNewBacklogQuota
(limitSize int64, limitTime int64, policy RetentionPolicy)
pulsaradmin/pkg/utils/backlog_quota.go:28
↓ 1 callersFunctionNewConfigBackedCachingProvider
NewConfigBackedCachingProvider builds and returns a CachingTokenProvider that utilizes a configProvider to cache tokens
oauth2/config_tokenprovider.go:36
↓ 1 callersFunctionNewConnectionPool
NewConnectionPool init connection pool.
pulsar/internal/connection_pool.go:64
↓ 1 callersMethodNewConsumerID
()
pulsar/internal/rpc_client.go:59
↓ 1 callersFunctionNewDefaultClientCredentialsFlow
NewDefaultClientCredentialsFlow provides an easy way to build up a default client credentials flow with all the correct configuration.
oauth2/client_credentials_flow.go:125
↓ 1 callersFunctionNewDefaultProvider
(t http.RoundTripper)
pulsaradmin/pkg/admin/auth/provider.go:39
↓ 1 callersFunctionNewHTTPClient
(serviceNameResolver ServiceNameResolver, tlsConfig *TLSOptions, requestTimeout time.Duration, logger log.Log
pulsar/internal/http_client.go:62
↓ 1 callersFunctionNewKeyBasedBatchBuilder
NewKeyBasedBatchBuilder init batch builder and return BatchBuilder pointer. Build a new key based batch message container.
pulsar/internal/key_based_batch_builder.go:86
↓ 1 callersFunctionNewKeySharedPolicySticky
NewKeySharedPolicySticky construct KeySharedPolicy in Sticky mode with hashRanges formed in value pair list: [x1, x2, y1, y2, z1, z2], and must not ov
pulsar/key_shared_policy.go:48
↓ 1 callersFunctionNewLocalBrokerData
()
pulsaradmin/pkg/utils/load_manage_report.go:75
↓ 1 callersFunctionNewLocalDeviceCodeProvider
NewLocalDeviceCodeProvider allows for the easy setup of LocalDeviceCodeProvider
oauth2/device_code_provider.go:58
↓ 1 callersFunctionNewMessage
(topic string, id MessageID, payload []byte, properties map[string]string)
pulsaradmin/pkg/utils/message.go:32
← previousnext →1,101–1,200 of 5,094, ranked by callers