v1alpha1

package
v2.5.0-rc8+incompatible Latest Latest
Warning

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

 Go to latest Published: Feb 4, 2020 License: Apache-2.0 Imports: 18 Imported by: 0

Documentation ¶

Overview ¶

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

Index ¶

Constants ¶

This section is empty.

Variables ¶

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

SchemeGroupVersion is group version used to register these objects

View Source 
var (
	SchemeBuilder = runtime.NewSchemeBuilder(addKnownTypes)
	AddToScheme   = SchemeBuilder.AddToScheme
)

Functions ¶

func GetOpenAPIDefinitions ¶ 

func GetOpenAPIDefinitions(ref common.ReferenceCallback) map[string]common.OpenAPIDefinition

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 ¶ 

func (in *ArtifactRepositoryRef) DeepCopy() *ArtifactRepositoryRef

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 ¶ 

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

func (*TTLStrategy) String ¶ 

func (this *TTLStrategy) String() string

func (*TTLStrategy) Unmarshal ¶ 

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

func (*TTLStrategy) XXX_DiscardUnknown ¶ 

func (m *TTLStrategy) XXX_DiscardUnknown()

func (*TTLStrategy) XXX_Marshal ¶ 

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

func (*TTLStrategy) XXX_Merge ¶ 

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

func (*TTLStrategy) XXX_Size ¶ 

func (m *TTLStrategy) XXX_Size() int

func (*TTLStrategy) XXX_Unmarshal ¶ 

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

type TarStrategy ¶ 

type TarStrategy struct{}

TarStrategy will tar and gzip the file or directory when saving

func (*TarStrategy) DeepCopy ¶ 

func (in *TarStrategy) DeepCopy() *TarStrategy

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

func (*TarStrategy) DeepCopyInto ¶ 

func (in *TarStrategy) DeepCopyInto(out *TarStrategy)

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

func (*TarStrategy) Descriptor ¶ 

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

func (*TarStrategy) Marshal ¶ 

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

func (*TarStrategy) MarshalTo ¶ 

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

func (*TarStrategy) MarshalToSizedBuffer ¶ 

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

func (*TarStrategy) ProtoMessage ¶ 

func (*TarStrategy) ProtoMessage()

func (*TarStrategy) Reset ¶ 

func (m *TarStrategy) Reset()

func (*TarStrategy) Size ¶ 

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

func (*TarStrategy) String ¶ 

func (this *TarStrategy) String() string

func (*TarStrategy) Unmarshal ¶ 

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

func (*TarStrategy) XXX_DiscardUnknown ¶ 

func (m *TarStrategy) XXX_DiscardUnknown()

func (*TarStrategy) XXX_Marshal ¶ 

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

func (*TarStrategy) XXX_Merge ¶ 

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

func (*TarStrategy) XXX_Size ¶ 

func (m *TarStrategy) XXX_Size() int

func (*TarStrategy) XXX_Unmarshal ¶ 

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

