loxinet

package

Go to main page

Versions in this module

v0

v0.9.8

Jan 27, 2025

Changes in this version

+ const ClusterNetID

+ const MaxSrcLBMarkerNum

+ const NatFwMark

+ const OnDfltSnatFwMark

+ const SrcChkFwMark

+ func FindSysOifForHost(host string) string

type CIKAArgs

+ CDev string

+ CSubnet string

+ CSubnet6 string

type CIStateH

+ ClusterGw string

+ ClusterGw6 string

+ ClusterIf string

+ ClusterNet string

+ ClusterNet6 string

+ OGw []string

+ OGw6 []string

+ OSrc string

+ OSrc6 string

+ func (ci *CIStateH) CIDestroy()

+ func (h *CIStateH) CIAddClusterRoute(dest string, add bool)

type ClusterNode

+ Egress bool

type DpCtInfo

+ IdType uint32

+ Ident uint32

+ L4ServPortMax uint16

type FwDpWorkQ

+ OnDflt bool

type LBDpWorkQ

+ Ppv2En bool

+ SrcCheck bool

type NatSel

+ const EpN3

type NatT

+ const DpNat

type NeighKey

+ Link int

type NetAPIStruct

+ func (na *NetAPIStruct) NetUserAdd(param *cmn.User) (int, error)

+ func (na *NetAPIStruct) NetUserDel(ID int) error

+ func (na *NetAPIStruct) NetUserGet() ([]cmn.User, error)

+ func (na *NetAPIStruct) NetUserLogin(param *cmn.User) (string, bool, error)

+ func (na *NetAPIStruct) NetUserLogout(tokenString string) error

+ func (na *NetAPIStruct) NetUserUpdate(param *cmn.User) error

+ func (na *NetAPIStruct) NetUserValidate(token string) (interface{}, error)

type RuleH

+ func (R *RuleH) AdvRuleVIP(IP net.IP, eIP net.IP, inst string, egress bool) error

+ func (R *RuleH) RulesSyncToClusterState(inst, ciStateStr string)

v0.9.7

Oct 25, 2024

Changes in this version

+ const MaxLBEndPoints

+ func DpLBRuleMod(w *LBDpWorkQ) int — linux/amd64

+ func NcloudApiInit() error

+ type AWSAPIStruct struct

+ func AWSCloudHookNew() *AWSAPIStruct

+ func (aws *AWSAPIStruct) CloudAPIInit(cloudCIDRBlock string) error

+ func (aws *AWSAPIStruct) CloudDestroyVIPNetWork() error

+ func (aws *AWSAPIStruct) CloudPrepareVIPNetWork() error

+ func (aws *AWSAPIStruct) CloudUnPrepareVIPNetWork() error

+ func (aws *AWSAPIStruct) CloudUpdatePrivateIP(vIP net.IP, eIP net.IP, add bool) error

+ type CloudHookInterface interface

+ CloudAPIInit func(cloudCIDRBlock string) error

+ CloudDestroyVIPNetWork func() error

+ CloudPrepareVIPNetWork func() error

+ CloudUnPrepareVIPNetWork func() error

+ CloudUpdatePrivateIP func(vIP net.IP, eIP net.IP, add bool) error

+ func CloudHookNew(cloudLabel string) CloudHookInterface

type DpEbpfH — linux/amd64

+ func (e *DpEbpfH) DpLBRuleAdd(w *LBDpWorkQ) int

+ func (e *DpEbpfH) DpLBRuleDel(w *LBDpWorkQ) int

type DpHookInterface

+ DpLBRuleAdd func(*LBDpWorkQ) int

+ DpLBRuleDel func(*LBDpWorkQ) int

type Ifa

+ Addr [6]byte

+ type LBDpWorkQ struct

+ BlockNum uint16

+ CsumDis bool

+ DsrMode bool

+ EpSel NatSel

+ HostURL string

+ InActTo uint64

+ L4Port uint16

+ Mark int

+ NatType NatT

+ PersistTo uint64

+ Proto uint8

+ SecMode SecT

+ ServiceIP net.IP

+ Status *DpStatusT

+ Work DpWorkT

+ ZoneNum int

+ type NcloudClient struct

+ func (n *NcloudClient) NcloudCreatePrivateIp(ni string, vIP net.IP) error

+ func (n *NcloudClient) NcloudDeletePrivateIp(ni string, vIP net.IP) error

+ func (n *NcloudClient) NcloudGetMetadataInterfaceID() (string, error)

+ func (n *NcloudClient) NcloudUpdatePrivateIp(vIP net.IP, add bool) error

+ type NcloudConfig struct

+ AccessKey string

+ SecretKey string

type RuleH

+ func (R *RuleH) AddLbRule(serv cmn.LbServiceArg, servSecIPs []cmn.LbSecIPArg, ...) (int, error)

+ func (R *RuleH) AddRuleVIP(VIP net.IP, pVIP net.IP)

+ func (R *RuleH) DeleteLbRule(serv cmn.LbServiceArg) (int, error)

+ func (R *RuleH) DeleteRuleVIP(VIP net.IP)

+ func (R *RuleH) GetLBRule() ([]cmn.LbRuleMod, error)

+ func (R *RuleH) GetLBRuleByID(ruleID uint32) *ruleEnt

+ func (R *RuleH) GetLBRuleByServArgs(serv cmn.LbServiceArg) *ruleEnt

+ func (R *RuleH) GetLBRuleSecIPs(serv cmn.LbServiceArg) []string

+ type SecT uint8

+ const DpE2EHTTPS

+ const DpTermHTTPS

v0.9.6

Aug 5, 2024

Changes in this version

type NatDpWorkQ

+ HostURL string

+ TermHTTPS bool

v0.9.5

Jul 15, 2024

Changes in this version

type L3H

+ func (l3 *L3H) IfasTicker()

type NatDpWorkQ

+ TermHTTPs bool

type NatSel

+ const EpN2

type NetAPIStruct

+ func (na *NetAPIStruct) NetGoBGPPolicyApplyDel(param *cmn.GoBGPPolicyApply) (int, error)

type RouteDpWorkQ

+ NMax int

type Rt

+ func (rt *Rt) RtNhMarkString() string

v0.9.4

Jun 8, 2024

Changes in this version

+ const RtActFullProxy

type GoBgpH

+ func (gbh *GoBgpH) AddPolicyDefinedSets(df cmn.GoBGPPolicyDefinedSetMod) (int, error)

+ func (gbh *GoBgpH) AddPolicyDefinitions(name string, stmt []cmn.Statement) (int, error)

+ func (gbh *GoBgpH) BGPApplyPolicyToNeighbor(cmdType, neigh string, polType string, policies []string, routeAction string) (int, error)

+ func (gbh *GoBgpH) DelPolicyDefinedSets(Name string, DefinedTypeString string) (int, error)

+ func (gbh *GoBgpH) DelPolicyDefinitions(name string) (int, error)

+ func (gbh *GoBgpH) GetActionRoute(route api.RouteAction) string

+ func (gbh *GoBgpH) GetCommunityActionType(name string) api.CommunityAction_Type

+ func (gbh *GoBgpH) GetMatchSetType(name string) api.MatchSet_Type

+ func (gbh *GoBgpH) GetPolicy(name string) (*api.Policy, error)

+ func (gbh *GoBgpH) GetPolicyDefinedSet(name string, DefinedTypeString string) ([]cmn.GoBGPPolicyDefinedSetMod, error)

+ func (gbh *GoBgpH) GetPolicyDefinitions() ([]cmn.GoBGPPolicyDefinitionsMod, error)

+ func (gbh *GoBgpH) GetRouteAction(name string) api.RouteAction

+ func (gbh *GoBgpH) GetTypeCommunityAction(CommunityActionType api.CommunityAction_Type) string

+ func (gbh *GoBgpH) GetTypeMatchSet(matchSet api.MatchSet_Type) string

+ func (gbh *GoBgpH) MakePrefixDefinedSet(prefixList []cmn.Prefix) ([]*api.Prefix, error)

type NatT

+ const DpFullProxy

type NetAPIStruct

+ func (na *NetAPIStruct) NetGoBGPPolicyApplyAdd(param *cmn.GoBGPPolicyApply) (int, error)

+ func (na *NetAPIStruct) NetGoBGPPolicyDefinedSetAdd(param *cmn.GoBGPPolicyDefinedSetMod) (int, error)

