v1alpha1

package
v2.5.2+incompatible Latest Latest
Warning

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

Go to latest
Published: Feb 24, 2020 License: Apache-2.0 Imports: 18 Imported by: 2,802

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
)

Functions

func Kind

func Kind(kind string) schema.GroupKind

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

func Resource

func Resource(resource string) schema.GroupResource

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

Types

type ArchiveStrategy

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

ArchiveStrategy describes how to archive files/directory when saving artifacts

func (*ArchiveStrategy) DeepCopy

func (in *ArchiveStrategy) DeepCopy() *ArchiveStrategy

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

func (*ArchiveStrategy) DeepCopyInto

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

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

func (*ArchiveStrategy) Descriptor

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

func (*ArchiveStrategy) Marshal

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

func (*ArchiveStrategy) 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) 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"`
}

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) HasLocation

func (a *Artifact) HasLocation() bool

HasLocation whether or not an artifact has a location defined

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"`
}

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

func (*ArtifactLocation) DeepCopy

func (in *ArtifactLocation) DeepCopy() *ArtifactLocation

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

func (*ArtifactLocation) DeepCopyInto

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

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

func (*ArtifactLocation) Descriptor

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

func (*ArtifactLocation) Marshal

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

func (*ArtifactLocation) 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) Reset

func (m *ArtifactLocation) Reset()

func (*ArtifactLocation) Size

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

func (*ArtifactLocation) String

func (this *ArtifactLocation) String() string

func (*ArtifactLocation) Unmarshal

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

func (*ArtifactLocation) XXX_DiscardUnknown

func (m *ArtifactLocation) XXX_DiscardUnknown()

func (*ArtifactLocation) XXX_Marshal

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

func (*ArtifactLocation) XXX_Merge

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

func (*ArtifactLocation) XXX_Size

func (m *ArtifactLocation) XXX_Size() int

func (*ArtifactLocation) XXX_Unmarshal

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

type ArtifactRepositoryRef

type ArtifactRepositoryRef struct {
	ConfigMap string `json:"configMap,omitempty" protobuf:"bytes,1,opt,name=configMap"`
	Key       string `json:"key,omitempty" protobuf:"bytes,2,opt,name=key"`
}

func (*ArtifactRepositoryRef) DeepCopy

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

func (*ArtifactRepositoryRef) DeepCopyInto

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

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

func (*ArtifactRepositoryRef) Descriptor

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

func (*ArtifactRepositoryRef) Marshal

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

func (*ArtifactRepositoryRef) MarshalTo

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

func (*ArtifactRepositoryRef) MarshalToSizedBuffer

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

func (*ArtifactRepositoryRef) ProtoMessage

func (*ArtifactRepositoryRef) ProtoMessage()

func (*ArtifactRepositoryRef) Reset

func (m *ArtifactRepositoryRef) Reset()

func (*ArtifactRepositoryRef) Size

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

func (*ArtifactRepositoryRef) String

func (this *ArtifactRepositoryRef) String() string

func (*ArtifactRepositoryRef) Unmarshal

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

func (*ArtifactRepositoryRef) XXX_DiscardUnknown

func (m *ArtifactRepositoryRef) XXX_DiscardUnknown()

func (*ArtifactRepositoryRef) XXX_Marshal

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

func (*ArtifactRepositoryRef) XXX_Merge

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

func (*ArtifactRepositoryRef) XXX_Size

func (m *ArtifactRepositoryRef) XXX_Size() int

func (*ArtifactRepositoryRef) XXX_Unmarshal

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

type ArtifactoryArtifact

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

ArtifactoryArtifact is the location of an artifactory artifact

func (*ArtifactoryArtifact) DeepCopy

func (in *ArtifactoryArtifact) DeepCopy() *ArtifactoryArtifact

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

func (*ArtifactoryArtifact) DeepCopyInto

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

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

func (*ArtifactoryArtifact) Descriptor

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

