v1alpha5

package
v0.5.0 Latest Latest
Warning

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

 Go to latest Published: Mar 14, 2024 License: BSD-3-Clause Imports: 19 Imported by: 7

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

View Source 
const ArtifactPathPattern = `^([^\[\]:]+):([^\[\]:]+)(?::(\d*))?(?:\[([^\[\]:]+)\])?$`

Variables

View Source 
var (
	// GroupVersion is group version used to register these objects
	GroupVersion = schema.GroupVersion{Group: apis.Group, Version: "v1alpha5"}

	// 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 CompletionStates = struct {
	Succeeded CompletionState
	Failed    CompletionState
}{
	Succeeded: "Succeeded",
	Failed:    "Failed",
}
View Source 
var ConditionTypes = struct {
	SynchronizationSucceeded string
}{
	SynchronizationSucceeded: "Synchronized",
}
View Source 
var OnChangeTypes = struct {
	Pipeline OnChangeType
	RunSpec  OnChangeType
}{
	Pipeline: "pipeline",
	RunSpec:  "runSpec",
}

Functions

func ConditionStatusForSynchronizationState 

func ConditionStatusForSynchronizationState(state apis.SynchronizationState) metav1.ConditionStatus

func WriteRunTimeParameters 

func WriteRunTimeParameters(oh pipelines.ObjectHasher, rps []RuntimeParameter)

Types

type ArtifactLocator 

type ArtifactLocator struct {
	Component string `json:"-" yaml:"-"`
	Artifact  string `json:"-" yaml:"-"`
	Index     int    `json:"-" yaml:"-"`
}

func (*ArtifactLocator) DeepCopy 

func (in *ArtifactLocator) DeepCopy() *ArtifactLocator

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

func (*ArtifactLocator) DeepCopyInto 

func (in *ArtifactLocator) DeepCopyInto(out *ArtifactLocator)

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

func (*ArtifactLocator) String 

func (ap *ArtifactLocator) String() string

type ArtifactPath 

type ArtifactPath struct {
	Locator ArtifactLocator `json:"-" yaml:"-"`
	Filter  string          `json:"-" yaml:"-"`
}

+kubebuilder:validation:Type=string +kubebuilder:validation:Pattern=`^([^\[\]:]+):([^\[\]:]+)(?::(\d*))?(?:\[([^\[\]:]+)\])?$`

func ArtifactPathFromString 

func ArtifactPathFromString(path string) (artifactPath ArtifactPath, err error)

func (*ArtifactPath) DeepCopy 

func (in *ArtifactPath) DeepCopy() *ArtifactPath

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

func (*ArtifactPath) DeepCopyInto 

func (in *ArtifactPath) DeepCopyInto(out *ArtifactPath)

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

func (ArtifactPath) MarshalText 

func (ap ArtifactPath) MarshalText() ([]byte, error)

func (ArtifactPath) String 

func (ap ArtifactPath) String() string

func (*ArtifactPath) UnmarshalText 

func (ap *ArtifactPath) UnmarshalText(bytes []byte) error

type CompletionState 

type CompletionState string

type Conditions 

type Conditions []metav1.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) MergeIntoConditions 

func (conditions Conditions) MergeIntoConditions(condition metav1.Condition) Conditions

func (Conditions) SynchronizationSucceeded 

func (conditions Conditions) SynchronizationSucceeded() metav1.Condition

func (Conditions) ToMap 

func (conditions Conditions) ToMap() map[string]metav1.Condition

type Dependencies 

type Dependencies struct {
	RunConfigurations map[string]RunReference `json:"runConfigurations,omitempty"`
}

func (*Dependencies) DeepCopy 

func (in *Dependencies) DeepCopy() *Dependencies

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

func (*Dependencies) DeepCopyInto 

func (in *Dependencies) DeepCopyInto(out *Dependencies)

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

type Experiment 

type Experiment struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec   ExperimentSpec `json:"spec,omitempty"`
	Status Status         `json:"status,omitempty"`
}

