Documentation ¶
Overview ¶
Package v1 contains API Schema definitions for the pipelines.kubeflow.org v1 API group +kubebuilder:object:generate=true +groupName=pipelines.kubeflow.org
Index ¶
- Variables
- func AnnotationsFromDebugOptions(ctx context.Context, debugOptions DebugOptions) map[string]string
- type DebugOptions
- type Experiment
- func (in *Experiment) DeepCopy() *Experiment
- func (in *Experiment) DeepCopyInto(out *Experiment)
- func (in *Experiment) DeepCopyObject() runtime.Object
- func (e Experiment) GetKind() string
- func (e Experiment) GetNamespacedName() types.NamespacedName
- func (e *Experiment) GetStatus() Status
- func (e *Experiment) SetStatus(status Status)
- type ExperimentList
- type ExperimentSpec
- type Pipeline
- func (in *Pipeline) DeepCopy() *Pipeline
- func (in *Pipeline) DeepCopyInto(out *Pipeline)
- func (in *Pipeline) DeepCopyObject() runtime.Object
- func (p Pipeline) GetKind() string
- func (p Pipeline) GetNamespacedName() types.NamespacedName
- func (p *Pipeline) GetStatus() Status
- func (p *Pipeline) SetStatus(status Status)
- type PipelineList
- type PipelineSpec
- type RunConfiguration
- func (rcs RunConfiguration) ComputeHash() []byte
- func (rcs RunConfiguration) ComputeVersion() string
- func (in *RunConfiguration) DeepCopy() *RunConfiguration
- func (in *RunConfiguration) DeepCopyInto(out *RunConfiguration)
- func (in *RunConfiguration) DeepCopyObject() runtime.Object
- func (rc RunConfiguration) GetKind() string
- func (rc RunConfiguration) GetNamespacedName() types.NamespacedName
- func (rc *RunConfiguration) GetStatus() Status
- func (rc *RunConfiguration) SetStatus(status Status)
- type RunConfigurationList
- type RunConfigurationSpec
- type RunConfigurationStatus
- type Status
- type SynchronizationState
Constants ¶
This section is empty.
Variables ¶
var ( // GroupVersion is group version used to register these objects GroupVersion = schema.GroupVersion{Group: "pipelines.kubeflow.org", Version: "v1"} // SchemeBuilder is used to add go types to the GroupVersionKind scheme SchemeBuilder = &scheme.Builder{GroupVersion: GroupVersion} // AddToScheme adds the types in this group-version to the given scheme. AddToScheme = SchemeBuilder.AddToScheme )
var Annotations = struct { Debug string }{ Debug: GroupVersion.Group + "/debug", }
Functions ¶
func AnnotationsFromDebugOptions ¶ added in v0.0.2
func AnnotationsFromDebugOptions(ctx context.Context, debugOptions DebugOptions) map[string]string
Types ¶
type DebugOptions ¶ added in v0.0.2
type DebugOptions struct {
KeepWorkflows bool `json:"keepWorkflows,omitempty"`
}
func DebugOptionsFromAnnotations ¶ added in v0.0.2
func DebugOptionsFromAnnotations(ctx context.Context, annotations map[string]string) DebugOptions
func (*DebugOptions) DeepCopy ¶ added in v0.0.2
func (in *DebugOptions) DeepCopy() *DebugOptions
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new DebugOptions.
func (*DebugOptions) DeepCopyInto ¶ added in v0.0.2
func (in *DebugOptions) DeepCopyInto(out *DebugOptions)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (DebugOptions) WithDefaults ¶ added in v0.0.2
func (options DebugOptions) WithDefaults(defaults DebugOptions) DebugOptions
type Experiment ¶ added in v0.0.3
type Experiment struct { metav1.TypeMeta `json:",inline"` metav1.ObjectMeta `json:"metadata,omitempty"` Spec ExperimentSpec `json:"spec,omitempty"` Status Status `json:"status,omitempty"` }
func (*Experiment) DeepCopy ¶ added in v0.0.3
func (in *Experiment) DeepCopy() *Experiment
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Experiment.
func (*Experiment) DeepCopyInto ¶ added in v0.0.3
func (in *Experiment) DeepCopyInto(out *Experiment)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*Experiment) DeepCopyObject ¶ added in v0.0.3
func (in *Experiment) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
func (Experiment) GetKind ¶ added in v0.1.0
func (e Experiment) GetKind() string
func (Experiment) GetNamespacedName ¶ added in v0.1.0
func (e Experiment) GetNamespacedName() types.NamespacedName
func (*Experiment) GetStatus ¶ added in v0.0.3
func (e *Experiment) GetStatus() Status
func (*Experiment) SetStatus ¶ added in v0.0.3
func (e *Experiment) SetStatus(status Status)
type ExperimentList ¶ added in v0.0.3
type ExperimentList struct { metav1.TypeMeta `json:",inline"` metav1.ListMeta `json:"metadata,omitempty"` Items []Experiment `json:"items"` }
func (*ExperimentList) DeepCopy ¶ added in v0.0.3
func (in *ExperimentList) DeepCopy() *ExperimentList
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ExperimentList.
func (*ExperimentList) DeepCopyInto ¶ added in v0.0.3
func (in *ExperimentList) DeepCopyInto(out *ExperimentList)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*ExperimentList) DeepCopyObject ¶ added in v0.0.3
func (in *ExperimentList) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type ExperimentSpec ¶ added in v0.0.3
type ExperimentSpec struct {
Description string `json:"description,omitempty"`
}
func (ExperimentSpec) ComputeHash ¶ added in v0.0.3
func (es ExperimentSpec) ComputeHash() []byte
func (ExperimentSpec) ComputeVersion ¶ added in v0.0.3
func (es ExperimentSpec) ComputeVersion() string
func (*ExperimentSpec) DeepCopy ¶ added in v0.0.3
func (in *ExperimentSpec) DeepCopy() *ExperimentSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ExperimentSpec.
func (*ExperimentSpec) DeepCopyInto ¶ added in v0.0.3
func (in *ExperimentSpec) DeepCopyInto(out *ExperimentSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type Pipeline ¶
type Pipeline struct { metav1.TypeMeta `json:",inline"` metav1.ObjectMeta `json:"metadata,omitempty"` Spec PipelineSpec `json:"spec,omitempty"` Status Status `json:"status,omitempty"` }
func (*Pipeline) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Pipeline.
func (*Pipeline) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*Pipeline) DeepCopyObject ¶
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
func (Pipeline) GetNamespacedName ¶ added in v0.1.0
func (p Pipeline) GetNamespacedName() types.NamespacedName
type PipelineList ¶
type PipelineList struct { metav1.TypeMeta `json:",inline"` metav1.ListMeta `json:"metadata,omitempty"` Items []Pipeline `json:"items"` }
func (*PipelineList) DeepCopy ¶
func (in *PipelineList) DeepCopy() *PipelineList
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PipelineList.
func (*PipelineList) DeepCopyInto ¶
func (in *PipelineList) DeepCopyInto(out *PipelineList)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*PipelineList) DeepCopyObject ¶
func (in *PipelineList) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type PipelineSpec ¶
type PipelineSpec struct { Image string `json:"image" yaml:"image"` TfxComponents string `json:"tfxComponents" yaml:"tfxComponents"` Env map[string]string `json:"env,omitempty" yaml:"env"` BeamArgs map[string]string `json:"beamArgs,omitempty" yaml:"beamArgs"` }
func (PipelineSpec) ComputeHash ¶ added in v0.0.2
func (ps PipelineSpec) ComputeHash() []byte
func (PipelineSpec) ComputeVersion ¶ added in v0.0.2
func (ps PipelineSpec) ComputeVersion() string
func (*PipelineSpec) DeepCopy ¶
func (in *PipelineSpec) DeepCopy() *PipelineSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PipelineSpec.
func (*PipelineSpec) DeepCopyInto ¶
func (in *PipelineSpec) DeepCopyInto(out *PipelineSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type RunConfiguration ¶ added in v0.0.2
type RunConfiguration struct { metav1.TypeMeta `json:",inline"` metav1.ObjectMeta `json:"metadata,omitempty"` Spec RunConfigurationSpec `json:"spec,omitempty"` Status RunConfigurationStatus `json:"status,omitempty"` }
func (RunConfiguration) ComputeHash ¶ added in v0.0.3
func (rcs RunConfiguration) ComputeHash() []byte
func (RunConfiguration) ComputeVersion ¶ added in v0.0.3
func (rcs RunConfiguration) ComputeVersion() string
func (*RunConfiguration) DeepCopy ¶ added in v0.0.2
func (in *RunConfiguration) DeepCopy() *RunConfiguration
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new RunConfiguration.
func (*RunConfiguration) DeepCopyInto ¶ added in v0.0.2
func (in *RunConfiguration) DeepCopyInto(out *RunConfiguration)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*RunConfiguration) DeepCopyObject ¶ added in v0.0.2
func (in *RunConfiguration) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
func (RunConfiguration) GetKind ¶ added in v0.1.0
func (rc RunConfiguration) GetKind() string
func (RunConfiguration) GetNamespacedName ¶ added in v0.1.0
func (rc RunConfiguration) GetNamespacedName() types.NamespacedName
func (*RunConfiguration) GetStatus ¶ added in v0.0.3
func (rc *RunConfiguration) GetStatus() Status
func (*RunConfiguration) SetStatus ¶ added in v0.0.3
func (rc *RunConfiguration) SetStatus(status Status)
type RunConfigurationList ¶ added in v0.0.2
type RunConfigurationList struct { metav1.TypeMeta `json:",inline"` metav1.ListMeta `json:"metadata,omitempty"` Items []RunConfiguration `json:"items"` }
func (*RunConfigurationList) DeepCopy ¶ added in v0.0.2
func (in *RunConfigurationList) DeepCopy() *RunConfigurationList
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new RunConfigurationList.
func (*RunConfigurationList) DeepCopyInto ¶ added in v0.0.2
func (in *RunConfigurationList) DeepCopyInto(out *RunConfigurationList)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*RunConfigurationList) DeepCopyObject ¶ added in v0.0.2
func (in *RunConfigurationList) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type RunConfigurationSpec ¶ added in v0.0.2
type RunConfigurationSpec struct { PipelineName string `json:"pipelineName,omitempty"` ExperimentName string `json:"experimentName,omitempty"` Schedule string `json:"schedule,omitempty"` RuntimeParameters map[string]string `json:"runtimeParameters,omitempty"` }
func (*RunConfigurationSpec) DeepCopy ¶ added in v0.0.2
func (in *RunConfigurationSpec) DeepCopy() *RunConfigurationSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new RunConfigurationSpec.
func (*RunConfigurationSpec) DeepCopyInto ¶ added in v0.0.2
func (in *RunConfigurationSpec) DeepCopyInto(out *RunConfigurationSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type RunConfigurationStatus ¶ added in v0.0.3
type RunConfigurationStatus struct { Status `json:",inline"` ObservedPipelineVersion string `json:"observedPipelineVersion,omitempty"` }
func (*RunConfigurationStatus) DeepCopy ¶ added in v0.0.3
func (in *RunConfigurationStatus) DeepCopy() *RunConfigurationStatus
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new RunConfigurationStatus.
func (*RunConfigurationStatus) DeepCopyInto ¶ added in v0.0.3
func (in *RunConfigurationStatus) DeepCopyInto(out *RunConfigurationStatus)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type Status ¶ added in v0.0.2
type Status struct { KfpId string `json:"kfpId,omitempty"` SynchronizationState SynchronizationState `json:"synchronizationState,omitempty"` Version string `json:"version,omitempty"` ObservedGeneration int64 `json:"observedGeneration,omitempty"` }
func (*Status) DeepCopy ¶ added in v0.0.2
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Status.
func (*Status) DeepCopyInto ¶ added in v0.0.2
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type SynchronizationState ¶
type SynchronizationState string
const ( Creating SynchronizationState = "Creating" Succeeded SynchronizationState = "Succeeded" Updating SynchronizationState = "Updating" Deleting SynchronizationState = "Deleting" Deleted SynchronizationState = "Deleted" Failed SynchronizationState = "Failed" )