agent

Documentation

Index

• type Agent
  • func NewAgent(ctx context.Context, ...) (*Agent, error)
  • func (a *Agent) CreateNodeResourceTopology(sysPath string) error
  • func (a *Agent) CreateNodeResourceTsp() string
  • func (a *Agent) DeleteNodeResourceTsp() error
  • func (a *Agent) GenerateNodeResourceTspName() string
  • func (a *Agent) Run(healthCheck *metrics.HealthCheck, enableProfiling bool, bindAddr string)

Types

type Agent

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

func NewAgent

func NewAgent(ctx context.Context,
	nodeName, runtimeEndpoint, cgroupDriver, sysPath, kubeletRootPath string,
	kubeClient kubernetes.Interface,
	craneClient craneclientset.Interface,
	podInformer coreinformers.PodInformer,
	nodeInformer coreinformers.NodeInformer,
	nodeQOSInformer v1alpha1.NodeQOSInformer,
	podQOSInformer v1alpha1.PodQOSInformer,
	actionInformer v1alpha1.AvoidanceActionInformer,
	tspInformer predictionv1.TimeSeriesPredictionInformer,
	nrtInformer topologyinformer.NodeResourceTopologyInformer,
	nodeResourceReserved map[string]string,
	ifaces []string,
	healthCheck *metrics.HealthCheck,
	collectInterval time.Duration,
	executeExcess string,
	cpuManagerReconcilePeriod time.Duration,
	defaultCPUPolicy string,
) (*Agent, error)

func (*Agent) CreateNodeResourceTopology

func (a *Agent) CreateNodeResourceTopology(sysPath string) error

func (*Agent) CreateNodeResourceTsp

func (a *Agent) CreateNodeResourceTsp() string

func (*Agent) DeleteNodeResourceTsp

func (a *Agent) DeleteNodeResourceTsp() error

func (*Agent) GenerateNodeResourceTspName

func (a *Agent) GenerateNodeResourceTspName() string

func (*Agent) Run

func (a *Agent) Run(healthCheck *metrics.HealthCheck, enableProfiling bool, bindAddr string)