See Client interface for documentation.
()
| 758 | |
| 759 | // See Client interface for documentation. |
| 760 | func (c *RawBinaryClient) Version() VersionResponse { |
| 761 | versions := make(map[int]string) |
| 762 | |
| 763 | c.mutex.Lock() |
| 764 | defer c.mutex.Unlock() |
| 765 | |
| 766 | err := c.sendRequest(opVersion, 0, nil, nil) |
| 767 | if err != nil { |
| 768 | return NewVersionErrorResponse(err, versions) |
| 769 | } |
| 770 | |
| 771 | status, _, _, value, err := c.receiveResponse(opVersion) |
| 772 | if err != nil { |
| 773 | return NewVersionErrorResponse(err, versions) |
| 774 | } |
| 775 | |
| 776 | versions[c.ShardId()] = string(value) |
| 777 | return NewVersionResponse(status, versions) |
| 778 | } |
| 779 | |
| 780 | func (c *RawBinaryClient) genericOp( |
| 781 | code opCode, |
nothing calls this directly
no test coverage detected