Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

v1alpha7

package

Go to main page

Versions in this module

v0

v0.1.19

May 7, 2026

Changes in this version

type PersistentStorageInstance

+ func (r *PersistentStorageInstance) ValidateCreate() (admission.Warnings, error)

+ func (r *PersistentStorageInstance) ValidateDelete() (admission.Warnings, error)

+ func (r *PersistentStorageInstance) ValidateUpdate(old runtime.Object) (admission.Warnings, error)

v0.1.18

Apr 9, 2026

v0.1.17

Mar 12, 2026

v0.1.16

Feb 20, 2026

v0.1.15

Dec 10, 2025

Changes in this version

+ const DirectiveLifetimeJob

+ const DirectiveLifetimePersistent

+ const OwnerKindLabel

+ const OwnerNameLabel

+ const OwnerNamespaceLabel

+ const OwnerUidLabel

+ const PersistentStorageNameLabel

+ const PersistentStorageNamespaceLabel

+ const StatusCompleted

+ const StatusDriverWait

+ const StatusError

+ const StatusPending

+ const StatusQueued

+ const StatusRunning

+ const StatusTransientCondition

+ const StorageLifetimeJob

+ const StorageLifetimePersistent

+ const StorageTypeLabel

+ const WorkflowNameLabel

+ const WorkflowNamespaceLabel

+ const WorkflowUidLabel

+ var AddToScheme = SchemeBuilder.AddToScheme

+ var GroupVersion = schema.GroupVersion

+ var SchemeBuilder = &scheme.Builder

+ func AddOwnerLabels(child metav1.Object, owner metav1.Object)

+ func AddPersistentStorageLabels(child metav1.Object, persistentStorage *PersistentStorageInstance)

+ func AddWorkflowLabels(child metav1.Object, workflow *Workflow)

+ func InheritParentLabels(child metav1.Object, owner metav1.Object)

+ func MatchingOwner(owner metav1.Object) client.MatchingLabels

+ func MatchingPersistentStorage(persistentStorage *PersistentStorageInstance) client.MatchingLabels

+ func MatchingWorkflow(workflow *Workflow) client.MatchingLabels

+ func OwnerLabelMapFunc(ctx context.Context, o client.Object) []reconcile.Request

+ func RemoveOwnerLabels(child metav1.Object)

+ func SeverityStringToStatus(severity string) (string, error)

+ type AllocationSetColocationConstraint struct

+ Key string

+ Type string

+ func (in *AllocationSetColocationConstraint) DeepCopy() *AllocationSetColocationConstraint

+ func (in *AllocationSetColocationConstraint) DeepCopyInto(out *AllocationSetColocationConstraint)

+ type AllocationSetConstraints struct

+ Colocation []AllocationSetColocationConstraint

+ Count int

+ Labels []string

+ Scale int

+ func (in *AllocationSetConstraints) DeepCopy() *AllocationSetConstraints

+ func (in *AllocationSetConstraints) DeepCopyInto(out *AllocationSetConstraints)

+ type AllocationStrategy string

+ const AllocateAcrossServers

+ const AllocatePerCompute

+ const AllocatePerServer

+ const AllocateSingleServer

+ type ClientMount struct

+ Spec ClientMountSpec

+ Status ClientMountStatus

+ func (*ClientMount) Hub()

+ func (c *ClientMount) GetStatus() updater.Status[*ClientMountStatus]

+ func (in *ClientMount) DeepCopy() *ClientMount

+ func (in *ClientMount) DeepCopyInto(out *ClientMount)

+ func (in *ClientMount) DeepCopyObject() runtime.Object

+ func (r *ClientMount) SetupWebhookWithManager(mgr ctrl.Manager) error

+ type ClientMountDevice struct

+ DeviceReference *ClientMountDeviceReference

+ LVM *ClientMountDeviceLVM

+ Lustre *ClientMountDeviceLustre

+ Type ClientMountDeviceType

