network

package module

Go to main page

Versions in this module

v1

v1.1.1

Jun 26, 2023

Changes in this version

type TcpClient

+ func (c *TcpClient) IsRunning() bool

v1.1.0

Jun 26, 2023

v1.0.9

Jun 26, 2023

Changes in this version

+ type ISession interface

+ OnClose func()

+ OnConnect func()

+ OnMessage func(*Message, *TcpSession)

+ type TcpServer struct

+ Addr string

+ MaxConnNum int

+ MessageHandler func(packet *Packet)

+ func NewTcpServer(addr string, maxConnNum int, buffSize int, logger *spoor.Spoor) *TcpServer

+ func (s *TcpServer) Close()

+ func (s *TcpServer) Init()

+ func (s *TcpServer) OnClose()

+ func (s *TcpServer) OnConnect()

+ func (s *TcpServer) OnMessage(message *Message, conn *TcpSession)

+ func (s *TcpServer) Run()

v1.0.8

Jun 25, 2023

Changes in this version

+ type TCPKeepAliveListener struct

+ func (ln TCPKeepAliveListener) Accept() (c net.Conn, err error)

v1.0.7

Jun 25, 2023

v1.0.6

Jun 21, 2023

Changes in this version

+ func HttpServer(handler http.Handler) *http.Server

+ func SetRouteVars(r *http.Request, val interface{})

+ func Vars(r *http.Request) map[string]string

+ type HttpRouter struct

+ func NewHttpRouter() *HttpRouter

+ func (g *HttpRouter) GetPageView() int64

+ func (g *HttpRouter) Handle(method, path string, h http.Handler)

+ func (g *HttpRouter) HandleFunc(method, path string, h func(http.ResponseWriter, *http.Request))

+ func (g *HttpRouter) HandleStaticFile(method, path, dir string)

+ func (g *HttpRouter) ServeHTTP(w http.ResponseWriter, r *http.Request)

+ func (g *HttpRouter) SetNotFoundHandler(h http.Handler)

+ type RpcServer struct

+ Addr string

+ func (srv *RpcServer) Close()

+ func (srv *RpcServer) Init(addr string)

+ func (srv *RpcServer) Run()

v1.0.5

Jun 19, 2023

Changes in this version

+ func FreeMessage(msg *Message)

+ func ResetMessage(m *Message)

+ type IService interface

+ OnClose func()

+ OnConnect func()

+ OnMessage func(*Message, *TcpSession)

type Message

+ func GetPooledMessage() *Message

+ type TcpClient struct

+ Address string

+ ChMsg chan *Message

+ OnCloseCallBack func()

+ OnMessageCb func(message *Packet)

+ func (c *TcpClient) Close()

+ func (c *TcpClient) Dial() (*net.TCPConn, error)

+ func (c *TcpClient) OnClose()

+ func (c *TcpClient) OnMessage(data *Message, conn *TcpSession)

+ func (c *TcpClient) Run()

+ type TcpSession struct

+ Conn net.Conn

+ ConnID int64

+ Impl IService

+ func NewTcpSession(conn *net.TCPConn, msgBuffSize int, logger *spoor.Spoor) (*TcpSession, error)

+ func (c *TcpSession) AsyncSend(msgID uint16, msg interface{}) bool

+ func (c *TcpSession) AsyncSendLastPacket(msgID uint16, msg interface{}) bool

+ func (c *TcpSession) AsyncSendRowMsg(data []byte) bool

+ func (c *TcpSession) Close()

+ func (c *TcpSession) Connect()

+ func (c *TcpSession) HandleRead()

+ func (c *TcpSession) HandleWrite()

+ func (c *TcpSession) IsClosed() bool

+ func (c *TcpSession) IsShutdown() bool

+ func (c *TcpSession) LastSignal(signal []byte) error

+ func (c *TcpSession) LocalAddr() net.Addr

+ func (c *TcpSession) OnClose()

+ func (c *TcpSession) OnConnect()

+ func (c *TcpSession) Read(b []byte) (int, error)

+ func (c *TcpSession) RemoteAddr() net.Addr

+ func (c *TcpSession) Reset()

+ func (c *TcpSession) Signal(signal []byte) error

+ func (c *TcpSession) Verified() bool

+ func (c *TcpSession) Verify()

+ func (c *TcpSession) Write(b []byte) (int, error)

v1.0.4

Sep 7, 2022

Changes in this version

+ type BufferPacker struct

+ func (p *BufferPacker) Pack(msgID uint16, msg interface{}) ([]byte, error)

+ func (p *BufferPacker) Read(conn *TcpConnX) ([]byte, error)

+ func (p *BufferPacker) SetMsgLen(lenMsgLen int32, minMsgLen uint32, maxMsgLen uint32)

+ func (p *BufferPacker) Unpack(data []byte) (*Message, error)

+ func (p *BufferPacker) Write(conn *TcpConnX, buff ...byte) error

+ type ByteBuffer struct

+ func NewByteBuffer() *ByteBuffer

+ func (bf *ByteBuffer) Append(buff []byte)

+ func (bf *ByteBuffer) AppendInt16(x int16)

+ func (bf *ByteBuffer) AppendInt32(x int32)

+ func (bf *ByteBuffer) AppendInt64(x int64)

+ func (bf *ByteBuffer) EnsureWritableBytes(len int32)

