resourcequota

Documentation

Index

• Constants
• func Register(plugins *admission.Plugins)
• type Evaluator
• type EvaluatorController
  • func NewEvaluatorController(quotaAccessor QuotaAccessor, registry quota.Registry) *EvaluatorController
  • func (e *EvaluatorController) Evaluate(ctx context.Context, a admission.Attributes) error
  • func (e *EvaluatorController) Start(ctx context.Context) error
• type QuotaAccessor
  • func NewQuotaAccessor(client onmetalapi.Interface, lister corev1alpha1listers.ResourceQuotaLister) (QuotaAccessor, error)
• type ResourceQuota
  • func NewResourceQuota() *ResourceQuota
  • func (r *ResourceQuota) SetDrainedNotification(stopCh <-chan struct{})
  • func (r *ResourceQuota) SetExternalOnmetalClientSet(client onmetalapi.Interface)
  • func (r *ResourceQuota) SetExternalOnmetalInformerFactory(f informers.SharedInformerFactory)
  • func (r *ResourceQuota) SetQuotaRegistry(registry quota.Registry)
  • func (r *ResourceQuota) Validate(ctx context.Context, a admission.Attributes, o admission.ObjectInterfaces) error
  • func (r *ResourceQuota) ValidateInitialization() error

Constants

const PluginName = "ResourceQuota"

Functions

func Register

func Register(plugins *admission.Plugins)

Types

type Evaluator

type Evaluator interface {
	Evaluate(ctx context.Context, a admission.Attributes) error
}

type EvaluatorController

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

func NewEvaluatorController

func NewEvaluatorController(quotaAccessor QuotaAccessor, registry quota.Registry) *EvaluatorController

func (*EvaluatorController) Evaluate

func (e *EvaluatorController) Evaluate(ctx context.Context, a admission.Attributes) error

func (*EvaluatorController) Start

func (e *EvaluatorController) Start(ctx context.Context) error

type QuotaAccessor

type QuotaAccessor interface {
	List(ctx context.Context, namespace string) ([]corev1alpha1.ResourceQuota, error)
	UpdateStatus(ctx context.Context, newQuota, oldQuota *corev1alpha1.ResourceQuota) error
}

func NewQuotaAccessor

func NewQuotaAccessor(
	client onmetalapi.Interface,
	lister corev1alpha1listers.ResourceQuotaLister,
) (QuotaAccessor, error)

type ResourceQuota

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

func NewResourceQuota

func NewResourceQuota() *ResourceQuota

func (*ResourceQuota) SetDrainedNotification

func (r *ResourceQuota) SetDrainedNotification(stopCh <-chan struct{})

func (*ResourceQuota) SetExternalOnmetalClientSet

func (r *ResourceQuota) SetExternalOnmetalClientSet(client onmetalapi.Interface)

func (*ResourceQuota) SetExternalOnmetalInformerFactory

func (r *ResourceQuota) SetExternalOnmetalInformerFactory(f informers.SharedInformerFactory)

func (*ResourceQuota) SetQuotaRegistry

func (r *ResourceQuota) SetQuotaRegistry(registry quota.Registry)

func (*ResourceQuota) Validate

func (r *ResourceQuota) Validate(ctx context.Context, a admission.Attributes, o admission.ObjectInterfaces) error

func (*ResourceQuota) ValidateInitialization

func (r *ResourceQuota) ValidateInitialization() error