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
↓ 1 callersMethoduseragent
()
pulsaradmin/pkg/rest/client.go:223
↓ 1 callersMethodvalidateAccessToken
validateAccessToken checks the validity of the cached access token
oauth2/cache/cache.go:100
↓ 1 callersMethodvalidateMsg
(msg *ProducerMessage)
pulsar/producer_partition.go:1144
↓ 1 callersFunctionvalidateNamespaceName
(tenant, namespace string)
pulsaradmin/pkg/utils/namespace_name.go:63
↓ 1 callersMethodwait
wait for broadcast calls. Similar to regular sync.Cond
pulsar/internal/channel_cond.go:42
↓ 1 callersMethodwaitUntilReady
()
pulsar/internal/connection.go:365
↓ 1 callersMethodwatchReaderForNewMessages
(ctx context.Context, reader Reader)
pulsar/table_view_impl.go:267
↓ 1 callersFunctionwriteElement
(w io.Writer, element interface{})
pulsar/primitiveSerDe.go:273
↓ 1 callersFunctionwriteSize
Write the encoded size for the uncompressed payload
pulsar/internal/compression/lz4.go:73
MethodAbort
(ctx context.Context)
pulsar/transaction_impl.go:120
MethodAck
Ack the consumption of a single message
pulsar/consumer_regex.go:186
MethodAck
Ack the consumption of a single message
pulsar/consumer_multitopic.go:179
MethodAck
Ack the consumption of a single message
pulsar/consumer_impl.go:565
MethodAck
()
pulsar/impl_message.go:69
MethodAck
(m Message)
pulsar/consumer_zero_queue.go:161
MethodAck
(_ pulsar.Message)
pulsar/internal/pulsartracing/consumer_interceptor_test.go:74
MethodAckCumulative
AckCumulative the reception of all the messages in the stream up to (and including) the provided message.
pulsar/consumer_regex.go:254
MethodAckCumulative
AckCumulative the reception of all the messages in the stream up to (and including) the provided message
pulsar/consumer_multitopic.go:264
MethodAckCumulative
AckCumulative the reception of all the messages in the stream up to (and including) the provided message, identified by its MessageID
pulsar/consumer_impl.go:589
MethodAckCumulative
(msg Message)
pulsar/consumer_zero_queue.go:212
MethodAckCumulative
(_ pulsar.Message)
pulsar/internal/pulsartracing/consumer_interceptor_test.go:86
MethodAckID
(_ pulsar.MessageID)
pulsar/internal/pulsartracing/consumer_interceptor_test.go:78
MethodAckIDCumulative
(msgID MessageID)
pulsar/consumer_partition.go:879
MethodAckIDCumulative
(_ pulsar.MessageID)
pulsar/internal/pulsartracing/consumer_interceptor_test.go:90
MethodAckIDList
(msgIDs []MessageID)
pulsar/consumer_regex.go:222
MethodAckIDList
(msgIDs []MessageID)
pulsar/consumer_multitopic.go:203
MethodAckIDList
(msgIDs []MessageID)
pulsar/consumer_partition.go:796
MethodAckIDList
(msgIDs []MessageID)
pulsar/consumer_impl.go:43
MethodAckIDList
(msgIDs []MessageID)
pulsar/consumer_impl.go:581
MethodAckIDList
(msgIDs []MessageID)
pulsar/consumer_zero_queue.go:199
MethodAckIDList
(_ []pulsar.MessageID)
pulsar/internal/pulsartracing/consumer_interceptor_test.go:82
MethodAckIDWithResponse
(msgID MessageID)
pulsar/consumer_partition.go:780
MethodAckIDWithResponseCumulative
(msgID MessageID)
pulsar/consumer_partition.go:887
MethodAckIDWithTxn
AckIDWithTxn acknowledges the consumption of a message with transaction.
pulsar/consumer_partition.go:592
MethodAckWithResponse
()
pulsar/impl_message.go:80
MethodAckWithTxn
AckID the consumption of a single message, identified by its MessageID
pulsar/consumer_regex.go:235
MethodAckWithTxn
AckWithTxn the consumption of a single message with a transaction
pulsar/consumer_multitopic.go:246
MethodAckWithTxn
(msg Message, txn Transaction)
pulsar/consumer_impl.go:550
MethodAckWithTxn
(msg Message, txn Transaction)
pulsar/consumer_zero_queue.go:203
MethodAckWithTxn
(_ pulsar.Message, _ pulsar.Transaction)
pulsar/internal/pulsartracing/consumer_interceptor_test.go:55
MethodAcquire
(ctx context.Context)
pulsar/internal/semaphore.go:67
MethodActiveConsumerChanged
(isActive bool)
pulsar/consumer_partition.go:272
MethodAdd
(msgID *messageID)
pulsar/negative_acks_tracker.go:121
MethodAdd
Add will add single message to batch.
pulsar/internal/batch_builder.go:189
MethodAdd
(key string, val *batchContainer)
pulsar/internal/key_based_batch_builder.go:66
MethodAdd
Add will add single message to key-based batch with message key.
pulsar/internal/key_based_batch_builder.go:130
MethodAddConsumeHandler
(id uint64, handler internal.ConsumerHandler)
pulsar/consumer_test.go:6162
MethodAddConsumeHandler
(_ uint64, _ internal.ConsumerHandler)
pulsar/consumer_multitopic_test.go:345
MethodAddConsumeHandler
(_ uint64, h internal.ConsumerHandler)
pulsar/consumer_partition_test.go:641
MethodAddConsumeHandler
(id uint64, handler ConsumerHandler)
pulsar/internal/connection.go:1170
MethodAddInstance
(functionInstanceStats FunctionInstanceStats)
pulsaradmin/pkg/utils/functions_stats.go:83
MethodAddPublicKeyCipher
AddPublicKeyCipher encrypt data using the public key(s) in the argument. If more than one key name is specified, data key is encrypted using each of t
pulsar/crypto/message_crypto.go:27
MethodAfter
After is the same as time.After(d).
oauth2/clock/clock.go:49
MethodAfter
After is the fake version of time.After(d).
oauth2/clock/testing/fake_clock.go:71
MethodAfter
After is unimplemented, will panic. TODO: make interval clock use FakeClock so this can be implemented.
oauth2/clock/testing/fake_clock.go:199
MethodAuthorize
(audience string)
oauth2/client_credentials_flow.go:137
MethodAuthorize
(audience string)
oauth2/device_code_flow.go:110
MethodBatchIdx
()
pulsar/reader_test.go:579
MethodBatchIdx
()
pulsar/impl_message.go:184
MethodBatchIdx
()
pulsar/impl_message.go:541
MethodBatchSize
()
pulsar/reader_test.go:583
MethodBatchSize
()
pulsar/impl_message.go:192
MethodBatchSize
()
pulsar/impl_message.go:549
MethodBecameActive
(consumer Consumer, topicName string, partition int32)
pulsar/consumer_test.go:722
MethodBecameInactive
(consumer Consumer, topicName string, partition int32)
pulsar/consumer_test.go:734
MethodBeforeConsume
(_ ConsumerMessage)
pulsar/consumer_test.go:3262
MethodBeforeConsume
(message ConsumerMessage)
pulsar/consumer_test.go:3273
MethodBeforeConsume
(_ ConsumerMessage)
pulsar/consumer_test.go:3293
MethodBeforeConsume
(_ ConsumerMessage)
pulsar/consumer_test.go:6318
MethodBeforeConsume
(message ConsumerMessage)
pulsar/consumer_interceptor.go:42
MethodBeforeConsume
(message pulsar.ConsumerMessage)
pulsar/internal/pulsartracing/consumer_interceptor.go:32
MethodBeforeSend
(producer Producer, message *ProducerMessage)
pulsar/producer_interceptor.go:32
MethodBeforeSend
(_ Producer, _ *ProducerMessage)
pulsar/producer_test.go:1586
MethodBeforeSend
(_ Producer, _ *ProducerMessage)
pulsar/producer_test.go:1597
MethodBeforeSend
(producer pulsar.Producer, message *pulsar.ProducerMessage)
pulsar/internal/pulsartracing/producer_interceptor.go:32
FunctionBenchmarkCompression
(b *testing.B)
pulsar/internal/compression/compression_bench_test.go:78
FunctionBenchmarkCompressionParallel
(b *testing.B)
pulsar/internal/compression/compression_bench_test.go:98
FunctionBenchmarkDecompression
(b *testing.B)
pulsar/internal/compression/compression_bench_test.go:88
FunctionBenchmarkDefaultRouter
(b *testing.B)
pulsar/default_router_bench_test.go:31
FunctionBenchmarkDefaultRouterParallel
(b *testing.B)
pulsar/default_router_bench_test.go:43
MethodBrokerPublishTime
BrokerPublishTime returns broker publish time from broker entry metadata, or empty if the feature is not enabled in the broker.
pulsar/message.go:148
MethodBrokerPublishTime
()
pulsar/impl_message.go:400
MethodBrokerPublishTime
()
pulsar/negative_acks_tracker_test.go:260
MethodBrokerPublishTime
()
pulsar/negative_acks_tracker_test.go:340
MethodBrokerPublishTime
()
pulsar/internal/pulsartracing/message_carrier_util_test.go:138
MethodBrokerStats
()
pulsaradmin/pkg/admin/admin.go:56
MethodBrokerStats
BrokerStats is used to access the broker stats endpoints
pulsaradmin/pkg/admin/broker_stats.go:65
MethodBrokers
Brokers is used to access the brokers endpoints
pulsaradmin/pkg/admin/brokers.go:118
MethodC
()
oauth2/clock/clock.go:73
MethodC
C returns the underlying timer's channel.
oauth2/clock/clock.go:86
MethodC
C returns the channel that notifies when this timer has fired.
oauth2/clock/testing/fake_clock.go:229
MethodCalculateOverall
()
pulsaradmin/pkg/utils/functions_stats.go:87
MethodCallback
(code *DeviceCodeResult)
oauth2/device_code_flow_test.go:53
MethodCapacity
()
pulsar/internal/buffer.go:171
MethodChan
Chan return the messages chan to user
pulsar/consumer_regex.go:181
MethodChan
Chan return the message chan to users
pulsar/consumer_multitopic.go:174
MethodChan
Chan return the message chan to users
pulsar/consumer_impl.go:560
MethodChan
()
pulsar/retry_router.go:91
MethodChan
()
pulsar/dlq_router.go:102
MethodChan
()
pulsar/consumer_zero_queue.go:157
← previousnext →1,701–1,800 of 5,094, ranked by callers