MCPcopy
hub / github.com/IBM/sarama / TestHeartbeatResponse

Function TestHeartbeatResponse

heartbeat_response_test.go:34–99  ·  view source on GitHub ↗
(t *testing.T)

Source from the content-addressed store, hash-verified

32)
33
34func TestHeartbeatResponse(t *testing.T) {
35 tests := []struct {
36 CaseName string
37 Version int16
38 MessageBytes []byte
39 Message *HeartbeatResponse
40 }{
41 {
42 "v0_noErr",
43 0,
44 heartbeatResponseNoError_V0,
45 &HeartbeatResponse{
46 Version: 0,
47 Err: ErrNoError,
48 },
49 },
50 {
51 "v1_noErr",
52 1,
53 heartbeatResponseNoError_V1,
54 &HeartbeatResponse{
55 Version: 1,
56 Err: ErrNoError,
57 ThrottleTime: 100,
58 },
59 },
60 {
61 "v1_Err",
62 1,
63 heartbeatResponseError_V1,
64 &HeartbeatResponse{
65 Version: 1,
66 Err: ErrFencedInstancedId,
67 ThrottleTime: 100,
68 },
69 },
70 {
71 "v4_noErr",
72 4,
73 heartbeatResponseNoError_V4,
74 &HeartbeatResponse{
75 Version: 4,
76 Err: ErrNoError,
77 ThrottleTime: 100,
78 },
79 },
80 {
81 "v4_Err",
82 4,
83 heartbeatResponseError_V4,
84 &HeartbeatResponse{
85 Version: 4,
86 Err: ErrFencedInstancedId,
87 ThrottleTime: 100,
88 },
89 },
90 }
91 for _, c := range tests {

Callers

nothing calls this directly

Calls 3

testEncodableFunction · 0.85
testVersionDecodableFunction · 0.85
ErrorfMethod · 0.65

Tested by

no test coverage detected