+ func (in *ClientMountDevice) DeepCopy() *ClientMountDevice

+ func (in *ClientMountDevice) DeepCopyInto(out *ClientMountDevice)

+ type ClientMountDeviceLVM struct

+ DeviceType ClientMountLVMDeviceType

+ LogicalVolume string

+ NVMeInfo []ClientMountNVMeDesc

+ VolumeGroup string

+ func (in *ClientMountDeviceLVM) DeepCopy() *ClientMountDeviceLVM

+ func (in *ClientMountDeviceLVM) DeepCopyInto(out *ClientMountDeviceLVM)

+ type ClientMountDeviceLustre struct

+ FileSystemName string

+ MgsAddresses string

+ func (in *ClientMountDeviceLustre) DeepCopy() *ClientMountDeviceLustre

+ func (in *ClientMountDeviceLustre) DeepCopyInto(out *ClientMountDeviceLustre)

+ type ClientMountDeviceReference struct

+ Data int

+ ObjectReference corev1.ObjectReference

+ func (in *ClientMountDeviceReference) DeepCopy() *ClientMountDeviceReference

+ func (in *ClientMountDeviceReference) DeepCopyInto(out *ClientMountDeviceReference)

+ type ClientMountDeviceType string

+ const ClientMountDeviceTypeLVM

+ const ClientMountDeviceTypeLustre

+ const ClientMountDeviceTypeReference

+ type ClientMountInfo struct

+ Compute string

+ Device ClientMountDevice

+ GroupID uint32

+ MountPath string

+ Options string

+ SetPermissions bool

+ TargetType string

+ Type string

+ UserID uint32

+ func (in *ClientMountInfo) DeepCopy() *ClientMountInfo

+ func (in *ClientMountInfo) DeepCopyInto(out *ClientMountInfo)

+ type ClientMountInfoStatus struct

+ Ready bool

+ State ClientMountState

+ func (in *ClientMountInfoStatus) DeepCopy() *ClientMountInfoStatus

+ func (in *ClientMountInfoStatus) DeepCopyInto(out *ClientMountInfoStatus)

+ type ClientMountLVMDeviceType string

+ const ClientMountLVMDeviceTypeNVMe

+ type ClientMountList struct

+ Items []ClientMount

+ func (*ClientMountList) Hub()

+ func (c *ClientMountList) GetObjectList() []client.Object

+ func (in *ClientMountList) DeepCopy() *ClientMountList

+ func (in *ClientMountList) DeepCopyInto(out *ClientMountList)

+ func (in *ClientMountList) DeepCopyObject() runtime.Object

+ type ClientMountNVMeDesc struct

+ DeviceSerial string

+ NamespaceGUID string

+ NamespaceID string

+ func (in *ClientMountNVMeDesc) DeepCopy() *ClientMountNVMeDesc

+ func (in *ClientMountNVMeDesc) DeepCopyInto(out *ClientMountNVMeDesc)

+ type ClientMountSpec struct

+ DesiredState ClientMountState

+ Mounts []ClientMountInfo

+ Node string

+ func (in *ClientMountSpec) DeepCopy() *ClientMountSpec

+ func (in *ClientMountSpec) DeepCopyInto(out *ClientMountSpec)

+ type ClientMountState string

+ const ClientMountStateMounted

+ const ClientMountStateUnmounted

+ type ClientMountStatus struct

+ AllReady bool

+ Mounts []ClientMountInfoStatus

+ func (in *ClientMountStatus) DeepCopy() *ClientMountStatus

+ func (in *ClientMountStatus) DeepCopyInto(out *ClientMountStatus)

+ type ComputeBreakdown struct

+ Constraints ComputeConstraints

+ func (in *ComputeBreakdown) DeepCopy() *ComputeBreakdown

+ func (in *ComputeBreakdown) DeepCopyInto(out *ComputeBreakdown)

+ type ComputeConstraints struct

+ Location []ComputeLocationConstraint

+ func (in *ComputeConstraints) DeepCopy() *ComputeConstraints

+ func (in *ComputeConstraints) DeepCopyInto(out *ComputeConstraints)

+ type ComputeLocationAccess struct

+ Priority ComputeLocationPriority

+ Type ComputeLocationType

+ func (in *ComputeLocationAccess) DeepCopy() *ComputeLocationAccess

+ func (in *ComputeLocationAccess) DeepCopyInto(out *ComputeLocationAccess)

+ type ComputeLocationConstraint struct

+ Access []ComputeLocationAccess

+ Reference corev1.ObjectReference

+ func (in *ComputeLocationConstraint) DeepCopy() *ComputeLocationConstraint

+ func (in *ComputeLocationConstraint) DeepCopyInto(out *ComputeLocationConstraint)

+ type ComputeLocationPriority string

+ const ComputeLocationPriorityBestEffort

+ const ComputeLocationPriorityMandatory

+ type ComputeLocationType string

+ const ComputeLocationNetwork

+ const ComputeLocationPhysical

+ type Computes struct

+ Data []ComputesData

+ func (*Computes) Hub()

+ func (in *Computes) DeepCopy() *Computes

+ func (in *Computes) DeepCopyInto(out *Computes)

+ func (in *Computes) DeepCopyObject() runtime.Object

+ func (r *Computes) SetupWebhookWithManager(mgr ctrl.Manager) error

+ type ComputesData struct

+ Name string

+ func (in *ComputesData) DeepCopy() *ComputesData

+ func (in *ComputesData) DeepCopyInto(out *ComputesData)

+ type ComputesList struct

+ Items []Computes

+ func (*ComputesList) Hub()

+ func (c *ComputesList) GetObjectList() []client.Object

+ func (in *ComputesList) DeepCopy() *ComputesList

+ func (in *ComputesList) DeepCopyInto(out *ComputesList)

+ func (in *ComputesList) DeepCopyObject() runtime.Object

+ type DWDirectiveRule struct

+ Spec []dwdparse.DWDirectiveRuleSpec

+ func (*DWDirectiveRule) Hub()

+ func (in *DWDirectiveRule) DeepCopy() *DWDirectiveRule

+ func (in *DWDirectiveRule) DeepCopyInto(out *DWDirectiveRule)

+ func (in *DWDirectiveRule) DeepCopyObject() runtime.Object

+ func (r *DWDirectiveRule) SetupWebhookWithManager(mgr ctrl.Manager) error

+ type DWDirectiveRuleList struct

+ Items []DWDirectiveRule

+ func (*DWDirectiveRuleList) Hub()

+ func (in *DWDirectiveRuleList) DeepCopy() *DWDirectiveRuleList

+ func (in *DWDirectiveRuleList) DeepCopyInto(out *DWDirectiveRuleList)

+ func (in *DWDirectiveRuleList) DeepCopyObject() runtime.Object

+ type DeleteStatus struct

+ func DeleteChildren(ctx context.Context, c client.Client, childObjectLists []ObjectList, ...) (DeleteStatus, error)

+ func DeleteChildrenParallel(ctx context.Context, c client.Client, childObjectLists []ObjectList, ...) (DeleteStatus, error)

+ func DeleteChildrenWithLabels(ctx context.Context, c client.Client, childObjectLists []ObjectList, ...) (DeleteStatus, error)

+ func DeleteChildrenWithLabelsParallel(ctx context.Context, c client.Client, childObjectLists []ObjectList, ...) (DeleteStatus, error)

+ func (d *DeleteStatus) Complete() bool

+ func (d *DeleteStatus) Info() []interface{}

+ type DirectiveBreakdown struct

+ Spec DirectiveBreakdownSpec

+ Status DirectiveBreakdownStatus

+ func (*DirectiveBreakdown) Hub()

+ func (db *DirectiveBreakdown) GetStatus() updater.Status[*DirectiveBreakdownStatus]

+ func (in *DirectiveBreakdown) DeepCopy() *DirectiveBreakdown

+ func (in *DirectiveBreakdown) DeepCopyInto(out *DirectiveBreakdown)

+ func (in *DirectiveBreakdown) DeepCopyObject() runtime.Object

+ func (r *DirectiveBreakdown) SetupWebhookWithManager(mgr ctrl.Manager) error

+ type DirectiveBreakdownList struct

+ Items []DirectiveBreakdown

+ func (*DirectiveBreakdownList) Hub()

+ func (d *DirectiveBreakdownList) GetObjectList() []client.Object

+ func (in *DirectiveBreakdownList) DeepCopy() *DirectiveBreakdownList

+ func (in *DirectiveBreakdownList) DeepCopyInto(out *DirectiveBreakdownList)

+ func (in *DirectiveBreakdownList) DeepCopyObject() runtime.Object

+ type DirectiveBreakdownSpec struct

+ Directive string

+ UserID uint32

+ func (in *DirectiveBreakdownSpec) DeepCopy() *DirectiveBreakdownSpec

+ func (in *DirectiveBreakdownSpec) DeepCopyInto(out *DirectiveBreakdownSpec)

+ type DirectiveBreakdownStatus struct

+ Compute *ComputeBreakdown

+ Ready bool

+ Requires []string

+ Storage *StorageBreakdown

+ func (in *DirectiveBreakdownStatus) DeepCopy() *DirectiveBreakdownStatus

+ func (in *DirectiveBreakdownStatus) DeepCopyInto(out *DirectiveBreakdownStatus)

+ type MutatingRuleParser struct

+ func (r *MutatingRuleParser) MatchedDirective(workflow *Workflow, watchStates string, index int, label string)

+ type Node struct

+ Name string

+ Status ResourceStatus

+ func (in *Node) DeepCopy() *Node

+ func (in *Node) DeepCopyInto(out *Node)

+ type ObjectList interface

+ GetObjectList func() []client.Object

+ type PersistentStorageInstance struct

+ Spec PersistentStorageInstanceSpec

+ Status PersistentStorageInstanceStatus

+ func (*PersistentStorageInstance) Hub()

+ func (in *PersistentStorageInstance) DeepCopy() *PersistentStorageInstance

+ func (in *PersistentStorageInstance) DeepCopyInto(out *PersistentStorageInstance)

+ func (in *PersistentStorageInstance) DeepCopyObject() runtime.Object

+ func (psi *PersistentStorageInstance) GetStatus() updater.Status[*PersistentStorageInstanceStatus]

+ func (psi *PersistentStorageInstance) IsUsable() bool

+ func (r *PersistentStorageInstance) SetupWebhookWithManager(mgr ctrl.Manager) error

+ type PersistentStorageInstanceList struct

+ Items []PersistentStorageInstance

+ func (*PersistentStorageInstanceList) Hub()

+ func (in *PersistentStorageInstanceList) DeepCopy() *PersistentStorageInstanceList

+ func (in *PersistentStorageInstanceList) DeepCopyInto(out *PersistentStorageInstanceList)

+ func (in *PersistentStorageInstanceList) DeepCopyObject() runtime.Object

+ func (p *PersistentStorageInstanceList) GetObjectList() []client.Object

+ type PersistentStorageInstanceSpec struct

+ ConsumerReferences []corev1.ObjectReference

+ DWDirective string

+ FsType string

+ Name string

+ State PersistentStorageInstanceState

+ UserID uint32

+ func (in *PersistentStorageInstanceSpec) DeepCopy() *PersistentStorageInstanceSpec

+ func (in *PersistentStorageInstanceSpec) DeepCopyInto(out *PersistentStorageInstanceSpec)

+ type PersistentStorageInstanceState string

+ const PSIStateActive

+ const PSIStateCreating

+ const PSIStateDegraded

+ const PSIStateDestroying

+ type PersistentStorageInstanceStatus struct

+ Servers corev1.ObjectReference

+ State PersistentStorageInstanceState

+ func (in *PersistentStorageInstanceStatus) DeepCopy() *PersistentStorageInstanceStatus

+ func (in *PersistentStorageInstanceStatus) DeepCopyInto(out *PersistentStorageInstanceStatus)

+ type ResourceError struct

+ Error *ResourceErrorInfo

+ func (e *ResourceError) SetResourceError(err error)

+ func (e *ResourceError) SetResourceErrorAndLog(err error, log logr.Logger)

+ func (in *ResourceError) DeepCopy() *ResourceError

+ func (in *ResourceError) DeepCopyInto(out *ResourceError)

+ type ResourceErrorInfo struct

+ DebugMessage string

+ Severity ResourceErrorSeverity

+ Type ResourceErrorType

+ UserMessage string

+ func NewResourceError(format string, a ...any) *ResourceErrorInfo

+ func (e *ResourceErrorInfo) Error() string

+ func (e *ResourceErrorInfo) GetUserMessage() string

+ func (e *ResourceErrorInfo) WithError(err error) *ResourceErrorInfo

+ func (e *ResourceErrorInfo) WithFatal() *ResourceErrorInfo

+ func (e *ResourceErrorInfo) WithInternal() *ResourceErrorInfo

+ func (e *ResourceErrorInfo) WithMajor() *ResourceErrorInfo

+ func (e *ResourceErrorInfo) WithMinor() *ResourceErrorInfo

+ func (e *ResourceErrorInfo) WithUser() *ResourceErrorInfo

+ func (e *ResourceErrorInfo) WithUserMessage(format string, a ...any) *ResourceErrorInfo

+ func (e *ResourceErrorInfo) WithWLM() *ResourceErrorInfo

+ func (in *ResourceErrorInfo) DeepCopy() *ResourceErrorInfo

+ func (in *ResourceErrorInfo) DeepCopyInto(out *ResourceErrorInfo)

+ type ResourceErrorSeverity string

+ const SeverityFatal

+ const SeverityMajor

+ const SeverityMinor

+ func (severity ResourceErrorSeverity) ToStatus() (string, error)

+ type ResourceErrorType string

+ const TypeInternal

+ const TypeUser

+ const TypeWLM

+ type ResourceState string

+ const DisabledState

+ const EnabledState

+ type ResourceStatus string

+ const DegradedStatus

+ const DisabledStatus

+ const DrainedStatus

+ const FailedStatus

+ const FencedStatus

+ const NotPresentStatus

+ const OfflineStatus

+ const ReadyStatus

+ const StartingStatus

+ const UnknownStatus

+ type RuleList struct

+ func (r *RuleList) GetRuleList() []dwdparse.DWDirectiveRuleSpec

+ func (r *RuleList) ReadRules() error

+ type RuleParser interface

+ GetRuleList func() []dwdparse.DWDirectiveRuleSpec

+ MatchedDirective func(*Workflow, string, int, string)

+ ReadRules func() error

+ type Servers struct

+ Spec ServersSpec

+ Status ServersStatus

+ func (*Servers) Hub()

+ func (in *Servers) DeepCopy() *Servers

+ func (in *Servers) DeepCopyInto(out *Servers)

+ func (in *Servers) DeepCopyObject() runtime.Object

+ func (r *Servers) SetupWebhookWithManager(mgr ctrl.Manager) error

+ func (s *Servers) GetStatus() updater.Status[*ServersStatus]

+ type ServersList struct

+ Items []Servers

+ func (*ServersList) Hub()

+ func (in *ServersList) DeepCopy() *ServersList

+ func (in *ServersList) DeepCopyInto(out *ServersList)

+ func (in *ServersList) DeepCopyObject() runtime.Object

+ func (s *ServersList) GetObjectList() []client.Object

+ type ServersSpec struct

+ AllocationSets []ServersSpecAllocationSet

