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
FunctionTestElementErrors
(t *testing.T)
pulsar/primitiveSerDe_test.go:98
FunctionTestEmptyPath
(t *testing.T)
pulsar/internal/service_uri_test.go:88
FunctionTestEmptyServiceUriString
(t *testing.T)
pulsar/internal/service_uri_test.go:45
FunctionTestEncodeJSONBody
(t *testing.T)
pulsaradmin/pkg/rest/client_test.go:27
FunctionTestEncrypt
(t *testing.T)
pulsar/crypto/default_message_crypto_test.go:69
FunctionTestEncryptDecrypt
(t *testing.T)
pulsar/crypto/default_message_crypto_test.go:107
FunctionTestEncryptDecryptRedeliveryOnFailure
TestEncryptDecryptRedeliveryOnFailure test redelivery failed messages
pulsar/consumer_test.go:4492
FunctionTestEncryptionParam
(t *testing.T)
pulsar/crypto/message_metadata_test.go:108
FunctionTestEventTime
(t *testing.T)
pulsar/producer_test.go:314
FunctionTestExactlyOnceWithProducerNameSpecified
(t *testing.T)
pulsar/producer_test.go:1716
FunctionTestExclusiveProducer
(t *testing.T)
pulsar/producer_test.go:2005
FunctionTestExpireIncompleteChunks
(t *testing.T)
pulsar/message_chunking_test.go:211
FunctionTestExtensibleLoadManagerTestSuite
(t *testing.T)
pulsar/extensible_load_manager_test.go:44
FunctionTestFailOverConsumerPriority
(t *testing.T)
pulsar/consumer_test.go:338
FunctionTestFailPendingMessageWithClose
(t *testing.T)
pulsar/producer_test.go:2460
FunctionTestFailedSchemaEncode
(t *testing.T)
pulsar/producer_test.go:1221
FunctionTestFilterTopics
(t *testing.T)
pulsar/consumer_regex_test.go:39
FunctionTestFloatSchema
(t *testing.T)
pulsar/schema_test.go:597
FunctionTestFlushInPartitionedProducer
(t *testing.T)
pulsar/producer_test.go:529
FunctionTestFlushInProducer
(t *testing.T)
pulsar/producer_test.go:349
FunctionTestForEachAndListenJSONSchema
(t *testing.T)
pulsar/table_view_test.go:306
FunctionTestFrameChecksum
(t *testing.T)
pulsar/internal/checksum_test.go:26
FunctionTestGetAllActiveBrokers
(t *testing.T)
pulsaradmin/pkg/admin/brokers_test.go:68
FunctionTestGetDeliveryCount
(t *testing.T)
pulsar/consumer_test.go:3062
FunctionTestGetEncryptionKeys
(t *testing.T)
pulsar/crypto/message_metadata_test.go:27
FunctionTestGetLeaderBroker
(t *testing.T)
pulsaradmin/pkg/admin/brokers_test.go:52
FunctionTestGetMessageByID
(t *testing.T)
pulsaradmin/pkg/admin/subscription_test.go:254
FunctionTestGetMessageID
(t *testing.T)
pulsaradmin/pkg/admin/topic_test.go:461
FunctionTestGetMessagesByID
(t *testing.T)
pulsaradmin/pkg/admin/subscription_test.go:34
FunctionTestGetNamespaceName
(t *testing.T)
pulsaradmin/pkg/utils/namespace_name_test.go:26
FunctionTestGetPackageName
(t *testing.T)
pulsaradmin/pkg/utils/package_name_test.go:26
FunctionTestGetPartitionedTopicMetadataSuccess
(t *testing.T)
pulsar/internal/lookup_service_test.go:521
FunctionTestGetPrivateKey
(t *testing.T)
pulsar/crypto/default_crypto_key_reader_test.go:38
FunctionTestGetPublicKey
(t *testing.T)
pulsar/crypto/default_crypto_key_reader_test.go:26
FunctionTestGetTopicAutoCreation
(t *testing.T)
pulsaradmin/pkg/admin/namespace_test.go:144
FunctionTestGetTopicName
(t *testing.T)
pulsaradmin/pkg/utils/topic_name_test.go:26
FunctionTestGetTopicRestPath
(t *testing.T)
pulsar/internal/topic_name_test.go:160
FunctionTestGrabConn_AddConsumeHandlerFailure
TestGrabConn_AddConsumeHandlerFailure verifies that grabConn returns the error from AddConsumeHandler without sending a subscribe RPC.
pulsar/consumer_partition_test.go:527
FunctionTestGrabConn_BrokerFrameDuringSubscribe
TestGrabConn_BrokerFrameDuringSubscribe simulates the exact race: the broker sends a frame (e.g. ActiveConsumerChange) while the subscribe RPC is stil
pulsar/consumer_partition_test.go:439
FunctionTestGrabConn_ConnResetOnAddHandlerFailure
TestGrabConn_ConnResetOnAddHandlerFailure verifies that when AddConsumeHandler fails on the first call (no prior connection), pc.conn is reset to nil.
pulsar/consumer_partition_test.go:542
FunctionTestGrabConn_ConnResetOnFirstCallFailure
TestGrabConn_ConnResetOnFirstCallFailure verifies that when grabConn fails on the very first call (no prior connection), pc.conn is reset to nil rathe
pulsar/consumer_partition_test.go:420
FunctionTestGrabConn_GetConnectionFailure
TestGrabConn_GetConnectionFailure verifies that grabConn returns the error from GetConnection without registering a handler or sending an RPC.
pulsar/consumer_partition_test.go:510
FunctionTestGrabConn_HandlerRegisteredBeforeSubscribe
TestGrabConn_HandlerRegisteredBeforeSubscribe verifies that the consumer handler is registered on the connection BEFORE the subscribe RPC is sent. Wi
pulsar/consumer_partition_test.go:363
FunctionTestGrabConn_HandlerRemovedOnSubscribeFailure
TestGrabConn_HandlerRemovedOnSubscribeFailure verifies that when the subscribe RPC fails, the pre-registered consumer handler is removed from the conn
pulsar/consumer_partition_test.go:382
FunctionTestGrabConn_HandlerRemovedOnSubscribeTimeout
TestGrabConn_HandlerRemovedOnSubscribeTimeout verifies cleanup on timeout and that the close command is sent on the same connection (not a potentially
pulsar/consumer_partition_test.go:400
FunctionTestGrabConn_MessageReceivedDuringSubscribe_NilConn
TestGrabConn_MessageReceivedDuringSubscribe_NilConn verifies that when the broker delivers a MESSAGE frame while the subscribe RPC is in flight, the c
pulsar/consumer_partition_test.go:471
FunctionTestGrantProviderScopes
(t *testing.T)
pulsar/auth/oauth2_test.go:298
FunctionTestHTTPBasicAuth
(t *testing.T)
pulsar/client_impl_test.go:1041
FunctionTestHTTPLookupAvroSchema
(t *testing.T)
pulsar/schema_test.go:381
FunctionTestHTTPLookupJsonSchema
(t *testing.T)
pulsar/schema_test.go:182
FunctionTestHTTPOAuth2Auth
(t *testing.T)
pulsar/client_impl_test.go:938
FunctionTestHTTPOAuth2AuthFailed
(t *testing.T)
pulsar/client_impl_test.go:1008
FunctionTestHTTPSAuth
(t *testing.T)
pulsar/client_impl_test.go:816
FunctionTestHTTPSAuthError
(t *testing.T)
pulsar/client_impl_test.go:799
FunctionTestHTTPSAuthWithCertSupplier
(t *testing.T)
pulsar/client_impl_test.go:835
FunctionTestHTTPSBasicAuth
(t *testing.T)
pulsar/client_impl_test.go:1063
FunctionTestHTTPSConnection
(t *testing.T)
pulsar/client_impl_test.go:657
FunctionTestHTTPSConnectionCAError
(t *testing.T)
pulsar/client_impl_test.go:621
FunctionTestHTTPSConnectionHostNameVerification
(t *testing.T)
pulsar/client_impl_test.go:674
FunctionTestHTTPSConnectionHostNameVerificationError
(t *testing.T)
pulsar/client_impl_test.go:692
FunctionTestHTTPSInsecureConnection
(t *testing.T)
pulsar/client_impl_test.go:640
FunctionTestHTTPSOAuth2Auth
(t *testing.T)
pulsar/client_impl_test.go:972
FunctionTestHTTPSTokenAuthFromFile
(t *testing.T)
pulsar/client_impl_test.go:919
FunctionTestHTTPTokenAuth
(t *testing.T)
pulsar/client_impl_test.go:858
FunctionTestHTTPTokenAuthFromFile
(t *testing.T)
pulsar/client_impl_test.go:902
FunctionTestHTTPTokenAuthWithSupplier
(t *testing.T)
pulsar/client_impl_test.go:878
FunctionTestHTTPTopicPartitions
(t *testing.T)
pulsar/client_impl_test.go:711
FunctionTestHttpGetPartitionedTopicMetadataSuccess
(t *testing.T)
pulsar/internal/lookup_service_test.go:646
FunctionTestHttpLookupSuccess
(t *testing.T)
pulsar/internal/lookup_service_test.go:631
FunctionTestIllegalParams
(t *testing.T)
pulsar/auth/athenz_test.go:289
FunctionTestInitVersion
(t *testing.T)
pulsar/internal/version_test.go:26
FunctionTestInt16Schema
(t *testing.T)
pulsar/schema_test.go:495
FunctionTestInt32Schema
(t *testing.T)
pulsar/schema_test.go:529
FunctionTestInt64Schema
(t *testing.T)
pulsar/schema_test.go:563
FunctionTestInt8Schema
(t *testing.T)
pulsar/schema_test.go:460
FunctionTestInternalTopicSubscribeToPartitionsDoesNotBlockExistingPartitionLookup
(t *testing.T)
pulsar/consumer_test.go:5933
FunctionTestInternalTopicSubscribeToPartitionsPublishesConsumersBeforeDispatchingMessages
(t *testing.T)
pulsar/consumer_test.go:5993
FunctionTestInvalidBracketedAdditionalHost
(t *testing.T)
pulsar/internal/service_uri_test.go:187
FunctionTestInvalidChunkingConfig
(t *testing.T)
pulsar/message_chunking_test.go:43
FunctionTestInvalidKeyPath
(t *testing.T)
pulsar/crypto/default_crypto_key_reader_test.go:50
FunctionTestInvalidServiceUris
(t *testing.T)
pulsar/internal/service_uri_test.go:28
FunctionTestInvalidURL
(t *testing.T)
pulsar/producer_test.go:55
FunctionTestIpv6Uri
(t *testing.T)
pulsar/internal/service_uri_test.go:103
FunctionTestIpv6UriWithoutPulsarPort
(t *testing.T)
pulsar/internal/service_uri_test.go:109
FunctionTestIsHTTP
(t *testing.T)
pulsar/internal/service_uri_test.go:67
FunctionTestIsNilFixed
nolint
pulsaradmin/pkg/utils/utils_test.go:43
FunctionTestIsNonRetriableSubscribeError
(t *testing.T)
pulsar/consumer_test.go:6418
FunctionTestIsV2Namespace
(t *testing.T)
pulsar/internal/namespace_name_test.go:26
FunctionTestIsV2TopicName
(t *testing.T)
pulsar/internal/topic_name_test.go:128
FunctionTestJavaCompatibility
(t *testing.T)
pulsar/internal/compression/compression_test.go:71
FunctionTestJavaHash
(t *testing.T)
pulsar/internal/hash_test.go:44
FunctionTestJsonSchema
(t *testing.T)
pulsar/schema_test.go:134
FunctionTestKeyBasedBatchProducerConsumerKeyShared
(t *testing.T)
pulsar/consumer_test.go:3430
FunctionTestKeyBasedBatcherOrdering
(t *testing.T)
pulsar/internal/key_based_batch_builder_test.go:41
FunctionTestLargeMessage
(t *testing.T)
pulsar/message_chunking_test.go:62
FunctionTestLimit
(t *testing.T)
pulsar/internal/memory_limit_controller_test.go:29
FunctionTestLocalTopicPoliciesParityWithTopics
(t *testing.T)
pulsaradmin/pkg/admin/topic_policies_test.go:223
FunctionTestLookupConsumer
(t *testing.T)
pulsar/consumer_test.go:5532
FunctionTestLookupService_InvalidScheme_ShouldNotPanic
(t *testing.T)
pulsar/internal/rpc_client_test.go:47
FunctionTestLookupService_InvalidURL_ShouldNotPanic
(t *testing.T)
pulsar/internal/rpc_client_test.go:36
← previousnext →4,401–4,500 of 5,094, ranked by callers