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

Method WritablePartitions

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

WritablePartitions returns the sorted list of all writable partition IDs for the given topic, where "writable" means "having a valid leader accepting writes".

(topic string)

Source from the content-addressed store, hash-verified

51 // the given topic, where "writable" means "having a valid leader accepting
52 // writes".
53 WritablePartitions(topic string) ([]int32, error)
54
55 // Leader returns the broker object that is the leader of the current
56 // topic/partition, as determined by querying the cluster metadata.

Callers 3

TestClientMetadataFunction · 0.95
partitionMessageMethod · 0.65

Implementers 2

stubLeaderClientasync_producer_test.go
clientclient.go

Calls

no outgoing calls

Tested by 2

TestClientMetadataFunction · 0.76