config

Documentation

Index

• type Configuration
  • func NewConfiguration() *Configuration
  • func (c *Configuration) Complete(client clientset.Interface)
  • func (c *Configuration) GetActivePods() ([]*corev1.Pod, error)
  • func (c *Configuration) GetNode() (*corev1.Node, error)
  • func (c *Configuration) IsFeatureSupported(name string) bool
• type InformerFactory
• type VolcanoAgentConfiguration

Types

type Configuration

type Configuration struct {
	GenericConfiguration *VolcanoAgentConfiguration
	InformerFactory      *InformerFactory
}

func NewConfiguration

func NewConfiguration() *Configuration

func (*Configuration) Complete

func (c *Configuration) Complete(client clientset.Interface)

func (*Configuration) GetActivePods

func (c *Configuration) GetActivePods() ([]*corev1.Pod, error)

func (*Configuration) GetNode

func (c *Configuration) GetNode() (*corev1.Node, error)

func (*Configuration) IsFeatureSupported

func (c *Configuration) IsFeatureSupported(name string) bool

type InformerFactory

type InformerFactory struct {
	// K8SInformerFactory gives access to informers of k8s core resource for the controller.
	K8SInformerFactory informers.SharedInformerFactory
}

type VolcanoAgentConfiguration

type VolcanoAgentConfiguration struct {
	// HealthzAddress is the health check server address
	HealthzAddress string

	//HealthzPort is the health check server port
	HealthzPort int

	// KubeCgroupRoot is the root cgroup to use for pods.
	// same with kubelet configuration "cgroup-root"
	KubeCgroupRoot string

	// KubeClient is the client to visit k8s
	KubeClient clientset.Interface

	// KubeNodeName is the name of the node which pod is running.
	KubeNodeName string

	// KubePodName is the name of the pod.
	KubePodName string

	// KubePodName is the namespace of the pod.
	KubePodNamespace string

	// NodeLister list current node.
	NodeLister v1.NodeLister

	// PodLister list pods belong to current node.
	PodLister v1.PodLister

	// NodeHasSynced indicates whether nodes have been sync'd at least once.
	// Check this before trusting a response from the node lister.
	NodeHasSynced cache.InformerSynced

	// PodsHasSynced indicates whether pods have been sync'd at least once.
	// Check this before trusting a response from the pod lister.
	PodsHasSynced cache.InformerSynced

	// EventRecorder is the event sink
	Recorder record.EventRecorder

	// List of supported features, '*' supports all on-by-default features.
	SupportedFeatures []string

	// OverSubscriptionPolicy defines overSubscription policy.
	OverSubscriptionPolicy string

	// OverSubscriptionRatio is the over subscription ratio of idle resources, default to 60, which means 60%.
	OverSubscriptionRatio int

	// IncludeSystemUsage determines whether considering system usage when calculate overSubscription resource and evict.
	IncludeSystemUsage bool
}