stream

package
v0.7.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Aug 9, 2025 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Index

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 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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.