func (*ArtifactoryArtifact) HasLocation

func (a *ArtifactoryArtifact) HasLocation() bool

func (*ArtifactoryArtifact) Marshal

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

func (*ArtifactoryArtifact) MarshalTo

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

func (*ArtifactoryArtifact) MarshalToSizedBuffer

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

func (*ArtifactoryArtifact) ProtoMessage

func (*ArtifactoryArtifact) ProtoMessage()

func (*ArtifactoryArtifact) Reset

func (m *ArtifactoryArtifact) Reset()

func (*ArtifactoryArtifact) Size

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

func (*ArtifactoryArtifact) String

func (this *ArtifactoryArtifact) String() string

func (*ArtifactoryArtifact) Unmarshal

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

func (*ArtifactoryArtifact) XXX_DiscardUnknown

func (m *ArtifactoryArtifact) XXX_DiscardUnknown()

func (*ArtifactoryArtifact) XXX_Marshal

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

func (*ArtifactoryArtifact) XXX_Merge

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

func (*ArtifactoryArtifact) XXX_Size

func (m *ArtifactoryArtifact) XXX_Size() int

func (*ArtifactoryArtifact) XXX_Unmarshal

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

type ArtifactoryAuth

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

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

ArtifactoryAuth describes the secret selectors required for authenticating to artifactory

func (*ArtifactoryAuth) DeepCopy

func (in *ArtifactoryAuth) DeepCopy() *ArtifactoryAuth

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

func (*ArtifactoryAuth) DeepCopyInto

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

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

func (*ArtifactoryAuth) Descriptor

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

func (*ArtifactoryAuth) Marshal

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

func (*ArtifactoryAuth) 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    string `json:"duration,omitempty" protobuf:"varint,1,opt,name=duration"`
	Factor      int32  `json:"factor,omitempty" protobuf:"varint,2,opt,name=factor"`
	MaxDuration string `json:"maxDuration,omitempty" protobuf:"varint,3,opt,name=maxDuration"`
}

func (*Backoff) DeepCopy

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 ConcurrencyPolicy

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

type ContinueOn

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

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

func (*ContinueOn) DeepCopy

func (in *ContinueOn) DeepCopy() *ContinueOn

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

func (*ContinueOn) DeepCopyInto

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

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

func (*ContinueOn) Descriptor

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

func (*ContinueOn) Marshal

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

func (*ContinueOn) 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 CronWorkflow

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

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

func (*CronWorkflow) DeepCopy

func (in *CronWorkflow) DeepCopy() *CronWorkflow

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

func (*CronWorkflow) DeepCopyInto

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

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

func (*CronWorkflow) DeepCopyObject

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

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

func (*CronWorkflow) Descriptor

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

func (*CronWorkflow) Marshal

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

func (*CronWorkflow) 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 successful jobs to be kept at a time
	FailedJobsHistoryLimit *int32 `json:"failedJobsHistoryLimit,omitempty" protobuf:"varint,7,opt,name=failedJobsHistoryLimit"`
	// Timezone is the timezone against which the cron schedule will be calculated, e.g. "Asia/Tokyo". Default is machine's local time.
	Timezone string `json:"timezone,omitempty" protobuf:"bytes,8,opt,name=timezone"`
}

func (*CronWorkflowSpec) DeepCopy

func (in *CronWorkflowSpec) DeepCopy() *CronWorkflowSpec

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

func (*CronWorkflowSpec) DeepCopyInto

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

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

func (*CronWorkflowSpec) Descriptor

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

func (*CronWorkflowSpec) Marshal

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

func (*CronWorkflowSpec) 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,omitempty" protobuf:"bytes,1,rep,name=active"`
	// LastScheduleTime is the last time the CronWorkflow was scheduled
	LastScheduledTime *metav1.Time `json:"lastScheduledTime,omitempty" protobuf:"bytes,2,opt,name=lastScheduledTime"`
}

