Versions in this module Expand all Collapse all v0 v0.1.0 Nov 28, 2019 Changes in this version + const IdleTimeout + const ReadTimeout + const StopTimeout + const WriteTimeout + var ControllerSendChanBufferSize = 1000 + type AfterConnectHook func(*config.ClusterRegistry) + type AfterConnectToHook func() + type AfterDisconnectHook func() + type ClientCloseHandleFunc func(*config.ClusterRegistry) + type CloudBlackList struct + func (c *CloudBlackList) Clear() + func (c *CloudBlackList) Find(key string) bool + func (c *CloudBlackList) Pop() string + func (c *CloudBlackList) Push(addr string) + type CloudTunnel interface + Broadcast func(msg []byte) + RegistAfterConnectHook func(fn AfterConnectHook) + RegistCheckNameValidFunc func(fn ClusterNameChecker) + RegistClientCloseHandler func(fn ClientCloseHandleFunc) + RegistControllerManagerMsgHandler func(fn ControllerManagerMsgHandleFunc) + RegistRedirectFunc func(fn RedirectFunc) + RegistReturnMessageFunc func(fn TunnelReadMessageFunc) + Send func(clusterName string, msg []byte) error + SendToControllerManager func([]byte) error + Start func() error + Stop func() error + func NewCloudTunnel(address string) CloudTunnel + type ClusterNameChecker func(*config.ClusterRegistry) bool + type ControllerManagerMsgHandleFunc func(string, []byte) error + type ControllerTunnel interface + RegistAfterConnectToHook func(fn AfterConnectToHook) + RegistReceiveMessageHandler func(TunnelReadMessageFunc) + Send func(msg []byte) error + SendChan func() chan clustermessage.ClusterMessage + Start func() error + Stop func() error + func NewControllerTunnel(remoteAddr string) ControllerTunnel + type EdgeTunnel interface + RegistAfterConnectToHook func(fn AfterConnectToHook) + RegistAfterDisconnectHook func(fn AfterDisconnectHook) + RegistReceiveMessageHandler func(TunnelReadMessageFunc) + Send func(msg []byte) error + Start func() error + Stop func() error + func NewEdgeTunnel(conf *config.ClusterControllerConfig) EdgeTunnel + type RedirectFunc func() string + type TunnelReadMessageFunc func(string, []byte) error + type WSClient struct + Conn *websocket.Conn + Name string + func NewWSClient(name string, conn *websocket.Conn) *WSClient + func (c *WSClient) Close() error + func (c *WSClient) ReadMessage() ([]byte, error) + func (c *WSClient) WriteMessage(msg []byte) error