vcqueue

Documentation

Index

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

Variables

var (
	QueueGVK             = k8s.VCQueueGVK
	KubeVCQueueQuotaType = client.KubeFrameworkVersion(QueueGVK)
)

Functions

func New

func New(client framework.RuntimeClientInterface) framework.QueueInterface

Types

type KubeVCQueue

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

KubeVCQueue is a struct that contains client to operate volcano queue on cluster

func (*KubeVCQueue) AddEventListener

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

func (*KubeVCQueue) Create

func (vcq *KubeVCQueue) Create(ctx context.Context, q *api.QueueInfo) error

func (*KubeVCQueue) Delete

func (vcq *KubeVCQueue) Delete(ctx context.Context, q *api.QueueInfo) error

func (*KubeVCQueue) String

func (vcq *KubeVCQueue) String(name string) string

func (*KubeVCQueue) Update

func (vcq *KubeVCQueue) Update(ctx context.Context, q *api.QueueInfo) error