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

Function partitionIDs

examples/alter_partition_reassignments/main.go:231–237  ·  view source on GitHub ↗
(assignment [][]int32)

Source from the content-addressed store, hash-verified

229}
230
231func partitionIDs(assignment [][]int32) []int32 {
232 ids := make([]int32, len(assignment))
233 for i := range assignment {
234 ids[i] = int32(i)
235 }
236 return ids
237}
238
239func formatAssignment(assignment [][]int32) string {
240 parts := make([]string, len(assignment))

Callers 1

mainFunction · 0.85

Calls

no outgoing calls

Tested by

no test coverage detected