topology

Documentation

Index

• type Adapter
  • func NewPodResourcesServerTopologyAdapter(metaServer *metaserver.MetaServer, endpoints []string, ...) (Adapter, error)
• type DummyAdapter
  • func (d DummyAdapter) GetTopologyZones(_ context.Context) ([]*nodev1alpha1.TopologyZone, error)
  • func (d DummyAdapter) Run(_ context.Context, _ func()) error
• type NumaInfoGetter
• type PodResourcesFilter

Types

type Adapter

type Adapter interface {
	// GetTopologyZones return newest topology zone status
	GetTopologyZones(ctx context.Context) ([]*nodev1alpha1.TopologyZone, error)

	// Run is to start the topology adapter to watch the topology change
	Run(ctx context.Context, handler func()) error
}

Adapter is to get topology zone status, the src of that can be pod resource api or kubelet checkpoint.

func NewPodResourcesServerTopologyAdapter

func NewPodResourcesServerTopologyAdapter(metaServer *metaserver.MetaServer, endpoints []string,
	kubeletResourcePluginPaths []string, skipDeviceNames sets.String, numaInfoGetter NumaInfoGetter,
	podResourcesFilter PodResourcesFilter, getClientFunc podresources.GetClientFunc) (Adapter, error)

NewPodResourcesServerTopologyAdapter creates a topology adapter which uses pod resources server

type DummyAdapter

type DummyAdapter struct{}

DummyAdapter is a dummy topology adapter for test

func (DummyAdapter) GetTopologyZones

func (d DummyAdapter) GetTopologyZones(_ context.Context) ([]*nodev1alpha1.TopologyZone, error)

GetTopologyZones is to get dummy topology zone status

func (DummyAdapter) Run

func (d DummyAdapter) Run(_ context.Context, _ func()) error

Run is to start the dummy topology adapter

type NumaInfoGetter

type NumaInfoGetter func() ([]info.Node, error)

NumaInfoGetter is to get numa info

type PodResourcesFilter

type PodResourcesFilter func(*v1.Pod, *podresv1.PodResources) (*podresv1.PodResources, error)

PodResourcesFilter is to filter pod resources which does need to be reported