stream

Documentation

Index

• Variables
• type CommonStream
  • func (s *CommonStream) RestoreTerminal()
• type In
  • func NewIn(in io.ReadCloser) *In
  • func (i *In) Close() error
  • func (i *In) Read(p []byte) (int, error)
  • func (i *In) RestoreTerminal() error
  • func (i *In) SetRawTerminal() (err error)
• type Out
  • func NewOut(out io.Writer) *Out
  • func (o *Out) GetTtySize() (uint, uint)
  • func (o *Out) Write(p []byte) (int, error)
• type ResizeContainer
• type Streamer
  • func New() *Streamer
  • func (s *Streamer) SetRawTerminal() (func(), error)
  • func (s *Streamer) Stream(ctx context.Context, id string, resp types.HijackedResponse, ...) (err error)

Variables

var (
	ErrEmptyExecID   = errors.New("emtpy exec id")
	ErrTtySizeIsZero = errors.New("tty size is 0")
)

Types

type CommonStream

type CommonStream struct {
	State      *term.State
	IsTerminal bool
	Fd         uintptr
}

func (*CommonStream) RestoreTerminal

func (s *CommonStream) RestoreTerminal()

type In

type In struct {
	CommonStream
	// contains filtered or unexported fields
}

func NewIn

func NewIn(in io.ReadCloser) *In

func (*In) Close

func (i *In) Close() error

func (*In) Read

func (i *In) Read(p []byte) (int, error)

func (*In) RestoreTerminal

func (i *In) RestoreTerminal() error

func (*In) SetRawTerminal

func (i *In) SetRawTerminal() (err error)

type Out

type Out struct {
	CommonStream
	// contains filtered or unexported fields
}

func NewOut

func NewOut(out io.Writer) *Out

func (*Out) GetTtySize

func (o *Out) GetTtySize() (uint, uint)

func (*Out) Write

func (o *Out) Write(p []byte) (int, error)

type ResizeContainer

type ResizeContainer func(ctx context.Context, id string, options types.ResizeOptions) error

type Streamer

type Streamer struct {
	In  *In
	Out *Out
	Err io.Writer
	// contains filtered or unexported fields
}

func New

func New() *Streamer

func (*Streamer) SetRawTerminal

func (s *Streamer) SetRawTerminal() (func(), error)

func (*Streamer) Stream

func (s *Streamer) Stream(ctx context.Context, id string, resp types.HijackedResponse, resize ResizeContainer) (err error)