MCPcopy Create free account
hub / github.com/deepflowio/deepflow / getSubDomainPodGroups

Method getSubDomainPodGroups

server/controller/cloud/sub_domain.go:598–645  ·  view source on GitHub ↗
(
	subDomainLcuuid string, resource *kubernetes_model.KubernetesGatherResource, azLcuuid string,
)

Source from the content-addressed store, hash-verified

596}
597
598func (c *Cloud) getSubDomainPodGroups(
599 subDomainLcuuid string, resource *kubernetes_model.KubernetesGatherResource, azLcuuid string,
600) ([]model.PodGroup, []model.PodGroupPort, []model.PodGroupConfigMapConnection) {
601 var retPodGroups []model.PodGroup
602 var retPodGroupPorts []model.PodGroupPort
603 var retPodGroupConfigMapConnections []model.PodGroupConfigMapConnection
604
605 // 遍历PodGroups,更新az信息;并添加到Cloud的Resource中
606 for _, podGroup := range resource.PodGroups {
607 retPodGroups = append(retPodGroups, model.PodGroup{
608 Lcuuid: podGroup.Lcuuid,
609 Name: podGroup.Name,
610 Metadata: podGroup.Metadata,
611 MetadataHash: podGroup.MetadataHash,
612 Spec: podGroup.Spec,
613 SpecHash: podGroup.SpecHash,
614 Label: podGroup.Label,
615 NetworkMode: podGroup.NetworkMode,
616 Type: podGroup.Type,
617 PodNum: podGroup.PodNum,
618 PodNamespaceLcuuid: podGroup.PodNamespaceLcuuid,
619 PodClusterLcuuid: podGroup.PodClusterLcuuid,
620 AZLcuuid: azLcuuid,
621 RegionLcuuid: podGroup.RegionLcuuid,
622 SubDomainLcuuid: subDomainLcuuid,
623 })
624 }
625 for _, podGroupPort := range resource.PodGroupPorts {
626 retPodGroupPorts = append(retPodGroupPorts, model.PodGroupPort{
627 Lcuuid: podGroupPort.Lcuuid,
628 Name: podGroupPort.Name,
629 Protocol: podGroupPort.Protocol,
630 Port: podGroupPort.Port,
631 PodGroupLcuuid: podGroupPort.PodGroupLcuuid,
632 PodServiceLcuuid: podGroupPort.PodServiceLcuuid,
633 SubDomainLcuuid: subDomainLcuuid,
634 })
635 }
636 for _, connection := range resource.PodGroupConfigMapConnections {
637 retPodGroupConfigMapConnections = append(retPodGroupConfigMapConnections, model.PodGroupConfigMapConnection{
638 Lcuuid: connection.Lcuuid,
639 PodGroupLcuuid: connection.PodGroupLcuuid,
640 ConfigMapLcuuid: connection.ConfigMapLcuuid,
641 SubDomainLcuuid: subDomainLcuuid,
642 })
643 }
644 return retPodGroups, retPodGroupPorts, retPodGroupConfigMapConnections
645}
646
647func (c *Cloud) getSubDomainPodReplicaSets(
648 subDomainLcuuid string, resource *kubernetes_model.KubernetesGatherResource, azLcuuid string,

Callers 1

Calls

no outgoing calls

Tested by

no test coverage detected