mirror of
https://github.com/kubernetes-sigs/descheduler.git
synced 2026-01-26 21:31:18 +01:00
3a1a3ff9d8
When the feature is enabled each pod with descheduler.alpha.kubernetes.io/request-evict-only annotation will have the eviction API error examined for a specific error code/reason and message. If matched eviction of such a pod will be interpreted as initiation of an eviction in background.
43 lines
1.3 KiB
Go
43 lines
1.3 KiB
Go
package e2e
|
|
|
|
import (
|
|
"context"
|
|
"os"
|
|
"testing"
|
|
|
|
componentbaseconfig "k8s.io/component-base/config"
|
|
|
|
"sigs.k8s.io/descheduler/cmd/descheduler/app/options"
|
|
deschedulerapi "sigs.k8s.io/descheduler/pkg/api"
|
|
"sigs.k8s.io/descheduler/pkg/descheduler"
|
|
"sigs.k8s.io/descheduler/pkg/descheduler/client"
|
|
eutils "sigs.k8s.io/descheduler/pkg/descheduler/evictions/utils"
|
|
)
|
|
|
|
func TestClientConnectionConfiguration(t *testing.T) {
|
|
ctx := context.Background()
|
|
clientConnection := componentbaseconfig.ClientConnectionConfiguration{
|
|
Kubeconfig: os.Getenv("KUBECONFIG"),
|
|
QPS: 50,
|
|
Burst: 100,
|
|
}
|
|
clientSet, err := client.CreateClient(clientConnection, "")
|
|
if err != nil {
|
|
t.Errorf("Error during client creation with %v", err)
|
|
}
|
|
|
|
s, err := options.NewDeschedulerServer()
|
|
if err != nil {
|
|
t.Fatalf("Unable to initialize server: %v", err)
|
|
}
|
|
s.Client = clientSet
|
|
s.DefaultFeatureGates = initFeatureGates()
|
|
evictionPolicyGroupVersion, err := eutils.SupportEviction(s.Client)
|
|
if err != nil || len(evictionPolicyGroupVersion) == 0 {
|
|
t.Errorf("Error when checking support for eviction: %v", err)
|
|
}
|
|
if err := descheduler.RunDeschedulerStrategies(ctx, s, &deschedulerapi.DeschedulerPolicy{}, evictionPolicyGroupVersion); err != nil {
|
|
t.Errorf("Error running descheduler strategies: %+v", err)
|
|
}
|
|
}
|