v1alpha1

package
v3.0.0-rc1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Feb 8, 2021 License: Apache-2.0 Imports: 27 Imported by: 0

Documentation

Overview

Package v1alpha1 is the v1alpha1 version of the API. +groupName=argoproj.io +k8s:deepcopy-gen=package,register +k8s:openapi-gen=true

Index

Constants

This section is empty.

Variables

View Source
var (
	ErrInvalidLengthGenerated        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowGenerated          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupGenerated = fmt.Errorf("proto: unexpected end of group")
)
View Source
var (
	SchemeGroupVersion             = schema.GroupVersion{Group: workflow.Group, Version: "v1alpha1"}
	WorkflowSchemaGroupVersionKind = schema.GroupVersionKind{Group: workflow.Group, Version: "v1alpha1", Kind: workflow.WorkflowKind}
)

SchemeGroupVersion is group version used to register these objects

View Source
var (
	SchemeBuilder = runtime.NewSchemeBuilder(addKnownTypes)
	AddToScheme   = SchemeBuilder.AddToScheme
)
View Source
var (
	WorkflowCreatedAfter = func(t time.Time) WorkflowPredicate {
		return func(wf Workflow) bool {
			return wf.ObjectMeta.CreationTimestamp.After(t)
		}
	}
	WorkflowFinishedBefore = func(t time.Time) WorkflowPredicate {
		return func(wf Workflow) bool {
			return !wf.Status.FinishedAt.IsZero() && wf.Status.FinishedAt.Time.Before(t)
		}
	}
	WorkflowRanBetween = func(startTime time.Time, endTime time.Time) WorkflowPredicate {
		return func(wf Workflow) bool {
			return wf.ObjectMeta.CreationTimestamp.After(startTime) && !wf.Status.FinishedAt.IsZero() && wf.Status.FinishedAt.Time.Before(endTime)
		}
	}
)
View Source
var DefaultArtifactRepositoryRefStatus = &ArtifactRepositoryRefStatus{Default: true}

Functions

func FailedPodNode

func FailedPodNode(n NodeStatus) bool

func Kind

func Kind(kind string) schema.GroupKind

Kind takes an unqualified kind and returns back a Group qualified GroupKind

func NodeWithDisplayName

func NodeWithDisplayName(name string) func(n NodeStatus) bool

func Resource

func Resource(resource string) schema.GroupResource

Resource takes an unqualified resource and returns a Group-qualified GroupResource.

func ResourceQuantityDenominator

func ResourceQuantityDenominator(r apiv1.ResourceName) *resource.Quantity

func SucceededPodNode

func SucceededPodNode(n NodeStatus) bool

Types

type Amount

type Amount struct {
	Value json.Number `json:"-" protobuf:"bytes,1,opt,name=value,casttype=encoding/json.Number"`
}

Amount represent a numeric amount. +kubebuilder:validation:Type=number

func (*Amount) DeepCopy

func (in *Amount) DeepCopy() *Amount

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Amount.

func (*Amount) DeepCopyInto

func (in *Amount) DeepCopyInto(out *Amount)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*Amount) Descriptor

func (*Amount) Descriptor() ([]byte, []int)

func (*Amount) Float64

func (a *Amount) Float64() (float64, error)

func (*Amount) Marshal

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

func (Amount) MarshalJSON

func (a Amount) MarshalJSON() ([]byte, error)

func (*Amount) MarshalTo

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

func (*Amount) MarshalToSizedBuffer

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

func (Amount) OpenAPISchemaFormat

func (a Amount) OpenAPISchemaFormat() string

func (Amount) OpenAPISchemaType

func (a Amount) OpenAPISchemaType() []string

func (*Amount) ProtoMessage

func (*Amount) ProtoMessage()

func (*Amount) Reset

func (m *Amount) Reset()

func (*Amount) Size

func (m *Amount) Size() (n int)

func (*Amount) String

func (this *Amount) String() string

func (*Amount) Unmarshal

func (m *Amount) Unmarshal(dAtA []byte) error

func (*Amount) UnmarshalJSON

func (a *Amount) UnmarshalJSON(data []byte) error

func (*Amount) XXX_DiscardUnknown

func (m *Amount) XXX_DiscardUnknown()

func (*Amount) XXX_Marshal

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

func (*Amount) XXX_Merge

func (m *Amount) XXX_Merge(src proto.Message)

func (*Amount) XXX_Size

func (m *Amount) XXX_Size() int

func (*Amount) XXX_Unmarshal

func (m *Amount) XXX_Unmarshal(b []byte) error

type AnyString

type AnyString string

* It's JSON type is just string. * It will unmarshall int64, int32, float64, float32, boolean, a plain string and represents it as string. * It will marshall back to string - marshalling is not symmetric.

func AnyStringPtr

func AnyStringPtr(val interface{}) *AnyString

func ParseAnyString

func ParseAnyString(val interface{}) AnyString

func (AnyString) MarshalJSON

func (i AnyString) MarshalJSON() ([]byte, error)

func (AnyString) String

func (i AnyString) String() string

func (*AnyString) UnmarshalJSON

func (i *AnyString) UnmarshalJSON(value []byte) error

type ArchiveStrategy

type ArchiveStrategy struct {
	Tar  *TarStrategy  `json:"tar,omitempty" protobuf:"bytes,1,opt,name=tar"`
	None *NoneStrategy `json:"none,omitempty" protobuf:"bytes,2,opt,name=none"`
	Zip  *ZipStrategy  `json:"zip,omitempty" protobuf:"bytes,3,opt,name=zip"`
}

ArchiveStrategy describes how to archive files/directory when saving artifacts

func (*ArchiveStrategy) DeepCopy

func (in *ArchiveStrategy) DeepCopy() *ArchiveStrategy

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ArchiveStrategy.

func (*ArchiveStrategy) DeepCopyInto

func (in *ArchiveStrategy) DeepCopyInto(out *ArchiveStrategy)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*ArchiveStrategy) Descriptor

func (*ArchiveStrategy) Descriptor() ([]byte, []int)

func (*ArchiveStrategy) Marshal

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

func (*ArchiveStrategy) MarshalTo

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

func (*ArchiveStrategy) MarshalToSizedBuffer

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

func (*ArchiveStrategy) ProtoMessage

func (*ArchiveStrategy) ProtoMessage()

func (*ArchiveStrategy) Reset

func (m *ArchiveStrategy) Reset()

func (*ArchiveStrategy) Size

func (m *ArchiveStrategy) Size() (n int)

func (*ArchiveStrategy) String

func (this *ArchiveStrategy) String() string

func (*ArchiveStrategy) Unmarshal

func (m *ArchiveStrategy) Unmarshal(dAtA []byte) error

func (*ArchiveStrategy) XXX_DiscardUnknown

func (m *ArchiveStrategy) XXX_DiscardUnknown()

func (*ArchiveStrategy) XXX_Marshal

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

func (*ArchiveStrategy) XXX_Merge

func (m *ArchiveStrategy) XXX_Merge(src proto.Message)

func (*ArchiveStrategy) XXX_Size

func (m *ArchiveStrategy) XXX_Size() int

func (*ArchiveStrategy) XXX_Unmarshal

func (m *ArchiveStrategy) XXX_Unmarshal(b []byte) error

type Arguments

type Arguments struct {
	// Parameters is the list of parameters to pass to the template or workflow
	// +patchStrategy=merge
	// +patchMergeKey=name
	Parameters []Parameter `json:"parameters,omitempty" patchStrategy:"merge" patchMergeKey:"name" protobuf:"bytes,1,rep,name=parameters"`

	// Artifacts is the list of artifacts to pass to the template or workflow
	// +patchStrategy=merge
	// +patchMergeKey=name
	Artifacts Artifacts `json:"artifacts,omitempty" patchStrategy:"merge" patchMergeKey:"name" protobuf:"bytes,2,rep,name=artifacts"`
}

Arguments to a template

func (*Arguments) DeepCopy

func (in *Arguments) DeepCopy() *Arguments

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Arguments.

func (*Arguments) DeepCopyInto

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*Arguments) Descriptor

func (*Arguments) Descriptor() ([]byte, []int)

func (*Arguments) GetArtifactByName

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

GetArtifactByName retrieves an artifact by its name

func (*Arguments) GetParameterByName

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

GetParameterByName retrieves a parameter by its name

func (Arguments) IsEmpty

func (a Arguments) IsEmpty() bool

func (*Arguments) Marshal

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

func (*Arguments) MarshalTo

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

func (*Arguments) MarshalToSizedBuffer

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

func (*Arguments) ProtoMessage

func (*Arguments) ProtoMessage()

func (*Arguments) Reset

func (m *Arguments) Reset()

func (*Arguments) Size

func (m *Arguments) Size() (n int)

func (*Arguments) String

func (this *Arguments) String() string

func (*Arguments) Unmarshal

func (m *Arguments) Unmarshal(dAtA []byte) error

func (*Arguments) XXX_DiscardUnknown

func (m *Arguments) XXX_DiscardUnknown()

func (*Arguments) XXX_Marshal

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

func (*Arguments) XXX_Merge

func (m *Arguments) XXX_Merge(src proto.Message)

func (*Arguments) XXX_Size

func (m *Arguments) XXX_Size() int

func (*Arguments) XXX_Unmarshal

func (m *Arguments) XXX_Unmarshal(b []byte) error

type ArgumentsProvider

type ArgumentsProvider interface {
	GetParameterByName(name string) *Parameter
	GetArtifactByName(name string) *Artifact
}

type Artifact

type Artifact struct {
	// name of the artifact. must be unique within a template's inputs/outputs.
	Name string `json:"name" protobuf:"bytes,1,opt,name=name"`

	// Path is the container path to the artifact
	Path string `json:"path,omitempty" protobuf:"bytes,2,opt,name=path"`

	// mode bits to use on this file, must be a value between 0 and 0777
	// set when loading input artifacts.
	Mode *int32 `json:"mode,omitempty" protobuf:"varint,3,opt,name=mode"`

	// From allows an artifact to reference an artifact from a previous step
	From string `json:"from,omitempty" protobuf:"bytes,4,opt,name=from"`

	// ArtifactLocation contains the location of the artifact
	ArtifactLocation `json:",inline" protobuf:"bytes,5,opt,name=artifactLocation"`

	// GlobalName exports an output artifact to the global scope, making it available as
	// '{{workflow.outputs.artifacts.XXXX}} and in workflow.status.outputs.artifacts
	GlobalName string `json:"globalName,omitempty" protobuf:"bytes,6,opt,name=globalName"`

	// Archive controls how the artifact will be saved to the artifact repository.
	Archive *ArchiveStrategy `json:"archive,omitempty" protobuf:"bytes,7,opt,name=archive"`

	// Make Artifacts optional, if Artifacts doesn't generate or exist
	Optional bool `json:"optional,omitempty" protobuf:"varint,8,opt,name=optional"`

	// SubPath allows an artifact to be sourced from a subpath within the specified source
	SubPath string `json:"subPath,omitempty" protobuf:"bytes,9,opt,name=subPath"`

	// If mode is set, apply the permission recursively into the artifact if it is a folder
	RecurseMode bool `json:"recurseMode,omitempty" protobuf:"varint,10,opt,name=recurseMode"`
}

Artifact indicates an artifact to place at a specified path

func (*Artifact) DeepCopy

func (in *Artifact) DeepCopy() *Artifact

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Artifact.

func (*Artifact) DeepCopyInto

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*Artifact) Descriptor

func (*Artifact) Descriptor() ([]byte, []int)

func (*Artifact) GetArchive

func (a *Artifact) GetArchive() *ArchiveStrategy

func (*Artifact) Marshal

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

func (*Artifact) MarshalTo

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

func (*Artifact) MarshalToSizedBuffer

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

func (*Artifact) ProtoMessage

func (*Artifact) ProtoMessage()

func (*Artifact) Reset

func (m *Artifact) Reset()

func (*Artifact) Size

func (m *Artifact) Size() (n int)

func (*Artifact) String

func (this *Artifact) String() string

func (*Artifact) Unmarshal

func (m *Artifact) Unmarshal(dAtA []byte) error

func (*Artifact) XXX_DiscardUnknown

func (m *Artifact) XXX_DiscardUnknown()

func (*Artifact) XXX_Marshal

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

func (*Artifact) XXX_Merge

func (m *Artifact) XXX_Merge(src proto.Message)

func (*Artifact) XXX_Size

func (m *Artifact) XXX_Size() int

func (*Artifact) XXX_Unmarshal

func (m *Artifact) XXX_Unmarshal(b []byte) error

type ArtifactLocation

type ArtifactLocation struct {
	// ArchiveLogs indicates if the container logs should be archived
	ArchiveLogs *bool `json:"archiveLogs,omitempty" protobuf:"varint,1,opt,name=archiveLogs"`

	// S3 contains S3 artifact location details
	S3 *S3Artifact `json:"s3,omitempty" protobuf:"bytes,2,opt,name=s3"`

	// Git contains git artifact location details
	Git *GitArtifact `json:"git,omitempty" protobuf:"bytes,3,opt,name=git"`

	// HTTP contains HTTP artifact location details
	HTTP *HTTPArtifact `json:"http,omitempty" protobuf:"bytes,4,opt,name=http"`

	// Artifactory contains artifactory artifact location details
	Artifactory *ArtifactoryArtifact `json:"artifactory,omitempty" protobuf:"bytes,5,opt,name=artifactory"`

	// HDFS contains HDFS artifact location details
	HDFS *HDFSArtifact `json:"hdfs,omitempty" protobuf:"bytes,6,opt,name=hdfs"`

	// Raw contains raw artifact location details
	Raw *RawArtifact `json:"raw,omitempty" protobuf:"bytes,7,opt,name=raw"`

	// OSS contains OSS artifact location details
	OSS *OSSArtifact `json:"oss,omitempty" protobuf:"bytes,8,opt,name=oss"`

	// GCS contains GCS artifact location details
	GCS *GCSArtifact `json:"gcs,omitempty" protobuf:"bytes,9,opt,name=gcs"`
}

ArtifactLocation describes a location for a single or multiple artifacts. It is used as single artifact in the context of inputs/outputs (e.g. outputs.artifacts.artname). It is also used to describe the location of multiple artifacts such as the archive location of a single workflow step, which the executor will use as a default location to store its files.

func (*ArtifactLocation) AppendToKey

func (a *ArtifactLocation) AppendToKey(x string) error

func (*ArtifactLocation) DeepCopy

func (in *ArtifactLocation) DeepCopy() *ArtifactLocation

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ArtifactLocation.

func (*ArtifactLocation) DeepCopyInto

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*ArtifactLocation) Descriptor

func (*ArtifactLocation) Descriptor() ([]byte, []int)

func (*ArtifactLocation) Get

func (*ArtifactLocation) GetKey

func (a *ArtifactLocation) GetKey() (string, error)

func (*ArtifactLocation) HasKey

func (a *ArtifactLocation) HasKey() bool

HasKey returns whether or not an artifact has a key. They may or may not also HasLocation.

func (*ArtifactLocation) HasLocation

func (a *ArtifactLocation) HasLocation() bool

HasLocation whether or not an artifact has a *full* location defined An artifact that has a location implicitly has a key (i.e. HasKey() == true).

func (*ArtifactLocation) HasLocationOrKey

func (a *ArtifactLocation) HasLocationOrKey() bool

func (*ArtifactLocation) IsArchiveLogs

func (a *ArtifactLocation) IsArchiveLogs() bool

func (*ArtifactLocation) Marshal

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

func (*ArtifactLocation) MarshalTo

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

func (*ArtifactLocation) MarshalToSizedBuffer

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

func (*ArtifactLocation) ProtoMessage

func (*ArtifactLocation) ProtoMessage()

func (*ArtifactLocation) Relocate

func (a *ArtifactLocation) Relocate(l *ArtifactLocation) error

Relocate copies all location info from the parameter, except the key. But only if it does not have a location already.

func (*ArtifactLocation) Reset

func (m *ArtifactLocation) Reset()

func (*ArtifactLocation) SetKey

func (a *ArtifactLocation) SetKey(key string) error

set the key to a new value, use path.Join to combine items

func (*ArtifactLocation) SetType

SetType sets the type of the artifact to type the argument. Any existing value is deleted.

func (*ArtifactLocation) Size

func (m *ArtifactLocation) Size() (n int)

func (*ArtifactLocation) String

func (this *ArtifactLocation) String() string

func (*ArtifactLocation) Unmarshal

func (m *ArtifactLocation) Unmarshal(dAtA []byte) error

func (*ArtifactLocation) XXX_DiscardUnknown

func (m *ArtifactLocation) XXX_DiscardUnknown()

func (*ArtifactLocation) XXX_Marshal

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

func (*ArtifactLocation) XXX_Merge

func (m *ArtifactLocation) XXX_Merge(src proto.Message)

func (*ArtifactLocation) XXX_Size

func (m *ArtifactLocation) XXX_Size() int

func (*ArtifactLocation) XXX_Unmarshal

func (m *ArtifactLocation) XXX_Unmarshal(b []byte) error

type ArtifactLocationType

type ArtifactLocationType interface {
	HasLocation() bool
	GetKey() (string, error)
	SetKey(key string) error
}

type ArtifactRepositoryRef

type ArtifactRepositoryRef struct {
	// The name of the config map. Defaults to "artifact-repositories".
	ConfigMap string `json:"configMap,omitempty" protobuf:"bytes,1,opt,name=configMap"`
	// The config map key. Defaults to the value of the "workflows.argoproj.io/default-artifact-repository" annotation.
	Key string `json:"key,omitempty" protobuf:"bytes,2,opt,name=key"`
}

+protobuf.options.(gogoproto.goproto_stringer)=false

func (*ArtifactRepositoryRef) DeepCopy

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ArtifactRepositoryRef.

func (*ArtifactRepositoryRef) DeepCopyInto

func (in *ArtifactRepositoryRef) DeepCopyInto(out *ArtifactRepositoryRef)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*ArtifactRepositoryRef) Descriptor

func (*ArtifactRepositoryRef) Descriptor() ([]byte, []int)

func (*ArtifactRepositoryRef) GetConfigMapOr

func (r *ArtifactRepositoryRef) GetConfigMapOr(configMap string) string

func (*ArtifactRepositoryRef) GetKeyOr

func (r *ArtifactRepositoryRef) GetKeyOr(key string) string

func (*ArtifactRepositoryRef) Marshal

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

func (*ArtifactRepositoryRef) MarshalTo

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

func (*ArtifactRepositoryRef) MarshalToSizedBuffer

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

func (*ArtifactRepositoryRef) ProtoMessage

func (*ArtifactRepositoryRef) ProtoMessage()

func (*ArtifactRepositoryRef) Reset

func (m *ArtifactRepositoryRef) Reset()

func (*ArtifactRepositoryRef) Size

func (m *ArtifactRepositoryRef) Size() (n int)

func (*ArtifactRepositoryRef) String

func (r *ArtifactRepositoryRef) String() string

func (*ArtifactRepositoryRef) Unmarshal

func (m *ArtifactRepositoryRef) Unmarshal(dAtA []byte) error

func (*ArtifactRepositoryRef) XXX_DiscardUnknown

func (m *ArtifactRepositoryRef) XXX_DiscardUnknown()

func (*ArtifactRepositoryRef) XXX_Marshal

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

func (*ArtifactRepositoryRef) XXX_Merge

func (m *ArtifactRepositoryRef) XXX_Merge(src proto.Message)

func (*ArtifactRepositoryRef) XXX_Size

func (m *ArtifactRepositoryRef) XXX_Size() int

func (*ArtifactRepositoryRef) XXX_Unmarshal

func (m *ArtifactRepositoryRef) XXX_Unmarshal(b []byte) error

type ArtifactRepositoryRefStatus

type ArtifactRepositoryRefStatus struct {
	ArtifactRepositoryRef `json:",inline" protobuf:"bytes,1,opt,name=artifactRepositoryRef"`
	// The namespace of the config map. Defaults to the workflow's namespace, or the controller's namespace (if found).
	Namespace string `json:"namespace,omitempty" protobuf:"bytes,2,opt,name=namespace"`
	// If this ref represents the default artifact repository, rather than a config map.
	Default bool `json:"default,omitempty" protobuf:"varint,3,opt,name=default"`
}

+protobuf.options.(gogoproto.goproto_stringer)=false

func (*ArtifactRepositoryRefStatus) DeepCopy

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ArtifactRepositoryRefStatus.

func (*ArtifactRepositoryRefStatus) DeepCopyInto

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*ArtifactRepositoryRefStatus) Descriptor

func (*ArtifactRepositoryRefStatus) Descriptor() ([]byte, []int)

func (*ArtifactRepositoryRefStatus) Marshal

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

func (*ArtifactRepositoryRefStatus) MarshalTo

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

func (*ArtifactRepositoryRefStatus) MarshalToSizedBuffer

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

func (*ArtifactRepositoryRefStatus) ProtoMessage

func (*ArtifactRepositoryRefStatus) ProtoMessage()

func (*ArtifactRepositoryRefStatus) Reset

func (m *ArtifactRepositoryRefStatus) Reset()

func (*ArtifactRepositoryRefStatus) Size

func (m *ArtifactRepositoryRefStatus) Size() (n int)

func (*ArtifactRepositoryRefStatus) String

func (r *ArtifactRepositoryRefStatus) String() string

func (*ArtifactRepositoryRefStatus) Unmarshal

func (m *ArtifactRepositoryRefStatus) Unmarshal(dAtA []byte) error

func (*ArtifactRepositoryRefStatus) XXX_DiscardUnknown

func (m *ArtifactRepositoryRefStatus) XXX_DiscardUnknown()

func (*ArtifactRepositoryRefStatus) XXX_Marshal

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

func (*ArtifactRepositoryRefStatus) XXX_Merge

func (m *ArtifactRepositoryRefStatus) XXX_Merge(src proto.Message)

func (*ArtifactRepositoryRefStatus) XXX_Size

func (m *ArtifactRepositoryRefStatus) XXX_Size() int

func (*ArtifactRepositoryRefStatus) XXX_Unmarshal

func (m *ArtifactRepositoryRefStatus) XXX_Unmarshal(b []byte) error

type ArtifactoryArtifact

type ArtifactoryArtifact struct {
	// URL of the artifact
	URL             string `json:"url" protobuf:"bytes,1,opt,name=url"`
	ArtifactoryAuth `json:",inline" protobuf:"bytes,2,opt,name=artifactoryAuth"`
}

ArtifactoryArtifact is the location of an artifactory artifact

func (*ArtifactoryArtifact) DeepCopy

func (in *ArtifactoryArtifact) DeepCopy() *ArtifactoryArtifact

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ArtifactoryArtifact.

func (*ArtifactoryArtifact) DeepCopyInto

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*ArtifactoryArtifact) Descriptor

func (*ArtifactoryArtifact) Descriptor() ([]byte, []int)

func (*ArtifactoryArtifact) GetKey

func (a *ArtifactoryArtifact) GetKey() (string, error)
func (a *ArtifactoryArtifact) String() string {
	return a.URL
}

func (*ArtifactoryArtifact) HasLocation

func (a *ArtifactoryArtifact) HasLocation() bool

func (*ArtifactoryArtifact) Marshal

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

func (*ArtifactoryArtifact) MarshalTo

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

func (*ArtifactoryArtifact) MarshalToSizedBuffer

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

func (*ArtifactoryArtifact) ProtoMessage

func (*ArtifactoryArtifact) ProtoMessage()

func (*ArtifactoryArtifact) Reset

func (m *ArtifactoryArtifact) Reset()

func (*ArtifactoryArtifact) SetKey

func (a *ArtifactoryArtifact) SetKey(key string) error

func (*ArtifactoryArtifact) Size

func (m *ArtifactoryArtifact) Size() (n int)

func (*ArtifactoryArtifact) String

func (this *ArtifactoryArtifact) String() string

func (*ArtifactoryArtifact) Unmarshal

func (m *ArtifactoryArtifact) Unmarshal(dAtA []byte) error

func (*ArtifactoryArtifact) XXX_DiscardUnknown

func (m *ArtifactoryArtifact) XXX_DiscardUnknown()

func (*ArtifactoryArtifact) XXX_Marshal

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

func (*ArtifactoryArtifact) XXX_Merge

func (m *ArtifactoryArtifact) XXX_Merge(src proto.Message)

func (*ArtifactoryArtifact) XXX_Size

func (m *ArtifactoryArtifact) XXX_Size() int

func (*ArtifactoryArtifact) XXX_Unmarshal

func (m *ArtifactoryArtifact) XXX_Unmarshal(b []byte) error

type ArtifactoryAuth

type ArtifactoryAuth struct {
	// UsernameSecret is the secret selector to the repository username
	UsernameSecret *apiv1.SecretKeySelector `json:"usernameSecret,omitempty" protobuf:"bytes,1,opt,name=usernameSecret"`

	// PasswordSecret is the secret selector to the repository password
	PasswordSecret *apiv1.SecretKeySelector `json:"passwordSecret,omitempty" protobuf:"bytes,2,opt,name=passwordSecret"`
}

ArtifactoryAuth describes the secret selectors required for authenticating to artifactory

func (*ArtifactoryAuth) DeepCopy

func (in *ArtifactoryAuth) DeepCopy() *ArtifactoryAuth

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ArtifactoryAuth.

func (*ArtifactoryAuth) DeepCopyInto

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*ArtifactoryAuth) Descriptor

func (*ArtifactoryAuth) Descriptor() ([]byte, []int)

func (*ArtifactoryAuth) Marshal

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

func (*ArtifactoryAuth) MarshalTo

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

func (*ArtifactoryAuth) MarshalToSizedBuffer

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

func (*ArtifactoryAuth) ProtoMessage

func (*ArtifactoryAuth) ProtoMessage()

func (*ArtifactoryAuth) Reset

func (m *ArtifactoryAuth) Reset()

func (*ArtifactoryAuth) Size

func (m *ArtifactoryAuth) Size() (n int)

func (*ArtifactoryAuth) String

func (this *ArtifactoryAuth) String() string

func (*ArtifactoryAuth) Unmarshal

func (m *ArtifactoryAuth) Unmarshal(dAtA []byte) error

func (*ArtifactoryAuth) XXX_DiscardUnknown

func (m *ArtifactoryAuth) XXX_DiscardUnknown()

func (*ArtifactoryAuth) XXX_Marshal

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

func (*ArtifactoryAuth) XXX_Merge

func (m *ArtifactoryAuth) XXX_Merge(src proto.Message)

func (*ArtifactoryAuth) XXX_Size

func (m *ArtifactoryAuth) XXX_Size() int

func (*ArtifactoryAuth) XXX_Unmarshal

func (m *ArtifactoryAuth) XXX_Unmarshal(b []byte) error

type Artifacts

type Artifacts []Artifact

func (Artifacts) DeepCopy

func (in Artifacts) DeepCopy() Artifacts

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Artifacts.

func (Artifacts) DeepCopyInto

func (in Artifacts) DeepCopyInto(out *Artifacts)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (Artifacts) GetArtifactByName

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

type Backoff

type Backoff struct {
	// Duration is the amount to back off. Default unit is seconds, but could also be a duration (e.g. "2m", "1h")
	Duration string `json:"duration,omitempty" protobuf:"varint,1,opt,name=duration"`
	// Factor is a factor to multiply the base duration after each failed retry
	Factor *intstr.IntOrString `json:"factor,omitempty" protobuf:"varint,2,opt,name=factor"`
	// MaxDuration is the maximum amount of time allowed for the backoff strategy
	MaxDuration string `json:"maxDuration,omitempty" protobuf:"varint,3,opt,name=maxDuration"`
}

Backoff is a backoff strategy to use within retryStrategy

func (*Backoff) DeepCopy

func (in *Backoff) DeepCopy() *Backoff

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Backoff.

func (*Backoff) DeepCopyInto

func (in *Backoff) DeepCopyInto(out *Backoff)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*Backoff) Descriptor

func (*Backoff) Descriptor() ([]byte, []int)

func (*Backoff) Marshal

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

func (*Backoff) MarshalTo

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

func (*Backoff) MarshalToSizedBuffer

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

func (*Backoff) ProtoMessage

func (*Backoff) ProtoMessage()

func (*Backoff) Reset

func (m *Backoff) Reset()

func (*Backoff) Size

func (m *Backoff) Size() (n int)

func (*Backoff) String

func (this *Backoff) String() string

func (*Backoff) Unmarshal

func (m *Backoff) Unmarshal(dAtA []byte) error

func (*Backoff) XXX_DiscardUnknown

func (m *Backoff) XXX_DiscardUnknown()

func (*Backoff) XXX_Marshal

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

func (*Backoff) XXX_Merge

func (m *Backoff) XXX_Merge(src proto.Message)

func (*Backoff) XXX_Size

func (m *Backoff) XXX_Size() int

func (*Backoff) XXX_Unmarshal

func (m *Backoff) XXX_Unmarshal(b []byte) error

type Cache

type Cache struct {
	// ConfigMap sets a ConfigMap-based cache
	ConfigMap *apiv1.ConfigMapKeySelector `json:"configMap" protobuf:"bytes,1,opt,name=configMap"`
}

Cache is the configuration for the type of cache to be used

func (*Cache) DeepCopy

func (in *Cache) DeepCopy() *Cache

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Cache.

func (*Cache) DeepCopyInto

func (in *Cache) DeepCopyInto(out *Cache)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*Cache) Descriptor

func (*Cache) Descriptor() ([]byte, []int)

func (*Cache) Marshal

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

func (*Cache) MarshalTo

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

func (*Cache) MarshalToSizedBuffer

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

func (*Cache) ProtoMessage

func (*Cache) ProtoMessage()

func (*Cache) Reset

func (m *Cache) Reset()

func (*Cache) Size

func (m *Cache) Size() (n int)

func (*Cache) String

func (this *Cache) String() string

func (*Cache) Unmarshal

func (m *Cache) Unmarshal(dAtA []byte) error

func (*Cache) XXX_DiscardUnknown

func (m *Cache) XXX_DiscardUnknown()

func (*Cache) XXX_Marshal

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

func (*Cache) XXX_Merge

func (m *Cache) XXX_Merge(src proto.Message)

func (*Cache) XXX_Size

func (m *Cache) XXX_Size() int

func (*Cache) XXX_Unmarshal

func (m *Cache) XXX_Unmarshal(b []byte) error

type ClusterWorkflowTemplate

type ClusterWorkflowTemplate struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata" protobuf:"bytes,1,opt,name=metadata"`
	Spec              WorkflowTemplateSpec `json:"spec" protobuf:"bytes,2,opt,name=spec"`
}

ClusterWorkflowTemplate is the definition of a workflow template resource in cluster scope +genclient +genclient:noStatus +genclient:nonNamespaced +kubebuilder:resource:scope=Cluster,shortName=clusterwftmpl;cwft +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object

func (*ClusterWorkflowTemplate) DeepCopy

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterWorkflowTemplate.

func (*ClusterWorkflowTemplate) DeepCopyInto

func (in *ClusterWorkflowTemplate) DeepCopyInto(out *ClusterWorkflowTemplate)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*ClusterWorkflowTemplate) DeepCopyObject

func (in *ClusterWorkflowTemplate) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*ClusterWorkflowTemplate) Descriptor

func (*ClusterWorkflowTemplate) Descriptor() ([]byte, []int)

func (*ClusterWorkflowTemplate) GetResourceScope

func (cwftmpl *ClusterWorkflowTemplate) GetResourceScope() ResourceScope

GetResourceScope returns the template scope of workflow template.

func (*ClusterWorkflowTemplate) GetTemplateByName

func (cwftmpl *ClusterWorkflowTemplate) GetTemplateByName(name string) *Template

GetTemplateByName retrieves a defined template by its name