+ func (na *NetAPIStruct) NetGoBGPPolicyDefinedSetDel(param *cmn.GoBGPPolicyDefinedSetMod) (int, error)

+ func (na *NetAPIStruct) NetGoBGPPolicyDefinedSetGet(name string, DefinedTypeString string) ([]cmn.GoBGPPolicyDefinedSetMod, error)

+ func (na *NetAPIStruct) NetGoBGPPolicyDefinitionAdd(param *cmn.GoBGPPolicyDefinitionsMod) (int, error)

+ func (na *NetAPIStruct) NetGoBGPPolicyDefinitionDel(param *cmn.GoBGPPolicyDefinitionsMod) (int, error)

+ func (na *NetAPIStruct) NetGoBGPPolicyDefinitionsGet() ([]cmn.GoBGPPolicyDefinitionsMod, error)

v0.9.3

Apr 26, 2024

Changes in this version

+ const DefaultPersistTimeOut

type NatDpWorkQ

+ PersistTo uint64

v0.9.2

Apr 18, 2024

Changes in this version

+ const BGPConnected

+ const BGPDisconnected

+ const BondIDB

+ const BpfFsCheckFile

+ const CIErrBase

+ const CIModErr

+ const CIStateErr

+ const DflHostProbeTimeout

+ const DflLbaCheckTimeout

+ const DflLbaInactiveTries

+ const DflPolBlkSz

+ const DpErrBase

+ const DpTiVal

+ const DpWorkQLen

+ const DpWqUnkErr

+ const EBPF_ERR_BASE — windows/amd64

+ const EbpfErrBase — linux/amd64

+ const EbpfErrCtAdd — linux/amd64

+ const EbpfErrCtDel — linux/amd64

+ const EbpfErrEbpfLoad — linux/amd64

+ const EbpfErrEbpfUnload — linux/amd64

+ const EbpfErrFwAdd — linux/amd64

+ const EbpfErrFwDel — linux/amd64

+ const EbpfErrL2AddrAdd — linux/amd64

+ const EbpfErrL2AddrDel — linux/amd64

+ const EbpfErrMirrAdd — linux/amd64

+ const EbpfErrMirrDel — linux/amd64

+ const EbpfErrNat4Add — linux/amd64

+ const EbpfErrNat4Del — linux/amd64

+ const EbpfErrNhAdd — linux/amd64

+ const EbpfErrNhDel — linux/amd64

+ const EbpfErrPolAdd — linux/amd64

+ const EbpfErrPolDel — linux/amd64

+ const EbpfErrPortPropAdd — linux/amd64

+ const EbpfErrPortPropDel — linux/amd64

+ const EbpfErrRt4Add — linux/amd64

+ const EbpfErrRt4Del — linux/amd64

+ const EbpfErrSess4Add — linux/amd64

+ const EbpfErrSess4Del — linux/amd64

+ const EbpfErrSockVIPAdd — linux/amd64

+ const EbpfErrSockVIPDel — linux/amd64

+ const EbpfErrSockVIPMod — linux/amd64

+ const EbpfErrTmacAdd — linux/amd64

+ const EbpfErrTmacDel — linux/amd64

+ const EbpfErrWqUnk — linux/amd64

+ const EndPointCheckerDuration

+ const FdbGts

+ const GoBGPInitTiVal

+ const HostProbeConnectSCTP

+ const HostProbeConnectTCP

+ const HostProbeConnectUDP

+ const HostProbeHTTP

+ const HostProbeHTTPS

+ const HostProbeNone

+ const HostProbePing

+ const InitHostProbeTimeout

+ const KAInitTiVal

+ const L2ErrBase

+ const L2NoFdbErr

+ const L2OifErr

+ const L2SameFdbErr

+ const L2VxattrErr

+ const L3AddrErr

+ const L3ErrBase

+ const L3ObjErr

+ const LbDefaultInactiveNSTimeout

+ const LbDefaultInactiveTimeout

+ const LbMaxInactiveTimeout

+ const LoxinetTiVal

+ const MapNameBD

+ const MapNameCt4

+ const MapNameCt6

+ const MapNameFw4

+ const MapNameIpol

+ const MapNameNat4

+ const MapNameRt4

+ const MapNameRxBD

+ const MapNameTxBD

+ const MapNameULCL

+ const MaxBondInterfaces

+ const MaxDflLbaInactiveTries

+ const MaxEndPointCheckers

+ const MaxEndPointSweeps

+ const MaxHostProbeTime

+ const MaxInterfaces

+ const MaxMirrors

+ const MaxNatEndPoints

+ const MaxPols

+ const MaxRealInterfaces

+ const MaxSysNeigh

+ const MaxSysRoutes

+ const MaxTunnelNeigh

+ const MaxVtiInterfaces

+ const MaxWgInterfaces

+ const MaximumUlCls

+ const MaximumVlans

+ const MaximumZones

+ const MinPolRate

+ const MirrAllocErr

+ const MirrAttachErr

+ const MirrErrBase

+ const MirrExistsErr

+ const MirrInfoErr

+ const MirrModErr

+ const MirrNoExistErr

+ const MkMountCG2

+ const MkfsScript

+ const NeighAts

+ const NeighErrBase

+ const NeighExistsErr

+ const NeighHostRtErr

+ const NeighMacErr

+ const NeighNoEntErr

+ const NeighOifErr

+ const NeighRangeErr

+ const NeighRslvdAts

+ const NeighTunErr

+ const PolAllocErr

+ const PolAttachErr

+ const PolErrBase

+ const PolExistsErr

+ const PolInfoErr

+ const PolModErr

+ const PolNoExistErr

+ const PortBaseErr

+ const PortCounterErr

+ const PortExistsErr

+ const PortMapErr

+ const PortNoMasterErr

+ const PortNoRealDevErr

+ const PortNotExistErr

+ const PortPropExistsErr

+ const PortPropNotExistsErr

+ const PortZoneErr

+ const RPCTypeGRPC

+ const RPCTypeNetRPC

+ const RealPortIDB

+ const RmInL2Dst

+ const RmInL2Src

+ const RmInL3Dst

+ const RmInL3Src

+ const RmInL4Dst

+ const RmInL4Port

+ const RmInL4Src

+ const RmL2Dst

+ const RmL2Src

+ const RmL3Dst

+ const RmL3Src

+ const RmL4Dst

+ const RmL4Prot

+ const RmL4Src

+ const RmMax

+ const RmPort

+ const RmVlanID

+ const RootZone

+ const RtActDnat

+ const RtActDrop

+ const RtActFullNat

+ const RtActFwd

+ const RtActRedirect

+ const RtActSnat

+ const RtActTrap

+ const RtEm

+ const RtErrBase

+ const RtExistsErr

+ const RtFw

+ const RtLB

+ const RtMax

+ const RtMaximumFw4s

+ const RtMaximumLbs

+ const RtMf

+ const RtModErr

+ const RtNhErr

+ const RtNoEntErr

+ const RtRangeErr

+ const RtTrieAddErr

+ const RtTrieDelErr

+ const RtTypeDyn

+ const RtTypeHost

+ const RtTypeInd

+ const RtTypeIntf

+ const RtTypeSelf

+ const RuleAllocErr

+ const RuleArgsErr

+ const RuleEpCountErr

+ const RuleEpNotExistErr

+ const RuleErrBase

+ const RuleExistsErr

+ const RuleNotExistsErr

+ const RuleTupleErr

+ const RuleUnknownEpErr

+ const RuleUnknownServiceErr

+ const SessErrBase

+ const SessExistsErr

+ const SessModErr

+ const SessNoExistErr

+ const SessUlClExistErr

+ const SessUlClNoExistErr

+ const SessUlClNumErr

+ const VIPSweepDuration

+ const VlaNotExistErr

+ const VlanAddBrpErr

+ const VlanBaseErr

+ const VlanExistsErr

+ const VlanMpExistErr

+ const VlanNoPortErr

+ const VlanPortCreateErr

+ const VlanPortExistErr

+ const VlanPortPhyErr

+ const VlanPortTaggedErr

+ const VlanRangeErr

+ const VlanZoneErr

+ const VtIDB

+ const WgIDB

+ const XSyncPort

+ const ZoneBaseErr

+ const ZoneExistsErr

+ const ZoneNotExistErr

+ const ZoneNumberErr

+ var File_loxinet_xsync_proto protoreflect.FileDescriptor

+ var XSync_ServiceDesc = grpc.ServiceDesc

