edge

Documentation

Index

• Variables
• func RunWsServer(addr string, clientManager *ClientManager, wsConfig *Config, clientID string, ...) error
• func RunWsServerTLS(addr, certFile, keyFile string, clientManager *ClientManager, wsConfig *Config, ...) error
• type CallBackMsgInfo
• type CallBackReceiveMsgInfo
• type CallBackResp
• type Client
  • func (c *Client) Close()
  • func (c *Client) RmCallBackMsgInfo(msgID string) (bool, error)
  • func (c *Client) Run()
  • func (c *Client) SendMessage(message []byte) error
  • func (c *Client) SendMessageAdnReply(message []byte, timeout time.Duration) ([]byte, error)
• type ClientManager
• type Config
  • func NewDefaultConfig() *Config
  • func (c *Config) SetLogger(logger log.Interface)
  • func (c *Config) SetMaxMessageSize(i int)
  • func (c *Config) SetMaxRetry(i int)
  • func (c *Config) SetMessageTimeout(t time.Duration)
  • func (c *Config) SetPingPeriod(t time.Duration)
  • func (c *Config) SetPongWait(t time.Duration)
  • func (c *Config) SetWriteWait(t time.Duration)
• type NormalMsgInfo
• type TcpKeepAliveListener
  • func (ln TcpKeepAliveListener) Accept() (net.Conn, error)
• type WebsocketServer
  • func NewWebsocketServer(clientManager *ClientManager) *WebsocketServer
  • func (s *WebsocketServer) AddLister(listener net.Listener)
  • func (s *WebsocketServer) Close()
  • func (s *WebsocketServer) ListenAndServe(addr string, clientID string, receiveHandler func(message []byte) error, ...) error
  • func (s *WebsocketServer) ListenAndServeTLS(addr, certFile, keyFile, clientID string, ...) error
• type WsMessageInterface

Variables

var (
	CallBackMessageType = "CallBackType"
	NormalMessageType   = "NormalType"
)

Functions

func RunWsServer

func RunWsServer(addr string, clientManager *ClientManager,
	wsConfig *Config, clientID string,
	receiveHandler func(message []byte) error,
	receiveCallbackHandler func(message []byte) ([]byte, error)) error

func RunWsServerTLS

func RunWsServerTLS(addr, certFile, keyFile string, clientManager *ClientManager,
	wsConfig *Config, clientID string,
	receiveHandler func(message []byte) error,
	receiveCallbackHandler func(message []byte) ([]byte, error)) error

Types

type CallBackMsgInfo

type CallBackMsgInfo struct {
	ID   string `json:"id"`
	Data string `json:"data"`
	//ClientID   string `json:"client_id"`
	RetryCount int `json:"-"`
	// contains filtered or unexported fields
}

type CallBackReceiveMsgInfo

type CallBackReceiveMsgInfo struct {
	RespBody []byte `json:"resp_body"`
	Error    error  `json:"error"`
	ID       string `json:"id"`
}

type CallBackResp

type CallBackResp struct {
	RespBody []byte `json:"resp_body"`
	Error    error  `json:"error"`
}

type Client

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

func (*Client) Close

func (c *Client) Close()

func (*Client) RmCallBackMsgInfo

func (c *Client) RmCallBackMsgInfo(msgID string) (bool, error)

func (*Client) Run

func (c *Client) Run()

func (*Client) SendMessage

func (c *Client) SendMessage(message []byte) error

func (*Client) SendMessageAdnReply

func (c *Client) SendMessageAdnReply(message []byte, timeout time.Duration) ([]byte, error)

type ClientManager

type ClientManager struct {
	sync.Mutex

	WsCli    *Client
	Usable   bool
	WsServer *WebsocketServer
}

type Config

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

func NewDefaultConfig

func NewDefaultConfig() *Config

func (*Config) SetLogger

func (c *Config) SetLogger(logger log.Interface)

func (*Config) SetMaxMessageSize

func (c *Config) SetMaxMessageSize(i int)

func (*Config) SetMaxRetry

func (c *Config) SetMaxRetry(i int)

func (*Config) SetMessageTimeout

func (c *Config) SetMessageTimeout(t time.Duration)

func (*Config) SetPingPeriod

func (c *Config) SetPingPeriod(t time.Duration)

func (*Config) SetPongWait

func (c *Config) SetPongWait(t time.Duration)

func (*Config) SetWriteWait

func (c *Config) SetWriteWait(t time.Duration)

type NormalMsgInfo

type NormalMsgInfo struct {
	ID   string `json:"id"`
	Data string `json:"data"`
}

type TcpKeepAliveListener

type TcpKeepAliveListener struct {
	*net.TCPListener
}

func (TcpKeepAliveListener) Accept

func (ln TcpKeepAliveListener) Accept() (net.Conn, error)

type WebsocketServer

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

func NewWebsocketServer

func NewWebsocketServer(clientManager *ClientManager) *WebsocketServer

func (*WebsocketServer) AddLister

func (s *WebsocketServer) AddLister(listener net.Listener)

func (*WebsocketServer) Close

func (s *WebsocketServer) Close()

func (*WebsocketServer) ListenAndServe

func (s *WebsocketServer) ListenAndServe(addr string, clientID string,
	receiveHandler func(message []byte) error,
	receiveCallbackHandler func(message []byte) ([]byte, error)) error

func (*WebsocketServer) ListenAndServeTLS

func (s *WebsocketServer) ListenAndServeTLS(addr, certFile, keyFile, clientID string,
	receiveHandler func(message []byte) error,
	receiveCallbackHandler func(message []byte) ([]byte, error)) error

type WsMessageInterface

type WsMessageInterface struct {
	Type string `json:"type"`
	Body []byte `json:"body"`
}