v1alpha1

package
Version: v3.0.0-rc1 Latest Latest
Warning

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

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

Documentation

Overview

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

Index

Constants

This section is empty.

Variables

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

SchemeGroupVersion is group version used to register these objects

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

Functions

func FailedPodNode 

func FailedPodNode(n NodeStatus) bool

func 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 NodeWithDisplayName 

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

func Resource 

func Resource(resource string) schema.GroupResource

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

func ResourceQuantityDenominator 

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

func SucceededPodNode 

func SucceededPodNode(n NodeStatus) bool

Types

type Amount 

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

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

func (*Amount) DeepCopy 

func (in *Amount) DeepCopy() *Amount

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

func (*Amount) DeepCopyInto 

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

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

func (*Amount) Descriptor 

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

func (*Amount) Float64 

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

func (*Amount) Marshal 

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

func (Amount) MarshalJSON 

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

func (*Amount) MarshalTo 

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

func (*Amount) MarshalToSizedBuffer 

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

func (Amount) OpenAPISchemaFormat 

func (a Amount) OpenAPISchemaFormat() string

func (Amount) OpenAPISchemaType 

func (a Amount) OpenAPISchemaType() []string

func (*Amount) ProtoMessage 

func (*Amount) ProtoMessage()

func (*Amount) Reset 

func (m *Amount) Reset()

func (*Amount) Size 

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

func (*Amount) String 

func (this *Amount) String() string

func (*Amount) Unmarshal 

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

func (*Amount) UnmarshalJSON 

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

func (*Amount) XXX_DiscardUnknown 

func (m *Amount) XXX_DiscardUnknown()

func (*Amount) XXX_Marshal 

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

func (*Amount) XXX_Merge 

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

func (*Amount) XXX_Size 

func (m *Amount) XXX_Size() int

func (*Amount) XXX_Unmarshal 

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

type AnyString 

type AnyString string

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

func AnyStringPtr 

func AnyStringPtr(val interface{}) *AnyString

func ParseAnyString 

func ParseAnyString(val interface{}) AnyString

func (AnyString) MarshalJSON 

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

func (AnyString) String 

func (i AnyString) String() string

func (*AnyString) UnmarshalJSON 

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

type ArchiveStrategy 

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

ArchiveStrategy describes how to archive files/directory when saving artifacts

func (*ArchiveStrategy) DeepCopy 

func (in *ArchiveStrategy) DeepCopy() *ArchiveStrategy

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

func (*ArchiveStrategy) DeepCopyInto 

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

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

func (*ArchiveStrategy) Descriptor 

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

func (*ArchiveStrategy) Marshal 

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

func (*ArchiveStrategy) MarshalTo 

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

func (*ArchiveStrategy) MarshalToSizedBuffer 

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

func (*ArchiveStrategy) ProtoMessage 

func (*ArchiveStrategy) ProtoMessage()

func (*ArchiveStrategy) Reset 

func (m *ArchiveStrategy) Reset()

func (*ArchiveStrategy) Size 

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

func (*ArchiveStrategy) String 

func (this *ArchiveStrategy) String() string

func (*ArchiveStrategy) Unmarshal 

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

func (*ArchiveStrategy) XXX_DiscardUnknown 

func (m *ArchiveStrategy) XXX_DiscardUnknown()

func (*ArchiveStrategy) XXX_Marshal 

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

func (*ArchiveStrategy) XXX_Merge 

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

func (*ArchiveStrategy) XXX_Size 

func (m *ArchiveStrategy) XXX_Size() int

func (*ArchiveStrategy) XXX_Unmarshal 

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

type Arguments 

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

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

Arguments to a template

func (*Arguments) DeepCopy 

func (in *Arguments) DeepCopy() *Arguments

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

func (*Arguments) DeepCopyInto 

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

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

func (*Arguments) Descriptor 

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

func (*Arguments) GetArtifactByName 

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

GetArtifactByName retrieves an artifact by its name

func (*Arguments) GetParameterByName 

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

GetParameterByName retrieves a parameter by its name

func (Arguments) IsEmpty 

