elasticqueue

Documentation

Index

• Variables
• func New(client framework.RuntimeClientInterface) framework.QueueInterface
• type KubeElasticQueue
  • func (eq *KubeElasticQueue) AddEventListener(ctx context.Context, listenerType string, ...) error
  • func (eq *KubeElasticQueue) Create(ctx context.Context, q *api.QueueInfo) error
  • func (eq *KubeElasticQueue) Delete(ctx context.Context, q *api.QueueInfo) error
  • func (eq *KubeElasticQueue) String(name string) string
  • func (eq *KubeElasticQueue) Update(ctx context.Context, q *api.QueueInfo) error

Variables

var (
	QueueGVK                  = k8s.EQuotaGVK
	KubeElasticQueueQuotaType = client.KubeFrameworkVersion(QueueGVK)
)

Functions

func New

func New(client framework.RuntimeClientInterface) framework.QueueInterface

Types

type KubeElasticQueue

type KubeElasticQueue struct {
	GVK schema.GroupVersionKind
	// contains filtered or unexported fields
}

KubeElasticQueue is a struct that contains client to operate elastic queue on cluster Note: the CRD of elastic queue is ElasticResourceQuota

func (*KubeElasticQueue) AddEventListener

func (eq *KubeElasticQueue) AddEventListener(ctx context.Context, listenerType string,
	eventQ workqueue.RateLimitingInterface, listener interface{}) error

func (*KubeElasticQueue) Create

func (eq *KubeElasticQueue) Create(ctx context.Context, q *api.QueueInfo) error

func (*KubeElasticQueue) Delete

func (eq *KubeElasticQueue) Delete(ctx context.Context, q *api.QueueInfo) error

func (*KubeElasticQueue) String

func (eq *KubeElasticQueue) String(name string) string

func (*KubeElasticQueue) Update

func (eq *KubeElasticQueue) Update(ctx context.Context, q *api.QueueInfo) error