input

Documentation

Index

• func NewPodListerAndOOMObserver(kubeClient kube_client.Interface) (v1lister.PodLister, oom.Observer)
• func WatchEvictionEventsWithRetries(kubeClient kube_client.Interface, observer oom.Observer)
• type ClusterStateFeeder
  • func NewClusterStateFeeder(config *rest.Config, clusterState *model.ClusterState, memorySave bool) ClusterStateFeeder
• type ClusterStateFeederFactory
  • func (m ClusterStateFeederFactory) Make() *clusterStateFeeder

Functions

func NewPodListerAndOOMObserver

func NewPodListerAndOOMObserver(kubeClient kube_client.Interface) (v1lister.PodLister, oom.Observer)

NewPodListerAndOOMObserver creates pair of pod lister and OOM observer.

func WatchEvictionEventsWithRetries

func WatchEvictionEventsWithRetries(kubeClient kube_client.Interface, observer oom.Observer)

WatchEvictionEventsWithRetries watches new Events with reason=Evicted and passes them to the observer.

Types

type ClusterStateFeeder

type ClusterStateFeeder interface {
	// InitFromHistoryProvider loads historical pod spec into clusterState.
	InitFromHistoryProvider(historyProvider history.HistoryProvider)

	// InitFromCheckpoints loads historical checkpoints into clusterState.
	InitFromCheckpoints()

	// LoadVPAs updates clusterState with current state of VPAs.
	LoadVPAs()

	// LoadPods updates slusterState with current specification of Pods and their Containers.
	LoadPods()

	// LoadRealTimeMetrics updates clusterState with current usage metrics of containers.
	LoadRealTimeMetrics()

	// GarbageCollectCheckpoints removes historical checkpoints that don't have a matching VPA.
	GarbageCollectCheckpoints()
}

ClusterStateFeeder can update state of ClusterState object.

func NewClusterStateFeeder

func NewClusterStateFeeder(config *rest.Config, clusterState *model.ClusterState, memorySave bool) ClusterStateFeeder

NewClusterStateFeeder creates new ClusterStateFeeder with internal data providers, based on kube client config. Deprecated; Use ClusterStateFeederFactory instead.

type ClusterStateFeederFactory

type ClusterStateFeederFactory struct {
	ClusterState          *model.ClusterState
	KubeClient            kube_client.Interface
	MetricsClient         metrics.MetricsClient
	VpaCheckpointClient   vpa_api.VerticalPodAutoscalerCheckpointsGetter
	VpaLister             vpa_lister.VerticalPodAutoscalerLister
	PodLister             v1lister.PodLister
	OOMObserver           oom.Observer
	LegacySelectorFetcher target.VpaTargetSelectorFetcher
	SelectorFetcher       target.VpaTargetSelectorFetcher
	MemorySaveMode        bool
	ControllerFetcher     controllerfetcher.ControllerFetcher
}

ClusterStateFeederFactory makes instances of ClusterStateFeeder.

func (ClusterStateFeederFactory) Make

func (m ClusterStateFeederFactory) Make() *clusterStateFeeder

Make creates new ClusterStateFeeder with internal data providers, based on kube client.