func (a Arguments) IsEmpty() bool

func (*Arguments) Marshal 

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

func (*Arguments) MarshalTo 

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

func (*Arguments) MarshalToSizedBuffer 

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

func (*Arguments) ProtoMessage 

func (*Arguments) ProtoMessage()

func (*Arguments) Reset 

func (m *Arguments) Reset()

func (*Arguments) Size 

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

func (*Arguments) String 

func (this *Arguments) String() string

func (*Arguments) Unmarshal 

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

func (*Arguments) XXX_DiscardUnknown 

func (m *Arguments) XXX_DiscardUnknown()

func (*Arguments) XXX_Marshal 

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

func (*Arguments) XXX_Merge 

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

func (*Arguments) XXX_Size 

func (m *Arguments) XXX_Size() int

func (*Arguments) XXX_Unmarshal 

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

type ArgumentsProvider 

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

type Artifact 

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

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

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

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

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

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

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

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

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

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

Artifact indicates an artifact to place at a specified path

func (*Artifact) DeepCopy 

func (in *Artifact) DeepCopy() *Artifact

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

func (*Artifact) DeepCopyInto 

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

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

func (*Artifact) Descriptor 

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

func (*Artifact) GetArchive 

func (a *Artifact) GetArchive() *ArchiveStrategy

func (*Artifact) Marshal 

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

func (*Artifact) MarshalTo 

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

func (*Artifact) MarshalToSizedBuffer 

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

func (*Artifact) ProtoMessage 

func (*Artifact) ProtoMessage()

func (*Artifact) Reset 

func (m *Artifact) Reset()

func (*Artifact) Size 

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

func (*Artifact) String 

func (this *Artifact) String() string

func (*Artifact) Unmarshal 

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

func (*Artifact) XXX_DiscardUnknown 

func (m *Artifact) XXX_DiscardUnknown()

func (*Artifact) XXX_Marshal 

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

func (*Artifact) XXX_Merge 

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

func (*Artifact) XXX_Size 

func (m *Artifact) XXX_Size() int

func (*Artifact) XXX_Unmarshal 

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

type ArtifactLocation 

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

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

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

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

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

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

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

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

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

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

func (*ArtifactLocation) AppendToKey 

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

func (*ArtifactLocation) DeepCopy 

func (in *ArtifactLocation) DeepCopy() *ArtifactLocation

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

func (*ArtifactLocation) DeepCopyInto 

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

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

func (*ArtifactLocation) Descriptor 

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

func (*ArtifactLocation) Get 

func (a *ArtifactLocation) Get() ArtifactLocationType

func (*ArtifactLocation) GetKey 

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

func (*ArtifactLocation) HasKey 

func (a *ArtifactLocation) HasKey() bool

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

func (*ArtifactLocation) HasLocation 

func (a *ArtifactLocation) HasLocation() bool

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

func (*ArtifactLocation) HasLocationOrKey 

func (a *ArtifactLocation) HasLocationOrKey() bool

func (*ArtifactLocation) IsArchiveLogs 

func (a *ArtifactLocation) IsArchiveLogs() bool

func (*ArtifactLocation) Marshal 

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

func (*ArtifactLocation) MarshalTo 

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

func (*ArtifactLocation) MarshalToSizedBuffer 

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

func (*ArtifactLocation) ProtoMessage 

func (*ArtifactLocation) ProtoMessage()

func (*ArtifactLocation) Relocate 

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

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

func (*ArtifactLocation) Reset 

func (m *ArtifactLocation) Reset()

func (*ArtifactLocation) SetKey 

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

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

func (*ArtifactLocation) SetType 

func (a *ArtifactLocation) SetType(x ArtifactLocationType) error

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

func (*ArtifactLocation) Size 

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

func (*ArtifactLocation) String 

func (this *ArtifactLocation) String() string

func (*ArtifactLocation) Unmarshal 

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

func (*ArtifactLocation) XXX_DiscardUnknown 

func (m *ArtifactLocation) XXX_DiscardUnknown()

func (*ArtifactLocation) XXX_Marshal 

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

func (*ArtifactLocation) XXX_Merge 

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

