(t *testing.T, srv *util.KvrocksServer)
| 47 | } |
| 48 | |
| 49 | func createInteractiveCli(t *testing.T, srv *util.KvrocksServer) *interactiveCli { |
| 50 | c := exec.Command(util.CLIPath()) |
| 51 | c.Args = append(c.Args, "-h", srv.Host(), "-p", fmt.Sprintf("%d", srv.Port())) |
| 52 | w, err := c.StdinPipe() |
| 53 | require.NoError(t, err) |
| 54 | r, err := c.StdoutPipe() |
| 55 | require.NoError(t, err) |
| 56 | require.NoError(t, c.Start()) |
| 57 | return &interactiveCli{ |
| 58 | c: c, |
| 59 | r: bufio.NewReader(r), |
| 60 | w: bufio.NewWriter(w), |
| 61 | } |
| 62 | } |
| 63 | |
| 64 | func (c *interactiveCli) Close() error { |
| 65 | if err := c.c.Process.Signal(syscall.SIGTERM); err != nil { |
no test coverage detected