+ func DpEbpfDPLogLevel(cfg *C.struct_ebpfcfg, debug tk.LogLevelT) — linux/amd64

+ func DpEbpfSetLogLevel(logLevel tk.LogLevelT) — linux/amd64

+ func DpL2AddrMod(w *L2AddrDpWorkQ) int — linux/amd64

+ func DpNatLbRuleMod(w *NatDpWorkQ) int — linux/amd64

+ func DpNextHopMod(w *NextHopDpWorkQ) int — linux/amd64

+ func DpRouteMod(w *RouteDpWorkQ) int — linux/amd64

+ func DpRouterMacMod(w *RouterMacDpWorkQ) int — linux/amd64

+ func DpWorker(dp *DpH, f chan int, ch chan interface{})

+ func FormatTimedelta(t time.Time) string

+ func GetFlagToString(flag int) string

+ func Ifa2String(ifa *Ifa, it IterIntf)

+ func IfaMkString(ifa *Ifa, v4 bool) string

+ func IsLoxiAPIActive(url string) bool

+ func LogString2Level(logStr string) tk.LogLevelT

+ func LoxiXsyncMain(mode string)

+ func Main()

+ func MirrInfoCmp(mInfo1, mInfo2 *cmn.MirrInfo) bool

+ func MirrInfoValidate(mInfo *cmn.MirrInfo) bool

+ func MirrObjValidate(mObj *cmn.MirrObj) bool

+ func Neigh2String(ne *Neigh, it IterIntf)

+ func PolInfoXlateValidate(pInfo *cmn.PolInfo) bool

+ func PolObjValidate(pObj *cmn.PolObj) bool

+ func RegisterXSyncServer(s grpc.ServiceRegistrar, srv XSyncServer)

+ func Rt2String(rt *Rt) string

+ func RunCommand(command string, isFatal bool) (int, error)

+ func TestLoxinet(t *testing.T)

+ func Us2String(us *UserSess) string

+ func VlanValid(vlanID int) bool

+ type BlockCtInfoMod struct

+ Add bool

+ Ct []*CtInfo

+ func (*BlockCtInfoMod) Descriptor() ([]byte, []int)

+ func (*BlockCtInfoMod) ProtoMessage()

+ func (x *BlockCtInfoMod) GetAdd() bool

+ func (x *BlockCtInfoMod) GetCt() []*CtInfo

+ func (x *BlockCtInfoMod) ProtoReflect() protoreflect.Message

+ func (x *BlockCtInfoMod) Reset()

+ func (x *BlockCtInfoMod) String() string

+ type CIKAArgs struct

+ Interval int64

+ RemoteIP net.IP

+ SourceIP net.IP

+ SpawnKa bool

+ func KAString2Mode(kaStr string) CIKAArgs

+ type CIStateH struct

+ Bs *bfd.Struct

+ ClusterMap map[string]*ClusterInstance

+ Interval int64

+ NodeMap map[string]*ClusterNode

+ RemoteIP net.IP

+ SourceIP net.IP

+ SpawnKa bool

+ StateMap map[string]int

+ func CIInit(args CIKAArgs) *CIStateH

+ func (ci *CIStateH) BFDSessionNotify(instance string, remote string, ciState string)

+ func (ci *CIStateH) CISpawn()

+ func (h *CIStateH) CIBFDSessionAdd(bm cmn.BFDMod) (int, error)

+ func (h *CIStateH) CIBFDSessionDel(bm cmn.BFDMod) (int, error)

+ func (h *CIStateH) CIBFDSessionGet() ([]cmn.BFDMod, error)

+ func (h *CIStateH) CIStateGet() ([]cmn.HASMod, error)

+ func (h *CIStateH) CIStateGetInst(inst string) (string, error)

+ func (h *CIStateH) CIStateUpdate(cm cmn.HASMod) (int, error)

+ func (h *CIStateH) CITicker()

+ func (h *CIStateH) CIVipGet(inst string) (net.IP, error)

+ func (h *CIStateH) ClusterNodeAdd(node cmn.ClusterNodeMod) (int, error)

+ func (h *CIStateH) ClusterNodeDelete(node cmn.ClusterNodeMod) (int, error)

+ func (h *CIStateH) IsCIKAMode() bool

+ type ClusterInstance struct

+ State int

+ StateStr string

+ Vip net.IP

+ type ClusterNode struct

+ Addr net.IP

+ Status DpStatusT

+ func (cn *ClusterNode) DP(work DpWorkT) int

+ type ConnGet struct

+ Async int32

+ func (*ConnGet) Descriptor() ([]byte, []int)

+ func (*ConnGet) ProtoMessage()

+ func (x *ConnGet) GetAsync() int32

+ func (x *ConnGet) ProtoReflect() protoreflect.Message

+ func (x *ConnGet) Reset()

+ func (x *ConnGet) String() string

+ type CtInfo struct

+ Blocknum int32

+ Bytes int64

+ Cact string

+ Ci string

+ Cstate string

+ Deleted int32

+ Dip []byte

+ Dport int32

+ L4Servport int32

+ Packets int64

+ Pkey []byte

+ Proto string

+ Pval []byte

+ Serviceip []byte

+ Servproto string

+ Sip []byte

+ Sport int32

+ Xsync bool

+ func (*CtInfo) Descriptor() ([]byte, []int)

+ func (*CtInfo) ProtoMessage()

+ func (ci *CtInfo) ConvertToDpCtInfo() DpCtInfo

+ func (x *CtInfo) GetBlocknum() int32

+ func (x *CtInfo) GetBytes() int64

+ func (x *CtInfo) GetCact() string

+ func (x *CtInfo) GetCi() string

+ func (x *CtInfo) GetCstate() string

+ func (x *CtInfo) GetDeleted() int32

+ func (x *CtInfo) GetDip() []byte

+ func (x *CtInfo) GetDport() int32

+ func (x *CtInfo) GetL4Servport() int32

+ func (x *CtInfo) GetPackets() int64

+ func (x *CtInfo) GetPkey() []byte

+ func (x *CtInfo) GetProto() string

+ func (x *CtInfo) GetPval() []byte

+ func (x *CtInfo) GetServiceip() []byte

+ func (x *CtInfo) GetServproto() string

+ func (x *CtInfo) GetSip() []byte

+ func (x *CtInfo) GetSport() int32

+ func (x *CtInfo) GetXsync() bool

+ func (x *CtInfo) ProtoReflect() protoreflect.Message

+ func (x *CtInfo) Reset()

+ func (x *CtInfo) String() string

+ type CtInfoMod struct

+ Add bool

+ Ct *CtInfo

+ func (*CtInfoMod) Descriptor() ([]byte, []int)

+ func (*CtInfoMod) ProtoMessage()

+ func (x *CtInfoMod) GetAdd() bool

+ func (x *CtInfoMod) GetCt() *CtInfo

+ func (x *CtInfoMod) ProtoReflect() protoreflect.Message

+ func (x *CtInfoMod) Reset()

+ func (x *CtInfoMod) String() string

+ type DpCtInfo struct

+ BlockNum uint16

+ Bytes uint64

+ CAct string

+ CI string

+ CState string

+ DIP net.IP

+ Deleted int

+ Dport uint16

+ L4ServPort uint16

+ LTs time.Time

+ NTs time.Time

+ PKey []byte

+ PVal []byte

+ Packets uint64

+ Proto string

+ RuleID uint32

+ SIP net.IP

+ ServProto string

+ ServiceIP net.IP

+ Sport uint16

+ XSync bool

+ func (ci *DpCtInfo) ConvertToCtInfo(c *CtInfo)

+ func (ct *DpCtInfo) Key() string

+ func (ct *DpCtInfo) KeyState() string

+ func (ct *DpCtInfo) String() string

+ type DpEbpfH struct — linux/amd64

+ CtSync bool

+ RssEn bool

+ ToFinCh [mapNotifierWorkers]chan int

+ ToMapCh chan interface{}

+ func DpEbpfInit(clusterEn, rssEn, egrHooks, localVIP bool, nodeNum int, logLevel tk.LogLevelT) *DpEbpfH

+ func (e *DpEbpfH) DpCtAdd(w *DpCtInfo) int

+ func (e *DpEbpfH) DpCtDel(w *DpCtInfo) int

+ func (e *DpEbpfH) DpCtGetAsync()

+ func (e *DpEbpfH) DpEbpfUnInit()

