stream

package

v0.8.0-dev.4 Latest Latest Go to latest Published: Sep 1, 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 Message
type MultiplexedStream
- func NewMultiplexedStream(ctx context.Context, reader io.Reader, closer io.Closer, writer io.Writer, ...) *MultiplexedStream
type Type
- func (s Type) IsValid() bool
- func (s Type) Name() string

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Message ¶

type Message struct {
	StreamType Type
	Content    []byte
}

type MultiplexedStream ¶

type MultiplexedStream struct {
	// 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) Close ¶

func (m *MultiplexedStream) Close() error

func (*MultiplexedStream) Done ¶

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

func (*MultiplexedStream) Messages ¶

func (m *MultiplexedStream) Messages() chan Message

func (*MultiplexedStream) Write ¶

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

type Type ¶

type Type int

const (
	TypeStdin       Type = 0
	TypeStdout      Type = 1
	TypeStderr      Type = 2
	TypeSystemError Type = 3
)

func (Type) IsValid ¶

func (s Type) IsValid() bool

func (Type) Name ¶

func (s Type) Name() string

Source Files ¶

View all Source files

multiplex.go

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