-
Notifications
You must be signed in to change notification settings - Fork 108
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- Loading branch information
Showing
7 changed files
with
649 additions
and
1,074 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Large diffs are not rendered by default.
Oops, something went wrong.
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,173 @@ | ||
| /* eslint-disable camelcase */ | ||
| import { SetupContext, computed, ref, watch, Ref, set } from '@vue/composition-api' | ||
| import { fetchClusterList } from '@/api/base' | ||
| import useInterval from '@/views/dashboard/common/use-interval' | ||
|
|
||
| /** | ||
| * 获取集群列表 | ||
| * @param ctx | ||
| * @returns | ||
| */ | ||
| export function useClusterList (ctx: SetupContext) { | ||
| const { $store } = ctx.root | ||
|
|
||
| const clusterList = ref<any[]>([]) | ||
| const permissions = ref({}) | ||
| const curProjectId = computed(() => { | ||
| return $store.state.curProjectId | ||
| }) | ||
| // 获取集群列表 | ||
| const getClusterList = async () => { | ||
| const res = await fetchClusterList({ | ||
| $projectId: curProjectId.value | ||
| }, { needRes: true }).catch(() => ({ data: { results: [] } })) | ||
| clusterList.value = res.data.results | ||
| permissions.value = res.permissions | ||
| // 更新全局集群列表信息 | ||
| $store.commit('cluster/forceUpdateClusterList', clusterList.value) | ||
| return res.data | ||
| } | ||
| // 开启轮询 | ||
| const { start, stop } = useInterval(getClusterList, 5000) | ||
| const runningClusterIds = computed(() => { | ||
| return clusterList.value.filter(item => [ | ||
| 'initial_checking', | ||
| 'initializing', | ||
| 'removing', | ||
| 'so_initializing', | ||
| 'scheduling', | ||
| 'upgrading', | ||
| 'bke_installing'].includes(item.status)).map(item => item.cluster_id) | ||
| }) | ||
| watch(runningClusterIds, (newValue, oldValue) => { | ||
| if (!newValue.length) { | ||
| stop() | ||
| } else if (newValue.sort().join() !== oldValue.sort().join()) { | ||
| start() | ||
| } | ||
| }) | ||
|
|
||
| return { | ||
| clusterList, | ||
| permissions, | ||
| curProjectId, | ||
| getClusterList | ||
| } | ||
| } | ||
| export interface IOverviewMap { | ||
| [key: string]: { | ||
| cpu_usage: any; | ||
| disk_usage: any; | ||
| memory_usage: any; | ||
| }; | ||
| } | ||
| /** | ||
| * 获取集群指标数据 | ||
| * @param ctx | ||
| * @param clusterList | ||
| * @returns | ||
| */ | ||
| export function useClusterOverview (ctx: SetupContext, clusterList: Ref<any[]>) { | ||
| const { $store } = ctx.root | ||
|
|
||
| const clusterOverviewMap = ref<IOverviewMap>({}) | ||
| // 获取当前集群的指标信息 | ||
| const getClusterOverview = (clusterId) => { | ||
| if (!clusterOverviewMap.value[clusterId]) return null | ||
|
|
||
| return clusterOverviewMap.value[clusterId] | ||
| } | ||
| // 集群指标信息 | ||
| const fetchClusterOverview = async (cluster) => { | ||
| const res = await $store.dispatch('cluster/clusterOverview', { | ||
| projectId: cluster.project_id, | ||
| clusterId: cluster.cluster_id | ||
| }).catch(() => ({ data: {} })) | ||
| set(clusterOverviewMap.value, cluster.cluster_id, res.data) | ||
| return res.data | ||
| } | ||
| const overviewCluster = computed(() => { | ||
| return clusterList.value.filter(item => item.status === 'normal' | ||
| && !clusterOverviewMap.value?.[item.cluster_id]) | ||
| }) | ||
|
|
||
| watch(overviewCluster, () => { | ||
| overviewCluster.value.forEach(item => { | ||
| fetchClusterOverview(item) | ||
| }) | ||
| }) | ||
|
|
||
| return { | ||
| clusterOverviewMap, | ||
| getClusterOverview | ||
| } | ||
| } | ||
| /** | ||
| * 集群操作 | ||
| * @param ctx | ||
| * @returns | ||
| */ | ||
| export function useClusterOperate (ctx: SetupContext) { | ||
| const { $store, $bkMessage, $i18n } = ctx.root | ||
| // 集群删除 | ||
| const deleteCluster = async (cluster): Promise<boolean> => { | ||
| const result = await $store.dispatch('cluster/deleteCluster', { | ||
| projectId: cluster.project_id, | ||
| clusterId: cluster.cluster_id | ||
| }).catch(() => false) | ||
| result && $bkMessage({ | ||
| theme: 'success', | ||
| message: $i18n.t('删除成功') | ||
| }) | ||
| return result | ||
| } | ||
| // 任务下发成功提示 | ||
| const successTips = () => { | ||
| $bkMessage({ | ||
| theme: 'success', | ||
| message: $i18n.t('任务下发成功') | ||
| }) | ||
| } | ||
| // 集群升级 | ||
| const upgradeCluster = async (cluster, version: string): Promise<boolean> => { | ||
| const result = await $store.dispatch('cluster/upgradeCluster', { | ||
| projectId: cluster.project_id, | ||
| clusterId: cluster.cluster_id, | ||
| data: { | ||
| version, | ||
| operation: 'upgrade' | ||
| } | ||
| }).catch(() => false) | ||
| result && successTips() | ||
| return result | ||
| } | ||
| // 重新升级 | ||
| const reUpgradeCluster = async (cluster): Promise<boolean> => { | ||
| const result = await $store.dispatch('cluster/upgradeCluster', { | ||
| projectId: cluster.project_id, | ||
| clusterId: cluster.cluster_id, | ||
| data: { | ||
| version: '', | ||
| operation: 'reupgrade' | ||
| } | ||
| }).catch(() => false) | ||
| result && successTips() | ||
| return result | ||
| } | ||
| // 重新初始化 | ||
| const reInitializationCluster = async (cluster): Promise<boolean> => { | ||
| const result = await $store.dispatch('cluster/reInitializationCluster', { | ||
| projectId: cluster.project_id, | ||
| clusterId: cluster.cluster_id | ||
| }).catch(() => false) | ||
| result && successTips() | ||
| return result | ||
| } | ||
|
|
||
| return { | ||
| deleteCluster, | ||
| upgradeCluster, | ||
| reUpgradeCluster, | ||
| reInitializationCluster | ||
| } | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Empty file.