+ func (e *DpEbpfH) DpFwRuleAdd(w *FwDpWorkQ) int

+ func (e *DpEbpfH) DpFwRuleDel(w *FwDpWorkQ) int

+ func (e *DpEbpfH) DpFwRuleMod(w *FwDpWorkQ) int

+ func (e *DpEbpfH) DpGetLock()

+ func (e *DpEbpfH) DpL2AddrAdd(w *L2AddrDpWorkQ) int

+ func (e *DpEbpfH) DpL2AddrDel(w *L2AddrDpWorkQ) int

+ func (e *DpEbpfH) DpMirrAdd(w *MirrDpWorkQ) int

+ func (e *DpEbpfH) DpMirrDel(w *MirrDpWorkQ) int

+ func (e *DpEbpfH) DpMirrMod(w *MirrDpWorkQ) int

+ func (e *DpEbpfH) DpNatLbRuleAdd(w *NatDpWorkQ) int

+ func (e *DpEbpfH) DpNatLbRuleDel(w *NatDpWorkQ) int

+ func (e *DpEbpfH) DpNextHopAdd(w *NextHopDpWorkQ) int

+ func (e *DpEbpfH) DpNextHopDel(w *NextHopDpWorkQ) int

+ func (e *DpEbpfH) DpPolAdd(w *PolDpWorkQ) int

+ func (e *DpEbpfH) DpPolDel(w *PolDpWorkQ) int

+ func (e *DpEbpfH) DpPolMod(w *PolDpWorkQ) int

+ func (e *DpEbpfH) DpPortPropAdd(w *PortDpWorkQ) int

+ func (e *DpEbpfH) DpPortPropDel(w *PortDpWorkQ) int

+ func (e *DpEbpfH) DpPortPropMod(w *PortDpWorkQ) int

+ func (e *DpEbpfH) DpRelLock()

+ func (e *DpEbpfH) DpRouteAdd(w *RouteDpWorkQ) int

+ func (e *DpEbpfH) DpRouteDel(w *RouteDpWorkQ) int

+ func (e *DpEbpfH) DpRouterMacAdd(w *RouterMacDpWorkQ) int

+ func (e *DpEbpfH) DpRouterMacDel(w *RouterMacDpWorkQ) int

+ func (e *DpEbpfH) DpSockVIPAdd(w *SockVIPDpWorkQ) int

+ func (e *DpEbpfH) DpSockVIPDel(w *SockVIPDpWorkQ) int

+ func (e *DpEbpfH) DpSockVIPMod(w *SockVIPDpWorkQ) int

+ func (e *DpEbpfH) DpStat(w *StatDpWorkQ) int

+ func (e *DpEbpfH) DpTableGC()

+ func (e *DpEbpfH) DpTableGet(w *TableDpWorkQ) (DpRetT, error)

+ func (e *DpEbpfH) DpUlClAdd(w *UlClDpWorkQ) int

+ func (e *DpEbpfH) DpUlClDel(w *UlClDpWorkQ) int

+ func (e *DpEbpfH) DpUlClMod(w *UlClDpWorkQ) int

+ type DpEbpfH struct — windows/amd64

+ func DpEbpfInit() *DpEbpfH

+ type DpH struct

+ DpHooks DpHookInterface

+ FromDpCh chan interface{}

+ Peers []DpPeer

+ RPC *XSync

+ Remotes []XSync

+ SyncMtx sync.RWMutex

+ ToDpCh chan interface{}

+ ToFinCh chan int

+ func DpBrokerInit(dph DpHookInterface, rpcMode int) *DpH

+ func (dp *DpH) DpMapGetCt4() []cmn.CtInfo

+ func (dp *DpH) DpWorkOnFw(fWq *FwDpWorkQ) DpRetT

+ func (dp *DpH) DpWorkOnL2Addr(pWq *L2AddrDpWorkQ) DpRetT

+ func (dp *DpH) DpWorkOnMirr(mWq *MirrDpWorkQ) DpRetT

+ func (dp *DpH) DpWorkOnNatLb(nWq *NatDpWorkQ) DpRetT

+ func (dp *DpH) DpWorkOnNextHop(nhWq *NextHopDpWorkQ) DpRetT

+ func (dp *DpH) DpWorkOnPeerOp(pWq *PeerDpWorkQ) DpRetT

+ func (dp *DpH) DpWorkOnPol(pWq *PolDpWorkQ) DpRetT

+ func (dp *DpH) DpWorkOnPort(pWq *PortDpWorkQ) DpRetT

+ func (dp *DpH) DpWorkOnRoute(rtWq *RouteDpWorkQ) DpRetT

+ func (dp *DpH) DpWorkOnRtMac(rmWq *RouterMacDpWorkQ) DpRetT

+ func (dp *DpH) DpWorkOnSockVIP(vsWq *SockVIPDpWorkQ) DpRetT

+ func (dp *DpH) DpWorkOnStat(nWq *StatDpWorkQ) DpRetT

+ func (dp *DpH) DpWorkOnTableOp(nWq *TableDpWorkQ) (DpRetT, error)

+ func (dp *DpH) DpWorkOnUlCl(nWq *UlClDpWorkQ) DpRetT

+ func (dp *DpH) DpXsyncInSync() bool

+ func (dp *DpH) DpXsyncRPC(op DpSyncOpT, arg interface{}) int

+ func (dp *DpH) DpXsyncRPCReset() int

+ func (dp *DpH) WaitXsyncReady(who string)

+ type DpHookInterface interface

+ DpCtAdd func(w *DpCtInfo) int

+ DpCtDel func(w *DpCtInfo) int

+ DpCtGetAsync func()

+ DpEbpfUnInit func()

+ DpFwRuleAdd func(w *FwDpWorkQ) int

+ DpFwRuleDel func(w *FwDpWorkQ) int

+ DpGetLock func()

+ DpL2AddrAdd func(*L2AddrDpWorkQ) int

+ DpL2AddrDel func(*L2AddrDpWorkQ) int

+ DpMirrAdd func(*MirrDpWorkQ) int

+ DpMirrDel func(*MirrDpWorkQ) int

+ DpNatLbRuleAdd func(*NatDpWorkQ) int

+ DpNatLbRuleDel func(*NatDpWorkQ) int

+ DpNextHopAdd func(*NextHopDpWorkQ) int

+ DpNextHopDel func(*NextHopDpWorkQ) int

+ DpPolAdd func(*PolDpWorkQ) int

+ DpPolDel func(*PolDpWorkQ) int

+ DpPortPropAdd func(*PortDpWorkQ) int

+ DpPortPropDel func(*PortDpWorkQ) int

+ DpRelLock func()

+ DpRouteAdd func(*RouteDpWorkQ) int

+ DpRouteDel func(*RouteDpWorkQ) int

+ DpRouterMacAdd func(*RouterMacDpWorkQ) int

+ DpRouterMacDel func(*RouterMacDpWorkQ) int

+ DpSockVIPAdd func(w *SockVIPDpWorkQ) int

+ DpSockVIPDel func(w *SockVIPDpWorkQ) int

+ DpStat func(*StatDpWorkQ) int

+ DpTableGC func()

+ DpTableGet func(w *TableDpWorkQ) (DpRetT, error)

+ DpUlClAdd func(w *UlClDpWorkQ) int

+ DpUlClDel func(w *UlClDpWorkQ) int

+ type DpPeer struct

+ Client interface{}

+ Peer net.IP

+ type DpRetT interface

+ func DpWorkSingle(dp *DpH, m interface{}) DpRetT

+ type DpStatusT uint8

+ const DpChangeErr

+ const DpCreateErr

+ const DpInProgressErr

+ const DpRemoveErr

+ const DpUknownErr

+ type DpSyncOpT uint8

+ const DpSyncAdd

+ const DpSyncBcast

+ const DpSyncDelete

+ const DpSyncGet

+ type DpTunT uint8

+ const DpTunGre

+ const DpTunGtp

+ const DpTunIPIP

+ const DpTunStt

+ const DpTunVxlan

+ type DpWorkT uint8

+ const DpChange

+ const DpCreate

+ const DpMapGet

+ const DpRemove

+ const DpStatsClr

+ const DpStatsGet

+ const DpStatsGetImm

+ type FdbAttr struct

+ Dst net.IP

+ FdbType int

+ Oif string

+ type FdbEnt struct

+ FdbAttr FdbAttr

+ FdbKey FdbKey

