Documentation ¶
Index ¶
- Constants
- Variables
- func CreateK8sClient() (dynamic.Interface, error)
- func LoadJsonFromFile[T any](fileName string) (T, error)
- func LoadYamlFromFile[T any](fileName string) (T, error)
- type CronSchedule
- type ExperimentDefinition
- type K8sApi
- type Output
- type PipelineDefinition
- type Provider
- type ProviderApp
- type RunDefinition
- type RunScheduleDefinition
Constants ¶
View Source
const GoNumFields = 6
View Source
const OutputSeparator = " "
View Source
const StdNumFields = 5
Variables ¶
View Source
var FieldMatcher = regexp.MustCompile(`\S+`)
View Source
var ProviderConstants = struct { PipelineDefinitionParameter string ExperimentDefinitionParameter string RunDefinitionParameter string RunScheduleDefinitionParameter string ProviderConfigParameter string PipelineIdParameter string ExperimentIdParameter string RunScheduleIdParameter string RunIdParameter string PipelineFileParameter string OutputParameter string EventsourceServerPortParameter string }{ PipelineDefinitionParameter: "pipeline-definition", ExperimentDefinitionParameter: "experiment-definition", RunDefinitionParameter: "run-definition", RunScheduleDefinitionParameter: "runschedule-definition", ProviderConfigParameter: "provider-config", PipelineIdParameter: "pipeline-id", ExperimentIdParameter: "experiment-id", RunIdParameter: "run-id", RunScheduleIdParameter: "runschedule-id", PipelineFileParameter: "pipeline-file", OutputParameter: "out", EventsourceServerPortParameter: "port", }
View Source
var RunConfigurationGVR = pipelinesv1.GroupVersion.WithResource("runconfigurations")
View Source
var RunGVR = pipelinesv1.GroupVersion.WithResource("runs")
Functions ¶
func CreateK8sClient ¶
func LoadJsonFromFile ¶
func LoadYamlFromFile ¶
Types ¶
type CronSchedule ¶
type CronSchedule struct {
// contains filtered or unexported fields
}
func ParseCron ¶
func ParseCron(schedule string) (CronSchedule, error)
func (CronSchedule) PrintGo ¶
func (cs CronSchedule) PrintGo() string
func (CronSchedule) PrintStandard ¶
func (cs CronSchedule) PrintStandard() string
type ExperimentDefinition ¶
type K8sApi ¶
func (K8sApi) GetRunArtifactDefinitions ¶
func (k8a K8sApi) GetRunArtifactDefinitions(ctx context.Context, namespacedName types.NamespacedName, gvr schema.GroupVersionResource) ([]pipelinesv1.OutputArtifact, error)
type PipelineDefinition ¶
type PipelineDefinition struct { Name string `yaml:"name"` Version string `yaml:"version"` Image string `yaml:"image"` TfxComponents string `yaml:"tfxComponents"` Env []apis.NamedValue `yaml:"env"` BeamArgs []apis.NamedValue `yaml:"beamArgs"` }
type Provider ¶
type Provider[Config any] interface { CreatePipeline(ctx context.Context, providerConfig Config, pipelineDefinition PipelineDefinition, pipelineFile string) (string, error) UpdatePipeline(ctx context.Context, providerConfig Config, pipelineDefinition PipelineDefinition, id string, pipelineFile string) (string, error) DeletePipeline(ctx context.Context, providerConfig Config, id string) error CreateRun(ctx context.Context, providerConfig Config, runConfigurationDefinition RunDefinition) (string, error) DeleteRun(ctx context.Context, providerConfig Config, id string) error CreateRunSchedule(ctx context.Context, providerConfig Config, runScheduleDefinition RunScheduleDefinition) (string, error) UpdateRunSchedule(ctx context.Context, providerConfig Config, runScheduleDefinition RunScheduleDefinition, id string) (string, error) DeleteRunSchedule(ctx context.Context, providerConfig Config, id string) error CreateExperiment(ctx context.Context, providerConfig Config, experimentDefinition ExperimentDefinition) (string, error) UpdateExperiment(ctx context.Context, providerConfig Config, experimentDefinition ExperimentDefinition, id string) (string, error) DeleteExperiment(ctx context.Context, providerConfig Config, id string) error EventingServer(ctx context.Context, providerConfig Config) (generic.EventingServer, error) }
type ProviderApp ¶
func NewProviderApp ¶
func NewProviderApp[Config any]() ProviderApp[Config]
func (ProviderApp[Config]) LoadProviderConfig ¶
func (_ ProviderApp[Config]) LoadProviderConfig(c *cli.Context) (Config, error)
type RunDefinition ¶
type RunDefinition struct { Name common.NamespacedName `yaml:"name"` Version string `yaml:"version"` PipelineName common.NamespacedName `yaml:"pipelineName"` PipelineVersion string `yaml:"pipelineVersion"` RunConfigurationName common.NamespacedName `yaml:"runConfigurationName"` ExperimentName string `yaml:"experimentName"` RuntimeParameters map[string]string `yaml:"runtimeParameters"` Artifacts []pipelines.OutputArtifact `yaml:"artifacts,omitempty"` }
type RunScheduleDefinition ¶
type RunScheduleDefinition struct { Name string `yaml:"name"` Version string `yaml:"version"` PipelineName common.NamespacedName `yaml:"pipelineName"` PipelineVersion string `yaml:"pipelineVersion"` RunConfigurationName common.NamespacedName `yaml:"runConfigurationName"` ExperimentName string `yaml:"experimentName"` Schedule string `yaml:"schedule"` RuntimeParameters map[string]string `yaml:"runtimeParameters"` Artifacts []pipelines.OutputArtifact `yaml:"artifacts,omitempty"` }
Click to show internal directories.
Click to hide internal directories.