commit | 8487c5da136ee6f3c3acbad25681bd6b51238fad | [log] [tgz] |
---|---|---|
author | Scott Baker <smbaker@gmail.com> | Fri Oct 18 12:49:46 2019 -0700 |
committer | Scott Baker <smbaker@gmail.com> | Fri Oct 18 13:28:20 2019 -0700 |
tree | ba32f95038ff5a31598fb972c2d58d08d20cf6d4 | |
parent | 5620c670c6fce4df3dc06a6a1ffceb3c3472fc9e [diff] [blame] |
VOL-2112 move to voltha-lib-go Change-Id: I3435b8acb982deeab6b6ac28e798d7722ad01d0a
diff --git a/vendor/github.com/Shopify/sarama/create_partitions_response.go b/vendor/github.com/Shopify/sarama/create_partitions_response.go index abd621c..bb18204 100644 --- a/vendor/github.com/Shopify/sarama/create_partitions_response.go +++ b/vendor/github.com/Shopify/sarama/create_partitions_response.go
@@ -1,6 +1,9 @@ package sarama -import "time" +import ( + "fmt" + "time" +) type CreatePartitionsResponse struct { ThrottleTime time.Duration @@ -69,6 +72,14 @@ ErrMsg *string } +func (t *TopicPartitionError) Error() string { + text := t.Err.Error() + if t.ErrMsg != nil { + text = fmt.Sprintf("%s - %s", text, *t.ErrMsg) + } + return text +} + func (t *TopicPartitionError) encode(pe packetEncoder) error { pe.putInt16(int16(t.Err))