+ FdbTun FdbTunAttr

+ Port *Port

+ Sync DpStatusT

+ func (f *FdbEnt) DP(work DpWorkT) int

+ func (f *FdbEnt) L2FdbResolveNh() (bool, int, error)

+ type FdbKey struct

+ BridgeID int

+ MacAddr [6]byte

+ type FdbStat struct

+ Bytes uint64

+ Packets uint64

+ type FdbTunAttr struct

+ type FwDpWorkQ struct

+ DstIP net.IPNet

+ FwRecord bool

+ FwType FwOpT

+ FwVal1 uint16

+ FwVal2 uint32

+ L4DstMax uint16

+ L4DstMin uint16

+ L4SrcMax uint16

+ L4SrcMin uint16

+ Mark int

+ Port uint16

+ Pref uint16

+ Proto uint8

+ SrcIP net.IPNet

+ Status *DpStatusT

+ Work DpWorkT

+ ZoneNum int

+ type FwOpT uint8

+ const DpFwDrop

+ const DpFwFwd

+ const DpFwRdr

+ const DpFwTrap

+ type GoBgpH struct

+ func GoBgpInit(bgpPeerMode bool) *GoBgpH

+ func (gbh *GoBgpH) AddBGPRule(instance string, IP []string)

+ func (gbh *GoBgpH) AddCurrBgpRoutesToIPRoute() error

+ func (gbh *GoBgpH) AdvertiseRoute(rtPrefix string, pLen int, nh string, pref uint32, med uint32, ipv4 bool) int

+ func (gbh *GoBgpH) BGPGlobalConfigAdd(config cmn.GoBGPGlobalConfig) (int, error)

+ func (gbh *GoBgpH) BGPNeighGet(address string, enableAdv bool) ([]cmn.GoBGPNeighGetMod, error)

+ func (gbh *GoBgpH) BGPNeighMod(add bool, neigh net.IP, ras uint32, rPort uint32, mhop bool) (int, error)

+ func (gbh *GoBgpH) DelAdvertiseRoute(rtPrefix string, pLen int, nh string, pref uint32, med uint32) int

+ func (gbh *GoBgpH) DelBGPRule(instance string, IP []string)

+ func (gbh *GoBgpH) GetgoBGPRoutesEvents(client api.GobgpApiClient) int

+ func (gbh *GoBgpH) UpdateCIState(instance string, state int, vip net.IP)

+ type Ifa struct

+ Ifas []*IfaEnt

+ Key IfaKey

+ Sync DpStatusT

+ Zone *Zone

+ func (ifa *Ifa) DP(work DpWorkT) int

+ type IfaEnt struct

+ IfaAddr net.IP

+ IfaNet net.IPNet

+ Secondary bool

+ type IfaKey struct

+ Obj string

+ type IterIntf interface

+ NodeWalker func(b string)

+ type L2AddrDpWorkQ struct

+ BD int

+ L2Addr [6]uint8

+ NhNum int

+ PortNum int

+ Status *DpStatusT

+ Tagged int

+ Tun DpTunT

+ Work DpWorkT

+ type L2H struct

+ FdbMap map[FdbKey]*FdbEnt

+ Zone *Zone

+ func L2Init(z *Zone) *L2H

+ func (l2 *L2H) FdbTicker(f *FdbEnt)

+ func (l2 *L2H) Fdbs2String(it IterIntf) error

+ func (l2 *L2H) FdbsTicker()

+ func (l2 *L2H) L2DestructAll()

+ func (l2 *L2H) L2FdbAdd(key FdbKey, attr FdbAttr) (int, error)

+ func (l2 *L2H) L2FdbDel(key FdbKey) (int, error)

+ func (l2 *L2H) L2FdbFind(key FdbKey) *FdbEnt

+ func (l2 *L2H) PortNotifier(name string, osID int, evType PortEvent)

+ type L3H struct

+ IfaMap map[IfaKey]*Ifa

+ Zone *Zone

+ func L3Init(zone *Zone) *L3H

+ func (l3 *L3H) IfObjMkString(obj string, v4 bool) string

+ func (l3 *L3H) IfaAdd(Obj string, Cidr string) (int, error)

+ func (l3 *L3H) IfaAddrLocal(addr net.IP) (int, net.IP)

+ func (l3 *L3H) IfaDelete(Obj string, Cidr string) (int, error)

+ func (l3 *L3H) IfaDeleteAll(Obj string) (int, error)

+ func (l3 *L3H) IfaFind(Obj string, addr net.IP) (int, net.IP)

+ func (l3 *L3H) IfaFindAddr(Obj string, addr net.IP) (int, net.IP)

+ func (l3 *L3H) IfaGet() []cmn.IPAddrGet

+ func (l3 *L3H) IfaSelect(Obj string, addr net.IP, findAny bool) (int, net.IP, string)

+ func (l3 *L3H) IfaSelectAny(addr net.IP, findAny bool) (int, net.IP, string)

+ func (l3 *L3H) Ifas2String(it IterIntf) error

+ type MirrAttachObjT interface

+ type MirrDpWorkQ struct

+ Mark int

+ MiBD int

+ MiPortNum int

+ Name string

+ Status *DpStatusT

+ Work DpWorkT

+ type MirrEntry struct

+ HwNum uint64

+ Info cmn.MirrInfo

+ Key MirrKey

+ MObjs []MirrObjInfo

+ Stats PolStats

+ Sync DpStatusT

+ Zone *Zone

+ func (m *MirrEntry) DP(work DpWorkT) int

+ type MirrH struct

+ Mark *tk.Counter

+ MirrMap map[MirrKey]*MirrEntry

+ Zone *Zone

+ func MirrInit(zone *Zone) *MirrH

+ func (M *MirrH) MirrAdd(name string, mInfo cmn.MirrInfo, mObjArgs cmn.MirrObj) (int, error)

+ func (M *MirrH) MirrDelete(name string) (int, error)

+ func (M *MirrH) MirrDestructAll()

+ func (M *MirrH) MirrGet() ([]cmn.MirrGetMod, error)

+ func (M *MirrH) MirrPortDelete(name string)

+ func (M *MirrH) MirrTicker()

+ type MirrKey struct

+ Name string

+ type MirrObjInfo struct

+ Args cmn.MirrObj

+ AttachObj MirrAttachObjT

+ Parent *MirrEntry

+ Sync DpStatusT

+ func (mObjInfo *MirrObjInfo) MirrObj2DP(work DpWorkT) int

+ type MirrStats struct

+ Bytes uint64

+ PacketsOk uint64

+ type NatDpWorkQ struct

+ BlockNum uint16

+ CsumDis bool

+ DsrMode bool

+ EpSel NatSel

+ InActTo uint64

+ L4Port uint16

+ Mark int

+ NatType NatT

+ Proto uint8

+ ServiceIP net.IP

+ Status *DpStatusT

+ Work DpWorkT

+ ZoneNum int

+ type NatEP struct

+ InActive bool

+ RIP net.IP

+ Weight uint8

+ XIP net.IP

+ XPort uint16

+ type NatSel uint8

+ const EpHash

+ const EpLeastConn

+ const EpPrio

+ const EpRR

+ const EpRRPersist

+ type NatT uint8

+ const DpDnat

+ const DpFullNat

+ const DpHdnat

+ const DpHsnat

+ const DpSnat

+ type Neigh struct

+ Addr net.IP

+ Ats time.Time

+ Attr NeighAttr

+ Dummy bool

+ Inactive bool

+ Key NeighKey

+ Mark uint64

+ NhRtm map[RtKey]*Rt

+ OifPort *Port

+ RMark uint64

+ RecNh *Neigh

+ Resolved bool

+ Sync DpStatusT

+ TunEps []*NeighTunEp

+ Type NhType

+ func (ne *Neigh) DP(work DpWorkT) int

+ func (ne *Neigh) NeighRemoveTunEP(i int) []*NeighTunEp

+ type NeighAttr struct

+ HardwareAddr net.HardwareAddr

+ OSLinkIndex int

+ OSState int

+ type NeighH struct

+ NeighID *tk.Counter

+ NeighMap map[NeighKey]*Neigh

+ NeighTID *tk.Counter

+ Zone *Zone

+ func NeighInit(zone *Zone) *NeighH

+ func (n *NeighH) Activate(ne *Neigh)

+ func (n *NeighH) NeighAdd(Addr net.IP, Zone string, Attr NeighAttr) (int, error)

