cubefs

1
package sarama
2

3
import (
4
	"time"
5
)
6

7
type EndTxnResponse struct {
8
	ThrottleTime time.Duration
9
	Err          KError
10
}
11

12
func (e *EndTxnResponse) encode(pe packetEncoder) error {
13
	pe.putInt32(int32(e.ThrottleTime / time.Millisecond))
14
	pe.putInt16(int16(e.Err))
15
	return nil
16
}
17

18
func (e *EndTxnResponse) decode(pd packetDecoder, version int16) (err error) {
19
	throttleTime, err := pd.getInt32()
20
	if err != nil {
21
		return err
22
	}
23
	e.ThrottleTime = time.Duration(throttleTime) * time.Millisecond
24

25
	kerr, err := pd.getInt16()
26
	if err != nil {
27
		return err
28
	}
29
	e.Err = KError(kerr)
30

31
	return nil
32
}
33

34
func (e *EndTxnResponse) key() int16 {
35
	return 25
36
}
37

38
func (e *EndTxnResponse) version() int16 {
39
	return 0
40
}
41

42
func (r *EndTxnResponse) headerVersion() int16 {
43
	return 0
44
}
45

46
func (e *EndTxnResponse) requiredVersion() KafkaVersion {
47
	return V0_11_0_0
48
}
49