123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109 |
- package sarama
- import "time"
- type MemberResponse struct {
- MemberId string
- GroupInstanceId *string
- Err KError
- }
- type LeaveGroupResponse struct {
- Version int16
- ThrottleTime int32
- Err KError
- Members []MemberResponse
- }
- func (r *LeaveGroupResponse) encode(pe packetEncoder) error {
- if r.Version >= 1 {
- pe.putInt32(r.ThrottleTime)
- }
- pe.putInt16(int16(r.Err))
- if r.Version >= 3 {
- if err := pe.putArrayLength(len(r.Members)); err != nil {
- return err
- }
- for _, member := range r.Members {
- if err := pe.putString(member.MemberId); err != nil {
- return err
- }
- if err := pe.putNullableString(member.GroupInstanceId); err != nil {
- return err
- }
- pe.putInt16(int16(member.Err))
- }
- }
- return nil
- }
- func (r *LeaveGroupResponse) decode(pd packetDecoder, version int16) (err error) {
- r.Version = version
- if r.Version >= 1 {
- if r.ThrottleTime, err = pd.getInt32(); err != nil {
- return err
- }
- }
- kerr, err := pd.getInt16()
- if err != nil {
- return err
- }
- r.Err = KError(kerr)
- if r.Version >= 3 {
- membersLen, err := pd.getArrayLength()
- if err != nil {
- return err
- }
- r.Members = make([]MemberResponse, membersLen)
- for i := 0; i < len(r.Members); i++ {
- if r.Members[i].MemberId, err = pd.getString(); err != nil {
- return err
- }
- if r.Members[i].GroupInstanceId, err = pd.getNullableString(); err != nil {
- return err
- }
- if memberErr, err := pd.getInt16(); err != nil {
- return err
- } else {
- r.Members[i].Err = KError(memberErr)
- }
- }
- }
- return nil
- }
- func (r *LeaveGroupResponse) key() int16 {
- return 13
- }
- func (r *LeaveGroupResponse) version() int16 {
- return r.Version
- }
- func (r *LeaveGroupResponse) headerVersion() int16 {
- return 0
- }
- func (r *LeaveGroupResponse) isValidVersion() bool {
- return r.Version >= 0 && r.Version <= 3
- }
- func (r *LeaveGroupResponse) requiredVersion() KafkaVersion {
- switch r.Version {
- case 3:
- return V2_4_0_0
- case 2:
- return V2_0_0_0
- case 1:
- return V0_11_0_0
- case 0:
- return V0_9_0_0
- default:
- return V2_4_0_0
- }
- }
- func (r *LeaveGroupResponse) throttleTime() time.Duration {
- return time.Duration(r.ThrottleTime) * time.Millisecond
- }
|