MCPcopy Index your code
hub / github.com/deepflowio/deepflow / refreshNetworks

Method refreshNetworks

server/controller/recorder/cache/cache.go:599–624  ·  view source on GitHub ↗
()

Source from the content-addressed store, hash-verified

597}
598
599func (c *Cache) refreshNetworks() []int {
600 log.Info(refreshResource(ctrlrcommon.RESOURCE_TYPE_NETWORK_EN), c.metadata.LogPrefixes)
601 networkIDs := []int{}
602 networks, err := rcommon.PageWhereFind[metadbmodel.Network](c.metadata, c.getConditionDomainSubDomainCreateMethod())
603 if err != nil {
604 c.refreshFailed = true
605 log.Error(dbQueryResourceFailed(ctrlrcommon.RESOURCE_TYPE_NETWORK_EN, err), c.metadata.LogPrefixes)
606 return networkIDs
607 }
608
609 for _, item := range networks {
610 networkIDs = append(networkIDs, item.ID)
611 c.AddNetwork(item)
612 }
613
614 var publicNetwork *metadbmodel.Network
615 err = c.metadata.DB.Where("lcuuid = ?", rcommon.PUBLIC_NETWORK_LCUUID).First(&publicNetwork).Error
616 if err != nil {
617 c.refreshFailed = true
618 log.Error(dbQueryResourceFailed(ctrlrcommon.RESOURCE_TYPE_NETWORK_EN, err), c.metadata.LogPrefixes)
619 return networkIDs
620 }
621 c.ToolDataSet.SetPublicNetworkID(publicNetwork.ID)
622
623 return networkIDs
624}
625
626func (c *Cache) AddSubnets(items []*metadbmodel.Subnet) {
627 for _, item := range items {

Callers 1

RefreshMethod · 0.95

Calls 7

AddNetworkMethod · 0.95
SetPublicNetworkIDMethod · 0.80
refreshResourceFunction · 0.70
dbQueryResourceFailedFunction · 0.70
ErrorMethod · 0.65
InfoMethod · 0.45

Tested by

no test coverage detected