zfscmd

Sep 18, 2024

Changes in this version

type Cmd

+ func (c *Cmd) Log() Logger

+ func (c *Cmd) PipeTo(cmds [][]string, stdout io.ReadCloser, stderr io.Writer) (io.ReadCloser, error)

+ func (c *Cmd) StartPipe() error

Aug 18, 2024

Changes in this version

type Cmd

+ func New(ctx context.Context) *Cmd

+ func (c *Cmd) PipeFrom(stdin io.ReadCloser, stdout, stderr io.Writer, cmds [][]string) error

+ func (c *Cmd) WithCommand(name string, args []string) *Cmd

+ func (c *Cmd) WithPipeLen(n int) *Cmd

May 8, 2024

Changes in this version

+ func GetJobIDOrDefault(ctx context.Context, def string) string

+ func RegisterMetrics(r prometheus.Registerer)

+ func WithJobID(ctx context.Context, jobID string) context.Context

+ type ActiveCommand struct

+ Args []string

+ Path string

+ StartedAt time.Time

+ type Cmd struct

+ func CommandContext(ctx context.Context, name string, arg ...string) *Cmd

+ func (c *Cmd) CombinedOutput() (o []byte, err error)

+ func (c *Cmd) LogError(err error, debug bool)

+ func (c *Cmd) Output() (o []byte, err error)

+ func (c *Cmd) Pipe(stdin io.ReadCloser, stderr io.Writer, cmds ...[]string) (io.ReadCloser, error)

+ func (c *Cmd) Process() *os.Process

+ func (c *Cmd) Runtime() time.Duration

+ func (c *Cmd) SetStdio(stdio Stdio)

+ func (c *Cmd) Start() (err error)

+ func (c *Cmd) StdoutPipeWithErrorBuf() (p io.ReadCloser, errBuf *circlog.CircularLog, err error)

+ func (c *Cmd) String() string

+ func (c *Cmd) TestOnly_ExecCmd() *exec.Cmd

+ func (c *Cmd) Wait() (err error)

+ func (c *Cmd) WaitPipe() error

+ func (c *Cmd) WithLeftPipe() *Cmd

+ func (c *Cmd) WithLogError(v bool) *Cmd

+ type Logger = logger.Logger

+ type Report struct

+ Active []ActiveCommand

+ func GetReport() *Report

+ type Stdio struct

+ Stderr io.Writer

+ Stdin io.ReadCloser

+ Stdout io.Writer