v1alpha1

Feb 29, 2024

Changes in this version

type WorkflowStatus

+ func (ws *WorkflowStatus) IsTaskResultIncomplete(name string) bool

Jan 11, 2024

Changes in this version

type WorkflowStatus

+ TaskResultsCompletionStatus map[string]bool

+ func (ws *WorkflowStatus) TaskResultsInProgress() bool

Nov 27, 2023

Changes in this version

type WorkflowStatus

+ TaskResultsCompleted map[string]bool

+ func (ws *WorkflowStatus) GetTaskResultCompleted(name string) bool

+ func (ws *WorkflowStatus) GetTaskResultsCompleted() map[string]bool

+ func (ws *WorkflowStatus) InitializeTaskResultIncomplete(resultName string)

+ func (ws *WorkflowStatus) MarkTaskResultComplete(name string)

+ func (ws *WorkflowStatus) MarkTaskResultIncomplete(name string)

Nov 3, 2023

Changes in this version

+ type NodeFlag struct

+ Hooked bool

+ Retried bool

+ func (*NodeFlag) Descriptor() ([]byte, []int)

+ func (*NodeFlag) ProtoMessage()

+ func (in *NodeFlag) DeepCopy() *NodeFlag

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

+ func (m *NodeFlag) Marshal() (dAtA []byte, err error)

+ func (m *NodeFlag) MarshalTo(dAtA []byte) (int, error)

+ func (m *NodeFlag) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *NodeFlag) Reset()

+ func (m *NodeFlag) Size() (n int)

+ func (m *NodeFlag) Unmarshal(dAtA []byte) error

+ func (m *NodeFlag) XXX_DiscardUnknown()

+ func (m *NodeFlag) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *NodeFlag) XXX_Merge(src proto.Message)

+ func (m *NodeFlag) XXX_Size() int

+ func (m *NodeFlag) XXX_Unmarshal(b []byte) error

+ func (this *NodeFlag) String() string

type NodeStatus

+ NodeFlag *NodeFlag

Oct 13, 2023

Changes in this version

type ArtGCStatus

+ func (gcStatus *ArtGCStatus) AllArtifactGCPodsRecouped() bool

type ArtifactoryArtifactRepository

+ KeyFormat string

type Gauge

+ Operation GaugeOperation

+ type GaugeOperation string

+ const GaugeOperationAdd

+ const GaugeOperationSet

+ const GaugeOperationSub

type Mutex

+ Namespace string

type OSSBucket

+ UseSDKCreds bool

type PodGC

+ DeleteDelayDuration *metav1.Duration

type RetryStrategy

+ func (s RetryStrategy) RetryPolicyActual() RetryPolicy

type S3Bucket

+ CASecret *apiv1.SecretKeySelector

type SemaphoreRef

+ Namespace string

+ type WorkflowLevelArtifactGC struct

+ ForceFinalizerRemoval bool

+ PodSpecPatch string

+ func (*WorkflowLevelArtifactGC) Descriptor() ([]byte, []int)

+ func (*WorkflowLevelArtifactGC) ProtoMessage()

+ func (in *WorkflowLevelArtifactGC) DeepCopy() *WorkflowLevelArtifactGC

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

+ func (m *WorkflowLevelArtifactGC) Marshal() (dAtA []byte, err error)

+ func (m *WorkflowLevelArtifactGC) MarshalTo(dAtA []byte) (int, error)

+ func (m *WorkflowLevelArtifactGC) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *WorkflowLevelArtifactGC) Reset()

+ func (m *WorkflowLevelArtifactGC) Size() (n int)

+ func (m *WorkflowLevelArtifactGC) Unmarshal(dAtA []byte) error

+ func (m *WorkflowLevelArtifactGC) XXX_DiscardUnknown()

+ func (m *WorkflowLevelArtifactGC) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *WorkflowLevelArtifactGC) XXX_Merge(src proto.Message)

+ func (m *WorkflowLevelArtifactGC) XXX_Size() int

+ func (m *WorkflowLevelArtifactGC) XXX_Unmarshal(b []byte) error

+ func (this *WorkflowLevelArtifactGC) String() string

Sep 6, 2023

Changes in this version

type Nodes

+ func (n Nodes) Delete(key string)

+ func (n Nodes) Get(key string) (*NodeStatus, error)

+ func (n Nodes) GetName(key string) (string, error)

+ func (n Nodes) GetPhase(key string) (*NodePhase, error)

+ func (n Nodes) Has(key string) bool

+ func (n Nodes) Set(key string, status NodeStatus)

Apr 11, 2023

Changes in this version

+ type Column struct

+ Key string

+ Name string

+ Type string

+ func (*Column) Descriptor() ([]byte, []int)

+ func (*Column) ProtoMessage()

+ func (in *Column) DeepCopy() *Column

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

+ func (m *Column) Marshal() (dAtA []byte, err error)

+ func (m *Column) MarshalTo(dAtA []byte) (int, error)

+ func (m *Column) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *Column) Reset()

+ func (m *Column) Size() (n int)

+ func (m *Column) Unmarshal(dAtA []byte) error

+ func (m *Column) XXX_DiscardUnknown()

+ func (m *Column) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Column) XXX_Merge(src proto.Message)

+ func (m *Column) XXX_Size() int

+ func (m *Column) XXX_Unmarshal(b []byte) error

+ func (this *Column) String() string

Mar 30, 2023

Changes in this version

type Nodes

+ func (s Nodes) NestedChildrenStatus(parentNodeId string) ([]NodeStatus, error)

Sep 17, 2022

Changes in this version

+ const LogsSuffix

+ var AnyArtifactGCStrategy = map[ArtifactGCStrategy]bool

+ func NodeWithName(name string) func(n NodeStatus) bool

+ type ArtGCStatus struct

+ NotSpecified bool

+ PodsRecouped map[string]bool

+ StrategiesProcessed map[ArtifactGCStrategy]bool

+ func (*ArtGCStatus) Descriptor() ([]byte, []int)

+ func (*ArtGCStatus) ProtoMessage()

+ func (gcStatus *ArtGCStatus) IsArtifactGCPodRecouped(podName string) bool

+ func (gcStatus *ArtGCStatus) IsArtifactGCStrategyProcessed(strategy ArtifactGCStrategy) bool

+ func (gcStatus *ArtGCStatus) SetArtifactGCPodRecouped(podName string, recouped bool)

+ func (gcStatus *ArtGCStatus) SetArtifactGCStrategyProcessed(strategy ArtifactGCStrategy, processed bool)

+ func (in *ArtGCStatus) DeepCopy() *ArtGCStatus

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

+ func (m *ArtGCStatus) Marshal() (dAtA []byte, err error)

+ func (m *ArtGCStatus) MarshalTo(dAtA []byte) (int, error)

+ func (m *ArtGCStatus) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ArtGCStatus) Reset()

+ func (m *ArtGCStatus) Size() (n int)

+ func (m *ArtGCStatus) Unmarshal(dAtA []byte) error

+ func (m *ArtGCStatus) XXX_DiscardUnknown()

