resourcetopologyexporter

Documentation

Index

• func Execute(hnd resourcemonitor.Handle, nrtupdaterArgs nrtupdater.Args, ...) error
• type Args
• type ResourceObserver
  • func NewResourceObserver(hnd resourcemonitor.Handle, args resourcemonitor.Args) (*ResourceObserver, error)
  • func (rm *ResourceObserver) Run(eventsChan <-chan notification.Event, condChan chan<- v1.PodCondition)
  • func (rm *ResourceObserver) Stop()

Functions

func Execute

func Execute(hnd resourcemonitor.Handle, nrtupdaterArgs nrtupdater.Args, resourcemonitorArgs resourcemonitor.Args, rteArgs Args) error

Types

type Args

type Args struct {
	Debug                  bool
	ReferenceContainer     *sharedcpuspool.ContainerIdent
	TopologyManagerPolicy  string
	TopologyManagerScope   string
	KubeletConfigFile      string
	PodResourcesSocketPath string
	SleepInterval          time.Duration
	PodReadinessEnable     bool
	NotifyFilePath         string
	MaxEventsPerTimeUnit   int64
	TimeUnitToLimitEvents  time.Duration
	PrometheusMode         string
}

type ResourceObserver

type ResourceObserver struct {
	Infos <-chan nrtupdater.MonitorInfo
	// contains filtered or unexported fields
}

func NewResourceObserver

func NewResourceObserver(hnd resourcemonitor.Handle, args resourcemonitor.Args) (*ResourceObserver, error)

func (*ResourceObserver) Run

func (rm *ResourceObserver) Run(eventsChan <-chan notification.Event, condChan chan<- v1.PodCondition)

func (*ResourceObserver) Stop

func (rm *ResourceObserver) Stop()