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
MethodWarn
(args ...interface{})
pulsar/log/wrapper_logrus.go:70
MethodWarn
(args ...interface{})
pulsar/log/wrapper_logrus.go:118
MethodWarn
(args ...interface{})
pulsar/log/logger.go:44
MethodWarn
(args ...any)
pulsar/log/wrapper_slog.go:53
MethodWarn
(_ ...interface{})
pulsar/log/log.go:33
MethodWarn
(_ ...interface{})
pulsar/log/log.go:47
MethodWarnf
(format string, args ...interface{})
pulsar/log/wrapper_logrus.go:86
MethodWarnf
(format string, args ...interface{})
pulsar/log/wrapper_logrus.go:134
MethodWarnf
(format string, args ...interface{})
pulsar/log/logger.go:49
MethodWarnf
(format string, args ...any)
pulsar/log/wrapper_slog.go:72
MethodWarnf
(_ string, _ ...interface{})
pulsar/log/log.go:37
MethodWarnf
(_ string, _ ...interface{})
pulsar/log/log.go:51
MethodWithError
(err error)
pulsar/log/wrapper_logrus.go:56
MethodWithError
(err error)
pulsar/log/wrapper_slog.go:90
MethodWithError
(_ error)
pulsar/log/log.go:30
MethodWithField
(name string, value interface{})
pulsar/log/wrapper_logrus.go:50
MethodWithField
(name string, value interface{})
pulsar/log/wrapper_logrus.go:104
MethodWithField
(name string, value interface{})
pulsar/log/logger.go:39
MethodWithField
(_ string, _ interface{})
pulsar/log/log.go:29
MethodWithField
(_ string, _ interface{})
pulsar/log/log.go:43
MethodWithFields
(fs Fields)
pulsar/log/wrapper_logrus.go:44
MethodWithFields
(fs Fields)
pulsar/log/wrapper_logrus.go:98
MethodWithFields
(fields Fields)
pulsar/log/logger.go:38
MethodWithFields
(fields Fields)
pulsar/log/wrapper_slog.go:100
MethodWithFields
(_ Fields)
pulsar/log/log.go:28
MethodWithFields
(_ Fields)
pulsar/log/log.go:42
MethodWithTransport
(_ http.RoundTripper)
pulsar/auth/disabled.go:60
MethodWithTransport
(tripper http.RoundTripper)
pulsar/auth/oauth2.go:161
MethodWithTransport
(tr http.RoundTripper)
pulsar/auth/basic.go:81
MethodWithTransport
(tripper http.RoundTripper)
pulsar/auth/athenz.go:272
MethodWithTransport
(tripper http.RoundTripper)
pulsar/auth/tls.go:88
MethodWithTransport
(tripper http.RoundTripper)
pulsar/auth/token.go:121
MethodWithTransport
(transport http.RoundTripper)
pulsaradmin/pkg/admin/admin_test.go:72
MethodWithTransport
(tripper http.RoundTripper)
pulsaradmin/pkg/admin/auth/provider.go:32
MethodWithTransport
(t http.RoundTripper)
pulsaradmin/pkg/admin/auth/provider.go:53
MethodWithTransport
(tripper http.RoundTripper)
pulsaradmin/pkg/admin/auth/oauth2.go:144
MethodWithTransport
(tripper http.RoundTripper)
pulsaradmin/pkg/admin/auth/tls.go:106
MethodWithTransport
(tripper http.RoundTripper)
pulsaradmin/pkg/admin/auth/token.go:102
MethodWrappedRoundTripper
()
pulsar/auth/oauth2.go:145
MethodWrappedRoundTripper
()
pulsaradmin/pkg/admin/auth/oauth2.go:177
MethodWrite
(s []byte)
pulsar/internal/buffer.go:269
MethodWriteData
(_ context.Context, _ internal.Buffer)
pulsar/consumer_multitopic_test.go:335
MethodWriteData
(_ context.Context, buffer internal.Buffer)
pulsar/producer_test.go:2746
MethodWriteData
(ctx context.Context, data Buffer)
pulsar/internal/connection.go:457
MethodWriteUint16
(n uint16)
pulsar/internal/buffer.go:263
MethodWriteUint32
(n uint32)
pulsar/internal/buffer.go:253
MethodWriterIndex
()
pulsar/internal/buffer.go:210
MethodWrittenBytes
(size uint32)
pulsar/internal/buffer.go:206
MethodackCumulative
()
pulsar/impl_message.go:112
Methodadd
(cmid *chunkMessageID, ids []*messageID)
pulsar/consumer_partition.go:2828
Methodadd
(id MessageID)
pulsar/ack_grouping_tracker.go:92
Methodadd
(id MessageID)
pulsar/ack_grouping_tracker.go:144
MethodaddCumulative
(id MessageID)
pulsar/ack_grouping_tracker.go:96
MethodaddCumulative
(id MessageID)
pulsar/ack_grouping_tracker.go:185
MethodaddPublishPartitionToTxn
addPublishPartitionToTxn register the partitions which published messages with the transactionImpl. And this can be used when ending the transactionIm
pulsar/transaction_coordinator_client.go:390
MethodaddSubscriptionToTxn
addSubscriptionToTxn register the subscription which acked messages with the transactionImpl. And this can be used when ending the transactionImpl.
pulsar/transaction_coordinator_client.go:406
Methodclose
()
pulsar/transaction_coordinator_client.go:321
Methodclose
()
pulsar/transaction_coordinator_client.go:368
Methodclose
()
pulsar/ack_grouping_tracker.go:110
Methodclose
()
pulsar/ack_grouping_tracker.go:253
Methodclose
()
pulsar/retry_router.go:124
Methodclose
()
pulsar/dlq_router.go:144
FunctiondecodeOptionalJSON
(body []byte)
pulsaradmin/pkg/admin/topic_policies.go:230
Methoddone
(err error)
pulsar/producer_partition.go:1781
MethodendTxn
endTxn commit or abort the transactionImpl.
pulsar/transaction_coordinator_client.go:422
Methodflush
()
pulsar/ack_grouping_tracker.go:104
MethodflushAndClean
()
pulsar/ack_grouping_tracker.go:107
Methodget
(uuid string)
pulsar/consumer_partition.go:2733
MethodhasNext
()
pulsar/consumer_partition.go:2542
Functioninit
()
integration-tests/pb/hi.pb.go:131
Functioninit
()
integration-tests/pb/hello.pb.go:224
Functioninit
()
pulsar/producer_partition.go:84
Functioninit
init Initializes the module version information by reading the built in golang build info. If the application was not built using go modules then the
pulsar/internal/version.go:38
Functioninit
()
pulsar/internal/pulsar_proto/PulsarApi.pb.go:9583
MethodisDuplicate
(_ MessageID)
pulsar/ack_grouping_tracker.go:100
MethodisDuplicate
(id MessageID)
pulsar/ack_grouping_tracker.go:202
Functionmain
()
perf/pulsar-perf-go.go:89
Functionmain
()
examples/consumer-listener/consumer-listener.go:30
Functionmain
()
examples/producer/producer.go:32
Functionmain
()
examples/reader/reader.go:31
Functionmain
()
examples/consumer/consumer.go:31
MethodnewTransaction
newTransaction new a transactionImpl which can be used to guarantee exactly-once semantics.
pulsar/transaction_coordinator_client.go:375
Methodreset
()
pulsar/consumer_partition.go:300
FunctionrunFilterTopicsMatchingAllTopics
(t *testing.T)
pulsar/consumer_regex_test.go:44
FunctionrunFilterTopicsMatchingFoo
(t *testing.T)
pulsar/consumer_regex_test.go:64
FunctionrunRegexConsumerAddMatchingTopic
(t *testing.T, c Client, namespace string)
pulsar/consumer_regex_test.go:320
FunctionrunRegexConsumerAutoDiscoverTopics
(t *testing.T, c Client, namespace string)
pulsar/consumer_regex_test.go:369
FunctionrunRegexConsumerDiscoverPatternAll
(t *testing.T, c Client, namespace string)
pulsar/consumer_regex_test.go:154
FunctionrunRegexConsumerDiscoverPatternFoo
(t *testing.T, c Client, namespace string)
pulsar/consumer_regex_test.go:194
FunctionrunRegexConsumerMatchOneTopic
(t *testing.T, c Client, namespace string)
pulsar/consumer_regex_test.go:256
MethodshrinkReceiverQueueSize
()
pulsar/consumer_partition.go:2448
FunctionsplitURI
(r rune)
pulsar/internal/service_uri.go:152
Methodstart
()
pulsar/transaction_coordinator_client.go:347
Methodunsubscribe
(force bool)
pulsar/consumer_partition.go:527
← previous5,001–5,094 of 5,094, ranked by callers