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

Function TestDeleteTopicsResponse

protocol/deletetopics/deletetopics_test.go:33–74  ·  view source on GitHub ↗
(t *testing.T)

Source from the content-addressed store, hash-verified

31}
32
33func TestDeleteTopicsResponse(t *testing.T) {
34 prototest.TestResponse(t, v0, &deletetopics.Response{
35 Responses: []deletetopics.ResponseTopic{
36 {
37 Name: "foo",
38 ErrorCode: 1,
39 },
40 {
41 Name: "bar",
42 ErrorCode: 1,
43 },
44 },
45 })
46
47 prototest.TestResponse(t, v1, &deletetopics.Response{
48 ThrottleTimeMs: 500,
49 Responses: []deletetopics.ResponseTopic{
50 {
51 Name: "foo",
52 ErrorCode: 1,
53 },
54 {
55 Name: "bar",
56 ErrorCode: 1,
57 },
58 },
59 })
60
61 prototest.TestResponse(t, v3, &deletetopics.Response{
62 ThrottleTimeMs: 500,
63 Responses: []deletetopics.ResponseTopic{
64 {
65 Name: "foo",
66 ErrorCode: 1,
67 },
68 {
69 Name: "bar",
70 ErrorCode: 1,
71 },
72 },
73 })
74}

Callers

nothing calls this directly

Calls 1

TestResponseFunction · 0.92

Tested by

no test coverage detected