ws

Documentation

Index

• type PodLogSession
  • func NewPodLogSession(w http.ResponseWriter, r *http.Request) (*PodLogSession, error)
  • func (p *PodLogSession) Close() error
  • func (p *PodLogSession) Done() chan struct{}
  • func (p *PodLogSession) Read()
  • func (p *PodLogSession) SetReaderCloser(readCloser io.ReadCloser)
  • func (p *PodLogSession) Write() error
• type TerminalMessage
• type TerminalSession
  • func NewTerminalSession(w http.ResponseWriter, r *http.Request) (*TerminalSession, error)
  • func (t *TerminalSession) Close() error
  • func (t *TerminalSession) Done()
  • func (t *TerminalSession) Next() *remotecommand.TerminalSize
  • func (t *TerminalSession) Read(p []byte) (int, error)
  • func (t *TerminalSession) Write(p []byte) (int, error)

Types

type PodLogSession

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

func NewPodLogSession

func NewPodLogSession(w http.ResponseWriter, r *http.Request) (*PodLogSession, error)

func (*PodLogSession) Close

func (p *PodLogSession) Close() error

func (*PodLogSession) Done

func (p *PodLogSession) Done() chan struct{}

func (*PodLogSession) Read

func (p *PodLogSession) Read()

func (*PodLogSession) SetReaderCloser

func (p *PodLogSession) SetReaderCloser(readCloser io.ReadCloser)

func (*PodLogSession) Write

func (p *PodLogSession) Write() error

type TerminalMessage

type TerminalMessage struct {
	Operation string `json:"operation"`
	Data      string `json:"data"`
	Rows      uint16 `json:"rows"`
	Cols      uint16 `json:"cols"`
}

type TerminalSession

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

func NewTerminalSession

func NewTerminalSession(w http.ResponseWriter, r *http.Request) (*TerminalSession, error)

func (*TerminalSession) Close

func (t *TerminalSession) Close() error

func (*TerminalSession) Done

func (t *TerminalSession) Done()

func (*TerminalSession) Next

func (t *TerminalSession) Next() *remotecommand.TerminalSize

func (*TerminalSession) Read

func (t *TerminalSession) Read(p []byte) (int, error)

func (*TerminalSession) Write

func (t *TerminalSession) Write(p []byte) (int, error)