core_version

Documentation

Overview

Package core_version *

• @Title: core version 检查
• @Description: *
• core version 检查，含三个部份：
• - API：提供外部与内部两个接口调用，触发 core version 的检测，外部调用时将通过内部API通知其它节点开启检测
• - 检测体：polar stack daemon 启动时，将对 CheckRequestQueue 进行监听，一旦收到请求，开始检查 core version 镜像是否存在
• - 对 k8s configMap 与 镜像的操作
• 另外，每次启动主动更新一次主机的core version信息 *

Index

• Variables
• func InnerCheckCoreVersion(ctx *context.Context)
• func RequestCheckCoreVersion(ctx *context.Context)
• func StartCheckCoreVersion(client *clientset.Clientset)
• type OperatorType
  • func (opt OperatorType) ToString() string

Variables

var CheckRequestQueue chan OperatorType

CheckRequestQueue *

• @Description: 请求检查队列 *

var NameSpace = "kube-system"

Functions

func InnerCheckCoreVersion

func InnerCheckCoreVersion(ctx *context.Context)

InnerCheckCoreVersion *

• @Title: InnerCheckCoreVersion
• @Description: 由内部触发，通知当前 polarstack daemon 检查 core version，将不再通知其它节点 *

func RequestCheckCoreVersion

func RequestCheckCoreVersion(ctx *context.Context)

RequestCheckCoreVersion *

• @Title: RequestCheckCoreVersion
• @Description: 外部调用，通知 polar stack daemon 检查 core version，收到通知后将会通知其它 polarstack-daemon 节点 *

func StartCheckCoreVersion

func StartCheckCoreVersion(client *clientset.Clientset)

StartCheckCoreVersion *

• @Title: StartCheckCoreVersion
• @Description: 开始等待 检查 core version 的指令 *

Types

type OperatorType

type OperatorType string

var CheckCoreVersionOperatorType OperatorType = "CheckCoreVersionOperatorType"

CheckCoreVersionOperatorType 外部请求检查 core version

var SingleCheckCoreVersionOperatorType OperatorType = "SingleCheckCoreVersionOperatorType"

SingleCheckCoreVersionOperatorType 来自内部的检查通知

func (OperatorType) ToString

func (opt OperatorType) ToString() string