MCPcopy Create free account

hub / github.com/IBM/sarama / functions

Functions3,668 in github.com/IBM/sarama

⨍ Functions 3,668◇ Types & classes 511
↓ 1 callersFunctiondescribeTopic
describeTopic returns the current replica set for every partition, indexed by partition ID. The inner slice mirrors what Kafka stores: an ordered list
examples/alter_partition_reassignments/main.go:122
↓ 1 callersMethoddispatch
()
consumer.go:664
↓ 1 callersFunctiondoListenerTLSTest
(t *testing.T, expectSuccess bool, serverConfig, clientConfig *tls.Config)
client_tls_test.go:185
↓ 1 callersFunctiondowngradeFlexibleDecoder
(pd packetDecoder)
encoder_decoder.go:139
↓ 1 callersFunctiondowngradeFlexibleEncoder
(pe packetEncoder)
encoder_decoder.go:146
↓ 1 callersFunctiondupInt32Slice
(input []int32)
utils.go:34
↓ 1 callersMethodencode
(pe packetEncoder)
find_coordinator_response.go:56
↓ 1 callersMethodencode
(key, value packetEncoder)
control_record.go:63
↓ 1 callersMethodencode
(pe packetEncoder, version int16)
create_topics_response.go:226
↓ 1 callersMethodencodeHeader
(headerVersion int16, correlationId int32, payloadLength uint32)
mockbroker.go:347
↓ 1 callersMethodencodeRecords
(pe packetEncoder)
record_batch.go:204
↓ 1 callersFunctionencodeSubscriberPlanWithGenerationForBenchmark
(b *testing.B, assignments map[string][]int32, generation int32)
balance_strategy_test.go:2301
↓ 1 callersFunctionencodeSubscriberPlanWithOldSchema
(t *testing.T, assignments map[string][]int32)
balance_strategy_test.go:2313
↓ 1 callersMethodencodeTaggedFields
(pe packetEncoder)
api_versions_response.go:176
↓ 1 callersMethodencodeTaggedFields
(pe packetEncoder)
produce_response.go:226
↓ 1 callersMethodencodeTaggedFields
(pe packetEncoder)
produce_response.go:364
↓ 1 callersMethodencodeTaggedFields
(pe packetEncoder)
fetch_response.go:348
↓ 1 callersFunctionensureFullyReplicated
(t testing.TB, timeout time.Duration, retry time.Duration)
functional_test.go:500
↓ 1 callersFunctionexistingEnvironment
(ctx context.Context, env *testEnvironment)
functional_test.go:264
↓ 1 callersMethodfeed
(partition int32)
async_producer_test.go:121
↓ 1 callersMethodfetchInitialOffset
(topic string, partition int32, retries int)
offset_manager.go:151
↓ 1 callersMethodfetchNewMessages
fetchNewMessages can be nil if no fetch is made, it can occur when all partitions are paused
consumer.go:1304
↓ 1 callersMethodfindStrategy
findStrategy returns the BalanceStrategy with the specified protocolName from the slice provided.
consumer_group.go:637
↓ 1 callersFunctionformatAssignment
(assignment [][]int32)
examples/alter_partition_reassignments/main.go:239
↓ 1 callersMethodgetAbortedTransactions
()
fetch_response.go:374
↓ 1 callersMethodgetArrayLength
()
real_decoder.go:402
↓ 1 callersFunctiongetBalanceScore
Calculate the balance score of the given assignment, as the sum of assigned partitions size difference of all consumer pairs. A perfectly balanced ass
balance_strategy.go:490
↓ 1 callersMethodgetControlRecord
()
records.go:228
↓ 1 callersFunctiongetDecoder
(params ZstdDecoderParams, maxDecodedSize int)
zstd.go:86
↓ 1 callersMethodgetEmptyTaggedFieldArray
()
real_decoder.go:420
↓ 1 callersMethodgetError
(group, topic string, partition int32)
mockresponses.go:538
↓ 1 callersMethodgetError
(topic string, partition int32)
mockresponses.go:599
↓ 1 callersFunctiongetHeaderLength
(headerVersion int16)
broker.go:1380
↓ 1 callersMethodgetHighWaterMark
(topic string, partition int32)
mockresponses.go:399
↓ 1 callersMethodgetInt32Array
()
real_decoder.go:261
↓ 1 callersMethodgetInt32Array
()
real_decoder.go:556
↓ 1 callersMethodgetInt64Array
()
real_decoder.go:590
↓ 1 callersMethodgetInt8
primitives
real_decoder.go:33
↓ 1 callersMethodgetMessage
(topic string, partition int32, offset int64)
mockresponses.go:371
↓ 1 callersMethodgetMessageCount
(topic string, partition int32)
mockresponses.go:385
↓ 1 callersMethodgetNullableInt32Array
()
packet_decoder.go:39
↓ 1 callersMethodgetOffset
(topic string, partition int32, time int64)
mockresponses.go:263
↓ 1 callersMethodgetOffset
(topic string, partitionID int32, timestamp int64)
client.go:896
↓ 1 callersFunctiongetOrRegisterTopicHistogram
(name string, topic string, r metrics.Registry)
metrics.go:42
↓ 1 callersFunctiongetPartitions
(c sarama.Consumer)
tools/kafka-console-consumer/kafka-console-consumer.go:134
↓ 1 callersFunctiongetRandomSublist
(r *rand.Rand, s []string)
balance_strategy_test.go:2346
↓ 1 callersMethodgetString
()
real_decoder.go:214
↓ 1 callersMethodgetString
()
real_decoder.go:527
↓ 1 callersMethodgetSubset
(length int)
packet_decoder.go:45
↓ 1 callersFunctiongetTCPConnSockError
(_ *net.TCPConn)
sockopt_other.go:7
↓ 1 callersMethodgetTheActualPartitionToBeMoved
(partition topicPartitionAssignment, oldConsumer, newConsumer string)
balance_strategy.go:1045
↓ 1 callersMethodgetVarint
()
real_decoder.go:73
↓ 1 callersFunctiongzipCompress
(level int, data []byte)
compress.go:129
↓ 1 callersMethodhandle
(packets []byte, err error)
broker.go:140
↓ 1 callersMethodhandleErrorFor
(err error, targets partitionTargets)
offset_manager.go:473
↓ 1 callersMethodhandleRequests
(conn io.ReadWriteCloser, idx int, wg *sync.WaitGroup)
mockbroker.go:233
↓ 1 callersMethodhandleResponse
(broker *Broker, req *OffsetCommitRequest, resp *OffsetCommitResponse)
offset_manager.go:413
↓ 1 callersMethodhandleResponses
handleResponses handles the response codes left for us by our subscriptions, and abandons ones that have been closed
consumer.go:1205
↓ 1 callersMethodhandleSuccess
(sent *produceSet, response *ProduceResponse)
async_producer.go:1366
↓ 1 callersMethodhandleTxnError
(producer sarama.AsyncProducer, message *sarama.ConsumerMessage, session sarama.ConsumerGroupSession, err erro
examples/exactly_once/main.go:280
↓ 1 callersMethodhasCycles
lint:ignore U1000 // this is used but only in unittests as a helper (which are excluded by the integration build tag)
balance_strategy.go:1123
↓ 1 callersMethodhasGeneration
()
sticky_assignor_user_data.go:10
↓ 1 callersMethodhasTopic
(topic string)
balance_strategy.go:482
↓ 1 callersMethodhasTopics
(topics []string)
metadata.go:142
↓ 1 callersMethodheaderVersion
()
elect_leaders_response.go:136
↓ 1 callersMethodheartbeatLoop
()
consumer_group_session.go:303
↓ 1 callersMethodheartbeatRequest
(coordinator *Broker, memberID string, generationID int32)
consumer_group.go:703
↓ 1 callersMethodhmac
(key []byte, extra []byte)
scram_formatter.go:32
↓ 1 callersMethodin
lint:ignore U1000 // this is used but only in unittests as a helper (which are excluded by the integration build tag)
balance_strategy.go:1108
↓ 1 callersFunctionindexOfSubList
lint:ignore U1000 // this is used but only in unittests as a helper (which are excluded by the integration build tag)
balance_strategy.go:1173
↓ 1 callersMethodinitializeTransactions
re-init producer-id and producer-epoch if needed.
transaction_manager.go:955
↓ 1 callersMethodinterceptors
(msg *ConsumerMessage)
consumer.go:1026
↓ 1 callersFunctionisBalanced
Determine whether the current assignment plan is balanced.
balance_strategy.go:507
↓ 1 callersMethodisFlexible
()
elect_leaders_request.go:99
↓ 1 callersMethodisFlexible
()
encoder_decoder.go:70
↓ 1 callersMethodisFlexible
()
elect_leaders_response.go:147
↓ 1 callersMethodisFlexibleVersion
(version int16)
alter_configs_request.go:161
↓ 1 callersMethodisFlexibleVersion
(version int16)
init_producer_id_response.go:72
↓ 1 callersMethodisFlexibleVersion
(version int16)
acl_delete_response.go:82
↓ 1 callersMethodisFlexibleVersion
(version int16)
offset_commit_request.go:282
↓ 1 callersMethodisFlexibleVersion
(version int16)
acl_delete_request.go:75
↓ 1 callersMethodisFlexibleVersion
(version int16)
leave_group_request.go:120
↓ 1 callersMethodisFlexibleVersion
(version int16)
describe_log_dirs_request.go:107
↓ 1 callersMethodisFlexibleVersion
(version int16)
describe_producers_response.go:255
↓ 1 callersMethodisFlexibleVersion
(version int16)
offset_fetch_response.go:343
↓ 1 callersMethodisFlexibleVersion
(version int16)
find_coordinator_response.go:104
↓ 1 callersMethodisFlexibleVersion
(version int16)
update_features_response.go:134
↓ 1 callersMethodisFlexibleVersion
(version int16)
api_versions_response.go:350
↓ 1 callersMethodisFlexibleVersion
(version int16)
acl_create_request.go:74
↓ 1 callersMethodisFlexibleVersion
(version int16)
add_partitions_to_txn_response.go:114
↓ 1 callersMethodisFlexibleVersion
(version int16)
join_group_response.go:209
↓ 1 callersMethodisFlexibleVersion
(version int16)
create_topics_request.go:140
↓ 1 callersMethodisFlexibleVersion
(version int16)
alter_client_quotas_request.go:236
↓ 1 callersMethodisFlexibleVersion
(version int16)
list_transactions_request.go:120
↓ 1 callersMethodisFlexibleVersion
(version int16)
add_partitions_to_txn_request.go:105
↓ 1 callersMethodisFlexibleVersion
(version int16)
describe_configs_request.go:147
↓ 1 callersMethodisFlexibleVersion
(version int16)
alter_partition_reassignments_response.go:172
↓ 1 callersMethodisFlexibleVersion
(version int16)
alter_partition_reassignments_request.go:134
↓ 1 callersMethodisFlexibleVersion
(version int16)
alter_user_scram_credentials_response.go:102
↓ 1 callersMethodisFlexibleVersion
(version int16)
create_partitions_request.go:95
← previousnext →1,001–1,100 of 3,668, ranked by callers