packetconn

Documentation

Index

• Constants
• func NewDialer(gro bool) *net.Dialer
• func NewListener(gro bool) *net.ListenConfig
• type UDPConnWrapper
  • func NewUDPConnWrapper(conn *net.UDPConn) *UDPConnWrapper
  • func (w *UDPConnWrapper) Close() (ret error)
  • func (c *UDPConnWrapper) ConsumeBuffer(ba *bufferio.BufferArray) error
  • func (c *UDPConnWrapper) ConsumeBufferWithAddr(ba *bufferio.BufferArray, addr *net.UDPAddr) error
  • func (c *UDPConnWrapper) ProduceBuffer(ba *bufferio.BufferArray, offset int) error
  • func (c *UDPConnWrapper) ProduceBufferWithAddr(ba *bufferio.BufferArray, offset int, addrs []net.Addr) error
  • func (*UDPConnWrapper) SupportBufferIO() bool

Constants

const (
	UDPIOBatchSize = 128
)

Functions

func NewDialer

func NewDialer(gro bool) *net.Dialer

func NewListener

func NewListener(gro bool) *net.ListenConfig

Types

type UDPConnWrapper

type UDPConnWrapper struct {
	*net.UDPConn
	// contains filtered or unexported fields
}

This class is not thread-safe. I/O requires sequential operation.

func NewUDPConnWrapper

func NewUDPConnWrapper(conn *net.UDPConn) *UDPConnWrapper

func (*UDPConnWrapper) Close

func (w *UDPConnWrapper) Close() (ret error)

func (*UDPConnWrapper) ConsumeBuffer

func (c *UDPConnWrapper) ConsumeBuffer(ba *bufferio.BufferArray) error

func (*UDPConnWrapper) ConsumeBufferWithAddr

func (c *UDPConnWrapper) ConsumeBufferWithAddr(ba *bufferio.BufferArray, addr *net.UDPAddr) error

func (*UDPConnWrapper) ProduceBuffer

func (c *UDPConnWrapper) ProduceBuffer(ba *bufferio.BufferArray, offset int) error

func (*UDPConnWrapper) ProduceBufferWithAddr

func (c *UDPConnWrapper) ProduceBufferWithAddr(ba *bufferio.BufferArray, offset int, addrs []net.Addr) error

func (*UDPConnWrapper) SupportBufferIO

func (*UDPConnWrapper) SupportBufferIO() bool