net

package

v0.2.0-alpha.0 Latest Latest Go to latest Published: Jun 12, 2023 License: MIT Imports: 17 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/txchat/im

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
func InitServer(svcCtx *svc.ServiceContext, address []string, thread int, scheme CometScheme) (err error)
type CometScheme
type CometServer
- func NewCometServer(svcCtx *svc.ServiceContext) *CometServer
- func (s *CometServer) Serve(cometConn Conn, conn net.Conn, rp, wp *bytes.Pool, tr *xtime.Timer)
type Conn
type TCP
- func NewTCP(rwc io.ReadWriteCloser) *TCP
type Websocket
- func NewWebsocket(conn net.Conn) *Websocket

Constants ¶

This section is empty.

Variables ¶

View Source

var TCPServer = &tcpScheme{}

View Source

var WebsocketServer = &websocketScheme{}

Functions ¶

func InitServer ¶

func InitServer(svcCtx *svc.ServiceContext, address []string, thread int, scheme CometScheme) (err error)

InitServer listen all tcp.bind and start accept connections.

Types ¶

type CometScheme ¶

type CometScheme interface {
	Name() string
	GetConn(conn net.Conn) Conn
}

type CometServer ¶

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

func NewCometServer ¶

func NewCometServer(svcCtx *svc.ServiceContext) *CometServer

func (*CometServer) Serve ¶

func (s *CometServer) Serve(cometConn Conn, conn net.Conn, rp, wp *bytes.Pool, tr *xtime.Timer)

type Conn ¶

type Conn interface {
	SchemeName() string
	Upgrade(rr *bufio.Reader, wr *bufio.Writer) error
	Close() error
	Flush() error

	WriteProto(proto *protocol.Proto) error
	ReadProto(proto *protocol.Proto) error
	WriteHeart(proto *protocol.Proto, online int32) error
}

type TCP ¶

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

func NewTCP ¶

func NewTCP(rwc io.ReadWriteCloser) *TCP

func (*TCP) Close ¶

func (tcp *TCP) Close() error

func (*TCP) Flush ¶

func (tcp *TCP) Flush() error

func (*TCP) ReadProto ¶

func (tcp *TCP) ReadProto(p *protocol.Proto) error

func (*TCP) SchemeName ¶

func (tcp *TCP) SchemeName() string

func (*TCP) Upgrade ¶

func (tcp *TCP) Upgrade(rr *bufio.Reader, wr *bufio.Writer) error

func (*TCP) WriteHeart ¶

func (tcp *TCP) WriteHeart(p *protocol.Proto, online int32) error

func (*TCP) WriteProto ¶

func (tcp *TCP) WriteProto(p *protocol.Proto) error

type Websocket ¶

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

func NewWebsocket ¶

func NewWebsocket(conn net.Conn) *Websocket

func (*Websocket) Close ¶

func (ws *Websocket) Close() error

func (*Websocket) Flush ¶

func (ws *Websocket) Flush() error

func (*Websocket) ReadProto ¶

func (ws *Websocket) ReadProto(p *protocol.Proto) error

func (*Websocket) SchemeName ¶

func (ws *Websocket) SchemeName() string

func (*Websocket) Upgrade ¶

func (ws *Websocket) Upgrade(rr *bufio.Reader, wr *bufio.Writer) error

func (*Websocket) WriteHeart ¶

func (ws *Websocket) WriteHeart(p *protocol.Proto, online int32) error

func (*Websocket) WriteProto ¶

func (ws *Websocket) WriteProto(p *protocol.Proto) error

Source Files ¶

View all Source files

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