func (Experiment) ComputeHash 

func (es Experiment) ComputeHash() []byte

func (Experiment) ComputeVersion 

func (es Experiment) ComputeVersion() string

func (*Experiment) DeepCopy 

func (in *Experiment) DeepCopy() *Experiment

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

func (*Experiment) DeepCopyInto 

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 

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

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

func (Experiment) GetKind 

func (e Experiment) GetKind() string

func (Experiment) GetNamespacedName 

func (e Experiment) GetNamespacedName() types.NamespacedName

func (*Experiment) GetProvider 

func (e *Experiment) GetProvider() string

func (*Experiment) GetStatus 

func (e *Experiment) GetStatus() Status

func (*Experiment) Hub 

func (*Experiment) Hub()

func (*Experiment) SetStatus 

func (e *Experiment) SetStatus(status Status)

func (*Experiment) SetupWebhookWithManager 

func (e *Experiment) SetupWebhookWithManager(mgr ctrl.Manager) error

type ExperimentList 

type ExperimentList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []Experiment `json:"items"`
}

func (*ExperimentList) DeepCopy 

func (in *ExperimentList) DeepCopy() *ExperimentList

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

func (*ExperimentList) DeepCopyInto 

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 

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

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

type ExperimentSpec 

type ExperimentSpec struct {
	Description string `json:"description,omitempty"`
}

func (*ExperimentSpec) DeepCopy 

func (in *ExperimentSpec) DeepCopy() *ExperimentSpec

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

func (*ExperimentSpec) DeepCopyInto 

func (in *ExperimentSpec) DeepCopyInto(out *ExperimentSpec)

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

type HasProvider 

type HasProvider interface {
	metav1.Object
	GetProvider() string
}

+kubebuilder:object:generate=false

type LatestRuns 

type LatestRuns struct {
	Succeeded RunReference `json:"succeeded,omitempty"`
}

func (*LatestRuns) DeepCopy 

func (in *LatestRuns) DeepCopy() *LatestRuns

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

func (*LatestRuns) DeepCopyInto 

func (in *LatestRuns) DeepCopyInto(out *LatestRuns)

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

type OnChangeType 

type OnChangeType string

+kubebuilder:validation:Enum=pipeline;runSpec

type OutputArtifact 

type OutputArtifact struct {
	Name string       `json:"name"`
	Path ArtifactPath `json:"path"`
}

func (*OutputArtifact) DeepCopy 

func (in *OutputArtifact) DeepCopy() *OutputArtifact

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

func (*OutputArtifact) DeepCopyInto 

func (in *OutputArtifact) DeepCopyInto(out *OutputArtifact)

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

func (OutputArtifact) GetKey 

func (oa OutputArtifact) GetKey() string

func (OutputArtifact) GetValue 

func (oa OutputArtifact) GetValue() string

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

func (ps Pipeline) ComputeHash() []byte

func (Pipeline) ComputeVersion 

func (ps Pipeline) ComputeVersion() string

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 

func (p Pipeline) GetKind() string

func (Pipeline) GetNamespacedName 

func (p Pipeline) GetNamespacedName() types.NamespacedName

func (*Pipeline) GetProvider 

func (p *Pipeline) GetProvider() string

func (*Pipeline) GetStatus 

func (p *Pipeline) GetStatus() Status

func (*Pipeline) Hub 

func (*Pipeline) Hub()

func (*Pipeline) SetStatus 

func (p *Pipeline) SetStatus(status Status)

func (*Pipeline) SetupWebhookWithManager 

func (p *Pipeline) SetupWebhookWithManager(mgr ctrl.Manager) error

func (*Pipeline) UnversionedIdentifier 

func (pipeline *Pipeline) UnversionedIdentifier() PipelineIdentifier

func (*Pipeline) VersionedIdentifier 

func (pipeline *Pipeline) VersionedIdentifier() PipelineIdentifier