+ func (bf *ByteBuffer) Length() int32

+ func (bf *ByteBuffer) NextBytes(len int32) []byte

+ func (bf *ByteBuffer) ReadBuff() []byte

+ func (bf *ByteBuffer) ReadInt16() int16

+ func (bf *ByteBuffer) ReadInt32() int32

+ func (bf *ByteBuffer) ReadInt64() int64

+ func (bf *ByteBuffer) Reserve(len int32)

+ func (bf *ByteBuffer) Reset()

+ func (bf *ByteBuffer) Retrieve(len int32)

+ func (bf *ByteBuffer) SetByteOrder(littleEndian bool)

+ func (bf *ByteBuffer) Skip(len int32)

+ func (bf *ByteBuffer) Swap(other *ByteBuffer)

+ func (bf *ByteBuffer) Truncate(n int32)

+ func (bf *ByteBuffer) WriteBuff() []byte

+ func (bf *ByteBuffer) WriteBytes(n int32)

type Client

+ OnCloseCallBack func()

+ OnMessageCb func(message *Packet)

+ func (c *Client) Close()

+ func (c *Client) Dial() (*net.TCPConn, error)

+ func (c *Client) OnClose()

+ type IConn interface

+ OnClose func()

+ OnConnect func()

+ OnMessage func(*Message, *TcpConnX)

type IPacker

+ Read func(*TcpConnX) ([]byte, error)

type NormalPacker

+ func (p *NormalPacker) Read(conn *TcpConnX) ([]byte, error)

+ type Packet struct

+ Conn *TcpConnX

+ Msg *Message

type Server

+ Addr string

+ MaxConnNum int

+ MessageHandler func(packet *Packet)

+ func (s *Server) Close()

+ func (s *Server) Init()

+ func (s *Server) OnClose()

+ func (s *Server) OnConnect()

+ func (s *Server) OnMessage(message *Message, conn *TcpConnX)

+ type TcpConnX struct

+ Conn net.Conn

+ ConnID int64

+ Impl IConn

+ func NewTcpConnX(conn *net.TCPConn, msgBuffSize int, logger *spoor.Spoor) (*TcpConnX, error)

+ func (c *TcpConnX) AsyncSend(msgID uint16, msg interface{}) bool

+ func (c *TcpConnX) AsyncSendLastPacket(msgID uint16, msg interface{}) bool

+ func (c *TcpConnX) AsyncSendRowMsg(data []byte) bool

+ func (c *TcpConnX) Close()

+ func (c *TcpConnX) Connect()

+ func (c *TcpConnX) HandleRead()

+ func (c *TcpConnX) HandleWrite()

+ func (c *TcpConnX) IsClosed() bool

+ func (c *TcpConnX) IsShutdown() bool

+ func (c *TcpConnX) LastSignal(signal []byte) error

+ func (c *TcpConnX) LocalAddr() net.Addr

+ func (c *TcpConnX) OnClose()

+ func (c *TcpConnX) OnConnect()

+ func (c *TcpConnX) Read(b []byte) (int, error)

+ func (c *TcpConnX) RemoteAddr() net.Addr

+ func (c *TcpConnX) Reset()

+ func (c *TcpConnX) Signal(signal []byte) error

+ func (c *TcpConnX) Verified() bool

+ func (c *TcpConnX) Verify()

+ func (c *TcpConnX) Write(b []byte) (int, error)

v1.0.3

Jul 26, 2022

Changes in this version

+ type Client struct

+ Address string

+ ChMsg chan *Message

+ OnMessage func(message *ClientPacket)

+ func NewClient(address string) *Client

+ func (c *Client) Read(conn net.Conn)

+ func (c *Client) Run()

+ func (c *Client) Send(conn net.Conn, message *Message)

+ func (c *Client) Write(conn net.Conn)

+ type ClientPacket struct

+ Conn net.Conn

+ Msg *Message

+ type IPacker interface

+ Pack func(message *Message) ([]byte, error)

+ Unpack func(reader io.Reader) (*Message, error)

+ type Message struct

+ Data []byte

+ ID uint64

+ type NormalPacker struct

+ ByteOrder binary.ByteOrder

+ func (p *NormalPacker) Pack(message *Message) ([]byte, error)

+ func (p *NormalPacker) Unpack(reader io.Reader) (*Message, error)

+ type Server struct

+ Address string

+ OnSessionPacket func(packet *SessionPacket)

+ func NewServer(address string) *Server

+ func (s *Server) Run()

+ type Session struct

+ Conn net.Conn

+ IsClose bool

+ IsPlayerOnline bool

+ MessageHandler func(packet *SessionPacket)

+ UId uint64

+ WriteCh chan *Message

+ func NewSession(conn net.Conn) *Session

+ func (s *Session) Read()

+ func (s *Session) Run()

+ func (s *Session) SendMsg(msg *Message)

+ func (s *Session) Write()

+ type SessionMgr struct

+ Counter int64

+ Mutex sync.Mutex

+ Pid int64

+ Sessions map[uint64]*Session

+ var SessionMgrInstance SessionMgr

+ func (sm *SessionMgr) AddSession(s *Session)

+ func (sm *SessionMgr) DelSession(UId uint64)

+ type SessionPacket struct

+ Msg *Message

+ Sess *Session

v1.0.1

Jul 26, 2022

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