feat: topics

pb/constant/topic.go

@@ -1,10 +1,25 @@
 package constant
 
-// Nomo 产品 Kafka Topic（与 SpeedTop 产品一一对应，仅前缀不同 nomo_topic_ vs speedtop_topic_）
+// Nomo 模块 ODS Topic（事件处理链路各模块 handler 写入）
+const (
+	NomoTopicUserActiveOds         = "nomo_topic_user_active_ods"
+	NomoTopicUserBehaviorOds       = "nomo_topic_user_behavior_ods"
+	NomoTopicSpeedDetectOds        = "nomo_topic_speed_detect_ods"
+	NomoTopicDisconnectDomainOds   = "nomo_topic_disconnect_domain_ods"
+	NomoTopicFireBaseOds           = "nomo_topic_firebase_ods"
+	NomoTopicFireBaseTaskResultOds = "nomo_topic_firebase_task_result_ods"
+	NomoTopicPeekLogOds            = "nomo_topic_peek_log_ods"
+	NomoTopicBoostResultOds        = "nomo_topic_boost_result_ods"
+	NomoTopicAdLogOds              = "nomo_topic_ad_log_ods"
+	NomoTopicApiLaunchLogOds       = "nomo_topic_api_launch_log_ods"
+	NomoTopicApiOtherLogOds        = "nomo_topic_api_other_log_ods"
+	NomoTopicApiRouterLogOds       = "nomo_topic_api_router_log_ods"
+	NomoTopicFeedbackLogOds        = "nomo_topic_feedback_log_ods"
+	NomoTopicRateLogOds            = "nomo_topic_rate_log_ods"
+)
+
+// Nomo Boost Metrics 子 Topic（NM_Metrics handler 内部拆分写入）
 const (
-	NomoTopicUserActiveOds              = "nomo_topic_user_active_ods"
-	NomoTopicUserBehaviorOds            = "nomo_topic_user_behavior_ods"
-	NomoTopicUserUploadLogOds           = "nomo_topic_user_upload_log_ods"
 	NomoTopicBoostOds                   = "nomo_topic_boost_ods"
 	NomoTopicBoostOdsUserinfo           = "nomo_topic_boost_ods_userinfo"
 	NomoTopicBoostOdsAllowVpnApp        = "nomo_topic_boost_ods_allow_vpn_app"
@@ -15,22 +30,16 @@ const (
 	NomoTopicBoostOdsRouteHistory       = "nomo_topic_boost_ods_route_history"
 	NomoTopicBoostOdsReconnectionRecord = "nomo_topic_boost_ods_reconnection_record"
 	NomoTopicBoostOdsRoutingNodes       = "nomo_topic_boost_ods_routing_nodes"
-	NomoTopicBoostResultOds             = "nomo_topic_boost_result_ods"
-	NomoTopicSpeedDetectOds             = "nomo_topic_speed_detect_ods"
-	NomoTopicDisconnectDomainOds        = "nomo_topic_disconnect_domain_ods"
-	NomoTopicApiLaunchLogOds            = "nomo_topic_api_launch_log_ods"
-	NomoTopicApiOtherLogOds             = "nomo_topic_api_other_log_ods"
-	NomoTopicFireBaseOds                = "nomo_topic_firebase_ods"
-	NomoTopicFireBaseTaskResultOds      = "nomo_topic_firebase_task_result_ods"
-	NomoTopicPeekLogOds                 = "nomo_topic_peek_log_ods"
-	NomoTopicAdLogOds                   = "nomo_topic_ad_log_ods"
 )
 
-// Nomo 特有 Topic（不在 SpeedTop 中）
+// Nomo 日志文件上传 Topic（/api/v1/log/upload 写入）
+const (
+	NomoTopicUserUploadLogOds = "nomo_topic_user_upload_log_ods"
+)
+
+// Nomo Canal CDC Topic（MySQL binlog 变更写入）
 const (
-	NomoTopicDeviceInfoOds   = "nomo_topic_device_info_ods"
-	NomoTopicApiRouterLogOds = "nomo_topic_api_router_log_ods"
-	NomoTopicFeedbackLogOds  = "nomo_topic_feedback_log_ods"
+	NomoTopicDeviceInfoOds = "nomo_topic_device_info_ods"
 )
 
 // 公共 Topic（跨产品共享）