+ func (m *ArtGCStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ArtGCStatus) XXX_Merge(src proto.Message)

+ func (m *ArtGCStatus) XXX_Size() int

+ func (m *ArtGCStatus) XXX_Unmarshal(b []byte) error

+ func (this *ArtGCStatus) String() string

type Artifact

+ ArtifactGC *ArtifactGC

+ Deleted bool

+ func (a *Artifact) GetArtifactGC() *ArtifactGC

+ type ArtifactGC struct

+ PodMetadata *Metadata

+ ServiceAccountName string

+ Strategy ArtifactGCStrategy

+ func (*ArtifactGC) Descriptor() ([]byte, []int)

+ func (*ArtifactGC) ProtoMessage()

+ func (agc *ArtifactGC) GetStrategy() ArtifactGCStrategy

+ func (in *ArtifactGC) DeepCopy() *ArtifactGC

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

+ func (m *ArtifactGC) Marshal() (dAtA []byte, err error)

+ func (m *ArtifactGC) MarshalTo(dAtA []byte) (int, error)

+ func (m *ArtifactGC) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ArtifactGC) Reset()

+ func (m *ArtifactGC) Size() (n int)

+ func (m *ArtifactGC) Unmarshal(dAtA []byte) error

+ func (m *ArtifactGC) XXX_DiscardUnknown()

+ func (m *ArtifactGC) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ArtifactGC) XXX_Merge(src proto.Message)

+ func (m *ArtifactGC) XXX_Size() int

+ func (m *ArtifactGC) XXX_Unmarshal(b []byte) error

+ func (this *ArtifactGC) String() string

+ type ArtifactGCSpec struct

+ ArtifactsByNode map[string]ArtifactNodeSpec

+ func (*ArtifactGCSpec) Descriptor() ([]byte, []int)

+ func (*ArtifactGCSpec) ProtoMessage()

+ func (in *ArtifactGCSpec) DeepCopy() *ArtifactGCSpec

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

+ func (m *ArtifactGCSpec) Marshal() (dAtA []byte, err error)

+ func (m *ArtifactGCSpec) MarshalTo(dAtA []byte) (int, error)

+ func (m *ArtifactGCSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ArtifactGCSpec) Reset()

+ func (m *ArtifactGCSpec) Size() (n int)

+ func (m *ArtifactGCSpec) Unmarshal(dAtA []byte) error

+ func (m *ArtifactGCSpec) XXX_DiscardUnknown()

+ func (m *ArtifactGCSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ArtifactGCSpec) XXX_Merge(src proto.Message)

+ func (m *ArtifactGCSpec) XXX_Size() int

+ func (m *ArtifactGCSpec) XXX_Unmarshal(b []byte) error

+ func (this *ArtifactGCSpec) String() string

+ type ArtifactGCStatus struct

+ ArtifactResultsByNode map[string]ArtifactResultNodeStatus

+ func (*ArtifactGCStatus) Descriptor() ([]byte, []int)

+ func (*ArtifactGCStatus) ProtoMessage()

+ func (in *ArtifactGCStatus) DeepCopy() *ArtifactGCStatus

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

+ func (m *ArtifactGCStatus) Marshal() (dAtA []byte, err error)

+ func (m *ArtifactGCStatus) MarshalTo(dAtA []byte) (int, error)

+ func (m *ArtifactGCStatus) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ArtifactGCStatus) Reset()

+ func (m *ArtifactGCStatus) Size() (n int)

+ func (m *ArtifactGCStatus) Unmarshal(dAtA []byte) error

+ func (m *ArtifactGCStatus) XXX_DiscardUnknown()

+ func (m *ArtifactGCStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ArtifactGCStatus) XXX_Merge(src proto.Message)

+ func (m *ArtifactGCStatus) XXX_Size() int

+ func (m *ArtifactGCStatus) XXX_Unmarshal(b []byte) error

+ func (this *ArtifactGCStatus) String() string

+ type ArtifactGCStrategy string

+ const ArtifactGCNever

+ const ArtifactGCOnWorkflowCompletion

+ const ArtifactGCOnWorkflowDeletion

+ const ArtifactGCStrategyUndefined

type ArtifactLocation

+ Azure *AzureArtifact

+ type ArtifactNodeSpec struct

+ ArchiveLocation *ArtifactLocation

+ Artifacts map[string]Artifact

+ func (*ArtifactNodeSpec) Descriptor() ([]byte, []int)

+ func (*ArtifactNodeSpec) ProtoMessage()

+ func (in *ArtifactNodeSpec) DeepCopy() *ArtifactNodeSpec

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

+ func (m *ArtifactNodeSpec) Marshal() (dAtA []byte, err error)

+ func (m *ArtifactNodeSpec) MarshalTo(dAtA []byte) (int, error)

+ func (m *ArtifactNodeSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ArtifactNodeSpec) Reset()

+ func (m *ArtifactNodeSpec) Size() (n int)

+ func (m *ArtifactNodeSpec) Unmarshal(dAtA []byte) error

+ func (m *ArtifactNodeSpec) XXX_DiscardUnknown()

+ func (m *ArtifactNodeSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ArtifactNodeSpec) XXX_Merge(src proto.Message)

+ func (m *ArtifactNodeSpec) XXX_Size() int

+ func (m *ArtifactNodeSpec) XXX_Unmarshal(b []byte) error

+ func (this *ArtifactNodeSpec) String() string

type ArtifactRepository

+ Azure *AzureArtifactRepository

+ type ArtifactResult struct

+ Error *string

+ Name string

+ Success bool

+ func (*ArtifactResult) Descriptor() ([]byte, []int)

+ func (*ArtifactResult) ProtoMessage()

+ func (in *ArtifactResult) DeepCopy() *ArtifactResult

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

+ func (m *ArtifactResult) Marshal() (dAtA []byte, err error)

+ func (m *ArtifactResult) MarshalTo(dAtA []byte) (int, error)

+ func (m *ArtifactResult) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ArtifactResult) Reset()

+ func (m *ArtifactResult) Size() (n int)

+ func (m *ArtifactResult) Unmarshal(dAtA []byte) error

+ func (m *ArtifactResult) XXX_DiscardUnknown()

+ func (m *ArtifactResult) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ArtifactResult) XXX_Merge(src proto.Message)

+ func (m *ArtifactResult) XXX_Size() int

+ func (m *ArtifactResult) XXX_Unmarshal(b []byte) error

+ func (this *ArtifactResult) String() string

+ type ArtifactResultNodeStatus struct

+ ArtifactResults map[string]ArtifactResult

+ func (*ArtifactResultNodeStatus) Descriptor() ([]byte, []int)

+ func (*ArtifactResultNodeStatus) ProtoMessage()

+ func (in *ArtifactResultNodeStatus) DeepCopy() *ArtifactResultNodeStatus

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

+ func (m *ArtifactResultNodeStatus) Marshal() (dAtA []byte, err error)

+ func (m *ArtifactResultNodeStatus) MarshalTo(dAtA []byte) (int, error)

+ func (m *ArtifactResultNodeStatus) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ArtifactResultNodeStatus) Reset()