type PipelineIdentifier 

type PipelineIdentifier struct {
	Name    string `json:"-"`
	Version string `json:"-"`
}

+kubebuilder:validation:Type=string +kubebuilder:validation:Pattern:=`^[\w\-]+(?::[\w\-_.]+)?$`

func (*PipelineIdentifier) DeepCopy 

func (in *PipelineIdentifier) DeepCopy() *PipelineIdentifier

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

func (*PipelineIdentifier) DeepCopyInto 

func (in *PipelineIdentifier) DeepCopyInto(out *PipelineIdentifier)

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

func (*PipelineIdentifier) MarshalJSON 

func (pid *PipelineIdentifier) MarshalJSON() ([]byte, error)

func (*PipelineIdentifier) String 

func (pid *PipelineIdentifier) String() string

func (*PipelineIdentifier) UnmarshalJSON 

func (pid *PipelineIdentifier) UnmarshalJSON(bytes []byte) error

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           []apis.NamedValue `json:"env,omitempty" yaml:"env"`
	BeamArgs      []apis.NamedValue `json:"beamArgs,omitempty"`
}

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 ProviderAndId 

type ProviderAndId struct {
	Provider string `json:"-"`
	Id       string `json:"-"`
}

+kubebuilder:validation:Type=string

func (*ProviderAndId) DeepCopy 

func (in *ProviderAndId) DeepCopy() *ProviderAndId

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

func (*ProviderAndId) DeepCopyInto 

func (in *ProviderAndId) DeepCopyInto(out *ProviderAndId)

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

func (*ProviderAndId) MarshalJSON 

func (pid *ProviderAndId) MarshalJSON() ([]byte, error)

func (*ProviderAndId) String 

func (pid *ProviderAndId) String() string

func (*ProviderAndId) UnmarshalJSON 

func (pid *ProviderAndId) UnmarshalJSON(bytes []byte) error

type Resource 

type Resource interface {
	HasProvider
	runtime.Object
	GetStatus() Status
	SetStatus(Status)
	GetNamespacedName() types.NamespacedName
	ComputeVersion() string
	// GetKind is a workaround to address https://github.com/sky-uk/kfp-operator/issues/137
	GetKind() string
}

+kubebuilder:object:generate=false

type Run 

type Run struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec   RunSpec   `json:"spec,omitempty"`
	Status RunStatus `json:"status,omitempty"`
}

func (Run) ComputeHash 

func (r Run) ComputeHash() []byte

func (Run) ComputeVersion 

func (r Run) ComputeVersion() string

func (*Run) DeepCopy 

func (in *Run) DeepCopy() *Run

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

func (*Run) DeepCopyInto 

func (in *Run) DeepCopyInto(out *Run)

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

func (*Run) DeepCopyObject 

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

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

func (*Run) GetDependencyRuns 

func (r *Run) GetDependencyRuns() map[string]RunReference

func (*Run) GetKind 

func (r *Run) GetKind() string

func (*Run) GetNamespacedName 

func (r *Run) GetNamespacedName() types.NamespacedName

func (*Run) GetObservedPipelineVersion 

func (r *Run) GetObservedPipelineVersion() string

func (*Run) GetPipeline 

func (r *Run) GetPipeline() PipelineIdentifier

func (*Run) GetProvider 

func (r *Run) GetProvider() string

func (*Run) GetReferencedRCArtifacts 

func (r *Run) GetReferencedRCArtifacts() []RunConfigurationRef

func (*Run) GetReferencedRCs 

func (r *Run) GetReferencedRCs() []string

func (*Run) GetStatus 

func (r *Run) GetStatus() Status

func (*Run) Hub 

func (*Run) Hub()

func (*Run) SetDependencyRuns 

func (r *Run) SetDependencyRuns(references map[string]RunReference)

func (*Run) SetObservedPipelineVersion 

func (r *Run) SetObservedPipelineVersion(newVersion string)

