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

Method appendResourceVIPs

server/controller/cloud/cloud.go:717–748  ·  view source on GitHub ↗
(resource model.Resource)

Source from the content-addressed store, hash-verified

715}
716
717func (c *Cloud) appendResourceVIPs(resource model.Resource) model.Resource {
718
719 if genesis.GenesisService == nil {
720 log.Error("genesis service is nil", logger.NewORGPrefix(c.orgID))
721 return resource
722 }
723
724 genesisSyncData, err := genesis.GenesisService.GetGenesisSyncResponse(c.orgID)
725 if err != nil {
726 log.Error(err.Error(), logger.NewORGPrefix(c.orgID))
727 return resource
728 }
729
730 vtapIDToLcuuid, err := cloudcommon.GetVTapSubDomainMappingByDomain(c.basicInfo.Lcuuid, c.db.DB)
731 if err != nil {
732 log.Errorf("domain (%s) add vip failed: %s", c.basicInfo.Name, err.Error(), logger.NewORGPrefix(c.orgID))
733 return resource
734 }
735
736 for _, vip := range genesisSyncData.VIPs {
737 lcuuid, ok := vtapIDToLcuuid[int(vip.VtapID)]
738 if !ok || lcuuid != "" {
739 continue
740 }
741 resource.VIPs = append(resource.VIPs, model.VIP{
742 Lcuuid: vip.Lcuuid,
743 IP: vip.IP,
744 VTapID: vip.VtapID,
745 })
746 }
747 return resource
748}

Callers 1

GetResourceMethod · 0.95

Calls 3

ErrorMethod · 0.65
ErrorfMethod · 0.45

Tested by

no test coverage detected