inet

package
v1.0.3 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Dec 30, 2020 License: Apache-2.0 Imports: 19 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewKcpServer 

func NewKcpServer(addr string, processor iduck.Processor) (s *kcpServer, err error)

func NewQUICServer 

func NewQUICServer(addr string, processor iduck.Processor, config *tls.Config) (s *quicServer, err error)

func NewTcpServer 

func NewTcpServer(addr string, processor iduck.Processor) (s *tcpServer, err error)

func NewWsServer 

func NewWsServer(addr string, processor iduck.Processor) (s *wsServer, err error)

Types

type BroadcastNode 

type BroadcastNode struct {
	// 节点ID
	NodeId string
	// 网络连接
	Connections map[interface{}]iduck.IConnection
	// contains filtered or unexported fields
}

广播转发节点

func NewBroadcastNode 

func NewBroadcastNode() *BroadcastNode

func (*BroadcastNode) AddConn 

func (bNode *BroadcastNode) AddConn(conn iduck.IConnection) error

func (*BroadcastNode) Complete 

func (bNode *BroadcastNode) Complete() error

完成同步

func (*BroadcastNode) DelConn 

func (bNode *BroadcastNode) DelConn(key string) error

func (*BroadcastNode) Destroy 

func (bNode *BroadcastNode) Destroy() error

摧毁节点

func (*BroadcastNode) GetAllMessage 

func (bNode *BroadcastNode) GetAllMessage() chan []interface{}

func (*BroadcastNode) OnProtocolMessage 

func (bNode *BroadcastNode) OnProtocolMessage(msg interface{}) error

func (*BroadcastNode) OnRawMessage 

func (bNode *BroadcastNode) OnRawMessage([]byte) error

func (*BroadcastNode) Serve 

func (bNode *BroadcastNode) Serve()

type FrameNode 

type FrameNode struct {
	// 节点ID
	NodeId string
	// 网络连接
	Connections map[interface{}]iduck.IConnection

	// 同步周期
	FrameTicker *time.Ticker

	// rand seed
	RandSeed int64
	// contains filtered or unexported fields
}

帧同步节点

func NewFrameNode 

func NewFrameNode() *FrameNode

func (*FrameNode) AddConn 

func (gr *FrameNode) AddConn(conn iduck.IConnection) error

func (*FrameNode) Complete 

func (gr *FrameNode) Complete() error

完成同步

func (*FrameNode) DelConn 

func (gr *FrameNode) DelConn(key string) error

func (*FrameNode) Destroy 

func (gr *FrameNode) Destroy() error

摧毁节点

func (*FrameNode) GetAllMessage 

func (gr *FrameNode) GetAllMessage() chan []interface{}

func (*FrameNode) OnProtocolMessage 

func (gr *FrameNode) OnProtocolMessage(interface{}) error

func (*FrameNode) OnRawMessage 

func (gr *FrameNode) OnRawMessage(msg []byte) error

func (*FrameNode) Serve 

func (gr *FrameNode) Serve()

type KCPConn 

type KCPConn struct {
	*TCPConn
}

可靠的UDP，like TCP

func NewKcpConn 

func NewKcpConn(conn net.Conn, processor iduck.Processor) *KCPConn

type QuicStream 

type QuicStream struct {
	sync.RWMutex

	quic.Stream
	// contains filtered or unexported fields
}

func NewQuicStream 

func NewQuicStream(stream quic.Stream, processor iduck.Processor) *QuicStream

func (*QuicStream) AfterClose 

func (s *QuicStream) AfterClose(cb func())

func (*QuicStream) Close 

func (s *QuicStream) Close() error

func (*QuicStream) GetData 

func (s *QuicStream) GetData() interface{}

func (*QuicStream) GetNode 

func (s *QuicStream) GetNode() iduck.INode

func (*QuicStream) GetUuid 

func (s *QuicStream) GetUuid() string

func (*QuicStream) IsClosed 

func (s *QuicStream) IsClosed() bool

func (*QuicStream) ReadMsg 

func (s *QuicStream) ReadMsg()

read | write end -> write | read end -> conn end

func (*QuicStream) SetData 

func (s *QuicStream) SetData(data interface{})

func (*QuicStream) SetNode 

func (s *QuicStream) SetNode(node iduck.INode)

func (*QuicStream) WriteMsg 

func (s *QuicStream) WriteMsg(message interface{})

type TCPConn 

type TCPConn struct {
	sync.RWMutex

	net.Conn
	// contains filtered or unexported fields
}

func NewTcpConn 

func NewTcpConn(conn net.Conn, processor iduck.Processor) *TCPConn

func (*TCPConn) AfterClose 

func (tc *TCPConn) AfterClose(cb func())

func (*TCPConn) Close 

func (tc *TCPConn) Close() error

func (*TCPConn) GetData 

func (tc *TCPConn) GetData() interface{}

func (*TCPConn) GetNode 

func (tc *TCPConn) GetNode() iduck.INode

func (*TCPConn) GetUuid 

func (tc *TCPConn) GetUuid() string

func (*TCPConn) IsClosed 

func (tc *TCPConn) IsClosed() bool

func (*TCPConn) ReadMsg 

func (tc *TCPConn) ReadMsg()

read | write end -> write | read end -> conn end

func (*TCPConn) SetData 

func (tc *TCPConn) SetData(data interface{})

func (*TCPConn) SetNode 

func (tc *TCPConn) SetNode(node iduck.INode)

func (*TCPConn) WriteMsg 

func (tc *TCPConn) WriteMsg(message interface{})

type WSConn 

type WSConn struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func NewWSConn 

func NewWSConn(conn *websocket.Conn, processor iduck.Processor) *WSConn

func (*WSConn) AfterClose 

func (wc *WSConn) AfterClose(cb func())

func (*WSConn) Close 

func (wc *WSConn) Close() error

func (*WSConn) GetData 

func (wc *WSConn) GetData() interface{}

func (*WSConn) GetNode 

func (wc *WSConn) GetNode() iduck.INode

func (*WSConn) GetUuid 

func (wc *WSConn) GetUuid() string

func (*WSConn) IsClosed 

func (wc *WSConn) IsClosed() bool

func (*WSConn) ReadMsg 

func (wc *WSConn) ReadMsg()

read | write end -> write | read end -> conn end

func (*WSConn) SetData 

func (wc *WSConn) SetData(data interface{})

func (*WSConn) SetNode 

func (wc *WSConn) SetNode(node iduck.INode)

func (*WSConn) WriteMsg 

func (wc *WSConn) WriteMsg(message interface{})

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.