Documentation ¶
Overview ¶
+groupName=cyclone.caicloud.io
Index ¶
- Constants
- Variables
- func EnsureCRDCreated(masterUrl, kubeConfigPath string)
- func GroupResource(resource string) schema.GroupResource
- func RegisterDefaults(scheme *runtime.Scheme) error
- type Argument
- type ArgumentValue
- type ArtifactItem
- type CRDSpec
- type CRDWorkload
- type Inputs
- type KeyValue
- type Outputs
- type ParameterConfig
- type ParameterItem
- type Persistent
- type PodInfo
- type PodWorkload
- type Resource
- type ResourceItem
- type ResourceList
- type ResourcePullPolicy
- type ResourceSpec
- type ResourceType
- type Stage
- type StageItem
- type StageList
- type StageSpec
- type StageStatus
- type StageTemplate
- type StageTemplateList
- type StageTemplateSpec
- type Status
- type StatusRef
- type TemplateRef
- type TriggerType
- type Workflow
- type WorkflowList
- type WorkflowParam
- type WorkflowParamList
- type WorkflowParamSpec
- type WorkflowRun
- type WorkflowRunList
- type WorkflowRunSpec
- type WorkflowRunStatus
- type WorkflowSpec
- type WorkflowTrigger
- type WorkflowTriggerList
- type WorkflowTriggerSpec
- type WorkflowTriggerStatus
Constants ¶
const ( ImageResourceType = "Image" GitResourceType = "Git" KVResourceType = "KV" PVResourceType = "PV" GeneralResourceType = "General" )
const ( // Always pull resource. Old data would be removed if exist. PullAlways = "Always" // If old data exists, take advantage of it when pull resource, // incremental pull is performed. PullIfNotExist = "IfNotExist" )
const ( // When used for stage, it means stage is not executed yet. When used // for WorkflowRun overall status, it means no stages in WorkflowRun are // started to execute. StatusPending = "Pending" // Stage or WorkflowRun is in running. StatusRunning = "Running" // Stage or WorkflowRun have finished, but need to wait for external events // to continue. For example, a stage's executing result needs approval of // users, so that following stages can preceeding. StatusWaiting = "Waiting" // Stage or WorkflowRun gotten completed without errors. StatusCompleted = "Completed" // Something wrong in the execution of Stage or WorkflowRun. StatusError = "Error" // WorkflowRun have been cancelled. StatusCancelled = "Cancelled" )
const ( ScheduledTrigger = "Schedule" WebhookTrigger = "Webhook" )
const APIVersion = GroupName + "/" + Version
const GroupName = "cyclone.io"
GroupName is the group name use in this package
const Version = "v1alpha1"
Variables ¶
var ( SchemeBuilder = runtime.NewSchemeBuilder(addKnownTypes) AddToScheme = SchemeBuilder.AddToScheme )
var SchemeGroupVersion = schema.GroupVersion{Group: GroupName, Version: "v1alpha1"}
SchemeGroupVersion is group version used to register these objects
Functions ¶
func EnsureCRDCreated ¶
func EnsureCRDCreated(masterUrl, kubeConfigPath string)
EnsureCRDCreated will create built-in CRDs if they are not exist.
func GroupResource ¶
func GroupResource(resource string) schema.GroupResource
func RegisterDefaults ¶
RegisterDefaults adds defaulters functions to the given scheme. Public to allow building arbitrary schemes. All generated defaulters are covering - they call all nested defaulters.
Types ¶
type Argument ¶
Argument defines a argument.
func (*Argument) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Argument.
func (*Argument) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ArgumentValue ¶
type ArgumentValue ParameterItem
ArgumentValue defines a argument value
func (*ArgumentValue) DeepCopy ¶
func (in *ArgumentValue) DeepCopy() *ArgumentValue
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ArgumentValue.
func (*ArgumentValue) DeepCopyInto ¶
func (in *ArgumentValue) DeepCopyInto(out *ArgumentValue)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ArtifactItem ¶
type ArtifactItem struct { // Artifact name Name string `json:"name"` // Path of the artifact Path string `json:"path"` // Source of the artifact. When artifact is used as input, this is needed. // It's in the format of: <stage name>/<artifact name> // +Optional Source string `json:"source"` }
ArtifactItem defines an artifact
func (*ArtifactItem) DeepCopy ¶
func (in *ArtifactItem) DeepCopy() *ArtifactItem
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ArtifactItem.
func (*ArtifactItem) DeepCopyInto ¶
func (in *ArtifactItem) DeepCopyInto(out *ArtifactItem)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type CRDSpec ¶
type CRDSpec struct { // Specification of the CRD Manifest string `json:"manifest"` // How to judge CRD workload is completed StatusRef StatusRef `json:"statusRef"` }
CRDSpec defines CRD workload specification.
func (*CRDSpec) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CRDSpec.
func (*CRDSpec) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type CRDWorkload ¶
type CRDWorkload struct { // Stage workload specification Spec CRDSpec `json:"spec"` }
CRDWorkload describes crd type workload.
func (*CRDWorkload) DeepCopy ¶
func (in *CRDWorkload) DeepCopy() *CRDWorkload
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CRDWorkload.
func (*CRDWorkload) DeepCopyInto ¶
func (in *CRDWorkload) DeepCopyInto(out *CRDWorkload)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type Inputs ¶
type Inputs struct { // Resources used as input Resources []ResourceItem `json:"resources,omitempty"` // Parameters used as input Arguments []ArgumentValue `json:"arguments,omitempty"` // Artifacts to output Artifacts []ArtifactItem `json:"artifacts,omitempty"` }
Inputs defines stage inputs.
func (*Inputs) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Inputs.
func (*Inputs) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type KeyValue ¶
KeyValue defines a key-value pair
func (*KeyValue) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new KeyValue.
func (*KeyValue) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type Outputs ¶
type Outputs struct { // Resources used as output Resources []ResourceItem `json:"resources,omitempty"` // Artifacts to output Artifacts []ArtifactItem `json:"artifacts,omitempty"` }
Outputs defines stage output.
func (*Outputs) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Outputs.
func (*Outputs) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ParameterConfig ¶
type ParameterConfig struct { // Whose parameters to configure Name string `json:"name"` // Parameters Parameters []ParameterItem `json:"parameters"` }
ParameterConfig configures parameters of a resource or a stage.
func (*ParameterConfig) DeepCopy ¶
func (in *ParameterConfig) DeepCopy() *ParameterConfig
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ParameterConfig.
func (*ParameterConfig) DeepCopyInto ¶
func (in *ParameterConfig) DeepCopyInto(out *ParameterConfig)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ParameterItem ¶
type ParameterItem struct { // Name of the parameter Name string `json:"name"` // Value of the parameter Value string `json:"value"` }
ParameterItem defines a parameter
func (*ParameterItem) DeepCopy ¶
func (in *ParameterItem) DeepCopy() *ParameterItem
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ParameterItem.
func (*ParameterItem) DeepCopyInto ¶
func (in *ParameterItem) DeepCopyInto(out *ParameterItem)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type Persistent ¶
type Persistent struct { // Name of the PVC to hold the resource PVC string `json:"pvc"` // Path of resource in the PVC Path string `json:"path"` // Whether to pull resource when there already be data PullPolicy ResourcePullPolicy `json:"pullPolicy"` }
Persistent describes persistent parameters for the resource.
func (*Persistent) DeepCopy ¶
func (in *Persistent) DeepCopy() *Persistent
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Persistent.
func (*Persistent) DeepCopyInto ¶
func (in *Persistent) DeepCopyInto(out *Persistent)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type PodInfo ¶
PodInfo describes the pod a stage created.
func (*PodInfo) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PodInfo.
func (*PodInfo) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type PodWorkload ¶
type PodWorkload struct { // Stage inputs Inputs Inputs `json:"inputs,omitempty"` // Stage outputs Outputs Outputs `json:"outputs,omitempty"` // Stage workload specification Spec corev1.PodSpec `json:"spec"` }
PodWorkload describes pod type workload, a complete pod spec is included.
func (*PodWorkload) DeepCopy ¶
func (in *PodWorkload) DeepCopy() *PodWorkload
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PodWorkload.
func (*PodWorkload) DeepCopyInto ¶
func (in *PodWorkload) DeepCopyInto(out *PodWorkload)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type Resource ¶
type Resource struct { // Metadata for the resource, like kind and apiversion metav1.TypeMeta `json:",inline"` // Metadata for the particular object, including name, namespace, labels, etc metav1.ObjectMeta `json:"metadata,omitempty"` // Resource specification Spec ResourceSpec `json:"spec"` }
Resource represents a resource used in workflow
func (*Resource) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Resource.
func (*Resource) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*Resource) DeepCopyObject ¶
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type ResourceItem ¶
type ResourceItem struct { // Resource name Name string `json:"name"` // For input resource, this is the path that resource will be mounted in workload container. // Resolver would resolve resources and mount it in this path. // For output resource, this is the path in the workload container specify output data, for // the moment, only one path can be given. In the resolver container, data specified here would // be mounted in /workspace/data by default. Resolver will then push resource to remote server. // TODO(ChenDe): For output resource, need support multiple paths. Path string `json:"path"` }
ResourceItem defines a resource
func (*ResourceItem) DeepCopy ¶
func (in *ResourceItem) DeepCopy() *ResourceItem
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ResourceItem.
func (*ResourceItem) DeepCopyInto ¶
func (in *ResourceItem) DeepCopyInto(out *ResourceItem)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ResourceList ¶
type ResourceList struct { metav1.TypeMeta `json:",inline"` metav1.ListMeta `json:"metadata"` Items []Resource `json:"items""` }
ResourceList describes an array of Resource instances.
func (*ResourceList) DeepCopy ¶
func (in *ResourceList) DeepCopy() *ResourceList
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ResourceList.
func (*ResourceList) DeepCopyInto ¶
func (in *ResourceList) DeepCopyInto(out *ResourceList)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*ResourceList) DeepCopyObject ¶
func (in *ResourceList) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type ResourceSpec ¶
type ResourceSpec struct { // Image to resolve this kind of resource. Resolver string `json:"resolver,omitempty"` // Resource type, e.g. image, git, kv, general. Type ResourceType `json:"type"` // Persistent resource to PVC. Persistent *Persistent `json:"persistent"` // Parameters of the resource Parameters []ParameterItem `json:"parameters"` }
ResourceSpec describes a resource
func (*ResourceSpec) DeepCopy ¶
func (in *ResourceSpec) DeepCopy() *ResourceSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ResourceSpec.
func (*ResourceSpec) DeepCopyInto ¶
func (in *ResourceSpec) DeepCopyInto(out *ResourceSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type Stage ¶
type Stage struct { // Metadata for the resource, like kind and apiversion metav1.TypeMeta `json:",inline"` // Metadata for the particular object, including name, namespace, labels, etc metav1.ObjectMeta `json:"metadata,omitempty"` // Stage specification Spec StageSpec `json:"spec,omitempty"` }
Stage defines a workflow stage. Only one of Spec and Template should be specified.
func (*Stage) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Stage.
func (*Stage) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*Stage) DeepCopyObject ¶
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type StageItem ¶
type StageItem struct { // Name of stage Name string `json:"name"` // Input artifacts that this stage needed, we bind the artifacts source here. Artifacts []ArtifactItem `json:"artifacts"` // Stages that this stage depends on Depends []string `json:"depends"` }
StageItem describes a stage in a workflow.
func (*StageItem) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new StageItem.
func (*StageItem) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type StageList ¶
type StageList struct { metav1.TypeMeta `json:",inline"` metav1.ListMeta `json:"metadata"` Items []Stage `json:"items""` }
StageList describes an array of Stage instances.
func (*StageList) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new StageList.
func (*StageList) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*StageList) DeepCopyObject ¶
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type StageSpec ¶
type StageSpec struct { // Use stage template Template *TemplateRef `json:"template,omitempty"` // Pod kind workload Pod *PodWorkload `json:"pod,omitempty"` }
StageSpec defines stage specification. Exact one workload should be specified.
func (*StageSpec) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new StageSpec.
func (*StageSpec) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type StageStatus ¶
type StageStatus struct { // Information of the pod Pod *PodInfo `json:"pod"` // Conditions of a stage Status Status `json:"status"` // Key-value outputs of this stage Outputs []KeyValue `json:"outputs"` }
StageStatus describes status of a stage execution.
func (*StageStatus) DeepCopy ¶
func (in *StageStatus) DeepCopy() *StageStatus
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new StageStatus.
func (*StageStatus) DeepCopyInto ¶
func (in *StageStatus) DeepCopyInto(out *StageStatus)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type StageTemplate ¶
type StageTemplate struct { // Metadata for the resource, like kind and apiversion metav1.TypeMeta `json:",inline"` // Metadata for the particular object, including name, namespace, labels, etc metav1.ObjectMeta `json:"metadata,omitempty"` // Stage template specification Spec StageTemplateSpec `json:"spec"` }
StageTemplate defines a template of Stage.
func (*StageTemplate) DeepCopy ¶
func (in *StageTemplate) DeepCopy() *StageTemplate
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new StageTemplate.
func (*StageTemplate) DeepCopyInto ¶
func (in *StageTemplate) DeepCopyInto(out *StageTemplate)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*StageTemplate) DeepCopyObject ¶
func (in *StageTemplate) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type StageTemplateList ¶
type StageTemplateList struct { metav1.TypeMeta `json:",inline"` metav1.ListMeta `json:"metadata"` Items []StageTemplate `json:"items""` }
StageTemplateList describes an array of StageTemplate instances.
func (*StageTemplateList) DeepCopy ¶
func (in *StageTemplateList) DeepCopy() *StageTemplateList
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new StageTemplateList.
func (*StageTemplateList) DeepCopyInto ¶
func (in *StageTemplateList) DeepCopyInto(out *StageTemplateList)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*StageTemplateList) DeepCopyObject ¶
func (in *StageTemplateList) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type StageTemplateSpec ¶
type StageTemplateSpec struct { // Arguments of the template Arguments []Argument `json:"arguments,omitempty"` // Pod kind workload Pod PodWorkload `json:"pod,omitempty"` // CRD kind workload CRD CRDWorkload `json:"crd,omitempty"` }
StageTemplateSpec defines stage template specification. Exact one workload should be specified.
func (*StageTemplateSpec) DeepCopy ¶
func (in *StageTemplateSpec) DeepCopy() *StageTemplateSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new StageTemplateSpec.
func (*StageTemplateSpec) DeepCopyInto ¶
func (in *StageTemplateSpec) DeepCopyInto(out *StageTemplateSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type Status ¶
type Status struct { // Status with value: Running, Waiting, Completed, Error Status string `json:"status"` // LastTransitionTime is the last time the status transitioned from one status to another. // +optional LastTransitionTime metav1.Time `json:"lastTransitionTime,omitempty"` // The reason for the status's last transition. // +optional Reason string `json:"reason,omitempty"` // A human readable message indicating details about the transition. // +optional Message string `json:"message,omitempty"` }
Status of a Stage in a WorkflowRun or the whole WorkflowRun. +k8s:deepcopy-gen=true
func (*Status) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Status.
func (*Status) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type StatusRef ¶
type StatusRef struct { // Path of field in the CRD spec that determines status of CRD workload Path string `json:"path"` // Value indicates CRD workload completion ComplatedValue string `json:"complatedValue"` }
StatusRef defines how to judge CRD status completion.
func (*StatusRef) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new StatusRef.
func (*StatusRef) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type TemplateRef ¶
type TemplateRef struct { // Template name Name string `json:"name"` // Arguments passed to the template Arguments []ArgumentValue `json:"arguments"` }
TemplateRef refers to a stage template and defines necessary arguments.
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.
type Workflow ¶
type Workflow struct { // Metadata for the resource, like kind and apiversion metav1.TypeMeta `json:",inline"` // Metadata for the particular object, including name, namespace, labels, etc metav1.ObjectMeta `json:"metadata,omitempty"` // Workflow specification Spec WorkflowSpec `json:"spec"` }
Workflow defines a workflow
func (*Workflow) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Workflow.
func (*Workflow) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*Workflow) DeepCopyObject ¶
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type WorkflowList ¶
type WorkflowList struct { metav1.TypeMeta `json:",inline"` metav1.ListMeta `json:"metadata"` Items []Workflow `json:"items""` }
WorkflowList describes an array of Workflow instances.
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.
type WorkflowParam ¶
type WorkflowParam struct { // Metadata for the resource, like kind and apiversion metav1.TypeMeta `json:",inline"` // Metadata for the particular object, including name, namespace, labels, etc metav1.ObjectMeta `json:"metadata,omitempty"` // Workflow param specification Spec WorkflowParamSpec `json:"spec"` }
WorkflowParam describes global workflow runtime parameters
func (*WorkflowParam) DeepCopy ¶
func (in *WorkflowParam) DeepCopy() *WorkflowParam
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new WorkflowParam.
func (*WorkflowParam) DeepCopyInto ¶
func (in *WorkflowParam) DeepCopyInto(out *WorkflowParam)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*WorkflowParam) DeepCopyObject ¶
func (in *WorkflowParam) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type WorkflowParamList ¶
type WorkflowParamList struct { metav1.TypeMeta `json:",inline"` metav1.ListMeta `json:"metadata"` Items []WorkflowParam `json:"items""` }
WorkflowParamList describes an array of WorkflowParam instances.
func (*WorkflowParamList) DeepCopy ¶
func (in *WorkflowParamList) DeepCopy() *WorkflowParamList
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new WorkflowParamList.
func (*WorkflowParamList) DeepCopyInto ¶
func (in *WorkflowParamList) DeepCopyInto(out *WorkflowParamList)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*WorkflowParamList) DeepCopyObject ¶
func (in *WorkflowParamList) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type WorkflowParamSpec ¶
type WorkflowParamSpec struct { // PVC to be used for workflow PVC string `json:"pvc"` // Cluster where the workflow will run on Cluster string `json:"cluster"` }
WorkflowParamSpec describes global parameters a workflow should run with.
func (*WorkflowParamSpec) DeepCopy ¶
func (in *WorkflowParamSpec) DeepCopy() *WorkflowParamSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new WorkflowParamSpec.
func (*WorkflowParamSpec) DeepCopyInto ¶
func (in *WorkflowParamSpec) DeepCopyInto(out *WorkflowParamSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type WorkflowRun ¶
type WorkflowRun struct { // Metadata for the resource, like kind and apiversion metav1.TypeMeta `json:",inline"` // Metadata for the particular object, including name, namespace, labels, etc metav1.ObjectMeta `json:"metadata,omitempty"` // Workflow run specification Spec WorkflowRunSpec `json:"spec"` // Status of workflow execution Status WorkflowRunStatus `json:"status,omitempty"` }
WorkflowRun describes one workflow run, giving concrete runtime parameters and recording workflow run status.
func (*WorkflowRun) DeepCopy ¶
func (in *WorkflowRun) DeepCopy() *WorkflowRun
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new WorkflowRun.
func (*WorkflowRun) DeepCopyInto ¶
func (in *WorkflowRun) DeepCopyInto(out *WorkflowRun)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*WorkflowRun) DeepCopyObject ¶
func (in *WorkflowRun) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type WorkflowRunList ¶
type WorkflowRunList struct { metav1.TypeMeta `json:",inline"` metav1.ListMeta `json:"metadata"` Items []WorkflowRun `json:"items"` }
WorkflowRunList describes an array of WorkflowRun instances.
func (*WorkflowRunList) DeepCopy ¶
func (in *WorkflowRunList) DeepCopy() *WorkflowRunList
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new WorkflowRunList.
func (*WorkflowRunList) DeepCopyInto ¶
func (in *WorkflowRunList) DeepCopyInto(out *WorkflowRunList)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*WorkflowRunList) DeepCopyObject ¶
func (in *WorkflowRunList) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type WorkflowRunSpec ¶
type WorkflowRunSpec struct { // Reference to a Workflow WorkflowRef *corev1.ObjectReference `json:"workflowRef"` // Stages in the workflow to start execution StartStages []string `json:"startStages"` // Stages in the workflow to end execution EndStages []string `json:"endStages"` // Maximum time this workflow should run Timeout string `json:"timeout"` // ServiceAccount used in the workflow execution ServiceAccount string `json:"serviceAccount"` // Resource parameters Resources []ParameterConfig `json:"resources"` // Stage parameters Stages []ParameterConfig `json:"stages"` }
WorkflowRunSpec defines workflow run specification.
func (*WorkflowRunSpec) DeepCopy ¶
func (in *WorkflowRunSpec) DeepCopy() *WorkflowRunSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new WorkflowRunSpec.
func (*WorkflowRunSpec) DeepCopyInto ¶
func (in *WorkflowRunSpec) DeepCopyInto(out *WorkflowRunSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type WorkflowRunStatus ¶
type WorkflowRunStatus struct { // Status of all stages Stages map[string]*StageStatus `json:"stages"` // Overall status Overall Status `json:"overall"` // Whether gc is performed on this WorkflowRun, such as deleting pods. Cleaned bool `json:"cleaned"` }
WorkflowRunStatus records workflow running status.
func (*WorkflowRunStatus) DeepCopy ¶
func (in *WorkflowRunStatus) DeepCopy() *WorkflowRunStatus
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new WorkflowRunStatus.
func (*WorkflowRunStatus) DeepCopyInto ¶
func (in *WorkflowRunStatus) DeepCopyInto(out *WorkflowRunStatus)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type WorkflowSpec ¶
type WorkflowSpec struct {
Stages []StageItem `json:"stages"`
}
WorkflowSpec defines workflow specification.
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.
type WorkflowTrigger ¶
type WorkflowTrigger struct { // Metadata for the resource, like kind and apiversion metav1.TypeMeta `json:",inline"` // Metadata for the particular object, including name, namespace, labels, etc metav1.ObjectMeta `json:"metadata,omitempty"` // Specification of this workflow trigger Spec WorkflowTriggerSpec `json:"spec"` // Status of this trigger Status WorkflowTriggerStatus `json:"status"` }
WorkflowTrigger describes trigger of an workflow, time schedule and webhook supported.
func (*WorkflowTrigger) DeepCopy ¶
func (in *WorkflowTrigger) DeepCopy() *WorkflowTrigger
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new WorkflowTrigger.
func (*WorkflowTrigger) DeepCopyInto ¶
func (in *WorkflowTrigger) DeepCopyInto(out *WorkflowTrigger)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*WorkflowTrigger) DeepCopyObject ¶
func (in *WorkflowTrigger) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type WorkflowTriggerList ¶
type WorkflowTriggerList struct { metav1.TypeMeta `json:",inline"` metav1.ListMeta `json:"metadata"` Items []WorkflowTrigger `json:"items""` }
WorkflowTriggerList describes an array of WorkflowTrigger instances.
func (*WorkflowTriggerList) DeepCopy ¶
func (in *WorkflowTriggerList) DeepCopy() *WorkflowTriggerList
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new WorkflowTriggerList.
func (*WorkflowTriggerList) DeepCopyInto ¶
func (in *WorkflowTriggerList) DeepCopyInto(out *WorkflowTriggerList)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*WorkflowTriggerList) DeepCopyObject ¶
func (in *WorkflowTriggerList) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type WorkflowTriggerSpec ¶
type WorkflowTriggerSpec struct { // Type of this trigger, Schedule or Webhook Type TriggerType `json:"triggerType"` // Parameters of the trigger, for Schedule type trigger, "schedule" // parameter is required Parameters []ParameterItem `json:"parameters"` // Whether this trigger is disabled, if set to true, no workflow will be triggered Disabled bool `json:"disabled"` // Spec to run the workflow WorkflowRunSpec `json:",inline"` }
WorkflowTriggerSpec defines workflow trigger definition.
func (*WorkflowTriggerSpec) DeepCopy ¶
func (in *WorkflowTriggerSpec) DeepCopy() *WorkflowTriggerSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new WorkflowTriggerSpec.
func (*WorkflowTriggerSpec) DeepCopyInto ¶
func (in *WorkflowTriggerSpec) DeepCopyInto(out *WorkflowTriggerSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type WorkflowTriggerStatus ¶
type WorkflowTriggerStatus struct { // How many times this trigger got triggered Count int `json:"count"` }
WorkflowTriggerStatus describes status of a workflow trigger
func (*WorkflowTriggerStatus) DeepCopy ¶
func (in *WorkflowTriggerStatus) DeepCopy() *WorkflowTriggerStatus
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new WorkflowTriggerStatus.
func (*WorkflowTriggerStatus) DeepCopyInto ¶
func (in *WorkflowTriggerStatus) DeepCopyInto(out *WorkflowTriggerStatus)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.