Merge pull request #591 from tapdata/feat/TAP-11870-Rebalance

Feat/tap 11870 rebalance

Author: feynmx

apps/daas/src/i18n/langs/en.js

@@ -2251,6 +2251,7 @@ export default {
   daas_role_role_gongnengquanxian: 'Function Permission',
   daas_role_role_yemianquanxian: 'Page Permission',
   daas_role_role_gongnengmokuai: 'Function Module',
+  daas_role_role_no_matching_module: 'No matching modules',
   daas_role_role_gouxuanxiangyingmo:
     'Check the corresponding module to indicate that the navigation is visible to users under the current role, and enable [View All Data] to indicate that the role can view and operate all the data under this module, and if it is not checked, it can only view and operate the data created and authorized by itself data. ',
   daas_feature_unavailable: 'Restricted Feature',
@@ -2280,6 +2281,76 @@ export default {
   daas_cluster_engine_hostname: 'Hostname/IP',
   daas_cluster_connection_count: 'TCP Connection Count',
   daas_cluser_keyword_placeholder: 'Search for hostnames',
+  daas_task_rebalance_button: 'Task Rebalance',
+  daas_task_rebalance_title: 'Task Rebalance Plan',
+  daas_task_rebalance_subtitle:
+    'Drag task cards onto a target engine to adjust the task distribution across engines',
+  daas_task_rebalance_online: 'Online',
+  daas_task_rebalance_offline: 'Offline',
+  daas_task_rebalance_memory: 'Memory Usage',
+  daas_task_rebalance_task_count: 'Tasks',
+  daas_task_rebalance_legend_move: 'Tasks to be moved',
+  daas_task_rebalance_legend_locked: 'Tasks that cannot be rebalanced',
+  daas_task_rebalance_cancel: 'Cancel',
+  daas_task_rebalance_confirm: 'Confirm Rebalance',
+  daas_task_rebalance_create: 'Create Rebalance',
+  daas_task_rebalance_empty: 'No tasks available for rebalancing',
+  daas_task_rebalance_create_success: 'Rebalance plan created, migration started',
+  daas_task_rebalance_type_initial_sync: 'Full',
+  daas_task_rebalance_type_cdc: 'Incremental',
+  daas_task_rebalance_type_full_cdc: 'Full + Incremental',
+  daas_task_rebalance_reason_only_one_agent:
+    'At least two available engines are required',
+  daas_task_rebalance_reason_agent_offline: 'The current engine is offline',
+  daas_task_rebalance_reason_status_error:
+    'The task is not running and cannot be migrated',
+  daas_task_rebalance_reason_manual_agent:
+    'A fixed engine is specified and cannot be migrated',
+  daas_task_rebalance_reason_incremental:
+    'Initial sync in progress, cannot be migrated',
+  daas_task_rebalance_history_title: 'Task Rebalance Records',
+  daas_task_rebalance_history_list_title: 'History',
+  daas_task_rebalance_history_empty: 'No rebalance records',
+  daas_task_rebalance_history_empty_desc:
+    'Records will appear here after a rebalance',
+  daas_task_rebalance_history_detail_empty: 'Select a record on the left',
+  daas_task_rebalance_history_task_total: '{count} tasks',
+  daas_task_rebalance_history_record_creating: 'Creating',
+  daas_task_rebalance_history_record_running: 'Running',
+  daas_task_rebalance_history_record_done: 'Completed',
+  daas_task_rebalance_history_record_partial: 'Partially Completed',
+  daas_task_rebalance_history_record_cancelled: 'Cancelled',
+  daas_task_rebalance_history_record_failed: 'Failed',
+  daas_task_rebalance_history_job_pending: 'Pending',
+  daas_task_rebalance_history_job_starting: 'Starting',
+  daas_task_rebalance_history_job_stopping: 'Stopping',
+  daas_task_rebalance_history_job_ok: 'Completed',
+  daas_task_rebalance_history_job_cancelled: 'Cancelled',
+  daas_task_rebalance_history_job_invalid_agent: 'Invalid Agent',
+  daas_task_rebalance_history_job_status_error: 'Status Error',
+  daas_task_rebalance_history_job_stop_timeout: 'Stop Timeout',
+  daas_task_rebalance_history_job_start_timeout: 'Start Timeout',
+  daas_task_rebalance_history_job_failed: 'Failed',
+  daas_task_rebalance_history_stat_success: 'Success',
+  daas_task_rebalance_history_stat_failed: 'Failed',
+  daas_task_rebalance_history_stat_skipped: 'Skipped',
+  daas_task_rebalance_history_stat_running: 'Running',
+  daas_task_rebalance_history_stat_pending: 'Pending',
+  daas_task_rebalance_history_col_task: 'Task Name',
+  daas_task_rebalance_history_col_source: 'Source Engine',
+  daas_task_rebalance_history_col_target: 'Target Engine',
+  daas_task_rebalance_history_col_status: 'Status',
+  daas_task_rebalance_history_col_error: 'Error',
+  daas_task_rebalance_history_col_action: 'Action',
+  daas_task_rebalance_history_cancel: 'Cancel',
+  daas_task_rebalance_history_cancel_remaining: 'Cancel Remaining',
+  daas_task_rebalance_history_cancel_remaining_confirm:
+    'Cancel the remaining {count} pending tasks? This cannot be undone.',
+  daas_task_rebalance_history_cancel_success: 'Task cancelled',
+  daas_task_rebalance_history_cancel_remaining_success:
+    '{count} tasks cancelled',
+  daas_task_rebalance_history_progress: 'Execution Progress',
+  page_title_task_rebalance: 'Task Rebalance',
 
   webhook_alerts: 'Webhook Alerts',
   webhook_alerts_detail: 'Webhook Alert Details',

apps/daas/src/i18n/langs/zh-CN.js

@@ -2134,6 +2134,7 @@ export default {
   daas_role_role_gongnengmokuai: '功能模块',
   daas_role_role_gouxuanxiangyingmo:
     '勾选相应模块表示此导航对当前角色下用户可见，开启【查看全部数据】则表示角色可以查看和操作该模块下所有的数据，不勾选则只能查看和操作自己创建和被授权的数据。',
+  daas_role_role_no_matching_module: '没有匹配的模块',
 
   daas_feature_unavailable: '升级版本，解锁更多功能！',
   daas_feature_unavailable_subtitle:
@@ -2160,6 +2161,69 @@ export default {
   daas_cluster_engine_hostname: '主机名/IP',
   daas_cluster_connection_count: 'TCP 连接数',
   daas_cluser_keyword_placeholder: '搜索主机名',
+  daas_task_rebalance_button: '任务调度均衡',
+  daas_task_rebalance_title: '任务均衡方案',
+  daas_task_rebalance_subtitle: '拖动任务卡片到目标引擎，调整各引擎的任务分布',
+  daas_task_rebalance_online: '在线',
+  daas_task_rebalance_offline: '离线',
+  daas_task_rebalance_memory: '内存使用率',
+  daas_task_rebalance_task_count: '任务数',
+  daas_task_rebalance_legend_move: '将被调走的任务',
+  daas_task_rebalance_legend_locked: '不可均衡的任务',
+  daas_task_rebalance_cancel: '取消',
+  daas_task_rebalance_confirm: '确认均衡',
+  daas_task_rebalance_create: '创建均衡',
+  daas_task_rebalance_empty: '暂无可均衡的任务',
+  daas_task_rebalance_create_success: '均衡方案已创建，开始执行任务迁移',
+  daas_task_rebalance_type_initial_sync: '全量',
+  daas_task_rebalance_type_cdc: '增量',
+  daas_task_rebalance_type_full_cdc: '全量+增量',
+  daas_task_rebalance_reason_only_one_agent: '可用引擎不足 2 个，无法均衡',
+  daas_task_rebalance_reason_agent_offline: '当前引擎已离线',
+  daas_task_rebalance_reason_status_error: '任务非运行中，无法迁移',
+  daas_task_rebalance_reason_manual_agent: '已指定固定引擎，无法迁移',
+  daas_task_rebalance_reason_incremental: '全量同步中，无法迁移',
+  daas_task_rebalance_history_title: '任务均衡记录',
+  daas_task_rebalance_history_list_title: '历史记录',
+  daas_task_rebalance_history_empty: '暂无均衡记录',
+  daas_task_rebalance_history_empty_desc: '任务均衡后记录将显示在这里',
+  daas_task_rebalance_history_detail_empty: '请在左侧选择一条记录',
+  daas_task_rebalance_history_task_total: '{count} 个任务',
+  daas_task_rebalance_history_record_creating: '创建中',
+  daas_task_rebalance_history_record_running: '执行中',
+  daas_task_rebalance_history_record_done: '已完成',
+  daas_task_rebalance_history_record_partial: '部分完成',
+  daas_task_rebalance_history_record_cancelled: '已取消',
+  daas_task_rebalance_history_record_failed: '失败',
+  daas_task_rebalance_history_job_pending: '等待中',
+  daas_task_rebalance_history_job_starting: '启动中',
+  daas_task_rebalance_history_job_stopping: '停止中',
+  daas_task_rebalance_history_job_ok: '已完成',
+  daas_task_rebalance_history_job_cancelled: '已取消',
+  daas_task_rebalance_history_job_invalid_agent: '引擎不可用',
+  daas_task_rebalance_history_job_status_error: '状态异常',
+  daas_task_rebalance_history_job_stop_timeout: '停止超时',
+  daas_task_rebalance_history_job_start_timeout: '启动超时',
+  daas_task_rebalance_history_job_failed: '失败',
+  daas_task_rebalance_history_stat_success: '成功',
+  daas_task_rebalance_history_stat_failed: '失败',
+  daas_task_rebalance_history_stat_skipped: '跳过',
+  daas_task_rebalance_history_stat_running: '运行中',
+  daas_task_rebalance_history_stat_pending: '等待中',
+  daas_task_rebalance_history_col_task: '任务名称',
+  daas_task_rebalance_history_col_source: '源引擎',
+  daas_task_rebalance_history_col_target: '目标引擎',
+  daas_task_rebalance_history_col_status: '状态',
+  daas_task_rebalance_history_col_error: '错误原因',
+  daas_task_rebalance_history_col_action: '操作',
+  daas_task_rebalance_history_cancel: '取消',
+  daas_task_rebalance_history_cancel_remaining: '取消剩余任务',
+  daas_task_rebalance_history_cancel_remaining_confirm:
+    '确定取消剩余 {count} 个等待中的任务吗？此操作不可撤销。',
+  daas_task_rebalance_history_cancel_success: '任务已取消',
+  daas_task_rebalance_history_cancel_remaining_success: '已取消 {count} 个任务',
+  daas_task_rebalance_history_progress: '执行进度',
+  page_title_task_rebalance: '任务均衡',
 
   webhook_alerts: 'Webhook 告警',
   webhook_alerts_detail: 'Webhook 告警详情',

apps/daas/src/i18n/langs/zh-TW.js

@@ -2118,6 +2118,7 @@ export default {
   daas_role_role_gongnengquanxian: '功能權限',
   daas_role_role_yemianquanxian: '頁面權限',
   daas_role_role_gongnengmokuai: '功能模塊',
+  daas_role_role_no_matching_module: '沒有匹配的模塊',
   daas_role_role_gouxuanxiangyingmo:
     '勾選相應模塊表示此導航對當前角色下用戶可見，開啟【查看全部數據】則表示角色可以查看和操作該模塊下所有的數據，不勾選則只能查看和操作自己創建和被授權的數據。 ',
   daas_feature_unavailable: '功能暫不可用',
@@ -2145,6 +2146,69 @@ export default {
   daas_cluster_engine_hostname: '主機名/IP',
   daas_cluster_connection_count: 'TCP 連接數',
   daas_cluser_keyword_placeholder: '搜索主機名',
+  daas_task_rebalance_button: '任務調度均衡',
+  daas_task_rebalance_title: '任務均衡方案',
+  daas_task_rebalance_subtitle: '拖動任務卡片到目標引擎，調整各引擎的任務分佈',
+  daas_task_rebalance_online: '在線',
+  daas_task_rebalance_offline: '離線',
+  daas_task_rebalance_memory: '內存使用率',
+  daas_task_rebalance_task_count: '任務數',
+  daas_task_rebalance_legend_move: '將被調走的任務',
+  daas_task_rebalance_legend_locked: '不可均衡的任務',
+  daas_task_rebalance_cancel: '取消',
+  daas_task_rebalance_confirm: '確認均衡',
+  daas_task_rebalance_create: '創建均衡',
+  daas_task_rebalance_empty: '暫無可均衡的任務',
+  daas_task_rebalance_create_success: '均衡方案已創建，開始執行任務遷移',
+  daas_task_rebalance_type_initial_sync: '全量',
+  daas_task_rebalance_type_cdc: '增量',
+  daas_task_rebalance_type_full_cdc: '全量+增量',
+  daas_task_rebalance_reason_only_one_agent: '可用引擎不足 2 個，無法均衡',
+  daas_task_rebalance_reason_agent_offline: '當前引擎已離線',
+  daas_task_rebalance_reason_status_error: '任務非運行中，無法遷移',
+  daas_task_rebalance_reason_manual_agent: '已指定固定引擎，無法遷移',
+  daas_task_rebalance_reason_incremental: '全量同步中，無法遷移',
+  daas_task_rebalance_history_title: '任務均衡記錄',
+  daas_task_rebalance_history_list_title: '歷史記錄',
+  daas_task_rebalance_history_empty: '暫無均衡記錄',
+  daas_task_rebalance_history_empty_desc: '任務均衡後記錄將顯示在這裡',
+  daas_task_rebalance_history_detail_empty: '請在左側選擇一條記錄',
+  daas_task_rebalance_history_task_total: '{count} 個任務',
+  daas_task_rebalance_history_record_creating: '創建中',
+  daas_task_rebalance_history_record_running: '執行中',
+  daas_task_rebalance_history_record_done: '已完成',
+  daas_task_rebalance_history_record_partial: '部分完成',
+  daas_task_rebalance_history_record_cancelled: '已取消',
+  daas_task_rebalance_history_record_failed: '失敗',
+  daas_task_rebalance_history_job_pending: '等待中',
+  daas_task_rebalance_history_job_starting: '啟動中',
+  daas_task_rebalance_history_job_stopping: '停止中',
+  daas_task_rebalance_history_job_ok: '已完成',
+  daas_task_rebalance_history_job_cancelled: '已取消',
+  daas_task_rebalance_history_job_invalid_agent: '引擎不可用',
+  daas_task_rebalance_history_job_status_error: '狀態異常',
+  daas_task_rebalance_history_job_stop_timeout: '停止超時',
+  daas_task_rebalance_history_job_start_timeout: '啟動超時',
+  daas_task_rebalance_history_job_failed: '失敗',
+  daas_task_rebalance_history_stat_success: '成功',
+  daas_task_rebalance_history_stat_failed: '失敗',
+  daas_task_rebalance_history_stat_skipped: '跳過',
+  daas_task_rebalance_history_stat_running: '運行中',
+  daas_task_rebalance_history_stat_pending: '等待中',
+  daas_task_rebalance_history_col_task: '任務名稱',
+  daas_task_rebalance_history_col_source: '源引擎',
+  daas_task_rebalance_history_col_target: '目標引擎',
+  daas_task_rebalance_history_col_status: '狀態',
+  daas_task_rebalance_history_col_error: '錯誤原因',
+  daas_task_rebalance_history_col_action: '操作',
+  daas_task_rebalance_history_cancel: '取消',
+  daas_task_rebalance_history_cancel_remaining: '取消剩餘任務',
+  daas_task_rebalance_history_cancel_remaining_confirm:
+    '確定取消剩餘 {count} 個等待中的任務嗎？此操作不可撤銷。',
+  daas_task_rebalance_history_cancel_success: '任務已取消',
+  daas_task_rebalance_history_cancel_remaining_success: '已取消 {count} 個任務',
+  daas_task_rebalance_history_progress: '執行進度',
+  page_title_task_rebalance: '任務均衡',
 
   webhook_alerts: 'Webhook 告警',
   webhook_alerts_detail: 'Webhook 告警詳情',

apps/daas/src/router/menu.ts

@@ -83,6 +83,11 @@ export const MENU = [
       { name: 'dataEncryption' },
       { name: 'projectManagement' },
       { name: 'dataImportExport' },
+      {
+        name: 'taskRebalanceHistory',
+        parent: 'taskRebalance',
+        code: 'v2_task_rebalance',
+      },
     ],
   },
   {

apps/daas/src/router/routes.ts

@@ -482,6 +482,29 @@ export const routes = [
       },
     ],
   },
+  /* ---------- 任务均衡  ----------*/
+  {
+    path: '/task-rebalance',
+    name: 'taskRebalance',
+    component: Layout,
+    redirect: {
+      name: 'taskRebalanceHistory',
+    },
+    meta: {
+      title: 'page_title_task_rebalance',
+    },
+    children: [
+      {
+        path: '',
+        name: 'taskRebalanceHistory',
+        component: () => import('@/views/task-rebalance/History.vue'),
+        meta: {
+          hideTitle: true,
+          title: 'page_title_task_rebalance',
+        },
+      },
+    ],
+  },
   /* ---------- 函数管理  ----------*/
   {
     path: '/function',