qnet

Documentation

Index

• Constants
• Variables
• func NewFakeConn(node fatchoy.NodeID, addr string) fatchoy.Endpoint
• type Buffer
  • func (b *Buffer) PeekBool() bool
  • func (b *Buffer) PeekFloat32() float32
  • func (b *Buffer) PeekFloat64() float64
  • func (b *Buffer) PeekInt16() int16
  • func (b *Buffer) PeekInt32() int32
  • func (b *Buffer) PeekInt64() int64
  • func (b *Buffer) PeekInt8() int8
  • func (b *Buffer) PeekUint16() uint16
  • func (b *Buffer) PeekUint32() uint32
  • func (b *Buffer) PeekUint64() uint64
  • func (b *Buffer) PeekUint8() uint8
  • func (b *Buffer) ReadBool() bool
  • func (b *Buffer) ReadFloat32() float32
  • func (b *Buffer) ReadFloat64() float64
  • func (b *Buffer) ReadInt16() int16
  • func (b *Buffer) ReadInt32() int32
  • func (b *Buffer) ReadInt64() int64
  • func (b *Buffer) ReadInt8() int8
  • func (b *Buffer) ReadUint16() uint16
  • func (b *Buffer) ReadUint32() uint32
  • func (b *Buffer) ReadUint64() uint64
  • func (b *Buffer) ReadUint8() uint8
  • func (b *Buffer) WriteBool(v bool)
  • func (b *Buffer) WriteFloat32(f float32)
  • func (b *Buffer) WriteFloat64(f float64)
  • func (b *Buffer) WriteInt16(n int16)
  • func (b *Buffer) WriteInt32(n int32)
  • func (b *Buffer) WriteInt64(n int64)
  • func (b *Buffer) WriteInt8(n int8)
  • func (b *Buffer) WriteUInt8(n uint8)
  • func (b *Buffer) WriteUint16(n uint16)
  • func (b *Buffer) WriteUint32(n uint32)
  • func (b *Buffer) WriteUint64(n uint64)
• type Error
  • func NewError(err error, endpoint fatchoy.Endpoint) *Error
  • func (e Error) Error() string
• type FakeConn
  • func (c *FakeConn) Close() error
  • func (c *FakeConn) ForceClose(error)
  • func (c *FakeConn) Go(flag fatchoy.EndpointFlag)
  • func (c *FakeConn) RawConn() net.Conn
  • func (c *FakeConn) SendPacket(fatchoy.IPacket) error
• type StreamConn
  • func (c *StreamConn) ErrorChan() <-chan error
  • func (c *StreamConn) Init(node fatchoy.NodeID, enc codec.Encoder, inbound chan<- fatchoy.IPacket, ...)
  • func (c *StreamConn) IsRunning() bool
  • func (c *StreamConn) NodeID() fatchoy.NodeID
  • func (c *StreamConn) RemoteAddr() string
  • func (c *StreamConn) SetEncryptPair(encrypt cipher.BlockCryptor, decrypt cipher.BlockCryptor)
  • func (c *StreamConn) SetNodeID(node fatchoy.NodeID)
  • func (c *StreamConn) SetRemoteAddr(addr string)
  • func (c *StreamConn) SetUserData(ud interface{})
  • func (c *StreamConn) Stats() *stats.Stats
  • func (c *StreamConn) UserData() interface{}
• type TcpConn
  • func NewTcpConn(node fatchoy.NodeID, conn net.Conn, enc codec.Encoder, errChan chan error, ...) *TcpConn
  • func (t *TcpConn) Close() error
  • func (t *TcpConn) ForceClose(err error)
  • func (t *TcpConn) Go(flag fatchoy.EndpointFlag)
  • func (t *TcpConn) OutboundQueue() chan fatchoy.IPacket
  • func (t *TcpConn) RawConn() net.Conn
  • func (t *TcpConn) SendPacket(pkt fatchoy.IPacket) error
