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
↓ 2 callersMethodinternalFlow
Flow command gives additional permits to send messages to the consumer. A typical consumer implementation will use a queue to accumulate these message
pulsar/consumer_partition.go:1778
↓ 2 callersMethodinternalSend
(sr *sendRequest)
pulsar/producer_partition.go:614
↓ 2 callersMethodinternalSendAsync
( ctx context.Context, msg *ProducerMessage, callback func(MessageID, *ProducerMessage, error), flushImmed
pulsar/producer_partition.go:1317
↓ 2 callersFunctioninternalTestTopicsProperties
(t *testing.T, partitions int)
pulsaradmin/pkg/admin/topic_test.go:85
↓ 2 callersMethodinternalWriteData
(ctx context.Context, data Buffer)
pulsar/internal/connection.go:513
↓ 2 callersFunctionisNonRetriableSubscribeError
(err error)
pulsar/consumer_partition.go:126
↓ 2 callersFunctionisUnsetPolicyBody
(body []byte)
pulsaradmin/pkg/admin/topic_policies.go:260
↓ 2 callersFunctionlegacyTopicPolicyBool
(value *bool)
pulsaradmin/pkg/admin/topic.go:1122
↓ 2 callersFunctionloadPEM
(uri string)
pulsar/auth/athenz.go:233
↓ 2 callersMethodmarkScaleIfNeed
()
pulsar/consumer_partition.go:2438
↓ 2 callersFunctionmergeMaps
(a, b map[string]string)
pulsar/internal/metrics.go:601
↓ 2 callersMethodmessageID
(msgID MessageID)
pulsar/consumer_impl.go:906
↓ 2 callersFunctionmockKeyFile
mockKeyFile will mock a temp key file for testing.
pulsaradmin/pkg/admin/auth/oauth2_test.go:68
↓ 2 callersFunctionmockWellKnownServer
(tokenEndpoint string)
oauth2/client_credentials_flow_test.go:56
↓ 2 callersFunctionnewBenchDefaultRouter
()
pulsar/default_router_bench_test.go:57
↓ 2 callersFunctionnewCGoZStdProvider
(level Level)
pulsar/internal/compression/zstd_cgo.go:40
↓ 2 callersFunctionnewChunkRecorder
()
pulsar/producer_partition.go:1817
↓ 2 callersFunctionnewConnection
(opts connectionOptions)
pulsar/internal/connection.go:196
↓ 2 callersMethodnewDeviceCodeExchangeRequest
newDeviceCodeExchangeRequest builds a new DeviceCodeExchangeRequest wrapped in an http.Request
oauth2/authorization_tokenretriever.go:147
↓ 2 callersFunctionnewDeviceCodeFlow
( options DeviceCodeFlowOptions, oidcWellKnownEndpoints OIDCWellKnownEndpoints, codeProvider DeviceCodeProv
oauth2/device_code_flow.go:62
↓ 2 callersFunctionnewInternalTopicPartitionTestConsumer
(opts internalTopicPartitionTestConsumerOptions)
pulsar/consumer_test.go:6100
↓ 2 callersFunctionnewPartitionConsumer
(parent Consumer, client *client, options *partitionConsumerOpts, messageCh chan ConsumerMessage, dlq *dlqRou
pulsar/consumer_partition.go:403
↓ 2 callersFunctionnewPartitionConsumerOpts
(topic, consumerName string, idx int, options ConsumerOptions)
pulsar/consumer_impl.go:449
↓ 2 callersFunctionnewProtoNativeSchema
(protoNativeSchemaDef string, properties map[string]string)
pulsar/schema.go:241
↓ 2 callersFunctionnewReader
(client *client, options ReaderOptions)
pulsar/reader_impl.go:46
↓ 2 callersMethodnewRequest
(method, path string)
pulsar/internal/http_client.go:88
↓ 2 callersFunctionnewTestConnection
()
pulsar/internal/connection_test.go:196
↓ 2 callersMethodnotifyChan
()
pulsar/internal/channel_cond.go:72
↓ 2 callersMethodpartitionUpdateCheck
()
pulsar/table_view_impl.go:93
↓ 2 callersMethodpauseDispatchMessage
pauseDispatchMessage used to discard the message in the dispatcher goroutine. This method will be called When the parent consumer performs the seek op
pulsar/consumer_partition.go:264
↓ 2 callersFunctionpulsarFieldsToKVSlice
(f Fields)
pulsar/log/wrapper_slog.go:112
↓ 2 callersFunctionputNackEntry
(t *negativeAcksTracker, batchMsgID *messageID, delay time.Duration)
pulsar/negative_acks_tracker.go:98
↓ 2 callersMethodreadAtLeast
(size uint32)
pulsar/internal/connection_reader.go:108
↓ 2 callersFunctionreadKey
(keyName, path string, keyMeta map[string]string)
pulsar/consumer_test.go:4360
↓ 2 callersFunctionreadKey
(keyName, path string, keyMeta map[string]string)
pulsar/crypto/default_crypto_Key_reader.go:45
↓ 2 callersMethodreadSingleCommand
()
pulsar/internal/connection_reader.go:61
↓ 2 callersFunctionreconsumeLaterWithMultipleTopics
( consumers map[string]Consumer, log log.Logger, msg Message, customProperties map[string]string, delay t
pulsar/consumer_multitopic.go:33
↓ 2 callersMethodregisterAckTopic
(topic string, subName string)
pulsar/transaction_impl.go:196
↓ 2 callersMethodregisterProducerTopic
(topic string)
pulsar/transaction_impl.go:177
↓ 2 callersMethodremove
(cmid *chunkMessageID)
pulsar/consumer_partition.go:2842
↓ 2 callersMethodrequestGetLastMessageID
()
pulsar/consumer_partition.go:739
↓ 2 callersMethodrequestSeekWithoutClear
(msgID *messageID)
pulsar/consumer_partition.go:1100
↓ 2 callersMethodrequestToHost
(serviceNameResolver *ServiceNameResolver, requestID uint64, cmdType pb.BaseCommand_Type, message proto.Messa
pulsar/internal/rpc_client.go:121
↓ 2 callersFunctionreserveMemory
(mlc MemoryLimitController, ch chan int)
pulsar/internal/memory_limit_controller_test.go:223
↓ 2 callersMethodreset
()
pulsar/internal/batch_builder.go:65
↓ 2 callersFunctionrunCallback
(cb func(MessageID, *ProducerMessage, error), id MessageID, msg *ProducerMessage, err error)
pulsar/producer_partition.go:606
↓ 2 callersFunctionsafeRespClose
safeRespClose is used to close a response body
pulsaradmin/pkg/admin/subscription.go:371
↓ 2 callersMethodselectServiceURL
(brokerServiceURL, brokerServiceURLTLS string)
pulsar/client_impl.go:280
↓ 2 callersMethodsendCumulativeAck
(msgID MessageID)
pulsar/consumer_partition.go:950
↓ 2 callersFunctionserializeMessage
(wb Buffer, cmdSend *pb.BaseCommand, msgMetadata *pb.MessageMetadata, payload Buffer, compressionProvider
pulsar/internal/commands.go:261
↓ 2 callersMethodsetLastDataReceived
(t time.Time)
pulsar/internal/connection.go:831
↓ 2 callersMethodsetStateClosed
()
pulsar/internal/connection.go:1108
↓ 2 callersMethodsetTimeLocked
Actually changes the time and checks any waiters. f must be write-locked.
oauth2/clock/testing/fake_clock.go:135
↓ 2 callersMethodsize
()
pulsar/impl_message.go:404
↓ 2 callersFunctionspanCommonTags
(span opentracing.Span)
pulsar/internal/pulsartracing/span-enrichment.go:47
↓ 2 callersMethodstart
()
pulsar/internal/connection.go:229
↓ 2 callersMethodstartDispatcher
()
pulsar/consumer_partition.go:523
↓ 2 callersFunctionstopCh
()
perf/pulsar-perf-go.go:128
↓ 2 callersFunctionstrPointer
(s string)
pulsar/table_view_test.go:238
↓ 2 callersFunctiontestInvalidServiceURI
(t *testing.T, serviceURI string)
pulsar/internal/service_uri_test.go:197
↓ 2 callersFunctiontestSendAndReceive
(t *testing.T, producer Producer, consumer Consumer)
pulsar/client_impl_test.go:1146
↓ 2 callersFunctiontestSendAsyncCouldTimeoutWhileReconnecting
(t *testing.T, isDisableBatching bool)
pulsar/producer_test.go:2802
↓ 2 callersFunctiontestSendMessagesWithMetadata
(t *testing.T, disableBatch bool)
pulsar/producer_test.go:2395
↓ 2 callersFunctiontestTLSTransportWithBasicAuth
(t *testing.T, url string)
pulsar/client_impl_test.go:1086
↓ 2 callersFunctiontoAckError
(errorMap map[error][]MessageID)
pulsar/consumer_partition.go:869
↓ 2 callersMethodtoAckSet
()
pulsar/impl_message.go:472
↓ 2 callersFunctiontoMsgIDDataList
(pendingAcks map[position]*bitset.BitSet)
pulsar/ack_grouping_tracker.go:263
↓ 2 callersFunctiontopicStats
(topic string)
pulsar/helper_for_test.go:154
↓ 2 callersMethodtopics
()
pulsar/consumer_regex.go:454
↓ 2 callersMethodunsubscribe
(force bool)
pulsar/consumer_impl.go:506
↓ 2 callersMethodunsubscribe
(force bool)
pulsar/consumer_zero_queue.go:104
↓ 2 callersMethodupdateMetadataSeqID
(mm *pb.MessageMetadata, msg *ProducerMessage)
pulsar/producer_partition.go:754
↓ 2 callersFunctionvalidateHashRanges
(hashRanges []int)
pulsar/key_shared_policy.go:80
↓ 2 callersFunctionvalidateHostName
(serviceName string, serviceInfos []string, hostname string)
pulsar/internal/service_uri.go:181
↓ 1 callersMethodAckID
AckID the consumption of a single message, identified by its MessageID
pulsar/consumer_regex.go:202
↓ 1 callersMethodAckID
AckID the consumption of a single message, identified by its MessageID
pulsar/consumer_multitopic.go:184
↓ 1 callersMethodAckID
AckID does not handle errors returned by the Broker side, so no need to wait for doneCh to finish.
pulsar/consumer_impl.go:42
↓ 1 callersMethodAckID
AckID the consumption of a single message, identified by its MessageID
pulsar/consumer_impl.go:570
↓ 1 callersMethodAckID
(msgID MessageID)
pulsar/consumer_zero_queue.go:187
↓ 1 callersMethodAckIDCumulative
AckIDCumulative the reception of all the messages in the stream up to (and including) the provided message, identified by its MessageID
pulsar/consumer_regex.go:260
↓ 1 callersMethodAckIDCumulative
AckIDCumulative the reception of all the messages in the stream up to (and including) the provided message, identified by its MessageID
pulsar/consumer_multitopic.go:270
↓ 1 callersMethodAckIDCumulative
(msgID MessageID)
pulsar/consumer_impl.go:46
↓ 1 callersMethodAckIDCumulative
AckIDCumulative the reception of all the messages in the stream up to (and including) the provided message, identified by its MessageID
pulsar/consumer_impl.go:595
↓ 1 callersMethodAckIDCumulative
(msgID MessageID)
pulsar/consumer_zero_queue.go:216
↓ 1 callersMethodAddConsumeHandler
(id uint64, handler ConsumerHandler)
pulsar/internal/connection.go:85
↓ 1 callersMethodBecameActive
(consumer Consumer, topicName string, partition int32)
pulsar/consumer_partition.go:186
↓ 1 callersMethodBecameInactive
(consumer Consumer, topicName string, partition int32)
pulsar/consumer_partition.go:187
↓ 1 callersMethodCacheTokens
CacheTokens caches the id and refresh token from TokenResult in the configProvider
oauth2/config_tokenprovider.go:54
↓ 1 callersMethodCheckIdle
(maxIdleTime time.Duration)
pulsar/internal/connection.go:1035
↓ 1 callersMethodClearBacklogWithContext
(ctx context.Context, topic utils.TopicName, sName string)
pulsaradmin/pkg/admin/subscription.go:230
↓ 1 callersMethodClearNamespaceBacklogForSubscriptionWithContext
( ctx context.Context, namespace utils.NameSpaceName, sName string, )
pulsaradmin/pkg/admin/namespace.go:1844
↓ 1 callersMethodClearNamespaceBacklogWithContext
(ctx context.Context, namespace utils.NameSpaceName)
pulsaradmin/pkg/admin/namespace.go:1857
↓ 1 callersMethodClearNamespaceBundleBacklogForSubscriptionWithContext
( ctx context.Context, namespace utils.NameSpaceName, bundle, sName string)
pulsaradmin/pkg/admin/namespace.go:1819
↓ 1 callersMethodClearNamespaceBundleBacklogWithContext
( ctx context.Context, namespace utils.NameSpaceName, bundle string, )
pulsaradmin/pkg/admin/namespace.go:1831
↓ 1 callersMethodClearOffloadDeleteLagWithContext
(ctx context.Context, namespace utils.NameSpaceName)
pulsaradmin/pkg/admin/namespace.go:1178
↓ 1 callersMethodClose
()
pulsar/consumer_impl.go:708
↓ 1 callersMethodClose
()
pulsar/internal/client_handlers_test.go:73
↓ 1 callersMethodClose
()
pulsar/internal/batch_builder.go:66
↓ 1 callersMethodClose
()
pulsar/internal/connection.go:89
↓ 1 callersMethodClusters
()
pulsaradmin/pkg/admin/admin.go:45
← previousnext →801–900 of 5,094, ranked by callers