streams

Documentation

Index

• type IO
  • func (io *IO) Read(p []byte) (int, error)
  • func (io *IO) Write(p []byte) (n int, err error)
• type Log
  • func (w *Log) Write(p []byte) (n int, err error)
• type Stream
  • func (s *Stream) CloseWithError(err error) error

Types

type IO

type IO struct {
	Stream *Stream
}

IO implements an io.ReadWriter that forwards everything to the stream

func (*IO) Read

func (io *IO) Read(p []byte) (int, error)

func (*IO) Write

func (io *IO) Write(p []byte) (n int, err error)

type Log

type Log struct {
	Stream grpc.ServerStream
}

Log implements an io.Writer that proxies logs over a gRPC stream

func (*Log) Write

func (w *Log) Write(p []byte) (n int, err error)

type Stream

type Stream struct {
	streamsv1.Streaming_NewStreamServer

	ErrChan chan<- error
	// contains filtered or unexported fields
}

Stream is a bidirectional stream for container IO

func (*Stream) CloseWithError

func (s *Stream) CloseWithError(err error) error

CloseWithError sends the result of an action to the errChan or nil if no erros