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
MethodFlushWithCtx
(_ context.Context)
pulsar/internal/pulsartracing/producer_interceptor_test.go:70
MethodForEach
ForEach performs the given action for each entry in this map until all entries have been processed or the action returns an error.
pulsar/table_view.go:70
MethodForEachAndListen
(action func(string, interface{}) error)
pulsar/table_view_impl.go:221
MethodForceDelete
ForceDelete deletes a subscription forcefully
pulsaradmin/pkg/admin/subscription.go:52
MethodForceDelete
(topic utils.TopicName, sName string)
pulsaradmin/pkg/admin/subscription.go:178
MethodForceDeleteSchema
(topic string)
pulsaradmin/pkg/admin/schema.go:186
MethodForceDeleteWithContext
ForceDeleteWithContext deletes a subscription forcefully
pulsaradmin/pkg/admin/subscription.go:55
MethodForceReserveMemory
(size int64)
pulsar/internal/memory_limit_controller.go:105
MethodForeachKey
(handler func(key, val string) error)
pulsar/internal/pulsartracing/message_carrier_adaptors.go:31
MethodForeachKey
(_ func(_, _ string) error)
pulsar/internal/pulsartracing/message_carrier_adaptors.go:48
MethodForeachKey
(handler func(key, val string) error)
pulsar/internal/pulsartracing/message_carrier_adaptors.go:61
MethodForeachKey
(_ func(_, _ string) error)
pulsar/internal/pulsartracing/message_carrier_adaptors.go:78
MethodFunctions
()
pulsaradmin/pkg/admin/admin.go:46
MethodFunctions
Functions is used to access the functions endpoints
pulsaradmin/pkg/admin/functions.go:272
MethodFunctionsWorker
()
pulsaradmin/pkg/admin/functions_worker.go:64
MethodFunctionsWorker
()
pulsaradmin/pkg/admin/admin.go:58
MethodGenerateRoundRobinIndex
()
pulsar/consumer_test.go:6146
MethodGenerateRoundRobinIndex
()
pulsar/internal/connection_pool.go:150
MethodGet
(key string)
pulsar/table_view_impl.go:182
MethodGet
(schema *SchemaInfo)
pulsar/producer_partition.go:145
MethodGet
(schemaVersion []byte)
pulsar/consumer_partition.go:367
MethodGet
(endpoint string, obj interface{}, _ map[string]string)
pulsar/internal/lookup_service_test.go:592
MethodGet
(endpoint string, obj interface{}, params map[string]string)
pulsar/internal/http_client.go:58
MethodGet
(endpoint string, obj interface{}, params map[string]string)
pulsar/internal/http_client.go:149
MethodGet
(readerIdx uint32, size uint32)
pulsar/internal/buffer.go:194
MethodGet
(endpoint string, obj interface{})
pulsaradmin/pkg/rest/client.go:135
MethodGet
(name string)
pulsaradmin/pkg/admin/tenant.go:110
MethodGet
Get the configuration data for the specified cluster
pulsaradmin/pkg/admin/cluster.go:35
MethodGet
(name string)
pulsaradmin/pkg/admin/cluster.go:124
MethodGetAck
()
pulsar/internal/pulsar_proto/PulsarApi.pb.go:7466
MethodGetAckSet
()
pulsar/internal/pulsar_proto/PulsarApi.pb.go:3951
MethodGetAckType
()
pulsar/internal/pulsar_proto/PulsarApi.pb.go:4026
MethodGetActiveBrokers
GetActiveBrokers returns the list of active brokers in the cluster.
pulsaradmin/pkg/admin/brokers.go:38
MethodGetActiveBrokers
(cluster string)
pulsaradmin/pkg/admin/brokers.go:125
MethodGetActiveBrokersWithContext
GetActiveBrokersWithContext returns the list of active brokers in the cluster.
pulsaradmin/pkg/admin/brokers.go:41
MethodGetAddPartitionToTxn
()
pulsar/internal/pulsar_proto/PulsarApi.pb.go:7697
MethodGetAddPartitionToTxnResponse
()
pulsar/internal/pulsar_proto/PulsarApi.pb.go:7704
MethodGetAddSubscriptionToTxn
()
pulsar/internal/pulsar_proto/PulsarApi.pb.go:7711
MethodGetAddSubscriptionToTxnResponse
()
pulsar/internal/pulsar_proto/PulsarApi.pb.go:7718
MethodGetAddress
()
pulsar/internal/pulsar_proto/PulsarApi.pb.go:5245
MethodGetAddressList
()
pulsar/internal/service_name_resolver.go:105
MethodGetAdvertisedListenerName
()
pulsar/internal/pulsar_proto/PulsarApi.pb.go:3314
MethodGetAllDynamicConfigurations
()
pulsaradmin/pkg/admin/brokers.go:234
MethodGetAllDynamicConfigurationsWithContext
GetAllDynamicConfigurationsWithContext returns values of all overridden dynamic-configs
pulsaradmin/pkg/admin/brokers.go:91
MethodGetAllSchemas
(topic string)
pulsaradmin/pkg/admin/schema.go:156
MethodGetAllocatorStats
GetAllocatorStats returns stats from broker
pulsaradmin/pkg/admin/broker_stats.go:53
MethodGetAllocatorStats
(allocatorName string)
pulsaradmin/pkg/admin/broker_stats.go:130
MethodGetAllocatorStatsWithContext
GetAllocatorStatsWithContext returns stats from broker
pulsaradmin/pkg/admin/broker_stats.go:56
MethodGetAllowOutOfOrderDelivery
()
pulsar/internal/pulsar_proto/PulsarApi.pb.go:2826
MethodGetAntiAffinityNamespaces
GetAntiAffinityNamespaces returns all namespaces that grouped with given anti-affinity group
pulsaradmin/pkg/admin/namespace.go:400
MethodGetAntiAffinityNamespaces
(tenant, cluster, namespaceAntiAffinityGroup string)
pulsaradmin/pkg/admin/namespace.go:1460
MethodGetAntiAffinityNamespacesWithContext
GetAntiAffinityNamespacesWithContext returns all namespaces that grouped with given anti-affinity group
pulsaradmin/pkg/admin/namespace.go:403
MethodGetAssignedBrokerServiceUrl
()
pulsar/internal/pulsar_proto/PulsarApi.pb.go:4675
MethodGetAssignedBrokerServiceUrlTls
()
pulsar/internal/pulsar_proto/PulsarApi.pb.go:4682
MethodGetAssignments
GetAssignments returns the cluster assignments
pulsaradmin/pkg/admin/functions_worker.go:52
MethodGetAssignments
()
pulsaradmin/pkg/admin/functions_worker.go:128
MethodGetAssignmentsWithContext
GetAssignmentsWithContext returns the cluster assignments
pulsaradmin/pkg/admin/functions_worker.go:55
MethodGetAuthData
()
pulsar/internal/pulsar_proto/PulsarApi.pb.go:2369
MethodGetAuthData
()
pulsar/internal/pulsar_proto/PulsarApi.pb.go:2758
MethodGetAuthMethod
()
pulsar/internal/pulsar_proto/PulsarApi.pb.go:2355
MethodGetAuthMethodName
()
pulsar/internal/pulsar_proto/PulsarApi.pb.go:2362
MethodGetAuthResponse
()
pulsar/internal/pulsar_proto/PulsarApi.pb.go:7655
MethodGetAuthoritative
()
pulsar/internal/pulsar_proto/PulsarApi.pb.go:3286
MethodGetAuthoritative
()
pulsar/internal/pulsar_proto/PulsarApi.pb.go:3412
MethodGetAutoSubscriptionCreation
(context.Context, utils.TopicName, bool)
pulsaradmin/pkg/admin/topic_policies.go:128
MethodGetAutoSubscriptionCreation
( ctx context.Context, topic utils.TopicName, applied bool, )
pulsaradmin/pkg/admin/topic_policies.go:876
MethodGetAutoSubscriptionCreation
(topic utils.TopicName)
pulsaradmin/pkg/admin/topic.go:2312
MethodGetAutoSubscriptionCreationWithContext
GetAutoSubscriptionCreationWithContext returns auto subscription creation override for a topic. Returns nil if the auto subscription creation override
pulsaradmin/pkg/admin/topic.go:1018
MethodGetAvailablePermits
()
pulsar/internal/pulsar_proto/PulsarApi.pb.go:5224
MethodGetBacklogQuotaMap
(context.Context, utils.TopicName, bool)
pulsaradmin/pkg/admin/topic_policies.go:80
MethodGetBacklogQuotaMap
( ctx context.Context, topic utils.TopicName, applied bool, )
pulsaradmin/pkg/admin/topic_policies.go:551
MethodGetBacklogQuotaMap
(topic utils.TopicName, applied bool)
pulsaradmin/pkg/admin/topic.go:1941
MethodGetBacklogQuotaMap
GetBacklogQuotaMap returns backlog quota map on a namespace
pulsaradmin/pkg/admin/namespace.go:124
MethodGetBacklogQuotaMap
(namespace string)
pulsaradmin/pkg/admin/namespace.go:991
MethodGetBacklogQuotaMapWithContext
GetBacklogQuotaMapWithContext returns backlog quota map for a topic @param ctx context used for the request @param topic topicName struct @param appl
pulsaradmin/pkg/admin/topic.go:757
MethodGetBacklogQuotaMapWithContext
GetBacklogQuotaMapWithContext returns backlog quota map on a namespace
pulsaradmin/pkg/admin/namespace.go:127
MethodGetBlockedConsumerOnUnackedMsgs
()
pulsar/internal/pulsar_proto/PulsarApi.pb.go:5238
MethodGetBookieAffinityGroup
(namespace string)
pulsaradmin/pkg/admin/namespace.go:1583
MethodGetBookieAffinityGroupWithContext
GetBookieAffinityGroupWithContext returns bookie affinity group configured for a namespace. Returns nil if the bookie affinity group is not configured
pulsaradmin/pkg/admin/namespace.go:473
MethodGetBrokerServiceUrl
()
pulsar/internal/pulsar_proto/PulsarApi.pb.go:3384
MethodGetBrokerServiceUrlTls
()
pulsar/internal/pulsar_proto/PulsarApi.pb.go:3391
MethodGetBrokerTimestamp
()
pulsar/internal/pulsar_proto/PulsarApi.pb.go:2271
MethodGetBrokerWithNamespaceIsolationPolicy
GetBrokerWithNamespaceIsolationPolicy returns active broker with namespace-isolation policies attached to it.
pulsaradmin/pkg/admin/ns_isolation_policy.go:75
MethodGetBrokerWithNamespaceIsolationPolicy
(cluster, broker string)
pulsaradmin/pkg/admin/ns_isolation_policy.go:175
MethodGetBrokerWithNamespaceIsolationPolicyWithContext
GetBrokerWithNamespaceIsolationPolicyWithContext returns active broker with namespace-isolation policies attached to it.
pulsaradmin/pkg/admin/ns_isolation_policy.go:79
MethodGetBrokersWithNamespaceIsolationPolicy
GetBrokersWithNamespaceIsolationPolicy returns list of active brokers with namespace-isolation policies attached to it.
pulsaradmin/pkg/admin/ns_isolation_policy.go:65
MethodGetBrokersWithNamespaceIsolationPolicy
(cluster string)
pulsaradmin/pkg/admin/ns_isolation_policy.go:159
MethodGetBrokersWithNamespaceIsolationPolicyWithContext
GetBrokersWithNamespaceIsolationPolicyWithContext returns list of active brokers with namespace-isolation policies attached to it.
pulsaradmin/pkg/admin/ns_isolation_policy.go:69
MethodGetBuffer
(initSize int)
pulsar/internal/buffer.go:103
MethodGetBuiltInSinks
GetBuiltInSinks fetches a list of supported Pulsar IO sinks currently running in cluster mode
pulsaradmin/pkg/admin/sinks.go:147
MethodGetBuiltInSinks
()
pulsaradmin/pkg/admin/sinks.go:585
MethodGetBuiltInSinksWithContext
GetBuiltInSinksWithContext fetches a list of supported Pulsar IO sinks currently running in cluster mode
pulsaradmin/pkg/admin/sinks.go:150
MethodGetBuiltInSources
GetBuiltInSources fetches a list of supported Pulsar IO sources currently running in cluster mode
pulsaradmin/pkg/admin/sources.go:146
MethodGetBuiltInSources
()
pulsaradmin/pkg/admin/sources.go:594
MethodGetBuiltInSourcesWithContext
GetBuiltInSources fetches a list of supported Pulsar IO sources currently running in cluster mode
pulsaradmin/pkg/admin/sources.go:149
MethodGetBundleRange
(topic utils.TopicName)
pulsaradmin/pkg/admin/topic.go:1356
MethodGetBundleRangeWithContext
GetBundleRangeWithContext returns a bundle range of a topic
pulsaradmin/pkg/admin/topic.go:228
MethodGetChanged
()
pulsar/internal/pulsar_proto/PulsarApi.pb.go:5570
MethodGetClientCredentials
()
oauth2/client_credentials_provider.go:52
MethodGetClientCredentials
()
oauth2/client_credentials_flow_test.go:40
← previousnext →2,201–2,300 of 5,094, ranked by callers