Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

v1alpha5

package

Go to main page

Versions in this module

v0

v0.6.0

May 20, 2024

v0.5.0

Mar 14, 2024

v0.4.1

Feb 28, 2024

Changes in this version

type RunConfigurationStatus

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

v0.4.0

Sep 4, 2023

Changes in this version

+ const ArtifactPathPattern

+ var AddToScheme = SchemeBuilder.AddToScheme

+ var CompletionStates = struct{ ... }

+ var ConditionTypes = struct{ ... }

+ var GroupVersion = schema.GroupVersion

+ var OnChangeTypes = struct{ ... }

+ var SchemeBuilder = &scheme.Builder

+ func ConditionStatusForSynchronizationState(state apis.SynchronizationState) metav1.ConditionStatus

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

+ type ArtifactLocator struct

+ Artifact string

+ Component string

+ Index int

+ func (ap *ArtifactLocator) String() string

+ func (in *ArtifactLocator) DeepCopy() *ArtifactLocator

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

+ type ArtifactPath struct

+ Filter string

+ Locator ArtifactLocator

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

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

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

+ func (ap ArtifactPath) String() string

+ func (in *ArtifactPath) DeepCopy() *ArtifactPath

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

+ type CompletionState string

+ type Conditions []metav1.Condition

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

+ func (conditions Conditions) SynchronizationSucceeded() metav1.Condition

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

+ func (in Conditions) DeepCopy() Conditions

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

+ type Dependencies struct

+ RunConfigurations map[string]RunReference

+ func (in *Dependencies) DeepCopy() *Dependencies

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

+ type Experiment struct

+ Spec ExperimentSpec

+ Status Status

+ func (*Experiment) Hub()

+ func (e *Experiment) GetProvider() string

+ func (e *Experiment) GetStatus() Status

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

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

+ func (e Experiment) GetKind() string

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

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

+ func (es Experiment) ComputeVersion() string

+ 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 (in *ExperimentSpec) DeepCopy() *ExperimentSpec

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

+ type HasProvider interface

+ GetProvider func() string

+ type LatestRuns struct

+ Succeeded RunReference

+ func (in *LatestRuns) DeepCopy() *LatestRuns

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

+ type OnChangeType string

+ type OutputArtifact struct

+ Name string

+ Path ArtifactPath

+ func (in *OutputArtifact) DeepCopy() *OutputArtifact

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

+ func (oa OutputArtifact) GetKey() string

+ func (oa OutputArtifact) GetValue() string

+ type Pipeline struct

+ Spec PipelineSpec

+ Status Status

+ func (*Pipeline) Hub()

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

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

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

+ func (p *Pipeline) GetProvider() string

+ func (p *Pipeline) GetStatus() Status

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

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

+ func (p Pipeline) GetKind() string

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

+ func (pipeline *Pipeline) UnversionedIdentifier() PipelineIdentifier

+ func (pipeline *Pipeline) VersionedIdentifier() PipelineIdentifier

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

+ func (ps Pipeline) ComputeVersion() string

+ type PipelineIdentifier struct

+ Name string

+ Version string

+ func (in *PipelineIdentifier) DeepCopy() *PipelineIdentifier

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

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

+ func (pid *PipelineIdentifier) String() string

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

+ 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

+ BeamArgs []apis.NamedValue

+ Env []apis.NamedValue

+ Image string

+ TfxComponents string

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

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

+ type ProviderAndId struct

+ Id string

+ Provider string

+ func (in *ProviderAndId) DeepCopy() *ProviderAndId

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

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

+ func (pid *ProviderAndId) String() string

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

+ type Resource interface

+ ComputeVersion func() string

+ GetKind func() string

+ GetNamespacedName func() types.NamespacedName

+ GetStatus func() Status

+ SetStatus func(Status)

+ type Run struct

+ Spec RunSpec

+ Status RunStatus

+ func (*Run) Hub()

+ func (in *Run) DeepCopy() *Run

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

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

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

+ func (r *Run) GetKind() string

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

+ func (r *Run) GetObservedPipelineVersion() string

+ func (r *Run) GetPipeline() PipelineIdentifier

+ func (r *Run) GetProvider() string

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

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

+ func (r *Run) GetStatus() Status

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

+ func (r *Run) SetObservedPipelineVersion(newVersion string)

+ func (r *Run) SetStatus(status Status)

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

+ func (r *Run) ValidateCreate() error

+ func (r *Run) ValidateDelete() error

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

+ func (r Run) ComputeHash() []byte

+ func (r Run) ComputeVersion() string

+ type RunConfiguration struct

+ Spec RunConfigurationSpec

+ Status RunConfigurationStatus

+ func (*RunConfiguration) Hub()

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

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

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

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

+ func (rc *RunConfiguration) GetKind() string

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

+ func (rc *RunConfiguration) GetObservedPipelineVersion() string

+ func (rc *RunConfiguration) GetPipeline() PipelineIdentifier

