io

package

v0.10.0 Latest Latest Go to latest Published: Jul 7, 2016 License: Apache-2.0 Imports: 5 Imported by: 1

Details

This section is empty.

View Source

var EOF = io.EOF

func CircuitHeaderGenerator(data []byte) ([]byte, error)

func CircuitHeaderParser(reader io.Reader) (uint32, bool, error)

func DockerStderrHeaderGenerator(data []byte) ([]byte, error)

func DockerStderrHeaderParser(reader io.Reader) (uint32, bool, error)

func DockerStdoutHeaderGenerator(data []byte) ([]byte, error)

func DockerStdoutHeaderParser(reader io.Reader) (uint32, bool, error)

func NewCircuitReader(reader io.Reader) io.Reader

func NewCircuitWriter(writer io.Writer) io.Writer

func NewDockerStderrReader(reader io.Reader) io.Reader

func NewDockerStderrWriter(writer io.Writer) io.Writer

func NewDockerStdoutReader(reader io.Reader) io.Reader

func NewDockerStdoutWriter(writer io.Writer) io.Writer

type HeaderGenerator func(data []byte) ([]byte, error)

type HeaderParser func(io.Reader) (uint32, bool, error)

HeaderParser is a function which reads headers and returns the data segment length.

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

HeaderReader reads packets with headers

func (hr HeaderReader) Read(p []byte) (int, error)

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

HeaderWriter prepends all writes with the output of a HeaderGenerator function.

func (hw HeaderWriter) Write(p []byte) (int, error)

Write is required by the io.Writer interface