+ func (n *NeighH) NeighAddTunEP(ne *Neigh, rIP net.IP, sIP net.IP, tunID uint32, tunType DpTunT, sync bool) (int, *NeighTunEp)

+ func (n *NeighH) NeighDelAllTunEP(ne *Neigh) int

+ func (n *NeighH) NeighDelete(Addr net.IP, Zone string) (int, error)

+ func (n *NeighH) NeighDeleteByPort(port string)

+ func (n *NeighH) NeighDestructAll()

+ func (n *NeighH) NeighFind(Addr net.IP, Zone string) (*Neigh, int)

+ func (n *NeighH) NeighGet() ([]cmn.NeighMod, error)

+ func (n *NeighH) NeighPairRt(ne *Neigh, rt *Rt) int

+ func (n *NeighH) NeighRecursiveResolve(ne *Neigh) bool

+ func (n *NeighH) NeighTicker(ne *Neigh)

+ func (n *NeighH) NeighUnPairRt(ne *Neigh, rt *Rt) int

+ func (n *NeighH) Neighs2String(it IterIntf) error

+ func (n *NeighH) NeighsTicker()

+ func (n *NeighH) PortNotifier(name string, osID int, evType PortEvent)

+ type NeighKey struct

+ NhString string

+ Zone string

+ type NeighTunEp struct

+ Inactive bool

+ Mark uint64

+ Parent *Neigh

+ Sync DpStatusT

+ func (tep *NeighTunEp) DP(work DpWorkT) int

+ type NetAPIStruct struct

+ BgpPeerMode bool

+ func NetAPIInit(bgpPeerMode bool) *NetAPIStruct

+ func (*NetAPIStruct) NetMirrorAdd(mm *cmn.MirrMod) (int, error)

+ func (*NetAPIStruct) NetMirrorDel(mm *cmn.MirrMod) (int, error)

+ func (*NetAPIStruct) NetMirrorGet() ([]cmn.MirrGetMod, error)

+ func (*NetAPIStruct) NetPortGet() ([]cmn.PortDump, error)

+ func (na *NetAPIStruct) NetAddrAdd(am *cmn.IPAddrMod) (int, error)

+ func (na *NetAPIStruct) NetAddrDel(am *cmn.IPAddrMod) (int, error)

+ func (na *NetAPIStruct) NetAddrGet() ([]cmn.IPAddrGet, error)

+ func (na *NetAPIStruct) NetBFDAdd(bm *cmn.BFDMod) (int, error)

+ func (na *NetAPIStruct) NetBFDDel(bm *cmn.BFDMod) (int, error)

+ func (na *NetAPIStruct) NetBFDGet() ([]cmn.BFDMod, error)

+ func (na *NetAPIStruct) NetCIStateGet() ([]cmn.HASMod, error)

+ func (na *NetAPIStruct) NetCIStateMod(hm *cmn.HASMod) (int, error)

+ func (na *NetAPIStruct) NetCtInfoGet() ([]cmn.CtInfo, error)

+ func (na *NetAPIStruct) NetEpHostAdd(em *cmn.EndPointMod) (int, error)

+ func (na *NetAPIStruct) NetEpHostDel(em *cmn.EndPointMod) (int, error)

+ func (na *NetAPIStruct) NetEpHostGet() ([]cmn.EndPointMod, error)

+ func (na *NetAPIStruct) NetFdbAdd(fm *cmn.FdbMod) (int, error)

+ func (na *NetAPIStruct) NetFdbDel(fm *cmn.FdbMod) (int, error)

+ func (na *NetAPIStruct) NetFwRuleAdd(fm *cmn.FwRuleMod) (int, error)

+ func (na *NetAPIStruct) NetFwRuleDel(fm *cmn.FwRuleMod) (int, error)

+ func (na *NetAPIStruct) NetFwRuleGet() ([]cmn.FwRuleMod, error)

+ func (na *NetAPIStruct) NetGoBGPGCAdd(param *cmn.GoBGPGlobalConfig) (int, error)

+ func (na *NetAPIStruct) NetGoBGPNeighAdd(param *cmn.GoBGPNeighMod) (int, error)

+ func (na *NetAPIStruct) NetGoBGPNeighDel(param *cmn.GoBGPNeighMod) (int, error)

+ func (na *NetAPIStruct) NetGoBGPNeighGet() ([]cmn.GoBGPNeighGetMod, error)

+ func (na *NetAPIStruct) NetHandlePanic()

+ func (na *NetAPIStruct) NetLbRuleAdd(lm *cmn.LbRuleMod) (int, error)

+ func (na *NetAPIStruct) NetLbRuleDel(lm *cmn.LbRuleMod) (int, error)

+ func (na *NetAPIStruct) NetLbRuleGet() ([]cmn.LbRuleMod, error)

+ func (na *NetAPIStruct) NetNeighAdd(nm *cmn.NeighMod) (int, error)

+ func (na *NetAPIStruct) NetNeighDel(nm *cmn.NeighMod) (int, error)

+ func (na *NetAPIStruct) NetNeighGet() ([]cmn.NeighMod, error)

+ func (na *NetAPIStruct) NetParamGet(param *cmn.ParamMod) (int, error)

+ func (na *NetAPIStruct) NetParamSet(param cmn.ParamMod) (int, error)

+ func (na *NetAPIStruct) NetPolicerAdd(pm *cmn.PolMod) (int, error)

+ func (na *NetAPIStruct) NetPolicerDel(pm *cmn.PolMod) (int, error)

+ func (na *NetAPIStruct) NetPolicerGet() ([]cmn.PolMod, error)

+ func (na *NetAPIStruct) NetPortAdd(pm *cmn.PortMod) (int, error)

+ func (na *NetAPIStruct) NetPortDel(pm *cmn.PortMod) (int, error)

+ func (na *NetAPIStruct) NetRouteAdd(rm *cmn.RouteMod) (int, error)

+ func (na *NetAPIStruct) NetRouteDel(rm *cmn.RouteMod) (int, error)

+ func (na *NetAPIStruct) NetRouteGet() ([]cmn.RouteGet, error)

+ func (na *NetAPIStruct) NetSessionAdd(sm *cmn.SessionMod) (int, error)

+ func (na *NetAPIStruct) NetSessionDel(sm *cmn.SessionMod) (int, error)

+ func (na *NetAPIStruct) NetSessionGet() ([]cmn.SessionMod, error)

+ func (na *NetAPIStruct) NetSessionUlClAdd(sr *cmn.SessionUlClMod) (int, error)

+ func (na *NetAPIStruct) NetSessionUlClDel(sr *cmn.SessionUlClMod) (int, error)

+ func (na *NetAPIStruct) NetSessionUlClGet() ([]cmn.SessionUlClMod, error)

+ func (na *NetAPIStruct) NetVlanAdd(vm *cmn.VlanMod) (int, error)

+ func (na *NetAPIStruct) NetVlanDel(vm *cmn.VlanMod) (int, error)

+ func (na *NetAPIStruct) NetVlanGet() ([]cmn.VlanGet, error)

+ func (na *NetAPIStruct) NetVlanPortAdd(vm *cmn.VlanPortMod) (int, error)

+ func (na *NetAPIStruct) NetVlanPortDel(vm *cmn.VlanPortMod) (int, error)

+ type NextHopDpWorkQ struct

+ BD int

+ DstAddr [6]uint8

+ NNextHopNum int

+ NextHopNum int

+ RIP net.IP

+ Resolved bool

+ SIP net.IP

+ SrcAddr [6]uint8

+ Status *DpStatusT

+ TunID uint32

+ TunNh bool

+ TunType DpTunT

+ Work DpWorkT

+ type NhType uint8

+ const NhNormal

+ const NhRecursive

+ const NhTun

+ type PeerDpWorkQ struct

+ PeerIP net.IP

+ Status *DpStatusT

+ Work DpWorkT

+ type PolAttachObjT interface

+ type PolDpWorkQ struct

+ Cbs uint64

+ Cir uint64

+ Color bool

+ Ebs uint64

+ Mark int

+ Name string

+ Pir uint64

+ Srt bool

+ Status *DpStatusT

+ Work DpWorkT

+ type PolEntry struct

+ HwNum uint64

+ Info cmn.PolInfo

+ Key PolKey

+ PObjs []PolObjInfo

+ Stats PolStats

+ Sync DpStatusT

+ Zone *Zone

+ func (p *PolEntry) DP(work DpWorkT) int