func (*CronWorkflowStatus) DeepCopy

func (in *CronWorkflowStatus) DeepCopy() *CronWorkflowStatus

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

func (*CronWorkflowStatus) DeepCopyInto

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

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

func (*CronWorkflowStatus) Descriptor

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

func (*CronWorkflowStatus) Marshal

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

func (*CronWorkflowStatus) MarshalTo

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

func (*CronWorkflowStatus) MarshalToSizedBuffer

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

func (*CronWorkflowStatus) ProtoMessage

func (*CronWorkflowStatus) ProtoMessage()

func (*CronWorkflowStatus) Reset

func (m *CronWorkflowStatus) Reset()

func (*CronWorkflowStatus) Size

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

func (*CronWorkflowStatus) String

func (this *CronWorkflowStatus) String() string

func (*CronWorkflowStatus) Unmarshal

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

func (*CronWorkflowStatus) XXX_DiscardUnknown

func (m *CronWorkflowStatus) XXX_DiscardUnknown()

func (*CronWorkflowStatus) XXX_Marshal

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

func (*CronWorkflowStatus) XXX_Merge

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

func (*CronWorkflowStatus) XXX_Size

func (m *CronWorkflowStatus) XXX_Size() int

func (*CronWorkflowStatus) XXX_Unmarshal

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

type DAGTask

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

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

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

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

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

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

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

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

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

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

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

DAGTask represents a node in the graph during DAG execution

func (*DAGTask) ContinuesOn

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) IsResolvable

func (t *DAGTask) IsResolvable() bool

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

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

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

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

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

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

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

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

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

GitArtifact is the location of an git artifact

func (*GitArtifact) DeepCopy

func (in *GitArtifact) DeepCopy() *GitArtifact

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

func (*GitArtifact) DeepCopyInto

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

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

func (*GitArtifact) Descriptor

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

func (*GitArtifact) HasLocation

func (g *GitArtifact) HasLocation() bool

func (*GitArtifact) Marshal

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

func (*GitArtifact) 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) Size

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

func (*GitArtifact) String

func (this *GitArtifact) String() string

func (*GitArtifact) Unmarshal

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

func (*GitArtifact) XXX_DiscardUnknown

func (m *GitArtifact) XXX_DiscardUnknown()

func (*GitArtifact) XXX_Marshal

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

func (*GitArtifact) XXX_Merge

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

func (*GitArtifact) XXX_Size

func (m *GitArtifact) XXX_Size() int

func (*GitArtifact) XXX_Unmarshal

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

type HDFSArtifact

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

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

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

HDFSArtifact is the location of an HDFS artifact

func (*HDFSArtifact) DeepCopy

func (in *HDFSArtifact) DeepCopy() *HDFSArtifact

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

func (*HDFSArtifact) DeepCopyInto

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

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

func (*HDFSArtifact) Descriptor

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

func (*HDFSArtifact) HasLocation

func (h *HDFSArtifact) HasLocation() bool

func (*HDFSArtifact) Marshal

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

func (*HDFSArtifact) 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) Size

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

func (*HDFSArtifact) String

func (this *HDFSArtifact) String() string

func (*HDFSArtifact) Unmarshal

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

func (*HDFSArtifact) XXX_DiscardUnknown

func (m *HDFSArtifact) XXX_DiscardUnknown()

func (*HDFSArtifact) XXX_Marshal

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

func (*HDFSArtifact) XXX_Merge

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

func (*HDFSArtifact) XXX_Size

func (m *HDFSArtifact) XXX_Size() int

func (*HDFSArtifact) XXX_Unmarshal

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

type HDFSConfig

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

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

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

HDFSConfig is configurations for HDFS

func (*HDFSConfig) DeepCopy

func (in *HDFSConfig) DeepCopy() *HDFSConfig

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

func (*HDFSConfig) DeepCopyInto

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

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

func (*HDFSConfig) Descriptor

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

func (*HDFSConfig) Marshal

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

func (*HDFSConfig) 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"`
}

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

func (*HTTPArtifact) DeepCopy

func (in *HTTPArtifact) DeepCopy() *HTTPArtifact

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

func (*HTTPArtifact) DeepCopyInto

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

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

func (*HTTPArtifact) Descriptor

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

func (*HTTPArtifact) HasLocation

func (h *HTTPArtifact) HasLocation() bool

func (*HTTPArtifact) Marshal

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

func (*HTTPArtifact) 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) Size

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

func (*HTTPArtifact) String

func (this *HTTPArtifact) String() string

func (*HTTPArtifact) Unmarshal

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

func (*HTTPArtifact) XXX_DiscardUnknown

func (m *HTTPArtifact) XXX_DiscardUnknown()

func (*HTTPArtifact) XXX_Marshal

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

func (*HTTPArtifact) XXX_Merge

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

func (*HTTPArtifact) XXX_Size

func (m *HTTPArtifact) XXX_Size() int

func (*HTTPArtifact) XXX_Unmarshal

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

type Inputs

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

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

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

func (*Inputs) DeepCopy

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) 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 {
	Type    Type                 `protobuf:"bytes,1,opt,name=type,casttype=Type"`
	NumVal  json.Number          `protobuf:"bytes,2,opt,name=numVal"`
	BoolVal bool                 `protobuf:"bytes,3,opt,name=boolVal"`
	StrVal  string               `protobuf:"bytes,4,opt,name=strVal"`
	MapVal  map[string]ItemValue `protobuf:"bytes,5,opt,name=mapVal"`
	ListVal []ItemValue          `protobuf:"bytes,6,opt,name=listVal"`
}

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

+protobuf=true +protobuf.options.(gogoproto.goproto_stringer)=false +k8s:openapi-gen=true

func (*Item) DeepCopy

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)

DeepCopyInto is an custom deepcopy function to deal with our use of the interface{} type

func (*Item) Descriptor

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

func (Item) Format

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

func (*Item) Marshal

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

func (Item) MarshalJSON

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

MarshalJSON implements the json.Marshaller interface.

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

OpenAPISchemaFormat is used by the kube-openapi generator when constructing the OpenAPI spec of this type.

func (Item) OpenAPISchemaType

func (i Item) OpenAPISchemaType() []string

OpenAPISchemaType is used by the kube-openapi generator when constructing the OpenAPI spec of this type. See: https://github.com/kubernetes/kube-openapi/tree/master/pkg/generators

func (*Item) ProtoMessage

func (*Item) ProtoMessage()

func (*Item) 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

UnmarshalJSON implements the json.Unmarshaller interface.

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 ItemValue

type ItemValue struct {
	Type    Type              `protobuf:"varint,1,opt,name=type,casttype=Type"`
	NumVal  json.Number       `protobuf:"bytes,2,opt,name=numVal"`
	BoolVal bool              `protobuf:"bytes,3,opt,name=boolVal"`
	StrVal  string            `protobuf:"bytes,4,opt,name=strVal"`
	MapVal  map[string]string `protobuf:"bytes,5,opt,name=mapVal"`
	ListVal []json.RawMessage `protobuf:"bytes,6,opt,name=listVal"`
}

+protobuf=true +protobuf.options.(gogoproto.goproto_stringer)=false +k8s:openapi-gen=true

func (*ItemValue) DeepCopy

func (in *ItemValue) DeepCopy() *ItemValue

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

func (*ItemValue) DeepCopyInto

func (in *ItemValue) DeepCopyInto(out *ItemValue)

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

func (*ItemValue) Descriptor

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

func (ItemValue) Format

func (iv ItemValue) Format(s fmt.State, verb rune)

func (*ItemValue) Marshal

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

func (ItemValue) MarshalJSON

func (iv ItemValue) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaller interface.

func (*ItemValue) MarshalTo

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

func (*ItemValue) MarshalToSizedBuffer

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

func (*ItemValue) ProtoMessage

func (*ItemValue) ProtoMessage()

func (*ItemValue) Reset

func (m *ItemValue) Reset()

func (*ItemValue) Size

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

func (*ItemValue) String

func (iv *ItemValue) String() string

func (*ItemValue) Unmarshal

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

func (*ItemValue) UnmarshalJSON

func (iv *ItemValue) UnmarshalJSON(value []byte) error

UnmarshalJSON implements the json.Unmarshaller interface.

func (*ItemValue) XXX_DiscardUnknown

func (m *ItemValue) XXX_DiscardUnknown()

func (*ItemValue) XXX_Marshal

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

func (*ItemValue) XXX_Merge

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

func (*ItemValue) XXX_Size

func (m *ItemValue) XXX_Size() int

func (*ItemValue) XXX_Unmarshal

func (m *ItemValue) 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 NodePhase

type NodePhase string

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

const (
	NodePending   NodePhase = "Pending"
	NodeRunning   NodePhase = "Running"
	NodeSucceeded NodePhase = "Succeeded"
	NodeSkipped   NodePhase = "Skipped"
	NodeFailed    NodePhase = "Failed"
	NodeError     NodePhase = "Error"
)

Workflow and node statuses

type NodeStatus

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

NodeStatus contains status information about an individual node in the workflow

func (NodeStatus) CanRetry

func (n NodeStatus) CanRetry() bool

CanRetry returns whether the node should be retried or not.

func (NodeStatus) Completed

func (n NodeStatus) Completed() bool

Remove returns whether or not the node has completed execution

func (*NodeStatus) DeepCopy

func (in *NodeStatus) DeepCopy() *NodeStatus

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

func (*NodeStatus) DeepCopyInto

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

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

func (*NodeStatus) Descriptor

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

func (*NodeStatus) GetTemplateName

func (n *NodeStatus) GetTemplateName() string

func (*NodeStatus) GetTemplateRef

func (n *NodeStatus) GetTemplateRef() *TemplateRef

func (NodeStatus) IsDaemoned

func (n NodeStatus) IsDaemoned() bool

IsDaemoned returns whether or not the node is deamoned

func (*NodeStatus) IsResolvable

func (n *NodeStatus) IsResolvable() bool

func (*NodeStatus) Marshal

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

func (*NodeStatus) MarshalTo

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

func (*NodeStatus) MarshalToSizedBuffer

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

func (*NodeStatus) ProtoMessage

func (*NodeStatus) ProtoMessage()

func (*NodeStatus) Reset

func (m *NodeStatus) Reset()

func (*NodeStatus) Size

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

func (*NodeStatus) String

func (this *NodeStatus) String() string

func (NodeStatus) Successful

func (n NodeStatus) Successful() bool

Successful returns whether or not this node completed successfully

func (*NodeStatus) Unmarshal

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

func (*NodeStatus) XXX_DiscardUnknown

func (m *NodeStatus) XXX_DiscardUnknown()

func (*NodeStatus) XXX_Marshal

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

func (*NodeStatus) XXX_Merge

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

func (*NodeStatus) XXX_Size

func (m *NodeStatus) XXX_Size() int

func (*NodeStatus) XXX_Unmarshal

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

type NodeType

type NodeType string

NodeType is the type of a node

const (
	NodeTypePod       NodeType = "Pod"
	NodeTypeSteps     NodeType = "Steps"
	NodeTypeStepGroup NodeType = "StepGroup"
	NodeTypeDAG       NodeType = "DAG"
	NodeTypeTaskGroup NodeType = "TaskGroup"
	NodeTypeRetry     NodeType = "Retry"
	NodeTypeSkipped   NodeType = "Skipped"
	NodeTypeSuspend   NodeType = "Suspend"
)

Node types

type Nodes

type Nodes map[string]NodeStatus

func (Nodes) DeepCopy

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) FindByDisplayName

func (n Nodes) FindByDisplayName(name string) *NodeStatus

type NoneStrategy

type NoneStrategy struct{}

NoneStrategy indicates to skip tar process and upload the files or directory tree as independent files. Note that if the artifact is a directory, the artifact driver must support the ability to save/load the directory appropriately.

func (*NoneStrategy) DeepCopy

func (in *NoneStrategy) DeepCopy() *NoneStrategy

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

func (*NoneStrategy) DeepCopyInto

func (in *NoneStrategy) DeepCopyInto(out *NoneStrategy)

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

func (*NoneStrategy) Descriptor

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

func (*NoneStrategy) Marshal

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

func (*NoneStrategy) 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 Outputs

type Outputs struct {
	// Parameters holds the list of output parameters produced by a step
	// +patchStrategy=merge
	// +patchMergeKey=name
	Parameters []Parameter `json:"parameters,omitempty" patchStrategy:"merge" patchMergeKey:"name" protobuf:"bytes,1,rep,name=parameters"`

	// Artifacts holds the list of output artifacts produced by a step
	// +patchStrategy=merge
	// +patchMergeKey=name
	Artifacts Artifacts `json:"artifacts,omitempty" patchStrategy:"merge" patchMergeKey:"name" protobuf:"bytes,2,rep,name=artifacts"`

	// Result holds the result (stdout) of a script template
	Result *string `json:"result,omitempty" protobuf:"bytes,3,opt,name=result"`
}

Outputs hold parameters, artifacts, and results from a step

func (*Outputs) DeepCopy

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 `protobuf:"bytes,1,rep,name=steps"`
}

func (*ParallelSteps) DeepCopy

func (in *ParallelSteps) DeepCopy() *ParallelSteps

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

func (*ParallelSteps) DeepCopyInto

func (in *ParallelSteps) DeepCopyInto(out *ParallelSteps)

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

func (*ParallelSteps) Descriptor

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

func (*ParallelSteps) Marshal

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

func (*ParallelSteps) MarshalJSON

func (p *ParallelSteps) MarshalJSON() ([]byte, error)

func (*ParallelSteps) MarshalTo

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

func (*ParallelSteps) MarshalToSizedBuffer

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

func (*ParallelSteps) ProtoMessage

func (*ParallelSteps) ProtoMessage()

func (*ParallelSteps) Reset

func (m *ParallelSteps) Reset()

func (*ParallelSteps) Size

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

func (*ParallelSteps) String

func (this *ParallelSteps) String() string

func (*ParallelSteps) Unmarshal

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

func (*ParallelSteps) UnmarshalJSON

func (p *ParallelSteps) UnmarshalJSON(value []byte) error

func (*ParallelSteps) XXX_DiscardUnknown

func (m *ParallelSteps) XXX_DiscardUnknown()

func (*ParallelSteps) XXX_Marshal

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

func (*ParallelSteps) XXX_Merge

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

func (*ParallelSteps) XXX_Size

func (m *ParallelSteps) XXX_Size() int

func (*ParallelSteps) XXX_Unmarshal

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

type Parameter

type Parameter struct {
	// Name is the parameter name
	Name string `json:"name" protobuf:"bytes,1,opt,name=name"`

	// Default is the default value to use for an input parameter if a value was not supplied
	Default *string `json:"default,omitempty" protobuf:"bytes,2,opt,name=default"`

	// Value is the literal value to use for the parameter.
	// If specified in the context of an input parameter, the value takes precedence over any passed values
	Value *string `json:"value,omitempty" protobuf:"bytes,3,opt,name=value"`

	// ValueFrom is the source for the output parameter's value
	ValueFrom *ValueFrom `json:"valueFrom,omitempty" protobuf:"bytes,4,opt,name=valueFrom"`

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

Parameter indicate a passed string parameter to a service template with an optional default value

func (*Parameter) DeepCopy

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

type RawArtifact struct {
	// Data is the string contents of the artifact
	Data string `json:"data" protobuf:"bytes,1,opt,name=data"`
}

RawArtifact allows raw string content to be placed as an artifact in a container

func (*RawArtifact) DeepCopy

func (in *RawArtifact) DeepCopy() *RawArtifact

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

func (*RawArtifact) DeepCopyInto

func (in *RawArtifact) DeepCopyInto(out *RawArtifact)

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

func (*RawArtifact) Descriptor

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

func (*RawArtifact) HasLocation

func (r *RawArtifact) HasLocation() bool

func (*RawArtifact) Marshal

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

func (*RawArtifact) 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) Size

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