func (*ArtifactLocation) XXX_Size 

func (m *ArtifactLocation) XXX_Size() int

func (*ArtifactLocation) XXX_Unmarshal 

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

type ArtifactLocationType 

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

type ArtifactRepositoryRef 

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

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

func (*ArtifactRepositoryRef) DeepCopy 

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

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

func (*ArtifactRepositoryRef) GetKeyOr 

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

func (*ArtifactRepositoryRef) Marshal 

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

func (*ArtifactRepositoryRef) MarshalTo 

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

func (*ArtifactRepositoryRef) MarshalToSizedBuffer 

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

func (*ArtifactRepositoryRef) ProtoMessage 

func (*ArtifactRepositoryRef) ProtoMessage()

func (*ArtifactRepositoryRef) Reset 

func (m *ArtifactRepositoryRef) Reset()

func (*ArtifactRepositoryRef) Size 

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

func (*ArtifactRepositoryRef) String 

func (r *ArtifactRepositoryRef) String() string

func (*ArtifactRepositoryRef) Unmarshal 

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

func (*ArtifactRepositoryRef) XXX_DiscardUnknown 

func (m *ArtifactRepositoryRef) XXX_DiscardUnknown()

func (*ArtifactRepositoryRef) XXX_Marshal 

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

func (*ArtifactRepositoryRef) XXX_Merge 

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

func (*ArtifactRepositoryRef) XXX_Size 

func (m *ArtifactRepositoryRef) XXX_Size() int

func (*ArtifactRepositoryRef) XXX_Unmarshal 

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

type ArtifactRepositoryRefStatus 

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

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

func (*ArtifactRepositoryRefStatus) DeepCopy 

func (in *ArtifactRepositoryRefStatus) DeepCopy() *ArtifactRepositoryRefStatus

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

func (*ArtifactRepositoryRefStatus) DeepCopyInto 

func (in *ArtifactRepositoryRefStatus) DeepCopyInto(out *ArtifactRepositoryRefStatus)

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

func (*ArtifactRepositoryRefStatus) Descriptor 

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

func (*ArtifactRepositoryRefStatus) Marshal 

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

func (*ArtifactRepositoryRefStatus) MarshalTo 

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

func (*ArtifactRepositoryRefStatus) MarshalToSizedBuffer 

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

func (*ArtifactRepositoryRefStatus) ProtoMessage 

func (*ArtifactRepositoryRefStatus) ProtoMessage()

func (*ArtifactRepositoryRefStatus) Reset 

func (m *ArtifactRepositoryRefStatus) Reset()

func (*ArtifactRepositoryRefStatus) Size 

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

func (*ArtifactRepositoryRefStatus) String 

func (r *ArtifactRepositoryRefStatus) String() string

func (*ArtifactRepositoryRefStatus) Unmarshal 

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

func (*ArtifactRepositoryRefStatus) XXX_DiscardUnknown 

func (m *ArtifactRepositoryRefStatus) XXX_DiscardUnknown()

func (*ArtifactRepositoryRefStatus) XXX_Marshal 

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

func (*ArtifactRepositoryRefStatus) XXX_Merge 

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

func (*ArtifactRepositoryRefStatus) XXX_Size 

func (m *ArtifactRepositoryRefStatus) XXX_Size() int

func (*ArtifactRepositoryRefStatus) XXX_Unmarshal 

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

type ArtifactoryArtifact 

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

ArtifactoryArtifact is the location of an artifactory artifact

func (*ArtifactoryArtifact) DeepCopy 

func (in *ArtifactoryArtifact) DeepCopy() *ArtifactoryArtifact

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

func (*ArtifactoryArtifact) DeepCopyInto 

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

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

func (*ArtifactoryArtifact) Descriptor 

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

func (*ArtifactoryArtifact) GetKey 

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

func (*ArtifactoryArtifact) HasLocation 

func (a *ArtifactoryArtifact) HasLocation() bool

func (*ArtifactoryArtifact) Marshal 

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

func (*ArtifactoryArtifact) MarshalTo 

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