+ func (in *ServersSpec) DeepCopy() *ServersSpec

+ func (in *ServersSpec) DeepCopyInto(out *ServersSpec)

+ type ServersSpecAllocationSet struct

+ AllocationSize int64

+ Label string

+ Storage []ServersSpecStorage

+ func (in *ServersSpecAllocationSet) DeepCopy() *ServersSpecAllocationSet

+ func (in *ServersSpecAllocationSet) DeepCopyInto(out *ServersSpecAllocationSet)

+ type ServersSpecStorage struct

+ AllocationCount int

+ Name string

+ func (in *ServersSpecStorage) DeepCopy() *ServersSpecStorage

+ func (in *ServersSpecStorage) DeepCopyInto(out *ServersSpecStorage)

+ type ServersStatus struct

+ AllocationSets []ServersStatusAllocationSet

+ LastUpdate *metav1.MicroTime

+ Ready bool

+ func (in *ServersStatus) DeepCopy() *ServersStatus

+ func (in *ServersStatus) DeepCopyInto(out *ServersStatus)

+ type ServersStatusAllocationSet struct

+ Label string

+ Storage map[string]ServersStatusStorage

+ func (in *ServersStatusAllocationSet) DeepCopy() *ServersStatusAllocationSet

+ func (in *ServersStatusAllocationSet) DeepCopyInto(out *ServersStatusAllocationSet)

+ type ServersStatusStorage struct

+ AllocationSize int64

+ Ready bool

+ func (in *ServersStatusStorage) DeepCopy() *ServersStatusStorage

+ func (in *ServersStatusStorage) DeepCopyInto(out *ServersStatusStorage)

+ type Storage struct

+ Spec StorageSpec

+ Status StorageStatus

+ func (*Storage) Hub()

+ func (in *Storage) DeepCopy() *Storage

+ func (in *Storage) DeepCopyInto(out *Storage)

+ func (in *Storage) DeepCopyObject() runtime.Object

+ func (r *Storage) SetupWebhookWithManager(mgr ctrl.Manager) error

+ func (s *Storage) GetStatus() updater.Status[*StorageStatus]

+ type StorageAccess struct

+ Computes []Node

+ Protocol StorageAccessProtocol

+ Servers []Node

+ func (in *StorageAccess) DeepCopy() *StorageAccess

+ func (in *StorageAccess) DeepCopyInto(out *StorageAccess)

+ type StorageAccessProtocol string

+ const PCIe

+ type StorageAllocationSet struct

+ AllocationStrategy AllocationStrategy

+ Constraints AllocationSetConstraints

+ Label string

+ MinimumCapacity int64

+ func (in *StorageAllocationSet) DeepCopy() *StorageAllocationSet

+ func (in *StorageAllocationSet) DeepCopyInto(out *StorageAllocationSet)

+ type StorageBreakdown struct

+ AllocationSets []StorageAllocationSet

+ Lifetime string

+ Reference corev1.ObjectReference

+ func (in *StorageBreakdown) DeepCopy() *StorageBreakdown

+ func (in *StorageBreakdown) DeepCopyInto(out *StorageBreakdown)

+ type StorageDevice struct

+ Capacity int64

+ FirmwareVersion string

+ Model string

+ SerialNumber string

+ Slot string

+ Status ResourceStatus

+ WearLevel *int64

+ func (in *StorageDevice) DeepCopy() *StorageDevice

+ func (in *StorageDevice) DeepCopyInto(out *StorageDevice)

+ type StorageList struct

+ Items []Storage

+ func (*StorageList) Hub()

+ func (in *StorageList) DeepCopy() *StorageList

+ func (in *StorageList) DeepCopyInto(out *StorageList)

+ func (in *StorageList) DeepCopyObject() runtime.Object

+ func (s *StorageList) GetObjectList() []client.Object

+ type StorageSpec struct

+ Mode string

+ State ResourceState

+ func (in *StorageSpec) DeepCopy() *StorageSpec

