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
MethodNewProducerID
()
pulsar/internal/lookup_service_test.go:53
MethodNewProducerID
()
pulsar/internal/lookup_service_test.go:460
MethodNewProducerID
()
pulsar/internal/rpc_client.go:216
FunctionNewPublishRate
()
pulsaradmin/pkg/utils/publish_rate.go:25
MethodNewRequestID
()
pulsar/consumer_test.go:6197
MethodNewRequestID
()
pulsar/consumer_test.go:6271
MethodNewRequestID
()
pulsar/consumer_partition_test.go:681
MethodNewRequestID
Create a new unique request id
pulsar/internal/lookup_service_test.go:48
MethodNewRequestID
()
pulsar/internal/lookup_service_test.go:455
MethodNewRequestID
()
pulsar/internal/rpc_client.go:212
FunctionNewResourceQuota
()
pulsaradmin/pkg/utils/resource_quota.go:35
FunctionNewRetentionPolicies
(retentionTimeInMinutes int, retentionSizeInMB int)
pulsaradmin/pkg/utils/retention_policies.go:25
FunctionNewSubscribeRate
()
pulsaradmin/pkg/utils/dispatch_rate.go:39
MethodNewTimer
NewTimer is the same as time.NewTimer(d)
oauth2/clock/clock.go:54
MethodNewTimer
NewTimer constructs a fake timer, akin to time.NewTimer(d).
oauth2/clock/testing/fake_clock.go:84
MethodNewTimer
NewTimer is unimplemented, will panic. TODO: make interval clock use FakeClock so this can be implemented.
oauth2/clock/testing/fake_clock.go:205
MethodNewTransaction
(timeout time.Duration)
pulsar/client_impl.go:201
FunctionNewUpdateOptions
()
pulsaradmin/pkg/utils/update_options.go:25
FunctionNewWithAuthProvider
NewWithAuthProvider creates a client with auth provider. Deprecated: Use NewPulsarClientWithAuthProvider instead.
pulsaradmin/pkg/admin/admin.go:78
FunctionNewZStdProvider
(level Level)
pulsar/internal/compression/zstd_cgo.go:59
MethodNext
()
pulsar/reader_test.go:906
MethodNext
(ctx context.Context)
pulsar/reader_impl.go:161
MethodNext
Next param redeliveryCount indicates the number of times the message was redelivered. We can get the redeliveryCount from the CommandMessage.
pulsar/negative_backoff_policy.go:34
MethodNext
(redeliveryCount uint32)
pulsar/negative_backoff_policy.go:40
MethodNext
()
pulsar/producer_test.go:2971
MethodNow
Now returns the current time.
oauth2/clock/clock.go:39
MethodNow
Now returns f's time.
oauth2/clock/testing/fake_clock.go:57
MethodNow
Now returns i's time.
oauth2/clock/testing/fake_clock.go:187
MethodNsIsolationPolicy
()
pulsaradmin/pkg/admin/ns_isolation_policy.go:91
MethodNsIsolationPolicy
()
pulsaradmin/pkg/admin/admin.go:54
MethodNumPartitions
()
pulsar/producer_impl.go:288
MethodNumPartitions
()
pulsar/single_partition_router_test.go:30
MethodNumber
()
pulsar/internal/pulsar_proto/PulsarApi.pb.go:88
MethodNumber
()
pulsar/internal/pulsar_proto/PulsarApi.pb.go:150
MethodNumber
()
pulsar/internal/pulsar_proto/PulsarApi.pb.go:279
MethodNumber
()
pulsar/internal/pulsar_proto/PulsarApi.pb.go:338
MethodNumber
()
pulsar/internal/pulsar_proto/PulsarApi.pb.go:456
MethodNumber
()
pulsar/internal/pulsar_proto/PulsarApi.pb.go:512
MethodNumber
()
pulsar/internal/pulsar_proto/PulsarApi.pb.go:568
MethodNumber
()
pulsar/internal/pulsar_proto/PulsarApi.pb.go:681
MethodNumber
()
pulsar/internal/pulsar_proto/PulsarApi.pb.go:743
MethodNumber
()
pulsar/internal/pulsar_proto/PulsarApi.pb.go:799
MethodNumber
()
pulsar/internal/pulsar_proto/PulsarApi.pb.go:855
MethodNumber
()
pulsar/internal/pulsar_proto/PulsarApi.pb.go:914
MethodNumber
()
pulsar/internal/pulsar_proto/PulsarApi.pb.go:970
MethodNumber
()
pulsar/internal/pulsar_proto/PulsarApi.pb.go:1038
MethodNumber
()
pulsar/internal/pulsar_proto/PulsarApi.pb.go:1094
MethodNumber
()
pulsar/internal/pulsar_proto/PulsarApi.pb.go:1153
MethodNumber
()
pulsar/internal/pulsar_proto/PulsarApi.pb.go:1378
MethodOffload
Offload triggers offloading messages in topic to longterm storage
pulsaradmin/pkg/admin/topic.go:363
MethodOffload
(topic utils.TopicName, messageID utils.MessageID)
pulsaradmin/pkg/admin/topic.go:1489
MethodOffloadStatus
OffloadStatus checks the status of an ongoing offloading operation for a topic
pulsaradmin/pkg/admin/topic.go:369
MethodOffloadStatus
(topic utils.TopicName)
pulsaradmin/pkg/admin/topic.go:1498
MethodOffloadStatusWithContext
OffloadStatusWithContext checks the status of an ongoing offloading operation for a topic
pulsaradmin/pkg/admin/topic.go:372
MethodOffloadWithContext
OffloadWithContext triggers offloading messages in topic to longterm storage
pulsaradmin/pkg/admin/topic.go:366
MethodOnAcknowledge
(_ Consumer, _ MessageID)
pulsar/consumer_test.go:3264
MethodOnAcknowledge
(_ Consumer, _ MessageID)
pulsar/consumer_test.go:3284
MethodOnAcknowledge
(_ Consumer, _ MessageID)
pulsar/consumer_test.go:3295
MethodOnAcknowledge
(_ Consumer, _ MessageID)
pulsar/consumer_test.go:6319
MethodOnAcknowledge
(consumer Consumer, msgID MessageID)
pulsar/consumer_interceptor.go:48
MethodOnAcknowledge
(_ pulsar.Consumer, _ pulsar.MessageID)
pulsar/internal/pulsartracing/consumer_interceptor.go:36
MethodOnConsumerClose
(consumer Consumer, err error)
pulsar/consumer_test.go:6321
MethodOnConsumerClose
(consumer Consumer, err error)
pulsar/consumer_interceptor.go:60
MethodOnNegativeAcksSend
(_ Consumer, _ []MessageID)
pulsar/consumer_test.go:3266
MethodOnNegativeAcksSend
(_ Consumer, _ []MessageID)
pulsar/consumer_test.go:3286
MethodOnNegativeAcksSend
(_ Consumer, msgIDs []MessageID)
pulsar/consumer_test.go:3299
MethodOnNegativeAcksSend
(_ Consumer, _ []MessageID)
pulsar/consumer_test.go:6320
MethodOnNegativeAcksSend
(consumer Consumer, msgIDs []MessageID)
pulsar/consumer_interceptor.go:54
MethodOnNegativeAcksSend
(_ pulsar.Consumer, _ []pulsar.MessageID)
pulsar/internal/pulsartracing/consumer_interceptor.go:38
MethodOnSendAcknowledgement
(producer Producer, message *ProducerMessage, msgID MessageID)
pulsar/producer_interceptor.go:38
MethodOnSendAcknowledgement
(_ Producer, _ *ProducerMessage, _ MessageID)
pulsar/producer_test.go:1588
MethodOnSendAcknowledgement
(_ Producer, _ *ProducerMessage, _ MessageID)
pulsar/producer_test.go:1601
MethodOnSendAcknowledgement
(_ pulsar.Producer, _ *pulsar.ProducerMessage, _ pulsar.MessageID)
pulsar/internal/pulsartracing/producer_interceptor.go:36
MethodOrderingKey
()
pulsar/impl_message.go:357
MethodOrderingKey
()
pulsar/negative_acks_tracker_test.go:224
MethodOrderingKey
()
pulsar/negative_acks_tracker_test.go:304
MethodOrderingKey
()
pulsar/internal/pulsartracing/message_carrier_util_test.go:103
MethodPackages
Packages is used to access the functions endpoints
pulsaradmin/pkg/admin/packages.go:141
MethodPackages
()
pulsaradmin/pkg/admin/admin.go:59
FunctionParseAuthAction
(action string)
pulsaradmin/pkg/utils/auth_action.go:33
FunctionParseBacklogQuotaType
(str string)
pulsaradmin/pkg/utils/backlog_quota.go:68
FunctionParseInactiveTopicDeleteMode
(str string)
pulsaradmin/pkg/utils/inactive_topic_policies.go:35
FunctionParseRetentionPolicy
(str string)
pulsaradmin/pkg/utils/backlog_quota.go:44
FunctionParseSubscriptionAuthMode
(s string)
pulsaradmin/pkg/utils/subscription_auth_mode.go:29
FunctionParseTopicType
(topicType string)
pulsaradmin/pkg/utils/topic_type.go:29
MethodPartitionIdx
()
pulsar/reader_test.go:587
MethodPartitionIdx
()
pulsar/impl_message.go:188
MethodPartitionIdx
()
pulsar/impl_message.go:545
MethodPayload
()
pulsar/impl_message.go:333
MethodPayload
()
pulsar/negative_acks_tracker_test.go:196
MethodPayload
()
pulsar/negative_acks_tracker_test.go:276
MethodPayload
()
pulsar/internal/pulsartracing/message_carrier_util_test.go:79
MethodPeek
()
pulsar/producer_test.go:2555
MethodPeek
()
pulsar/internal/blocking_queue.go:166
MethodPeekLast
()
pulsar/producer_test.go:2559
MethodPeekLast
()
pulsar/internal/blocking_queue.go:176
MethodPeekMessages
(topic utils.TopicName, sName string, n int)
pulsaradmin/pkg/admin/subscription.go:278
MethodPeekMessagesWithContext
PeekMessagesWithContext peeks messages from a topic subscription
pulsaradmin/pkg/admin/subscription.go:114
MethodPercentUsage
()
pulsaradmin/pkg/utils/load_manage_report.go:128
MethodPoll
()
pulsar/producer_test.go:2547
← previousnext →3,201–3,300 of 5,094, ranked by callers