v1alpha1

package

Go to main page

Versions in this module

v0

v0.1.2

Dec 15, 2023

v0.1.1

Dec 14, 2023

v0.1.0

Dec 8, 2023

v0.0.2

Nov 28, 2023

Changes in this version

type Arguments

+ func (in *Arguments) DeepCopy() *Arguments

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

type Artifact

+ func (in *Artifact) DeepCopy() *Artifact

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

type ArtifactLocation

+ func (in *ArtifactLocation) DeepCopy() *ArtifactLocation

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

type ArtifactoryArtifact

+ func (in *ArtifactoryArtifact) DeepCopy() *ArtifactoryArtifact

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

type ArtifactoryAuth

+ func (in *ArtifactoryAuth) DeepCopy() *ArtifactoryAuth

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

type GitArtifact

+ func (in *GitArtifact) DeepCopy() *GitArtifact

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

type HTTPArtifact

+ func (in *HTTPArtifact) DeepCopy() *HTTPArtifact

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

type Inputs

+ func (in *Inputs) DeepCopy() *Inputs

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

type Item

+ func (in *Item) DeepCopy() *Item

type ItemValue

+ func (in *ItemValue) DeepCopy() *ItemValue

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

type NodeStatus

+ RetryStrategy *RetryStrategy

+ func (in *NodeStatus) DeepCopy() *NodeStatus

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

+ func (n NodeStatus) String() string

type Outputs

+ func (in *Outputs) DeepCopy() *Outputs

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

type Parameter

+ func (in *Parameter) DeepCopy() *Parameter

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

type RawArtifact

+ func (in *RawArtifact) DeepCopy() *RawArtifact

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

type ResourceTemplate

+ func (in *ResourceTemplate) DeepCopy() *ResourceTemplate

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

type RetryStrategy

+ func (in *RetryStrategy) DeepCopy() *RetryStrategy

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

type S3Artifact

+ func (in *S3Artifact) DeepCopy() *S3Artifact

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

type S3Bucket

+ func (in *S3Bucket) DeepCopy() *S3Bucket

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

+ type Script struct

+ Command []string

+ Image string

+ Source string

+ func (in *Script) DeepCopy() *Script

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

+ type Sidecar struct

+ func (in *Sidecar) DeepCopy() *Sidecar

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

+ type SidecarOptions struct

+ MirrorVolumeMounts *bool

+ func (in *SidecarOptions) DeepCopy() *SidecarOptions

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

type Template

+ func (in *Template) DeepCopy() *Template

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

type ValueFrom

+ func (in *ValueFrom) DeepCopy() *ValueFrom

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

type Workflow

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

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

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

+ func (wf *Workflow) GetTemplate(name string) *Template

type WorkflowList

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

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

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

type WorkflowSpec

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

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

type WorkflowStatus

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

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

+ func (wfs *WorkflowStatus) GetNodesWithRetries() []NodeStatus

type WorkflowStep

+ func (in *WorkflowStep) DeepCopy() *WorkflowStep

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

v0.0.1

Nov 11, 2023

Changes in this version

+ var AddToScheme = SchemeBuilder.AddToScheme

+ var SchemeBuilder = runtime.NewSchemeBuilder(addKnownTypes)

+ var SchemeGroupVersion = schema.GroupVersion

+ var WorkflowSchemaGroupVersionKind = schema.GroupVersionKind

+ func Kind(kind string) schema.GroupKind

+ func Resource(resource string) schema.GroupResource

+ type ArchiveStrategy struct

+ None *NoneStrategy

+ Tar *TarStrategy

+ type Arguments struct

+ Artifacts Artifacts

+ Parameters []Parameter

+ func (args *Arguments) GetArtifactByName(name string) *Artifact

+ func (args *Arguments) GetParameterByName(name string) *Parameter

+ type ArgumentsProvider interface

+ GetArtifactByName func(name string) *Artifact

+ GetParameterByName func(name string) *Parameter

+ type Artifact struct

+ Archive *ArchiveStrategy

+ From string

+ GlobalName string

+ Mode *int32

+ Name string

+ Optional bool

+ Path string

+ func (a *Artifact) HasLocation() bool

+ type ArtifactLocation struct

+ ArchiveLogs *bool

+ Artifactory *ArtifactoryArtifact

+ Git *GitArtifact

+ HDFS *HDFSArtifact

+ HTTP *HTTPArtifact

+ Raw *RawArtifact

+ S3 *S3Artifact

+ type ArtifactRepositoryRef struct

+ ConfigMap string

+ Key string

+ type ArtifactoryArtifact struct

+ URL string

+ func (a *ArtifactoryArtifact) HasLocation() bool

+ type ArtifactoryAuth struct

+ PasswordSecret *apiv1.SecretKeySelector

+ UsernameSecret *apiv1.SecretKeySelector

