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
MethodDownloadWithContext
DownloadWithContext downloads Function/Connector Package @param ctx context used for the request @param destinationFile file where data should be down
pulsaradmin/pkg/admin/packages.go:54
MethodEncode
(data interface{})
pulsar/schema.go:163
MethodEncode
(data interface{})
pulsar/schema.go:213
MethodEncode
(data interface{})
pulsar/schema.go:291
MethodEncode
(v interface{})
pulsar/schema.go:380
MethodEncode
(data interface{})
pulsar/schema.go:412
MethodEncode
(value interface{})
pulsar/schema.go:442
MethodEncode
(value interface{})
pulsar/schema.go:477
MethodEncode
(value interface{})
pulsar/schema.go:512
MethodEncode
(value interface{})
pulsar/schema.go:547
MethodEncode
(value interface{})
pulsar/schema.go:582
MethodEncode
(value interface{})
pulsar/schema.go:620
MethodEncrypt
Encrypt the payload using the data key and update message metadata with the key and encrypted data key
pulsar/crypto/message_crypto.go:34
MethodEncrypt
(_ []byte, _ *pb.MessageMetadata)
pulsar/internal/key_based_batch_builder_test.go:37
MethodEncrypt
Encrypt Noop ecryptor
pulsar/internal/crypto/noop_encryptor.go:31
MethodEncrypt
Encrypt producer encryptor
pulsar/internal/crypto/producer_encryptor.go:51
MethodEncryptionKeys
()
pulsar/crypto/message_metadata.go:49
MethodEncryptionParam
()
pulsar/crypto/message_metadata.go:78
MethodEntries
()
pulsar/table_view_impl.go:188
MethodEntryID
()
pulsar/reader_test.go:575
MethodEntryID
()
pulsar/impl_message.go:180
MethodEntryID
()
pulsar/impl_message.go:537
MethodEnum
()
pulsar/internal/pulsar_proto/PulsarApi.pb.go:70
MethodEnum
()
pulsar/internal/pulsar_proto/PulsarApi.pb.go:132
MethodEnum
()
pulsar/internal/pulsar_proto/PulsarApi.pb.go:261
MethodEnum
()
pulsar/internal/pulsar_proto/PulsarApi.pb.go:320
MethodEnum
()
pulsar/internal/pulsar_proto/PulsarApi.pb.go:438
MethodEnum
()
pulsar/internal/pulsar_proto/PulsarApi.pb.go:494
MethodEnum
()
pulsar/internal/pulsar_proto/PulsarApi.pb.go:663
MethodEnum
()
pulsar/internal/pulsar_proto/PulsarApi.pb.go:725
MethodEnum
()
pulsar/internal/pulsar_proto/PulsarApi.pb.go:781
MethodEnum
()
pulsar/internal/pulsar_proto/PulsarApi.pb.go:837
MethodEnum
()
pulsar/internal/pulsar_proto/PulsarApi.pb.go:896
MethodEnum
()
pulsar/internal/pulsar_proto/PulsarApi.pb.go:952
MethodEnum
()
pulsar/internal/pulsar_proto/PulsarApi.pb.go:1020
MethodEnum
()
pulsar/internal/pulsar_proto/PulsarApi.pb.go:1076
MethodEnum
()
pulsar/internal/pulsar_proto/PulsarApi.pb.go:1135
MethodEnum
()
pulsar/internal/pulsar_proto/PulsarApi.pb.go:1360
MethodEnumDescriptor
Deprecated: Use CompressionType.Descriptor instead.
pulsar/internal/pulsar_proto/PulsarApi.pb.go:103
MethodEnumDescriptor
Deprecated: Use ProducerAccessMode.Descriptor instead.
pulsar/internal/pulsar_proto/PulsarApi.pb.go:165
MethodEnumDescriptor
Deprecated: Use ServerError.Descriptor instead.
pulsar/internal/pulsar_proto/PulsarApi.pb.go:294
MethodEnumDescriptor
Deprecated: Use AuthMethod.Descriptor instead.
pulsar/internal/pulsar_proto/PulsarApi.pb.go:353
MethodEnumDescriptor
Deprecated: Use ProtocolVersion.Descriptor instead.
pulsar/internal/pulsar_proto/PulsarApi.pb.go:471
MethodEnumDescriptor
Deprecated: Use KeySharedMode.Descriptor instead.
pulsar/internal/pulsar_proto/PulsarApi.pb.go:527
MethodEnumDescriptor
Deprecated: Use TxnAction.Descriptor instead.
pulsar/internal/pulsar_proto/PulsarApi.pb.go:583
MethodEnumDescriptor
Deprecated: Use Schema_Type.Descriptor instead.
pulsar/internal/pulsar_proto/PulsarApi.pb.go:696
MethodEnumDescriptor
Deprecated: Use CommandSubscribe_SubType.Descriptor instead.
pulsar/internal/pulsar_proto/PulsarApi.pb.go:758
MethodEnumDescriptor
Deprecated: Use CommandSubscribe_InitialPosition.Descriptor instead.
pulsar/internal/pulsar_proto/PulsarApi.pb.go:814
MethodEnumDescriptor
Deprecated: Use CommandPartitionedTopicMetadataResponse_LookupType.Descriptor instead.
pulsar/internal/pulsar_proto/PulsarApi.pb.go:870
MethodEnumDescriptor
Deprecated: Use CommandLookupTopicResponse_LookupType.Descriptor instead.
pulsar/internal/pulsar_proto/PulsarApi.pb.go:929
MethodEnumDescriptor
Deprecated: Use CommandAck_AckType.Descriptor instead.
pulsar/internal/pulsar_proto/PulsarApi.pb.go:985
MethodEnumDescriptor
Deprecated: Use CommandAck_ValidationError.Descriptor instead.
pulsar/internal/pulsar_proto/PulsarApi.pb.go:1053
MethodEnumDescriptor
Deprecated: Use CommandTopicMigrated_ResourceType.Descriptor instead.
pulsar/internal/pulsar_proto/PulsarApi.pb.go:1109
MethodEnumDescriptor
Deprecated: Use CommandGetTopicsOfNamespace_Mode.Descriptor instead.
pulsar/internal/pulsar_proto/PulsarApi.pb.go:1168
MethodEnumDescriptor
Deprecated: Use BaseCommand_Type.Descriptor instead.
pulsar/internal/pulsar_proto/PulsarApi.pb.go:1393
MethodError
()
oauth2/authorization_tokenretriever.go:98
MethodError
()
pulsar/consumer.go:315
MethodError
Error satisfies the error interface.
pulsar/helper.go:48
MethodError
()
pulsar/error.go:145
MethodError
(args ...interface{})
pulsar/log/wrapper_logrus.go:74
MethodError
(args ...interface{})
pulsar/log/wrapper_logrus.go:122
MethodError
(args ...interface{})
pulsar/log/logger.go:45
MethodError
(args ...any)
pulsar/log/wrapper_slog.go:46
MethodError
(_ ...interface{})
pulsar/log/log.go:34
MethodError
(_ ...interface{})
pulsar/log/log.go:48
MethodError
()
pulsar/internal/service_uri.go:56
MethodError
()
pulsaradmin/pkg/rest/errors.go:28
MethodErrorf
(_ string, _ ...interface{})
pulsar/helper_for_test.go:189
MethodErrorf
(format string, args ...interface{})
pulsar/log/wrapper_logrus.go:90
MethodErrorf
(format string, args ...interface{})
pulsar/log/wrapper_logrus.go:138
MethodErrorf
(format string, args ...interface{})
pulsar/log/logger.go:50
MethodErrorf
(format string, args ...any)
pulsar/log/wrapper_slog.go:78
MethodErrorf
(_ string, _ ...interface{})
pulsar/log/log.go:38
MethodErrorf
(_ string, _ ...interface{})
pulsar/log/log.go:52
MethodEventTime
()
pulsar/impl_message.go:349
MethodEventTime
()
pulsar/negative_acks_tracker_test.go:216
MethodEventTime
()
pulsar/negative_acks_tracker_test.go:296
MethodEventTime
()
pulsar/internal/pulsartracing/message_carrier_util_test.go:95
MethodExchangeClientCredentials
(req ClientCredentialsExchangeRequest)
oauth2/auth_suite_test.go:50
MethodExchangeClientCredentials
ExchangeClientCredentials uses the ClientCredentialsExchangeRequest to exchange client credentials for tokens
oauth2/authorization_tokenretriever.go:341
MethodExchangeCode
(req AuthorizationCodeExchangeRequest)
oauth2/auth_suite_test.go:40
MethodExchangeCode
ExchangeCode uses the AuthCodeExchangeRequest to exchange an authorization code for tokens
oauth2/authorization_tokenretriever.go:226
MethodExchangeDeviceCode
(_ context.Context, req DeviceCodeExchangeRequest)
oauth2/auth_suite_test.go:55
MethodExchangeDeviceCode
ExchangeDeviceCode uses the DeviceCodeExchangeRequest to exchange a device code for tokens
oauth2/authorization_tokenretriever.go:282
MethodExchangeRefreshToken
(req RefreshTokenExchangeRequest)
oauth2/auth_suite_test.go:45
MethodExchangeRefreshToken
ExchangeRefreshToken uses the RefreshTokenExchangeRequest to exchange a refresh token for refreshed tokens
oauth2/authorization_tokenretriever.go:325
MethodExpireAllMessages
ExpireAllMessages expires all messages older than given N (expireTimeInSeconds) seconds for all subscriptions of the persistent-topic
pulsaradmin/pkg/admin/subscription.go:104
MethodExpireAllMessages
(topic utils.TopicName, expire int64)
pulsaradmin/pkg/admin/subscription.go:267
MethodExpireAllMessagesWithContext
ExpireAllMessagesWithContext expires all messages older than given N (expireTimeInSeconds) seconds for all subscriptions of the persistent-topic
pulsaradmin/pkg/admin/subscription.go:108
MethodExpireMessages
ExpireMessages expires all messages older than given N (expireTimeInSeconds) seconds for a given subscription
pulsaradmin/pkg/admin/subscription.go:96
MethodExpireMessages
(topic utils.TopicName, sName string, expire int64)
pulsaradmin/pkg/admin/subscription.go:252
MethodExpireMessagesWithContext
ExpireMessagesWithContext expires all messages older than given N (expireTimeInSeconds) seconds for a given subscription
pulsaradmin/pkg/admin/subscription.go:100
FunctionExtractUserName
ExtractUserName extracts the username claim from an authorization grant conforms to draft-ietf-oauth-access-token-jwt
oauth2/auth.go:111
MethodFlush
()
pulsar/producer_impl.go:339
MethodFlush
()
pulsar/producer_partition.go:1552
MethodFlush
Flush all the messages buffered in the client and wait until all messages have been successfully persisted.
pulsar/internal/batch_builder.go:256
MethodFlush
()
pulsar/internal/key_based_batch_builder.go:222
MethodFlush
()
pulsar/internal/pulsartracing/producer_interceptor_test.go:66
MethodFlushBatches
FlushBatches only for multiple batches container
pulsar/internal/batch_builder.go:295
MethodFlushBatches
FlushBatches all the messages buffered in multiple batches and wait until all messages have been successfully persisted.
pulsar/internal/key_based_batch_builder.go:196
← previousnext →2,101–2,200 of 5,094, ranked by callers