Versions in this module Expand all Collapse all v0 v0.1.14 Aug 29, 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 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 (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 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)
Go to main page