v1

package

Go to main page

Versions in this module

v0

v0.1.0

Jul 13, 2022

Changes in this version

type Experiment

+ func (e Experiment) GetKind() string

+ func (e Experiment) GetNamespacedName() types.NamespacedName

type Pipeline

+ func (p Pipeline) GetKind() string

+ func (p Pipeline) GetNamespacedName() types.NamespacedName

type RunConfiguration

+ func (rc RunConfiguration) GetKind() string

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

v0.0.3

Jun 20, 2022

Changes in this version

+ type Experiment struct

+ Spec ExperimentSpec

+ Status Status

+ func (e *Experiment) GetStatus() Status

+ func (e *Experiment) SetStatus(status Status)

+ func (e Experiment) NamespacedName() types.NamespacedName

+ func (in *Experiment) DeepCopy() *Experiment

+ func (in *Experiment) DeepCopyInto(out *Experiment)

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

+ type ExperimentList struct

+ Items []Experiment

+ func (in *ExperimentList) DeepCopy() *ExperimentList

+ func (in *ExperimentList) DeepCopyInto(out *ExperimentList)

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

+ type ExperimentSpec struct

+ Description string

+ func (es ExperimentSpec) ComputeHash() []byte

+ func (es ExperimentSpec) ComputeVersion() string

+ func (in *ExperimentSpec) DeepCopy() *ExperimentSpec

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

type Pipeline

+ func (p *Pipeline) GetStatus() Status

+ func (p *Pipeline) SetStatus(status Status)

type RunConfiguration

+ func (rc *RunConfiguration) GetStatus() Status

+ func (rc *RunConfiguration) SetStatus(status Status)

+ func (rcs RunConfiguration) ComputeHash() []byte

+ func (rcs RunConfiguration) ComputeVersion() string

type RunConfigurationSpec

+ ExperimentName string

+ type RunConfigurationStatus struct

+ ObservedPipelineVersion string

+ func (in *RunConfigurationStatus) DeepCopy() *RunConfigurationStatus

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

type Status

+ ObservedGeneration int64

v0.0.2

Jan 5, 2022

Changes in this version

+ var Annotations = struct{ ... }

+ func AnnotationsFromDebugOptions(ctx context.Context, debugOptions DebugOptions) map[string]string

+ type DebugOptions struct

+ KeepWorkflows bool

+ func DebugOptionsFromAnnotations(ctx context.Context, annotations map[string]string) DebugOptions

+ func (in *DebugOptions) DeepCopy() *DebugOptions

+ func (in *DebugOptions) DeepCopyInto(out *DebugOptions)

+ func (options DebugOptions) WithDefaults(defaults DebugOptions) DebugOptions

type Pipeline

+ func (p Pipeline) NamespacedName() types.NamespacedName

type PipelineSpec

+ BeamArgs map[string]string

+ func (ps PipelineSpec) ComputeHash() []byte

+ func (ps PipelineSpec) ComputeVersion() string

+ type RunConfiguration struct

+ Spec RunConfigurationSpec

+ Status Status

+ func (in *RunConfiguration) DeepCopy() *RunConfiguration

+ func (in *RunConfiguration) DeepCopyInto(out *RunConfiguration)

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

+ func (rc RunConfiguration) NamespacedName() types.NamespacedName

+ type RunConfigurationList struct

+ Items []RunConfiguration

+ func (in *RunConfigurationList) DeepCopy() *RunConfigurationList

+ func (in *RunConfigurationList) DeepCopyInto(out *RunConfigurationList)

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

+ type RunConfigurationSpec struct

+ PipelineName string

+ RuntimeParameters map[string]string

+ Schedule string

+ func (in *RunConfigurationSpec) DeepCopy() *RunConfigurationSpec

+ func (in *RunConfigurationSpec) DeepCopyInto(out *RunConfigurationSpec)

+ func (rcs RunConfigurationSpec) ComputeHash() []byte

+ func (rcs RunConfigurationSpec) ComputeVersion() string

+ type Status struct

+ KfpId string

+ SynchronizationState SynchronizationState

+ Version string

+ func (in *Status) DeepCopy() *Status

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

v0.0.1

Sep 27, 2021

Changes in this version

+ var AddToScheme = SchemeBuilder.AddToScheme

+ var GroupVersion = schema.GroupVersion

+ var SchemeBuilder = &scheme.Builder

+ func ComputeVersion(pipelineSpec PipelineSpec) string

+ type Pipeline struct

+ Spec PipelineSpec

+ Status PipelineStatus

+ func (in *Pipeline) DeepCopy() *Pipeline

+ func (in *Pipeline) DeepCopyInto(out *Pipeline)

+ func (in *Pipeline) DeepCopyObject() runtime.Object

+ type PipelineList struct

+ Items []Pipeline

+ func (in *PipelineList) DeepCopy() *PipelineList

+ func (in *PipelineList) DeepCopyInto(out *PipelineList)

+ func (in *PipelineList) DeepCopyObject() runtime.Object

+ type PipelineSpec struct

+ Env map[string]string

+ Image string

+ TfxComponents string

+ func (in *PipelineSpec) DeepCopy() *PipelineSpec

+ func (in *PipelineSpec) DeepCopyInto(out *PipelineSpec)

+ type PipelineStatus struct

+ Id string

+ SynchronizationState SynchronizationState

+ Version string

+ func (in *PipelineStatus) DeepCopy() *PipelineStatus

+ func (in *PipelineStatus) DeepCopyInto(out *PipelineStatus)

+ type SynchronizationState string

+ const Creating

+ const Deleted

+ const Deleting

+ const Failed

+ const Succeeded

+ const Unknown

+ const Updating

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