feat: tagrecorder add log

server/controller/tagrecorder/ch_app_label.go

@@ -39,6 +39,7 @@ func NewChAPPLabel() *ChAPPLabel {
 }
 
 func (l *ChAPPLabel) generateNewData(db *mysql.DB) (map[PrometheusAPPLabelKey]mysqlmodel.ChAPPLabel, bool) {
+	log.Infof("generate data for %s", l.resourceTypeName, db.LogPrefixORGID)
 	var prometheusLabels []mysqlmodel.PrometheusLabel
 	err := db.Unscoped().Find(&prometheusLabels).Error
 

server/controller/tagrecorder/ch_int_enum.go

@@ -37,6 +37,7 @@ func NewChIntEnum() *ChIntEnum {
 }
 
 func (e *ChIntEnum) generateNewData(dbClient *mysql.DB) (map[IntEnumTagKey]mysqlmodel.ChIntEnum, bool) {
+	log.Infof("generate data for %s", e.resourceTypeName, dbClient.LogPrefixORGID)
 	sql := "show tag all_int_enum values from tagrecorder"
 	db := "tagrecorder"
 	table := "tagrecorder"

server/controller/tagrecorder/ch_ip_relation.go

@@ -41,6 +41,7 @@ func NewChIPRelation() *ChIPRelation {
 }
 
 func (i *ChIPRelation) generateNewData(db *mysql.DB) (map[IPRelationKey]mysqlmodel.ChIPRelation, bool) {
+	log.Infof("generate data for %s", i.resourceTypeName, db.LogPrefixORGID)
 	toolDS, ok := i.newToolDataSet(db)
 	if !ok {
 		return nil, false

server/controller/tagrecorder/ch_label_name.go

@@ -37,6 +37,7 @@ func NewChPrometheusLabelName() *ChPrometheusLabelName {
 }
 
 func (l *ChPrometheusLabelName) generateNewData(db *mysql.DB) (map[IDKey]mysqlmodel.ChPrometheusLabelName, bool) {
+	log.Infof("generate data for %s", l.resourceTypeName, db.LogPrefixORGID)
 	var prometheusLabelName []mysqlmodel.PrometheusLabelName
 	err := db.Unscoped().Find(&prometheusLabelName).Error
 	if err != nil {

server/controller/tagrecorder/ch_lb_listener.go

@@ -39,6 +39,7 @@ func NewChLbListener(resourceTypeToIconID map[IconKey]int) *ChLbListener {
 }
 
 func (l *ChLbListener) generateNewData(db *mysql.DB) (map[IDKey]mysqlmodel.ChLBListener, bool) {
+	log.Infof("generate data for %s", l.resourceTypeName, db.LogPrefixORGID)
 	var lbListeners []mysqlmodel.LBListener
 	var lbTargetServers []mysqlmodel.LBTargetServer
 	err := db.Unscoped().Find(&lbListeners).Error

server/controller/tagrecorder/ch_metric_name.go

@@ -37,6 +37,7 @@ func NewChPrometheusMetricNames() *ChPrometheusMetricName {
 }
 
 func (l *ChPrometheusMetricName) generateNewData(db *mysql.DB) (map[IDKey]mysqlmodel.ChPrometheusMetricName, bool) {
+	log.Infof("generate data for %s", l.resourceTypeName, db.LogPrefixORGID)
 	var prometheusMetricName []mysqlmodel.PrometheusMetricName
 	err := db.Unscoped().Find(&prometheusMetricName).Error
 	if err != nil {

server/controller/tagrecorder/ch_node_type.go

@@ -36,6 +36,7 @@ func NewChNodeType() *ChNodeType {
 }
 
 func (n *ChNodeType) generateNewData(db *mysql.DB) (map[NodeTypeKey]mysqlmodel.ChNodeType, bool) {
+	log.Infof("generate data for %s", n.resourceTypeName, db.LogPrefixORGID)
 	keyToItem := make(map[NodeTypeKey]mysqlmodel.ChNodeType)
 	for resourceType, nodeType := range RESOURCE_TYPE_TO_NODE_TYPE {
 		keyToItem[NodeTypeKey{ResourceType: resourceType}] = mysqlmodel.ChNodeType{

server/controller/tagrecorder/ch_npb_tunnel.go

@@ -36,6 +36,7 @@ func NewChNpbTunnel() *ChNpbTunnel {
 }
 
 func (p *ChNpbTunnel) generateNewData(db *mysql.DB) (map[IDKey]mysqlmodel.ChNpbTunnel, bool) {
+	log.Infof("generate data for %s", p.resourceTypeName, db.LogPrefixORGID)
 	var npbTunnels []mysqlmodel.NpbTunnel
 	err := db.Unscoped().Select("id", "name", "team_id").Find(&npbTunnels).Error
 	if err != nil {

server/controller/tagrecorder/ch_os_app_tag.go

@@ -38,6 +38,7 @@ func NewChOSAppTag() *ChOSAppTag {
 }
 
 func (o *ChOSAppTag) generateNewData(db *mysql.DB) (map[IDKeyKey]mysqlmodel.ChOSAppTag, bool) {
+	log.Infof("generate data for %s", o.resourceTypeName, db.LogPrefixORGID)
 	var processes []mysqlmodel.Process
 	keyToItem := make(map[IDKeyKey]mysqlmodel.ChOSAppTag)
 	gidToOsAppTagMap := make(map[int]map[string]string)

server/controller/tagrecorder/ch_os_app_tags.go

@@ -39,6 +39,7 @@ func NewChOSAppTags() *ChOSAppTags {
 }
 
 func (o *ChOSAppTags) generateNewData(db *mysql.DB) (map[IDKey]mysqlmodel.ChOSAppTags, bool) {
+	log.Infof("generate data for %s", o.resourceTypeName, db.LogPrefixORGID)
 	var processes []mysqlmodel.Process
 	keyToItem := make(map[IDKey]mysqlmodel.ChOSAppTags)
 	gidToOsAppTagMap := make(map[int]map[string]string)

server/controller/tagrecorder/ch_policy.go

@@ -36,6 +36,7 @@ func NewChPolicy() *ChPolicy {
 }
 
 func (p *ChPolicy) generateNewData(db *mysql.DB) (map[PolicyKey]mysqlmodel.ChPolicy, bool) {
+	log.Infof("generate data for %s", p.resourceTypeName, db.LogPrefixORGID)
 	var (
 		pcapPolicys []mysqlmodel.PcapPolicy
 		npbPolicys  []mysqlmodel.NpbPolicy

server/controller/tagrecorder/ch_prometheus_metric_app_label_layout.go

@@ -37,6 +37,7 @@ func NewChPrometheusMetricAPPLabelLayout() *ChPrometheusMetricAPPLabelLayout {
 }
 
 func (l *ChPrometheusMetricAPPLabelLayout) generateNewData(db *mysql.DB) (map[IDKey]mysqlmodel.ChPrometheusMetricAPPLabelLayout, bool) {
+	log.Infof("generate data for %s", l.resourceTypeName, db.LogPrefixORGID)
 	var prometheusMetricAPPLabelLayout []mysqlmodel.PrometheusMetricAPPLabelLayout
 
 	err := db.Unscoped().Find(&prometheusMetricAPPLabelLayout).Error

server/controller/tagrecorder/ch_prometheus_target_label_layout.go

@@ -39,6 +39,7 @@ func NewChPrometheusTargetLabelLayout() *ChPrometheusTargetLabelLayout {
 }
 
 func (l *ChPrometheusTargetLabelLayout) generateNewData(db *mysql.DB) (map[IDKey]mysqlmodel.ChPrometheusTargetLabelLayout, bool) {
+	log.Infof("generate data for %s", l.resourceTypeName, db.LogPrefixORGID)
 	var prometheusTargets []mysqlmodel.PrometheusTarget
 	err := db.Unscoped().Find(&prometheusTargets).Error
 	if err != nil {

server/controller/tagrecorder/ch_string_enum.go

@@ -37,6 +37,7 @@ func NewChStringEnum() *ChStringEnum {
 }
 
 func (e *ChStringEnum) generateNewData(dbClient *mysql.DB) (map[StringEnumTagKey]mysqlmodel.ChStringEnum, bool) {
+	log.Infof("generate data for %s", e.resourceTypeName, dbClient.LogPrefixORGID)
 	sql := "show tag all_string_enum values from tagrecorder"
 	db := "tagrecorder"
 	table := "tagrecorder"

server/controller/tagrecorder/ch_tap_type.go

@@ -38,6 +38,7 @@ func NewChTapType(resourceTypeToIconID map[IconKey]int) *ChTapType {
 }
 
 func (t *ChTapType) generateNewData(db *mysql.DB) (map[TapTypeKey]mysqlmodel.ChTapType, bool) {
+	log.Infof("generate data for %s", t.resourceTypeName, db.LogPrefixORGID)
 	var tapTypes []mysqlmodel.TapType
 	err := db.Unscoped().Find(&tapTypes).Error
 	if err != nil {

server/controller/tagrecorder/ch_vtap.go

@@ -41,6 +41,7 @@ func NewChVTap(resourceTypeToIconID map[IconKey]int) *ChVTap {
 	return updater
 }
 func (v *ChVTap) generateNewData(db *mysql.DB) (map[IDKey]mysqlmodel.ChVTap, bool) {
+	log.Infof("generate data for %s", v.resourceTypeName, db.LogPrefixORGID)
 	var vTaps []mysqlmodel.VTap
 	err := db.Unscoped().Select("id", "type", "team_id", "name").Find(&vTaps).Error
 	if err != nil {

server/controller/tagrecorder/ch_vtap_port.go

@@ -55,6 +55,7 @@ func NewChVTapPort() *ChVTapPort {
 	return updater
 }
 func (v *ChVTapPort) generateNewData(db *metadb.DB) (map[VtapPortKey]metadbmodel.ChVTapPort, bool) {
+	log.Infof("generate data for %s", v.resourceTypeName, db.LogPrefixORGID)
 	var vTaps []metadbmodel.VTap
 	err := db.Where("type = ?", common.VTAP_TYPE_DEDICATED).Unscoped().Find(&vTaps).Error
 	if err != nil {