AllSucceededAggregator returns one non-error reply if every shard succeeded, propagates the first error otherwise.
| 89 | // AllSucceededAggregator returns one non-error reply if every shard succeeded, |
| 90 | // propagates the first error otherwise. |
| 91 | type AllSucceededAggregator struct { |
| 92 | err atomic.Value |
| 93 | res atomic.Value |
| 94 | } |
| 95 | |
| 96 | func (a *AllSucceededAggregator) Add(result interface{}, err error) error { |
| 97 | if err != nil { |
nothing calls this directly
no outgoing calls
no test coverage detected