aggregateKeyedValues aggregates individual key-value pairs while preserving key order
(cmd Cmder, keyedResults map[string]routing.AggregatorResErr, keyOrder []string, policy *routing.CommandPolicy)
| 403 | |
| 404 | // aggregateKeyedValues aggregates individual key-value pairs while preserving key order |
| 405 | func (c *ClusterClient) aggregateKeyedValues(cmd Cmder, keyedResults map[string]routing.AggregatorResErr, keyOrder []string, policy *routing.CommandPolicy) error { |
| 406 | if len(keyedResults) == 0 { |
| 407 | return errNoResToAggregate |
| 408 | } |
| 409 | |
| 410 | aggregator := c.createAggregator(policy, cmd, true) |
| 411 | |
| 412 | // Set key order for keyed aggregators |
| 413 | var keyedAgg *routing.DefaultKeyedAggregator |
| 414 | var isKeyedAgg bool |
| 415 | var err error |
| 416 | if keyedAgg, isKeyedAgg = aggregator.(*routing.DefaultKeyedAggregator); isKeyedAgg { |
| 417 | err = keyedAgg.BatchAddWithKeyOrder(keyedResults, keyOrder) |
| 418 | } else { |
| 419 | err = aggregator.BatchAdd(keyedResults) |
| 420 | } |
| 421 | |
| 422 | if err != nil { |
| 423 | return err |
| 424 | } |
| 425 | |
| 426 | return c.finishAggregation(cmd, aggregator) |
| 427 | } |
| 428 | |
| 429 | // aggregateResponses aggregates multiple shard responses |
| 430 | func (c *ClusterClient) aggregateResponses(cmd Cmder, cmds []Cmder, policy *routing.CommandPolicy) error { |
no test coverage detected