Documentation ¶
Index ¶
- Constants
- func NewQueueJobResPersistentVolumeClaim(config *rest.Config) queuejobresources.Interface
- func Register(regs *queuejobresources.RegisteredResources)
- type QueueJobResPersistentVolumeClaim
- func (qjrPersistentVolumeClaim *QueueJobResPersistentVolumeClaim) Cleanup(queuejob *arbv1.AppWrapper, qjobRes *arbv1.AppWrapperResource) error
- func (qjrPersistentVolumeClaim *QueueJobResPersistentVolumeClaim) GetAggregatedResources(job *arbv1.AppWrapper) *clusterstateapi.Resource
- func (qjrPersistentVolumeClaim *QueueJobResPersistentVolumeClaim) GetAggregatedResourcesByPriority(priority float64, job *arbv1.AppWrapper) *clusterstateapi.Resource
- func (qjrPersistentVolumeClaim *QueueJobResPersistentVolumeClaim) Run(stopCh <-chan struct{})
- func (qjrPersistentVolumeClaim *QueueJobResPersistentVolumeClaim) SyncQueueJob(queuejob *arbv1.AppWrapper, qjobRes *arbv1.AppWrapperResource) error
- func (qjrPersistentVolumeClaim *QueueJobResPersistentVolumeClaim) UpdateQueueJobStatus(queuejob *arbv1.AppWrapper) error
Constants ¶
View Source
const ( // QueueJobNameLabel label string for queuejob name QueueJobNameLabel string = "appwrapper-name" // ControllerUIDLabel label string for queuejob controller uid ControllerUIDLabel string = "controller-uid" )
Variables ¶
This section is empty.
Functions ¶
func NewQueueJobResPersistentVolumeClaim ¶
func NewQueueJobResPersistentVolumeClaim(config *rest.Config) queuejobresources.Interface
NewQueueJobResService creates a service controller
func Register ¶
func Register(regs *queuejobresources.RegisteredResources)
Register registers a queue job resource type
Types ¶
type QueueJobResPersistentVolumeClaim ¶
type QueueJobResPersistentVolumeClaim struct {
// contains filtered or unexported fields
}
QueueJobResService contains service info
func (*QueueJobResPersistentVolumeClaim) Cleanup ¶
func (qjrPersistentVolumeClaim *QueueJobResPersistentVolumeClaim) Cleanup(queuejob *arbv1.AppWrapper, qjobRes *arbv1.AppWrapperResource) error
Cleanup deletes all services
func (*QueueJobResPersistentVolumeClaim) GetAggregatedResources ¶
func (qjrPersistentVolumeClaim *QueueJobResPersistentVolumeClaim) GetAggregatedResources(job *arbv1.AppWrapper) *clusterstateapi.Resource
func (*QueueJobResPersistentVolumeClaim) GetAggregatedResourcesByPriority ¶
func (qjrPersistentVolumeClaim *QueueJobResPersistentVolumeClaim) GetAggregatedResourcesByPriority(priority float64, job *arbv1.AppWrapper) *clusterstateapi.Resource
func (*QueueJobResPersistentVolumeClaim) Run ¶
func (qjrPersistentVolumeClaim *QueueJobResPersistentVolumeClaim) Run(stopCh <-chan struct{})
Run the main goroutine responsible for watching and services.
func (*QueueJobResPersistentVolumeClaim) SyncQueueJob ¶
func (qjrPersistentVolumeClaim *QueueJobResPersistentVolumeClaim) SyncQueueJob(queuejob *arbv1.AppWrapper, qjobRes *arbv1.AppWrapperResource) error
func (*QueueJobResPersistentVolumeClaim) UpdateQueueJobStatus ¶
func (qjrPersistentVolumeClaim *QueueJobResPersistentVolumeClaim) UpdateQueueJobStatus(queuejob *arbv1.AppWrapper) error
Click to show internal directories.
Click to hide internal directories.