+ func (m *ArtifactResultNodeStatus) Size() (n int)

+ func (m *ArtifactResultNodeStatus) Unmarshal(dAtA []byte) error

+ func (m *ArtifactResultNodeStatus) XXX_DiscardUnknown()

+ func (m *ArtifactResultNodeStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ArtifactResultNodeStatus) XXX_Merge(src proto.Message)

+ func (m *ArtifactResultNodeStatus) XXX_Size() int

+ func (m *ArtifactResultNodeStatus) XXX_Unmarshal(b []byte) error

+ func (this *ArtifactResultNodeStatus) String() string

+ type ArtifactSearchQuery struct

+ ArtifactGCStrategies map[ArtifactGCStrategy]bool

+ ArtifactName string

+ Deleted *bool

+ NodeId string

+ NodeTypes map[NodeType]bool

+ TemplateName string

+ func NewArtifactSearchQuery() *ArtifactSearchQuery

+ func (*ArtifactSearchQuery) Descriptor() ([]byte, []int)

+ func (*ArtifactSearchQuery) ProtoMessage()

+ func (in *ArtifactSearchQuery) DeepCopy() *ArtifactSearchQuery

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

+ func (m *ArtifactSearchQuery) Marshal() (dAtA []byte, err error)

+ func (m *ArtifactSearchQuery) MarshalTo(dAtA []byte) (int, error)

+ func (m *ArtifactSearchQuery) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ArtifactSearchQuery) Reset()

+ func (m *ArtifactSearchQuery) Size() (n int)

+ func (m *ArtifactSearchQuery) Unmarshal(dAtA []byte) error

+ func (m *ArtifactSearchQuery) XXX_DiscardUnknown()

+ func (m *ArtifactSearchQuery) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ArtifactSearchQuery) XXX_Merge(src proto.Message)

+ func (m *ArtifactSearchQuery) XXX_Size() int

+ func (m *ArtifactSearchQuery) XXX_Unmarshal(b []byte) error

+ func (this *ArtifactSearchQuery) String() string

+ type ArtifactSearchResult struct

+ NodeID string

+ func (*ArtifactSearchResult) Descriptor() ([]byte, []int)

+ func (*ArtifactSearchResult) ProtoMessage()

+ func (in *ArtifactSearchResult) DeepCopy() *ArtifactSearchResult

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

+ func (m *ArtifactSearchResult) Marshal() (dAtA []byte, err error)

+ func (m *ArtifactSearchResult) MarshalTo(dAtA []byte) (int, error)

+ func (m *ArtifactSearchResult) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ArtifactSearchResult) Reset()

+ func (m *ArtifactSearchResult) Size() (n int)

+ func (m *ArtifactSearchResult) Unmarshal(dAtA []byte) error

+ func (m *ArtifactSearchResult) XXX_DiscardUnknown()

+ func (m *ArtifactSearchResult) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ArtifactSearchResult) XXX_Merge(src proto.Message)

+ func (m *ArtifactSearchResult) XXX_Size() int

+ func (m *ArtifactSearchResult) XXX_Unmarshal(b []byte) error

+ func (this *ArtifactSearchResult) String() string

+ type ArtifactSearchResults []ArtifactSearchResult

+ func (asr ArtifactSearchResults) GetArtifacts() []Artifact

+ func (in ArtifactSearchResults) DeepCopy() ArtifactSearchResults

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

+ type AzureArtifact struct

+ Blob string

+ func (*AzureArtifact) Descriptor() ([]byte, []int)

+ func (*AzureArtifact) ProtoMessage()

+ func (a *AzureArtifact) GetKey() (string, error)

+ func (a *AzureArtifact) HasLocation() bool

+ func (a *AzureArtifact) SetKey(key string) error

+ func (in *AzureArtifact) DeepCopy() *AzureArtifact

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

+ func (m *AzureArtifact) Marshal() (dAtA []byte, err error)

+ func (m *AzureArtifact) MarshalTo(dAtA []byte) (int, error)

+ func (m *AzureArtifact) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *AzureArtifact) Reset()

+ func (m *AzureArtifact) Size() (n int)

+ func (m *AzureArtifact) Unmarshal(dAtA []byte) error

+ func (m *AzureArtifact) XXX_DiscardUnknown()

+ func (m *AzureArtifact) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *AzureArtifact) XXX_Merge(src proto.Message)

+ func (m *AzureArtifact) XXX_Size() int

+ func (m *AzureArtifact) XXX_Unmarshal(b []byte) error

+ func (this *AzureArtifact) String() string

+ type AzureArtifactRepository struct

+ BlobNameFormat string

+ func (*AzureArtifactRepository) Descriptor() ([]byte, []int)

+ func (*AzureArtifactRepository) ProtoMessage()

+ func (in *AzureArtifactRepository) DeepCopy() *AzureArtifactRepository

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

+ func (m *AzureArtifactRepository) Marshal() (dAtA []byte, err error)

+ func (m *AzureArtifactRepository) MarshalTo(dAtA []byte) (int, error)

+ func (m *AzureArtifactRepository) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *AzureArtifactRepository) Reset()

+ func (m *AzureArtifactRepository) Size() (n int)

+ func (m *AzureArtifactRepository) Unmarshal(dAtA []byte) error

+ func (m *AzureArtifactRepository) XXX_DiscardUnknown()

+ func (m *AzureArtifactRepository) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *AzureArtifactRepository) XXX_Merge(src proto.Message)

+ func (m *AzureArtifactRepository) XXX_Size() int

+ func (m *AzureArtifactRepository) XXX_Unmarshal(b []byte) error

+ func (r *AzureArtifactRepository) IntoArtifactLocation(l *ArtifactLocation)

+ func (this *AzureArtifactRepository) String() string

+ type AzureBlobContainer struct

+ AccountKeySecret *apiv1.SecretKeySelector

+ Container string

+ Endpoint string

+ UseSDKCreds bool

+ func (*AzureBlobContainer) Descriptor() ([]byte, []int)

+ func (*AzureBlobContainer) ProtoMessage()

+ func (in *AzureBlobContainer) DeepCopy() *AzureBlobContainer

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

+ func (m *AzureBlobContainer) Marshal() (dAtA []byte, err error)

+ func (m *AzureBlobContainer) MarshalTo(dAtA []byte) (int, error)

+ func (m *AzureBlobContainer) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *AzureBlobContainer) Reset()

+ func (m *AzureBlobContainer) Size() (n int)

+ func (m *AzureBlobContainer) Unmarshal(dAtA []byte) error

+ func (m *AzureBlobContainer) XXX_DiscardUnknown()

+ func (m *AzureBlobContainer) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *AzureBlobContainer) XXX_Merge(src proto.Message)

+ func (m *AzureBlobContainer) XXX_Size() int

+ func (m *AzureBlobContainer) XXX_Unmarshal(b []byte) error

+ func (this *AzureBlobContainer) String() string

+ type BasicAuth struct

+ PasswordSecret *apiv1.SecretKeySelector

+ UsernameSecret *apiv1.SecretKeySelector

+ func (*BasicAuth) Descriptor() ([]byte, []int)

+ func (*BasicAuth) ProtoMessage()

+ func (in *BasicAuth) DeepCopy() *BasicAuth

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

+ func (m *BasicAuth) Marshal() (dAtA []byte, err error)

+ func (m *BasicAuth) MarshalTo(dAtA []byte) (int, error)

+ func (m *BasicAuth) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *BasicAuth) Reset()

+ func (m *BasicAuth) Size() (n int)

+ func (m *BasicAuth) Unmarshal(dAtA []byte) error

+ func (m *BasicAuth) XXX_DiscardUnknown()

+ func (m *BasicAuth) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *BasicAuth) XXX_Merge(src proto.Message)

+ func (m *BasicAuth) XXX_Size() int

+ func (m *BasicAuth) XXX_Unmarshal(b []byte) error

+ func (this *BasicAuth) String() string

+ type ClientCertAuth struct

+ ClientCertSecret *apiv1.SecretKeySelector

+ ClientKeySecret *apiv1.SecretKeySelector

+ func (*ClientCertAuth) Descriptor() ([]byte, []int)

+ func (*ClientCertAuth) ProtoMessage()

+ func (in *ClientCertAuth) DeepCopy() *ClientCertAuth

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

+ func (m *ClientCertAuth) Marshal() (dAtA []byte, err error)

+ func (m *ClientCertAuth) MarshalTo(dAtA []byte) (int, error)

+ func (m *ClientCertAuth) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ClientCertAuth) Reset()

+ func (m *ClientCertAuth) Size() (n int)

+ func (m *ClientCertAuth) Unmarshal(dAtA []byte) error

+ func (m *ClientCertAuth) XXX_DiscardUnknown()

+ func (m *ClientCertAuth) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ClientCertAuth) XXX_Merge(src proto.Message)

+ func (m *ClientCertAuth) XXX_Size() int

+ func (m *ClientCertAuth) XXX_Unmarshal(b []byte) error

+ func (this *ClientCertAuth) String() string

type ConditionType

+ const ConditionTypeArtifactGCError

type DAGTask

+ func (t *DAGTask) GetName() string

+ func (t *DAGTask) IsDAGTask() bool

+ func (t *DAGTask) IsWorkflowStep() bool

type GitArtifact

+ Branch string

+ SingleBranch bool

type HTTP

+ BodyFrom *HTTPBodySource

+ func (h *HTTP) GetBodyBytes() []byte

type HTTPArtifact

+ Auth *HTTPAuth

+ type HTTPAuth struct

+ BasicAuth BasicAuth

+ ClientCert ClientCertAuth

+ OAuth2 OAuth2Auth

+ func (*HTTPAuth) Descriptor() ([]byte, []int)

+ func (*HTTPAuth) ProtoMessage()

+ func (in *HTTPAuth) DeepCopy() *HTTPAuth

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

+ func (m *HTTPAuth) Marshal() (dAtA []byte, err error)

+ func (m *HTTPAuth) MarshalTo(dAtA []byte) (int, error)

+ func (m *HTTPAuth) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *HTTPAuth) Reset()

+ func (m *HTTPAuth) Size() (n int)

+ func (m *HTTPAuth) Unmarshal(dAtA []byte) error

+ func (m *HTTPAuth) XXX_DiscardUnknown()

+ func (m *HTTPAuth) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *HTTPAuth) XXX_Merge(src proto.Message)

+ func (m *HTTPAuth) XXX_Size() int

+ func (m *HTTPAuth) XXX_Unmarshal(b []byte) error

+ func (this *HTTPAuth) String() string

+ type HTTPBodySource struct

+ Bytes []byte

+ func (*HTTPBodySource) Descriptor() ([]byte, []int)

+ func (*HTTPBodySource) ProtoMessage()

+ func (in *HTTPBodySource) DeepCopy() *HTTPBodySource

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

+ func (m *HTTPBodySource) Marshal() (dAtA []byte, err error)

+ func (m *HTTPBodySource) MarshalTo(dAtA []byte) (int, error)

+ func (m *HTTPBodySource) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *HTTPBodySource) Reset()

+ func (m *HTTPBodySource) Size() (n int)

+ func (m *HTTPBodySource) Unmarshal(dAtA []byte) error

+ func (m *HTTPBodySource) XXX_DiscardUnknown()

+ func (m *HTTPBodySource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *HTTPBodySource) XXX_Merge(src proto.Message)

+ func (m *HTTPBodySource) XXX_Size() int

+ func (m *HTTPBodySource) XXX_Unmarshal(b []byte) error

+ func (this *HTTPBodySource) String() string

+ type ManifestFrom struct

+ Artifact *Artifact

+ func (*ManifestFrom) Descriptor() ([]byte, []int)

+ func (*ManifestFrom) ProtoMessage()

+ func (in *ManifestFrom) DeepCopy() *ManifestFrom

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

+ func (m *ManifestFrom) Marshal() (dAtA []byte, err error)

+ func (m *ManifestFrom) MarshalTo(dAtA []byte) (int, error)

+ func (m *ManifestFrom) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ManifestFrom) Reset()

+ func (m *ManifestFrom) Size() (n int)

+ func (m *ManifestFrom) Unmarshal(dAtA []byte) error

+ func (m *ManifestFrom) XXX_DiscardUnknown()

+ func (m *ManifestFrom) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ManifestFrom) XXX_Merge(src proto.Message)

+ func (m *ManifestFrom) XXX_Size() int

+ func (m *ManifestFrom) XXX_Unmarshal(b []byte) error

+ func (this *ManifestFrom) String() string

type NodeStatus

+ func (n *NodeStatus) GetName() string

+ func (n *NodeStatus) GetOutputs() *Outputs

+ func (n *NodeStatus) IsDAGTask() bool

+ func (n *NodeStatus) IsWorkflowStep() bool

type Nodes

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

+ type OAuth2Auth struct

+ ClientIDSecret *apiv1.SecretKeySelector

+ ClientSecretSecret *apiv1.SecretKeySelector

+ EndpointParams []OAuth2EndpointParam

+ Scopes []string

+ TokenURLSecret *apiv1.SecretKeySelector

+ func (*OAuth2Auth) Descriptor() ([]byte, []int)

+ func (*OAuth2Auth) ProtoMessage()

+ func (in *OAuth2Auth) DeepCopy() *OAuth2Auth

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

+ func (m *OAuth2Auth) Marshal() (dAtA []byte, err error)

+ func (m *OAuth2Auth) MarshalTo(dAtA []byte) (int, error)

+ func (m *OAuth2Auth) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *OAuth2Auth) Reset()

+ func (m *OAuth2Auth) Size() (n int)

+ func (m *OAuth2Auth) Unmarshal(dAtA []byte) error

+ func (m *OAuth2Auth) XXX_DiscardUnknown()

+ func (m *OAuth2Auth) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *OAuth2Auth) XXX_Merge(src proto.Message)

+ func (m *OAuth2Auth) XXX_Size() int

+ func (m *OAuth2Auth) XXX_Unmarshal(b []byte) error

+ func (this *OAuth2Auth) String() string

+ type OAuth2EndpointParam struct

+ Key string

+ Value string

+ func (*OAuth2EndpointParam) Descriptor() ([]byte, []int)

+ func (*OAuth2EndpointParam) ProtoMessage()

+ func (in *OAuth2EndpointParam) DeepCopy() *OAuth2EndpointParam

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

+ func (m *OAuth2EndpointParam) Marshal() (dAtA []byte, err error)

+ func (m *OAuth2EndpointParam) MarshalTo(dAtA []byte) (int, error)

+ func (m *OAuth2EndpointParam) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *OAuth2EndpointParam) Reset()

+ func (m *OAuth2EndpointParam) Size() (n int)

+ func (m *OAuth2EndpointParam) Unmarshal(dAtA []byte) error

+ func (m *OAuth2EndpointParam) XXX_DiscardUnknown()

+ func (m *OAuth2EndpointParam) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *OAuth2EndpointParam) XXX_Merge(src proto.Message)

+ func (m *OAuth2EndpointParam) XXX_Size() int

+ func (m *OAuth2EndpointParam) XXX_Unmarshal(b []byte) error

+ func (this *OAuth2EndpointParam) String() string

type Outputs

+ func (o *Outputs) GetArtifacts() Artifacts

type ResourceTemplate

+ ManifestFrom *ManifestFrom

type Template

+ func (tmpl *Template) GetOutputs() *Outputs

type TemplateReferenceHolder

+ GetName func() string

+ IsDAGTask func() bool

+ IsWorkflowStep func() bool

type Workflow

+ func (w *Workflow) GetArtifactGCStrategy(a *Artifact) ArtifactGCStrategy

+ func (w *Workflow) GetTemplates() []Template

+ func (w *Workflow) HasArtifactGC() bool

+ func (w *Workflow) SearchArtifacts(q *ArtifactSearchQuery) ArtifactSearchResults

+ type WorkflowArtifactGCTask struct

+ Spec ArtifactGCSpec

+ Status ArtifactGCStatus

+ func MustUnmarshalWorkflowArtifactGCTask(text interface{}) *WorkflowArtifactGCTask

+ func (*WorkflowArtifactGCTask) Descriptor() ([]byte, []int)

+ func (*WorkflowArtifactGCTask) ProtoMessage()

+ func (in *WorkflowArtifactGCTask) DeepCopy() *WorkflowArtifactGCTask

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

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

+ func (m *WorkflowArtifactGCTask) Marshal() (dAtA []byte, err error)

+ func (m *WorkflowArtifactGCTask) MarshalTo(dAtA []byte) (int, error)

+ func (m *WorkflowArtifactGCTask) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *WorkflowArtifactGCTask) Reset()

+ func (m *WorkflowArtifactGCTask) Size() (n int)

+ func (m *WorkflowArtifactGCTask) Unmarshal(dAtA []byte) error

+ func (m *WorkflowArtifactGCTask) XXX_DiscardUnknown()

+ func (m *WorkflowArtifactGCTask) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *WorkflowArtifactGCTask) XXX_Merge(src proto.Message)

+ func (m *WorkflowArtifactGCTask) XXX_Size() int

+ func (m *WorkflowArtifactGCTask) XXX_Unmarshal(b []byte) error

+ func (this *WorkflowArtifactGCTask) String() string

+ type WorkflowArtifactGCTaskList struct

+ Items []WorkflowArtifactGCTask

+ func (*WorkflowArtifactGCTaskList) Descriptor() ([]byte, []int)

+ func (*WorkflowArtifactGCTaskList) ProtoMessage()

+ func (in *WorkflowArtifactGCTaskList) DeepCopy() *WorkflowArtifactGCTaskList

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

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

+ func (m *WorkflowArtifactGCTaskList) Marshal() (dAtA []byte, err error)

+ func (m *WorkflowArtifactGCTaskList) MarshalTo(dAtA []byte) (int, error)

+ func (m *WorkflowArtifactGCTaskList) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *WorkflowArtifactGCTaskList) Reset()

+ func (m *WorkflowArtifactGCTaskList) Size() (n int)

+ func (m *WorkflowArtifactGCTaskList) Unmarshal(dAtA []byte) error

+ func (m *WorkflowArtifactGCTaskList) XXX_DiscardUnknown()

+ func (m *WorkflowArtifactGCTaskList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *WorkflowArtifactGCTaskList) XXX_Merge(src proto.Message)

+ func (m *WorkflowArtifactGCTaskList) XXX_Size() int

+ func (m *WorkflowArtifactGCTaskList) XXX_Unmarshal(b []byte) error

+ func (this *WorkflowArtifactGCTaskList) String() string

type WorkflowSpec

+ ArtifactGC *ArtifactGC

+ func (wfs WorkflowSpec) GetArtifactGC() *ArtifactGC

type WorkflowStatus

+ ArtifactGCStatus *ArtGCStatus

+ func (ws *WorkflowStatus) GetStoredTemplates() []Template

type WorkflowStep

+ func (step *WorkflowStep) GetName() string

+ func (step *WorkflowStep) IsDAGTask() bool

+ func (step *WorkflowStep) IsWorkflowStep() bool

Mar 18, 2022

Changes in this version

type NodeStatus

+ func (ws NodeStatus) IsExitNode() bool

Mar 14, 2022

Changes in this version

+ const MainLogsArtifactName

+ const ProgressDefault

+ const ProgressUndefined

+ const ProgressZero

+ func ParseStringToDuration(durationString string) (time.Duration, error)

type Artifact

+ func (a *Artifact) CleanPath() error

+ type ContainerSetRetryStrategy struct

+ Duration string

+ Retries *intstr.IntOrString

+ func (*ContainerSetRetryStrategy) Descriptor() ([]byte, []int)

+ func (*ContainerSetRetryStrategy) ProtoMessage()

+ func (in *ContainerSetRetryStrategy) DeepCopy() *ContainerSetRetryStrategy

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

+ func (m *ContainerSetRetryStrategy) Marshal() (dAtA []byte, err error)

+ func (m *ContainerSetRetryStrategy) MarshalTo(dAtA []byte) (int, error)

+ func (m *ContainerSetRetryStrategy) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ContainerSetRetryStrategy) Reset()

+ func (m *ContainerSetRetryStrategy) Size() (n int)

+ func (m *ContainerSetRetryStrategy) Unmarshal(dAtA []byte) error

+ func (m *ContainerSetRetryStrategy) XXX_DiscardUnknown()

+ func (m *ContainerSetRetryStrategy) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ContainerSetRetryStrategy) XXX_Merge(src proto.Message)

+ func (m *ContainerSetRetryStrategy) XXX_Size() int

+ func (m *ContainerSetRetryStrategy) XXX_Unmarshal(b []byte) error

+ func (this *ContainerSetRetryStrategy) String() string

type ContainerSetTemplate

+ RetryStrategy *ContainerSetRetryStrategy

+ func (t *ContainerSetTemplate) GetRetryStrategy() (wait.Backoff, error)

type HTTP

