Functions — github.com/apache/pulsar-client-go

hub / github.com/apache/pulsar-client-go / functions

Functions5,094 in github.com/apache/pulsar-client-go

⨍ Functions 5,094◇ Types & classes 637

↓ 1 callersMethodexpectMoreIncomingMessages

()

pulsar/consumer_partition.go:2421

↓ 1 callersFunctionextractTopicPattern

(tn *internal.TopicName)

pulsar/consumer_regex.go:541

↓ 1 callersMethodfailPendingRequests

(err error)

pulsar/internal/connection.go:814

↓ 1 callersMethodfailTimeoutMessages

()

pulsar/producer_partition.go:940

↓ 1 callersFunctionfile_PulsarApi_proto_init

()

pulsar/internal/pulsar_proto/PulsarApi.pb.go:9584

↓ 1 callersFunctionfile_hello_proto_init

()

integration-tests/pb/hello.pb.go:225

↓ 1 callersFunctionfile_hi_proto_rawDescGZIP

()

integration-tests/pb/hi.pb.go:112

↓ 1 callersMethodfindPendingRequest

(requestID uint64)

pulsar/internal/connection.go:807

↓ 1 callersMethodfirstChunkID

()

pulsar/consumer_partition.go:2666

↓ 1 callersMethodflowIfNeed

()

pulsar/consumer_partition.go:308

↓ 1 callersMethodflush

()

pulsar/ack_grouping_tracker.go:220

↓ 1 callersMethodflushAndClean

()

pulsar/ack_grouping_tracker.go:232

↓ 1 callersFunctionfromMessageID

(msgID MessageID)

pulsar/impl_message.go:229

↓ 1 callersFunctionfromString

(uriStr string)

pulsar/internal/service_uri.go:89

↓ 1 callersFunctionfromString

(autoFailoverPolicyTypeName string)

pulsaradmin/pkg/utils/ns_isolation_data.go:42

↓ 1 callersMethodgenSingleMessageMetadataInBatch

( msg *ProducerMessage, uncompressedSize int, )

pulsar/producer_partition.go:770

↓ 1 callersMethodget

()

pulsar/consumer_partition.go:304

↓ 1 callersMethodgetAckBitSet

()

pulsar/impl_message.go:430

↓ 1 callersMethodgetConn

()

pulsar/impl_message.go:408

↓ 1 callersFunctiongetDefaultTransport

(tlsConfig *TLSOptions)

pulsar/internal/http_client.go:340

↓ 1 callersFunctiongetFileProto

(fileDesc protoreflect.FileDescriptor, protoMap map[string]*descriptorpb.FileDescriptorProto)

pulsar/schema.go:284

↓ 1 callersFunctiongetIndividualMsgsFromBatch

(topic utils.TopicName, msgID *utils.MessageID, data []byte, properties map[string]string)

pulsaradmin/pkg/admin/subscription.go:437

↓ 1 callersFunctiongetKeyMeta

(metaMap map[string]string)

pulsar/crypto/message_metadata.go:102

↓ 1 callersFunctiongetKeyMetaMap

(keyValues []*pb.KeyValue)

pulsar/crypto/message_metadata.go:113

↓ 1 callersFunctiongetMessageKey

getMessageKey extracts message key from message metadata. If the OrderingKey exists, the base64-encoded string is returned, otherwise the PartitionKey

pulsar/internal/key_based_batch_builder.go:233

↓ 1 callersMethodgetMigratedBrokerServiceURL

(commandTopicMigrated *pb.CommandTopicMigrated)

pulsar/internal/connection.go:956

↓ 1 callersMethodgetOrCreateSchema

(schemaInfo *SchemaInfo)

pulsar/producer_partition.go:441

↓ 1 callersFunctiongetPartitionIndex

(topic string)

pulsar/internal/topic_name.go:123

↓ 1 callersFunctiongetPartitionIndex

(topic string)

pulsaradmin/pkg/utils/topic_name.go:150

↓ 1 callersFunctiongetPreviousMessage

(mid *trackingMessageID)

pulsar/consumer_partition.go:2392

↓ 1 callersMethodgetProducer

()

pulsar/retry_router.go:132

↓ 1 callersFunctiongetProtoNativeSchemaInfo

(message proto.Message)

