mux

package
v0.0.0-...-1ef8d7c Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jun 29, 2018 License: GPL-3.0 Imports: 17 Imported by: 0

Documentation

Index

Constants

View Source
const (
	CONN_SERVER = uint8(4)
	CONN_CLIENT = uint8(5)
)

Variables

This section is empty.

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
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL