statefulset

Documentation

Index

• Constants
• func NewQueueJobResStatefulSet(config *rest.Config) queuejobresources.Interface
• func Register(regs *queuejobresources.RegisteredResources)
• type QueueJobResStatefulSet
  • func (qjrStatefulSet *QueueJobResStatefulSet) Cleanup(queuejob *arbv1.AppWrapper, qjobRes *arbv1.AppWrapperResource) error
  • func (qjrStatefulSet *QueueJobResStatefulSet) GetAggregatedResources(queueJob *arbv1.AppWrapper) *clusterstateapi.Resource
  • func (qjrStatefulSet *QueueJobResStatefulSet) GetAggregatedResourcesByPriority(priority float64, queueJob *arbv1.AppWrapper) *clusterstateapi.Resource
  • func (qjrStatefulSet *QueueJobResStatefulSet) GetPodTemplate(qjobRes *arbv1.AppWrapperResource) (*v1.PodTemplateSpec, int32, error)
  • func (qjrStatefulSet *QueueJobResStatefulSet) Run(stopCh <-chan struct{})
  • func (qjrStatefulSet *QueueJobResStatefulSet) SyncQueueJob(queuejob *arbv1.AppWrapper, qjobRes *arbv1.AppWrapperResource) error
  • func (qjrStatefulSet *QueueJobResStatefulSet) UpdateQueueJobStatus(queuejob *arbv1.AppWrapper) error

Constants

const (
	// QueueJobNameLabel label string for queuejob name
	QueueJobNameLabel string = "appwrapper-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 QueueJobResStatefulSet

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

QueueJobResStatefulSet - stateful sets

func (*QueueJobResStatefulSet) Cleanup

func (qjrStatefulSet *QueueJobResStatefulSet) Cleanup(queuejob *arbv1.AppWrapper, qjobRes *arbv1.AppWrapperResource) error

Cleanup deletes all services

func (*QueueJobResStatefulSet) GetAggregatedResources

func (qjrStatefulSet *QueueJobResStatefulSet) GetAggregatedResources(queueJob *arbv1.AppWrapper) *clusterstateapi.Resource

func (*QueueJobResStatefulSet) GetAggregatedResourcesByPriority

func (qjrStatefulSet *QueueJobResStatefulSet) GetAggregatedResourcesByPriority(priority float64, queueJob *arbv1.AppWrapper) *clusterstateapi.Resource

func (*QueueJobResStatefulSet) GetPodTemplate

func (qjrStatefulSet *QueueJobResStatefulSet) GetPodTemplate(qjobRes *arbv1.AppWrapperResource) (*v1.PodTemplateSpec, int32, error)

GetPodTemplate Parse queue job api object to get Pod template

func (*QueueJobResStatefulSet) Run

func (qjrStatefulSet *QueueJobResStatefulSet) Run(stopCh <-chan struct{})

Run the main goroutine responsible for watching and services.

func (*QueueJobResStatefulSet) SyncQueueJob

func (qjrStatefulSet *QueueJobResStatefulSet) SyncQueueJob(queuejob *arbv1.AppWrapper, qjobRes *arbv1.AppWrapperResource) error

func (*QueueJobResStatefulSet) UpdateQueueJobStatus

func (qjrStatefulSet *QueueJobResStatefulSet) UpdateQueueJobStatus(queuejob *arbv1.AppWrapper) error