func (*ArtifactoryArtifact) MarshalToSizedBuffer 

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

func (*ArtifactoryArtifact) ProtoMessage 

func (*ArtifactoryArtifact) ProtoMessage()

func (*ArtifactoryArtifact) Reset 

func (m *ArtifactoryArtifact) Reset()

func (*ArtifactoryArtifact) SetKey 

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

func (*ArtifactoryArtifact) Size 

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

func (*ArtifactoryArtifact) String 

func (this *ArtifactoryArtifact) String() string

func (*ArtifactoryArtifact) Unmarshal 

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

func (*ArtifactoryArtifact) XXX_DiscardUnknown 

func (m *ArtifactoryArtifact) XXX_DiscardUnknown()

func (*ArtifactoryArtifact) XXX_Marshal 

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

func (*ArtifactoryArtifact) XXX_Merge 

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

func (*ArtifactoryArtifact) XXX_Size 

func (m *ArtifactoryArtifact) XXX_Size() int

func (*ArtifactoryArtifact) XXX_Unmarshal 

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

type ArtifactoryAuth 

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

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

ArtifactoryAuth describes the secret selectors required for authenticating to artifactory

func (*ArtifactoryAuth) DeepCopy 

func (in *ArtifactoryAuth) DeepCopy() *ArtifactoryAuth

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

func (*ArtifactoryAuth) DeepCopyInto 

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

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

func (*ArtifactoryAuth) Descriptor 

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

func (*ArtifactoryAuth) Marshal 

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

func (*ArtifactoryAuth) MarshalTo 

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

func (*ArtifactoryAuth) MarshalToSizedBuffer 

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

func (*ArtifactoryAuth) ProtoMessage 

func (*ArtifactoryAuth) ProtoMessage()

func (*ArtifactoryAuth) Reset 

func (m *ArtifactoryAuth) Reset()

func (*ArtifactoryAuth) Size 

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

func (*ArtifactoryAuth) String 

func (this *ArtifactoryAuth) String() string

func (*ArtifactoryAuth) Unmarshal 

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

func (*ArtifactoryAuth) XXX_DiscardUnknown 

func (m *ArtifactoryAuth) XXX_DiscardUnknown()

func (*ArtifactoryAuth) XXX_Marshal 

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

func (*ArtifactoryAuth) XXX_Merge 

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

func (*ArtifactoryAuth) XXX_Size 

func (m *ArtifactoryAuth) XXX_Size() int

func (*ArtifactoryAuth) XXX_Unmarshal 

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

type Artifacts 

type Artifacts []Artifact

func (Artifacts) DeepCopy 

func (in Artifacts) DeepCopy() Artifacts

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

func (Artifacts) DeepCopyInto 

func (in Artifacts) DeepCopyInto(out *Artifacts)

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

func (Artifacts) GetArtifactByName 

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

type Backoff 

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

Backoff is a backoff strategy to use within retryStrategy

func (*Backoff) DeepCopy 

func (in *Backoff) DeepCopy() *Backoff

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

func (*Backoff) DeepCopyInto 

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

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

func (*Backoff) Descriptor 

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

func (*Backoff) Marshal 

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

func (*Backoff) MarshalTo 

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

func (*Backoff) MarshalToSizedBuffer 

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

func (*Backoff) ProtoMessage 

func (*Backoff) ProtoMessage()

func (*Backoff) Reset 

func (m *Backoff) Reset()

func (*Backoff) Size 

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

func (*Backoff) String 

func (this *Backoff) String() string

func (*Backoff) Unmarshal 

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

func (*Backoff) XXX_DiscardUnknown 

func (m *Backoff) XXX_DiscardUnknown()

func (*Backoff) XXX_Marshal 

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

func (*Backoff) XXX_Merge 

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

func (*Backoff) XXX_Size 

func (m *Backoff) XXX_Size() int

func (*Backoff) XXX_Unmarshal 

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

type Cache 

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

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

func (*Cache) DeepCopy 

func (in *Cache) DeepCopy() *Cache

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

func (*Cache) DeepCopyInto 

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

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

func (*Cache) Descriptor 

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