func (*ClusterWorkflowTemplate) GetWorkflowMetadata

func (cwftmpl *ClusterWorkflowTemplate) GetWorkflowMetadata() *metav1.ObjectMeta

func (*ClusterWorkflowTemplate) GetWorkflowSpec

func (cwftmpl *ClusterWorkflowTemplate) GetWorkflowSpec() *WorkflowSpec

GetWorkflowSpec returns the WorkflowSpec of cluster workflow template.

func (*ClusterWorkflowTemplate) Marshal

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

func (*ClusterWorkflowTemplate) MarshalTo

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

func (*ClusterWorkflowTemplate) MarshalToSizedBuffer

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

func (*ClusterWorkflowTemplate) ProtoMessage

func (*ClusterWorkflowTemplate) ProtoMessage()

func (*ClusterWorkflowTemplate) Reset

func (m *ClusterWorkflowTemplate) Reset()

func (*ClusterWorkflowTemplate) Size

func (m *ClusterWorkflowTemplate) Size() (n int)

func (*ClusterWorkflowTemplate) String

func (this *ClusterWorkflowTemplate) String() string

func (*ClusterWorkflowTemplate) Unmarshal

func (m *ClusterWorkflowTemplate) Unmarshal(dAtA []byte) error

func (*ClusterWorkflowTemplate) XXX_DiscardUnknown

func (m *ClusterWorkflowTemplate) XXX_DiscardUnknown()

func (*ClusterWorkflowTemplate) XXX_Marshal

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

func (*ClusterWorkflowTemplate) XXX_Merge

func (m *ClusterWorkflowTemplate) XXX_Merge(src proto.Message)

func (*ClusterWorkflowTemplate) XXX_Size

func (m *ClusterWorkflowTemplate) XXX_Size() int

func (*ClusterWorkflowTemplate) XXX_Unmarshal

func (m *ClusterWorkflowTemplate) XXX_Unmarshal(b []byte) error

type ClusterWorkflowTemplateList

type ClusterWorkflowTemplateList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata" protobuf:"bytes,1,opt,name=metadata"`
	Items           ClusterWorkflowTemplates `json:"items" protobuf:"bytes,2,rep,name=items"`
}

ClusterWorkflowTemplateList is list of ClusterWorkflowTemplate resources +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object

func (*ClusterWorkflowTemplateList) DeepCopy

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterWorkflowTemplateList.

func (*ClusterWorkflowTemplateList) DeepCopyInto

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*ClusterWorkflowTemplateList) DeepCopyObject

func (in *ClusterWorkflowTemplateList) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*ClusterWorkflowTemplateList) Descriptor

func (*ClusterWorkflowTemplateList) Descriptor() ([]byte, []int)

func (*ClusterWorkflowTemplateList) Marshal

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

func (*ClusterWorkflowTemplateList) MarshalTo

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

func (*ClusterWorkflowTemplateList) MarshalToSizedBuffer

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

func (*ClusterWorkflowTemplateList) ProtoMessage

func (*ClusterWorkflowTemplateList) ProtoMessage()

func (*ClusterWorkflowTemplateList) Reset

func (m *ClusterWorkflowTemplateList) Reset()

func (*ClusterWorkflowTemplateList) Size

func (m *ClusterWorkflowTemplateList) Size() (n int)

func (*ClusterWorkflowTemplateList) String

func (this *ClusterWorkflowTemplateList) String() string

func (*ClusterWorkflowTemplateList) Unmarshal

func (m *ClusterWorkflowTemplateList) Unmarshal(dAtA []byte) error

func (*ClusterWorkflowTemplateList) XXX_DiscardUnknown

func (m *ClusterWorkflowTemplateList) XXX_DiscardUnknown()

func (*ClusterWorkflowTemplateList) XXX_Marshal

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

func (*ClusterWorkflowTemplateList) XXX_Merge

func (m *ClusterWorkflowTemplateList) XXX_Merge(src proto.Message)

func (*ClusterWorkflowTemplateList) XXX_Size

func (m *ClusterWorkflowTemplateList) XXX_Size() int

func (*ClusterWorkflowTemplateList) XXX_Unmarshal

func (m *ClusterWorkflowTemplateList) XXX_Unmarshal(b []byte) error

type ClusterWorkflowTemplates

type ClusterWorkflowTemplates []ClusterWorkflowTemplate

func (ClusterWorkflowTemplates) DeepCopy

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterWorkflowTemplates.

func (ClusterWorkflowTemplates) DeepCopyInto

func (in ClusterWorkflowTemplates) DeepCopyInto(out *ClusterWorkflowTemplates)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (ClusterWorkflowTemplates) Len

func (w ClusterWorkflowTemplates) Len() int

func (ClusterWorkflowTemplates) Less

func (w ClusterWorkflowTemplates) Less(i, j int) bool

func (ClusterWorkflowTemplates) Swap

func (w ClusterWorkflowTemplates) Swap(i, j int)

type ConcurrencyPolicy

type ConcurrencyPolicy string
const (
	AllowConcurrent   ConcurrencyPolicy = "Allow"
	ForbidConcurrent  ConcurrencyPolicy = "Forbid"
	ReplaceConcurrent ConcurrencyPolicy = "Replace"
)

type Condition

type Condition struct {
	// Type is the type of condition
	Type ConditionType `json:"type,omitempty" protobuf:"bytes,1,opt,name=type,casttype=ConditionType"`

	// Status is the status of the condition
	Status metav1.ConditionStatus `json:"status,omitempty" protobuf:"bytes,2,opt,name=status,casttype=k8s.io/apimachinery/pkg/apis/meta/v1.ConditionStatus"`

	// Message is the condition message
	Message string `json:"message,omitempty" protobuf:"bytes,3,opt,name=message"`
}

func (*Condition) DeepCopy

func (in *Condition) DeepCopy() *Condition

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Condition.

func (*Condition) DeepCopyInto

func (in *Condition) DeepCopyInto(out *Condition)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*Condition) Descriptor

func (*Condition) Descriptor() ([]byte, []int)

func (*Condition) Marshal

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

func (*Condition) MarshalTo

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

func (*Condition) MarshalToSizedBuffer

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

func (*Condition) ProtoMessage

func (*Condition) ProtoMessage()

func (*Condition) Reset

func (m *Condition) Reset()

func (*Condition) Size

func (m *Condition) Size() (n int)

func (*Condition) String

func (this *Condition) String() string

func (*Condition) Unmarshal

func (m *Condition) Unmarshal(dAtA []byte) error

func (*Condition) XXX_DiscardUnknown

func (m *Condition) XXX_DiscardUnknown()

func (*Condition) XXX_Marshal

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

func (*Condition) XXX_Merge

func (m *Condition) XXX_Merge(src proto.Message)

func (*Condition) XXX_Size

func (m *Condition) XXX_Size() int

func (*Condition) XXX_Unmarshal

func (m *Condition) XXX_Unmarshal(b []byte) error

type ConditionType

type ConditionType string
const (
	// ConditionTypeCompleted is a signifies the workflow has completed
	ConditionTypeCompleted ConditionType = "Completed"
	// ConditionTypePodRunning any workflow pods are currently running
	ConditionTypePodRunning ConditionType = "PodRunning"
	// ConditionTypeSpecWarning is a warning on the current application spec
	ConditionTypeSpecWarning ConditionType = "SpecWarning"
	// ConditionTypeSpecWarning is an error on the current application spec
	ConditionTypeSpecError ConditionType = "SpecError"
	// ConditionTypeMetricsError is an error during metric emission
	ConditionTypeMetricsError ConditionType = "MetricsError"
)
const (
	// ConditionTypeSubmissionError signifies that there was an error when submitting the CronWorkflow as a Workflow
	ConditionTypeSubmissionError ConditionType = "SubmissionError"
)

type Conditions

type Conditions []Condition

func (Conditions) DeepCopy

func (in Conditions) DeepCopy() Conditions

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Conditions.

func (Conditions) DeepCopyInto

func (in Conditions) DeepCopyInto(out *Conditions)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*Conditions) DisplayString

func (cs *Conditions) DisplayString(fmtStr string, iconMap map[ConditionType]string) string

func (*Conditions) JoinConditions

func (cs *Conditions) JoinConditions(conditions *Conditions)

func (*Conditions) RemoveCondition

func (cs *Conditions) RemoveCondition(conditionType ConditionType)

func (*Conditions) UpsertCondition

func (cs *Conditions) UpsertCondition(condition Condition)

func (*Conditions) UpsertConditionMessage

func (cs *Conditions) UpsertConditionMessage(condition Condition)

type ContinueOn

type ContinueOn struct {
	// +optional
	Error bool `json:"error,omitempty" protobuf:"varint,1,opt,name=error"`
	// +optional
	Failed bool `json:"failed,omitempty" protobuf:"varint,2,opt,name=failed"`
}

ContinueOn defines if a workflow should continue even if a task or step fails/errors. It can be specified if the workflow should continue when the pod errors, fails or both.

func (*ContinueOn) DeepCopy

func (in *ContinueOn) DeepCopy() *ContinueOn

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ContinueOn.

func (*ContinueOn) DeepCopyInto

func (in *ContinueOn) DeepCopyInto(out *ContinueOn)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*ContinueOn) Descriptor

func (*ContinueOn) Descriptor() ([]byte, []int)

func (*ContinueOn) Marshal

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

func (*ContinueOn) MarshalTo

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

func (*ContinueOn) MarshalToSizedBuffer

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

func (*ContinueOn) ProtoMessage

func (*ContinueOn) ProtoMessage()

func (*ContinueOn) Reset

func (m *ContinueOn) Reset()

func (*ContinueOn) Size

func (m *ContinueOn) Size() (n int)

func (*ContinueOn) String

func (this *ContinueOn) String() string

func (*ContinueOn) Unmarshal

func (m *ContinueOn) Unmarshal(dAtA []byte) error

func (*ContinueOn) XXX_DiscardUnknown

func (m *ContinueOn) XXX_DiscardUnknown()

func (*ContinueOn) XXX_Marshal

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

func (*ContinueOn) XXX_Merge

func (m *ContinueOn) XXX_Merge(src proto.Message)

func (*ContinueOn) XXX_Size

func (m *ContinueOn) XXX_Size() int

func (*ContinueOn) XXX_Unmarshal

func (m *ContinueOn) XXX_Unmarshal(b []byte) error

type Counter

type Counter struct {
	// Value is the value of the metric
	Value string `json:"value" protobuf:"bytes,1,opt,name=value"`
}

Counter is a Counter prometheus metric

func (*Counter) DeepCopy

func (in *Counter) DeepCopy() *Counter

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Counter.

func (*Counter) DeepCopyInto

func (in *Counter) DeepCopyInto(out *Counter)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*Counter) Descriptor

func (*Counter) Descriptor() ([]byte, []int)

func (*Counter) Marshal

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

func (*Counter) MarshalTo

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

func (*Counter) MarshalToSizedBuffer

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

func (*Counter) ProtoMessage

func (*Counter) ProtoMessage()

func (*Counter) Reset

func (m *Counter) Reset()

func (*Counter) Size

func (m *Counter) Size() (n int)

func (*Counter) String

func (this *Counter) String() string

func (*Counter) Unmarshal

func (m *Counter) Unmarshal(dAtA []byte) error

func (*Counter) XXX_DiscardUnknown

func (m *Counter) XXX_DiscardUnknown()

func (*Counter) XXX_Marshal

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

func (*Counter) XXX_Merge

func (m *Counter) XXX_Merge(src proto.Message)

func (*Counter) XXX_Size

func (m *Counter) XXX_Size() int

func (*Counter) XXX_Unmarshal

func (m *Counter) XXX_Unmarshal(b []byte) error

type CreateS3BucketOptions

type CreateS3BucketOptions struct {
	// ObjectLocking Enable object locking
	ObjectLocking bool `json:"objectLocking,omitempty" protobuf:"varint,3,opt,name=objectLocking"`
}

CreateS3BucketOptions options used to determine automatic automatic bucket-creation process

func (*CreateS3BucketOptions) DeepCopy

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CreateS3BucketOptions.

func (*CreateS3BucketOptions) DeepCopyInto

func (in *CreateS3BucketOptions) DeepCopyInto(out *CreateS3BucketOptions)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*CreateS3BucketOptions) Descriptor

func (*CreateS3BucketOptions) Descriptor() ([]byte, []int)

func (*CreateS3BucketOptions) Marshal

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

func (*CreateS3BucketOptions) MarshalTo

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

func (*CreateS3BucketOptions) MarshalToSizedBuffer

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

func (*CreateS3BucketOptions) ProtoMessage

func (*CreateS3BucketOptions) ProtoMessage()

func (*CreateS3BucketOptions) Reset

func (m *CreateS3BucketOptions) Reset()

func (*CreateS3BucketOptions) Size

func (m *CreateS3BucketOptions) Size() (n int)

func (*CreateS3BucketOptions) String

func (this *CreateS3BucketOptions) String() string

func (*CreateS3BucketOptions) Unmarshal

func (m *CreateS3BucketOptions) Unmarshal(dAtA []byte) error

func (*CreateS3BucketOptions) XXX_DiscardUnknown

func (m *CreateS3BucketOptions) XXX_DiscardUnknown()

func (*CreateS3BucketOptions) XXX_Marshal

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

func (*CreateS3BucketOptions) XXX_Merge

func (m *CreateS3BucketOptions) XXX_Merge(src proto.Message)

func (*CreateS3BucketOptions) XXX_Size

func (m *CreateS3BucketOptions) XXX_Size() int

func (*CreateS3BucketOptions) XXX_Unmarshal

func (m *CreateS3BucketOptions) XXX_Unmarshal(b []byte) error

type CronWorkflow

type CronWorkflow struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata" protobuf:"bytes,1,opt,name=metadata"`
	Spec              CronWorkflowSpec   `json:"spec" protobuf:"bytes,2,opt,name=spec"`
	Status            CronWorkflowStatus `json:"status,omitempty" protobuf:"bytes,3,opt,name=status"`
}

CronWorkflow is the definition of a scheduled workflow resource +genclient +genclient:noStatus +kubebuilder:resource:shortName=cwf;cronwf +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object

func (*CronWorkflow) DeepCopy

func (in *CronWorkflow) DeepCopy() *CronWorkflow

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CronWorkflow.

func (*CronWorkflow) DeepCopyInto

func (in *CronWorkflow) DeepCopyInto(out *CronWorkflow)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*CronWorkflow) DeepCopyObject

func (in *CronWorkflow) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*CronWorkflow) Descriptor

func (*CronWorkflow) Descriptor() ([]byte, []int)

func (*CronWorkflow) Marshal

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

func (*CronWorkflow) MarshalTo

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

func (*CronWorkflow) MarshalToSizedBuffer

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

func (*CronWorkflow) ProtoMessage

func (*CronWorkflow) ProtoMessage()

func (*CronWorkflow) Reset

func (m *CronWorkflow) Reset()

func (*CronWorkflow) Size

func (m *CronWorkflow) Size() (n int)

func (*CronWorkflow) String

func (this *CronWorkflow) String() string

func (*CronWorkflow) Unmarshal

func (m *CronWorkflow) Unmarshal(dAtA []byte) error

func (*CronWorkflow) XXX_DiscardUnknown

func (m *CronWorkflow) XXX_DiscardUnknown()

func (*CronWorkflow) XXX_Marshal

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

func (*CronWorkflow) XXX_Merge

func (m *CronWorkflow) XXX_Merge(src proto.Message)

func (*CronWorkflow) XXX_Size

func (m *CronWorkflow) XXX_Size() int

func (*CronWorkflow) XXX_Unmarshal

func (m *CronWorkflow) XXX_Unmarshal(b []byte) error

type CronWorkflowList

type CronWorkflowList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata" protobuf:"bytes,1,opt,name=metadata"`
	Items           []CronWorkflow `json:"items" protobuf:"bytes,2,rep,name=items"`
}

CronWorkflowList is list of CronWorkflow resources +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object

func (*CronWorkflowList) DeepCopy

func (in *CronWorkflowList) DeepCopy() *CronWorkflowList

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CronWorkflowList.

func (*CronWorkflowList) DeepCopyInto

func (in *CronWorkflowList) DeepCopyInto(out *CronWorkflowList)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*CronWorkflowList) DeepCopyObject

func (in *CronWorkflowList) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*CronWorkflowList) Descriptor

func (*CronWorkflowList) Descriptor() ([]byte, []int)

func (*CronWorkflowList) Marshal

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

func (*CronWorkflowList) MarshalTo

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

func (*CronWorkflowList) MarshalToSizedBuffer

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

func (*CronWorkflowList) ProtoMessage

func (*CronWorkflowList) ProtoMessage()

func (*CronWorkflowList) Reset

func (m *CronWorkflowList) Reset()

func (*CronWorkflowList) Size

func (m *CronWorkflowList) Size() (n int)

func (*CronWorkflowList) String

func (this *CronWorkflowList) String() string

func (*CronWorkflowList) Unmarshal

func (m *CronWorkflowList) Unmarshal(dAtA []byte) error

func (*CronWorkflowList) XXX_DiscardUnknown

func (m *CronWorkflowList) XXX_DiscardUnknown()

func (*CronWorkflowList) XXX_Marshal

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

func (*CronWorkflowList) XXX_Merge

func (m *CronWorkflowList) XXX_Merge(src proto.Message)

func (*CronWorkflowList) XXX_Size

func (m *CronWorkflowList) XXX_Size() int

func (*CronWorkflowList) XXX_Unmarshal

func (m *CronWorkflowList) XXX_Unmarshal(b []byte) error

type CronWorkflowSpec

type CronWorkflowSpec struct {
	// WorkflowSpec is the spec of the workflow to be run
	WorkflowSpec WorkflowSpec `json:"workflowSpec" protobuf:"bytes,1,opt,name=workflowSpec,casttype=WorkflowSpec"`
	// Schedule is a schedule to run the Workflow in Cron format
	Schedule string `json:"schedule" protobuf:"bytes,2,opt,name=schedule"`
	// ConcurrencyPolicy is the K8s-style concurrency policy that will be used
	ConcurrencyPolicy ConcurrencyPolicy `json:"concurrencyPolicy,omitempty" protobuf:"bytes,3,opt,name=concurrencyPolicy,casttype=ConcurrencyPolicy"`
	// Suspend is a flag that will stop new CronWorkflows from running if set to true
	Suspend bool `json:"suspend,omitempty" protobuf:"varint,4,opt,name=suspend"`
	// StartingDeadlineSeconds is the K8s-style deadline that will limit the time a CronWorkflow will be run after its
	// original scheduled time if it is missed.
	StartingDeadlineSeconds *int64 `json:"startingDeadlineSeconds,omitempty" protobuf:"varint,5,opt,name=startingDeadlineSeconds"`
	// SuccessfulJobsHistoryLimit is the number of successful jobs to be kept at a time
	SuccessfulJobsHistoryLimit *int32 `json:"successfulJobsHistoryLimit,omitempty" protobuf:"varint,6,opt,name=successfulJobsHistoryLimit"`
	// FailedJobsHistoryLimit is the number of failed jobs to be kept at a time
	FailedJobsHistoryLimit *int32 `json:"failedJobsHistoryLimit,omitempty" protobuf:"varint,7,opt,name=failedJobsHistoryLimit"`
	// Timezone is the timezone against which the cron schedule will be calculated, e.g. "Asia/Tokyo". Default is machine's local time.
	Timezone string `json:"timezone,omitempty" protobuf:"bytes,8,opt,name=timezone"`
	// WorkflowMetadata contains some metadata of the workflow to be run
	WorkflowMetadata *metav1.ObjectMeta `json:"workflowMetadata,omitempty" protobuf:"bytes,9,opt,name=workflowMeta"`
}

CronWorkflowSpec is the specification of a CronWorkflow

func (*CronWorkflowSpec) DeepCopy

func (in *CronWorkflowSpec) DeepCopy() *CronWorkflowSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CronWorkflowSpec.

func (*CronWorkflowSpec) DeepCopyInto

func (in *CronWorkflowSpec) DeepCopyInto(out *CronWorkflowSpec)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*CronWorkflowSpec) Descriptor

func (*CronWorkflowSpec) Descriptor() ([]byte, []int)

func (*CronWorkflowSpec) Marshal

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

func (*CronWorkflowSpec) MarshalTo

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

func (*CronWorkflowSpec) MarshalToSizedBuffer

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

func (*CronWorkflowSpec) ProtoMessage

func (*CronWorkflowSpec) ProtoMessage()

func (*CronWorkflowSpec) Reset

func (m *CronWorkflowSpec) Reset()

func (*CronWorkflowSpec) Size

func (m *CronWorkflowSpec) Size() (n int)

func (*CronWorkflowSpec) String

func (this *CronWorkflowSpec) String() string

func (*CronWorkflowSpec) Unmarshal

func (m *CronWorkflowSpec) Unmarshal(dAtA []byte) error

func (*CronWorkflowSpec) XXX_DiscardUnknown

func (m *CronWorkflowSpec) XXX_DiscardUnknown()

func (*CronWorkflowSpec) XXX_Marshal

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

func (*CronWorkflowSpec) XXX_Merge

func (m *CronWorkflowSpec) XXX_Merge(src proto.Message)

func (*CronWorkflowSpec) XXX_Size

func (m *CronWorkflowSpec) XXX_Size() int

func (*CronWorkflowSpec) XXX_Unmarshal

func (m *CronWorkflowSpec) XXX_Unmarshal(b []byte) error

type CronWorkflowStatus

type CronWorkflowStatus struct {
	// Active is a list of active workflows stemming from this CronWorkflow
	Active []v1.ObjectReference `json:"active" protobuf:"bytes,1,rep,name=active"`
	// LastScheduleTime is the last time the CronWorkflow was scheduled
	LastScheduledTime *metav1.Time `json:"lastScheduledTime" protobuf:"bytes,2,opt,name=lastScheduledTime"`
	// Conditions is a list of conditions the CronWorkflow may have
	Conditions Conditions `json:"conditions" protobuf:"bytes,3,rep,name=conditions"`
}

CronWorkflowStatus is the status of a CronWorkflow

func (*CronWorkflowStatus) DeepCopy

func (in *CronWorkflowStatus) DeepCopy() *CronWorkflowStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CronWorkflowStatus.

func (*CronWorkflowStatus) DeepCopyInto

func (in *CronWorkflowStatus) DeepCopyInto(out *CronWorkflowStatus)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*CronWorkflowStatus) Descriptor

func (*CronWorkflowStatus) Descriptor() ([]byte, []int)

func (*CronWorkflowStatus) HasActiveUID

func (c *CronWorkflowStatus) HasActiveUID(uid types.UID) bool

func (*CronWorkflowStatus) Marshal

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

func (*CronWorkflowStatus) MarshalTo

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

func (*CronWorkflowStatus) MarshalToSizedBuffer

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

func (*CronWorkflowStatus) ProtoMessage

func (*CronWorkflowStatus) ProtoMessage()

func (*CronWorkflowStatus) Reset

func (m *CronWorkflowStatus) Reset()

func (*CronWorkflowStatus) Size

func (m *CronWorkflowStatus) Size() (n int)

func (*CronWorkflowStatus) String

func (this *CronWorkflowStatus) String() string

func (*CronWorkflowStatus) Unmarshal

func (m *CronWorkflowStatus) Unmarshal(dAtA []byte) error

func (*CronWorkflowStatus) XXX_DiscardUnknown

func (m *CronWorkflowStatus) XXX_DiscardUnknown()

func (*CronWorkflowStatus) XXX_Marshal

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

func (*CronWorkflowStatus) XXX_Merge

func (m *CronWorkflowStatus) XXX_Merge(src proto.Message)

func (*CronWorkflowStatus) XXX_Size

func (m *CronWorkflowStatus) XXX_Size() int

func (*CronWorkflowStatus) XXX_Unmarshal

func (m *CronWorkflowStatus) XXX_Unmarshal(b []byte) error

type DAGTask

type DAGTask struct {
	// Name is the name of the target
	Name string `json:"name" protobuf:"bytes,1,opt,name=name"`

	// Name of template to execute
	Template string `json:"template,omitempty" protobuf:"bytes,2,opt,name=template"`

	// Arguments are the parameter and artifact arguments to the template
	Arguments Arguments `json:"arguments,omitempty" protobuf:"bytes,3,opt,name=arguments"`

	// TemplateRef is the reference to the template resource to execute.
	TemplateRef *TemplateRef `json:"templateRef,omitempty" protobuf:"bytes,4,opt,name=templateRef"`

	// Dependencies are name of other targets which this depends on
	Dependencies []string `json:"dependencies,omitempty" protobuf:"bytes,5,rep,name=dependencies"`

	// WithItems expands a task into multiple parallel tasks from the items in the list
	WithItems []Item `json:"withItems,omitempty" protobuf:"bytes,6,rep,name=withItems"`

	// WithParam expands a task into multiple parallel tasks from the value in the parameter,
	// which is expected to be a JSON list.
	WithParam string `json:"withParam,omitempty" protobuf:"bytes,7,opt,name=withParam"`

	// WithSequence expands a task into a numeric sequence
	WithSequence *Sequence `json:"withSequence,omitempty" protobuf:"bytes,8,opt,name=withSequence"`

	// When is an expression in which the task should conditionally execute
	When string `json:"when,omitempty" protobuf:"bytes,9,opt,name=when"`

	// ContinueOn makes argo to proceed with the following step even if this step fails.
	// Errors and Failed states can be specified
	ContinueOn *ContinueOn `json:"continueOn,omitempty" protobuf:"bytes,10,opt,name=continueOn"`

	// OnExit is a template reference which is invoked at the end of the
	// template, irrespective of the success, failure, or error of the
	// primary template.
	OnExit string `json:"onExit,omitempty" protobuf:"bytes,11,opt,name=onExit"`

	// Depends are name of other targets which this depends on
	Depends string `json:"depends,omitempty" protobuf:"bytes,12,opt,name=depends"`
}

DAGTask represents a node in the graph during DAG execution

func (*DAGTask) ContinuesOn

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

ContinuesOn returns whether the DAG should be proceeded if the task fails or errors.

func (*DAGTask) DeepCopy

func (in *DAGTask) DeepCopy() *DAGTask

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new DAGTask.

func (*DAGTask) DeepCopyInto

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*DAGTask) Descriptor

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

func (*DAGTask) GetTemplateName

func (t *DAGTask) GetTemplateName() string

func (*DAGTask) GetTemplateRef

func (t *DAGTask) GetTemplateRef() *TemplateRef

func (*DAGTask) Marshal

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

func (*DAGTask) MarshalTo

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

func (*DAGTask) MarshalToSizedBuffer

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

func (*DAGTask) ProtoMessage

func (*DAGTask) ProtoMessage()

func (*DAGTask) Reset

func (m *DAGTask) Reset()

func (*DAGTask) ShouldExpand

func (t *DAGTask) ShouldExpand() bool

func (*DAGTask) Size

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

func (*DAGTask) String

func (this *DAGTask) String() string

func (*DAGTask) Unmarshal

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

func (*DAGTask) XXX_DiscardUnknown

func (m *DAGTask) XXX_DiscardUnknown()

func (*DAGTask) XXX_Marshal

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

func (*DAGTask) XXX_Merge

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

func (*DAGTask) XXX_Size

func (m *DAGTask) XXX_Size() int

func (*DAGTask) XXX_Unmarshal

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

type DAGTemplate

type DAGTemplate struct {
	// Target are one or more names of targets to execute in a DAG
	Target string `json:"target,omitempty" protobuf:"bytes,1,opt,name=target"`

	// Tasks are a list of DAG tasks
	// +patchStrategy=merge
	// +patchMergeKey=name
	Tasks []DAGTask `json:"tasks" patchStrategy:"merge" patchMergeKey:"name" protobuf:"bytes,2,rep,name=tasks"`

	// This flag is for DAG logic. The DAG logic has a built-in "fail fast" feature to stop scheduling new steps,
	// as soon as it detects that one of the DAG nodes is failed. Then it waits until all DAG nodes are completed
	// before failing the DAG itself.
	// The FailFast flag default is true,  if set to false, it will allow a DAG to run all branches of the DAG to
	// completion (either success or failure), regardless of the failed outcomes of branches in the DAG.
	// More info and example about this feature at https://github.com/argoproj/argo/issues/1442
	FailFast *bool `json:"failFast,omitempty" protobuf:"varint,3,opt,name=failFast"`
}

DAGTemplate is a template subtype for directed acyclic graph templates

func (*DAGTemplate) DeepCopy

func (in *DAGTemplate) DeepCopy() *DAGTemplate

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new DAGTemplate.

func (*DAGTemplate) DeepCopyInto

func (in *DAGTemplate) DeepCopyInto(out *DAGTemplate)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*DAGTemplate) Descriptor

func (*DAGTemplate) Descriptor() ([]byte, []int)

func (*DAGTemplate) Marshal

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

func (*DAGTemplate) MarshalTo

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

func (*DAGTemplate) MarshalToSizedBuffer

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

func (*DAGTemplate) ProtoMessage

func (*DAGTemplate) ProtoMessage()

func (*DAGTemplate) Reset

func (m *DAGTemplate) Reset()

func (*DAGTemplate) Size

func (m *DAGTemplate) Size() (n int)

func (*DAGTemplate) String

func (this *DAGTemplate) String() string

func (*DAGTemplate) Unmarshal

func (m *DAGTemplate) Unmarshal(dAtA []byte) error

func (*DAGTemplate) XXX_DiscardUnknown

func (m *DAGTemplate) XXX_DiscardUnknown()

func (*DAGTemplate) XXX_Marshal

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

func (*DAGTemplate) XXX_Merge

func (m *DAGTemplate) XXX_Merge(src proto.Message)

func (*DAGTemplate) XXX_Size

func (m *DAGTemplate) XXX_Size() int

func (*DAGTemplate) XXX_Unmarshal

func (m *DAGTemplate) XXX_Unmarshal(b []byte) error

type EstimatedDuration

type EstimatedDuration int

EstimatedDuration is in seconds.

func NewEstimatedDuration

func NewEstimatedDuration(d time.Duration) EstimatedDuration

func (EstimatedDuration) ToDuration

func (d EstimatedDuration) ToDuration() time.Duration

type Event

type Event struct {
	// Selector (https://github.com/antonmedv/expr) that we must must match the event. E.g. `payload.message == "test"`
	Selector string `json:"selector" protobuf:"bytes,1,opt,name=selector"`
}

func (*Event) DeepCopy

func (in *Event) DeepCopy() *Event

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Event.

func (*Event) DeepCopyInto

func (in *Event) DeepCopyInto(out *Event)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*Event) Descriptor

func (*Event) Descriptor() ([]byte, []int)

func (*Event) Marshal

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

func (*Event) MarshalTo

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

func (*Event) MarshalToSizedBuffer

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

func (*Event) ProtoMessage

func (*Event) ProtoMessage()

func (*Event) Reset

func (m *Event) Reset()

func (*Event) Size

func (m *Event) Size() (n int)

func (*Event) String

func (this *Event) String() string

func (*Event) Unmarshal

func (m *Event) Unmarshal(dAtA []byte) error

func (*Event) XXX_DiscardUnknown

func (m *Event) XXX_DiscardUnknown()

func (*Event) XXX_Marshal

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

func (*Event) XXX_Merge

func (m *Event) XXX_Merge(src proto.Message)

func (*Event) XXX_Size

func (m *Event) XXX_Size() int

func (*Event) XXX_Unmarshal

func (m *Event) XXX_Unmarshal(b []byte) error

type ExecutorConfig

type ExecutorConfig struct {
	// ServiceAccountName specifies the service account name of the executor container.
	ServiceAccountName string `json:"serviceAccountName,omitempty" protobuf:"bytes,1,opt,name=serviceAccountName"`
}