type Template ¶ 

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

	// Template is the name of the template which is used as the base of this template.
	Template string `json:"template,omitempty" protobuf:"bytes,2,opt,name=template"`

	// Arguments hold arguments to the template.
	Arguments Arguments `json:"arguments,omitempty" protobuf:"bytes,3,opt,name=arguments"`

	// TemplateRef is the reference to the template resource which is used as the base of this template.
	TemplateRef *TemplateRef `json:"templateRef,omitempty" protobuf:"bytes,4,opt,name=templateRef"`

	// Inputs describe what inputs parameters and artifacts are supplied to this template
	Inputs Inputs `json:"inputs,omitempty" protobuf:"bytes,5,opt,name=inputs"`

	// Outputs describe the parameters and artifacts that this template produces
	Outputs Outputs `json:"outputs,omitempty" protobuf:"bytes,6,opt,name=outputs"`

	// NodeSelector is a selector to schedule this step of the workflow to be
	// run on the selected node(s). Overrides the selector set at the workflow level.
	NodeSelector map[string]string `json:"nodeSelector,omitempty" protobuf:"bytes,7,opt,name=nodeSelector"`

	// Affinity sets the pod's scheduling constraints
	// Overrides the affinity set at the workflow level (if any)
	Affinity *apiv1.Affinity `json:"affinity,omitempty" protobuf:"bytes,8,opt,name=affinity"`

	// Metdata sets the pods's metadata, i.e. annotations and labels
	Metadata Metadata `json:"metadata,omitempty" protobuf:"bytes,9,opt,name=metadata"`

	// Deamon will allow a workflow to proceed to the next step so long as the container reaches readiness
	Daemon *bool `json:"daemon,omitempty" protobuf:"bytes,10,opt,name=daemon"`

	// Steps define a series of sequential/parallel workflow steps
	Steps []ParallelSteps `json:"steps,omitempty" protobuf:"bytes,11,opt,name=steps"`

	// Container is the main container image to run in the pod
	Container *apiv1.Container `json:"container,omitempty" protobuf:"bytes,12,opt,name=container"`

	// Script runs a portion of code against an interpreter
	Script *ScriptTemplate `json:"script,omitempty" protobuf:"bytes,13,opt,name=script"`

	// Resource template subtype which can run k8s resources
	Resource *ResourceTemplate `json:"resource,omitempty" protobuf:"bytes,14,opt,name=resource"`

	// DAG template subtype which runs a DAG
	DAG *DAGTemplate `json:"dag,omitempty" protobuf:"bytes,15,opt,name=dag"`

	// Suspend template subtype which can suspend a workflow when reaching the step
	Suspend *SuspendTemplate `json:"suspend,omitempty" protobuf:"bytes,16,opt,name=suspend"`

	// Volumes is a list of volumes that can be mounted by containers in a template.
	// +patchStrategy=merge
	// +patchMergeKey=name
	Volumes []apiv1.Volume `json:"volumes,omitempty" patchStrategy:"merge" patchMergeKey:"name" protobuf:"bytes,17,opt,name=volumes"`

	// InitContainers is a list of containers which run before the main container.
	// +patchStrategy=merge
	// +patchMergeKey=name
	InitContainers []UserContainer `json:"initContainers,omitempty" patchStrategy:"merge" patchMergeKey:"name" protobuf:"bytes,18,opt,name=initContainers"`

	// Sidecars is a list of containers which run alongside the main container
	// Sidecars are automatically killed when the main container completes
	// +patchStrategy=merge
	// +patchMergeKey=name
	Sidecars []UserContainer `json:"sidecars,omitempty" patchStrategy:"merge" patchMergeKey:"name" protobuf:"bytes,19,opt,name=sidecars"`

	// Location in which all files related to the step will be stored (logs, artifacts, etc...).
	// Can be overridden by individual items in Outputs. If omitted, will use the default
	// artifact repository location configured in the controller, appended with the
	// <workflowname>/<nodename> in the key.
	ArchiveLocation *ArtifactLocation `json:"archiveLocation,omitempty" protobuf:"bytes,20,opt,name=archiveLocation"`

	// Optional duration in seconds relative to the StartTime that the pod may be active on a node
	// before the system actively tries to terminate the pod; value must be positive integer
	// This field is only applicable to container and script templates.
	ActiveDeadlineSeconds *int64 `json:"activeDeadlineSeconds,omitempty" protobuf:"bytes,21,opt,name=activeDeadlineSeconds"`

	// RetryStrategy describes how to retry a template when it fails
	RetryStrategy *RetryStrategy `json:"retryStrategy,omitempty" protobuf:"bytes,22,opt,name=retryStrategy"`

	// Parallelism limits the max total parallel pods that can execute at the same time within the
	// boundaries of this template invocation. If additional steps/dag templates are invoked, the
	// pods created by those templates will not be counted towards this total.
	Parallelism *int64 `json:"parallelism,omitempty" protobuf:"bytes,23,opt,name=parallelism"`

	// Tolerations to apply to workflow pods.
	// +patchStrategy=merge
	// +patchMergeKey=key
	Tolerations []apiv1.Toleration `json:"tolerations,omitempty" patchStrategy:"merge" patchMergeKey:"key" protobuf:"bytes,24,opt,name=tolerations"`

	// If specified, the pod will be dispatched by specified scheduler.
	// Or it will be dispatched by workflow scope scheduler if specified.
	// If neither specified, the pod will be dispatched by default scheduler.
	// +optional
	SchedulerName string `json:"schedulerName,omitempty" protobuf:"bytes,25,opt,name=schedulerName"`

	// PriorityClassName to apply to workflow pods.
	PriorityClassName string `json:"priorityClassName,omitempty" protobuf:"bytes,26,opt,name=priorityClassName"`

	// Priority to apply to workflow pods.
	Priority *int32 `json:"priority,omitempty" protobuf:"bytes,27,opt,name=priority"`

	// ServiceAccountName to apply to workflow pods
	ServiceAccountName string `json:"serviceAccountName,omitempty" protobuf:"bytes,28,opt,name=serviceAccountName"`

	// AutomountServiceAccountToken indicates whether a service account token should be automatically mounted in pods.
	// ServiceAccountName of ExecutorConfig must be specified if this value is false.
	AutomountServiceAccountToken *bool `json:"automountServiceAccountToken,omitempty" protobuf:"varint,32,opt,name=automountServiceAccountToken"`

	// Executor holds configurations of the executor container.
	Executor *ExecutorConfig `json:"executor,omitempty" protobuf:"bytes,33,opt,name=executor"`

	// HostAliases is an optional list of hosts and IPs that will be injected into the pod spec
	// +patchStrategy=merge
	// +patchMergeKey=ip
	HostAliases []apiv1.HostAlias `json:"hostAliases,omitempty" patchStrategy:"merge" patchMergeKey:"ip" protobuf:"bytes,29,opt,name=hostAliases"`

	// SecurityContext holds pod-level security attributes and common container settings.
	// Optional: Defaults to empty.  See type description for default values of each field.
	// +optional
	SecurityContext *apiv1.PodSecurityContext `json:"securityContext,omitempty" protobuf:"bytes,30,opt,name=securityContext"`

	// PodSpecPatch holds strategic merge patch to apply against the pod spec. Allows parameterization of
	// container fields which are not strings (e.g. resource limits).
	PodSpecPatch string `json:"podSpecPatch,omitempty" protobuf:"bytes,31,opt,name=podSpecPatch"`
}

Template is a reusable and composable unit of execution in a workflow

func (*Template) DeepCopy ¶ 

func (in *Template) DeepCopy() *Template

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

func (*Template) DeepCopyInto ¶ 

func (in *Template) DeepCopyInto(out *Template)

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

func (*Template) Descriptor ¶ 

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

func (*Template) GetBaseTemplate ¶ 

func (tmpl *Template) GetBaseTemplate() *Template

GetBaseTemplate returns a base template content.

func (*Template) GetTemplateName ¶ 

func (tmpl *Template) GetTemplateName() string

func (*Template) GetTemplateRef ¶ 

func (tmpl *Template) GetTemplateRef() *TemplateRef

func (*Template) GetType ¶ 

func (tmpl *Template) GetType() TemplateType

GetType returns the type of this template

func (*Template) HasPodSpecPatch ¶ 

func (tmpl *Template) HasPodSpecPatch() bool

func (*Template) IsLeaf ¶ 

func (tmpl *Template) IsLeaf() bool

IsLeaf returns whether or not the template is a leaf

func (*Template) IsPodType ¶ 

func (tmpl *Template) IsPodType() bool

IsPodType returns whether or not the template is a pod type

func (*Template) IsResolvable ¶ 

func (tmpl *Template) IsResolvable() bool

func (*Template) Marshal ¶ 

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

func (*Template) MarshalTo ¶ 

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

func (*Template) MarshalToSizedBuffer ¶ 

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

func (*Template) ProtoMessage ¶ 

