(req types.RequestQuery)
| 336 | } |
| 337 | |
| 338 | func (cli *socketClient) QuerySync(req types.RequestQuery) (*types.ResponseQuery, error) { |
| 339 | reqres := cli.queueRequest(types.ToRequestQuery(req)) |
| 340 | if err := cli.FlushSync(); err != nil { |
| 341 | return nil, err |
| 342 | } |
| 343 | |
| 344 | return reqres.Response.GetQuery(), cli.Error() |
| 345 | } |
| 346 | |
| 347 | func (cli *socketClient) CommitSync() (*types.ResponseCommit, error) { |
| 348 | reqres := cli.queueRequest(types.ToRequestCommit()) |
nothing calls this directly
no test coverage detected