ExecutorConfig holds configurations of an executor container.

func (*ExecutorConfig) DeepCopy

func (in *ExecutorConfig) DeepCopy() *ExecutorConfig

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ExecutorConfig.

func (*ExecutorConfig) DeepCopyInto

func (in *ExecutorConfig) DeepCopyInto(out *ExecutorConfig)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*ExecutorConfig) Descriptor

func (*ExecutorConfig) Descriptor() ([]byte, []int)

func (*ExecutorConfig) Marshal

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

func (*ExecutorConfig) MarshalTo

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

func (*ExecutorConfig) MarshalToSizedBuffer

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

func (*ExecutorConfig) ProtoMessage

func (*ExecutorConfig) ProtoMessage()

func (*ExecutorConfig) Reset

func (m *ExecutorConfig) Reset()

func (*ExecutorConfig) Size

func (m *ExecutorConfig) Size() (n int)

func (*ExecutorConfig) String

func (this *ExecutorConfig) String() string

func (*ExecutorConfig) Unmarshal

func (m *ExecutorConfig) Unmarshal(dAtA []byte) error

func (*ExecutorConfig) XXX_DiscardUnknown

func (m *ExecutorConfig) XXX_DiscardUnknown()

func (*ExecutorConfig) XXX_Marshal

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

func (*ExecutorConfig) XXX_Merge

func (m *ExecutorConfig) XXX_Merge(src proto.Message)

func (*ExecutorConfig) XXX_Size

func (m *ExecutorConfig) XXX_Size() int

func (*ExecutorConfig) XXX_Unmarshal

func (m *ExecutorConfig) XXX_Unmarshal(b []byte) error

type GCSArtifact

type GCSArtifact struct {
	GCSBucket `json:",inline" protobuf:"bytes,1,opt,name=gCSBucket"`

	// Key is the path in the bucket where the artifact resides
	Key string `json:"key" protobuf:"bytes,2,opt,name=key"`
}

GCSArtifact is the location of a GCS artifact

func (*GCSArtifact) DeepCopy

func (in *GCSArtifact) DeepCopy() *GCSArtifact

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new GCSArtifact.

func (*GCSArtifact) DeepCopyInto

func (in *GCSArtifact) DeepCopyInto(out *GCSArtifact)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*GCSArtifact) Descriptor

func (*GCSArtifact) Descriptor() ([]byte, []int)

func (*GCSArtifact) GetKey

func (g *GCSArtifact) GetKey() (string, error)

func (*GCSArtifact) HasLocation

func (g *GCSArtifact) HasLocation() bool

func (*GCSArtifact) Marshal

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

func (*GCSArtifact) MarshalTo

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

func (*GCSArtifact) MarshalToSizedBuffer

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

func (*GCSArtifact) ProtoMessage

func (*GCSArtifact) ProtoMessage()

func (*GCSArtifact) Reset

func (m *GCSArtifact) Reset()

func (*GCSArtifact) SetKey

func (g *GCSArtifact) SetKey(key string) error

func (*GCSArtifact) Size

func (m *GCSArtifact) Size() (n int)

func (*GCSArtifact) String

func (this *GCSArtifact) String() string

func (*GCSArtifact) Unmarshal

func (m *GCSArtifact) Unmarshal(dAtA []byte) error

func (*GCSArtifact) XXX_DiscardUnknown

func (m *GCSArtifact) XXX_DiscardUnknown()

func (*GCSArtifact) XXX_Marshal

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

func (*GCSArtifact) XXX_Merge

func (m *GCSArtifact) XXX_Merge(src proto.Message)

func (*GCSArtifact) XXX_Size

func (m *GCSArtifact) XXX_Size() int

func (*GCSArtifact) XXX_Unmarshal

func (m *GCSArtifact) XXX_Unmarshal(b []byte) error

type GCSBucket

type GCSBucket struct {

	// Bucket is the name of the bucket
	Bucket string `json:"bucket,omitempty" protobuf:"bytes,1,opt,name=bucket"`

	// ServiceAccountKeySecret is the secret selector to the bucket's service account key
	ServiceAccountKeySecret *apiv1.SecretKeySelector `json:"serviceAccountKeySecret,omitempty" protobuf:"bytes,2,opt,name=serviceAccountKeySecret"`
}

GCSBucket contains the access information for interfacring with a GCS bucket

func (*GCSBucket) DeepCopy

func (in *GCSBucket) DeepCopy() *GCSBucket

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new GCSBucket.

func (*GCSBucket) DeepCopyInto

func (in *GCSBucket) DeepCopyInto(out *GCSBucket)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*GCSBucket) Descriptor

func (*GCSBucket) Descriptor() ([]byte, []int)

func (*GCSBucket) Marshal

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

func (*GCSBucket) MarshalTo

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

func (*GCSBucket) MarshalToSizedBuffer

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

func (*GCSBucket) ProtoMessage

func (*GCSBucket) ProtoMessage()

func (*GCSBucket) Reset

func (m *GCSBucket) Reset()

func (*GCSBucket) Size

func (m *GCSBucket) Size() (n int)

func (*GCSBucket) String

func (this *GCSBucket) String() string

func (*GCSBucket) Unmarshal

func (m *GCSBucket) Unmarshal(dAtA []byte) error

func (*GCSBucket) XXX_DiscardUnknown

func (m *GCSBucket) XXX_DiscardUnknown()

func (*GCSBucket) XXX_Marshal

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

func (*GCSBucket) XXX_Merge

func (m *GCSBucket) XXX_Merge(src proto.Message)

func (*GCSBucket) XXX_Size

func (m *GCSBucket) XXX_Size() int

func (*GCSBucket) XXX_Unmarshal

func (m *GCSBucket) XXX_Unmarshal(b []byte) error

type Gauge

type Gauge struct {
	// Value is the value of the metric
	Value string `json:"value" protobuf:"bytes,1,opt,name=value"`
	// Realtime emits this metric in real time if applicable
	Realtime *bool `json:"realtime" protobuf:"varint,2,opt,name=realtime"`
}

Gauge is a Gauge prometheus metric

func (*Gauge) DeepCopy

func (in *Gauge) DeepCopy() *Gauge

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Gauge.

func (*Gauge) DeepCopyInto

func (in *Gauge) DeepCopyInto(out *Gauge)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*Gauge) Descriptor

func (*Gauge) Descriptor() ([]byte, []int)

func (*Gauge) Marshal

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

func (*Gauge) MarshalTo

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

func (*Gauge) MarshalToSizedBuffer

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

func (*Gauge) ProtoMessage

func (*Gauge) ProtoMessage()

func (*Gauge) Reset

func (m *Gauge) Reset()

func (*Gauge) Size

func (m *Gauge) Size() (n int)

func (*Gauge) String

func (this *Gauge) String() string

func (*Gauge) Unmarshal

func (m *Gauge) Unmarshal(dAtA []byte) error

func (*Gauge) XXX_DiscardUnknown

func (m *Gauge) XXX_DiscardUnknown()

func (*Gauge) XXX_Marshal

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

func (*Gauge) XXX_Merge

func (m *Gauge) XXX_Merge(src proto.Message)

func (*Gauge) XXX_Size

func (m *Gauge) XXX_Size() int

func (*Gauge) XXX_Unmarshal

func (m *Gauge) XXX_Unmarshal(b []byte) error

type GitArtifact

type GitArtifact struct {
	// Repo is the git repository
	Repo string `json:"repo" protobuf:"bytes,1,opt,name=repo"`

	// Revision is the git commit, tag, branch to checkout
	Revision string `json:"revision,omitempty" protobuf:"bytes,2,opt,name=revision"`

	// Depth specifies clones/fetches should be shallow and include the given
	// number of commits from the branch tip
	Depth *uint64 `json:"depth,omitempty" protobuf:"bytes,3,opt,name=depth"`

	// Fetch specifies a number of refs that should be fetched before checkout
	Fetch []string `json:"fetch,omitempty" protobuf:"bytes,4,rep,name=fetch"`

	// UsernameSecret is the secret selector to the repository username
	UsernameSecret *apiv1.SecretKeySelector `json:"usernameSecret,omitempty" protobuf:"bytes,5,opt,name=usernameSecret"`

	// PasswordSecret is the secret selector to the repository password
	PasswordSecret *apiv1.SecretKeySelector `json:"passwordSecret,omitempty" protobuf:"bytes,6,opt,name=passwordSecret"`

	// SSHPrivateKeySecret is the secret selector to the repository ssh private key
	SSHPrivateKeySecret *apiv1.SecretKeySelector `json:"sshPrivateKeySecret,omitempty" protobuf:"bytes,7,opt,name=sshPrivateKeySecret"`

	// InsecureIgnoreHostKey disables SSH strict host key checking during git clone
	InsecureIgnoreHostKey bool `json:"insecureIgnoreHostKey,omitempty" protobuf:"varint,8,opt,name=insecureIgnoreHostKey"`
}

GitArtifact is the location of an git artifact

func (*GitArtifact) DeepCopy

func (in *GitArtifact) DeepCopy() *GitArtifact

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new GitArtifact.

func (*GitArtifact) DeepCopyInto

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*GitArtifact) Descriptor

func (*GitArtifact) Descriptor() ([]byte, []int)

func (*GitArtifact) GetDepth

func (g *GitArtifact) GetDepth() int

func (*GitArtifact) GetKey

func (g *GitArtifact) GetKey() (string, error)

func (*GitArtifact) HasLocation

func (g *GitArtifact) HasLocation() bool

func (*GitArtifact) Marshal

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

func (*GitArtifact) MarshalTo

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

func (*GitArtifact) MarshalToSizedBuffer

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

func (*GitArtifact) ProtoMessage

func (*GitArtifact) ProtoMessage()

func (*GitArtifact) Reset

func (m *GitArtifact) Reset()

func (*GitArtifact) SetKey

func (g *GitArtifact) SetKey(string) error

func (*GitArtifact) Size

func (m *GitArtifact) Size() (n int)

func (*GitArtifact) String

func (this *GitArtifact) String() string

func (*GitArtifact) Unmarshal

func (m *GitArtifact) Unmarshal(dAtA []byte) error

func (*GitArtifact) XXX_DiscardUnknown

func (m *GitArtifact) XXX_DiscardUnknown()

func (*GitArtifact) XXX_Marshal

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

func (*GitArtifact) XXX_Merge

func (m *GitArtifact) XXX_Merge(src proto.Message)

func (*GitArtifact) XXX_Size

func (m *GitArtifact) XXX_Size() int

func (*GitArtifact) XXX_Unmarshal

func (m *GitArtifact) XXX_Unmarshal(b []byte) error

type HDFSArtifact

type HDFSArtifact struct {
	HDFSConfig `json:",inline" protobuf:"bytes,1,opt,name=hDFSConfig"`

	// Path is a file path in HDFS
	Path string `json:"path" protobuf:"bytes,2,opt,name=path"`

	// Force copies a file forcibly even if it exists (default: false)
	Force bool `json:"force,omitempty" protobuf:"varint,3,opt,name=force"`
}

HDFSArtifact is the location of an HDFS artifact

func (*HDFSArtifact) DeepCopy

func (in *HDFSArtifact) DeepCopy() *HDFSArtifact

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new HDFSArtifact.

func (*HDFSArtifact) DeepCopyInto

func (in *HDFSArtifact) DeepCopyInto(out *HDFSArtifact)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*HDFSArtifact) Descriptor

func (*HDFSArtifact) Descriptor() ([]byte, []int)

func (*HDFSArtifact) GetKey

func (h *HDFSArtifact) GetKey() (string, error)

func (*HDFSArtifact) HasLocation

func (h *HDFSArtifact) HasLocation() bool

func (*HDFSArtifact) Marshal

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

func (*HDFSArtifact) MarshalTo

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

func (*HDFSArtifact) MarshalToSizedBuffer

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

func (*HDFSArtifact) ProtoMessage

func (*HDFSArtifact) ProtoMessage()

func (*HDFSArtifact) Reset

func (m *HDFSArtifact) Reset()

func (*HDFSArtifact) SetKey

func (g *HDFSArtifact) SetKey(key string) error

func (*HDFSArtifact) Size

func (m *HDFSArtifact) Size() (n int)

func (*HDFSArtifact) String

func (this *HDFSArtifact) String() string

func (*HDFSArtifact) Unmarshal

func (m *HDFSArtifact) Unmarshal(dAtA []byte) error

func (*HDFSArtifact) XXX_DiscardUnknown

func (m *HDFSArtifact) XXX_DiscardUnknown()

func (*HDFSArtifact) XXX_Marshal

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

func (*HDFSArtifact) XXX_Merge

func (m *HDFSArtifact) XXX_Merge(src proto.Message)

func (*HDFSArtifact) XXX_Size

func (m *HDFSArtifact) XXX_Size() int

func (*HDFSArtifact) XXX_Unmarshal

func (m *HDFSArtifact) XXX_Unmarshal(b []byte) error

type HDFSConfig

type HDFSConfig struct {
	HDFSKrbConfig `json:",inline" protobuf:"bytes,1,opt,name=hDFSKrbConfig"`

	// Addresses is accessible addresses of HDFS name nodes
	Addresses []string `json:"addresses,omitempty" protobuf:"bytes,2,rep,name=addresses"`

	// HDFSUser is the user to access HDFS file system.
	// It is ignored if either ccache or keytab is used.
	HDFSUser string `json:"hdfsUser,omitempty" protobuf:"bytes,3,opt,name=hdfsUser"`
}

HDFSConfig is configurations for HDFS

func (*HDFSConfig) DeepCopy

func (in *HDFSConfig) DeepCopy() *HDFSConfig

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new HDFSConfig.

func (*HDFSConfig) DeepCopyInto

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*HDFSConfig) Descriptor

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

func (*HDFSConfig) Marshal

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

func (*HDFSConfig) MarshalTo

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

func (*HDFSConfig) MarshalToSizedBuffer

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

func (*HDFSConfig) ProtoMessage

func (*HDFSConfig) ProtoMessage()

func (*HDFSConfig) Reset

func (m *HDFSConfig) Reset()

func (*HDFSConfig) Size

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

func (*HDFSConfig) String

func (this *HDFSConfig) String() string

func (*HDFSConfig) Unmarshal

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

func (*HDFSConfig) XXX_DiscardUnknown

func (m *HDFSConfig) XXX_DiscardUnknown()

func (*HDFSConfig) XXX_Marshal

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

func (*HDFSConfig) XXX_Merge

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

func (*HDFSConfig) XXX_Size

func (m *HDFSConfig) XXX_Size() int

func (*HDFSConfig) XXX_Unmarshal

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

type HDFSKrbConfig

type HDFSKrbConfig struct {
	// KrbCCacheSecret is the secret selector for Kerberos ccache
	// Either ccache or keytab can be set to use Kerberos.
	KrbCCacheSecret *apiv1.SecretKeySelector `json:"krbCCacheSecret,omitempty" protobuf:"bytes,1,opt,name=krbCCacheSecret"`

	// KrbKeytabSecret is the secret selector for Kerberos keytab
	// Either ccache or keytab can be set to use Kerberos.
	KrbKeytabSecret *apiv1.SecretKeySelector `json:"krbKeytabSecret,omitempty" protobuf:"bytes,2,opt,name=krbKeytabSecret"`

	// KrbUsername is the Kerberos username used with Kerberos keytab
	// It must be set if keytab is used.
	KrbUsername string `json:"krbUsername,omitempty" protobuf:"bytes,3,opt,name=krbUsername"`

	// KrbRealm is the Kerberos realm used with Kerberos keytab
	// It must be set if keytab is used.
	KrbRealm string `json:"krbRealm,omitempty" protobuf:"bytes,4,opt,name=krbRealm"`

	// KrbConfig is the configmap selector for Kerberos config as string
	// It must be set if either ccache or keytab is used.
	KrbConfigConfigMap *apiv1.ConfigMapKeySelector `json:"krbConfigConfigMap,omitempty" protobuf:"bytes,5,opt,name=krbConfigConfigMap"`

	// KrbServicePrincipalName is the principal name of Kerberos service
	// It must be set if either ccache or keytab is used.
	KrbServicePrincipalName string `json:"krbServicePrincipalName,omitempty" protobuf:"bytes,6,opt,name=krbServicePrincipalName"`
}

HDFSKrbConfig is auth configurations for Kerberos

func (*HDFSKrbConfig) DeepCopy

func (in *HDFSKrbConfig) DeepCopy() *HDFSKrbConfig

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new HDFSKrbConfig.

func (*HDFSKrbConfig) DeepCopyInto

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*HDFSKrbConfig) Descriptor

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

func (*HDFSKrbConfig) Marshal

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

func (*HDFSKrbConfig) MarshalTo

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

func (*HDFSKrbConfig) MarshalToSizedBuffer

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

func (*HDFSKrbConfig) ProtoMessage

func (*HDFSKrbConfig) ProtoMessage()

func (*HDFSKrbConfig) Reset

func (m *HDFSKrbConfig) Reset()

func (*HDFSKrbConfig) Size

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

func (*HDFSKrbConfig) String

func (this *HDFSKrbConfig) String() string

func (*HDFSKrbConfig) Unmarshal

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

func (*HDFSKrbConfig) XXX_DiscardUnknown

func (m *HDFSKrbConfig) XXX_DiscardUnknown()

func (*HDFSKrbConfig) XXX_Marshal

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

func (*HDFSKrbConfig) XXX_Merge

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

func (*HDFSKrbConfig) XXX_Size

func (m *HDFSKrbConfig) XXX_Size() int

func (*HDFSKrbConfig) XXX_Unmarshal

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

type HTTPArtifact

type HTTPArtifact struct {
	// URL of the artifact
	URL string `json:"url" protobuf:"bytes,1,opt,name=url"`

	// Headers are an optional list of headers to send with HTTP requests for artifacts
	Headers []Header `json:"headers,omitempty" protobuf:"bytes,2,opt,name=headers"`
}

HTTPArtifact allows an file served on HTTP to be placed as an input artifact in a container

func (*HTTPArtifact) DeepCopy

func (in *HTTPArtifact) DeepCopy() *HTTPArtifact

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new HTTPArtifact.

func (*HTTPArtifact) DeepCopyInto

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*HTTPArtifact) Descriptor

func (*HTTPArtifact) Descriptor() ([]byte, []int)

func (*HTTPArtifact) GetKey

func (h *HTTPArtifact) GetKey() (string, error)

func (*HTTPArtifact) HasLocation

func (h *HTTPArtifact) HasLocation() bool

func (*HTTPArtifact) Marshal

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

func (*HTTPArtifact) MarshalTo

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

func (*HTTPArtifact) MarshalToSizedBuffer

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

func (*HTTPArtifact) ProtoMessage

func (*HTTPArtifact) ProtoMessage()

func (*HTTPArtifact) Reset

func (m *HTTPArtifact) Reset()

func (*HTTPArtifact) SetKey

func (g *HTTPArtifact) SetKey(key string) error

func (*HTTPArtifact) Size

func (m *HTTPArtifact) Size() (n int)

func (*HTTPArtifact) String

func (this *HTTPArtifact) String() string

func (*HTTPArtifact) Unmarshal

func (m *HTTPArtifact) Unmarshal(dAtA []byte) error

func (*HTTPArtifact) XXX_DiscardUnknown

func (m *HTTPArtifact) XXX_DiscardUnknown()

func (*HTTPArtifact) XXX_Marshal

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

func (*HTTPArtifact) XXX_Merge

func (m *HTTPArtifact) XXX_Merge(src proto.Message)

func (*HTTPArtifact) XXX_Size

func (m *HTTPArtifact) XXX_Size() int

func (*HTTPArtifact) XXX_Unmarshal

func (m *HTTPArtifact) XXX_Unmarshal(b []byte) error
type Header struct {
	// Name is the header name
	Name string `json:"name" protobuf:"bytes,1,opt,name=name"`

	// Value is the literal value to use for the header
	Value string `json:"value" protobuf:"bytes,2,opt,name=value"`
}

Header indicate a key-value request header to be used when fetching artifacts over HTTP

func (*Header) DeepCopy

func (in *Header) DeepCopy() *Header

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Header.

func (*Header) DeepCopyInto

func (in *Header) DeepCopyInto(out *Header)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*Header) Descriptor

func (*Header) Descriptor() ([]byte, []int)

func (*Header) Marshal

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

func (*Header) MarshalTo

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

func (*Header) MarshalToSizedBuffer

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

func (*Header) ProtoMessage

func (*Header) ProtoMessage()

func (*Header) Reset

func (m *Header) Reset()

func (*Header) Size

func (m *Header) Size() (n int)

func (*Header) String

func (this *Header) String() string

func (*Header) Unmarshal

func (m *Header) Unmarshal(dAtA []byte) error

func (*Header) XXX_DiscardUnknown

func (m *Header) XXX_DiscardUnknown()

func (*Header) XXX_Marshal

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

func (*Header) XXX_Merge

func (m *Header) XXX_Merge(src proto.Message)

func (*Header) XXX_Size

func (m *Header) XXX_Size() int

func (*Header) XXX_Unmarshal

func (m *Header) XXX_Unmarshal(b []byte) error

type Histogram

type Histogram struct {
	// Value is the value of the metric
	Value string `json:"value" protobuf:"bytes,3,opt,name=value"`
	// Buckets is a list of bucket divisors for the histogram
	Buckets []Amount `json:"buckets" protobuf:"bytes,4,rep,name=buckets"`
}

Histogram is a Histogram prometheus metric

func (*Histogram) DeepCopy

func (in *Histogram) DeepCopy() *Histogram

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Histogram.

func (*Histogram) DeepCopyInto

func (in *Histogram) DeepCopyInto(out *Histogram)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*Histogram) Descriptor

func (*Histogram) Descriptor() ([]byte, []int)

func (*Histogram) GetBuckets

func (in *Histogram) GetBuckets() []float64

func (*Histogram) Marshal

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

func (*Histogram) MarshalTo

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

func (*Histogram) MarshalToSizedBuffer

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

func (*Histogram) ProtoMessage

func (*Histogram) ProtoMessage()

func (*Histogram) Reset

func (m *Histogram) Reset()

func (*Histogram) Size

func (m *Histogram) Size() (n int)

func (*Histogram) String

func (this *Histogram) String() string

func (*Histogram) Unmarshal

func (m *Histogram) Unmarshal(dAtA []byte) error

func (*Histogram) XXX_DiscardUnknown

func (m *Histogram) XXX_DiscardUnknown()

func (*Histogram) XXX_Marshal

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

func (*Histogram) XXX_Merge

func (m *Histogram) XXX_Merge(src proto.Message)

func (*Histogram) XXX_Size

func (m *Histogram) XXX_Size() int

func (*Histogram) XXX_Unmarshal

func (m *Histogram) XXX_Unmarshal(b []byte) error

type Inputs

type Inputs struct {
	// Parameters are a list of parameters passed as inputs
	// +patchStrategy=merge
	// +patchMergeKey=name
	Parameters []Parameter `json:"parameters,omitempty" patchStrategy:"merge" patchMergeKey:"name" protobuf:"bytes,1,opt,name=parameters"`

	// Artifact are a list of artifacts passed as inputs
	// +patchStrategy=merge
	// +patchMergeKey=name
	Artifacts Artifacts `json:"artifacts,omitempty" patchStrategy:"merge" patchMergeKey:"name" protobuf:"bytes,2,opt,name=artifacts"`
}

Inputs are the mechanism for passing parameters, artifacts, volumes from one template to another

func (*Inputs) DeepCopy

func (in *Inputs) DeepCopy() *Inputs

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Inputs.

func (*Inputs) DeepCopyInto

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*Inputs) Descriptor

func (*Inputs) Descriptor() ([]byte, []int)

func (*Inputs) GetArtifactByName

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

GetArtifactByName returns an input artifact by its name

func (*Inputs) GetParameterByName

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

GetParameterByName returns an input parameter by its name

func (*Inputs) HasInputs

func (in *Inputs) HasInputs() bool

HasInputs returns whether or not there are any inputs

func (Inputs) IsEmpty

func (in Inputs) IsEmpty() bool

func (*Inputs) Marshal

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

func (*Inputs) MarshalTo

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

func (*Inputs) MarshalToSizedBuffer

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

func (*Inputs) ProtoMessage

func (*Inputs) ProtoMessage()

func (*Inputs) Reset

func (m *Inputs) Reset()

func (*Inputs) Size

func (m *Inputs) Size() (n int)

func (*Inputs) String

func (this *Inputs) String() string

func (*Inputs) Unmarshal

func (m *Inputs) Unmarshal(dAtA []byte) error

func (*Inputs) XXX_DiscardUnknown

func (m *Inputs) XXX_DiscardUnknown()

func (*Inputs) XXX_Marshal

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

func (*Inputs) XXX_Merge

func (m *Inputs) XXX_Merge(src proto.Message)

func (*Inputs) XXX_Size

func (m *Inputs) XXX_Size() int

func (*Inputs) XXX_Unmarshal

func (m *Inputs) XXX_Unmarshal(b []byte) error

type Item

type Item struct {
	Value json.RawMessage `json:"-" protobuf:"bytes,1,opt,name=value,casttype=encoding/json.RawMessage"`
}

Item expands a single workflow step into multiple parallel steps The value of Item can be a map, string, bool, or number

+protobuf.options.(gogoproto.goproto_stringer)=false +kubebuilder:validation:Type=object

func ParseItem

func ParseItem(s string) (Item, error)

func (*Item) DeepCopy

func (in *Item) DeepCopy() *Item

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Item.

func (*Item) DeepCopyInto

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

func (*Item) Descriptor

func (*Item) Descriptor() ([]byte, []int)

func (Item) Format

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

func (*Item) GetListVal

func (i *Item) GetListVal() []Item

you MUST assert `GetType() == List` before invocation as this does not return errors

func (*Item) GetMapVal

func (i *Item) GetMapVal() map[string]Item

you MUST assert `GetType() == Map` before invocation as this does not return errors

func (*Item) GetStrVal

func (i *Item) GetStrVal() string

you MUST assert `GetType() == String` before invocation as this does not return errors

func (*Item) GetType

func (i *Item) GetType() Type

func (*Item) Marshal

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

func (Item) MarshalJSON

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

func (*Item) MarshalTo

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

func (*Item) MarshalToSizedBuffer

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

func (Item) OpenAPISchemaFormat

func (i Item) OpenAPISchemaFormat() string

func (*Item) ProtoMessage

func (*Item) ProtoMessage()

func (*Item) Reset

func (m *Item) Reset()

func (*Item) Size

func (m *Item) Size() (n int)

func (*Item) String

func (i *Item) String() string

func (*Item) Unmarshal

func (m *Item) Unmarshal(dAtA []byte) error

func (*Item) UnmarshalJSON

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

func (*Item) XXX_DiscardUnknown

func (m *Item) XXX_DiscardUnknown()

func (*Item) XXX_Marshal

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

func (*Item) XXX_Merge

func (m *Item) XXX_Merge(src proto.Message)

func (*Item) XXX_Size

func (m *Item) XXX_Size() int

func (*Item) XXX_Unmarshal

func (m *Item) XXX_Unmarshal(b []byte) error
type Link struct {
	// The name of the link, E.g. "Workflow Logs" or "Pod Logs"
	Name string `json:"name" protobuf:"bytes,1,opt,name=name"`
	// Either "workflow" or "pod"
	Scope string `json:"scope" protobuf:"bytes,2,opt,name=scope"`
	// The URL. May contain "${metadata.namespace}", "${metadata.name}", "${status.startedAt}" and "${status.finishedAt}".
	URL string `json:"url" protobuf:"bytes,3,opt,name=url"`
}

A link to another app. +patchStrategy=merge +patchMergeKey=name

func (*Link) DeepCopy

func (in *Link) DeepCopy() *Link

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Link.

func (*Link) DeepCopyInto

func (in *Link) DeepCopyInto(out *Link)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*Link) Descriptor

func (*Link) Descriptor() ([]byte, []int)

func (*Link) Marshal

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

func (*Link) MarshalTo

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

func (*Link) MarshalToSizedBuffer

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

func (*Link) ProtoMessage

func (*Link) ProtoMessage()

func (*Link) Reset

func (m *Link) Reset()

func (*Link) Size

func (m *Link) Size() (n int)

func (*Link) String

func (this *Link) String() string

func (*Link) Unmarshal

func (m *Link) Unmarshal(dAtA []byte) error

func (*Link) XXX_DiscardUnknown

func (m *Link) XXX_DiscardUnknown()

func (*Link) XXX_Marshal

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

func (*Link) XXX_Merge

func (m *Link) XXX_Merge(src proto.Message)

func (*Link) XXX_Size

func (m *Link) XXX_Size() int

func (*Link) XXX_Unmarshal

func (m *Link) XXX_Unmarshal(b []byte) error

type MemoizationStatus

type MemoizationStatus struct {
	// Hit indicates whether this node was created from a cache entry
	Hit bool `json:"hit" protobuf:"bytes,1,opt,name=hit"`
	// Key is the name of the key used for this node's cache
	Key string `json:"key" protobuf:"bytes,2,opt,name=key"`
	// Cache is the name of the cache that was used
	CacheName string `json:"cacheName" protobuf:"bytes,3,opt,name=cacheName"`
}

MemoizationStatus is the status of this memoized node

func (*MemoizationStatus) DeepCopy

func (in *MemoizationStatus) DeepCopy() *MemoizationStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new MemoizationStatus.

func (*MemoizationStatus) DeepCopyInto

func (in *MemoizationStatus) DeepCopyInto(out *MemoizationStatus)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*MemoizationStatus) Descriptor

func (*MemoizationStatus) Descriptor() ([]byte, []int)

func (*MemoizationStatus) Marshal

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

func (*MemoizationStatus) MarshalTo

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

func (*MemoizationStatus) MarshalToSizedBuffer

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

func (*MemoizationStatus) ProtoMessage

func (*MemoizationStatus) ProtoMessage()

func (*MemoizationStatus) Reset

func (m *MemoizationStatus) Reset()

func (*MemoizationStatus) Size

func (m *MemoizationStatus) Size() (n int)

func (*MemoizationStatus) String

func (this *MemoizationStatus) String() string

func (*MemoizationStatus) Unmarshal

func (m *MemoizationStatus) Unmarshal(dAtA []byte) error

func (*MemoizationStatus) XXX_DiscardUnknown

func (m *MemoizationStatus) XXX_DiscardUnknown()

func (*MemoizationStatus) XXX_Marshal

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

func (*MemoizationStatus) XXX_Merge

func (m *MemoizationStatus) XXX_Merge(src proto.Message)

func (*MemoizationStatus) XXX_Size

func (m *MemoizationStatus) XXX_Size() int

func (*MemoizationStatus) XXX_Unmarshal

func (m *MemoizationStatus) XXX_Unmarshal(b []byte) error

type Memoize

type Memoize struct {
	// Key is the key to use as the caching key
	Key string `json:"key" protobuf:"bytes,1,opt,name=key"`
	// Cache sets and configures the kind of cache
	Cache *Cache `json:"cache" protobuf:"bytes,2,opt,name=cache"`
	// MaxAge is the maximum age (e.g. "180s", "24h") of an entry that is still considered valid. If an entry is older
	// than the MaxAge, it will be ignored.
	MaxAge string `json:"maxAge" protobuf:"bytes,3,opt,name=maxAge"`
}

Memoization enables caching for the Outputs of the template

func (*Memoize) DeepCopy

func (in *Memoize) DeepCopy() *Memoize

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Memoize.

func (*Memoize) DeepCopyInto

func (in *Memoize) DeepCopyInto(out *Memoize)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*Memoize) Descriptor

func (*Memoize) Descriptor() ([]byte, []int)