func (*Run) SetStatus 

func (r *Run) SetStatus(status Status)

func (*Run) SetupWebhookWithManager 

func (r *Run) SetupWebhookWithManager(mgr ctrl.Manager) error

func (*Run) ValidateCreate 

func (r *Run) ValidateCreate() error

func (*Run) ValidateDelete 

func (r *Run) ValidateDelete() error

func (*Run) ValidateUpdate 

func (r *Run) ValidateUpdate(old runtime.Object) error

type RunConfiguration 

type RunConfiguration struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec   RunConfigurationSpec   `json:"spec,omitempty"`
	Status RunConfigurationStatus `json:"status,omitempty"`
}

func (*RunConfiguration) DeepCopy 

func (in *RunConfiguration) DeepCopy() *RunConfiguration

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

func (*RunConfiguration) DeepCopyInto 

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 

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

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

func (*RunConfiguration) GetDependencyRuns 

func (rc *RunConfiguration) GetDependencyRuns() map[string]RunReference

func (*RunConfiguration) GetKind 

func (rc *RunConfiguration) GetKind() string

func (*RunConfiguration) GetNamespacedName 

func (rc *RunConfiguration) GetNamespacedName() types.NamespacedName

func (*RunConfiguration) GetObservedPipelineVersion 

func (rc *RunConfiguration) GetObservedPipelineVersion() string

func (*RunConfiguration) GetPipeline 

func (rc *RunConfiguration) GetPipeline() PipelineIdentifier

func (*RunConfiguration) GetProvider 

func (rc *RunConfiguration) GetProvider() string

func (*RunConfiguration) GetReferencedRCArtifacts 

func (rc *RunConfiguration) GetReferencedRCArtifacts() []RunConfigurationRef

func (*RunConfiguration) GetReferencedRCs 

func (rc *RunConfiguration) GetReferencedRCs() []string

func (*RunConfiguration) Hub 

func (*RunConfiguration) Hub()

func (*RunConfiguration) SetDependencyRuns 

func (rc *RunConfiguration) SetDependencyRuns(references map[string]RunReference)

func (*RunConfiguration) SetObservedPipelineVersion 

func (rc *RunConfiguration) SetObservedPipelineVersion(observedPipelineVersion string)

func (*RunConfiguration) SetupWebhookWithManager 

func (rc *RunConfiguration) SetupWebhookWithManager(mgr ctrl.Manager) error

func (*RunConfiguration) ValidateCreate 

func (rc *RunConfiguration) ValidateCreate() error

func (*RunConfiguration) ValidateDelete 

func (rc *RunConfiguration) ValidateDelete() error

func (*RunConfiguration) ValidateUpdate 

func (rc *RunConfiguration) ValidateUpdate(_ runtime.Object) error

type RunConfigurationConversionRemainder 

type RunConfigurationConversionRemainder struct {
	RunConversionRemainder `json:",inline"`
	Triggers               Triggers `json:"triggers,omitempty"`
}

func (*RunConfigurationConversionRemainder) DeepCopy 

func (in *RunConfigurationConversionRemainder) DeepCopy() *RunConfigurationConversionRemainder

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

func (*RunConfigurationConversionRemainder) DeepCopyInto 

func (in *RunConfigurationConversionRemainder) DeepCopyInto(out *RunConfigurationConversionRemainder)

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

func (RunConfigurationConversionRemainder) Empty 

func (rcr RunConfigurationConversionRemainder) Empty() bool

type RunConfigurationList 

type RunConfigurationList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []RunConfiguration `json:"items"`
}

func (*RunConfigurationList) DeepCopy 

func (in *RunConfigurationList) DeepCopy() *RunConfigurationList

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

func (*RunConfigurationList) DeepCopyInto 

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 

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

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

type RunConfigurationRef 

type RunConfigurationRef struct {
	Name           string `json:"name"`
	OutputArtifact string `json:"outputArtifact"`
}

