Documentation

Index

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 NewQueueJobResNetworkPolicy

func NewQueueJobResNetworkPolicy(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 QueueJobResNetworkPolicy

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

        QueueJobResService contains service info

        func (*QueueJobResNetworkPolicy) Cleanup

        func (qjrNetworkPolicy *QueueJobResNetworkPolicy) Cleanup(queuejob *arbv1.AppWrapper, qjobRes *arbv1.AppWrapperResource) error

          Cleanup deletes all services

          func (*QueueJobResNetworkPolicy) GetAggregatedResources

          func (qjrNetworkPolicy *QueueJobResNetworkPolicy) GetAggregatedResources(job *arbv1.AppWrapper) *clusterstateapi.Resource

          func (*QueueJobResNetworkPolicy) GetAggregatedResourcesByPriority

          func (qjrNetworkPolicy *QueueJobResNetworkPolicy) GetAggregatedResourcesByPriority(priority float64, job *arbv1.AppWrapper) *clusterstateapi.Resource

          func (*QueueJobResNetworkPolicy) Run

          func (qjrNetworkPolicy *QueueJobResNetworkPolicy) Run(stopCh <-chan struct{})

            Run the main goroutine responsible for watching and services.

            func (*QueueJobResNetworkPolicy) SyncQueueJob

            func (qjrNetworkPolicy *QueueJobResNetworkPolicy) SyncQueueJob(queuejob *arbv1.AppWrapper, qjobRes *arbv1.AppWrapperResource) error

            func (*QueueJobResNetworkPolicy) UpdateQueueJobStatus

            func (qjrNetworkPolicy *QueueJobResNetworkPolicy) UpdateQueueJobStatus(queuejob *arbv1.AppWrapper) error

            Source Files