etherconn

Jun 5, 2023

Changes in this version

type RelayType

+ func (rt *RelayType) UnmarshalText(text []byte) error

+ func (rt RelayType) MarshalText() (text []byte, err error)

type VLANs

+ func (vlans *VLANs) UnmarshalText(text []byte) error

+ func (vlans VLANs) MarshalText() (text []byte, err error)

Apr 8, 2023

Changes in this version

+ func GetIfNameViaDesc(desc string) (string, error)

+ func SetPromisc(ifname string) error — linux/amd64

+ type AncillaryVLAN struct

+ VLAN int

type PacketRelay

+ Type func() RelayType

+ type PcapConn struct

+ func NewPcapConn(ifname string) (*PcapConn, error)

+ func (pconn *PcapConn) CloseMe()

type RawSocketRelay

+ func NewRawSocketRelayPcap(parentctx context.Context, ifname string, options ...RelayOption) (*RawSocketRelay, error)

+ func NewRawSocketRelayWithRelayConn(parentctx context.Context, ifname string, conn rawRelayConn, ...) (*RawSocketRelay, error)

+ func (rsr *RawSocketRelay) Type() RelayType

+ type RelayType string

+ const RelayTypeAFP

+ const RelayTypePCAP

+ const RelayTypeXDP

+ const UnknownRelay

type XDPRelay — linux/amd64

+ func (xr *XDPRelay) Type() RelayType

Dec 14, 2022

Changes in this version

type EtherConn

+ func (ec *EtherConn) GetEtherTypes() []uint16

type RelayReceival

+ LocalEndpoint *L2Endpoint

+ RemoteEndpoint *L2Endpoint

May 9, 2022

Changes in this version

+ type ChanMap struct

+ func NewChanMap() *ChanMap

+ func (cm *ChanMap) CloseAll()

+ func (cm *ChanMap) Del(k interface{})

+ func (cm *ChanMap) DelList(ks []interface{})

+ func (cm *ChanMap) Get(k interface{}) chan *RelayReceival

+ func (cm *ChanMap) GetList() []chan *RelayReceival

+ func (cm *ChanMap) Set(k interface{}, v chan *RelayReceival)

+ func (cm *ChanMap) SetList(ks []interface{}, v chan *RelayReceival)

+ type SharedEconn interface

+ Register func(k L4RecvKey) (torecvch chan *RelayReceival)

+ SetWriteDeadline func(t time.Time) error

+ WriteIPPktTo func(p []byte, dstmac net.HardwareAddr) (int, error)

type SharedEtherConn

+ func (sec *SharedEtherConn) SetWriteDeadline(t time.Time) error

Mar 15, 2022

Changes in this version

type XDPRelayOption

+ func WithXDPEtherTypes(ets []uint16) XDPRelayOption

Feb 25, 2022

Changes in this version

+ func SetIfVLANOffloading(ifname string, enable bool) error

type RelayPacketStats

+ RxDefault *uint64

Feb 4, 2022

Changes in this version

+ const DefaultTTL

+ const DefaultXDPChunkSize

+ func GetIFQueueNum(ifname string) (int, error)

+ type LogFunc func(fmt string, a ...interface{})

type RelayOption

+ func WithMultiEngine(count uint) RelayOption

type SharedEtherConnOption

+ func WithSharedEConnPerClntRecvChanDepth(depth uint) SharedEtherConnOption

type XDPRelay

+ func (xr *XDPRelay) NumSocket() int

type XDPRelayOption

+ func WithSendingMode(m XDPSendingMode) XDPRelayOption

+ func WithXDPExtProg(fname, prog, qmap, xskmap string) XDPRelayOption

+ func WithXDPPerClntRecvChanDepth(depth uint) XDPRelayOption

+ func WithXDPRXPktHandler(h XDPSocketPktHandler) XDPRelayOption

+ func WithXDPSendChanDepth(depth uint) XDPRelayOption

