kubequota

Documentation

Index

• Constants
• func Register(plugins *admission.Plugins)
• type KubeResourceQuota
  • func NewKubeResourceQuota(config *resourcequotaapi.Configuration) *KubeResourceQuota
  • func (k *KubeResourceQuota) SetExternalKubeInformerFactory(informers informers.SharedInformerFactory)
  • func (k *KubeResourceQuota) SetKcpInformers(local, global kcpinformers.SharedInformerFactory)
  • func (k *KubeResourceQuota) SetKubeClusterClient(kubeClusterClient kcpkubernetesclientset.ClusterInterface)
  • func (k *KubeResourceQuota) SetQuotaConfiguration(quotaConfiguration quota.Configuration)
  • func (k *KubeResourceQuota) SetServerShutdownChannel(ch <-chan struct{})
  • func (k *KubeResourceQuota) Validate(ctx context.Context, a admission.Attributes, o admission.ObjectInterfaces) error
  • func (k *KubeResourceQuota) ValidateInitialization() error
• type LogicalClusterDeletionMonitor
  • func NewLogicalClusterDeletionMonitor(name string, ...) *LogicalClusterDeletionMonitor
  • func (m *LogicalClusterDeletionMonitor) Start(stop <-chan struct{})

Constants

const PluginName = "KCPKubeResourceQuota"

PluginName is the name of this admission plugin.

Functions

func Register

func Register(plugins *admission.Plugins)

Register registers this admission plugin.

Types

type KubeResourceQuota

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

KubeResourceQuota is an admission plugin that handles quota per logical cluster.

func NewKubeResourceQuota

func NewKubeResourceQuota(config *resourcequotaapi.Configuration) *KubeResourceQuota

NewKubeResourceQuota returns a new KubeResourceQuota admission plugin.

func (*KubeResourceQuota) SetExternalKubeInformerFactory

func (k *KubeResourceQuota) SetExternalKubeInformerFactory(informers informers.SharedInformerFactory)

func (*KubeResourceQuota) SetKcpInformers

func (k *KubeResourceQuota) SetKcpInformers(local, global kcpinformers.SharedInformerFactory)

func (*KubeResourceQuota) SetKubeClusterClient

func (k *KubeResourceQuota) SetKubeClusterClient(kubeClusterClient kcpkubernetesclientset.ClusterInterface)

func (*KubeResourceQuota) SetQuotaConfiguration

func (k *KubeResourceQuota) SetQuotaConfiguration(quotaConfiguration quota.Configuration)

func (*KubeResourceQuota) SetServerShutdownChannel

func (k *KubeResourceQuota) SetServerShutdownChannel(ch <-chan struct{})

func (*KubeResourceQuota) Validate

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

Validate gets or creates a resourcequota.QuotaAdmission plugin for the logical cluster in the request and then delegates validation to it.

func (*KubeResourceQuota) ValidateInitialization

func (k *KubeResourceQuota) ValidateInitialization() error

ValidateInitialization validates all the expected fields are set.

type LogicalClusterDeletionMonitor

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

LogicalClusterDeletionMonitor monitors LogicalClusters and invokes stopFunc for each deleted LogicalCluster.

func NewLogicalClusterDeletionMonitor

func NewLogicalClusterDeletionMonitor(
	name string,
	logicalClusterInformer corev1alpha1informers.LogicalClusterClusterInformer,
	stopFunc func(logicalcluster.Name),
) *LogicalClusterDeletionMonitor

func (*LogicalClusterDeletionMonitor) Start

func (m *LogicalClusterDeletionMonitor) Start(stop <-chan struct{})