Versions in this module Expand all Collapse all v0 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)
Go to main page