limitranger

Documentation

Index

• Constants
• func PersistentVolumeClaimValidateLimitFunc(limitRange *corev1.LimitRange, pvc *api.PersistentVolumeClaim) error
• func PodMutateLimitFunc(limitRange *corev1.LimitRange, pod *api.Pod) error
• func PodValidateLimitFunc(limitRange *corev1.LimitRange, pod *api.Pod) error
• func Register(plugins *admission.Plugins)
• type DefaultLimitRangerActions
  • func (d *DefaultLimitRangerActions) MutateLimit(limitRange *corev1.LimitRange, resourceName string, obj runtime.Object) error
  • func (d *DefaultLimitRangerActions) SupportsAttributes(a admission.Attributes) bool
  • func (d *DefaultLimitRangerActions) SupportsLimit(limitRange *corev1.LimitRange) bool
  • func (d *DefaultLimitRangerActions) ValidateLimit(limitRange *corev1.LimitRange, resourceName string, obj runtime.Object) error
• type LimitRanger
  • func NewLimitRanger(actions LimitRangerActions) (*LimitRanger, error)
  • func (l *LimitRanger) Admit(a admission.Attributes, o admission.ObjectInterfaces) (err error)
  • func (l *LimitRanger) GetLimitRanges(a admission.Attributes) ([]*corev1.LimitRange, error)
  • func (a *LimitRanger) SetExternalKubeClientSet(client kubernetes.Interface)
  • func (l *LimitRanger) SetExternalKubeInformerFactory(f informers.SharedInformerFactory)
  • func (l *LimitRanger) Validate(a admission.Attributes, o admission.ObjectInterfaces) (err error)
  • func (l *LimitRanger) ValidateInitialization() error
• type LimitRangerActions

Constants

const (

	// PluginName indicates name of admission plugin.
	PluginName = "LimitRanger"
)

Functions

func PersistentVolumeClaimValidateLimitFunc

func PersistentVolumeClaimValidateLimitFunc(limitRange *corev1.LimitRange, pvc *api.PersistentVolumeClaim) error

PersistentVolumeClaimValidateLimitFunc enforces storage limits for PVCs. Users request storage via pvc.Spec.Resources.Requests. Min/Max is enforced by an admin with LimitRange. Claims will not be modified with default values because storage is a required part of pvc.Spec. All storage enforced values *only* apply to pvc.Spec.Resources.Requests.

func PodMutateLimitFunc

func PodMutateLimitFunc(limitRange *corev1.LimitRange, pod *api.Pod) error

PodMutateLimitFunc sets resource requirements enumerated by the pod against the specified LimitRange. The pod may be modified to apply default resource requirements if not specified, and enumerated on the LimitRange

func PodValidateLimitFunc

func PodValidateLimitFunc(limitRange *corev1.LimitRange, pod *api.Pod) error

PodValidateLimitFunc enforces resource requirements enumerated by the pod against the specified LimitRange.

func Register

func Register(plugins *admission.Plugins)

Register registers a plugin

Types

type DefaultLimitRangerActions

type DefaultLimitRangerActions struct{}

DefaultLimitRangerActions is the default implementation of LimitRangerActions.

func (*DefaultLimitRangerActions) MutateLimit

func (d *DefaultLimitRangerActions) MutateLimit(limitRange *corev1.LimitRange, resourceName string, obj runtime.Object) error

Limit enforces resource requirements of incoming resources against enumerated constraints on the LimitRange. It may modify the incoming object to apply default resource requirements if not specified, and enumerated on the LimitRange

func (*DefaultLimitRangerActions) SupportsAttributes

func (d *DefaultLimitRangerActions) SupportsAttributes(a admission.Attributes) bool

SupportsAttributes ignores all calls that do not deal with pod resources or storage requests (PVCs). Also ignores any call that has a subresource defined.

func (*DefaultLimitRangerActions) SupportsLimit

func (d *DefaultLimitRangerActions) SupportsLimit(limitRange *corev1.LimitRange) bool

SupportsLimit always returns true.

func (*DefaultLimitRangerActions) ValidateLimit

func (d *DefaultLimitRangerActions) ValidateLimit(limitRange *corev1.LimitRange, resourceName string, obj runtime.Object) error

Limit enforces resource requirements of incoming resources against enumerated constraints on the LimitRange. It may modify the incoming object to apply default resource requirements if not specified, and enumerated on the LimitRange

type LimitRanger

type LimitRanger struct {
	*admission.Handler
	// contains filtered or unexported fields
}

LimitRanger enforces usage limits on a per resource basis in the namespace

func NewLimitRanger

func NewLimitRanger(actions LimitRangerActions) (*LimitRanger, error)

NewLimitRanger returns an object that enforces limits based on the supplied limit function

func (*LimitRanger) Admit

func (l *LimitRanger) Admit(a admission.Attributes, o admission.ObjectInterfaces) (err error)

Admit admits resources into cluster that do not violate any defined LimitRange in the namespace

func (*LimitRanger) GetLimitRanges

func (l *LimitRanger) GetLimitRanges(a admission.Attributes) ([]*corev1.LimitRange, error)

func (*LimitRanger) SetExternalKubeClientSet

func (a *LimitRanger) SetExternalKubeClientSet(client kubernetes.Interface)

func (*LimitRanger) SetExternalKubeInformerFactory

func (l *LimitRanger) SetExternalKubeInformerFactory(f informers.SharedInformerFactory)

func (*LimitRanger) Validate

func (l *LimitRanger) Validate(a admission.Attributes, o admission.ObjectInterfaces) (err error)

Validate admits resources into cluster that do not violate any defined LimitRange in the namespace

func (*LimitRanger) ValidateInitialization

func (l *LimitRanger) ValidateInitialization() error

type LimitRangerActions

type LimitRangerActions interface {
	// MutateLimit is a pluggable function to set limits on the object.
	MutateLimit(limitRange *corev1.LimitRange, kind string, obj runtime.Object) error
	// ValidateLimits is a pluggable function to enforce limits on the object.
	ValidateLimit(limitRange *corev1.LimitRange, kind string, obj runtime.Object) error
	// SupportsAttributes is a pluggable function to allow overridding what resources the limitranger
	// supports.
	SupportsAttributes(attr admission.Attributes) bool
	// SupportsLimit is a pluggable function to allow ignoring limits that should not be applied
	// for any reason.
	SupportsLimit(limitRange *corev1.LimitRange) bool
}