• type TcpServer
  • func NewTcpServer(enc codec.Encoder, inbound chan fatchoy.IPacket, outsize int) *TcpServer
  • func (s *TcpServer) BacklogChan() chan fatchoy.Endpoint
  • func (s *TcpServer) Close()
  • func (s *TcpServer) ErrorChan() chan error
  • func (s *TcpServer) Listen(addr string) error
  • func (s *TcpServer) Shutdown()

Constants

const (
	StatBytesRecv   int = iota // bytes received
	StatBytesSent              // bytes sent
	StatPacketsRecv            // packets received
	StatPacketsSent            // packets sent
	NumStat
)

Variables

var (
	ErrConnIsClosing        = errors.New("connection is closing when sending")
	ErrConnOutboundOverflow = errors.New("connection outbound queue overflow")
	ErrConnForceClose       = errors.New("connection forced to close")
)

var ErrBufferOutOfRange = errors.New("buffer out of range")

var (
	TConnReadTimeout = 200
)

Functions

func NewFakeConn

func NewFakeConn(node fatchoy.NodeID, addr string) fatchoy.Endpoint

Types

type Buffer

type Buffer struct {
	bytes.Buffer
}

func (*Buffer) PeekBool

func (b *Buffer) PeekBool() bool

func (*Buffer) PeekFloat32

func (b *Buffer) PeekFloat32() float32

func (*Buffer) PeekFloat64

func (b *Buffer) PeekFloat64() float64

func (*Buffer) PeekInt16

func (b *Buffer) PeekInt16() int16

func (*Buffer) PeekInt32

func (b *Buffer) PeekInt32() int32

func (*Buffer) PeekInt64

func (b *Buffer) PeekInt64() int64

func (*Buffer) PeekInt8

func (b *Buffer) PeekInt8() int8

func (*Buffer) PeekUint16

func (b *Buffer) PeekUint16() uint16

func (*Buffer) PeekUint32

func (b *Buffer) PeekUint32() uint32

func (*Buffer) PeekUint64

func (b *Buffer) PeekUint64() uint64

func (*Buffer) PeekUint8

func (b *Buffer) PeekUint8() uint8

func (*Buffer) ReadBool

func (b *Buffer) ReadBool() bool

func (*Buffer) ReadFloat32

func (b *Buffer) ReadFloat32() float32

func (*Buffer) ReadFloat64

func (b *Buffer) ReadFloat64() float64

func (*Buffer) ReadInt16

func (b *Buffer) ReadInt16() int16

func (*Buffer) ReadInt32

func (b *Buffer) ReadInt32() int32

func (*Buffer) ReadInt64

func (b *Buffer) ReadInt64() int64

func (*Buffer) ReadInt8

func (b *Buffer) ReadInt8() int8

func (*Buffer) ReadUint16

func (b *Buffer) ReadUint16() uint16

func (*Buffer) ReadUint32

func (b *Buffer) ReadUint32() uint32

func (*Buffer) ReadUint64

func (b *Buffer) ReadUint64() uint64

func (*Buffer) ReadUint8

func (b *Buffer) ReadUint8() uint8

func (*Buffer) WriteBool

func (b *Buffer) WriteBool(v bool)

func (*Buffer) WriteFloat32

func (b *Buffer) WriteFloat32(f float32)

func (*Buffer) WriteFloat64

func (b *Buffer) WriteFloat64(f float64)

func (*Buffer) WriteInt16

func (b *Buffer) WriteInt16(n int16)

func (*Buffer) WriteInt32

func (b *Buffer) WriteInt32(n int32)

func (*Buffer) WriteInt64

func (b *Buffer) WriteInt64(n int64)

func (*Buffer) WriteInt8

func (b *Buffer) WriteInt8(n int8)

func (*Buffer) WriteUInt8

func (b *Buffer) WriteUInt8(n uint8)

func (*Buffer) WriteUint16

