| /dports/databases/tile38/tile38-1.12.0/vendor/github.com/streadway/amqp/_examples/simple-consumer/ |
| H A D | consumer.go | 57 func NewConsumer(amqpURI, exchange, exchangeType, queueName, key, ctag string) (*Consumer, error) { func
|
| /dports/www/gitlab-workhorse/gitlab-foss-0a901d60f8ae4a60c04ae82e6e9c3a03e9321417/workhorse/vendor/gopkg.in/DataDog/dd-trace-go.v1/contrib/confluentinc/confluent-kafka-go/kafka/ |
| H A D | kafka.go | 22 func NewConsumer(conf *kafka.ConfigMap, opts ...Option) (*Consumer, error) { func
|
| /dports/devel/gitlab-shell/gitlab-shell-65b8ec55bebd0aea64ac52b9878bafcc2ad992d3/vendor/gopkg.in/DataDog/dd-trace-go.v1/contrib/confluentinc/confluent-kafka-go/kafka/ |
| H A D | kafka.go | 22 func NewConsumer(conf *kafka.ConfigMap, opts ...Option) (*Consumer, error) { func
|
| /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 | 24 func NewConsumer(t ErrorReporter, config *sarama.Config) *Consumer { func
|
| /dports/net/goreplay/goreplay-1.2.0/vendor/github.com/Shopify/sarama/mocks/ |
| H A D | consumer.go | 24 func NewConsumer(t ErrorReporter, config *sarama.Config) *Consumer { func
|
| /dports/net-im/dendrite/dendrite-0.5.1/vendor/github.com/Shopify/sarama/mocks/ |
| H A D | consumer.go | 24 func NewConsumer(t ErrorReporter, config *sarama.Config) *Consumer { func
|
| /dports/databases/tile38/tile38-1.12.0/vendor/github.com/Shopify/sarama/mocks/ |
| H A D | consumer.go | 24 func NewConsumer(t ErrorReporter, config *sarama.Config) *Consumer { func
|
| /dports/sysutils/doctl/doctl-1.68.0/vendor/github.com/natefinch/pie/ |
| H A D | pie.go | 126 func NewConsumer() *rpc.Client { func
|
| /dports/www/fabio/fabio-1.5.14/vendor/github.com/Shopify/sarama/sarama-1.19.0/mocks/ |
| H A D | consumer.go | 24 func NewConsumer(t ErrorReporter, config *sarama.Config) *Consumer { func
|
| /dports/net/goreplay/goreplay-1.2.0/vendor/github.com/Shopify/sarama/sarama-1.26.4/mocks/ |
| H A D | consumer.go | 24 func NewConsumer(t ErrorReporter, config *sarama.Config) *Consumer { func
|
| /dports/databases/tile38/tile38-1.12.0/vendor/github.com/Shopify/sarama/ |
| H A D | consumer.go | 87 func NewConsumer(addrs []string, config *Config) (Consumer, error) { func
|
| /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 | 80 func NewConsumer(addrs []string, config *Config) (Consumer, error) { func
|
| /dports/www/fabio/fabio-1.5.14/vendor/github.com/Shopify/sarama/sarama-1.19.0/ |
| H A D | consumer.go | 88 func NewConsumer(addrs []string, config *Config) (Consumer, error) { func
|
| /dports/www/fabio/fabio-1.5.14/vendor/github.com/Shopify/sarama/ |
| H A D | consumer.go | 88 func NewConsumer(addrs []string, config *Config) (Consumer, error) { func
|
| /dports/net/goreplay/goreplay-1.2.0/vendor/github.com/Shopify/sarama/sarama-1.26.4/ |
| H A D | consumer.go | 84 func NewConsumer(addrs []string, config *Config) (Consumer, error) { func
|
| /dports/net/goreplay/goreplay-1.2.0/vendor/github.com/Shopify/sarama/ |
| H A D | consumer.go | 84 func NewConsumer(addrs []string, config *Config) (Consumer, error) { func
|
| /dports/net-im/dendrite/dendrite-0.5.1/vendor/github.com/Shopify/sarama/ |
| H A D | consumer.go | 88 func NewConsumer(addrs []string, config *Config) (Consumer, error) { func
|
| /dports/net/nsq/nsq-1.2.1/vendor/github.com/nsqio/go-nsq/ |
| H A D | consumer.go | 147 func NewConsumer(topic string, channel string, config *Config) (*Consumer, error) { func
|
| /dports/www/gitea/gitea-1.16.5/vendor/github.com/mrjones/oauth/ |
| H A D | oauth.go | 242 func NewConsumer(consumerKey string, consumerSecret string, func
|