pipe

Documentation

Index

• type Relay
  • func NewPipeRelay(in io.ReadCloser, out io.WriteCloser) *Relay
  • func (rl *Relay) Close() error
  • func (rl *Relay) Receive(frame *frame.Frame) error
  • func (rl *Relay) Send(frame *frame.Frame) error

Types

type Relay

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

Relay ... PipeRelay communicate with underlying process using standard streams (STDIN, STDOUT). Attention, use TCP alternative for Windows as more reliable option. This relay closes automatically with the process.

func NewPipeRelay

func NewPipeRelay(in io.ReadCloser, out io.WriteCloser) *Relay

NewPipeRelay creates new pipe based data relay.

func (*Relay) Close

func (rl *Relay) Close() error

Close the connection. Pipes are closed automatically with the underlying process.

func (*Relay) Receive

func (rl *Relay) Receive(frame *frame.Frame) error

func (*Relay) Send

func (rl *Relay) Send(frame *frame.Frame) error

Send signed (prefixed) data to underlying process.