pipe

Documentation

Index

• type Pipe
  • func NewPipe(conn *websocket.Conn, marshal util.Marshaler, session *models.Session, ...) *Pipe
  • func (p *Pipe) HandleAliveDetection(isStop <-chan int)
  • func (p *Pipe) HandleRequest(execID string, sessionWriter io.WriteCloser, g *global.Global)
  • func (p *Pipe) HandleResponse(respType message.ResponseMessage_ResponseType, sessionReader io.ReadCloser, ...)
• type SessionReplay
  • func NewSessionReplay(s models.Session) (*SessionReplay, error)
  • func (s *SessionReplay) Close() error

Types

type Pipe

type Pipe struct {
	// contains filtered or unexported fields
}

Pipe is a full duplex channel between the docker container and the terminal

func NewPipe

func NewPipe(conn *websocket.Conn, marshal util.Marshaler, session *models.Session, unMarshal util.Unmarshaler, wg *sync.WaitGroup, writeLock *sync.Mutex) *Pipe

NewPipe return an initialized *Pipe

func (*Pipe) HandleAliveDetection

func (p *Pipe) HandleAliveDetection(isStop <-chan int)

HandleAliveDetection handle alive detection for the websocket

func (*Pipe) HandleRequest

func (p *Pipe) HandleRequest(execID string, sessionWriter io.WriteCloser, g *global.Global)

HandleRequest handle request from the client

func (*Pipe) HandleResponse

func (p *Pipe) HandleResponse(respType message.ResponseMessage_ResponseType, sessionReader io.ReadCloser, sessionReplay *SessionReplay)

HandleResponse handle response from the container

type SessionReplay

type SessionReplay struct {
	// contains filtered or unexported fields
}

SessionReplay is for session replay

func NewSessionReplay

func NewSessionReplay(s models.Session) (*SessionReplay, error)

NewSessionReplay return an initialized *SessionReplay

func (*SessionReplay) Close

func (s *SessionReplay) Close() error

Close close the underlying files