resourceusage

Documentation

Index

• Constants
• type ResourceList
  • func (r ResourceList) String() string
• type ResourceQuotaEnforcer
  • func NewResourceQuotaEnforcer(crdInformerFactory crdinformers.SharedInformerFactory, ...) ResourceQuotaEnforcer
  • func (r *ResourceQuotaEnforcer) AdmitScheduledSparkApplication(app so.ScheduledSparkApplication) (string, error)
  • func (r *ResourceQuotaEnforcer) AdmitSparkApplication(app so.SparkApplication) (string, error)
  • func (r ResourceQuotaEnforcer) WaitForCacheSync(stopCh <-chan struct{}) error
• type ResourceUsageWatcher
  • func (r *ResourceUsageWatcher) GetCurrentResourceUsage(namespace string) ResourceList
  • func (r *ResourceUsageWatcher) GetCurrentResourceUsageWithApplication(namespace, kind, name string) (namespaceResources, applicationResources ResourceList)

Constants

const (
	KindSparkApplication          = "SparkApplication"
	KindScheduledSparkApplication = "ScheduledSparkApplication"
)

Types

type ResourceList

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

more convenient replacement for corev1.ResourceList

func (ResourceList) String

func (r ResourceList) String() string

type ResourceQuotaEnforcer

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

func NewResourceQuotaEnforcer

func NewResourceQuotaEnforcer(crdInformerFactory crdinformers.SharedInformerFactory, coreV1InformerFactory informers.SharedInformerFactory) ResourceQuotaEnforcer

func (*ResourceQuotaEnforcer) AdmitScheduledSparkApplication

func (r *ResourceQuotaEnforcer) AdmitScheduledSparkApplication(app so.ScheduledSparkApplication) (string, error)

func (*ResourceQuotaEnforcer) AdmitSparkApplication

func (r *ResourceQuotaEnforcer) AdmitSparkApplication(app so.SparkApplication) (string, error)

func (ResourceQuotaEnforcer) WaitForCacheSync

func (r ResourceQuotaEnforcer) WaitForCacheSync(stopCh <-chan struct{}) error

type ResourceUsageWatcher

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

func (*ResourceUsageWatcher) GetCurrentResourceUsage

func (r *ResourceUsageWatcher) GetCurrentResourceUsage(namespace string) ResourceList

func (*ResourceUsageWatcher) GetCurrentResourceUsageWithApplication

func (r *ResourceUsageWatcher) GetCurrentResourceUsageWithApplication(namespace, kind, name string) (namespaceResources, applicationResources ResourceList)