tcp

Documentation

Index

• Constants
• type Conn
  • func (c *Conn) Close()
  • func (c *Conn) CompleteRead(spliter func(b []byte) (int, bool), handler func(*Conn, []byte) bool) error
  • func (c *Conn) CompleteWrite(b []byte) (err error)
  • func (c *Conn) GetCid() uint64
  • func (c *Conn) IsClosed() bool
• type Server
  • func NewServer() *Server
  • func (s *Server) GetConn(cid uint64) *Conn
  • func (s *Server) ListenAndServe(host string, port int) error
  • func (s *Server) NewConn(conn net.Conn) *Conn
  • func (s *Server) SetHandler(handler func(*Conn, []byte) bool) *Server
  • func (s *Server) SetSpliter(spliter func([]byte) (int, bool)) *Server

Constants

const (
	HeaderEnd     = "\r\n\r\n"
	LineEnd       = "\r\n"
	ContentLength = "Content-Length:"
)

Types

type Conn

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

func (*Conn) Close

func (c *Conn) Close()

func (*Conn) CompleteRead

func (c *Conn) CompleteRead(spliter func(b []byte) (int, bool), handler func(*Conn, []byte) bool) error

func (*Conn) CompleteWrite

func (c *Conn) CompleteWrite(b []byte) (err error)

func (*Conn) GetCid

func (c *Conn) GetCid() uint64

func (*Conn) IsClosed

func (c *Conn) IsClosed() bool

type Server

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

func NewServer

func NewServer() *Server

func (*Server) GetConn

func (s *Server) GetConn(cid uint64) *Conn

func (*Server) ListenAndServe

func (s *Server) ListenAndServe(host string, port int) error

func (*Server) NewConn

func (s *Server) NewConn(conn net.Conn) *Conn

func (*Server) SetHandler

func (s *Server) SetHandler(handler func(*Conn, []byte) bool) *Server

func (*Server) SetSpliter

func (s *Server) SetSpliter(spliter func([]byte) (int, bool)) *Server