MCPcopy
hub / github.com/IBM/sarama / throttleTime

Method throttleTime

broker.go:1919–1919  ·  view source on GitHub ↗
()

Source from the content-addressed store, hash-verified

1917
1918type throttleSupport interface {
1919 throttleTime() time.Duration
1920}
1921
1922func (b *Broker) handleThrottledResponse(resp protocolBody) {

Callers 1

handleThrottledResponseMethod · 0.65

Implementers 15

InitProducerIDResponseinit_producer_id_response.go
DeleteAclsResponseacl_delete_response.go
OffsetFetchResponseoffset_fetch_response.go
FindCoordinatorResponsefind_coordinator_response.go
UpdateFeaturesResponseupdate_features_response.go
ApiVersionsResponseapi_versions_response.go
AddPartitionsToTxnResponseadd_partitions_to_txn_response.go
JoinGroupResponsejoin_group_response.go
AlterPartitionReassignmentsResponsealter_partition_reassignments_response
AlterUserScramCredentialsResponsealter_user_scram_credentials_response.
OffsetCommitResponseoffset_commit_response.go
EndTxnResponseend_txn_response.go

Calls

no outgoing calls

Tested by

no test coverage detected