+ func WithXDPTXPktHandler(h XDPSocketPktHandler) XDPRelayOption

+ func WithXDPUMEMChunkSize(fsize uint) XDPRelayOption

+ type XDPSendingMode string

+ const XDPSendingModeBatch

+ const XDPSendingModeSingle

+ type XDPSocketPktHandler func(pbytes []byte, sockid int) error

+ type XdpSockStats struct

+ Recv uint64

+ Sent uint64

+ type XdpSockStatsList map[int]*XdpSockStats

+ func (list XdpSockStatsList) String() string

Jun 7, 2021

Changes in this version

+ const DefaultXDPUMEMNumOfTrunk

+ type L4RecvKey [19]byte

+ func NewL4RecvKeyViaUDPAddr(uaddr *net.UDPAddr) (r L4RecvKey)

+ func (l4k L4RecvKey) String() string

type PacketRelay

+ GetStats func() *RelayPacketStats

type RelayReceival

+ func (rr *RelayReceival) GetL4Key() (r L4RecvKey)

+ type SharedEtherConn struct

+ func NewSharedEtherConn(parentctx context.Context, mac net.HardwareAddr, relay PacketRelay, ...) *SharedEtherConn

+ func (sec *SharedEtherConn) Close()

+ func (sec *SharedEtherConn) Register(k L4RecvKey) (torecvch chan *RelayReceival)

+ func (sec *SharedEtherConn) RegisterList(keys []L4RecvKey) (torecvch chan *RelayReceival)

+ func (sec *SharedEtherConn) WriteIPPktTo(p []byte, dstmac net.HardwareAddr) (int, error)

+ func (sec *SharedEtherConn) WriteIPPktToFrom(p []byte, srcmac, dstmac net.HardwareAddr, vlans VLANs) (int, error)

+ func (sec *SharedEtherConn) WritePktTo(p []byte, etype uint16, dstmac net.HardwareAddr) (int, error)

+ func (sec *SharedEtherConn) WritePktToFrom(p []byte, etype uint16, srcmac, dstmac net.HardwareAddr, vlans VLANs) (int, error)

+ type SharedEtherConnOption func(sec *SharedEtherConn)

+ type SharingRUDPConn struct

+ func NewSharingRUDPConn(src string, c *SharedEtherConn, roptions []RUDPConnOption, ...) (*SharingRUDPConn, error)

+ func (sruc *SharingRUDPConn) Close() error

+ func (sruc *SharingRUDPConn) LocalAddr() net.Addr

+ func (sruc *SharingRUDPConn) ReadFrom(p []byte) (int, net.Addr, error)

+ func (sruc *SharingRUDPConn) SetDeadline(t time.Time) error

+ func (sruc *SharingRUDPConn) SetReadDeadline(t time.Time) error

+ func (sruc *SharingRUDPConn) SetWriteDeadline(t time.Time) error

+ func (sruc *SharingRUDPConn) WriteTo(p []byte, addr net.Addr) (int, error)

+ type SharingRUDPConnOptions func(srudpc *SharingRUDPConn)

+ type XDPRelay struct

+ func NewXDPRelay(parentctx context.Context, ifname string, options ...XDPRelayOption) (*XDPRelay, error)

+ func (xr *XDPRelay) Deregister(ks []L2EndpointKey)

+ func (xr *XDPRelay) GetStats() *RelayPacketStats

+ func (xr *XDPRelay) IfName() string

+ func (xr *XDPRelay) Register(ks []L2EndpointKey, recvMulticast bool) (chan *RelayReceival, chan []byte, chan struct{})

+ func (xr *XDPRelay) RegisterDefault() (chan *RelayReceival, chan []byte, chan struct{})

+ func (xr *XDPRelay) Stop()

+ type XDPRelayOption func(xr *XDPRelay)

+ func WithQueueID(qidlist []int) XDPRelayOption

+ func WithXDPDebug(debug bool) XDPRelayOption

