conf

Documentation

Index

• Constants
• Variables
• func DumpConfiguration()
• func FlattenConfigMaps(configMaps []*v1.ConfigMap) map[string]string
• func GetDefaultKubeConfigPath() string
• func GetSchedulerNamespace() string
• func SetSchedulerConf(conf *SchedulerConf)
• func UpdateConfigMaps(configMaps []*v1.ConfigMap, initial bool) error
• type SchedulerConf
  • func CreateDefaultConfig() *SchedulerConf
  • func GetSchedulerConf() *SchedulerConf
  • func (conf *SchedulerConf) Clone() *SchedulerConf
  • func (conf *SchedulerConf) GetKubeConfigPath() string
  • func (conf *SchedulerConf) GetSchedulingInterval() time.Duration
  • func (conf *SchedulerConf) IsOperatorPluginEnabled(name string) bool
  • func (conf *SchedulerConf) IsTestMode() bool
  • func (conf *SchedulerConf) SetTestMode(testMode bool)
• type SchedulerConfFactory

Constants

const (
	// env vars
	EnvHome       = "HOME"
	EnvKubeConfig = "KUBECONFIG"
	EnvNamespace  = "NAMESPACE"

	// prefixes
	PrefixService    = "service."
	PrefixLog        = "log."
	PrefixKubernetes = "kubernetes."

	// service
	CMSvcClusterID                    = PrefixService + "clusterId"
	CMSvcPolicyGroup                  = PrefixService + "policyGroup"
	CMSvcSchedulingInterval           = PrefixService + "schedulingInterval"
	CMSvcVolumeBindTimeout            = PrefixService + "volumeBindTimeout"
	CMSvcEventChannelCapacity         = PrefixService + "eventChannelCapacity"
	CMSvcDispatchTimeout              = PrefixService + "dispatchTimeout"
	CMSvcOperatorPlugins              = PrefixService + "operatorPlugins"
	CMSvcDisableGangScheduling        = PrefixService + "disableGangScheduling"
	CMSvcEnableConfigHotRefresh       = PrefixService + "enableConfigHotRefresh"
	CMSvcPlaceholderImage             = PrefixService + "placeholderImage"
	CMSvcNodeInstanceTypeNodeLabelKey = PrefixService + "nodeInstanceTypeNodeLabelKey"

	// log
	CMLogLevel = PrefixLog + "level"

	// kubernetes
	CMKubeQPS   = PrefixKubernetes + "qps"
	CMKubeBurst = PrefixKubernetes + "burst"

	// defaults
	DefaultNamespace              = "default"
	DefaultClusterID              = "mycluster"
	DefaultPolicyGroup            = "queues"
	DefaultSchedulingInterval     = time.Second
	DefaultVolumeBindTimeout      = 10 * time.Second
	DefaultEventChannelCapacity   = 1024 * 1024
	DefaultDispatchTimeout        = 300 * time.Second
	DefaultOperatorPlugins        = "general"
	DefaultDisableGangScheduling  = false
	DefaultEnableConfigHotRefresh = true
	DefaultLoggingLevel           = 0
	DefaultLogEncoding            = "console"
	DefaultKubeQPS                = 1000
	DefaultKubeBurst              = 1000
)

Variables

var (
	BuildVersion    string
	BuildDate       string
	IsPluginVersion bool
	GoVersion       string
	Arch            string
	CoreSHA         string
	SiSHA           string
	ShimSHA         string
)

Functions

func DumpConfiguration

func DumpConfiguration()

func FlattenConfigMaps

func FlattenConfigMaps(configMaps []*v1.ConfigMap) map[string]string

func GetDefaultKubeConfigPath

func GetDefaultKubeConfigPath() string

func GetSchedulerNamespace

func GetSchedulerNamespace() string

func SetSchedulerConf

func SetSchedulerConf(conf *SchedulerConf)

func UpdateConfigMaps

func UpdateConfigMaps(configMaps []*v1.ConfigMap, initial bool) error

Types

type SchedulerConf

type SchedulerConf struct {
	SchedulerName            string        `json:"schedulerName"`
	ClusterID                string        `json:"clusterId"`
	ClusterVersion           string        `json:"clusterVersion"`
	PolicyGroup              string        `json:"policyGroup"`
	Interval                 time.Duration `json:"schedulingIntervalSecond"`
	KubeConfig               string        `json:"absoluteKubeConfigFilePath"`
	LoggingLevel             int           `json:"loggingLevel"`
	VolumeBindTimeout        time.Duration `json:"volumeBindTimeout"`
	TestMode                 bool          `json:"testMode"`
	EventChannelCapacity     int           `json:"eventChannelCapacity"`
	DispatchTimeout          time.Duration `json:"dispatchTimeout"`
	KubeQPS                  int           `json:"kubeQPS"`
	KubeBurst                int           `json:"kubeBurst"`
	OperatorPlugins          string        `json:"operatorPlugins"`
	EnableConfigHotRefresh   bool          `json:"enableConfigHotRefresh"`
	DisableGangScheduling    bool          `json:"disableGangScheduling"`
	UserLabelKey             string        `json:"userLabelKey"`
	PlaceHolderImage         string        `json:"placeHolderImage"`
	InstanceTypeNodeLabelKey string        `json:"instanceTypeNodeLabelKey"`
	Namespace                string        `json:"namespace"`
	sync.RWMutex
}

func CreateDefaultConfig

func CreateDefaultConfig() *SchedulerConf

CreateDefaultConfig creates and returns a configuration representing all default values

func GetSchedulerConf

func GetSchedulerConf() *SchedulerConf

func (*SchedulerConf) Clone

func (conf *SchedulerConf) Clone() *SchedulerConf

func (*SchedulerConf) GetKubeConfigPath

func (conf *SchedulerConf) GetKubeConfigPath() string

func (*SchedulerConf) GetSchedulingInterval

func (conf *SchedulerConf) GetSchedulingInterval() time.Duration

func (*SchedulerConf) IsOperatorPluginEnabled

func (conf *SchedulerConf) IsOperatorPluginEnabled(name string) bool

func (*SchedulerConf) IsTestMode

func (conf *SchedulerConf) IsTestMode() bool

func (*SchedulerConf) SetTestMode

func (conf *SchedulerConf) SetTestMode(testMode bool)

type SchedulerConfFactory

type SchedulerConfFactory = func() *SchedulerConf