MCPcopy Create free account

hub / github.com/IBM/sarama / functions

Functions3,668 in github.com/IBM/sarama

⨍ Functions 3,668◇ Types & classes 511
↓ 1 callersMethodisFlexibleVersion
(version int16)
fetch_request.go:311
↓ 1 callersMethodisFlexibleVersion
(version int16)
offset_commit_response.go:135
↓ 1 callersMethodisFlexibleVersion
(version int16)
end_txn_response.go:65
↓ 1 callersMethodisFlexibleVersion
(version int16)
find_coordinator_request.go:75
↓ 1 callersMethodisFlexibleVersion
(version int16)
list_partition_reassignments_request.go:88
↓ 1 callersMethodisFlexibleVersion
(version int16)
delete_groups_response.go:91
↓ 1 callersMethodisFlexibleVersion
(version int16)
offset_request.go:221
↓ 1 callersMethodisFlexibleVersion
(version int16)
list_transactions_response.go:143
↓ 1 callersMethodisFlexibleVersion
(version int16)
list_groups_request.go:79
↓ 1 callersMethodisFlexibleVersion
(version int16)
heartbeat_request.go:80
↓ 1 callersMethodisFlexibleVersion
(version int16)
produce_request.go:253
↓ 1 callersMethodisFlexibleVersion
(version int16)
elect_leaders_request.go:103
↓ 1 callersMethodisFlexibleVersion
(version int16)
encoder_decoder.go:69
↓ 1 callersMethodisFlexibleVersion
(version int16)
describe_groups_response.go:89
↓ 1 callersMethodisFlexibleVersion
(version int16)
elect_leaders_response.go:151
↓ 1 callersMethodisFlexibleVersion
(version int16)
describe_groups_request.go:62
↓ 1 callersMethodisFlexibleVersion
(version int16)
acl_create_response.go:83
↓ 1 callersMethodisFlexibleVersion
(version int16)
describe_transactions_request.go:53
↓ 1 callersMethodisFlexibleVersion
(version int16)
delete_records_request.go:121
↓ 1 callersMethodisFlexibleVersion
(version int16)
metadata_response.go:363
↓ 1 callersMethodisFlexibleVersion
(version int16)
acl_describe_request.go:47
↓ 1 callersMethodisFlexibleVersion
(version int16)
describe_user_scram_credentials_response.go:180
↓ 1 callersMethodisFlexibleVersion
(version int16)
txn_offset_commit_request.go:156
↓ 1 callersMethodisFlexibleVersion
(version int16)
list_partition_reassignments_response.go:184
↓ 1 callersMethodisFlexibleVersion
(version int16)
delete_topics_response.go:134
↓ 1 callersMethodisFlexibleVersion
(version int16)
offset_response.go:226
↓ 1 callersMethodisFlexibleVersion
(version int16)
add_offsets_to_txn_response.go:66
↓ 1 callersMethodisFlexibleVersion
(version int16)
describe_client_quotas_request.go:184
↓ 1 callersMethodisFlexibleVersion
(version int16)
metadata_request.go:181
↓ 1 callersMethodisFlexibleVersion
(version int16)
produce_response.go:410
↓ 1 callersMethodisFlexibleVersion
(version int16)
describe_user_scram_credentials_request.go:80
↓ 1 callersMethodisFlexibleVersion
(version int16)
acl_describe_response.go:98
↓ 1 callersMethodisFlexibleVersion
(version int16)
incremental_alter_configs_request.go:200
↓ 1 callersMethodisFlexibleVersion
(version int16)
end_txn_request.go:74
↓ 1 callersMethodisFlexibleVersion
(version int16)
describe_transactions_response.go:217
↓ 1 callersMethodisFlexibleVersion
(version int16)
update_features_request.go:122
↓ 1 callersMethodisFlexibleVersion
(version int16)
alter_user_scram_credentials_request.go:160
↓ 1 callersMethodisFlexibleVersion
(version int16)
join_group_request.go:210
↓ 1 callersMethodisFlexibleVersion
(version int16)
delete_topics_request.go:124
↓ 1 callersMethodisFlexibleVersion
(version int16)
list_groups_response.go:147
↓ 1 callersMethodisFlexibleVersion
(version int16)
create_partitions_response.go:90
↓ 1 callersMethodisFlexibleVersion
(version int16)
heartbeat_response.go:64
↓ 1 callersMethodisFlexibleVersion
(version int16)
sasl_authenticate_response.go:79
↓ 1 callersMethodisFlexibleVersion
(version int16)
describe_log_dirs_response.go:99
↓ 1 callersMethodisFlexibleVersion
(version int16)
add_offsets_to_txn_request.go:77
↓ 1 callersMethodisFlexibleVersion
(version int16)
describe_configs_response.go:175
↓ 1 callersMethodisFlexibleVersion
(version int16)
offset_fetch_request.go:298
↓ 1 callersMethodisFlexibleVersion
(version int16)
alter_client_quotas_response.go:169
↓ 1 callersMethodisFlexibleVersion
(version int16)
api_versions_request.go:70
↓ 1 callersMethodisFlexibleVersion
(version int16)
incremental_alter_configs_response.go:78
↓ 1 callersMethodisFlexibleVersion
(version int16)
alter_configs_response.go:164
↓ 1 callersMethodisFlexibleVersion
(version int16)
sasl_authenticate_request.go:53
↓ 1 callersMethodisFlexibleVersion
(version int16)
describe_producers_request.go:102
↓ 1 callersMethodisFlexibleVersion
(version int16)
init_producer_id_request.go:80
↓ 1 callersMethodisFlexibleVersion
(version int16)
delete_records_response.go:122
↓ 1 callersMethodisFlexibleVersion
(version int16)
create_topics_response.go:133
↓ 1 callersMethodisFlexibleVersion
(version int16)
sync_group_request.go:169
↓ 1 callersMethodisFlexibleVersion
(version int16)
sync_group_response.go:108
↓ 1 callersMethodisFlexibleVersion
(version int16)
delete_groups_request.go:48
↓ 1 callersMethodisFlexibleVersion
(version int16)
txn_offset_commit_response.go:118
↓ 1 callersMethodisFlexibleVersion
(version int16)
fetch_response.go:536
↓ 1 callersMethodisFlexibleVersion
(version int16)
leave_group_response.go:109
↓ 1 callersMethodisFlexibleVersion
(version int16)
describe_client_quotas_response.go:272
↓ 1 callersMethodisGSSAPI
(buffer []byte)
mockbroker.go:229
↓ 1 callersMethodisLinked
lint:ignore U1000 // this is used but only in unittests as a helper (which are excluded by the integration build tag)
balance_strategy.go:1073
↓ 1 callersFunctionisRetriableClaimError
isRetriableClaimError reports whether err from newConsumerGroupClaim is a transient condition worth retrying after a metadata refresh
consumer_group_session.go:219
↓ 1 callersMethodisSticky
lint:ignore U1000 // this is used but only in unittests as a helper (which are excluded by the integration build tag)
balance_strategy.go:1155
↓ 1 callersFunctionisTopicExistsErrorOrOk
(err KError)
functional_test.go:447
↓ 1 callersFunctionisTopicNotExistsErrorOrOk
(err KError)
functional_test.go:443
↓ 1 callersMethodisTransitionValid
Return true if current transition is allowed.
transaction_manager.go:190
↓ 1 callersMethodisValidVersion
()
metadata_request.go:173
↓ 1 callersMethodisValidVersion
()
request.go:16
↓ 1 callersFunctionjavaConsumerArgs
(topic string, startOffset int64, count int)
functional_java_interop_test.go:292
↓ 1 callersFunctionjavaProducerArgs
(topic string, codec CompressionCodec)
functional_java_interop_test.go:274
↓ 1 callersFunctionjavaProducerCompressionArgs
(codec CompressionCodec)
functional_java_interop_test.go:285
↓ 1 callersMethodjoinGroupRequest
(coordinator *Broker, topics []string, held *heldAssignment)
consumer_group.go:532
↓ 1 callersFunctionleastUsedBroker
leastUsedBroker returns the broker in brokerIDs (sorted ascending) that is not already in exclude and currently hosts the fewest replicas, breaking ti
examples/alter_partition_reassignments/main.go:177
↓ 1 callersMethodleave
Leaves the cluster, called by Close.
consumer_group.go:763
↓ 1 callersMethodloop
(topics []string)
functional_consumer_group_test.go:601
↓ 1 callersMethodloopCheckPartitionNumbers
(allSubscribedTopicPartitions map[string][]int32, topics []string, session *consumerGroupSession)
consumer_group.go:852
↓ 1 callersMethodlostHeldAssignment
(held *heldAssignment, err error)
consumer_group.go:505
↓ 1 callersFunctionlz4Compress
(data []byte)
compress.go:178
↓ 1 callersFunctionmakeInput
(length int)
real_decoder_test.go:79
↓ 1 callersFunctionmapToString
mapToString returns a list of key-value pairs ordered by key. keyValSep separates the key from the value. elemSep separates each pair.
broker.go:1854
↓ 1 callersFunctionmaxValHistogramValidator
(name string, maxMax int)
metrics_helpers_functional_test.go:46
↓ 1 callersMethodmaybeTransitionToErrorState
(err error)
async_producer.go:1688
↓ 1 callersFunctionminCountHistogramValidator
(name string, minCount int)
metrics_helpers_functional_test.go:26
↓ 1 callersFunctionminMaxHistogramValidator
lint:ignore U1000 // this is used but only in unittests which are excluded by the integration build tag
metrics_helpers_test.go:95
↓ 1 callersFunctionminValHistogramValidator
(name string, minMin int)
metrics_helpers_functional_test.go:36
↓ 1 callersMethodmovePartition
(partition topicPartitionAssignment, oldConsumer, newConsumer string)
balance_strategy.go:1022
↓ 1 callersMethodnegotiateApiVersion
negotiateApiVersion clamps pb's version to the broker's advertised maximum for pb's API (treating pb's current version as the client max). When the br
broker.go:1242
↓ 1 callersFunctionnewAccessLogProducer
(brokerList []string, version sarama.KafkaVersion)
examples/http_server/http_server.go:223
↓ 1 callersMethodnewAuthenticatorChecksum
()
gssapi_kerberos.go:100
↓ 1 callersMethodnewBrokerConsumer
(broker *Broker)
consumer.go:1059
↓ 1 callersMethodnewBrokerProducer
one per broker; also constructs an associated flusher
async_producer.go:982
↓ 1 callersFunctionnewBufConn
(conn net.Conn)
utils.go:105
↓ 1 callersMethodnewClaimWithRetry
newClaimWithRetry calls newConsumerGroupClaim, retrying transient errors so that brief leader/metadata desync around a rebalance doesn't leave a parti
consumer_group_session.go:187
↓ 1 callersFunctionnewConsumerGroupClaim
(sess *consumerGroupSession, topic string, partition int32, offset int64)
consumer_group_session.go:457
↓ 1 callersFunctionnewConsumerGroupSession
(ctx context.Context, parent *consumerGroup, claims map[string][]int32, memberID string, generationID int32, h
consumer_group_session.go:71
↓ 1 callersFunctionnewDataCollector
(brokerList []string, version sarama.KafkaVersion)
examples/http_server/http_server.go:195
← previousnext →1,101–1,200 of 3,668, ranked by callers