+ type PolH struct

+ Mark *tk.Counter

+ PolMap map[PolKey]*PolEntry

+ Zone *Zone

+ func PolInit(zone *Zone) *PolH

+ func (P *PolH) PolAdd(pName string, pInfo cmn.PolInfo, pObjArgs cmn.PolObj) (int, error)

+ func (P *PolH) PolDelete(pName string) (int, error)

+ func (P *PolH) PolDestructAll()

+ func (P *PolH) PolGetAll() ([]cmn.PolMod, error)

+ func (P *PolH) PolPortDelete(name string)

+ func (P *PolH) PolTicker()

+ type PolKey struct

+ PolName string

+ type PolObjInfo struct

+ Args cmn.PolObj

+ AttachObj PolAttachObjT

+ Parent *PolEntry

+ Sync DpStatusT

+ func (pObjInfo *PolObjInfo) PolObj2DP(work DpWorkT) int

+ type PolStats struct

+ Bytes uint64

+ PacketsNok uint64

+ PacketsOk uint64

+ type Port struct

+ HInfo PortHwInfo

+ L2 PortLayer2Info

+ L3 PortLayer3Info

+ Name string

+ PortNo int

+ SInfo PortSwInfo

+ Stats PortStatsInfo

+ Sync DpStatusT

+ Zone string

+ func (p *Port) DP(work DpWorkT) int

+ func (p *Port) IsIPinIPTunPort() bool

+ func (p *Port) IsL3TunPort() bool

+ func (p *Port) IsLeafPort() bool

+ func (p *Port) IsSlavePort() bool

+ type PortDpWorkQ struct

+ IngVlan int

+ LoadEbpf string

+ OsPortNum int

+ PortNum int

+ Prop cmn.PortProp

+ SetBD int

+ SetMirr int

+ SetPol int

+ SetZoneNum int

+ Status *DpStatusT

+ Work DpWorkT

+ type PortEvent uint

+ const PortEvDelete

+ const PortEvDown

+ const PortEvLowerDown

+ type PortEventIntf interface

+ PortNotifier func(name string, osID int, evType PortEvent)

+ type PortHwInfo struct

+ Link bool

+ MacAddr [6]byte

+ Master string

+ Mtu int

+ Real string

+ State bool

+ TunDst net.IP

+ TunID uint32

+ TunSrc net.IP

+ type PortLayer2Info struct

+ IsPvid bool

+ Vid int

+ type PortLayer3Info struct

+ Ipv4Addrs []string

+ Ipv6Addrs []string

+ Routed bool

+ type PortStatsInfo struct

+ RxBytes uint64

+ RxError uint64

+ RxPackets uint64

+ TxBytes uint64

+ TxError uint64

+ TxPackets uint64

+ type PortSwInfo struct

+ BpfLoaded bool

+ OsID int

+ PortActive bool

+ PortMirNum int

+ PortOvl *Port

+ PortPolNum int

+ PortProp cmn.PortProp

+ PortReal *Port

+ PortType int

+ SessMark uint64

+ type PortsH struct

+ func PortInit() *PortsH

+ func (P *PortsH) PortAdd(name string, osid int, ptype int, zone string, hwi PortHwInfo, ...) (int, error)

+ func (P *PortsH) PortDel(name string, ptype int) (int, error)

+ func (P *PortsH) PortDestructAll()

+ func (P *PortsH) PortFindByName(name string) (p *Port)

+ func (P *PortsH) PortFindByOSID(osID int) (p *Port)

+ func (P *PortsH) PortGetSlaves(master string) (int, []*Port)

+ func (P *PortsH) PortHasTunSlaves(master string, ptype int) (bool, []*Port)

+ func (P *PortsH) PortL2AddrMatch(name string, mp *Port) bool

+ func (P *PortsH) PortNotifierRegister(notifier PortEventIntf)

+ func (P *PortsH) PortTicker()

+ func (P *PortsH) PortUpdateProp(name string, prop cmn.PortProp, zone string, updt bool, propVal int) (int, error)

+ func (P *PortsH) Ports2Json(w io.Writer) error

+ func (P *PortsH) Ports2String(it IterIntf) error

+ func (P *PortsH) PortsToGet() ([]cmn.PortDump, error)

+ type RPCHookInterface interface

+ RPCClose func(*DpPeer) int

+ RPCConnect func(*DpPeer) int

+ RPCReset func(*DpPeer) int

+ RPCSend func(*DpPeer, string, any) (int, error)

+ type RouteDpWorkQ struct

+ Dst net.IPNet

+ NMark int

+ RtMark int

+ RtType int

+ Status *DpStatusT

+ Work DpWorkT

+ ZoneNum int

+ type RouterMacDpWorkQ struct

+ BD int

+ L2Addr [6]uint8

+ NhNum int

+ PortNum int

+ Status *DpStatusT

+ TunID uint32

+ TunType DpTunT

+ Work DpWorkT

+ type Rt struct

+ Addr net.IP

+ Attr RtAttr

+ Dead bool

+ Key RtKey

+ Mark uint64

+ NextHops []*Neigh

+ NhAttr []RtNhAttr

+ RtDepObjs []RtDepObj

+ Stat RtStat

+ Sync DpStatusT

+ TFlags int

+ ZoneNum int

+ func (rt *Rt) DP(work DpWorkT) int

+ func (rt *Rt) RtGetNhMark() uint64

+ type RtAttr struct

+ HostRoute bool

+ IfRoute bool

+ Ifi int

+ OSFlags int

+ Protocol int

+ type RtDepObj interface

+ type RtH struct

+ Mark *tk.Counter

+ RtMap map[RtKey]*Rt

+ Trie4 *tk.TrieRoot

+ Trie6 *tk.TrieRoot

+ Zone *Zone

+ func RtInit(zone *Zone) *RtH

+ func (r *RtH) RouteGet() ([]cmn.RouteGet, error)

+ func (r *RtH) RoutesSync()

+ func (r *RtH) RoutesTicker()

+ func (r *RtH) RtAdd(Dst net.IPNet, Zone string, Ra RtAttr, Na []RtNhAttr) (int, error)

+ func (r *RtH) RtDelete(Dst net.IPNet, Zone string) (int, error)

+ func (r *RtH) RtDeleteByPort(port string) (int, error)

+ func (r *RtH) RtDeleteHost(Dst net.IPNet, Zone string) (int, error)

+ func (r *RtH) RtDestructAll()

+ func (r *RtH) RtFind(Dst net.IPNet, Zone string) *Rt

+ func (r *RtH) Rts2String(it IterIntf) error

+ func (r *RtH) TrieData2String(d tk.TrieData) string

+ func (r *RtH) TrieNodeWalker(b string)

+ type RtKey struct

+ RtCidr string

+ Zone string

+ type RtNhAttr struct

+ LinkIndex int

+ NhAddr net.IP

+ type RtStat struct

+ Bytes uint64

+ Packets uint64

+ type RuleCfg struct

+ RuleInactChkTime int

+ RuleInactTries int

+ type RuleH struct

+ func RulesInit(zone *Zone) *RuleH

+ func (R *RuleH) AddEPHost(apiCall bool, hostName string, name string, args epHostOpts) (int, error)

+ func (R *RuleH) AddFwRule(fwRule cmn.FwRuleArg, fwOptArgs cmn.FwOptArg) (int, error)

+ func (R *RuleH) AddNatLbRule(serv cmn.LbServiceArg, servSecIPs []cmn.LbSecIPArg, ...) (int, error)

+ func (R *RuleH) AdvRuleVIPIfL2(IP net.IP) error

+ func (R *RuleH) DeleteEPHost(apiCall bool, name string, hostName string, probeType string, probePort uint16) (int, error)

+ func (R *RuleH) DeleteFwRule(fwRule cmn.FwRuleArg) (int, error)

+ func (R *RuleH) DeleteNatLbRule(serv cmn.LbServiceArg) (int, error)

+ func (R *RuleH) GetEpHosts() ([]cmn.EndPointMod, error)

+ func (R *RuleH) GetFwRule() ([]cmn.FwRuleMod, error)

+ func (R *RuleH) GetNatLbRule() ([]cmn.LbRuleMod, error)

+ func (R *RuleH) GetNatLbRuleByID(ruleID uint32) *ruleEnt

+ func (R *RuleH) GetNatLbRuleByServArgs(serv cmn.LbServiceArg) *ruleEnt

