newMockBroker spins up a MockBroker with auto-cleanup.
(t *testing.T, id int32)
| 2127 | |
| 2128 | // newMockBroker spins up a MockBroker with auto-cleanup. |
| 2129 | func newMockBroker(t *testing.T, id int32) *MockBroker { |
| 2130 | t.Helper() |
| 2131 | b := NewMockBroker(t, id) |
| 2132 | t.Cleanup(func() { b.Close() }) |
| 2133 | return b |
| 2134 | } |
| 2135 | |
| 2136 | // newTestAdmin builds a V2.1 ClusterAdmin against the given seed broker with |
| 2137 | // retry backoff disabled and auto-cleanup. |
no test coverage detected