func (*RunConfigurationRef) DeepCopy 

func (in *RunConfigurationRef) DeepCopy() *RunConfigurationRef

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

func (*RunConfigurationRef) DeepCopyInto 

func (in *RunConfigurationRef) DeepCopyInto(out *RunConfigurationRef)

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

type RunConfigurationSpec 

type RunConfigurationSpec struct {
	Run      RunSpec  `json:"run,omitempty"`
	Triggers Triggers `json:"triggers,omitempty"`
}

func (*RunConfigurationSpec) DeepCopy 

func (in *RunConfigurationSpec) DeepCopy() *RunConfigurationSpec

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

func (*RunConfigurationSpec) DeepCopyInto 

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 

type RunConfigurationStatus struct {
	SynchronizationState     apis.SynchronizationState `json:"synchronizationState,omitempty"`
	Provider                 string                    `json:"provider,omitempty"`
	ObservedPipelineVersion  string                    `json:"observedPipelineVersion,omitempty"`
	TriggeredPipelineVersion string                    `json:"triggeredPipelineVersion,omitempty"`
	LatestRuns               LatestRuns                `json:"latestRuns,omitempty"`
	Dependencies             Dependencies              `json:"dependencies,omitempty"`
	Triggers                 TriggersStatus            `json:"triggers,omitempty"`
	ObservedGeneration       int64                     `json:"observedGeneration,omitempty"`
	Conditions               Conditions                `json:"conditions,omitempty"`
}

func (*RunConfigurationStatus) DeepCopy 

func (in *RunConfigurationStatus) DeepCopy() *RunConfigurationStatus

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

func (*RunConfigurationStatus) DeepCopyInto 

func (in *RunConfigurationStatus) DeepCopyInto(out *RunConfigurationStatus)

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

func (*RunConfigurationStatus) SetSynchronizationState added in v0.4.1 

func (rcs *RunConfigurationStatus) SetSynchronizationState(state apis.SynchronizationState, message string)

type RunConversionRemainder 

type RunConversionRemainder struct {
	Artifacts           []OutputArtifact   `json:"artifacts,omitempty"`
	ValueFromParameters []RuntimeParameter `json:"valueFromParameters,omitempty"`
}

func (RunConversionRemainder) ConversionAnnotation 

func (rcr RunConversionRemainder) ConversionAnnotation() string

func (*RunConversionRemainder) DeepCopy 

func (in *RunConversionRemainder) DeepCopy() *RunConversionRemainder

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

func (*RunConversionRemainder) DeepCopyInto 

func (in *RunConversionRemainder) DeepCopyInto(out *RunConversionRemainder)

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

func (RunConversionRemainder) Empty 

func (rcr RunConversionRemainder) Empty() bool

type RunList 

type RunList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []Run `json:"items"`
}

func (*RunList) DeepCopy 

func (in *RunList) DeepCopy() *RunList

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

func (*RunList) DeepCopyInto 

func (in *RunList) DeepCopyInto(out *RunList)

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

func (*RunList) DeepCopyObject 

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

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

type RunReference 

type RunReference struct {
	ProviderId string            `json:"providerId,omitempty"`
	Artifacts  []common.Artifact `json:"artifacts,omitempty"`
}

func (*RunReference) DeepCopy 

func (in *RunReference) DeepCopy() *RunReference

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

func (*RunReference) DeepCopyInto 

func (in *RunReference) DeepCopyInto(out *RunReference)

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

type RunSchedule 

type RunSchedule struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec   RunScheduleSpec `json:"spec,omitempty"`
	Status Status          `json:"status,omitempty"`
}

func (RunSchedule) ComputeHash 

func (rs RunSchedule) ComputeHash() []byte

func (RunSchedule) ComputeVersion 

func (rs RunSchedule) ComputeVersion() string

func (*RunSchedule) DeepCopy 

func (in *RunSchedule) DeepCopy() *RunSchedule

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

func (*RunSchedule) DeepCopyInto 

func (in *RunSchedule) DeepCopyInto(out *RunSchedule)

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

func (*RunSchedule) DeepCopyObject 

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

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

func (*RunSchedule) GetKind 

func (rs *RunSchedule) GetKind() string

func (*RunSchedule) GetNamespacedName 

func (rs *RunSchedule) GetNamespacedName() types.NamespacedName

func (*RunSchedule) GetPipeline 

func (rs *RunSchedule) GetPipeline() PipelineIdentifier

func (*RunSchedule) GetProvider 

func (rs *RunSchedule) GetProvider() string

func (*RunSchedule) GetStatus 

func (rs *RunSchedule) GetStatus() Status

func (*RunSchedule) Hub 

func (*RunSchedule) Hub()

func (*RunSchedule) SetStatus 

func (rs *RunSchedule) SetStatus(status Status)

func (*RunSchedule) SetupWebhookWithManager 

func (rs *RunSchedule) SetupWebhookWithManager(mgr ctrl.Manager) error

type RunScheduleList 

type RunScheduleList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []RunSchedule `json:"items"`
}

func (*RunScheduleList) DeepCopy 

func (in *RunScheduleList) DeepCopy() *RunScheduleList

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

func (*RunScheduleList) DeepCopyInto 

func (in *RunScheduleList) DeepCopyInto(out *RunScheduleList)

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

func (*RunScheduleList) DeepCopyObject 

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

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

type RunScheduleSpec 

type RunScheduleSpec struct {
	Pipeline          PipelineIdentifier `json:"pipeline,omitempty"`
	ExperimentName    string             `json:"experimentName,omitempty"`
	RuntimeParameters []apis.NamedValue  `json:"runtimeParameters,omitempty"`
	Artifacts         []OutputArtifact   `json:"artifacts,omitempty"`
	Schedule          string             `json:"schedule,omitempty"`
}

func (*RunScheduleSpec) DeepCopy 

func (in *RunScheduleSpec) DeepCopy() *RunScheduleSpec

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

func (*RunScheduleSpec) DeepCopyInto 

func (in *RunScheduleSpec) DeepCopyInto(out *RunScheduleSpec)

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

type RunSpec 

type RunSpec struct {
	Pipeline          PipelineIdentifier `json:"pipeline,omitempty"`
	ExperimentName    string             `json:"experimentName,omitempty"`
	RuntimeParameters []RuntimeParameter `json:"runtimeParameters,omitempty"`
	Artifacts         []OutputArtifact   `json:"artifacts,omitempty"`
}

func (RunSpec) ComputeVersion 

func (rs RunSpec) ComputeVersion() string

func (*RunSpec) DeepCopy 

func (in *RunSpec) DeepCopy() *RunSpec

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

func (*RunSpec) DeepCopyInto 

func (in *RunSpec) DeepCopyInto(out *RunSpec)

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

func (*RunSpec) HasUnmetDependencies 

func (runSpec *RunSpec) HasUnmetDependencies(dependencies Dependencies) bool

func (*RunSpec) ResolveRuntimeParameters 

func (runSpec *RunSpec) ResolveRuntimeParameters(dependencies Dependencies) ([]apis.NamedValue, error)

func (RunSpec) WriteRunSpec 

func (rs RunSpec) WriteRunSpec(oh pipelines.ObjectHasher)

type RunSpecTriggerStatus 

type RunSpecTriggerStatus struct {
	Version string `json:"version,omitempty"`
}

func (*RunSpecTriggerStatus) DeepCopy 

func (in *RunSpecTriggerStatus) DeepCopy() *RunSpecTriggerStatus

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

func (*RunSpecTriggerStatus) DeepCopyInto 

func (in *RunSpecTriggerStatus) DeepCopyInto(out *RunSpecTriggerStatus)

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

type RunStatus 

type RunStatus struct {
	Status                  `json:",inline"`
	ObservedPipelineVersion string          `json:"observedPipelineVersion,omitempty"`
	Dependencies            Dependencies    `json:"dependencies,omitempty"`
	CompletionState         CompletionState `json:"completionState,omitempty"`
	MarkedCompletedAt       *metav1.Time    `json:"markedCompletedAt,omitempty"`
}

func (*RunStatus) DeepCopy 

func (in *RunStatus) DeepCopy() *RunStatus

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

func (*RunStatus) DeepCopyInto 

func (in *RunStatus) DeepCopyInto(out *RunStatus)

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

type RuntimeParameter 

type RuntimeParameter struct {
	Name      string     `json:"name"`
	Value     string     `json:"value,omitempty"`
	ValueFrom *ValueFrom `json:"valueFrom,omitempty"`
}

func MergeRuntimeParameters 

func MergeRuntimeParameters(namedValues []apis.NamedValue, valueFroms []RuntimeParameter) (rts []RuntimeParameter)

func SplitRunTimeParameters 

func SplitRunTimeParameters(rts []RuntimeParameter) (namedValues []apis.NamedValue, valueFroms []RuntimeParameter)

func (*RuntimeParameter) DeepCopy 

func (in *RuntimeParameter) DeepCopy() *RuntimeParameter

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

func (*RuntimeParameter) DeepCopyInto 

func (in *RuntimeParameter) DeepCopyInto(out *RuntimeParameter)

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

type Status 

type Status struct {
	ProviderId           ProviderAndId             `json:"providerId,omitempty"`
	SynchronizationState apis.SynchronizationState `json:"synchronizationState,omitempty"`
	Version              string                    `json:"version,omitempty"`
	ObservedGeneration   int64                     `json:"observedGeneration,omitempty"`
	Conditions           Conditions                `json:"conditions,omitempty"`
}

+kubebuilder:object:generate=true

func (*Status) DeepCopy 

func (in *Status) DeepCopy() *Status

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

func (*Status) DeepCopyInto 

func (in *Status) DeepCopyInto(out *Status)

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

type TriggeredRunReference 

type TriggeredRunReference struct {
	ProviderId string `json:"providerId,omitempty"`
}

func (*TriggeredRunReference) DeepCopy 

func (in *TriggeredRunReference) DeepCopy() *TriggeredRunReference

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

func (*TriggeredRunReference) DeepCopyInto 

func (in *TriggeredRunReference) DeepCopyInto(out *TriggeredRunReference)

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

type Triggers 

type Triggers struct {
	Schedules         []string       `json:"schedules,omitempty"`
	OnChange          []OnChangeType `json:"onChange,omitempty"`
	RunConfigurations []string       `json:"runConfigurations,omitempty"`
}

func (*Triggers) DeepCopy 

func (in *Triggers) DeepCopy() *Triggers

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

func (*Triggers) DeepCopyInto 

func (in *Triggers) DeepCopyInto(out *Triggers)

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

type TriggersStatus 

type TriggersStatus struct {
	RunConfigurations map[string]TriggeredRunReference `json:"runConfigurations,omitempty"`
	RunSpec           RunSpecTriggerStatus             `json:"runSpec,omitempty"`
}

func (*TriggersStatus) DeepCopy 

func (in *TriggersStatus) DeepCopy() *TriggersStatus

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

func (*TriggersStatus) DeepCopyInto 

func (in *TriggersStatus) DeepCopyInto(out *TriggersStatus)

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

func (TriggersStatus) Equals 

func (ts TriggersStatus) Equals(other TriggersStatus) bool

type ValueFrom 

type ValueFrom struct {
	RunConfigurationRef RunConfigurationRef `json:"runConfigurationRef"`
}

func (*ValueFrom) DeepCopy 

func (in *ValueFrom) DeepCopy() *ValueFrom

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

func (*ValueFrom) DeepCopyInto 

func (in *ValueFrom) DeepCopyInto(out *ValueFrom)

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.