hub

May 13, 2016

Changes in this version

+ type TimedInboundRay struct

+ func NewTimedInboundRay(name string, inboundRay ray.InboundRay) *TimedInboundRay

+ func (this *TimedInboundRay) InboundInput() ray.OutputStream

+ func (this *TimedInboundRay) InboundOutput() ray.InputStream

+ func (this *TimedInboundRay) Monitor()

+ func (this *TimedInboundRay) Release()

type UDPServer

+ func (this *UDPServer) RemoveRay(name string)

May 3, 2016

Changes in this version

type Connection

+ func (this *Connection) Release()

May 1, 2016

Changes in this version

+ type Connection interface

+ Close func() error

+ CloseRead func() error

+ CloseWrite func() error

+ LocalAddr func() net.Addr

+ Read func([]byte) (int, error)

+ RemoteAddr func() net.Addr

+ SetDeadline func(t time.Time) error

+ SetReadDeadline func(t time.Time) error

+ SetWriteDeadline func(t time.Time) error

+ Write func([]byte) (int, error)

+ type ConnectionHandler func(Connection)

+ type TCPConnection struct

+ func (this *TCPConnection) Close() error

+ func (this *TCPConnection) CloseRead() error

+ func (this *TCPConnection) CloseWrite() error

+ func (this *TCPConnection) LocalAddr() net.Addr

+ func (this *TCPConnection) Read(b []byte) (int, error)

+ func (this *TCPConnection) Release()

+ func (this *TCPConnection) RemoteAddr() net.Addr

+ func (this *TCPConnection) SetDeadline(t time.Time) error

+ func (this *TCPConnection) SetReadDeadline(t time.Time) error

+ func (this *TCPConnection) SetWriteDeadline(t time.Time) error

+ func (this *TCPConnection) Write(b []byte) (int, error)

+ type TLSConnection struct

+ func (this *TLSConnection) Close() error

+ func (this *TLSConnection) CloseRead() error

+ func (this *TLSConnection) CloseWrite() error

+ func (this *TLSConnection) LocalAddr() net.Addr

+ func (this *TLSConnection) Read(b []byte) (int, error)

+ func (this *TLSConnection) Release()

+ func (this *TLSConnection) RemoteAddr() net.Addr

+ func (this *TLSConnection) SetDeadline(t time.Time) error

+ func (this *TLSConnection) SetReadDeadline(t time.Time) error

+ func (this *TLSConnection) SetWriteDeadline(t time.Time) error

+ func (this *TLSConnection) Write(b []byte) (int, error)

Apr 19, 2016

Changes in this version

+ var ErrorClosedConnection = errors.New("Connection already closed.")

Feb 28, 2016

Changes in this version

+ type TCPConn struct

+ func (this *TCPConn) Close() error

+ func (this *TCPConn) CloseRead() error

+ func (this *TCPConn) CloseWrite() error

+ func (this *TCPConn) LocalAddr() net.Addr

+ func (this *TCPConn) Read(b []byte) (int, error)

+ func (this *TCPConn) Release()

+ func (this *TCPConn) RemoteAddr() net.Addr

+ func (this *TCPConn) SetDeadline(t time.Time) error

+ func (this *TCPConn) SetReadDeadline(t time.Time) error

+ func (this *TCPConn) SetWriteDeadline(t time.Time) error

+ func (this *TCPConn) Write(b []byte) (int, error)

+ type TCPHub struct

+ func ListenTCP(port v2net.Port, callback func(*TCPConn)) (*TCPHub, error)

+ func (this *TCPHub) Close()

+ type UDPHub struct

+ func ListenUDP(port v2net.Port, callback UDPPayloadHandler) (*UDPHub, error)

+ func (this *UDPHub) Close()

+ func (this *UDPHub) WriteTo(payload []byte, dest v2net.Destination) (int, error)

+ type UDPPayloadHandler func(*alloc.Buffer, v2net.Destination)

+ type UDPResponseCallback func(packet v2net.Packet)

+ type UDPServer struct

+ func NewUDPServer(packetDispatcher dispatcher.PacketDispatcher) *UDPServer

+ func (this *UDPServer) Dispatch(source v2net.Destination, packet v2net.Packet, callback UDPResponseCallback)