+ func (rc *RunConfiguration) GetProvider() string

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

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

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

+ func (rc *RunConfiguration) SetObservedPipelineVersion(observedPipelineVersion string)

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

+ func (rc *RunConfiguration) ValidateCreate() error

+ func (rc *RunConfiguration) ValidateDelete() error

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

+ type RunConfigurationConversionRemainder struct

+ Triggers Triggers

+ func (in *RunConfigurationConversionRemainder) DeepCopy() *RunConfigurationConversionRemainder

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

+ func (rcr RunConfigurationConversionRemainder) Empty() bool

+ type RunConfigurationList struct

+ Items []RunConfiguration

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

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

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

+ type RunConfigurationRef struct

+ Name string

+ OutputArtifact string

+ func (in *RunConfigurationRef) DeepCopy() *RunConfigurationRef

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

+ type RunConfigurationSpec struct

+ Run RunSpec

+ Triggers Triggers

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

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

+ type RunConfigurationStatus struct

+ Conditions Conditions

+ Dependencies Dependencies

+ LatestRuns LatestRuns

+ ObservedGeneration int64

+ ObservedPipelineVersion string

+ Provider string

+ SynchronizationState apis.SynchronizationState

+ TriggeredPipelineVersion string

+ Triggers TriggersStatus

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

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

+ type RunConversionRemainder struct

+ Artifacts []OutputArtifact

+ ValueFromParameters []RuntimeParameter

+ func (in *RunConversionRemainder) DeepCopy() *RunConversionRemainder

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

+ func (rcr RunConversionRemainder) ConversionAnnotation() string

+ func (rcr RunConversionRemainder) Empty() bool

+ type RunList struct

+ Items []Run

+ func (in *RunList) DeepCopy() *RunList

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

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

+ type RunReference struct

+ Artifacts []common.Artifact

+ ProviderId string

+ func (in *RunReference) DeepCopy() *RunReference

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

+ type RunSchedule struct

+ Spec RunScheduleSpec

+ Status Status

+ func (*RunSchedule) Hub()

+ func (in *RunSchedule) DeepCopy() *RunSchedule

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

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

+ func (rs *RunSchedule) GetKind() string

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

+ func (rs *RunSchedule) GetPipeline() PipelineIdentifier

+ func (rs *RunSchedule) GetProvider() string

+ func (rs *RunSchedule) GetStatus() Status

+ func (rs *RunSchedule) SetStatus(status Status)

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

+ func (rs RunSchedule) ComputeHash() []byte

+ func (rs RunSchedule) ComputeVersion() string

+ type RunScheduleList struct

+ Items []RunSchedule

+ func (in *RunScheduleList) DeepCopy() *RunScheduleList

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

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

+ type RunScheduleSpec struct

+ Artifacts []OutputArtifact

+ ExperimentName string

+ Pipeline PipelineIdentifier

+ RuntimeParameters []apis.NamedValue

+ Schedule string

+ func (in *RunScheduleSpec) DeepCopy() *RunScheduleSpec

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

+ type RunSpec struct

+ Artifacts []OutputArtifact

+ ExperimentName string

+ Pipeline PipelineIdentifier

+ RuntimeParameters []RuntimeParameter

+ func (in *RunSpec) DeepCopy() *RunSpec

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

+ func (rs RunSpec) ComputeVersion() string

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

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

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

+ type RunSpecTriggerStatus struct

+ Version string

+ func (in *RunSpecTriggerStatus) DeepCopy() *RunSpecTriggerStatus

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

+ type RunStatus struct

+ CompletionState CompletionState

+ Dependencies Dependencies

+ MarkedCompletedAt *metav1.Time

+ ObservedPipelineVersion string

+ func (in *RunStatus) DeepCopy() *RunStatus

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

+ type RuntimeParameter struct

+ Name string

+ Value string

+ ValueFrom *ValueFrom

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

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

+ func (in *RuntimeParameter) DeepCopy() *RuntimeParameter

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

+ type Status struct

+ Conditions Conditions

+ ObservedGeneration int64

+ ProviderId ProviderAndId

+ SynchronizationState apis.SynchronizationState

+ Version string

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

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

+ type TriggeredRunReference struct

+ ProviderId string

+ func (in *TriggeredRunReference) DeepCopy() *TriggeredRunReference

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

+ type Triggers struct

+ OnChange []OnChangeType

+ RunConfigurations []string

+ Schedules []string

+ func (in *Triggers) DeepCopy() *Triggers

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

+ type TriggersStatus struct

+ RunConfigurations map[string]TriggeredRunReference

+ RunSpec RunSpecTriggerStatus

+ func (in *TriggersStatus) DeepCopy() *TriggersStatus

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

+ func (ts TriggersStatus) Equals(other TriggersStatus) bool

+ type ValueFrom struct

+ RunConfigurationRef RunConfigurationRef

+ func (in *ValueFrom) DeepCopy() *ValueFrom

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