+ InsecureSkipVerify bool

+ SuccessCondition string

+ type HTTPHeaders []HTTPHeader

+ func (h HTTPHeaders) ToHeader() http.Header

+ func (in HTTPHeaders) DeepCopy() HTTPHeaders

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

+ 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 LabelValueFrom struct

+ Expression string

+ func (*LabelValueFrom) Descriptor() ([]byte, []int)

+ func (*LabelValueFrom) ProtoMessage()

+ func (in *LabelValueFrom) DeepCopy() *LabelValueFrom

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

+ func (m *LabelValueFrom) Marshal() (dAtA []byte, err error)

+ func (m *LabelValueFrom) MarshalTo(dAtA []byte) (int, error)

+ func (m *LabelValueFrom) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *LabelValueFrom) Reset()

+ func (m *LabelValueFrom) Size() (n int)

+ func (m *LabelValueFrom) Unmarshal(dAtA []byte) error

+ func (m *LabelValueFrom) XXX_DiscardUnknown()

+ func (m *LabelValueFrom) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *LabelValueFrom) XXX_Merge(src proto.Message)

+ func (m *LabelValueFrom) XXX_Size() int

+ func (m *LabelValueFrom) XXX_Unmarshal(b []byte) error

+ func (this *LabelValueFrom) 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 LifecycleHook

+ Expression string

+ TemplateRef *TemplateRef

type LifecycleHooks

+ func (lchs LifecycleHooks) HasExitHook() bool

type NodeResult

+ Progress Progress

type NodeType

+ const NodeTypePlugin

+ type Object struct

+ Value json.RawMessage

+ func (*Object) Descriptor() ([]byte, []int)

+ func (*Object) ProtoMessage()

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

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

+ func (i Object) OpenAPISchemaFormat() string

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

+ func (in *Object) DeepCopy() *Object

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

+ func (m *Object) Marshal() (dAtA []byte, err error)

+ func (m *Object) MarshalTo(dAtA []byte) (int, error)

+ func (m *Object) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *Object) Reset()

+ func (m *Object) Size() (n int)

+ func (m *Object) Unmarshal(dAtA []byte) error

+ func (m *Object) XXX_DiscardUnknown()

+ func (m *Object) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Object) XXX_Merge(src proto.Message)

+ func (m *Object) XXX_Size() int

+ func (m *Object) XXX_Unmarshal(b []byte) error

+ func (this *Object) String() string

type Outputs

+ func (out *Outputs) HasArtifacts() bool

+ func (out *Outputs) HasLogs() bool

+ func (out *Outputs) HasParameters() bool

+ func (out *Outputs) HasResult() bool

type Parameter

+ Description *AnyString

+ type Plugin struct

+ func (*Plugin) Descriptor() ([]byte, []int)

+ func (*Plugin) ProtoMessage()

+ func (in *Plugin) DeepCopy() *Plugin

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

+ func (m *Plugin) Marshal() (dAtA []byte, err error)

+ func (m *Plugin) MarshalTo(dAtA []byte) (int, error)

+ func (m *Plugin) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *Plugin) Reset()

+ func (m *Plugin) Size() (n int)

+ func (m *Plugin) Unmarshal(dAtA []byte) error

+ func (m *Plugin) XXX_DiscardUnknown()

+ func (m *Plugin) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Plugin) XXX_Merge(src proto.Message)

+ func (m *Plugin) XXX_Size() int

+ func (m *Plugin) XXX_Unmarshal(b []byte) error

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

+ func (this *Plugin) String() string

type Progress

+ func (in Progress) Complete() Progress

type SubmitOpts

+ PodPriorityClassName string

+ Priority *int32

type Template

+ Plugin *Plugin

+ func (t *Template) GetRetryStrategy() (wait.Backoff, error)

+ func (t *Template) HasOutputs() bool

+ func (t *Template) IsDaemon() bool

+ func (tmpl *Template) GetNodeType() NodeType

type TemplateType

+ const TemplateTypePlugin

type Workflow

+ func (w *Workflow) GetExecSpec() *WorkflowSpec

+ type WorkflowMetadata struct

+ Annotations map[string]string

+ Labels map[string]string

+ LabelsFrom map[string]LabelValueFrom

+ func (*WorkflowMetadata) Descriptor() ([]byte, []int)

+ func (*WorkflowMetadata) ProtoMessage()

+ func (in *WorkflowMetadata) AsObjectMeta() *metav1.ObjectMeta

+ func (in *WorkflowMetadata) DeepCopy() *WorkflowMetadata

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

+ func (m *WorkflowMetadata) Marshal() (dAtA []byte, err error)

+ func (m *WorkflowMetadata) MarshalTo(dAtA []byte) (int, error)

+ func (m *WorkflowMetadata) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *WorkflowMetadata) Reset()

+ func (m *WorkflowMetadata) Size() (n int)

+ func (m *WorkflowMetadata) Unmarshal(dAtA []byte) error

+ func (m *WorkflowMetadata) XXX_DiscardUnknown()

+ func (m *WorkflowMetadata) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *WorkflowMetadata) XXX_Merge(src proto.Message)

+ func (m *WorkflowMetadata) XXX_Size() int

+ func (m *WorkflowMetadata) XXX_Unmarshal(b []byte) error

+ func (this *WorkflowMetadata) String() string

type WorkflowSpec

+ Hooks LifecycleHooks

+ WorkflowMetadata *WorkflowMetadata

+ func (wfs *WorkflowSpec) GetExitHook(args Arguments) *LifecycleHook

+ func (wfs *WorkflowSpec) HasExitHook() bool

+ type WorkflowTaskResult struct

+ func (*WorkflowTaskResult) Descriptor() ([]byte, []int)

+ func (*WorkflowTaskResult) ProtoMessage()

+ func (in *WorkflowTaskResult) DeepCopy() *WorkflowTaskResult

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

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

+ func (m *WorkflowTaskResult) Marshal() (dAtA []byte, err error)

+ func (m *WorkflowTaskResult) MarshalTo(dAtA []byte) (int, error)

+ func (m *WorkflowTaskResult) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *WorkflowTaskResult) Reset()

+ func (m *WorkflowTaskResult) Size() (n int)

+ func (m *WorkflowTaskResult) Unmarshal(dAtA []byte) error

+ func (m *WorkflowTaskResult) XXX_DiscardUnknown()

+ func (m *WorkflowTaskResult) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *WorkflowTaskResult) XXX_Merge(src proto.Message)

+ func (m *WorkflowTaskResult) XXX_Size() int

+ func (m *WorkflowTaskResult) XXX_Unmarshal(b []byte) error

+ func (this *WorkflowTaskResult) String() string

+ type WorkflowTaskResultList struct

+ Items []WorkflowTaskResult

+ func (*WorkflowTaskResultList) Descriptor() ([]byte, []int)

+ func (*WorkflowTaskResultList) ProtoMessage()

+ func (in *WorkflowTaskResultList) DeepCopy() *WorkflowTaskResultList

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

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

+ func (m *WorkflowTaskResultList) Marshal() (dAtA []byte, err error)

