cubefs
36 строк · 601.0 Байт
1package sarama
2
3type HeartbeatResponse struct {
4Err KError
5}
6
7func (r *HeartbeatResponse) encode(pe packetEncoder) error {
8pe.putInt16(int16(r.Err))
9return nil
10}
11
12func (r *HeartbeatResponse) decode(pd packetDecoder, version int16) error {
13kerr, err := pd.getInt16()
14if err != nil {
15return err
16}
17r.Err = KError(kerr)
18
19return nil
20}
21
22func (r *HeartbeatResponse) key() int16 {
23return 12
24}
25
26func (r *HeartbeatResponse) version() int16 {
27return 0
28}
29
30func (r *HeartbeatResponse) headerVersion() int16 {
31return 0
32}
33
34func (r *HeartbeatResponse) requiredVersion() KafkaVersion {
35return V0_9_0_0
36}
37