func (*Cache) Marshal 

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

func (*Cache) MarshalTo 

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

func (*Cache) MarshalToSizedBuffer 

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

func (*Cache) ProtoMessage 

func (*Cache) ProtoMessage()

func (*Cache) Reset 

func (m *Cache) Reset()

func (*Cache) Size 

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

func (*Cache) String 

func (this *Cache) String() string

func (*Cache) Unmarshal 

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

func (*Cache) XXX_DiscardUnknown 

func (m *Cache) XXX_DiscardUnknown()

func (*Cache) XXX_Marshal 

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

func (*Cache) XXX_Merge 

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

func (*Cache) XXX_Size 

func (m *Cache) XXX_Size() int

func (*Cache) XXX_Unmarshal 

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

type ClusterWorkflowTemplate 

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

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

func (*ClusterWorkflowTemplate) DeepCopy 

func (in *ClusterWorkflowTemplate) DeepCopy() *ClusterWorkflowTemplate

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

func (*ClusterWorkflowTemplate) DeepCopyInto 

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

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

func (*ClusterWorkflowTemplate) DeepCopyObject 

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

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

func (*ClusterWorkflowTemplate) Descriptor 

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

func (*ClusterWorkflowTemplate) GetResourceScope 

func (cwftmpl *ClusterWorkflowTemplate) GetResourceScope() ResourceScope

GetResourceScope returns the template scope of workflow template.

func (*ClusterWorkflowTemplate) GetTemplateByName 

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

GetTemplateByName retrieves a defined template by its name

func (*ClusterWorkflowTemplate) GetWorkflowMetadata 

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

func (*ClusterWorkflowTemplate) GetWorkflowSpec 

func (cwftmpl *ClusterWorkflowTemplate) GetWorkflowSpec() *WorkflowSpec

GetWorkflowSpec returns the WorkflowSpec of cluster workflow template.

func (*ClusterWorkflowTemplate) Marshal 

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

func (*ClusterWorkflowTemplate) MarshalTo 

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

func (*ClusterWorkflowTemplate) MarshalToSizedBuffer 

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

func (*ClusterWorkflowTemplate) ProtoMessage 

func (*ClusterWorkflowTemplate) ProtoMessage()

func (*ClusterWorkflowTemplate) Reset 

func (m *ClusterWorkflowTemplate) Reset()

func (*ClusterWorkflowTemplate) Size 

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

func (*ClusterWorkflowTemplate) String 

func (this *ClusterWorkflowTemplate) String() string

func (*ClusterWorkflowTemplate) Unmarshal 

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

func (*ClusterWorkflowTemplate) XXX_DiscardUnknown 

func (m *ClusterWorkflowTemplate) XXX_DiscardUnknown()

func (*ClusterWorkflowTemplate) XXX_Marshal 

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

func (*ClusterWorkflowTemplate) XXX_Merge 

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

func (*ClusterWorkflowTemplate) XXX_Size 

func (m *ClusterWorkflowTemplate) XXX_Size() int

func (*ClusterWorkflowTemplate) XXX_Unmarshal 

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

type ClusterWorkflowTemplateList 

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

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

func (*ClusterWorkflowTemplateList) DeepCopy 

func (in *ClusterWorkflowTemplateList) DeepCopy() *ClusterWorkflowTemplateList

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

func (*ClusterWorkflowTemplateList) DeepCopyInto 

func (in *ClusterWorkflowTemplateList) DeepCopyInto(out *ClusterWorkflowTemplateList)

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

func (*ClusterWorkflowTemplateList) DeepCopyObject 

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

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

func (*ClusterWorkflowTemplateList) Descriptor 

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

func (*ClusterWorkflowTemplateList) Marshal 

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

func (*ClusterWorkflowTemplateList) MarshalTo 

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

func (*ClusterWorkflowTemplateList) MarshalToSizedBuffer 

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

func (*ClusterWorkflowTemplateList) ProtoMessage 

func (*ClusterWorkflowTemplateList) ProtoMessage()

func (*ClusterWorkflowTemplateList) Reset 