+ func (in *StorageSpec) DeepCopyInto(out *StorageSpec)

+ type StorageStatus struct

+ Access StorageAccess

+ Capacity int64

+ Devices []StorageDevice

+ Message string

+ RebootRequired bool

+ Status ResourceStatus

+ Type StorageType

+ func (in *StorageStatus) DeepCopy() *StorageStatus

+ func (in *StorageStatus) DeepCopyInto(out *StorageStatus)

+ type StorageType string

+ const NVMe

+ type SystemConfiguration struct

+ Spec SystemConfigurationSpec

+ Status SystemConfigurationStatus

+ func (*SystemConfiguration) Hub()

+ func (in *SystemConfiguration) Computes() []*string

+ func (in *SystemConfiguration) ComputesExternal() []*string

+ func (in *SystemConfiguration) DeepCopy() *SystemConfiguration

+ func (in *SystemConfiguration) DeepCopyInto(out *SystemConfiguration)

+ func (in *SystemConfiguration) DeepCopyObject() runtime.Object

+ func (r *SystemConfiguration) SetupWebhookWithManager(mgr ctrl.Manager) error

+ func (s *SystemConfiguration) GetStatus() updater.Status[*SystemConfigurationStatus]

+ type SystemConfigurationComputeNodeReference struct

+ Index int

+ Name string

+ func (in *SystemConfigurationComputeNodeReference) DeepCopy() *SystemConfigurationComputeNodeReference

+ func (in *SystemConfigurationComputeNodeReference) DeepCopyInto(out *SystemConfigurationComputeNodeReference)

+ type SystemConfigurationExternalComputeNode struct

+ Name string

+ func (in *SystemConfigurationExternalComputeNode) DeepCopy() *SystemConfigurationExternalComputeNode

+ func (in *SystemConfigurationExternalComputeNode) DeepCopyInto(out *SystemConfigurationExternalComputeNode)

+ type SystemConfigurationList struct

+ Items []SystemConfiguration

+ func (*SystemConfigurationList) Hub()

+ func (in *SystemConfigurationList) DeepCopy() *SystemConfigurationList

+ func (in *SystemConfigurationList) DeepCopyInto(out *SystemConfigurationList)

+ func (in *SystemConfigurationList) DeepCopyObject() runtime.Object

+ type SystemConfigurationSpec struct

+ ExternalComputeNodes []SystemConfigurationExternalComputeNode

+ Ports []intstr.IntOrString

+ PortsCooldownInSeconds int

+ StorageNodes []SystemConfigurationStorageNode

+ func (in *SystemConfigurationSpec) DeepCopy() *SystemConfigurationSpec

+ func (in *SystemConfigurationSpec) DeepCopyInto(out *SystemConfigurationSpec)

+ type SystemConfigurationStatus struct

+ Ready bool

+ func (in *SystemConfigurationStatus) DeepCopy() *SystemConfigurationStatus

+ func (in *SystemConfigurationStatus) DeepCopyInto(out *SystemConfigurationStatus)

+ type SystemConfigurationStorageNode struct

+ ComputesAccess []SystemConfigurationComputeNodeReference

+ Name string

+ Type string

+ func (in *SystemConfigurationStorageNode) DeepCopy() *SystemConfigurationStorageNode

+ func (in *SystemConfigurationStorageNode) DeepCopyInto(out *SystemConfigurationStorageNode)

+ type SystemNodeStatus string

+ const SystemNodeStatusDisabled

+ const SystemNodeStatusEnabled

+ type SystemStatus struct

+ Data SystemStatusData

+ func (*SystemStatus) Hub()

+ func (in *SystemStatus) DeepCopy() *SystemStatus

+ func (in *SystemStatus) DeepCopyInto(out *SystemStatus)

+ func (in *SystemStatus) DeepCopyObject() runtime.Object

+ func (r *SystemStatus) SetupWebhookWithManager(mgr ctrl.Manager) error

