queuejobresources

type Factory func(config *rest.Config) Interface

type Interface interface {
	SyncQueueJob(queuejob *qjobv1.XQueueJob, qjobRes *qjobv1.XQueueJobResource) error
	UpdateQueueJobStatus(queuejob *qjobv1.XQueueJob) error
	GetAggregatedResources(queuejob *qjobv1.XQueueJob) *schedulerapi.Resource
	GetAggregatedResourcesByPriority(priority int, queuejob *qjobv1.XQueueJob) *schedulerapi.Resource
	Cleanup(queuejob *qjobv1.XQueueJob, qjobRes *qjobv1.XQueueJobResource) error
	Run(stopCh <-chan struct{})
}

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

type RefManager interface {

	//Tag the owner
	AddTag(owner *qjobv1.XQueueJobResource, getTag func() string) error

	//check whether ownee is a member of owner
	BelongTo(owner *qjobv1.XQueueJobResource, ownee runtime.Object) bool

	//mark the ownee to be a member of owner
	AddReference(owner *qjobv1.XQueueJobResource, ownee runtime.Object) error
}

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