+ func WithXDPDefaultReceival(mirroring bool) XDPRelayOption

+ func WithXDPMaxEtherFrameSize(fsize uint) XDPRelayOption

+ func WithXDPUMEMNumOfTrunk(num uint) XDPRelayOption

Feb 10, 2021

Changes in this version

+ const DefaultVLANEtype

+ var DefaultEtherTypes = []uint16

type EtherConn

+ func (ec *EtherConn) WriteIPPktToFrom(p []byte, srcmac, dstmac net.HardwareAddr, vlans VLANs) (int, error)

+ func (ec *EtherConn) WritePktToFrom(p []byte, etype uint16, srcmac, dstmac net.HardwareAddr, vlans VLANs) (int, error)

type EtherConnOption

+ func WithDefault() EtherConnOption

+ func WithEtherTypes(ets []uint16) EtherConnOption

type L2Endpoint

+ Etype uint16

+ func NewL2EndpointFromMACVLANEtype(mac net.HardwareAddr, vlans VLANs, etype uint16) *L2Endpoint

+ func (l2e *L2Endpoint) GetVLANsWithDefaultEtype() (r VLANs)

type PacketRelay

+ RegisterDefault func() (recv chan *RelayReceival, send chan []byte, stop chan struct{})

type RUDPConn

+ func (ruc *RUDPConn) WriteToFrom(p []byte, srcaddr, dstaddr net.Addr) (int, error)

type RawSocketRelay

+ func (rsr *RawSocketRelay) RegisterDefault() (chan *RelayReceival, chan []byte, chan struct{})

type RelayOption

+ func WithDefaultReceival(mirroring bool) RelayOption

Sep 11, 2020

Changes in this version

+ var ErrRelayStopped = fmt.Errorf("relay stopped")

type PacketRelay

+ IfName func() string

type RawSocketRelay

+ func (rsr *RawSocketRelay) IfName() string

Aug 17, 2020

Changes in this version

type EtherConnOption

+ func WithRecvMulticast(recv bool) EtherConnOption

type RelayOption

+ func WithBPFFilter(filter string) RelayOption

type RelayReceival

+ RemoteMAC net.HardwareAddr

Aug 9, 2020

Changes in this version

+ type VLANs []*VLAN

+ func (vlans *VLANs) Copy(vlans2 VLANs)

+ func (vlans VLANs) Clone() VLANs

+ func (vlans VLANs) Equal(vlans2 VLANs) bool

+ func (vlans VLANs) IDs() []uint16

+ func (vlans VLANs) SetIDs(ids []uint16) error

+ func (vlans VLANs) String() string

Aug 2, 2020

Changes in this version

+ const DefaultMaxEtherFrameSize

+ const DefaultPerClntRecvChanDepth

+ const DefaultRelayRecvTimeout

+ const DefaultSendChanDepth

+ const L2EndpointKeySize

+ const MaxNumVLAN

+ const NOVLANTAG

+ var BroadCastMAC = net.HardwareAddr

+ var ErrTimeOut = fmt.Errorf("timeout")

+ func ResolveNexhopMACWithBrodcast(ip net.IP) net.HardwareAddr

+ type EtherConn struct

+ func NewEtherConn(mac net.HardwareAddr, relay PacketRelay, options ...EtherConnOption) *EtherConn

+ func (ec *EtherConn) Close() error

+ func (ec *EtherConn) LocalAddr() *L2Endpoint

+ func (ec *EtherConn) ReadPkt() ([]byte, net.HardwareAddr, error)

+ func (ec *EtherConn) ReadPktFrom(p []byte) (int, net.HardwareAddr, error)

+ func (ec *EtherConn) SetDeadline(t time.Time) error

+ func (ec *EtherConn) SetReadDeadline(t time.Time) error

+ func (ec *EtherConn) SetWriteDeadline(t time.Time) error

