MCPcopy Create free account

hub / github.com/IBM/sarama / functions

Functions3,668 in github.com/IBM/sarama

⨍ Functions 3,668◇ Types & classes 511
↓ 2 callersFunctionbuildClientFirstMessage
Build SASL/OAUTHBEARER initial client response as described by RFC-7628 https://tools.ietf.org/html/rfc7628
broker.go:1833
↓ 2 callersMethodcachedController
()
client.go:1180
↓ 2 callersMethodcachedPartitions
(topic string, partitionSet partitionType)
client.go:842
↓ 2 callersFunctioncanConsumerParticipateInReassignment
Determine whether a specific consumer should be considered for topic partition assignment.
balance_strategy.go:634
↓ 2 callersFunctioncanTopicPartitionParticipateInReassignment
Only consider reassigning those topic partitions that have two or more potential consumers.
balance_strategy.go:654
↓ 2 callersMethodcheckBrokersHealth
()
client.go:700
↓ 2 callersMethodclear
()
async_producer.go:415
↓ 2 callersMethodclose
close shuts down the muter, waking any goroutines blocked in waitUntilMuted.
async_producer.go:270
↓ 2 callersMethodcompleteTransaction
End current transaction.
transaction_manager.go:615
↓ 2 callersMethodcomputeBackoff
()
consumer.go:548
↓ 2 callersMethodconstructRequestFor
(targets partitionTargets)
offset_manager.go:334
↓ 2 callersMethodcoordinator
()
offset_manager.go:205
↓ 2 callersMethodcopyFunc
(predicate func(topic string, partition int32) bool)
produce_set.go:164
↓ 2 callersFunctioncountHistogramValidator
(name string, expectedCount int)
metrics_helpers_test.go:84
↓ 2 callersFunctioncountMeterValidator
(name string, expectedCount int)
metrics_helpers_test.go:60
↓ 2 callersFunctioncounterValidator
(name string, expectedCount int)
metrics_helpers_test.go:109
↓ 2 callersMethodcrc
(curOffset int, buf []byte)
crc32_field.go:76
↓ 2 callersFunctioncreateTlsConfiguration
()
examples/http_server/http_server.go:62
↓ 2 callersFunctioncurrentUnixMilli
()
broker.go:1701
↓ 2 callersMethoddecode
(pd packetDecoder)
records.go:82
↓ 2 callersMethoddecode
(key, value packetDecoder)
control_record.go:24
↓ 2 callersMethoddecodeSet
decodes a message set from a previously encoded bulk-message
message.go:186
↓ 2 callersFunctiondecodeUserDataBytes
(t *testing.T, base64Data string)
sticky_assignor_user_data_test.go:46
↓ 2 callersFunctiondeepCopyAssignment
(assignment map[string][]topicPartitionAssignment)
balance_strategy.go:815
↓ 2 callersFunctiondefaultConfig
(clientID string)
functional_consumer_group_test.go:401
↓ 2 callersFunctiondeserializeTopicPartitionAssignment
Deserialize topic partition assignment data to aid with creation of a sticky assignment.
balance_strategy.go:671
↓ 2 callersMethoddropPartition
(topic string, partition int32)
produce_set.go:302
↓ 2 callersMethodencode
(pe packetEncoder)
list_transactions_request.go:55
↓ 2 callersMethodendTxn
send EndTxn request with commit flag. (true when committing false otherwise)
transaction_manager.go:639
↓ 2 callersMethodensureEncoded
()
examples/http_server/http_server.go:154
↓ 2 callersFunctionerrorForTopics
(topics []string, err error)
metadata.go:56
↓ 2 callersFunctionfilterAssignedPartitions
filterAssignedPartitions returns a map of consumer group members to their list of previously-assigned topic partitions, limited to those topic partiti
balance_strategy.go:685
↓ 2 callersMethodfindCoordinator
(coordinatorKey string, coordinatorType CoordinatorType, attemptsRemaining int)
client.go:1196
↓ 2 callersMethodfinishTransaction
(commit bool)
async_producer.go:535
↓ 2 callersMethodflushToBroker
()
offset_manager.go:279
↓ 2 callersMethodflushToBrokerFor
(targets partitionTargets)
offset_manager.go:283
↓ 2 callersMethodforTopics
(topics []string)
metadata.go:33
↓ 2 callersFunctionfuzzPanic
fuzzPanic turns any panic during decode into a test failure. Decode errors are an acceptable outcome for arbitrary input; panics, OOB slice access, an
encoder_decoder_fuzz_test.go:10
↓ 2 callersFunctiongenerateMessages
(topic string, partition, messageLoad, messageSize int)
tools/kafka-producer-performance/main.go:203
↓ 2 callersMethodgeneration
()
sticky_assignor_user_data.go:11
↓ 2 callersMethodgetAndIncrementSequenceNumber
(topic string, partition int32)
transaction_manager.go:235
↓ 2 callersMethodgetDialer
()
config.go:929
↓ 2 callersMethodgetFloat64
()
packet_decoder.go:23
↓ 2 callersMethodgetInt16
()
real_decoder.go:43
↓ 2 callersMethodgetInt32
()
real_decoder.go:53
↓ 2 callersMethodgetInt64Array
()
packet_decoder.go:40
↓ 2 callersMethodgetNullableInt32Array
()
real_decoder.go:236
↓ 2 callersMethodgetNullableInt32Array
()
real_decoder.go:564
↓ 2 callersMethodgetNullableInt64Array
()
real_decoder.go:598
↓ 2 callersFunctiongetOrRegisterTopicMeter
(name string, topic string, r metrics.Registry)
metrics.go:38
↓ 2 callersMethodgetPartitions
(topic string, pt partitionType)
client.go:390
↓ 2 callersMethodgetProducerID
()
transaction_manager.go:253
↓ 2 callersMethodgetSockError
()
broker.go:160
↓ 2 callersMethodgetStringLength
()
real_decoder.go:195
↓ 2 callersMethodgetStringLength
()
real_decoder.go:508
↓ 2 callersMethodgetVarint
()
packet_decoder.go:21
↓ 2 callersMethodgetVarintBytes
()
packet_decoder.go:33
↓ 2 callersFunctiongetZstdEncoder
(params ZstdEncoderParams)
zstd.go:61
↓ 2 callersFunctiongetZstdEncoderChannel
getZstdEncoderChannel returns the buffered channel that retains idle zstd encoders for the given params. The slow path holds a single global mutex and
zstd.go:33
↓ 2 callersMethodhandleError
(err error)
offset_manager.go:741
↓ 2 callersMethodhandleError
(sent *produceSet, err error)
async_producer.go:1525
↓ 2 callersMethodinitProducerId
()
transaction_manager.go:496
↓ 2 callersMethodinitSecContext
( client KerberosClient, bytes []byte, )
gssapi_kerberos.go:164
↓ 2 callersMethodisMuted
isMuted reports whether the partition has an in-flight batch. Requires: m.mu held.
async_producer.go:146
↓ 2 callersMethodisOverflow
()
records.go:165
↓ 2 callersFunctionisRetriableTransactionCoordinatorError
isRetriableTransactionCoordinatorError reports whether the given error is a transaction-coordinator error that refreshing the coordinator and retrying
admin_transactions.go:224
↓ 2 callersMethodisTransactional
return true is txnmngr is transactinal.
transaction_manager.go:270
↓ 2 callersFunctionlistOffsetsAndValidate
( t *testing.T, adminClient ClusterAdmin, topic string, partitionsCount int32, offsetQuery int64, expect
functional_admin_test.go:94
↓ 2 callersMethodmac
(key []byte)
scram_formatter.go:16
↓ 2 callersFunctionmagicValue
(pd packetDecoder)
records.go:224
↓ 2 callersFunctionmakeResponsePromise
(res protocolBody)
broker.go:1134
↓ 2 callersMethodmapToRequest
()
transaction_manager.go:173
↓ 2 callersMethodmaybeAddPartitionToCurrentTxn
called before sending any transactional record won't do anything if current topic-partition is already added to transaction.
transaction_manager.go:767
↓ 2 callersMethodmaybeCloseLocked
maybeCloseLocked closes on transport errors and reports whether a close was performed. NOTE: caller must hold b.lock.
broker.go:384
↓ 2 callersFunctionmemberData
memberData reads cooperative ownership from the subscription metadata
balance_strategy.go:877
↓ 2 callersFunctionmeterValidator
(name string, extraValidator func(*testing.T, metrics.Meter))
metrics_helpers_test.go:46
↓ 2 callersFunctionminCountMeterValidator
(name string, minCount int)
metrics_helpers_functional_test.go:16
↓ 2 callersFunctionmockGroupCoordinators
mockGroupCoordinators builds a FindCoordinator handler placing every named group on coordinator.
admin_test.go:2157
↓ 2 callersFunctionmurmur2
murmur2 implements the same hashing algorithm used by the Apache Kafka Java client's DefaultPartitioner (org.apache.kafka.common.utils.Utils.murmur2).
murmur2.go:13
↓ 2 callersMethodmutePartition
mutePartition increments the in-flight count for a single partition. Requires: m.mu held.
async_producer.go:160
↓ 2 callersMethodmuteSet
muteSet increments the in-flight count for all partitions in the set. Requires: m.mu held.
async_producer.go:169
↓ 2 callersMethodneedsRetry
(msg *ProducerMessage)
async_producer.go:1292
↓ 2 callersFunctionnewAsyncProducer
(client Client)
async_producer.go:300
↓ 2 callersFunctionnewCapturingOffsetManager
newCapturingOffsetManager builds an offset manager whose commit requests are recorded in the returned capture.
offset_manager_test.go:990
↓ 2 callersFunctionnewConsumerGroup
(groupID string, client Client)
consumer_group.go:145
↓ 2 callersMethodnewSession
(ctx context.Context, topics []string, handler ConsumerGroupHandler, retries int)
consumer_group.go:513
↓ 2 callersFunctionnewSyncProducerFromAsyncProducer
(p *asyncProducer)
sync_producer.go:108
↓ 2 callersFunctionnewTestAdmin
newTestAdmin builds a V2.1 ClusterAdmin against the given seed broker with retry backoff disabled and auto-cleanup.
admin_test.go:2138
↓ 2 callersFunctionnewTokenProvider
(token *AccessToken, err error)
broker_test.go:381
↓ 2 callersFunctionownedTopicPartitions
(owned []*OwnedPartition)
balance_strategy.go:902
↓ 2 callersFunctionparseKafkaVersion
(version string)
functional_test.go:574
↓ 2 callersMethodpartitioner
(topic string)
mocks/sync_producer.go:138
↓ 2 callersMethodpeekInt8
similar to getSubset, but it doesn't advance the offset
packet_decoder.go:47
↓ 2 callersFunctionpopulateTopicPartitions
(topics map[string][]int32)
sticky_assignor_user_data.go:139
↓ 2 callersMethodpreferredBroker
()
consumer.go:625
↓ 2 callersFunctionprepareFlexibleDecoder
(pd *realDecoder, in versionedDecoder, version int16)
encoder_decoder.go:118
↓ 2 callersFunctionprepareFlexibleEncoder
(pe packetEncoder, req encoder)
encoder_decoder.go:125
↓ 2 callersFunctionprepopulateCurrentAssignments
We need to process subscriptions' user data with each consumer's reported generation in mind higher generations overwrite lower generations in case of
balance_strategy.go:915
↓ 2 callersFunctionproduceMessagesForPartitions
(t *testing.T, client Client, topic string, partitionsCount int32, messagesPerPartition int, baseTimestamp int
functional_admin_test.go:68
↓ 2 callersFunctionproxyForBrokerID
(t testing.TB, brokerID int32)
functional_test.go:476
← previousnext →601–700 of 3,668, ranked by callers