Versions in this module Expand all Collapse all v0 v0.1.2 Jun 3, 2020 Changes in this version + var AddToScheme = SchemeBuilder.AddToScheme + var ErrIntOverflowGenerated = fmt.Errorf("proto: integer overflow") + var ErrInvalidLengthGenerated = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrUnexpectedEndOfGroupGenerated = fmt.Errorf("proto: unexpected end of group") + var SchemeBuilder = runtime.NewSchemeBuilder(addKnownTypes) + var SchemeGroupVersion = schema.GroupVersion + var WorkflowSchemaGroupVersionKind = schema.GroupVersionKind + func Kind(kind string) schema.GroupKind + func Resource(resource string) schema.GroupResource + type ArchiveStrategy struct + None *NoneStrategy + Tar *TarStrategy + func (*ArchiveStrategy) Descriptor() ([]byte, []int) + func (*ArchiveStrategy) ProtoMessage() + func (in *ArchiveStrategy) DeepCopy() *ArchiveStrategy + func (in *ArchiveStrategy) DeepCopyInto(out *ArchiveStrategy) + 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 (m *ArchiveStrategy) Reset() + func (m *ArchiveStrategy) Size() (n int) + 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 + func (this *ArchiveStrategy) String() string + type Arguments struct + Artifacts Artifacts + Parameters []Parameter + func (*Arguments) Descriptor() ([]byte, []int) + func (*Arguments) ProtoMessage() + func (args *Arguments) GetArtifactByName(name string) *Artifact + func (args *Arguments) GetParameterByName(name string) *Parameter + func (in *Arguments) DeepCopy() *Arguments + func (in *Arguments) DeepCopyInto(out *Arguments) + 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 (m *Arguments) Reset() + func (m *Arguments) Size() (n int) + 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 + func (this *Arguments) String() string + type ArgumentsProvider interface + GetArtifactByName func(name string) *Artifact + GetParameterByName func(name string) *Parameter + type Artifact struct + Archive *ArchiveStrategy + From string + GlobalName string + Mode *int32 + Name string + Optional bool + Path string + func (*Artifact) Descriptor() ([]byte, []int) + func (*Artifact) ProtoMessage() + func (a *Artifact) HasLocation() bool + func (in *Artifact) DeepCopy() *Artifact + func (in *Artifact) DeepCopyInto(out *Artifact) + 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 (m *Artifact) Reset() + func (m *Artifact) Size() (n int) + 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 + func (this *Artifact) String() string + type ArtifactLocation struct + ArchiveLogs *bool + Artifactory *ArtifactoryArtifact + Git *GitArtifact + HDFS *HDFSArtifact + HTTP *HTTPArtifact + Raw *RawArtifact + S3 *S3Artifact + func (*ArtifactLocation) Descriptor() ([]byte, []int) + func (*ArtifactLocation) ProtoMessage() + func (in *ArtifactLocation) DeepCopy() *ArtifactLocation + func (in *ArtifactLocation) DeepCopyInto(out *ArtifactLocation) + 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 (m *ArtifactLocation) Reset() + func (m *ArtifactLocation) Size() (n int) + 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 + func (this *ArtifactLocation) String() string + type ArtifactRepositoryRef struct + ConfigMap string + Key string + func (*ArtifactRepositoryRef) Descriptor() ([]byte, []int) + func (*ArtifactRepositoryRef) ProtoMessage() + func (in *ArtifactRepositoryRef) DeepCopy() *ArtifactRepositoryRef + func (in *ArtifactRepositoryRef) DeepCopyInto(out *ArtifactRepositoryRef) + 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 (m *ArtifactRepositoryRef) Reset() + func (m *ArtifactRepositoryRef) Size() (n int) + 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 + func (this *ArtifactRepositoryRef) String() string + type ArtifactoryArtifact struct + URL string + func (*ArtifactoryArtifact) Descriptor() ([]byte, []int) + func (*ArtifactoryArtifact) ProtoMessage() + func (a *ArtifactoryArtifact) HasLocation() bool + func (in *ArtifactoryArtifact) DeepCopy() *ArtifactoryArtifact + func (in *ArtifactoryArtifact) DeepCopyInto(out *ArtifactoryArtifact) + 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 (m *ArtifactoryArtifact) Reset() + func (m *ArtifactoryArtifact) Size() (n int) + 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 + func (this *ArtifactoryArtifact) String() string + type ArtifactoryAuth struct + PasswordSecret *apiv1.SecretKeySelector + UsernameSecret *apiv1.SecretKeySelector + func (*ArtifactoryAuth) Descriptor() ([]byte, []int) + func (*ArtifactoryAuth) ProtoMessage() + func (in *ArtifactoryAuth) DeepCopy() *ArtifactoryAuth + func (in *ArtifactoryAuth) DeepCopyInto(out *ArtifactoryAuth) + 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 (m *ArtifactoryAuth) Reset() + func (m *ArtifactoryAuth) Size() (n int) + 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 + func (this *ArtifactoryAuth) String() string + type Artifacts []Artifact + func (a Artifacts) GetArtifactByName(name string) *Artifact + func (in Artifacts) DeepCopy() Artifacts + func (in Artifacts) DeepCopyInto(out *Artifacts) + type Backoff struct + Duration string + Factor int32 + MaxDuration string + func (*Backoff) Descriptor() ([]byte, []int) + func (*Backoff) ProtoMessage() + func (in *Backoff) DeepCopy() *Backoff + func (in *Backoff) DeepCopyInto(out *Backoff) + 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 (m *Backoff) Reset() + func (m *Backoff) Size() (n int) + 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 + func (this *Backoff) String() string + type ConcurrencyPolicy string + const AllowConcurrent + const ForbidConcurrent + const ReplaceConcurrent + type ContinueOn struct + Error bool + Failed bool + func (*ContinueOn) Descriptor() ([]byte, []int) + func (*ContinueOn) ProtoMessage() + func (in *ContinueOn) DeepCopy() *ContinueOn + func (in *ContinueOn) DeepCopyInto(out *ContinueOn) + 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 (m *ContinueOn) Reset() + func (m *ContinueOn) Size() (n int) + 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 + func (this *ContinueOn) String() string + type CronWorkflow struct + Spec CronWorkflowSpec + Status CronWorkflowStatus + func (*CronWorkflow) Descriptor() ([]byte, []int) + func (*CronWorkflow) ProtoMessage() + func (in *CronWorkflow) DeepCopy() *CronWorkflow + func (in *CronWorkflow) DeepCopyInto(out *CronWorkflow) + func (in *CronWorkflow) DeepCopyObject() runtime.Object + 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 (m *CronWorkflow) Reset() + func (m *CronWorkflow) Size() (n int) + 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 + func (this *CronWorkflow) String() string + type CronWorkflowList struct + Items []CronWorkflow + func (*CronWorkflowList) Descriptor() ([]byte, []int) + func (*CronWorkflowList) ProtoMessage() + func (in *CronWorkflowList) DeepCopy() *CronWorkflowList + func (in *CronWorkflowList) DeepCopyInto(out *CronWorkflowList) + func (in *CronWorkflowList) DeepCopyObject() runtime.Object + 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 (m *CronWorkflowList) Reset() + func (m *CronWorkflowList) Size() (n int) + 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 + func (this *CronWorkflowList) String() string + type CronWorkflowSpec struct + ConcurrencyPolicy ConcurrencyPolicy + FailedJobsHistoryLimit *int32 + Schedule string + StartingDeadlineSeconds *int64 + SuccessfulJobsHistoryLimit *int32 + Suspend bool + Timezone string + WorkflowSpec WorkflowSpec + func (*CronWorkflowSpec) Descriptor() ([]byte, []int) + func (*CronWorkflowSpec) ProtoMessage() + func (in *CronWorkflowSpec) DeepCopy() *CronWorkflowSpec + func (in *CronWorkflowSpec) DeepCopyInto(out *CronWorkflowSpec) + 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 (m *CronWorkflowSpec) Reset() + func (m *CronWorkflowSpec) Size() (n int) + 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 + func (this *CronWorkflowSpec) String() string + type CronWorkflowStatus struct + Active []v1.ObjectReference + LastScheduledTime *metav1.Time + func (*CronWorkflowStatus) Descriptor() ([]byte, []int) + func (*CronWorkflowStatus) ProtoMessage() + func (in *CronWorkflowStatus) DeepCopy() *CronWorkflowStatus + func (in *CronWorkflowStatus) DeepCopyInto(out *CronWorkflowStatus) + 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 (m *CronWorkflowStatus) Reset() + func (m *CronWorkflowStatus) Size() (n int) + 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 + func (this *CronWorkflowStatus) String() string + type DAGTask struct + Arguments Arguments + ContinueOn *ContinueOn + Dependencies []string + Name string + OnExit string + Template string + TemplateRef *TemplateRef + When string + WithItems []Item + WithParam string + WithSequence *Sequence + func (*DAGTask) Descriptor() ([]byte, []int) + func (*DAGTask) ProtoMessage() + func (in *DAGTask) DeepCopy() *DAGTask + func (in *DAGTask) DeepCopyInto(out *DAGTask) + 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 (m *DAGTask) Reset() + func (m *DAGTask) Size() (n int) + 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 + func (t *DAGTask) ContinuesOn(phase NodePhase) bool + func (t *DAGTask) GetTemplateName() string + func (t *DAGTask) GetTemplateRef() *TemplateRef + func (t *DAGTask) IsResolvable() bool + func (this *DAGTask) String() string + type DAGTemplate struct + FailFast *bool + Target string + Tasks []DAGTask + func (*DAGTemplate) Descriptor() ([]byte, []int) + func (*DAGTemplate) ProtoMessage() + func (in *DAGTemplate) DeepCopy() *DAGTemplate + func (in *DAGTemplate) DeepCopyInto(out *DAGTemplate) + 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 (m *DAGTemplate) Reset() + func (m *DAGTemplate) Size() (n int) + 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 + func (this *DAGTemplate) String() string + type ExecutorConfig struct + ServiceAccountName string + func (*ExecutorConfig) Descriptor() ([]byte, []int) + func (*ExecutorConfig) ProtoMessage() + func (in *ExecutorConfig) DeepCopy() *ExecutorConfig + func (in *ExecutorConfig) DeepCopyInto(out *ExecutorConfig) + 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 (m *ExecutorConfig) Reset() + func (m *ExecutorConfig) Size() (n int) + 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 + func (this *ExecutorConfig) String() string + type GitArtifact struct + Depth *uint64 + Fetch []string + InsecureIgnoreHostKey bool + PasswordSecret *apiv1.SecretKeySelector + Repo string + Revision string + SSHPrivateKeySecret *apiv1.SecretKeySelector + UsernameSecret *apiv1.SecretKeySelector + func (*GitArtifact) Descriptor() ([]byte, []int) + func (*GitArtifact) ProtoMessage() + func (g *GitArtifact) HasLocation() bool + func (in *GitArtifact) DeepCopy() *GitArtifact + func (in *GitArtifact) DeepCopyInto(out *GitArtifact) + 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 (m *GitArtifact) Reset() + func (m *GitArtifact) Size() (n int) + 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 + func (this *GitArtifact) String() string + type HDFSArtifact struct + Force bool + Path string + func (*HDFSArtifact) Descriptor() ([]byte, []int) + func (*HDFSArtifact) ProtoMessage() + func (h *HDFSArtifact) HasLocation() bool + func (in *HDFSArtifact) DeepCopy() *HDFSArtifact + func (in *HDFSArtifact) DeepCopyInto(out *HDFSArtifact) + 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 (m *HDFSArtifact) Reset() + func (m *HDFSArtifact) Size() (n int) + 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 + func (this *HDFSArtifact) String() string + type HDFSConfig struct + Addresses []string + HDFSUser string + func (*HDFSConfig) Descriptor() ([]byte, []int) + func (*HDFSConfig) ProtoMessage() + func (in *HDFSConfig) DeepCopy() *HDFSConfig + func (in *HDFSConfig) DeepCopyInto(out *HDFSConfig) + 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 (m *HDFSConfig) Reset() + func (m *HDFSConfig) Size() (n int) + 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 + func (this *HDFSConfig) String() string + type HDFSKrbConfig struct + KrbCCacheSecret *apiv1.SecretKeySelector + KrbConfigConfigMap *apiv1.ConfigMapKeySelector + KrbKeytabSecret *apiv1.SecretKeySelector + KrbRealm string + KrbServicePrincipalName string + KrbUsername string + func (*HDFSKrbConfig) Descriptor() ([]byte, []int) + func (*HDFSKrbConfig) ProtoMessage() + func (in *HDFSKrbConfig) DeepCopy() *HDFSKrbConfig + func (in *HDFSKrbConfig) DeepCopyInto(out *HDFSKrbConfig) + 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 (m *HDFSKrbConfig) Reset() + func (m *HDFSKrbConfig) Size() (n int) + 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 + func (this *HDFSKrbConfig) String() string + type HTTPArtifact struct + URL string + func (*HTTPArtifact) Descriptor() ([]byte, []int) + func (*HTTPArtifact) ProtoMessage() + func (h *HTTPArtifact) HasLocation() bool + func (in *HTTPArtifact) DeepCopy() *HTTPArtifact + func (in *HTTPArtifact) DeepCopyInto(out *HTTPArtifact) + 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 (m *HTTPArtifact) Reset() + func (m *HTTPArtifact) Size() (n int) + 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 + func (this *HTTPArtifact) String() string + type Inputs struct + Artifacts Artifacts + Parameters []Parameter + func (*Inputs) Descriptor() ([]byte, []int) + func (*Inputs) ProtoMessage() + func (in *Inputs) DeepCopy() *Inputs + func (in *Inputs) DeepCopyInto(out *Inputs) + 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 (m *Inputs) Reset() + func (m *Inputs) Size() (n int) + 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 + func (this *Inputs) String() string + type Item struct + BoolVal bool + ListVal []ItemValue + MapVal map[string]ItemValue + NumVal json.Number + StrVal string + Type Type + func (*Item) Descriptor() ([]byte, []int) + func (*Item) ProtoMessage() + func (i *Item) DeepCopyInto(out *Item) + func (i *Item) String() string + func (i *Item) UnmarshalJSON(value []byte) error + func (i Item) Format(s fmt.State, verb rune) + func (i Item) MarshalJSON() ([]byte, error) + func (i Item) OpenAPISchemaFormat() string + func (i Item) OpenAPISchemaType() []string + func (in *Item) DeepCopy() *Item + func (m *Item) Marshal() (dAtA []byte, err error) + func (m *Item) MarshalTo(dAtA []byte) (int, error) + func (m *Item) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Item) Reset() + func (m *Item) Size() (n int) + func (m *Item) Unmarshal(dAtA []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 struct + BoolVal bool + ListVal []json.RawMessage + MapVal map[string]string + NumVal json.Number + StrVal string + Type Type + func (*ItemValue) Descriptor() ([]byte, []int) + func (*ItemValue) ProtoMessage() + func (in *ItemValue) DeepCopy() *ItemValue + func (in *ItemValue) DeepCopyInto(out *ItemValue) + func (iv *ItemValue) String() string + func (iv *ItemValue) UnmarshalJSON(value []byte) error + func (iv ItemValue) Format(s fmt.State, verb rune) + func (iv ItemValue) MarshalJSON() ([]byte, error) + func (m *ItemValue) Marshal() (dAtA []byte, err error) + func (m *ItemValue) MarshalTo(dAtA []byte) (int, error) + func (m *ItemValue) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ItemValue) Reset() + func (m *ItemValue) Size() (n int) + func (m *ItemValue) Unmarshal(dAtA []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 struct + Annotations map[string]string + Labels map[string]string + func (*Metadata) Descriptor() ([]byte, []int) + func (*Metadata) ProtoMessage() + func (in *Metadata) DeepCopy() *Metadata + func (in *Metadata) DeepCopyInto(out *Metadata) + 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 (m *Metadata) Reset() + func (m *Metadata) Size() (n int) + 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 + func (this *Metadata) String() string + type NodePhase string + const NodeError + const NodeFailed + const NodePending + const NodeRunning + const NodeSkipped + const NodeSucceeded + type NodeStatus struct + BoundaryID string + Children []string + Daemoned *bool + DisplayName string + FinishedAt metav1.Time + ID string + Inputs *Inputs + Message string + Name string + OutboundNodes []string + Outputs *Outputs + Phase NodePhase + PodIP string + StartedAt metav1.Time + StoredTemplateID string + TemplateName string + TemplateRef *TemplateRef + TemplateScope string + Type NodeType + WorkflowTemplateName string + func (*NodeStatus) Descriptor() ([]byte, []int) + func (*NodeStatus) ProtoMessage() + func (in *NodeStatus) DeepCopy() *NodeStatus + func (in *NodeStatus) DeepCopyInto(out *NodeStatus) + 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 (m *NodeStatus) Reset() + func (m *NodeStatus) Size() (n int) + 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 + func (n *NodeStatus) GetTemplateName() string + func (n *NodeStatus) GetTemplateRef() *TemplateRef + func (n *NodeStatus) IsActiveSuspendNode() bool + func (n *NodeStatus) IsResolvable() bool + func (n NodeStatus) CanRetry() bool + func (n NodeStatus) Completed() bool + func (n NodeStatus) IsDaemoned() bool + func (n NodeStatus) Successful() bool + func (this *NodeStatus) String() string + type NodeType string + const NodeTypeDAG + const NodeTypePod + const NodeTypeRetry + const NodeTypeSkipped + const NodeTypeStepGroup + const NodeTypeSteps + const NodeTypeSuspend + const NodeTypeTaskGroup + type Nodes map[string]NodeStatus + func (in Nodes) Any(f func(node NodeStatus) bool) bool + func (in Nodes) DeepCopy() Nodes + func (in Nodes) DeepCopyInto(out *Nodes) + func (n Nodes) FindByDisplayName(name string) *NodeStatus + type NoneStrategy struct + func (*NoneStrategy) Descriptor() ([]byte, []int) + func (*NoneStrategy) ProtoMessage() + func (in *NoneStrategy) DeepCopy() *NoneStrategy + func (in *NoneStrategy) DeepCopyInto(out *NoneStrategy) + 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 (m *NoneStrategy) Reset() + func (m *NoneStrategy) Size() (n int) + 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 + func (this *NoneStrategy) String() string + type Outputs struct + Artifacts Artifacts + Parameters []Parameter + Result *string + func (*Outputs) Descriptor() ([]byte, []int) + func (*Outputs) ProtoMessage() + func (in *Outputs) DeepCopy() *Outputs + func (in *Outputs) DeepCopyInto(out *Outputs) + 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 (m *Outputs) Reset() + func (m *Outputs) Size() (n int) + 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 + func (out *Outputs) GetArtifactByName(name string) *Artifact + func (out *Outputs) HasOutputs() bool + func (this *Outputs) String() string + type ParallelSteps struct + Steps []WorkflowStep + func (*ParallelSteps) Descriptor() ([]byte, []int) + func (*ParallelSteps) ProtoMessage() + func (in *ParallelSteps) DeepCopy() *ParallelSteps + func (in *ParallelSteps) DeepCopyInto(out *ParallelSteps) + func (m *ParallelSteps) Marshal() (dAtA []byte, err error) + func (m *ParallelSteps) MarshalTo(dAtA []byte) (int, error) + func (m *ParallelSteps) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ParallelSteps) Reset() + func (m *ParallelSteps) Size() (n int) + func (m *ParallelSteps) Unmarshal(dAtA []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 + func (p *ParallelSteps) MarshalJSON() ([]byte, error) + func (p *ParallelSteps) UnmarshalJSON(value []byte) error + func (this *ParallelSteps) String() string + type Parameter struct + Default *string + GlobalName string + Name string + Value *string + ValueFrom *ValueFrom + func (*Parameter) Descriptor() ([]byte, []int) + func (*Parameter) ProtoMessage() + func (in *Parameter) DeepCopy() *Parameter + func (in *Parameter) DeepCopyInto(out *Parameter) + 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 (m *Parameter) Reset() + func (m *Parameter) Size() (n int) + 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 + func (p *Parameter) UnmarshalJSON(value []byte) error + func (this *Parameter) String() string + type PodGC struct + Strategy PodGCStrategy + func (*PodGC) Descriptor() ([]byte, []int) + func (*PodGC) ProtoMessage() + func (in *PodGC) DeepCopy() *PodGC + func (in *PodGC) DeepCopyInto(out *PodGC) + 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 (m *PodGC) Reset() + func (m *PodGC) Size() (n int) + 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 + func (this *PodGC) String() string + type PodGCStrategy string + const PodGCOnPodCompletion + const PodGCOnPodSuccess + const PodGCOnWorkflowCompletion + const PodGCOnWorkflowSuccess + type RawArtifact struct + Data string + func (*RawArtifact) Descriptor() ([]byte, []int) + func (*RawArtifact) ProtoMessage() + func (in *RawArtifact) DeepCopy() *RawArtifact + func (in *RawArtifact) DeepCopyInto(out *RawArtifact) + 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 (m *RawArtifact) Reset() + func (m *RawArtifact) Size() (n int) + 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 + func (r *RawArtifact) HasLocation() bool + func (this *RawArtifact) String() string + type ResourceTemplate struct + Action string + FailureCondition string + Manifest string + MergeStrategy string + SetOwnerReference bool + SuccessCondition string + func (*ResourceTemplate) Descriptor() ([]byte, []int) + func (*ResourceTemplate) ProtoMessage() + func (in *ResourceTemplate) DeepCopy() *ResourceTemplate + func (in *ResourceTemplate) DeepCopyInto(out *ResourceTemplate) + 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 (m *ResourceTemplate) Reset() + func (m *ResourceTemplate) Size() (n int) + 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 + func (this *ResourceTemplate) String() string + type RetryPolicy string + const RetryPolicyAlways + const RetryPolicyOnError + const RetryPolicyOnFailure + type RetryStrategy struct + Backoff *Backoff + Limit *int32 + RetryPolicy RetryPolicy + func (*RetryStrategy) Descriptor() ([]byte, []int) + func (*RetryStrategy) ProtoMessage() + func (in *RetryStrategy) DeepCopy() *RetryStrategy + func (in *RetryStrategy) DeepCopyInto(out *RetryStrategy) + 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 (m *RetryStrategy) Reset() + func (m *RetryStrategy) Size() (n int) + 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 + func (this *RetryStrategy) String() string + type S3Artifact struct + Key string + func (*S3Artifact) Descriptor() ([]byte, []int) + func (*S3Artifact) ProtoMessage() + func (in *S3Artifact) DeepCopy() *S3Artifact + func (in *S3Artifact) DeepCopyInto(out *S3Artifact) + 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 (m *S3Artifact) Reset() + func (m *S3Artifact) Size() (n int) + 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 + func (s *S3Artifact) HasLocation() bool + func (this *S3Artifact) String() string + type S3Bucket struct + AccessKeySecret apiv1.SecretKeySelector + Bucket string + Endpoint string + Insecure *bool + Region string + RoleARN string + SecretKeySecret apiv1.SecretKeySelector + func (*S3Bucket) Descriptor() ([]byte, []int) + func (*S3Bucket) ProtoMessage() + func (in *S3Bucket) DeepCopy() *S3Bucket + func (in *S3Bucket) DeepCopyInto(out *S3Bucket) + 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 (m *S3Bucket) Reset() + func (m *S3Bucket) Size() (n int) + 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 + func (this *S3Bucket) String() string + type ScriptTemplate struct + Source string + func (*ScriptTemplate) Descriptor() ([]byte, []int) + func (*ScriptTemplate) ProtoMessage() + func (in *ScriptTemplate) DeepCopy() *ScriptTemplate + func (in *ScriptTemplate) DeepCopyInto(out *ScriptTemplate) + 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 (m *ScriptTemplate) Reset() + func (m *ScriptTemplate) Size() (n int) + 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 + func (this *ScriptTemplate) String() string + type Sequence struct + Count string + End string + Format string + Start string + func (*Sequence) Descriptor() ([]byte, []int) + func (*Sequence) ProtoMessage() + func (in *Sequence) DeepCopy() *Sequence + func (in *Sequence) DeepCopyInto(out *Sequence) + 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 (m *Sequence) Reset() + func (m *Sequence) Size() (n int) + 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 + func (this *Sequence) String() string + type SuspendTemplate struct + Duration string + func (*SuspendTemplate) Descriptor() ([]byte, []int) + func (*SuspendTemplate) ProtoMessage() + func (in *SuspendTemplate) DeepCopy() *SuspendTemplate + func (in *SuspendTemplate) DeepCopyInto(out *SuspendTemplate) + 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 (m *SuspendTemplate) Reset() + func (m *SuspendTemplate) Size() (n int) + 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 + func (this *SuspendTemplate) String() string + type TTLStrategy struct + SecondsAfterCompletion *int32 + SecondsAfterFailure *int32 + SecondsAfterSuccess *int32 + func (*TTLStrategy) Descriptor() ([]byte, []int) + func (*TTLStrategy) ProtoMessage() + func (in *TTLStrategy) DeepCopy() *TTLStrategy + func (in *TTLStrategy) DeepCopyInto(out *TTLStrategy) + 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 (m *TTLStrategy) Reset() + func (m *TTLStrategy) Size() (n int) + 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 + func (this *TTLStrategy) String() string + type TarStrategy struct + func (*TarStrategy) Descriptor() ([]byte, []int) + func (*TarStrategy) ProtoMessage() + func (in *TarStrategy) DeepCopy() *TarStrategy + func (in *TarStrategy) DeepCopyInto(out *TarStrategy) + 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 (m *TarStrategy) Reset() + func (m *TarStrategy) Size() (n int) + 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 + func (this *TarStrategy) String() string + type Template struct + ActiveDeadlineSeconds *int64 + Affinity *apiv1.Affinity + ArchiveLocation *ArtifactLocation + AutomountServiceAccountToken *bool + Container *apiv1.Container + DAG *DAGTemplate + Daemon *bool + Executor *ExecutorConfig + HostAliases []apiv1.HostAlias + InitContainers []UserContainer + Inputs Inputs + Metadata Metadata + Name string + NodeSelector map[string]string + Outputs Outputs + Parallelism *int64 + PodSpecPatch string + Priority *int32 + PriorityClassName string + Resource *ResourceTemplate + RetryStrategy *RetryStrategy + SchedulerName string + Script *ScriptTemplate + SecurityContext *apiv1.PodSecurityContext + ServiceAccountName string + Sidecars []UserContainer + Steps []ParallelSteps + Suspend *SuspendTemplate + Template string + TemplateRef *TemplateRef + Tolerations []apiv1.Toleration + Volumes []apiv1.Volume + func (*Template) Descriptor() ([]byte, []int) + func (*Template) ProtoMessage() + func (in *Template) DeepCopy() *Template + func (in *Template) DeepCopyInto(out *Template) + 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 (m *Template) Reset() + func (m *Template) Size() (n int) + 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 + func (this *Template) String() string + func (tmpl *Template) GetBaseTemplate() *Template + func (tmpl *Template) GetTemplateName() string + func (tmpl *Template) GetTemplateRef() *TemplateRef + func (tmpl *Template) GetType() TemplateType + func (tmpl *Template) HasPodSpecPatch() bool + func (tmpl *Template) IsLeaf() bool + func (tmpl *Template) IsPodType() bool + func (tmpl *Template) IsResolvable() bool + type TemplateGetter interface + GetName func() string + GetNamespace func() string + GetTemplateByName func(name string) *Template + GetTemplateScope func() string + GroupVersionKind func() schema.GroupVersionKind + type TemplateHolder interface + GetTemplateName func() string + GetTemplateRef func() *TemplateRef + IsResolvable func() bool + type TemplateRef struct + Name string + RuntimeResolution bool + Template string + func (*TemplateRef) Descriptor() ([]byte, []int) + func (*TemplateRef) ProtoMessage() + func (in *TemplateRef) DeepCopy() *TemplateRef + func (in *TemplateRef) DeepCopyInto(out *TemplateRef) + 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 (m *TemplateRef) Reset() + func (m *TemplateRef) Size() (n int) + 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 + func (this *TemplateRef) String() string + type TemplateStorage interface + GetStoredTemplate func(templateScope string, holder TemplateHolder) *Template + SetStoredTemplate func(templateScope string, holder TemplateHolder, tmpl *Template) (bool, error) + type TemplateType string + const TemplateTypeContainer + const TemplateTypeDAG + const TemplateTypeResource + const TemplateTypeScript + const TemplateTypeSteps + const TemplateTypeSuspend + const TemplateTypeUnknown + type Type int + const Bool + const List + const Map + const Number + const String + type UserContainer struct + MirrorVolumeMounts *bool + func (*UserContainer) Descriptor() ([]byte, []int) + func (*UserContainer) ProtoMessage() + func (in *UserContainer) DeepCopy() *UserContainer + func (in *UserContainer) DeepCopyInto(out *UserContainer) + 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 (m *UserContainer) Reset() + func (m *UserContainer) Size() (n int) + 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 + func (this *UserContainer) String() string + type ValueFrom struct + JQFilter string + JSONPath string + Parameter string + Path string + func (*ValueFrom) Descriptor() ([]byte, []int) + func (*ValueFrom) ProtoMessage() + func (in *ValueFrom) DeepCopy() *ValueFrom + func (in *ValueFrom) DeepCopyInto(out *ValueFrom) + 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 (m *ValueFrom) Reset() + func (m *ValueFrom) Size() (n int) + 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 + func (this *ValueFrom) String() string + type Workflow struct + Spec WorkflowSpec + Status WorkflowStatus + func (*Workflow) Descriptor() ([]byte, []int) + func (*Workflow) ProtoMessage() + func (in *Workflow) DeepCopy() *Workflow + func (in *Workflow) DeepCopyInto(out *Workflow) + func (in *Workflow) DeepCopyObject() runtime.Object + 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 (m *Workflow) Reset() + func (m *Workflow) Size() (n int) + 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 + func (this *Workflow) String() string + func (wf *Workflow) GetOffloadNodeStatusVersion() string + func (wf *Workflow) GetStoredTemplate(templateScope string, holder TemplateHolder) *Template + func (wf *Workflow) GetTemplateByName(name string) *Template + func (wf *Workflow) GetTemplateScope() string + func (wf *Workflow) NodeID(name string) string + func (wf *Workflow) SetStoredTemplate(templateScope string, holder TemplateHolder, tmpl *Template) (bool, error) + type WorkflowList struct + Items Workflows + func (*WorkflowList) Descriptor() ([]byte, []int) + func (*WorkflowList) ProtoMessage() + func (in *WorkflowList) DeepCopy() *WorkflowList + func (in *WorkflowList) DeepCopyInto(out *WorkflowList) + func (in *WorkflowList) DeepCopyObject() runtime.Object + 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 (m *WorkflowList) Reset() + func (m *WorkflowList) Size() (n int) + 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 + func (this *WorkflowList) String() string + type WorkflowSpec struct + ActiveDeadlineSeconds *int64 + Affinity *apiv1.Affinity + Arguments Arguments + ArtifactRepositoryRef *ArtifactRepositoryRef + AutomountServiceAccountToken *bool + DNSConfig *apiv1.PodDNSConfig + DNSPolicy *apiv1.DNSPolicy + Entrypoint string + Executor *ExecutorConfig + HostAliases []apiv1.HostAlias + HostNetwork *bool + ImagePullSecrets []apiv1.LocalObjectReference + NodeSelector map[string]string + OnExit string + Parallelism *int64 + PodGC *PodGC + PodPriority *int32 + PodPriorityClassName string + PodSpecPatch string + Priority *int32 + SchedulerName string + SecurityContext *apiv1.PodSecurityContext + ServiceAccountName string + Suspend *bool + TTLSecondsAfterFinished *int32 + TTLStrategy *TTLStrategy + Templates []Template + Tolerations []apiv1.Toleration + VolumeClaimTemplates []apiv1.PersistentVolumeClaim + Volumes []apiv1.Volume + func (*WorkflowSpec) Descriptor() ([]byte, []int) + func (*WorkflowSpec) ProtoMessage() + func (in *WorkflowSpec) DeepCopy() *WorkflowSpec + func (in *WorkflowSpec) DeepCopyInto(out *WorkflowSpec) + 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 (m *WorkflowSpec) Reset() + func (m *WorkflowSpec) Size() (n int) + 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 + func (this *WorkflowSpec) String() string + func (wfs *WorkflowSpec) HasPodSpecPatch() bool + type WorkflowStatus struct + CompressedNodes string + FinishedAt metav1.Time + Message string + Nodes Nodes + OffloadNodeStatusVersion string + Outputs *Outputs + PersistentVolumeClaims []apiv1.Volume + Phase NodePhase + StartedAt metav1.Time + StoredTemplates map[string]Template + func (*WorkflowStatus) Descriptor() ([]byte, []int) + func (*WorkflowStatus) ProtoMessage() + func (in *WorkflowStatus) AnyActiveSuspendNode() bool + func (in *WorkflowStatus) DeepCopy() *WorkflowStatus + func (in *WorkflowStatus) DeepCopyInto(out *WorkflowStatus) + 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 (m *WorkflowStatus) Reset() + func (m *WorkflowStatus) Size() (n int) + 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 + func (this *WorkflowStatus) String() string + func (ws *WorkflowStatus) Completed() bool + func (ws *WorkflowStatus) Failed() bool + func (ws *WorkflowStatus) GetOffloadNodeStatusVersion() string + func (ws *WorkflowStatus) IsOffloadNodeStatus() bool + func (ws *WorkflowStatus) Successful() bool + type WorkflowStep struct + Arguments Arguments + ContinueOn *ContinueOn + Name string + OnExit string + Template string + TemplateRef *TemplateRef + When string + WithItems []Item + WithParam string + WithSequence *Sequence + func (*WorkflowStep) Descriptor() ([]byte, []int) + func (*WorkflowStep) ProtoMessage() + func (in *WorkflowStep) DeepCopy() *WorkflowStep + func (in *WorkflowStep) DeepCopyInto(out *WorkflowStep) + 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 (m *WorkflowStep) Reset() + func (m *WorkflowStep) Size() (n int) + 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 + func (s *WorkflowStep) ContinuesOn(phase NodePhase) bool + func (step *WorkflowStep) GetTemplateName() string + func (step *WorkflowStep) GetTemplateRef() *TemplateRef + func (step *WorkflowStep) IsResolvable() bool + func (this *WorkflowStep) String() string + type WorkflowTemplate struct + Spec WorkflowTemplateSpec + func (*WorkflowTemplate) Descriptor() ([]byte, []int) + func (*WorkflowTemplate) ProtoMessage() + func (in *WorkflowTemplate) DeepCopy() *WorkflowTemplate + func (in *WorkflowTemplate) DeepCopyInto(out *WorkflowTemplate) + func (in *WorkflowTemplate) DeepCopyObject() runtime.Object + 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 (m *WorkflowTemplate) Reset() + func (m *WorkflowTemplate) Size() (n int) + 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 + func (this *WorkflowTemplate) String() string + func (wftmpl *WorkflowTemplate) GetTemplateByName(name string) *Template + func (wftmpl *WorkflowTemplate) GetTemplateScope() string + type WorkflowTemplateList struct + Items WorkflowTemplates + func (*WorkflowTemplateList) Descriptor() ([]byte, []int) + func (*WorkflowTemplateList) ProtoMessage() + func (in *WorkflowTemplateList) DeepCopy() *WorkflowTemplateList + func (in *WorkflowTemplateList) DeepCopyInto(out *WorkflowTemplateList) + func (in *WorkflowTemplateList) DeepCopyObject() runtime.Object + 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 (m *WorkflowTemplateList) Reset() + func (m *WorkflowTemplateList) Size() (n int) + 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 + func (this *WorkflowTemplateList) String() string + type WorkflowTemplateSpec struct + Arguments Arguments + Templates []Template + func (*WorkflowTemplateSpec) Descriptor() ([]byte, []int) + func (*WorkflowTemplateSpec) ProtoMessage() + func (in *WorkflowTemplateSpec) DeepCopy() *WorkflowTemplateSpec + func (in *WorkflowTemplateSpec) DeepCopyInto(out *WorkflowTemplateSpec) + 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 (m *WorkflowTemplateSpec) Reset() + func (m *WorkflowTemplateSpec) Size() (n int) + 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 + func (this *WorkflowTemplateSpec) String() string + type WorkflowTemplates []WorkflowTemplate + func (in WorkflowTemplates) DeepCopy() WorkflowTemplates + func (in WorkflowTemplates) DeepCopyInto(out *WorkflowTemplates) + func (w WorkflowTemplates) Len() int + func (w WorkflowTemplates) Less(i, j int) bool + func (w WorkflowTemplates) Swap(i, j int) + type Workflows []Workflow + func (in Workflows) DeepCopy() Workflows + func (in Workflows) DeepCopyInto(out *Workflows) + func (w Workflows) Len() int + func (w Workflows) Less(i, j int) bool + func (w Workflows) Swap(i, j int)