mirror of
https://github.com/hanzoai/traces.git
synced 2026-10-30 18:20:41 +00:00
* Update Prometheus to v0.307.2 * Update otel collector * Update OTel collector
130 lines
2.6 KiB
Go
130 lines
2.6 KiB
Go
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) setVersion(v int16) {
|
|
r.Version = v
|
|
}
|
|
|
|
func (r *LeaveGroupResponse) encode(pe packetEncoder) error {
|
|
if r.Version >= 1 {
|
|
pe.putInt32(r.ThrottleTime)
|
|
}
|
|
pe.putKError(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.putKError(member.Err)
|
|
pe.putEmptyTaggedFieldArray()
|
|
}
|
|
}
|
|
pe.putEmptyTaggedFieldArray()
|
|
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
|
|
}
|
|
}
|
|
r.Err, err = pd.getKError()
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
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 r.Members[i].Err, err = pd.getKError(); err != nil {
|
|
return err
|
|
}
|
|
if _, err := pd.getEmptyTaggedFieldArray(); err != nil {
|
|
return err
|
|
}
|
|
}
|
|
}
|
|
|
|
_, err = pd.getEmptyTaggedFieldArray()
|
|
return err
|
|
}
|
|
|
|
func (r *LeaveGroupResponse) key() int16 {
|
|
return apiKeyLeaveGroup
|
|
}
|
|
|
|
func (r *LeaveGroupResponse) version() int16 {
|
|
return r.Version
|
|
}
|
|
|
|
func (r *LeaveGroupResponse) headerVersion() int16 {
|
|
if r.Version >= 4 {
|
|
return 1
|
|
}
|
|
return 0
|
|
}
|
|
|
|
func (r *LeaveGroupResponse) isValidVersion() bool {
|
|
return r.Version >= 0 && r.Version <= 4
|
|
}
|
|
|
|
func (r *LeaveGroupResponse) isFlexible() bool {
|
|
return r.isFlexibleVersion(r.Version)
|
|
}
|
|
|
|
func (r *LeaveGroupResponse) isFlexibleVersion(version int16) bool {
|
|
return version >= 4
|
|
}
|
|
|
|
func (r *LeaveGroupResponse) requiredVersion() KafkaVersion {
|
|
switch r.Version {
|
|
case 4:
|
|
return V2_4_0_0
|
|
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
|
|
}
|