network

type BaseRouter struct {
}

type Config struct {
	Name    string `json:"name"`
	Host    string `json:"host"`
	TCPPort int    `json:"port"`
	Version string `json:"version"`

	MaxPacketSize     uint32 `json:"max_packet_size"`
	MaxConn           int    `json:"max_conn"`
	WorkerPoolSize    uint32 `json:"worker_pool_size"`
	MaxWorkerTaskLen  uint32 `json:"max_worker_task_len"`
	MaxMessageChanLen uint32 `json:"max_message_chan_len"`

	Raft struct {
		Id      string `json:"id"`
		Addr    string `json:"addr"`
		Cluster string `json:"cluster"`
	} `json:"raft"`
}

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

type Connection struct {
	TCPServer IServer
	Conn      *net.TCPConn
	ConnID    uint32

	ExitBuffChan chan bool
	// contains filtered or unexported fields
}

type HandFunc func(*net.TCPConn, []byte, int) error

type IConnManager interface {
	Add(IConnection)
	Remove(IConnection)
	Get(uint32) (IConnection, error)
	Len() int
	ClearConn()
}

type IConnection interface {
	Start()
	Stop()

	GetTCPConnection() *net.TCPConn
	GetConnID() uint32
	RemoteAddr() net.Addr

	SendMessage(uint32, []byte) error
	SendBuffMessage(uint32, []byte) error

	SetProperty(string, interface{})
	GetProperty(string) (interface{}, error)
	RemoveProperty(string)
}

type IMessage interface {
	GetID() uint32
	GetData() []byte
	GetDataLen() uint32

	SetID(uint32)
	SetData([]byte)
	SetDataLen(uint32)
}

type IMessageHandle interface {
	DoMessageHandler(IRequest)
	AddRouter(uint32, IRouter)
	StartWorkerPool()
	SendMessageToTaskQueue(IRequest)
}

type IPack interface {
	GetHeadLen() uint32
	Pack(IMessage) ([]byte, error)
	Unpack([]byte) (IMessage, error)
}

type IRequest interface {
	GetConnection() IConnection
	GetData() []byte
	GetMessageID() uint32
}

type IRouter interface {
	BeforeHook(IRequest)
	Handle(IRequest)
	AfterHook(IRequest)
}

type IServer interface {
	Start()
	Close()
	Serve()
	AddRouter(uint32, IRouter)
	GetConnManager() IConnManager
	SetOnConnStart(func(IConnection))
	SetOnConnStop(func(IConnection))
	CallOnConnStart(IConnection)
	CallOnConnStop(IConnection)
}

type Message struct {
	ID      uint32
	DataLen uint32
	Data    []byte
}

type MessageHandle struct {
	APIs           map[uint32]IRouter
	WorkerPoolSize uint32
	TaskQueue      []chan IRequest
}

type Pack struct {
}

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

type Server struct {
	Name      string
	IPVersion string
	IP        string
	Port      int

	ConnManager IConnManager

	OnConnStart func(conn IConnection)
	OnConnStop  func(conn IConnection)
	// contains filtered or unexported fields
}