Documentation ¶
Index ¶
- Variables
- func ConvertToCIDR(ips []string)
- func GetDefaultMaskLen(ip string) uint32
- func GetTapTypesFromDB(db *gorm.DB) []*models.TapType
- func NodeToProto(podClusterId int, protocol trident.ServiceProtocol, serverPorts []uint32, ...) *trident.ServiceInfo
- type DBDataCache
- func (d *DBDataCache) GetACLs() []*models.ACL
- func (d *DBDataCache) GetAZs() []*models.AZ
- func (d *DBDataCache) GetAgentGroupConfigsFromDB(db *gorm.DB) []*agent_config.AgentGroupConfigModel
- func (d *DBDataCache) GetCENs() []*models.CEN
- func (d *DBDataCache) GetChDevicesIDTypeAndName() []*models.ChDevice
- func (d *DBDataCache) GetChVTapPorts() []*models.ChVTapPort
- func (d *DBDataCache) GetDataCacheFromDB(db *gorm.DB)
- func (d *DBDataCache) GetDhcpPorts() []*models.DHCPPort
- func (d *DBDataCache) GetDomains() []*models.Domain
- func (d *DBDataCache) GetFloatingIPs() []*models.FloatingIP
- func (d *DBDataCache) GetHostDevices() []*models.Host
- func (d *DBDataCache) GetLANIPs() []*models.LANIP
- func (d *DBDataCache) GetLBListeners() []*models.LBListener
- func (d *DBDataCache) GetLBTargetServers() []*models.LBTargetServer
- func (d *DBDataCache) GetLBs() []*models.LB
- func (d *DBDataCache) GetNats() []*models.NATGateway
- func (d *DBDataCache) GetNetworks() []*models.Network
- func (d *DBDataCache) GetNpbPolicies() []*models.NpbPolicy
- func (d *DBDataCache) GetNpbTunnels() []*models.NpbTunnel
- func (d *DBDataCache) GetPcapPolicies() []*models.PcapPolicy
- func (d *DBDataCache) GetPeerConnections() []*models.PeerConnection
- func (d *DBDataCache) GetPodClusters() []*models.PodCluster
- func (d *DBDataCache) GetPodGroupPorts() []*models.PodGroupPort
- func (d *DBDataCache) GetPodGroups() []*models.PodGroup
- func (d *DBDataCache) GetPodNSsIDAndName() []*models.PodNamespace
- func (d *DBDataCache) GetPodNodes() []*models.PodNode
- func (d *DBDataCache) GetPodServicePorts() []*models.PodServicePort
- func (d *DBDataCache) GetPodServices() []*models.PodService
- func (d *DBDataCache) GetPods() []*models.Pod
- func (d *DBDataCache) GetProcesses() []*models.Process
- func (d *DBDataCache) GetRdsInstances() []*models.RDSInstance
- func (d *DBDataCache) GetRedisInstances() []*models.RedisInstance
- func (d *DBDataCache) GetRegions() []*models.Region
- func (d *DBDataCache) GetResourceGroupExtraInfos() []*models.ResourceGroupExtraInfo
- func (d *DBDataCache) GetResourceGroups() []*models.ResourceGroup
- func (d *DBDataCache) GetSkipVTaps() []*models.VTap
- func (d *DBDataCache) GetSubDomains() []*models.SubDomain
- func (d *DBDataCache) GetSubnets() []*models.Subnet
- func (d *DBDataCache) GetSysConfigurations() []*models.SysConfiguration
- func (d *DBDataCache) GetVIPs() []*models.VIP
- func (d *DBDataCache) GetVInterfaces() []*models.VInterface
- func (d *DBDataCache) GetVPCs() []*models.VPC
- func (d *DBDataCache) GetVRouters() []*models.VRouter
- func (d *DBDataCache) GetVTapsIDAndName() []*models.VTap
- func (d *DBDataCache) GetVipDomains() []*models.Domain
- func (d *DBDataCache) GetVmPodNodeConns() []*models.VMPodNodeConnection
- func (d *DBDataCache) GetVms() []*models.VM
- func (d *DBDataCache) GetWANIPs() []*models.WANIP
- type DomainCIDRProto
- type DomainIPKey
- type DomainInterfaceData
- type DomainInterfaceProto
- type DomainPeerConnProto
- type DomainPeerConnsData
- type DomainPlatformData
- type DomainToPlatformData
- func (d *DomainToPlatformData) GetAZToPlatformDataOnlyPod() DomainPlatformData
- func (d *DomainToPlatformData) GetAllCompletePlatformDataExceptPod() *PlatformData
- func (d *DomainToPlatformData) GetAllSimplePlatformData() *PlatformData
- func (d *DomainToPlatformData) GetAllSimplePlatformDataExceptPod() *PlatformData
- func (d *DomainToPlatformData) GetDomainToAllPlatformData() DomainPlatformData
- func (d *DomainToPlatformData) GetDomainToPlatformDataExceptPod() DomainPlatformData
- func (d *DomainToPlatformData) GetDomainToPlatformDataOnlyPod() DomainPlatformData
- func (d *DomainToPlatformData) GetNoDomainPlatformData() *PlatformData
- func (d *DomainToPlatformData) GetRegionToPlatformDataOnlyPod() DomainPlatformData
- type GProcessInfoProto
- type GroupData
- type GroupDataOP
- type GroupIDs
- type GroupIP
- type GroupKey
- type GroupProto
- type GroupRawData
- type IDToNetworkMacs
- type IDToVifs
- type IPData
- type InterfaceProto
- type IpResourceData
- type MacID
- type MetaData
- func (m *MetaData) GetDBDataCache() *DBDataCache
- func (m *MetaData) GetDropletGroups() []byte
- func (m *MetaData) GetDropletGroupsVersion() uint64
- func (m *MetaData) GetDropletPolicyStr() []byte
- func (m *MetaData) GetDropletPolicyVersion() uint64
- func (m *MetaData) GetGroupDataOP() *GroupDataOP
- func (m *MetaData) GetPlatformDataOP() *PlatformDataOP
- func (m *MetaData) GetPlatformVips() []string
- func (m *MetaData) GetPolicyDataOP() *PolicyDataOP
- func (m *MetaData) GetStartTime() int64
- func (m *MetaData) GetTapTypes() []*trident.TapType
- func (m *MetaData) GetTridentGroups() []byte
- func (m *MetaData) GetTridentGroupsVersion() uint64
- func (m *MetaData) GetVTapPolicyString(vtapID int, functions mapset.Set) []byte
- func (m *MetaData) GetVTapPolicyVersion(vtapID int, functions mapset.Set) uint64
- func (m *MetaData) InitData(startTime int64)
- func (m *MetaData) PutChGroup()
- func (m *MetaData) PutChPlatformData()
- func (m *MetaData) PutChPolicy()
- func (m *MetaData) PutChTapType()
- func (m *MetaData) TimedRefreshMetaData()
- type NetworkMacs
- type NodeKey
- type PlatformData
- func (f *PlatformData) GeneratePlatformDataResult()
- func (f *PlatformData) GetPlatformDataResult() ([]byte, uint64)
- func (f *PlatformData) GetPlatformDataStr() []byte
- func (f *PlatformData) GetPlatformDataVersion() uint64
- func (f *PlatformData) GetVersion() uint64
- func (f *PlatformData) Merge(other *PlatformData)
- func (f *PlatformData) MergeInterfaces(other *PlatformData)
- func (f *PlatformData) MergePeerConnProtos(other *PlatformData)
- func (f *PlatformData) String() string
- type PlatformDataOP
- func (p *PlatformDataOP) GeneratePlatformData()
- func (p *PlatformDataOP) GetAllPlatformDataForIngester() *PlatformData
- func (p *PlatformDataOP) GetNoDomainPeerConns() TPeerConnections
- func (p *PlatformDataOP) GetPlatformDataChangedCh() <-chan struct{}
- func (p *PlatformDataOP) GetPodIPs() []*trident.PodIp
- func (p *PlatformDataOP) GetRawData() *PlatformRawData
- func (p *PlatformDataOP) GetSegment() *Segment
- func (p *PlatformDataOP) RegisteNotifyIngesterDatachanged(notify func())
- type PlatformRawData
- func (r *PlatformRawData) ConvertDBAZ(dbDataCache *DBDataCache)
- func (r *PlatformRawData) ConvertDBCEN(dbDataCache *DBDataCache)
- func (r *PlatformRawData) ConvertDBCache(dbDataCache *DBDataCache)
- func (r *PlatformRawData) ConvertDBDHCPPort(dbDataCache *DBDataCache)
- func (r *PlatformRawData) ConvertDBIPs(dbDataCache *DBDataCache)
- func (r *PlatformRawData) ConvertDBLB(dbDataCache *DBDataCache)
- func (r *PlatformRawData) ConvertDBNat(dbDataCache *DBDataCache)
- func (r *PlatformRawData) ConvertDBNetwork(dbDataCache *DBDataCache)
- func (r *PlatformRawData) ConvertDBPeerConnection(dbDataCache *DBDataCache)
- func (r *PlatformRawData) ConvertDBPod(dbDataCache *DBDataCache)
- func (r *PlatformRawData) ConvertDBPodGroup(dbDataCache *DBDataCache)
- func (r *PlatformRawData) ConvertDBPodGroupPort(dbDataCache *DBDataCache)
- func (r *PlatformRawData) ConvertDBPodNode(dbDataCache *DBDataCache)
- func (r *PlatformRawData) ConvertDBPodService(dbDataCache *DBDataCache)
- func (r *PlatformRawData) ConvertDBPodServicePort(dbDataCache *DBDataCache)
- func (r *PlatformRawData) ConvertDBProcesses(dbDataCache *DBDataCache)
- func (r *PlatformRawData) ConvertDBRdsInstance(dbDataCache *DBDataCache)
- func (r *PlatformRawData) ConvertDBRedisInstance(dbDataCache *DBDataCache)
- func (r *PlatformRawData) ConvertDBRegion(dbDataCache *DBDataCache)
- func (r *PlatformRawData) ConvertDBVIPs(dbDataCache *DBDataCache)
- func (r *PlatformRawData) ConvertDBVInterface(dbDataCache *DBDataCache)
- func (r *PlatformRawData) ConvertDBVM(dbDataCache *DBDataCache)
- func (r *PlatformRawData) ConvertDBVPC(dbDataCache *DBDataCache)
- func (r *PlatformRawData) ConvertDBVRouter(dbDataCache *DBDataCache)
- func (r *PlatformRawData) ConvertDBVTaps(dbDataCache *DBDataCache)
- func (r *PlatformRawData) ConvertDBVipDomain(dbDataCache *DBDataCache)
- func (r *PlatformRawData) ConvertDBVmPodNodeConn(dbDataCache *DBDataCache)
- func (r *PlatformRawData) ConvertHost(dbDataCache *DBDataCache)
- func (r *PlatformRawData) ConvertSkipVTapVIfIDs(dbDataCache *DBDataCache)
- func (r *PlatformRawData) GetContainers(vtapID int) []*trident.Container
- func (r *PlatformRawData) GetHostIDToVifs() map[int]mapset.Set
- func (r *PlatformRawData) GetIDToNetwork() map[int]*models.Network
- func (r *PlatformRawData) GetPod(podID int) *models.Pod
- func (r *PlatformRawData) GetPodGroup(podGroupID int) *models.PodGroup
- func (r *PlatformRawData) GetPodNode(podNodeID int) *models.PodNode
- func (r *PlatformRawData) GetPodNodeIDToVmID() map[int]int
- func (r *PlatformRawData) GetServerToVmIDs() map[string]mapset.Set
- func (r *PlatformRawData) GetSkipInterface(server string) []*trident.SkipInterface
- func (r *PlatformRawData) GetVMIDToPodNodeID() map[int]int
- func (r *PlatformRawData) GetVTap(vtapID int) *models.VTap
- type Policy
- type PolicyDataOP
- type PolicyRawData
- type Segment
- func (s *Segment) ClearVTapUsedVInterfaceIDs()
- func (s *Segment) GenerateNoVTapUsedSegments(rawData *PlatformRawData)
- func (s *Segment) GetAllGatewayHostSegments() []*trident.Segment
- func (s *Segment) GetHostIDSegments(hostID int) []*trident.Segment
- func (s *Segment) GetLaunchServerSegments(launchServer string) []*trident.Segment
- func (s *Segment) GetNotVtapUsedSegments() []*trident.Segment
- func (s *Segment) GetPodIDSegments(podID int) []*trident.Segment
- func (s *Segment) GetPodNodeSegments(podNodeID int) []*trident.Segment
- func (s *Segment) GetTypeVMSegments(launchServer string, hostID int) []*trident.Segment
- func (s *Segment) GetVMIDSegments(vmID int) []*trident.Segment
- type ServerToNetworkMacs
- type ServiceDataOP
- type ServiceRawData
- type TInterfaces
- type TPeerConnections
- type TapType
- type TypeIDData
- type TypeIDKey
Constants ¶
This section is empty.
Variables ¶
View Source
var PodGroupTypeMap = map[int]uint32{ POD_GROUP_DEPLOYMENT: uint32(trident.AutoServiceType_AUTO_SERVICE_TYPE_POD_GROUP_DEPLOYMENT), POD_GROUP_STATEFULSET: uint32(trident.AutoServiceType_AUTO_SERVICE_TYPE_POD_GROUP_STATEFULSET), POD_GROUP_RC: uint32(trident.AutoServiceType_AUTO_SERVICE_TYPE_POD_GROUP_RC), POD_GROUP_DAEMON_SET: uint32(trident.AutoServiceType_AUTO_SERVICE_TYPE_POD_GROUP_DAEMON_SET), POD_GROUP_REPLICASET_CONTROLLER: uint32(trident.AutoServiceType_AUTO_SERVICE_TYPE_POD_GROUP_REPLICASET_CONTROLLER), POD_GROUP_CLONESET: uint32(trident.AutoServiceType_AUTO_SERVICE_TYPE_POD_GROUP_CLONESET), }
Functions ¶
func ConvertToCIDR ¶
func ConvertToCIDR(ips []string)
func GetDefaultMaskLen ¶
func NodeToProto ¶
func NodeToProto( podClusterId int, protocol trident.ServiceProtocol, serverPorts []uint32, serviceType trident.ServiceType, serviceID int) *trident.ServiceInfo
Types ¶
type DBDataCache ¶
type DBDataCache struct { ORGID // contains filtered or unexported fields }
func (*DBDataCache) GetACLs ¶
func (d *DBDataCache) GetACLs() []*models.ACL
func (*DBDataCache) GetAZs ¶
func (d *DBDataCache) GetAZs() []*models.AZ
func (*DBDataCache) GetAgentGroupConfigsFromDB ¶
func (d *DBDataCache) GetAgentGroupConfigsFromDB(db *gorm.DB) []*agent_config.AgentGroupConfigModel
func (*DBDataCache) GetCENs ¶
func (d *DBDataCache) GetCENs() []*models.CEN
func (*DBDataCache) GetChDevicesIDTypeAndName ¶
func (d *DBDataCache) GetChDevicesIDTypeAndName() []*models.ChDevice
func (*DBDataCache) GetChVTapPorts ¶
func (d *DBDataCache) GetChVTapPorts() []*models.ChVTapPort
func (*DBDataCache) GetDataCacheFromDB ¶
func (d *DBDataCache) GetDataCacheFromDB(db *gorm.DB)
func (*DBDataCache) GetDhcpPorts ¶
func (d *DBDataCache) GetDhcpPorts() []*models.DHCPPort
func (*DBDataCache) GetDomains ¶
func (d *DBDataCache) GetDomains() []*models.Domain
func (*DBDataCache) GetFloatingIPs ¶
func (d *DBDataCache) GetFloatingIPs() []*models.FloatingIP
func (*DBDataCache) GetHostDevices ¶
func (d *DBDataCache) GetHostDevices() []*models.Host
func (*DBDataCache) GetLANIPs ¶
func (d *DBDataCache) GetLANIPs() []*models.LANIP
func (*DBDataCache) GetLBListeners ¶
func (d *DBDataCache) GetLBListeners() []*models.LBListener
func (*DBDataCache) GetLBTargetServers ¶
func (d *DBDataCache) GetLBTargetServers() []*models.LBTargetServer
func (*DBDataCache) GetLBs ¶
func (d *DBDataCache) GetLBs() []*models.LB
func (*DBDataCache) GetNats ¶
func (d *DBDataCache) GetNats() []*models.NATGateway
func (*DBDataCache) GetNetworks ¶
func (d *DBDataCache) GetNetworks() []*models.Network
func (*DBDataCache) GetNpbPolicies ¶
func (d *DBDataCache) GetNpbPolicies() []*models.NpbPolicy
func (*DBDataCache) GetNpbTunnels ¶
func (d *DBDataCache) GetNpbTunnels() []*models.NpbTunnel
func (*DBDataCache) GetPcapPolicies ¶
func (d *DBDataCache) GetPcapPolicies() []*models.PcapPolicy
func (*DBDataCache) GetPeerConnections ¶
func (d *DBDataCache) GetPeerConnections() []*models.PeerConnection
func (*DBDataCache) GetPodClusters ¶
func (d *DBDataCache) GetPodClusters() []*models.PodCluster
func (*DBDataCache) GetPodGroupPorts ¶
func (d *DBDataCache) GetPodGroupPorts() []*models.PodGroupPort
func (*DBDataCache) GetPodGroups ¶
func (d *DBDataCache) GetPodGroups() []*models.PodGroup
func (*DBDataCache) GetPodNSsIDAndName ¶
func (d *DBDataCache) GetPodNSsIDAndName() []*models.PodNamespace
func (*DBDataCache) GetPodNodes ¶
func (d *DBDataCache) GetPodNodes() []*models.PodNode
func (*DBDataCache) GetPodServicePorts ¶
func (d *DBDataCache) GetPodServicePorts() []*models.PodServicePort
func (*DBDataCache) GetPodServices ¶
func (d *DBDataCache) GetPodServices() []*models.PodService
func (*DBDataCache) GetPods ¶
func (d *DBDataCache) GetPods() []*models.Pod
func (*DBDataCache) GetProcesses ¶
func (d *DBDataCache) GetProcesses() []*models.Process
func (*DBDataCache) GetRdsInstances ¶
func (d *DBDataCache) GetRdsInstances() []*models.RDSInstance
func (*DBDataCache) GetRedisInstances ¶
func (d *DBDataCache) GetRedisInstances() []*models.RedisInstance
func (*DBDataCache) GetRegions ¶
func (d *DBDataCache) GetRegions() []*models.Region
func (*DBDataCache) GetResourceGroupExtraInfos ¶
func (d *DBDataCache) GetResourceGroupExtraInfos() []*models.ResourceGroupExtraInfo
func (*DBDataCache) GetResourceGroups ¶
func (d *DBDataCache) GetResourceGroups() []*models.ResourceGroup
func (*DBDataCache) GetSkipVTaps ¶
func (d *DBDataCache) GetSkipVTaps() []*models.VTap
func (*DBDataCache) GetSubDomains ¶
func (d *DBDataCache) GetSubDomains() []*models.SubDomain
func (*DBDataCache) GetSubnets ¶
func (d *DBDataCache) GetSubnets() []*models.Subnet
func (*DBDataCache) GetSysConfigurations ¶
func (d *DBDataCache) GetSysConfigurations() []*models.SysConfiguration
func (*DBDataCache) GetVIPs ¶
func (d *DBDataCache) GetVIPs() []*models.VIP
func (*DBDataCache) GetVInterfaces ¶
func (d *DBDataCache) GetVInterfaces() []*models.VInterface
func (*DBDataCache) GetVPCs ¶
func (d *DBDataCache) GetVPCs() []*models.VPC
func (*DBDataCache) GetVRouters ¶
func (d *DBDataCache) GetVRouters() []*models.VRouter
func (*DBDataCache) GetVTapsIDAndName ¶
func (d *DBDataCache) GetVTapsIDAndName() []*models.VTap
func (*DBDataCache) GetVipDomains ¶
func (d *DBDataCache) GetVipDomains() []*models.Domain
func (*DBDataCache) GetVmPodNodeConns ¶
func (d *DBDataCache) GetVmPodNodeConns() []*models.VMPodNodeConnection
func (*DBDataCache) GetVms ¶
func (d *DBDataCache) GetVms() []*models.VM
func (*DBDataCache) GetWANIPs ¶
func (d *DBDataCache) GetWANIPs() []*models.WANIP
type DomainCIDRProto ¶
type DomainCIDRProto struct {
// contains filtered or unexported fields
}
type DomainIPKey ¶
type DomainInterfaceData ¶
type DomainInterfaceData map[string]TInterfaces
type DomainInterfaceProto ¶
type DomainInterfaceProto struct { ORGID // contains filtered or unexported fields }
func NewDomainInterfaceProto ¶
func NewDomainInterfaceProto(orgID ORGID) *DomainInterfaceProto
type DomainPeerConnProto ¶
type DomainPeerConnProto struct {
// contains filtered or unexported fields
}
func NewDomainPeerConnProto ¶
func NewDomainPeerConnProto(length int) *DomainPeerConnProto
type DomainPeerConnsData ¶
type DomainPeerConnsData map[string]TPeerConnections
type DomainPlatformData ¶
type DomainPlatformData map[string]*PlatformData
type DomainToPlatformData ¶
type DomainToPlatformData struct {
// contains filtered or unexported fields
}
func (*DomainToPlatformData) GetAZToPlatformDataOnlyPod ¶
func (d *DomainToPlatformData) GetAZToPlatformDataOnlyPod() DomainPlatformData
func (*DomainToPlatformData) GetAllCompletePlatformDataExceptPod ¶
func (d *DomainToPlatformData) GetAllCompletePlatformDataExceptPod() *PlatformData
func (*DomainToPlatformData) GetAllSimplePlatformData ¶
func (d *DomainToPlatformData) GetAllSimplePlatformData() *PlatformData
func (*DomainToPlatformData) GetAllSimplePlatformDataExceptPod ¶
func (d *DomainToPlatformData) GetAllSimplePlatformDataExceptPod() *PlatformData
func (*DomainToPlatformData) GetDomainToAllPlatformData ¶
func (d *DomainToPlatformData) GetDomainToAllPlatformData() DomainPlatformData
func (*DomainToPlatformData) GetDomainToPlatformDataExceptPod ¶
func (d *DomainToPlatformData) GetDomainToPlatformDataExceptPod() DomainPlatformData
func (*DomainToPlatformData) GetDomainToPlatformDataOnlyPod ¶
func (d *DomainToPlatformData) GetDomainToPlatformDataOnlyPod() DomainPlatformData
func (*DomainToPlatformData) GetNoDomainPlatformData ¶
func (d *DomainToPlatformData) GetNoDomainPlatformData() *PlatformData
func (*DomainToPlatformData) GetRegionToPlatformDataOnlyPod ¶
func (d *DomainToPlatformData) GetRegionToPlatformDataOnlyPod() DomainPlatformData
type GProcessInfoProto ¶
type GProcessInfoProto struct {
// contains filtered or unexported fields
}
GProcessInfoProto is only used to send to the ingester module.
type GroupData ¶
type GroupData struct {
// contains filtered or unexported fields
}
func NewGroupData ¶
func NewGroupData(groupsProto []*trident.Group, svcsProto []*trident.ServiceInfo) *GroupData
type GroupDataOP ¶
type GroupDataOP struct { ORGID // contains filtered or unexported fields }
func (*GroupDataOP) GetGroupIDToPodServiceIDs ¶
func (g *GroupDataOP) GetGroupIDToPodServiceIDs() map[int][]int
func (*GroupDataOP) GetIDToGroup ¶
func (g *GroupDataOP) GetIDToGroup() map[int]*models.ResourceGroup
func (*GroupDataOP) SetStartTime ¶
func (g *GroupDataOP) SetStartTime(startTime int64)
type GroupProto ¶
type GroupProto struct { ORGID // contains filtered or unexported fields }
func NewGroupProto ¶
func NewGroupProto(orgID ORGID, startTime int64) *GroupProto
func (*GroupProto) GenerateIngesterGroup ¶
func (g *GroupProto) GenerateIngesterGroup(groupData *GroupData)
func (*GroupProto) GetGroups ¶
func (g *GroupProto) GetGroups() []byte
func (*GroupProto) GetVersion ¶
func (g *GroupProto) GetVersion() uint64
func (*GroupProto) SetStartTime ¶
func (g *GroupProto) SetStartTime(startTime int64)
func (*GroupProto) String ¶
func (g *GroupProto) String() string
type GroupRawData ¶
type GroupRawData struct {
// contains filtered or unexported fields
}
type IDToNetworkMacs ¶
type IDToNetworkMacs map[int]NetworkMacs
type InterfaceProto ¶
type InterfaceProto struct {
// contains filtered or unexported fields
}
type IpResourceData ¶
type IpResourceData struct {
// contains filtered or unexported fields
}
type MetaData ¶
type MetaData struct { ORGID // contains filtered or unexported fields }
func NewMetaData ¶
func (*MetaData) GetDBDataCache ¶
func (m *MetaData) GetDBDataCache() *DBDataCache
func (*MetaData) GetDropletGroups ¶
func (*MetaData) GetDropletGroupsVersion ¶
func (*MetaData) GetDropletPolicyStr ¶
func (*MetaData) GetDropletPolicyVersion ¶
func (*MetaData) GetGroupDataOP ¶
func (m *MetaData) GetGroupDataOP() *GroupDataOP
func (*MetaData) GetPlatformDataOP ¶
func (m *MetaData) GetPlatformDataOP() *PlatformDataOP
func (*MetaData) GetPlatformVips ¶
func (*MetaData) GetPolicyDataOP ¶
func (m *MetaData) GetPolicyDataOP() *PolicyDataOP
func (*MetaData) GetStartTime ¶
func (*MetaData) GetTapTypes ¶
func (*MetaData) GetTridentGroups ¶
func (*MetaData) GetTridentGroupsVersion ¶
func (*MetaData) GetVTapPolicyString ¶
func (*MetaData) GetVTapPolicyVersion ¶
func (*MetaData) PutChGroup ¶
func (m *MetaData) PutChGroup()
func (*MetaData) PutChPlatformData ¶
func (m *MetaData) PutChPlatformData()
func (*MetaData) PutChPolicy ¶
func (m *MetaData) PutChPolicy()
func (*MetaData) PutChTapType ¶
func (m *MetaData) PutChTapType()
func (*MetaData) TimedRefreshMetaData ¶
func (m *MetaData) TimedRefreshMetaData()
type NetworkMacs ¶
type PlatformData ¶
type PlatformData struct {
// contains filtered or unexported fields
}
func NewPlatformData ¶
func NewPlatformData(domain string, lcuuid string, version uint64, dataType uint32) *PlatformData
func (*PlatformData) GeneratePlatformDataResult ¶
func (f *PlatformData) GeneratePlatformDataResult()
func (*PlatformData) GetPlatformDataResult ¶
func (f *PlatformData) GetPlatformDataResult() ([]byte, uint64)
func (*PlatformData) GetPlatformDataStr ¶
func (f *PlatformData) GetPlatformDataStr() []byte
func (*PlatformData) GetPlatformDataVersion ¶
func (f *PlatformData) GetPlatformDataVersion() uint64
func (*PlatformData) GetVersion ¶
func (f *PlatformData) GetVersion() uint64
func (*PlatformData) Merge ¶
func (f *PlatformData) Merge(other *PlatformData)
func (*PlatformData) MergeInterfaces ¶
func (f *PlatformData) MergeInterfaces(other *PlatformData)
func (*PlatformData) MergePeerConnProtos ¶
func (f *PlatformData) MergePeerConnProtos(other *PlatformData)
func (*PlatformData) String ¶
func (f *PlatformData) String() string
type PlatformDataOP ¶
type PlatformDataOP struct { GProcessInfoProto *atomic.Value // *GProcessInfoProto // 生成的平台数据 *DomainToPlatformData *Segment ORGID // contains filtered or unexported fields }
func (*PlatformDataOP) GeneratePlatformData ¶
func (p *PlatformDataOP) GeneratePlatformData()
func (*PlatformDataOP) GetAllPlatformDataForIngester ¶
func (p *PlatformDataOP) GetAllPlatformDataForIngester() *PlatformData
func (*PlatformDataOP) GetNoDomainPeerConns ¶
func (p *PlatformDataOP) GetNoDomainPeerConns() TPeerConnections
func (*PlatformDataOP) GetPlatformDataChangedCh ¶
func (p *PlatformDataOP) GetPlatformDataChangedCh() <-chan struct{}
func (*PlatformDataOP) GetPodIPs ¶
func (p *PlatformDataOP) GetPodIPs() []*trident.PodIp
func (*PlatformDataOP) GetRawData ¶
func (p *PlatformDataOP) GetRawData() *PlatformRawData
func (*PlatformDataOP) GetSegment ¶
func (p *PlatformDataOP) GetSegment() *Segment
func (*PlatformDataOP) RegisteNotifyIngesterDatachanged ¶
func (p *PlatformDataOP) RegisteNotifyIngesterDatachanged(notify func())
type PlatformRawData ¶
type PlatformRawData struct { VInterfaceIDToWANIP map[int][]*models.WANIP VInterfaceIDToLANIP map[int][]*models.LANIP ORGID // contains filtered or unexported fields }
func NewPlatformRawData ¶
func NewPlatformRawData(orgID ORGID) *PlatformRawData
func (*PlatformRawData) ConvertDBAZ ¶
func (r *PlatformRawData) ConvertDBAZ(dbDataCache *DBDataCache)
func (*PlatformRawData) ConvertDBCEN ¶
func (r *PlatformRawData) ConvertDBCEN(dbDataCache *DBDataCache)
func (*PlatformRawData) ConvertDBCache ¶
func (r *PlatformRawData) ConvertDBCache(dbDataCache *DBDataCache)
有依赖 需要按顺序convert
func (*PlatformRawData) ConvertDBDHCPPort ¶
func (r *PlatformRawData) ConvertDBDHCPPort(dbDataCache *DBDataCache)
func (*PlatformRawData) ConvertDBIPs ¶
func (r *PlatformRawData) ConvertDBIPs(dbDataCache *DBDataCache)
func (*PlatformRawData) ConvertDBLB ¶
func (r *PlatformRawData) ConvertDBLB(dbDataCache *DBDataCache)
func (*PlatformRawData) ConvertDBNat ¶
func (r *PlatformRawData) ConvertDBNat(dbDataCache *DBDataCache)
func (*PlatformRawData) ConvertDBNetwork ¶
func (r *PlatformRawData) ConvertDBNetwork(dbDataCache *DBDataCache)
func (*PlatformRawData) ConvertDBPeerConnection ¶
func (r *PlatformRawData) ConvertDBPeerConnection(dbDataCache *DBDataCache)
func (*PlatformRawData) ConvertDBPod ¶
func (r *PlatformRawData) ConvertDBPod(dbDataCache *DBDataCache)
func (*PlatformRawData) ConvertDBPodGroup ¶
func (r *PlatformRawData) ConvertDBPodGroup(dbDataCache *DBDataCache)
func (*PlatformRawData) ConvertDBPodGroupPort ¶
func (r *PlatformRawData) ConvertDBPodGroupPort(dbDataCache *DBDataCache)
func (*PlatformRawData) ConvertDBPodNode ¶
func (r *PlatformRawData) ConvertDBPodNode(dbDataCache *DBDataCache)
func (*PlatformRawData) ConvertDBPodService ¶
func (r *PlatformRawData) ConvertDBPodService(dbDataCache *DBDataCache)
func (*PlatformRawData) ConvertDBPodServicePort ¶
func (r *PlatformRawData) ConvertDBPodServicePort(dbDataCache *DBDataCache)
func (*PlatformRawData) ConvertDBProcesses ¶
func (r *PlatformRawData) ConvertDBProcesses(dbDataCache *DBDataCache)
func (*PlatformRawData) ConvertDBRdsInstance ¶
func (r *PlatformRawData) ConvertDBRdsInstance(dbDataCache *DBDataCache)
func (*PlatformRawData) ConvertDBRedisInstance ¶
func (r *PlatformRawData) ConvertDBRedisInstance(dbDataCache *DBDataCache)
func (*PlatformRawData) ConvertDBRegion ¶
func (r *PlatformRawData) ConvertDBRegion(dbDataCache *DBDataCache)
func (*PlatformRawData) ConvertDBVIPs ¶
func (r *PlatformRawData) ConvertDBVIPs(dbDataCache *DBDataCache)
func (*PlatformRawData) ConvertDBVInterface ¶
func (r *PlatformRawData) ConvertDBVInterface(dbDataCache *DBDataCache)
func (*PlatformRawData) ConvertDBVM ¶
func (r *PlatformRawData) ConvertDBVM(dbDataCache *DBDataCache)
func (*PlatformRawData) ConvertDBVPC ¶
func (r *PlatformRawData) ConvertDBVPC(dbDataCache *DBDataCache)
func (*PlatformRawData) ConvertDBVRouter ¶
func (r *PlatformRawData) ConvertDBVRouter(dbDataCache *DBDataCache)
func (*PlatformRawData) ConvertDBVTaps ¶
func (r *PlatformRawData) ConvertDBVTaps(dbDataCache *DBDataCache)
func (*PlatformRawData) ConvertDBVipDomain ¶
func (r *PlatformRawData) ConvertDBVipDomain(dbDataCache *DBDataCache)
func (*PlatformRawData) ConvertDBVmPodNodeConn ¶
func (r *PlatformRawData) ConvertDBVmPodNodeConn(dbDataCache *DBDataCache)
func (*PlatformRawData) ConvertHost ¶
func (r *PlatformRawData) ConvertHost(dbDataCache *DBDataCache)
func (*PlatformRawData) ConvertSkipVTapVIfIDs ¶
func (r *PlatformRawData) ConvertSkipVTapVIfIDs(dbDataCache *DBDataCache)
func (*PlatformRawData) GetContainers ¶
func (r *PlatformRawData) GetContainers(vtapID int) []*trident.Container
func (*PlatformRawData) GetHostIDToVifs ¶
func (r *PlatformRawData) GetHostIDToVifs() map[int]mapset.Set
func (*PlatformRawData) GetIDToNetwork ¶
func (r *PlatformRawData) GetIDToNetwork() map[int]*models.Network
func (*PlatformRawData) GetPodGroup ¶
func (r *PlatformRawData) GetPodGroup(podGroupID int) *models.PodGroup
func (*PlatformRawData) GetPodNode ¶
func (r *PlatformRawData) GetPodNode(podNodeID int) *models.PodNode
func (*PlatformRawData) GetPodNodeIDToVmID ¶
func (r *PlatformRawData) GetPodNodeIDToVmID() map[int]int
func (*PlatformRawData) GetServerToVmIDs ¶
func (r *PlatformRawData) GetServerToVmIDs() map[string]mapset.Set
func (*PlatformRawData) GetSkipInterface ¶
func (r *PlatformRawData) GetSkipInterface(server string) []*trident.SkipInterface
func (*PlatformRawData) GetVMIDToPodNodeID ¶
func (r *PlatformRawData) GetVMIDToPodNodeID() map[int]int
type Policy ¶
type Policy struct { ORGID // contains filtered or unexported fields }
func (*Policy) GenerateIngesterData ¶
func (p *Policy) GenerateIngesterData()
func (*Policy) GetAllSerializeString ¶
func (*Policy) GetAllVersion ¶
func (*Policy) MergeIngesterPolicy ¶
type PolicyDataOP ¶
type PolicyDataOP struct { ORGID // contains filtered or unexported fields }
func (*PolicyDataOP) GetDropletPolicy ¶
func (op *PolicyDataOP) GetDropletPolicy() *Policy
func (*PolicyDataOP) GetRawData ¶
func (op *PolicyDataOP) GetRawData() *PolicyRawData
func (*PolicyDataOP) String ¶
func (op *PolicyDataOP) String() string
type PolicyRawData ¶
type PolicyRawData struct {
// contains filtered or unexported fields
}
type Segment ¶
type Segment struct { ORGID // contains filtered or unexported fields }
func (*Segment) ClearVTapUsedVInterfaceIDs ¶
func (s *Segment) ClearVTapUsedVInterfaceIDs()
func (*Segment) GenerateNoVTapUsedSegments ¶
func (s *Segment) GenerateNoVTapUsedSegments(rawData *PlatformRawData)
func (*Segment) GetAllGatewayHostSegments ¶
func (*Segment) GetHostIDSegments ¶
func (*Segment) GetLaunchServerSegments ¶
func (*Segment) GetNotVtapUsedSegments ¶
func (*Segment) GetPodNodeSegments ¶
func (*Segment) GetTypeVMSegments ¶
type ServerToNetworkMacs ¶
type ServerToNetworkMacs map[string]NetworkMacs
type ServiceDataOP ¶
type ServiceDataOP struct { ORGID // contains filtered or unexported fields }
func (*ServiceDataOP) GenerateServiceData ¶
func (s *ServiceDataOP) GenerateServiceData()
func (*ServiceDataOP) GetServiceData ¶
func (s *ServiceDataOP) GetServiceData() []*trident.ServiceInfo
type ServiceRawData ¶
type ServiceRawData struct {
// contains filtered or unexported fields
}
func (*ServiceRawData) ConvertDBData ¶
func (r *ServiceRawData) ConvertDBData(dbDataCache *DBDataCache)
type TInterfaces ¶
type TPeerConnections ¶
type TPeerConnections []*trident.PeerConnection
type TypeIDData ¶
Click to show internal directories.
Click to hide internal directories.