engine

package

Go to main page

Versions in this module

v1

v1.0.6

Jan 23, 2025

Changes in this version

+ const NatTypeFullCone

+ const NatTypeSymmetric

+ var DefaultLogWriter io.Writer = nil

+ func Log(msg string)

+ type NatPortMappingEntry struct

+ LanHostIpAddr uint32

+ LanHostPort uint16

+ WanIpAddr uint32

+ WanPort uint16

+ type NatPortMappingEntryConfig struct

+ LanHostIpAddr string

+ LanHostPort uint16

+ WanIpAddr string

+ WanPort uint16

+ type NatWanFlowHash struct

+ RemoteIpAddr uint32

+ RemotePort uint16

+ WanIpAddr uint32

+ WanPort uint16

type NetIf

+ NatPortMappingTable []*NatPortMappingEntry

+ NatType int

+ NatWanFlowTable map[NatWanFlowHash]*NatFlow

+ func (i *NetIf) SendFreeArp()

type NetIfConfig

+ NatPortMappingTable []*NatPortMappingEntryConfig

+ NatType int

v1.0.5

Jan 21, 2025

v1.0.4

Nov 21, 2024

v1.0.3

Jan 20, 2024

Changes in this version

+ const LanToWan

+ const WanToLan

+ type NatFlow struct

+ LanHostIpAddr uint32

+ LanHostPort uint16

+ LastAliveTime uint32

+ NatFlowHash NatFlowHash

+ RemoteIpAddr uint32

+ RemotePort uint16

+ WanIpAddr uint32

+ WanPort uint16

+ type NatFlowHash struct

+ LanHostIpAddr uint32

+ LanHostPort uint16

+ RemoteIpAddr uint32

+ RemotePort uint16

+ func (f NatFlowHash) String() string

+ type NatWan struct

+ RemoteIpAddr uint32

+ RemotePort uint16

+ WanIpAddr uint32

+ WanPort uint16

type NetIf

+ NatFlowTable map[NatFlowHash]*NatFlow

+ NatFlowWanTable map[NatWan]*NatFlow

+ func (i *NetIf) FindRoute(ipv4DstAddr []byte) (nextHopIpAddr []byte, outNetIfName string)

+ func (i *NetIf) NatAddFlow(ipv4SrcAddr []byte, ipv4DstAddr []byte, srcPort uint16, dstPort uint16) *NatFlow

+ func (i *NetIf) NatGetFlowByHash(natFlowHash NatFlowHash) *NatFlow

+ func (i *NetIf) NatGetFlowByWan(remoteIpAddr []byte, remotePort uint16, wanIpAddr []byte, wanPort uint16) *NatFlow

+ func (i *NetIf) SendUdpPktByFlow(natFlowHash NatFlowHash, dir int, udpPayload []byte)

v1.0.2

Nov 2, 2023

Changes in this version

type NetIf

+ NatPortAlloc map[uint32]*PortAlloc

+ NatPortAllocLock sync.RWMutex

+ func (i *NetIf) NatTableClear()

+ type PortAlloc struct

+ AllocPortMap map[SrcAddr]uint16

+ Lock sync.RWMutex

+ RemainPortMap map[uint16]struct{}

+ type SrcAddr struct

+ IpAddr uint32

+ Port uint16

v1.0.1

Aug 24, 2023

Changes in this version

type Config

+ NetIfList []*NetIfConfig

+ RoutingTable []*RoutingEntryConfig

type Engine

+ Ipv4PktFwdHook func(ipv4Pkt []byte) []byte

+ RoutingTable []*RoutingEntry

+ type InNatEntry struct

+ IpAddr uint32

+ LastAliveTime uint32

+ Port uint16

type NetIf

+ LoChan chan []byte

+ NatEnable bool

+ NatTable map[OutNatEntry]*InNatEntry

+ NatTableLock sync.RWMutex

+ func (i *NetIf) MacAddrToU(macAddr []byte) (macAddrU uint64)

