agent

Documentation

Index

• type Agent
  • func NewAgent(ctx context.Context, nodeName, runtimeEndpoint, cgroupDriver string, ...) (*Agent, error)
  • func (a *Agent) CreateNodeResourceTsp() (string, error)
  • 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 string,
	kubeClient *kubernetes.Clientset,
	craneClient *craneclientset.Clientset,
	podInformer coreinformers.PodInformer,
	nodeInformer coreinformers.NodeInformer,
	nepInformer v1alpha1.NodeQOSEnsurancePolicyInformer,
	actionInformer v1alpha1.AvoidanceActionInformer,
	tspInformer predictionv1.TimeSeriesPredictionInformer,
	nodeResourceReserved map[string]string,
	ifaces []string,
	healthCheck *metrics.HealthCheck,
	CollectInterval time.Duration,
) (*Agent, error)

func (*Agent) CreateNodeResourceTsp

func (a *Agent) CreateNodeResourceTsp() (string, error)

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)