(addr net.Addr, keys []string, cb func(*Item))
| 380 | } |
| 381 | |
| 382 | func (c *Client) getFromAddr(addr net.Addr, keys []string, cb func(*Item)) error { |
| 383 | return c.withAddrRw(addr, func(conn *conn) error { |
| 384 | rw := conn.rw |
| 385 | if _, err := fmt.Fprintf(rw, "gets %s\r\n", strings.Join(keys, " ")); err != nil { |
| 386 | return err |
| 387 | } |
| 388 | if err := rw.Flush(); err != nil { |
| 389 | return err |
| 390 | } |
| 391 | if err := parseGetResponse(rw.Reader, conn, cb); err != nil { |
| 392 | return err |
| 393 | } |
| 394 | return nil |
| 395 | }) |
| 396 | } |
| 397 | |
| 398 | // flushAllFromAddr send the flush_all command to the given addr |
| 399 | func (c *Client) flushAllFromAddr(addr net.Addr) error { |
no test coverage detected