cdp

Documentation

Index

• Constants
• func New(arguments framework.Arguments) framework.Plugin
• type CooldownProtectionPlugin
  • func (*CooldownProtectionPlugin) Name() string
  • func (*CooldownProtectionPlugin) OnSessionClose(ssn *framework.Session)
  • func (sp *CooldownProtectionPlugin) OnSessionOpen(ssn *framework.Session)

Constants

const (
	// refer to issue https://github.com/volcano-sh/volcano/issues/2075,
	// plugin cdp means cooldown protection, related to elastic scheduler,
	// when we need to enable elastic training or serving,
	// preemptible job's pods can be preempted or back to running repeatedly,
	// if no cooldown protection set, these pods can be preempted again after they just started for a short time,
	// this may cause service stability dropped.
	// cdp plugin here is to ensure vcjob's pods cannot be preempted within cooldown protection conditions.
	// currently cdp plugin only support cooldown time protection.
	PluginName = "cdp"
)

Functions

func New

func New(arguments framework.Arguments) framework.Plugin

New return CooldownProtectionPlugin

Types

type CooldownProtectionPlugin

type CooldownProtectionPlugin struct {
}

func (*CooldownProtectionPlugin) Name

func (*CooldownProtectionPlugin) Name() string

Name implements framework.Plugin

func (*CooldownProtectionPlugin) OnSessionClose

func (*CooldownProtectionPlugin) OnSessionClose(ssn *framework.Session)

OnSessionClose implements framework.Plugin

func (*CooldownProtectionPlugin) OnSessionOpen

func (sp *CooldownProtectionPlugin) OnSessionOpen(ssn *framework.Session)

OnSessionOpen implements framework.Plugin