reconciler

Documentation

Index

• Constants
• func RegisterCgroupReconciler(level ReconcilerLevel, cgroupFile system.Resource, description string, ...)
• func RegisterHostAppReconciler(resource system.Resource, description string, fn reconcileFunc, ...)
• type Context
• type Filter
  • func NoneFilter() Filter
  • func PodQOSFilter() Filter
• type Reconciler
  • func NewHostAppReconciler(ctx Context) Reconciler
  • func NewReconciler(ctx Context) Reconciler
• type ReconcilerLevel
• type ReconcilerOption

Constants

const (
	NoneFilterCondition = ""
	NoneFilterName      = "none"
)

const (
	PodQOSFilterName = "podQOS"
)

Functions

func RegisterCgroupReconciler

func RegisterCgroupReconciler(level ReconcilerLevel, cgroupFile system.Resource, description string,
	fn reconcileFunc, filter Filter, conditions ...string)

RegisterCgroupReconciler registers a cgroup reconciler according to the cgroup file, reconcile function and filter conditions. A cgroup file of one level can have multiple reconcile functions with different filtered conditions.

e.g. pod-level cfs_quota can be registered both by cpuset hook and batchresource hook. While cpuset hook reconciles
cfs_quota for LSE and LSR pods, batchresource reconciles pods of BE QoS.

TODO: support priority+qos filter.

func RegisterHostAppReconciler

func RegisterHostAppReconciler(resource system.Resource, description string, fn reconcileFunc, opt *ReconcilerOption)

Types

type Context

type Context struct {
	StatesInformer    statesinformer.StatesInformer
	Executor          resourceexecutor.ResourceUpdateExecutor
	ReconcileInterval time.Duration
}

type Filter

type Filter interface {
	Name() string
	Filter(podMeta *statesinformer.PodMeta) string
}

Filter & Conditions: 1. a condition for one cgroup file should have no more than one filter/index func 2. different indexes of one cgroup file can have different reconcile functions 3. indexes for one cgroup should be enumerable

func NoneFilter

func NoneFilter() Filter

NoneFilter returns a Filter which skip filtering anything (into the same condition)

func PodQOSFilter

func PodQOSFilter() Filter

PodQOSFilter returns a Filter which filters pod qos class

type Reconciler

type Reconciler interface {
	Run(stopCh <-chan struct{}) error
}

func NewHostAppReconciler

func NewHostAppReconciler(ctx Context) Reconciler

func NewReconciler

func NewReconciler(ctx Context) Reconciler

type ReconcilerLevel

type ReconcilerLevel string

const (
	KubeQOSLevel   ReconcilerLevel = "kubeqos"
	PodLevel       ReconcilerLevel = "pod"
	ContainerLevel ReconcilerLevel = "container"
	SandboxLevel   ReconcilerLevel = "sandbox"
)

type ReconcilerOption

type ReconcilerOption struct {
}