+ type Artifacts []Artifact

+ func (a Artifacts) GetArtifactByName(name string) *Artifact

+ type Backoff struct

+ Duration string

+ Factor int32

+ MaxDuration string

+ type ContinueOn struct

+ Error bool

+ Failed bool

+ type DAGTask struct

+ Arguments Arguments

+ ContinueOn *ContinueOn

+ Dependencies []string

+ Name string

+ OnExit string

+ Template string

+ TemplateRef *TemplateRef

+ When string

+ WithItems []Item

+ WithParam string

+ WithSequence *Sequence

+ func (t *DAGTask) ContinuesOn(phase NodePhase) bool

+ func (t *DAGTask) GetTemplateName() string

+ func (t *DAGTask) GetTemplateRef() *TemplateRef

+ func (t *DAGTask) IsResolvable() bool

+ type DAGTemplate struct

+ FailFast *bool

+ Target string

+ Tasks []DAGTask

+ type ExecutorConfig struct

+ ServiceAccountName string

+ type GitArtifact struct

+ Depth *uint64

+ Fetch []string

+ InsecureIgnoreHostKey bool

+ PasswordSecret *apiv1.SecretKeySelector

+ Repo string

+ Revision string

+ SSHPrivateKeySecret *apiv1.SecretKeySelector

+ UsernameSecret *apiv1.SecretKeySelector

+ func (g *GitArtifact) HasLocation() bool

+ type HDFSArtifact struct

+ Force bool

+ Path string

+ func (h *HDFSArtifact) HasLocation() bool

+ type HDFSConfig struct

+ Addresses []string

+ HDFSUser string

+ type HDFSKrbConfig struct

+ KrbCCacheSecret *apiv1.SecretKeySelector

+ KrbConfigConfigMap *apiv1.ConfigMapKeySelector

+ KrbKeytabSecret *apiv1.SecretKeySelector

+ KrbRealm string

+ KrbServicePrincipalName string

+ KrbUsername string

+ type HTTPArtifact struct

+ URL string

+ func (h *HTTPArtifact) HasLocation() bool

+ type Inputs struct

+ Artifacts Artifacts

+ Parameters []Parameter

+ func (in *Inputs) GetArtifactByName(name string) *Artifact

+ func (in *Inputs) GetParameterByName(name string) *Parameter

+ func (in *Inputs) HasInputs() bool

+ type Item struct

+ BoolVal bool

+ ListVal []ItemValue

+ MapVal map[string]ItemValue

+ NumVal json.Number

+ StrVal string

+ Type Type

+ func (i *Item) DeepCopyInto(out *Item)

+ func (i *Item) String() string

+ func (i *Item) UnmarshalJSON(value []byte) error

+ func (i Item) Format(s fmt.State, verb rune)

+ func (i Item) MarshalJSON() ([]byte, error)

+ func (i Item) OpenAPISchemaFormat() string

+ func (i Item) OpenAPISchemaType() []string

+ type ItemValue struct

+ BoolVal bool

+ ListVal []json.RawMessage

+ MapVal map[string]string

+ NumVal json.Number

+ StrVal string

+ Type Type

+ func (iv *ItemValue) String() string

+ func (iv *ItemValue) UnmarshalJSON(value []byte) error

+ func (iv ItemValue) Format(s fmt.State, verb rune)

+ func (iv ItemValue) MarshalJSON() ([]byte, error)

+ type Metadata struct

+ Annotations map[string]string

+ Labels map[string]string

+ type NodePhase string

+ const NodeError

+ const NodeFailed

+ const NodePending

+ const NodeRunning

+ const NodeSkipped

+ const NodeSucceeded

+ type NodeStatus struct

+ BoundaryID string

+ Children []string

+ Daemoned *bool

+ DisplayName string

+ FinishedAt metav1.Time

+ ID string

+ Inputs *Inputs

+ Message string

+ Name string

+ OutboundNodes []string

+ Outputs *Outputs

+ Phase NodePhase

+ PodIP string

+ StartedAt metav1.Time

+ StoredTemplateID string

+ TemplateName string

+ TemplateRef *TemplateRef

+ TemplateScope string

+ Type NodeType

+ WorkflowTemplateName string

+ func (n *NodeStatus) GetTemplateName() string

+ func (n *NodeStatus) GetTemplateRef() *TemplateRef

+ func (n *NodeStatus) IsActiveSuspendNode() bool

+ func (n *NodeStatus) IsResolvable() bool

+ func (n NodeStatus) CanRetry() bool

+ func (n NodeStatus) Completed() bool

+ func (n NodeStatus) IsDaemoned() bool

+ func (n NodeStatus) Successful() bool

+ type NodeType string

+ const NodeTypeDAG

+ const NodeTypePod

+ const NodeTypeRetry

+ const NodeTypeSkipped

