controller

package
v0.5.14 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Dec 3, 2024 License: Apache-2.0 Imports: 33 Imported by: 0

Documentation

Index

Constants

View Source 
const OOMRecorderControllerName = "oomRecorder"

Variables

This section is empty.

Functions

func GetContainer 

func GetContainer(pod *core.Pod, containerName string) *core.Container

GetContainer get container info from pod

Types

type PodOOMRecorderController 

type PodOOMRecorderController struct {
	Recorder *oom.PodOOMRecorder
	// contains filtered or unexported fields
}

PodOOMRecorderController controls pod oom events recorder

func NewPodOOMRecorderController added in v0.5.12 

func NewPodOOMRecorderController(ctx context.Context,
	controlCtx *katalystbase.GenericContext,
	genericConf *generic.GenericConfiguration,
	_ *controller.GenericControllerConfiguration,
	recConf *controller.ResourceRecommenderConfig,
) (*PodOOMRecorderController, error)

NewPodOOMRecorderController

func (*PodOOMRecorderController) ProcessContainer added in v0.5.12 

func (oc *PodOOMRecorderController) ProcessContainer(pod *core.Pod)

ProcessContainer checks for OOM kills in pod containers and enqueues them for processing.

func (*PodOOMRecorderController) Run added in v0.5.12 

func (oc *PodOOMRecorderController) Run()

type ResourceRecommendController 

type ResourceRecommendController struct {
	OOMRecorder        *oom.PodOOMRecorder
	ProcessorManager   *processormanager.Manager
	RecommenderManager *recommendermanager.Manager
	// contains filtered or unexported fields
}

func NewResourceRecommendController added in v0.5.12 

func NewResourceRecommendController(ctx context.Context,
	controlCtx *katalystbase.GenericContext,
	genericConf *generic.GenericConfiguration,
	_ *controller.GenericControllerConfiguration,
	recConf *controller.ResourceRecommenderConfig,
	OOMRecorder *oom.PodOOMRecorder,
) (*ResourceRecommendController, error)

func (*ResourceRecommendController) CancelTasks 

func (rrc *ResourceRecommendController) CancelTasks(namespacedName k8stypes.NamespacedName) *errortypes.CustomError

CancelTasks Cancel all process task

func (*ResourceRecommendController) ProcessNextResourceRecommend added in v0.5.12 

func (rrc *ResourceRecommendController) ProcessNextResourceRecommend() bool

func (*ResourceRecommendController) RegisterTasks 

func (rrc *ResourceRecommendController) RegisterTasks(recommendation recommendationtypes.Recommendation) *errortypes.CustomError

func (*ResourceRecommendController) Run added in v0.5.12 

func (rrc *ResourceRecommendController) Run()

func (*ResourceRecommendController) UpdateRecommendationStatus 

func (rrc *ResourceRecommendController) UpdateRecommendationStatus(namespacedName k8stypes.NamespacedName, recommendation *recommendationtypes.Recommendation) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.