Skip to content

Commit 58dd9c5

Browse files
askyrieSongZhen0704
authored andcommitted
feature: supprot configuration vtap group name
1 parent 41a2b2b commit 58dd9c5

File tree

4 files changed

+27
-25
lines changed

4 files changed

+27
-25
lines changed

server/controller/genesis/grpc/server.go

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -153,6 +153,7 @@ func (g *SynchronizerServer) GenerateCache() {
153153
g.workloadResourceEnabledCache.SetDefault(fmt.Sprintf("%d-", orgID), true)
154154
}
155155
g.workloadResourceEnabledCache.SetDefault(key, true)
156+
g.workloadResourceEnabledCache.SetDefault(fmt.Sprintf("%d-%s", orgID, group.Name), true)
156157
}
157158
}
158159
}

server/controller/trisolaris/services/grpc/agentsynchronize/sync_push.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -378,9 +378,9 @@ func (e *AgentEvent) generateNoAgentCacheDynamicConfig() *api.DynamicConfig {
378378
}
379379

380380
func (e *AgentEvent) generateNoAgentCacheUserConfig(groupID string, orgID int) *koanf.Koanf {
381-
vtapConfig := trisolaris.GetORGVTapInfo(orgID).GetVTapConfigFromShortID(groupID)
381+
vtapConfig := trisolaris.GetORGVTapInfo(orgID).GetVTapConfigByNameOrShortUUID(groupID)
382382
if vtapConfig == nil {
383-
log.Warningf("not found vtap group short id (%s) config", groupID, logger.NewORGPrefix(orgID))
383+
log.Warningf("vtap group config (name or short_uuid: %s) not found", groupID, logger.NewORGPrefix(orgID))
384384
return koanf.New(".")
385385
}
386386
return vtapConfig.GetUserConfig()

server/controller/trisolaris/vtap/vtap.go

Lines changed: 9 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -68,7 +68,7 @@ type VTapInfo struct {
6868
lcuuidToVPCID map[string]int
6969
hostIDToVPCID map[int]int
7070
hypervNetworkHostIds mapset.Set
71-
vtapGroupShortIDToLcuuid map[string]string
71+
vtapGroupNameOrShortIDToLcuuid map[string]string
7272
vtapGroupLcuuidToShortID map[string]string
7373
vtapGroupLcuuidToConfiguration map[string]*VTapConfig
7474
vtapGroupLcuuidToLocalConfig map[string]string
@@ -137,7 +137,7 @@ func NewVTapInfo(db *gorm.DB, metaData *metadata.MetaData, cfg *config.Config, o
137137
lcuuidToVPCID: make(map[string]int),
138138
hostIDToVPCID: make(map[int]int),
139139
hypervNetworkHostIds: mapset.NewSet(),
140-
vtapGroupShortIDToLcuuid: make(map[string]string),
140+
vtapGroupNameOrShortIDToLcuuid: make(map[string]string),
141141
vtapGroupLcuuidToShortID: make(map[string]string),
142142
vtapGroupLcuuidToConfiguration: make(map[string]*VTapConfig),
143143
vtapGroupLcuuidToLocalConfig: make(map[string]string),
@@ -252,14 +252,15 @@ func (v *VTapInfo) loadVTapGroup() {
252252
return
253253
}
254254

255-
vtapGroupShortIDToLcuuid := make(map[string]string)
255+
vtapGroupNameOrShortIDToLcuuid := make(map[string]string)
256256
vtapGroupLcuuidToShortID := make(map[string]string)
257257
for _, vtapGroup := range vtapGroups {
258-
vtapGroupShortIDToLcuuid[vtapGroup.ShortUUID] = vtapGroup.Lcuuid
258+
vtapGroupNameOrShortIDToLcuuid[vtapGroup.Name] = vtapGroup.Lcuuid
259+
vtapGroupNameOrShortIDToLcuuid[vtapGroup.ShortUUID] = vtapGroup.Lcuuid
259260
vtapGroupLcuuidToShortID[vtapGroup.Lcuuid] = vtapGroup.ShortUUID
260261
}
261262

262-
v.vtapGroupShortIDToLcuuid = vtapGroupShortIDToLcuuid
263+
v.vtapGroupNameOrShortIDToLcuuid = vtapGroupNameOrShortIDToLcuuid
263264
v.vtapGroupLcuuidToShortID = vtapGroupLcuuidToShortID
264265
}
265266

@@ -504,11 +505,11 @@ func (v *VTapInfo) getAgentConfigs() {
504505
v.vtapGroupLcuuidToConfiguration = vtapGroupLcuuidToConfiguration
505506
}
506507

507-
func (v *VTapInfo) GetVTapConfigFromShortID(shortID string) *VTapConfig {
508+
func (v *VTapInfo) GetVTapConfigByNameOrShortUUID(nameOrShortUUID string) *VTapConfig {
508509
if v == nil {
509510
return nil
510511
}
511-
lcuuid, ok := v.vtapGroupShortIDToLcuuid[shortID]
512+
lcuuid, ok := v.vtapGroupNameOrShortIDToLcuuid[nameOrShortUUID]
512513
if !ok {
513514
return nil
514515
}
@@ -527,7 +528,7 @@ func (v *VTapInfo) GetVTapLocalConfigByShortID(shortID string) string {
527528
if v == nil {
528529
return ""
529530
}
530-
lcuuid, ok := v.vtapGroupShortIDToLcuuid[shortID]
531+
lcuuid, ok := v.vtapGroupNameOrShortIDToLcuuid[shortID]
531532
if !ok {
532533
return ""
533534
}

server/controller/trisolaris/vtap/vtap_discovery.go

Lines changed: 15 additions & 15 deletions
Original file line numberDiff line numberDiff line change
@@ -33,16 +33,16 @@ import (
3333
)
3434

3535
type VTapRegister struct {
36-
tapMode int
37-
vTapGroupID string
38-
defaultVTapGroup string
39-
defaultVTapGroupLicenseFuntions string
40-
vTapAutoRegister bool
41-
agentUniqueIdentifier int
42-
teamID int
43-
vTapInfo *VTapInfo
44-
registerBy string
45-
groupLicenseFunctions string
36+
tapMode int
37+
vTapGroupID string
38+
defaultVTapGroup string
39+
defaultVTapGroupLicenseFunctions string
40+
vTapAutoRegister bool
41+
agentUniqueIdentifier int
42+
teamID int
43+
vTapInfo *VTapInfo
44+
registerBy string
45+
groupLicenseFunctions string
4646
VTapLKData
4747
ORGID
4848
}
@@ -126,12 +126,12 @@ func (r *VTapRegister) setRegisterBy(registerBy string) {
126126
}
127127

128128
func (r *VTapRegister) getVTapGroupLcuuid(db *gorm.DB) string {
129-
r.groupLicenseFunctions = r.defaultVTapGroupLicenseFuntions
129+
r.groupLicenseFunctions = r.defaultVTapGroupLicenseFunctions
130130
if r.vTapGroupID != "" {
131131
vtapGroup := &models.VTapGroup{}
132-
ret := db.Where("short_uuid = ?", r.vTapGroupID).First(vtapGroup)
132+
ret := db.Where("name = ?", r.vTapGroupID).Or("short_uuid = ?", r.vTapGroupID).First(vtapGroup)
133133
if ret.Error != nil {
134-
log.Error(r.Logf("vtap group(short_uuid=%s) not found", r.vTapGroupID))
134+
log.Error(r.Logf("vtap group (name or short_uuid: %s) not found", r.vTapGroupID))
135135
return r.defaultVTapGroup
136136
} else {
137137
r.groupLicenseFunctions = vtapGroup.LicenseFunctions
@@ -935,15 +935,15 @@ func (r *VTapRegister) registerVTap(done func()) {
935935
log.Error(r.Log(err.Error()))
936936
return
937937
}
938-
vtapConfig := r.vTapInfo.GetVTapConfigFromShortID(r.vTapGroupID)
938+
vtapConfig := r.vTapInfo.GetVTapConfigByNameOrShortUUID(r.vTapGroupID)
939939
if vtapConfig != nil {
940940
r.tapMode = vtapConfig.GetConfigTapMode()
941941
} else {
942942
r.tapMode = DefaultTapMode
943943
}
944944
r.region = v.getRegion()
945945
r.defaultVTapGroup = v.getDefaultVTapGroup()
946-
r.defaultVTapGroupLicenseFuntions = v.getDefaultVTapGroupLicenseFunctions()
946+
r.defaultVTapGroupLicenseFunctions = v.getDefaultVTapGroupLicenseFunctions()
947947
r.vTapAutoRegister = v.getVTapAutoRegister()
948948
log.Infof(r.Logf("register vtap: %s", r))
949949
var vtap *models.VTap

0 commit comments

Comments
 (0)