resource

package

v0.5.0 Latest Latest Go to latest Published: Apr 28, 2024 License: Apache-2.0 Imports: 17 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/kubewharf/katalyst-core

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func NewReclaimedResourcesEvictionPlugin(_ *client.GenericClientSet, _ events.EventRecorder, ...) plugin.EvictionPlugin
type GracePeriodGetter
type ResourcesEvictionPlugin
- func NewResourcesEvictionPlugin(pluginName string, metaServer *metaserver.MetaServer, ...) *ResourcesEvictionPlugin
type ResourcesGetter
type ThresholdGetter

Constants ¶

View Source

const (
	MetricsNamePodCount         = "pod_count"
	MetricsNamePodResource      = "pod_resource"
	MetricsNameGetResourceEmpty = "get_resource_empty"
)

View Source

const ReclaimedResourcesEvictionPluginName = "reclaimed-resource-pressure-eviction-plugin"

Variables ¶

This section is empty.

Functions ¶

func NewReclaimedResourcesEvictionPlugin ¶

func NewReclaimedResourcesEvictionPlugin(_ *client.GenericClientSet, _ events.EventRecorder,
	metaServer *metaserver.MetaServer, emitter metrics.MetricEmitter, conf *config.Configuration) plugin.EvictionPlugin

Types ¶

type GracePeriodGetter ¶

type GracePeriodGetter func() int64

type ResourcesEvictionPlugin ¶

type ResourcesEvictionPlugin struct {
	// contains filtered or unexported fields
}

ResourcesEvictionPlugin implements EvictPlugin interface it trigger pod eviction logic based on the tolerance of resources.

func NewResourcesEvictionPlugin ¶

func NewResourcesEvictionPlugin(pluginName string, metaServer *metaserver.MetaServer,
	emitter metrics.MetricEmitter, resourcesGetter ResourcesGetter, thresholdGetter ThresholdGetter,
	deletionGracePeriodGetter GracePeriodGetter, thresholdMetToleranceDurationGetter GracePeriodGetter,
	skipZeroQuantityResourceNames sets.String,
	podFilter func(pod *v1.Pod) (bool, error)) *ResourcesEvictionPlugin

func (*ResourcesEvictionPlugin) GetEvictPods ¶

func (b *ResourcesEvictionPlugin) GetEvictPods(_ context.Context, request *pluginapi.GetEvictPodsRequest) (*pluginapi.GetEvictPodsResponse, error)

func (*ResourcesEvictionPlugin) GetTopEvictionPods ¶

func (b *ResourcesEvictionPlugin) GetTopEvictionPods(_ context.Context, request *pluginapi.GetTopEvictionPodsRequest) (*pluginapi.GetTopEvictionPodsResponse, error)

func (*ResourcesEvictionPlugin) Name ¶

func (b *ResourcesEvictionPlugin) Name() string

func (*ResourcesEvictionPlugin) Start ¶

func (b *ResourcesEvictionPlugin) Start()

func (*ResourcesEvictionPlugin) ThresholdMet ¶

func (b *ResourcesEvictionPlugin) ThresholdMet(ctx context.Context) (*pluginapi.ThresholdMetResponse, error)

ThresholdMet evict pods when the beset effort resources usage is greater than the supply (after considering toleration).

type ResourcesGetter ¶

type ResourcesGetter func(ctx context.Context) (v1.ResourceList, error)

type ThresholdGetter ¶

type ThresholdGetter func(resourceName v1.ResourceName) *float64

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL