metadata

package
v0.0.0-...-9634a1a Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Feb 15, 2023 License: Apache-2.0 Imports: 22 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func ConvertToCIDR 

func ConvertToCIDR(ips []string)

func GetDefaultMaskLen 

func GetDefaultMaskLen(ip string) uint32

func GetTapTypesFromDB 

func GetTapTypesFromDB(db *gorm.DB) []*models.TapType

func NodeToProto 

func NodeToProto(
	podClusterId int, protocol trident.ServiceProtocol, serverPorts []uint32,
	serviceType trident.ServiceType, serviceID int) *trident.ServiceInfo

Types

type DBDataCache 

type DBDataCache struct {
	// 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) GetCENs 

func (d *DBDataCache) GetCENs() []*models.CEN

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) 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) 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) 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) GetVTapGroupConfigurationsFromDB 

func (d *DBDataCache) GetVTapGroupConfigurationsFromDB(db *gorm.DB) []*models.VTapGroupConfiguration

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 DomainIPKey struct {
	Domain string
	IP     string
}

type DomainInterfaceData 

type DomainInterfaceData map[string]TInterfaces

type DomainInterfaceProto 

type DomainInterfaceProto struct {
	// contains filtered or unexported fields
}

func NewDomainInterfaceProto 

func NewDomainInterfaceProto() *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 GroupDataOP 

type GroupDataOP struct {
	// 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

type GroupIDs 

type GroupIDs struct {
	// contains filtered or unexported fields
}

type GroupIP 

type GroupIP struct {
	// contains filtered or unexported fields
}

type GroupKey 

type GroupKey struct {
	// contains filtered or unexported fields
}

type GroupProto 

type GroupProto struct {
	// contains filtered or unexported fields
}

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 IDToVifs 

type IDToVifs map[int]mapset.Set

type IPData 

type IPData struct {
	IP     string
	VPCID  int
	Domain string
}

type InterfaceProto 

type InterfaceProto struct {
	// contains filtered or unexported fields
}

type IpResourceData 

type IpResourceData struct {
	// contains filtered or unexported fields
}

type MacID 

type MacID struct {
	Mac string
	ID  int
}

type MetaData 

type MetaData struct {
	// contains filtered or unexported fields
}

func NewMetaData 

func NewMetaData(db *gorm.DB, cfg *config.Config) *MetaData

func (*MetaData) GetDBDataCache 

func (m *MetaData) GetDBDataCache() *DBDataCache

func (*MetaData) GetDropletGroups 

func (m *MetaData) GetDropletGroups() []byte

func (*MetaData) GetDropletGroupsVersion 

func (m *MetaData) GetDropletGroupsVersion() uint64

func (*MetaData) GetDropletPolicyStr 

func (m *MetaData) GetDropletPolicyStr() []byte

func (*MetaData) GetDropletPolicyVersion 

func (m *MetaData) GetDropletPolicyVersion() uint64

func (*MetaData) GetGroupDataOP 

func (m *MetaData) GetGroupDataOP() *GroupDataOP

func (*MetaData) GetPlatformDataOP 

func (m *MetaData) GetPlatformDataOP() *PlatformDataOP

func (*MetaData) GetPlatformVips 

func (m *MetaData) GetPlatformVips() []string

func (*MetaData) GetTapTypes 

func (m *MetaData) GetTapTypes() []*trident.TapType

func (*MetaData) GetTridentGroups 

func (m *MetaData) GetTridentGroups() []byte

func (*MetaData) GetTridentGroupsVersion 

func (m *MetaData) GetTridentGroupsVersion() uint64

func (*MetaData) GetVTapPolicyString 

func (m *MetaData) GetVTapPolicyString(vtapID int, functions mapset.Set) []byte

func (*MetaData) GetVTapPolicyVersion 

func (m *MetaData) GetVTapPolicyVersion(vtapID int, functions mapset.Set) uint64

func (*MetaData) InitData 

func (m *MetaData) InitData()

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 NetworkMacs map[int][]*MacID

type NodeKey 

type NodeKey struct {
	// contains filtered or unexported fields
}

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 {

	// 生成的平台数据
	*DomainToPlatformData

	*Segment
	// 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

type PlatformRawData 

type PlatformRawData struct {
	VInterfaceIDToWANIP map[int][]*models.WANIP
	VInterfaceIDToLANIP map[int][]*models.LANIP
	// contains filtered or unexported fields
}

func NewPlatformRawData 

func NewPlatformRawData() *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) 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) 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) 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) 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) GetHostIDToVifs 

func (r *PlatformRawData) GetHostIDToVifs() map[int]mapset.Set

func (*PlatformRawData) GetIDToNetwork 

func (r *PlatformRawData) GetIDToNetwork() map[int]*models.Network

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 {
	// contains filtered or unexported fields
}

func (*Policy) String 

func (p *Policy) String() string

type PolicyDataOP 

type PolicyDataOP struct {
	// contains filtered or unexported fields
}

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 {
	// 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 (s *Segment) GetAllGatewayHostSegments() []*trident.Segment

func (*Segment) GetHostIDSegments 

func (s *Segment) GetHostIDSegments(hostID int) []*trident.Segment

func (*Segment) GetLaunchServerSegments 

func (s *Segment) GetLaunchServerSegments(launchServer string) []*trident.Segment

func (*Segment) GetNotVtapUsedSegments 

func (s *Segment) GetNotVtapUsedSegments() []*trident.Segment

func (*Segment) GetPodNodeSegments 

func (s *Segment) GetPodNodeSegments(podNodeID int) []*trident.Segment

func (*Segment) GetTypeVMSegments 

func (s *Segment) GetTypeVMSegments(launchServer string, hostID int) []*trident.Segment

func (*Segment) GetVMIDSegments 

func (s *Segment) GetVMIDSegments(vmID int) []*trident.Segment

type ServerToNetworkMacs 

type ServerToNetworkMacs map[string]NetworkMacs

type ServiceDataOP 

type ServiceDataOP struct {
	// 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 TInterfaces []*trident.Interface

type TPeerConnections 

type TPeerConnections []*trident.PeerConnection

type TapType 

type TapType struct {
	// contains filtered or unexported fields
}

type TypeIDData 

type TypeIDData struct {
	LaunchServer   string
	LaunchServerID int
	AZ             string
	VPCID          int
	PodID          int
	PodGroupID     int
	PodClusterID   int
	PodNodeID      int
	PodNamespaceID int
	Type           int
}

type TypeIDKey 

type TypeIDKey struct {
	Type int
	ID   int
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.