pulsar/schema.go:250

↓ 1 callersFunctiongetServicePort

(serviceName string, serviceInfos []string)

pulsar/internal/service_uri.go:252

↓ 1 callersMethodgetState

()

pulsar/transaction_coordinator_client.go:64

↓ 1 callersFunctiongetTCAssignTopicName

(partition uint64)

pulsar/transaction_coordinator_client.go:436

↓ 1 callersMethodgetTLSConfig

()

pulsar/internal/connection.go:1116

↓ 1 callersMethodhandleAckResponse

(ackResponse *pb.CommandAckResponse)

pulsar/internal/connection.go:745

↓ 1 callersMethodhandleActiveConsumerChange

(consumerChange *pb.CommandActiveConsumerChange)

pulsar/internal/connection.go:933

↓ 1 callersMethodhandleAuthChallenge

(authChallenge *pb.CommandAuthChallenge)

pulsar/internal/connection.go:851

↓ 1 callersMethodhandleCloseConsumer

(closeConsumer *pb.CommandCloseConsumer)

pulsar/internal/connection.go:921

↓ 1 callersMethodhandleCloseProducer

(closeProducer *pb.CommandCloseProducer)

pulsar/internal/connection.go:943

↓ 1 callersMethodhandleDeviceCodeResponse

(resp *http.Response)

oauth2/device_code_provider.go:123

↓ 1 callersMethodhandleMessage

(response *pb.CommandMessage, payload Buffer)

pulsar/internal/connection.go:781

↓ 1 callersMethodhandlePing

()

pulsar/internal/connection.go:846

↓ 1 callersMethodhandlePong

()

pulsar/internal/connection.go:842

↓ 1 callersMethodhandleResponseError

(serverError *pb.CommandError)

pulsar/internal/connection.go:731

↓ 1 callersMethodhandleSendError

(sendError *pb.CommandSendError)

pulsar/internal/connection.go:879

↓ 1 callersMethodhandleSendReceipt

(response *pb.CommandSendReceipt)

pulsar/internal/connection.go:765

↓ 1 callersMethodhandleSubscribe

(cmd *pb.CommandSubscribe)

pulsar/consumer_test.go:6234

↓ 1 callersMethodhandleTopicMigrated

(commandTopicMigrated *pb.CommandTopicMigrated)

pulsar/internal/connection.go:967

↓ 1 callersMethodhandler

(id uint64)

pulsar/consumer_test.go:6175

↓ 1 callersMethodhasNext

()

pulsar/consumer_impl.go:802

↓ 1 callersMethodhasPrevBatchAcked

()

pulsar/impl_message.go:458

↓ 1 callersMethodhasSameSchema

(schemaVersion []byte)

pulsar/internal/batch_builder.go:181

↓ 1 callersMethodhasSpace

hasSpace should return true if and only if the batch container can accommodate another message of length payload.

pulsar/internal/batch_builder.go:170

↓ 1 callersMethodhasSpace

hasSpace should return true if and only if the batch container can accommodate another message of length payload.

pulsar/internal/key_based_batch_builder.go:119

↓ 1 callersFunctioninitLogger

(debug bool)

perf/pulsar-perf-go.go:77

↓ 1 callersMethodinitializeCompressionProvider

( compressionType pb.CompressionType)

pulsar/consumer_partition.go:2499

↓ 1 callersMethodinternalAck

(req *ackRequest)

pulsar/consumer_partition.go:1173

↓ 1 callersMethodinternalAckList

(request *ackListRequest)

pulsar/consumer_partition.go:1223

↓ 1 callersMethodinternalAckWithTxn

(req *ackWithTxnRequest)

pulsar/consumer_partition.go:601

↓ 1 callersMethodinternalClose

(req *closeProducer)

pulsar/producer_partition.go:1469

↓ 1 callersMethodinternalClose

(req *closeRequest)

pulsar/consumer_partition.go:2048

↓ 1 callersMethodinternalFlush

(fr *flushRequest)

pulsar/producer_partition.go:1062

↓ 1 callersMethodinternalFlushCurrentBatches

()

pulsar/producer_partition.go:1031

↓ 1 callersMethodinternalGetLastMessageID

(req *getLastMsgIDRequest)

pulsar/consumer_partition.go:728

↓ 1 callersMethodinternalRedeliver

