( shard int, conn net2.ManagedConn, expiration uint32)
| 400 | } |
| 401 | |
| 402 | func (c *ShardedClient) flushHelper( |
| 403 | shard int, |
| 404 | conn net2.ManagedConn, |
| 405 | expiration uint32) Response { |
| 406 | |
| 407 | if conn == nil { |
| 408 | return NewErrorResponse(c.connectionError(shard, nil)) |
| 409 | } |
| 410 | client := c.builder(shard, conn) |
| 411 | defer c.release(client, conn) |
| 412 | |
| 413 | return client.Flush(expiration) |
| 414 | } |
| 415 | |
| 416 | // See Client interface for documentation. |
| 417 | func (c *ShardedClient) Flush(expiration uint32) Response { |
no test coverage detected