( ctx context.Context, req types.RequestQuery, )
| 346 | } |
| 347 | |
| 348 | func (cli *socketClient) QuerySync( |
| 349 | ctx context.Context, |
| 350 | req types.RequestQuery, |
| 351 | ) (*types.ResponseQuery, error) { |
| 352 | reqres, err := cli.queueRequestAndFlushSync(ctx, types.ToRequestQuery(req)) |
| 353 | if err != nil { |
| 354 | return nil, err |
| 355 | } |
| 356 | return reqres.Response.GetQuery(), nil |
| 357 | } |
| 358 | |
| 359 | func (cli *socketClient) CommitSync(ctx context.Context) (*types.ResponseCommit, error) { |
| 360 | reqres, err := cli.queueRequestAndFlushSync(ctx, types.ToRequestCommit()) |
nothing calls this directly
no test coverage detected