func (*Template) ProtoMessage()

func (*Template) Reset ¶ 

func (m *Template) Reset()

func (*Template) Size ¶ 

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

func (*Template) String ¶ 

func (this *Template) String() string

func (*Template) Unmarshal ¶ 

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

func (*Template) XXX_DiscardUnknown ¶ 

func (m *Template) XXX_DiscardUnknown()

func (*Template) XXX_Marshal ¶ 

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

func (*Template) XXX_Merge ¶ 

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

func (*Template) XXX_Size ¶ 

func (m *Template) XXX_Size() int

func (*Template) XXX_Unmarshal ¶ 

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

type TemplateGetter ¶ 

type TemplateGetter interface {
	GetNamespace() string
	GetName() string
	GroupVersionKind() schema.GroupVersionKind
	GetTemplateByName(name string) *Template
	GetTemplateScope() string
}

TemplateGetter is an interface to get templates.

type TemplateHolder ¶ 

type TemplateHolder interface {
	GetTemplateName() string
	GetTemplateRef() *TemplateRef
	IsResolvable() bool
}

TemplateHolder is an interface for holders of templates.

type TemplateRef ¶ 

type TemplateRef struct {
	// Name is the resource name of the template.
	Name string `json:"name,omitempty" protobuf:"bytes,1,opt,name=name"`
	// Template is the name of referred template in the resource.
	Template string `json:"template,omitempty" protobuf:"bytes,2,opt,name=template"`
	// RuntimeResolution skips validation at creation time.
	// By enabling this option, you can create the referred workflow template before the actual runtime.
	RuntimeResolution bool `json:"runtimeResolution,omitempty" protobuf:"varint,3,opt,name=runtimeResolution"`
}

TemplateRef is a reference of template resource.

func (*TemplateRef) DeepCopy ¶ 

func (in *TemplateRef) DeepCopy() *TemplateRef

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

func (*TemplateRef) DeepCopyInto ¶ 

func (in *TemplateRef) DeepCopyInto(out *TemplateRef)

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

func (*TemplateRef) Descriptor ¶ 

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

func (*TemplateRef) Marshal ¶ 

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

func (*TemplateRef) MarshalTo ¶ 

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

func (*TemplateRef) MarshalToSizedBuffer ¶ 

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

func (*TemplateRef) ProtoMessage ¶ 

func (*TemplateRef) ProtoMessage()

func (*TemplateRef) Reset ¶ 

func (m *TemplateRef) Reset()

func (*TemplateRef) Size ¶ 

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

func (*TemplateRef) String ¶ 

func (this *TemplateRef) String() string

func (*TemplateRef) Unmarshal ¶ 

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

func (*TemplateRef) XXX_DiscardUnknown ¶ 

func (m *TemplateRef) XXX_DiscardUnknown()

func (*TemplateRef) XXX_Marshal ¶ 

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

func (*TemplateRef) XXX_Merge ¶ 

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

func (*TemplateRef) XXX_Size ¶ 

func (m *TemplateRef) XXX_Size() int

func (*TemplateRef) XXX_Unmarshal ¶ 

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

type TemplateStorage ¶ 

type TemplateStorage interface {
	GetStoredTemplate(templateScope string, holder TemplateHolder) *Template
	SetStoredTemplate(templateScope string, holder TemplateHolder, tmpl *Template) (bool, error)
}

TemplateStorage is an interface of template storage getter and setter.

type TemplateType ¶ 

type TemplateType string

TemplateType is the type of a template 

const (
	TemplateTypeContainer TemplateType = "Container"
	TemplateTypeSteps     TemplateType = "Steps"
	TemplateTypeScript    TemplateType = "Script"
	TemplateTypeResource  TemplateType = "Resource"
	TemplateTypeDAG       TemplateType = "DAG"
	TemplateTypeSuspend   TemplateType = "Suspend"
	TemplateTypeUnknown   TemplateType = "Unknown"
)

Possible template types

type Type ¶ 

type Type int

Type represents the stored type of Item. 

const (
	Number Type = iota
	String
	Bool
	Map
	List
)

type UserContainer ¶ 

type UserContainer struct {
	apiv1.Container `json:",inline" protobuf:"bytes,1,opt,name=container"`

	// MirrorVolumeMounts will mount the same volumes specified in the main container
	// to the container (including artifacts), at the same mountPaths. This enables
	// dind daemon to partially see the same filesystem as the main container in
	// order to use features such as docker volume binding
	MirrorVolumeMounts *bool `json:"mirrorVolumeMounts,omitempty" protobuf:"varint,2,opt,name=mirrorVolumeMounts"`
}

UserContainer is a container specified by a user.

func (*UserContainer) DeepCopy ¶ 

func (in *UserContainer) DeepCopy() *UserContainer

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

func (*UserContainer) DeepCopyInto ¶ 

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

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

func (*UserContainer) Descriptor ¶ 

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

func (*UserContainer) Marshal ¶ 

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

func (*UserContainer) MarshalTo ¶ 

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

func (*UserContainer) MarshalToSizedBuffer ¶ 

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

func (*UserContainer) ProtoMessage ¶ 

func (*UserContainer) ProtoMessage()

func (*UserContainer) Reset ¶ 

func (m *UserContainer) Reset()

func (*UserContainer) Size ¶ 

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

func (*UserContainer) String ¶ 

func (this *UserContainer) String() string

func (*UserContainer) Unmarshal ¶ 

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

func (*UserContainer) XXX_DiscardUnknown ¶ 

func (m *UserContainer) XXX_DiscardUnknown()

func (*UserContainer) XXX_Marshal ¶ 

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

func (*UserContainer) XXX_Merge ¶ 

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

func (*UserContainer) XXX_Size ¶ 

func (m *UserContainer) XXX_Size() int

func (*UserContainer) XXX_Unmarshal ¶ 

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

type ValueFrom ¶ 

type ValueFrom struct {
	// Path in the container to retrieve an output parameter value from in container templates
	Path string `json:"path,omitempty" protobuf:"bytes,1,opt,name=path"`

	// JSONPath of a resource to retrieve an output parameter value from in resource templates
	JSONPath string `json:"jsonPath,omitempty" protobuf:"bytes,2,opt,name=jsonPath"`

	// JQFilter expression against the resource object in resource templates
	JQFilter string `json:"jqFilter,omitempty" protobuf:"bytes,3,opt,name=jqFilter"`

	// Parameter reference to a step or dag task in which to retrieve an output parameter value from
	// (e.g. '{{steps.mystep.outputs.myparam}}')
	Parameter string `json:"parameter,omitempty" protobuf:"bytes,4,opt,name=parameter"`
}

ValueFrom describes a location in which to obtain the value to a parameter

func (*ValueFrom) DeepCopy ¶ 

func (in *ValueFrom) DeepCopy() *ValueFrom

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

func (*ValueFrom) DeepCopyInto ¶ 

func (in *ValueFrom) DeepCopyInto(out *ValueFrom)

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

func (*ValueFrom) Descriptor ¶ 

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

func (*ValueFrom) Marshal ¶ 

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

func (*ValueFrom) MarshalTo ¶ 

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

func (*ValueFrom) MarshalToSizedBuffer ¶ 

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

func (*ValueFrom) ProtoMessage ¶ 

func (*ValueFrom) ProtoMessage()

func (*ValueFrom) Reset ¶ 

func (m *ValueFrom) Reset()

func (*ValueFrom) Size ¶ 

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

func (*ValueFrom) String ¶ 

func (this *ValueFrom) String() string

func (*ValueFrom) Unmarshal ¶ 

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

func (*ValueFrom) XXX_DiscardUnknown ¶ 

func (m *ValueFrom) XXX_DiscardUnknown()

func (*ValueFrom) XXX_Marshal ¶ 

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

func (*ValueFrom) XXX_Merge ¶ 

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

func (*ValueFrom) XXX_Size ¶ 

func (m *ValueFrom) XXX_Size() int

func (*ValueFrom) XXX_Unmarshal ¶ 

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

type Workflow ¶ 

type Workflow struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata" protobuf:"bytes,1,opt,name=metadata"`
	Spec              WorkflowSpec   `json:"spec" protobuf:"bytes,2,opt,name=spec "`
	Status            WorkflowStatus `json:"status" protobuf:"bytes,3,opt,name=status"`
}

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

func (*Workflow) DeepCopy ¶ 

func (in *Workflow) DeepCopy() *Workflow

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

func (*Workflow) DeepCopyInto ¶ 

func (in *Workflow) DeepCopyInto(out *Workflow)

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

func (*Workflow) DeepCopyObject ¶ 

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

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

func (*Workflow) Descriptor ¶ 

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

func (*Workflow) GetOffloadNodeStatusVersion ¶ 

func (wf *Workflow) GetOffloadNodeStatusVersion() string

func (*Workflow) GetStoredTemplate ¶ 

func (wf *Workflow) GetStoredTemplate(templateScope string, holder TemplateHolder) *Template

GetStoredTemplate retrieves a template from stored templates of the workflow.

func (*Workflow) GetTemplateByName ¶ 

func (wf *Workflow) GetTemplateByName(name string) *Template

GetTemplateByName retrieves a defined template by its name

func (*Workflow) GetTemplateScope ¶ 

func (wf *Workflow) GetTemplateScope() string

GetTemplateScope returns the template scope of workflow.

func (*Workflow) Marshal ¶ 

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

func (*Workflow) MarshalTo ¶ 

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

func (*Workflow) MarshalToSizedBuffer ¶ 

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

func (*Workflow) NodeID ¶ 

func (wf *Workflow) NodeID(name string) string

NodeID creates a deterministic node ID based on a node name

func (*Workflow) ProtoMessage ¶ 

func (*Workflow) ProtoMessage()

func (*Workflow) Reset ¶ 

func (m *Workflow) Reset()

func (*Workflow) SetStoredTemplate ¶ 

func (wf *Workflow) SetStoredTemplate(templateScope string, holder TemplateHolder, tmpl *Template) (bool, error)

SetStoredTemplate stores a new template in stored templates of the workflow.

func (*Workflow) Size ¶ 

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

func (*Workflow) String ¶ 

func (this *Workflow) String() string

func (*Workflow) Unmarshal ¶ 

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

func (*Workflow) XXX_DiscardUnknown ¶ 

func (m *Workflow) XXX_DiscardUnknown()

func (*Workflow) XXX_Marshal ¶ 

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

func (*Workflow) XXX_Merge ¶ 

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

func (*Workflow) XXX_Size ¶ 

func (m *Workflow) XXX_Size() int

func (*Workflow) XXX_Unmarshal ¶ 

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

type WorkflowList ¶ 

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

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

func (*WorkflowList) DeepCopy ¶ 

func (in *WorkflowList) DeepCopy() *WorkflowList

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

func (*WorkflowList) DeepCopyInto ¶ 

func (in *WorkflowList) DeepCopyInto(out *WorkflowList)

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

func (*WorkflowList) DeepCopyObject ¶ 

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

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

func (*WorkflowList) Descriptor ¶ 

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

func (*WorkflowList) Marshal ¶ 

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

func (*WorkflowList) MarshalTo ¶ 

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

func (*WorkflowList) MarshalToSizedBuffer ¶ 

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

func (*WorkflowList) ProtoMessage ¶ 

func (*WorkflowList) ProtoMessage()

func (*WorkflowList) Reset ¶ 

func (m *WorkflowList) Reset()

func (*WorkflowList) Size ¶ 

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

func (*WorkflowList) String ¶ 

func (this *WorkflowList) String() string

func (*WorkflowList) Unmarshal ¶ 

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

func (*WorkflowList) XXX_DiscardUnknown ¶ 

func (m *WorkflowList) XXX_DiscardUnknown()

func (*WorkflowList) XXX_Marshal ¶ 

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

func (*WorkflowList) XXX_Merge ¶ 

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

func (*WorkflowList) XXX_Size ¶ 

func (m *WorkflowList) XXX_Size() int

func (*WorkflowList) XXX_Unmarshal ¶ 

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

type WorkflowSpec ¶ 

type WorkflowSpec struct {
	// Templates is a list of workflow templates used in a workflow
	// +patchStrategy=merge
	// +patchMergeKey=name
	Templates []Template `json:"templates" patchStrategy:"merge" patchMergeKey:"name" protobuf:"bytes,1,opt,name=templates"`

	// Entrypoint is a template reference to the starting point of the workflow
	Entrypoint string `json:"entrypoint" protobuf:"bytes,2,opt,name=entrypoint"`

	// Arguments contain the parameters and artifacts sent to the workflow entrypoint
	// Parameters are referencable globally using the 'workflow' variable prefix.
	// e.g. {{workflow.parameters.myparam}}
	Arguments Arguments `json:"arguments,omitempty" protobuf:"bytes,3,opt,name=arguments"`

	// ServiceAccountName is the name of the ServiceAccount to run all pods of the workflow as.
	ServiceAccountName string `json:"serviceAccountName,omitempty" protobuf:"bytes,4,opt,name=serviceAccountName"`

	// AutomountServiceAccountToken indicates whether a service account token should be automatically mounted in pods.
	// ServiceAccountName of ExecutorConfig must be specified if this value is false.
	AutomountServiceAccountToken *bool `json:"automountServiceAccountToken,omitempty" protobuf:"varint,28,opt,name=automountServiceAccountToken"`

	// Executor holds configurations of executor containers of the workflow.
	Executor *ExecutorConfig `json:"executor,omitempty" protobuf:"bytes,29,opt,name=executor"`

	// Volumes is a list of volumes that can be mounted by containers in a workflow.
	// +patchStrategy=merge
	// +patchMergeKey=name
	Volumes []apiv1.Volume `json:"volumes,omitempty" patchStrategy:"merge" patchMergeKey:"name" protobuf:"bytes,5,opt,name=volumes"`

	// VolumeClaimTemplates is a list of claims that containers are allowed to reference.
	// The Workflow controller will create the claims at the beginning of the workflow
	// and delete the claims upon completion of the workflow
	// +patchStrategy=merge
	// +patchMergeKey=name
	VolumeClaimTemplates []apiv1.PersistentVolumeClaim `` /* 129-byte string literal not displayed */

	// Parallelism limits the max total parallel pods that can execute at the same time in a workflow
	Parallelism *int64 `json:"parallelism,omitempty" protobuf:"bytes,7,opt,name=parallelism"`

	// ArtifactRepositoryRef specifies the configMap name and key containing the artifact repository config.
	ArtifactRepositoryRef *ArtifactRepositoryRef `json:"artifactRepositoryRef,omitempty" protobuf:"bytes,8,opt,name=artifactRepositoryRef"`

	// Suspend will suspend the workflow and prevent execution of any future steps in the workflow
	Suspend *bool `json:"suspend,omitempty" protobuf:"bytes,9,opt,name=suspend"`

	// NodeSelector is a selector which will result in all pods of the workflow
	// to be scheduled on the selected node(s). This is able to be overridden by
	// a nodeSelector specified in the template.
	NodeSelector map[string]string `json:"nodeSelector,omitempty" protobuf:"bytes,10,opt,name=nodeSelector"`

	// Affinity sets the scheduling constraints for all pods in the workflow.
	// Can be overridden by an affinity specified in the template
	Affinity *apiv1.Affinity `json:"affinity,omitempty" protobuf:"bytes,11,opt,name=affinity"`

	// Tolerations to apply to workflow pods.
	// +patchStrategy=merge
	// +patchMergeKey=key
	Tolerations []apiv1.Toleration `json:"tolerations,omitempty" patchStrategy:"merge" patchMergeKey:"key" protobuf:"bytes,12,opt,name=tolerations"`

	// ImagePullSecrets is a list of references to secrets in the same namespace to use for pulling any images
	// in pods that reference this ServiceAccount. ImagePullSecrets are distinct from Secrets because Secrets
	// can be mounted in the pod, but ImagePullSecrets are only accessed by the kubelet.
	// More info: https://kubernetes.io/docs/concepts/containers/images/#specifying-imagepullsecrets-on-a-pod
	// +patchStrategy=merge
	// +patchMergeKey=name
	ImagePullSecrets []apiv1.LocalObjectReference `json:"imagePullSecrets,omitempty" patchStrategy:"merge" patchMergeKey:"name" protobuf:"bytes,13,opt,name=imagePullSecrets"`

	// Host networking requested for this workflow pod. Default to false.
	HostNetwork *bool `json:"hostNetwork,omitempty" protobuf:"bytes,14,opt,name=hostNetwork"`

	// Set DNS policy for the pod.
	// Defaults to "ClusterFirst".
	// Valid values are 'ClusterFirstWithHostNet', 'ClusterFirst', 'Default' or 'None'.
	// DNS parameters given in DNSConfig will be merged with the policy selected with DNSPolicy.
	// To have DNS options set along with hostNetwork, you have to specify DNS policy
	// explicitly to 'ClusterFirstWithHostNet'.
	DNSPolicy *apiv1.DNSPolicy `json:"dnsPolicy,omitempty" protobuf:"bytes,15,opt,name=dnsPolicy"`

	// PodDNSConfig defines the DNS parameters of a pod in addition to
	// those generated from DNSPolicy.
	DNSConfig *apiv1.PodDNSConfig `json:"dnsConfig,omitempty" protobuf:"bytes,16,opt,name=dnsConfig"`

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

	// TTLSecondsAfterFinished limits the lifetime of a Workflow that has finished execution
	// (Succeeded, Failed, Error). If this field is set, once the Workflow finishes, it will be
	// deleted after ttlSecondsAfterFinished expires. If this field is unset,
	// ttlSecondsAfterFinished will not expire. If this field is set to zero,
	// ttlSecondsAfterFinished expires immediately after the Workflow finishes.
	// DEPRECATED: Use TTLStrategy.SecondsAfterCompletion instead.
	TTLSecondsAfterFinished *int32 `json:"ttlSecondsAfterFinished,omitempty" protobuf:"bytes,18,opt,name=ttlSecondsAfterFinished"`

	// TTLStrategy limits the lifetime of a Workflow that has finished execution depending on if it
	// Succeeded or Failed. If this struct is set, once the Workflow finishes, it will be
	// deleted after the time to live expires. If this field is unset,
	// the controller config map will hold the default values
	// Update
	TTLStrategy *TTLStrategy `json:"ttlStrategy,omitempty" protobuf:"bytes,30,opt,name=ttlStrategy"`

	// Optional duration in seconds relative to the workflow start time which the workflow is
	// allowed to run before the controller terminates the workflow. A value of zero is used to
	// terminate a Running workflow
	ActiveDeadlineSeconds *int64 `json:"activeDeadlineSeconds,omitempty" protobuf:"bytes,19,opt,name=activeDeadlineSeconds"`

	// Priority is used if controller is configured to process limited number of workflows in parallel. Workflows with higher priority are processed first.
	Priority *int32 `json:"priority,omitempty" protobuf:"bytes,20,opt,name=priority"`

	// Set scheduler name for all pods.
	// Will be overridden if container/script template's scheduler name is set.
	// Default scheduler will be used if neither specified.
	// +optional
	SchedulerName string `json:"schedulerName,omitempty" protobuf:"bytes,21,opt,name=schedulerName"`

	// PodGC describes the strategy to use when to deleting completed pods
	PodGC *PodGC `json:"podGC,omitempty" protobuf:"bytes,22,opt,name=podGC"`

	// PriorityClassName to apply to workflow pods.
	PodPriorityClassName string `json:"podPriorityClassName,omitempty" protobuf:"bytes,23,opt,name=podPriorityClassName"`

	// Priority to apply to workflow pods.
	PodPriority *int32 `json:"podPriority,omitempty" protobuf:"bytes,24,opt,name=podPriority"`

	// +patchStrategy=merge
	// +patchMergeKey=ip
	HostAliases []apiv1.HostAlias `json:"hostAliases,omitempty" patchStrategy:"merge" patchMergeKey:"ip" protobuf:"bytes,25,opt,name=hostAliases"`

	// SecurityContext holds pod-level security attributes and common container settings.
	// Optional: Defaults to empty.  See type description for default values of each field.
	// +optional
	SecurityContext *apiv1.PodSecurityContext `json:"securityContext,omitempty" protobuf:"bytes,26,opt,name=securityContext"`

	// PodSpecPatch holds strategic merge patch to apply against the pod spec. Allows parameterization of
	// container fields which are not strings (e.g. resource limits).
	PodSpecPatch string `json:"podSpecPatch,omitempty" protobuf:"bytes,27,opt,name=podSpecPatch"`
}

WorkflowSpec is the specification of a Workflow.

func (*WorkflowSpec) DeepCopy ¶ 

func (in *WorkflowSpec) DeepCopy() *WorkflowSpec

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

func (*WorkflowSpec) DeepCopyInto ¶ 

func (in *WorkflowSpec) DeepCopyInto(out *WorkflowSpec)

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

func (*WorkflowSpec) Descriptor ¶ 

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

func (*WorkflowSpec) HasPodSpecPatch ¶ 

func (wfs *WorkflowSpec) HasPodSpecPatch() bool

func (*WorkflowSpec) Marshal ¶ 

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

func (*WorkflowSpec) MarshalTo ¶ 

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

func (*WorkflowSpec) MarshalToSizedBuffer ¶ 

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

func (*WorkflowSpec) ProtoMessage ¶ 

func (*WorkflowSpec) ProtoMessage()

func (*WorkflowSpec) Reset ¶ 

func (m *WorkflowSpec) Reset()

func (*WorkflowSpec) Size ¶ 

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

func (*WorkflowSpec) String ¶ 

func (this *WorkflowSpec) String() string

func (*WorkflowSpec) Unmarshal ¶ 

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

func (*WorkflowSpec) XXX_DiscardUnknown ¶ 

func (m *WorkflowSpec) XXX_DiscardUnknown()

func (*WorkflowSpec) XXX_Marshal ¶ 

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

func (*WorkflowSpec) XXX_Merge ¶ 

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

func (*WorkflowSpec) XXX_Size ¶ 

func (m *WorkflowSpec) XXX_Size() int

func (*WorkflowSpec) XXX_Unmarshal ¶ 

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

type WorkflowStatus ¶ 

type WorkflowStatus struct {
	// Phase a simple, high-level summary of where the workflow is in its lifecycle.
	Phase NodePhase `json:"phase,omitempty" protobuf:"bytes,1,opt,name=phase,casttype=NodePhase"`

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

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

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

	// Compressed and base64 decoded Nodes map
	CompressedNodes string `json:"compressedNodes,omitempty" protobuf:"bytes,5,opt,name=compressedNodes"`

	// Nodes is a mapping between a node ID and the node's status.
	Nodes Nodes `json:"nodes,omitempty" protobuf:"bytes,6,rep,name=nodes"`

	// Whether on not node status has been offloaded to a database. If exists, then Nodes and CompressedNodes will be empty.
	// This will actually be populated with a hash of the offloaded data.
	OffloadNodeStatusVersion string `json:"offloadNodeStatusVersion,omitempty" protobuf:"bytes,10,rep,name=offloadNodeStatusVersion"`

	// StoredTemplates is a mapping between a template ref and the node's status.
	StoredTemplates map[string]Template `json:"storedTemplates,omitempty" protobuf:"bytes,9,rep,name=storedTemplates"`

	// PersistentVolumeClaims tracks all PVCs that were created as part of the workflow.
	// The contents of this list are drained at the end of the workflow.
	PersistentVolumeClaims []apiv1.Volume `json:"persistentVolumeClaims,omitempty" protobuf:"bytes,7,rep,name=persistentVolumeClaims"`

	// Outputs captures output values and artifact locations produced by the workflow via global outputs
	Outputs *Outputs `json:"outputs,omitempty" protobuf:"bytes,8,opt,name=outputs"`
}

