statesinformer

package

v1.7.0 Latest Latest Go to latest Published: Oct 22, 2025 License: Apache-2.0 Imports: 5 Imported by: 1

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/koordinator-sh/koordinator

Links

Open Source Insights

Documentation ¶

Index ¶

func DeepCopyContainerTaskIds(in map[string][]int32) map[string][]int32
type CallbackTarget
- func (t *CallbackTarget) String() string
type PodMeta
type RegisterType
- func (r RegisterType) String() string
type StatesInformer
type UpdateCbFn

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func DeepCopyContainerTaskIds ¶ added in v1.6.0

func DeepCopyContainerTaskIds(in map[string][]int32) map[string][]int32

DeepCopyContainerTaskIds creates a deep copy of ContainerTaskIds

Types ¶

type CallbackTarget ¶ added in v1.4.0

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

func (*CallbackTarget) String ¶ added in v1.4.0

func (t *CallbackTarget) String() string

type PodMeta ¶

type PodMeta struct {
	Pod              *corev1.Pod
	CgroupDir        string
	ContainerTaskIds map[string][]int32
}

func (*PodMeta) DeepCopy ¶

func (in *PodMeta) DeepCopy() *PodMeta

func (*PodMeta) IsRunningOrPending ¶ added in v1.4.0

func (in *PodMeta) IsRunningOrPending() bool

func (*PodMeta) Key ¶ added in v1.4.0

func (in *PodMeta) Key() string

type RegisterType ¶ added in v0.5.0

type RegisterType int64

const (
	RegisterTypeNodeSLOSpec RegisterType = iota
	RegisterTypeAllPods
	RegisterTypeNodeTopology
	RegisterTypeNodeMetadata
)

func (RegisterType) String ¶ added in v0.5.0

func (r RegisterType) String() string

type StatesInformer ¶

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

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

	GetAllPods() []*PodMeta

	GetNodeTopo() *topov1alpha1.NodeResourceTopology

	GetVolumeName(pvcNamespace, pvcName string) string

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

type UpdateCbFn ¶ added in v0.4.0

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

Source Files ¶

View all Source files

api.go

Directories ¶

Path	Synopsis
impl
mockstatesinformer Package mock_impl is a generated GoMock package.	Package mock_impl is a generated GoMock package.

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL