Documentation
¶
Index ¶
- Constants
- Variables
- func NewCallbackRunner() *callbackRunner
- func NewNodeInformer() *nodeInformer
- func NewNodeMetricInformer() *nodeMetricInformer
- func NewNodeSLOInformer() *nodeSLOInformer
- func NewNodeTopoInformer() *nodeTopoInformer
- func NewPVCInformer() *pvcInformer
- func NewPodsInformer() *podsInformer
- func NewStatesInformer(config *Config, kubeClient clientset.Interface, ...) statesinformer.StatesInformer
- type Config
- type GetGPUDriverAndModelFunc
- type KubeletStub
- type PluginName
- type PluginOption
- type PluginState
- type UpdateCbCtx
Constants ¶
View Source
const ( HTTPScheme = "http" HTTPSScheme = "https" )
Variables ¶
View Source
var DefaultPluginRegistry = map[PluginName]informerPlugin{ // contains filtered or unexported fields }
Functions ¶
func NewCallbackRunner ¶
func NewCallbackRunner() *callbackRunner
func NewNodeInformer ¶
func NewNodeInformer() *nodeInformer
func NewNodeMetricInformer ¶
func NewNodeMetricInformer() *nodeMetricInformer
func NewNodeSLOInformer ¶
func NewNodeSLOInformer() *nodeSLOInformer
func NewNodeTopoInformer ¶
func NewNodeTopoInformer() *nodeTopoInformer
func NewPVCInformer ¶
func NewPVCInformer() *pvcInformer
func NewPodsInformer ¶
func NewPodsInformer() *podsInformer
func NewStatesInformer ¶
func NewStatesInformer(config *Config, kubeClient clientset.Interface, crdClient koordclientset.Interface, topologyClient topologyclientset.Interface, metricsCache metriccache.MetricCache, nodeName string, schedulingClient schedv1alpha1.SchedulingV1alpha1Interface, predictorFactory prediction.PredictorFactory) statesinformer.StatesInformer
TODO merge all clients into one struct
Types ¶
type Config ¶
type Config struct {
KubeletPreferredAddressType string
KubeletSyncInterval time.Duration
KubeletSyncTimeout time.Duration
InsecureKubeletTLS bool
KubeletReadOnlyPort uint
NodeTopologySyncInterval time.Duration
DisableQueryKubeletConfig bool
EnableNodeMetricReport bool
MetricReportInterval time.Duration // Deprecated
EnablePodTaskIds bool
XPUEnforceCollectFromDeviceInfos bool
}
func NewDefaultConfig ¶
func NewDefaultConfig() *Config
type KubeletStub ¶
type KubeletStub interface {
GetAllPods() (corev1.PodList, error)
GetKubeletConfiguration() (*kubeletconfiginternal.KubeletConfiguration, error)
}
type PluginName ¶
type PluginName string
type PluginOption ¶
type PluginOption struct {
KubeClient clientset.Interface
KoordClient koordclientset.Interface
TopoClient topologyclientset.Interface
NodeName string
// contains filtered or unexported fields
}
type PluginState ¶
type PluginState struct {
// contains filtered or unexported fields
}
type UpdateCbCtx ¶
type UpdateCbCtx struct{}
Click to show internal directories.
Click to hide internal directories.