netlib

type Acceptor interface {
	GetSessionConfig() *SessionConfig
	Addr() net.Addr
	// contains filtered or unexported methods
}

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

type BasicSessionFilter struct {
}

type BasicSessionHandler struct {
}

type BinaryEncDecoder struct {
}

type Call struct {
	ServiceMethod string      // The name of the service and method to call.
	Args          interface{} // The argument to the function (*struct).
	Reply         interface{} // The reply from the function (*struct).
	Error         error       // After completion, the error status.
	Done          chan *Call  // Receives *Call when Go is complete.
}

type Configuration struct {
	SrvInfo    ServerInfo
	IoServices []SessionConfig
}

type Connector interface {
	GetSessionConfig() *SessionConfig
	// contains filtered or unexported methods
}

type DefaultProtocolDecoder struct {
}

type DefaultProtocolEncoder struct {
	PacketCutor PacketCutSlicesFunc
}

type EncDecoder interface {
	Unmarshal(buf []byte, pack interface{}) error
	Marshal(pack interface{}) ([]byte, error)
}

type GbpEncDecoder struct {
}

type GobEncDecoder struct {
}

type Handler interface {
	Process(session *Session, packetid int, data interface{}) error
}

type HandlerWrapper func(session *Session, packetid int, data interface{}) error

type ISession interface {
	SetAttribute(key, value interface{}) bool
	RemoveAttribute(key interface{})
	GetAttribute(key interface{}) interface{}
	GetSessionConfig() *SessionConfig
	LocalAddr() string
	RemoteAddr() string
	IsIdle() bool
	Close()
	Send(packetid int, data interface{}, sync ...bool) bool
	SendEx(packetid int, logicNo uint32, data interface{}, sync bool) bool
	FireConnectEvent() bool
	FireDisconnectEvent() bool
	FirePacketReceived(packetid int, logicNo uint32, packet interface{}) bool
	FirePacketSent(packetid int, logicNo uint32, data []byte) bool
	FireSessionIdle() bool
}

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

type NetLibParamError struct {
	Src   string
	Param string
}

type NilEncDecoder struct {
}

type PacketCutSlicesFunc func(data []byte) (int, []interface{})

type PacketFactory interface {
	CreatePacket() interface{}
}

type PacketFactoryWrapper func() interface{}

type PacketHeader struct {
	EncodeType int16
	PacketId   int16
}

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

type ProtoHeader struct {
	Len     uint16 //包长度
	Seq     uint16 //包序号
	LogicNo uint32 //逻辑号
}

type ProtocolDecoder interface {
	Decode(s *Session, r io.Reader) (packetid int, logicNo uint32, packet interface{}, err error, raw []byte)
	FinishDecode(s *Session)
}

type ProtocolEncoder interface {
	Encode(s *Session, packetid int, logicNo uint32, packet interface{}, w io.Writer) (data []byte, err error)
	FinishEncode(s *Session)
}

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

type ServerError string

type ServerInfo struct {
	Name   string
	Type   int
	Id     int
	AreaID int
	Data   string
	Banner []string
}

type ServiceStats struct {
	Id           int
	Type         int
	Name         string
	Addr         string
	MaxActive    int
	MaxDone      int
	RunningTime  int64
	SessionStats []SessionStats
}

type Session struct {
	Id      int
	GroupId int
	Sid     int64
	Auth    bool

	PendingRcv bool
	PendingSnd bool
	// contains filtered or unexported fields
}

type SessionCloseListener interface {
	// contains filtered or unexported methods
}

type SessionConfig struct {
	Id                      int
	Type                    int
	AreaId                  int
	Protocol                string //"tcp" "ws" "wss"
	Name                    string
	Ip                      string
	Path                    string //path of "ws"
	CertFile                string
	KeyFile                 string
	OuterIp                 string //对外的IP
	Port                    int
	MaxDone                 int
	MaxPend                 int
	MaxPacket               int
	MaxConn                 int
	ExtraConn               int
	RcvBuff                 int
	SndBuff                 int
	SoLinger                int
	MTU                     int
	WriteTimeout            time.Duration
	ReadTimeout             time.Duration
	IdleTimeout             time.Duration
	KeepAlive               bool
	KeepAlivePeriod         time.Duration
	KeepAliveIdle           time.Duration
	KeepAliveCount          int
	NoDelay                 bool
	IsClient                bool
	IsAutoReconn            bool
	IsInnerLink             bool
	AuthKey                 string //Authentication Key
	EncoderName             string //ProtocolEncoder name
	DecoderName             string //ProtocolDecoder name
	UnknowPacketHandlerName string
	FilterChain             []string
	HandlerChain            []string
	SupportFragment         bool
	AllowMultiConn          bool
	// contains filtered or unexported fields
}

type SessionCutPacketListener interface {
	// contains filtered or unexported methods
}

type SessionFilter interface {
	GetName() string
	GetInterestOps() uint
	OnSessionOpened(s *Session) bool                                                    //run in main goroutine
	OnSessionClosed(s *Session) bool                                                    //run in main goroutine
	OnSessionIdle(s *Session) bool                                                      //run in main goroutine
	OnPacketReceived(s *Session, packetid int, logicNo uint32, packet interface{}) bool //run in session receive goroutine
	OnPacketSent(s *Session, packetid int, logicNo uint32, data []byte) bool            //run in session send goroutine
}

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

type SessionFilterCreator func() SessionFilter

type SessionHandler interface {
	GetName() string
	GetInterestOps() uint
	OnSessionOpened(s *Session)                                                    //run in main goroutine
	OnSessionClosed(s *Session)                                                    //run in main goroutine
	OnSessionIdle(s *Session)                                                      //run in main goroutine
	OnPacketReceived(s *Session, packetid int, logicNo uint32, packet interface{}) //run in session receive goroutine
	OnPacketSent(s *Session, packetid int, logicNo uint32, data []byte)            //run in session send goroutine
}

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

type SessionHandlerCreator func() SessionHandler

type SessionStats struct {
	Id           int
	GroupId      int
	RunningTime  int64
	SendedBytes  int64
	RecvedBytes  int64
	SendedPack   int64
	RecvedPack   int64
	PendSendPack int
	PendRecvPack int
	RemoteAddr   string
}

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

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

type TcpSession struct {
	Session
	// contains filtered or unexported fields
}

type TypeTester func(pack interface{}) int

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

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

type UdpSession struct {
	Session
	// contains filtered or unexported fields
}

type UnknowPacketHandler interface {
	OnUnknowPacket(s *Session, packetid int, logicNo uint32, data []byte) bool //run in session receive goroutine
}

type UnknowPacketHandlerCreator func() UnknowPacketHandler

type UnknowPacketHandlerWrapper func(session *Session, packetid int, logicNo uint32, data []byte) bool

type UnparsePacketTypeErr struct {
	EncodeType int16
	PacketId   int16
	Err        error
}

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

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

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

type WsSession struct {
	Session
	// contains filtered or unexported fields
}