conn

Documentation

Index

• Constants
• func NewReadMessages(n int) []ipv4.Message
• func NewWriteMessages(n int) []ipv4.Message
• type Conn
  • func New(listen, remote *overlay.OverlayAddr, labels prometheus.Labels) (Conn, error)
• type ReadMeta
  • func (m *ReadMeta) Reset()
  • func (m *ReadMeta) SetSrc(a *overlay.OverlayAddr, raddr *net.UDPAddr, ot overlay.Type)
• type Timespec

Constants

const (
	SizeOfInt      = C.sizeof_int
	SizeOfTimespec = C.sizeof_struct_timespec
)

Functions

func NewReadMessages

func NewReadMessages(n int) []ipv4.Message

func NewWriteMessages

func NewWriteMessages(n int) []ipv4.Message

Types

type Conn

type Conn interface {
	Read(common.RawBytes) (int, *ReadMeta, error)
	ReadBatch([]ipv4.Message, []ReadMeta) (int, error)
	Write(common.RawBytes) (int, error)
	WriteTo(common.RawBytes, *overlay.OverlayAddr) (int, error)
	WriteBatch([]ipv4.Message) (int, error)
	LocalAddr() *overlay.OverlayAddr
	RemoteAddr() *overlay.OverlayAddr
	Close() error
}

func New

func New(listen, remote *overlay.OverlayAddr, labels prometheus.Labels) (Conn, error)

type ReadMeta

type ReadMeta struct {
	Src     *overlay.OverlayAddr
	RcvOvfl int
	Recvd   time.Time

	ReadDelay time.Duration
	// contains filtered or unexported fields
}

func (*ReadMeta) Reset

func (m *ReadMeta) Reset()

func (*ReadMeta) SetSrc

func (m *ReadMeta) SetSrc(a *overlay.OverlayAddr, raddr *net.UDPAddr, ot overlay.Type)

type Timespec

type Timespec C.struct_timespec