mux

Documentation

Index

• Constants
• func NewMuxBridge() services.Service
• func NewMuxClient() services.Service
• func NewMuxServer() services.Service
• func NewMuxServerManager() services.Service
• type ClientUDPConnItem
• type MuxBridge
  • func (s *MuxBridge) CheckArgs() (err error)
  • func (s *MuxBridge) Clean()
  • func (s *MuxBridge) InitService() (err error)
  • func (s *MuxBridge) Start(args interface{}, log *logger.Logger) (err error)
  • func (s *MuxBridge) StopService()
• type MuxBridgeArgs
• type MuxClient
  • func (s *MuxClient) CheckArgs() (err error)
  • func (s *MuxClient) Clean()
  • func (s *MuxClient) InitService() (err error)
  • func (s *MuxClient) ServeConn(inConn *smux.Stream, localAddr, ID string)
  • func (s *MuxClient) ServeUDP(inConn *smux.Stream, localAddr, ID string)
  • func (s *MuxClient) Start(args interface{}, log *logger.Logger) (err error)
  • func (s *MuxClient) StopService()
  • func (s *MuxClient) UDPGCDeamon()
  • func (s *MuxClient) UDPRevecive(key, ID string)
• type MuxClientArgs
• type MuxServer
  • func (s *MuxServer) CheckArgs() (err error)
  • func (s *MuxServer) Clean()
  • func (s *MuxServer) GetConn(index string) (conn net.Conn, err error)
  • func (s *MuxServer) GetOutConn() (outConn net.Conn, ID string, err error)
  • func (s *MuxServer) InitService() (err error)
  • func (s *MuxServer) Start(args interface{}, log *logger.Logger) (err error)
  • func (s *MuxServer) StopService()
  • func (s *MuxServer) UDPGCDeamon()
  • func (s *MuxServer) UDPRevecive(key, ID string)
  • func (s *MuxServer) UDPSend(data []byte, localAddr, srcAddr *net.UDPAddr)
• type MuxServerArgs
• type MuxServerManager
  • func (s *MuxServerManager) CheckArgs() (err error)
  • func (s *MuxServerManager) Clean()
  • func (s *MuxServerManager) InitService() (err error)
  • func (s *MuxServerManager) Start(args interface{}, log *logger.Logger) (err error)
  • func (s *MuxServerManager) StopService()
• type MuxUDPConnItem

Constants

const (
	CONN_CLIENT_CONTROL = uint8(1)
	CONN_SERVER         = uint8(4)
	CONN_CLIENT         = uint8(5)
)

Functions

func NewMuxBridge

func NewMuxBridge() services.Service

func NewMuxClient

func NewMuxClient() services.Service

func NewMuxServer

func NewMuxServer() services.Service

func NewMuxServerManager

func NewMuxServerManager() services.Service

Types

type ClientUDPConnItem

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

type MuxBridge

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

func (*MuxBridge) CheckArgs

func (s *MuxBridge) CheckArgs() (err error)

func (*MuxBridge) Clean

func (s *MuxBridge) Clean()

func (*MuxBridge) InitService

func (s *MuxBridge) InitService() (err error)

func (*MuxBridge) Start

func (s *MuxBridge) Start(args interface{}, log *logger.Logger) (err error)

func (*MuxBridge) StopService

func (s *MuxBridge) StopService()

type MuxBridgeArgs

type MuxBridgeArgs struct {
	CertFile     *string
	KeyFile      *string
	CertBytes    []byte
	KeyBytes     []byte
	Local        *string
	LocalType    *string
	Timeout      *int
	IsCompress   *bool
	KCP          kcpcfg.KCPConfigArgs
	TCPSMethod   *string
	TCPSPassword *string
	TOUMethod    *string
	TOUPassword  *string
}

type MuxClient

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

func (*MuxClient) CheckArgs

func (s *MuxClient) CheckArgs() (err error)

func (*MuxClient) Clean

func (s *MuxClient) Clean()

func (*MuxClient) InitService

func (s *MuxClient) InitService() (err error)

func (*MuxClient) ServeConn

func (s *MuxClient) ServeConn(inConn *smux.Stream, localAddr, ID string)

func (*MuxClient) ServeUDP

func (s *MuxClient) ServeUDP(inConn *smux.Stream, localAddr, ID string)

func (*MuxClient) Start

func (s *MuxClient) Start(args interface{}, log *logger.Logger) (err error)

func (*MuxClient) StopService

func (s *MuxClient) StopService()

func (*MuxClient) UDPGCDeamon

func (s *MuxClient) UDPGCDeamon()

func (*MuxClient) UDPRevecive

func (s *MuxClient) UDPRevecive(key, ID string)

type MuxClientArgs

type MuxClientArgs struct {
	Parent       *string
	ParentType   *string
	CertFile     *string
	KeyFile      *string
	CertBytes    []byte
	KeyBytes     []byte
	Key          *string
	Timeout      *int
	IsCompress   *bool
	SessionCount *int
	KCP          kcpcfg.KCPConfigArgs
	Jumper       *string
	TCPSMethod   *string
	TCPSPassword *string
	TOUMethod    *string
	TOUPassword  *string
}

type MuxServer

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

func (*MuxServer) CheckArgs

func (s *MuxServer) CheckArgs() (err error)

func (*MuxServer) Clean

func (s *MuxServer) Clean()

func (*MuxServer) GetConn

func (s *MuxServer) GetConn(index string) (conn net.Conn, err error)

func (*MuxServer) GetOutConn

func (s *MuxServer) GetOutConn() (outConn net.Conn, ID string, err error)

func (*MuxServer) InitService

func (s *MuxServer) InitService() (err error)

func (*MuxServer) Start

func (s *MuxServer) Start(args interface{}, log *logger.Logger) (err error)

func (*MuxServer) StopService

func (s *MuxServer) StopService()

func (*MuxServer) UDPGCDeamon

func (s *MuxServer) UDPGCDeamon()

func (*MuxServer) UDPRevecive

func (s *MuxServer) UDPRevecive(key, ID string)

func (*MuxServer) UDPSend

func (s *MuxServer) UDPSend(data []byte, localAddr, srcAddr *net.UDPAddr)

type MuxServerArgs

type MuxServerArgs struct {
	Parent       *string
	ParentType   *string
	CertFile     *string
	KeyFile      *string
	CertBytes    []byte
	KeyBytes     []byte
	Local        *string
	IsUDP        *bool
	Key          *string
	Remote       *string
	Timeout      *int
	Route        *[]string
	Mgr          *MuxServerManager
	IsCompress   *bool
	SessionCount *int
	KCP          kcpcfg.KCPConfigArgs
	Jumper       *string
	TCPSMethod   *string
	TCPSPassword *string
	TOUMethod    *string
	TOUPassword  *string
}

type MuxServerManager

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

func (*MuxServerManager) CheckArgs

func (s *MuxServerManager) CheckArgs() (err error)

func (*MuxServerManager) Clean

func (s *MuxServerManager) Clean()

func (*MuxServerManager) InitService

func (s *MuxServerManager) InitService() (err error)

func (*MuxServerManager) Start

func (s *MuxServerManager) Start(args interface{}, log *logger.Logger) (err error)

func (*MuxServerManager) StopService

func (s *MuxServerManager) StopService()

type MuxUDPConnItem

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