(req *redeliveryRequest)

pulsar/consumer_partition.go:996

↓ 1 callersMethodinternalSeek

(seek *seekRequest)

pulsar/consumer_partition.go:1080

↓ 1 callersMethodinternalSeekByTime

(seek *seekByTimeRequest)

pulsar/consumer_partition.go:1146

↓ 1 callersMethodinternalSendRequest

(req *request)

pulsar/internal/connection.go:705

↓ 1 callersMethodinternalUnsubscribe

(unsub *unsubscribeRequest)

pulsar/consumer_partition.go:656

↓ 1 callersMethodisAllowAckCumulative

()

pulsar/consumer_partition.go:895

↓ 1 callersMethodisIdle

()

pulsar/internal/connection.go:1028

↓ 1 callersFunctionjsonHeaders

()

pulsar/helper_for_test.go:62

↓ 1 callersMethodknownTopics

()

pulsar/consumer_regex.go:399

↓ 1 callersMethodlastChunkID

()

pulsar/consumer_partition.go:2675

↓ 1 callersMethodlastDataReceived

()

pulsar/internal/connection.go:824

↓ 1 callersFunctionlegacyTopicPolicyInt64

(value *int64)

pulsaradmin/pkg/admin/topic.go:1115

↓ 1 callersFunctionlegacyTopicSchemaCompatibilityStrategy

( value *utils.SchemaCompatibilityStrategy, )

pulsaradmin/pkg/admin/topic.go:1129

↓ 1 callersMethodloadPrivateKey

(key []byte)

pulsar/crypto/default_message_crypto.go:329

↓ 1 callersMethodloadPublicKey

read the public key into RSA key

pulsar/crypto/default_message_crypto.go:344

↓ 1 callersMethodlookupTopic

(brokerServiceURL string)

pulsar/producer_partition.go:247

↓ 1 callersMethodlookupTopic

(brokerServiceURL string)

pulsar/consumer_partition.go:2187

↓ 1 callersMethodmessageID

(msgID MessageID)

pulsar/consumer_zero_queue.go:179

↓ 1 callersMethodmessageShouldBeDiscarded

(msgID *trackingMessageID)

pulsar/consumer_partition.go:1701

↓ 1 callersFunctionmockHTTPGetLookupResult

(obj interface{})

pulsar/internal/lookup_service_test.go:602

↓ 1 callersFunctionmockHTTPGetPartitionedTopicMetadataResult

(obj interface{})

pulsar/internal/lookup_service_test.go:615

↓ 1 callersFunctionmockKeyFileWithIssuer

(issuerURL string)

oauth2/client_credentials_flow_test.go:64

↓ 1 callersFunctionmockKeyFileWithoutIssuer

()

oauth2/client_credentials_flow_test.go:86

↓ 1 callersFunctionmockKeyFileWithoutIssuer

()

pulsar/auth/oauth2_test.go:106

↓ 1 callersFunctionmockOAuthServer

mockOAuthServer will mock a oauth service for the tests

pulsaradmin/pkg/admin/auth/oauth2_test.go:34

↓ 1 callersMethodmonitor

()

pulsar/consumer_regex.go:360

↓ 1 callersMethodnack

(cmid *chunkMessageID)

pulsar/consumer_partition.go:2870

↓ 1 callersFunctionnewChunkMessageID

(firstChunkID *messageID, lastChunkID *messageID)

pulsar/impl_message.go:495

↓ 1 callersFunctionnewChunkedMsgCtx

(numChunksFromMsg int32, totalChunkMsgSize int)

pulsar/consumer_partition.go:2648

↓ 1 callersFunctionnewChunkedMsgCtxMap

(maxPending int, pc *partitionConsumer)

pulsar/consumer_partition.go:2707

↓ 1 callersFunctionnewClient

(options ClientOptions)

pulsar/client_impl.go:60

↓ 1 callersFunctionnewConnectionReader

(cnx *connection)

pulsar/internal/connection_reader.go:33

↓ 1 callersFunctionnewConsumer

(client *client, options ConsumerOptions)

pulsar/consumer_impl.go:75

↓ 1 callersFunctionnewConsumerCommand

()

perf/perf-consumer.go:43

← previous next →1,501–1,600 of 5,094, ranked by callers