Versions in this module Expand all Collapse all v3 v3.2.5 Oct 26, 2021 v3.2.4 Oct 26, 2021 v3.2.3 Oct 26, 2021 Changes in this version + const ExitLifecycleEvent + var AddToScheme = SchemeBuilder.AddToScheme + var DefaultArchivePattern = "{{workflow.name}}/{{pod.name}}" + 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 WorkflowCreatedAfter = func(t time.Time) WorkflowPredicate + var WorkflowFinishedBefore = func(t time.Time) WorkflowPredicate + var WorkflowRanBetween = func(startTime time.Time, endTime time.Time) WorkflowPredicate + var WorkflowSchemaGroupVersionKind = schema.GroupVersionKind + func FailedPodNode(n NodeStatus) bool + func Kind(kind string) schema.GroupKind + func MustMarshallJSON(v interface{}) string + func MustUnmarshal(text, v interface{}) + func NodeWithDisplayName(name string) func(n NodeStatus) bool + func Resource(resource string) schema.GroupResource + func ResourceQuantityDenominator(r apiv1.ResourceName) *resource.Quantity + func SucceededPodNode(n NodeStatus) bool + type Amount struct + Value json.Number + func (*Amount) Descriptor() ([]byte, []int) + func (*Amount) ProtoMessage() + func (a *Amount) Float64() (float64, error) + func (a *Amount) UnmarshalJSON(data []byte) error + func (a Amount) MarshalJSON() ([]byte, error) + func (a Amount) OpenAPISchemaFormat() string + func (a Amount) OpenAPISchemaType() []string + func (in *Amount) DeepCopy() *Amount + func (in *Amount) DeepCopyInto(out *Amount) + func (m *Amount) Marshal() (dAtA []byte, err error) + func (m *Amount) MarshalTo(dAtA []byte) (int, error) + func (m *Amount) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Amount) Reset() + func (m *Amount) Size() (n int) + func (m *Amount) Unmarshal(dAtA []byte) error + func (m *Amount) XXX_DiscardUnknown() + func (m *Amount) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Amount) XXX_Merge(src proto.Message) + func (m *Amount) XXX_Size() int + func (m *Amount) XXX_Unmarshal(b []byte) error + func (this *Amount) String() string + type AnyString string + func AnyStringPtr(val interface{}) *AnyString + func ParseAnyString(val interface{}) AnyString + func (i *AnyString) UnmarshalJSON(value []byte) error + func (i AnyString) MarshalJSON() ([]byte, error) + func (i AnyString) String() string + type ArchiveStrategy struct + None *NoneStrategy + Tar *TarStrategy + Zip *ZipStrategy + 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 (a Arguments) IsEmpty() bool + 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 + FromExpression string + GlobalName string + Mode *int32 + Name string + Optional bool + Path string + RecurseMode bool + SubPath string + func (*Artifact) Descriptor() ([]byte, []int) + func (*Artifact) ProtoMessage() + func (a *Artifact) GetArchive() *ArchiveStrategy + 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 + GCS *GCSArtifact + Git *GitArtifact + HDFS *HDFSArtifact + HTTP *HTTPArtifact + OSS *OSSArtifact + Raw *RawArtifact + S3 *S3Artifact + func (*ArtifactLocation) Descriptor() ([]byte, []int) + func (*ArtifactLocation) ProtoMessage() + func (a *ArtifactLocation) AppendToKey(x string) error + func (a *ArtifactLocation) Get() ArtifactLocationType + func (a *ArtifactLocation) GetKey() (string, error) + func (a *ArtifactLocation) HasKey() bool + func (a *ArtifactLocation) HasLocation() bool + func (a *ArtifactLocation) HasLocationOrKey() bool + func (a *ArtifactLocation) IsArchiveLogs() bool + func (a *ArtifactLocation) Relocate(l *ArtifactLocation) error + func (a *ArtifactLocation) SetKey(key string) error + func (a *ArtifactLocation) SetType(x ArtifactLocationType) error + 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 ArtifactLocationType interface + GetKey func() (string, error) + HasLocation func() bool + SetKey func(key string) error + type ArtifactPaths struct + func (*ArtifactPaths) Descriptor() ([]byte, []int) + func (*ArtifactPaths) ProtoMessage() + func (in *ArtifactPaths) DeepCopy() *ArtifactPaths + func (in *ArtifactPaths) DeepCopyInto(out *ArtifactPaths) + func (m *ArtifactPaths) Marshal() (dAtA []byte, err error) + func (m *ArtifactPaths) MarshalTo(dAtA []byte) (int, error) + func (m *ArtifactPaths) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ArtifactPaths) Reset() + func (m *ArtifactPaths) Size() (n int) + func (m *ArtifactPaths) Unmarshal(dAtA []byte) error + func (m *ArtifactPaths) XXX_DiscardUnknown() + func (m *ArtifactPaths) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ArtifactPaths) XXX_Merge(src proto.Message) + func (m *ArtifactPaths) XXX_Size() int + func (m *ArtifactPaths) XXX_Unmarshal(b []byte) error + func (this *ArtifactPaths) String() string + type ArtifactRepository struct + ArchiveLogs *bool + Artifactory *ArtifactoryArtifactRepository + GCS *GCSArtifactRepository + HDFS *HDFSArtifactRepository + OSS *OSSArtifactRepository + S3 *S3ArtifactRepository + func (*ArtifactRepository) Descriptor() ([]byte, []int) + func (*ArtifactRepository) ProtoMessage() + func (a *ArtifactRepository) Get() ArtifactRepositoryType + func (a *ArtifactRepository) IsArchiveLogs() bool + func (a *ArtifactRepository) ToArtifactLocation() *ArtifactLocation + func (in *ArtifactRepository) DeepCopy() *ArtifactRepository + func (in *ArtifactRepository) DeepCopyInto(out *ArtifactRepository) + func (m *ArtifactRepository) Marshal() (dAtA []byte, err error) + func (m *ArtifactRepository) MarshalTo(dAtA []byte) (int, error) + func (m *ArtifactRepository) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ArtifactRepository) Reset() + func (m *ArtifactRepository) Size() (n int) + func (m *ArtifactRepository) Unmarshal(dAtA []byte) error + func (m *ArtifactRepository) XXX_DiscardUnknown() + func (m *ArtifactRepository) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ArtifactRepository) XXX_Merge(src proto.Message) + func (m *ArtifactRepository) XXX_Size() int + func (m *ArtifactRepository) XXX_Unmarshal(b []byte) error + func (this *ArtifactRepository) 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 (r *ArtifactRepositoryRef) GetConfigMapOr(configMap string) string + func (r *ArtifactRepositoryRef) GetKeyOr(key string) string + func (r *ArtifactRepositoryRef) String() string + type ArtifactRepositoryRefStatus struct + ArtifactRepository *ArtifactRepository + Default bool + Namespace string + func (*ArtifactRepositoryRefStatus) Descriptor() ([]byte, []int) + func (*ArtifactRepositoryRefStatus) ProtoMessage() + func (in *ArtifactRepositoryRefStatus) DeepCopy() *ArtifactRepositoryRefStatus + func (in *ArtifactRepositoryRefStatus) DeepCopyInto(out *ArtifactRepositoryRefStatus) + func (m *ArtifactRepositoryRefStatus) Marshal() (dAtA []byte, err error) + func (m *ArtifactRepositoryRefStatus) MarshalTo(dAtA []byte) (int, error) + func (m *ArtifactRepositoryRefStatus) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ArtifactRepositoryRefStatus) Reset() + func (m *ArtifactRepositoryRefStatus) Size() (n int) + func (m *ArtifactRepositoryRefStatus) Unmarshal(dAtA []byte) error + func (m *ArtifactRepositoryRefStatus) XXX_DiscardUnknown() + func (m *ArtifactRepositoryRefStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ArtifactRepositoryRefStatus) XXX_Merge(src proto.Message) + func (m *ArtifactRepositoryRefStatus) XXX_Size() int + func (m *ArtifactRepositoryRefStatus) XXX_Unmarshal(b []byte) error + func (r *ArtifactRepositoryRefStatus) String() string + type ArtifactRepositoryType interface + IntoArtifactLocation func(l *ArtifactLocation) + type ArtifactoryArtifact struct + URL string + func (*ArtifactoryArtifact) Descriptor() ([]byte, []int) + func (*ArtifactoryArtifact) ProtoMessage() + func (a *ArtifactoryArtifact) GetKey() (string, error) + func (a *ArtifactoryArtifact) HasLocation() bool + func (a *ArtifactoryArtifact) SetKey(key string) error + 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 ArtifactoryArtifactRepository struct + RepoURL string + func (*ArtifactoryArtifactRepository) Descriptor() ([]byte, []int) + func (*ArtifactoryArtifactRepository) ProtoMessage() + func (in *ArtifactoryArtifactRepository) DeepCopy() *ArtifactoryArtifactRepository + func (in *ArtifactoryArtifactRepository) DeepCopyInto(out *ArtifactoryArtifactRepository) + func (m *ArtifactoryArtifactRepository) Marshal() (dAtA []byte, err error) + func (m *ArtifactoryArtifactRepository) MarshalTo(dAtA []byte) (int, error) + func (m *ArtifactoryArtifactRepository) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ArtifactoryArtifactRepository) Reset() + func (m *ArtifactoryArtifactRepository) Size() (n int) + func (m *ArtifactoryArtifactRepository) Unmarshal(dAtA []byte) error + func (m *ArtifactoryArtifactRepository) XXX_DiscardUnknown() + func (m *ArtifactoryArtifactRepository) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ArtifactoryArtifactRepository) XXX_Merge(src proto.Message) + func (m *ArtifactoryArtifactRepository) XXX_Size() int + func (m *ArtifactoryArtifactRepository) XXX_Unmarshal(b []byte) error + func (r *ArtifactoryArtifactRepository) IntoArtifactLocation(l *ArtifactLocation) + func (this *ArtifactoryArtifactRepository) 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 *intstr.IntOrString + 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 Cache struct + ConfigMap *apiv1.ConfigMapKeySelector + func (*Cache) Descriptor() ([]byte, []int) + func (*Cache) ProtoMessage() + func (in *Cache) DeepCopy() *Cache + func (in *Cache) DeepCopyInto(out *Cache) + func (m *Cache) Marshal() (dAtA []byte, err error) + func (m *Cache) MarshalTo(dAtA []byte) (int, error) + func (m *Cache) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Cache) Reset() + func (m *Cache) Size() (n int) + func (m *Cache) Unmarshal(dAtA []byte) error + func (m *Cache) XXX_DiscardUnknown() + func (m *Cache) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Cache) XXX_Merge(src proto.Message) + func (m *Cache) XXX_Size() int + func (m *Cache) XXX_Unmarshal(b []byte) error + func (this *Cache) String() string + type ClusterWorkflowTemplate struct + Spec WorkflowTemplateSpec + func MustUnmarshalClusterWorkflow(text interface{}) *ClusterWorkflowTemplate + func (*ClusterWorkflowTemplate) Descriptor() ([]byte, []int) + func (*ClusterWorkflowTemplate) ProtoMessage() + func (cwftmpl *ClusterWorkflowTemplate) GetResourceScope() ResourceScope + func (cwftmpl *ClusterWorkflowTemplate) GetTemplateByName(name string) *Template + func (cwftmpl *ClusterWorkflowTemplate) GetWorkflowMetadata() *metav1.ObjectMeta + func (cwftmpl *ClusterWorkflowTemplate) GetWorkflowSpec() *WorkflowSpec + func (in *ClusterWorkflowTemplate) DeepCopy() *ClusterWorkflowTemplate + func (in *ClusterWorkflowTemplate) DeepCopyInto(out *ClusterWorkflowTemplate) + func (in *ClusterWorkflowTemplate) DeepCopyObject() runtime.Object + func (m *ClusterWorkflowTemplate) Marshal() (dAtA []byte, err error) + func (m *ClusterWorkflowTemplate) MarshalTo(dAtA []byte) (int, error) + func (m *ClusterWorkflowTemplate) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ClusterWorkflowTemplate) Reset() + func (m *ClusterWorkflowTemplate) Size() (n int) + func (m *ClusterWorkflowTemplate) Unmarshal(dAtA []byte) error + func (m *ClusterWorkflowTemplate) XXX_DiscardUnknown() + func (m *ClusterWorkflowTemplate) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ClusterWorkflowTemplate) XXX_Merge(src proto.Message) + func (m *ClusterWorkflowTemplate) XXX_Size() int + func (m *ClusterWorkflowTemplate) XXX_Unmarshal(b []byte) error + func (this *ClusterWorkflowTemplate) String() string + type ClusterWorkflowTemplateList struct + Items ClusterWorkflowTemplates + func (*ClusterWorkflowTemplateList) Descriptor() ([]byte, []int) + func (*ClusterWorkflowTemplateList) ProtoMessage() + func (in *ClusterWorkflowTemplateList) DeepCopy() *ClusterWorkflowTemplateList + func (in *ClusterWorkflowTemplateList) DeepCopyInto(out *ClusterWorkflowTemplateList) + func (in *ClusterWorkflowTemplateList) DeepCopyObject() runtime.Object + func (m *ClusterWorkflowTemplateList) Marshal() (dAtA []byte, err error) + func (m *ClusterWorkflowTemplateList) MarshalTo(dAtA []byte) (int, error) + func (m *ClusterWorkflowTemplateList) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ClusterWorkflowTemplateList) Reset() + func (m *ClusterWorkflowTemplateList) Size() (n int) + func (m *ClusterWorkflowTemplateList) Unmarshal(dAtA []byte) error + func (m *ClusterWorkflowTemplateList) XXX_DiscardUnknown() + func (m *ClusterWorkflowTemplateList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ClusterWorkflowTemplateList) XXX_Merge(src proto.Message) + func (m *ClusterWorkflowTemplateList) XXX_Size() int + func (m *ClusterWorkflowTemplateList) XXX_Unmarshal(b []byte) error + func (this *ClusterWorkflowTemplateList) String() string + type ClusterWorkflowTemplates []ClusterWorkflowTemplate + func (in ClusterWorkflowTemplates) DeepCopy() ClusterWorkflowTemplates + func (in ClusterWorkflowTemplates) DeepCopyInto(out *ClusterWorkflowTemplates) + func (w ClusterWorkflowTemplates) Len() int + func (w ClusterWorkflowTemplates) Less(i, j int) bool + func (w ClusterWorkflowTemplates) Swap(i, j int) + type ConcurrencyPolicy string + const AllowConcurrent + const ForbidConcurrent + const ReplaceConcurrent + type Condition struct + Message string + Status metav1.ConditionStatus + Type ConditionType + func (*Condition) Descriptor() ([]byte, []int) + func (*Condition) ProtoMessage() + func (in *Condition) DeepCopy() *Condition + func (in *Condition) DeepCopyInto(out *Condition) + func (m *Condition) Marshal() (dAtA []byte, err error) + func (m *Condition) MarshalTo(dAtA []byte) (int, error) + func (m *Condition) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Condition) Reset() + func (m *Condition) Size() (n int) + func (m *Condition) Unmarshal(dAtA []byte) error + func (m *Condition) XXX_DiscardUnknown() + func (m *Condition) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Condition) XXX_Merge(src proto.Message) + func (m *Condition) XXX_Size() int + func (m *Condition) XXX_Unmarshal(b []byte) error + func (this *Condition) String() string + type ConditionType string + const ConditionTypeCompleted + const ConditionTypeMetricsError + const ConditionTypePodRunning + const ConditionTypeSpecError + const ConditionTypeSpecWarning + const ConditionTypeSubmissionError + type Conditions []Condition + func (cs *Conditions) DisplayString(fmtStr string, iconMap map[ConditionType]string) string + func (cs *Conditions) JoinConditions(conditions *Conditions) + func (cs *Conditions) RemoveCondition(conditionType ConditionType) + func (cs *Conditions) UpsertCondition(condition Condition) + func (cs *Conditions) UpsertConditionMessage(condition Condition) + func (in Conditions) DeepCopy() Conditions + func (in Conditions) DeepCopyInto(out *Conditions) + type ContainerNode struct + Dependencies []string + func (*ContainerNode) Descriptor() ([]byte, []int) + func (*ContainerNode) ProtoMessage() + func (in *ContainerNode) DeepCopy() *ContainerNode + func (in *ContainerNode) DeepCopyInto(out *ContainerNode) + func (m *ContainerNode) Marshal() (dAtA []byte, err error) + func (m *ContainerNode) MarshalTo(dAtA []byte) (int, error) + func (m *ContainerNode) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ContainerNode) Reset() + func (m *ContainerNode) Size() (n int) + func (m *ContainerNode) Unmarshal(dAtA []byte) error + func (m *ContainerNode) XXX_DiscardUnknown() + func (m *ContainerNode) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ContainerNode) XXX_Merge(src proto.Message) + func (m *ContainerNode) XXX_Size() int + func (m *ContainerNode) XXX_Unmarshal(b []byte) error + func (this *ContainerNode) String() string + type ContainerSetTemplate struct + Containers []ContainerNode + VolumeMounts []corev1.VolumeMount + func (*ContainerSetTemplate) Descriptor() ([]byte, []int) + func (*ContainerSetTemplate) ProtoMessage() + func (in *ContainerSetTemplate) DeepCopy() *ContainerSetTemplate + func (in *ContainerSetTemplate) DeepCopyInto(out *ContainerSetTemplate) + func (in *ContainerSetTemplate) GetContainers() []corev1.Container + func (in *ContainerSetTemplate) GetGraph() []ContainerNode + func (in *ContainerSetTemplate) HasContainerNamed(n string) bool + func (in *ContainerSetTemplate) HasSequencedContainers() bool + func (in *ContainerSetTemplate) Validate() error + func (m *ContainerSetTemplate) Marshal() (dAtA []byte, err error) + func (m *ContainerSetTemplate) MarshalTo(dAtA []byte) (int, error) + func (m *ContainerSetTemplate) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ContainerSetTemplate) Reset() + func (m *ContainerSetTemplate) Size() (n int) + func (m *ContainerSetTemplate) Unmarshal(dAtA []byte) error + func (m *ContainerSetTemplate) XXX_DiscardUnknown() + func (m *ContainerSetTemplate) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ContainerSetTemplate) XXX_Merge(src proto.Message) + func (m *ContainerSetTemplate) XXX_Size() int + func (m *ContainerSetTemplate) XXX_Unmarshal(b []byte) error + func (this *ContainerSetTemplate) String() string + 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 Counter struct + Value string + func (*Counter) Descriptor() ([]byte, []int) + func (*Counter) ProtoMessage() + func (in *Counter) DeepCopy() *Counter + func (in *Counter) DeepCopyInto(out *Counter) + func (m *Counter) Marshal() (dAtA []byte, err error) + func (m *Counter) MarshalTo(dAtA []byte) (int, error) + func (m *Counter) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Counter) Reset() + func (m *Counter) Size() (n int) + func (m *Counter) Unmarshal(dAtA []byte) error + func (m *Counter) XXX_DiscardUnknown() + func (m *Counter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Counter) XXX_Merge(src proto.Message) + func (m *Counter) XXX_Size() int + func (m *Counter) XXX_Unmarshal(b []byte) error + func (this *Counter) String() string + type CreateS3BucketOptions struct + ObjectLocking bool + func (*CreateS3BucketOptions) Descriptor() ([]byte, []int) + func (*CreateS3BucketOptions) ProtoMessage() + func (in *CreateS3BucketOptions) DeepCopy() *CreateS3BucketOptions + func (in *CreateS3BucketOptions) DeepCopyInto(out *CreateS3BucketOptions) + func (m *CreateS3BucketOptions) Marshal() (dAtA []byte, err error) + func (m *CreateS3BucketOptions) MarshalTo(dAtA []byte) (int, error) + func (m *CreateS3BucketOptions) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *CreateS3BucketOptions) Reset() + func (m *CreateS3BucketOptions) Size() (n int) + func (m *CreateS3BucketOptions) Unmarshal(dAtA []byte) error + func (m *CreateS3BucketOptions) XXX_DiscardUnknown() + func (m *CreateS3BucketOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CreateS3BucketOptions) XXX_Merge(src proto.Message) + func (m *CreateS3BucketOptions) XXX_Size() int + func (m *CreateS3BucketOptions) XXX_Unmarshal(b []byte) error + func (this *CreateS3BucketOptions) String() string + type CronWorkflow struct + Spec CronWorkflowSpec + Status CronWorkflowStatus + func MustUnmarshalCronWorkflow(text interface{}) *CronWorkflow + 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 + WorkflowMetadata *metav1.ObjectMeta + 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 + Conditions Conditions + LastScheduledTime *metav1.Time + func (*CronWorkflowStatus) Descriptor() ([]byte, []int) + func (*CronWorkflowStatus) ProtoMessage() + func (c *CronWorkflowStatus) HasActiveUID(uid types.UID) bool + 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 + Depends string + Hooks LifecycleHooks + Inline *Template + 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) GetExitHook(args Arguments) *LifecycleHook + func (t *DAGTask) GetTemplate() *Template + func (t *DAGTask) GetTemplateName() string + func (t *DAGTask) GetTemplateRef() *TemplateRef + func (t *DAGTask) HasExitHook() bool + func (t *DAGTask) ShouldExpand() 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 Data struct + Source DataSource + Transformation Transformation + func (*Data) Descriptor() ([]byte, []int) + func (*Data) ProtoMessage() + func (in *Data) DeepCopy() *Data + func (in *Data) DeepCopyInto(out *Data) + func (m *Data) Marshal() (dAtA []byte, err error) + func (m *Data) MarshalTo(dAtA []byte) (int, error) + func (m *Data) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Data) Reset() + func (m *Data) Size() (n int) + func (m *Data) Unmarshal(dAtA []byte) error + func (m *Data) XXX_DiscardUnknown() + func (m *Data) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Data) XXX_Merge(src proto.Message) + func (m *Data) XXX_Size() int + func (m *Data) XXX_Unmarshal(b []byte) error + func (this *Data) String() string + type DataSource struct + ArtifactPaths *ArtifactPaths + func (*DataSource) Descriptor() ([]byte, []int) + func (*DataSource) ProtoMessage() + func (ds *DataSource) GetArtifactIfNeeded() (*Artifact, bool) + func (in *DataSource) DeepCopy() *DataSource + func (in *DataSource) DeepCopyInto(out *DataSource) + func (m *DataSource) Marshal() (dAtA []byte, err error) + func (m *DataSource) MarshalTo(dAtA []byte) (int, error) + func (m *DataSource) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *DataSource) Reset() + func (m *DataSource) Size() (n int) + func (m *DataSource) Unmarshal(dAtA []byte) error + func (m *DataSource) XXX_DiscardUnknown() + func (m *DataSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DataSource) XXX_Merge(src proto.Message) + func (m *DataSource) XXX_Size() int + func (m *DataSource) XXX_Unmarshal(b []byte) error + func (this *DataSource) String() string + type DataSourceProcessor interface + ProcessArtifactPaths func(*ArtifactPaths) (interface{}, error) + type EstimatedDuration int + func NewEstimatedDuration(d time.Duration) EstimatedDuration + func (d EstimatedDuration) ToDuration() time.Duration + type Event struct + Selector string + func (*Event) Descriptor() ([]byte, []int) + func (*Event) ProtoMessage() + func (in *Event) DeepCopy() *Event + func (in *Event) DeepCopyInto(out *Event) + func (m *Event) Marshal() (dAtA []byte, err error) + func (m *Event) MarshalTo(dAtA []byte) (int, error) + func (m *Event) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Event) Reset() + func (m *Event) Size() (n int) + func (m *Event) Unmarshal(dAtA []byte) error + func (m *Event) XXX_DiscardUnknown() + func (m *Event) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Event) XXX_Merge(src proto.Message) + func (m *Event) XXX_Size() int + func (m *Event) XXX_Unmarshal(b []byte) error + func (this *Event) 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 GCSArtifact struct + Key string + func (*GCSArtifact) Descriptor() ([]byte, []int) + func (*GCSArtifact) ProtoMessage() + func (g *GCSArtifact) GetKey() (string, error) + func (g *GCSArtifact) HasLocation() bool + func (g *GCSArtifact) SetKey(key string) error + func (in *GCSArtifact) DeepCopy() *GCSArtifact + func (in *GCSArtifact) DeepCopyInto(out *GCSArtifact) + func (m *GCSArtifact) Marshal() (dAtA []byte, err error) + func (m *GCSArtifact) MarshalTo(dAtA []byte) (int, error) + func (m *GCSArtifact) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *GCSArtifact) Reset() + func (m *GCSArtifact) Size() (n int) + func (m *GCSArtifact) Unmarshal(dAtA []byte) error + func (m *GCSArtifact) XXX_DiscardUnknown() + func (m *GCSArtifact) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *GCSArtifact) XXX_Merge(src proto.Message) + func (m *GCSArtifact) XXX_Size() int + func (m *GCSArtifact) XXX_Unmarshal(b []byte) error + func (this *GCSArtifact) String() string + type GCSArtifactRepository struct + KeyFormat string + func (*GCSArtifactRepository) Descriptor() ([]byte, []int) + func (*GCSArtifactRepository) ProtoMessage() + func (in *GCSArtifactRepository) DeepCopy() *GCSArtifactRepository + func (in *GCSArtifactRepository) DeepCopyInto(out *GCSArtifactRepository) + func (m *GCSArtifactRepository) Marshal() (dAtA []byte, err error) + func (m *GCSArtifactRepository) MarshalTo(dAtA []byte) (int, error) + func (m *GCSArtifactRepository) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *GCSArtifactRepository) Reset() + func (m *GCSArtifactRepository) Size() (n int) + func (m *GCSArtifactRepository) Unmarshal(dAtA []byte) error + func (m *GCSArtifactRepository) XXX_DiscardUnknown() + func (m *GCSArtifactRepository) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *GCSArtifactRepository) XXX_Merge(src proto.Message) + func (m *GCSArtifactRepository) XXX_Size() int + func (m *GCSArtifactRepository) XXX_Unmarshal(b []byte) error + func (r *GCSArtifactRepository) IntoArtifactLocation(l *ArtifactLocation) + func (this *GCSArtifactRepository) String() string + type GCSBucket struct + Bucket string + ServiceAccountKeySecret *apiv1.SecretKeySelector + func (*GCSBucket) Descriptor() ([]byte, []int) + func (*GCSBucket) ProtoMessage() + func (in *GCSBucket) DeepCopy() *GCSBucket + func (in *GCSBucket) DeepCopyInto(out *GCSBucket) + func (m *GCSBucket) Marshal() (dAtA []byte, err error) + func (m *GCSBucket) MarshalTo(dAtA []byte) (int, error) + func (m *GCSBucket) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *GCSBucket) Reset() + func (m *GCSBucket) Size() (n int) + func (m *GCSBucket) Unmarshal(dAtA []byte) error + func (m *GCSBucket) XXX_DiscardUnknown() + func (m *GCSBucket) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *GCSBucket) XXX_Merge(src proto.Message) + func (m *GCSBucket) XXX_Size() int + func (m *GCSBucket) XXX_Unmarshal(b []byte) error + func (this *GCSBucket) String() string + type Gauge struct + Realtime *bool + Value string + func (*Gauge) Descriptor() ([]byte, []int) + func (*Gauge) ProtoMessage() + func (in *Gauge) DeepCopy() *Gauge + func (in *Gauge) DeepCopyInto(out *Gauge) + func (m *Gauge) Marshal() (dAtA []byte, err error) + func (m *Gauge) MarshalTo(dAtA []byte) (int, error) + func (m *Gauge) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Gauge) Reset() + func (m *Gauge) Size() (n int) + func (m *Gauge) Unmarshal(dAtA []byte) error + func (m *Gauge) XXX_DiscardUnknown() + func (m *Gauge) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Gauge) XXX_Merge(src proto.Message) + func (m *Gauge) XXX_Size() int + func (m *Gauge) XXX_Unmarshal(b []byte) error + func (this *Gauge) String() string + type GitArtifact struct + Depth *uint64 + DisableSubmodules bool + 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) GetDepth() int + func (g *GitArtifact) GetKey() (string, error) + func (g *GitArtifact) HasLocation() bool + func (g *GitArtifact) SetKey(string) error + 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 (g *HDFSArtifact) SetKey(key string) error + func (h *HDFSArtifact) GetKey() (string, error) + 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 HDFSArtifactRepository struct + Force bool + PathFormat string + func (*HDFSArtifactRepository) Descriptor() ([]byte, []int) + func (*HDFSArtifactRepository) ProtoMessage() + func (in *HDFSArtifactRepository) DeepCopy() *HDFSArtifactRepository + func (in *HDFSArtifactRepository) DeepCopyInto(out *HDFSArtifactRepository) + func (m *HDFSArtifactRepository) Marshal() (dAtA []byte, err error) + func (m *HDFSArtifactRepository) MarshalTo(dAtA []byte) (int, error) + func (m *HDFSArtifactRepository) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *HDFSArtifactRepository) Reset() + func (m *HDFSArtifactRepository) Size() (n int) + func (m *HDFSArtifactRepository) Unmarshal(dAtA []byte) error + func (m *HDFSArtifactRepository) XXX_DiscardUnknown() + func (m *HDFSArtifactRepository) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *HDFSArtifactRepository) XXX_Merge(src proto.Message) + func (m *HDFSArtifactRepository) XXX_Size() int + func (m *HDFSArtifactRepository) XXX_Unmarshal(b []byte) error + func (r *HDFSArtifactRepository) IntoArtifactLocation(l *ArtifactLocation) + func (this *HDFSArtifactRepository) 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 HTTP struct + Body string + Headers []HTTPHeader + Method string + TimeoutSeconds *int64 + URL string + func (*HTTP) Descriptor() ([]byte, []int) + func (*HTTP) ProtoMessage() + func (in *HTTP) DeepCopy() *HTTP + func (in *HTTP) DeepCopyInto(out *HTTP) + func (m *HTTP) Marshal() (dAtA []byte, err error) + func (m *HTTP) MarshalTo(dAtA []byte) (int, error) + func (m *HTTP) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *HTTP) Reset() + func (m *HTTP) Size() (n int) + func (m *HTTP) Unmarshal(dAtA []byte) error + func (m *HTTP) XXX_DiscardUnknown() + func (m *HTTP) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *HTTP) XXX_Merge(src proto.Message) + func (m *HTTP) XXX_Size() int + func (m *HTTP) XXX_Unmarshal(b []byte) error + func (this *HTTP) String() string + type HTTPArtifact struct + Headers []Header + URL string + func (*HTTPArtifact) Descriptor() ([]byte, []int) + func (*HTTPArtifact) ProtoMessage() + func (g *HTTPArtifact) SetKey(key string) error + func (h *HTTPArtifact) GetKey() (string, error) + 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 HTTPHeader struct + Name string + Value string + ValueFrom *HTTPHeaderSource + func (*HTTPHeader) Descriptor() ([]byte, []int) + func (*HTTPHeader) ProtoMessage() + func (in *HTTPHeader) DeepCopy() *HTTPHeader + func (in *HTTPHeader) DeepCopyInto(out *HTTPHeader) + func (m *HTTPHeader) Marshal() (dAtA []byte, err error) + func (m *HTTPHeader) MarshalTo(dAtA []byte) (int, error) + func (m *HTTPHeader) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *HTTPHeader) Reset() + func (m *HTTPHeader) Size() (n int) + func (m *HTTPHeader) Unmarshal(dAtA []byte) error + func (m *HTTPHeader) XXX_DiscardUnknown() + func (m *HTTPHeader) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *HTTPHeader) XXX_Merge(src proto.Message) + func (m *HTTPHeader) XXX_Size() int + func (m *HTTPHeader) XXX_Unmarshal(b []byte) error + func (this *HTTPHeader) String() string + type HTTPHeaderSource struct + SecretKeyRef *v1.SecretKeySelector + func (*HTTPHeaderSource) Descriptor() ([]byte, []int) + func (*HTTPHeaderSource) ProtoMessage() + func (in *HTTPHeaderSource) DeepCopy() *HTTPHeaderSource + func (in *HTTPHeaderSource) DeepCopyInto(out *HTTPHeaderSource) + func (m *HTTPHeaderSource) Marshal() (dAtA []byte, err error) + func (m *HTTPHeaderSource) MarshalTo(dAtA []byte) (int, error) + func (m *HTTPHeaderSource) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *HTTPHeaderSource) Reset() + func (m *HTTPHeaderSource) Size() (n int) + func (m *HTTPHeaderSource) Unmarshal(dAtA []byte) error + func (m *HTTPHeaderSource) XXX_DiscardUnknown() + func (m *HTTPHeaderSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *HTTPHeaderSource) XXX_Merge(src proto.Message) + func (m *HTTPHeaderSource) XXX_Size() int + func (m *HTTPHeaderSource) XXX_Unmarshal(b []byte) error + func (this *HTTPHeaderSource) String() string + type Header struct + Name string + Value string + func (*Header) Descriptor() ([]byte, []int) + func (*Header) ProtoMessage() + func (in *Header) DeepCopy() *Header + func (in *Header) DeepCopyInto(out *Header) + func (m *Header) Marshal() (dAtA []byte, err error) + func (m *Header) MarshalTo(dAtA []byte) (int, error) + func (m *Header) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Header) Reset() + func (m *Header) Size() (n int) + func (m *Header) Unmarshal(dAtA []byte) error + func (m *Header) XXX_DiscardUnknown() + func (m *Header) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Header) XXX_Merge(src proto.Message) + func (m *Header) XXX_Size() int + func (m *Header) XXX_Unmarshal(b []byte) error + func (this *Header) String() string + type Histogram struct + Buckets []Amount + Value string + func (*Histogram) Descriptor() ([]byte, []int) + func (*Histogram) ProtoMessage() + func (in *Histogram) DeepCopy() *Histogram + func (in *Histogram) DeepCopyInto(out *Histogram) + func (in *Histogram) GetBuckets() []float64 + func (m *Histogram) Marshal() (dAtA []byte, err error) + func (m *Histogram) MarshalTo(dAtA []byte) (int, error) + func (m *Histogram) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Histogram) Reset() + func (m *Histogram) Size() (n int) + func (m *Histogram) Unmarshal(dAtA []byte) error + func (m *Histogram) XXX_DiscardUnknown() + func (m *Histogram) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Histogram) XXX_Merge(src proto.Message) + func (m *Histogram) XXX_Size() int + func (m *Histogram) XXX_Unmarshal(b []byte) error + func (this *Histogram) 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 (in Inputs) IsEmpty() 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 + Value json.RawMessage + func ParseItem(s string) (Item, error) + func (*Item) Descriptor() ([]byte, []int) + func (*Item) ProtoMessage() + func (i *Item) DeepCopyInto(out *Item) + func (i *Item) GetListVal() []Item + func (i *Item) GetMapVal() map[string]Item + func (i *Item) GetStrVal() string + func (i *Item) GetType() Type + func (i *Item) String() string + func (i *Item) UnmarshalJSON(value []byte) error + func (i Item) Format(s fmt.State, _ 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 LabelKeys struct + Items []string + func (*LabelKeys) Descriptor() ([]byte, []int) + func (*LabelKeys) ProtoMessage() + func (in *LabelKeys) DeepCopy() *LabelKeys + func (in *LabelKeys) DeepCopyInto(out *LabelKeys) + func (m *LabelKeys) Marshal() (dAtA []byte, err error) + func (m *LabelKeys) MarshalTo(dAtA []byte) (int, error) + func (m *LabelKeys) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *LabelKeys) Reset() + func (m *LabelKeys) Size() (n int) + func (m *LabelKeys) Unmarshal(dAtA []byte) error + func (m *LabelKeys) XXX_DiscardUnknown() + func (m *LabelKeys) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *LabelKeys) XXX_Merge(src proto.Message) + func (m *LabelKeys) XXX_Size() int + func (m *LabelKeys) XXX_Unmarshal(b []byte) error + func (this *LabelKeys) String() string + type LabelValues struct + Items []string + func (*LabelValues) Descriptor() ([]byte, []int) + func (*LabelValues) ProtoMessage() + func (in *LabelValues) DeepCopy() *LabelValues + func (in *LabelValues) DeepCopyInto(out *LabelValues) + func (m *LabelValues) Marshal() (dAtA []byte, err error) + func (m *LabelValues) MarshalTo(dAtA []byte) (int, error) + func (m *LabelValues) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *LabelValues) Reset() + func (m *LabelValues) Size() (n int) + func (m *LabelValues) Unmarshal(dAtA []byte) error + func (m *LabelValues) XXX_DiscardUnknown() + func (m *LabelValues) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *LabelValues) XXX_Merge(src proto.Message) + func (m *LabelValues) XXX_Size() int + func (m *LabelValues) XXX_Unmarshal(b []byte) error + func (this *LabelValues) String() string + type LifecycleEvent string + type LifecycleHook struct + Arguments Arguments + Template string + func (*LifecycleHook) Descriptor() ([]byte, []int) + func (*LifecycleHook) ProtoMessage() + func (in *LifecycleHook) DeepCopy() *LifecycleHook + func (in *LifecycleHook) DeepCopyInto(out *LifecycleHook) + func (lch *LifecycleHook) WithArgs(args Arguments) *LifecycleHook + func (m *LifecycleHook) Marshal() (dAtA []byte, err error) + func (m *LifecycleHook) MarshalTo(dAtA []byte) (int, error) + func (m *LifecycleHook) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *LifecycleHook) Reset() + func (m *LifecycleHook) Size() (n int) + func (m *LifecycleHook) Unmarshal(dAtA []byte) error + func (m *LifecycleHook) XXX_DiscardUnknown() + func (m *LifecycleHook) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *LifecycleHook) XXX_Merge(src proto.Message) + func (m *LifecycleHook) XXX_Size() int + func (m *LifecycleHook) XXX_Unmarshal(b []byte) error + func (this *LifecycleHook) String() string + type LifecycleHooks map[LifecycleEvent]LifecycleHook + func (in LifecycleHooks) DeepCopy() LifecycleHooks + func (in LifecycleHooks) DeepCopyInto(out *LifecycleHooks) + func (lchs LifecycleHooks) GetExitHook() *LifecycleHook + type Link struct + Name string + Scope string + URL string + func (*Link) Descriptor() ([]byte, []int) + func (*Link) ProtoMessage() + func (in *Link) DeepCopy() *Link + func (in *Link) DeepCopyInto(out *Link) + func (m *Link) Marshal() (dAtA []byte, err error) + func (m *Link) MarshalTo(dAtA []byte) (int, error) + func (m *Link) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Link) Reset() + func (m *Link) Size() (n int) + func (m *Link) Unmarshal(dAtA []byte) error + func (m *Link) XXX_DiscardUnknown() + func (m *Link) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Link) XXX_Merge(src proto.Message) + func (m *Link) XXX_Size() int + func (m *Link) XXX_Unmarshal(b []byte) error + func (this *Link) String() string + type MemoizationStatus struct + CacheName string + Hit bool + Key string + func (*MemoizationStatus) Descriptor() ([]byte, []int) + func (*MemoizationStatus) ProtoMessage() + func (in *MemoizationStatus) DeepCopy() *MemoizationStatus + func (in *MemoizationStatus) DeepCopyInto(out *MemoizationStatus) + func (m *MemoizationStatus) Marshal() (dAtA []byte, err error) + func (m *MemoizationStatus) MarshalTo(dAtA []byte) (int, error) + func (m *MemoizationStatus) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *MemoizationStatus) Reset() + func (m *MemoizationStatus) Size() (n int) + func (m *MemoizationStatus) Unmarshal(dAtA []byte) error + func (m *MemoizationStatus) XXX_DiscardUnknown() + func (m *MemoizationStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *MemoizationStatus) XXX_Merge(src proto.Message) + func (m *MemoizationStatus) XXX_Size() int + func (m *MemoizationStatus) XXX_Unmarshal(b []byte) error + func (this *MemoizationStatus) String() string + type Memoize struct + Cache *Cache + Key string + MaxAge string + func (*Memoize) Descriptor() ([]byte, []int) + func (*Memoize) ProtoMessage() + func (in *Memoize) DeepCopy() *Memoize + func (in *Memoize) DeepCopyInto(out *Memoize) + func (m *Memoize) Marshal() (dAtA []byte, err error) + func (m *Memoize) MarshalTo(dAtA []byte) (int, error) + func (m *Memoize) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Memoize) Reset() + func (m *Memoize) Size() (n int) + func (m *Memoize) Unmarshal(dAtA []byte) error + func (m *Memoize) XXX_DiscardUnknown() + func (m *Memoize) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Memoize) XXX_Merge(src proto.Message) + func (m *Memoize) XXX_Size() int + func (m *Memoize) XXX_Unmarshal(b []byte) error + func (this *Memoize) String() string + 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 MetricLabel struct + Key string + Value string + func (*MetricLabel) Descriptor() ([]byte, []int) + func (*MetricLabel) ProtoMessage() + func (in *MetricLabel) DeepCopy() *MetricLabel + func (in *MetricLabel) DeepCopyInto(out *MetricLabel) + func (m *MetricLabel) Marshal() (dAtA []byte, err error) + func (m *MetricLabel) MarshalTo(dAtA []byte) (int, error) + func (m *MetricLabel) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *MetricLabel) Reset() + func (m *MetricLabel) Size() (n int) + func (m *MetricLabel) Unmarshal(dAtA []byte) error + func (m *MetricLabel) XXX_DiscardUnknown() + func (m *MetricLabel) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *MetricLabel) XXX_Merge(src proto.Message) + func (m *MetricLabel) XXX_Size() int + func (m *MetricLabel) XXX_Unmarshal(b []byte) error + func (this *MetricLabel) String() string + type MetricType string + const MetricTypeCounter + const MetricTypeGauge + const MetricTypeHistogram + const MetricTypeUnknown + type Metrics struct + Prometheus []*Prometheus + func (*Metrics) Descriptor() ([]byte, []int) + func (*Metrics) ProtoMessage() + func (in *Metrics) DeepCopy() *Metrics + func (in *Metrics) DeepCopyInto(out *Metrics) + func (m *Metrics) Marshal() (dAtA []byte, err error) + func (m *Metrics) MarshalTo(dAtA []byte) (int, error) + func (m *Metrics) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Metrics) Reset() + func (m *Metrics) Size() (n int) + func (m *Metrics) Unmarshal(dAtA []byte) error + func (m *Metrics) XXX_DiscardUnknown() + func (m *Metrics) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Metrics) XXX_Merge(src proto.Message) + func (m *Metrics) XXX_Size() int + func (m *Metrics) XXX_Unmarshal(b []byte) error + func (this *Metrics) String() string + type Mutex struct + Name string + func (*Mutex) Descriptor() ([]byte, []int) + func (*Mutex) ProtoMessage() + func (in *Mutex) DeepCopy() *Mutex + func (in *Mutex) DeepCopyInto(out *Mutex) + func (m *Mutex) Marshal() (dAtA []byte, err error) + func (m *Mutex) MarshalTo(dAtA []byte) (int, error) + func (m *Mutex) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Mutex) Reset() + func (m *Mutex) Size() (n int) + func (m *Mutex) Unmarshal(dAtA []byte) error + func (m *Mutex) XXX_DiscardUnknown() + func (m *Mutex) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Mutex) XXX_Merge(src proto.Message) + func (m *Mutex) XXX_Size() int + func (m *Mutex) XXX_Unmarshal(b []byte) error + func (this *Mutex) String() string + type MutexHolding struct + Holder string + Mutex string + func (*MutexHolding) Descriptor() ([]byte, []int) + func (*MutexHolding) ProtoMessage() + func (in *MutexHolding) DeepCopy() *MutexHolding + func (in *MutexHolding) DeepCopyInto(out *MutexHolding) + func (m *MutexHolding) Marshal() (dAtA []byte, err error) + func (m *MutexHolding) MarshalTo(dAtA []byte) (int, error) + func (m *MutexHolding) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *MutexHolding) Reset() + func (m *MutexHolding) Size() (n int) + func (m *MutexHolding) Unmarshal(dAtA []byte) error + func (m *MutexHolding) XXX_DiscardUnknown() + func (m *MutexHolding) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *MutexHolding) XXX_Merge(src proto.Message) + func (m *MutexHolding) XXX_Size() int + func (m *MutexHolding) XXX_Unmarshal(b []byte) error + func (this *MutexHolding) String() string + type MutexStatus struct + Holding []MutexHolding + Waiting []MutexHolding + func (*MutexStatus) Descriptor() ([]byte, []int) + func (*MutexStatus) ProtoMessage() + func (in *MutexStatus) DeepCopy() *MutexStatus + func (in *MutexStatus) DeepCopyInto(out *MutexStatus) + func (m *MutexStatus) Marshal() (dAtA []byte, err error) + func (m *MutexStatus) MarshalTo(dAtA []byte) (int, error) + func (m *MutexStatus) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *MutexStatus) Reset() + func (m *MutexStatus) Size() (n int) + func (m *MutexStatus) Unmarshal(dAtA []byte) error + func (m *MutexStatus) XXX_DiscardUnknown() + func (m *MutexStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *MutexStatus) XXX_Merge(src proto.Message) + func (m *MutexStatus) XXX_Size() int + func (m *MutexStatus) XXX_Unmarshal(b []byte) error + func (ms *MutexStatus) GetHolding(mutexName string) (int, MutexHolding) + func (ms *MutexStatus) GetWaiting(mutexName string) (int, MutexHolding) + func (ms *MutexStatus) LockAcquired(holderKey, lockKey string, currentHolders []string) bool + func (ms *MutexStatus) LockReleased(holderKey, lockKey string) bool + func (ms *MutexStatus) LockWaiting(holderKey, lockKey string, currentHolders []string) bool + func (this *MutexStatus) String() string + type NodePhase string + const NodeError + const NodeFailed + const NodeOmitted + const NodePending + const NodeRunning + const NodeSkipped + const NodeSucceeded + func (phase NodePhase) Completed() bool + func (phase NodePhase) FailedOrError() bool + func (phase NodePhase) Fulfilled() bool + type NodeResult struct + Message string + Outputs *Outputs + Phase NodePhase + func (*NodeResult) Descriptor() ([]byte, []int) + func (*NodeResult) ProtoMessage() + func (in *NodeResult) DeepCopy() *NodeResult + func (in *NodeResult) DeepCopyInto(out *NodeResult) + func (in NodeResult) Fulfilled() bool + func (m *NodeResult) Marshal() (dAtA []byte, err error) + func (m *NodeResult) MarshalTo(dAtA []byte) (int, error) + func (m *NodeResult) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *NodeResult) Reset() + func (m *NodeResult) Size() (n int) + func (m *NodeResult) Unmarshal(dAtA []byte) error + func (m *NodeResult) XXX_DiscardUnknown() + func (m *NodeResult) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *NodeResult) XXX_Merge(src proto.Message) + func (m *NodeResult) XXX_Size() int + func (m *NodeResult) XXX_Unmarshal(b []byte) error + func (this *NodeResult) String() string + type NodeStatus struct + BoundaryID string + Children []string + Daemoned *bool + DisplayName string + EstimatedDuration EstimatedDuration + FinishedAt metav1.Time + HostNodeName string + ID string + Inputs *Inputs + MemoizationStatus *MemoizationStatus + Message string + Name string + OutboundNodes []string + Outputs *Outputs + Phase NodePhase + PodIP string + Progress Progress + ResourcesDuration ResourcesDuration + StartedAt metav1.Time + SynchronizationStatus *NodeSynchronizationStatus + TemplateName string + TemplateRef *TemplateRef + TemplateScope string + Type NodeType + 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) GetTemplate() *Template + func (n *NodeStatus) GetTemplateName() string + func (n *NodeStatus) GetTemplateRef() *TemplateRef + func (n *NodeStatus) IsActiveSuspendNode() bool + func (n NodeStatus) CanRetry() bool + func (n NodeStatus) Completed() bool + func (n NodeStatus) FailedOrError() bool + func (n NodeStatus) FinishTime() *metav1.Time + func (n NodeStatus) Fulfilled() bool + func (n NodeStatus) GetDuration() time.Duration + func (n NodeStatus) GetTemplateScope() (ResourceScope, string) + func (n NodeStatus) HasChild(childID string) bool + func (n NodeStatus) IsDaemoned() bool + func (n NodeStatus) Omitted() bool + func (n NodeStatus) Pending() bool + func (n NodeStatus) StartTime() *metav1.Time + func (n NodeStatus) Succeeded() bool + func (this *NodeStatus) String() string + type NodeSynchronizationStatus struct + Waiting string + func (*NodeSynchronizationStatus) Descriptor() ([]byte, []int) + func (*NodeSynchronizationStatus) ProtoMessage() + func (in *NodeSynchronizationStatus) DeepCopy() *NodeSynchronizationStatus + func (in *NodeSynchronizationStatus) DeepCopyInto(out *NodeSynchronizationStatus) + func (m *NodeSynchronizationStatus) Marshal() (dAtA []byte, err error) + func (m *NodeSynchronizationStatus) MarshalTo(dAtA []byte) (int, error) + func (m *NodeSynchronizationStatus) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *NodeSynchronizationStatus) Reset() + func (m *NodeSynchronizationStatus) Size() (n int) + func (m *NodeSynchronizationStatus) Unmarshal(dAtA []byte) error + func (m *NodeSynchronizationStatus) XXX_DiscardUnknown() + func (m *NodeSynchronizationStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *NodeSynchronizationStatus) XXX_Merge(src proto.Message) + func (m *NodeSynchronizationStatus) XXX_Size() int + func (m *NodeSynchronizationStatus) XXX_Unmarshal(b []byte) error + func (this *NodeSynchronizationStatus) String() string + type NodeType string + const NodeTypeContainer + const NodeTypeDAG + const NodeTypeHTTP + 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(NodeStatus) bool) bool + func (in Nodes) DeepCopy() Nodes + func (in Nodes) DeepCopyInto(out *Nodes) + func (n Nodes) Find(f func(NodeStatus) bool) *NodeStatus + func (n Nodes) FindByDisplayName(name string) *NodeStatus + func (n Nodes) HasHTTPNodes() bool + func (s Nodes) Children(parentNodeId string) Nodes + func (s Nodes) Filter(predicate func(NodeStatus) bool) Nodes + func (s Nodes) Map(f func(x NodeStatus) interface{}) map[string]interface{} + 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 OSSArtifact struct + Key string + func (*OSSArtifact) Descriptor() ([]byte, []int) + func (*OSSArtifact) ProtoMessage() + func (in *OSSArtifact) DeepCopy() *OSSArtifact + func (in *OSSArtifact) DeepCopyInto(out *OSSArtifact) + func (m *OSSArtifact) Marshal() (dAtA []byte, err error) + func (m *OSSArtifact) MarshalTo(dAtA []byte) (int, error) + func (m *OSSArtifact) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *OSSArtifact) Reset() + func (m *OSSArtifact) Size() (n int) + func (m *OSSArtifact) Unmarshal(dAtA []byte) error + func (m *OSSArtifact) XXX_DiscardUnknown() + func (m *OSSArtifact) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *OSSArtifact) XXX_Merge(src proto.Message) + func (m *OSSArtifact) XXX_Size() int + func (m *OSSArtifact) XXX_Unmarshal(b []byte) error + func (o *OSSArtifact) GetKey() (string, error) + func (o *OSSArtifact) HasLocation() bool + func (o *OSSArtifact) SetKey(key string) error + func (this *OSSArtifact) String() string + type OSSArtifactRepository struct + KeyFormat string + func (*OSSArtifactRepository) Descriptor() ([]byte, []int) + func (*OSSArtifactRepository) ProtoMessage() + func (in *OSSArtifactRepository) DeepCopy() *OSSArtifactRepository + func (in *OSSArtifactRepository) DeepCopyInto(out *OSSArtifactRepository) + func (m *OSSArtifactRepository) Marshal() (dAtA []byte, err error) + func (m *OSSArtifactRepository) MarshalTo(dAtA []byte) (int, error) + func (m *OSSArtifactRepository) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *OSSArtifactRepository) Reset() + func (m *OSSArtifactRepository) Size() (n int) + func (m *OSSArtifactRepository) Unmarshal(dAtA []byte) error + func (m *OSSArtifactRepository) XXX_DiscardUnknown() + func (m *OSSArtifactRepository) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *OSSArtifactRepository) XXX_Merge(src proto.Message) + func (m *OSSArtifactRepository) XXX_Size() int + func (m *OSSArtifactRepository) XXX_Unmarshal(b []byte) error + func (r *OSSArtifactRepository) IntoArtifactLocation(l *ArtifactLocation) + func (this *OSSArtifactRepository) String() string + type OSSBucket struct + AccessKeySecret *apiv1.SecretKeySelector + Bucket string + CreateBucketIfNotPresent bool + Endpoint string + LifecycleRule *OSSLifecycleRule + SecretKeySecret *apiv1.SecretKeySelector + SecurityToken string + func (*OSSBucket) Descriptor() ([]byte, []int) + func (*OSSBucket) ProtoMessage() + func (in *OSSBucket) DeepCopy() *OSSBucket + func (in *OSSBucket) DeepCopyInto(out *OSSBucket) + func (m *OSSBucket) Marshal() (dAtA []byte, err error) + func (m *OSSBucket) MarshalTo(dAtA []byte) (int, error) + func (m *OSSBucket) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *OSSBucket) Reset() + func (m *OSSBucket) Size() (n int) + func (m *OSSBucket) Unmarshal(dAtA []byte) error + func (m *OSSBucket) XXX_DiscardUnknown() + func (m *OSSBucket) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *OSSBucket) XXX_Merge(src proto.Message) + func (m *OSSBucket) XXX_Size() int + func (m *OSSBucket) XXX_Unmarshal(b []byte) error + func (this *OSSBucket) String() string + type OSSLifecycleRule struct + MarkDeletionAfterDays int32 + MarkInfrequentAccessAfterDays int32 + func (*OSSLifecycleRule) Descriptor() ([]byte, []int) + func (*OSSLifecycleRule) ProtoMessage() + func (in *OSSLifecycleRule) DeepCopy() *OSSLifecycleRule + func (in *OSSLifecycleRule) DeepCopyInto(out *OSSLifecycleRule) + func (m *OSSLifecycleRule) Marshal() (dAtA []byte, err error) + func (m *OSSLifecycleRule) MarshalTo(dAtA []byte) (int, error) + func (m *OSSLifecycleRule) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *OSSLifecycleRule) Reset() + func (m *OSSLifecycleRule) Size() (n int) + func (m *OSSLifecycleRule) Unmarshal(dAtA []byte) error + func (m *OSSLifecycleRule) XXX_DiscardUnknown() + func (m *OSSLifecycleRule) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *OSSLifecycleRule) XXX_Merge(src proto.Message) + func (m *OSSLifecycleRule) XXX_Size() int + func (m *OSSLifecycleRule) XXX_Unmarshal(b []byte) error + func (this *OSSLifecycleRule) String() string + type Outputs struct + Artifacts Artifacts + ExitCode *string + 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 (b ParallelSteps) OpenAPISchemaFormat() string + func (b ParallelSteps) OpenAPISchemaType() []string + 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) UnmarshalJSON(value []byte) error + func (p ParallelSteps) MarshalJSON() ([]byte, error) + func (this *ParallelSteps) String() string + type Parameter struct + Default *AnyString + Enum []AnyString + GlobalName string + Name string + Value *AnyString + 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) GetValue() string + func (p *Parameter) HasValue() bool + func (this *Parameter) String() string + type PodGC struct + LabelSelector *metav1.LabelSelector + 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 (podGC *PodGC) GetLabelSelector() *metav1.LabelSelector + func (podGC *PodGC) Matches(labels labels.Set) (bool, error) + func (this *PodGC) String() string + type PodGCStrategy string + const PodGCOnPodCompletion + const PodGCOnPodSuccess + const PodGCOnWorkflowCompletion + const PodGCOnWorkflowSuccess + type Progress string + func NewProgress(n, m int64) (Progress, bool) + func ParseProgress(s string) (Progress, bool) + func (in Progress) Add(x Progress) Progress + func (in Progress) IsValid() bool + func (in Progress) M() int64 + func (in Progress) N() int64 + type Prometheus struct + Counter *Counter + Gauge *Gauge + Help string + Histogram *Histogram + Labels []*MetricLabel + Name string + When string + func (*Prometheus) Descriptor() ([]byte, []int) + func (*Prometheus) ProtoMessage() + func (in *Prometheus) DeepCopy() *Prometheus + func (in *Prometheus) DeepCopyInto(out *Prometheus) + func (m *Prometheus) Marshal() (dAtA []byte, err error) + func (m *Prometheus) MarshalTo(dAtA []byte) (int, error) + func (m *Prometheus) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Prometheus) Reset() + func (m *Prometheus) Size() (n int) + func (m *Prometheus) Unmarshal(dAtA []byte) error + func (m *Prometheus) XXX_DiscardUnknown() + func (m *Prometheus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Prometheus) XXX_Merge(src proto.Message) + func (m *Prometheus) XXX_Size() int + func (m *Prometheus) XXX_Unmarshal(b []byte) error + func (p *Prometheus) GetDesc() string + func (p *Prometheus) GetMetricLabels() map[string]string + func (p *Prometheus) GetMetricType() MetricType + func (p *Prometheus) GetValueString() string + func (p *Prometheus) IsRealtime() bool + func (p *Prometheus) SetValueString(val string) + func (this *Prometheus) String() string + 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) GetKey() (string, error) + func (r *RawArtifact) HasLocation() bool + func (r *RawArtifact) SetKey(string) error + func (this *RawArtifact) String() string + type ResourceDuration int64 + func NewResourceDuration(d time.Duration) ResourceDuration + func (in ResourceDuration) Duration() time.Duration + func (in ResourceDuration) String() string + type ResourceScope string + const ResourceScopeCluster + const ResourceScopeLocal + const ResourceScopeNamespaced + type ResourceTemplate struct + Action string + FailureCondition string + Flags []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 ResourcesDuration map[apiv1.ResourceName]ResourceDuration + func (in ResourcesDuration) Add(o ResourcesDuration) ResourcesDuration + func (in ResourcesDuration) DeepCopy() ResourcesDuration + func (in ResourcesDuration) DeepCopyInto(out *ResourcesDuration) + func (in ResourcesDuration) IsZero() bool + func (in ResourcesDuration) String() string + type RetryAffinity struct + NodeAntiAffinity *RetryNodeAntiAffinity + func (*RetryAffinity) Descriptor() ([]byte, []int) + func (*RetryAffinity) ProtoMessage() + func (in *RetryAffinity) DeepCopy() *RetryAffinity + func (in *RetryAffinity) DeepCopyInto(out *RetryAffinity) + func (m *RetryAffinity) Marshal() (dAtA []byte, err error) + func (m *RetryAffinity) MarshalTo(dAtA []byte) (int, error) + func (m *RetryAffinity) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *RetryAffinity) Reset() + func (m *RetryAffinity) Size() (n int) + func (m *RetryAffinity) Unmarshal(dAtA []byte) error + func (m *RetryAffinity) XXX_DiscardUnknown() + func (m *RetryAffinity) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *RetryAffinity) XXX_Merge(src proto.Message) + func (m *RetryAffinity) XXX_Size() int + func (m *RetryAffinity) XXX_Unmarshal(b []byte) error + func (this *RetryAffinity) String() string + type RetryNodeAntiAffinity struct + func (*RetryNodeAntiAffinity) Descriptor() ([]byte, []int) + func (*RetryNodeAntiAffinity) ProtoMessage() + func (in *RetryNodeAntiAffinity) DeepCopy() *RetryNodeAntiAffinity + func (in *RetryNodeAntiAffinity) DeepCopyInto(out *RetryNodeAntiAffinity) + func (m *RetryNodeAntiAffinity) Marshal() (dAtA []byte, err error) + func (m *RetryNodeAntiAffinity) MarshalTo(dAtA []byte) (int, error) + func (m *RetryNodeAntiAffinity) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *RetryNodeAntiAffinity) Reset() + func (m *RetryNodeAntiAffinity) Size() (n int) + func (m *RetryNodeAntiAffinity) Unmarshal(dAtA []byte) error + func (m *RetryNodeAntiAffinity) XXX_DiscardUnknown() + func (m *RetryNodeAntiAffinity) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *RetryNodeAntiAffinity) XXX_Merge(src proto.Message) + func (m *RetryNodeAntiAffinity) XXX_Size() int + func (m *RetryNodeAntiAffinity) XXX_Unmarshal(b []byte) error + func (this *RetryNodeAntiAffinity) String() string + type RetryPolicy string + const RetryPolicyAlways + const RetryPolicyOnError + const RetryPolicyOnFailure + const RetryPolicyOnTransientError + type RetryStrategy struct + Affinity *RetryAffinity + Backoff *Backoff + Expression string + Limit *intstr.IntOrString + 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) GetKey() (string, error) + func (s *S3Artifact) HasLocation() bool + func (s *S3Artifact) SetKey(key string) error + func (this *S3Artifact) String() string + type S3ArtifactRepository struct + KeyFormat string + KeyPrefix string + func (*S3ArtifactRepository) Descriptor() ([]byte, []int) + func (*S3ArtifactRepository) ProtoMessage() + func (in *S3ArtifactRepository) DeepCopy() *S3ArtifactRepository + func (in *S3ArtifactRepository) DeepCopyInto(out *S3ArtifactRepository) + func (m *S3ArtifactRepository) Marshal() (dAtA []byte, err error) + func (m *S3ArtifactRepository) MarshalTo(dAtA []byte) (int, error) + func (m *S3ArtifactRepository) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *S3ArtifactRepository) Reset() + func (m *S3ArtifactRepository) Size() (n int) + func (m *S3ArtifactRepository) Unmarshal(dAtA []byte) error + func (m *S3ArtifactRepository) XXX_DiscardUnknown() + func (m *S3ArtifactRepository) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *S3ArtifactRepository) XXX_Merge(src proto.Message) + func (m *S3ArtifactRepository) XXX_Size() int + func (m *S3ArtifactRepository) XXX_Unmarshal(b []byte) error + func (r *S3ArtifactRepository) IntoArtifactLocation(l *ArtifactLocation) + func (this *S3ArtifactRepository) String() string + type S3Bucket struct + AccessKeySecret *apiv1.SecretKeySelector + Bucket string + CreateBucketIfNotPresent *CreateS3BucketOptions + EncryptionOptions *S3EncryptionOptions + Endpoint string + Insecure *bool + Region string + RoleARN string + SecretKeySecret *apiv1.SecretKeySelector + UseSDKCreds bool + 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 S3EncryptionOptions struct + EnableEncryption bool + KmsEncryptionContext string + KmsKeyId string + ServerSideCustomerKeySecret *apiv1.SecretKeySelector + func (*S3EncryptionOptions) Descriptor() ([]byte, []int) + func (*S3EncryptionOptions) ProtoMessage() + func (in *S3EncryptionOptions) DeepCopy() *S3EncryptionOptions + func (in *S3EncryptionOptions) DeepCopyInto(out *S3EncryptionOptions) + func (m *S3EncryptionOptions) Marshal() (dAtA []byte, err error) + func (m *S3EncryptionOptions) MarshalTo(dAtA []byte) (int, error) + func (m *S3EncryptionOptions) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *S3EncryptionOptions) Reset() + func (m *S3EncryptionOptions) Size() (n int) + func (m *S3EncryptionOptions) Unmarshal(dAtA []byte) error + func (m *S3EncryptionOptions) XXX_DiscardUnknown() + func (m *S3EncryptionOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *S3EncryptionOptions) XXX_Merge(src proto.Message) + func (m *S3EncryptionOptions) XXX_Size() int + func (m *S3EncryptionOptions) XXX_Unmarshal(b []byte) error + func (this *S3EncryptionOptions) 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 SemaphoreHolding struct + Holders []string + Semaphore string + func (*SemaphoreHolding) Descriptor() ([]byte, []int) + func (*SemaphoreHolding) ProtoMessage() + func (in *SemaphoreHolding) DeepCopy() *SemaphoreHolding + func (in *SemaphoreHolding) DeepCopyInto(out *SemaphoreHolding) + func (m *SemaphoreHolding) Marshal() (dAtA []byte, err error) + func (m *SemaphoreHolding) MarshalTo(dAtA []byte) (int, error) + func (m *SemaphoreHolding) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *SemaphoreHolding) Reset() + func (m *SemaphoreHolding) Size() (n int) + func (m *SemaphoreHolding) Unmarshal(dAtA []byte) error + func (m *SemaphoreHolding) XXX_DiscardUnknown() + func (m *SemaphoreHolding) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *SemaphoreHolding) XXX_Merge(src proto.Message) + func (m *SemaphoreHolding) XXX_Size() int + func (m *SemaphoreHolding) XXX_Unmarshal(b []byte) error + func (this *SemaphoreHolding) String() string + type SemaphoreRef struct + ConfigMapKeyRef *apiv1.ConfigMapKeySelector + func (*SemaphoreRef) Descriptor() ([]byte, []int) + func (*SemaphoreRef) ProtoMessage() + func (in *SemaphoreRef) DeepCopy() *SemaphoreRef + func (in *SemaphoreRef) DeepCopyInto(out *SemaphoreRef) + func (m *SemaphoreRef) Marshal() (dAtA []byte, err error) + func (m *SemaphoreRef) MarshalTo(dAtA []byte) (int, error) + func (m *SemaphoreRef) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *SemaphoreRef) Reset() + func (m *SemaphoreRef) Size() (n int) + func (m *SemaphoreRef) Unmarshal(dAtA []byte) error + func (m *SemaphoreRef) XXX_DiscardUnknown() + func (m *SemaphoreRef) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *SemaphoreRef) XXX_Merge(src proto.Message) + func (m *SemaphoreRef) XXX_Size() int + func (m *SemaphoreRef) XXX_Unmarshal(b []byte) error + func (this *SemaphoreRef) String() string + type SemaphoreStatus struct + Holding []SemaphoreHolding + Waiting []SemaphoreHolding + func (*SemaphoreStatus) Descriptor() ([]byte, []int) + func (*SemaphoreStatus) ProtoMessage() + func (in *SemaphoreStatus) DeepCopy() *SemaphoreStatus + func (in *SemaphoreStatus) DeepCopyInto(out *SemaphoreStatus) + func (m *SemaphoreStatus) Marshal() (dAtA []byte, err error) + func (m *SemaphoreStatus) MarshalTo(dAtA []byte) (int, error) + func (m *SemaphoreStatus) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *SemaphoreStatus) Reset() + func (m *SemaphoreStatus) Size() (n int) + func (m *SemaphoreStatus) Unmarshal(dAtA []byte) error + func (m *SemaphoreStatus) XXX_DiscardUnknown() + func (m *SemaphoreStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *SemaphoreStatus) XXX_Merge(src proto.Message) + func (m *SemaphoreStatus) XXX_Size() int + func (m *SemaphoreStatus) XXX_Unmarshal(b []byte) error + func (ss *SemaphoreStatus) GetHolding(semaphoreName string) (int, SemaphoreHolding) + func (ss *SemaphoreStatus) GetWaiting(semaphoreName string) (int, SemaphoreHolding) + func (ss *SemaphoreStatus) LockAcquired(holderKey, lockKey string, currentHolders []string) bool + func (ss *SemaphoreStatus) LockReleased(holderKey, lockKey string) bool + func (ss *SemaphoreStatus) LockWaiting(holderKey, lockKey string, currentHolders []string) bool + func (this *SemaphoreStatus) String() string + type Sequence struct + Count *intstr.IntOrString + End *intstr.IntOrString + Format string + Start *intstr.IntOrString + 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 ShutdownStrategy string + const ShutdownStrategyNone + const ShutdownStrategyStop + const ShutdownStrategyTerminate + func (s ShutdownStrategy) Enabled() bool + func (s ShutdownStrategy) ShouldExecute(isOnExitPod bool) bool + type Submit struct + Arguments *Arguments + WorkflowTemplateRef WorkflowTemplateRef + func (*Submit) Descriptor() ([]byte, []int) + func (*Submit) ProtoMessage() + func (in *Submit) DeepCopy() *Submit + func (in *Submit) DeepCopyInto(out *Submit) + func (m *Submit) Marshal() (dAtA []byte, err error) + func (m *Submit) MarshalTo(dAtA []byte) (int, error) + func (m *Submit) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Submit) Reset() + func (m *Submit) Size() (n int) + func (m *Submit) Unmarshal(dAtA []byte) error + func (m *Submit) XXX_DiscardUnknown() + func (m *Submit) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Submit) XXX_Merge(src proto.Message) + func (m *Submit) XXX_Size() int + func (m *Submit) XXX_Unmarshal(b []byte) error + func (this *Submit) String() string + type SubmitOpts struct + Annotations string + DryRun bool + Entrypoint string + GenerateName string + Labels string + Name string + OwnerReference *metav1.OwnerReference + ParameterFile string + Parameters []string + ServerDryRun bool + ServiceAccount string + func (*SubmitOpts) Descriptor() ([]byte, []int) + func (*SubmitOpts) ProtoMessage() + func (in *SubmitOpts) DeepCopy() *SubmitOpts + func (in *SubmitOpts) DeepCopyInto(out *SubmitOpts) + func (m *SubmitOpts) Marshal() (dAtA []byte, err error) + func (m *SubmitOpts) MarshalTo(dAtA []byte) (int, error) + func (m *SubmitOpts) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *SubmitOpts) Reset() + func (m *SubmitOpts) Size() (n int) + func (m *SubmitOpts) Unmarshal(dAtA []byte) error + func (m *SubmitOpts) XXX_DiscardUnknown() + func (m *SubmitOpts) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *SubmitOpts) XXX_Merge(src proto.Message) + func (m *SubmitOpts) XXX_Size() int + func (m *SubmitOpts) XXX_Unmarshal(b []byte) error + func (this *SubmitOpts) String() string + type SuppliedValueFrom struct + func (*SuppliedValueFrom) Descriptor() ([]byte, []int) + func (*SuppliedValueFrom) ProtoMessage() + func (in *SuppliedValueFrom) DeepCopy() *SuppliedValueFrom + func (in *SuppliedValueFrom) DeepCopyInto(out *SuppliedValueFrom) + func (m *SuppliedValueFrom) Marshal() (dAtA []byte, err error) + func (m *SuppliedValueFrom) MarshalTo(dAtA []byte) (int, error) + func (m *SuppliedValueFrom) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *SuppliedValueFrom) Reset() + func (m *SuppliedValueFrom) Size() (n int) + func (m *SuppliedValueFrom) Unmarshal(dAtA []byte) error + func (m *SuppliedValueFrom) XXX_DiscardUnknown() + func (m *SuppliedValueFrom) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *SuppliedValueFrom) XXX_Merge(src proto.Message) + func (m *SuppliedValueFrom) XXX_Size() int + func (m *SuppliedValueFrom) XXX_Unmarshal(b []byte) error + func (this *SuppliedValueFrom) 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 Synchronization struct + Mutex *Mutex + Semaphore *SemaphoreRef + func (*Synchronization) Descriptor() ([]byte, []int) + func (*Synchronization) ProtoMessage() + func (in *Synchronization) DeepCopy() *Synchronization + func (in *Synchronization) DeepCopyInto(out *Synchronization) + func (m *Synchronization) Marshal() (dAtA []byte, err error) + func (m *Synchronization) MarshalTo(dAtA []byte) (int, error) + func (m *Synchronization) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Synchronization) Reset() + func (m *Synchronization) Size() (n int) + func (m *Synchronization) Unmarshal(dAtA []byte) error + func (m *Synchronization) XXX_DiscardUnknown() + func (m *Synchronization) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Synchronization) XXX_Merge(src proto.Message) + func (m *Synchronization) XXX_Size() int + func (m *Synchronization) XXX_Unmarshal(b []byte) error + func (s *Synchronization) GetType() SynchronizationType + func (this *Synchronization) String() string + type SynchronizationAction interface + LockAcquired func(holderKey, lockKey string, currentHolders []string) bool + LockReleased func(holderKey, lockKey string) bool + LockWaiting func(holderKey, lockKey string, currentHolders []string) bool + type SynchronizationStatus struct + Mutex *MutexStatus + Semaphore *SemaphoreStatus + func (*SynchronizationStatus) Descriptor() ([]byte, []int) + func (*SynchronizationStatus) ProtoMessage() + func (in *SynchronizationStatus) DeepCopy() *SynchronizationStatus + func (in *SynchronizationStatus) DeepCopyInto(out *SynchronizationStatus) + func (m *SynchronizationStatus) Marshal() (dAtA []byte, err error) + func (m *SynchronizationStatus) MarshalTo(dAtA []byte) (int, error) + func (m *SynchronizationStatus) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *SynchronizationStatus) Reset() + func (m *SynchronizationStatus) Size() (n int) + func (m *SynchronizationStatus) Unmarshal(dAtA []byte) error + func (m *SynchronizationStatus) XXX_DiscardUnknown() + func (m *SynchronizationStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *SynchronizationStatus) XXX_Merge(src proto.Message) + func (m *SynchronizationStatus) XXX_Size() int + func (m *SynchronizationStatus) XXX_Unmarshal(b []byte) error + func (ss *SynchronizationStatus) GetStatus(syncType SynchronizationType) SynchronizationAction + func (this *SynchronizationStatus) String() string + type SynchronizationType string + const SynchronizationTypeMutex + const SynchronizationTypeSemaphore + const SynchronizationTypeUnknown + 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 + CompressionLevel *int32 + 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 *intstr.IntOrString + Affinity *apiv1.Affinity + ArchiveLocation *ArtifactLocation + AutomountServiceAccountToken *bool + Container *apiv1.Container + ContainerSet *ContainerSetTemplate + DAG *DAGTemplate + Daemon *bool + Data *Data + Executor *ExecutorConfig + FailFast *bool + HTTP *HTTP + HostAliases []apiv1.HostAlias + InitContainers []UserContainer + Inputs Inputs + Memoize *Memoize + Metadata Metadata + Metrics *Metrics + 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 + Synchronization *Synchronization + Timeout string + Tolerations []apiv1.Toleration + Volumes []apiv1.Volume + func MustUnmarshalTemplate(text interface{}) *Template + 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) GetMainContainerNames() []string + func (tmpl *Template) GetSidecarNames() []string + func (tmpl *Template) GetType() TemplateType + func (tmpl *Template) GetVolumeMounts() []apiv1.VolumeMount + func (tmpl *Template) HasOutput() bool + func (tmpl *Template) HasParallelism() bool + func (tmpl *Template) HasPodSpecPatch() bool + func (tmpl *Template) HasSequencedContainers() bool + func (tmpl *Template) IsFailFast() bool + func (tmpl *Template) IsLeaf() bool + func (tmpl *Template) IsMainContainerName(containerName string) bool + func (tmpl *Template) IsPodType() bool + func (tmpl *Template) SaveLogsAsArtifact() bool + func (tmpl *Template) SetType(tmplType TemplateType) + type TemplateHolder interface + GetName func() string + GetNamespace func() string + GetResourceScope func() ResourceScope + GetTemplateByName func(name string) *Template + GroupVersionKind func() schema.GroupVersionKind + type TemplateRef struct + ClusterScope bool + Name string + 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 TemplateReferenceHolder interface + GetTemplate func() *Template + GetTemplateName func() string + GetTemplateRef func() *TemplateRef + type TemplateType string + const TemplateTypeContainer + const TemplateTypeContainerSet + const TemplateTypeDAG + const TemplateTypeData + const TemplateTypeHTTP + const TemplateTypeResource + const TemplateTypeScript + const TemplateTypeSteps + const TemplateTypeSuspend + const TemplateTypeUnknown + type Transformation []TransformationStep + func (in Transformation) DeepCopy() Transformation + func (in Transformation) DeepCopyInto(out *Transformation) + type TransformationStep struct + Expression string + func (*TransformationStep) Descriptor() ([]byte, []int) + func (*TransformationStep) ProtoMessage() + func (in *TransformationStep) DeepCopy() *TransformationStep + func (in *TransformationStep) DeepCopyInto(out *TransformationStep) + func (m *TransformationStep) Marshal() (dAtA []byte, err error) + func (m *TransformationStep) MarshalTo(dAtA []byte) (int, error) + func (m *TransformationStep) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *TransformationStep) Reset() + func (m *TransformationStep) Size() (n int) + func (m *TransformationStep) Unmarshal(dAtA []byte) error + func (m *TransformationStep) XXX_DiscardUnknown() + func (m *TransformationStep) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *TransformationStep) XXX_Merge(src proto.Message) + func (m *TransformationStep) XXX_Size() int + func (m *TransformationStep) XXX_Unmarshal(b []byte) error + func (this *TransformationStep) String() string + 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 + ConfigMapKeyRef *apiv1.ConfigMapKeySelector + Default *AnyString + Event string + Expression string + JQFilter string + JSONPath string + Parameter string + Path string + Supplied *SuppliedValueFrom + 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 Version struct + BuildDate string + Compiler string + GitCommit string + GitTag string + GitTreeState string + GoVersion string + Platform string + Version string + func (*Version) Descriptor() ([]byte, []int) + func (*Version) ProtoMessage() + func (in *Version) DeepCopy() *Version + func (in *Version) DeepCopyInto(out *Version) + func (m *Version) Marshal() (dAtA []byte, err error) + func (m *Version) MarshalTo(dAtA []byte) (int, error) + func (m *Version) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Version) Reset() + func (m *Version) Size() (n int) + func (m *Version) Unmarshal(dAtA []byte) error + func (m *Version) XXX_DiscardUnknown() + func (m *Version) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Version) XXX_Merge(src proto.Message) + func (m *Version) XXX_Size() int + func (m *Version) XXX_Unmarshal(b []byte) error + func (this *Version) String() string + type VolumeClaimGC struct + Strategy VolumeClaimGCStrategy + func (*VolumeClaimGC) Descriptor() ([]byte, []int) + func (*VolumeClaimGC) ProtoMessage() + func (in *VolumeClaimGC) DeepCopy() *VolumeClaimGC + func (in *VolumeClaimGC) DeepCopyInto(out *VolumeClaimGC) + func (m *VolumeClaimGC) Marshal() (dAtA []byte, err error) + func (m *VolumeClaimGC) MarshalTo(dAtA []byte) (int, error) + func (m *VolumeClaimGC) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *VolumeClaimGC) Reset() + func (m *VolumeClaimGC) Size() (n int) + func (m *VolumeClaimGC) Unmarshal(dAtA []byte) error + func (m *VolumeClaimGC) XXX_DiscardUnknown() + func (m *VolumeClaimGC) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *VolumeClaimGC) XXX_Merge(src proto.Message) + func (m *VolumeClaimGC) XXX_Size() int + func (m *VolumeClaimGC) XXX_Unmarshal(b []byte) error + func (this *VolumeClaimGC) String() string + func (vgc VolumeClaimGC) GetStrategy() VolumeClaimGCStrategy + type VolumeClaimGCStrategy string + const VolumeClaimGCOnCompletion + const VolumeClaimGCOnSuccess + type Workflow struct + Spec WorkflowSpec + Status WorkflowStatus + func MustUnmarshalWorkflow(text interface{}) *Workflow + 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 (w *Workflow) GetTTLStrategy() *TTLStrategy + func (wf *Workflow) GetNodeByName(nodeName string) *NodeStatus + func (wf *Workflow) GetOffloadNodeStatusVersion() string + func (wf *Workflow) GetResourceScope() ResourceScope + func (wf *Workflow) GetSemaphoreKeys() []string + func (wf *Workflow) GetStoredTemplate(scope ResourceScope, resourceName string, caller TemplateReferenceHolder) *Template + func (wf *Workflow) GetTemplateByName(name string) *Template + func (wf *Workflow) GetWorkflowSpec() WorkflowSpec + func (wf *Workflow) NodeID(name string) string + func (wf *Workflow) SetStoredTemplate(scope ResourceScope, resourceName string, caller TemplateReferenceHolder, ...) (bool, error) + type WorkflowEventBinding struct + Spec WorkflowEventBindingSpec + func (*WorkflowEventBinding) Descriptor() ([]byte, []int) + func (*WorkflowEventBinding) ProtoMessage() + func (in *WorkflowEventBinding) DeepCopy() *WorkflowEventBinding + func (in *WorkflowEventBinding) DeepCopyInto(out *WorkflowEventBinding) + func (in *WorkflowEventBinding) DeepCopyObject() runtime.Object + func (m *WorkflowEventBinding) Marshal() (dAtA []byte, err error) + func (m *WorkflowEventBinding) MarshalTo(dAtA []byte) (int, error) + func (m *WorkflowEventBinding) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *WorkflowEventBinding) Reset() + func (m *WorkflowEventBinding) Size() (n int) + func (m *WorkflowEventBinding) Unmarshal(dAtA []byte) error + func (m *WorkflowEventBinding) XXX_DiscardUnknown() + func (m *WorkflowEventBinding) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *WorkflowEventBinding) XXX_Merge(src proto.Message) + func (m *WorkflowEventBinding) XXX_Size() int + func (m *WorkflowEventBinding) XXX_Unmarshal(b []byte) error + func (this *WorkflowEventBinding) String() string + type WorkflowEventBindingList struct + Items []WorkflowEventBinding + func (*WorkflowEventBindingList) Descriptor() ([]byte, []int) + func (*WorkflowEventBindingList) ProtoMessage() + func (in *WorkflowEventBindingList) DeepCopy() *WorkflowEventBindingList + func (in *WorkflowEventBindingList) DeepCopyInto(out *WorkflowEventBindingList) + func (in *WorkflowEventBindingList) DeepCopyObject() runtime.Object + func (m *WorkflowEventBindingList) Marshal() (dAtA []byte, err error) + func (m *WorkflowEventBindingList) MarshalTo(dAtA []byte) (int, error) + func (m *WorkflowEventBindingList) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *WorkflowEventBindingList) Reset() + func (m *WorkflowEventBindingList) Size() (n int) + func (m *WorkflowEventBindingList) Unmarshal(dAtA []byte) error + func (m *WorkflowEventBindingList) XXX_DiscardUnknown() + func (m *WorkflowEventBindingList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *WorkflowEventBindingList) XXX_Merge(src proto.Message) + func (m *WorkflowEventBindingList) XXX_Size() int + func (m *WorkflowEventBindingList) XXX_Unmarshal(b []byte) error + func (this *WorkflowEventBindingList) String() string + type WorkflowEventBindingSpec struct + Event Event + Submit *Submit + func (*WorkflowEventBindingSpec) Descriptor() ([]byte, []int) + func (*WorkflowEventBindingSpec) ProtoMessage() + func (in *WorkflowEventBindingSpec) DeepCopy() *WorkflowEventBindingSpec + func (in *WorkflowEventBindingSpec) DeepCopyInto(out *WorkflowEventBindingSpec) + func (m *WorkflowEventBindingSpec) Marshal() (dAtA []byte, err error) + func (m *WorkflowEventBindingSpec) MarshalTo(dAtA []byte) (int, error) + func (m *WorkflowEventBindingSpec) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *WorkflowEventBindingSpec) Reset() + func (m *WorkflowEventBindingSpec) Size() (n int) + func (m *WorkflowEventBindingSpec) Unmarshal(dAtA []byte) error + func (m *WorkflowEventBindingSpec) XXX_DiscardUnknown() + func (m *WorkflowEventBindingSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *WorkflowEventBindingSpec) XXX_Merge(src proto.Message) + func (m *WorkflowEventBindingSpec) XXX_Size() int + func (m *WorkflowEventBindingSpec) XXX_Unmarshal(b []byte) error + func (this *WorkflowEventBindingSpec) String() string + 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 WorkflowPhase string + const WorkflowError + const WorkflowFailed + const WorkflowPending + const WorkflowRunning + const WorkflowSucceeded + const WorkflowUnknown + func (p WorkflowPhase) Completed() bool + type WorkflowPredicate = func(wf Workflow) bool + type WorkflowSpec struct + ActiveDeadlineSeconds *int64 + Affinity *apiv1.Affinity + ArchiveLogs *bool + Arguments Arguments + ArtifactRepositoryRef *ArtifactRepositoryRef + AutomountServiceAccountToken *bool + DNSConfig *apiv1.PodDNSConfig + DNSPolicy *apiv1.DNSPolicy + Entrypoint string + Executor *ExecutorConfig + HostAliases []apiv1.HostAlias + HostNetwork *bool + ImagePullSecrets []apiv1.LocalObjectReference + Metrics *Metrics + NodeSelector map[string]string + OnExit string + Parallelism *int64 + PodDisruptionBudget *policyv1beta.PodDisruptionBudgetSpec + PodGC *PodGC + PodMetadata *Metadata + PodPriority *int32 + PodPriorityClassName string + PodSpecPatch string + Priority *int32 + RetryStrategy *RetryStrategy + SchedulerName string + SecurityContext *apiv1.PodSecurityContext + ServiceAccountName string + Shutdown ShutdownStrategy + Suspend *bool + Synchronization *Synchronization + TTLStrategy *TTLStrategy + TemplateDefaults *Template + Templates []Template + Tolerations []apiv1.Toleration + VolumeClaimGC *VolumeClaimGC + VolumeClaimTemplates []apiv1.PersistentVolumeClaim + Volumes []apiv1.Volume + WorkflowTemplateRef *WorkflowTemplateRef + 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 + func (wfs WorkflowSpec) GetTTLStrategy() *TTLStrategy + func (wfs WorkflowSpec) GetVolumeClaimGC() *VolumeClaimGC + type WorkflowSpecHolder interface + GetWorkflowMetadata func() *metav1.ObjectMeta + GetWorkflowSpec func() *WorkflowSpec + type WorkflowStatus struct + ArtifactRepositoryRef *ArtifactRepositoryRefStatus + CompressedNodes string + Conditions Conditions + EstimatedDuration EstimatedDuration + FinishedAt metav1.Time + Message string + Nodes Nodes + OffloadNodeStatusVersion string + Outputs *Outputs + PersistentVolumeClaims []apiv1.Volume + Phase WorkflowPhase + Progress Progress + ResourcesDuration ResourcesDuration + StartedAt metav1.Time + StoredTemplates map[string]Template + StoredWorkflowSpec *WorkflowSpec + Synchronization *SynchronizationStatus + 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) GetDuration() time.Duration + func (ws *WorkflowStatus) GetOffloadNodeStatusVersion() string + func (ws *WorkflowStatus) IsOffloadNodeStatus() bool + func (ws WorkflowStatus) Failed() bool + func (ws WorkflowStatus) FinishTime() *metav1.Time + func (ws WorkflowStatus) Fulfilled() bool + func (ws WorkflowStatus) StartTime() *metav1.Time + func (ws WorkflowStatus) Successful() bool + type WorkflowStep struct + Arguments Arguments + ContinueOn *ContinueOn + Hooks LifecycleHooks + Inline *Template + 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) GetExitHook(args Arguments) *LifecycleHook + func (step *WorkflowStep) GetTemplate() *Template + func (step *WorkflowStep) GetTemplateName() string + func (step *WorkflowStep) GetTemplateRef() *TemplateRef + func (step *WorkflowStep) HasExitHook() bool + func (step *WorkflowStep) ShouldExpand() bool + func (this *WorkflowStep) String() string + type WorkflowTaskSet struct + Spec WorkflowTaskSetSpec + Status WorkflowTaskSetStatus + func (*WorkflowTaskSet) Descriptor() ([]byte, []int) + func (*WorkflowTaskSet) ProtoMessage() + func (in *WorkflowTaskSet) DeepCopy() *WorkflowTaskSet + func (in *WorkflowTaskSet) DeepCopyInto(out *WorkflowTaskSet) + func (in *WorkflowTaskSet) DeepCopyObject() runtime.Object + func (m *WorkflowTaskSet) Marshal() (dAtA []byte, err error) + func (m *WorkflowTaskSet) MarshalTo(dAtA []byte) (int, error) + func (m *WorkflowTaskSet) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *WorkflowTaskSet) Reset() + func (m *WorkflowTaskSet) Size() (n int) + func (m *WorkflowTaskSet) Unmarshal(dAtA []byte) error + func (m *WorkflowTaskSet) XXX_DiscardUnknown() + func (m *WorkflowTaskSet) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *WorkflowTaskSet) XXX_Merge(src proto.Message) + func (m *WorkflowTaskSet) XXX_Size() int + func (m *WorkflowTaskSet) XXX_Unmarshal(b []byte) error + func (this *WorkflowTaskSet) String() string + type WorkflowTaskSetList struct + Items []WorkflowTaskSet + func (*WorkflowTaskSetList) Descriptor() ([]byte, []int) + func (*WorkflowTaskSetList) ProtoMessage() + func (in *WorkflowTaskSetList) DeepCopy() *WorkflowTaskSetList + func (in *WorkflowTaskSetList) DeepCopyInto(out *WorkflowTaskSetList) + func (in *WorkflowTaskSetList) DeepCopyObject() runtime.Object + func (m *WorkflowTaskSetList) Marshal() (dAtA []byte, err error) + func (m *WorkflowTaskSetList) MarshalTo(dAtA []byte) (int, error) + func (m *WorkflowTaskSetList) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *WorkflowTaskSetList) Reset() + func (m *WorkflowTaskSetList) Size() (n int) + func (m *WorkflowTaskSetList) Unmarshal(dAtA []byte) error + func (m *WorkflowTaskSetList) XXX_DiscardUnknown() + func (m *WorkflowTaskSetList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *WorkflowTaskSetList) XXX_Merge(src proto.Message) + func (m *WorkflowTaskSetList) XXX_Size() int + func (m *WorkflowTaskSetList) XXX_Unmarshal(b []byte) error + func (this *WorkflowTaskSetList) String() string + type WorkflowTaskSetSpec struct + Tasks map[string]Template + func (*WorkflowTaskSetSpec) Descriptor() ([]byte, []int) + func (*WorkflowTaskSetSpec) ProtoMessage() + func (in *WorkflowTaskSetSpec) DeepCopy() *WorkflowTaskSetSpec + func (in *WorkflowTaskSetSpec) DeepCopyInto(out *WorkflowTaskSetSpec) + func (m *WorkflowTaskSetSpec) Marshal() (dAtA []byte, err error) + func (m *WorkflowTaskSetSpec) MarshalTo(dAtA []byte) (int, error) + func (m *WorkflowTaskSetSpec) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *WorkflowTaskSetSpec) Reset() + func (m *WorkflowTaskSetSpec) Size() (n int) + func (m *WorkflowTaskSetSpec) Unmarshal(dAtA []byte) error + func (m *WorkflowTaskSetSpec) XXX_DiscardUnknown() + func (m *WorkflowTaskSetSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *WorkflowTaskSetSpec) XXX_Merge(src proto.Message) + func (m *WorkflowTaskSetSpec) XXX_Size() int + func (m *WorkflowTaskSetSpec) XXX_Unmarshal(b []byte) error + func (this *WorkflowTaskSetSpec) String() string + type WorkflowTaskSetStatus struct + Nodes map[string]NodeResult + func (*WorkflowTaskSetStatus) Descriptor() ([]byte, []int) + func (*WorkflowTaskSetStatus) ProtoMessage() + func (in *WorkflowTaskSetStatus) DeepCopy() *WorkflowTaskSetStatus + func (in *WorkflowTaskSetStatus) DeepCopyInto(out *WorkflowTaskSetStatus) + func (m *WorkflowTaskSetStatus) Marshal() (dAtA []byte, err error) + func (m *WorkflowTaskSetStatus) MarshalTo(dAtA []byte) (int, error) + func (m *WorkflowTaskSetStatus) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *WorkflowTaskSetStatus) Reset() + func (m *WorkflowTaskSetStatus) Size() (n int) + func (m *WorkflowTaskSetStatus) Unmarshal(dAtA []byte) error + func (m *WorkflowTaskSetStatus) XXX_DiscardUnknown() + func (m *WorkflowTaskSetStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *WorkflowTaskSetStatus) XXX_Merge(src proto.Message) + func (m *WorkflowTaskSetStatus) XXX_Size() int + func (m *WorkflowTaskSetStatus) XXX_Unmarshal(b []byte) error + func (this *WorkflowTaskSetStatus) String() string + type WorkflowTemplate struct + Spec WorkflowTemplateSpec + func MustUnmarshalWorkflowTemplate(text interface{}) *WorkflowTemplate + 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) GetResourceScope() ResourceScope + func (wftmpl *WorkflowTemplate) GetTemplateByName(name string) *Template + func (wftmpl *WorkflowTemplate) GetWorkflowMetadata() *metav1.ObjectMeta + func (wftmpl *WorkflowTemplate) GetWorkflowSpec() *WorkflowSpec + 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 WorkflowTemplateRef struct + ClusterScope bool + Name string + func (*WorkflowTemplateRef) Descriptor() ([]byte, []int) + func (*WorkflowTemplateRef) ProtoMessage() + func (in *WorkflowTemplateRef) DeepCopy() *WorkflowTemplateRef + func (in *WorkflowTemplateRef) DeepCopyInto(out *WorkflowTemplateRef) + func (m *WorkflowTemplateRef) Marshal() (dAtA []byte, err error) + func (m *WorkflowTemplateRef) MarshalTo(dAtA []byte) (int, error) + func (m *WorkflowTemplateRef) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *WorkflowTemplateRef) Reset() + func (m *WorkflowTemplateRef) Size() (n int) + func (m *WorkflowTemplateRef) Unmarshal(dAtA []byte) error + func (m *WorkflowTemplateRef) XXX_DiscardUnknown() + func (m *WorkflowTemplateRef) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *WorkflowTemplateRef) XXX_Merge(src proto.Message) + func (m *WorkflowTemplateRef) XXX_Size() int + func (m *WorkflowTemplateRef) XXX_Unmarshal(b []byte) error + func (ref *WorkflowTemplateRef) ToTemplateRef(entrypoint string) *TemplateRef + func (this *WorkflowTemplateRef) String() string + type WorkflowTemplateSpec struct + WorkflowMetadata *metav1.ObjectMeta + 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) Filter(predicate WorkflowPredicate) Workflows + func (w Workflows) Len() int + func (w Workflows) Less(i, j int) bool + func (w Workflows) Swap(i, j int) + type ZipStrategy struct + func (*ZipStrategy) Descriptor() ([]byte, []int) + func (*ZipStrategy) ProtoMessage() + func (in *ZipStrategy) DeepCopy() *ZipStrategy + func (in *ZipStrategy) DeepCopyInto(out *ZipStrategy) + func (m *ZipStrategy) Marshal() (dAtA []byte, err error) + func (m *ZipStrategy) MarshalTo(dAtA []byte) (int, error) + func (m *ZipStrategy) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ZipStrategy) Reset() + func (m *ZipStrategy) Size() (n int) + func (m *ZipStrategy) Unmarshal(dAtA []byte) error + func (m *ZipStrategy) XXX_DiscardUnknown() + func (m *ZipStrategy) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ZipStrategy) XXX_Merge(src proto.Message) + func (m *ZipStrategy) XXX_Size() int + func (m *ZipStrategy) XXX_Unmarshal(b []byte) error + func (this *ZipStrategy) String() string Other modules containing this package github.com/svnshing/argo-workflows
Go to main page