cubefs

1
package sarama
2

3
import "time"
4

5
type DeleteTopicsRequest struct {
6
	Version int16
7
	Topics  []string
8
	Timeout time.Duration
9
}
10

11
func (d *DeleteTopicsRequest) encode(pe packetEncoder) error {
12
	if err := pe.putStringArray(d.Topics); err != nil {
13
		return err
14
	}
15
	pe.putInt32(int32(d.Timeout / time.Millisecond))
16

17
	return nil
18
}
19

20
func (d *DeleteTopicsRequest) decode(pd packetDecoder, version int16) (err error) {
21
	if d.Topics, err = pd.getStringArray(); err != nil {
22
		return err
23
	}
24
	timeout, err := pd.getInt32()
25
	if err != nil {
26
		return err
27
	}
28
	d.Timeout = time.Duration(timeout) * time.Millisecond
29
	d.Version = version
30
	return nil
31
}
32

33
func (d *DeleteTopicsRequest) key() int16 {
34
	return 20
35
}
36

37
func (d *DeleteTopicsRequest) version() int16 {
38
	return d.Version
39
}
40

41
func (d *DeleteTopicsRequest) headerVersion() int16 {
42
	return 1
43
}
44

45
func (d *DeleteTopicsRequest) requiredVersion() KafkaVersion {
46
	switch d.Version {
47
	case 1:
48
		return V0_11_0_0
49
	default:
50
		return V0_10_1_0
51
	}
52
}
53