network

Sep 15, 2023

Changes in this version

+ func WithPacketListenerWriteIdleTimeout(timeout time.Duration) func(*PacketListenerProxy) error

+ type PacketListenerProxy struct

+ func (proxy *PacketListenerProxy) NewSession(respWriter PacketResponseReceiver) (PacketRequestSender, error)

Aug 7, 2023

Changes in this version

+ var ErrClosed = errors.New("network device already closed")

+ var ErrMsgSize = fmt.Errorf("packet size is too big: %w", syscall.EMSGSIZE)

+ var ErrPortUnreachable = errors.New("port is not reachable")

+ type DelegatePacketProxy interface

+ SetProxy func(proxy PacketProxy) error

+ func NewDelegatePacketProxy(proxy PacketProxy) (DelegatePacketProxy, error)

+ type IPDevice interface

+ Close func() error

+ MTU func() int

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

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

+ type PacketProxy interface

+ NewSession func(PacketResponseReceiver) (PacketRequestSender, error)

+ func NewPacketProxyFromPacketListener(pl transport.PacketListener) (PacketProxy, error)

+ type PacketRequestSender interface

+ Close func() error

+ WriteTo func(p []byte, destination netip.AddrPort) (int, error)

+ type PacketResponseReceiver interface

+ Close func() error

+ WriteFrom func(p []byte, source net.Addr) (int, error)