Documentation ¶
Overview ¶
Package v1alpha1 is the v1alpha1 version of the API. +groupName=argoproj.io +k8s:deepcopy-gen=package,register +k8s:openapi-gen=true
Index ¶
- Variables
- func GetOpenAPIDefinitions(ref common.ReferenceCallback) map[string]common.OpenAPIDefinition
- func Kind(kind string) schema.GroupKind
- func Resource(resource string) schema.GroupResource
- type ArchiveStrategy
- func (in *ArchiveStrategy) DeepCopy() *ArchiveStrategy
- func (in *ArchiveStrategy) DeepCopyInto(out *ArchiveStrategy)
- func (*ArchiveStrategy) Descriptor() ([]byte, []int)
- func (m *ArchiveStrategy) Marshal() (dAtA []byte, err error)
- func (m *ArchiveStrategy) MarshalTo(dAtA []byte) (int, error)
- func (m *ArchiveStrategy) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ArchiveStrategy) ProtoMessage()
- func (m *ArchiveStrategy) Reset()
- func (m *ArchiveStrategy) Size() (n int)
- func (this *ArchiveStrategy) String() string
- func (m *ArchiveStrategy) Unmarshal(dAtA []byte) error
- func (m *ArchiveStrategy) XXX_DiscardUnknown()
- func (m *ArchiveStrategy) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ArchiveStrategy) XXX_Merge(src proto.Message)
- func (m *ArchiveStrategy) XXX_Size() int
- func (m *ArchiveStrategy) XXX_Unmarshal(b []byte) error
- type Arguments
- func (in *Arguments) DeepCopy() *Arguments
- func (in *Arguments) DeepCopyInto(out *Arguments)
- func (*Arguments) Descriptor() ([]byte, []int)
- func (args *Arguments) GetArtifactByName(name string) *Artifact
- func (args *Arguments) GetParameterByName(name string) *Parameter
- func (m *Arguments) Marshal() (dAtA []byte, err error)
- func (m *Arguments) MarshalTo(dAtA []byte) (int, error)
- func (m *Arguments) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Arguments) ProtoMessage()
- func (m *Arguments) Reset()
- func (m *Arguments) Size() (n int)
- func (this *Arguments) String() string
- func (m *Arguments) Unmarshal(dAtA []byte) error
- func (m *Arguments) XXX_DiscardUnknown()
- func (m *Arguments) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Arguments) XXX_Merge(src proto.Message)
- func (m *Arguments) XXX_Size() int
- func (m *Arguments) XXX_Unmarshal(b []byte) error
- type ArgumentsProvider
- type Artifact
- func (in *Artifact) DeepCopy() *Artifact
- func (in *Artifact) DeepCopyInto(out *Artifact)
- func (*Artifact) Descriptor() ([]byte, []int)
- func (a *Artifact) HasLocation() bool
- func (m *Artifact) Marshal() (dAtA []byte, err error)
- func (m *Artifact) MarshalTo(dAtA []byte) (int, error)
- func (m *Artifact) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Artifact) ProtoMessage()
- func (m *Artifact) Reset()
- func (m *Artifact) Size() (n int)
- func (this *Artifact) String() string
- func (m *Artifact) Unmarshal(dAtA []byte) error
- func (m *Artifact) XXX_DiscardUnknown()
- func (m *Artifact) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Artifact) XXX_Merge(src proto.Message)
- func (m *Artifact) XXX_Size() int
- func (m *Artifact) XXX_Unmarshal(b []byte) error
- type ArtifactLocation
- func (in *ArtifactLocation) DeepCopy() *ArtifactLocation
- func (in *ArtifactLocation) DeepCopyInto(out *ArtifactLocation)
- func (*ArtifactLocation) Descriptor() ([]byte, []int)
- func (m *ArtifactLocation) Marshal() (dAtA []byte, err error)
- func (m *ArtifactLocation) MarshalTo(dAtA []byte) (int, error)
- func (m *ArtifactLocation) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ArtifactLocation) ProtoMessage()
- func (m *ArtifactLocation) Reset()
- func (m *ArtifactLocation) Size() (n int)
- func (this *ArtifactLocation) String() string
- func (m *ArtifactLocation) Unmarshal(dAtA []byte) error
- func (m *ArtifactLocation) XXX_DiscardUnknown()
- func (m *ArtifactLocation) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ArtifactLocation) XXX_Merge(src proto.Message)
- func (m *ArtifactLocation) XXX_Size() int
- func (m *ArtifactLocation) XXX_Unmarshal(b []byte) error
- type ArtifactRepositoryRef
- func (in *ArtifactRepositoryRef) DeepCopy() *ArtifactRepositoryRef
- func (in *ArtifactRepositoryRef) DeepCopyInto(out *ArtifactRepositoryRef)
- func (*ArtifactRepositoryRef) Descriptor() ([]byte, []int)
- func (m *ArtifactRepositoryRef) Marshal() (dAtA []byte, err error)
- func (m *ArtifactRepositoryRef) MarshalTo(dAtA []byte) (int, error)
- func (m *ArtifactRepositoryRef) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ArtifactRepositoryRef) ProtoMessage()
- func (m *ArtifactRepositoryRef) Reset()
- func (m *ArtifactRepositoryRef) Size() (n int)
- func (this *ArtifactRepositoryRef) String() string
- func (m *ArtifactRepositoryRef) Unmarshal(dAtA []byte) error
- func (m *ArtifactRepositoryRef) XXX_DiscardUnknown()
- func (m *ArtifactRepositoryRef) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ArtifactRepositoryRef) XXX_Merge(src proto.Message)
- func (m *ArtifactRepositoryRef) XXX_Size() int
- func (m *ArtifactRepositoryRef) XXX_Unmarshal(b []byte) error
- type ArtifactoryArtifact
- func (in *ArtifactoryArtifact) DeepCopy() *ArtifactoryArtifact
- func (in *ArtifactoryArtifact) DeepCopyInto(out *ArtifactoryArtifact)
- func (*ArtifactoryArtifact) Descriptor() ([]byte, []int)
- func (a *ArtifactoryArtifact) HasLocation() bool
- func (m *ArtifactoryArtifact) Marshal() (dAtA []byte, err error)
- func (m *ArtifactoryArtifact) MarshalTo(dAtA []byte) (int, error)
- func (m *ArtifactoryArtifact) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ArtifactoryArtifact) ProtoMessage()
- func (m *ArtifactoryArtifact) Reset()
- func (m *ArtifactoryArtifact) Size() (n int)
- func (this *ArtifactoryArtifact) String() string
- func (m *ArtifactoryArtifact) Unmarshal(dAtA []byte) error
- func (m *ArtifactoryArtifact) XXX_DiscardUnknown()
- func (m *ArtifactoryArtifact) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ArtifactoryArtifact) XXX_Merge(src proto.Message)
- func (m *ArtifactoryArtifact) XXX_Size() int
- func (m *ArtifactoryArtifact) XXX_Unmarshal(b []byte) error
- type ArtifactoryAuth
- func (in *ArtifactoryAuth) DeepCopy() *ArtifactoryAuth
- func (in *ArtifactoryAuth) DeepCopyInto(out *ArtifactoryAuth)
- func (*ArtifactoryAuth) Descriptor() ([]byte, []int)
- func (m *ArtifactoryAuth) Marshal() (dAtA []byte, err error)
- func (m *ArtifactoryAuth) MarshalTo(dAtA []byte) (int, error)
- func (m *ArtifactoryAuth) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ArtifactoryAuth) ProtoMessage()
- func (m *ArtifactoryAuth) Reset()
- func (m *ArtifactoryAuth) Size() (n int)
- func (this *ArtifactoryAuth) String() string
- func (m *ArtifactoryAuth) Unmarshal(dAtA []byte) error
- func (m *ArtifactoryAuth) XXX_DiscardUnknown()
- func (m *ArtifactoryAuth) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ArtifactoryAuth) XXX_Merge(src proto.Message)
- func (m *ArtifactoryAuth) XXX_Size() int
- func (m *ArtifactoryAuth) XXX_Unmarshal(b []byte) error
- type Artifacts
- type Backoff
- func (in *Backoff) DeepCopy() *Backoff
- func (in *Backoff) DeepCopyInto(out *Backoff)
- func (*Backoff) Descriptor() ([]byte, []int)
- func (m *Backoff) Marshal() (dAtA []byte, err error)
- func (m *Backoff) MarshalTo(dAtA []byte) (int, error)
- func (m *Backoff) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Backoff) ProtoMessage()
- func (m *Backoff) Reset()
- func (m *Backoff) Size() (n int)
- func (this *Backoff) String() string
- func (m *Backoff) Unmarshal(dAtA []byte) error
- func (m *Backoff) XXX_DiscardUnknown()
- func (m *Backoff) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Backoff) XXX_Merge(src proto.Message)
- func (m *Backoff) XXX_Size() int
- func (m *Backoff) XXX_Unmarshal(b []byte) error
- type ConcurrencyPolicy
- type ContinueOn
- func (in *ContinueOn) DeepCopy() *ContinueOn
- func (in *ContinueOn) DeepCopyInto(out *ContinueOn)
- func (*ContinueOn) Descriptor() ([]byte, []int)
- func (m *ContinueOn) Marshal() (dAtA []byte, err error)
- func (m *ContinueOn) MarshalTo(dAtA []byte) (int, error)
- func (m *ContinueOn) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ContinueOn) ProtoMessage()
- func (m *ContinueOn) Reset()
- func (m *ContinueOn) Size() (n int)
- func (this *ContinueOn) String() string
- func (m *ContinueOn) Unmarshal(dAtA []byte) error
- func (m *ContinueOn) XXX_DiscardUnknown()
- func (m *ContinueOn) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ContinueOn) XXX_Merge(src proto.Message)
- func (m *ContinueOn) XXX_Size() int
- func (m *ContinueOn) XXX_Unmarshal(b []byte) error
- type CronWorkflow
- func (in *CronWorkflow) DeepCopy() *CronWorkflow
- func (in *CronWorkflow) DeepCopyInto(out *CronWorkflow)
- func (in *CronWorkflow) DeepCopyObject() runtime.Object
- func (*CronWorkflow) Descriptor() ([]byte, []int)
- func (m *CronWorkflow) Marshal() (dAtA []byte, err error)
- func (m *CronWorkflow) MarshalTo(dAtA []byte) (int, error)
- func (m *CronWorkflow) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*CronWorkflow) ProtoMessage()
- func (m *CronWorkflow) Reset()
- func (m *CronWorkflow) Size() (n int)
- func (this *CronWorkflow) String() string
- func (m *CronWorkflow) Unmarshal(dAtA []byte) error
- func (m *CronWorkflow) XXX_DiscardUnknown()
- func (m *CronWorkflow) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CronWorkflow) XXX_Merge(src proto.Message)
- func (m *CronWorkflow) XXX_Size() int
- func (m *CronWorkflow) XXX_Unmarshal(b []byte) error
- type CronWorkflowList
- func (in *CronWorkflowList) DeepCopy() *CronWorkflowList
- func (in *CronWorkflowList) DeepCopyInto(out *CronWorkflowList)
- func (in *CronWorkflowList) DeepCopyObject() runtime.Object
- func (*CronWorkflowList) Descriptor() ([]byte, []int)
- func (m *CronWorkflowList) Marshal() (dAtA []byte, err error)
- func (m *CronWorkflowList) MarshalTo(dAtA []byte) (int, error)
- func (m *CronWorkflowList) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*CronWorkflowList) ProtoMessage()
- func (m *CronWorkflowList) Reset()
- func (m *CronWorkflowList) Size() (n int)
- func (this *CronWorkflowList) String() string
- func (m *CronWorkflowList) Unmarshal(dAtA []byte) error
- func (m *CronWorkflowList) XXX_DiscardUnknown()
- func (m *CronWorkflowList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CronWorkflowList) XXX_Merge(src proto.Message)
- func (m *CronWorkflowList) XXX_Size() int
- func (m *CronWorkflowList) XXX_Unmarshal(b []byte) error
- type CronWorkflowSpec
- func (in *CronWorkflowSpec) DeepCopy() *CronWorkflowSpec
- func (in *CronWorkflowSpec) DeepCopyInto(out *CronWorkflowSpec)
- func (*CronWorkflowSpec) Descriptor() ([]byte, []int)
- func (m *CronWorkflowSpec) Marshal() (dAtA []byte, err error)
- func (m *CronWorkflowSpec) MarshalTo(dAtA []byte) (int, error)
- func (m *CronWorkflowSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*CronWorkflowSpec) ProtoMessage()
- func (m *CronWorkflowSpec) Reset()
- func (m *CronWorkflowSpec) Size() (n int)
- func (this *CronWorkflowSpec) String() string
- func (m *CronWorkflowSpec) Unmarshal(dAtA []byte) error
- func (m *CronWorkflowSpec) XXX_DiscardUnknown()
- func (m *CronWorkflowSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CronWorkflowSpec) XXX_Merge(src proto.Message)
- func (m *CronWorkflowSpec) XXX_Size() int
- func (m *CronWorkflowSpec) XXX_Unmarshal(b []byte) error
- type CronWorkflowStatus
- func (in *CronWorkflowStatus) DeepCopy() *CronWorkflowStatus
- func (in *CronWorkflowStatus) DeepCopyInto(out *CronWorkflowStatus)
- func (*CronWorkflowStatus) Descriptor() ([]byte, []int)
- func (m *CronWorkflowStatus) Marshal() (dAtA []byte, err error)
- func (m *CronWorkflowStatus) MarshalTo(dAtA []byte) (int, error)
- func (m *CronWorkflowStatus) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*CronWorkflowStatus) ProtoMessage()
- func (m *CronWorkflowStatus) Reset()
- func (m *CronWorkflowStatus) Size() (n int)
- func (this *CronWorkflowStatus) String() string
- func (m *CronWorkflowStatus) Unmarshal(dAtA []byte) error
- func (m *CronWorkflowStatus) XXX_DiscardUnknown()
- func (m *CronWorkflowStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CronWorkflowStatus) XXX_Merge(src proto.Message)
- func (m *CronWorkflowStatus) XXX_Size() int
- func (m *CronWorkflowStatus) XXX_Unmarshal(b []byte) error
- type DAGTask
- func (t *DAGTask) ContinuesOn(phase NodePhase) bool
- func (in *DAGTask) DeepCopy() *DAGTask
- func (in *DAGTask) DeepCopyInto(out *DAGTask)
- func (*DAGTask) Descriptor() ([]byte, []int)
- func (t *DAGTask) GetTemplateName() string
- func (t *DAGTask) GetTemplateRef() *TemplateRef
- func (t *DAGTask) IsResolvable() bool
- func (m *DAGTask) Marshal() (dAtA []byte, err error)
- func (m *DAGTask) MarshalTo(dAtA []byte) (int, error)
- func (m *DAGTask) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*DAGTask) ProtoMessage()
- func (m *DAGTask) Reset()
- func (m *DAGTask) Size() (n int)
- func (this *DAGTask) String() string
- func (m *DAGTask) Unmarshal(dAtA []byte) error
- func (m *DAGTask) XXX_DiscardUnknown()
- func (m *DAGTask) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DAGTask) XXX_Merge(src proto.Message)
- func (m *DAGTask) XXX_Size() int
- func (m *DAGTask) XXX_Unmarshal(b []byte) error
- type DAGTemplate
- func (in *DAGTemplate) DeepCopy() *DAGTemplate
- func (in *DAGTemplate) DeepCopyInto(out *DAGTemplate)
- func (*DAGTemplate) Descriptor() ([]byte, []int)
- func (m *DAGTemplate) Marshal() (dAtA []byte, err error)
- func (m *DAGTemplate) MarshalTo(dAtA []byte) (int, error)
- func (m *DAGTemplate) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*DAGTemplate) ProtoMessage()
- func (m *DAGTemplate) Reset()
- func (m *DAGTemplate) Size() (n int)
- func (this *DAGTemplate) String() string
- func (m *DAGTemplate) Unmarshal(dAtA []byte) error
- func (m *DAGTemplate) XXX_DiscardUnknown()
- func (m *DAGTemplate) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DAGTemplate) XXX_Merge(src proto.Message)
- func (m *DAGTemplate) XXX_Size() int
- func (m *DAGTemplate) XXX_Unmarshal(b []byte) error
- type ExecutorConfig
- func (in *ExecutorConfig) DeepCopy() *ExecutorConfig
- func (in *ExecutorConfig) DeepCopyInto(out *ExecutorConfig)
- func (*ExecutorConfig) Descriptor() ([]byte, []int)
- func (m *ExecutorConfig) Marshal() (dAtA []byte, err error)
- func (m *ExecutorConfig) MarshalTo(dAtA []byte) (int, error)
- func (m *ExecutorConfig) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ExecutorConfig) ProtoMessage()
- func (m *ExecutorConfig) Reset()
- func (m *ExecutorConfig) Size() (n int)
- func (this *ExecutorConfig) String() string
- func (m *ExecutorConfig) Unmarshal(dAtA []byte) error
- func (m *ExecutorConfig) XXX_DiscardUnknown()
- func (m *ExecutorConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ExecutorConfig) XXX_Merge(src proto.Message)
- func (m *ExecutorConfig) XXX_Size() int
- func (m *ExecutorConfig) XXX_Unmarshal(b []byte) error
- type GitArtifact
- func (in *GitArtifact) DeepCopy() *GitArtifact
- func (in *GitArtifact) DeepCopyInto(out *GitArtifact)
- func (*GitArtifact) Descriptor() ([]byte, []int)
- func (g *GitArtifact) HasLocation() bool
- func (m *GitArtifact) Marshal() (dAtA []byte, err error)
- func (m *GitArtifact) MarshalTo(dAtA []byte) (int, error)
- func (m *GitArtifact) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GitArtifact) ProtoMessage()
- func (m *GitArtifact) Reset()
- func (m *GitArtifact) Size() (n int)
- func (this *GitArtifact) String() string
- func (m *GitArtifact) Unmarshal(dAtA []byte) error
- func (m *GitArtifact) XXX_DiscardUnknown()
- func (m *GitArtifact) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GitArtifact) XXX_Merge(src proto.Message)
- func (m *GitArtifact) XXX_Size() int
- func (m *GitArtifact) XXX_Unmarshal(b []byte) error
- type HDFSArtifact
- func (in *HDFSArtifact) DeepCopy() *HDFSArtifact
- func (in *HDFSArtifact) DeepCopyInto(out *HDFSArtifact)
- func (*HDFSArtifact) Descriptor() ([]byte, []int)
- func (h *HDFSArtifact) HasLocation() bool
- func (m *HDFSArtifact) Marshal() (dAtA []byte, err error)
- func (m *HDFSArtifact) MarshalTo(dAtA []byte) (int, error)
- func (m *HDFSArtifact) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*HDFSArtifact) ProtoMessage()
- func (m *HDFSArtifact) Reset()
- func (m *HDFSArtifact) Size() (n int)
- func (this *HDFSArtifact) String() string
- func (m *HDFSArtifact) Unmarshal(dAtA []byte) error
- func (m *HDFSArtifact) XXX_DiscardUnknown()
- func (m *HDFSArtifact) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *HDFSArtifact) XXX_Merge(src proto.Message)
- func (m *HDFSArtifact) XXX_Size() int
- func (m *HDFSArtifact) XXX_Unmarshal(b []byte) error
- type HDFSConfig
- func (in *HDFSConfig) DeepCopy() *HDFSConfig
- func (in *HDFSConfig) DeepCopyInto(out *HDFSConfig)
- func (*HDFSConfig) Descriptor() ([]byte, []int)
- func (m *HDFSConfig) Marshal() (dAtA []byte, err error)
- func (m *HDFSConfig) MarshalTo(dAtA []byte) (int, error)
- func (m *HDFSConfig) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*HDFSConfig) ProtoMessage()
- func (m *HDFSConfig) Reset()
- func (m *HDFSConfig) Size() (n int)
- func (this *HDFSConfig) String() string
- func (m *HDFSConfig) Unmarshal(dAtA []byte) error
- func (m *HDFSConfig) XXX_DiscardUnknown()
- func (m *HDFSConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *HDFSConfig) XXX_Merge(src proto.Message)
- func (m *HDFSConfig) XXX_Size() int
- func (m *HDFSConfig) XXX_Unmarshal(b []byte) error
- type HDFSKrbConfig
- func (in *HDFSKrbConfig) DeepCopy() *HDFSKrbConfig
- func (in *HDFSKrbConfig) DeepCopyInto(out *HDFSKrbConfig)
- func (*HDFSKrbConfig) Descriptor() ([]byte, []int)
- func (m *HDFSKrbConfig) Marshal() (dAtA []byte, err error)
- func (m *HDFSKrbConfig) MarshalTo(dAtA []byte) (int, error)
- func (m *HDFSKrbConfig) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*HDFSKrbConfig) ProtoMessage()
- func (m *HDFSKrbConfig) Reset()
- func (m *HDFSKrbConfig) Size() (n int)
- func (this *HDFSKrbConfig) String() string
- func (m *HDFSKrbConfig) Unmarshal(dAtA []byte) error
- func (m *HDFSKrbConfig) XXX_DiscardUnknown()
- func (m *HDFSKrbConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *HDFSKrbConfig) XXX_Merge(src proto.Message)
- func (m *HDFSKrbConfig) XXX_Size() int
- func (m *HDFSKrbConfig) XXX_Unmarshal(b []byte) error
- type HTTPArtifact
- func (in *HTTPArtifact) DeepCopy() *HTTPArtifact
- func (in *HTTPArtifact) DeepCopyInto(out *HTTPArtifact)
- func (*HTTPArtifact) Descriptor() ([]byte, []int)
- func (h *HTTPArtifact) HasLocation() bool
- func (m *HTTPArtifact) Marshal() (dAtA []byte, err error)
- func (m *HTTPArtifact) MarshalTo(dAtA []byte) (int, error)
- func (m *HTTPArtifact) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*HTTPArtifact) ProtoMessage()
- func (m *HTTPArtifact) Reset()
- func (m *HTTPArtifact) Size() (n int)
- func (this *HTTPArtifact) String() string
- func (m *HTTPArtifact) Unmarshal(dAtA []byte) error
- func (m *HTTPArtifact) XXX_DiscardUnknown()
- func (m *HTTPArtifact) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *HTTPArtifact) XXX_Merge(src proto.Message)
- func (m *HTTPArtifact) XXX_Size() int
- func (m *HTTPArtifact) XXX_Unmarshal(b []byte) error
- type Inputs
- func (in *Inputs) DeepCopy() *Inputs
- func (in *Inputs) DeepCopyInto(out *Inputs)
- func (*Inputs) Descriptor() ([]byte, []int)
- func (in *Inputs) GetArtifactByName(name string) *Artifact
- func (in *Inputs) GetParameterByName(name string) *Parameter
- func (in *Inputs) HasInputs() bool
- func (m *Inputs) Marshal() (dAtA []byte, err error)
- func (m *Inputs) MarshalTo(dAtA []byte) (int, error)
- func (m *Inputs) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Inputs) ProtoMessage()
- func (m *Inputs) Reset()
- func (m *Inputs) Size() (n int)
- func (this *Inputs) String() string
- func (m *Inputs) Unmarshal(dAtA []byte) error
- func (m *Inputs) XXX_DiscardUnknown()
- func (m *Inputs) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Inputs) XXX_Merge(src proto.Message)
- func (m *Inputs) XXX_Size() int
- func (m *Inputs) XXX_Unmarshal(b []byte) error
- type Item
- func (in *Item) DeepCopy() *Item
- func (i *Item) DeepCopyInto(out *Item)
- func (*Item) Descriptor() ([]byte, []int)
- func (i Item) Format(s fmt.State, verb rune)
- func (m *Item) Marshal() (dAtA []byte, err error)
- func (i Item) MarshalJSON() ([]byte, error)
- func (m *Item) MarshalTo(dAtA []byte) (int, error)
- func (m *Item) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (i Item) OpenAPISchemaFormat() string
- func (i Item) OpenAPISchemaType() []string
- func (*Item) ProtoMessage()
- func (m *Item) Reset()
- func (m *Item) Size() (n int)
- func (i *Item) String() string
- func (m *Item) Unmarshal(dAtA []byte) error
- func (i *Item) UnmarshalJSON(value []byte) error
- func (m *Item) XXX_DiscardUnknown()
- func (m *Item) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Item) XXX_Merge(src proto.Message)
- func (m *Item) XXX_Size() int
- func (m *Item) XXX_Unmarshal(b []byte) error
- type ItemValue
- func (in *ItemValue) DeepCopy() *ItemValue
- func (in *ItemValue) DeepCopyInto(out *ItemValue)
- func (*ItemValue) Descriptor() ([]byte, []int)
- func (iv ItemValue) Format(s fmt.State, verb rune)
- func (m *ItemValue) Marshal() (dAtA []byte, err error)
- func (iv ItemValue) MarshalJSON() ([]byte, error)
- func (m *ItemValue) MarshalTo(dAtA []byte) (int, error)
- func (m *ItemValue) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ItemValue) ProtoMessage()
- func (m *ItemValue) Reset()
- func (m *ItemValue) Size() (n int)
- func (iv *ItemValue) String() string
- func (m *ItemValue) Unmarshal(dAtA []byte) error
- func (iv *ItemValue) UnmarshalJSON(value []byte) error
- func (m *ItemValue) XXX_DiscardUnknown()
- func (m *ItemValue) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ItemValue) XXX_Merge(src proto.Message)
- func (m *ItemValue) XXX_Size() int
- func (m *ItemValue) XXX_Unmarshal(b []byte) error
- type Metadata
- func (in *Metadata) DeepCopy() *Metadata
- func (in *Metadata) DeepCopyInto(out *Metadata)
- func (*Metadata) Descriptor() ([]byte, []int)
- func (m *Metadata) Marshal() (dAtA []byte, err error)
- func (m *Metadata) MarshalTo(dAtA []byte) (int, error)
- func (m *Metadata) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Metadata) ProtoMessage()
- func (m *Metadata) Reset()
- func (m *Metadata) Size() (n int)
- func (this *Metadata) String() string
- func (m *Metadata) Unmarshal(dAtA []byte) error
- func (m *Metadata) XXX_DiscardUnknown()
- func (m *Metadata) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Metadata) XXX_Merge(src proto.Message)
- func (m *Metadata) XXX_Size() int
- func (m *Metadata) XXX_Unmarshal(b []byte) error
- type NodePhase
- type NodeStatus
- func (n NodeStatus) CanRetry() bool
- func (n NodeStatus) Completed() bool
- func (in *NodeStatus) DeepCopy() *NodeStatus
- func (in *NodeStatus) DeepCopyInto(out *NodeStatus)
- func (*NodeStatus) Descriptor() ([]byte, []int)
- func (n *NodeStatus) GetTemplateName() string
- func (n *NodeStatus) GetTemplateRef() *TemplateRef
- func (n NodeStatus) IsDaemoned() bool
- func (n *NodeStatus) IsResolvable() bool
- func (m *NodeStatus) Marshal() (dAtA []byte, err error)
- func (m *NodeStatus) MarshalTo(dAtA []byte) (int, error)
- func (m *NodeStatus) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*NodeStatus) ProtoMessage()
- func (m *NodeStatus) Reset()
- func (m *NodeStatus) Size() (n int)
- func (this *NodeStatus) String() string
- func (n NodeStatus) Successful() bool
- func (m *NodeStatus) Unmarshal(dAtA []byte) error
- func (m *NodeStatus) XXX_DiscardUnknown()
- func (m *NodeStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *NodeStatus) XXX_Merge(src proto.Message)
- func (m *NodeStatus) XXX_Size() int
- func (m *NodeStatus) XXX_Unmarshal(b []byte) error
- type NodeType
- type Nodes
- type NoneStrategy
- func (in *NoneStrategy) DeepCopy() *NoneStrategy
- func (in *NoneStrategy) DeepCopyInto(out *NoneStrategy)
- func (*NoneStrategy) Descriptor() ([]byte, []int)
- func (m *NoneStrategy) Marshal() (dAtA []byte, err error)
- func (m *NoneStrategy) MarshalTo(dAtA []byte) (int, error)
- func (m *NoneStrategy) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*NoneStrategy) ProtoMessage()
- func (m *NoneStrategy) Reset()
- func (m *NoneStrategy) Size() (n int)
- func (this *NoneStrategy) String() string
- func (m *NoneStrategy) Unmarshal(dAtA []byte) error
- func (m *NoneStrategy) XXX_DiscardUnknown()
- func (m *NoneStrategy) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *NoneStrategy) XXX_Merge(src proto.Message)
- func (m *NoneStrategy) XXX_Size() int
- func (m *NoneStrategy) XXX_Unmarshal(b []byte) error
- type Outputs
- func (in *Outputs) DeepCopy() *Outputs
- func (in *Outputs) DeepCopyInto(out *Outputs)
- func (*Outputs) Descriptor() ([]byte, []int)
- func (out *Outputs) GetArtifactByName(name string) *Artifact
- func (out *Outputs) HasOutputs() bool
- func (m *Outputs) Marshal() (dAtA []byte, err error)
- func (m *Outputs) MarshalTo(dAtA []byte) (int, error)
- func (m *Outputs) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Outputs) ProtoMessage()
- func (m *Outputs) Reset()
- func (m *Outputs) Size() (n int)
- func (this *Outputs) String() string
- func (m *Outputs) Unmarshal(dAtA []byte) error
- func (m *Outputs) XXX_DiscardUnknown()
- func (m *Outputs) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Outputs) XXX_Merge(src proto.Message)
- func (m *Outputs) XXX_Size() int
- func (m *Outputs) XXX_Unmarshal(b []byte) error
- type ParallelSteps
- func (in *ParallelSteps) DeepCopy() *ParallelSteps
- func (in *ParallelSteps) DeepCopyInto(out *ParallelSteps)
- func (*ParallelSteps) Descriptor() ([]byte, []int)
- func (m *ParallelSteps) Marshal() (dAtA []byte, err error)
- func (p *ParallelSteps) MarshalJSON() ([]byte, error)
- func (m *ParallelSteps) MarshalTo(dAtA []byte) (int, error)
- func (m *ParallelSteps) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ParallelSteps) ProtoMessage()
- func (m *ParallelSteps) Reset()
- func (m *ParallelSteps) Size() (n int)
- func (this *ParallelSteps) String() string
- func (m *ParallelSteps) Unmarshal(dAtA []byte) error
- func (p *ParallelSteps) UnmarshalJSON(value []byte) error
- func (m *ParallelSteps) XXX_DiscardUnknown()
- func (m *ParallelSteps) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ParallelSteps) XXX_Merge(src proto.Message)
- func (m *ParallelSteps) XXX_Size() int
- func (m *ParallelSteps) XXX_Unmarshal(b []byte) error
- type Parameter
- func (in *Parameter) DeepCopy() *Parameter
- func (in *Parameter) DeepCopyInto(out *Parameter)
- func (*Parameter) Descriptor() ([]byte, []int)
- func (m *Parameter) Marshal() (dAtA []byte, err error)
- func (m *Parameter) MarshalTo(dAtA []byte) (int, error)
- func (m *Parameter) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Parameter) ProtoMessage()
- func (m *Parameter) Reset()
- func (m *Parameter) Size() (n int)
- func (this *Parameter) String() string
- func (m *Parameter) Unmarshal(dAtA []byte) error
- func (m *Parameter) XXX_DiscardUnknown()
- func (m *Parameter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Parameter) XXX_Merge(src proto.Message)
- func (m *Parameter) XXX_Size() int
- func (m *Parameter) XXX_Unmarshal(b []byte) error
- type PodGC
- func (in *PodGC) DeepCopy() *PodGC
- func (in *PodGC) DeepCopyInto(out *PodGC)
- func (*PodGC) Descriptor() ([]byte, []int)
- func (m *PodGC) Marshal() (dAtA []byte, err error)
- func (m *PodGC) MarshalTo(dAtA []byte) (int, error)
- func (m *PodGC) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*PodGC) ProtoMessage()
- func (m *PodGC) Reset()
- func (m *PodGC) Size() (n int)
- func (this *PodGC) String() string
- func (m *PodGC) Unmarshal(dAtA []byte) error
- func (m *PodGC) XXX_DiscardUnknown()
- func (m *PodGC) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PodGC) XXX_Merge(src proto.Message)
- func (m *PodGC) XXX_Size() int
- func (m *PodGC) XXX_Unmarshal(b []byte) error
- type PodGCStrategy
- type RawArtifact
- func (in *RawArtifact) DeepCopy() *RawArtifact
- func (in *RawArtifact) DeepCopyInto(out *RawArtifact)
- func (*RawArtifact) Descriptor() ([]byte, []int)
- func (r *RawArtifact) HasLocation() bool
- func (m *RawArtifact) Marshal() (dAtA []byte, err error)
- func (m *RawArtifact) MarshalTo(dAtA []byte) (int, error)
- func (m *RawArtifact) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*RawArtifact) ProtoMessage()
- func (m *RawArtifact) Reset()
- func (m *RawArtifact) Size() (n int)
- func (this *RawArtifact) String() string
- func (m *RawArtifact) Unmarshal(dAtA []byte) error
- func (m *RawArtifact) XXX_DiscardUnknown()
- func (m *RawArtifact) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RawArtifact) XXX_Merge(src proto.Message)
- func (m *RawArtifact) XXX_Size() int
- func (m *RawArtifact) XXX_Unmarshal(b []byte) error
- type ResourceTemplate
- func (in *ResourceTemplate) DeepCopy() *ResourceTemplate
- func (in *ResourceTemplate) DeepCopyInto(out *ResourceTemplate)
- func (*ResourceTemplate) Descriptor() ([]byte, []int)
- func (m *ResourceTemplate) Marshal() (dAtA []byte, err error)
- func (m *ResourceTemplate) MarshalTo(dAtA []byte) (int, error)
- func (m *ResourceTemplate) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ResourceTemplate) ProtoMessage()
- func (m *ResourceTemplate) Reset()
- func (m *ResourceTemplate) Size() (n int)
- func (this *ResourceTemplate) String() string
- func (m *ResourceTemplate) Unmarshal(dAtA []byte) error
- func (m *ResourceTemplate) XXX_DiscardUnknown()
- func (m *ResourceTemplate) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ResourceTemplate) XXX_Merge(src proto.Message)
- func (m *ResourceTemplate) XXX_Size() int
- func (m *ResourceTemplate) XXX_Unmarshal(b []byte) error
- type RetryPolicy
- type RetryStrategy
- func (in *RetryStrategy) DeepCopy() *RetryStrategy
- func (in *RetryStrategy) DeepCopyInto(out *RetryStrategy)
- func (*RetryStrategy) Descriptor() ([]byte, []int)
- func (m *RetryStrategy) Marshal() (dAtA []byte, err error)
- func (m *RetryStrategy) MarshalTo(dAtA []byte) (int, error)
- func (m *RetryStrategy) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*RetryStrategy) ProtoMessage()
- func (m *RetryStrategy) Reset()
- func (m *RetryStrategy) Size() (n int)
- func (this *RetryStrategy) String() string
- func (m *RetryStrategy) Unmarshal(dAtA []byte) error
- func (m *RetryStrategy) XXX_DiscardUnknown()
- func (m *RetryStrategy) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RetryStrategy) XXX_Merge(src proto.Message)
- func (m *RetryStrategy) XXX_Size() int
- func (m *RetryStrategy) XXX_Unmarshal(b []byte) error
- type S3Artifact
- func (in *S3Artifact) DeepCopy() *S3Artifact
- func (in *S3Artifact) DeepCopyInto(out *S3Artifact)
- func (*S3Artifact) Descriptor() ([]byte, []int)
- func (s *S3Artifact) HasLocation() bool
- func (m *S3Artifact) Marshal() (dAtA []byte, err error)
- func (m *S3Artifact) MarshalTo(dAtA []byte) (int, error)
- func (m *S3Artifact) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*S3Artifact) ProtoMessage()
- func (m *S3Artifact) Reset()
- func (m *S3Artifact) Size() (n int)
- func (this *S3Artifact) String() string
- func (m *S3Artifact) Unmarshal(dAtA []byte) error
- func (m *S3Artifact) XXX_DiscardUnknown()
- func (m *S3Artifact) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *S3Artifact) XXX_Merge(src proto.Message)
- func (m *S3Artifact) XXX_Size() int
- func (m *S3Artifact) XXX_Unmarshal(b []byte) error
- type S3Bucket
- func (in *S3Bucket) DeepCopy() *S3Bucket
- func (in *S3Bucket) DeepCopyInto(out *S3Bucket)
- func (*S3Bucket) Descriptor() ([]byte, []int)
- func (m *S3Bucket) Marshal() (dAtA []byte, err error)
- func (m *S3Bucket) MarshalTo(dAtA []byte) (int, error)
- func (m *S3Bucket) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*S3Bucket) ProtoMessage()
- func (m *S3Bucket) Reset()
- func (m *S3Bucket) Size() (n int)
- func (this *S3Bucket) String() string
- func (m *S3Bucket) Unmarshal(dAtA []byte) error
- func (m *S3Bucket) XXX_DiscardUnknown()
- func (m *S3Bucket) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *S3Bucket) XXX_Merge(src proto.Message)
- func (m *S3Bucket) XXX_Size() int
- func (m *S3Bucket) XXX_Unmarshal(b []byte) error
- type ScriptTemplate
- func (in *ScriptTemplate) DeepCopy() *ScriptTemplate
- func (in *ScriptTemplate) DeepCopyInto(out *ScriptTemplate)
- func (*ScriptTemplate) Descriptor() ([]byte, []int)
- func (m *ScriptTemplate) Marshal() (dAtA []byte, err error)
- func (m *ScriptTemplate) MarshalTo(dAtA []byte) (int, error)
- func (m *ScriptTemplate) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ScriptTemplate) ProtoMessage()
- func (m *ScriptTemplate) Reset()
- func (m *ScriptTemplate) Size() (n int)
- func (this *ScriptTemplate) String() string
- func (m *ScriptTemplate) Unmarshal(dAtA []byte) error
- func (m *ScriptTemplate) XXX_DiscardUnknown()
- func (m *ScriptTemplate) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ScriptTemplate) XXX_Merge(src proto.Message)
- func (m *ScriptTemplate) XXX_Size() int
- func (m *ScriptTemplate) XXX_Unmarshal(b []byte) error
- type Sequence
- func (in *Sequence) DeepCopy() *Sequence
- func (in *Sequence) DeepCopyInto(out *Sequence)
- func (*Sequence) Descriptor() ([]byte, []int)
- func (m *Sequence) Marshal() (dAtA []byte, err error)
- func (m *Sequence) MarshalTo(dAtA []byte) (int, error)
- func (m *Sequence) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Sequence) ProtoMessage()
- func (m *Sequence) Reset()
- func (m *Sequence) Size() (n int)
- func (this *Sequence) String() string
- func (m *Sequence) Unmarshal(dAtA []byte) error
- func (m *Sequence) XXX_DiscardUnknown()
- func (m *Sequence) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Sequence) XXX_Merge(src proto.Message)
- func (m *Sequence) XXX_Size() int
- func (m *Sequence) XXX_Unmarshal(b []byte) error
- type SuspendTemplate
- func (in *SuspendTemplate) DeepCopy() *SuspendTemplate
- func (in *SuspendTemplate) DeepCopyInto(out *SuspendTemplate)
- func (*SuspendTemplate) Descriptor() ([]byte, []int)
- func (m *SuspendTemplate) Marshal() (dAtA []byte, err error)
- func (m *SuspendTemplate) MarshalTo(dAtA []byte) (int, error)
- func (m *SuspendTemplate) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*SuspendTemplate) ProtoMessage()
- func (m *SuspendTemplate) Reset()
- func (m *SuspendTemplate) Size() (n int)
- func (this *SuspendTemplate) String() string
- func (m *SuspendTemplate) Unmarshal(dAtA []byte) error
- func (m *SuspendTemplate) XXX_DiscardUnknown()
- func (m *SuspendTemplate) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SuspendTemplate) XXX_Merge(src proto.Message)
- func (m *SuspendTemplate) XXX_Size() int
- func (m *SuspendTemplate) XXX_Unmarshal(b []byte) error
- type TTLStrategy
- func (in *TTLStrategy) DeepCopy() *TTLStrategy
- func (in *TTLStrategy) DeepCopyInto(out *TTLStrategy)
- func (*TTLStrategy) Descriptor() ([]byte, []int)
- func (m *TTLStrategy) Marshal() (dAtA []byte, err error)
- func (m *TTLStrategy) MarshalTo(dAtA []byte) (int, error)
- func (m *TTLStrategy) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*TTLStrategy) ProtoMessage()
- func (m *TTLStrategy) Reset()
- func (m *TTLStrategy) Size() (n int)
- func (this *TTLStrategy) String() string
- func (m *TTLStrategy) Unmarshal(dAtA []byte) error
- func (m *TTLStrategy) XXX_DiscardUnknown()
- func (m *TTLStrategy) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *TTLStrategy) XXX_Merge(src proto.Message)
- func (m *TTLStrategy) XXX_Size() int
- func (m *TTLStrategy) XXX_Unmarshal(b []byte) error
- type TarStrategy
- func (in *TarStrategy) DeepCopy() *TarStrategy
- func (in *TarStrategy) DeepCopyInto(out *TarStrategy)
- func (*TarStrategy) Descriptor() ([]byte, []int)
- func (m *TarStrategy) Marshal() (dAtA []byte, err error)
- func (m *TarStrategy) MarshalTo(dAtA []byte) (int, error)
- func (m *TarStrategy) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*TarStrategy) ProtoMessage()
- func (m *TarStrategy) Reset()
- func (m *TarStrategy) Size() (n int)
- func (this *TarStrategy) String() string
- func (m *TarStrategy) Unmarshal(dAtA []byte) error
- func (m *TarStrategy) XXX_DiscardUnknown()
- func (m *TarStrategy) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *TarStrategy) XXX_Merge(src proto.Message)
- func (m *TarStrategy) XXX_Size() int
- func (m *TarStrategy) XXX_Unmarshal(b []byte) error
- type Template
- func (in *Template) DeepCopy() *Template
- func (in *Template) DeepCopyInto(out *Template)
- func (*Template) Descriptor() ([]byte, []int)
- 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
- func (m *Template) Marshal() (dAtA []byte, err error)
- func (m *Template) MarshalTo(dAtA []byte) (int, error)
- func (m *Template) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Template) ProtoMessage()
- func (m *Template) Reset()
- func (m *Template) Size() (n int)
- func (this *Template) String() string
- func (m *Template) Unmarshal(dAtA []byte) error
- func (m *Template) XXX_DiscardUnknown()
- func (m *Template) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Template) XXX_Merge(src proto.Message)
- func (m *Template) XXX_Size() int
- func (m *Template) XXX_Unmarshal(b []byte) error
- type TemplateGetter
- type TemplateHolder
- type TemplateRef
- func (in *TemplateRef) DeepCopy() *TemplateRef
- func (in *TemplateRef) DeepCopyInto(out *TemplateRef)
- func (*TemplateRef) Descriptor() ([]byte, []int)
- func (m *TemplateRef) Marshal() (dAtA []byte, err error)
- func (m *TemplateRef) MarshalTo(dAtA []byte) (int, error)
- func (m *TemplateRef) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*TemplateRef) ProtoMessage()
- func (m *TemplateRef) Reset()
- func (m *TemplateRef) Size() (n int)
- func (this *TemplateRef) String() string
- func (m *TemplateRef) Unmarshal(dAtA []byte) error
- func (m *TemplateRef) XXX_DiscardUnknown()
- func (m *TemplateRef) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *TemplateRef) XXX_Merge(src proto.Message)
- func (m *TemplateRef) XXX_Size() int
- func (m *TemplateRef) XXX_Unmarshal(b []byte) error
- type TemplateStorage
- type TemplateType
- type Type
- type UserContainer
- func (in *UserContainer) DeepCopy() *UserContainer
- func (in *UserContainer) DeepCopyInto(out *UserContainer)
- func (*UserContainer) Descriptor() ([]byte, []int)
- func (m *UserContainer) Marshal() (dAtA []byte, err error)
- func (m *UserContainer) MarshalTo(dAtA []byte) (int, error)
- func (m *UserContainer) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*UserContainer) ProtoMessage()
- func (m *UserContainer) Reset()
- func (m *UserContainer) Size() (n int)
- func (this *UserContainer) String() string
- func (m *UserContainer) Unmarshal(dAtA []byte) error
- func (m *UserContainer) XXX_DiscardUnknown()
- func (m *UserContainer) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *UserContainer) XXX_Merge(src proto.Message)
- func (m *UserContainer) XXX_Size() int
- func (m *UserContainer) XXX_Unmarshal(b []byte) error
- type ValueFrom
- func (in *ValueFrom) DeepCopy() *ValueFrom
- func (in *ValueFrom) DeepCopyInto(out *ValueFrom)
- func (*ValueFrom) Descriptor() ([]byte, []int)
- func (m *ValueFrom) Marshal() (dAtA []byte, err error)
- func (m *ValueFrom) MarshalTo(dAtA []byte) (int, error)
- func (m *ValueFrom) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ValueFrom) ProtoMessage()
- func (m *ValueFrom) Reset()
- func (m *ValueFrom) Size() (n int)
- func (this *ValueFrom) String() string
- func (m *ValueFrom) Unmarshal(dAtA []byte) error
- func (m *ValueFrom) XXX_DiscardUnknown()
- func (m *ValueFrom) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ValueFrom) XXX_Merge(src proto.Message)
- func (m *ValueFrom) XXX_Size() int
- func (m *ValueFrom) XXX_Unmarshal(b []byte) error
- type Workflow
- func (in *Workflow) DeepCopy() *Workflow
- func (in *Workflow) DeepCopyInto(out *Workflow)
- func (in *Workflow) DeepCopyObject() runtime.Object
- func (*Workflow) Descriptor() ([]byte, []int)
- 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 (m *Workflow) Marshal() (dAtA []byte, err error)
- func (m *Workflow) MarshalTo(dAtA []byte) (int, error)
- func (m *Workflow) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (wf *Workflow) NodeID(name string) string
- func (*Workflow) ProtoMessage()
- func (m *Workflow) Reset()
- func (wf *Workflow) SetStoredTemplate(templateScope string, holder TemplateHolder, tmpl *Template) (bool, error)
- func (m *Workflow) Size() (n int)
- func (this *Workflow) String() string
- func (m *Workflow) Unmarshal(dAtA []byte) error
- func (m *Workflow) XXX_DiscardUnknown()
- func (m *Workflow) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Workflow) XXX_Merge(src proto.Message)
- func (m *Workflow) XXX_Size() int
- func (m *Workflow) XXX_Unmarshal(b []byte) error
- type WorkflowList
- func (in *WorkflowList) DeepCopy() *WorkflowList
- func (in *WorkflowList) DeepCopyInto(out *WorkflowList)
- func (in *WorkflowList) DeepCopyObject() runtime.Object
- func (*WorkflowList) Descriptor() ([]byte, []int)
- func (m *WorkflowList) Marshal() (dAtA []byte, err error)
- func (m *WorkflowList) MarshalTo(dAtA []byte) (int, error)
- func (m *WorkflowList) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*WorkflowList) ProtoMessage()
- func (m *WorkflowList) Reset()
- func (m *WorkflowList) Size() (n int)
- func (this *WorkflowList) String() string
- func (m *WorkflowList) Unmarshal(dAtA []byte) error
- func (m *WorkflowList) XXX_DiscardUnknown()
- func (m *WorkflowList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *WorkflowList) XXX_Merge(src proto.Message)
- func (m *WorkflowList) XXX_Size() int
- func (m *WorkflowList) XXX_Unmarshal(b []byte) error
- type WorkflowSpec
- func (in *WorkflowSpec) DeepCopy() *WorkflowSpec
- func (in *WorkflowSpec) DeepCopyInto(out *WorkflowSpec)
- func (*WorkflowSpec) Descriptor() ([]byte, []int)
- func (wfs *WorkflowSpec) HasPodSpecPatch() bool
- func (m *WorkflowSpec) Marshal() (dAtA []byte, err error)
- func (m *WorkflowSpec) MarshalTo(dAtA []byte) (int, error)
- func (m *WorkflowSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*WorkflowSpec) ProtoMessage()
- func (m *WorkflowSpec) Reset()
- func (m *WorkflowSpec) Size() (n int)
- func (this *WorkflowSpec) String() string
- func (m *WorkflowSpec) Unmarshal(dAtA []byte) error
- func (m *WorkflowSpec) XXX_DiscardUnknown()
- func (m *WorkflowSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *WorkflowSpec) XXX_Merge(src proto.Message)
- func (m *WorkflowSpec) XXX_Size() int
- func (m *WorkflowSpec) XXX_Unmarshal(b []byte) error
- type WorkflowStatus
- func (ws *WorkflowStatus) Completed() bool
- func (in *WorkflowStatus) DeepCopy() *WorkflowStatus
- func (in *WorkflowStatus) DeepCopyInto(out *WorkflowStatus)
- func (*WorkflowStatus) Descriptor() ([]byte, []int)
- func (ws *WorkflowStatus) Failed() bool
- func (ws *WorkflowStatus) GetOffloadNodeStatusVersion() string
- func (ws *WorkflowStatus) IsOffloadNodeStatus() bool
- func (m *WorkflowStatus) Marshal() (dAtA []byte, err error)
- func (m *WorkflowStatus) MarshalTo(dAtA []byte) (int, error)
- func (m *WorkflowStatus) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*WorkflowStatus) ProtoMessage()
- func (m *WorkflowStatus) Reset()
- func (m *WorkflowStatus) Size() (n int)
- func (this *WorkflowStatus) String() string
- func (ws *WorkflowStatus) Successful() bool
- func (m *WorkflowStatus) Unmarshal(dAtA []byte) error
- func (m *WorkflowStatus) XXX_DiscardUnknown()
- func (m *WorkflowStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *WorkflowStatus) XXX_Merge(src proto.Message)
- func (m *WorkflowStatus) XXX_Size() int
- func (m *WorkflowStatus) XXX_Unmarshal(b []byte) error
- type WorkflowStep
- func (s *WorkflowStep) ContinuesOn(phase NodePhase) bool
- func (in *WorkflowStep) DeepCopy() *WorkflowStep
- func (in *WorkflowStep) DeepCopyInto(out *WorkflowStep)
- func (*WorkflowStep) Descriptor() ([]byte, []int)
- func (step *WorkflowStep) GetTemplateName() string
- func (step *WorkflowStep) GetTemplateRef() *TemplateRef
- func (step *WorkflowStep) IsResolvable() bool
- func (m *WorkflowStep) Marshal() (dAtA []byte, err error)
- func (m *WorkflowStep) MarshalTo(dAtA []byte) (int, error)
- func (m *WorkflowStep) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*WorkflowStep) ProtoMessage()
- func (m *WorkflowStep) Reset()
- func (m *WorkflowStep) Size() (n int)
- func (this *WorkflowStep) String() string
- func (m *WorkflowStep) Unmarshal(dAtA []byte) error
- func (m *WorkflowStep) XXX_DiscardUnknown()
- func (m *WorkflowStep) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *WorkflowStep) XXX_Merge(src proto.Message)
- func (m *WorkflowStep) XXX_Size() int
- func (m *WorkflowStep) XXX_Unmarshal(b []byte) error
- type WorkflowTemplate
- func (in *WorkflowTemplate) DeepCopy() *WorkflowTemplate
- func (in *WorkflowTemplate) DeepCopyInto(out *WorkflowTemplate)
- func (in *WorkflowTemplate) DeepCopyObject() runtime.Object
- func (*WorkflowTemplate) Descriptor() ([]byte, []int)
- func (wftmpl *WorkflowTemplate) GetTemplateByName(name string) *Template
- func (wftmpl *WorkflowTemplate) GetTemplateScope() string
- func (m *WorkflowTemplate) Marshal() (dAtA []byte, err error)
- func (m *WorkflowTemplate) MarshalTo(dAtA []byte) (int, error)
- func (m *WorkflowTemplate) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*WorkflowTemplate) ProtoMessage()
- func (m *WorkflowTemplate) Reset()
- func (m *WorkflowTemplate) Size() (n int)
- func (this *WorkflowTemplate) String() string
- func (m *WorkflowTemplate) Unmarshal(dAtA []byte) error
- func (m *WorkflowTemplate) XXX_DiscardUnknown()
- func (m *WorkflowTemplate) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *WorkflowTemplate) XXX_Merge(src proto.Message)
- func (m *WorkflowTemplate) XXX_Size() int
- func (m *WorkflowTemplate) XXX_Unmarshal(b []byte) error
- type WorkflowTemplateList
- func (in *WorkflowTemplateList) DeepCopy() *WorkflowTemplateList
- func (in *WorkflowTemplateList) DeepCopyInto(out *WorkflowTemplateList)
- func (in *WorkflowTemplateList) DeepCopyObject() runtime.Object
- func (*WorkflowTemplateList) Descriptor() ([]byte, []int)
- func (m *WorkflowTemplateList) Marshal() (dAtA []byte, err error)
- func (m *WorkflowTemplateList) MarshalTo(dAtA []byte) (int, error)
- func (m *WorkflowTemplateList) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*WorkflowTemplateList) ProtoMessage()
- func (m *WorkflowTemplateList) Reset()
- func (m *WorkflowTemplateList) Size() (n int)
- func (this *WorkflowTemplateList) String() string
- func (m *WorkflowTemplateList) Unmarshal(dAtA []byte) error
- func (m *WorkflowTemplateList) XXX_DiscardUnknown()
- func (m *WorkflowTemplateList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *WorkflowTemplateList) XXX_Merge(src proto.Message)
- func (m *WorkflowTemplateList) XXX_Size() int
- func (m *WorkflowTemplateList) XXX_Unmarshal(b []byte) error
- type WorkflowTemplateSpec
- func (in *WorkflowTemplateSpec) DeepCopy() *WorkflowTemplateSpec
- func (in *WorkflowTemplateSpec) DeepCopyInto(out *WorkflowTemplateSpec)
- func (*WorkflowTemplateSpec) Descriptor() ([]byte, []int)
- func (m *WorkflowTemplateSpec) Marshal() (dAtA []byte, err error)
- func (m *WorkflowTemplateSpec) MarshalTo(dAtA []byte) (int, error)
- func (m *WorkflowTemplateSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*WorkflowTemplateSpec) ProtoMessage()
- func (m *WorkflowTemplateSpec) Reset()
- func (m *WorkflowTemplateSpec) Size() (n int)
- func (this *WorkflowTemplateSpec) String() string
- func (m *WorkflowTemplateSpec) Unmarshal(dAtA []byte) error
- func (m *WorkflowTemplateSpec) XXX_DiscardUnknown()
- func (m *WorkflowTemplateSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *WorkflowTemplateSpec) XXX_Merge(src proto.Message)
- func (m *WorkflowTemplateSpec) XXX_Size() int
- func (m *WorkflowTemplateSpec) XXX_Unmarshal(b []byte) error
- type WorkflowTemplates
- type Workflows
Constants ¶
This section is empty.
Variables ¶
var ( ErrInvalidLengthGenerated = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowGenerated = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupGenerated = fmt.Errorf("proto: unexpected end of group") )
var ( SchemeGroupVersion = schema.GroupVersion{Group: workflow.Group, Version: "v1alpha1"} WorkflowSchemaGroupVersionKind = schema.GroupVersionKind{Group: workflow.Group, Version: "v1alpha1", Kind: workflow.WorkflowKind} )
SchemeGroupVersion is group version used to register these objects
var ( SchemeBuilder = runtime.NewSchemeBuilder(addKnownTypes) AddToScheme = SchemeBuilder.AddToScheme )
Functions ¶
func GetOpenAPIDefinitions ¶
func GetOpenAPIDefinitions(ref common.ReferenceCallback) map[string]common.OpenAPIDefinition
func Resource ¶
func Resource(resource string) schema.GroupResource
Resource takes an unqualified resource and returns a Group-qualified GroupResource.
Types ¶
type ArchiveStrategy ¶
type ArchiveStrategy struct { Tar *TarStrategy `json:"tar,omitempty" protobuf:"bytes,1,opt,name=tar"` None *NoneStrategy `json:"none,omitempty" protobuf:"bytes,2,opt,name=none"` }
ArchiveStrategy describes how to archive files/directory when saving artifacts
func (*ArchiveStrategy) DeepCopy ¶
func (in *ArchiveStrategy) DeepCopy() *ArchiveStrategy
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ArchiveStrategy.
func (*ArchiveStrategy) DeepCopyInto ¶
func (in *ArchiveStrategy) DeepCopyInto(out *ArchiveStrategy)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*ArchiveStrategy) Descriptor ¶
func (*ArchiveStrategy) Descriptor() ([]byte, []int)
func (*ArchiveStrategy) Marshal ¶
func (m *ArchiveStrategy) Marshal() (dAtA []byte, err error)
func (*ArchiveStrategy) MarshalToSizedBuffer ¶
func (m *ArchiveStrategy) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ArchiveStrategy) ProtoMessage ¶
func (*ArchiveStrategy) ProtoMessage()
func (*ArchiveStrategy) Reset ¶
func (m *ArchiveStrategy) Reset()
func (*ArchiveStrategy) Size ¶
func (m *ArchiveStrategy) Size() (n int)
func (*ArchiveStrategy) String ¶
func (this *ArchiveStrategy) String() string
func (*ArchiveStrategy) Unmarshal ¶
func (m *ArchiveStrategy) Unmarshal(dAtA []byte) error
func (*ArchiveStrategy) XXX_DiscardUnknown ¶
func (m *ArchiveStrategy) XXX_DiscardUnknown()
func (*ArchiveStrategy) XXX_Marshal ¶
func (m *ArchiveStrategy) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ArchiveStrategy) XXX_Merge ¶
func (m *ArchiveStrategy) XXX_Merge(src proto.Message)
func (*ArchiveStrategy) XXX_Size ¶
func (m *ArchiveStrategy) XXX_Size() int
func (*ArchiveStrategy) XXX_Unmarshal ¶
func (m *ArchiveStrategy) XXX_Unmarshal(b []byte) error
type Arguments ¶
type Arguments struct { // Parameters is the list of parameters to pass to the template or workflow // +patchStrategy=merge // +patchMergeKey=name Parameters []Parameter `json:"parameters,omitempty" patchStrategy:"merge" patchMergeKey:"name" protobuf:"bytes,1,rep,name=parameters"` // Artifacts is the list of artifacts to pass to the template or workflow // +patchStrategy=merge // +patchMergeKey=name Artifacts Artifacts `json:"artifacts,omitempty" patchStrategy:"merge" patchMergeKey:"name" protobuf:"bytes,2,rep,name=artifacts"` }
Arguments to a template
func (*Arguments) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Arguments.
func (*Arguments) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*Arguments) Descriptor ¶
func (*Arguments) GetArtifactByName ¶
GetArtifactByName retrieves an artifact by its name
func (*Arguments) GetParameterByName ¶
GetParameterByName retrieves a parameter by its name
func (*Arguments) MarshalToSizedBuffer ¶
func (*Arguments) ProtoMessage ¶
func (*Arguments) ProtoMessage()
func (*Arguments) XXX_DiscardUnknown ¶
func (m *Arguments) XXX_DiscardUnknown()
func (*Arguments) XXX_Marshal ¶
func (*Arguments) XXX_Unmarshal ¶
type ArgumentsProvider ¶
type Artifact ¶
type Artifact struct { // name of the artifact. must be unique within a template's inputs/outputs. Name string `json:"name" protobuf:"bytes,1,opt,name=name"` // Path is the container path to the artifact Path string `json:"path,omitempty" protobuf:"bytes,2,opt,name=path"` // mode bits to use on this file, must be a value between 0 and 0777 // set when loading input artifacts. Mode *int32 `json:"mode,omitempty" protobuf:"varint,3,opt,name=mode"` // From allows an artifact to reference an artifact from a previous step From string `json:"from,omitempty" protobuf:"bytes,4,opt,name=from"` // ArtifactLocation contains the location of the artifact ArtifactLocation `json:",inline" protobuf:"bytes,5,opt,name=artifactLocation"` // GlobalName exports an output artifact to the global scope, making it available as // '{{workflow.outputs.artifacts.XXXX}} and in workflow.status.outputs.artifacts GlobalName string `json:"globalName,omitempty" protobuf:"bytes,6,opt,name=globalName"` // Archive controls how the artifact will be saved to the artifact repository. Archive *ArchiveStrategy `json:"archive,omitempty" protobuf:"bytes,7,opt,name=archive"` // Make Artifacts optional, if Artifacts doesn't generate or exist Optional bool `json:"optional,omitempty" protobuf:"varint,8,opt,name=optional"` }
Artifact indicates an artifact to place at a specified path
func (*Artifact) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Artifact.
func (*Artifact) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*Artifact) Descriptor ¶
func (*Artifact) HasLocation ¶
HasLocation whether or not an artifact has a location defined
func (*Artifact) MarshalToSizedBuffer ¶
func (*Artifact) ProtoMessage ¶
func (*Artifact) ProtoMessage()
func (*Artifact) XXX_DiscardUnknown ¶
func (m *Artifact) XXX_DiscardUnknown()
func (*Artifact) XXX_Marshal ¶
func (*Artifact) XXX_Unmarshal ¶
type ArtifactLocation ¶
type ArtifactLocation struct { // ArchiveLogs indicates if the container logs should be archived ArchiveLogs *bool `json:"archiveLogs,omitempty" protobuf:"varint,1,opt,name=archiveLogs"` // S3 contains S3 artifact location details S3 *S3Artifact `json:"s3,omitempty" protobuf:"bytes,2,opt,name=s3"` // Git contains git artifact location details Git *GitArtifact `json:"git,omitempty" protobuf:"bytes,3,opt,name=git"` // HTTP contains HTTP artifact location details HTTP *HTTPArtifact `json:"http,omitempty" protobuf:"bytes,4,opt,name=http"` // Artifactory contains artifactory artifact location details Artifactory *ArtifactoryArtifact `json:"artifactory,omitempty" protobuf:"bytes,5,opt,name=artifactory"` // HDFS contains HDFS artifact location details HDFS *HDFSArtifact `json:"hdfs,omitempty" protobuf:"bytes,6,opt,name=hdfs"` // Raw contains raw artifact location details Raw *RawArtifact `json:"raw,omitempty" protobuf:"bytes,7,opt,name=raw"` }
ArtifactLocation describes a location for a single or multiple artifacts. It is used as single artifact in the context of inputs/outputs (e.g. outputs.artifacts.artname). It is also used to describe the location of multiple artifacts such as the archive location of a single workflow step, which the executor will use as a default location to store its files.
func (*ArtifactLocation) DeepCopy ¶
func (in *ArtifactLocation) DeepCopy() *ArtifactLocation
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ArtifactLocation.
func (*ArtifactLocation) DeepCopyInto ¶
func (in *ArtifactLocation) DeepCopyInto(out *ArtifactLocation)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*ArtifactLocation) Descriptor ¶
func (*ArtifactLocation) Descriptor() ([]byte, []int)
func (*ArtifactLocation) Marshal ¶
func (m *ArtifactLocation) Marshal() (dAtA []byte, err error)
func (*ArtifactLocation) MarshalToSizedBuffer ¶
func (m *ArtifactLocation) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ArtifactLocation) ProtoMessage ¶
func (*ArtifactLocation) ProtoMessage()
func (*ArtifactLocation) Reset ¶
func (m *ArtifactLocation) Reset()
func (*ArtifactLocation) Size ¶
func (m *ArtifactLocation) Size() (n int)
func (*ArtifactLocation) String ¶
func (this *ArtifactLocation) String() string
func (*ArtifactLocation) Unmarshal ¶
func (m *ArtifactLocation) Unmarshal(dAtA []byte) error
func (*ArtifactLocation) XXX_DiscardUnknown ¶
func (m *ArtifactLocation) XXX_DiscardUnknown()
func (*ArtifactLocation) XXX_Marshal ¶
func (m *ArtifactLocation) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ArtifactLocation) XXX_Merge ¶
func (m *ArtifactLocation) XXX_Merge(src proto.Message)
func (*ArtifactLocation) XXX_Size ¶
func (m *ArtifactLocation) XXX_Size() int
func (*ArtifactLocation) XXX_Unmarshal ¶
func (m *ArtifactLocation) XXX_Unmarshal(b []byte) error
type ArtifactRepositoryRef ¶
type ArtifactRepositoryRef struct { ConfigMap string `json:"configMap,omitempty" protobuf:"bytes,1,opt,name=configMap"` Key string `json:"key,omitempty" protobuf:"bytes,2,opt,name=key"` }
func (*ArtifactRepositoryRef) DeepCopy ¶
func (in *ArtifactRepositoryRef) DeepCopy() *ArtifactRepositoryRef
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ArtifactRepositoryRef.
func (*ArtifactRepositoryRef) DeepCopyInto ¶
func (in *ArtifactRepositoryRef) DeepCopyInto(out *ArtifactRepositoryRef)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*ArtifactRepositoryRef) Descriptor ¶
func (*ArtifactRepositoryRef) Descriptor() ([]byte, []int)
func (*ArtifactRepositoryRef) Marshal ¶
func (m *ArtifactRepositoryRef) Marshal() (dAtA []byte, err error)
func (*ArtifactRepositoryRef) MarshalTo ¶
func (m *ArtifactRepositoryRef) MarshalTo(dAtA []byte) (int, error)
func (*ArtifactRepositoryRef) MarshalToSizedBuffer ¶
func (m *ArtifactRepositoryRef) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ArtifactRepositoryRef) ProtoMessage ¶
func (*ArtifactRepositoryRef) ProtoMessage()
func (*ArtifactRepositoryRef) Reset ¶
func (m *ArtifactRepositoryRef) Reset()
func (*ArtifactRepositoryRef) Size ¶
func (m *ArtifactRepositoryRef) Size() (n int)
func (*ArtifactRepositoryRef) String ¶
func (this *ArtifactRepositoryRef) String() string
func (*ArtifactRepositoryRef) Unmarshal ¶
func (m *ArtifactRepositoryRef) Unmarshal(dAtA []byte) error
func (*ArtifactRepositoryRef) XXX_DiscardUnknown ¶
func (m *ArtifactRepositoryRef) XXX_DiscardUnknown()
func (*ArtifactRepositoryRef) XXX_Marshal ¶
func (m *ArtifactRepositoryRef) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ArtifactRepositoryRef) XXX_Merge ¶
func (m *ArtifactRepositoryRef) XXX_Merge(src proto.Message)
func (*ArtifactRepositoryRef) XXX_Size ¶
func (m *ArtifactRepositoryRef) XXX_Size() int
func (*ArtifactRepositoryRef) XXX_Unmarshal ¶
func (m *ArtifactRepositoryRef) XXX_Unmarshal(b []byte) error
type ArtifactoryArtifact ¶
type ArtifactoryArtifact struct { // URL of the artifact URL string `json:"url" protobuf:"bytes,1,opt,name=url"` ArtifactoryAuth `json:",inline" protobuf:"bytes,2,opt,name=artifactoryAuth"` }
ArtifactoryArtifact is the location of an artifactory artifact
func (*ArtifactoryArtifact) DeepCopy ¶
func (in *ArtifactoryArtifact) DeepCopy() *ArtifactoryArtifact
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ArtifactoryArtifact.
func (*ArtifactoryArtifact) DeepCopyInto ¶
func (in *ArtifactoryArtifact) DeepCopyInto(out *ArtifactoryArtifact)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*ArtifactoryArtifact) Descriptor ¶
func (*ArtifactoryArtifact) Descriptor() ([]byte, []int)
func (*ArtifactoryArtifact) HasLocation ¶
func (a *ArtifactoryArtifact) HasLocation() bool
func (*ArtifactoryArtifact) Marshal ¶
func (m *ArtifactoryArtifact) Marshal() (dAtA []byte, err error)
func (*ArtifactoryArtifact) MarshalTo ¶
func (m *ArtifactoryArtifact) MarshalTo(dAtA []byte) (int, error)
func (*ArtifactoryArtifact) MarshalToSizedBuffer ¶
func (m *ArtifactoryArtifact) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ArtifactoryArtifact) ProtoMessage ¶
func (*ArtifactoryArtifact) ProtoMessage()
func (*ArtifactoryArtifact) Reset ¶
func (m *ArtifactoryArtifact) Reset()
func (*ArtifactoryArtifact) Size ¶
func (m *ArtifactoryArtifact) Size() (n int)
func (*ArtifactoryArtifact) String ¶
func (this *ArtifactoryArtifact) String() string
func (*ArtifactoryArtifact) Unmarshal ¶
func (m *ArtifactoryArtifact) Unmarshal(dAtA []byte) error
func (*ArtifactoryArtifact) XXX_DiscardUnknown ¶
func (m *ArtifactoryArtifact) XXX_DiscardUnknown()
func (*ArtifactoryArtifact) XXX_Marshal ¶
func (m *ArtifactoryArtifact) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ArtifactoryArtifact) XXX_Merge ¶
func (m *ArtifactoryArtifact) XXX_Merge(src proto.Message)
func (*ArtifactoryArtifact) XXX_Size ¶
func (m *ArtifactoryArtifact) XXX_Size() int
func (*ArtifactoryArtifact) XXX_Unmarshal ¶
func (m *ArtifactoryArtifact) XXX_Unmarshal(b []byte) error
type ArtifactoryAuth ¶
type ArtifactoryAuth struct { // UsernameSecret is the secret selector to the repository username UsernameSecret *apiv1.SecretKeySelector `json:"usernameSecret,omitempty" protobuf:"bytes,1,opt,name=usernameSecret"` // PasswordSecret is the secret selector to the repository password PasswordSecret *apiv1.SecretKeySelector `json:"passwordSecret,omitempty" protobuf:"bytes,2,opt,name=passwordSecret"` }
ArtifactoryAuth describes the secret selectors required for authenticating to artifactory
func (*ArtifactoryAuth) DeepCopy ¶
func (in *ArtifactoryAuth) DeepCopy() *ArtifactoryAuth
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ArtifactoryAuth.
func (*ArtifactoryAuth) DeepCopyInto ¶
func (in *ArtifactoryAuth) DeepCopyInto(out *ArtifactoryAuth)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*ArtifactoryAuth) Descriptor ¶
func (*ArtifactoryAuth) Descriptor() ([]byte, []int)
func (*ArtifactoryAuth) Marshal ¶
func (m *ArtifactoryAuth) Marshal() (dAtA []byte, err error)
func (*ArtifactoryAuth) MarshalToSizedBuffer ¶
func (m *ArtifactoryAuth) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ArtifactoryAuth) ProtoMessage ¶
func (*ArtifactoryAuth) ProtoMessage()
func (*ArtifactoryAuth) Reset ¶
func (m *ArtifactoryAuth) Reset()
func (*ArtifactoryAuth) Size ¶
func (m *ArtifactoryAuth) Size() (n int)
func (*ArtifactoryAuth) String ¶
func (this *ArtifactoryAuth) String() string
func (*ArtifactoryAuth) Unmarshal ¶
func (m *ArtifactoryAuth) Unmarshal(dAtA []byte) error
func (*ArtifactoryAuth) XXX_DiscardUnknown ¶
func (m *ArtifactoryAuth) XXX_DiscardUnknown()
func (*ArtifactoryAuth) XXX_Marshal ¶
func (m *ArtifactoryAuth) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ArtifactoryAuth) XXX_Merge ¶
func (m *ArtifactoryAuth) XXX_Merge(src proto.Message)
func (*ArtifactoryAuth) XXX_Size ¶
func (m *ArtifactoryAuth) XXX_Size() int
func (*ArtifactoryAuth) XXX_Unmarshal ¶
func (m *ArtifactoryAuth) XXX_Unmarshal(b []byte) error
type Artifacts ¶
type Artifacts []Artifact
func (Artifacts) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Artifacts.
func (Artifacts) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (Artifacts) GetArtifactByName ¶
type Backoff ¶
type Backoff struct { Duration string `json:"duration,omitempty" protobuf:"varint,1,opt,name=duration"` Factor int32 `json:"factor,omitempty" protobuf:"varint,2,opt,name=factor"` MaxDuration string `json:"maxDuration,omitempty" protobuf:"varint,3,opt,name=maxDuration"` }
func (*Backoff) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Backoff.
func (*Backoff) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*Backoff) Descriptor ¶
func (*Backoff) MarshalToSizedBuffer ¶
func (*Backoff) ProtoMessage ¶
func (*Backoff) ProtoMessage()
func (*Backoff) XXX_DiscardUnknown ¶
func (m *Backoff) XXX_DiscardUnknown()
func (*Backoff) XXX_Marshal ¶
func (*Backoff) XXX_Unmarshal ¶
type ConcurrencyPolicy ¶
type ConcurrencyPolicy string
const ( AllowConcurrent ConcurrencyPolicy = "Allow" ForbidConcurrent ConcurrencyPolicy = "Forbid" ReplaceConcurrent ConcurrencyPolicy = "Replace" )
type ContinueOn ¶
type ContinueOn struct { // +optional Error bool `json:"error,omitempty" protobuf:"varint,1,opt,name=error"` // +optional Failed bool `json:"failed,omitempty" protobuf:"varint,2,opt,name=failed"` }
ContinueOn defines if a workflow should continue even if a task or step fails/errors. It can be specified if the workflow should continue when the pod errors, fails or both.
func (*ContinueOn) DeepCopy ¶
func (in *ContinueOn) DeepCopy() *ContinueOn
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ContinueOn.
func (*ContinueOn) DeepCopyInto ¶
func (in *ContinueOn) DeepCopyInto(out *ContinueOn)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*ContinueOn) Descriptor ¶
func (*ContinueOn) Descriptor() ([]byte, []int)
func (*ContinueOn) Marshal ¶
func (m *ContinueOn) Marshal() (dAtA []byte, err error)
func (*ContinueOn) MarshalToSizedBuffer ¶
func (m *ContinueOn) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ContinueOn) ProtoMessage ¶
func (*ContinueOn) ProtoMessage()
func (*ContinueOn) Reset ¶
func (m *ContinueOn) Reset()
func (*ContinueOn) Size ¶
func (m *ContinueOn) Size() (n int)
func (*ContinueOn) String ¶
func (this *ContinueOn) String() string
func (*ContinueOn) Unmarshal ¶
func (m *ContinueOn) Unmarshal(dAtA []byte) error
func (*ContinueOn) XXX_DiscardUnknown ¶
func (m *ContinueOn) XXX_DiscardUnknown()
func (*ContinueOn) XXX_Marshal ¶
func (m *ContinueOn) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ContinueOn) XXX_Merge ¶
func (m *ContinueOn) XXX_Merge(src proto.Message)
func (*ContinueOn) XXX_Size ¶
func (m *ContinueOn) XXX_Size() int
func (*ContinueOn) XXX_Unmarshal ¶
func (m *ContinueOn) XXX_Unmarshal(b []byte) error
type CronWorkflow ¶
type CronWorkflow struct { metav1.TypeMeta `json:",inline"` metav1.ObjectMeta `json:"metadata,omitempty" protobuf:"bytes,1,opt,name=metadata"` Spec CronWorkflowSpec `json:"spec" protobuf:"bytes,2,opt,name=spec"` Status CronWorkflowStatus `json:"status" protobuf:"bytes,3,opt,name=status"` }
CronWorkflow is the definition of a scheduled workflow resource +genclient +genclient:noStatus +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object
func (*CronWorkflow) DeepCopy ¶
func (in *CronWorkflow) DeepCopy() *CronWorkflow
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CronWorkflow.
func (*CronWorkflow) DeepCopyInto ¶
func (in *CronWorkflow) DeepCopyInto(out *CronWorkflow)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*CronWorkflow) DeepCopyObject ¶
func (in *CronWorkflow) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
func (*CronWorkflow) Descriptor ¶
func (*CronWorkflow) Descriptor() ([]byte, []int)
func (*CronWorkflow) Marshal ¶
func (m *CronWorkflow) Marshal() (dAtA []byte, err error)
func (*CronWorkflow) MarshalToSizedBuffer ¶
func (m *CronWorkflow) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*CronWorkflow) ProtoMessage ¶
func (*CronWorkflow) ProtoMessage()
func (*CronWorkflow) Reset ¶
func (m *CronWorkflow) Reset()
func (*CronWorkflow) Size ¶
func (m *CronWorkflow) Size() (n int)
func (*CronWorkflow) String ¶
func (this *CronWorkflow) String() string
func (*CronWorkflow) Unmarshal ¶
func (m *CronWorkflow) Unmarshal(dAtA []byte) error
func (*CronWorkflow) XXX_DiscardUnknown ¶
func (m *CronWorkflow) XXX_DiscardUnknown()
func (*CronWorkflow) XXX_Marshal ¶
func (m *CronWorkflow) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CronWorkflow) XXX_Merge ¶
func (m *CronWorkflow) XXX_Merge(src proto.Message)
func (*CronWorkflow) XXX_Size ¶
func (m *CronWorkflow) XXX_Size() int
func (*CronWorkflow) XXX_Unmarshal ¶
func (m *CronWorkflow) XXX_Unmarshal(b []byte) error
type CronWorkflowList ¶
type CronWorkflowList struct { metav1.TypeMeta `json:",inline"` metav1.ListMeta `json:"metadata" protobuf:"bytes,1,opt,name=metadata"` Items []CronWorkflow `json:"items" protobuf:"bytes,2,rep,name=items"` }
CronWorkflowList is list of CronWorkflow resources +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object
func (*CronWorkflowList) DeepCopy ¶
func (in *CronWorkflowList) DeepCopy() *CronWorkflowList
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CronWorkflowList.
func (*CronWorkflowList) DeepCopyInto ¶
func (in *CronWorkflowList) DeepCopyInto(out *CronWorkflowList)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*CronWorkflowList) DeepCopyObject ¶
func (in *CronWorkflowList) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
func (*CronWorkflowList) Descriptor ¶
func (*CronWorkflowList) Descriptor() ([]byte, []int)
func (*CronWorkflowList) Marshal ¶
func (m *CronWorkflowList) Marshal() (dAtA []byte, err error)
func (*CronWorkflowList) MarshalToSizedBuffer ¶
func (m *CronWorkflowList) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*CronWorkflowList) ProtoMessage ¶
func (*CronWorkflowList) ProtoMessage()
func (*CronWorkflowList) Reset ¶
func (m *CronWorkflowList) Reset()
func (*CronWorkflowList) Size ¶
func (m *CronWorkflowList) Size() (n int)
func (*CronWorkflowList) String ¶
func (this *CronWorkflowList) String() string
func (*CronWorkflowList) Unmarshal ¶
func (m *CronWorkflowList) Unmarshal(dAtA []byte) error
func (*CronWorkflowList) XXX_DiscardUnknown ¶
func (m *CronWorkflowList) XXX_DiscardUnknown()
func (*CronWorkflowList) XXX_Marshal ¶
func (m *CronWorkflowList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CronWorkflowList) XXX_Merge ¶
func (m *CronWorkflowList) XXX_Merge(src proto.Message)
func (*CronWorkflowList) XXX_Size ¶
func (m *CronWorkflowList) XXX_Size() int
func (*CronWorkflowList) XXX_Unmarshal ¶
func (m *CronWorkflowList) XXX_Unmarshal(b []byte) error
type CronWorkflowSpec ¶
type CronWorkflowSpec struct { // WorkflowSpec is the spec of the workflow to be run WorkflowSpec WorkflowSpec `json:"workflowSpec" protobuf:"bytes,1,opt,name=workflowSpec,casttype=WorkflowSpec"` // Schedule is a schedule to run the Workflow in Cron format Schedule string `json:"schedule" protobuf:"bytes,2,opt,name=schedule"` // ConcurrencyPolicy is the K8s-style concurrency policy that will be used ConcurrencyPolicy ConcurrencyPolicy `json:"concurrencyPolicy,omitempty" protobuf:"bytes,3,opt,name=concurrencyPolicy,casttype=ConcurrencyPolicy"` // Suspend is a flag that will stop new CronWorkflows from running if set to true Suspend bool `json:"suspend,omitempty" protobuf:"varint,4,opt,name=suspend"` // StartingDeadlineSeconds is the K8s-style deadline that will limit the time a CronWorkflow will be run after its // original scheduled time if it is missed. StartingDeadlineSeconds *int64 `json:"startingDeadlineSeconds,omitempty" protobuf:"varint,5,opt,name=startingDeadlineSeconds"` // SuccessfulJobsHistoryLimit is the number of successful jobs to be kept at a time SuccessfulJobsHistoryLimit *int32 `json:"successfulJobsHistoryLimit,omitempty" protobuf:"varint,6,opt,name=successfulJobsHistoryLimit"` // FailedJobsHistoryLimit is the number of successful jobs to be kept at a time FailedJobsHistoryLimit *int32 `json:"failedJobsHistoryLimit,omitempty" protobuf:"varint,7,opt,name=failedJobsHistoryLimit"` // Timezone is the timezone against which the cron schedule will be calculated, e.g. "Asia/Tokyo". Default is machine's local time. Timezone string `json:"timezone,omitempty" protobuf:"bytes,8,opt,name=timezone"` }
func (*CronWorkflowSpec) DeepCopy ¶
func (in *CronWorkflowSpec) DeepCopy() *CronWorkflowSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CronWorkflowSpec.
func (*CronWorkflowSpec) DeepCopyInto ¶
func (in *CronWorkflowSpec) DeepCopyInto(out *CronWorkflowSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*CronWorkflowSpec) Descriptor ¶
func (*CronWorkflowSpec) Descriptor() ([]byte, []int)
func (*CronWorkflowSpec) Marshal ¶
func (m *CronWorkflowSpec) Marshal() (dAtA []byte, err error)
func (*CronWorkflowSpec) MarshalToSizedBuffer ¶
func (m *CronWorkflowSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*CronWorkflowSpec) ProtoMessage ¶
func (*CronWorkflowSpec) ProtoMessage()
func (*CronWorkflowSpec) Reset ¶
func (m *CronWorkflowSpec) Reset()
func (*CronWorkflowSpec) Size ¶
func (m *CronWorkflowSpec) Size() (n int)
func (*CronWorkflowSpec) String ¶
func (this *CronWorkflowSpec) String() string
func (*CronWorkflowSpec) Unmarshal ¶
func (m *CronWorkflowSpec) Unmarshal(dAtA []byte) error
func (*CronWorkflowSpec) XXX_DiscardUnknown ¶
func (m *CronWorkflowSpec) XXX_DiscardUnknown()
func (*CronWorkflowSpec) XXX_Marshal ¶
func (m *CronWorkflowSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CronWorkflowSpec) XXX_Merge ¶
func (m *CronWorkflowSpec) XXX_Merge(src proto.Message)
func (*CronWorkflowSpec) XXX_Size ¶
func (m *CronWorkflowSpec) XXX_Size() int
func (*CronWorkflowSpec) XXX_Unmarshal ¶
func (m *CronWorkflowSpec) XXX_Unmarshal(b []byte) error
type CronWorkflowStatus ¶
type CronWorkflowStatus struct { // Active is a list of active workflows stemming from this CronWorkflow Active []v1.ObjectReference `json:"active,omitempty" protobuf:"bytes,1,rep,name=active"` // LastScheduleTime is the last time the CronWorkflow was scheduled LastScheduledTime *metav1.Time `json:"lastScheduledTime,omitempty" protobuf:"bytes,2,opt,name=lastScheduledTime"` }
func (*CronWorkflowStatus) DeepCopy ¶
func (in *CronWorkflowStatus) DeepCopy() *CronWorkflowStatus
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CronWorkflowStatus.
func (*CronWorkflowStatus) DeepCopyInto ¶
func (in *CronWorkflowStatus) DeepCopyInto(out *CronWorkflowStatus)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*CronWorkflowStatus) Descriptor ¶
func (*CronWorkflowStatus) Descriptor() ([]byte, []int)
func (*CronWorkflowStatus) Marshal ¶
func (m *CronWorkflowStatus) Marshal() (dAtA []byte, err error)
func (*CronWorkflowStatus) MarshalTo ¶
func (m *CronWorkflowStatus) MarshalTo(dAtA []byte) (int, error)
func (*CronWorkflowStatus) MarshalToSizedBuffer ¶
func (m *CronWorkflowStatus) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*CronWorkflowStatus) ProtoMessage ¶
func (*CronWorkflowStatus) ProtoMessage()
func (*CronWorkflowStatus) Reset ¶
func (m *CronWorkflowStatus) Reset()
func (*CronWorkflowStatus) Size ¶
func (m *CronWorkflowStatus) Size() (n int)
func (*CronWorkflowStatus) String ¶
func (this *CronWorkflowStatus) String() string
func (*CronWorkflowStatus) Unmarshal ¶
func (m *CronWorkflowStatus) Unmarshal(dAtA []byte) error
func (*CronWorkflowStatus) XXX_DiscardUnknown ¶
func (m *CronWorkflowStatus) XXX_DiscardUnknown()
func (*CronWorkflowStatus) XXX_Marshal ¶
func (m *CronWorkflowStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CronWorkflowStatus) XXX_Merge ¶
func (m *CronWorkflowStatus) XXX_Merge(src proto.Message)
func (*CronWorkflowStatus) XXX_Size ¶
func (m *CronWorkflowStatus) XXX_Size() int
func (*CronWorkflowStatus) XXX_Unmarshal ¶
func (m *CronWorkflowStatus) XXX_Unmarshal(b []byte) error
type DAGTask ¶
type DAGTask struct { // Name is the name of the target Name string `json:"name" protobuf:"bytes,1,opt,name=name"` // Name of template to execute Template string `json:"template" protobuf:"bytes,2,opt,name=template"` // Arguments are the parameter and artifact arguments to the template Arguments Arguments `json:"arguments,omitempty" protobuf:"bytes,3,opt,name=arguments"` // TemplateRef is the reference to the template resource to execute. TemplateRef *TemplateRef `json:"templateRef,omitempty" protobuf:"bytes,4,opt,name=templateRef"` // Dependencies are name of other targets which this depends on Dependencies []string `json:"dependencies,omitempty" protobuf:"bytes,5,rep,name=dependencies"` // WithItems expands a task into multiple parallel tasks from the items in the list WithItems []Item `json:"withItems,omitempty" protobuf:"bytes,6,rep,name=withItems"` // WithParam expands a task into multiple parallel tasks from the value in the parameter, // which is expected to be a JSON list. WithParam string `json:"withParam,omitempty" protobuf:"bytes,7,opt,name=withParam"` // WithSequence expands a task into a numeric sequence WithSequence *Sequence `json:"withSequence,omitempty" protobuf:"bytes,8,opt,name=withSequence"` // When is an expression in which the task should conditionally execute When string `json:"when,omitempty" protobuf:"bytes,9,opt,name=when"` // ContinueOn makes argo to proceed with the following step even if this step fails. // Errors and Failed states can be specified ContinueOn *ContinueOn `json:"continueOn,omitempty" protobuf:"bytes,10,opt,name=continueOn"` // OnExit is a template reference which is invoked at the end of the // template, irrespective of the success, failure, or error of the // primary template. OnExit string `json:"onExit,omitempty" protobuf:"bytes,11,opt,name=onExit"` }
DAGTask represents a node in the graph during DAG execution
func (*DAGTask) ContinuesOn ¶
ContinuesOn returns whether the DAG should be proceeded if the task fails or errors.
func (*DAGTask) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new DAGTask.
func (*DAGTask) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*DAGTask) Descriptor ¶
func (*DAGTask) GetTemplateName ¶
func (*DAGTask) GetTemplateRef ¶
func (t *DAGTask) GetTemplateRef() *TemplateRef
func (*DAGTask) IsResolvable ¶
func (*DAGTask) MarshalToSizedBuffer ¶
func (*DAGTask) ProtoMessage ¶
func (*DAGTask) ProtoMessage()
func (*DAGTask) XXX_DiscardUnknown ¶
func (m *DAGTask) XXX_DiscardUnknown()
func (*DAGTask) XXX_Marshal ¶
func (*DAGTask) XXX_Unmarshal ¶
type DAGTemplate ¶
type DAGTemplate struct { // Target are one or more names of targets to execute in a DAG Target string `json:"target,omitempty" protobuf:"bytes,1,opt,name=target"` // Tasks are a list of DAG tasks // +patchStrategy=merge // +patchMergeKey=name Tasks []DAGTask `json:"tasks" patchStrategy:"merge" patchMergeKey:"name" protobuf:"bytes,2,rep,name=tasks"` // This flag is for DAG logic. The DAG logic has a built-in "fail fast" feature to stop scheduling new steps, // as soon as it detects that one of the DAG nodes is failed. Then it waits until all DAG nodes are completed // before failing the DAG itself. // The FailFast flag default is true, if set to false, it will allow a DAG to run all branches of the DAG to // completion (either success or failure), regardless of the failed outcomes of branches in the DAG. // More info and example about this feature at https://github.com/argoproj/argo/issues/1442 FailFast *bool `json:"failFast,omitempty" protobuf:"varint,3,opt,name=failFast"` }
DAGTemplate is a template subtype for directed acyclic graph templates
func (*DAGTemplate) DeepCopy ¶
func (in *DAGTemplate) DeepCopy() *DAGTemplate
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new DAGTemplate.
func (*DAGTemplate) DeepCopyInto ¶
func (in *DAGTemplate) DeepCopyInto(out *DAGTemplate)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*DAGTemplate) Descriptor ¶
func (*DAGTemplate) Descriptor() ([]byte, []int)
func (*DAGTemplate) Marshal ¶
func (m *DAGTemplate) Marshal() (dAtA []byte, err error)
func (*DAGTemplate) MarshalToSizedBuffer ¶
func (m *DAGTemplate) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*DAGTemplate) ProtoMessage ¶
func (*DAGTemplate) ProtoMessage()
func (*DAGTemplate) Reset ¶
func (m *DAGTemplate) Reset()
func (*DAGTemplate) Size ¶
func (m *DAGTemplate) Size() (n int)
func (*DAGTemplate) String ¶
func (this *DAGTemplate) String() string
func (*DAGTemplate) Unmarshal ¶
func (m *DAGTemplate) Unmarshal(dAtA []byte) error
func (*DAGTemplate) XXX_DiscardUnknown ¶
func (m *DAGTemplate) XXX_DiscardUnknown()
func (*DAGTemplate) XXX_Marshal ¶
func (m *DAGTemplate) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*DAGTemplate) XXX_Merge ¶
func (m *DAGTemplate) XXX_Merge(src proto.Message)
func (*DAGTemplate) XXX_Size ¶
func (m *DAGTemplate) XXX_Size() int
func (*DAGTemplate) XXX_Unmarshal ¶
func (m *DAGTemplate) XXX_Unmarshal(b []byte) error
type ExecutorConfig ¶
type ExecutorConfig struct { // ServiceAccountName specifies the service account name of the executor container. ServiceAccountName string `json:"serviceAccountName,omitempty" protobuf:"bytes,1,opt,name=serviceAccountName"` }
ExecutorConfig holds configurations of an executor container.
func (*ExecutorConfig) DeepCopy ¶
func (in *ExecutorConfig) DeepCopy() *ExecutorConfig
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ExecutorConfig.
func (*ExecutorConfig) DeepCopyInto ¶
func (in *ExecutorConfig) DeepCopyInto(out *ExecutorConfig)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*ExecutorConfig) Descriptor ¶
func (*ExecutorConfig) Descriptor() ([]byte, []int)
func (*ExecutorConfig) Marshal ¶
func (m *ExecutorConfig) Marshal() (dAtA []byte, err error)
func (*ExecutorConfig) MarshalToSizedBuffer ¶
func (m *ExecutorConfig) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ExecutorConfig) ProtoMessage ¶
func (*ExecutorConfig) ProtoMessage()
func (*ExecutorConfig) Reset ¶
func (m *ExecutorConfig) Reset()
func (*ExecutorConfig) Size ¶
func (m *ExecutorConfig) Size() (n int)
func (*ExecutorConfig) String ¶
func (this *ExecutorConfig) String() string
func (*ExecutorConfig) Unmarshal ¶
func (m *ExecutorConfig) Unmarshal(dAtA []byte) error
func (*ExecutorConfig) XXX_DiscardUnknown ¶
func (m *ExecutorConfig) XXX_DiscardUnknown()
func (*ExecutorConfig) XXX_Marshal ¶
func (m *ExecutorConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ExecutorConfig) XXX_Merge ¶
func (m *ExecutorConfig) XXX_Merge(src proto.Message)
func (*ExecutorConfig) XXX_Size ¶
func (m *ExecutorConfig) XXX_Size() int
func (*ExecutorConfig) XXX_Unmarshal ¶
func (m *ExecutorConfig) XXX_Unmarshal(b []byte) error
type GitArtifact ¶
type GitArtifact struct { // Repo is the git repository Repo string `json:"repo" protobuf:"bytes,1,opt,name=repo"` // Revision is the git commit, tag, branch to checkout Revision string `json:"revision,omitempty" protobuf:"bytes,2,opt,name=revision"` // Depth specifies clones/fetches should be shallow and include the given // number of commits from the branch tip Depth *uint64 `json:"depth,omitempty" protobuf:"bytes,3,opt,name=depth"` // Fetch specifies a number of refs that should be fetched before checkout Fetch []string `json:"fetch,omitempty" protobuf:"bytes,4,rep,name=fetch"` // UsernameSecret is the secret selector to the repository username UsernameSecret *apiv1.SecretKeySelector `json:"usernameSecret,omitempty" protobuf:"bytes,5,opt,name=usernameSecret"` // PasswordSecret is the secret selector to the repository password PasswordSecret *apiv1.SecretKeySelector `json:"passwordSecret,omitempty" protobuf:"bytes,6,opt,name=passwordSecret"` // SSHPrivateKeySecret is the secret selector to the repository ssh private key SSHPrivateKeySecret *apiv1.SecretKeySelector `json:"sshPrivateKeySecret,omitempty" protobuf:"bytes,7,opt,name=sshPrivateKeySecret"` // InsecureIgnoreHostKey disables SSH strict host key checking during git clone InsecureIgnoreHostKey bool `json:"insecureIgnoreHostKey,omitempty" protobuf:"varint,8,opt,name=insecureIgnoreHostKey"` }
GitArtifact is the location of an git artifact
func (*GitArtifact) DeepCopy ¶
func (in *GitArtifact) DeepCopy() *GitArtifact
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new GitArtifact.
func (*GitArtifact) DeepCopyInto ¶
func (in *GitArtifact) DeepCopyInto(out *GitArtifact)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*GitArtifact) Descriptor ¶
func (*GitArtifact) Descriptor() ([]byte, []int)
func (*GitArtifact) HasLocation ¶
func (g *GitArtifact) HasLocation() bool
func (*GitArtifact) Marshal ¶
func (m *GitArtifact) Marshal() (dAtA []byte, err error)
func (*GitArtifact) MarshalToSizedBuffer ¶
func (m *GitArtifact) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*GitArtifact) ProtoMessage ¶
func (*GitArtifact) ProtoMessage()
func (*GitArtifact) Reset ¶
func (m *GitArtifact) Reset()
func (*GitArtifact) Size ¶
func (m *GitArtifact) Size() (n int)
func (*GitArtifact) String ¶
func (this *GitArtifact) String() string
func (*GitArtifact) Unmarshal ¶
func (m *GitArtifact) Unmarshal(dAtA []byte) error
func (*GitArtifact) XXX_DiscardUnknown ¶
func (m *GitArtifact) XXX_DiscardUnknown()
func (*GitArtifact) XXX_Marshal ¶
func (m *GitArtifact) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GitArtifact) XXX_Merge ¶
func (m *GitArtifact) XXX_Merge(src proto.Message)
func (*GitArtifact) XXX_Size ¶
func (m *GitArtifact) XXX_Size() int
func (*GitArtifact) XXX_Unmarshal ¶
func (m *GitArtifact) XXX_Unmarshal(b []byte) error
type HDFSArtifact ¶
type HDFSArtifact struct { HDFSConfig `json:",inline" protobuf:"bytes,1,opt,name=hDFSConfig"` // Path is a file path in HDFS Path string `json:"path" protobuf:"bytes,2,opt,name=path"` // Force copies a file forcibly even if it exists (default: false) Force bool `json:"force,omitempty" protobuf:"varint,3,opt,name=force"` }
HDFSArtifact is the location of an HDFS artifact
func (*HDFSArtifact) DeepCopy ¶
func (in *HDFSArtifact) DeepCopy() *HDFSArtifact
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new HDFSArtifact.
func (*HDFSArtifact) DeepCopyInto ¶
func (in *HDFSArtifact) DeepCopyInto(out *HDFSArtifact)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*HDFSArtifact) Descriptor ¶
func (*HDFSArtifact) Descriptor() ([]byte, []int)
func (*HDFSArtifact) HasLocation ¶
func (h *HDFSArtifact) HasLocation() bool
func (*HDFSArtifact) Marshal ¶
func (m *HDFSArtifact) Marshal() (dAtA []byte, err error)
func (*HDFSArtifact) MarshalToSizedBuffer ¶
func (m *HDFSArtifact) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*HDFSArtifact) ProtoMessage ¶
func (*HDFSArtifact) ProtoMessage()
func (*HDFSArtifact) Reset ¶
func (m *HDFSArtifact) Reset()
func (*HDFSArtifact) Size ¶
func (m *HDFSArtifact) Size() (n int)
func (*HDFSArtifact) String ¶
func (this *HDFSArtifact) String() string
func (*HDFSArtifact) Unmarshal ¶
func (m *HDFSArtifact) Unmarshal(dAtA []byte) error
func (*HDFSArtifact) XXX_DiscardUnknown ¶
func (m *HDFSArtifact) XXX_DiscardUnknown()
func (*HDFSArtifact) XXX_Marshal ¶
func (m *HDFSArtifact) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*HDFSArtifact) XXX_Merge ¶
func (m *HDFSArtifact) XXX_Merge(src proto.Message)
func (*HDFSArtifact) XXX_Size ¶
func (m *HDFSArtifact) XXX_Size() int
func (*HDFSArtifact) XXX_Unmarshal ¶
func (m *HDFSArtifact) XXX_Unmarshal(b []byte) error
type HDFSConfig ¶
type HDFSConfig struct { HDFSKrbConfig `json:",inline" protobuf:"bytes,1,opt,name=hDFSKrbConfig"` // Addresses is accessible addresses of HDFS name nodes Addresses []string `json:"addresses" protobuf:"bytes,2,rep,name=addresses"` // HDFSUser is the user to access HDFS file system. // It is ignored if either ccache or keytab is used. HDFSUser string `json:"hdfsUser,omitempty" protobuf:"bytes,3,opt,name=hdfsUser"` }
HDFSConfig is configurations for HDFS
func (*HDFSConfig) DeepCopy ¶
func (in *HDFSConfig) DeepCopy() *HDFSConfig
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new HDFSConfig.
func (*HDFSConfig) DeepCopyInto ¶
func (in *HDFSConfig) DeepCopyInto(out *HDFSConfig)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*HDFSConfig) Descriptor ¶
func (*HDFSConfig) Descriptor() ([]byte, []int)
func (*HDFSConfig) Marshal ¶
func (m *HDFSConfig) Marshal() (dAtA []byte, err error)
func (*HDFSConfig) MarshalToSizedBuffer ¶
func (m *HDFSConfig) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*HDFSConfig) ProtoMessage ¶
func (*HDFSConfig) ProtoMessage()
func (*HDFSConfig) Reset ¶
func (m *HDFSConfig) Reset()
func (*HDFSConfig) Size ¶
func (m *HDFSConfig) Size() (n int)
func (*HDFSConfig) String ¶
func (this *HDFSConfig) String() string
func (*HDFSConfig) Unmarshal ¶
func (m *HDFSConfig) Unmarshal(dAtA []byte) error
func (*HDFSConfig) XXX_DiscardUnknown ¶
func (m *HDFSConfig) XXX_DiscardUnknown()
func (*HDFSConfig) XXX_Marshal ¶
func (m *HDFSConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*HDFSConfig) XXX_Merge ¶
func (m *HDFSConfig) XXX_Merge(src proto.Message)
func (*HDFSConfig) XXX_Size ¶
func (m *HDFSConfig) XXX_Size() int
func (*HDFSConfig) XXX_Unmarshal ¶
func (m *HDFSConfig) XXX_Unmarshal(b []byte) error
type HDFSKrbConfig ¶
type HDFSKrbConfig struct { // KrbCCacheSecret is the secret selector for Kerberos ccache // Either ccache or keytab can be set to use Kerberos. KrbCCacheSecret *apiv1.SecretKeySelector `json:"krbCCacheSecret,omitempty" protobuf:"bytes,1,opt,name=krbCCacheSecret"` // KrbKeytabSecret is the secret selector for Kerberos keytab // Either ccache or keytab can be set to use Kerberos. KrbKeytabSecret *apiv1.SecretKeySelector `json:"krbKeytabSecret,omitempty" protobuf:"bytes,2,opt,name=krbKeytabSecret"` // KrbUsername is the Kerberos username used with Kerberos keytab // It must be set if keytab is used. KrbUsername string `json:"krbUsername,omitempty" protobuf:"bytes,3,opt,name=krbUsername"` // KrbRealm is the Kerberos realm used with Kerberos keytab // It must be set if keytab is used. KrbRealm string `json:"krbRealm,omitempty" protobuf:"bytes,4,opt,name=krbRealm"` // KrbConfig is the configmap selector for Kerberos config as string // It must be set if either ccache or keytab is used. KrbConfigConfigMap *apiv1.ConfigMapKeySelector `json:"krbConfigConfigMap,omitempty" protobuf:"bytes,5,opt,name=krbConfigConfigMap"` // KrbServicePrincipalName is the principal name of Kerberos service // It must be set if either ccache or keytab is used. KrbServicePrincipalName string `json:"krbServicePrincipalName,omitempty" protobuf:"bytes,6,opt,name=krbServicePrincipalName"` }
HDFSKrbConfig is auth configurations for Kerberos
func (*HDFSKrbConfig) DeepCopy ¶
func (in *HDFSKrbConfig) DeepCopy() *HDFSKrbConfig
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new HDFSKrbConfig.
func (*HDFSKrbConfig) DeepCopyInto ¶
func (in *HDFSKrbConfig) DeepCopyInto(out *HDFSKrbConfig)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*HDFSKrbConfig) Descriptor ¶
func (*HDFSKrbConfig) Descriptor() ([]byte, []int)
func (*HDFSKrbConfig) Marshal ¶
func (m *HDFSKrbConfig) Marshal() (dAtA []byte, err error)
func (*HDFSKrbConfig) MarshalToSizedBuffer ¶
func (m *HDFSKrbConfig) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*HDFSKrbConfig) ProtoMessage ¶
func (*HDFSKrbConfig) ProtoMessage()
func (*HDFSKrbConfig) Reset ¶
func (m *HDFSKrbConfig) Reset()
func (*HDFSKrbConfig) Size ¶
func (m *HDFSKrbConfig) Size() (n int)
func (*HDFSKrbConfig) String ¶
func (this *HDFSKrbConfig) String() string
func (*HDFSKrbConfig) Unmarshal ¶
func (m *HDFSKrbConfig) Unmarshal(dAtA []byte) error
func (*HDFSKrbConfig) XXX_DiscardUnknown ¶
func (m *HDFSKrbConfig) XXX_DiscardUnknown()
func (*HDFSKrbConfig) XXX_Marshal ¶
func (m *HDFSKrbConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*HDFSKrbConfig) XXX_Merge ¶
func (m *HDFSKrbConfig) XXX_Merge(src proto.Message)
func (*HDFSKrbConfig) XXX_Size ¶
func (m *HDFSKrbConfig) XXX_Size() int
func (*HDFSKrbConfig) XXX_Unmarshal ¶
func (m *HDFSKrbConfig) XXX_Unmarshal(b []byte) error
type HTTPArtifact ¶
type HTTPArtifact struct { // URL of the artifact URL string `json:"url" protobuf:"bytes,1,opt,name=url"` }
HTTPArtifact allows an file served on HTTP to be placed as an input artifact in a container
func (*HTTPArtifact) DeepCopy ¶
func (in *HTTPArtifact) DeepCopy() *HTTPArtifact
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new HTTPArtifact.
func (*HTTPArtifact) DeepCopyInto ¶
func (in *HTTPArtifact) DeepCopyInto(out *HTTPArtifact)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*HTTPArtifact) Descriptor ¶
func (*HTTPArtifact) Descriptor() ([]byte, []int)
func (*HTTPArtifact) HasLocation ¶
func (h *HTTPArtifact) HasLocation() bool
func (*HTTPArtifact) Marshal ¶
func (m *HTTPArtifact) Marshal() (dAtA []byte, err error)
func (*HTTPArtifact) MarshalToSizedBuffer ¶
func (m *HTTPArtifact) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*HTTPArtifact) ProtoMessage ¶
func (*HTTPArtifact) ProtoMessage()
func (*HTTPArtifact) Reset ¶
func (m *HTTPArtifact) Reset()
func (*HTTPArtifact) Size ¶
func (m *HTTPArtifact) Size() (n int)
func (*HTTPArtifact) String ¶
func (this *HTTPArtifact) String() string
func (*HTTPArtifact) Unmarshal ¶
func (m *HTTPArtifact) Unmarshal(dAtA []byte) error
func (*HTTPArtifact) XXX_DiscardUnknown ¶
func (m *HTTPArtifact) XXX_DiscardUnknown()
func (*HTTPArtifact) XXX_Marshal ¶
func (m *HTTPArtifact) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*HTTPArtifact) XXX_Merge ¶
func (m *HTTPArtifact) XXX_Merge(src proto.Message)
func (*HTTPArtifact) XXX_Size ¶
func (m *HTTPArtifact) XXX_Size() int
func (*HTTPArtifact) XXX_Unmarshal ¶
func (m *HTTPArtifact) XXX_Unmarshal(b []byte) error
type Inputs ¶
type Inputs struct { // Parameters are a list of parameters passed as inputs // +patchStrategy=merge // +patchMergeKey=name Parameters []Parameter `json:"parameters,omitempty" patchStrategy:"merge" patchMergeKey:"name" protobuf:"bytes,1,opt,name=parameters"` // Artifact are a list of artifacts passed as inputs // +patchStrategy=merge // +patchMergeKey=name Artifacts Artifacts `json:"artifacts,omitempty" patchStrategy:"merge" patchMergeKey:"name" protobuf:"bytes,2,opt,name=artifacts"` }
Inputs are the mechanism for passing parameters, artifacts, volumes from one template to another
func (*Inputs) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Inputs.
func (*Inputs) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*Inputs) Descriptor ¶
func (*Inputs) GetArtifactByName ¶
GetArtifactByName returns an input artifact by its name
func (*Inputs) GetParameterByName ¶
GetParameterByName returns an input parameter by its name
func (*Inputs) MarshalToSizedBuffer ¶
func (*Inputs) ProtoMessage ¶
func (*Inputs) ProtoMessage()
func (*Inputs) XXX_DiscardUnknown ¶
func (m *Inputs) XXX_DiscardUnknown()
func (*Inputs) XXX_Marshal ¶
func (*Inputs) XXX_Unmarshal ¶
type Item ¶
type Item struct { Type Type `protobuf:"bytes,1,opt,name=type,casttype=Type"` NumVal json.Number `protobuf:"bytes,2,opt,name=numVal"` BoolVal bool `protobuf:"bytes,3,opt,name=boolVal"` StrVal string `protobuf:"bytes,4,opt,name=strVal"` MapVal map[string]ItemValue `protobuf:"bytes,5,opt,name=mapVal"` ListVal []ItemValue `protobuf:"bytes,6,opt,name=listVal"` }
Item expands a single workflow step into multiple parallel steps The value of Item can be a map, string, bool, or number
+protobuf=true +protobuf.options.(gogoproto.goproto_stringer)=false +k8s:openapi-gen=true
func (*Item) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Item.
func (*Item) DeepCopyInto ¶
DeepCopyInto is an custom deepcopy function to deal with our use of the interface{} type
func (*Item) Descriptor ¶
func (Item) MarshalJSON ¶
MarshalJSON implements the json.Marshaller interface.
func (Item) OpenAPISchemaFormat ¶
OpenAPISchemaFormat is used by the kube-openapi generator when constructing the OpenAPI spec of this type.
func (Item) OpenAPISchemaType ¶
OpenAPISchemaType is used by the kube-openapi generator when constructing the OpenAPI spec of this type. See: https://github.com/kubernetes/kube-openapi/tree/master/pkg/generators
func (*Item) ProtoMessage ¶
func (*Item) ProtoMessage()
func (*Item) UnmarshalJSON ¶
UnmarshalJSON implements the json.Unmarshaller interface.
func (*Item) XXX_DiscardUnknown ¶
func (m *Item) XXX_DiscardUnknown()
func (*Item) XXX_Unmarshal ¶
type ItemValue ¶
type ItemValue struct { Type Type `protobuf:"varint,1,opt,name=type,casttype=Type"` NumVal json.Number `protobuf:"bytes,2,opt,name=numVal"` BoolVal bool `protobuf:"bytes,3,opt,name=boolVal"` StrVal string `protobuf:"bytes,4,opt,name=strVal"` MapVal map[string]string `protobuf:"bytes,5,opt,name=mapVal"` ListVal []json.RawMessage `protobuf:"bytes,6,opt,name=listVal"` }
+protobuf=true +protobuf.options.(gogoproto.goproto_stringer)=false +k8s:openapi-gen=true
func (*ItemValue) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ItemValue.
func (*ItemValue) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*ItemValue) Descriptor ¶
func (ItemValue) MarshalJSON ¶
MarshalJSON implements the json.Marshaller interface.
func (*ItemValue) MarshalToSizedBuffer ¶
func (*ItemValue) ProtoMessage ¶
func (*ItemValue) ProtoMessage()
func (*ItemValue) UnmarshalJSON ¶
UnmarshalJSON implements the json.Unmarshaller interface.
func (*ItemValue) XXX_DiscardUnknown ¶
func (m *ItemValue) XXX_DiscardUnknown()
func (*ItemValue) XXX_Marshal ¶
func (*ItemValue) XXX_Unmarshal ¶
type Metadata ¶
type Metadata struct { Annotations map[string]string `json:"annotations,omitempty" protobuf:"bytes,1,opt,name=annotations"` Labels map[string]string `json:"labels,omitempty" protobuf:"bytes,2,opt,name=labels"` }
Pod metdata
func (*Metadata) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Metadata.
func (*Metadata) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*Metadata) Descriptor ¶
func (*Metadata) MarshalToSizedBuffer ¶
func (*Metadata) ProtoMessage ¶
func (*Metadata) ProtoMessage()
func (*Metadata) XXX_DiscardUnknown ¶
func (m *Metadata) XXX_DiscardUnknown()
func (*Metadata) XXX_Marshal ¶
func (*Metadata) XXX_Unmarshal ¶
type NodePhase ¶
type NodePhase string
NodePhase is a label for the condition of a node at the current time.
type NodeStatus ¶
type NodeStatus struct { // ID is a unique identifier of a node within the worklow // It is implemented as a hash of the node name, which makes the ID deterministic ID string `json:"id" protobuf:"bytes,1,opt,name=id"` // Name is unique name in the node tree used to generate the node ID Name string `json:"name" protobuf:"bytes,2,opt,name=name"` // DisplayName is a human readable representation of the node. Unique within a template boundary DisplayName string `json:"displayName" protobuf:"bytes,3,opt,name=displayName"` // Type indicates type of node Type NodeType `json:"type" protobuf:"bytes,4,opt,name=type,casttype=NodeType"` // TemplateName is the template name which this node corresponds to. // Not applicable to virtual nodes (e.g. Retry, StepGroup) TemplateName string `json:"templateName,omitempty" protobuf:"bytes,5,opt,name=templateName"` // TemplateRef is the reference to the template resource which this node corresponds to. // Not applicable to virtual nodes (e.g. Retry, StepGroup) TemplateRef *TemplateRef `json:"templateRef,omitempty" protobuf:"bytes,6,opt,name=templateRef"` // StoredTemplateID is the ID of stored template. // DEPRECATED: This value is not used anymore. StoredTemplateID string `json:"storedTemplateID,omitempty" protobuf:"bytes,18,opt,name=storedTemplateID"` // WorkflowTemplateName is the WorkflowTemplate resource name on which the resolved template of this node is retrieved. // DEPRECATED: This value is not used anymore. WorkflowTemplateName string `json:"workflowTemplateName,omitempty" protobuf:"bytes,19,opt,name=workflowTemplateName"` // TemplateScope is the template scope in which the template of this node was retrieved. TemplateScope string `json:"templateScope,omitempty" protobuf:"bytes,20,opt,name=templateScope"` // Phase a simple, high-level summary of where the node is in its lifecycle. // Can be used as a state machine. Phase NodePhase `json:"phase,omitempty" protobuf:"bytes,7,opt,name=phase,casttype=NodePhase"` // BoundaryID indicates the node ID of the associated template root node in which this node belongs to BoundaryID string `json:"boundaryID,omitempty" protobuf:"bytes,8,opt,name=boundaryID"` // A human readable message indicating details about why the node is in this condition. Message string `json:"message,omitempty" protobuf:"bytes,9,opt,name=message"` // Time at which this node started StartedAt metav1.Time `json:"startedAt,omitempty" protobuf:"bytes,10,opt,name=startedAt"` // Time at which this node completed FinishedAt metav1.Time `json:"finishedAt,omitempty" protobuf:"bytes,11,opt,name=finishedAt"` // PodIP captures the IP of the pod for daemoned steps PodIP string `json:"podIP,omitempty" protobuf:"bytes,12,opt,name=podIP"` // Daemoned tracks whether or not this node was daemoned and need to be terminated Daemoned *bool `json:"daemoned,omitempty" protobuf:"varint,13,opt,name=daemoned"` // Inputs captures input parameter values and artifact locations supplied to this template invocation Inputs *Inputs `json:"inputs,omitempty" protobuf:"bytes,14,opt,name=inputs"` // Outputs captures output parameter values and artifact locations produced by this template invocation Outputs *Outputs `json:"outputs,omitempty" protobuf:"bytes,15,opt,name=outputs"` // Children is a list of child node IDs Children []string `json:"children,omitempty" protobuf:"bytes,16,rep,name=children"` // OutboundNodes tracks the node IDs which are considered "outbound" nodes to a template invocation. // For every invocation of a template, there are nodes which we considered as "outbound". Essentially, // these are last nodes in the execution sequence to run, before the template is considered completed. // These nodes are then connected as parents to a following step. // // In the case of single pod steps (i.e. container, script, resource templates), this list will be nil // since the pod itself is already considered the "outbound" node. // In the case of DAGs, outbound nodes are the "target" tasks (tasks with no children). // In the case of steps, outbound nodes are all the containers involved in the last step group. // NOTE: since templates are composable, the list of outbound nodes are carried upwards when // a DAG/steps template invokes another DAG/steps template. In other words, the outbound nodes of // a template, will be a superset of the outbound nodes of its last children. OutboundNodes []string `json:"outboundNodes,omitempty" protobuf:"bytes,17,rep,name=outboundNodes"` }
NodeStatus contains status information about an individual node in the workflow
func (NodeStatus) CanRetry ¶
func (n NodeStatus) CanRetry() bool
CanRetry returns whether the node should be retried or not.
func (NodeStatus) Completed ¶
func (n NodeStatus) Completed() bool
Remove returns whether or not the node has completed execution
func (*NodeStatus) DeepCopy ¶
func (in *NodeStatus) DeepCopy() *NodeStatus
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new NodeStatus.
func (*NodeStatus) DeepCopyInto ¶
func (in *NodeStatus) DeepCopyInto(out *NodeStatus)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*NodeStatus) Descriptor ¶
func (*NodeStatus) Descriptor() ([]byte, []int)
func (*NodeStatus) GetTemplateName ¶
func (n *NodeStatus) GetTemplateName() string
func (*NodeStatus) GetTemplateRef ¶
func (n *NodeStatus) GetTemplateRef() *TemplateRef
func (NodeStatus) IsDaemoned ¶
func (n NodeStatus) IsDaemoned() bool
IsDaemoned returns whether or not the node is deamoned
func (*NodeStatus) IsResolvable ¶
func (n *NodeStatus) IsResolvable() bool
func (*NodeStatus) Marshal ¶
func (m *NodeStatus) Marshal() (dAtA []byte, err error)
func (*NodeStatus) MarshalToSizedBuffer ¶
func (m *NodeStatus) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*NodeStatus) ProtoMessage ¶
func (*NodeStatus) ProtoMessage()
func (*NodeStatus) Reset ¶
func (m *NodeStatus) Reset()
func (*NodeStatus) Size ¶
func (m *NodeStatus) Size() (n int)
func (*NodeStatus) String ¶
func (this *NodeStatus) String() string
func (NodeStatus) Successful ¶
func (n NodeStatus) Successful() bool
Successful returns whether or not this node completed successfully
func (*NodeStatus) Unmarshal ¶
func (m *NodeStatus) Unmarshal(dAtA []byte) error
func (*NodeStatus) XXX_DiscardUnknown ¶
func (m *NodeStatus) XXX_DiscardUnknown()
func (*NodeStatus) XXX_Marshal ¶
func (m *NodeStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*NodeStatus) XXX_Merge ¶
func (m *NodeStatus) XXX_Merge(src proto.Message)
func (*NodeStatus) XXX_Size ¶
func (m *NodeStatus) XXX_Size() int
func (*NodeStatus) XXX_Unmarshal ¶
func (m *NodeStatus) XXX_Unmarshal(b []byte) error
type NodeType ¶
type NodeType string
NodeType is the type of a node
const ( NodeTypePod NodeType = "Pod" NodeTypeSteps NodeType = "Steps" NodeTypeStepGroup NodeType = "StepGroup" NodeTypeDAG NodeType = "DAG" NodeTypeTaskGroup NodeType = "TaskGroup" NodeTypeRetry NodeType = "Retry" NodeTypeSkipped NodeType = "Skipped" NodeTypeSuspend NodeType = "Suspend" )
Node types
type Nodes ¶
type Nodes map[string]NodeStatus
func (Nodes) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Nodes.
func (Nodes) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (Nodes) FindByDisplayName ¶
func (n Nodes) FindByDisplayName(name string) *NodeStatus
type NoneStrategy ¶
type NoneStrategy struct{}
NoneStrategy indicates to skip tar process and upload the files or directory tree as independent files. Note that if the artifact is a directory, the artifact driver must support the ability to save/load the directory appropriately.
func (*NoneStrategy) DeepCopy ¶
func (in *NoneStrategy) DeepCopy() *NoneStrategy
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new NoneStrategy.
func (*NoneStrategy) DeepCopyInto ¶
func (in *NoneStrategy) DeepCopyInto(out *NoneStrategy)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*NoneStrategy) Descriptor ¶
func (*NoneStrategy) Descriptor() ([]byte, []int)
func (*NoneStrategy) Marshal ¶
func (m *NoneStrategy) Marshal() (dAtA []byte, err error)
func (*NoneStrategy) MarshalToSizedBuffer ¶
func (m *NoneStrategy) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*NoneStrategy) ProtoMessage ¶
func (*NoneStrategy) ProtoMessage()
func (*NoneStrategy) Reset ¶
func (m *NoneStrategy) Reset()
func (*NoneStrategy) Size ¶
func (m *NoneStrategy) Size() (n int)
func (*NoneStrategy) String ¶
func (this *NoneStrategy) String() string
func (*NoneStrategy) Unmarshal ¶
func (m *NoneStrategy) Unmarshal(dAtA []byte) error
func (*NoneStrategy) XXX_DiscardUnknown ¶
func (m *NoneStrategy) XXX_DiscardUnknown()
func (*NoneStrategy) XXX_Marshal ¶
func (m *NoneStrategy) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*NoneStrategy) XXX_Merge ¶
func (m *NoneStrategy) XXX_Merge(src proto.Message)
func (*NoneStrategy) XXX_Size ¶
func (m *NoneStrategy) XXX_Size() int
func (*NoneStrategy) XXX_Unmarshal ¶
func (m *NoneStrategy) XXX_Unmarshal(b []byte) error
type Outputs ¶
type Outputs struct { // Parameters holds the list of output parameters produced by a step // +patchStrategy=merge // +patchMergeKey=name Parameters []Parameter `json:"parameters,omitempty" patchStrategy:"merge" patchMergeKey:"name" protobuf:"bytes,1,rep,name=parameters"` // Artifacts holds the list of output artifacts produced by a step // +patchStrategy=merge // +patchMergeKey=name Artifacts Artifacts `json:"artifacts,omitempty" patchStrategy:"merge" patchMergeKey:"name" protobuf:"bytes,2,rep,name=artifacts"` // Result holds the result (stdout) of a script template Result *string `json:"result,omitempty" protobuf:"bytes,3,opt,name=result"` }
Outputs hold parameters, artifacts, and results from a step
func (*Outputs) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Outputs.
func (*Outputs) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*Outputs) Descriptor ¶
func (*Outputs) GetArtifactByName ¶
func (*Outputs) HasOutputs ¶
HasOutputs returns whether or not there are any outputs
func (*Outputs) MarshalToSizedBuffer ¶
func (*Outputs) ProtoMessage ¶
func (*Outputs) ProtoMessage()
func (*Outputs) XXX_DiscardUnknown ¶
func (m *Outputs) XXX_DiscardUnknown()
func (*Outputs) XXX_Marshal ¶
func (*Outputs) XXX_Unmarshal ¶
type ParallelSteps ¶
type ParallelSteps struct {
Steps []WorkflowStep `protobuf:"bytes,1,rep,name=steps"`
}
func (*ParallelSteps) DeepCopy ¶
func (in *ParallelSteps) DeepCopy() *ParallelSteps
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ParallelSteps.
func (*ParallelSteps) DeepCopyInto ¶
func (in *ParallelSteps) DeepCopyInto(out *ParallelSteps)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*ParallelSteps) Descriptor ¶
func (*ParallelSteps) Descriptor() ([]byte, []int)
func (*ParallelSteps) Marshal ¶
func (m *ParallelSteps) Marshal() (dAtA []byte, err error)
func (*ParallelSteps) MarshalJSON ¶
func (p *ParallelSteps) MarshalJSON() ([]byte, error)
func (*ParallelSteps) MarshalToSizedBuffer ¶
func (m *ParallelSteps) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ParallelSteps) ProtoMessage ¶
func (*ParallelSteps) ProtoMessage()
func (*ParallelSteps) Reset ¶
func (m *ParallelSteps) Reset()
func (*ParallelSteps) Size ¶
func (m *ParallelSteps) Size() (n int)
func (*ParallelSteps) String ¶
func (this *ParallelSteps) String() string
func (*ParallelSteps) Unmarshal ¶
func (m *ParallelSteps) Unmarshal(dAtA []byte) error
func (*ParallelSteps) UnmarshalJSON ¶
func (p *ParallelSteps) UnmarshalJSON(value []byte) error
func (*ParallelSteps) XXX_DiscardUnknown ¶
func (m *ParallelSteps) XXX_DiscardUnknown()
func (*ParallelSteps) XXX_Marshal ¶
func (m *ParallelSteps) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ParallelSteps) XXX_Merge ¶
func (m *ParallelSteps) XXX_Merge(src proto.Message)
func (*ParallelSteps) XXX_Size ¶
func (m *ParallelSteps) XXX_Size() int
func (*ParallelSteps) XXX_Unmarshal ¶
func (m *ParallelSteps) XXX_Unmarshal(b []byte) error
type Parameter ¶
type Parameter struct { // Name is the parameter name Name string `json:"name" protobuf:"bytes,1,opt,name=name"` // Default is the default value to use for an input parameter if a value was not supplied Default *string `json:"default,omitempty" protobuf:"bytes,2,opt,name=default"` // Value is the literal value to use for the parameter. // If specified in the context of an input parameter, the value takes precedence over any passed values Value *string `json:"value,omitempty" protobuf:"bytes,3,opt,name=value"` // ValueFrom is the source for the output parameter's value ValueFrom *ValueFrom `json:"valueFrom,omitempty" protobuf:"bytes,4,opt,name=valueFrom"` // GlobalName exports an output parameter to the global scope, making it available as // '{{workflow.outputs.parameters.XXXX}} and in workflow.status.outputs.parameters GlobalName string `json:"globalName,omitempty" protobuf:"bytes,5,opt,name=globalName"` }
Parameter indicate a passed string parameter to a service template with an optional default value
func (*Parameter) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Parameter.
func (*Parameter) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*Parameter) Descriptor ¶
func (*Parameter) MarshalToSizedBuffer ¶
func (*Parameter) ProtoMessage ¶
func (*Parameter) ProtoMessage()
func (*Parameter) XXX_DiscardUnknown ¶
func (m *Parameter) XXX_DiscardUnknown()
func (*Parameter) XXX_Marshal ¶
func (*Parameter) XXX_Unmarshal ¶
type PodGC ¶
type PodGC struct {
Strategy PodGCStrategy `json:"strategy,omitempty" protobuf:"bytes,1,opt,name=strategy,casttype=PodGCStrategy"`
}
PodGC describes how to delete completed pods as they complete
func (*PodGC) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PodGC.
func (*PodGC) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*PodGC) Descriptor ¶
func (*PodGC) ProtoMessage ¶
func (*PodGC) ProtoMessage()
func (*PodGC) XXX_DiscardUnknown ¶
func (m *PodGC) XXX_DiscardUnknown()
func (*PodGC) XXX_Marshal ¶
func (*PodGC) XXX_Unmarshal ¶
type PodGCStrategy ¶
type PodGCStrategy string
PodGCStrategy is the strategy when to delete completed pods for GC.
const ( PodGCOnPodCompletion PodGCStrategy = "OnPodCompletion" PodGCOnPodSuccess PodGCStrategy = "OnPodSuccess" PodGCOnWorkflowCompletion PodGCStrategy = "OnWorkflowCompletion" PodGCOnWorkflowSuccess PodGCStrategy = "OnWorkflowSuccess" )
PodGCStrategy
type RawArtifact ¶
type RawArtifact struct { // Data is the string contents of the artifact Data string `json:"data" protobuf:"bytes,1,opt,name=data"` }
RawArtifact allows raw string content to be placed as an artifact in a container
func (*RawArtifact) DeepCopy ¶
func (in *RawArtifact) DeepCopy() *RawArtifact
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new RawArtifact.
func (*RawArtifact) DeepCopyInto ¶
func (in *RawArtifact) DeepCopyInto(out *RawArtifact)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*RawArtifact) Descriptor ¶
func (*RawArtifact) Descriptor() ([]byte, []int)
func (*RawArtifact) HasLocation ¶
func (r *RawArtifact) HasLocation() bool
func (*RawArtifact) Marshal ¶
func (m *RawArtifact) Marshal() (dAtA []byte, err error)
func (*RawArtifact) MarshalToSizedBuffer ¶
func (m *RawArtifact) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*RawArtifact) ProtoMessage ¶
func (*RawArtifact) ProtoMessage()
func (*RawArtifact) Reset ¶
func (m *RawArtifact) Reset()
func (*RawArtifact) Size ¶
func (m *RawArtifact) Size() (n int)
func (*RawArtifact) String ¶
func (this *RawArtifact) String() string
func (*RawArtifact) Unmarshal ¶
func (m *RawArtifact) Unmarshal(dAtA []byte) error
func (*RawArtifact) XXX_DiscardUnknown ¶
func (m *RawArtifact) XXX_DiscardUnknown()
func (*RawArtifact) XXX_Marshal ¶
func (m *RawArtifact) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RawArtifact) XXX_Merge ¶
func (m *RawArtifact) XXX_Merge(src proto.Message)
func (*RawArtifact) XXX_Size ¶
func (m *RawArtifact) XXX_Size() int
func (*RawArtifact) XXX_Unmarshal ¶
func (m *RawArtifact) XXX_Unmarshal(b []byte) error
type ResourceTemplate ¶
type ResourceTemplate struct { // Action is the action to perform to the resource. // Must be one of: get, create, apply, delete, replace, patch Action string `json:"action" protobuf:"bytes,1,opt,name=action"` // MergeStrategy is the strategy used to merge a patch. It defaults to "strategic" // Must be one of: strategic, merge, json MergeStrategy string `json:"mergeStrategy,omitempty" protobuf:"bytes,2,opt,name=mergeStrategy"` // Manifest contains the kubernetes manifest Manifest string `json:"manifest" protobuf:"bytes,3,opt,name=manifest"` // SetOwnerReference sets the reference to the workflow on the OwnerReference of generated resource. SetOwnerReference bool `json:"setOwnerReference,omitempty" protobuf:"varint,4,opt,name=setOwnerReference"` // SuccessCondition is a label selector expression which describes the conditions // of the k8s resource in which it is acceptable to proceed to the following step SuccessCondition string `json:"successCondition,omitempty" protobuf:"bytes,5,opt,name=successCondition"` // FailureCondition is a label selector expression which describes the conditions // of the k8s resource in which the step was considered failed FailureCondition string `json:"failureCondition,omitempty" protobuf:"bytes,6,opt,name=failureCondition"` }
ResourceTemplate is a template subtype to manipulate kubernetes resources
func (*ResourceTemplate) DeepCopy ¶
func (in *ResourceTemplate) DeepCopy() *ResourceTemplate
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ResourceTemplate.
func (*ResourceTemplate) DeepCopyInto ¶
func (in *ResourceTemplate) DeepCopyInto(out *ResourceTemplate)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*ResourceTemplate) Descriptor ¶
func (*ResourceTemplate) Descriptor() ([]byte, []int)
func (*ResourceTemplate) Marshal ¶
func (m *ResourceTemplate) Marshal() (dAtA []byte, err error)
func (*ResourceTemplate) MarshalToSizedBuffer ¶
func (m *ResourceTemplate) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ResourceTemplate) ProtoMessage ¶
func (*ResourceTemplate) ProtoMessage()
func (*ResourceTemplate) Reset ¶
func (m *ResourceTemplate) Reset()
func (*ResourceTemplate) Size ¶
func (m *ResourceTemplate) Size() (n int)
func (*ResourceTemplate) String ¶
func (this *ResourceTemplate) String() string
func (*ResourceTemplate) Unmarshal ¶
func (m *ResourceTemplate) Unmarshal(dAtA []byte) error
func (*ResourceTemplate) XXX_DiscardUnknown ¶
func (m *ResourceTemplate) XXX_DiscardUnknown()
func (*ResourceTemplate) XXX_Marshal ¶
func (m *ResourceTemplate) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ResourceTemplate) XXX_Merge ¶
func (m *ResourceTemplate) XXX_Merge(src proto.Message)
func (*ResourceTemplate) XXX_Size ¶
func (m *ResourceTemplate) XXX_Size() int
func (*ResourceTemplate) XXX_Unmarshal ¶
func (m *ResourceTemplate) XXX_Unmarshal(b []byte) error
type RetryPolicy ¶
type RetryPolicy string
const ( RetryPolicyAlways RetryPolicy = "Always" RetryPolicyOnFailure RetryPolicy = "OnFailure" RetryPolicyOnError RetryPolicy = "OnError" )
type RetryStrategy ¶
type RetryStrategy struct { // Limit is the maximum number of attempts when retrying a container Limit *int32 `json:"limit,omitempty" protobuf:"varint,1,opt,name=limit"` // RetryPolicy is a policy of NodePhase statuses that will be retried RetryPolicy RetryPolicy `json:"retryPolicy,omitempty" protobuf:"bytes,2,opt,name=retryPolicy,casttype=RetryPolicy"` // Backoff is a backoff strategy Backoff *Backoff `json:"backoff,omitempty" protobuf:"bytes,3,opt,name=backoff,casttype=Backoff"` }
RetryStrategy provides controls on how to retry a workflow step
func (*RetryStrategy) DeepCopy ¶
func (in *RetryStrategy) DeepCopy() *RetryStrategy
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new RetryStrategy.
func (*RetryStrategy) DeepCopyInto ¶
func (in *RetryStrategy) DeepCopyInto(out *RetryStrategy)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*RetryStrategy) Descriptor ¶
func (*RetryStrategy) Descriptor() ([]byte, []int)
func (*RetryStrategy) Marshal ¶
func (m *RetryStrategy) Marshal() (dAtA []byte, err error)
func (*RetryStrategy) MarshalToSizedBuffer ¶
func (m *RetryStrategy) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*RetryStrategy) ProtoMessage ¶
func (*RetryStrategy) ProtoMessage()
func (*RetryStrategy) Reset ¶
func (m *RetryStrategy) Reset()
func (*RetryStrategy) Size ¶
func (m *RetryStrategy) Size() (n int)
func (*RetryStrategy) String ¶
func (this *RetryStrategy) String() string
func (*RetryStrategy) Unmarshal ¶
func (m *RetryStrategy) Unmarshal(dAtA []byte) error
func (*RetryStrategy) XXX_DiscardUnknown ¶
func (m *RetryStrategy) XXX_DiscardUnknown()
func (*RetryStrategy) XXX_Marshal ¶
func (m *RetryStrategy) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RetryStrategy) XXX_Merge ¶
func (m *RetryStrategy) XXX_Merge(src proto.Message)
func (*RetryStrategy) XXX_Size ¶
func (m *RetryStrategy) XXX_Size() int
func (*RetryStrategy) XXX_Unmarshal ¶
func (m *RetryStrategy) XXX_Unmarshal(b []byte) error
type S3Artifact ¶
type S3Artifact struct { S3Bucket `json:",inline" protobuf:"bytes,1,opt,name=s3Bucket"` // Key is the key in the bucket where the artifact resides Key string `json:"key" protobuf:"bytes,2,opt,name=key"` }
S3Artifact is the location of an S3 artifact
func (*S3Artifact) DeepCopy ¶
func (in *S3Artifact) DeepCopy() *S3Artifact
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new S3Artifact.
func (*S3Artifact) DeepCopyInto ¶
func (in *S3Artifact) DeepCopyInto(out *S3Artifact)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*S3Artifact) Descriptor ¶
func (*S3Artifact) Descriptor() ([]byte, []int)
func (*S3Artifact) HasLocation ¶
func (s *S3Artifact) HasLocation() bool
func (*S3Artifact) Marshal ¶
func (m *S3Artifact) Marshal() (dAtA []byte, err error)
func (*S3Artifact) MarshalToSizedBuffer ¶
func (m *S3Artifact) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*S3Artifact) ProtoMessage ¶
func (*S3Artifact) ProtoMessage()
func (*S3Artifact) Reset ¶
func (m *S3Artifact) Reset()
func (*S3Artifact) Size ¶
func (m *S3Artifact) Size() (n int)
func (*S3Artifact) String ¶
func (this *S3Artifact) String() string
func (*S3Artifact) Unmarshal ¶
func (m *S3Artifact) Unmarshal(dAtA []byte) error
func (*S3Artifact) XXX_DiscardUnknown ¶
func (m *S3Artifact) XXX_DiscardUnknown()
func (*S3Artifact) XXX_Marshal ¶
func (m *S3Artifact) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*S3Artifact) XXX_Merge ¶
func (m *S3Artifact) XXX_Merge(src proto.Message)
func (*S3Artifact) XXX_Size ¶
func (m *S3Artifact) XXX_Size() int
func (*S3Artifact) XXX_Unmarshal ¶
func (m *S3Artifact) XXX_Unmarshal(b []byte) error
type S3Bucket ¶
type S3Bucket struct { // Endpoint is the hostname of the bucket endpoint Endpoint string `json:"endpoint" protobuf:"bytes,1,opt,name=endpoint"` // Bucket is the name of the bucket Bucket string `json:"bucket" protobuf:"bytes,2,opt,name=bucket"` // Region contains the optional bucket region Region string `json:"region,omitempty" protobuf:"bytes,3,opt,name=region"` // Insecure will connect to the service with TLS Insecure *bool `json:"insecure,omitempty" protobuf:"varint,4,opt,name=insecure"` // AccessKeySecret is the secret selector to the bucket's access key AccessKeySecret apiv1.SecretKeySelector `json:"accessKeySecret" protobuf:"bytes,5,opt,name=accessKeySecret"` // SecretKeySecret is the secret selector to the bucket's secret key SecretKeySecret apiv1.SecretKeySelector `json:"secretKeySecret" protobuf:"bytes,6,opt,name=secretKeySecret"` // RoleARN is the Amazon Resource Name (ARN) of the role to assume. RoleARN string `json:"roleARN,omitempty" protobuf:"bytes,7,opt,name=roleARN"` }
S3Bucket contains the access information required for interfacing with an S3 bucket
func (*S3Bucket) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new S3Bucket.
func (*S3Bucket) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*S3Bucket) Descriptor ¶
func (*S3Bucket) MarshalToSizedBuffer ¶
func (*S3Bucket) ProtoMessage ¶
func (*S3Bucket) ProtoMessage()
func (*S3Bucket) XXX_DiscardUnknown ¶
func (m *S3Bucket) XXX_DiscardUnknown()
func (*S3Bucket) XXX_Marshal ¶
func (*S3Bucket) XXX_Unmarshal ¶
type ScriptTemplate ¶
type ScriptTemplate struct { apiv1.Container `json:",inline" protobuf:"bytes,1,opt,name=container"` // Source contains the source code of the script to execute Source string `json:"source" protobuf:"bytes,2,opt,name=source"` }
ScriptTemplate is a template subtype to enable scripting through code steps
func (*ScriptTemplate) DeepCopy ¶
func (in *ScriptTemplate) DeepCopy() *ScriptTemplate
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ScriptTemplate.
func (*ScriptTemplate) DeepCopyInto ¶
func (in *ScriptTemplate) DeepCopyInto(out *ScriptTemplate)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*ScriptTemplate) Descriptor ¶
func (*ScriptTemplate) Descriptor() ([]byte, []int)
func (*ScriptTemplate) Marshal ¶
func (m *ScriptTemplate) Marshal() (dAtA []byte, err error)
func (*ScriptTemplate) MarshalToSizedBuffer ¶
func (m *ScriptTemplate) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ScriptTemplate) ProtoMessage ¶
func (*ScriptTemplate) ProtoMessage()
func (*ScriptTemplate) Reset ¶
func (m *ScriptTemplate) Reset()
func (*ScriptTemplate) Size ¶
func (m *ScriptTemplate) Size() (n int)
func (*ScriptTemplate) String ¶
func (this *ScriptTemplate) String() string
func (*ScriptTemplate) Unmarshal ¶
func (m *ScriptTemplate) Unmarshal(dAtA []byte) error
func (*ScriptTemplate) XXX_DiscardUnknown ¶
func (m *ScriptTemplate) XXX_DiscardUnknown()
func (*ScriptTemplate) XXX_Marshal ¶
func (m *ScriptTemplate) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ScriptTemplate) XXX_Merge ¶
func (m *ScriptTemplate) XXX_Merge(src proto.Message)
func (*ScriptTemplate) XXX_Size ¶
func (m *ScriptTemplate) XXX_Size() int
func (*ScriptTemplate) XXX_Unmarshal ¶
func (m *ScriptTemplate) XXX_Unmarshal(b []byte) error
type Sequence ¶
type Sequence struct { // Count is number of elements in the sequence (default: 0). Not to be used with end Count string `json:"count,omitempty" protobuf:"bytes,1,opt,name=count"` // Number at which to start the sequence (default: 0) Start string `json:"start,omitempty" protobuf:"bytes,2,opt,name=start"` // Number at which to end the sequence (default: 0). Not to be used with Count End string `json:"end,omitempty" protobuf:"bytes,3,opt,name=end"` // Format is a printf format string to format the value in the sequence Format string `json:"format,omitempty" protobuf:"bytes,4,opt,name=format"` }
Sequence expands a workflow step into numeric range
func (*Sequence) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Sequence.
func (*Sequence) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*Sequence) Descriptor ¶
func (*Sequence) MarshalToSizedBuffer ¶
func (*Sequence) ProtoMessage ¶
func (*Sequence) ProtoMessage()
func (*Sequence) XXX_DiscardUnknown ¶
func (m *Sequence) XXX_DiscardUnknown()
func (*Sequence) XXX_Marshal ¶
func (*Sequence) XXX_Unmarshal ¶
type SuspendTemplate ¶
type SuspendTemplate struct { // Duration is the seconds to wait before automatically resuming a template Duration string `json:"duration,omitempty" protobuf:"bytes,1,opt,name=duration"` }
SuspendTemplate is a template subtype to suspend a workflow at a predetermined point in time
func (*SuspendTemplate) DeepCopy ¶
func (in *SuspendTemplate) DeepCopy() *SuspendTemplate
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SuspendTemplate.
func (*SuspendTemplate) DeepCopyInto ¶
func (in *SuspendTemplate) DeepCopyInto(out *SuspendTemplate)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*SuspendTemplate) Descriptor ¶
func (*SuspendTemplate) Descriptor() ([]byte, []int)
func (*SuspendTemplate) Marshal ¶
func (m *SuspendTemplate) Marshal() (dAtA []byte, err error)
func (*SuspendTemplate) MarshalToSizedBuffer ¶
func (m *SuspendTemplate) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*SuspendTemplate) ProtoMessage ¶
func (*SuspendTemplate) ProtoMessage()
func (*SuspendTemplate) Reset ¶
func (m *SuspendTemplate) Reset()
func (*SuspendTemplate) Size ¶
func (m *SuspendTemplate) Size() (n int)
func (*SuspendTemplate) String ¶
func (this *SuspendTemplate) String() string
func (*SuspendTemplate) Unmarshal ¶
func (m *SuspendTemplate) Unmarshal(dAtA []byte) error
func (*SuspendTemplate) XXX_DiscardUnknown ¶
func (m *SuspendTemplate) XXX_DiscardUnknown()
func (*SuspendTemplate) XXX_Marshal ¶
func (m *SuspendTemplate) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SuspendTemplate) XXX_Merge ¶
func (m *SuspendTemplate) XXX_Merge(src proto.Message)
func (*SuspendTemplate) XXX_Size ¶
func (m *SuspendTemplate) XXX_Size() int
func (*SuspendTemplate) XXX_Unmarshal ¶
func (m *SuspendTemplate) XXX_Unmarshal(b []byte) error
type TTLStrategy ¶
type TTLStrategy struct { SecondsAfterCompletion *int32 `json:"secondsAfterCompletion,omitempty" protobuf:"bytes,1,opt,name=secondsAfterCompletion"` SecondsAfterSuccess *int32 `json:"secondsAfterSuccess,omitempty" protobuf:"bytes,2,opt,name=secondsAfterSuccess"` SecondsAfterFailure *int32 `json:"secondsAfterFailure,omitempty" protobuf:"bytes,3,opt,name=secondsAfterFailure"` }
TTLStrategy is the strategy for the time to live depending on if the workflow succeded or failed
func (*TTLStrategy) DeepCopy ¶
func (in *TTLStrategy) DeepCopy() *TTLStrategy
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new TTLStrategy.
func (*TTLStrategy) DeepCopyInto ¶
func (in *TTLStrategy) DeepCopyInto(out *TTLStrategy)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*TTLStrategy) Descriptor ¶
func (*TTLStrategy) Descriptor() ([]byte, []int)
func (*TTLStrategy) Marshal ¶
func (m *TTLStrategy) Marshal() (dAtA []byte, err error)
func (*TTLStrategy) MarshalToSizedBuffer ¶
func (m *TTLStrategy) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*TTLStrategy) ProtoMessage ¶
func (*TTLStrategy) ProtoMessage()
func (*TTLStrategy) Reset ¶
func (m *TTLStrategy) Reset()
func (*TTLStrategy) Size ¶
func (m *TTLStrategy) Size() (n int)
func (*TTLStrategy) String ¶
func (this *TTLStrategy) String() string
func (*TTLStrategy) Unmarshal ¶
func (m *TTLStrategy) Unmarshal(dAtA []byte) error
func (*TTLStrategy) XXX_DiscardUnknown ¶
func (m *TTLStrategy) XXX_DiscardUnknown()
func (*TTLStrategy) XXX_Marshal ¶
func (m *TTLStrategy) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*TTLStrategy) XXX_Merge ¶
func (m *TTLStrategy) XXX_Merge(src proto.Message)
func (*TTLStrategy) XXX_Size ¶
func (m *TTLStrategy) XXX_Size() int
func (*TTLStrategy) XXX_Unmarshal ¶
func (m *TTLStrategy) XXX_Unmarshal(b []byte) error
type TarStrategy ¶
type TarStrategy struct{}
TarStrategy will tar and gzip the file or directory when saving
func (*TarStrategy) DeepCopy ¶
func (in *TarStrategy) DeepCopy() *TarStrategy
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new TarStrategy.
func (*TarStrategy) DeepCopyInto ¶
func (in *TarStrategy) DeepCopyInto(out *TarStrategy)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*TarStrategy) Descriptor ¶
func (*TarStrategy) Descriptor() ([]byte, []int)
func (*TarStrategy) Marshal ¶
func (m *TarStrategy) Marshal() (dAtA []byte, err error)
func (*TarStrategy) MarshalToSizedBuffer ¶
func (m *TarStrategy) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*TarStrategy) ProtoMessage ¶
func (*TarStrategy) ProtoMessage()
func (*TarStrategy) Reset ¶
func (m *TarStrategy) Reset()
func (*TarStrategy) Size ¶
func (m *TarStrategy) Size() (n int)
func (*TarStrategy) String ¶
func (this *TarStrategy) String() string
func (*TarStrategy) Unmarshal ¶
func (m *TarStrategy) Unmarshal(dAtA []byte) error
func (*TarStrategy) XXX_DiscardUnknown ¶
func (m *TarStrategy) XXX_DiscardUnknown()
func (*TarStrategy) XXX_Marshal ¶
func (m *TarStrategy) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*TarStrategy) XXX_Merge ¶
func (m *TarStrategy) XXX_Merge(src proto.Message)
func (*TarStrategy) XXX_Size ¶
func (m *TarStrategy) XXX_Size() int
func (*TarStrategy) XXX_Unmarshal ¶
func (m *TarStrategy) XXX_Unmarshal(b []byte) error
type Template ¶
type Template struct { // Name is the name of the template Name string `json:"name" protobuf:"bytes,1,opt,name=name"` // Template is the name of the template which is used as the base of this template. Template string `json:"template,omitempty" protobuf:"bytes,2,opt,name=template"` // Arguments hold arguments to the template. Arguments Arguments `json:"arguments,omitempty" protobuf:"bytes,3,opt,name=arguments"` // TemplateRef is the reference to the template resource which is used as the base of this template. TemplateRef *TemplateRef `json:"templateRef,omitempty" protobuf:"bytes,4,opt,name=templateRef"` // Inputs describe what inputs parameters and artifacts are supplied to this template Inputs Inputs `json:"inputs,omitempty" protobuf:"bytes,5,opt,name=inputs"` // Outputs describe the parameters and artifacts that this template produces Outputs Outputs `json:"outputs,omitempty" protobuf:"bytes,6,opt,name=outputs"` // NodeSelector is a selector to schedule this step of the workflow to be // run on the selected node(s). Overrides the selector set at the workflow level. NodeSelector map[string]string `json:"nodeSelector,omitempty" protobuf:"bytes,7,opt,name=nodeSelector"` // Affinity sets the pod's scheduling constraints // Overrides the affinity set at the workflow level (if any) Affinity *apiv1.Affinity `json:"affinity,omitempty" protobuf:"bytes,8,opt,name=affinity"` // Metdata sets the pods's metadata, i.e. annotations and labels Metadata Metadata `json:"metadata,omitempty" protobuf:"bytes,9,opt,name=metadata"` // Deamon will allow a workflow to proceed to the next step so long as the container reaches readiness Daemon *bool `json:"daemon,omitempty" protobuf:"bytes,10,opt,name=daemon"` // Steps define a series of sequential/parallel workflow steps Steps []ParallelSteps `json:"steps,omitempty" protobuf:"bytes,11,opt,name=steps"` // Container is the main container image to run in the pod Container *apiv1.Container `json:"container,omitempty" protobuf:"bytes,12,opt,name=container"` // Script runs a portion of code against an interpreter Script *ScriptTemplate `json:"script,omitempty" protobuf:"bytes,13,opt,name=script"` // Resource template subtype which can run k8s resources Resource *ResourceTemplate `json:"resource,omitempty" protobuf:"bytes,14,opt,name=resource"` // DAG template subtype which runs a DAG DAG *DAGTemplate `json:"dag,omitempty" protobuf:"bytes,15,opt,name=dag"` // Suspend template subtype which can suspend a workflow when reaching the step Suspend *SuspendTemplate `json:"suspend,omitempty" protobuf:"bytes,16,opt,name=suspend"` // Volumes is a list of volumes that can be mounted by containers in a template. // +patchStrategy=merge // +patchMergeKey=name Volumes []apiv1.Volume `json:"volumes,omitempty" patchStrategy:"merge" patchMergeKey:"name" protobuf:"bytes,17,opt,name=volumes"` // InitContainers is a list of containers which run before the main container. // +patchStrategy=merge // +patchMergeKey=name InitContainers []UserContainer `json:"initContainers,omitempty" patchStrategy:"merge" patchMergeKey:"name" protobuf:"bytes,18,opt,name=initContainers"` // Sidecars is a list of containers which run alongside the main container // Sidecars are automatically killed when the main container completes // +patchStrategy=merge // +patchMergeKey=name Sidecars []UserContainer `json:"sidecars,omitempty" patchStrategy:"merge" patchMergeKey:"name" protobuf:"bytes,19,opt,name=sidecars"` // Location in which all files related to the step will be stored (logs, artifacts, etc...). // Can be overridden by individual items in Outputs. If omitted, will use the default // artifact repository location configured in the controller, appended with the // <workflowname>/<nodename> in the key. ArchiveLocation *ArtifactLocation `json:"archiveLocation,omitempty" protobuf:"bytes,20,opt,name=archiveLocation"` // Optional duration in seconds relative to the StartTime that the pod may be active on a node // before the system actively tries to terminate the pod; value must be positive integer // This field is only applicable to container and script templates. ActiveDeadlineSeconds *int64 `json:"activeDeadlineSeconds,omitempty" protobuf:"bytes,21,opt,name=activeDeadlineSeconds"` // RetryStrategy describes how to retry a template when it fails RetryStrategy *RetryStrategy `json:"retryStrategy,omitempty" protobuf:"bytes,22,opt,name=retryStrategy"` // Parallelism limits the max total parallel pods that can execute at the same time within the // boundaries of this template invocation. If additional steps/dag templates are invoked, the // pods created by those templates will not be counted towards this total. Parallelism *int64 `json:"parallelism,omitempty" protobuf:"bytes,23,opt,name=parallelism"` // Tolerations to apply to workflow pods. // +patchStrategy=merge // +patchMergeKey=key Tolerations []apiv1.Toleration `json:"tolerations,omitempty" patchStrategy:"merge" patchMergeKey:"key" protobuf:"bytes,24,opt,name=tolerations"` // If specified, the pod will be dispatched by specified scheduler. // Or it will be dispatched by workflow scope scheduler if specified. // If neither specified, the pod will be dispatched by default scheduler. // +optional SchedulerName string `json:"schedulerName,omitempty" protobuf:"bytes,25,opt,name=schedulerName"` // PriorityClassName to apply to workflow pods. PriorityClassName string `json:"priorityClassName,omitempty" protobuf:"bytes,26,opt,name=priorityClassName"` // Priority to apply to workflow pods. Priority *int32 `json:"priority,omitempty" protobuf:"bytes,27,opt,name=priority"` // ServiceAccountName to apply to workflow pods ServiceAccountName string `json:"serviceAccountName,omitempty" protobuf:"bytes,28,opt,name=serviceAccountName"` // AutomountServiceAccountToken indicates whether a service account token should be automatically mounted in pods. // ServiceAccountName of ExecutorConfig must be specified if this value is false. AutomountServiceAccountToken *bool `json:"automountServiceAccountToken,omitempty" protobuf:"varint,32,opt,name=automountServiceAccountToken"` // Executor holds configurations of the executor container. Executor *ExecutorConfig `json:"executor,omitempty" protobuf:"bytes,33,opt,name=executor"` // HostAliases is an optional list of hosts and IPs that will be injected into the pod spec // +patchStrategy=merge // +patchMergeKey=ip HostAliases []apiv1.HostAlias `json:"hostAliases,omitempty" patchStrategy:"merge" patchMergeKey:"ip" protobuf:"bytes,29,opt,name=hostAliases"` // SecurityContext holds pod-level security attributes and common container settings. // Optional: Defaults to empty. See type description for default values of each field. // +optional SecurityContext *apiv1.PodSecurityContext `json:"securityContext,omitempty" protobuf:"bytes,30,opt,name=securityContext"` // PodSpecPatch holds strategic merge patch to apply against the pod spec. Allows parameterization of // container fields which are not strings (e.g. resource limits). PodSpecPatch string `json:"podSpecPatch,omitempty" protobuf:"bytes,31,opt,name=podSpecPatch"` }
Template is a reusable and composable unit of execution in a workflow
func (*Template) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Template.
func (*Template) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*Template) Descriptor ¶
func (*Template) GetBaseTemplate ¶
GetBaseTemplate returns a base template content.
func (*Template) GetTemplateName ¶
func (*Template) GetTemplateRef ¶
func (tmpl *Template) GetTemplateRef() *TemplateRef
func (*Template) GetType ¶
func (tmpl *Template) GetType() TemplateType
GetType returns the type of this template
func (*Template) HasPodSpecPatch ¶
func (*Template) IsResolvable ¶
func (*Template) MarshalToSizedBuffer ¶
func (*Template) ProtoMessage ¶
func (*Template) ProtoMessage()
func (*Template) XXX_DiscardUnknown ¶
func (m *Template) XXX_DiscardUnknown()
func (*Template) XXX_Marshal ¶
func (*Template) XXX_Unmarshal ¶
type TemplateGetter ¶
type TemplateGetter interface { GetNamespace() string GetName() string GroupVersionKind() schema.GroupVersionKind GetTemplateByName(name string) *Template GetTemplateScope() string }
TemplateGetter is an interface to get templates.
type TemplateHolder ¶
type TemplateHolder interface { GetTemplateName() string GetTemplateRef() *TemplateRef IsResolvable() bool }
TemplateHolder is an interface for holders of templates.
type TemplateRef ¶
type TemplateRef struct { // Name is the resource name of the template. Name string `json:"name,omitempty" protobuf:"bytes,1,opt,name=name"` // Template is the name of referred template in the resource. Template string `json:"template,omitempty" protobuf:"bytes,2,opt,name=template"` // RuntimeResolution skips validation at creation time. // By enabling this option, you can create the referred workflow template before the actual runtime. RuntimeResolution bool `json:"runtimeResolution,omitempty" protobuf:"varint,3,opt,name=runtimeResolution"` }
TemplateRef is a reference of template resource.
func (*TemplateRef) DeepCopy ¶
func (in *TemplateRef) DeepCopy() *TemplateRef
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new TemplateRef.
func (*TemplateRef) DeepCopyInto ¶
func (in *TemplateRef) DeepCopyInto(out *TemplateRef)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*TemplateRef) Descriptor ¶
func (*TemplateRef) Descriptor() ([]byte, []int)
func (*TemplateRef) Marshal ¶
func (m *TemplateRef) Marshal() (dAtA []byte, err error)
func (*TemplateRef) MarshalToSizedBuffer ¶
func (m *TemplateRef) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*TemplateRef) ProtoMessage ¶
func (*TemplateRef) ProtoMessage()
func (*TemplateRef) Reset ¶
func (m *TemplateRef) Reset()
func (*TemplateRef) Size ¶
func (m *TemplateRef) Size() (n int)
func (*TemplateRef) String ¶
func (this *TemplateRef) String() string
func (*TemplateRef) Unmarshal ¶
func (m *TemplateRef) Unmarshal(dAtA []byte) error
func (*TemplateRef) XXX_DiscardUnknown ¶
func (m *TemplateRef) XXX_DiscardUnknown()
func (*TemplateRef) XXX_Marshal ¶
func (m *TemplateRef) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*TemplateRef) XXX_Merge ¶
func (m *TemplateRef) XXX_Merge(src proto.Message)
func (*TemplateRef) XXX_Size ¶
func (m *TemplateRef) XXX_Size() int
func (*TemplateRef) XXX_Unmarshal ¶
func (m *TemplateRef) XXX_Unmarshal(b []byte) error
type TemplateStorage ¶
type TemplateStorage interface { GetStoredTemplate(templateScope string, holder TemplateHolder) *Template SetStoredTemplate(templateScope string, holder TemplateHolder, tmpl *Template) (bool, error) }
TemplateStorage is an interface of template storage getter and setter.
type TemplateType ¶
type TemplateType string
TemplateType is the type of a template
const ( TemplateTypeContainer TemplateType = "Container" TemplateTypeSteps TemplateType = "Steps" TemplateTypeScript TemplateType = "Script" TemplateTypeResource TemplateType = "Resource" TemplateTypeDAG TemplateType = "DAG" TemplateTypeSuspend TemplateType = "Suspend" TemplateTypeUnknown TemplateType = "Unknown" )
Possible template types
type UserContainer ¶
type UserContainer struct { apiv1.Container `json:",inline" protobuf:"bytes,1,opt,name=container"` // MirrorVolumeMounts will mount the same volumes specified in the main container // to the container (including artifacts), at the same mountPaths. This enables // dind daemon to partially see the same filesystem as the main container in // order to use features such as docker volume binding MirrorVolumeMounts *bool `json:"mirrorVolumeMounts,omitempty" protobuf:"varint,2,opt,name=mirrorVolumeMounts"` }
UserContainer is a container specified by a user.
func (*UserContainer) DeepCopy ¶
func (in *UserContainer) DeepCopy() *UserContainer
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new UserContainer.
func (*UserContainer) DeepCopyInto ¶
func (in *UserContainer) DeepCopyInto(out *UserContainer)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*UserContainer) Descriptor ¶
func (*UserContainer) Descriptor() ([]byte, []int)
func (*UserContainer) Marshal ¶
func (m *UserContainer) Marshal() (dAtA []byte, err error)
func (*UserContainer) MarshalToSizedBuffer ¶
func (m *UserContainer) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*UserContainer) ProtoMessage ¶
func (*UserContainer) ProtoMessage()
func (*UserContainer) Reset ¶
func (m *UserContainer) Reset()
func (*UserContainer) Size ¶
func (m *UserContainer) Size() (n int)
func (*UserContainer) String ¶
func (this *UserContainer) String() string
func (*UserContainer) Unmarshal ¶
func (m *UserContainer) Unmarshal(dAtA []byte) error
func (*UserContainer) XXX_DiscardUnknown ¶
func (m *UserContainer) XXX_DiscardUnknown()
func (*UserContainer) XXX_Marshal ¶
func (m *UserContainer) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*UserContainer) XXX_Merge ¶
func (m *UserContainer) XXX_Merge(src proto.Message)
func (*UserContainer) XXX_Size ¶
func (m *UserContainer) XXX_Size() int
func (*UserContainer) XXX_Unmarshal ¶
func (m *UserContainer) XXX_Unmarshal(b []byte) error
type ValueFrom ¶
type ValueFrom struct { // Path in the container to retrieve an output parameter value from in container templates Path string `json:"path,omitempty" protobuf:"bytes,1,opt,name=path"` // JSONPath of a resource to retrieve an output parameter value from in resource templates JSONPath string `json:"jsonPath,omitempty" protobuf:"bytes,2,opt,name=jsonPath"` // JQFilter expression against the resource object in resource templates JQFilter string `json:"jqFilter,omitempty" protobuf:"bytes,3,opt,name=jqFilter"` // Parameter reference to a step or dag task in which to retrieve an output parameter value from // (e.g. '{{steps.mystep.outputs.myparam}}') Parameter string `json:"parameter,omitempty" protobuf:"bytes,4,opt,name=parameter"` }
ValueFrom describes a location in which to obtain the value to a parameter
func (*ValueFrom) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ValueFrom.
func (*ValueFrom) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*ValueFrom) Descriptor ¶
func (*ValueFrom) MarshalToSizedBuffer ¶
func (*ValueFrom) ProtoMessage ¶
func (*ValueFrom) ProtoMessage()
func (*ValueFrom) XXX_DiscardUnknown ¶
func (m *ValueFrom) XXX_DiscardUnknown()
func (*ValueFrom) XXX_Marshal ¶
func (*ValueFrom) XXX_Unmarshal ¶
type Workflow ¶
type Workflow struct { metav1.TypeMeta `json:",inline"` metav1.ObjectMeta `json:"metadata" protobuf:"bytes,1,opt,name=metadata"` Spec WorkflowSpec `json:"spec" protobuf:"bytes,2,opt,name=spec "` Status WorkflowStatus `json:"status" protobuf:"bytes,3,opt,name=status"` }
Workflow is the definition of a workflow resource +genclient +genclient:noStatus +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object
func (*Workflow) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Workflow.
func (*Workflow) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*Workflow) DeepCopyObject ¶
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
func (*Workflow) Descriptor ¶
func (*Workflow) GetOffloadNodeStatusVersion ¶
func (*Workflow) GetStoredTemplate ¶
func (wf *Workflow) GetStoredTemplate(templateScope string, holder TemplateHolder) *Template
GetStoredTemplate retrieves a template from stored templates of the workflow.
func (*Workflow) GetTemplateByName ¶
GetTemplateByName retrieves a defined template by its name
func (*Workflow) GetTemplateScope ¶
GetTemplateScope returns the template scope of workflow.
func (*Workflow) MarshalToSizedBuffer ¶
func (*Workflow) ProtoMessage ¶
func (*Workflow) ProtoMessage()
func (*Workflow) SetStoredTemplate ¶
func (wf *Workflow) SetStoredTemplate(templateScope string, holder TemplateHolder, tmpl *Template) (bool, error)
SetStoredTemplate stores a new template in stored templates of the workflow.
func (*Workflow) XXX_DiscardUnknown ¶
func (m *Workflow) XXX_DiscardUnknown()
func (*Workflow) XXX_Marshal ¶
func (*Workflow) XXX_Unmarshal ¶
type WorkflowList ¶
type WorkflowList struct { metav1.TypeMeta `json:",inline"` metav1.ListMeta `json:"metadata" protobuf:"bytes,1,opt,name=metadata"` Items Workflows `json:"items" protobuf:"bytes,2,opt,name=items"` }
WorkflowList is list of Workflow resources +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object
func (*WorkflowList) DeepCopy ¶
func (in *WorkflowList) DeepCopy() *WorkflowList
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new WorkflowList.
func (*WorkflowList) DeepCopyInto ¶
func (in *WorkflowList) DeepCopyInto(out *WorkflowList)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*WorkflowList) DeepCopyObject ¶
func (in *WorkflowList) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
func (*WorkflowList) Descriptor ¶
func (*WorkflowList) Descriptor() ([]byte, []int)
func (*WorkflowList) Marshal ¶
func (m *WorkflowList) Marshal() (dAtA []byte, err error)
func (*WorkflowList) MarshalToSizedBuffer ¶
func (m *WorkflowList) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*WorkflowList) ProtoMessage ¶
func (*WorkflowList) ProtoMessage()
func (*WorkflowList) Reset ¶
func (m *WorkflowList) Reset()
func (*WorkflowList) Size ¶
func (m *WorkflowList) Size() (n int)
func (*WorkflowList) String ¶
func (this *WorkflowList) String() string
func (*WorkflowList) Unmarshal ¶
func (m *WorkflowList) Unmarshal(dAtA []byte) error
func (*WorkflowList) XXX_DiscardUnknown ¶
func (m *WorkflowList) XXX_DiscardUnknown()
func (*WorkflowList) XXX_Marshal ¶
func (m *WorkflowList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*WorkflowList) XXX_Merge ¶
func (m *WorkflowList) XXX_Merge(src proto.Message)
func (*WorkflowList) XXX_Size ¶
func (m *WorkflowList) XXX_Size() int
func (*WorkflowList) XXX_Unmarshal ¶
func (m *WorkflowList) XXX_Unmarshal(b []byte) error
type WorkflowSpec ¶
type WorkflowSpec struct { // Templates is a list of workflow templates used in a workflow // +patchStrategy=merge // +patchMergeKey=name Templates []Template `json:"templates" patchStrategy:"merge" patchMergeKey:"name" protobuf:"bytes,1,opt,name=templates"` // Entrypoint is a template reference to the starting point of the workflow Entrypoint string `json:"entrypoint" protobuf:"bytes,2,opt,name=entrypoint"` // Arguments contain the parameters and artifacts sent to the workflow entrypoint // Parameters are referencable globally using the 'workflow' variable prefix. // e.g. {{workflow.parameters.myparam}} Arguments Arguments `json:"arguments,omitempty" protobuf:"bytes,3,opt,name=arguments"` // ServiceAccountName is the name of the ServiceAccount to run all pods of the workflow as. ServiceAccountName string `json:"serviceAccountName,omitempty" protobuf:"bytes,4,opt,name=serviceAccountName"` // AutomountServiceAccountToken indicates whether a service account token should be automatically mounted in pods. // ServiceAccountName of ExecutorConfig must be specified if this value is false. AutomountServiceAccountToken *bool `json:"automountServiceAccountToken,omitempty" protobuf:"varint,28,opt,name=automountServiceAccountToken"` // Executor holds configurations of executor containers of the workflow. Executor *ExecutorConfig `json:"executor,omitempty" protobuf:"bytes,29,opt,name=executor"` // Volumes is a list of volumes that can be mounted by containers in a workflow. // +patchStrategy=merge // +patchMergeKey=name Volumes []apiv1.Volume `json:"volumes,omitempty" patchStrategy:"merge" patchMergeKey:"name" protobuf:"bytes,5,opt,name=volumes"` // VolumeClaimTemplates is a list of claims that containers are allowed to reference. // The Workflow controller will create the claims at the beginning of the workflow // and delete the claims upon completion of the workflow // +patchStrategy=merge // +patchMergeKey=name VolumeClaimTemplates []apiv1.PersistentVolumeClaim `` /* 129-byte string literal not displayed */ // Parallelism limits the max total parallel pods that can execute at the same time in a workflow Parallelism *int64 `json:"parallelism,omitempty" protobuf:"bytes,7,opt,name=parallelism"` // ArtifactRepositoryRef specifies the configMap name and key containing the artifact repository config. ArtifactRepositoryRef *ArtifactRepositoryRef `json:"artifactRepositoryRef,omitempty" protobuf:"bytes,8,opt,name=artifactRepositoryRef"` // Suspend will suspend the workflow and prevent execution of any future steps in the workflow Suspend *bool `json:"suspend,omitempty" protobuf:"bytes,9,opt,name=suspend"` // NodeSelector is a selector which will result in all pods of the workflow // to be scheduled on the selected node(s). This is able to be overridden by // a nodeSelector specified in the template. NodeSelector map[string]string `json:"nodeSelector,omitempty" protobuf:"bytes,10,opt,name=nodeSelector"` // Affinity sets the scheduling constraints for all pods in the workflow. // Can be overridden by an affinity specified in the template Affinity *apiv1.Affinity `json:"affinity,omitempty" protobuf:"bytes,11,opt,name=affinity"` // Tolerations to apply to workflow pods. // +patchStrategy=merge // +patchMergeKey=key Tolerations []apiv1.Toleration `json:"tolerations,omitempty" patchStrategy:"merge" patchMergeKey:"key" protobuf:"bytes,12,opt,name=tolerations"` // ImagePullSecrets is a list of references to secrets in the same namespace to use for pulling any images // in pods that reference this ServiceAccount. ImagePullSecrets are distinct from Secrets because Secrets // can be mounted in the pod, but ImagePullSecrets are only accessed by the kubelet. // More info: https://kubernetes.io/docs/concepts/containers/images/#specifying-imagepullsecrets-on-a-pod // +patchStrategy=merge // +patchMergeKey=name ImagePullSecrets []apiv1.LocalObjectReference `json:"imagePullSecrets,omitempty" patchStrategy:"merge" patchMergeKey:"name" protobuf:"bytes,13,opt,name=imagePullSecrets"` // Host networking requested for this workflow pod. Default to false. HostNetwork *bool `json:"hostNetwork,omitempty" protobuf:"bytes,14,opt,name=hostNetwork"` // Set DNS policy for the pod. // Defaults to "ClusterFirst". // Valid values are 'ClusterFirstWithHostNet', 'ClusterFirst', 'Default' or 'None'. // DNS parameters given in DNSConfig will be merged with the policy selected with DNSPolicy. // To have DNS options set along with hostNetwork, you have to specify DNS policy // explicitly to 'ClusterFirstWithHostNet'. DNSPolicy *apiv1.DNSPolicy `json:"dnsPolicy,omitempty" protobuf:"bytes,15,opt,name=dnsPolicy"` // PodDNSConfig defines the DNS parameters of a pod in addition to // those generated from DNSPolicy. DNSConfig *apiv1.PodDNSConfig `json:"dnsConfig,omitempty" protobuf:"bytes,16,opt,name=dnsConfig"` // OnExit is a template reference which is invoked at the end of the // workflow, irrespective of the success, failure, or error of the // primary workflow. OnExit string `json:"onExit,omitempty" protobuf:"bytes,17,opt,name=onExit"` // TTLSecondsAfterFinished limits the lifetime of a Workflow that has finished execution // (Succeeded, Failed, Error). If this field is set, once the Workflow finishes, it will be // deleted after ttlSecondsAfterFinished expires. If this field is unset, // ttlSecondsAfterFinished will not expire. If this field is set to zero, // ttlSecondsAfterFinished expires immediately after the Workflow finishes. // DEPRECATED: Use TTLStrategy.SecondsAfterCompletion instead. TTLSecondsAfterFinished *int32 `json:"ttlSecondsAfterFinished,omitempty" protobuf:"bytes,18,opt,name=ttlSecondsAfterFinished"` // TTLStrategy limits the lifetime of a Workflow that has finished execution depending on if it // Succeeded or Failed. If this struct is set, once the Workflow finishes, it will be // deleted after the time to live expires. If this field is unset, // the controller config map will hold the default values // Update TTLStrategy *TTLStrategy `json:"ttlStrategy,omitempty" protobuf:"bytes,30,opt,name=ttlStrategy"` // Optional duration in seconds relative to the workflow start time which the workflow is // allowed to run before the controller terminates the workflow. A value of zero is used to // terminate a Running workflow ActiveDeadlineSeconds *int64 `json:"activeDeadlineSeconds,omitempty" protobuf:"bytes,19,opt,name=activeDeadlineSeconds"` // Priority is used if controller is configured to process limited number of workflows in parallel. Workflows with higher priority are processed first. Priority *int32 `json:"priority,omitempty" protobuf:"bytes,20,opt,name=priority"` // Set scheduler name for all pods. // Will be overridden if container/script template's scheduler name is set. // Default scheduler will be used if neither specified. // +optional SchedulerName string `json:"schedulerName,omitempty" protobuf:"bytes,21,opt,name=schedulerName"` // PodGC describes the strategy to use when to deleting completed pods PodGC *PodGC `json:"podGC,omitempty" protobuf:"bytes,22,opt,name=podGC"` // PriorityClassName to apply to workflow pods. PodPriorityClassName string `json:"podPriorityClassName,omitempty" protobuf:"bytes,23,opt,name=podPriorityClassName"` // Priority to apply to workflow pods. PodPriority *int32 `json:"podPriority,omitempty" protobuf:"bytes,24,opt,name=podPriority"` // +patchStrategy=merge // +patchMergeKey=ip HostAliases []apiv1.HostAlias `json:"hostAliases,omitempty" patchStrategy:"merge" patchMergeKey:"ip" protobuf:"bytes,25,opt,name=hostAliases"` // SecurityContext holds pod-level security attributes and common container settings. // Optional: Defaults to empty. See type description for default values of each field. // +optional SecurityContext *apiv1.PodSecurityContext `json:"securityContext,omitempty" protobuf:"bytes,26,opt,name=securityContext"` // PodSpecPatch holds strategic merge patch to apply against the pod spec. Allows parameterization of // container fields which are not strings (e.g. resource limits). PodSpecPatch string `json:"podSpecPatch,omitempty" protobuf:"bytes,27,opt,name=podSpecPatch"` }
WorkflowSpec is the specification of a Workflow.
func (*WorkflowSpec) DeepCopy ¶
func (in *WorkflowSpec) DeepCopy() *WorkflowSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new WorkflowSpec.
func (*WorkflowSpec) DeepCopyInto ¶
func (in *WorkflowSpec) DeepCopyInto(out *WorkflowSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*WorkflowSpec) Descriptor ¶
func (*WorkflowSpec) Descriptor() ([]byte, []int)
func (*WorkflowSpec) HasPodSpecPatch ¶
func (wfs *WorkflowSpec) HasPodSpecPatch() bool
func (*WorkflowSpec) Marshal ¶
func (m *WorkflowSpec) Marshal() (dAtA []byte, err error)
func (*WorkflowSpec) MarshalToSizedBuffer ¶
func (m *WorkflowSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*WorkflowSpec) ProtoMessage ¶
func (*WorkflowSpec) ProtoMessage()
func (*WorkflowSpec) Reset ¶
func (m *WorkflowSpec) Reset()
func (*WorkflowSpec) Size ¶
func (m *WorkflowSpec) Size() (n int)
func (*WorkflowSpec) String ¶
func (this *WorkflowSpec) String() string
func (*WorkflowSpec) Unmarshal ¶
func (m *WorkflowSpec) Unmarshal(dAtA []byte) error
func (*WorkflowSpec) XXX_DiscardUnknown ¶
func (m *WorkflowSpec) XXX_DiscardUnknown()
func (*WorkflowSpec) XXX_Marshal ¶
func (m *WorkflowSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*WorkflowSpec) XXX_Merge ¶
func (m *WorkflowSpec) XXX_Merge(src proto.Message)
func (*WorkflowSpec) XXX_Size ¶
func (m *WorkflowSpec) XXX_Size() int
func (*WorkflowSpec) XXX_Unmarshal ¶
func (m *WorkflowSpec) XXX_Unmarshal(b []byte) error
type WorkflowStatus ¶
type WorkflowStatus struct { // Phase a simple, high-level summary of where the workflow is in its lifecycle. Phase NodePhase `json:"phase,omitempty" protobuf:"bytes,1,opt,name=phase,casttype=NodePhase"` // Time at which this workflow started StartedAt metav1.Time `json:"startedAt,omitempty" protobuf:"bytes,2,opt,name=startedAt"` // Time at which this workflow completed FinishedAt metav1.Time `json:"finishedAt,omitempty" protobuf:"bytes,3,opt,name=finishedAt"` // A human readable message indicating details about why the workflow is in this condition. Message string `json:"message,omitempty" protobuf:"bytes,4,opt,name=message"` // Compressed and base64 decoded Nodes map CompressedNodes string `json:"compressedNodes,omitempty" protobuf:"bytes,5,opt,name=compressedNodes"` // Nodes is a mapping between a node ID and the node's status. Nodes Nodes `json:"nodes,omitempty" protobuf:"bytes,6,rep,name=nodes"` // Whether on not node status has been offloaded to a database. If exists, then Nodes and CompressedNodes will be empty. // This will actually be populated with a hash of the offloaded data. OffloadNodeStatusVersion string `json:"offloadNodeStatusVersion,omitempty" protobuf:"bytes,10,rep,name=offloadNodeStatusVersion"` // StoredTemplates is a mapping between a template ref and the node's status. StoredTemplates map[string]Template `json:"storedTemplates,omitempty" protobuf:"bytes,9,rep,name=storedTemplates"` // PersistentVolumeClaims tracks all PVCs that were created as part of the workflow. // The contents of this list are drained at the end of the workflow. PersistentVolumeClaims []apiv1.Volume `json:"persistentVolumeClaims,omitempty" protobuf:"bytes,7,rep,name=persistentVolumeClaims"` // Outputs captures output values and artifact locations produced by the workflow via global outputs Outputs *Outputs `json:"outputs,omitempty" protobuf:"bytes,8,opt,name=outputs"` }
WorkflowStatus contains overall status information about a workflow
func (*WorkflowStatus) Completed ¶
func (ws *WorkflowStatus) Completed() bool
Completed returns whether or not the workflow has completed execution
func (*WorkflowStatus) DeepCopy ¶
func (in *WorkflowStatus) DeepCopy() *WorkflowStatus
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new WorkflowStatus.
func (*WorkflowStatus) DeepCopyInto ¶
func (in *WorkflowStatus) DeepCopyInto(out *WorkflowStatus)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*WorkflowStatus) Descriptor ¶
func (*WorkflowStatus) Descriptor() ([]byte, []int)
func (*WorkflowStatus) Failed ¶
func (ws *WorkflowStatus) Failed() bool
Failed return whether or not the workflow has failed
func (*WorkflowStatus) GetOffloadNodeStatusVersion ¶
func (ws *WorkflowStatus) GetOffloadNodeStatusVersion() string
func (*WorkflowStatus) IsOffloadNodeStatus ¶
func (ws *WorkflowStatus) IsOffloadNodeStatus() bool
func (*WorkflowStatus) Marshal ¶
func (m *WorkflowStatus) Marshal() (dAtA []byte, err error)
func (*WorkflowStatus) MarshalToSizedBuffer ¶
func (m *WorkflowStatus) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*WorkflowStatus) ProtoMessage ¶
func (*WorkflowStatus) ProtoMessage()
func (*WorkflowStatus) Reset ¶
func (m *WorkflowStatus) Reset()
func (*WorkflowStatus) Size ¶
func (m *WorkflowStatus) Size() (n int)
func (*WorkflowStatus) String ¶
func (this *WorkflowStatus) String() string
func (*WorkflowStatus) Successful ¶
func (ws *WorkflowStatus) Successful() bool
Successful return whether or not the workflow has succeeded
func (*WorkflowStatus) Unmarshal ¶
func (m *WorkflowStatus) Unmarshal(dAtA []byte) error
func (*WorkflowStatus) XXX_DiscardUnknown ¶
func (m *WorkflowStatus) XXX_DiscardUnknown()
func (*WorkflowStatus) XXX_Marshal ¶
func (m *WorkflowStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*WorkflowStatus) XXX_Merge ¶
func (m *WorkflowStatus) XXX_Merge(src proto.Message)
func (*WorkflowStatus) XXX_Size ¶
func (m *WorkflowStatus) XXX_Size() int
func (*WorkflowStatus) XXX_Unmarshal ¶
func (m *WorkflowStatus) XXX_Unmarshal(b []byte) error
type WorkflowStep ¶
type WorkflowStep struct { // Name of the step Name string `json:"name,omitempty" protobuf:"bytes,1,opt,name=name"` // Template is the name of the template to execute as the step Template string `json:"template,omitempty" protobuf:"bytes,2,opt,name=template"` // Arguments hold arguments to the template Arguments Arguments `json:"arguments,omitempty" protobuf:"bytes,3,opt,name=arguments"` // TemplateRef is the reference to the template resource to execute as the step. TemplateRef *TemplateRef `json:"templateRef,omitempty" protobuf:"bytes,4,opt,name=templateRef"` // WithItems expands a step into multiple parallel steps from the items in the list WithItems []Item `json:"withItems,omitempty" protobuf:"bytes,5,rep,name=withItems"` // WithParam expands a step into multiple parallel steps from the value in the parameter, // which is expected to be a JSON list. WithParam string `json:"withParam,omitempty" protobuf:"bytes,6,opt,name=withParam"` // WithSequence expands a step into a numeric sequence WithSequence *Sequence `json:"withSequence,omitempty" protobuf:"bytes,7,opt,name=withSequence"` // When is an expression in which the step should conditionally execute When string `json:"when,omitempty" protobuf:"bytes,8,opt,name=when"` // ContinueOn makes argo to proceed with the following step even if this step fails. // Errors and Failed states can be specified ContinueOn *ContinueOn `json:"continueOn,omitempty" protobuf:"bytes,9,opt,name=continueOn"` // OnExit is a template reference which is invoked at the end of the // template, irrespective of the success, failure, or error of the // primary template. OnExit string `json:"onExit,omitempty" protobuf:"bytes,11,opt,name=onExit"` }
WorkflowStep is a reference to a template to execute in a series of step
func (*WorkflowStep) ContinuesOn ¶
func (s *WorkflowStep) ContinuesOn(phase NodePhase) bool
ContinuesOn returns whether the StepGroup should be proceeded if the task fails or errors.
func (*WorkflowStep) DeepCopy ¶
func (in *WorkflowStep) DeepCopy() *WorkflowStep
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new WorkflowStep.
func (*WorkflowStep) DeepCopyInto ¶
func (in *WorkflowStep) DeepCopyInto(out *WorkflowStep)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*WorkflowStep) Descriptor ¶
func (*WorkflowStep) Descriptor() ([]byte, []int)
func (*WorkflowStep) GetTemplateName ¶
func (step *WorkflowStep) GetTemplateName() string
func (*WorkflowStep) GetTemplateRef ¶
func (step *WorkflowStep) GetTemplateRef() *TemplateRef
func (*WorkflowStep) IsResolvable ¶
func (step *WorkflowStep) IsResolvable() bool
func (*WorkflowStep) Marshal ¶
func (m *WorkflowStep) Marshal() (dAtA []byte, err error)
func (*WorkflowStep) MarshalToSizedBuffer ¶
func (m *WorkflowStep) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*WorkflowStep) ProtoMessage ¶
func (*WorkflowStep) ProtoMessage()
func (*WorkflowStep) Reset ¶
func (m *WorkflowStep) Reset()
func (*WorkflowStep) Size ¶
func (m *WorkflowStep) Size() (n int)
func (*WorkflowStep) String ¶
func (this *WorkflowStep) String() string
func (*WorkflowStep) Unmarshal ¶
func (m *WorkflowStep) Unmarshal(dAtA []byte) error
func (*WorkflowStep) XXX_DiscardUnknown ¶
func (m *WorkflowStep) XXX_DiscardUnknown()
func (*WorkflowStep) XXX_Marshal ¶
func (m *WorkflowStep) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*WorkflowStep) XXX_Merge ¶
func (m *WorkflowStep) XXX_Merge(src proto.Message)
func (*WorkflowStep) XXX_Size ¶
func (m *WorkflowStep) XXX_Size() int
func (*WorkflowStep) XXX_Unmarshal ¶
func (m *WorkflowStep) XXX_Unmarshal(b []byte) error
type WorkflowTemplate ¶
type WorkflowTemplate struct { metav1.TypeMeta `json:",inline"` metav1.ObjectMeta `json:"metadata,omitempty" protobuf:"bytes,1,opt,name=metadata"` Spec WorkflowTemplateSpec `json:"spec" protobuf:"bytes,2,opt,name=spec"` }
WorkflowTemplate is the definition of a workflow template resource +genclient +genclient:noStatus +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object
func (*WorkflowTemplate) DeepCopy ¶
func (in *WorkflowTemplate) DeepCopy() *WorkflowTemplate
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new WorkflowTemplate.
func (*WorkflowTemplate) DeepCopyInto ¶
func (in *WorkflowTemplate) DeepCopyInto(out *WorkflowTemplate)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*WorkflowTemplate) DeepCopyObject ¶
func (in *WorkflowTemplate) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
func (*WorkflowTemplate) Descriptor ¶
func (*WorkflowTemplate) Descriptor() ([]byte, []int)
func (*WorkflowTemplate) GetTemplateByName ¶
func (wftmpl *WorkflowTemplate) GetTemplateByName(name string) *Template
GetTemplateByName retrieves a defined template by its name
func (*WorkflowTemplate) GetTemplateScope ¶
func (wftmpl *WorkflowTemplate) GetTemplateScope() string
GetTemplateScope returns the template scope of workflow template.
func (*WorkflowTemplate) Marshal ¶
func (m *WorkflowTemplate) Marshal() (dAtA []byte, err error)
func (*WorkflowTemplate) MarshalToSizedBuffer ¶
func (m *WorkflowTemplate) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*WorkflowTemplate) ProtoMessage ¶
func (*WorkflowTemplate) ProtoMessage()
func (*WorkflowTemplate) Reset ¶
func (m *WorkflowTemplate) Reset()
func (*WorkflowTemplate) Size ¶
func (m *WorkflowTemplate) Size() (n int)
func (*WorkflowTemplate) String ¶
func (this *WorkflowTemplate) String() string
func (*WorkflowTemplate) Unmarshal ¶
func (m *WorkflowTemplate) Unmarshal(dAtA []byte) error
func (*WorkflowTemplate) XXX_DiscardUnknown ¶
func (m *WorkflowTemplate) XXX_DiscardUnknown()
func (*WorkflowTemplate) XXX_Marshal ¶
func (m *WorkflowTemplate) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*WorkflowTemplate) XXX_Merge ¶
func (m *WorkflowTemplate) XXX_Merge(src proto.Message)
func (*WorkflowTemplate) XXX_Size ¶
func (m *WorkflowTemplate) XXX_Size() int
func (*WorkflowTemplate) XXX_Unmarshal ¶
func (m *WorkflowTemplate) XXX_Unmarshal(b []byte) error
type WorkflowTemplateList ¶
type WorkflowTemplateList struct { metav1.TypeMeta `json:",inline"` metav1.ListMeta `json:"metadata" protobuf:"bytes,1,opt,name=metadata"` Items WorkflowTemplates `json:"items" protobuf:"bytes,2,rep,name=items"` }
WorkflowTemplateList is list of WorkflowTemplate resources +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object
func (*WorkflowTemplateList) DeepCopy ¶
func (in *WorkflowTemplateList) DeepCopy() *WorkflowTemplateList
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new WorkflowTemplateList.
func (*WorkflowTemplateList) DeepCopyInto ¶
func (in *WorkflowTemplateList) DeepCopyInto(out *WorkflowTemplateList)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*WorkflowTemplateList) DeepCopyObject ¶
func (in *WorkflowTemplateList) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
func (*WorkflowTemplateList) Descriptor ¶
func (*WorkflowTemplateList) Descriptor() ([]byte, []int)
func (*WorkflowTemplateList) Marshal ¶
func (m *WorkflowTemplateList) Marshal() (dAtA []byte, err error)
func (*WorkflowTemplateList) MarshalTo ¶
func (m *WorkflowTemplateList) MarshalTo(dAtA []byte) (int, error)
func (*WorkflowTemplateList) MarshalToSizedBuffer ¶
func (m *WorkflowTemplateList) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*WorkflowTemplateList) ProtoMessage ¶
func (*WorkflowTemplateList) ProtoMessage()
func (*WorkflowTemplateList) Reset ¶
func (m *WorkflowTemplateList) Reset()
func (*WorkflowTemplateList) Size ¶
func (m *WorkflowTemplateList) Size() (n int)
func (*WorkflowTemplateList) String ¶
func (this *WorkflowTemplateList) String() string
func (*WorkflowTemplateList) Unmarshal ¶
func (m *WorkflowTemplateList) Unmarshal(dAtA []byte) error
func (*WorkflowTemplateList) XXX_DiscardUnknown ¶
func (m *WorkflowTemplateList) XXX_DiscardUnknown()
func (*WorkflowTemplateList) XXX_Marshal ¶
func (m *WorkflowTemplateList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*WorkflowTemplateList) XXX_Merge ¶
func (m *WorkflowTemplateList) XXX_Merge(src proto.Message)
func (*WorkflowTemplateList) XXX_Size ¶
func (m *WorkflowTemplateList) XXX_Size() int
func (*WorkflowTemplateList) XXX_Unmarshal ¶
func (m *WorkflowTemplateList) XXX_Unmarshal(b []byte) error
type WorkflowTemplateSpec ¶
type WorkflowTemplateSpec struct { // Templates is a list of workflow templates. Templates []Template `json:"templates" protobuf:"bytes,1,rep,name=templates"` // Arguments hold arguments to the template. Arguments Arguments `json:"arguments,omitempty" protobuf:"bytes,3,opt,name=arguments"` }
WorkflowTemplateSpec is a spec of WorkflowTemplate.
func (*WorkflowTemplateSpec) DeepCopy ¶
func (in *WorkflowTemplateSpec) DeepCopy() *WorkflowTemplateSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new WorkflowTemplateSpec.
func (*WorkflowTemplateSpec) DeepCopyInto ¶
func (in *WorkflowTemplateSpec) DeepCopyInto(out *WorkflowTemplateSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*WorkflowTemplateSpec) Descriptor ¶
func (*WorkflowTemplateSpec) Descriptor() ([]byte, []int)
func (*WorkflowTemplateSpec) Marshal ¶
func (m *WorkflowTemplateSpec) Marshal() (dAtA []byte, err error)
func (*WorkflowTemplateSpec) MarshalTo ¶
func (m *WorkflowTemplateSpec) MarshalTo(dAtA []byte) (int, error)
func (*WorkflowTemplateSpec) MarshalToSizedBuffer ¶
func (m *WorkflowTemplateSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*WorkflowTemplateSpec) ProtoMessage ¶
func (*WorkflowTemplateSpec) ProtoMessage()
func (*WorkflowTemplateSpec) Reset ¶
func (m *WorkflowTemplateSpec) Reset()
func (*WorkflowTemplateSpec) Size ¶
func (m *WorkflowTemplateSpec) Size() (n int)
func (*WorkflowTemplateSpec) String ¶
func (this *WorkflowTemplateSpec) String() string
func (*WorkflowTemplateSpec) Unmarshal ¶
func (m *WorkflowTemplateSpec) Unmarshal(dAtA []byte) error
func (*WorkflowTemplateSpec) XXX_DiscardUnknown ¶
func (m *WorkflowTemplateSpec) XXX_DiscardUnknown()
func (*WorkflowTemplateSpec) XXX_Marshal ¶
func (m *WorkflowTemplateSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*WorkflowTemplateSpec) XXX_Merge ¶
func (m *WorkflowTemplateSpec) XXX_Merge(src proto.Message)
func (*WorkflowTemplateSpec) XXX_Size ¶
func (m *WorkflowTemplateSpec) XXX_Size() int
func (*WorkflowTemplateSpec) XXX_Unmarshal ¶
func (m *WorkflowTemplateSpec) XXX_Unmarshal(b []byte) error
type WorkflowTemplates ¶
type WorkflowTemplates []WorkflowTemplate
func (WorkflowTemplates) DeepCopy ¶
func (in WorkflowTemplates) DeepCopy() WorkflowTemplates
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new WorkflowTemplates.
func (WorkflowTemplates) DeepCopyInto ¶
func (in WorkflowTemplates) DeepCopyInto(out *WorkflowTemplates)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (WorkflowTemplates) Len ¶
func (w WorkflowTemplates) Len() int
func (WorkflowTemplates) Less ¶
func (w WorkflowTemplates) Less(i, j int) bool
func (WorkflowTemplates) Swap ¶
func (w WorkflowTemplates) Swap(i, j int)
type Workflows ¶
type Workflows []Workflow
Workflows is a sort interface which sorts running jobs earlier before considering FinishedAt
func (Workflows) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Workflows.
func (Workflows) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.