func (m *ClusterWorkflowTemplateList) Reset()

func (*ClusterWorkflowTemplateList) Size 

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

func (*ClusterWorkflowTemplateList) String 

func (this *ClusterWorkflowTemplateList) String() string

func (*ClusterWorkflowTemplateList) Unmarshal 

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

func (*ClusterWorkflowTemplateList) XXX_DiscardUnknown 

func (m *ClusterWorkflowTemplateList) XXX_DiscardUnknown()

func (*ClusterWorkflowTemplateList) XXX_Marshal 

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

func (*ClusterWorkflowTemplateList) XXX_Merge 

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

func (*ClusterWorkflowTemplateList) XXX_Size 

func (m *ClusterWorkflowTemplateList) XXX_Size() int

func (*ClusterWorkflowTemplateList) XXX_Unmarshal 

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

type ClusterWorkflowTemplates 

type ClusterWorkflowTemplates []ClusterWorkflowTemplate

func (ClusterWorkflowTemplates) DeepCopy 

func (in ClusterWorkflowTemplates) DeepCopy() ClusterWorkflowTemplates

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

func (ClusterWorkflowTemplates) DeepCopyInto 

func (in ClusterWorkflowTemplates) DeepCopyInto(out *ClusterWorkflowTemplates)

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

func (ClusterWorkflowTemplates) Len 

func (w ClusterWorkflowTemplates) Len() int

func (ClusterWorkflowTemplates) Less 

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

func (ClusterWorkflowTemplates) Swap 

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

type ConcurrencyPolicy 

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

type Condition 

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

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

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

func (*Condition) DeepCopy 

func (in *Condition) DeepCopy() *Condition

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

func (*Condition) DeepCopyInto 

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

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

func (*Condition) Descriptor 

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

func (*Condition) Marshal 

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

func (*Condition) MarshalTo 

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

func (*Condition) MarshalToSizedBuffer 

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

func (*Condition) ProtoMessage 

func (*Condition) ProtoMessage()

func (*Condition) Reset 

func (m *Condition) Reset()

func (*Condition) Size 

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

func (*Condition) String 

func (this *Condition) String() string

func (*Condition) Unmarshal 

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

func (*Condition) XXX_DiscardUnknown 

func (m *Condition) XXX_DiscardUnknown()

func (*Condition) XXX_Marshal 

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

func (*Condition) XXX_Merge 

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

func (*Condition) XXX_Size 

func (m *Condition) XXX_Size() int

func (*Condition) XXX_Unmarshal 

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

type ConditionType 

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

type Conditions 

type Conditions []Condition

func (Conditions) DeepCopy 

func (in Conditions) DeepCopy() Conditions

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

func (Conditions) DeepCopyInto 

func (in Conditions) DeepCopyInto(out *Conditions)

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

func (*Conditions) DisplayString 

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

func (*Conditions) JoinConditions 

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

func (*Conditions) RemoveCondition 

func (cs *Conditions) RemoveCondition(conditionType ConditionType)

func (*Conditions) UpsertCondition 

func (cs *Conditions) UpsertCondition(condition Condition)

func (*Conditions) UpsertConditionMessage 

func (cs *Conditions) UpsertConditionMessage(condition Condition)

type ContinueOn 

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

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

func (*ContinueOn) DeepCopy 

func (in *ContinueOn) DeepCopy() *ContinueOn

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

func (*ContinueOn) DeepCopyInto 

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

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

func (*ContinueOn) Descriptor 

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

func (*ContinueOn) Marshal 

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

func (*ContinueOn) MarshalTo 

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

func (*ContinueOn) MarshalToSizedBuffer 

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

func (*ContinueOn) ProtoMessage 

func (*ContinueOn) ProtoMessage()

func (*ContinueOn) Reset 

func (m *ContinueOn) Reset()

func (*ContinueOn) Size 

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

func (*ContinueOn) String 

func (this *ContinueOn) String() string

func (*ContinueOn) Unmarshal 

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

func (*ContinueOn) XXX_DiscardUnknown 

func (m *ContinueOn) XXX_DiscardUnknown()