+ func (m *WorkflowTaskResultList) MarshalTo(dAtA []byte) (int, error)

+ func (m *WorkflowTaskResultList) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *WorkflowTaskResultList) Reset()

+ func (m *WorkflowTaskResultList) Size() (n int)

+ func (m *WorkflowTaskResultList) Unmarshal(dAtA []byte) error

+ func (m *WorkflowTaskResultList) XXX_DiscardUnknown()

+ func (m *WorkflowTaskResultList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *WorkflowTaskResultList) XXX_Merge(src proto.Message)

+ func (m *WorkflowTaskResultList) XXX_Size() int

+ func (m *WorkflowTaskResultList) XXX_Unmarshal(b []byte) error

+ func (this *WorkflowTaskResultList) String() string

Dec 15, 2021

Changes in this version

type CronWorkflow

+ func (c *CronWorkflow) GetLatestSchedule() string

+ func (c *CronWorkflow) IsUsingNewSchedule() bool

+ func (c *CronWorkflow) SetSchedule(schedule string)

type CronWorkflowSpec

+ func (c *CronWorkflowSpec) GetScheduleString() string

type PodGC

+ func (podGC *PodGC) GetStrategy() PodGCStrategy

type PodGCStrategy

+ const PodGCOnPodNone

+ func (s PodGCStrategy) IsValid() bool

Oct 6, 2021

Changes in this version

type DAGTask

+ Inline *Template

+ func (t *DAGTask) GetTemplate() *Template

+ 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 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 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

+ func (n *NodeStatus) GetTemplate() *Template

type NodeType

+ const NodeTypeHTTP

type Nodes

+ func (n Nodes) HasHTTPNodes() bool

type RetryStrategy

+ Expression string

type S3Bucket

+ EncryptionOptions *S3EncryptionOptions

+ 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 Template

+ HTTP *HTTP

type TemplateReferenceHolder

+ GetTemplate func() *Template

type TemplateType

+ const TemplateTypeHTTP

type ValueFrom

+ ConfigMapKeyRef *apiv1.ConfigMapKeySelector

type WorkflowSpec

+ ArchiveLogs *bool

type WorkflowStep

+ Inline *Template

+ func (step *WorkflowStep) GetTemplate() *Template

+ 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

Jul 15, 2021

Changes in this version

+ var DefaultArchivePattern = "{{workflow.name}}/{{pod.name}}"

+ 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 ArtifactRepositoryRefStatus

+ ArtifactRepository *ArtifactRepository

+ type ArtifactRepositoryType interface

+ IntoArtifactLocation func(l *ArtifactLocation)

+ 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 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 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 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 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

Jun 21, 2021

Changes in this version

+ const ExitLifecycleEvent

+ func MustMarshallJSON(v interface{}) string

+ func MustUnmarshal(text, v interface{})

type Artifact

+ FromExpression string

+ 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 ClusterWorkflowTemplate

+ func MustUnmarshalClusterWorkflow(text interface{}) *ClusterWorkflowTemplate

+ 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 CronWorkflow

+ func MustUnmarshalCronWorkflow(text interface{}) *CronWorkflow

type DAGTask

+ Hooks LifecycleHooks

+ func (t *DAGTask) GetExitHook(args Arguments) *LifecycleHook

+ func (t *DAGTask) HasExitHook() bool

+ 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 GitArtifact

+ DisableSubmodules bool

+ 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 NodeType

+ const NodeTypeContainer

type OSSBucket

+ LifecycleRule *OSSLifecycleRule

+ SecurityToken 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 Template

+ ContainerSet *ContainerSetTemplate

+ Data *Data

+ FailFast *bool

+ func MustUnmarshalTemplate(text interface{}) *Template

+ func (tmpl *Template) GetSidecarNames() []string

+ func (tmpl *Template) GetVolumeMounts() []apiv1.VolumeMount

+ func (tmpl *Template) HasOutput() bool

+ func (tmpl *Template) HasParallelism() bool

+ func (tmpl *Template) HasSequencedContainers() bool

+ func (tmpl *Template) IsFailFast() bool

+ func (tmpl *Template) SaveLogsAsArtifact() bool

+ func (tmpl *Template) SetType(tmplType TemplateType)

type TemplateType

+ const TemplateTypeContainerSet

+ const TemplateTypeData

+ 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 ValueFrom

+ Expression string

type Workflow

+ func MustUnmarshalWorkflow(text interface{}) *Workflow

type WorkflowSpec

+ TemplateDefaults *Template

type WorkflowStep

+ Hooks LifecycleHooks

+ func (step *WorkflowStep) GetExitHook(args Arguments) *LifecycleHook

+ func (step *WorkflowStep) HasExitHook() bool

type WorkflowTemplate

+ func MustUnmarshalWorkflowTemplate(text interface{}) *WorkflowTemplate

May 24, 2021

Changes in this version

type Parameter

+ func (p *Parameter) GetValue() string

+ func (p *Parameter) HasValue() bool

Apr 20, 2021

Changes in this version

+ type NodeReason string

+ const WaitingForSyncLock

type NodeStatus

+ func (ns NodeStatus) GetReason() NodeReason

Mar 30, 2021

Changes in this version

+ var AddToScheme = SchemeBuilder.AddToScheme

+ var DefaultArtifactRepositoryRefStatus = &ArtifactRepositoryRefStatus

+ 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 GetOpenAPIDefinitions(ref common.ReferenceCallback) map[string]common.OpenAPIDefinition

+ func Kind(kind string) schema.GroupKind

+ 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

+ 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 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

+ 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 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 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 (*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 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 (*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

+ Name string

+ OnExit string

+ Template string

+ TemplateRef *TemplateRef

+ When string

+ WithItems []Item

+ WithParam string

+ WithSequence *Sequence

+ func (*DAGTask) Descriptor() ([]byte, []int)

+ func (*DAGTask) ProtoMessage()

+ func (in *DAGTask) DeepCopy() *DAGTask

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

+ func (m *DAGTask) Marshal() (dAtA []byte, err error)

+ func (m *DAGTask) MarshalTo(dAtA []byte) (int, error)

+ func (m *DAGTask) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *DAGTask) Reset()

+ func (m *DAGTask) Size() (n int)

+ func (m *DAGTask) Unmarshal(dAtA []byte) error

+ func (m *DAGTask) XXX_DiscardUnknown()

+ func (m *DAGTask) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *DAGTask) XXX_Merge(src proto.Message)

+ func (m *DAGTask) XXX_Size() int

+ func (m *DAGTask) XXX_Unmarshal(b []byte) error

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

+ func (t *DAGTask) GetTemplateName() string

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

+ func (t *DAGTask) 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 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 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

+ 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 HDFSConfig struct

+ Addresses []string

+ HDFSUser string

+ func (*HDFSConfig) Descriptor() ([]byte, []int)

+ func (*HDFSConfig) ProtoMessage()

+ func (in *HDFSConfig) DeepCopy() *HDFSConfig

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

+ func (m *HDFSConfig) Marshal() (dAtA []byte, err error)

