MCPcopy
hub / github.com/segmentio/kafka-go / TestEndTxnResponse

Function TestEndTxnResponse

protocol/endtxn/endtxn_test.go:21–28  ·  view source on GitHub ↗
(t *testing.T)

Source from the content-addressed store, hash-verified

19}
20
21func TestEndTxnResponse(t *testing.T) {
22 for _, version := range []int16{0, 1, 2, 3} {
23 prototest.TestResponse(t, version, &endtxn.Response{
24 ThrottleTimeMs: 1000,
25 ErrorCode: 4,
26 })
27 }
28}

Callers

nothing calls this directly

Calls 1

TestResponseFunction · 0.92

Tested by

no test coverage detected