1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
|
//go:build !functional
package sarama
import "testing"
var (
responseHeaderBytesV0 = []byte{
0x00, 0x00, 0x0f, 0x00,
0x0a, 0xbb, 0xcc, 0xff,
}
responseHeaderBytesV1 = []byte{
0x00, 0x00, 0x0f, 0x00,
0x0a, 0xbb, 0xcc, 0xff, 0x00,
}
)
func TestResponseHeaderV0(t *testing.T) {
header := responseHeader{}
testVersionDecodable(t, "response header", &header, responseHeaderBytesV0, 0)
if header.length != 0xf00 {
t.Error("Decoding header length failed, got", header.length)
}
if header.correlationID != 0x0abbccff {
t.Error("Decoding header correlation id failed, got", header.correlationID)
}
}
func TestResponseHeaderV1(t *testing.T) {
header := responseHeader{}
testVersionDecodable(t, "response header", &header, responseHeaderBytesV1, 1)
if header.length != 0xf00 {
t.Error("Decoding header length failed, got", header.length)
}
if header.correlationID != 0x0abbccff {
t.Error("Decoding header correlation id failed, got", header.correlationID)
}
}
|