+ const NodeTypeStepGroup

+ const NodeTypeSteps

+ const NodeTypeSuspend

+ const NodeTypeTaskGroup

+ type Nodes map[string]NodeStatus

+ func (in Nodes) Any(f func(node NodeStatus) bool) bool

+ func (n Nodes) FindByDisplayName(name string) *NodeStatus

+ type NoneStrategy struct

+ type Outputs struct

+ Artifacts Artifacts

+ Parameters []Parameter

+ Result *string

+ func (out *Outputs) GetArtifactByName(name string) *Artifact

+ func (out *Outputs) HasOutputs() bool

+ type ParallelSteps struct

+ Steps []WorkflowStep

+ func (p *ParallelSteps) MarshalJSON() ([]byte, error)

+ func (p *ParallelSteps) UnmarshalJSON(value []byte) error

+ type Parameter struct

+ Default *string

+ GlobalName string

+ Name string

+ Value *string

+ ValueFrom *ValueFrom

+ func (p *Parameter) UnmarshalJSON(value []byte) error

+ type PodGC struct

+ Strategy PodGCStrategy

+ type PodGCStrategy string

+ const PodGCOnPodCompletion

+ const PodGCOnPodSuccess

+ const PodGCOnWorkflowCompletion

+ const PodGCOnWorkflowSuccess

+ type RawArtifact struct

+ Data string

+ func (r *RawArtifact) HasLocation() bool

+ type ResourceTemplate struct

+ Action string

+ FailureCondition string

+ Manifest string

+ MergeStrategy string

+ SetOwnerReference bool

+ SuccessCondition string

+ type RetryPolicy string

+ const RetryPolicyAlways

+ const RetryPolicyOnError

+ const RetryPolicyOnFailure

+ type RetryStrategy struct

+ Backoff *Backoff

+ Limit *int32

+ RetryPolicy RetryPolicy

+ type S3Artifact struct

+ Key string

+ func (s *S3Artifact) HasLocation() bool

+ type S3Bucket struct

+ AccessKeySecret apiv1.SecretKeySelector

+ Bucket string

+ Endpoint string

+ Insecure *bool

+ Region string

+ RoleARN string

+ SecretKeySecret apiv1.SecretKeySelector

+ type ScriptTemplate struct

+ Source string

+ type Sequence struct

+ Count string

+ End string

+ Format string

+ Start string

+ type SuspendTemplate struct

+ Duration string

+ type TTLStrategy struct

+ SecondsAfterCompletion *int32

+ SecondsAfterFailure *int32

+ SecondsAfterSuccess *int32

+ type TarStrategy struct

+ type Template struct

+ ActiveDeadlineSeconds *int64

+ Affinity *apiv1.Affinity

+ ArchiveLocation *ArtifactLocation

+ AutomountServiceAccountToken *bool

+ Container *apiv1.Container

+ DAG *DAGTemplate

+ Daemon *bool

+ Executor *ExecutorConfig

+ HostAliases []apiv1.HostAlias

+ InitContainers []UserContainer

+ Inputs Inputs

+ Metadata Metadata

+ Name string

+ NodeSelector map[string]string

+ Outputs Outputs

+ Parallelism *int64

+ PodSpecPatch string

+ Priority *int32

+ PriorityClassName string

+ Resource *ResourceTemplate

+ RetryStrategy *RetryStrategy

+ SchedulerName string

+ Script *ScriptTemplate

+ SecurityContext *apiv1.PodSecurityContext

+ ServiceAccountName string

+ Sidecars []UserContainer

+ Steps []ParallelSteps

+ Suspend *SuspendTemplate

+ Template string

+ TemplateRef *TemplateRef

+ Tolerations []apiv1.Toleration

+ Volumes []apiv1.Volume

+ func (tmpl *Template) GetBaseTemplate() *Template

+ func (tmpl *Template) GetTemplateName() string

+ func (tmpl *Template) GetTemplateRef() *TemplateRef

+ func (tmpl *Template) GetType() TemplateType

+ func (tmpl *Template) HasPodSpecPatch() bool

+ func (tmpl *Template) IsLeaf() bool

+ func (tmpl *Template) IsPodType() bool

+ func (tmpl *Template) IsResolvable() bool

+ type TemplateGetter interface

+ GetName func() string

+ GetNamespace func() string

+ GetTemplateByName func(name string) *Template

+ GetTemplateScope func() string

+ GroupVersionKind func() schema.GroupVersionKind

+ type TemplateHolder interface

+ GetTemplateName func() string

+ GetTemplateRef func() *TemplateRef

+ IsResolvable func() bool

+ type TemplateRef struct

+ Name string

+ RuntimeResolution bool

+ Template string

+ type TemplateStorage interface

+ GetStoredTemplate func(templateScope string, holder TemplateHolder) *Template

