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
FunctionTestTopics_PublishRate
(t *testing.T)
pulsaradmin/pkg/admin/topic_test.go:1669
FunctionTestTopics_ReplicationClusters
(t *testing.T)
pulsaradmin/pkg/admin/topic_test.go:1254
FunctionTestTrackerPendingAcks
(t *testing.T)
pulsar/ack_grouping_tracker_test.go:266
FunctionTestTransactionDisabled
(t *testing.T)
pulsar/transaction_disabled_test.go:27
FunctionTestTxn_AckAndSend
(t *testing.T)
pulsar/transaction_test.go:342
FunctionTestTxn_AckChunkMessage
(t *testing.T)
pulsar/transaction_test.go:468
FunctionTestTxn_ConnReconnect
(t *testing.T)
pulsar/transaction_test.go:560
FunctionTestTxn_ConsumeAndProduce
Validate the behavior of producing and consuming messages with and without transactions. It consists of the following steps: 1. Prepare: Create a Pul
pulsar/transaction_test.go:249
FunctionTestTxn_ImplCommitOrAbort
Test points: 1. Abort and commit txn. 1. Do nothing, just open a transaction and then commit it or abort it. The operations of committing/abortin
pulsar/transaction_test.go:102
FunctionTestTxn_NoTransactionCoordinator
(t *testing.T)
pulsar/transaction_test.go:208
FunctionTestTxn_RegisterOpAndEndOp
Test the internal API including the registerSendOrAckOp and endSendOrAckOp.
pulsar/transaction_test.go:135
FunctionTestTxn_RegisterTopic
Test the internal API, registerAckTopic and registerProducerTopic
pulsar/transaction_test.go:157
FunctionTestTxn_TCClient
(t *testing.T)
pulsar/transaction_test.go:34
FunctionTestTxn_TransactionAbort
(t *testing.T)
pulsar/transaction_test.go:412
FunctionTestTxn_txnStateErrorMessage
(t *testing.T)
pulsar/transaction_test.go:613
FunctionTestUnloadTopicBeforeConsume
(t *testing.T)
pulsar/consumer_zero_queue_test.go:388
FunctionTestUnsupportedServiceNameError
(t *testing.T)
pulsar/internal/service_uri_test.go:57
FunctionTestUpdateDynamicConfiguration
(t *testing.T)
pulsaradmin/pkg/admin/brokers_test.go:83
FunctionTestUpdateDynamicConfigurationWithCustomURL
(t *testing.T)
pulsaradmin/pkg/admin/brokers_test.go:101
FunctionTestUpdateInvalidServiceUrl
(t *testing.T)
pulsar/internal/service_name_resolver_test.go:37
FunctionTestUpdateOptionsMarshalJSON
(t *testing.T)
pulsaradmin/pkg/utils/update_options_test.go:28
FunctionTestUpdateOptionsUnmarshalJSON
(t *testing.T)
pulsaradmin/pkg/utils/update_options_test.go:37
FunctionTestUpdateTopicPartitions
(t *testing.T)
pulsaradmin/pkg/admin/topic_test.go:438
FunctionTestUpsertEncryptionKey
(t *testing.T)
pulsar/crypto/message_metadata_test.go:87
FunctionTestUserInfo
(t *testing.T)
pulsar/internal/service_uri_test.go:98
FunctionTestUserInfoWithMultipleHosts
(t *testing.T)
pulsar/internal/service_uri_test.go:191
FunctionTestValidateHashRanges
(t *testing.T)
pulsar/key_shared_policy_test.go:33
FunctionTestVersionHasNoSpaces
(t *testing.T)
pulsar/internal/version_test.go:30
FunctionTestWaitForExclusiveProducer
(t *testing.T)
pulsar/producer_test.go:2036
FunctionTestWebServiceUrlTLSWithTLSTransportWithBasicAuth
(t *testing.T)
pulsar/client_impl_test.go:1117
FunctionTestWithDeadLetterTopicDeadLetterTopicProducerName
(t *testing.T)
pulsar/consumer_test.go:2258
FunctionTestWithoutDeadLetterTopicDeadLetterTopicProducerName
(t *testing.T)
pulsar/consumer_test.go:2171
FunctionTestWriteElements
(t *testing.T)
pulsar/primitiveSerDe_test.go:29
FunctionTestZeroQueueConsumerGetLastMessageIDs
(t *testing.T)
pulsar/consumer_zero_queue_test.go:646
FunctionTestZeroQueueConsumer_AckCumulativeConsumer
(t *testing.T)
pulsar/consumer_zero_queue_test.go:758
FunctionTestZeroQueueConsumer_Chan
(t *testing.T)
pulsar/consumer_zero_queue_test.go:706
FunctionTestZeroQueueConsumer_Nack
(t *testing.T)
pulsar/consumer_zero_queue_test.go:813
FunctionTestZeroQueueConsumer_Seek
(t *testing.T)
pulsar/consumer_zero_queue_test.go:880
FunctionTestZeroQueueConsumer_SeekByTime
(t *testing.T)
pulsar/consumer_zero_queue_test.go:940
FunctionTest_joinErrors
(t *testing.T)
pulsar/error_test.go:27
MethodTick
Tick is the same as time.Tick(d)
oauth2/clock/clock.go:61
MethodTick
Tick constructs a fake ticker, akin to time.Tick
oauth2/clock/testing/fake_clock.go:101
MethodTick
Tick is unimplemented, will panic. TODO: make interval clock use FakeClock so this can be implemented.
oauth2/clock/testing/fake_clock.go:211
MethodToken
Token returns a valid access token, if available.
oauth2/cache/cache.go:69
MethodTopic
()
pulsar/producer_impl.go:280
MethodTopic
Topic returns the topic from which this message originated from.
pulsar/message.go:81
MethodTopic
()
pulsar/message.go:178
MethodTopic
()
pulsar/producer_partition.go:598
MethodTopic
Topic return the topic to which producer is publishing to
pulsar/producer.go:223
MethodTopic
()
pulsar/reader_impl.go:157
MethodTopic
()
pulsar/impl_message.go:325
MethodTopic
()
pulsar/impl_message.go:557
MethodTopic
()
pulsar/negative_acks_tracker_test.go:188
MethodTopic
()
pulsar/negative_acks_tracker_test.go:268
MethodTopic
()
pulsar/internal/pulsartracing/producer_interceptor_test.go:46
MethodTopic
()
pulsar/internal/pulsartracing/message_carrier_util_test.go:71
MethodTopicPartitions
(topic string)
pulsar/client_impl.go:248
MethodTopicPolicies
(isGlobal bool)
pulsaradmin/pkg/admin/topic_policies.go:160
MethodTopics
Topics is used to access the topics endpoints
pulsaradmin/pkg/admin/topic.go:1094
MethodTransport
()
pulsar/auth/disabled.go:56
MethodTransport
()
pulsar/auth/provider.go:49
MethodTransport
()
pulsar/auth/oauth2.go:151
MethodTransport
()
pulsar/auth/basic.go:77
MethodTransport
()
pulsar/auth/athenz.go:268
MethodTransport
()
pulsar/auth/tls.go:84
MethodTransport
()
pulsar/auth/token.go:117
MethodTransport
()
pulsaradmin/pkg/admin/admin_test.go:68
MethodTransport
()
pulsaradmin/pkg/admin/auth/provider.go:49
MethodTransport
()
pulsaradmin/pkg/admin/auth/oauth2.go:148
MethodTransport
()
pulsaradmin/pkg/admin/auth/tls.go:92
MethodTransport
()
pulsaradmin/pkg/admin/auth/token.go:98
MethodTriggerFunction
TriggerFunction triggers the function by writing to the input topic
pulsaradmin/pkg/admin/functions.go:214
MethodTriggerFunction
(tenant, namespace, name, topic, triggerValue, triggerFile string)
pulsaradmin/pkg/admin/functions.go:871
MethodTriggerFunctionWithContext
TriggerFunctionWithContext triggers the function by writing to the input topic
pulsaradmin/pkg/admin/functions.go:217
MethodTryAcquire
()
pulsar/internal/semaphore.go:84
MethodType
()
pulsar/internal/pulsar_proto/PulsarApi.pb.go:84
MethodType
()
pulsar/internal/pulsar_proto/PulsarApi.pb.go:146
MethodType
()
pulsar/internal/pulsar_proto/PulsarApi.pb.go:275
MethodType
()
pulsar/internal/pulsar_proto/PulsarApi.pb.go:334
MethodType
()
pulsar/internal/pulsar_proto/PulsarApi.pb.go:452
MethodType
()
pulsar/internal/pulsar_proto/PulsarApi.pb.go:508
MethodType
()
pulsar/internal/pulsar_proto/PulsarApi.pb.go:564
MethodType
()
pulsar/internal/pulsar_proto/PulsarApi.pb.go:677
MethodType
()
pulsar/internal/pulsar_proto/PulsarApi.pb.go:739
MethodType
()
pulsar/internal/pulsar_proto/PulsarApi.pb.go:795
MethodType
()
pulsar/internal/pulsar_proto/PulsarApi.pb.go:851
MethodType
()
pulsar/internal/pulsar_proto/PulsarApi.pb.go:910
MethodType
()
pulsar/internal/pulsar_proto/PulsarApi.pb.go:966
MethodType
()
pulsar/internal/pulsar_proto/PulsarApi.pb.go:1034
MethodType
()
pulsar/internal/pulsar_proto/PulsarApi.pb.go:1090
MethodType
()
pulsar/internal/pulsar_proto/PulsarApi.pb.go:1149
MethodType
()
pulsar/internal/pulsar_proto/PulsarApi.pb.go:1374
MethodUnload
(topic utils.TopicName)
pulsaradmin/pkg/admin/topic.go:1512
MethodUnload
Unload a namespace from the current serving broker
pulsaradmin/pkg/admin/namespace.go:476
MethodUnload
(namespace string)
pulsaradmin/pkg/admin/namespace.go:1625
MethodUnloadNamespaceBundle
UnloadNamespaceBundle unloads namespace bundle
pulsaradmin/pkg/admin/namespace.go:482
MethodUnloadNamespaceBundle
(namespace, bundle string)
pulsaradmin/pkg/admin/namespace.go:1638
MethodUnloadNamespaceBundleWithContext
UnloadNamespaceBundleWithContext unloads namespace bundle
pulsaradmin/pkg/admin/namespace.go:485
MethodUnloadWithContext
UnloadWithContext a topic
pulsaradmin/pkg/admin/topic.go:378
MethodUnloadWithContext
UnloadWithContext a namespace from the current serving broker
pulsaradmin/pkg/admin/namespace.go:479
← previousnext →4,801–4,900 of 5,094, ranked by callers