statesinformer

Documentation

Index

• Constants
• type Config
  • func NewDefaultConfig() *Config
  • func (c *Config) InitFlags(fs *flag.FlagSet)
• type KubeletStub
  • func NewKubeletStub(addr string, port int, scheme string, timeout time.Duration, cfg *rest.Config) (KubeletStub, error)
• type PodMeta
  • func (in *PodMeta) DeepCopy() *PodMeta
• type RegisterType
  • func (r RegisterType) String() string
• type StatesInformer
  • func NewStatesInformer(config *Config, kubeClient clientset.Interface, ...) StatesInformer
• type UpdateCbCtx
• type UpdateCbFn

Constants

const (
	HTTPScheme  = "http"
	HTTPSScheme = "https"
)

Types

type Config

type Config struct {
	KubeletPreferredAddressType string
	KubeletSyncInterval         time.Duration
	KubeletSyncTimeout          time.Duration
	InsecureKubeletTLS          bool
	KubeletReadOnlyPort         uint
	NodeTopologySyncInterval    time.Duration
}

func NewDefaultConfig

func NewDefaultConfig() *Config

func (*Config) InitFlags

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

type KubeletStub

type KubeletStub interface {
	GetAllPods() (corev1.PodList, error)
}

func NewKubeletStub

func NewKubeletStub(addr string, port int, scheme string, timeout time.Duration, cfg *rest.Config) (KubeletStub, error)

type PodMeta

type PodMeta struct {
	Pod       *corev1.Pod
	CgroupDir string
}

func (*PodMeta) DeepCopy

func (in *PodMeta) DeepCopy() *PodMeta

type RegisterType

type RegisterType int64

const (
	RegisterTypeNodeSLOSpec RegisterType = iota
	RegisterTypeAllPods
	RegisterTypeNodeTopology
)

func (RegisterType) String

func (r RegisterType) String() string

type StatesInformer

type StatesInformer interface {
	Run(stopCh <-chan struct{}) error
	HasSynced() bool

	GetNode() *corev1.Node
	GetNodeSLO() *slov1alpha1.NodeSLO

	GetAllPods() []*PodMeta

	RegisterCallbacks(objType RegisterType, name, description string, callbackFn UpdateCbFn)
}

func NewStatesInformer

func NewStatesInformer(config *Config, kubeClient clientset.Interface, crdClient koordclientset.Interface, topologyClient *topologyclientset.Clientset, metricsCache metriccache.MetricCache, pleg pleg.Pleg, nodeName string) StatesInformer

type UpdateCbCtx

type UpdateCbCtx struct{}

type UpdateCbFn

type UpdateCbFn func(t RegisterType, obj interface{}, pods []*PodMeta)