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

Method RefreshMetadata

client.go:83–83  ·  view source on GitHub ↗

RefreshMetadata takes a list of topics and queries the cluster to refresh the available metadata for those topics. If no topics are provided, it will refresh metadata for all topics.

(topics ...string)

Source from the content-addressed store, hash-verified

81 // available metadata for those topics. If no topics are provided, it will refresh
82 // metadata for all topics.
83 RefreshMetadata(topics ...string) error
84
85 // GetOffset queries the cluster to get the most recent available offset at the
86 // given time (in milliseconds) on the topic/partition combination.

Callers 15

testTxnProduceAndCommitOffsetFunction · 0.95
prepareDockerTestEnvironmentFunction · 0.95
TestClientReceivingUnknownTopicWithBackoffFuncFunction · 0.95
TestClientReceivingUnknownTopicFunction · 0.95
TestClientReceivingPartialMetadataFunction · 0.95
TestClientRefreshBehaviourWhenEmptyMetadataResponseFunction · 0.95
TestClientRefreshMetadataBrokerOfflineFunction · 0.95
TestClientGetBrokerFunction · 0.95
TestClientMetadataTimeoutFunction · 0.95
TestClientRefreshMetadataLeaderlessFunction · 0.95
TestClientUpdateMetadataErrorAndRetryFunction · 0.95
TestClientRefreshesMetadataConcurrentlyFunction · 0.95

Implementers 2

stubLeaderClientasync_producer_test.go
clientclient.go

Calls

no outgoing calls

Tested by 15

testTxnProduceAndCommitOffsetFunction · 0.76
prepareDockerTestEnvironmentFunction · 0.76
TestClientReceivingUnknownTopicWithBackoffFuncFunction · 0.76
TestClientReceivingUnknownTopicFunction · 0.76
TestClientReceivingPartialMetadataFunction · 0.76
TestClientRefreshBehaviourWhenEmptyMetadataResponseFunction · 0.76
TestClientRefreshMetadataBrokerOfflineFunction · 0.76
TestClientGetBrokerFunction · 0.76
TestClientMetadataTimeoutFunction · 0.76
TestClientRefreshMetadataLeaderlessFunction · 0.76
TestClientUpdateMetadataErrorAndRetryFunction · 0.76
TestClientRefreshesMetadataConcurrentlyFunction · 0.76