WorkflowStatus contains overall status information about a workflow

func (*WorkflowStatus) Completed ¶ 

func (ws *WorkflowStatus) Completed() bool

Completed returns whether or not the workflow has completed execution

func (*WorkflowStatus) DeepCopy ¶ 

func (in *WorkflowStatus) DeepCopy() *WorkflowStatus

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

func (*WorkflowStatus) DeepCopyInto ¶ 

func (in *WorkflowStatus) DeepCopyInto(out *WorkflowStatus)

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

func (*WorkflowStatus) Descriptor ¶ 

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

func (*WorkflowStatus) Failed ¶ 

func (ws *WorkflowStatus) Failed() bool

Failed return whether or not the workflow has failed

func (*WorkflowStatus) GetOffloadNodeStatusVersion ¶ 

func (ws *WorkflowStatus) GetOffloadNodeStatusVersion() string

func (*WorkflowStatus) IsOffloadNodeStatus ¶ 

func (ws *WorkflowStatus) IsOffloadNodeStatus() bool

func (*WorkflowStatus) Marshal ¶ 

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

func (*WorkflowStatus) MarshalTo ¶ 

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

func (*WorkflowStatus) MarshalToSizedBuffer ¶ 

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

func (*WorkflowStatus) ProtoMessage ¶ 

func (*WorkflowStatus) ProtoMessage()

func (*WorkflowStatus) Reset ¶ 

func (m *WorkflowStatus) Reset()

func (*WorkflowStatus) Size ¶ 

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

func (*WorkflowStatus) String ¶ 

func (this *WorkflowStatus) String() string

func (*WorkflowStatus) Successful ¶ 

func (ws *WorkflowStatus) Successful() bool

Successful return whether or not the workflow has succeeded

func (*WorkflowStatus) Unmarshal ¶ 

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

func (*WorkflowStatus) XXX_DiscardUnknown ¶ 

func (m *WorkflowStatus) XXX_DiscardUnknown()

func (*WorkflowStatus) XXX_Marshal ¶ 

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

func (*WorkflowStatus) XXX_Merge ¶ 

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

func (*WorkflowStatus) XXX_Size ¶ 

func (m *WorkflowStatus) XXX_Size() int

func (*WorkflowStatus) XXX_Unmarshal ¶ 

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

type WorkflowStep ¶ 

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

	// Template is the name of the template to execute as the step
	Template string `json:"template,omitempty" protobuf:"bytes,2,opt,name=template"`

	// Arguments hold arguments to the template
	Arguments Arguments `json:"arguments,omitempty" protobuf:"bytes,3,opt,name=arguments"`

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

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

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

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

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

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

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

WorkflowStep is a reference to a template to execute in a series of step

func (*WorkflowStep) ContinuesOn ¶ 

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

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

func (*WorkflowStep) DeepCopy ¶ 

func (in *WorkflowStep) DeepCopy() *WorkflowStep

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

func (*WorkflowStep) DeepCopyInto ¶ 

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

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

func (*WorkflowStep) Descriptor ¶ 

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

func (*WorkflowStep) GetTemplateName ¶ 

func (step *WorkflowStep) GetTemplateName() string

func (*WorkflowStep) GetTemplateRef ¶ 

func (step *WorkflowStep) GetTemplateRef() *TemplateRef

func (*WorkflowStep) IsResolvable ¶ 

func (step *WorkflowStep) IsResolvable() bool

func (*WorkflowStep) Marshal ¶ 

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

func (*WorkflowStep) MarshalTo ¶ 

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

func (*WorkflowStep) MarshalToSizedBuffer ¶ 

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

func (*WorkflowStep) ProtoMessage ¶ 

func (*WorkflowStep) ProtoMessage()

func (*WorkflowStep) Reset ¶ 

func (m *WorkflowStep) Reset()

func (*WorkflowStep) Size ¶ 

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

func (*WorkflowStep) String ¶ 

func (this *WorkflowStep) String() string

func (*WorkflowStep) Unmarshal ¶ 

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

func (*WorkflowStep) XXX_DiscardUnknown ¶ 

func (m *WorkflowStep) XXX_DiscardUnknown()

func (*WorkflowStep) XXX_Marshal ¶ 

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

func (*WorkflowStep) XXX_Merge ¶ 

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

func (*WorkflowStep) XXX_Size ¶ 

func (m *WorkflowStep) XXX_Size() int

func (*WorkflowStep) XXX_Unmarshal ¶ 

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

type WorkflowTemplate ¶ 

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

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

func (*WorkflowTemplate) DeepCopy ¶ 

func (in *WorkflowTemplate) DeepCopy() *WorkflowTemplate

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

func (*WorkflowTemplate) DeepCopyInto ¶ 

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

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

func (*WorkflowTemplate) DeepCopyObject ¶ 

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

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

func (*WorkflowTemplate) Descriptor ¶ 

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

func (*WorkflowTemplate) GetTemplateByName ¶ 

func (wftmpl *WorkflowTemplate) GetTemplateByName(name string) *Template

GetTemplateByName retrieves a defined template by its name

func (*WorkflowTemplate) GetTemplateScope ¶ 

func (wftmpl *WorkflowTemplate) GetTemplateScope() string

GetTemplateScope returns the template scope of workflow template.

func (*WorkflowTemplate) Marshal ¶ 

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

func (*WorkflowTemplate) MarshalTo ¶ 

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

func (*WorkflowTemplate) MarshalToSizedBuffer ¶ 

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

