stream

package

v0.7.0-dev.19 Latest Latest Go to latest Published: Aug 8, 2025 License: Apache-2.0 Imports: 7 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/silenium-dev/docker-wrapper

Links

Open Source Insights

Documentation ¶

Index ¶

type MultiplexedStream
- func NewMultiplexedStream(ctx context.Context, reader io.Reader, closer io.Closer, writer io.Writer, ...) *MultiplexedStream
type StreamType
- func (s StreamType) IsValid() bool
- func (s StreamType) Name() string

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type MultiplexedStream ¶

type MultiplexedStream struct {
	io.Closer
	// contains filtered or unexported fields
}

func NewMultiplexedStream ¶

func NewMultiplexedStream(
	ctx context.Context,
	reader io.Reader,
	closer io.Closer,
	writer io.Writer,
	multiplex bool,
	logger *zap.SugaredLogger,
) *MultiplexedStream

func (*MultiplexedStream) Done ¶

func (m *MultiplexedStream) Done() <-chan struct{}

func (*MultiplexedStream) Stderr ¶

func (m *MultiplexedStream) Stderr() <-chan []byte

func (*MultiplexedStream) Stdout ¶

func (m *MultiplexedStream) Stdout() <-chan []byte

func (*MultiplexedStream) SystemError ¶

func (m *MultiplexedStream) SystemError() <-chan []byte

func (*MultiplexedStream) Write ¶

func (m *MultiplexedStream) Write(data []byte) (int, error)

type StreamType ¶

type StreamType int

const (
	StreamTypeStdin       StreamType = 0
	StreamTypeStdout      StreamType = 1
	StreamTypeStderr      StreamType = 2
	StreamTypeSystemError StreamType = 3
)

func (StreamType) IsValid ¶

func (s StreamType) IsValid() bool

func (StreamType) Name ¶

func (s StreamType) Name() string

Source Files ¶

View all Source files

multiplex.go

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL