statesinformer

Documentation

Index

• type CallbackTarget
  • func (t *CallbackTarget) String() string
• type PodMeta
  • func (in *PodMeta) DeepCopy() *PodMeta
  • func (in *PodMeta) IsRunningOrPending() bool
  • func (in *PodMeta) Key() string
• type RegisterType
  • func (r RegisterType) String() string
• type StatesInformer
• type UpdateCbFn

Types

type CallbackTarget

type CallbackTarget struct {
	Pods             []*PodMeta
	HostApplications []slov1alpha1.HostApplicationSpec
}

func (*CallbackTarget) String

func (t *CallbackTarget) String() string

type PodMeta

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

func (*PodMeta) DeepCopy

func (in *PodMeta) DeepCopy() *PodMeta

func (*PodMeta) IsRunningOrPending

func (in *PodMeta) IsRunningOrPending() bool

func (*PodMeta) Key

func (in *PodMeta) Key() string

type RegisterType

type RegisterType int64

const (
	RegisterTypeNodeSLOSpec RegisterType = iota
	RegisterTypeAllPods
	RegisterTypeNodeTopology
	RegisterTypeNodeMetadata
)

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

	GetNodeTopo() *topov1alpha1.NodeResourceTopology

	GetVolumeName(pvcNamespace, pvcName string) string

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

type UpdateCbFn

type UpdateCbFn func(t RegisterType, obj interface{}, target *CallbackTarget)