/dports/databases/tile38/tile38-1.12.0/vendor/github.com/Shopify/sarama/ |
H A D | consumer.go | 36 type ConsumerErrors []*ConsumerError type 38 func (ce ConsumerErrors) Error() string { 426 var errors ConsumerErrors
|
/dports/net-mgmt/bosun/bosun-0.9.0-preview/vendor/github.com/google/cadvisor/Godeps/_workspace/src/github.com/Shopify/sarama/ |
H A D | consumer.go | 34 type ConsumerErrors []*ConsumerError type 36 func (ce ConsumerErrors) Error() string { 397 var errors ConsumerErrors
|
H A D | offset_manager.go | 370 var errors ConsumerErrors
|
/dports/www/fabio/fabio-1.5.14/vendor/github.com/Shopify/sarama/sarama-1.19.0/ |
H A D | consumer.go | 37 type ConsumerErrors []*ConsumerError type 39 func (ce ConsumerErrors) Error() string { 430 var errors ConsumerErrors
|
H A D | offset_manager.go | 543 var errors ConsumerErrors
|
/dports/www/fabio/fabio-1.5.14/vendor/github.com/Shopify/sarama/ |
H A D | consumer.go | 37 type ConsumerErrors []*ConsumerError type 39 func (ce ConsumerErrors) Error() string { 430 var errors ConsumerErrors
|
H A D | offset_manager.go | 543 var errors ConsumerErrors
|
/dports/net-im/dendrite/dendrite-0.5.1/vendor/github.com/Shopify/sarama/ |
H A D | consumer.go | 45 type ConsumerErrors []*ConsumerError type 47 func (ce ConsumerErrors) Error() string { 442 var consumerErrors ConsumerErrors
|
/dports/net/goreplay/goreplay-1.2.0/vendor/github.com/Shopify/sarama/sarama-1.26.4/ |
H A D | consumer.go | 41 type ConsumerErrors []*ConsumerError type 43 func (ce ConsumerErrors) Error() string { 425 var errors ConsumerErrors
|
H A D | offset_manager.go | 555 var errors ConsumerErrors
|
/dports/net/goreplay/goreplay-1.2.0/vendor/github.com/Shopify/sarama/ |
H A D | consumer.go | 41 type ConsumerErrors []*ConsumerError type 43 func (ce ConsumerErrors) Error() string { 425 var errors ConsumerErrors
|
/dports/www/gitlab-workhorse/gitlab-foss-0a901d60f8ae4a60c04ae82e6e9c3a03e9321417/workhorse/vendor/gocloud.dev/pubsub/kafkapubsub/ |
H A D | kafka.go | 642 case sarama.ConsumerErrors: 643 if p, ok := i.(*sarama.ConsumerErrors); ok {
|
/dports/www/gohugo/hugo-0.91.2/vendor/gocloud.dev/pubsub/kafkapubsub/ |
H A D | kafka.go | 622 case sarama.ConsumerErrors: 623 if p, ok := i.(*sarama.ConsumerErrors); ok {
|
/dports/sysutils/gomplate/gomplate-3.9.0/vendor/gocloud.dev/pubsub/kafkapubsub/ |
H A D | kafka.go | 622 case sarama.ConsumerErrors: 623 if p, ok := i.(*sarama.ConsumerErrors); ok {
|
/dports/devel/gitlab-runner/gitlab-runner-8925d9a06fd8e452e2161a768462652a2a13111f/vendor/gocloud.dev/go-cloud-5094f54ed8bb/pubsub/kafkapubsub/ |
H A D | kafka.go | 622 case sarama.ConsumerErrors: 623 if p, ok := i.(*sarama.ConsumerErrors); ok {
|
/dports/net-mgmt/bosun/bosun-0.9.0-preview/vendor/github.com/google/cadvisor/Godeps/_workspace/src/github.com/Shopify/sarama/mocks/ |
H A D | consumer.go | 218 var errs = make(sarama.ConsumerErrors, 0)
|
/dports/net/goreplay/goreplay-1.2.0/vendor/github.com/Shopify/sarama/mocks/ |
H A D | consumer.go | 234 var errs = make(sarama.ConsumerErrors, 0)
|
/dports/net-im/dendrite/dendrite-0.5.1/vendor/github.com/Shopify/sarama/mocks/ |
H A D | consumer.go | 234 errs := make(sarama.ConsumerErrors, 0)
|
H A D | consumer_test.go | 86 errs := pc.Close().(sarama.ConsumerErrors)
|
/dports/databases/tile38/tile38-1.12.0/vendor/github.com/Shopify/sarama/mocks/ |
H A D | consumer.go | 234 var errs = make(sarama.ConsumerErrors, 0)
|
H A D | consumer_test.go | 86 errs := pc.Close().(sarama.ConsumerErrors)
|
/dports/www/fabio/fabio-1.5.14/vendor/github.com/Shopify/sarama/sarama-1.19.0/mocks/ |
H A D | consumer.go | 234 var errs = make(sarama.ConsumerErrors, 0)
|
H A D | consumer_test.go | 86 errs := pc.Close().(sarama.ConsumerErrors)
|
/dports/net/goreplay/goreplay-1.2.0/vendor/github.com/Shopify/sarama/sarama-1.26.4/mocks/ |
H A D | consumer.go | 234 var errs = make(sarama.ConsumerErrors, 0)
|
H A D | consumer_test.go | 86 errs := pc.Close().(sarama.ConsumerErrors)
|