resourcetopologyexporter

Documentation

Index

• func Execute(hnd Handle, nrtupdaterArgs nrtupdater.Args, ...) error
• type Args
  • func (args Args) Clone() Args
• type Handle
• 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 Handle, nrtupdaterArgs nrtupdater.Args, resourcemonitorArgs resourcemonitor.Args, rteArgs Args) error

Types

type Args

type Args struct {
	ReferenceContainer     *sharedcpuspool.ContainerIdent `json:"referenceContainer,omitempty"`
	TopologyManagerPolicy  string                         `json:"topologyManagerPolicy,omitempty"`
	TopologyManagerScope   string                         `json:"topologyManagerScope,omitempty"`
	KubeletConfigFile      string                         `json:"kubeletConfigFile,omitempty"`
	PodResourcesSocketPath string                         `json:"podResourcesSocketPath,omitempty"`
	SleepInterval          time.Duration                  `json:"sleepInterval,omitempty"`
	PodReadinessEnable     bool                           `json:"podReadinessEnable,omitempty"`
	NotifyFilePath         string                         `json:"notifyFilePath,omitempty"`
	MaxEventsPerTimeUnit   int64                          `json:"maxEventPerTimeUnit,omitempty"`
	TimeUnitToLimitEvents  time.Duration                  `json:"timeUnitToLimitEvents,omitempty"`
	AddNRTOwnerEnable      bool                           `json:"addNRTOwnerEnable,omitempty"`
	MetricsMode            string                         `json:"metricsMode,omitempty"`
	MetricsPort            int                            `json:"metricsPort,omitempty"`
	MetricsAddress         string                         `json:"metricsAddress,omitempty"`
	MetricsTLSCfg          metricssrv.TLSConfig           `json:"metricsTLS,omitempty"`
}

func (Args) Clone

func (args Args) Clone() Args

type Handle

type Handle struct {
	ResMon resourcemonitor.Handle
	NRTCli topologyclientset.Interface
}

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()