func (*Memoize) Marshal

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

func (*Memoize) MarshalTo

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

func (*Memoize) MarshalToSizedBuffer

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

func (*Memoize) ProtoMessage

func (*Memoize) ProtoMessage()

func (*Memoize) Reset

func (m *Memoize) Reset()

func (*Memoize) Size

func (m *Memoize) Size() (n int)

func (*Memoize) String

func (this *Memoize) String() string

func (*Memoize) Unmarshal

func (m *Memoize) Unmarshal(dAtA []byte) error

func (*Memoize) XXX_DiscardUnknown

func (m *Memoize) XXX_DiscardUnknown()

func (*Memoize) XXX_Marshal

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

func (*Memoize) XXX_Merge

func (m *Memoize) XXX_Merge(src proto.Message)

func (*Memoize) XXX_Size

func (m *Memoize) XXX_Size() int

func (*Memoize) XXX_Unmarshal

func (m *Memoize) XXX_Unmarshal(b []byte) error

type Metadata

type Metadata struct {
	Annotations map[string]string `json:"annotations,omitempty" protobuf:"bytes,1,opt,name=annotations"`
	Labels      map[string]string `json:"labels,omitempty" protobuf:"bytes,2,opt,name=labels"`
}

Pod metdata

func (*Metadata) DeepCopy

func (in *Metadata) DeepCopy() *Metadata

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Metadata.

func (*Metadata) DeepCopyInto

func (in *Metadata) DeepCopyInto(out *Metadata)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*Metadata) Descriptor

func (*Metadata) Descriptor() ([]byte, []int)

func (*Metadata) Marshal

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

func (*Metadata) MarshalTo

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

func (*Metadata) MarshalToSizedBuffer

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

func (*Metadata) ProtoMessage

func (*Metadata) ProtoMessage()

func (*Metadata) Reset

func (m *Metadata) Reset()

func (*Metadata) Size

func (m *Metadata) Size() (n int)

func (*Metadata) String

func (this *Metadata) String() string

func (*Metadata) Unmarshal

func (m *Metadata) Unmarshal(dAtA []byte) error

func (*Metadata) XXX_DiscardUnknown

func (m *Metadata) XXX_DiscardUnknown()

func (*Metadata) XXX_Marshal

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

func (*Metadata) XXX_Merge

func (m *Metadata) XXX_Merge(src proto.Message)

func (*Metadata) XXX_Size

func (m *Metadata) XXX_Size() int

func (*Metadata) XXX_Unmarshal

func (m *Metadata) XXX_Unmarshal(b []byte) error

type MetricLabel

type MetricLabel struct {
	Key   string `json:"key" protobuf:"bytes,1,opt,name=key"`
	Value string `json:"value" protobuf:"bytes,2,opt,name=value"`
}

MetricLabel is a single label for a prometheus metric

func (*MetricLabel) DeepCopy

func (in *MetricLabel) DeepCopy() *MetricLabel

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new MetricLabel.

func (*MetricLabel) DeepCopyInto

func (in *MetricLabel) DeepCopyInto(out *MetricLabel)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*MetricLabel) Descriptor

func (*MetricLabel) Descriptor() ([]byte, []int)

func (*MetricLabel) Marshal

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

func (*MetricLabel) MarshalTo

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

func (*MetricLabel) MarshalToSizedBuffer

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

func (*MetricLabel) ProtoMessage

func (*MetricLabel) ProtoMessage()

func (*MetricLabel) Reset

func (m *MetricLabel) Reset()

func (*MetricLabel) Size

func (m *MetricLabel) Size() (n int)

func (*MetricLabel) String

func (this *MetricLabel) String() string

func (*MetricLabel) Unmarshal

func (m *MetricLabel) Unmarshal(dAtA []byte) error

func (*MetricLabel) XXX_DiscardUnknown

func (m *MetricLabel) XXX_DiscardUnknown()

func (*MetricLabel) XXX_Marshal

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

func (*MetricLabel) XXX_Merge

func (m *MetricLabel) XXX_Merge(src proto.Message)

func (*MetricLabel) XXX_Size

func (m *MetricLabel) XXX_Size() int

func (*MetricLabel) XXX_Unmarshal

func (m *MetricLabel) XXX_Unmarshal(b []byte) error

type MetricType

type MetricType string
const (
	MetricTypeGauge     MetricType = "Gauge"
	MetricTypeHistogram MetricType = "Histogram"
	MetricTypeCounter   MetricType = "Counter"
	MetricTypeUnknown   MetricType = "Unknown"
)

type Metrics

type Metrics struct {
	// Prometheus is a list of prometheus metrics to be emitted
	Prometheus []*Prometheus `json:"prometheus" protobuf:"bytes,1,rep,name=prometheus"`
}

Metrics are a list of metrics emitted from a Workflow/Template

func (*Metrics) DeepCopy

func (in *Metrics) DeepCopy() *Metrics

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Metrics.

func (*Metrics) DeepCopyInto

func (in *Metrics) DeepCopyInto(out *Metrics)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*Metrics) Descriptor

func (*Metrics) Descriptor() ([]byte, []int)

func (*Metrics) Marshal

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

func (*Metrics) MarshalTo

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

func (*Metrics) MarshalToSizedBuffer

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

func (*Metrics) ProtoMessage

func (*Metrics) ProtoMessage()

func (*Metrics) Reset

func (m *Metrics) Reset()

func (*Metrics) Size

func (m *Metrics) Size() (n int)

func (*Metrics) String

func (this *Metrics) String() string

func (*Metrics) Unmarshal

func (m *Metrics) Unmarshal(dAtA []byte) error

func (*Metrics) XXX_DiscardUnknown

func (m *Metrics) XXX_DiscardUnknown()

func (*Metrics) XXX_Marshal

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

func (*Metrics) XXX_Merge

func (m *Metrics) XXX_Merge(src proto.Message)

func (*Metrics) XXX_Size

func (m *Metrics) XXX_Size() int

func (*Metrics) XXX_Unmarshal

func (m *Metrics) XXX_Unmarshal(b []byte) error

type Mutex

type Mutex struct {
	// name of the mutex
	Name string `json:"name,omitempty" protobuf:"bytes,1,opt,name=name"`
}

Mutex holds Mutex configuration

func (*Mutex) DeepCopy

func (in *Mutex) DeepCopy() *Mutex

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Mutex.

func (*Mutex) DeepCopyInto

func (in *Mutex) DeepCopyInto(out *Mutex)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*Mutex) Descriptor

func (*Mutex) Descriptor() ([]byte, []int)

func (*Mutex) Marshal

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

func (*Mutex) MarshalTo

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

func (*Mutex) MarshalToSizedBuffer

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

func (*Mutex) ProtoMessage

func (*Mutex) ProtoMessage()

func (*Mutex) Reset

func (m *Mutex) Reset()

func (*Mutex) Size

func (m *Mutex) Size() (n int)

func (*Mutex) String

func (this *Mutex) String() string

func (*Mutex) Unmarshal

func (m *Mutex) Unmarshal(dAtA []byte) error

func (*Mutex) XXX_DiscardUnknown

func (m *Mutex) XXX_DiscardUnknown()

func (*Mutex) XXX_Marshal

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

func (*Mutex) XXX_Merge

func (m *Mutex) XXX_Merge(src proto.Message)

func (*Mutex) XXX_Size

func (m *Mutex) XXX_Size() int

func (*Mutex) XXX_Unmarshal

func (m *Mutex) XXX_Unmarshal(b []byte) error

type MutexHolding

type MutexHolding struct {
	// Reference for the mutex
	// e.g: ${namespace}/mutex/${mutexName}
	Mutex string `json:"mutex,omitempty" protobuf:"bytes,1,opt,name=mutex"`
	// Holder is a reference to the object which holds the Mutex.
	// Holding Scenario:
	//   1. Current workflow's NodeID which is holding the lock.
	//      e.g: ${NodeID}
	// Waiting Scenario:
	//   1. Current workflow or other workflow NodeID which is holding the lock.
	//      e.g: ${WorkflowName}/${NodeID}
	Holder string `json:"holder,omitempty" protobuf:"bytes,2,opt,name=holder"`
}

MutexHolding describes the mutex and the object which is holding it.

func (*MutexHolding) DeepCopy

func (in *MutexHolding) DeepCopy() *MutexHolding

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new MutexHolding.

func (*MutexHolding) DeepCopyInto

func (in *MutexHolding) DeepCopyInto(out *MutexHolding)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*MutexHolding) Descriptor

func (*MutexHolding) Descriptor() ([]byte, []int)

func (*MutexHolding) Marshal

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

func (*MutexHolding) MarshalTo

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

func (*MutexHolding) MarshalToSizedBuffer

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

func (*MutexHolding) ProtoMessage

func (*MutexHolding) ProtoMessage()

func (*MutexHolding) Reset

func (m *MutexHolding) Reset()

func (*MutexHolding) Size

func (m *MutexHolding) Size() (n int)

func (*MutexHolding) String

func (this *MutexHolding) String() string

func (*MutexHolding) Unmarshal

func (m *MutexHolding) Unmarshal(dAtA []byte) error

func (*MutexHolding) XXX_DiscardUnknown

func (m *MutexHolding) XXX_DiscardUnknown()

func (*MutexHolding) XXX_Marshal

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

func (*MutexHolding) XXX_Merge

func (m *MutexHolding) XXX_Merge(src proto.Message)

func (*MutexHolding) XXX_Size

func (m *MutexHolding) XXX_Size() int

func (*MutexHolding) XXX_Unmarshal

func (m *MutexHolding) XXX_Unmarshal(b []byte) error

type MutexStatus

type MutexStatus struct {
	// Holding is a list of mutexes and their respective objects that are held by mutex lock for this workflow.
	// +listType=atomic
	Holding []MutexHolding `json:"holding,omitempty" protobuf:"bytes,1,opt,name=holding"`
	// Waiting is a list of mutexes and their respective objects this workflow is waiting for.
	// +listType=atomic
	Waiting []MutexHolding `json:"waiting,omitempty" protobuf:"bytes,2,opt,name=waiting"`
}

MutexStatus contains which objects hold mutex locks, and which objects this workflow is waiting on to release locks.

func (*MutexStatus) DeepCopy

func (in *MutexStatus) DeepCopy() *MutexStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new MutexStatus.

func (*MutexStatus) DeepCopyInto

func (in *MutexStatus) DeepCopyInto(out *MutexStatus)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*MutexStatus) Descriptor

func (*MutexStatus) Descriptor() ([]byte, []int)

func (*MutexStatus) GetHolding

func (ms *MutexStatus) GetHolding(mutexName string) (int, MutexHolding)

func (*MutexStatus) GetWaiting

func (ms *MutexStatus) GetWaiting(mutexName string) (int, MutexHolding)

func (*MutexStatus) LockAcquired

func (ms *MutexStatus) LockAcquired(holderKey, lockKey string, currentHolders []string) bool

func (*MutexStatus) LockReleased

func (ms *MutexStatus) LockReleased(holderKey, lockKey string) bool

func (*MutexStatus) LockWaiting

func (ms *MutexStatus) LockWaiting(holderKey, lockKey string, currentHolders []string) bool

func (*MutexStatus) Marshal

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

func (*MutexStatus) MarshalTo

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

func (*MutexStatus) MarshalToSizedBuffer

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

func (*MutexStatus) ProtoMessage

func (*MutexStatus) ProtoMessage()

func (*MutexStatus) Reset

func (m *MutexStatus) Reset()

func (*MutexStatus) Size

func (m *MutexStatus) Size() (n int)

func (*MutexStatus) String

func (this *MutexStatus) String() string

func (*MutexStatus) Unmarshal

func (m *MutexStatus) Unmarshal(dAtA []byte) error

func (*MutexStatus) XXX_DiscardUnknown

func (m *MutexStatus) XXX_DiscardUnknown()

func (*MutexStatus) XXX_Marshal

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

func (*MutexStatus) XXX_Merge

func (m *MutexStatus) XXX_Merge(src proto.Message)

func (*MutexStatus) XXX_Size

func (m *MutexStatus) XXX_Size() int

func (*MutexStatus) XXX_Unmarshal

func (m *MutexStatus) XXX_Unmarshal(b []byte) error

type NodePhase

type NodePhase string

NodePhase is a label for the condition of a node at the current time.

const (
	// Node is waiting to run
	NodePending NodePhase = "Pending"
	// Node is running
	NodeRunning NodePhase = "Running"
	// Node finished with no errors
	NodeSucceeded NodePhase = "Succeeded"
	// Node was skipped
	NodeSkipped NodePhase = "Skipped"
	// Node or child of node exited with non-0 code
	NodeFailed NodePhase = "Failed"
	// Node had an error other than a non 0 exit code
	NodeError NodePhase = "Error"
	// Node was omitted because its `depends` condition was not met (only relevant in DAGs)
	NodeOmitted NodePhase = "Omitted"
)

Workflow and node statuses

func (NodePhase) Completed

func (phase NodePhase) Completed() bool

Completed returns whether or not a phase completed. Notably, a skipped phase is not considered as having completed

func (NodePhase) FailedOrError

func (phase NodePhase) FailedOrError() bool

func (NodePhase) Fulfilled

func (phase NodePhase) Fulfilled() bool

Fulfilled returns whether a phase is fulfilled, i.e. it completed execution or was skipped or omitted

type NodeStatus

type NodeStatus struct {
	// ID is a unique identifier of a node within the worklow
	// It is implemented as a hash of the node name, which makes the ID deterministic
	ID string `json:"id" protobuf:"bytes,1,opt,name=id"`

	// Name is unique name in the node tree used to generate the node ID
	Name string `json:"name" protobuf:"bytes,2,opt,name=name"`

	// DisplayName is a human readable representation of the node. Unique within a template boundary
	DisplayName string `json:"displayName,omitempty" protobuf:"bytes,3,opt,name=displayName"`

	// Type indicates type of node
	Type NodeType `json:"type" protobuf:"bytes,4,opt,name=type,casttype=NodeType"`

	// TemplateName is the template name which this node corresponds to.
	// Not applicable to virtual nodes (e.g. Retry, StepGroup)
	TemplateName string `json:"templateName,omitempty" protobuf:"bytes,5,opt,name=templateName"`

	// TemplateRef is the reference to the template resource which this node corresponds to.
	// Not applicable to virtual nodes (e.g. Retry, StepGroup)
	TemplateRef *TemplateRef `json:"templateRef,omitempty" protobuf:"bytes,6,opt,name=templateRef"`

	// StoredTemplateID is the ID of stored template.
	// DEPRECATED: This value is not used anymore.
	StoredTemplateID string `json:"storedTemplateID,omitempty" protobuf:"bytes,18,opt,name=storedTemplateID"`

	// WorkflowTemplateName is the WorkflowTemplate resource name on which the resolved template of this node is retrieved.
	// DEPRECATED: This value is not used anymore.
	WorkflowTemplateName string `json:"workflowTemplateName,omitempty" protobuf:"bytes,19,opt,name=workflowTemplateName"`

	// TemplateScope is the template scope in which the template of this node was retrieved.
	TemplateScope string `json:"templateScope,omitempty" protobuf:"bytes,20,opt,name=templateScope"`

	// Phase a simple, high-level summary of where the node is in its lifecycle.
	// Can be used as a state machine.
	Phase NodePhase `json:"phase,omitempty" protobuf:"bytes,7,opt,name=phase,casttype=NodePhase"`

	// BoundaryID indicates the node ID of the associated template root node in which this node belongs to
	BoundaryID string `json:"boundaryID,omitempty" protobuf:"bytes,8,opt,name=boundaryID"`

	// A human readable message indicating details about why the node is in this condition.
	Message string `json:"message,omitempty" protobuf:"bytes,9,opt,name=message"`

	// Time at which this node started
	StartedAt metav1.Time `json:"startedAt,omitempty" protobuf:"bytes,10,opt,name=startedAt"`

	// Time at which this node completed
	FinishedAt metav1.Time `json:"finishedAt,omitempty" protobuf:"bytes,11,opt,name=finishedAt"`

	// EstimatedDuration in seconds.
	EstimatedDuration EstimatedDuration `json:"estimatedDuration,omitempty" protobuf:"varint,24,opt,name=estimatedDuration,casttype=EstimatedDuration"`

	// Progress to completion
	Progress Progress `json:"progress,omitempty" protobuf:"bytes,26,opt,name=progress,casttype=Progress"`

	// ResourcesDuration is indicative, but not accurate, resource duration. This is populated when the nodes completes.
	ResourcesDuration ResourcesDuration `json:"resourcesDuration,omitempty" protobuf:"bytes,21,opt,name=resourcesDuration"`

	// PodIP captures the IP of the pod for daemoned steps
	PodIP string `json:"podIP,omitempty" protobuf:"bytes,12,opt,name=podIP"`

	// Daemoned tracks whether or not this node was daemoned and need to be terminated
	Daemoned *bool `json:"daemoned,omitempty" protobuf:"varint,13,opt,name=daemoned"`

	// Inputs captures input parameter values and artifact locations supplied to this template invocation
	Inputs *Inputs `json:"inputs,omitempty" protobuf:"bytes,14,opt,name=inputs"`

	// Outputs captures output parameter values and artifact locations produced by this template invocation
	Outputs *Outputs `json:"outputs,omitempty" protobuf:"bytes,15,opt,name=outputs"`

	// Children is a list of child node IDs
	Children []string `json:"children,omitempty" protobuf:"bytes,16,rep,name=children"`

	// OutboundNodes tracks the node IDs which are considered "outbound" nodes to a template invocation.
	// For every invocation of a template, there are nodes which we considered as "outbound". Essentially,
	// these are last nodes in the execution sequence to run, before the template is considered completed.
	// These nodes are then connected as parents to a following step.
	//
	// In the case of single pod steps (i.e. container, script, resource templates), this list will be nil
	// since the pod itself is already considered the "outbound" node.
	// In the case of DAGs, outbound nodes are the "target" tasks (tasks with no children).
	// In the case of steps, outbound nodes are all the containers involved in the last step group.
	// NOTE: since templates are composable, the list of outbound nodes are carried upwards when
	// a DAG/steps template invokes another DAG/steps template. In other words, the outbound nodes of
	// a template, will be a superset of the outbound nodes of its last children.
	OutboundNodes []string `json:"outboundNodes,omitempty" protobuf:"bytes,17,rep,name=outboundNodes"`

	// HostNodeName name of the Kubernetes node on which the Pod is running, if applicable
	HostNodeName string `json:"hostNodeName,omitempty" protobuf:"bytes,22,rep,name=hostNodeName"`

	// MemoizationStatus holds information about cached nodes
	MemoizationStatus *MemoizationStatus `json:"memoizationStatus,omitempty" protobuf:"varint,23,opt,name=memoizationStatus"`

	// SynchronizationStatus is the synchronization status of the node
	SynchronizationStatus *NodeSynchronizationStatus `json:"synchronizationStatus,omitempty" protobuf:"bytes,25,opt,name=synchronizationStatus"`
}

NodeStatus contains status information about an individual node in the workflow

func (NodeStatus) CanRetry

func (n NodeStatus) CanRetry() bool

CanRetry returns whether the node should be retried or not.

func (NodeStatus) Completed

func (n NodeStatus) Completed() bool

Completed returns whether a node completed. Notably, a skipped node is not considered as having completed

func (*NodeStatus) DeepCopy

func (in *NodeStatus) DeepCopy() *NodeStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new NodeStatus.

func (*NodeStatus) DeepCopyInto

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*NodeStatus) Descriptor

func (*NodeStatus) Descriptor() ([]byte, []int)

func (NodeStatus) FailedOrError

func (n NodeStatus) FailedOrError() bool

func (NodeStatus) FinishTime

func (n NodeStatus) FinishTime() *metav1.Time

func (NodeStatus) Fulfilled

func (n NodeStatus) Fulfilled() bool

Fulfilled returns whether a node is fulfilled, i.e. it finished execution, was skipped, or was dameoned successfully

func (NodeStatus) GetDuration

func (n NodeStatus) GetDuration() time.Duration

func (*NodeStatus) GetTemplateName

func (n *NodeStatus) GetTemplateName() string

func (*NodeStatus) GetTemplateRef

func (n *NodeStatus) GetTemplateRef() *TemplateRef

func (NodeStatus) GetTemplateScope

func (n NodeStatus) GetTemplateScope() (ResourceScope, string)

func (*NodeStatus) IsActiveSuspendNode

func (n *NodeStatus) IsActiveSuspendNode() bool

IsActiveSuspendNode returns whether this node is an active suspend node

func (NodeStatus) IsDaemoned

func (n NodeStatus) IsDaemoned() bool

IsDaemoned returns whether or not the node is deamoned

func (*NodeStatus) Marshal

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

func (*NodeStatus) MarshalTo

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

func (*NodeStatus) MarshalToSizedBuffer

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

func (NodeStatus) Omitted

func (n NodeStatus) Omitted() bool

func (NodeStatus) Pending

func (n NodeStatus) Pending() bool

Pending returns whether or not the node is in pending state

func (*NodeStatus) ProtoMessage

func (*NodeStatus) ProtoMessage()

func (*NodeStatus) Reset

func (m *NodeStatus) Reset()

func (*NodeStatus) Size

func (m *NodeStatus) Size() (n int)

func (NodeStatus) StartTime

func (n NodeStatus) StartTime() *metav1.Time

func (*NodeStatus) String

func (this *NodeStatus) String() string

func (NodeStatus) Succeeded

func (n NodeStatus) Succeeded() bool

func (*NodeStatus) Unmarshal

func (m *NodeStatus) Unmarshal(dAtA []byte) error

func (*NodeStatus) XXX_DiscardUnknown

func (m *NodeStatus) XXX_DiscardUnknown()

func (*NodeStatus) XXX_Marshal

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

func (*NodeStatus) XXX_Merge

func (m *NodeStatus) XXX_Merge(src proto.Message)

func (*NodeStatus) XXX_Size

func (m *NodeStatus) XXX_Size() int

func (*NodeStatus) XXX_Unmarshal

func (m *NodeStatus) XXX_Unmarshal(b []byte) error

type NodeSynchronizationStatus

type NodeSynchronizationStatus struct {
	// Waiting is the name of the lock that this node is waiting for
	Waiting string `json:"waiting,omitempty" protobuf:"bytes,1,opt,name=waiting"`
}

NodeSynchronizationStatus stores the status of a node

func (*NodeSynchronizationStatus) DeepCopy

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new NodeSynchronizationStatus.

func (*NodeSynchronizationStatus) DeepCopyInto

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*NodeSynchronizationStatus) Descriptor

func (*NodeSynchronizationStatus) Descriptor() ([]byte, []int)

func (*NodeSynchronizationStatus) Marshal

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

func (*NodeSynchronizationStatus) MarshalTo

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

func (*NodeSynchronizationStatus) MarshalToSizedBuffer

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

func (*NodeSynchronizationStatus) ProtoMessage

func (*NodeSynchronizationStatus) ProtoMessage()

func (*NodeSynchronizationStatus) Reset

func (m *NodeSynchronizationStatus) Reset()

func (*NodeSynchronizationStatus) Size

func (m *NodeSynchronizationStatus) Size() (n int)

func (*NodeSynchronizationStatus) String

func (this *NodeSynchronizationStatus) String() string

func (*NodeSynchronizationStatus) Unmarshal

func (m *NodeSynchronizationStatus) Unmarshal(dAtA []byte) error

func (*NodeSynchronizationStatus) XXX_DiscardUnknown

func (m *NodeSynchronizationStatus) XXX_DiscardUnknown()

func (*NodeSynchronizationStatus) XXX_Marshal

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

func (*NodeSynchronizationStatus) XXX_Merge

func (m *NodeSynchronizationStatus) XXX_Merge(src proto.Message)

func (*NodeSynchronizationStatus) XXX_Size

func (m *NodeSynchronizationStatus) XXX_Size() int

func (*NodeSynchronizationStatus) XXX_Unmarshal

func (m *NodeSynchronizationStatus) XXX_Unmarshal(b []byte) error

type NodeType

type NodeType string

NodeType is the type of a node

const (
	NodeTypePod       NodeType = "Pod"
	NodeTypeSteps     NodeType = "Steps"
	NodeTypeStepGroup NodeType = "StepGroup"
	NodeTypeDAG       NodeType = "DAG"
	NodeTypeTaskGroup NodeType = "TaskGroup"
	NodeTypeRetry     NodeType = "Retry"
	NodeTypeSkipped   NodeType = "Skipped"
	NodeTypeSuspend   NodeType = "Suspend"
)

Node types

type Nodes

type Nodes map[string]NodeStatus

func (Nodes) Any

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

func (Nodes) Children

func (s Nodes) Children(parentNodeId string) Nodes

Children returns the children of the parent.

func (Nodes) DeepCopy

func (in Nodes) DeepCopy() Nodes

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Nodes.

func (Nodes) DeepCopyInto

func (in Nodes) DeepCopyInto(out *Nodes)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (Nodes) Filter

func (s Nodes) Filter(predicate func(NodeStatus) bool) Nodes

Filter returns the subset of the nodes that match the predicate, e.g. only failed nodes

func (Nodes) Find

func (n Nodes) Find(f func(NodeStatus) bool) *NodeStatus

func (Nodes) FindByDisplayName

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

func (Nodes) Map

func (s Nodes) Map(f func(x NodeStatus) interface{}) map[string]interface{}

Map maps the nodes to new values, e.g. `x.Hostname`

type NoneStrategy

type NoneStrategy struct{}

NoneStrategy indicates to skip tar process and upload the files or directory tree as independent files. Note that if the artifact is a directory, the artifact driver must support the ability to save/load the directory appropriately.

func (*NoneStrategy) DeepCopy

func (in *NoneStrategy) DeepCopy() *NoneStrategy

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new NoneStrategy.

func (*NoneStrategy) DeepCopyInto

func (in *NoneStrategy) DeepCopyInto(out *NoneStrategy)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*NoneStrategy) Descriptor

func (*NoneStrategy) Descriptor() ([]byte, []int)

func (*NoneStrategy) Marshal

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

func (*NoneStrategy) MarshalTo

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

func (*NoneStrategy) MarshalToSizedBuffer

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

func (*NoneStrategy) ProtoMessage

func (*NoneStrategy) ProtoMessage()

func (*NoneStrategy) Reset

func (m *NoneStrategy) Reset()

func (*NoneStrategy) Size

func (m *NoneStrategy) Size() (n int)

func (*NoneStrategy) String

func (this *NoneStrategy) String() string

func (*NoneStrategy) Unmarshal

func (m *NoneStrategy) Unmarshal(dAtA []byte) error

func (*NoneStrategy) XXX_DiscardUnknown

func (m *NoneStrategy) XXX_DiscardUnknown()

func (*NoneStrategy) XXX_Marshal

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

func (*NoneStrategy) XXX_Merge

func (m *NoneStrategy) XXX_Merge(src proto.Message)

func (*NoneStrategy) XXX_Size

func (m *NoneStrategy) XXX_Size() int

func (*NoneStrategy) XXX_Unmarshal

func (m *NoneStrategy) XXX_Unmarshal(b []byte) error

type OSSArtifact

type OSSArtifact struct {
	OSSBucket `json:",inline" protobuf:"bytes,1,opt,name=oSSBucket"`

	// Key is the path in the bucket where the artifact resides
	Key string `json:"key" protobuf:"bytes,2,opt,name=key"`
}

OSSArtifact is the location of an Alibaba Cloud OSS artifact

func (*OSSArtifact) DeepCopy

func (in *OSSArtifact) DeepCopy() *OSSArtifact

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new OSSArtifact.

func (*OSSArtifact) DeepCopyInto

func (in *OSSArtifact) DeepCopyInto(out *OSSArtifact)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*OSSArtifact) Descriptor

func (*OSSArtifact) Descriptor() ([]byte, []int)

func (*OSSArtifact) GetKey

func (o *OSSArtifact) GetKey() (string, error)

func (*OSSArtifact) HasLocation

func (o *OSSArtifact) HasLocation() bool

func (*OSSArtifact) Marshal

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

func (*OSSArtifact) MarshalTo

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

func (*OSSArtifact) MarshalToSizedBuffer

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

func (*OSSArtifact) ProtoMessage

func (*OSSArtifact) ProtoMessage()

func (*OSSArtifact) Reset

func (m *OSSArtifact) Reset()

func (*OSSArtifact) SetKey

func (o *OSSArtifact) SetKey(key string) error

func (*OSSArtifact) Size

func (m *OSSArtifact) Size() (n int)

func (*OSSArtifact) String

func (this *OSSArtifact) String() string

func (*OSSArtifact) Unmarshal

func (m *OSSArtifact) Unmarshal(dAtA []byte) error

func (*OSSArtifact) XXX_DiscardUnknown

func (m *OSSArtifact) XXX_DiscardUnknown()

func (*OSSArtifact) XXX_Marshal

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

func (*OSSArtifact) XXX_Merge

func (m *OSSArtifact) XXX_Merge(src proto.Message)

func (*OSSArtifact) XXX_Size

func (m *OSSArtifact) XXX_Size() int

func (*OSSArtifact) XXX_Unmarshal

func (m *OSSArtifact) XXX_Unmarshal(b []byte) error

type OSSBucket

type OSSBucket struct {
	// Endpoint is the hostname of the bucket endpoint
	Endpoint string `json:"endpoint,omitempty" protobuf:"bytes,1,opt,name=endpoint"`

	// Bucket is the name of the bucket
	Bucket string `json:"bucket,omitempty" protobuf:"bytes,2,opt,name=bucket"`

	// AccessKeySecret is the secret selector to the bucket's access key
	AccessKeySecret *apiv1.SecretKeySelector `json:"accessKeySecret,omitempty" protobuf:"bytes,3,opt,name=accessKeySecret"`

	// SecretKeySecret is the secret selector to the bucket's secret key
	SecretKeySecret *apiv1.SecretKeySelector `json:"secretKeySecret,omitempty" protobuf:"bytes,4,opt,name=secretKeySecret"`
}

OSSBucket contains the access information required for interfacing with an Alibaba Cloud OSS bucket

func (*OSSBucket) DeepCopy

func (in *OSSBucket) DeepCopy() *OSSBucket

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new OSSBucket.

func (*OSSBucket) DeepCopyInto

func (in *OSSBucket) DeepCopyInto(out *OSSBucket)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*OSSBucket) Descriptor

func (*OSSBucket) Descriptor() ([]byte, []int)

func (*OSSBucket) Marshal

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

func (*OSSBucket) MarshalTo

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

func (*OSSBucket) MarshalToSizedBuffer

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

func (*OSSBucket) ProtoMessage

func (*OSSBucket) ProtoMessage()

func (*OSSBucket) Reset

func (m *OSSBucket) Reset()

func (*OSSBucket) Size

func (m *OSSBucket) Size() (n int)

func (*OSSBucket) String

func (this *OSSBucket) String() string

func (*OSSBucket) Unmarshal

func (m *OSSBucket) Unmarshal(dAtA []byte) error

func (*OSSBucket) XXX_DiscardUnknown

func (m *OSSBucket) XXX_DiscardUnknown()

func (*OSSBucket) XXX_Marshal

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

func (*OSSBucket) XXX_Merge

func (m *OSSBucket) XXX_Merge(src proto.Message)

func (*OSSBucket) XXX_Size

func (m *OSSBucket) XXX_Size() int

func (*OSSBucket) XXX_Unmarshal

func (m *OSSBucket) XXX_Unmarshal(b []byte) error

type Outputs

