reliable

package

Go to main page

Versions in this module

v0

v0.7.0

Mar 12, 2022

v0.6.0

Dec 4, 2020

Changes in this version

+ type UnderlayPacket struct

+ Address *net.UDPAddr

+ Payload []byte

+ func (p *UnderlayPacket) DecodeFromBytes(b []byte) error

+ func (p *UnderlayPacket) SerializeTo(b []byte) (int, error)

v0.5.0

Mar 30, 2020

Changes in this version

+ type Dispatcher interface

+ Register func(ctx context.Context, ia addr.IA, address *net.UDPAddr, svc addr.HostSVC) (net.PacketConn, uint16, error)

+ func NewDispatcher(name string) Dispatcher

v0.4.0

Nov 14, 2019

Changes in this version

+ const DefaultDispSocketFileMode

+ var ErrBadAddressType common.ErrMsg = "bad address type"

+ var ErrBadCookie common.ErrMsg = "bad cookie"

+ var ErrBadFrameLength common.ErrMsg = "bad frame length"

+ var ErrBadLength common.ErrMsg = "bad length"

+ var ErrBufferTooSmall common.ErrMsg = "buffer too small"

+ var ErrIncompleteAddress common.ErrMsg = "incomplete IP address"

+ var ErrIncompleteFrameHeader common.ErrMsg = "incomplete frame header"

+ var ErrIncompleteMessage common.ErrMsg = "incomplete message"

+ var ErrIncompletePort common.ErrMsg = "incomplete UDP port"

+ var ErrNoAddress common.ErrMsg = "no address found"

+ var ErrNoPort common.ErrMsg = "missing port"

+ var ErrPayloadTooLong common.ErrMsg = "payload too long"

+ func IsDispatcherError(err error) bool

+ func IsSpecificSysError(err error, errno syscall.Errno) bool

+ func IsSysError(err error) bool

+ type CommandBitField uint8

+ const CmdAlwaysOn

+ const CmdBindAddress

+ const CmdEnableSCMP

+ type Confirmation struct

+ Port uint16

+ func (c *Confirmation) DecodeFromBytes(b []byte) error

+ func (c *Confirmation) SerializeTo(b []byte) (int, error)

+ type DispatcherService interface

+ Register func(ia addr.IA, public *addr.AppAddr, bind *overlay.OverlayAddr, svc addr.HostSVC) (net.PacketConn, uint16, error)

+ RegisterTimeout func(ia addr.IA, public *addr.AppAddr, bind *overlay.OverlayAddr, svc addr.HostSVC, ...) (net.PacketConn, uint16, error)

+ func NewDispatcherService(name string) DispatcherService

+ type OverlayPacket struct

+ Address *net.UDPAddr

+ Payload []byte

+ func (p *OverlayPacket) DecodeFromBytes(b []byte) error

+ func (p *OverlayPacket) SerializeTo(b []byte) (int, error)

+ type ReadPacketizer struct

+ func NewReadPacketizer(conn net.Conn) *ReadPacketizer

+ func (r *ReadPacketizer) Read(b []byte) (int, error)

+ type Registration struct

+ BindAddress *net.UDPAddr

+ IA addr.IA

+ PublicAddress *net.UDPAddr

+ SVCAddress addr.HostSVC

+ func (r *Registration) DecodeFromBytes(b []byte) error

+ func (r *Registration) SerializeTo(b []byte) (int, error)

+ type WriteStreamer struct

+ func NewWriteStreamer(conn net.Conn) *WriteStreamer

+ func (writer *WriteStreamer) Write(b []byte) error

v0.3.1

Sep 24, 2018

v0.3.0

Sep 19, 2018

v0.2.0

Aug 27, 2018

v0.1.1

Jul 31, 2018

Changes in this version

+ const DefaultDispPath

v0.1.0

Jul 19, 2018

Changes in this version

+ var MaxLength = (1 << 16) - 1 - hdrLen

+ var NilAppAddr = &AppAddr

+ type AppAddr struct

+ Addr addr.HostAddr

+ Port uint16

+ func AppAddrFromRaw(buf common.RawBytes, addrType addr.HostAddrType) (*AppAddr, error)

+ func (a *AppAddr) Len() int

+ func (a *AppAddr) Network() string

+ func (a *AppAddr) String() string

+ func (a *AppAddr) Write(buf common.RawBytes) (int, error)

+ type Conn struct

+ func Dial(address string) (*Conn, error)

+ func DialTimeout(address string, timeout time.Duration) (*Conn, error)

+ func Register(dispatcher string, ia addr.IA, public, bind *AppAddr, svc addr.HostSVC) (*Conn, uint16, error)

+ func RegisterTimeout(dispatcher string, ia addr.IA, public, bind *AppAddr, svc addr.HostSVC, ...) (*Conn, uint16, error)

+ func (conn *Conn) Read(buf []byte) (int, error)

+ func (conn *Conn) ReadFrom(buf []byte) (int, net.Addr, error)

+ func (conn *Conn) ReadN(msgs []Msg) (int, error)

+ func (conn *Conn) String() string

+ func (conn *Conn) Write(buf []byte) (int, error)

+ func (conn *Conn) WriteN(bufs []Msg) (int, error)

+ func (conn *Conn) WriteNAll(bufs []Msg) (int, error)

+ func (conn *Conn) WriteTo(buf []byte, dst net.Addr) (int, error)

+ type Listener struct

+ func Listen(laddr string) (*Listener, error)

+ func (listener *Listener) Accept() (net.Conn, error)

+ func (listener *Listener) String() string

+ type Msg struct

+ Addr *AppAddr

+ Buffer []byte

+ Copied int

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