Searched refs:brokerConsumers (Results 1 – 7 of 7) sorted by relevance
| /dports/databases/tile38/tile38-1.12.0/vendor/github.com/Shopify/sarama/ |
| H A D | consumer.go | 83 brokerConsumers map[*Broker]*brokerConsumer member
113 brokerConsumers: make(map[*Broker]*brokerConsumer),
216 bc := c.brokerConsumers[broker]
219 c.brokerConsumers[broker] = bc
235 if c.brokerConsumers[brokerWorker.broker] == brokerWorker {
236 delete(c.brokerConsumers, brokerWorker.broker)
245 delete(c.brokerConsumers, brokerWorker.broker)
|
| /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 | 76 brokerConsumers map[*Broker]*brokerConsumer member
106 brokerConsumers: make(map[*Broker]*brokerConsumer),
193 bc := c.brokerConsumers[broker]
196 c.brokerConsumers[broker] = bc
212 if c.brokerConsumers[brokerWorker.broker] == brokerWorker {
213 delete(c.brokerConsumers, brokerWorker.broker)
222 delete(c.brokerConsumers, brokerWorker.broker)
|
| /dports/www/fabio/fabio-1.5.14/vendor/github.com/Shopify/sarama/sarama-1.19.0/ |
| H A D | consumer.go | 84 brokerConsumers map[*Broker]*brokerConsumer member
114 brokerConsumers: make(map[*Broker]*brokerConsumer),
217 bc := c.brokerConsumers[broker]
220 c.brokerConsumers[broker] = bc
236 if c.brokerConsumers[brokerWorker.broker] == brokerWorker {
237 delete(c.brokerConsumers, brokerWorker.broker)
246 delete(c.brokerConsumers, brokerWorker.broker)
|
| /dports/www/fabio/fabio-1.5.14/vendor/github.com/Shopify/sarama/ |
| H A D | consumer.go | 84 brokerConsumers map[*Broker]*brokerConsumer member
114 brokerConsumers: make(map[*Broker]*brokerConsumer),
217 bc := c.brokerConsumers[broker]
220 c.brokerConsumers[broker] = bc
236 if c.brokerConsumers[brokerWorker.broker] == brokerWorker {
237 delete(c.brokerConsumers, brokerWorker.broker)
246 delete(c.brokerConsumers, brokerWorker.broker)
|
| /dports/net-im/dendrite/dendrite-0.5.1/vendor/github.com/Shopify/sarama/ |
| H A D | consumer.go | 82 brokerConsumers map[*Broker]*brokerConsumer member
115 brokerConsumers: make(map[*Broker]*brokerConsumer),
215 bc := c.brokerConsumers[broker]
218 c.brokerConsumers[broker] = bc
234 if c.brokerConsumers[brokerWorker.broker] == brokerWorker {
235 delete(c.brokerConsumers, brokerWorker.broker)
244 delete(c.brokerConsumers, brokerWorker.broker)
|
| /dports/net/goreplay/goreplay-1.2.0/vendor/github.com/Shopify/sarama/sarama-1.26.4/ |
| H A D | consumer.go | 78 brokerConsumers map[*Broker]*brokerConsumer member
111 brokerConsumers: make(map[*Broker]*brokerConsumer),
211 bc := c.brokerConsumers[broker]
214 c.brokerConsumers[broker] = bc
230 if c.brokerConsumers[brokerWorker.broker] == brokerWorker {
231 delete(c.brokerConsumers, brokerWorker.broker)
240 delete(c.brokerConsumers, brokerWorker.broker)
|
| /dports/net/goreplay/goreplay-1.2.0/vendor/github.com/Shopify/sarama/ |
| H A D | consumer.go | 78 brokerConsumers map[*Broker]*brokerConsumer member
111 brokerConsumers: make(map[*Broker]*brokerConsumer),
211 bc := c.brokerConsumers[broker]
214 c.brokerConsumers[broker] = bc
230 if c.brokerConsumers[brokerWorker.broker] == brokerWorker {
231 delete(c.brokerConsumers, brokerWorker.broker)
240 delete(c.brokerConsumers, brokerWorker.broker)
|