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

Function TestDeleteTopicsRequest

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

Source from the content-addressed store, hash-verified

14)
15
16func TestDeleteTopicsRequest(t *testing.T) {
17 prototest.TestRequest(t, v0, &deletetopics.Request{
18 TopicNames: []string{"foo", "bar"},
19 TimeoutMs: 500,
20 })
21
22 prototest.TestRequest(t, v1, &deletetopics.Request{
23 TopicNames: []string{"foo", "bar"},
24 TimeoutMs: 500,
25 })
26
27 prototest.TestRequest(t, v3, &deletetopics.Request{
28 TopicNames: []string{"foo", "bar"},
29 TimeoutMs: 500,
30 })
31}
32
33func TestDeleteTopicsResponse(t *testing.T) {
34 prototest.TestResponse(t, v0, &deletetopics.Response{

Callers

nothing calls this directly

Calls 1

TestRequestFunction · 0.92

Tested by

no test coverage detected