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

Function TestElectLeadersResponse

protocol/electleaders/electleaders_test.go:38–67  ·  view source on GitHub ↗
(t *testing.T)

Source from the content-addressed store, hash-verified

36}
37
38func TestElectLeadersResponse(t *testing.T) {
39 prototest.TestResponse(t, v0, &electleaders.Response{
40 ThrottleTime: 500,
41 ReplicaElectionResults: []electleaders.ResponseReplicaElectionResult{
42 {
43 Topic: "foo",
44 PartitionResults: []electleaders.ResponsePartitionResult{
45 {PartitionID: 100, ErrorCode: 0, ErrorMessage: ""},
46 {PartitionID: 101, ErrorCode: 0, ErrorMessage: ""},
47 {PartitionID: 102, ErrorCode: 0, ErrorMessage: ""},
48 },
49 },
50 },
51 })
52
53 prototest.TestResponse(t, v1, &electleaders.Response{
54 ThrottleTime: 500,
55 ErrorCode: 1,
56 ReplicaElectionResults: []electleaders.ResponseReplicaElectionResult{
57 {
58 Topic: "foo",
59 PartitionResults: []electleaders.ResponsePartitionResult{
60 {PartitionID: 100, ErrorCode: 0, ErrorMessage: ""},
61 {PartitionID: 101, ErrorCode: 0, ErrorMessage: ""},
62 {PartitionID: 102, ErrorCode: 0, ErrorMessage: ""},
63 },
64 },
65 },
66 })
67}

Callers

nothing calls this directly

Calls 1

TestResponseFunction · 0.92

Tested by

no test coverage detected