networkpolicy

Documentation

Index

• Constants
• func NewQueueJobResNetworkPolicy(config *rest.Config) queuejobresources.Interface
• func Register(regs *queuejobresources.RegisteredResources)
• type QueueJobResNetworkPolicy
  • func (qjrNetworkPolicy *QueueJobResNetworkPolicy) Cleanup(queuejob *arbv1.AppWrapper, qjobRes *arbv1.AppWrapperResource) error
  • func (qjrNetworkPolicy *QueueJobResNetworkPolicy) GetAggregatedResources(job *arbv1.AppWrapper) *clusterstateapi.Resource
  • func (qjrNetworkPolicy *QueueJobResNetworkPolicy) GetAggregatedResourcesByPriority(priority float64, job *arbv1.AppWrapper) *clusterstateapi.Resource
  • func (qjrNetworkPolicy *QueueJobResNetworkPolicy) Run(stopCh <-chan struct{})
  • func (qjrNetworkPolicy *QueueJobResNetworkPolicy) SyncQueueJob(queuejob *arbv1.AppWrapper, qjobRes *arbv1.AppWrapperResource) error
  • func (qjrNetworkPolicy *QueueJobResNetworkPolicy) 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 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