Documentation
¶
Overview ¶
Package evictionmanager is the package that contains the libraries that drive the Kubelet binary. The kubelet is responsible for node level pod management. It runs on each worker in the cluster.
Index ¶
- Constants
- Variables
- func NewInnerEvictionPluginInitializers() map[string]plugin.InitFunc
- type EvictionManger
- func (m *EvictionManger) DeRegisterPlugin(pluginName string)
- func (m *EvictionManger) GetHandlerType() string
- func (m *EvictionManger) RegisterPlugin(pluginName string, endpoint string, _ []string) error
- func (m *EvictionManger) Run(ctx context.Context)
- func (m *EvictionManger) ValidatePlugin(pluginName string, endpoint string, versions []string) error
- type LatestCNRGetter
- type LatestPodsGetter
Constants ¶
View Source
const ( EventReasonEvictFailed = "EvictFailed" EventReasonEvictCreated = "EvictCreated" EventReasonEvictExceededGracePeriod = "EvictExceededGracePeriod" EventReasonEvictSucceeded = "EvictSucceeded" )
View Source
const ( MetricsNameVictimPodCNT = "victims_cnt" MetricsNameRunningPodCNT = "running_pod_cnt" MetricsNameCandidatePodCNT = "candidate_pod_cnt" MetricsNameDryRunVictimPodCNT = "dryrun_victims_cnt" MetricsNameDryRunConditionCNT = "dryrun_condition_cnt" )
View Source
const (
EventActionEvicting = "Evicting"
)
Variables ¶
View Source
var InnerEvictionPluginsDisabledByDefault = sets.NewString()
Functions ¶
Types ¶
type EvictionManger ¶
type EvictionManger struct {
// contains filtered or unexported fields
}
EvictionManger reconciles to check if some threshold has been met, and trigger pod eviction actions if needed.
func NewEvictionManager ¶
func NewEvictionManager(genericClient *client.GenericClientSet, recorder events.EventRecorder, metaServer *metaserver.MetaServer, emitter metrics.MetricEmitter, conf *pkgconfig.Configuration) *EvictionManger
func (*EvictionManger) DeRegisterPlugin ¶
func (m *EvictionManger) DeRegisterPlugin(pluginName string)
func (*EvictionManger) GetHandlerType ¶
func (m *EvictionManger) GetHandlerType() string
func (*EvictionManger) RegisterPlugin ¶
func (m *EvictionManger) RegisterPlugin(pluginName string, endpoint string, _ []string) error
func (*EvictionManger) Run ¶
func (m *EvictionManger) Run(ctx context.Context)
func (*EvictionManger) ValidatePlugin ¶
func (m *EvictionManger) ValidatePlugin(pluginName string, endpoint string, versions []string) error
ValidatePlugin validates a plugin if the version is correct and the name has the format of an extended resource
type LatestCNRGetter ¶
type LatestCNRGetter func() *v1alpha1.CustomNodeResource
LatestCNRGetter returns the latest CNR resources.
type LatestPodsGetter ¶
LatestPodsGetter returns the latest pods that are running.
Source Files
¶
Directories
¶
| Path | Synopsis |
|---|---|
|
Package plugin is the package that defines the eviction strategy, and those strategies must implement EvictPlugin interface, supporting both embedded plugin and external registered plugin.
|
Package plugin is the package that defines the eviction strategy, and those strategies must implement EvictPlugin interface, supporting both embedded plugin and external registered plugin. |
Click to show internal directories.
Click to hide internal directories.