runtimehooks

Documentation

Index

• Constants
• type Config
  • func NewDefaultConfig() *Config
  • func (c *Config) InitFlags(fs *flag.FlagSet)
• type HookPlugin
• type RuntimeHook
  • func NewRuntimeHook(si statesinformer.StatesInformer, cfg *Config) (RuntimeHook, error)

Constants

const (
	// GroupIdentity sets pod cpu group identity(bvt) according to QoS.
	//
	// owner: @zwzhang0107 @saintube
	// alpha: v0.3
	// beta: v1.1
	GroupIdentity featuregate.Feature = "GroupIdentity"

	// CPUSetAllocator sets container cpuset according to allocate result from koord-scheduler for LSR/LS pods.
	//
	// owner: @saintube @zwzhang0107
	// alpha: v0.3
	// beta: v1.1
	CPUSetAllocator featuregate.Feature = "CPUSetAllocator"

	// GPUEnvInject injects gpu allocated env info according to allocate result from koord-scheduler.
	//
	// owner: @ZYecho @jasonliu747
	// alpha: v0.3
	// beta: v1.1
	GPUEnvInject featuregate.Feature = "GPUEnvInject"

	// BatchResource sets request and limits of cpu and memory on cgroup file according batch resources.
	//
	// owner: @saintube @zwzhang0107
	// alpha: v1.1
	BatchResource featuregate.Feature = "BatchResource"

	// CPUNormalization adjusts cpu cgroups value for cpu normalized LS pod.
	//
	// owner: @saintube @zwzhang0107
	// alpha: v1.4
	CPUNormalization featuregate.Feature = "CPUNormalization"

	// CoreSched manages Linux Core Scheduling cookies for containers who enable the core sched.
	// NOTE: CoreSched is an alternative policy of the CPU QoS, and it is exclusive to the Group Identity feature.
	//
	// owner: @saintube @zwzhang0107
	// alpha: v1.4
	CoreSched featuregate.Feature = "CoreSched"

	// TerwayQoS enables net QoS feature of koordlet.
	// owner: @l1b0k
	// alpha: v1.5
	TerwayQoS featuregate.Feature = "TerwayQoS"
)

Types

type Config

type Config struct {
	RuntimeHooksNetwork             string
	RuntimeHooksAddr                string
	RuntimeHooksFailurePolicy       string
	RuntimeHooksPluginFailurePolicy string
	RuntimeHookConfigFilePath       string
	RuntimeHookHostEndpoint         string
	RuntimeHookDisableStages        []string
	RuntimeHooksNRI                 bool
	RuntimeHooksNRIConnectTimeout   time.Duration
	RuntimeHooksNRIBackOffDuration  time.Duration
	RuntimeHooksNRIBackOffCap       time.Duration
	RuntimeHooksNRIBackOffFactor    float64
	RuntimeHooksNRIBackOffSteps     int
	RuntimeHooksNRISocketPath       string
	RuntimeHooksNRIPluginName       string
	RuntimeHooksNRIPluginIndex      string
	RuntimeHookReconcileInterval    time.Duration
}

func NewDefaultConfig

func NewDefaultConfig() *Config

func (*Config) InitFlags

func (c *Config) InitFlags(fs *flag.FlagSet)

type HookPlugin

type HookPlugin interface {
	Register(op hooks.Options)
}

type RuntimeHook

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

func NewRuntimeHook

func NewRuntimeHook(si statesinformer.StatesInformer, cfg *Config) (RuntimeHook, error)