func (*RawArtifact) String

func (this *RawArtifact) String() string

func (*RawArtifact) Unmarshal

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

func (*RawArtifact) XXX_DiscardUnknown

func (m *RawArtifact) XXX_DiscardUnknown()

func (*RawArtifact) XXX_Marshal

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

func (*RawArtifact) XXX_Merge

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

func (*RawArtifact) XXX_Size

func (m *RawArtifact) XXX_Size() int

func (*RawArtifact) XXX_Unmarshal

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

type ResourceTemplate

type ResourceTemplate struct {
	// Action is the action to perform to the resource.
	// Must be one of: get, create, apply, delete, replace, patch
	Action string `json:"action" protobuf:"bytes,1,opt,name=action"`

	// MergeStrategy is the strategy used to merge a patch. It defaults to "strategic"
	// Must be one of: strategic, merge, json
	MergeStrategy string `json:"mergeStrategy,omitempty" protobuf:"bytes,2,opt,name=mergeStrategy"`

	// Manifest contains the kubernetes manifest
	Manifest string `json:"manifest" protobuf:"bytes,3,opt,name=manifest"`

	// SetOwnerReference sets the reference to the workflow on the OwnerReference of generated resource.
	SetOwnerReference bool `json:"setOwnerReference,omitempty" protobuf:"varint,4,opt,name=setOwnerReference"`

	// SuccessCondition is a label selector expression which describes the conditions
	// of the k8s resource in which it is acceptable to proceed to the following step
	SuccessCondition string `json:"successCondition,omitempty" protobuf:"bytes,5,opt,name=successCondition"`

	// FailureCondition is a label selector expression which describes the conditions
	// of the k8s resource in which the step was considered failed
	FailureCondition string `json:"failureCondition,omitempty" protobuf:"bytes,6,opt,name=failureCondition"`
}

ResourceTemplate is a template subtype to manipulate kubernetes resources

func (*ResourceTemplate) DeepCopy

func (in *ResourceTemplate) DeepCopy() *ResourceTemplate

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

func (*ResourceTemplate) DeepCopyInto

func (in *ResourceTemplate) DeepCopyInto(out *ResourceTemplate)

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

func (*ResourceTemplate) Descriptor

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

func (*ResourceTemplate) Marshal

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

func (*ResourceTemplate) 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 RetryPolicy

type RetryPolicy string
const (
	RetryPolicyAlways    RetryPolicy = "Always"
	RetryPolicyOnFailure RetryPolicy = "OnFailure"
	RetryPolicyOnError   RetryPolicy = "OnError"
)

type RetryStrategy

type RetryStrategy struct {
	// Limit is the maximum number of attempts when retrying a container
	Limit *int32 `json:"limit,omitempty" protobuf:"varint,1,opt,name=limit"`

	// RetryPolicy is a policy of NodePhase statuses that will be retried
	RetryPolicy RetryPolicy `json:"retryPolicy,omitempty" protobuf:"bytes,2,opt,name=retryPolicy,casttype=RetryPolicy"`

	// Backoff is a backoff strategy
	Backoff *Backoff `json:"backoff,omitempty" protobuf:"bytes,3,opt,name=backoff,casttype=Backoff"`
}

