(t *testing.T)
| 278 | } |
| 279 | |
| 280 | func TestMetadataResponseWithBrokersV1(t *testing.T) { |
| 281 | response := MetadataResponse{} |
| 282 | |
| 283 | testVersionDecodable(t, "topics, V1", &response, brokersNoTopicsMetadataResponseV1, 1) |
| 284 | if len(response.Brokers) != 2 { |
| 285 | t.Error("Decoding produced", len(response.Brokers), "brokers where there were 2!") |
| 286 | } |
| 287 | if response.Brokers[0].rack == nil || *response.Brokers[0].rack != "rack0" { |
| 288 | t.Error("Decoding produced invalid broker 0 rack.") |
| 289 | } |
| 290 | if response.Brokers[1].rack == nil || *response.Brokers[1].rack != "rack1" { |
| 291 | t.Error("Decoding produced invalid broker 1 rack.") |
| 292 | } |
| 293 | if response.ControllerID != 1 { |
| 294 | t.Error("Decoding produced", response.ControllerID, "should have been 1!") |
| 295 | } |
| 296 | if len(response.Topics) != 0 { |
| 297 | t.Error("Decoding produced", len(response.Brokers), "brokers where there were none!") |
| 298 | } |
| 299 | } |
| 300 | |
| 301 | func TestMetadataResponseWithTopicsV1(t *testing.T) { |
| 302 | response := MetadataResponse{} |
nothing calls this directly
no test coverage detected