func (*ContinueOn) XXX_Marshal 

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

func (*ContinueOn) XXX_Merge 

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

func (*ContinueOn) XXX_Size 

func (m *ContinueOn) XXX_Size() int

func (*ContinueOn) XXX_Unmarshal 

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

type Counter 

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

Counter is a Counter prometheus metric

func (*Counter) DeepCopy 

func (in *Counter) DeepCopy() *Counter

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

func (*Counter) DeepCopyInto 

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

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

func (*Counter) Descriptor 

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

func (*Counter) Marshal 

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

func (*Counter) MarshalTo 

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

func (*Counter) MarshalToSizedBuffer 

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

func (*Counter) ProtoMessage 

func (*Counter) ProtoMessage()

func (*Counter) Reset 

func (m *Counter) Reset()

func (*Counter) Size 

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

func (*Counter) String 

func (this *Counter) String() string

func (*Counter) Unmarshal 

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

func (*Counter) XXX_DiscardUnknown 

func (m *Counter) XXX_DiscardUnknown()

func (*Counter) XXX_Marshal 

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

func (*Counter) XXX_Merge 

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

func (*Counter) XXX_Size 

func (m *Counter) XXX_Size() int

func (*Counter) XXX_Unmarshal 

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

type CreateS3BucketOptions 

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

CreateS3BucketOptions options used to determine automatic automatic bucket-creation process

func (*CreateS3BucketOptions) DeepCopy 

func (in *CreateS3BucketOptions) DeepCopy() *CreateS3BucketOptions

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

func (*CreateS3BucketOptions) DeepCopyInto 

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

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

func (*CreateS3BucketOptions) Descriptor 

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

func (*CreateS3BucketOptions) Marshal 

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

func (*CreateS3BucketOptions) MarshalTo 

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

func (*CreateS3BucketOptions) MarshalToSizedBuffer 

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

func (*CreateS3BucketOptions) ProtoMessage 

func (*CreateS3BucketOptions) ProtoMessage()

func (*CreateS3BucketOptions) Reset 

func (m *CreateS3BucketOptions) Reset()

func (*CreateS3BucketOptions) Size 

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

func (*CreateS3BucketOptions) String 

func (this *CreateS3BucketOptions) String() string

func (*CreateS3BucketOptions) Unmarshal 

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

func (*CreateS3BucketOptions) XXX_DiscardUnknown 

func (m *CreateS3BucketOptions) XXX_DiscardUnknown()

func (*CreateS3BucketOptions) XXX_Marshal 

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

func (*CreateS3BucketOptions) XXX_Merge 

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

func (*CreateS3BucketOptions) XXX_Size 

func (m *CreateS3BucketOptions) XXX_Size() int

func (*CreateS3BucketOptions) XXX_Unmarshal 

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

type CronWorkflow 

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

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

func (*CronWorkflow) DeepCopy 

func (in *CronWorkflow) DeepCopy() *CronWorkflow

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

func (*CronWorkflow) DeepCopyInto 

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

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

func (*CronWorkflow) DeepCopyObject 

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

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

func (*CronWorkflow) Descriptor 

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

func (*CronWorkflow) Marshal 

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

func (*CronWorkflow) MarshalTo 

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

func (*CronWorkflow) MarshalToSizedBuffer 

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

func (*CronWorkflow) ProtoMessage 

func (*CronWorkflow) ProtoMessage()

func (*CronWorkflow) Reset 

func (m *CronWorkflow) Reset()

func (*CronWorkflow) Size 

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

func (*CronWorkflow) String 

func (this *CronWorkflow) String() string

func (*CronWorkflow) Unmarshal 

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

func (*CronWorkflow) XXX_DiscardUnknown 

func (m *CronWorkflow) XXX_DiscardUnknown()

func (*CronWorkflow) XXX_Marshal 

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

func (*CronWorkflow) XXX_Merge 

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

func (*CronWorkflow) XXX_Size 

func (m *CronWorkflow) XXX_Size() int

func (*CronWorkflow) XXX_Unmarshal 

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

type CronWorkflowList 

type CronWorkflowList struct {