RetryStrategy provides controls on how to retry a workflow step

func (*RetryStrategy) DeepCopy

func (in *RetryStrategy) DeepCopy() *RetryStrategy

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

func (*RetryStrategy) DeepCopyInto

func (in *RetryStrategy) DeepCopyInto(out *RetryStrategy)

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

func (*RetryStrategy) Descriptor

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

func (*RetryStrategy) Marshal

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

func (*RetryStrategy) 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) 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) Size

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

func (*S3Artifact) String

func (this *S3Artifact) String() string

func (*S3Artifact) Unmarshal

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

func (*S3Artifact) XXX_DiscardUnknown

func (m *S3Artifact) XXX_DiscardUnknown()

func (*S3Artifact) XXX_Marshal

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

func (*S3Artifact) XXX_Merge

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

func (*S3Artifact) XXX_Size

func (m *S3Artifact) XXX_Size() int

func (*S3Artifact) XXX_Unmarshal

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

type S3Bucket

type S3Bucket struct {
	// Endpoint is the hostname of the bucket endpoint
	Endpoint string `json:"endpoint" protobuf:"bytes,1,opt,name=endpoint"`

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

	// Region contains the optional bucket region
	Region string `json:"region,omitempty" protobuf:"bytes,3,opt,name=region"`

	// Insecure will connect to the service with TLS
	Insecure *bool `json:"insecure,omitempty" protobuf:"varint,4,opt,name=insecure"`

	// AccessKeySecret is the secret selector to the bucket's access key
	AccessKeySecret apiv1.SecretKeySelector `json:"accessKeySecret" protobuf:"bytes,5,opt,name=accessKeySecret"`

	// SecretKeySecret is the secret selector to the bucket's secret key
	SecretKeySecret apiv1.SecretKeySelector `json:"secretKeySecret" protobuf:"bytes,6,opt,name=secretKeySecret"`

	// RoleARN is the Amazon Resource Name (ARN) of the role to assume.
	RoleARN string `json:"roleARN,omitempty" protobuf:"bytes,7,opt,name=roleARN"`
}

S3Bucket contains the access information required for interfacing with an S3 bucket

func (*S3Bucket) DeepCopy

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 Sequence

type Sequence struct {
	// Count is number of elements in the sequence (default: 0). Not to be used with end
	Count string `json:"count,omitempty" protobuf:"bytes,1,opt,name=count"`

	// Number at which to start the sequence (default: 0)
	Start string `json:"start,omitempty" protobuf:"bytes,2,opt,name=start"`

	// Number at which to end the sequence (default: 0). Not to be used with Count
	End string `json:"end,omitempty" protobuf:"bytes,3,opt,name=end"`

	// Format is a printf format string to format the value in the sequence
	Format string `json:"format,omitempty" protobuf:"bytes,4,opt,name=format"`
}

Sequence expands a workflow step into numeric range

func (*Sequence) DeepCopy

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

type TTLStrategy struct {
	SecondsAfterCompletion *int32 `json:"secondsAfterCompletion,omitempty" protobuf:"bytes,1,opt,name=secondsAfterCompletion"`
	SecondsAfterSuccess    *int32 `json:"secondsAfterSuccess,omitempty" protobuf:"bytes,2,opt,name=secondsAfterSuccess"`
	SecondsAfterFailure    *int32 `json:"secondsAfterFailure,omitempty" protobuf:"bytes,3,opt,name=secondsAfterFailure"`
}

TTLStrategy is the strategy for the time to live depending on if the workflow succeded or failed

func (*TTLStrategy) DeepCopy

func (in *TTLStrategy) DeepCopy() *TTLStrategy

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

func (*TTLStrategy) DeepCopyInto

func (in *TTLStrategy) DeepCopyInto(out *TTLStrategy)

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

func (*TTLStrategy) Descriptor

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

func (*TTLStrategy) Marshal

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

func (*TTLStrategy) 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