go-service-pb/pb/constant/topic.go

package constant

// 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 (
	NomoTopicBoostOds                   = "nomo_topic_boost_ods"
	NomoTopicBoostOdsUserinfo           = "nomo_topic_boost_ods_userinfo"
	NomoTopicBoostOdsAllowVpnApp        = "nomo_topic_boost_ods_allow_vpn_app"
	NomoTopicBoostOdsPerformanceMetrics = "nomo_topic_boost_ods_performance_metrics"
	NomoTopicBoostOdsReconnection       = "nomo_topic_boost_ods_reconnection"
	NomoTopicBoostOdsConnection         = "nomo_topic_boost_ods_connection"
	NomoTopicBoostOdsConnectionHistory  = "nomo_topic_boost_ods_connection_history"
	NomoTopicBoostOdsRouteHistory       = "nomo_topic_boost_ods_route_history"
	NomoTopicBoostOdsReconnectionRecord = "nomo_topic_boost_ods_reconnection_record"
	NomoTopicBoostOdsRoutingNodes       = "nomo_topic_boost_ods_routing_nodes"
)

// 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"
)

// 公共 Topic（跨产品共享）
const (
	CommonPeakStream = "topic_peak_stream" // 公共削峰填谷主 topic
)