statefulset

Documentation

Index

• Constants
• func NewQueueJobResStatefulSet(config *rest.Config) queuejobresources.Interface
• func Register(regs *queuejobresources.RegisteredResources)
• type QueueJobResSS
  • func (qjrService *QueueJobResSS) Cleanup(queuejob *arbv1.XQueueJob, qjobRes *arbv1.XQueueJobResource) error
  • func (qjrPod *QueueJobResSS) GetAggregatedResources(job *arbv1.XQueueJob) *schedulerapi.Resource
  • func (qjrPod *QueueJobResSS) GetAggregatedResourcesByPriority(priority int, job *arbv1.XQueueJob) *schedulerapi.Resource
  • func (qjrPod *QueueJobResSS) GetPodTemplate(qjobRes *arbv1.XQueueJobResource) (*v1.PodTemplateSpec, int32, error)
  • func (qjrService *QueueJobResSS) Run(stopCh <-chan struct{})
  • func (qjrService *QueueJobResSS) SyncQueueJob(queuejob *arbv1.XQueueJob, qjobRes *arbv1.XQueueJobResource) error
  • func (qjrPod *QueueJobResSS) UpdateQueueJobStatus(queuejob *arbv1.XQueueJob) error

Constants

const (
	// QueueJobNameLabel label string for queuejob name
	QueueJobNameLabel string = "xqueuejob-name"

	// ControllerUIDLabel label string for queuejob controller uid
	ControllerUIDLabel string = "controller-uid"
)

Functions

func NewQueueJobResStatefulSet

func NewQueueJobResStatefulSet(config *rest.Config) queuejobresources.Interface

NewQueueJobResStatefulSet - creates a controller for SS

func Register

func Register(regs *queuejobresources.RegisteredResources)

Register registers a queue job resource type

Types

type QueueJobResSS

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

QueueJobResSS - stateful sets

func (*QueueJobResSS) Cleanup

func (qjrService *QueueJobResSS) Cleanup(queuejob *arbv1.XQueueJob, qjobRes *arbv1.XQueueJobResource) error

Cleanup - cleans the resources

func (*QueueJobResSS) GetAggregatedResources

func (qjrPod *QueueJobResSS) GetAggregatedResources(job *arbv1.XQueueJob) *schedulerapi.Resource

func (*QueueJobResSS) GetAggregatedResourcesByPriority

func (qjrPod *QueueJobResSS) GetAggregatedResourcesByPriority(priority int, job *arbv1.XQueueJob) *schedulerapi.Resource

func (*QueueJobResSS) GetPodTemplate

func (qjrPod *QueueJobResSS) GetPodTemplate(qjobRes *arbv1.XQueueJobResource) (*v1.PodTemplateSpec, int32, error)

GetPodTemplate Parse queue job api object to get Pod template

func (*QueueJobResSS) Run

func (qjrService *QueueJobResSS) Run(stopCh <-chan struct{})

Run the main goroutine responsible for watching and services.

func (*QueueJobResSS) SyncQueueJob

func (qjrService *QueueJobResSS) SyncQueueJob(queuejob *arbv1.XQueueJob, qjobRes *arbv1.XQueueJobResource) error

SyncQueueJob - syncs the resources of the queuejob

func (*QueueJobResSS) UpdateQueueJobStatus

func (qjrPod *QueueJobResSS) UpdateQueueJobStatus(queuejob *arbv1.XQueueJob) error