type Outputs struct {
	// Parameters holds the list of output parameters produced by a step
	// +patchStrategy=merge
	// +patchMergeKey=name
	Parameters []Parameter `json:"parameters,omitempty" patchStrategy:"merge" patchMergeKey:"name" protobuf:"bytes,1,rep,name=parameters"`

	// Artifacts holds the list of output artifacts produced by a step
	// +patchStrategy=merge
	// +patchMergeKey=name
	Artifacts Artifacts `json:"artifacts,omitempty" patchStrategy:"merge" patchMergeKey:"name" protobuf:"bytes,2,rep,name=artifacts"`

	// Result holds the result (stdout) of a script template
	Result *string `json:"result,omitempty" protobuf:"bytes,3,opt,name=result"`

	// ExitCode holds the exit code of a script template
	ExitCode *string `json:"exitCode,omitempty" protobuf:"bytes,4,opt,name=exitCode"`
}

Outputs hold parameters, artifacts, and results from a step

func (*Outputs) DeepCopy

func (in *Outputs) DeepCopy() *Outputs

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Outputs.

func (*Outputs) DeepCopyInto

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*Outputs) Descriptor

func (*Outputs) Descriptor() ([]byte, []int)

func (*Outputs) GetArtifactByName

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

func (*Outputs) HasOutputs

func (out *Outputs) HasOutputs() bool

HasOutputs returns whether or not there are any outputs

func (*Outputs) Marshal

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

func (*Outputs) MarshalTo

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

func (*Outputs) MarshalToSizedBuffer

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

func (*Outputs) ProtoMessage

func (*Outputs) ProtoMessage()

func (*Outputs) Reset

func (m *Outputs) Reset()

func (*Outputs) Size

func (m *Outputs) Size() (n int)

func (*Outputs) String

func (this *Outputs) String() string

func (*Outputs) Unmarshal

func (m *Outputs) Unmarshal(dAtA []byte) error

func (*Outputs) XXX_DiscardUnknown

func (m *Outputs) XXX_DiscardUnknown()

func (*Outputs) XXX_Marshal

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

func (*Outputs) XXX_Merge

func (m *Outputs) XXX_Merge(src proto.Message)

func (*Outputs) XXX_Size

func (m *Outputs) XXX_Size() int

func (*Outputs) XXX_Unmarshal

func (m *Outputs) XXX_Unmarshal(b []byte) error

type ParallelSteps

type ParallelSteps struct {
	Steps []WorkflowStep `json:"-" protobuf:"bytes,1,rep,name=steps"`
}

+kubebuilder:validation:Type=array

func (*ParallelSteps) DeepCopy

func (in *ParallelSteps) DeepCopy() *ParallelSteps

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ParallelSteps.

func (*ParallelSteps) DeepCopyInto

func (in *ParallelSteps) DeepCopyInto(out *ParallelSteps)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*ParallelSteps) Descriptor

func (*ParallelSteps) Descriptor() ([]byte, []int)

func (*ParallelSteps) Marshal

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

func (ParallelSteps) MarshalJSON

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

func (*ParallelSteps) MarshalTo

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

func (*ParallelSteps) MarshalToSizedBuffer

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

func (ParallelSteps) OpenAPISchemaFormat

func (b ParallelSteps) OpenAPISchemaFormat() string

func (ParallelSteps) OpenAPISchemaType

func (b ParallelSteps) OpenAPISchemaType() []string

func (*ParallelSteps) ProtoMessage

func (*ParallelSteps) ProtoMessage()

func (*ParallelSteps) Reset

func (m *ParallelSteps) Reset()

func (*ParallelSteps) Size

func (m *ParallelSteps) Size() (n int)

func (*ParallelSteps) String

func (this *ParallelSteps) String() string

func (*ParallelSteps) Unmarshal

func (m *ParallelSteps) Unmarshal(dAtA []byte) error

func (*ParallelSteps) UnmarshalJSON

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

WorkflowStep is an anonymous list inside of ParallelSteps (i.e. it does not have a key), so it needs its own custom Unmarshaller

func (*ParallelSteps) XXX_DiscardUnknown

func (m *ParallelSteps) XXX_DiscardUnknown()

func (*ParallelSteps) XXX_Marshal

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

func (*ParallelSteps) XXX_Merge

func (m *ParallelSteps) XXX_Merge(src proto.Message)

func (*ParallelSteps) XXX_Size

func (m *ParallelSteps) XXX_Size() int

func (*ParallelSteps) XXX_Unmarshal

func (m *ParallelSteps) XXX_Unmarshal(b []byte) error

type Parameter

type Parameter struct {
	// Name is the parameter name
	Name string `json:"name" protobuf:"bytes,1,opt,name=name"`

	// Default is the default value to use for an input parameter if a value was not supplied
	Default *AnyString `json:"default,omitempty" protobuf:"bytes,2,opt,name=default"`

	// Value is the literal value to use for the parameter.
	// If specified in the context of an input parameter, the value takes precedence over any passed values
	Value *AnyString `json:"value,omitempty" protobuf:"bytes,3,opt,name=value"`

	// ValueFrom is the source for the output parameter's value
	ValueFrom *ValueFrom `json:"valueFrom,omitempty" protobuf:"bytes,4,opt,name=valueFrom"`

	// GlobalName exports an output parameter to the global scope, making it available as
	// '{{workflow.outputs.parameters.XXXX}} and in workflow.status.outputs.parameters
	GlobalName string `json:"globalName,omitempty" protobuf:"bytes,5,opt,name=globalName"`

	// Enum holds a list of string values to choose from, for the actual value of the parameter
	Enum []AnyString `json:"enum,omitempty" protobuf:"bytes,6,rep,name=enum"`
}

Parameter indicate a passed string parameter to a service template with an optional default value

func (*Parameter) DeepCopy

func (in *Parameter) DeepCopy() *Parameter

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Parameter.

func (*Parameter) DeepCopyInto

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*Parameter) Descriptor

func (*Parameter) Descriptor() ([]byte, []int)

func (*Parameter) Marshal

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

func (*Parameter) MarshalTo

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

func (*Parameter) MarshalToSizedBuffer

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

func (*Parameter) ProtoMessage

func (*Parameter) ProtoMessage()

func (*Parameter) Reset

func (m *Parameter) Reset()

func (*Parameter) Size

func (m *Parameter) Size() (n int)

func (*Parameter) String

func (this *Parameter) String() string

func (*Parameter) Unmarshal

func (m *Parameter) Unmarshal(dAtA []byte) error

func (*Parameter) XXX_DiscardUnknown

func (m *Parameter) XXX_DiscardUnknown()

func (*Parameter) XXX_Marshal

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

func (*Parameter) XXX_Merge

func (m *Parameter) XXX_Merge(src proto.Message)

func (*Parameter) XXX_Size

func (m *Parameter) XXX_Size() int

func (*Parameter) XXX_Unmarshal

func (m *Parameter) XXX_Unmarshal(b []byte) error

type PodGC

type PodGC struct {
	// Strategy is the strategy to use. One of "OnPodCompletion", "OnPodSuccess", "OnWorkflowCompletion", "OnWorkflowSuccess"
	Strategy PodGCStrategy `json:"strategy,omitempty" protobuf:"bytes,1,opt,name=strategy,casttype=PodGCStrategy"`
}

PodGC describes how to delete completed pods as they complete

func (*PodGC) DeepCopy

func (in *PodGC) DeepCopy() *PodGC

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PodGC.

func (*PodGC) DeepCopyInto

func (in *PodGC) DeepCopyInto(out *PodGC)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*PodGC) Descriptor

func (*PodGC) Descriptor() ([]byte, []int)

func (*PodGC) Marshal

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

func (*PodGC) MarshalTo

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

func (*PodGC) MarshalToSizedBuffer

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

func (*PodGC) ProtoMessage

func (*PodGC) ProtoMessage()

func (*PodGC) Reset

func (m *PodGC) Reset()

func (*PodGC) Size

func (m *PodGC) Size() (n int)

func (*PodGC) String

func (this *PodGC) String() string

func (*PodGC) Unmarshal

func (m *PodGC) Unmarshal(dAtA []byte) error

func (*PodGC) XXX_DiscardUnknown

func (m *PodGC) XXX_DiscardUnknown()

func (*PodGC) XXX_Marshal

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

func (*PodGC) XXX_Merge

func (m *PodGC) XXX_Merge(src proto.Message)

func (*PodGC) XXX_Size

func (m *PodGC) XXX_Size() int

func (*PodGC) XXX_Unmarshal

func (m *PodGC) XXX_Unmarshal(b []byte) error

type PodGCStrategy

type PodGCStrategy string

PodGCStrategy is the strategy when to delete completed pods for GC.

const (
	PodGCOnPodCompletion      PodGCStrategy = "OnPodCompletion"
	PodGCOnPodSuccess         PodGCStrategy = "OnPodSuccess"
	PodGCOnWorkflowCompletion PodGCStrategy = "OnWorkflowCompletion"
	PodGCOnWorkflowSuccess    PodGCStrategy = "OnWorkflowSuccess"
)

PodGCStrategy

type Progress

type Progress string

Progress in N/M format. N is number of task complete. M is number of tasks.

func NewProgress

func NewProgress(n, m int64) (Progress, bool)

func ParseProgress

func ParseProgress(s string) (Progress, bool)

func (Progress) Add

func (in Progress) Add(x Progress) Progress

func (Progress) IsValid

func (in Progress) IsValid() bool

func (Progress) M

func (in Progress) M() int64

func (Progress) N

func (in Progress) N() int64

type Prometheus

type Prometheus struct {
	// Name is the name of the metric
	Name string `json:"name" protobuf:"bytes,1,opt,name=name"`
	// Labels is a list of metric labels
	Labels []*MetricLabel `json:"labels,omitempty" protobuf:"bytes,2,rep,name=labels"`
	// Help is a string that describes the metric
	Help string `json:"help" protobuf:"bytes,3,opt,name=help"`
	// When is a conditional statement that decides when to emit the metric
	When string `json:"when,omitempty" protobuf:"bytes,4,opt,name=when"`
	// Gauge is a gauge metric
	Gauge *Gauge `json:"gauge,omitempty" protobuf:"bytes,5,opt,name=gauge"`
	// Histogram is a histogram metric
	Histogram *Histogram `json:"histogram,omitempty" protobuf:"bytes,6,opt,name=histogram"`
	// Counter is a counter metric
	Counter *Counter `json:"counter,omitempty" protobuf:"bytes,7,opt,name=counter"`
}

Prometheus is a prometheus metric to be emitted

func (*Prometheus) DeepCopy

func (in *Prometheus) DeepCopy() *Prometheus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Prometheus.

func (*Prometheus) DeepCopyInto

func (in *Prometheus) DeepCopyInto(out *Prometheus)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*Prometheus) Descriptor

func (*Prometheus) Descriptor() ([]byte, []int)

func (*Prometheus) GetDesc

func (p *Prometheus) GetDesc() string

func (*Prometheus) GetMetricLabels

func (p *Prometheus) GetMetricLabels() map[string]string

func (*Prometheus) GetMetricType

func (p *Prometheus) GetMetricType() MetricType

func (*Prometheus) GetValueString

func (p *Prometheus) GetValueString() string

func (*Prometheus) IsRealtime

func (p *Prometheus) IsRealtime() bool

func (*Prometheus) Marshal

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

func (*Prometheus) MarshalTo

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

func (*Prometheus) MarshalToSizedBuffer

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

func (*Prometheus) ProtoMessage

func (*Prometheus) ProtoMessage()

func (*Prometheus) Reset

func (m *Prometheus) Reset()

func (*Prometheus) SetValueString

func (p *Prometheus) SetValueString(val string)

func (*Prometheus) Size

func (m *Prometheus) Size() (n int)

func (*Prometheus) String

func (this *Prometheus) String() string

func (*Prometheus) Unmarshal

func (m *Prometheus) Unmarshal(dAtA []byte) error

func (*Prometheus) XXX_DiscardUnknown

func (m *Prometheus) XXX_DiscardUnknown()

func (*Prometheus) XXX_Marshal

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

func (*Prometheus) XXX_Merge

func (m *Prometheus) XXX_Merge(src proto.Message)

func (*Prometheus) XXX_Size

func (m *Prometheus) XXX_Size() int

func (*Prometheus) XXX_Unmarshal

func (m *Prometheus) XXX_Unmarshal(b []byte) error

type RawArtifact

type RawArtifact struct {
	// Data is the string contents of the artifact
	Data string `json:"data" protobuf:"bytes,1,opt,name=data"`
}

RawArtifact allows raw string content to be placed as an artifact in a container

func (*RawArtifact) DeepCopy

func (in *RawArtifact) DeepCopy() *RawArtifact

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new RawArtifact.

func (*RawArtifact) DeepCopyInto

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*RawArtifact) Descriptor

func (*RawArtifact) Descriptor() ([]byte, []int)

func (*RawArtifact) GetKey

func (r *RawArtifact) GetKey() (string, error)

func (*RawArtifact) HasLocation

func (r *RawArtifact) HasLocation() bool

func (*RawArtifact) Marshal

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

func (*RawArtifact) MarshalTo

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

func (*RawArtifact) MarshalToSizedBuffer

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

func (*RawArtifact) ProtoMessage

func (*RawArtifact) ProtoMessage()

func (*RawArtifact) Reset

func (m *RawArtifact) Reset()

func (*RawArtifact) SetKey

func (r *RawArtifact) SetKey(string) error

func (*RawArtifact) Size

func (m *RawArtifact) Size() (n int)

func (*RawArtifact) String

func (this *RawArtifact) String() string

func (*RawArtifact) Unmarshal

func (m *RawArtifact) Unmarshal(dAtA []byte) error

func (*RawArtifact) XXX_DiscardUnknown

func (m *RawArtifact) XXX_DiscardUnknown()

func (*RawArtifact) XXX_Marshal

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

func (*RawArtifact) XXX_Merge

func (m *RawArtifact) XXX_Merge(src proto.Message)

func (*RawArtifact) XXX_Size

func (m *RawArtifact) XXX_Size() int

func (*RawArtifact) XXX_Unmarshal

func (m *RawArtifact) XXX_Unmarshal(b []byte) error

type ResourceDuration

type ResourceDuration int64

The amount of requested resource * the duration that request was used. This is represented as duration in seconds, so can be converted to and from duration (with loss of precision).

func NewResourceDuration

func NewResourceDuration(d time.Duration) ResourceDuration

func (ResourceDuration) Duration

func (in ResourceDuration) Duration() time.Duration

func (ResourceDuration) String

func (in ResourceDuration) String() string

type ResourceScope

type ResourceScope string
const (
	ResourceScopeLocal      ResourceScope = "local"
	ResourceScopeNamespaced ResourceScope = "namespaced"
	ResourceScopeCluster    ResourceScope = "cluster"
)

type ResourceTemplate

type ResourceTemplate struct {
	// Action is the action to perform to the resource.
	// Must be one of: get, create, apply, delete, replace, patch
	Action string `json:"action" protobuf:"bytes,1,opt,name=action"`

	// MergeStrategy is the strategy used to merge a patch. It defaults to "strategic"
	// Must be one of: strategic, merge, json
	MergeStrategy string `json:"mergeStrategy,omitempty" protobuf:"bytes,2,opt,name=mergeStrategy"`

	// Manifest contains the kubernetes manifest
	Manifest string `json:"manifest,omitempty" protobuf:"bytes,3,opt,name=manifest"`

	// SetOwnerReference sets the reference to the workflow on the OwnerReference of generated resource.
	SetOwnerReference bool `json:"setOwnerReference,omitempty" protobuf:"varint,4,opt,name=setOwnerReference"`

	// SuccessCondition is a label selector expression which describes the conditions
	// of the k8s resource in which it is acceptable to proceed to the following step
	SuccessCondition string `json:"successCondition,omitempty" protobuf:"bytes,5,opt,name=successCondition"`

	// FailureCondition is a label selector expression which describes the conditions
	// of the k8s resource in which the step was considered failed
	FailureCondition string `json:"failureCondition,omitempty" protobuf:"bytes,6,opt,name=failureCondition"`

	// Flags is a set of additional options passed to kubectl before submitting a resource
	// I.e. to disable resource validation:
	// flags: [
	// 	"--validate=false"  # disable resource validation
	// ]
	Flags []string `json:"flags,omitempty" protobuf:"varint,7,opt,name=flags"`
}

ResourceTemplate is a template subtype to manipulate kubernetes resources

func (*ResourceTemplate) DeepCopy

func (in *ResourceTemplate) DeepCopy() *ResourceTemplate

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ResourceTemplate.

func (*ResourceTemplate) DeepCopyInto

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*ResourceTemplate) Descriptor

func (*ResourceTemplate) Descriptor() ([]byte, []int)

func (*ResourceTemplate) Marshal

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

func (*ResourceTemplate) MarshalTo

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

func (*ResourceTemplate) MarshalToSizedBuffer

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

func (*ResourceTemplate) ProtoMessage

func (*ResourceTemplate) ProtoMessage()

func (*ResourceTemplate) Reset

func (m *ResourceTemplate) Reset()

func (*ResourceTemplate) Size

func (m *ResourceTemplate) Size() (n int)

func (*ResourceTemplate) String

func (this *ResourceTemplate) String() string

func (*ResourceTemplate) Unmarshal

func (m *ResourceTemplate) Unmarshal(dAtA []byte) error

func (*ResourceTemplate) XXX_DiscardUnknown

func (m *ResourceTemplate) XXX_DiscardUnknown()

func (*ResourceTemplate) XXX_Marshal

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

func (*ResourceTemplate) XXX_Merge

func (m *ResourceTemplate) XXX_Merge(src proto.Message)

func (*ResourceTemplate) XXX_Size

func (m *ResourceTemplate) XXX_Size() int

func (*ResourceTemplate) XXX_Unmarshal

func (m *ResourceTemplate) XXX_Unmarshal(b []byte) error

type ResourcesDuration

type ResourcesDuration map[apiv1.ResourceName]ResourceDuration

This contains each duration by request requested. e.g. 100m CPU * 1h, 1Gi memory * 1h

func (ResourcesDuration) Add

func (ResourcesDuration) DeepCopy

func (in ResourcesDuration) DeepCopy() ResourcesDuration

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ResourcesDuration.

func (ResourcesDuration) DeepCopyInto

func (in ResourcesDuration) DeepCopyInto(out *ResourcesDuration)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (ResourcesDuration) IsZero

func (in ResourcesDuration) IsZero() bool

func (ResourcesDuration) String

func (in ResourcesDuration) String() string

type RetryAffinity

type RetryAffinity struct {
	NodeAntiAffinity *RetryNodeAntiAffinity `json:"nodeAntiAffinity,omitempty" protobuf:"bytes,1,opt,name=nodeAntiAffinity"`
}

RetryAffinity prevents running steps on the same host.

func (*RetryAffinity) DeepCopy

func (in *RetryAffinity) DeepCopy() *RetryAffinity

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new RetryAffinity.

func (*RetryAffinity) DeepCopyInto

func (in *RetryAffinity) DeepCopyInto(out *RetryAffinity)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*RetryAffinity) Descriptor

func (*RetryAffinity) Descriptor() ([]byte, []int)

func (*RetryAffinity) Marshal

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

func (*RetryAffinity) MarshalTo

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

func (*RetryAffinity) MarshalToSizedBuffer

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

func (*RetryAffinity) ProtoMessage

func (*RetryAffinity) ProtoMessage()

func (*RetryAffinity) Reset

func (m *RetryAffinity) Reset()

func (*RetryAffinity) Size

func (m *RetryAffinity) Size() (n int)

func (*RetryAffinity) String

func (this *RetryAffinity) String() string

func (*RetryAffinity) Unmarshal

func (m *RetryAffinity) Unmarshal(dAtA []byte) error

func (*RetryAffinity) XXX_DiscardUnknown

func (m *RetryAffinity) XXX_DiscardUnknown()

func (*RetryAffinity) XXX_Marshal

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

func (*RetryAffinity) XXX_Merge

func (m *RetryAffinity) XXX_Merge(src proto.Message)

func (*RetryAffinity) XXX_Size

func (m *RetryAffinity) XXX_Size() int

func (*RetryAffinity) XXX_Unmarshal

func (m *RetryAffinity) XXX_Unmarshal(b []byte) error

type RetryNodeAntiAffinity

type RetryNodeAntiAffinity struct {
}

RetryNodeAntiAffinity is a placeholder for future expansion, only empty nodeAntiAffinity is allowed. In order to prevent running steps on the same host, it uses "kubernetes.io/hostname".

func (*RetryNodeAntiAffinity) DeepCopy

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new RetryNodeAntiAffinity.

func (*RetryNodeAntiAffinity) DeepCopyInto

func (in *RetryNodeAntiAffinity) DeepCopyInto(out *RetryNodeAntiAffinity)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*RetryNodeAntiAffinity) Descriptor

func (*RetryNodeAntiAffinity) Descriptor() ([]byte, []int)

func (*RetryNodeAntiAffinity) Marshal

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

func (*RetryNodeAntiAffinity) MarshalTo

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

func (*RetryNodeAntiAffinity) MarshalToSizedBuffer

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

func (*RetryNodeAntiAffinity) ProtoMessage

func (*RetryNodeAntiAffinity) ProtoMessage()

func (*RetryNodeAntiAffinity) Reset

func (m *RetryNodeAntiAffinity) Reset()

func (*RetryNodeAntiAffinity) Size

func (m *RetryNodeAntiAffinity) Size() (n int)

func (*RetryNodeAntiAffinity) String

func (this *RetryNodeAntiAffinity) String() string

func (*RetryNodeAntiAffinity) Unmarshal

func (m *RetryNodeAntiAffinity) Unmarshal(dAtA []byte) error

func (*RetryNodeAntiAffinity) XXX_DiscardUnknown

func (m *RetryNodeAntiAffinity) XXX_DiscardUnknown()

func (*RetryNodeAntiAffinity) XXX_Marshal

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

func (*RetryNodeAntiAffinity) XXX_Merge

func (m *RetryNodeAntiAffinity) XXX_Merge(src proto.Message)

func (*RetryNodeAntiAffinity) XXX_Size

func (m *RetryNodeAntiAffinity) XXX_Size() int

func (*RetryNodeAntiAffinity) XXX_Unmarshal

func (m *RetryNodeAntiAffinity) XXX_Unmarshal(b []byte) error

type RetryPolicy

type RetryPolicy string
const (
	RetryPolicyAlways    RetryPolicy = "Always"
	RetryPolicyOnFailure RetryPolicy = "OnFailure"
	RetryPolicyOnError   RetryPolicy = "OnError"
)

type RetryStrategy

type RetryStrategy struct {
	// Limit is the maximum number of attempts when retrying a container
	Limit *intstr.IntOrString `json:"limit,omitempty" protobuf:"varint,1,opt,name=limit"`

	// RetryPolicy is a policy of NodePhase statuses that will be retried
	RetryPolicy RetryPolicy `json:"retryPolicy,omitempty" protobuf:"bytes,2,opt,name=retryPolicy,casttype=RetryPolicy"`

	// Backoff is a backoff strategy
	Backoff *Backoff `json:"backoff,omitempty" protobuf:"bytes,3,opt,name=backoff,casttype=Backoff"`

	// Affinity prevents running workflow's step on the same host
	Affinity *RetryAffinity `json:"affinity,omitempty" protobuf:"bytes,4,opt,name=affinity"`
}

RetryStrategy provides controls on how to retry a workflow step

func (*RetryStrategy) DeepCopy

func (in *RetryStrategy) DeepCopy() *RetryStrategy

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new RetryStrategy.

func (*RetryStrategy) DeepCopyInto

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*RetryStrategy) Descriptor

func (*RetryStrategy) Descriptor() ([]byte, []int)

func (*RetryStrategy) Marshal

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

func (*RetryStrategy) MarshalTo

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

func (*RetryStrategy) MarshalToSizedBuffer

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

func (*RetryStrategy) ProtoMessage

func (*RetryStrategy) ProtoMessage()

func (*RetryStrategy) Reset

func (m *RetryStrategy) Reset()

func (*RetryStrategy) Size

func (m *RetryStrategy) Size() (n int)

func (*RetryStrategy) String

func (this *RetryStrategy) String() string

func (*RetryStrategy) Unmarshal

func (m *RetryStrategy) Unmarshal(dAtA []byte) error

func (*RetryStrategy) XXX_DiscardUnknown

func (m *RetryStrategy) XXX_DiscardUnknown()

func (*RetryStrategy) XXX_Marshal

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

func (*RetryStrategy) XXX_Merge

func (m *RetryStrategy) XXX_Merge(src proto.Message)

func (*RetryStrategy) XXX_Size

func (m *RetryStrategy) XXX_Size() int

func (*RetryStrategy) XXX_Unmarshal

func (m *RetryStrategy) XXX_Unmarshal(b []byte) error

type S3Artifact

type S3Artifact struct {
	S3Bucket `json:",inline" protobuf:"bytes,1,opt,name=s3Bucket"`

	// Key is the key in the bucket where the artifact resides
	Key string `json:"key" protobuf:"bytes,2,opt,name=key"`
}

S3Artifact is the location of an S3 artifact

func (*S3Artifact) DeepCopy

func (in *S3Artifact) DeepCopy() *S3Artifact

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new S3Artifact.

func (*S3Artifact) DeepCopyInto

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*S3Artifact) Descriptor

func (*S3Artifact) Descriptor() ([]byte, []int)

func (*S3Artifact) GetKey

func (s *S3Artifact) GetKey() (string, error)

func (*S3Artifact) HasLocation

func (s *S3Artifact) HasLocation() bool

func (*S3Artifact) Marshal

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

func (*S3Artifact) MarshalTo

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

func (*S3Artifact) MarshalToSizedBuffer

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

func (*S3Artifact) ProtoMessage

func (*S3Artifact) ProtoMessage()

func (*S3Artifact) Reset

func (m *S3Artifact) Reset()

func (*S3Artifact) SetKey

func (s *S3Artifact) SetKey(key string) error

func (*S3Artifact) Size

func (m *S3Artifact) Size() (n int)

func (*S3Artifact) String

func (this *S3Artifact) String() string

func (*S3Artifact) Unmarshal

func (m *S3Artifact) Unmarshal(dAtA []byte) error

func (*S3Artifact) XXX_DiscardUnknown

func (m *S3Artifact) XXX_DiscardUnknown()

func (*S3Artifact) XXX_Marshal

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

func (*S3Artifact) XXX_Merge

func (m *S3Artifact) XXX_Merge(src proto.Message)

func (*S3Artifact) XXX_Size

func (m *S3Artifact) XXX_Size() int

func (*S3Artifact) XXX_Unmarshal

func (m *S3Artifact) XXX_Unmarshal(b []byte) error

type S3Bucket

type S3Bucket struct {
	// Endpoint is the hostname of the bucket endpoint
	Endpoint string `json:"endpoint,omitempty" protobuf:"bytes,1,opt,name=endpoint"`

	// Bucket is the name of the bucket
	Bucket string `json:"bucket,omitempty" protobuf:"bytes,2,opt,name=bucket"`

	// Region contains the optional bucket region
	Region string `json:"region,omitempty" protobuf:"bytes,3,opt,name=region"`

	// Insecure will connect to the service with TLS
	Insecure *bool `json:"insecure,omitempty" protobuf:"varint,4,opt,name=insecure"`

	// AccessKeySecret is the secret selector to the bucket's access key
	AccessKeySecret *apiv1.SecretKeySelector `json:"accessKeySecret,omitempty" protobuf:"bytes,5,opt,name=accessKeySecret"`

	// SecretKeySecret is the secret selector to the bucket's secret key
	SecretKeySecret *apiv1.SecretKeySelector `json:"secretKeySecret,omitempty" protobuf:"bytes,6,opt,name=secretKeySecret"`

	// RoleARN is the Amazon Resource Name (ARN) of the role to assume.
	RoleARN string `json:"roleARN,omitempty" protobuf:"bytes,7,opt,name=roleARN"`

	// UseSDKCreds tells the driver to figure out credentials based on sdk defaults.
	UseSDKCreds bool `json:"useSDKCreds,omitempty" protobuf:"varint,8,opt,name=useSDKCreds"`

	// CreateBucketIfNotPresent tells the driver to attempt to create the S3 bucket for output artifacts, if it doesn't exist
	CreateBucketIfNotPresent *CreateS3BucketOptions `json:"createBucketIfNotPresent,omitempty" protobuf:"bytes,9,opt,name=createBucketIfNotPresent"`
}

S3Bucket contains the access information required for interfacing with an S3 bucket

func (*S3Bucket) DeepCopy

func (in *S3Bucket) DeepCopy() *S3Bucket

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new S3Bucket.

func (*S3Bucket) DeepCopyInto

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*S3Bucket) Descriptor

func (*S3Bucket) Descriptor() ([]byte, []int)

func (*S3Bucket) Marshal

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

func (*S3Bucket) MarshalTo

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

func (*S3Bucket) MarshalToSizedBuffer

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

func (*S3Bucket) ProtoMessage

func (*S3Bucket) ProtoMessage()

func (*S3Bucket) Reset

func (m *S3Bucket) Reset()

func (*S3Bucket) Size

func (m *S3Bucket) Size() (n int)

func (*S3Bucket) String

func (this *S3Bucket) String() string

func (*S3Bucket) Unmarshal

func (m *S3Bucket) Unmarshal(dAtA []byte) error

func (*S3Bucket) XXX_DiscardUnknown

func (m *S3Bucket) XXX_DiscardUnknown()

func (*S3Bucket) XXX_Marshal

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

func (*S3Bucket) XXX_Merge

func (m *S3Bucket) XXX_Merge(src proto.Message)

func (*S3Bucket) XXX_Size

func (m *S3Bucket) XXX_Size() int

func (*S3Bucket) XXX_Unmarshal

func (m *S3Bucket) XXX_Unmarshal(b []byte) error

type ScriptTemplate

type ScriptTemplate struct {
	apiv1.Container `json:",inline" protobuf:"bytes,1,opt,name=container"`

	// Source contains the source code of the script to execute
	Source string `json:"source" protobuf:"bytes,2,opt,name=source"`
}

ScriptTemplate is a template subtype to enable scripting through code steps

func (*ScriptTemplate) DeepCopy

func (in *ScriptTemplate) DeepCopy() *ScriptTemplate

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ScriptTemplate.

func (*ScriptTemplate) DeepCopyInto

func (in *ScriptTemplate) DeepCopyInto(out *ScriptTemplate)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*ScriptTemplate) Descriptor

func (*ScriptTemplate) Descriptor() ([]byte, []int)

func (*ScriptTemplate) Marshal

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

func (*ScriptTemplate) MarshalTo

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

func (*ScriptTemplate) MarshalToSizedBuffer

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

func (*ScriptTemplate) ProtoMessage

func (*ScriptTemplate) ProtoMessage()

func (*ScriptTemplate) Reset

func (m *ScriptTemplate) Reset()

func (*ScriptTemplate) Size

func (m *ScriptTemplate) Size() (n int)

func (*ScriptTemplate) String

func (this *ScriptTemplate) String() string

func (*ScriptTemplate) Unmarshal

func (m *ScriptTemplate) Unmarshal(dAtA []byte) error

func (*ScriptTemplate) XXX_DiscardUnknown

func (m *ScriptTemplate) XXX_DiscardUnknown()

func (*ScriptTemplate) XXX_Marshal

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

func (*ScriptTemplate) XXX_Merge

func (m *ScriptTemplate) XXX_Merge(src proto.Message)

func (*ScriptTemplate) XXX_Size

func (m *ScriptTemplate) XXX_Size() int

func (*ScriptTemplate) XXX_Unmarshal

func (m *ScriptTemplate) XXX_Unmarshal(b []byte) error

type SemaphoreHolding

type SemaphoreHolding struct {
	// Semaphore stores the semaphore name.
	Semaphore string `json:"semaphore,omitempty" protobuf:"bytes,1,opt,name=semaphore"`
	// Holders stores the list of current holder names in the workflow.
	// +listType=atomic
	Holders []string `json:"holders,omitempty" protobuf:"bytes,2,opt,name=holders"`
}

func (*SemaphoreHolding) DeepCopy

func (in *SemaphoreHolding) DeepCopy() *SemaphoreHolding

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SemaphoreHolding.

func (*SemaphoreHolding) DeepCopyInto

func (in *SemaphoreHolding) DeepCopyInto(out *SemaphoreHolding)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*SemaphoreHolding) Descriptor

func (*SemaphoreHolding) Descriptor() ([]byte, []int)

func (*SemaphoreHolding) Marshal

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

func (*SemaphoreHolding) MarshalTo

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

func (*SemaphoreHolding) MarshalToSizedBuffer

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

func (*SemaphoreHolding) ProtoMessage

func (*SemaphoreHolding) ProtoMessage()

func (*SemaphoreHolding) Reset

func (m *SemaphoreHolding) Reset()

func (*SemaphoreHolding) Size

func (m *SemaphoreHolding) Size() (n int)

func (*SemaphoreHolding) String

func (this *SemaphoreHolding) String() string

func (*SemaphoreHolding) Unmarshal

func (m *SemaphoreHolding) Unmarshal(dAtA []byte) error

func (*SemaphoreHolding) XXX_DiscardUnknown

func (m *SemaphoreHolding) XXX_DiscardUnknown()

func (*SemaphoreHolding) XXX_Marshal

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

func (*SemaphoreHolding) XXX_Merge

func (m *SemaphoreHolding) XXX_Merge(src proto.Message)

func (*SemaphoreHolding) XXX_Size

func (m *SemaphoreHolding) XXX_Size() int

func (*SemaphoreHolding) XXX_Unmarshal

func (m *SemaphoreHolding) XXX_Unmarshal(b []byte) error

type SemaphoreRef

type SemaphoreRef struct {
	// ConfigMapKeyRef is configmap selector for Semaphore configuration
	ConfigMapKeyRef *apiv1.ConfigMapKeySelector `json:"configMapKeyRef,omitempty" protobuf:"bytes,1,opt,name=configMapKeyRef"`
}

SemaphoreRef is a reference of Semaphore

func (*SemaphoreRef) DeepCopy

func (in *SemaphoreRef) DeepCopy() *SemaphoreRef

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SemaphoreRef.

func (*SemaphoreRef) DeepCopyInto

func (in *SemaphoreRef) DeepCopyInto(out *SemaphoreRef)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*SemaphoreRef) Descriptor

func (*SemaphoreRef) Descriptor() ([]byte, []int)

func (*SemaphoreRef) Marshal

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

func (*SemaphoreRef) MarshalTo

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

func (*SemaphoreRef) MarshalToSizedBuffer

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

func (*SemaphoreRef) ProtoMessage

func (*SemaphoreRef) ProtoMessage()

func (*SemaphoreRef) Reset

func (m *SemaphoreRef) Reset()

func (*SemaphoreRef) Size

func (m *SemaphoreRef) Size() (n int)

func (*SemaphoreRef) String

func (this *SemaphoreRef) String() string

func (*SemaphoreRef) Unmarshal

func (m *SemaphoreRef) Unmarshal(dAtA []byte) error

func (*SemaphoreRef) XXX_DiscardUnknown

func (m *SemaphoreRef) XXX_DiscardUnknown()

func (*SemaphoreRef) XXX_Marshal

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

func (*SemaphoreRef) XXX_Merge

func (m *SemaphoreRef) XXX_Merge(src proto.Message)

func (*SemaphoreRef) XXX_Size

func (m *SemaphoreRef) XXX_Size() int

func (*SemaphoreRef) XXX_Unmarshal

func (m *SemaphoreRef) XXX_Unmarshal(b []byte) error

type SemaphoreStatus

type SemaphoreStatus struct {
	// Holding stores the list of resource acquired synchronization lock for workflows.
	Holding []SemaphoreHolding `json:"holding,omitempty" protobuf:"bytes,1,opt,name=holding"`
	// Waiting indicates the list of current synchronization lock holders.
	Waiting []SemaphoreHolding `json:"waiting,omitempty" protobuf:"bytes,2,opt,name=waiting"`
}

func (*SemaphoreStatus) DeepCopy

func (in *SemaphoreStatus) DeepCopy() *SemaphoreStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SemaphoreStatus.

func (*SemaphoreStatus) DeepCopyInto

func (in *SemaphoreStatus) DeepCopyInto(out *SemaphoreStatus)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*SemaphoreStatus) Descriptor

func (*SemaphoreStatus) Descriptor() ([]byte, []int)

func (*SemaphoreStatus) GetHolding

func (ss *SemaphoreStatus) GetHolding(semaphoreName string) (int, SemaphoreHolding)

func (*SemaphoreStatus) GetWaiting

func (ss *SemaphoreStatus) GetWaiting(semaphoreName string) (int, SemaphoreHolding)

func (*SemaphoreStatus) LockAcquired

func (ss *SemaphoreStatus) LockAcquired(holderKey, lockKey string, currentHolders []string) bool

func (*SemaphoreStatus) LockReleased

func (ss *SemaphoreStatus) LockReleased(holderKey, lockKey string) bool

func (*SemaphoreStatus) LockWaiting

func (ss *SemaphoreStatus) LockWaiting(holderKey, lockKey string, currentHolders []string) bool

func (*SemaphoreStatus) Marshal

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

func (*SemaphoreStatus) MarshalTo

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

func (*SemaphoreStatus) MarshalToSizedBuffer

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

func (*SemaphoreStatus) ProtoMessage

func (*SemaphoreStatus) ProtoMessage()

func (*SemaphoreStatus) Reset

func (m *SemaphoreStatus) Reset()

func (*SemaphoreStatus) Size

func (m *SemaphoreStatus) Size() (n int)

func (*SemaphoreStatus) String

func (this *SemaphoreStatus) String() string

func (*SemaphoreStatus) Unmarshal

func (m *SemaphoreStatus) Unmarshal(dAtA []byte) error

func (*SemaphoreStatus) XXX_DiscardUnknown

func (m *SemaphoreStatus) XXX_DiscardUnknown()

func (*SemaphoreStatus) XXX_Marshal

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

func (*SemaphoreStatus) XXX_Merge

func (m *SemaphoreStatus) XXX_Merge(src proto.Message)

func (*SemaphoreStatus) XXX_Size

func (m *SemaphoreStatus) XXX_Size() int

func (*SemaphoreStatus) XXX_Unmarshal

func (m *SemaphoreStatus) XXX_Unmarshal(b []byte) error

type Sequence

type Sequence struct {
	// Count is number of elements in the sequence (default: 0). Not to be used with end
	Count *intstr.IntOrString `json:"count,omitempty" protobuf:"bytes,1,opt,name=count"`

	// Number at which to start the sequence (default: 0)
	Start *intstr.IntOrString `json:"start,omitempty" protobuf:"bytes,2,opt,name=start"`

	// Number at which to end the sequence (default: 0). Not to be used with Count
	End *intstr.IntOrString `json:"end,omitempty" protobuf:"bytes,3,opt,name=end"`

	// Format is a printf format string to format the value in the sequence
	Format string `json:"format,omitempty" protobuf:"bytes,4,opt,name=format"`
}

Sequence expands a workflow step into numeric range

func (*Sequence) DeepCopy

func (in *Sequence) DeepCopy() *Sequence

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Sequence.

func (*Sequence) DeepCopyInto

func (in *Sequence) DeepCopyInto(out *Sequence)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*Sequence) Descriptor

func (*Sequence) Descriptor() ([]byte, []int)

func (*Sequence) Marshal

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

func (*Sequence) MarshalTo

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

func (*Sequence) MarshalToSizedBuffer

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

func (*Sequence) ProtoMessage

func (*Sequence) ProtoMessage()

func (*Sequence) Reset

func (m *Sequence) Reset()

func (*Sequence) Size

func (m *Sequence) Size() (n int)

func (*Sequence) String

func (this *Sequence) String() string

func (*Sequence) Unmarshal

func (m *Sequence) Unmarshal(dAtA []byte) error

func (*Sequence) XXX_DiscardUnknown

func (m *Sequence) XXX_DiscardUnknown()

func (*Sequence) XXX_Marshal

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

func (*Sequence) XXX_Merge

func (m *Sequence) XXX_Merge(src proto.Message)

func (*Sequence) XXX_Size

func (m *Sequence) XXX_Size() int

func (*Sequence) XXX_Unmarshal

func (m *Sequence) XXX_Unmarshal(b []byte) error

type ShutdownStrategy

type ShutdownStrategy string
const (
	ShutdownStrategyTerminate ShutdownStrategy = "Terminate"
	ShutdownStrategyStop      ShutdownStrategy = "Stop"
)

func (ShutdownStrategy) ShouldExecute

func (s ShutdownStrategy) ShouldExecute(isOnExitPod bool) bool

type Submit

type Submit struct {
	// WorkflowTemplateRef the workflow template to submit
	WorkflowTemplateRef WorkflowTemplateRef `json:"workflowTemplateRef" protobuf:"bytes,1,opt,name=workflowTemplateRef"`

	// Metadata optional means to customize select fields of the workflow metadata
	metav1.ObjectMeta `json:"metadata,omitempty" protobuf:"bytes,3,opt,name=metadata"`

	// Arguments extracted from the event and then set as arguments to the workflow created.
	Arguments *Arguments `json:"arguments,omitempty" protobuf:"bytes,2,opt,name=arguments"`
}

func (*Submit) DeepCopy

func (in *Submit) DeepCopy() *Submit

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Submit.

func (*Submit) DeepCopyInto

func (in *Submit) DeepCopyInto(out *Submit)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*Submit) Descriptor

func (*Submit) Descriptor() ([]byte, []int)

func (*Submit) Marshal

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

func (*Submit) MarshalTo

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

func (*Submit) MarshalToSizedBuffer

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

func (*Submit) ProtoMessage

func (*Submit) ProtoMessage()

func (*Submit) Reset

func (m *Submit) Reset()

func (*Submit) Size

func (m *Submit) Size() (n int)

func (*Submit) String

func (this *Submit) String() string

func (*Submit) Unmarshal

func (m *Submit) Unmarshal(dAtA []byte) error

func (*Submit) XXX_DiscardUnknown

func (m *Submit) XXX_DiscardUnknown()

func (*Submit) XXX_Marshal

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

func (*Submit) XXX_Merge

func (m *Submit) XXX_Merge(src proto.Message)

func (*Submit) XXX_Size

func (m *Submit) XXX_Size() int

func (*Submit) XXX_Unmarshal

func (m *Submit) XXX_Unmarshal(b []byte) error

type SubmitOpts

type SubmitOpts struct {
	// Name overrides metadata.name
	Name string `json:"name,omitempty" protobuf:"bytes,1,opt,name=name"`
	// GenerateName overrides metadata.generateName
	GenerateName string `json:"generateName,omitempty" protobuf:"bytes,2,opt,name=generateName"`
	// Entrypoint overrides spec.entrypoint
	Entrypoint string `json:"entryPoint,omitempty" protobuf:"bytes,4,opt,name=entrypoint"`
	// Parameters passes input parameters to workflow
	Parameters []string `json:"parameters,omitempty" protobuf:"bytes,5,rep,name=parameters"`
	// ParameterFile holds a reference to a parameter file. This option is not supported in API
	ParameterFile string `json:"parameterFile,omitempty" protobuf:"bytes,6,opt,name=parameterFile"`
	// ServiceAccount runs all pods in the workflow using specified ServiceAccount.
	ServiceAccount string `json:"serviceAccount,omitempty" protobuf:"bytes,7,opt,name=serviceAccount"`
	// DryRun validates the workflow on the client-side without creating it. This option is not supported in API
	DryRun bool `json:"dryRun,omitempty" protobuf:"varint,8,opt,name=dryRun"`
	// ServerDryRun validates the workflow on the server-side without creating it
	ServerDryRun bool `json:"serverDryRun,omitempty" protobuf:"varint,9,opt,name=serverDryRun"`
	// Labels adds to metadata.labels
	Labels string `json:"labels,omitempty" protobuf:"bytes,10,opt,name=labels"`
	// OwnerReference creates a metadata.ownerReference
	OwnerReference *metav1.OwnerReference `json:"ownerReference,omitempty" protobuf:"bytes,11,opt,name=ownerReference"`
}

SubmitOpts are workflow submission options

func (*SubmitOpts) DeepCopy

func (in *SubmitOpts) DeepCopy() *SubmitOpts

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SubmitOpts.

func (*SubmitOpts) DeepCopyInto

func (in *SubmitOpts) DeepCopyInto(out *SubmitOpts)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*SubmitOpts) Descriptor

func (*SubmitOpts) Descriptor() ([]byte, []int)

func (*SubmitOpts) Marshal

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

func (*SubmitOpts) MarshalTo

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

func (*SubmitOpts) MarshalToSizedBuffer

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

func (*SubmitOpts) ProtoMessage

func (*SubmitOpts) ProtoMessage()

func (*SubmitOpts) Reset

func (m *SubmitOpts) Reset()

func (*SubmitOpts) Size

func (m *SubmitOpts) Size() (n int)

func (*SubmitOpts) String

func (this *SubmitOpts) String() string

func (*SubmitOpts) Unmarshal

func (m *SubmitOpts) Unmarshal(dAtA []byte) error

func (*SubmitOpts) XXX_DiscardUnknown

func (m *SubmitOpts) XXX_DiscardUnknown()

func (*SubmitOpts) XXX_Marshal

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

func (*SubmitOpts) XXX_Merge

func (m *SubmitOpts) XXX_Merge(src proto.Message)

func (*SubmitOpts) XXX_Size

func (m *SubmitOpts) XXX_Size() int

func (*SubmitOpts) XXX_Unmarshal

func (m *SubmitOpts) XXX_Unmarshal(b []byte) error

type SuppliedValueFrom

type SuppliedValueFrom struct {
}

SuppliedValueFrom is a placeholder for a value to be filled in directly, either through the CLI, API, etc.

func (*SuppliedValueFrom) DeepCopy

func (in *SuppliedValueFrom) DeepCopy() *SuppliedValueFrom

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SuppliedValueFrom.

func (*SuppliedValueFrom) DeepCopyInto

func (in *SuppliedValueFrom) DeepCopyInto(out *SuppliedValueFrom)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*SuppliedValueFrom) Descriptor

func (*SuppliedValueFrom) Descriptor() ([]byte, []int)

func (*SuppliedValueFrom) Marshal

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

func (*SuppliedValueFrom) MarshalTo

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

func (*SuppliedValueFrom) MarshalToSizedBuffer

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

func (*SuppliedValueFrom) ProtoMessage

func (*SuppliedValueFrom) ProtoMessage()

func (*SuppliedValueFrom) Reset

func (m *SuppliedValueFrom) Reset()

func (*SuppliedValueFrom) Size

func (m *SuppliedValueFrom) Size() (n int)

func (*SuppliedValueFrom) String

func (this *SuppliedValueFrom) String() string

func (*SuppliedValueFrom) Unmarshal

func (m *SuppliedValueFrom) Unmarshal(dAtA []byte) error

func (*SuppliedValueFrom) XXX_DiscardUnknown

func (m *SuppliedValueFrom) XXX_DiscardUnknown()

func (*SuppliedValueFrom) XXX_Marshal

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

func (*SuppliedValueFrom) XXX_Merge

func (m *SuppliedValueFrom) XXX_Merge(src proto.Message)

func (*SuppliedValueFrom) XXX_Size

func (m *SuppliedValueFrom) XXX_Size() int

func (*SuppliedValueFrom) XXX_Unmarshal

func (m *SuppliedValueFrom) XXX_Unmarshal(b []byte) error

type SuspendTemplate

type SuspendTemplate struct {
	// Duration is the seconds to wait before automatically resuming a template
	Duration string `json:"duration,omitempty" protobuf:"bytes,1,opt,name=duration"`
}

SuspendTemplate is a template subtype to suspend a workflow at a predetermined point in time

func (*SuspendTemplate) DeepCopy

func (in *SuspendTemplate) DeepCopy() *SuspendTemplate

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SuspendTemplate.

func (*SuspendTemplate) DeepCopyInto

func (in *SuspendTemplate) DeepCopyInto(out *SuspendTemplate)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*SuspendTemplate) Descriptor

func (*SuspendTemplate) Descriptor() ([]byte, []int)

func (*SuspendTemplate) Marshal

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

func (*SuspendTemplate) MarshalTo

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

func (*SuspendTemplate) MarshalToSizedBuffer

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

func (*SuspendTemplate) ProtoMessage

func (*SuspendTemplate) ProtoMessage()

func (*SuspendTemplate) Reset

func (m *SuspendTemplate) Reset()

func (*SuspendTemplate) Size

func (m *SuspendTemplate) Size() (n int)

func (*SuspendTemplate) String

func (this *SuspendTemplate) String() string

func (*SuspendTemplate) Unmarshal

func (m *SuspendTemplate) Unmarshal(dAtA []byte) error

func (*SuspendTemplate) XXX_DiscardUnknown

func (m *SuspendTemplate) XXX_DiscardUnknown()

func (*SuspendTemplate) XXX_Marshal

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

func (*SuspendTemplate) XXX_Merge

func (m *SuspendTemplate) XXX_Merge(src proto.Message)

func (*SuspendTemplate) XXX_Size

func (m *SuspendTemplate) XXX_Size() int

func (*SuspendTemplate) XXX_Unmarshal

func (m *SuspendTemplate) XXX_Unmarshal(b []byte) error

type Synchronization

type Synchronization struct {
	// Semaphore holds the Semaphore configuration
	Semaphore *SemaphoreRef `json:"semaphore,omitempty" protobuf:"bytes,1,opt,name=semaphore"`
	// Mutex holds the Mutex lock details
	Mutex *Mutex `json:"mutex,omitempty" protobuf:"bytes,2,opt,name=mutex"`
}

Synchronization holds synchronization lock configuration

func (*Synchronization) DeepCopy

func (in *Synchronization) DeepCopy() *Synchronization

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Synchronization.

func (*Synchronization) DeepCopyInto

func (in *Synchronization) DeepCopyInto(out *Synchronization)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*Synchronization) Descriptor

func (*Synchronization) Descriptor() ([]byte, []int)

func (*Synchronization) GetType

func (s *Synchronization) GetType() SynchronizationType

func (*Synchronization) Marshal

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

func (*Synchronization) MarshalTo

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

func (*Synchronization) MarshalToSizedBuffer

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

func (*Synchronization) ProtoMessage

func (*Synchronization) ProtoMessage()

func (*Synchronization) Reset

func (m *Synchronization) Reset()

func (*Synchronization) Size

func (m *Synchronization) Size() (n int)

func (*Synchronization) String

func (this *Synchronization) String() string

func (*Synchronization) Unmarshal

func (m *Synchronization) Unmarshal(dAtA []byte) error

func (*Synchronization) XXX_DiscardUnknown

func (m *Synchronization) XXX_DiscardUnknown()

func (*Synchronization) XXX_Marshal

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

func (*Synchronization) XXX_Merge

func (m *Synchronization) XXX_Merge(src proto.Message)

func (*Synchronization) XXX_Size

func (m *Synchronization) XXX_Size() int

func (*Synchronization) XXX_Unmarshal

func (m *Synchronization) XXX_Unmarshal(b []byte) error

type SynchronizationAction

type SynchronizationAction interface {
	LockWaiting(holderKey, lockKey string, currentHolders []string) bool
	LockAcquired(holderKey, lockKey string, currentHolders []string) bool
	LockReleased(holderKey, lockKey string) bool
}

type SynchronizationStatus

type SynchronizationStatus struct {
	// Semaphore stores this workflow's Semaphore holder details
	Semaphore *SemaphoreStatus `json:"semaphore,omitempty" protobuf:"bytes,1,opt,name=semaphore"`
	// Mutex stores this workflow's mutex holder details
	Mutex *MutexStatus `json:"mutex,omitempty" protobuf:"bytes,2,opt,name=mutex"`
}

SynchronizationStatus stores the status of semaphore and mutex.

func (*SynchronizationStatus) DeepCopy

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SynchronizationStatus.

func (*SynchronizationStatus) DeepCopyInto

func (in *SynchronizationStatus) DeepCopyInto(out *SynchronizationStatus)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*SynchronizationStatus) Descriptor

func (*SynchronizationStatus) Descriptor() ([]byte, []int)

func (*SynchronizationStatus) GetStatus

func (*SynchronizationStatus) Marshal

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

func (*SynchronizationStatus) MarshalTo

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

func (*SynchronizationStatus) MarshalToSizedBuffer

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

func (*SynchronizationStatus) ProtoMessage

func (*SynchronizationStatus) ProtoMessage()

func (*SynchronizationStatus) Reset

func (m *SynchronizationStatus) Reset()

func (*SynchronizationStatus) Size

func (m *SynchronizationStatus) Size() (n int)

func (*SynchronizationStatus) String

func (this *SynchronizationStatus) String() string

func (*SynchronizationStatus) Unmarshal

func (m *SynchronizationStatus) Unmarshal(dAtA []byte) error

func (*SynchronizationStatus) XXX_DiscardUnknown

func (m *SynchronizationStatus) XXX_DiscardUnknown()

func (*SynchronizationStatus) XXX_Marshal

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

func (*SynchronizationStatus) XXX_Merge

func (m *SynchronizationStatus) XXX_Merge(src proto.Message)

func (*SynchronizationStatus) XXX_Size

func (m *SynchronizationStatus) XXX_Size() int

func (*SynchronizationStatus) XXX_Unmarshal

func (m *SynchronizationStatus) XXX_Unmarshal(b []byte) error

type SynchronizationType

type SynchronizationType string
const (
	SynchronizationTypeSemaphore SynchronizationType = "Semaphore"
	SynchronizationTypeMutex     SynchronizationType = "Mutex"
	SynchronizationTypeUnknown   SynchronizationType = "Unknown"
)

type TTLStrategy

type TTLStrategy struct {
	// SecondsAfterCompletion is the number of seconds to live after completion
	SecondsAfterCompletion *int32 `json:"secondsAfterCompletion,omitempty" protobuf:"bytes,1,opt,name=secondsAfterCompletion"`
	// SecondsAfterSuccess is the number of seconds to live after success
	SecondsAfterSuccess *int32 `json:"secondsAfterSuccess,omitempty" protobuf:"bytes,2,opt,name=secondsAfterSuccess"`
	// SecondsAfterFailure is the number of seconds to live after failure
	SecondsAfterFailure *int32 `json:"secondsAfterFailure,omitempty" protobuf:"bytes,3,opt,name=secondsAfterFailure"`
}

TTLStrategy is the strategy for the time to live depending on if the workflow succeeded or failed

func (*TTLStrategy) DeepCopy

func (in *TTLStrategy) DeepCopy() *TTLStrategy

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new TTLStrategy.

func (*TTLStrategy) DeepCopyInto

func (in *TTLStrategy) DeepCopyInto(out *TTLStrategy)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*TTLStrategy) Descriptor

func (*TTLStrategy) Descriptor() ([]byte, []int)

func (*TTLStrategy) Marshal

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

func (*TTLStrategy) MarshalTo

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

func (*TTLStrategy) MarshalToSizedBuffer

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

func (*TTLStrategy) ProtoMessage

func (*TTLStrategy) ProtoMessage()

func (*TTLStrategy) Reset

func (m *TTLStrategy) Reset()

func (*TTLStrategy) Size

func (m *TTLStrategy) Size() (n int)

func (*TTLStrategy) String

func (this *TTLStrategy) String() string

func (*TTLStrategy) Unmarshal

func (m *TTLStrategy) Unmarshal(dAtA []byte) error

func (*TTLStrategy) XXX_DiscardUnknown

func (m *TTLStrategy) XXX_DiscardUnknown()

func (*TTLStrategy) XXX_Marshal

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

func (*TTLStrategy) XXX_Merge

func (m *TTLStrategy) XXX_Merge(src proto.Message)

func (*TTLStrategy) XXX_Size

func (m *TTLStrategy) XXX_Size() int

func (*TTLStrategy) XXX_Unmarshal

func (m *TTLStrategy) XXX_Unmarshal(b []byte) error

type TarStrategy

type TarStrategy struct {
	// CompressionLevel specifies the gzip compression level to use for the artifact.
	// Defaults to gzip.DefaultCompression.
	CompressionLevel *int32 `json:"compressionLevel,omitempty" protobuf:"varint,1,opt,name=compressionLevel"`
}

TarStrategy will tar and gzip the file or directory when saving

func (*TarStrategy) DeepCopy

func (in *TarStrategy) DeepCopy() *TarStrategy

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new TarStrategy.

func (*TarStrategy) DeepCopyInto

func (in *TarStrategy) DeepCopyInto(out *TarStrategy)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*TarStrategy) Descriptor

func (*TarStrategy) Descriptor() ([]byte, []int)

func (*TarStrategy) Marshal

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

func (*TarStrategy) MarshalTo

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

func (*TarStrategy) MarshalToSizedBuffer

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

func (*TarStrategy) ProtoMessage

func (*TarStrategy) ProtoMessage()

func (*TarStrategy) Reset

func (m *TarStrategy) Reset()

func (*TarStrategy) Size

func (m *TarStrategy) Size() (n int)

func (*TarStrategy) String

func (this *TarStrategy) String() string

func (*TarStrategy) Unmarshal

func (m *TarStrategy) Unmarshal(dAtA []byte) error

func (*TarStrategy) XXX_DiscardUnknown

func (m *TarStrategy) XXX_DiscardUnknown()

func (*TarStrategy) XXX_Marshal

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

func (*TarStrategy) XXX_Merge

func (m *TarStrategy) XXX_Merge(src proto.Message)

func (*TarStrategy) XXX_Size

func (m *TarStrategy) XXX_Size() int

func (*TarStrategy) XXX_Unmarshal

func (m *TarStrategy) XXX_Unmarshal(b []byte) error

type Template

type Template struct {
	// Name is the name of the template
	Name string `json:"name" protobuf:"bytes,1,opt,name=name"`

	// Template is the name of the template which is used as the base of this template.
	// DEPRECATED: This field is not used.
	Template string `json:"template,omitempty" protobuf:"bytes,2,opt,name=template"`

	// Arguments hold arguments to the template.
	// DEPRECATED: This field is not used.
	Arguments Arguments `json:"arguments,omitempty" protobuf:"bytes,3,opt,name=arguments"`

	// TemplateRef is the reference to the template resource which is used as the base of this template.
	// DEPRECATED: This field is not used.
	TemplateRef *TemplateRef `json:"templateRef,omitempty" protobuf:"bytes,4,opt,name=templateRef"`

	// Inputs describe what inputs parameters and artifacts are supplied to this template
	Inputs Inputs `json:"inputs,omitempty" protobuf:"bytes,5,opt,name=inputs"`

	// Outputs describe the parameters and artifacts that this template produces
	Outputs Outputs `json:"outputs,omitempty" protobuf:"bytes,6,opt,name=outputs"`

	// NodeSelector is a selector to schedule this step of the workflow to be
	// run on the selected node(s). Overrides the selector set at the workflow level.
	NodeSelector map[string]string `json:"nodeSelector,omitempty" protobuf:"bytes,7,opt,name=nodeSelector"`

	// Affinity sets the pod's scheduling constraints
	// Overrides the affinity set at the workflow level (if any)
	Affinity *apiv1.Affinity `json:"affinity,omitempty" protobuf:"bytes,8,opt,name=affinity"`

	// Metdata sets the pods's metadata, i.e. annotations and labels
	Metadata Metadata `json:"metadata,omitempty" protobuf:"bytes,9,opt,name=metadata"`

	// Deamon will allow a workflow to proceed to the next step so long as the container reaches readiness
	Daemon *bool `json:"daemon,omitempty" protobuf:"bytes,10,opt,name=daemon"`

	// Steps define a series of sequential/parallel workflow steps
	Steps []ParallelSteps `json:"steps,omitempty" protobuf:"bytes,11,opt,name=steps"`

	// Container is the main container image to run in the pod
	Container *apiv1.Container `json:"container,omitempty" protobuf:"bytes,12,opt,name=container"`

	// Script runs a portion of code against an interpreter
	Script *ScriptTemplate `json:"script,omitempty" protobuf:"bytes,13,opt,name=script"`

	// Resource template subtype which can run k8s resources
	Resource *ResourceTemplate `json:"resource,omitempty" protobuf:"bytes,14,opt,name=resource"`

	// DAG template subtype which runs a DAG
	DAG *DAGTemplate `json:"dag,omitempty" protobuf:"bytes,15,opt,name=dag"`

	// Suspend template subtype which can suspend a workflow when reaching the step
	Suspend *SuspendTemplate `json:"suspend,omitempty" protobuf:"bytes,16,opt,name=suspend"`

	// Volumes is a list of volumes that can be mounted by containers in a template.
	// +patchStrategy=merge
	// +patchMergeKey=name
	Volumes []apiv1.Volume `json:"volumes,omitempty" patchStrategy:"merge" patchMergeKey:"name" protobuf:"bytes,17,opt,name=volumes"`

	// InitContainers is a list of containers which run before the main container.
	// +patchStrategy=merge
	// +patchMergeKey=name
	InitContainers []UserContainer `json:"initContainers,omitempty" patchStrategy:"merge" patchMergeKey:"name" protobuf:"bytes,18,opt,name=initContainers"`

	// Sidecars is a list of containers which run alongside the main container
	// Sidecars are automatically killed when the main container completes
	// +patchStrategy=merge
	// +patchMergeKey=name
	Sidecars []UserContainer `json:"sidecars,omitempty" patchStrategy:"merge" patchMergeKey:"name" protobuf:"bytes,19,opt,name=sidecars"`

	// Location in which all files related to the step will be stored (logs, artifacts, etc...).
	// Can be overridden by individual items in Outputs. If omitted, will use the default
	// artifact repository location configured in the controller, appended with the
	// <workflowname>/<nodename> in the key.
	ArchiveLocation *ArtifactLocation `json:"archiveLocation,omitempty" protobuf:"bytes,20,opt,name=archiveLocation"`

	// Optional duration in seconds relative to the StartTime that the pod may be active on a node
	// before the system actively tries to terminate the pod; value must be positive integer
	// This field is only applicable to container and script templates.
	ActiveDeadlineSeconds *intstr.IntOrString `json:"activeDeadlineSeconds,omitempty" protobuf:"bytes,21,opt,name=activeDeadlineSeconds"`

	// RetryStrategy describes how to retry a template when it fails
	RetryStrategy *RetryStrategy `json:"retryStrategy,omitempty" protobuf:"bytes,22,opt,name=retryStrategy"`

	// Parallelism limits the max total parallel pods that can execute at the same time within the
	// boundaries of this template invocation. If additional steps/dag templates are invoked, the
	// pods created by those templates will not be counted towards this total.
	Parallelism *int64 `json:"parallelism,omitempty" protobuf:"bytes,23,opt,name=parallelism"`

	// Tolerations to apply to workflow pods.
	// +patchStrategy=merge
	// +patchMergeKey=key
	Tolerations []apiv1.Toleration `json:"tolerations,omitempty" patchStrategy:"merge" patchMergeKey:"key" protobuf:"bytes,24,opt,name=tolerations"`

	// If specified, the pod will be dispatched by specified scheduler.
	// Or it will be dispatched by workflow scope scheduler if specified.
	// If neither specified, the pod will be dispatched by default scheduler.
	// +optional
	SchedulerName string `json:"schedulerName,omitempty" protobuf:"bytes,25,opt,name=schedulerName"`

	// PriorityClassName to apply to workflow pods.
	PriorityClassName string `json:"priorityClassName,omitempty" protobuf:"bytes,26,opt,name=priorityClassName"`

	// Priority to apply to workflow pods.
	Priority *int32 `json:"priority,omitempty" protobuf:"bytes,27,opt,name=priority"`

	// ServiceAccountName to apply to workflow pods
	ServiceAccountName string `json:"serviceAccountName,omitempty" protobuf:"bytes,28,opt,name=serviceAccountName"`

	// AutomountServiceAccountToken indicates whether a service account token should be automatically mounted in pods.
	// ServiceAccountName of ExecutorConfig must be specified if this value is false.
	AutomountServiceAccountToken *bool `json:"automountServiceAccountToken,omitempty" protobuf:"varint,32,opt,name=automountServiceAccountToken"`

	// Executor holds configurations of the executor container.
	Executor *ExecutorConfig `json:"executor,omitempty" protobuf:"bytes,33,opt,name=executor"`

	// HostAliases is an optional list of hosts and IPs that will be injected into the pod spec
	// +patchStrategy=merge
	// +patchMergeKey=ip
	HostAliases []apiv1.HostAlias `json:"hostAliases,omitempty" patchStrategy:"merge" patchMergeKey:"ip" protobuf:"bytes,29,opt,name=hostAliases"`

	// SecurityContext holds pod-level security attributes and common container settings.
	// Optional: Defaults to empty.  See type description for default values of each field.
	// +optional
	SecurityContext *apiv1.PodSecurityContext `json:"securityContext,omitempty" protobuf:"bytes,30,opt,name=securityContext"`

	// PodSpecPatch holds strategic merge patch to apply against the pod spec. Allows parameterization of
	// container fields which are not strings (e.g. resource limits).
	PodSpecPatch string `json:"podSpecPatch,omitempty" protobuf:"bytes,31,opt,name=podSpecPatch"`

	// Metrics are a list of metrics emitted from this template
	Metrics *Metrics `json:"metrics,omitempty" protobuf:"bytes,35,opt,name=metrics"`

	// Synchronization holds synchronization lock configuration for this template
	Synchronization *Synchronization `json:"synchronization,omitempty" protobuf:"bytes,36,opt,name=synchronization,casttype=Synchronization"`

	// Memoize allows templates to use outputs generated from already executed templates
	Memoize *Memoize `json:"memoize,omitempty" protobuf:"bytes,37,opt,name=memoize"`

	// Timout allows to set the total node execution timeout duration counting from the node's start time.
	// This duration also includes time in which the node spends in Pending state. This duration may not be applied to Step or DAG templates.
	Timeout string `json:"timeout,omitempty" protobuf:"bytes,38,opt,name=timeout"`
}

Template is a reusable and composable unit of execution in a workflow

func (*Template) DeepCopy

func (in *Template) DeepCopy() *Template

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Template.

func (*Template) DeepCopyInto

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*Template) Descriptor

func (*Template) Descriptor() ([]byte, []int)

func (*Template) GetBaseTemplate

func (tmpl *Template) GetBaseTemplate() *Template

GetBaseTemplate returns a base template content.

func (*Template) GetTemplateName

func (tmpl *Template) GetTemplateName() string

DEPRECATED: Templates should not be used as TemplateReferenceHolder

func (*Template) GetTemplateRef

func (tmpl *Template) GetTemplateRef() *TemplateRef

DEPRECATED: Templates should not be used as TemplateReferenceHolder

func (*Template) GetType

func (tmpl *Template) GetType() TemplateType

GetType returns the type of this template

func (*Template) HasPodSpecPatch

func (tmpl *Template) HasPodSpecPatch() bool

func (*Template) IsLeaf

func (tmpl *Template) IsLeaf() bool

IsLeaf returns whether or not the template is a leaf

func (*Template) IsPodType

func (tmpl *Template) IsPodType() bool

IsPodType returns whether or not the template is a pod type

func (*Template) Marshal

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

func (*Template) MarshalTo

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

func (*Template) MarshalToSizedBuffer

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

func (*Template) ProtoMessage

func (*Template) ProtoMessage()

func (*Template) Reset

func (m *Template) Reset()

func (*Template) Size

func (m *Template) Size() (n int)

func (*Template) String

func (this *Template) String() string

func (*Template) Unmarshal

func (m *Template) Unmarshal(dAtA []byte) error

func (*Template) XXX_DiscardUnknown

func (m *Template) XXX_DiscardUnknown()

func (*Template) XXX_Marshal

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

func (*Template) XXX_Merge

func (m *Template) XXX_Merge(src proto.Message)

func (*Template) XXX_Size

func (m *Template) XXX_Size() int

func (*Template) XXX_Unmarshal

func (m *Template) XXX_Unmarshal(b []byte) error

type TemplateHolder

type TemplateHolder interface {
	GetNamespace() string
	GetName() string
	GroupVersionKind() schema.GroupVersionKind
	GetTemplateByName(name string) *Template
	GetResourceScope() ResourceScope
}

TemplateHolder is an object that holds templates; e.g. Workflow, WorkflowTemplate, and ClusterWorkflowTemplate

type TemplateRef

type TemplateRef struct {
	// Name is the resource name of the template.
	Name string `json:"name,omitempty" protobuf:"bytes,1,opt,name=name"`
	// Template is the name of referred template in the resource.
	Template string `json:"template,omitempty" protobuf:"bytes,2,opt,name=template"`
	// RuntimeResolution skips validation at creation time.
	// By enabling this option, you can create the referred workflow template before the actual runtime.
	// DEPRECATED: This value is not used anymore and is ignored
	RuntimeResolution bool `json:"runtimeResolution,omitempty" protobuf:"varint,3,opt,name=runtimeResolution"`
	// ClusterScope indicates the referred template is cluster scoped (i.e. a ClusterWorkflowTemplate).
	ClusterScope bool `json:"clusterScope,omitempty" protobuf:"varint,4,opt,name=clusterScope"`
}

TemplateRef is a reference of template resource.

func (*TemplateRef) DeepCopy

func (in *TemplateRef) DeepCopy() *TemplateRef

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new TemplateRef.

func (*TemplateRef) DeepCopyInto

func (in *TemplateRef) DeepCopyInto(out *TemplateRef)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*TemplateRef) Descriptor

func (*TemplateRef) Descriptor() ([]byte, []int)

func (*TemplateRef) Marshal

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

func (*TemplateRef) MarshalTo

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

func (*TemplateRef) MarshalToSizedBuffer

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

func (*TemplateRef) ProtoMessage

func (*TemplateRef) ProtoMessage()

func (*TemplateRef) Reset

func (m *TemplateRef) Reset()

func (*TemplateRef) Size

func (m *TemplateRef) Size() (n int)

func (*TemplateRef) String

func (this *TemplateRef) String() string

func (*TemplateRef) Unmarshal

func (m *TemplateRef) Unmarshal(dAtA []byte) error

func (*TemplateRef) XXX_DiscardUnknown

func (m *TemplateRef) XXX_DiscardUnknown()

func (*TemplateRef) XXX_Marshal

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

func (*TemplateRef) XXX_Merge

func (m *TemplateRef) XXX_Merge(src proto.Message)

func (*TemplateRef) XXX_Size

func (m *TemplateRef) XXX_Size() int

func (*TemplateRef) XXX_Unmarshal

func (m *TemplateRef) XXX_Unmarshal(b []byte) error

type TemplateReferenceHolder

type TemplateReferenceHolder interface {
	GetTemplateName() string
	GetTemplateRef() *TemplateRef
}

TemplateReferenceHolder is an object that holds a reference to other templates; e.g. WorkflowStep, DAGTask, and NodeStatus

type TemplateType

type TemplateType string

TemplateType is the type of a template

const (
	TemplateTypeContainer TemplateType = "Container"
	TemplateTypeSteps     TemplateType = "Steps"
	TemplateTypeScript    TemplateType = "Script"
	TemplateTypeResource  TemplateType = "Resource"
	TemplateTypeDAG       TemplateType = "DAG"
	TemplateTypeSuspend   TemplateType = "Suspend"
	TemplateTypeUnknown   TemplateType = "Unknown"
)

Possible template types

type Type

type Type int

Type represents the stored type of Item.

const (
	Number Type = iota
	String
	Bool
	Map
	List
)

type UserContainer

type UserContainer struct {
	apiv1.Container `json:",inline" protobuf:"bytes,1,opt,name=container"`

	// MirrorVolumeMounts will mount the same volumes specified in the main container
	// to the container (including artifacts), at the same mountPaths. This enables
	// dind daemon to partially see the same filesystem as the main container in
	// order to use features such as docker volume binding
	MirrorVolumeMounts *bool `json:"mirrorVolumeMounts,omitempty" protobuf:"varint,2,opt,name=mirrorVolumeMounts"`
}

UserContainer is a container specified by a user.

func (*UserContainer) DeepCopy

func (in *UserContainer) DeepCopy() *UserContainer

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new UserContainer.

func (*UserContainer) DeepCopyInto

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*UserContainer) Descriptor

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

func (*UserContainer) Marshal

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

func (*UserContainer) MarshalTo

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

func (*UserContainer) MarshalToSizedBuffer

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

func (*UserContainer) ProtoMessage

func (*UserContainer) ProtoMessage()

func (*UserContainer) Reset

func (m *UserContainer) Reset()

func (*UserContainer) Size

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

func (*UserContainer) String

func (this *UserContainer) String() string

func (*UserContainer) Unmarshal

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

func (*UserContainer) XXX_DiscardUnknown

func (m *UserContainer) XXX_DiscardUnknown()

func (*UserContainer) XXX_Marshal

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

func (*UserContainer) XXX_Merge

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

func (*UserContainer) XXX_Size

func (m *UserContainer) XXX_Size() int

func (*UserContainer) XXX_Unmarshal

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

type ValueFrom

type ValueFrom struct {
	// Path in the container to retrieve an output parameter value from in container templates
	Path string `json:"path,omitempty" protobuf:"bytes,1,opt,name=path"`

	// JSONPath of a resource to retrieve an output parameter value from in resource templates
	JSONPath string `json:"jsonPath,omitempty" protobuf:"bytes,2,opt,name=jsonPath"`

	// JQFilter expression against the resource object in resource templates
	JQFilter string `json:"jqFilter,omitempty" protobuf:"bytes,3,opt,name=jqFilter"`

	// Selector (https://github.com/antonmedv/expr) that is evaluated against the event to get the value of the parameter. E.g. `payload.message`
	Event string `json:"event,omitempty" protobuf:"bytes,7,opt,name=event"`

	// Parameter reference to a step or dag task in which to retrieve an output parameter value from
	// (e.g. '{{steps.mystep.outputs.myparam}}')
	Parameter string `json:"parameter,omitempty" protobuf:"bytes,4,opt,name=parameter"`

	// Supplied value to be filled in directly, either through the CLI, API, etc.
	Supplied *SuppliedValueFrom `json:"supplied,omitempty" protobuf:"bytes,6,opt,name=supplied"`

	// Default specifies a value to be used if retrieving the value from the specified source fails
	Default *AnyString `json:"default,omitempty" protobuf:"bytes,5,opt,name=default"`
}

ValueFrom describes a location in which to obtain the value to a parameter

func (*ValueFrom) DeepCopy

func (in *ValueFrom) DeepCopy() *ValueFrom

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ValueFrom.

func (*ValueFrom) DeepCopyInto

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*ValueFrom) Descriptor

func (*ValueFrom) Descriptor() ([]byte, []int)

func (*ValueFrom) Marshal

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

func (*ValueFrom) MarshalTo

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

func (*ValueFrom) MarshalToSizedBuffer

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

func (*ValueFrom) ProtoMessage

func (*ValueFrom) ProtoMessage()

func (*ValueFrom) Reset

func (m *ValueFrom) Reset()

func (*ValueFrom) Size

func (m *ValueFrom) Size() (n int)

func (*ValueFrom) String

func (this *ValueFrom) String() string

func (*ValueFrom) Unmarshal

func (m *ValueFrom) Unmarshal(dAtA []byte) error

func (*ValueFrom) XXX_DiscardUnknown

func (m *ValueFrom) XXX_DiscardUnknown()

func (*ValueFrom) XXX_Marshal

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

func (*ValueFrom) XXX_Merge

func (m *ValueFrom) XXX_Merge(src proto.Message)

func (*ValueFrom) XXX_Size

func (m *ValueFrom) XXX_Size() int

func (*ValueFrom) XXX_Unmarshal

func (m *ValueFrom) XXX_Unmarshal(b []byte) error

type Version

type Version struct {
	Version      string `json:"version" protobuf:"bytes,1,opt,name=version"`
	BuildDate    string `json:"buildDate" protobuf:"bytes,2,opt,name=buildDate"`
	GitCommit    string `json:"gitCommit" protobuf:"bytes,3,opt,name=gitCommit"`
	GitTag       string `json:"gitTag" protobuf:"bytes,4,opt,name=gitTag"`
	GitTreeState string `json:"gitTreeState" protobuf:"bytes,5,opt,name=gitTreeState"`
	GoVersion    string `json:"goVersion" protobuf:"bytes,6,opt,name=goVersion"`
	Compiler     string `json:"compiler" protobuf:"bytes,7,opt,name=compiler"`
	Platform     string `json:"platform" protobuf:"bytes,8,opt,name=platform"`
}

func (*Version) DeepCopy

func (in *Version) DeepCopy() *Version

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Version.

func (*Version) DeepCopyInto

func (in *Version) DeepCopyInto(out *Version)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*Version) Descriptor

func (*Version) Descriptor() ([]byte, []int)

func (*Version) Marshal

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

func (*Version) MarshalTo

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

func (*Version) MarshalToSizedBuffer

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

func (*Version) ProtoMessage

func (*Version) ProtoMessage()

func (*Version) Reset

func (m *Version) Reset()

func (*Version) Size

func (m *Version) Size() (n int)

func (*Version) String

func (this *Version) String() string

func (*Version) Unmarshal

func (m *Version) Unmarshal(dAtA []byte) error

func (*Version) XXX_DiscardUnknown

func (m *Version) XXX_DiscardUnknown()

func (*Version) XXX_Marshal

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

func (*Version) XXX_Merge

func (m *Version) XXX_Merge(src proto.Message)

func (*Version) XXX_Size

func (m *Version) XXX_Size() int

func (*Version) XXX_Unmarshal

func (m *Version) XXX_Unmarshal(b []byte) error

type VolumeClaimGC

type VolumeClaimGC struct {
	// Strategy is the strategy to use. One of "OnWorkflowCompletion", "OnWorkflowSuccess"
	Strategy VolumeClaimGCStrategy `json:"strategy,omitempty" protobuf:"bytes,1,opt,name=strategy,casttype=VolumeClaimGCStrategy"`
}

VolumeClaimGC describes how to delete volumes from completed Workflows

func (*VolumeClaimGC) DeepCopy

func (in *VolumeClaimGC) DeepCopy() *VolumeClaimGC

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new VolumeClaimGC.

func (*VolumeClaimGC) DeepCopyInto

func (in *VolumeClaimGC) DeepCopyInto(out *VolumeClaimGC)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*VolumeClaimGC) Descriptor

func (*VolumeClaimGC) Descriptor() ([]byte, []int)

func (VolumeClaimGC) GetStrategy

func (vgc VolumeClaimGC) GetStrategy() VolumeClaimGCStrategy

GetStrategy returns the VolumeClaimGCStrategy to use for the workflow

func (*VolumeClaimGC) Marshal

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

func (*VolumeClaimGC) MarshalTo

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

func (*VolumeClaimGC) MarshalToSizedBuffer

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

func (*VolumeClaimGC) ProtoMessage

func (*VolumeClaimGC) ProtoMessage()

func (*VolumeClaimGC) Reset

func (m *VolumeClaimGC) Reset()

func (*VolumeClaimGC) Size

func (m *VolumeClaimGC) Size() (n int)

func (*VolumeClaimGC) String

func (this *VolumeClaimGC) String() string

func (*VolumeClaimGC) Unmarshal

func (m *VolumeClaimGC) Unmarshal(dAtA []byte) error

func (*VolumeClaimGC) XXX_DiscardUnknown

func (m *VolumeClaimGC) XXX_DiscardUnknown()

func (*VolumeClaimGC) XXX_Marshal

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

func (*VolumeClaimGC) XXX_Merge

func (m *VolumeClaimGC) XXX_Merge(src proto.Message)

func (*VolumeClaimGC) XXX_Size

func (m *VolumeClaimGC) XXX_Size() int

func (*VolumeClaimGC) XXX_Unmarshal

func (m *VolumeClaimGC) XXX_Unmarshal(b []byte) error

type VolumeClaimGCStrategy

type VolumeClaimGCStrategy string

VolumeClaimGCStrategy is the strategy to use when deleting volumes from completed workflows

const (
	VolumeClaimGCOnCompletion VolumeClaimGCStrategy = "OnWorkflowCompletion"
	VolumeClaimGCOnSuccess    VolumeClaimGCStrategy = "OnWorkflowSuccess"
)

type Workflow

type Workflow struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata" protobuf:"bytes,1,opt,name=metadata"`
	Spec              WorkflowSpec   `json:"spec" protobuf:"bytes,2,opt,name=spec "`
	Status            WorkflowStatus `json:"status,omitempty" protobuf:"bytes,3,opt,name=status"`
}

Workflow is the definition of a workflow resource +genclient +genclient:noStatus +kubebuilder:resource:shortName=wf +kubebuilder:printcolumn:name="Status",type="string",JSONPath=".status.phase",description="Status of the workflow" +kubebuilder:printcolumn:name="Age",type="date",format="date-time",JSONPath=".status.startedAt",description="When the workflow was started" +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object

func (*Workflow) DeepCopy

func (in *Workflow) DeepCopy() *Workflow

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Workflow.

func (*Workflow) DeepCopyInto

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*Workflow) DeepCopyObject

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

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*Workflow) Descriptor

func (*Workflow) Descriptor() ([]byte, []int)

func (*Workflow) GetNodeByName

func (wf *Workflow) GetNodeByName(nodeName string) *NodeStatus

func (*Workflow) GetOffloadNodeStatusVersion

func (wf *Workflow) GetOffloadNodeStatusVersion() string

func (*Workflow) GetResourceScope

func (wf *Workflow) GetResourceScope() ResourceScope

GetResourceScope returns the template scope of workflow.

func (*Workflow) GetSemaphoreKeys

func (wf *Workflow) GetSemaphoreKeys() []string

GetSemaphoreKeys will return list of semaphore configmap keys which are configured in the workflow Example key format namespace/configmapname (argo/my-config) Return []string

func (*Workflow) GetStoredTemplate

func (wf *Workflow) GetStoredTemplate(scope ResourceScope, resourceName string, caller TemplateReferenceHolder) *Template

GetStoredTemplate retrieves a template from stored templates of the workflow.

func (*Workflow) GetTTLStrategy

func (w *Workflow) GetTTLStrategy() *TTLStrategy

GetTTLStrategy return TTLStrategy based on Order of precedence: 1. Workflow, 2. WorkflowTemplate, 3. Workflowdefault

func (*Workflow) GetTemplateByName

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

GetTemplateByName retrieves a defined template by its name

func (*Workflow) GetWorkflowSpec

func (wf *Workflow) GetWorkflowSpec() WorkflowSpec

GetWorkflowSpec returns the Spec of a workflow.

func (*Workflow) Marshal

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

func (*Workflow) MarshalTo

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

func (*Workflow) MarshalToSizedBuffer

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

func (*Workflow) NodeID

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

NodeID creates a deterministic node ID based on a node name

func (*Workflow) ProtoMessage

func (*Workflow) ProtoMessage()

func (*Workflow) Reset

func (m *Workflow) Reset()

func (*Workflow) SetStoredTemplate

func (wf *Workflow) SetStoredTemplate(scope ResourceScope, resourceName string, caller TemplateReferenceHolder, tmpl *Template) (bool, error)

SetStoredTemplate stores a new template in stored templates of the workflow.

func (*Workflow) Size

func (m *Workflow) Size() (n int)

func (*Workflow) String

func (this *Workflow) String() string

func (*Workflow) Unmarshal

func (m *Workflow) Unmarshal(dAtA []byte) error

func (*Workflow) XXX_DiscardUnknown

func (m *Workflow) XXX_DiscardUnknown()

func (*Workflow) XXX_Marshal

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

func (*Workflow) XXX_Merge

func (m *Workflow) XXX_Merge(src proto.Message)

func (*Workflow) XXX_Size

func (m *Workflow) XXX_Size() int

func (*Workflow) XXX_Unmarshal

func (m *Workflow) XXX_Unmarshal(b []byte) error

type WorkflowEventBinding

type WorkflowEventBinding struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata" protobuf:"bytes,1,opt,name=metadata"`
	Spec              WorkflowEventBindingSpec `json:"spec" protobuf:"bytes,2,opt,name=spec"`
}

WorkflowEventBinding is the definition of an event resource +genclient +genclient:noStatus +kubebuilder:resource:shortName=wfeb +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object

func (*WorkflowEventBinding) DeepCopy

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new WorkflowEventBinding.

func (*WorkflowEventBinding) DeepCopyInto

func (in *WorkflowEventBinding) DeepCopyInto(out *WorkflowEventBinding)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*WorkflowEventBinding) DeepCopyObject

func (in *WorkflowEventBinding) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*WorkflowEventBinding) Descriptor

func (*WorkflowEventBinding) Descriptor() ([]byte, []int)

func (*WorkflowEventBinding) Marshal

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

func (*WorkflowEventBinding) MarshalTo

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

func (*WorkflowEventBinding) MarshalToSizedBuffer

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

func (*WorkflowEventBinding) ProtoMessage

func (*WorkflowEventBinding) ProtoMessage()

func (*WorkflowEventBinding) Reset

func (m *WorkflowEventBinding) Reset()

func (*WorkflowEventBinding) Size

func (m *WorkflowEventBinding) Size() (n int)

func (*WorkflowEventBinding) String

func (this *WorkflowEventBinding) String() string

func (*WorkflowEventBinding) Unmarshal

func (m *WorkflowEventBinding) Unmarshal(dAtA []byte) error

func (*WorkflowEventBinding) XXX_DiscardUnknown

func (m *WorkflowEventBinding) XXX_DiscardUnknown()

func (*WorkflowEventBinding) XXX_Marshal

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

func (*WorkflowEventBinding) XXX_Merge

func (m *WorkflowEventBinding) XXX_Merge(src proto.Message)

func (*WorkflowEventBinding) XXX_Size

func (m *WorkflowEventBinding) XXX_Size() int

func (*WorkflowEventBinding) XXX_Unmarshal

func (m *WorkflowEventBinding) XXX_Unmarshal(b []byte) error

type WorkflowEventBindingList

type WorkflowEventBindingList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata" protobuf:"bytes,1,opt,name=metadata"`
	Items           []WorkflowEventBinding `json:"items" protobuf:"bytes,2,rep,name=items"`
}

WorkflowEventBindingList is list of event resources +kubebuilder:resource:shortName=wfebs +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object

func (*WorkflowEventBindingList) DeepCopy

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new WorkflowEventBindingList.

func (*WorkflowEventBindingList) DeepCopyInto

func (in *WorkflowEventBindingList) DeepCopyInto(out *WorkflowEventBindingList)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*WorkflowEventBindingList) DeepCopyObject

func (in *WorkflowEventBindingList) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*WorkflowEventBindingList) Descriptor

func (*WorkflowEventBindingList) Descriptor() ([]byte, []int)

func (*WorkflowEventBindingList) Marshal

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

func (*WorkflowEventBindingList) MarshalTo

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

func (*WorkflowEventBindingList) MarshalToSizedBuffer

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

func (*WorkflowEventBindingList) ProtoMessage

func (*WorkflowEventBindingList) ProtoMessage()

func (*WorkflowEventBindingList) Reset

func (m *WorkflowEventBindingList) Reset()

func (*WorkflowEventBindingList) Size

func (m *WorkflowEventBindingList) Size() (n int)

func (*WorkflowEventBindingList) String

func (this *WorkflowEventBindingList) String() string

func (*WorkflowEventBindingList) Unmarshal

func (m *WorkflowEventBindingList) Unmarshal(dAtA []byte) error

func (*WorkflowEventBindingList) XXX_DiscardUnknown

func (m *WorkflowEventBindingList) XXX_DiscardUnknown()

func (*WorkflowEventBindingList) XXX_Marshal

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

func (*WorkflowEventBindingList) XXX_Merge

func (m *WorkflowEventBindingList) XXX_Merge(src proto.Message)

func (*WorkflowEventBindingList) XXX_Size

func (m *WorkflowEventBindingList) XXX_Size() int

func (*WorkflowEventBindingList) XXX_Unmarshal

func (m *WorkflowEventBindingList) XXX_Unmarshal(b []byte) error

type WorkflowEventBindingSpec

type WorkflowEventBindingSpec struct {
	// Event is the event to bind to
	Event Event `json:"event" protobuf:"bytes,1,opt,name=event"`
	// Submit is the workflow template to submit
	Submit *Submit `json:"submit,omitempty" protobuf:"bytes,2,opt,name=submit"`
}

func (*WorkflowEventBindingSpec) DeepCopy

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new WorkflowEventBindingSpec.

func (*WorkflowEventBindingSpec) DeepCopyInto

func (in *WorkflowEventBindingSpec) DeepCopyInto(out *WorkflowEventBindingSpec)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*WorkflowEventBindingSpec) Descriptor

func (*WorkflowEventBindingSpec) Descriptor() ([]byte, []int)

func (*WorkflowEventBindingSpec) Marshal

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

func (*WorkflowEventBindingSpec) MarshalTo

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

func (*WorkflowEventBindingSpec) MarshalToSizedBuffer

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

func (*WorkflowEventBindingSpec) ProtoMessage

func (*WorkflowEventBindingSpec) ProtoMessage()

func (*WorkflowEventBindingSpec) Reset

func (m *WorkflowEventBindingSpec) Reset()

func (*WorkflowEventBindingSpec) Size

func (m *WorkflowEventBindingSpec) Size() (n int)

func (*WorkflowEventBindingSpec) String

func (this *WorkflowEventBindingSpec) String() string

func (*WorkflowEventBindingSpec) Unmarshal

func (m *WorkflowEventBindingSpec) Unmarshal(dAtA []byte) error

func (*WorkflowEventBindingSpec) XXX_DiscardUnknown

func (m *WorkflowEventBindingSpec) XXX_DiscardUnknown()

func (*WorkflowEventBindingSpec) XXX_Marshal

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

func (*WorkflowEventBindingSpec) XXX_Merge

func (m *WorkflowEventBindingSpec) XXX_Merge(src proto.Message)

func (*WorkflowEventBindingSpec) XXX_Size

func (m *WorkflowEventBindingSpec) XXX_Size() int

func (*WorkflowEventBindingSpec) XXX_Unmarshal

func (m *WorkflowEventBindingSpec) XXX_Unmarshal(b []byte) error

type WorkflowList

type WorkflowList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata" protobuf:"bytes,1,opt,name=metadata"`
	Items           Workflows `json:"items" protobuf:"bytes,2,opt,name=items"`
}

WorkflowList is list of Workflow resources +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object

func (*WorkflowList) DeepCopy

func (in *WorkflowList) DeepCopy() *WorkflowList

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new WorkflowList.

func (*WorkflowList) DeepCopyInto

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*WorkflowList) DeepCopyObject

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

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*WorkflowList) Descriptor

func (*WorkflowList) Descriptor() ([]byte, []int)

func (*WorkflowList) Marshal

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

func (*WorkflowList) MarshalTo

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

func (*WorkflowList) MarshalToSizedBuffer

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

func (*WorkflowList) ProtoMessage

func (*WorkflowList) ProtoMessage()

func (*WorkflowList) Reset

func (m *WorkflowList) Reset()

func (*WorkflowList) Size

func (m *WorkflowList) Size() (n int)

func (*WorkflowList) String

func (this *WorkflowList) String() string

func (*WorkflowList) Unmarshal

func (m *WorkflowList) Unmarshal(dAtA []byte) error

func (*WorkflowList) XXX_DiscardUnknown

func (m *WorkflowList) XXX_DiscardUnknown()

func (*WorkflowList) XXX_Marshal

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

func (*WorkflowList) XXX_Merge

func (m *WorkflowList) XXX_Merge(src proto.Message)

func (*WorkflowList) XXX_Size

func (m *WorkflowList) XXX_Size() int

func (*WorkflowList) XXX_Unmarshal

func (m *WorkflowList) XXX_Unmarshal(b []byte) error

type WorkflowPhase

type WorkflowPhase string

the workflow's phase

const (
	WorkflowUnknown   WorkflowPhase = ""
	WorkflowPending   WorkflowPhase = "Pending" // pending some set-up - rarely used
	WorkflowRunning   WorkflowPhase = "Running" // any node has started; pods might not be running yet, the workflow maybe suspended too
	WorkflowSucceeded WorkflowPhase = "Succeeded"
	WorkflowFailed    WorkflowPhase = "Failed" // it maybe that the the workflow was terminated
	WorkflowError     WorkflowPhase = "Error"
)

func (WorkflowPhase) Completed

func (p WorkflowPhase) Completed() bool

type WorkflowPredicate

type WorkflowPredicate = func(wf Workflow) bool

type WorkflowSpec

type WorkflowSpec struct {
	// Templates is a list of workflow templates used in a workflow
	// +patchStrategy=merge
	// +patchMergeKey=name
	Templates []Template `json:"templates,omitempty" patchStrategy:"merge" patchMergeKey:"name" protobuf:"bytes,1,opt,name=templates"`

	// Entrypoint is a template reference to the starting point of the workflow.
	Entrypoint string `json:"entrypoint,omitempty" protobuf:"bytes,2,opt,name=entrypoint"`

	// Arguments contain the parameters and artifacts sent to the workflow entrypoint
	// Parameters are referencable globally using the 'workflow' variable prefix.
	// e.g. {{workflow.parameters.myparam}}
	Arguments Arguments `json:"arguments,omitempty" protobuf:"bytes,3,opt,name=arguments"`

	// ServiceAccountName is the name of the ServiceAccount to run all pods of the workflow as.
	ServiceAccountName string `json:"serviceAccountName,omitempty" protobuf:"bytes,4,opt,name=serviceAccountName"`

	// AutomountServiceAccountToken indicates whether a service account token should be automatically mounted in pods.
	// ServiceAccountName of ExecutorConfig must be specified if this value is false.
	AutomountServiceAccountToken *bool `json:"automountServiceAccountToken,omitempty" protobuf:"varint,28,opt,name=automountServiceAccountToken"`

	// Executor holds configurations of executor containers of the workflow.
	Executor *ExecutorConfig `json:"executor,omitempty" protobuf:"bytes,29,opt,name=executor"`

	// Volumes is a list of volumes that can be mounted by containers in a workflow.
	// +patchStrategy=merge
	// +patchMergeKey=name
	Volumes []apiv1.Volume `json:"volumes,omitempty" patchStrategy:"merge" patchMergeKey:"name" protobuf:"bytes,5,opt,name=volumes"`

	// VolumeClaimTemplates is a list of claims that containers are allowed to reference.
	// The Workflow controller will create the claims at the beginning of the workflow
	// and delete the claims upon completion of the workflow
	// +patchStrategy=merge
	// +patchMergeKey=name
	VolumeClaimTemplates []apiv1.PersistentVolumeClaim `` /* 129-byte string literal not displayed */

	// Parallelism limits the max total parallel pods that can execute at the same time in a workflow
	Parallelism *int64 `json:"parallelism,omitempty" protobuf:"bytes,7,opt,name=parallelism"`

	// ArtifactRepositoryRef specifies the configMap name and key containing the artifact repository config.
	ArtifactRepositoryRef *ArtifactRepositoryRef `json:"artifactRepositoryRef,omitempty" protobuf:"bytes,8,opt,name=artifactRepositoryRef"`

	// Suspend will suspend the workflow and prevent execution of any future steps in the workflow
	Suspend *bool `json:"suspend,omitempty" protobuf:"bytes,9,opt,name=suspend"`

	// NodeSelector is a selector which will result in all pods of the workflow
	// to be scheduled on the selected node(s). This is able to be overridden by
	// a nodeSelector specified in the template.
	NodeSelector map[string]string `json:"nodeSelector,omitempty" protobuf:"bytes,10,opt,name=nodeSelector"`

	// Affinity sets the scheduling constraints for all pods in the workflow.
	// Can be overridden by an affinity specified in the template
	Affinity *apiv1.Affinity `json:"affinity,omitempty" protobuf:"bytes,11,opt,name=affinity"`

	// Tolerations to apply to workflow pods.
	// +patchStrategy=merge
	// +patchMergeKey=key
	Tolerations []apiv1.Toleration `json:"tolerations,omitempty" patchStrategy:"merge" patchMergeKey:"key" protobuf:"bytes,12,opt,name=tolerations"`

	// ImagePullSecrets is a list of references to secrets in the same namespace to use for pulling any images
	// in pods that reference this ServiceAccount. ImagePullSecrets are distinct from Secrets because Secrets
	// can be mounted in the pod, but ImagePullSecrets are only accessed by the kubelet.
	// More info: https://kubernetes.io/docs/concepts/containers/images/#specifying-imagepullsecrets-on-a-pod
	// +patchStrategy=merge
	// +patchMergeKey=name
	ImagePullSecrets []apiv1.LocalObjectReference `json:"imagePullSecrets,omitempty" patchStrategy:"merge" patchMergeKey:"name" protobuf:"bytes,13,opt,name=imagePullSecrets"`

	// Host networking requested for this workflow pod. Default to false.
	HostNetwork *bool `json:"hostNetwork,omitempty" protobuf:"bytes,14,opt,name=hostNetwork"`

	// Set DNS policy for the pod.
	// Defaults to "ClusterFirst".
	// Valid values are 'ClusterFirstWithHostNet', 'ClusterFirst', 'Default' or 'None'.
	// DNS parameters given in DNSConfig will be merged with the policy selected with DNSPolicy.
	// To have DNS options set along with hostNetwork, you have to specify DNS policy
	// explicitly to 'ClusterFirstWithHostNet'.
	DNSPolicy *apiv1.DNSPolicy `json:"dnsPolicy,omitempty" protobuf:"bytes,15,opt,name=dnsPolicy"`

	// PodDNSConfig defines the DNS parameters of a pod in addition to
	// those generated from DNSPolicy.
	DNSConfig *apiv1.PodDNSConfig `json:"dnsConfig,omitempty" protobuf:"bytes,16,opt,name=dnsConfig"`

	// OnExit is a template reference which is invoked at the end of the
	// workflow, irrespective of the success, failure, or error of the
	// primary workflow.
	OnExit string `json:"onExit,omitempty" protobuf:"bytes,17,opt,name=onExit"`

	// TTLSecondsAfterFinished limits the lifetime of a Workflow that has finished execution
	// (Succeeded, Failed, Error). If this field is set, once the Workflow finishes, it will be
	// deleted after ttlSecondsAfterFinished expires. If this field is unset,
	// ttlSecondsAfterFinished will not expire. If this field is set to zero,
	// ttlSecondsAfterFinished expires immediately after the Workflow finishes.
	// DEPRECATED: Use TTLStrategy.SecondsAfterCompletion instead.
	TTLSecondsAfterFinished *int32 `json:"ttlSecondsAfterFinished,omitempty" protobuf:"bytes,18,opt,name=ttlSecondsAfterFinished"`

	// TTLStrategy limits the lifetime of a Workflow that has finished execution depending on if it
	// Succeeded or Failed. If this struct is set, once the Workflow finishes, it will be
	// deleted after the time to live expires. If this field is unset,
	// the controller config map will hold the default values.
	TTLStrategy *TTLStrategy `json:"ttlStrategy,omitempty" protobuf:"bytes,30,opt,name=ttlStrategy"`

	// Optional duration in seconds relative to the workflow start time which the workflow is
	// allowed to run before the controller terminates the workflow. A value of zero is used to
	// terminate a Running workflow
	ActiveDeadlineSeconds *int64 `json:"activeDeadlineSeconds,omitempty" protobuf:"bytes,19,opt,name=activeDeadlineSeconds"`

	// Priority is used if controller is configured to process limited number of workflows in parallel. Workflows with higher priority are processed first.
	Priority *int32 `json:"priority,omitempty" protobuf:"bytes,20,opt,name=priority"`

	// Set scheduler name for all pods.
	// Will be overridden if container/script template's scheduler name is set.
	// Default scheduler will be used if neither specified.
	// +optional
	SchedulerName string `json:"schedulerName,omitempty" protobuf:"bytes,21,opt,name=schedulerName"`

	// PodGC describes the strategy to use when to deleting completed pods
	PodGC *PodGC `json:"podGC,omitempty" protobuf:"bytes,22,opt,name=podGC"`

	// PriorityClassName to apply to workflow pods.
	PodPriorityClassName string `json:"podPriorityClassName,omitempty" protobuf:"bytes,23,opt,name=podPriorityClassName"`

	// Priority to apply to workflow pods.
	PodPriority *int32 `json:"podPriority,omitempty" protobuf:"bytes,24,opt,name=podPriority"`

	// +patchStrategy=merge
	// +patchMergeKey=ip
	HostAliases []apiv1.HostAlias `json:"hostAliases,omitempty" patchStrategy:"merge" patchMergeKey:"ip" protobuf:"bytes,25,opt,name=hostAliases"`

	// SecurityContext holds pod-level security attributes and common container settings.
	// Optional: Defaults to empty.  See type description for default values of each field.
	// +optional
	SecurityContext *apiv1.PodSecurityContext `json:"securityContext,omitempty" protobuf:"bytes,26,opt,name=securityContext"`

	// PodSpecPatch holds strategic merge patch to apply against the pod spec. Allows parameterization of
	// container fields which are not strings (e.g. resource limits).
	PodSpecPatch string `json:"podSpecPatch,omitempty" protobuf:"bytes,27,opt,name=podSpecPatch"`

	//PodDisruptionBudget holds the number of concurrent disruptions that you allow for Workflow's Pods.
	//Controller will automatically add the selector with workflow name, if selector is empty.
	//Optional: Defaults to empty.
	// +optional
	PodDisruptionBudget *policyv1beta.PodDisruptionBudgetSpec `json:"podDisruptionBudget,omitempty" protobuf:"bytes,31,opt,name=podDisruptionBudget"`

	// Metrics are a list of metrics emitted from this Workflow
	Metrics *Metrics `json:"metrics,omitempty" protobuf:"bytes,32,opt,name=metrics"`

	// Shutdown will shutdown the workflow according to its ShutdownStrategy
	Shutdown ShutdownStrategy `json:"shutdown,omitempty" protobuf:"bytes,33,opt,name=shutdown,casttype=ShutdownStrategy"`

	// WorkflowTemplateRef holds a reference to a WorkflowTemplate for execution
	WorkflowTemplateRef *WorkflowTemplateRef `json:"workflowTemplateRef,omitempty" protobuf:"bytes,34,opt,name=workflowTemplateRef"`

	// Synchronization holds synchronization lock configuration for this Workflow
	Synchronization *Synchronization `json:"synchronization,omitempty" protobuf:"bytes,35,opt,name=synchronization,casttype=Synchronization"`

	// VolumeClaimGC describes the strategy to use when to deleting volumes from completed workflows
	VolumeClaimGC *VolumeClaimGC `json:"volumeClaimGC,omitempty" protobuf:"bytes,36,opt,name=volumeClaimGC,casttype=VolumeClaimGC"`

	// RetryStrategy for all templates in the workflow.
	RetryStrategy *RetryStrategy `json:"retryStrategy,omitempty" protobuf:"bytes,37,opt,name=retryStrategy"`
}

WorkflowSpec is the specification of a Workflow.

func (*WorkflowSpec) DeepCopy

func (in *WorkflowSpec) DeepCopy() *WorkflowSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new WorkflowSpec.

func (*WorkflowSpec) DeepCopyInto

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*WorkflowSpec) Descriptor

func (*WorkflowSpec) Descriptor() ([]byte, []int)

func (WorkflowSpec) GetTTLStrategy

func (wfs WorkflowSpec) GetTTLStrategy() *TTLStrategy

func (WorkflowSpec) GetVolumeClaimGC

func (wfs WorkflowSpec) GetVolumeClaimGC() *VolumeClaimGC

GetVolumeClaimGC returns the VolumeClaimGC that was defined in the workflow spec. If none was provided, a default value is returned.

func (*WorkflowSpec) HasPodSpecPatch

func (wfs *WorkflowSpec) HasPodSpecPatch() bool

func (*WorkflowSpec) Marshal

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

func (*WorkflowSpec) MarshalTo

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

func (*WorkflowSpec) MarshalToSizedBuffer

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

func (*WorkflowSpec) ProtoMessage

func (*WorkflowSpec) ProtoMessage()

func (*WorkflowSpec) Reset

func (m *WorkflowSpec) Reset()

func (*WorkflowSpec) Size

func (m *WorkflowSpec) Size() (n int)

func (*WorkflowSpec) String

func (this *WorkflowSpec) String() string

func (*WorkflowSpec) Unmarshal

func (m *WorkflowSpec) Unmarshal(dAtA []byte) error

func (*WorkflowSpec) XXX_DiscardUnknown

func (m *WorkflowSpec) XXX_DiscardUnknown()

func (*WorkflowSpec) XXX_Marshal

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

func (*WorkflowSpec) XXX_Merge

func (m *WorkflowSpec) XXX_Merge(src proto.Message)

func (*WorkflowSpec) XXX_Size

func (m *WorkflowSpec) XXX_Size() int

func (*WorkflowSpec) XXX_Unmarshal

func (m *WorkflowSpec) XXX_Unmarshal(b []byte) error

type WorkflowSpecHolder

type WorkflowSpecHolder interface {
	metav1.Object
	GetWorkflowMetadata() *metav1.ObjectMeta
	GetWorkflowSpec() *WorkflowSpec
}

WorkflowSpecHolder is an object that holds a WorkflowSpec; e.g., WorkflowTemplate, and ClusterWorkflowTemplate

type WorkflowStatus

type WorkflowStatus struct {
	// Phase a simple, high-level summary of where the workflow is in its lifecycle.
	Phase WorkflowPhase `json:"phase,omitempty" protobuf:"bytes,1,opt,name=phase,casttype=WorkflowPhase"`

	// Time at which this workflow started
	StartedAt metav1.Time `json:"startedAt,omitempty" protobuf:"bytes,2,opt,name=startedAt"`

	// Time at which this workflow completed
	FinishedAt metav1.Time `json:"finishedAt,omitempty" protobuf:"bytes,3,opt,name=finishedAt"`

	// EstimatedDuration in seconds.
	EstimatedDuration EstimatedDuration `json:"estimatedDuration,omitempty" protobuf:"varint,16,opt,name=estimatedDuration,casttype=EstimatedDuration"`

	// Progress to completion
	Progress Progress `json:"progress,omitempty" protobuf:"bytes,17,opt,name=progress,casttype=Progress"`

	// A human readable message indicating details about why the workflow is in this condition.
	Message string `json:"message,omitempty" protobuf:"bytes,4,opt,name=message"`

	// Compressed and base64 decoded Nodes map
	CompressedNodes string `json:"compressedNodes,omitempty" protobuf:"bytes,5,opt,name=compressedNodes"`

	// Nodes is a mapping between a node ID and the node's status.
	Nodes Nodes `json:"nodes,omitempty" protobuf:"bytes,6,rep,name=nodes"`

	// Whether on not node status has been offloaded to a database. If exists, then Nodes and CompressedNodes will be empty.
	// This will actually be populated with a hash of the offloaded data.
	OffloadNodeStatusVersion string `json:"offloadNodeStatusVersion,omitempty" protobuf:"bytes,10,rep,name=offloadNodeStatusVersion"`

	// StoredTemplates is a mapping between a template ref and the node's status.
	StoredTemplates map[string]Template `json:"storedTemplates,omitempty" protobuf:"bytes,9,rep,name=storedTemplates"`

	// PersistentVolumeClaims tracks all PVCs that were created as part of the workflow.
	// The contents of this list are drained at the end of the workflow.
	PersistentVolumeClaims []apiv1.Volume `json:"persistentVolumeClaims,omitempty" protobuf:"bytes,7,rep,name=persistentVolumeClaims"`

	// Outputs captures output values and artifact locations produced by the workflow via global outputs
	Outputs *Outputs `json:"outputs,omitempty" protobuf:"bytes,8,opt,name=outputs"`

	// Conditions is a list of conditions the Workflow may have
	Conditions Conditions `json:"conditions,omitempty" protobuf:"bytes,13,rep,name=conditions"`

	// ResourcesDuration is the total for the workflow
	ResourcesDuration ResourcesDuration `json:"resourcesDuration,omitempty" protobuf:"bytes,12,opt,name=resourcesDuration"`

	// StoredWorkflowSpec stores the WorkflowTemplate spec for future execution.
	StoredWorkflowSpec *WorkflowSpec `json:"storedWorkflowTemplateSpec,omitempty" protobuf:"bytes,14,opt,name=storedWorkflowTemplateSpec"`

	// Synchronization stores the status of synchronization locks
	Synchronization *SynchronizationStatus `json:"synchronization,omitempty" protobuf:"bytes,15,opt,name=synchronization"`

	// ArtifactRepositoryRef is used to cache the repository to use so we do not need to determine it everytime we reconcile.
	ArtifactRepositoryRef *ArtifactRepositoryRefStatus `json:"artifactRepositoryRef,omitempty" protobuf:"bytes,18,opt,name=artifactRepositoryRef"`
}

WorkflowStatus contains overall status information about a workflow

func (*WorkflowStatus) AnyActiveSuspendNode

func (in *WorkflowStatus) AnyActiveSuspendNode() bool

func (*WorkflowStatus) DeepCopy

func (in *WorkflowStatus) DeepCopy() *WorkflowStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new WorkflowStatus.

func (*WorkflowStatus) DeepCopyInto

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*WorkflowStatus) Descriptor

func (*WorkflowStatus) Descriptor() ([]byte, []int)

func (WorkflowStatus) Failed

func (ws WorkflowStatus) Failed() bool

Failed return whether or not the workflow has failed

func (WorkflowStatus) FinishTime

func (ws WorkflowStatus) FinishTime() *metav1.Time

func (WorkflowStatus) Fulfilled

func (ws WorkflowStatus) Fulfilled() bool

Fulfilled returns whether or not the workflow has fulfilled its execution

func (*WorkflowStatus) GetDuration

func (ws *WorkflowStatus) GetDuration() time.Duration

func (*WorkflowStatus) GetOffloadNodeStatusVersion

func (ws *WorkflowStatus) GetOffloadNodeStatusVersion() string

func (*WorkflowStatus) IsOffloadNodeStatus

func (ws *WorkflowStatus) IsOffloadNodeStatus() bool

func (*WorkflowStatus) Marshal

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

func (*WorkflowStatus) MarshalTo

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

func (*WorkflowStatus) MarshalToSizedBuffer

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

func (*WorkflowStatus) ProtoMessage

func (*WorkflowStatus) ProtoMessage()

func (*WorkflowStatus) Reset

func (m *WorkflowStatus) Reset()

func (*WorkflowStatus) Size

func (m *WorkflowStatus) Size() (n int)

func (WorkflowStatus) StartTime

func (ws WorkflowStatus) StartTime() *metav1.Time

func (*WorkflowStatus) String

func (this *WorkflowStatus) String() string

func (WorkflowStatus) Successful

func (ws WorkflowStatus) Successful() bool

Successful return whether or not the workflow has succeeded

func (*WorkflowStatus) Unmarshal

func (m *WorkflowStatus) Unmarshal(dAtA []byte) error

func (*WorkflowStatus) XXX_DiscardUnknown

func (m *WorkflowStatus) XXX_DiscardUnknown()

func (*WorkflowStatus) XXX_Marshal

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

func (*WorkflowStatus) XXX_Merge

func (m *WorkflowStatus) XXX_Merge(src proto.Message)

func (*WorkflowStatus) XXX_Size

func (m *WorkflowStatus) XXX_Size() int

func (*WorkflowStatus) XXX_Unmarshal

func (m *WorkflowStatus) XXX_Unmarshal(b []byte) error

type WorkflowStep

type WorkflowStep struct {
	// Name of the step
	Name string `json:"name,omitempty" protobuf:"bytes,1,opt,name=name"`

	// Template is the name of the template to execute as the step
	Template string `json:"template,omitempty" protobuf:"bytes,2,opt,name=template"`

	// Arguments hold arguments to the template
	Arguments Arguments `json:"arguments,omitempty" protobuf:"bytes,3,opt,name=arguments"`

	// TemplateRef is the reference to the template resource to execute as the step.
	TemplateRef *TemplateRef `json:"templateRef,omitempty" protobuf:"bytes,4,opt,name=templateRef"`

	// WithItems expands a step into multiple parallel steps from the items in the list
	WithItems []Item `json:"withItems,omitempty" protobuf:"bytes,5,rep,name=withItems"`

	// WithParam expands a step into multiple parallel steps from the value in the parameter,
	// which is expected to be a JSON list.
	WithParam string `json:"withParam,omitempty" protobuf:"bytes,6,opt,name=withParam"`

	// WithSequence expands a step into a numeric sequence
	WithSequence *Sequence `json:"withSequence,omitempty" protobuf:"bytes,7,opt,name=withSequence"`

	// When is an expression in which the step should conditionally execute
	When string `json:"when,omitempty" protobuf:"bytes,8,opt,name=when"`

	// ContinueOn makes argo to proceed with the following step even if this step fails.
	// Errors and Failed states can be specified
	ContinueOn *ContinueOn `json:"continueOn,omitempty" protobuf:"bytes,9,opt,name=continueOn"`

	// OnExit is a template reference which is invoked at the end of the
	// template, irrespective of the success, failure, or error of the
	// primary template.
	OnExit string `json:"onExit,omitempty" protobuf:"bytes,11,opt,name=onExit"`
}

WorkflowStep is a reference to a template to execute in a series of step

func (*WorkflowStep) ContinuesOn

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

ContinuesOn returns whether the StepGroup should be proceeded if the task fails or errors.

func (*WorkflowStep) DeepCopy

func (in *WorkflowStep) DeepCopy() *WorkflowStep

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new WorkflowStep.

func (*WorkflowStep) DeepCopyInto

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*WorkflowStep) Descriptor

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

func (*WorkflowStep) GetTemplateName

func (step *WorkflowStep) GetTemplateName() string

func (*WorkflowStep) GetTemplateRef

func (step *WorkflowStep) GetTemplateRef() *TemplateRef

func (*WorkflowStep) Marshal

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

func (*WorkflowStep) MarshalTo

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

func (*WorkflowStep) MarshalToSizedBuffer

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

func (*WorkflowStep) ProtoMessage

func (*WorkflowStep) ProtoMessage()

func (*WorkflowStep) Reset

func (m *WorkflowStep) Reset()

func (*WorkflowStep) ShouldExpand

func (step *WorkflowStep) ShouldExpand() bool

func (*WorkflowStep) Size

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

func (*WorkflowStep) String

func (this *WorkflowStep) String() string

func (*WorkflowStep) Unmarshal

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

func (*WorkflowStep) XXX_DiscardUnknown

func (m *WorkflowStep) XXX_DiscardUnknown()

func (*WorkflowStep) XXX_Marshal

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

func (*WorkflowStep) XXX_Merge

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

func (*WorkflowStep) XXX_Size

func (m *WorkflowStep) XXX_Size() int

func (*WorkflowStep) XXX_Unmarshal

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

type WorkflowTemplate

type WorkflowTemplate struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata" protobuf:"bytes,1,opt,name=metadata"`
	Spec              WorkflowTemplateSpec `json:"spec" protobuf:"bytes,2,opt,name=spec"`
}

WorkflowTemplate is the definition of a workflow template resource +genclient +genclient:noStatus +kubebuilder:resource:shortName=wftmpl +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object

func (*WorkflowTemplate) DeepCopy

func (in *WorkflowTemplate) DeepCopy() *WorkflowTemplate

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new WorkflowTemplate.

func (*WorkflowTemplate) DeepCopyInto

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*WorkflowTemplate) DeepCopyObject

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

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*WorkflowTemplate) Descriptor

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

func (*WorkflowTemplate) GetResourceScope

func (wftmpl *WorkflowTemplate) GetResourceScope() ResourceScope

GetResourceScope returns the template scope of workflow template.

func (*WorkflowTemplate) GetTemplateByName

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

GetTemplateByName retrieves a defined template by its name

func (*WorkflowTemplate) GetWorkflowMetadata

func (wftmpl *WorkflowTemplate) GetWorkflowMetadata() *metav1.ObjectMeta

func (*WorkflowTemplate) GetWorkflowSpec

func (wftmpl *WorkflowTemplate) GetWorkflowSpec() *WorkflowSpec

GetWorkflowSpec returns the WorkflowSpec of workflow template.

func (*WorkflowTemplate) Marshal

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

func (*WorkflowTemplate) MarshalTo

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

func (*WorkflowTemplate) MarshalToSizedBuffer

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

func (*WorkflowTemplate) ProtoMessage

func (*WorkflowTemplate) ProtoMessage()

func (*WorkflowTemplate) Reset

func (m *WorkflowTemplate) Reset()

func (*WorkflowTemplate) Size

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

func (*WorkflowTemplate) String

func (this *WorkflowTemplate) String() string

func (*WorkflowTemplate) Unmarshal

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

func (*WorkflowTemplate) XXX_DiscardUnknown

func (m *WorkflowTemplate) XXX_DiscardUnknown()

func (*WorkflowTemplate) XXX_Marshal

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

func (*WorkflowTemplate) XXX_Merge

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

func (*WorkflowTemplate) XXX_Size

func (m *WorkflowTemplate) XXX_Size() int

func (*WorkflowTemplate) XXX_Unmarshal

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

type WorkflowTemplateList

type WorkflowTemplateList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata" protobuf:"bytes,1,opt,name=metadata"`
	Items           WorkflowTemplates `json:"items" protobuf:"bytes,2,rep,name=items"`
}

WorkflowTemplateList is list of WorkflowTemplate resources +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object

func (*WorkflowTemplateList) DeepCopy

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new WorkflowTemplateList.

func (*WorkflowTemplateList) DeepCopyInto

func (in *WorkflowTemplateList) DeepCopyInto(out *WorkflowTemplateList)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*WorkflowTemplateList) DeepCopyObject

func (in *WorkflowTemplateList) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*WorkflowTemplateList) Descriptor

func (*WorkflowTemplateList) Descriptor() ([]byte, []int)

func (*WorkflowTemplateList) Marshal

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

func (*WorkflowTemplateList) MarshalTo

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

func (*WorkflowTemplateList) MarshalToSizedBuffer

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

func (*WorkflowTemplateList) ProtoMessage

func (*WorkflowTemplateList) ProtoMessage()

func (*WorkflowTemplateList) Reset

func (m *WorkflowTemplateList) Reset()

func (*WorkflowTemplateList) Size

func (m *WorkflowTemplateList) Size() (n int)

func (*WorkflowTemplateList) String

func (this *WorkflowTemplateList) String() string

func (*WorkflowTemplateList) Unmarshal

func (m *WorkflowTemplateList) Unmarshal(dAtA []byte) error

func (*WorkflowTemplateList) XXX_DiscardUnknown

func (m *WorkflowTemplateList) XXX_DiscardUnknown()

func (*WorkflowTemplateList) XXX_Marshal

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

func (*WorkflowTemplateList) XXX_Merge

func (m *WorkflowTemplateList) XXX_Merge(src proto.Message)

func (*WorkflowTemplateList) XXX_Size

func (m *WorkflowTemplateList) XXX_Size() int

func (*WorkflowTemplateList) XXX_Unmarshal

func (m *WorkflowTemplateList) XXX_Unmarshal(b []byte) error

type WorkflowTemplateRef

type WorkflowTemplateRef struct {
	// Name is the resource name of the workflow template.
	Name string `json:"name,omitempty" protobuf:"bytes,1,opt,name=name"`
	// ClusterScope indicates the referred template is cluster scoped (i.e. a ClusterWorkflowTemplate).
	ClusterScope bool `json:"clusterScope,omitempty" protobuf:"varint,2,opt,name=clusterScope"`
}

WorkflowTemplateRef is a reference to a WorkflowTemplate resource.

func (*WorkflowTemplateRef) DeepCopy

func (in *WorkflowTemplateRef) DeepCopy() *WorkflowTemplateRef

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new WorkflowTemplateRef.

func (*WorkflowTemplateRef) DeepCopyInto

func (in *WorkflowTemplateRef) DeepCopyInto(out *WorkflowTemplateRef)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*WorkflowTemplateRef) Descriptor

func (*WorkflowTemplateRef) Descriptor() ([]byte, []int)

func (*WorkflowTemplateRef) Marshal

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

func (*WorkflowTemplateRef) MarshalTo

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

func (*WorkflowTemplateRef) MarshalToSizedBuffer

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

func (*WorkflowTemplateRef) ProtoMessage

func (*WorkflowTemplateRef) ProtoMessage()

func (*WorkflowTemplateRef) Reset

func (m *WorkflowTemplateRef) Reset()

func (*WorkflowTemplateRef) Size

func (m *WorkflowTemplateRef) Size() (n int)

func (*WorkflowTemplateRef) String

func (this *WorkflowTemplateRef) String() string

func (*WorkflowTemplateRef) ToTemplateRef

func (ref *WorkflowTemplateRef) ToTemplateRef(entrypoint string) *TemplateRef

func (*WorkflowTemplateRef) Unmarshal

func (m *WorkflowTemplateRef) Unmarshal(dAtA []byte) error

func (*WorkflowTemplateRef) XXX_DiscardUnknown

func (m *WorkflowTemplateRef) XXX_DiscardUnknown()

func (*WorkflowTemplateRef) XXX_Marshal

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

func (*WorkflowTemplateRef) XXX_Merge

func (m *WorkflowTemplateRef) XXX_Merge(src proto.Message)

func (*WorkflowTemplateRef) XXX_Size

func (m *WorkflowTemplateRef) XXX_Size() int

func (*WorkflowTemplateRef) XXX_Unmarshal

func (m *WorkflowTemplateRef) XXX_Unmarshal(b []byte) error

type WorkflowTemplateSpec

type WorkflowTemplateSpec struct {
	WorkflowSpec `json:",inline" protobuf:"bytes,1,opt,name=workflowSpec"`
	// WorkflowMetadata contains some metadata of the workflow to be refer
	WorkflowMetadata *metav1.ObjectMeta `json:"workflowMetadata,omitempty" protobuf:"bytes,2,opt,name=workflowMeta"`
}

WorkflowTemplateSpec is a spec of WorkflowTemplate.

func (*WorkflowTemplateSpec) DeepCopy

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new WorkflowTemplateSpec.

func (*WorkflowTemplateSpec) DeepCopyInto

func (in *WorkflowTemplateSpec) DeepCopyInto(out *WorkflowTemplateSpec)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*WorkflowTemplateSpec) Descriptor

func (*WorkflowTemplateSpec) Descriptor() ([]byte, []int)

func (*WorkflowTemplateSpec) Marshal

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

func (*WorkflowTemplateSpec) MarshalTo

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

func (*WorkflowTemplateSpec) MarshalToSizedBuffer

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

func (*WorkflowTemplateSpec) ProtoMessage

func (*WorkflowTemplateSpec) ProtoMessage()

func (*WorkflowTemplateSpec) Reset

func (m *WorkflowTemplateSpec) Reset()

func (*WorkflowTemplateSpec) Size

func (m *WorkflowTemplateSpec) Size() (n int)

func (*WorkflowTemplateSpec) String

func (this *WorkflowTemplateSpec) String() string

func (*WorkflowTemplateSpec) Unmarshal

func (m *WorkflowTemplateSpec) Unmarshal(dAtA []byte) error

func (*WorkflowTemplateSpec) XXX_DiscardUnknown

func (m *WorkflowTemplateSpec) XXX_DiscardUnknown()

func (*WorkflowTemplateSpec) XXX_Marshal

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

func (*WorkflowTemplateSpec) XXX_Merge

func (m *WorkflowTemplateSpec) XXX_Merge(src proto.Message)

func (*WorkflowTemplateSpec) XXX_Size

func (m *WorkflowTemplateSpec) XXX_Size() int

func (*WorkflowTemplateSpec) XXX_Unmarshal

func (m *WorkflowTemplateSpec) XXX_Unmarshal(b []byte) error

type WorkflowTemplates

type WorkflowTemplates []WorkflowTemplate

func (WorkflowTemplates) DeepCopy

func (in WorkflowTemplates) DeepCopy() WorkflowTemplates

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new WorkflowTemplates.

func (WorkflowTemplates) DeepCopyInto

func (in WorkflowTemplates) DeepCopyInto(out *WorkflowTemplates)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (WorkflowTemplates) Len

func (w WorkflowTemplates) Len() int

func (WorkflowTemplates) Less

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

func (WorkflowTemplates) Swap

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

type Workflows

type Workflows []Workflow

Workflows is a sort interface which sorts running jobs earlier before considering FinishedAt

func (Workflows) DeepCopy

func (in Workflows) DeepCopy() Workflows

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Workflows.

func (Workflows) DeepCopyInto

func (in Workflows) DeepCopyInto(out *Workflows)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (Workflows) Filter

func (w Workflows) Filter(predicate WorkflowPredicate) Workflows

func (Workflows) Len

func (w Workflows) Len() int

func (Workflows) Less

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

func (Workflows) Swap

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

type ZipStrategy

type ZipStrategy struct{}

ZipStrategy will unzip zipped input artifacts

func (*ZipStrategy) DeepCopy

func (in *ZipStrategy) DeepCopy() *ZipStrategy

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ZipStrategy.

func (*ZipStrategy) DeepCopyInto

func (in *ZipStrategy) DeepCopyInto(out *ZipStrategy)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*ZipStrategy) Descriptor

func (*ZipStrategy) Descriptor() ([]byte, []int)

func (*ZipStrategy) Marshal

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

func (*ZipStrategy) MarshalTo

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

func (*ZipStrategy) MarshalToSizedBuffer

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

func (*ZipStrategy) ProtoMessage

func (*ZipStrategy) ProtoMessage()

func (*ZipStrategy) Reset

func (m *ZipStrategy) Reset()

func (*ZipStrategy) Size

func (m *ZipStrategy) Size() (n int)

func (*ZipStrategy) String

func (this *ZipStrategy) String() string

func (*ZipStrategy) Unmarshal

func (m *ZipStrategy) Unmarshal(dAtA []byte) error

func (*ZipStrategy) XXX_DiscardUnknown

func (m *ZipStrategy) XXX_DiscardUnknown()

func (*ZipStrategy) XXX_Marshal

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

func (*ZipStrategy) XXX_Merge

func (m *ZipStrategy) XXX_Merge(src proto.Message)

func (*ZipStrategy) XXX_Size

func (m *ZipStrategy) XXX_Size() int

func (*ZipStrategy) XXX_Unmarshal

func (m *ZipStrategy) XXX_Unmarshal(b []byte) error

Jump to

Keyboard shortcuts

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