input

Documentation

Index

• func NewPodListerAndOOMObserver(kubeClient kube_client.Interface, namespace string) (v1lister.PodLister, oom.Observer)
• func WatchEvictionEventsWithRetries(kubeClient kube_client.Interface, observer oom.Observer, namespace string)
• 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, namespace string) (v1lister.PodLister, oom.Observer)

NewPodListerAndOOMObserver creates pair of pod lister and OOM observer.

func WatchEvictionEventsWithRetries

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

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 clusterState 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, namespace string) 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
	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.