+ SetStoredTemplate func(templateScope string, holder TemplateHolder, tmpl *Template) (bool, error)

+ type TemplateType string

+ const TemplateTypeContainer

+ const TemplateTypeDAG

+ const TemplateTypeResource

+ const TemplateTypeScript

+ const TemplateTypeSteps

+ const TemplateTypeSuspend

+ const TemplateTypeUnknown

+ type Type int

+ const Bool

+ const List

+ const Map

+ const Number

+ const String

+ type UserContainer struct

+ MirrorVolumeMounts *bool

+ type ValueFrom struct

+ JQFilter string

+ JSONPath string

+ Parameter string

+ Path string

+ type Workflow struct

+ Spec WorkflowSpec

+ Status WorkflowStatus

+ func (wf *Workflow) GetOffloadNodeStatusVersion() string

+ func (wf *Workflow) GetStoredTemplate(templateScope string, holder TemplateHolder) *Template

+ func (wf *Workflow) GetTemplateByName(name string) *Template

+ func (wf *Workflow) GetTemplateScope() string

+ func (wf *Workflow) NodeID(name string) string

+ func (wf *Workflow) SetStoredTemplate(templateScope string, holder TemplateHolder, tmpl *Template) (bool, error)

+ type WorkflowList struct

+ Items Workflows

+ type WorkflowSpec struct

+ ActiveDeadlineSeconds *int64

+ Affinity *apiv1.Affinity

+ Arguments Arguments

+ ArtifactRepositoryRef *ArtifactRepositoryRef

+ AutomountServiceAccountToken *bool

+ DNSConfig *apiv1.PodDNSConfig

+ DNSPolicy *apiv1.DNSPolicy

+ Entrypoint string

+ Executor *ExecutorConfig

+ HostAliases []apiv1.HostAlias

+ HostNetwork *bool

+ ImagePullSecrets []apiv1.LocalObjectReference

+ NodeSelector map[string]string

+ OnExit string

+ Parallelism *int64

+ PodGC *PodGC

+ PodPriority *int32

+ PodPriorityClassName string

+ PodSpecPatch string

+ Priority *int32

+ SchedulerName string

+ SecurityContext *apiv1.PodSecurityContext

+ ServiceAccountName string

+ Suspend *bool

+ TTLSecondsAfterFinished *int32

+ TTLStrategy *TTLStrategy

+ Templates []Template

+ Tolerations []apiv1.Toleration

+ VolumeClaimTemplates []apiv1.PersistentVolumeClaim

+ Volumes []apiv1.Volume

+ func (wfs *WorkflowSpec) HasPodSpecPatch() bool

+ type WorkflowStatus struct

+ CompressedNodes string

+ FinishedAt metav1.Time

+ Message string

+ Nodes Nodes

+ OffloadNodeStatusVersion string

+ Outputs *Outputs

+ PersistentVolumeClaims []apiv1.Volume

+ Phase NodePhase

+ StartedAt metav1.Time

+ StoredTemplates map[string]Template

+ func (in *WorkflowStatus) AnyActiveSuspendNode() bool

+ func (ws *WorkflowStatus) Completed() bool

+ func (ws *WorkflowStatus) Failed() bool

+ func (ws *WorkflowStatus) GetOffloadNodeStatusVersion() string

+ func (ws *WorkflowStatus) IsOffloadNodeStatus() bool

+ func (ws *WorkflowStatus) Successful() bool

+ type WorkflowStep struct

+ Arguments Arguments

+ ContinueOn *ContinueOn

+ Name string

+ OnExit string

+ Template string

+ TemplateRef *TemplateRef

+ When string

+ WithItems []Item

+ WithParam string

+ WithSequence *Sequence

+ func (s *WorkflowStep) ContinuesOn(phase NodePhase) bool

+ func (step *WorkflowStep) GetTemplateName() string

+ func (step *WorkflowStep) GetTemplateRef() *TemplateRef

+ func (step *WorkflowStep) IsResolvable() bool

+ type WorkflowTemplate struct

+ Spec WorkflowTemplateSpec

+ func (wftmpl *WorkflowTemplate) GetTemplateByName(name string) *Template

+ func (wftmpl *WorkflowTemplate) GetTemplateScope() string

+ type WorkflowTemplateList struct

+ Items WorkflowTemplates

+ type WorkflowTemplateSpec struct

+ Arguments Arguments

+ Templates []Template

+ type WorkflowTemplates []WorkflowTemplate

+ func (w WorkflowTemplates) Len() int

+ func (w WorkflowTemplates) Less(i, j int) bool

+ func (w WorkflowTemplates) Swap(i, j int)

+ type Workflows []Workflow

+ func (w Workflows) Len() int

+ func (w Workflows) Less(i, j int) bool

+ func (w Workflows) Swap(i, j int)

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL