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) GetNamespacedName ¶ added in v0.1.0
func (e Experiment) GetNamespacedName() types.NamespacedName
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 ¶
func (in *Pipeline) DeepCopy() *Pipeline
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Pipeline.
func (*Pipeline) DeepCopyInto ¶
func (in *Pipeline) DeepCopyInto(out *Pipeline)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*Pipeline) DeepCopyObject ¶
func (in *Pipeline) DeepCopyObject() runtime.Object
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) GetNamespacedName ¶ added in v0.1.0
func (rc RunConfiguration) GetNamespacedName() types.NamespacedName
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
func (in *Status) DeepCopy() *Status
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Status.
func (*Status) DeepCopyInto ¶ added in v0.0.2
func (in *Status) DeepCopyInto(out *Status)
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"
)