connector

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

type CheckOriginHFunc func(r *http.Request) bool

type Connector struct {
	CRChan       chan *ChanMsgPack
	CWChan       chan []byte
	CRRoutineCan context.CancelFunc
	CWRoutineCan context.CancelFunc
	LinkerClient linker.ILinker
	// contains filtered or unexported fields
}

type IConnection interface {
	SendMessage(data []byte)
	Run()
	Done()
	// for  read  or   write msg
	WriteMsg(ctx context.Context)
	ReadMsg(ctx context.Context)
	GetConnectionCid() string
	GetConnection() interface{}
	SetBindId(bindId string)
	GetBindId() string
}

type IConnector interface {
	Run() error
	Done()
	AddRouterRearEndHandler(serverType string, handler RouteRearEndHFunc)
	// set checkOrigin 跨域 func
	SetCheckOriginHandler(handler CheckOriginHFunc)
	// set verify Connect func
	SetVerifyConnectHandler(handler VerifyClientConnectHFunc)
	AddExceptionHandler(handler gnError.ExceptionHandleFunc)

	CMDHandler(cmd string, handler gn.HandlerFunc)

	LoopClientReadChan(ctx context.Context)
	LoopLinkerChan(ctx context.Context)
	ListenAndRun() error
	GetLinker() linker.ILinker
	SendPack(serverAddress, router, bindId, cid string, data []byte)
	GetServerIdByRouter(serverType string, LogicBindId string, cid string, serverList []*config.ServersConfig) string
}

type RouteRearEndHFunc func(cid, bindId string, serverList []*config.ServersConfig) (serverId string)

type VerifyClientConnectHFunc func(r *http.Request) bool

type WSConnection struct {
	RChan chan []byte
	WChan chan *ChanMsgPack
	// contains filtered or unexported fields
}