+ type SystemStatusData struct

+ Nodes map[string]SystemNodeStatus

+ func (in *SystemStatusData) DeepCopy() *SystemStatusData

+ func (in *SystemStatusData) DeepCopyInto(out *SystemStatusData)

+ type SystemStatusList struct

+ Items []SystemStatus

+ func (*SystemStatusList) Hub()

+ func (in *SystemStatusList) DeepCopy() *SystemStatusList

+ func (in *SystemStatusList) DeepCopyInto(out *SystemStatusList)

+ func (in *SystemStatusList) DeepCopyObject() runtime.Object

+ type ValidatingRuleParser struct

+ func (r *ValidatingRuleParser) MatchedDirective(workflow *Workflow, watchStates string, index int, label string)

+ type Workflow struct

+ Spec WorkflowSpec

+ Status WorkflowStatus

+ func (*Workflow) Hub()

+ func (c *Workflow) GetStatus() updater.Status[*WorkflowStatus]

+ func (in *Workflow) DeepCopy() *Workflow

+ func (in *Workflow) DeepCopyInto(out *Workflow)

+ func (in *Workflow) DeepCopyObject() runtime.Object

+ func (w *Workflow) Default()

+ func (w *Workflow) SetupWebhookWithManager(mgr ctrl.Manager) error

+ func (w *Workflow) ValidateCreate() (admission.Warnings, error)

+ func (w *Workflow) ValidateDelete() (admission.Warnings, error)

+ func (w *Workflow) ValidateUpdate(old runtime.Object) (admission.Warnings, error)

+ type WorkflowDriverStatus struct

+ CompleteTime *metav1.MicroTime

+ Completed bool

+ DWDIndex int

+ DriverID string

+ Error string

+ LastHB int64

+ Message string

+ Status string

+ TaskID string

+ WatchState WorkflowState

+ func (in *WorkflowDriverStatus) DeepCopy() *WorkflowDriverStatus

+ func (in *WorkflowDriverStatus) DeepCopyInto(out *WorkflowDriverStatus)

+ type WorkflowList struct

+ Items []Workflow

+ func (*WorkflowList) Hub()

+ func (in *WorkflowList) DeepCopy() *WorkflowList

+ func (in *WorkflowList) DeepCopyInto(out *WorkflowList)

+ func (in *WorkflowList) DeepCopyObject() runtime.Object

+ type WorkflowSpec struct

+ DWDirectives []string

+ DesiredState WorkflowState

+ ForceReady bool

+ GroupID uint32

+ Hurry bool

+ JobID intstr.IntOrString

+ UserID uint32

+ WLMID string

+ func (in *WorkflowSpec) DeepCopy() *WorkflowSpec

+ func (in *WorkflowSpec) DeepCopyInto(out *WorkflowSpec)

+ type WorkflowState string

+ const StateDataIn

+ const StateDataOut

+ const StatePostRun

+ const StatePreRun

+ const StateProposal

+ const StateSetup

+ const StateTeardown

+ type WorkflowStatus struct

+ Computes corev1.ObjectReference

+ DesiredStateChange *metav1.MicroTime

+ DirectiveBreakdowns []corev1.ObjectReference

+ Drivers []WorkflowDriverStatus

+ ElapsedTimeLastState string

+ Env map[string]string

+ Message string

+ Ready bool

+ ReadyChange *metav1.MicroTime

+ Requires []string

+ State WorkflowState

+ Status string

+ WorkflowToken *WorkflowTokenSecret

+ func (in *WorkflowStatus) DeepCopy() *WorkflowStatus

+ func (in *WorkflowStatus) DeepCopyInto(out *WorkflowStatus)

+ type WorkflowTokenSecret struct

+ SecretName string

+ SecretNamespace string

+ func (in *WorkflowTokenSecret) DeepCopy() *WorkflowTokenSecret

+ func (in *WorkflowTokenSecret) DeepCopyInto(out *WorkflowTokenSecret)