mux

Documentation

Index

• Constants
• func NewMuxBridge() services.Service
• func NewMuxClient() services.Service
• func NewMuxServer() services.Service
• func NewMuxServerManager() services.Service
• 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()
• 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) UDPConnDeamon()
• 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 MuxUDPItem

Constants

const (
	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 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
}

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()

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
}

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) UDPConnDeamon

func (s *MuxServer) UDPConnDeamon()

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
}

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 MuxUDPItem

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