+ func (R *RuleH) GetNatLbRuleSecIPs(serv cmn.LbServiceArg) []string

+ func (R *RuleH) IsEPHostActive(epKey string) bool

+ func (R *RuleH) IsIPRuleVIP(IP net.IP) bool

+ func (R *RuleH) RuleDestructAll()

+ func (R *RuleH) RuleVIPSyncToClusterState()

+ func (R *RuleH) Rules2Json() ([]byte, error)

+ func (R *RuleH) RulesSync()

+ func (R *RuleH) RulesTicker()

+ type SessH struct

+ Mark *tk.Counter

+ UserMap map[UserKey]*UserSess

+ Zone *Zone

+ func SessInit(zone *Zone) *SessH

+ func (s *SessH) SessAdd(user string, IP net.IP, anTun cmn.SessTun, cnTun cmn.SessTun) (int, error)

+ func (s *SessH) SessDelete(user string) (int, error)

+ func (s *SessH) SessGet() ([]cmn.SessionMod, error)

+ func (s *SessH) SessUlclGet() ([]cmn.SessionUlClMod, error)

+ func (s *SessH) SessionTicker()

+ func (s *SessH) SessionsSync()

+ func (s *SessH) USess2String(it IterIntf) error

+ func (s *SessH) UlClAddCls(user string, cls cmn.UlClArg) (int, error)

+ func (s *SessH) UlClDeleteCls(user string, cls cmn.UlClArg) (int, error)

+ type SockVIPDpWorkQ struct

+ Port uint16

+ RwPort uint16

+ Status *DpStatusT

+ VIP net.IP

+ Work DpWorkT

+ type StatDpWorkQ struct

+ Bytes *uint64

+ DropPackets *uint64

+ Mark uint32

+ Name string

+ Packets *uint64

+ Work DpWorkT

+ type TableDpWorkQ struct

+ Name string

+ Work DpWorkT

+ type UlClDpWorkQ struct

+ MDip net.IP

+ MSip net.IP

+ Mark int

+ Qfi uint8

+ Status *DpStatusT

+ TDip net.IP

+ TSip net.IP

+ TTeID uint32

+ Type DpTunT

+ Work DpWorkT

+ Zone int

+ type UlClInf struct

+ Addr net.IP

+ NumDl uint64

+ NumUl uint64

+ Qfi uint8

+ Stats UlClStats

+ Status DpStatusT

+ func (ulcl *UlClInf) DP(work DpWorkT) int

+ type UlClStats struct

+ DlBytes uint64

+ DlPackets uint64

+ UlBytes uint64

+ UlPackets uint64

+ type UnimplementedXSyncServer struct

+ func (UnimplementedXSyncServer) DpWorkOnBlockCtModGRPC(context.Context, *BlockCtInfoMod) (*XSyncReply, error)

+ func (UnimplementedXSyncServer) DpWorkOnCtGetGRPC(context.Context, *ConnGet) (*XSyncReply, error)

+ func (UnimplementedXSyncServer) DpWorkOnCtModGRPC(context.Context, *CtInfoMod) (*XSyncReply, error)

+ type UnsafeXSyncServer interface

+ type UserKey struct

+ UserID string

+ type UserSess struct

+ Addr net.IP

+ AnTun cmn.SessTun

+ CnTun cmn.SessTun

+ Key UserKey

+ UlCl map[string]*UlClInf

+ Zone int

+ type UserTun struct

+ Addr net.IP

+ TeID uint32

+ type Vlan struct

+ Created bool

+ Name string

+ NumTagPorts int

+ NumUnTagPorts int

+ Stat vlanStat

+ TaggedPorts [MaxInterfaces]*Port

+ UnTaggedPorts [MaxInterfaces]*Port

+ VlanID int

+ Zone string

+ func (v *Vlan) DP(work DpWorkT) int

+ type VlansH struct

+ VlanMap [MaximumVlans]Vlan

+ Zone *Zone

+ func VlanInit(zone *Zone) *VlansH

+ func (V *VlansH) VlanAdd(vlanID int, name string, zone string, osid int, hwi PortHwInfo) (int, error)

+ func (V *VlansH) VlanDelete(vlanID int) (int, error)

+ func (V *VlansH) VlanDestructAll()

+ func (V *VlansH) VlanGet() ([]cmn.VlanGet, error)

+ func (V *VlansH) VlanPortAdd(vlanID int, portName string, tagged bool) (int, error)

+ func (V *VlansH) VlanPortDelete(vlanID int, portName string, tagged bool) (int, error)

+ func (V *VlansH) Vlans2String(it IterIntf) error

+ func (V *VlansH) VlansSync()

+ func (V *VlansH) VlansTicker()

+ type XSync struct

+ RPCHooks RPCHookInterface

+ RPCState bool

+ RPCType int

+ RemoteID int

+ func (xs *XSync) DpWorkOnBlockCtAdd(blockCtis []DpCtInfo, ret *int) error

+ func (xs *XSync) DpWorkOnBlockCtDelete(blockCtis []DpCtInfo, ret *int) error

+ func (xs *XSync) DpWorkOnBlockCtModGRPC(ctx context.Context, m *BlockCtInfoMod) (*XSyncReply, error)

+ func (xs *XSync) DpWorkOnCtAdd(cti DpCtInfo, ret *int) error

+ func (xs *XSync) DpWorkOnCtDelete(cti DpCtInfo, ret *int) error

+ func (xs *XSync) DpWorkOnCtGet(async int, ret *int) error

+ func (xs *XSync) DpWorkOnCtGetGRPC(ctx context.Context, m *ConnGet) (*XSyncReply, error)

+ func (xs *XSync) DpWorkOnCtModGRPC(ctx context.Context, m *CtInfoMod) (*XSyncReply, error)

+ type XSyncClient interface

+ DpWorkOnBlockCtModGRPC func(ctx context.Context, in *BlockCtInfoMod, opts ...grpc.CallOption) (*XSyncReply, error)

+ DpWorkOnCtGetGRPC func(ctx context.Context, in *ConnGet, opts ...grpc.CallOption) (*XSyncReply, error)

+ DpWorkOnCtModGRPC func(ctx context.Context, in *CtInfoMod, opts ...grpc.CallOption) (*XSyncReply, error)

+ func NewXSyncClient(cc grpc.ClientConnInterface) XSyncClient

+ type XSyncReply struct

+ Response int32

+ func (*XSyncReply) Descriptor() ([]byte, []int)

+ func (*XSyncReply) ProtoMessage()

+ func (x *XSyncReply) GetResponse() int32

+ func (x *XSyncReply) ProtoReflect() protoreflect.Message

+ func (x *XSyncReply) Reset()

+ func (x *XSyncReply) String() string

+ type XSyncServer interface

+ DpWorkOnBlockCtModGRPC func(context.Context, *BlockCtInfoMod) (*XSyncReply, error)

+ DpWorkOnCtGetGRPC func(context.Context, *ConnGet) (*XSyncReply, error)

+ DpWorkOnCtModGRPC func(context.Context, *CtInfoMod) (*XSyncReply, error)

+ type Zone struct

+ L2 *L2H

+ L3 *L3H

+ Mirrs *MirrH

+ Mtx sync.RWMutex

+ Name string

+ Nh *NeighH

+ Pols *PolH

+ Ports *PortsH

+ Rt *RtH

+ Rules *RuleH

+ Sess *SessH

+ Vlans *VlansH

+ ZoneNum int

+ type ZoneH struct

+ ZoneBrs map[string]*Zone

+ ZoneMap map[string]*Zone

+ ZoneMark *tk.Counter

+ ZonePorts map[string]*Zone

+ func ZoneInit() *ZoneH

+ func (z *ZoneH) GetPortZone(port string) *Zone

+ func (z *ZoneH) ZoneAdd(name string) (int, error)

+ func (z *ZoneH) ZoneBrAdd(name string, zns string) (int, error)

+ func (z *ZoneH) ZoneBrDelete(name string) (int, error)

+ func (z *ZoneH) ZoneDelete(name string) (int, error)

+ func (z *ZoneH) ZonePortAdd(name string, zns string) (int, error)

+ func (z *ZoneH) ZonePortDelete(name string) (int, error)

+ func (z *ZoneH) ZonePortIsValid(name string, zns string) (int, error)

+ func (z *ZoneH) ZoneTicker()

+ func (z *ZoneH) Zonefind(name string) (*Zone, int)

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