evictor

Documentation

Index

• Constants
• Variables
• func GetEvictionTriggerAndReason(annotations map[string]string) (string, string)
• func RegisterEvictor(name string, factoryFn FactoryFn)
• type DeleteEvictor
  • func (e *DeleteEvictor) Evict(ctx context.Context, job *sev1alpha1.PodMigrationJob, pod *corev1.Pod) error
• type FactoryFn
• type Interface
  • func NewDeleteEvictor(client kubernetes.Interface) (Interface, error)
  • func NewNativeEvictor(client kubernetes.Interface) (Interface, error)
  • func NewSoftEvictor(client kubernetes.Interface) (Interface, error)
• type Interpreter
  • func NewInterpreter(handle framework.Handle, defaultEvictionPolicy string, evictQPS float32, ...) (Interpreter, error)
• type NativeEvictor
  • func (e *NativeEvictor) Evict(ctx context.Context, job *sev1alpha1.PodMigrationJob, pod *corev1.Pod) error
• type SoftEvictor
  • func (e *SoftEvictor) Evict(ctx context.Context, job *sev1alpha1.PodMigrationJob, pod *corev1.Pod) error

Constants

const (
	LabelEvictPolicy = "koordinator.sh/evict-policy"

	AnnotationEvictReason  = "koordinator.sh/evict-reason"
	AnnotationEvictTrigger = "koordinator.sh/evict-trigger"
)

const (
	DeleteEvictorName = "Delete"
)

const (
	NativeEvictorName = "Eviction"
)

const (
	SoftEvictorName = "SoftEviction"
)

Variables

var (
	ErrTooManyEvictions = errors.New("TooManyEvictions")
)

Functions

func GetEvictionTriggerAndReason

func GetEvictionTriggerAndReason(annotations map[string]string) (string, string)

func RegisterEvictor

func RegisterEvictor(name string, factoryFn FactoryFn)

Types

type DeleteEvictor

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

func (*DeleteEvictor) Evict

func (e *DeleteEvictor) Evict(ctx context.Context, job *sev1alpha1.PodMigrationJob, pod *corev1.Pod) error

type FactoryFn

type FactoryFn func(client kubernetes.Interface) (Interface, error)

type Interface

type Interface interface {
	Evict(ctx context.Context, job *sev1alpha1.PodMigrationJob, pod *corev1.Pod) error
}

func NewDeleteEvictor

func NewDeleteEvictor(client kubernetes.Interface) (Interface, error)

func NewNativeEvictor

func NewNativeEvictor(client kubernetes.Interface) (Interface, error)

func NewSoftEvictor

func NewSoftEvictor(client kubernetes.Interface) (Interface, error)

type Interpreter

type Interpreter interface {
	Interface
}

func NewInterpreter

func NewInterpreter(handle framework.Handle, defaultEvictionPolicy string, evictQPS float32, evictBurst int) (Interpreter, error)

type NativeEvictor

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

func (*NativeEvictor) Evict

func (e *NativeEvictor) Evict(ctx context.Context, job *sev1alpha1.PodMigrationJob, pod *corev1.Pod) error

type SoftEvictor

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

func (*SoftEvictor) Evict

func (e *SoftEvictor) Evict(ctx context.Context, job *sev1alpha1.PodMigrationJob, pod *corev1.Pod) error