topology

Documentation

Index

• Constants
• func AreTSCFrequencyTopologyHintsDefined(vmi *k6tv1.VirtualMachineInstance) bool
• func CalculateTSCLabelDiff(frequenciesInUse []int64, frequenciesOnNode []int64, nodeFrequency int64, ...) (toAdd []int64, toRemove []int64)
• func FilterNodesFromCache(objs []interface{}, predicates ...FilterPredicateFunc) []*v1.Node
• func HasInvTSCFrequency(node *v1.Node) bool
• func IsManualTSCFrequencyRequired(vmi *k6tv1.VirtualMachineInstance) bool
• func IsSchedulable(node *v1.Node) bool
• func LowestTSCFrequency(nodes []*v1.Node) int64
• func NewTopologyHinter(nodeStore cache.Store, vmiStore cache.Store, arch string, ...) *topologyHinter
• func TSCFrequenciesOnNode(node *v1.Node) (frequencies []int64)
• func TSCFrequencyFromNode(node *v1.Node) (frequency int64, scalable bool, err error)
• func TSCFrequencyFromPod(pod *v1.Pod) (frequency int64, err error)
• func ToTSCSchedulableLabel(frequency int64) string
• func ToTSCSchedulableLabels(frequencies []int64) (labels []string)
• type FilterPredicateFunc
  • func NodeOfVMI(vmi *virtv1.VirtualMachineInstance) FilterPredicateFunc
  • func Not(f FilterPredicateFunc) FilterPredicateFunc
  • func TSCFrequencyGreaterEqual(frequency int64) FilterPredicateFunc
• type Hinter
• type MockHinter
  • func NewMockHinter(ctrl *gomock.Controller) *MockHinter
  • func (_m *MockHinter) EXPECT() *_MockHinterRecorder
  • func (_m *MockHinter) LowestTSCFrequencyOnCluster() (int64, error)
  • func (_m *MockHinter) TSCFrequenciesInUse() []int64
  • func (_m *MockHinter) TopologyHintsForVMI(vmi *v1.VirtualMachineInstance) (*v1.TopologyHints, error)
  • func (_m *MockHinter) TopologyHintsRequiredForVMI(vmi *v1.VirtualMachineInstance) bool
• type MockNodeTopologyUpdater
  • func NewMockNodeTopologyUpdater(ctrl *gomock.Controller) *MockNodeTopologyUpdater
  • func (_m *MockNodeTopologyUpdater) EXPECT() *_MockNodeTopologyUpdaterRecorder
  • func (_m *MockNodeTopologyUpdater) Run(interval time.Duration, stopChan <-chan struct{})
• type NodeTopologyUpdater
  • func NewNodeTopologyUpdater(clientset kubecli.KubevirtClient, hinter Hinter, ...) NodeTopologyUpdater

Constants

const TSCFrequencyLabel = virtv1.CPUTimerLabel + "tsc-frequency"

const TSCFrequencySchedulingLabel = "scheduling.node.kubevirt.io/tsc-frequency"

const TSCScalableLabel = virtv1.CPUTimerLabel + "tsc-scalable"

Functions

func AreTSCFrequencyTopologyHintsDefined

func AreTSCFrequencyTopologyHintsDefined(vmi *k6tv1.VirtualMachineInstance) bool

func CalculateTSCLabelDiff

func CalculateTSCLabelDiff(frequenciesInUse []int64, frequenciesOnNode []int64, nodeFrequency int64, scalable bool) (toAdd []int64, toRemove []int64)

func FilterNodesFromCache

func FilterNodesFromCache(objs []interface{}, predicates ...FilterPredicateFunc) []*v1.Node

func HasInvTSCFrequency

func HasInvTSCFrequency(node *v1.Node) bool

func IsManualTSCFrequencyRequired

func IsManualTSCFrequencyRequired(vmi *k6tv1.VirtualMachineInstance) bool

func IsSchedulable

func IsSchedulable(node *v1.Node) bool

func LowestTSCFrequency

func LowestTSCFrequency(nodes []*v1.Node) int64

func NewTopologyHinter

func NewTopologyHinter(nodeStore cache.Store, vmiStore cache.Store, arch string, clusterConfig *virtconfig.ClusterConfig) *topologyHinter

func TSCFrequenciesOnNode

func TSCFrequenciesOnNode(node *v1.Node) (frequencies []int64)

func TSCFrequencyFromNode

func TSCFrequencyFromNode(node *v1.Node) (frequency int64, scalable bool, err error)

func TSCFrequencyFromPod

func TSCFrequencyFromPod(pod *v1.Pod) (frequency int64, err error)

func ToTSCSchedulableLabel

func ToTSCSchedulableLabel(frequency int64) string

func ToTSCSchedulableLabels

func ToTSCSchedulableLabels(frequencies []int64) (labels []string)

Types

type FilterPredicateFunc

type FilterPredicateFunc func(node *v1.Node) bool

func NodeOfVMI

func NodeOfVMI(vmi *virtv1.VirtualMachineInstance) FilterPredicateFunc

func Not

func Not(f FilterPredicateFunc) FilterPredicateFunc

func TSCFrequencyGreaterEqual

func TSCFrequencyGreaterEqual(frequency int64) FilterPredicateFunc

type Hinter

type Hinter interface {
	TopologyHintsForVMI(vmi *k6tv1.VirtualMachineInstance) (hints *k6tv1.TopologyHints, err error)
	TopologyHintsRequiredForVMI(vmi *k6tv1.VirtualMachineInstance) bool
	TSCFrequenciesInUse() []int64
	LowestTSCFrequencyOnCluster() (int64, error)
}

type MockHinter

type MockHinter struct {
	// contains filtered or unexported fields
}

Mock of Hinter interface

func NewMockHinter

func NewMockHinter(ctrl *gomock.Controller) *MockHinter

func (*MockHinter) EXPECT

func (_m *MockHinter) EXPECT() *_MockHinterRecorder

func (*MockHinter) LowestTSCFrequencyOnCluster

func (_m *MockHinter) LowestTSCFrequencyOnCluster() (int64, error)

func (*MockHinter) TSCFrequenciesInUse

func (_m *MockHinter) TSCFrequenciesInUse() []int64

func (*MockHinter) TopologyHintsForVMI

func (_m *MockHinter) TopologyHintsForVMI(vmi *v1.VirtualMachineInstance) (*v1.TopologyHints, error)

func (*MockHinter) TopologyHintsRequiredForVMI

func (_m *MockHinter) TopologyHintsRequiredForVMI(vmi *v1.VirtualMachineInstance) bool

type MockNodeTopologyUpdater

type MockNodeTopologyUpdater struct {
	// contains filtered or unexported fields
}

Mock of NodeTopologyUpdater interface

func NewMockNodeTopologyUpdater

func NewMockNodeTopologyUpdater(ctrl *gomock.Controller) *MockNodeTopologyUpdater

func (*MockNodeTopologyUpdater) EXPECT

func (_m *MockNodeTopologyUpdater) EXPECT() *_MockNodeTopologyUpdaterRecorder

func (*MockNodeTopologyUpdater) Run

func (_m *MockNodeTopologyUpdater) Run(interval time.Duration, stopChan <-chan struct{})

type NodeTopologyUpdater

type NodeTopologyUpdater interface {
	Run(interval time.Duration, stopChan <-chan struct{})
}

func NewNodeTopologyUpdater

func NewNodeTopologyUpdater(clientset kubecli.KubevirtClient, hinter Hinter, nodeInformer cache.SharedIndexInformer) NodeTopologyUpdater