(wb *writeBuffer)
| 237 | } |
| 238 | |
| 239 | func (r metadataResponseV6) writeTo(wb *writeBuffer) { |
| 240 | wb.writeInt32(r.ThrottleTimeMs) |
| 241 | wb.writeArray(len(r.Brokers), func(i int) { r.Brokers[i].writeTo(wb) }) |
| 242 | wb.writeString(r.ClusterId) |
| 243 | wb.writeInt32(r.ControllerID) |
| 244 | wb.writeArray(len(r.Topics), func(i int) { r.Topics[i].writeTo(wb) }) |
| 245 | } |
| 246 | |
| 247 | type topicMetadataV6 struct { |
| 248 | TopicErrorCode int16 |
nothing calls this directly
no test coverage detected