socket

Documentation

Index

• func TcpRelay(ws *websocket.Conn, rq *TcpRelayParam) error
• type PlainData
  • func (d *PlainData) GetPayload(v any) error
• type TcpRelayParam
• type WsConn
  • func NewWsClient(u, p, o string) (*WsConn, error)
  • func (pod *WsConn) Close() error
  • func (pod *WsConn) Die(r string)
  • func (pod *WsConn) Read(v []byte) error
  • func (pod *WsConn) ReadJson(v any) error
  • func (pod *WsConn) Write(p []byte) error
  • func (pod *WsConn) WriteJson(v any) error

Functions

func TcpRelay

func TcpRelay(ws *websocket.Conn, rq *TcpRelayParam) error

Types

type PlainData

type PlainData struct {
	Method  string
	TaskId  uint
	Success bool
	Message string
	Payload any
}

func (*PlainData) GetPayload

func (d *PlainData) GetPayload(v any) error

type TcpRelayParam

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

type WsConn

type WsConn struct {
	*websocket.Conn
}

func NewWsClient

func NewWsClient(u, p, o string) (*WsConn, error)

func (*WsConn) Close

func (pod *WsConn) Close() error

func (*WsConn) Die

func (pod *WsConn) Die(r string)

func (*WsConn) Read

func (pod *WsConn) Read(v []byte) error

func (*WsConn) ReadJson

func (pod *WsConn) ReadJson(v any) error

func (*WsConn) Write

func (pod *WsConn) Write(p []byte) error

func (*WsConn) WriteJson

func (pod *WsConn) WriteJson(v any) error