defs

type AuthorizedCallback func(IConnection, IPacket) bool

type ClientConnCallback func(net.Conn)

type CloseCallback func(IConnection)

type ConnCallback func(IConnection)

type ExitCallback func()

type IClient interface {
	Name() string
	Connect() IConnection
	Close() bool
	SetRetry(bool)
	SetCodec(ICodec)
	SetIOModule(IIOModule)
	SetConnCallback(ConnCallback)
	SetMsgCallback(MsgCallback)
	SendData([]byte)
	SendDataById(string, []byte)
	SendPacket(IPacket)
	SendDataAwait([]byte) (IPacket, error)
	SendDataByIdAwait(string, []byte) (IPacket, error)
	SendPacketAwait(IPacket) (IPacket, error)
	GetConn() IConnection
}

type ICodec interface {
	Init(IConnection) bool
	Write(IPacket) error
	Read() (IPacket, error)
}

type IConnection interface {
	GetId() string
	LocalAddr() string
	RemoteAddr() string
	Close() bool
	IsClosed() bool
	OnConnection()
	ReadPacket(IPacket)
	WriteData([]byte)
	WriteDataById(string, []byte)
	WritePacket(IPacket)
	WriteDataAwait([]byte) (IPacket, error)
	WriteDataByIdAwait(string, []byte) (IPacket, error)
	WritePacketAwait(IPacket) (IPacket, error)
	WriteComplete()
	SetContext(interface{}, interface{})
	GetContext(interface{}) interface{}
	DelContext(interface{})
	UpdateCodec(ICodec)
}

type IIOModule interface {
	Codec(ICodec) bool
	Close()
	OnConnectionLost()
	Write(IPacket)
	WriteAwait(IPacket) (IPacket, error)
	UpdateCodec(ICodec)
}

type IPacket interface {
	SetData([]byte)
	GetData() []byte
	SetSessionId(string)
	GetSessionId() string
	SetId(interface{})
	GetId() string
	SetStatus(int)
	GetStatus() int
	GetSequence() uint64
	SetSequence(uint64)
}

type IServer interface {
	Host() string
	Name() string
	Serve()
	Stop()
	SetCodec(ICodec)
	SetNewIOModuleCallback(NewIOModuleCallback)
	SetConnCallback(ConnCallback)
	SetMsgCallback(MsgCallback)
	SetExitCallback(ExitCallback)
	SetAuthorizedCallback(AuthorizedCallback)
	SetWriteCompleteCallback(WriteCompleteCallback)
}

type ISession interface {
	//GetServeObj() ServeObj
	GetConnId() string
	GetSessionId() string
	Close() bool
	CloseSession() bool
	WritePacket(IPacket)
	WriteData([]byte)
	WriteDataById(string, []byte)
	WritePacketAwait(IPacket) (IPacket, error)
	WriteDataAwait([]byte) (IPacket, error)
	WriteDataByIdAwait(string, []byte) (IPacket, error)
	OnService(ISession, IPacket) bool
	SetContext(key, value interface{})
	GetContext(key interface{}) interface{}
	SetPacket(IPacket)
	GetPacket() IPacket
}

type ITcpConnection interface {
	GetConn() net.Conn
}

type IWSConnection interface {
	GetConn() *websocket.Conn
	GetMsgType() int
}

type IWSServer interface {
	IServer
	SetMsgType(int)
}

type MethodType struct {
	sync.Mutex
	Method    reflect.Method //调用方法
	ArgType   reflect.Type   //方法参数类型
	ReplyType reflect.Type   //方法的返回值类型
	// contains filtered or unexported fields
}

type MsgCallback func(IConnection, IPacket)

type NewIOModuleCallback func(IConnection) IIOModule

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

type ParseDataCallback func([]byte, interface{}) bool

type ParseMethodNameCallback func(string) (string, error)

type SerializeDataCallback func(interface{}, ...interface{}) []byte

type ServeObj interface {
	OnServiceHandle(session ISession, packet IPacket) bool
}

type WriteCompleteCallback func(IConnection)