Kube-Scheduler插件的自定义

k8s的发展越来越像是一个框架，然后把各种扩展的能力留给开发者。开发者可以基于这些接口结合自己的业务场景，实现自己的场景化需求。其中kube scheduler 就是充分体现了这个特质，关于kube scheduler 本身的介绍参加之前的文章，今天我想介绍如何给scheduler 添加一个调度plugin。

我们首先通过yaml定义这个plugin

apiVersion: kubescheduler.config.k8s.io/v1beta1
kind: KubeSchedulerConfiguration
clientConnection: kubeconfig: "/etc/kubernetes/scheduler.conf"
profiles:
- schedulerName: default-scheduler plugins: score: enabled: - name: HelloWorldPlugin disabled: - name: "*" pluginConfig: - name: HelloWorldPlugin args: xxx: "xxx" yyy: "123" zzz: 3

我们定义了一个 HelloWorldPlugin 的插件，并且定义了这个插件的启动参数。然后需要修改kube scheduler启动参数通过 --config 指定上面的配置文件。

接下来我们就需要实现这个插件，scheduler是通过每个插件的打分的方式确定调度的主机。所以我们需要实现一个打分的接口

type ScorePlugin interface { Plugin // 打分 Score(ctx context.Context, state *CycleState, p *v1.Pod, nodeName string) (int64, *Status) ScoreExtensions() ScoreExtensions
} type ScoreExtensions interface { // 打分归一化，保证每个插件的公平性 NormalizeScore(ctx context.Context, state *CycleState, p *v1.Pod, scores NodeScoreList) *Status
}

我们根据自己的业务需求实现这个接口，譬如下面这个例子，基于主机网络带宽的调度：首先通过promethues获取主机的网络流量，打分依据网络流量大小。

func (n *HelloWorldPlugin) Score(ctx context.Context, state *framework.CycleState, p *v1.Pod, nodeName string) (int64, *framework.Status) { nodeBandwidth, err := n.prometheus.GetNodeBandwidthMeasure(nodeName) if err != nil { return 0, framework.NewStatus(framework.Error, fmt.Sprintf("error getting node bandwidth measure: %s", err)) } klog.Infof("[NetworkTraffic] node '%s' bandwidth: %s", nodeName, nodeBandwidth.Value) return int64(nodeBandwidth.Value), nil
}

我们希望网络流量越大，得分越少，于是在归一化处理的时候，我们通过下面简单公式转化成最终的分数。

func (n *HelloWorldPlugin) NormalizeScore(ctx context.Context, state *framework.CycleState, pod *v1.Pod, scores framework.NodeScoreList) *framework.Status { for i, node := range scores { scores[i].Score = framework.MaxNodeScore - (node.Score * framework.MaxNodeScore / higherScore) } klog.Infof("[NetworkTraffic] Nodes final score: %v", scores) return nil
}

这样一个简单的，基于网络流量调度的插件就实现了。

Kube-Scheduler插件的自定义相关推荐

Quartz Scheduler插件–隐藏的宝藏
尽管在官方文档中进行了简要描述,但我相信Quartz插件了解得还不够多,看看它们有多有用. 本质上,Quartz中的插件是方便的类,用于包装基础侦听器的注册. 您可以自由编写自己的插件,但我们将专注于 ...
jquery倒计时插件可自定义多个倒计时间
jquery倒计时插件设置多个自定义倒计时时间,任意设置天.小时.分钟.秒倒计时间功能. 查看演示>> <!DOCTYPE html PUBLIC "-//W3C//DTD ...
VBS操作IE ---（【当不使用IE时】可以使用Chrome插件，自定义JS插件操作浏览器）
目录 ■前言 ■举个简单VBS操作IE的例子 --- ■如何让IE打开是IE,而不是Edge ■其他更多VBS相关・更多操作一览・按键 shift ctrl alt ・打开图片,以幻灯片形式显示 ...
【泛微系统】OA系统集成echart插件，自定义图表demo实例
OA系统集成echart插件,自定义图表demo实例前言在公司有时候需要做一些自定义报表,因为系统自带的报表工具很low,这时候可以使用echart插件: 第一步:下载相关jar包首先下载一下m ...
13、Kanzi插件——通过Kanzi Engine插件创建自定义节点+代码解析
一.通过插件创建自定义类型的节点在类Plugindemo 中添加一行 static kanzi::PropertyTypeEditorInfoSharedPtr makeEditorInfo(); ...
【java笔记-006】【uni-app】当前运行的基座不包含原生插件[xxx]，请在manifest中配置该插件，重新制作包括该原生插件的自定义运行基座
uni-app引入原生插件的步骤如下:https://nativesupport.dcloud.net.cn/NativePlugin/course/android 将制作好的原生安卓插件包复制到 ...
doom emacs如何安装新插件和自定义快捷键
doom emacs如何安装新插件和自定义快捷键最近在学习和使用doom emacs,遇到了2个问题. 问题1: 虽然doom emacs已经配置了很多的三方插件,但是还有些个性化的插件如何按doo ...
【Maven实战技巧】「插件使用专题」Maven-Archetype插件创建自定义maven项目骨架
技术推荐自定义Archetype Maven骨架/以当前项目为模板创建maven骨架,可以参考http://maven.apache.org/archetype/maven-archetype-pl ...
pdfjs 插件进行自定义遮罩打印
pdfjs插件进行自定义遮罩打印效果展示思路 pdfjs插件每一张pdf都会生成一个canvas 在每个canvas的父级div添加事件拖拽形成遮罩 (viewer.js 11981行左右 ...

Kube-Scheduler插件的自定义

Kube-Scheduler插件的自定义相关推荐

最新文章

热门文章