resourcetopologyexporter

Documentation

Index

• Constants
• func Execute(cli podresourcesapi.PodResourcesListerClient, nrtupdaterArgs nrtupdater.Args, ...) error
• func IsTriggeringFSNotifyEvent(event fsnotify.Event) bool
• type Args
• type PollTrigger
• type ResourceMonitor
  • func NewResourceMonitor(cli podresourcesapi.PodResourcesListerClient, args resourcemonitor.Args, ...) (*ResourceMonitor, error)
  • func (rm *ResourceMonitor) Run(eventsChan <-chan PollTrigger) (<-chan nrtupdater.MonitorInfo, chan<- struct{})

Constants

const (
	StateCPUManager    string = "cpu_manager_state"
	StateMemoryManager string = "memory_manager_state"
	StateDeviceManager string = "kubelet_internal_checkpoint"
)

Functions

func Execute

func Execute(cli podresourcesapi.PodResourcesListerClient, nrtupdaterArgs nrtupdater.Args, resourcemonitorArgs resourcemonitor.Args, rteArgs Args) error

func IsTriggeringFSNotifyEvent

func IsTriggeringFSNotifyEvent(event fsnotify.Event) bool

Types

type Args

type Args struct {
	Debug                  bool
	ReferenceContainer     *podrescli.ContainerIdent
	TopologyManagerPolicy  string
	KubeletConfigFile      string
	KubeletStateDirs       []string
	PodResourcesSocketPath string
	SleepInterval          time.Duration
}

type PollTrigger

type PollTrigger struct {
	Timer     bool
	Timestamp time.Time
}

type ResourceMonitor

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

func NewResourceMonitor

func NewResourceMonitor(cli podresourcesapi.PodResourcesListerClient, args resourcemonitor.Args, rteArgs Args) (*ResourceMonitor, error)

func (*ResourceMonitor) Run

func (rm *ResourceMonitor) Run(eventsChan <-chan PollTrigger) (<-chan nrtupdater.MonitorInfo, chan<- struct{})