func (*WorkflowTemplate) ProtoMessage ¶ 

func (*WorkflowTemplate) ProtoMessage()

func (*WorkflowTemplate) Reset ¶ 

func (m *WorkflowTemplate) Reset()

func (*WorkflowTemplate) Size ¶ 

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

func (*WorkflowTemplate) String ¶ 

func (this *WorkflowTemplate) String() string

func (*WorkflowTemplate) Unmarshal ¶ 

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

func (*WorkflowTemplate) XXX_DiscardUnknown ¶ 

func (m *WorkflowTemplate) XXX_DiscardUnknown()

func (*WorkflowTemplate) XXX_Marshal ¶ 

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

func (*WorkflowTemplate) XXX_Merge ¶ 

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

func (*WorkflowTemplate) XXX_Size ¶ 

func (m *WorkflowTemplate) XXX_Size() int

func (*WorkflowTemplate) XXX_Unmarshal ¶ 

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

type WorkflowTemplateList ¶ 

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

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

func (*WorkflowTemplateList) DeepCopy ¶ 

func (in *WorkflowTemplateList) DeepCopy() *WorkflowTemplateList

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

func (*WorkflowTemplateList) DeepCopyInto ¶ 

func (in *WorkflowTemplateList) DeepCopyInto(out *WorkflowTemplateList)

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

func (*WorkflowTemplateList) DeepCopyObject ¶ 

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

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

func (*WorkflowTemplateList) Descriptor ¶ 

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

func (*WorkflowTemplateList) Marshal ¶ 

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

func (*WorkflowTemplateList) MarshalTo ¶ 

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

func (*WorkflowTemplateList) MarshalToSizedBuffer ¶ 

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

func (*WorkflowTemplateList) ProtoMessage ¶ 

func (*WorkflowTemplateList) ProtoMessage()

func (*WorkflowTemplateList) Reset ¶ 

func (m *WorkflowTemplateList) Reset()

func (*WorkflowTemplateList) Size ¶ 

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

func (*WorkflowTemplateList) String ¶ 

func (this *WorkflowTemplateList) String() string

func (*WorkflowTemplateList) Unmarshal ¶ 

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

func (*WorkflowTemplateList) XXX_DiscardUnknown ¶ 

func (m *WorkflowTemplateList) XXX_DiscardUnknown()

func (*WorkflowTemplateList) XXX_Marshal ¶ 

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

func (*WorkflowTemplateList) XXX_Merge ¶ 

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

func (*WorkflowTemplateList) XXX_Size ¶ 

func (m *WorkflowTemplateList) XXX_Size() int

func (*WorkflowTemplateList) XXX_Unmarshal ¶ 

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

type WorkflowTemplateSpec ¶ 

type WorkflowTemplateSpec struct {
	// Templates is a list of workflow templates.
	Templates []Template `json:"templates" protobuf:"bytes,1,rep,name=templates"`
	// Arguments hold arguments to the template.
	Arguments Arguments `json:"arguments,omitempty" protobuf:"bytes,3,opt,name=arguments"`
}

WorkflowTemplateSpec is a spec of WorkflowTemplate.

func (*WorkflowTemplateSpec) DeepCopy ¶ 

func (in *WorkflowTemplateSpec) DeepCopy() *WorkflowTemplateSpec

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

func (*WorkflowTemplateSpec) DeepCopyInto ¶ 

func (in *WorkflowTemplateSpec) DeepCopyInto(out *WorkflowTemplateSpec)

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

func (*WorkflowTemplateSpec) Descriptor ¶ 

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

func (*WorkflowTemplateSpec) Marshal ¶ 

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

func (*WorkflowTemplateSpec) MarshalTo ¶ 

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

func (*WorkflowTemplateSpec) MarshalToSizedBuffer ¶ 

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

func (*WorkflowTemplateSpec) ProtoMessage ¶ 

func (*WorkflowTemplateSpec) ProtoMessage()

func (*WorkflowTemplateSpec) Reset ¶ 

func (m *WorkflowTemplateSpec) Reset()

func (*WorkflowTemplateSpec) Size ¶ 

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

func (*WorkflowTemplateSpec) String ¶ 

func (this *WorkflowTemplateSpec) String() string

func (*WorkflowTemplateSpec) Unmarshal ¶ 

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

func (*WorkflowTemplateSpec) XXX_DiscardUnknown ¶ 

func (m *WorkflowTemplateSpec) XXX_DiscardUnknown()

func (*WorkflowTemplateSpec) XXX_Marshal ¶ 

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

func (*WorkflowTemplateSpec) XXX_Merge ¶ 

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

func (*WorkflowTemplateSpec) XXX_Size ¶ 

func (m *WorkflowTemplateSpec) XXX_Size() int

func (*WorkflowTemplateSpec) XXX_Unmarshal ¶ 

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

type WorkflowTemplates ¶ 

type WorkflowTemplates []WorkflowTemplate

func (WorkflowTemplates) DeepCopy ¶ 

func (in WorkflowTemplates) DeepCopy() WorkflowTemplates

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

func (WorkflowTemplates) DeepCopyInto ¶ 

func (in WorkflowTemplates) DeepCopyInto(out *WorkflowTemplates)

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

func (WorkflowTemplates) Len ¶ 

func (w WorkflowTemplates) Len() int

func (WorkflowTemplates) Less ¶ 

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

func (WorkflowTemplates) Swap ¶ 

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

type Workflows ¶ 

type Workflows []Workflow

Workflows is a sort interface which sorts running jobs earlier before considering FinishedAt

func (Workflows) DeepCopy ¶ 

func (in Workflows) DeepCopy() Workflows

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

func (Workflows) DeepCopyInto ¶ 

func (in Workflows) DeepCopyInto(out *Workflows)

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

func (Workflows) Len ¶ 

func (w Workflows) Len() int

func (Workflows) Less ¶ 

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

func (Workflows) Swap ¶ 

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

Source Files ¶

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.