Home
last modified time | relevance | path

Searched refs:ConsumerErrors (Results 1 – 25 of 33) sorted by relevance

12

/dports/databases/tile38/tile38-1.12.0/vendor/github.com/Shopify/sarama/
H A Dconsumer.go36 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 Dconsumer.go34 type ConsumerErrors []*ConsumerError type
36 func (ce ConsumerErrors) Error() string {
397 var errors ConsumerErrors
H A Doffset_manager.go370 var errors ConsumerErrors
/dports/www/fabio/fabio-1.5.14/vendor/github.com/Shopify/sarama/sarama-1.19.0/
H A Dconsumer.go37 type ConsumerErrors []*ConsumerError type
39 func (ce ConsumerErrors) Error() string {
430 var errors ConsumerErrors
H A Doffset_manager.go543 var errors ConsumerErrors
/dports/www/fabio/fabio-1.5.14/vendor/github.com/Shopify/sarama/
H A Dconsumer.go37 type ConsumerErrors []*ConsumerError type
39 func (ce ConsumerErrors) Error() string {
430 var errors ConsumerErrors
H A Doffset_manager.go543 var errors ConsumerErrors
/dports/net-im/dendrite/dendrite-0.5.1/vendor/github.com/Shopify/sarama/
H A Dconsumer.go45 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 Dconsumer.go41 type ConsumerErrors []*ConsumerError type
43 func (ce ConsumerErrors) Error() string {
425 var errors ConsumerErrors
H A Doffset_manager.go555 var errors ConsumerErrors
/dports/net/goreplay/goreplay-1.2.0/vendor/github.com/Shopify/sarama/
H A Dconsumer.go41 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 Dkafka.go642 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 Dkafka.go622 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 Dkafka.go622 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 Dkafka.go622 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 Dconsumer.go218 var errs = make(sarama.ConsumerErrors, 0)
/dports/net/goreplay/goreplay-1.2.0/vendor/github.com/Shopify/sarama/mocks/
H A Dconsumer.go234 var errs = make(sarama.ConsumerErrors, 0)
/dports/net-im/dendrite/dendrite-0.5.1/vendor/github.com/Shopify/sarama/mocks/
H A Dconsumer.go234 errs := make(sarama.ConsumerErrors, 0)
H A Dconsumer_test.go86 errs := pc.Close().(sarama.ConsumerErrors)
/dports/databases/tile38/tile38-1.12.0/vendor/github.com/Shopify/sarama/mocks/
H A Dconsumer.go234 var errs = make(sarama.ConsumerErrors, 0)
H A Dconsumer_test.go86 errs := pc.Close().(sarama.ConsumerErrors)
/dports/www/fabio/fabio-1.5.14/vendor/github.com/Shopify/sarama/sarama-1.19.0/mocks/
H A Dconsumer.go234 var errs = make(sarama.ConsumerErrors, 0)
H A Dconsumer_test.go86 errs := pc.Close().(sarama.ConsumerErrors)
/dports/net/goreplay/goreplay-1.2.0/vendor/github.com/Shopify/sarama/sarama-1.26.4/mocks/
H A Dconsumer.go234 var errs = make(sarama.ConsumerErrors, 0)
H A Dconsumer_test.go86 errs := pc.Close().(sarama.ConsumerErrors)

12