Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/apache/pulsar-client-go
/ functions
Functions
5,094 in github.com/apache/pulsar-client-go
⨍
Functions
5,094
◇
Types & classes
637
↓ 1 callers
Method
GetRetentionWithContext
( ctx context.Context, topic utils.TopicName, applied bool, )
pulsaradmin/pkg/admin/topic.go:1875
↓ 1 callers
Method
GetRetentionWithContext
(ctx context.Context, namespace string)
pulsaradmin/pkg/admin/namespace.go:964
↓ 1 callers
Method
GetRuntimeConfigurationsWithContext
(ctx context.Context)
pulsaradmin/pkg/admin/brokers.go:208
↓ 1 callers
Method
GetSchema
GetSchema returns schema for a given version.
pulsar/internal/lookup_service.go:74
↓ 1 callers
Method
GetSchemaAutoUpdateCompatibilityStrategyWithContext
( ctx context.Context, namespace utils.NameSpaceName, )
pulsaradmin/pkg/admin/namespace.go:1127
↓ 1 callers
Method
GetSchemaCompatibilityStrategyApplied
( topic utils.TopicName, applied bool, )
pulsaradmin/pkg/admin/topic.go:2354
↓ 1 callers
Method
GetSchemaCompatibilityStrategyAppliedWithContext
GetSchemaCompatibilityStrategyAppliedWithContext returns schema compatibility strategy for a topic. @param ctx context used for the request @param to
pulsaradmin/pkg/admin/topic.go:1061
↓ 1 callers
Method
GetSchemaCompatibilityStrategyWithContext
(ctx context.Context, namespace utils.NameSpaceName)
pulsaradmin/pkg/admin/namespace.go:1160
↓ 1 callers
Method
GetSchemaInfoByVersionWithContext
( ctx context.Context, topic string, version int64, )
pulsaradmin/pkg/admin/schema.go:133
↓ 1 callers
Method
GetSchemaInfoWithContext
(ctx context.Context, topic string)
pulsaradmin/pkg/admin/schema.go:85
↓ 1 callers
Method
GetSchemaInfoWithVersionWithContext
( ctx context.Context, topic string, )
pulsaradmin/pkg/admin/schema.go:107
↓ 1 callers
Method
GetSchemaValidationEnforcedWithContext
(ctx context.Context, topic utils.TopicName)
pulsaradmin/pkg/admin/topic.go:2215
↓ 1 callers
Method
GetSchemaValidationEnforcedWithContext
( ctx context.Context, namespace utils.NameSpaceName, )
pulsaradmin/pkg/admin/namespace.go:1098
↓ 1 callers
Method
GetSendError
()
pulsar/internal/pulsar_proto/PulsarApi.pb.go:7452
↓ 1 callers
Method
GetSendReceipt
()
pulsar/internal/pulsar_proto/PulsarApi.pb.go:7445
↓ 1 callers
Method
GetSinkStatusWithContext
( ctx context.Context, tenant, namespace, sink string, )
pulsaradmin/pkg/admin/sinks.go:489
↓ 1 callers
Method
GetSinkStatusWithIDWithContext
( ctx context.Context, tenant, namespace, sink string, id int, )
pulsaradmin/pkg/admin/sinks.go:505
↓ 1 callers
Method
GetSinkWithContext
(ctx context.Context, tenant, namespace, sink string)
pulsaradmin/pkg/admin/sinks.go:201
↓ 1 callers
Method
GetSourceStatusWithContext
( ctx context.Context, tenant, namespace, source string, )
pulsaradmin/pkg/admin/sources.go:490
↓ 1 callers
Method
GetSourceStatusWithIDWithContext
(ctx context.Context, tenant, namespace, source string, id int)
pulsaradmin/pkg/admin/sources.go:507
↓ 1 callers
Method
GetSourceWithContext
( ctx context.Context, tenant, namespace, source string, )
pulsaradmin/pkg/admin/sources.go:200
↓ 1 callers
Method
GetStatsWithContext
(ctx context.Context, topic utils.TopicName)
pulsaradmin/pkg/admin/topic.go:1396
↓ 1 callers
Method
GetStatsWithOption
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 callers
Method
GetStatsWithOptionWithContext
( ctx context.Context, topic utils.TopicName, option utils.GetStatsOptions, )
pulsaradmin/pkg/admin/topic.go:1407
↓ 1 callers
Method
GetSubPermissionsWithContext
( ctx context.Context, namespace utils.NameSpaceName, )
pulsaradmin/pkg/admin/namespace.go:1751
↓ 1 callers
Method
GetSubscribeRateWithContext
(ctx context.Context, topic utils.TopicName)
pulsaradmin/pkg/admin/topic.go:2054
↓ 1 callers
Method
GetSubscribeRateWithContext
( ctx context.Context, namespace utils.NameSpaceName, )
pulsaradmin/pkg/admin/namespace.go:1933
↓ 1 callers
Method
GetSubscriptionDispatchRateWithContext
( ctx context.Context, topic utils.TopicName, )
pulsaradmin/pkg/admin/topic.go:2084
↓ 1 callers
Method
GetSubscriptionDispatchRateWithContext
( ctx context.Context, namespace utils.NameSpaceName, )
pulsaradmin/pkg/admin/namespace.go:1906
↓ 1 callers
Method
GetSubscriptionExpirationTimeWithContext
( ctx context.Context, namespace utils.NameSpaceName, )
pulsaradmin/pkg/admin/namespace.go:2063
↓ 1 callers
Method
GetTLSCertificate
GetTLSCertificate returns a client certificate chain, or nil if the data are not available
pulsar/auth/provider.go:37
↓ 1 callers
Method
GetTLSCertificate
()
pulsaradmin/pkg/admin/auth/tls.go:83
↓ 1 callers
Method
GetTopicAutoCreationWithContext
( ctx context.Context, namespace utils.NameSpaceName, )
pulsaradmin/pkg/admin/namespace.go:1046
↓ 1 callers
Method
GetTopicEpoch
()
pulsar/internal/pulsar_proto/PulsarApi.pb.go:3589
↓ 1 callers
Method
GetTopicMigrated
()
pulsar/internal/pulsar_proto/PulsarApi.pb.go:7809
↓ 1 callers
Method
GetTopicsWithContext
(ctx context.Context)
pulsaradmin/pkg/admin/broker_stats.go:106
↓ 1 callers
Method
GetTopicsWithContext
(ctx context.Context, namespace string)
pulsaradmin/pkg/admin/namespace.go:791
↓ 1 callers
Method
GetVersionByPayload
GetVersionByPayload gets the version of a schema
pulsaradmin/pkg/admin/schema.go:58
↓ 1 callers
Method
GetVersionBySchemaInfo
GetVersionBySchemaInfo gets the version of a schema
pulsaradmin/pkg/admin/schema.go:55
↓ 1 callers
Method
GetVersionBySchemaInfoWithContext
( ctx context.Context, topic string, schemaInfo utils.SchemaInfo, )
pulsaradmin/pkg/admin/schema.go:246
↓ 1 callers
Method
GetWithContext
(ctx context.Context, endpoint string, obj interface{})
pulsaradmin/pkg/rest/client.go:139
↓ 1 callers
Method
GetWithContext
(ctx context.Context, name string)
pulsaradmin/pkg/admin/tenant.go:114
↓ 1 callers
Method
GetWithContext
(ctx context.Context, name string)
pulsaradmin/pkg/admin/cluster.go:128
↓ 1 callers
Method
GetWithOptions
nolint:bodyclose // false positive
pulsar/internal/http_client.go:180
↓ 1 callers
Method
GetWithQueryParams
(endpoint string, obj interface{}, params map[string]string, decode bool)
pulsar/internal/http_client.go:174
↓ 1 callers
Method
GrantNamespacePermissionWithContext
( ctx context.Context, namespace utils.NameSpaceName, role string, action []utils.AuthAction)
pulsaradmin/pkg/admin/namespace.go:1691
↓ 1 callers
Method
GrantPermissionWithContext
( ctx context.Context, topic utils.TopicName, role string, action []utils.AuthAction, )
pulsaradmin/pkg/admin/topic.go:1322
↓ 1 callers
Method
GrantSubPermission
GrantSubPermission grants permission to role to access subscription's admin-api
pulsaradmin/pkg/admin/namespace.go:520
↓ 1 callers
Method
GrantSubPermissionWithContext
( ctx context.Context, namespace utils.NameSpaceName, sName string, roles []string, )
pulsaradmin/pkg/admin/namespace.go:1721
↓ 1 callers
Method
HealthCheck
Deprecated: Use HealthCheckWithTopicVersion instead
pulsaradmin/pkg/admin/brokers.go:94
↓ 1 callers
Method
HealthCheckWithContext
(ctx context.Context)
pulsaradmin/pkg/admin/brokers.go:252
↓ 1 callers
Function
HomeDir
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 callers
Method
ID
()
pulsar/internal/connection.go:87
↓ 1 callers
Method
IsMemoryLimited
()
pulsar/internal/memory_limit_controller.go:126
↓ 1 callers
Method
IsMultiBatches
Return the batch container batch message in multiple batches.
pulsar/internal/batch_builder.go:63
↓ 1 callers
Method
IsProxied
()
pulsar/internal/connection.go:361
↓ 1 callers
Function
JavaStringHash
JavaStringHash and Java String.hashCode() equivalent
pulsar/internal/hash.go:23
↓ 1 callers
Method
List
List returns the list of topics under a namespace
pulsaradmin/pkg/admin/topic.go:153
↓ 1 callers
Method
ListFailureDomainsWithContext
( ctx context.Context, clusterName string, )
pulsaradmin/pkg/admin/cluster.go:212
↓ 1 callers
Method
ListSinksWithContext
(ctx context.Context, tenant, namespace string)
pulsaradmin/pkg/admin/sinks.go:190
↓ 1 callers
Method
ListSourcesWithContext
(ctx context.Context, tenant, namespace string)
pulsaradmin/pkg/admin/sources.go:189
↓ 1 callers
Method
ListVersionsWithContext
(ctx context.Context, packageURL string)
pulsaradmin/pkg/admin/packages.go:282
↓ 1 callers
Method
ListWithContext
(ctx context.Context, typeName, namespace string)
pulsaradmin/pkg/admin/packages.go:271
↓ 1 callers
Method
ListWithContext
(ctx context.Context)
pulsaradmin/pkg/admin/tenant.go:103
↓ 1 callers
Method
ListWithContext
(ctx context.Context, topic utils.TopicName)
pulsaradmin/pkg/admin/subscription.go:190
↓ 1 callers
Method
ListWithContext
(ctx context.Context, namespace utils.NameSpaceName)
pulsaradmin/pkg/admin/topic.go:1246
↓ 1 callers
Method
ListWithContext
(ctx context.Context)
pulsaradmin/pkg/admin/cluster.go:118
↓ 1 callers
Method
Lock
()
pulsar/internal/blocking_queue.go:225
↓ 1 callers
Method
LookupService
(URL string)
pulsar/internal/rpc_client.go:224
↓ 1 callers
Method
LookupWithContext
(ctx context.Context, topic utils.TopicName)
pulsaradmin/pkg/admin/topic.go:1349
↓ 1 callers
Method
MoveToFront
MoveToFront copy the available portion of data at the beginning of the buffer
pulsar/internal/buffer.go:60
↓ 1 callers
Function
Murmur3_32Hash
Murmur3_32Hash use Murmur3 hashing function
pulsar/internal/hash.go:33
↓ 1 callers
Method
NackID
(msgID MessageID)
pulsar/consumer_regex.go:300
↓ 1 callers
Method
NackID
(msgID MessageID)
pulsar/consumer_multitopic.go:318
↓ 1 callers
Method
NackID
(msgID MessageID)
pulsar/consumer_partition.go:960
↓ 1 callers
Method
NackID
(id MessageID)
pulsar/consumer_impl.go:48
↓ 1 callers
Method
NackID
(msgID MessageID)
pulsar/consumer_impl.go:702
↓ 1 callers
Method
NackID
(msgID MessageID)
pulsar/consumer_zero_queue.go:256
↓ 1 callers
Function
NewAuthPolicies
()
pulsaradmin/pkg/utils/auth_polices.go:26
↓ 1 callers
Function
NewAuthenticationBasicWithParams
(params map[string]string)
pulsar/auth/basic.go:48
↓ 1 callers
Function
NewAuthenticationFromTLSCertSupplier
(tlsCertSupplier func() (*tls.Certificate, error))
pulsar/auth/tls.go:48
↓ 1 callers
Function
NewAuthenticationOAuth2
( issuer oauth2.Issuer, flow *oauth2.ClientCredentialsFlow)
pulsar/auth/oauth2.go:76
↓ 1 callers
Function
NewAuthenticationOAuth2WithDefaultFlow
NewAuthenticationOAuth2WithDefaultFlow uses memory to save the grant
pulsaradmin/pkg/admin/auth/oauth2.go:53
↓ 1 callers
Function
NewAuthenticationTLSFromAuthParams
(encodedAuthParams string, transport http.RoundTripper)
pulsaradmin/pkg/admin/auth/tls.go:57
↓ 1 callers
Function
NewAuthenticationTLSWithParams
NewAuthenticationTLSWithParams initialize the authentication provider with map param.
pulsar/auth/tls.go:33
↓ 1 callers
Function
NewAuthenticationTokenFromAuthParams
(encodedAuthParam string, transport http.RoundTripper)
pulsaradmin/pkg/admin/auth/token.go:65
↓ 1 callers
Function
NewAuthenticationTokenFromSupplier
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 callers
Function
NewAuthenticationTokenWithParams
NewAuthenticationTokenWithParams return a interface of Provider with string map.
pulsar/auth/token.go:36
↓ 1 callers
Function
NewBacklogQuota
(limitSize int64, limitTime int64, policy RetentionPolicy)
pulsaradmin/pkg/utils/backlog_quota.go:28
↓ 1 callers
Function
NewConfigBackedCachingProvider
NewConfigBackedCachingProvider builds and returns a CachingTokenProvider that utilizes a configProvider to cache tokens
oauth2/config_tokenprovider.go:36
↓ 1 callers
Function
NewConnectionPool
NewConnectionPool init connection pool.
pulsar/internal/connection_pool.go:64
↓ 1 callers
Method
NewConsumerID
()
pulsar/internal/rpc_client.go:59
↓ 1 callers
Function
NewDefaultClientCredentialsFlow
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 callers
Function
NewDefaultProvider
(t http.RoundTripper)
pulsaradmin/pkg/admin/auth/provider.go:39
↓ 1 callers
Function
NewHTTPClient
(serviceNameResolver ServiceNameResolver, tlsConfig *TLSOptions, requestTimeout time.Duration, logger log.Log
pulsar/internal/http_client.go:62
↓ 1 callers
Function
NewKeyBasedBatchBuilder
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 callers
Function
NewKeySharedPolicySticky
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 callers
Function
NewLocalBrokerData
()
pulsaradmin/pkg/utils/load_manage_report.go:75
↓ 1 callers
Function
NewLocalDeviceCodeProvider
NewLocalDeviceCodeProvider allows for the easy setup of LocalDeviceCodeProvider
oauth2/device_code_provider.go:58
↓ 1 callers
Function
NewMessage
(topic string, id MessageID, payload []byte, properties map[string]string)
pulsaradmin/pkg/utils/message.go:32
← previous
next →
1,101–1,200 of 5,094, ranked by callers