Searched refs:syncGroupRequest (Results 1 – 5 of 5) sorted by relevance
| /dports/www/fabio/fabio-1.5.14/vendor/github.com/Shopify/sarama/ |
| H A D | consumer_group.go | 230 sync, err := c.syncGroupRequest(coordinator, plan, join.GenerationId)
297 func (c *consumerGroup) syncGroupRequest(coordinator *Broker, plan BalanceStrategyPlan, generationI… func
|
| /dports/www/fabio/fabio-1.5.14/vendor/github.com/Shopify/sarama/sarama-1.19.0/ |
| H A D | consumer_group.go | 230 sync, err := c.syncGroupRequest(coordinator, plan, join.GenerationId)
297 func (c *consumerGroup) syncGroupRequest(coordinator *Broker, plan BalanceStrategyPlan, generationI… func
|
| /dports/net/goreplay/goreplay-1.2.0/vendor/github.com/Shopify/sarama/ |
| H A D | consumer_group.go | 258 sync, err := c.syncGroupRequest(coordinator, plan, join.GenerationId)
331 func (c *consumerGroup) syncGroupRequest(coordinator *Broker, plan BalanceStrategyPlan, generationI… func
|
| /dports/net/goreplay/goreplay-1.2.0/vendor/github.com/Shopify/sarama/sarama-1.26.4/ |
| H A D | consumer_group.go | 258 sync, err := c.syncGroupRequest(coordinator, plan, join.GenerationId)
331 func (c *consumerGroup) syncGroupRequest(coordinator *Broker, plan BalanceStrategyPlan, generationI… func
|
| /dports/net-im/dendrite/dendrite-0.5.1/vendor/github.com/Shopify/sarama/ |
| H A D | consumer_group.go | 258 groupRequest, err := c.syncGroupRequest(coordinator, plan, join.GenerationId)
331 func (c *consumerGroup) syncGroupRequest(coordinator *Broker, plan BalanceStrategyPlan, generationI… func
|