(t *testing.T)
| 252 | } |
| 253 | |
| 254 | func testWriterSetsRightBalancer(t *testing.T) { |
| 255 | const topic = "test-writer-1" |
| 256 | balancer := &CRC32Balancer{} |
| 257 | w := newTestWriter(WriterConfig{ |
| 258 | Topic: topic, |
| 259 | Balancer: balancer, |
| 260 | }) |
| 261 | defer w.Close() |
| 262 | |
| 263 | if w.Balancer != balancer { |
| 264 | t.Errorf("Balancer not set correctly") |
| 265 | } |
| 266 | } |
| 267 | |
| 268 | func testWriterRoundRobin1(t *testing.T) { |
| 269 | const topic = "test-writer-1" |
nothing calls this directly
no test coverage detected