catp

package

v0.5.0 Latest Latest Go to latest Published: Nov 30, 2022 License: GPL-3.0 Imports: 3 Imported by: 0

Details

This section is empty.

This section is empty.

func Start(command []string, streamIn io.Reader, streamOut io.Writer, captureStderr io.Writer) error

Start create a catp chain and start it.

type Chain struct {
	// contains filtered or unexported fields
}

func New() Chain

New build a new catp chain.

func (c *Chain) Add(pipe Pipe)

func (c *Chain) Run(input io.Reader, output io.Writer) (result error)

type Pipe interface {
	Configure(input io.Reader, output io.Writer, doneHandler func(), errorHandler func(error)) io.Reader
	Start()
}

Pipe stream data from input to output.

type ProcessConfiguration struct {
	Command []string
	Stderr  io.Writer
}

ProcessConfiguration is the process execute by catp.

type ProcessPipe struct {
	SimplePipe
	ProcessConfiguration
}

func NewProcessPipe(configuration ProcessConfiguration) *ProcessPipe

func (p *ProcessPipe) Start()

type SimplePipe struct {
	// contains filtered or unexported fields
}

func (p *SimplePipe) Configure(
	input io.Reader, output io.Writer,
	doneHandler func(),
	errorHandler func(error)) io.Reader

func (p *SimplePipe) Start()

Start a goroutine to copy data from input to output.