See Client interface for documentation.
()
| 494 | |
| 495 | // See Client interface for documentation. |
| 496 | func (c *ShardedClient) Version() VersionResponse { |
| 497 | shardConns := c.manager.GetAllShards() |
| 498 | |
| 499 | var err error |
| 500 | versions := make(map[int]string) |
| 501 | for shard, conn := range shardConns { |
| 502 | response := c.versionHelper(shard, conn) |
| 503 | if response.Error() != nil { |
| 504 | if err == nil { |
| 505 | err = response.Error() |
| 506 | } else { |
| 507 | err = errors.Wrap(response.Error(), err.Error()) |
| 508 | } |
| 509 | continue |
| 510 | } |
| 511 | |
| 512 | for shardId, versionString := range response.Versions() { |
| 513 | versions[shardId] = versionString |
| 514 | } |
| 515 | } |
| 516 | |
| 517 | if err != nil { |
| 518 | return NewVersionErrorResponse(err, versions) |
| 519 | } |
| 520 | |
| 521 | return NewVersionResponse(StatusNoError, versions) |
| 522 | } |
| 523 | |
| 524 | func (c *ShardedClient) verbosityHelper( |
| 525 | shard int, |
nothing calls this directly
no test coverage detected