Documentation ¶
Index ¶
- Constants
- func NewQueueJobResDeployment(config *rest.Config) queuejobresources.Interface
- func Register(regs *queuejobresources.RegisteredResources)
- type QueueJobResDeployment
- func (qjrService *QueueJobResDeployment) Cleanup(queuejob *arbv1.XQueueJob, qjobRes *arbv1.XQueueJobResource) error
- func (qjrPod *QueueJobResDeployment) GetAggregatedResources(job *arbv1.XQueueJob) *schedulerapi.Resource
- func (qjrPod *QueueJobResDeployment) GetAggregatedResourcesByPriority(priority int, job *arbv1.XQueueJob) *schedulerapi.Resource
- func (qjrPod *QueueJobResDeployment) GetPodTemplate(qjobRes *arbv1.XQueueJobResource) (*v1.PodTemplateSpec, int32, error)
- func (qjrService *QueueJobResDeployment) Run(stopCh <-chan struct{})
- func (qjrService *QueueJobResDeployment) SyncQueueJob(queuejob *arbv1.XQueueJob, qjobRes *arbv1.XQueueJobResource) error
- func (qjrPod *QueueJobResDeployment) UpdateQueueJobStatus(queuejob *arbv1.XQueueJob) error
Constants ¶
View Source
const ( // QueueJobNameLabel label string for queuejob name QueueJobNameLabel string = "xqueuejob-name" // ControllerUIDLabel label string for queuejob controller uid ControllerUIDLabel string = "controller-uid" )
Variables ¶
This section is empty.
Functions ¶
func NewQueueJobResDeployment ¶
func NewQueueJobResDeployment(config *rest.Config) queuejobresources.Interface
NewQueueJobResDeployment returns a new deployment controller
func Register ¶
func Register(regs *queuejobresources.RegisteredResources)
Register registers a queue job resource type
Types ¶
type QueueJobResDeployment ¶
type QueueJobResDeployment struct {
// contains filtered or unexported fields
}
QueueJobResDeployment contains the resources of this queuejob
func (*QueueJobResDeployment) Cleanup ¶
func (qjrService *QueueJobResDeployment) Cleanup(queuejob *arbv1.XQueueJob, qjobRes *arbv1.XQueueJobResource) error
Cleanup deletes all resources with this contorller
func (*QueueJobResDeployment) GetAggregatedResources ¶
func (qjrPod *QueueJobResDeployment) GetAggregatedResources(job *arbv1.XQueueJob) *schedulerapi.Resource
func (*QueueJobResDeployment) GetAggregatedResourcesByPriority ¶
func (qjrPod *QueueJobResDeployment) GetAggregatedResourcesByPriority(priority int, job *arbv1.XQueueJob) *schedulerapi.Resource
func (*QueueJobResDeployment) GetPodTemplate ¶
func (qjrPod *QueueJobResDeployment) GetPodTemplate(qjobRes *arbv1.XQueueJobResource) (*v1.PodTemplateSpec, int32, error)
func (*QueueJobResDeployment) Run ¶
func (qjrService *QueueJobResDeployment) Run(stopCh <-chan struct{})
Run the main goroutine responsible for watching and services.
func (*QueueJobResDeployment) SyncQueueJob ¶
func (qjrService *QueueJobResDeployment) SyncQueueJob(queuejob *arbv1.XQueueJob, qjobRes *arbv1.XQueueJobResource) error
SyncQueueJob syncs the resources of this queuejob
func (*QueueJobResDeployment) UpdateQueueJobStatus ¶
func (qjrPod *QueueJobResDeployment) UpdateQueueJobStatus(queuejob *arbv1.XQueueJob) error
Click to show internal directories.
Click to hide internal directories.