+ func (m *HDFSConfig) MarshalTo(dAtA []byte) (int, error)

+ func (m *HDFSConfig) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *HDFSConfig) Reset()

+ func (m *HDFSConfig) Size() (n int)

+ func (m *HDFSConfig) Unmarshal(dAtA []byte) error

+ func (m *HDFSConfig) XXX_DiscardUnknown()

+ func (m *HDFSConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *HDFSConfig) XXX_Merge(src proto.Message)

+ func (m *HDFSConfig) XXX_Size() int

+ func (m *HDFSConfig) XXX_Unmarshal(b []byte) error

+ func (this *HDFSConfig) String() string

+ type HDFSKrbConfig struct

+ KrbCCacheSecret *apiv1.SecretKeySelector

+ KrbConfigConfigMap *apiv1.ConfigMapKeySelector

+ KrbKeytabSecret *apiv1.SecretKeySelector

+ KrbRealm string

+ KrbServicePrincipalName string

+ KrbUsername string

+ func (*HDFSKrbConfig) Descriptor() ([]byte, []int)

+ func (*HDFSKrbConfig) ProtoMessage()

+ func (in *HDFSKrbConfig) DeepCopy() *HDFSKrbConfig

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

+ func (m *HDFSKrbConfig) Marshal() (dAtA []byte, err error)

+ func (m *HDFSKrbConfig) MarshalTo(dAtA []byte) (int, error)

+ func (m *HDFSKrbConfig) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *HDFSKrbConfig) Reset()

+ func (m *HDFSKrbConfig) Size() (n int)

+ func (m *HDFSKrbConfig) Unmarshal(dAtA []byte) error

+ func (m *HDFSKrbConfig) XXX_DiscardUnknown()

+ func (m *HDFSKrbConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *HDFSKrbConfig) XXX_Merge(src proto.Message)

+ func (m *HDFSKrbConfig) XXX_Size() int

+ func (m *HDFSKrbConfig) XXX_Unmarshal(b []byte) error

+ func (this *HDFSKrbConfig) String() string

+ type HTTPArtifact struct

+ 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 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 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 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) 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 NodeTypeDAG

+ const NodeTypePod

+ const NodeTypeRetry

+ const NodeTypeSkipped

+ const NodeTypeStepGroup

+ const NodeTypeSteps

+ const NodeTypeSuspend

+ const NodeTypeTaskGroup

+ type Nodes map[string]NodeStatus

+ func (in Nodes) Any(f func(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 (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 OSSBucket struct

+ AccessKeySecret *apiv1.SecretKeySelector

+ Bucket string

+ CreateBucketIfNotPresent bool

+ Endpoint string

+ SecretKeySecret *apiv1.SecretKeySelector

+ 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 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 (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

+ 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 S3Bucket struct

+ AccessKeySecret *apiv1.SecretKeySelector

+ Bucket string

+ CreateBucketIfNotPresent *CreateS3BucketOptions

+ 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 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

+ DAG *DAGTemplate

+ Daemon *bool

+ Executor *ExecutorConfig

+ 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 (*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) GetType() TemplateType

+ func (tmpl *Template) HasPodSpecPatch() bool

+ func (tmpl *Template) IsLeaf() bool

+ func (tmpl *Template) IsMainContainerName(containerName string) bool

+ func (tmpl *Template) IsPodType() bool

+ 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

+ GetTemplateName func() string

+ GetTemplateRef func() *TemplateRef

+ type TemplateType string

+ const TemplateTypeContainer

+ const TemplateTypeDAG

+ const TemplateTypeResource

+ const TemplateTypeScript

+ const TemplateTypeSteps

+ const TemplateTypeSuspend

+ const TemplateTypeUnknown

+ type Type int

+ const Bool

+ const List

+ const Map

+ const Number

+ const String

+ type UserContainer struct

+ MirrorVolumeMounts *bool

+ func (*UserContainer) Descriptor() ([]byte, []int)

+ func (*UserContainer) ProtoMessage()

+ func (in *UserContainer) DeepCopy() *UserContainer

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

+ func (m *UserContainer) Marshal() (dAtA []byte, err error)

+ func (m *UserContainer) MarshalTo(dAtA []byte) (int, error)

+ func (m *UserContainer) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *UserContainer) Reset()

+ func (m *UserContainer) Size() (n int)

+ func (m *UserContainer) Unmarshal(dAtA []byte) error

+ func (m *UserContainer) XXX_DiscardUnknown()

+ func (m *UserContainer) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *UserContainer) XXX_Merge(src proto.Message)

+ func (m *UserContainer) XXX_Size() int

+ func (m *UserContainer) XXX_Unmarshal(b []byte) error

+ func (this *UserContainer) String() string

+ type ValueFrom struct

+ Default *AnyString

+ Event 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 (*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

+ 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

+ 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

+ Name string

+ OnExit string

+ Template string

+ TemplateRef *TemplateRef

+ When string

+ WithItems []Item

+ WithParam string

+ WithSequence *Sequence

+ func (*WorkflowStep) Descriptor() ([]byte, []int)

+ func (*WorkflowStep) ProtoMessage()

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

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

+ func (m *WorkflowStep) Marshal() (dAtA []byte, err error)

+ func (m *WorkflowStep) MarshalTo(dAtA []byte) (int, error)

+ func (m *WorkflowStep) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *WorkflowStep) Reset()

+ func (m *WorkflowStep) Size() (n int)

+ func (m *WorkflowStep) Unmarshal(dAtA []byte) error

+ func (m *WorkflowStep) XXX_DiscardUnknown()

+ func (m *WorkflowStep) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *WorkflowStep) XXX_Merge(src proto.Message)

+ func (m *WorkflowStep) XXX_Size() int

+ func (m *WorkflowStep) XXX_Unmarshal(b []byte) error

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

+ func (step *WorkflowStep) GetTemplateName() string

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

+ func (step *WorkflowStep) ShouldExpand() bool

+ func (this *WorkflowStep) String() string

+ type WorkflowTemplate struct

+ Spec WorkflowTemplateSpec

+ func (*WorkflowTemplate) Descriptor() ([]byte, []int)

+ func (*WorkflowTemplate) ProtoMessage()

+ func (in *WorkflowTemplate) DeepCopy() *WorkflowTemplate

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

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

+ func (m *WorkflowTemplate) Marshal() (dAtA []byte, err error)

+ func (m *WorkflowTemplate) MarshalTo(dAtA []byte) (int, error)

+ func (m *WorkflowTemplate) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *WorkflowTemplate) Reset()

+ func (m *WorkflowTemplate) Size() (n int)

+ func (m *WorkflowTemplate) Unmarshal(dAtA []byte) error

+ func (m *WorkflowTemplate) XXX_DiscardUnknown()

+ func (m *WorkflowTemplate) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *WorkflowTemplate) XXX_Merge(src proto.Message)

+ func (m *WorkflowTemplate) XXX_Size() int

+ func (m *WorkflowTemplate) XXX_Unmarshal(b []byte) error

+ func (this *WorkflowTemplate) String() string

+ func (wftmpl *WorkflowTemplate) 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