podapp

Documentation

Index

• Constants
• func GetWaterLevel(annotations map[string]string, key string) int
• func ScheduleCompensation(annotations map[string]string, key string) *bool
• type MutatingAdmission
  • func (a *MutatingAdmission) GetAnnotationsOfDeployment(ctx context.Context, pod *corev1.Pod) (*UserStrategy, error)
  • func (a *MutatingAdmission) Handle(ctx context.Context, req admission.Request) admission.Response
• type UserStrategy
• type ValidatingAdmission
  • func (v *ValidatingAdmission) Handle(_ context.Context, req admission.Request) admission.Response

Constants

const (
	AnnotationLowWaterLevel        string = "webhook-demo.com/low-water-level"
	AnnotationHighWaterLevel       string = "webhook-demo.com/high-water-level"
	AnnotationScheduleCompensation string = "webhook-demo.com/schedule-compensation"
	OnDemandNodeLabelKey           string = "node.kubernetes.io/capacity"
	OnDemandValue                  string = "on-demand"
	SpotNodeLabelKey               string = "node.kubernetes.io/capacity"
	SpotValue                      string = "spot"
	PDC                            string = "controller.kubernetes.io/pod-deletion-cost"
)

Functions

func GetWaterLevel

func GetWaterLevel(annotations map[string]string, key string) int

func ScheduleCompensation

func ScheduleCompensation(annotations map[string]string, key string) *bool

Types

type MutatingAdmission

type MutatingAdmission struct {
	Decoder admission.Decoder
	Client  *kubernetes.Clientset
}

MutatingAdmission mutates API request if necessary.

func (*MutatingAdmission) GetAnnotationsOfDeployment

func (a *MutatingAdmission) GetAnnotationsOfDeployment(ctx context.Context, pod *corev1.Pod) (*UserStrategy, error)

func (*MutatingAdmission) Handle

func (a *MutatingAdmission) Handle(ctx context.Context, req admission.Request) admission.Response

Handle yields a response to an AdmissionRequest.

type UserStrategy

type UserStrategy struct {
	LowWaterLevel        int
	HighWaterLevel       int
	ScheduleCompensation *bool
}

type ValidatingAdmission

type ValidatingAdmission struct {
	Decoder admission.Decoder
}

func (*ValidatingAdmission) Handle

func (v *ValidatingAdmission) Handle(_ context.Context, req admission.Request) admission.Response

Handle implements admission.Handler interface. It yields a response to an AdmissionRequest.