+ func (i *NetIf) RxEthernet(ethFrm []byte)

+ func (i *NetIf) TxEthernet(ethPayload []byte, ethDstMac []byte, ethProto uint16) []byte

+ func (i *NetIf) UToMacAddr(macAddrU uint64) (macAddr []byte)

type NetIfConfig

+ NatEnable bool

+ type OutNatEntry struct

+ DstIpAddr uint32

+ DstPort uint16

+ SrcIpAddr uint32

+ SrcPort uint16

+ type RoutingEntry struct

+ DstIpAddr []byte

+ NetIf string

+ NetworkMask []byte

+ NextHop []byte

+ type RoutingEntryConfig struct

+ DstIpAddr string

+ NetIf string

+ NetworkMask string

+ NextHop string

v1.0.0

Aug 19, 2023

Changes in this version

+ var BROADCAST_MAC_ADDR = []byte

+ func ParseIpAddr(ipAddrStr string) ([]byte, error)

+ func ParseMacAddr(macAddrStr string) ([]byte, error)

+ type Config struct

+ DebugLog bool

+ NetIfConfigList []*NetIfConfig

+ type Engine struct

+ DebugLog bool

+ NetIfMap map[string]*NetIf

+ Stop bool

+ func InitEngine(config *Config) (*Engine, error)

+ func (e *Engine) GetNetIf(name string) *NetIf

+ func (e *Engine) RunEngine()

+ func (e *Engine) StopEngine()

+ type NetIf struct

+ ArpCacheTable map[uint32]uint64

+ ArpCacheTableLock sync.RWMutex

+ Engine *Engine

+ EthRxChan chan []byte

+ EthTxChan chan []byte

+ GatewayIpAddr []byte

+ HandleUdp func(udpPayload []byte, udpSrcPort uint16, udpDstPort uint16, ipv4SrcAddr []byte)

+ IpAddr []byte

+ MacAddr []byte

+ Name string

+ NetworkMask []byte

+ func (i *NetIf) ConvMacAddrToUint64(macAddr []byte) (macAddrUint64 uint64)

+ func (i *NetIf) ConvUint64ToMacAddr(macAddrUint64 uint64) (macAddr []byte)

+ func (i *NetIf) GetArpCache(ipAddr []byte) (macAddr []byte)

+ func (i *NetIf) HandleArp(ethPayload []byte, ethSrcMac []byte)

+ func (i *NetIf) NetworkStateCheck()

+ func (i *NetIf) PacketHandle()

+ func (i *NetIf) RxIcmp(ipv4Payload []byte, ipv4SrcAddr []byte)

+ func (i *NetIf) RxIpv4(ethPayload []byte)

+ func (i *NetIf) RxTcp()

+ func (i *NetIf) RxUdp(ipv4Payload []byte, ipv4SrcAddr []byte)

+ func (i *NetIf) SetArpCache(ipAddr []byte, macAddr []byte)

+ func (i *NetIf) TxIcmp(icmpPayload []byte, seq uint16, ipv4DstAddr []byte) []byte

+ func (i *NetIf) TxIpv4(ipv4Payload []byte, ipv4HeadProto uint8, ipv4DstAddr []byte) []byte

+ func (i *NetIf) TxTcpAck(tcpSrcPort uint16, tcpDstPort uint16, ipv4DstAddr []byte) []byte

+ func (i *NetIf) TxTcpSyn(tcpSrcPort uint16, tcpDstPort uint16, ipv4DstAddr []byte) []byte

+ func (i *NetIf) TxTcpSynAck(tcpSrcPort uint16, tcpDstPort uint16, ipv4DstAddr []byte) []byte

+ func (i *NetIf) TxUdp(udpPayload []byte, udpSrcPort uint16, udpDstPort uint16, ipv4DstAddr []byte) []byte

+ type NetIfConfig struct

+ EthRxChan chan []byte

+ EthTxChan chan []byte

+ GatewayIpAddr string

+ IpAddr string

+ MacAddr string

+ Name string

+ NetworkMask string

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