v1

package
v0.1.0 Latest Latest
Warning

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

Go to latest
Published: Jul 13, 2022 License: BSD-3-Clause Imports: 11 Imported by: 0

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

Constants

This section is empty.

Variables

View Source
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
)
View Source
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

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) GetKind added in v0.1.0

func (p Pipeline) GetKind() string

func (Pipeline) GetNamespacedName added in v0.1.0

func (p Pipeline) GetNamespacedName() types.NamespacedName

func (*Pipeline) GetStatus added in v0.0.3

func (p *Pipeline) GetStatus() Status

func (*Pipeline) SetStatus added in v0.0.3

func (p *Pipeline) SetStatus(status Status)

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

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

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

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL