[VOL-5486] Upgrade library versions
Change-Id: I8b4e88699e03f44ee13e467867f45ae3f0a63c4b
Signed-off-by: Abhay Kumar <abhay.kumar@radisys.com>
diff --git a/vendor/github.com/IBM/sarama/elect_leaders_request.go b/vendor/github.com/IBM/sarama/elect_leaders_request.go
new file mode 100644
index 0000000..01b9dd5
--- /dev/null
+++ b/vendor/github.com/IBM/sarama/elect_leaders_request.go
@@ -0,0 +1,125 @@
+package sarama
+
+type ElectLeadersRequest struct {
+ Version int16
+ Type ElectionType
+ TopicPartitions map[string][]int32
+ TimeoutMs int32
+}
+
+func (r *ElectLeadersRequest) setVersion(v int16) {
+ r.Version = v
+}
+
+func (r *ElectLeadersRequest) encode(pe packetEncoder) error {
+ if r.Version > 0 {
+ pe.putInt8(int8(r.Type))
+ }
+
+ if err := pe.putArrayLength(len(r.TopicPartitions)); err != nil {
+ return err
+ }
+
+ for topic, partitions := range r.TopicPartitions {
+ if err := pe.putString(topic); err != nil {
+ return err
+ }
+
+ if err := pe.putInt32Array(partitions); err != nil {
+ return err
+ }
+
+ pe.putEmptyTaggedFieldArray()
+ }
+
+ pe.putInt32(r.TimeoutMs)
+
+ pe.putEmptyTaggedFieldArray()
+ return nil
+}
+
+func (r *ElectLeadersRequest) decode(pd packetDecoder, version int16) (err error) {
+ r.Version = version
+ if r.Version > 0 {
+ t, err := pd.getInt8()
+ if err != nil {
+ return err
+ }
+ r.Type = ElectionType(t)
+ }
+
+ topicCount, err := pd.getArrayLength()
+ if err != nil {
+ return err
+ }
+ if topicCount > 0 {
+ r.TopicPartitions = make(map[string][]int32)
+ for i := 0; i < topicCount; i++ {
+ topic, err := pd.getString()
+ if err != nil {
+ return err
+ }
+ partitionCount, err := pd.getArrayLength()
+ if err != nil {
+ return err
+ }
+ partitions := make([]int32, partitionCount)
+ for j := 0; j < partitionCount; j++ {
+ partition, err := pd.getInt32()
+ if err != nil {
+ return err
+ }
+ partitions[j] = partition
+ }
+ r.TopicPartitions[topic] = partitions
+ if _, err := pd.getEmptyTaggedFieldArray(); err != nil {
+ return err
+ }
+ }
+ }
+
+ r.TimeoutMs, err = pd.getInt32()
+ if err != nil {
+ return err
+ }
+
+ _, err = pd.getEmptyTaggedFieldArray()
+ return err
+}
+
+func (r *ElectLeadersRequest) key() int16 {
+ return apiKeyElectLeaders
+}
+
+func (r *ElectLeadersRequest) version() int16 {
+ return r.Version
+}
+
+func (r *ElectLeadersRequest) headerVersion() int16 {
+ return 2
+}
+
+func (r *ElectLeadersRequest) isValidVersion() bool {
+ return r.Version >= 0 && r.Version <= 2
+}
+
+func (r *ElectLeadersRequest) isFlexible() bool {
+ return r.isFlexibleVersion(r.Version)
+}
+
+func (r *ElectLeadersRequest) isFlexibleVersion(version int16) bool {
+ return version >= 2
+}
+
+func (r *ElectLeadersRequest) requiredVersion() KafkaVersion {
+ switch r.Version {
+ case 2:
+ return V2_4_0_0
+ case 1:
+ return V0_11_0_0
+ case 0:
+ return V0_10_0_0
+ default:
+ return V2_4_0_0
+ }
+}