websocket

Documentation

Index

• func CloseLog(t *tail.Tail)
• func Handler(apiOp *types.APIRequest) (types.APIObjectList, error)
• func KubeHandler(apiOp *types.APIRequest) (types.APIObject, error)
• func LogHandler(apiOp *types.APIRequest) (types.APIObjectList, error)
• func NewTailLog(logFilePath string) (*tail.Tail, error)
• func WriteLastLogs(t *tail.Tail, w http.ResponseWriter, f http.Flusher, logFilePath string) error
• type BinaryReader
  • func NewReader(con *websocket.Conn) *BinaryReader
  • func (s *BinaryReader) Read(p []byte) (int, error)
• type BinaryWriter
  • func NewWriter(con *websocket.Conn) *BinaryWriter
  • func (s *BinaryWriter) Write(p []byte) (int, error)

Functions

func CloseLog

func CloseLog(t *tail.Tail)

func Handler

func Handler(apiOp *types.APIRequest) (types.APIObjectList, error)

func KubeHandler

func KubeHandler(apiOp *types.APIRequest) (types.APIObject, error)

func LogHandler

func LogHandler(apiOp *types.APIRequest) (types.APIObjectList, error)

func NewTailLog

func NewTailLog(logFilePath string) (*tail.Tail, error)

func WriteLastLogs

func WriteLastLogs(t *tail.Tail, w http.ResponseWriter, f http.Flusher, logFilePath string) error

Types

type BinaryReader

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

func NewReader

func NewReader(con *websocket.Conn) *BinaryReader

func (*BinaryReader) Read

func (s *BinaryReader) Read(p []byte) (int, error)

type BinaryWriter

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

func NewWriter

func NewWriter(con *websocket.Conn) *BinaryWriter

func (*BinaryWriter) Write

func (s *BinaryWriter) Write(p []byte) (int, error)