func (b *Buffer) WriteUint16(n uint16)

func (*Buffer) WriteUint32

func (b *Buffer) WriteUint32(n uint32)

func (*Buffer) WriteUint64

func (b *Buffer) WriteUint64(n uint64)

type Error

type Error struct {
	Err      error
	Endpoint fatchoy.Endpoint
}

func NewError

func NewError(err error, endpoint fatchoy.Endpoint) *Error

func (Error) Error

func (e Error) Error() string

type FakeConn

type FakeConn struct {
	StreamConn
}

a fake endpoint

func (*FakeConn) Close

func (c *FakeConn) Close() error

func (*FakeConn) ForceClose

func (c *FakeConn) ForceClose(error)

func (*FakeConn) Go

func (c *FakeConn) Go(flag fatchoy.EndpointFlag)

func (*FakeConn) RawConn

func (c *FakeConn) RawConn() net.Conn

func (*FakeConn) SendPacket

func (c *FakeConn) SendPacket(fatchoy.IPacket) error

type StreamConn

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

stream connection

func (*StreamConn) ErrorChan

func (c *StreamConn) ErrorChan() <-chan error

func (*StreamConn) Init

func (c *StreamConn) Init(node fatchoy.NodeID, enc codec.Encoder, inbound chan<- fatchoy.IPacket,
	outsize int, errChan chan error, stat *stats.Stats)

func (*StreamConn) IsRunning

func (c *StreamConn) IsRunning() bool

func (*StreamConn) NodeID

func (c *StreamConn) NodeID() fatchoy.NodeID

func (*StreamConn) RemoteAddr

func (c *StreamConn) RemoteAddr() string

func (*StreamConn) SetEncryptPair

func (c *StreamConn) SetEncryptPair(encrypt cipher.BlockCryptor, decrypt cipher.BlockCryptor)

func (*StreamConn) SetNodeID

func (c *StreamConn) SetNodeID(node fatchoy.NodeID)

func (*StreamConn) SetRemoteAddr

func (c *StreamConn) SetRemoteAddr(addr string)

func (*StreamConn) SetUserData

func (c *StreamConn) SetUserData(ud interface{})

func (*StreamConn) Stats

func (c *StreamConn) Stats() *stats.Stats

func (*StreamConn) UserData

func (c *StreamConn) UserData() interface{}

type TcpConn

type TcpConn struct {
	StreamConn
	// contains filtered or unexported fields
}

TCP connection

func NewTcpConn

func NewTcpConn(node fatchoy.NodeID, conn net.Conn, enc codec.Encoder, errChan chan error,
	incoming chan<- fatchoy.IPacket, outsize int, stats *stats.Stats) *TcpConn

func (*TcpConn) Close

func (t *TcpConn) Close() error

func (*TcpConn) ForceClose

func (t *TcpConn) ForceClose(err error)

func (*TcpConn) Go

func (t *TcpConn) Go(flag fatchoy.EndpointFlag)

func (*TcpConn) OutboundQueue

func (t *TcpConn) OutboundQueue() chan fatchoy.IPacket

func (*TcpConn) RawConn

func (t *TcpConn) RawConn() net.Conn

func (*TcpConn) SendPacket

func (t *TcpConn) SendPacket(pkt fatchoy.IPacket) error

type TcpServer

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

func NewTcpServer

func NewTcpServer(enc codec.Encoder, inbound chan fatchoy.IPacket, outsize int) *TcpServer

func (*TcpServer) BacklogChan

func (s *TcpServer) BacklogChan() chan fatchoy.Endpoint

func (*TcpServer) Close

func (s *TcpServer) Close()

func (*TcpServer) ErrorChan

func (s *TcpServer) ErrorChan() chan error

func (*TcpServer) Listen

func (s *TcpServer) Listen(addr string) error

func (*TcpServer) Shutdown

func (s *TcpServer) Shutdown()