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

package constant

// Nomo 产品 Kafka Topic（与 SpeedTop 产品一一对应，仅前缀不同 nomo_topic_ vs speedtop_topic_）
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"
	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"
	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 中）
const (
	NomoTopicDeviceInfoOds    = "nomo_topic_device_info_ods"
	NomoTopicApiRouterLogOds  = "nomo_topic_api_router_log_ods"
	NomoTopicFeedbackLogOds   = "nomo_topic_feedback_log_ods"
)

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