+ func (ec *EtherConn) WriteIPPktTo(p []byte, dstmac net.HardwareAddr) (int, error)

+ func (ec *EtherConn) WritePktTo(p []byte, etype uint16, dstmac net.HardwareAddr) (int, error)

+ type EtherConnOption func(ec *EtherConn)

+ func WithRecvMulticasat(recv bool) EtherConnOption

+ func WithVLANs(vlans []*VLAN) EtherConnOption

+ type L2Endpoint struct

+ HwAddr net.HardwareAddr

+ VLANs []uint16

+ func NewL2EndpointFromMACVLAN(mac net.HardwareAddr, vlans []*VLAN) *L2Endpoint

+ func (l2e *L2Endpoint) GetKey() (key L2EndpointKey)

+ func (l2e *L2Endpoint) Network() string

+ func (l2e *L2Endpoint) String() (s string)

+ type L2EndpointKey [L2EndpointKeySize]byte

+ func (l2epkey L2EndpointKey) String() string

+ type PacketRelay interface

+ Deregister func(k L2EndpointKey)

+ Register func(k L2EndpointKey, recvMulticast bool) (recv chan *RelayReceival, send chan []byte)

+ Stop func()

+ type RUDPConn struct

+ func NewRUDPConn(src string, c *EtherConn, options ...RUDPConnOption) (*RUDPConn, error)

+ func (ruc *RUDPConn) Close() error

+ func (ruc *RUDPConn) LocalAddr() net.Addr

+ func (ruc *RUDPConn) ReadFrom(p []byte) (int, net.Addr, error)

+ func (ruc *RUDPConn) SetAddr(src *net.UDPAddr)

+ func (ruc *RUDPConn) SetDeadline(t time.Time) error

+ func (ruc *RUDPConn) SetReadDeadline(t time.Time) error

+ func (ruc *RUDPConn) SetWriteDeadline(t time.Time) error

+ func (ruc *RUDPConn) WriteTo(p []byte, addr net.Addr) (int, error)

+ type RUDPConnOption func(rudpc *RUDPConn)

+ func WithAcceptAny(accept bool) RUDPConnOption

+ func WithResolveNextHopMacFunc(f func(net.IP) net.HardwareAddr) RUDPConnOption

+ type RawSocketRelay struct

+ func NewRawSocketRelay(parentctx context.Context, ifname string, options ...RelayOption) (*RawSocketRelay, error)

+ func (rsr *RawSocketRelay) Deregister(k L2EndpointKey)

+ func (rsr *RawSocketRelay) GetStats() *RelayPacketStats

+ func (rsr *RawSocketRelay) Register(k L2EndpointKey, recvMulticast bool) (chan *RelayReceival, chan []byte)

+ func (rsr *RawSocketRelay) Stop()

+ type RelayOption func(*RawSocketRelay)

+ func WithDebug(debug bool) RelayOption

+ func WithEtherType(etypes []uint16) RelayOption

+ func WithMaxEtherFrameSize(size uint) RelayOption

+ func WithPerClntChanRecvDepth(depth uint) RelayOption

+ func WithRecvTimeout(t time.Duration) RelayOption

+ func WithSendChanDepth(depth uint) RelayOption

+ type RelayPacketStats struct

+ Rx *uint64

+ RxBufferFull *uint64

+ RxInvalid *uint64

+ RxMiss *uint64

+ RxMulticastIgnored *uint64

+ RxNonHitMulticast *uint64

+ RxOffered *uint64

+ Tx *uint64

+ func (rps RelayPacketStats) String() string

+ type RelayReceival struct

+ EtherBytes []byte

+ EtherPayloadBytes []byte

+ LocalIP net.IP

+ LocalPort uint16

+ Protocol uint8

+ RemoteIP net.IP

+ RemoteL2EP *L2Endpoint

+ RemotePort uint16

+ TransportPayloadBytes []byte

+ type VLAN struct

+ EtherType uint16

+ ID uint16