internal

Documentation

Index

• type Parameters
• type VAILogEntry
• type VAIProvider
  • func (vaip VAIProvider) CreateExperiment(_ context.Context, _ VAIProviderConfig, _ ExperimentDefinition) (string, error)
  • func (vaip VAIProvider) CreatePipeline(ctx context.Context, providerConfig VAIProviderConfig, ...) (string, error)
  • func (vaip VAIProvider) CreateRun(ctx context.Context, providerConfig VAIProviderConfig, ...) (string, error)
  • func (vaip VAIProvider) CreateRunSchedule(ctx context.Context, providerConfig VAIProviderConfig, ...) (string, error)
  • func (vaip VAIProvider) DeleteExperiment(_ context.Context, _ VAIProviderConfig, _ string) error
  • func (vaip VAIProvider) DeletePipeline(ctx context.Context, providerConfig VAIProviderConfig, id string) error
  • func (vaip VAIProvider) DeleteRun(_ context.Context, _ VAIProviderConfig, _ string) error
  • func (vaip VAIProvider) DeleteRunSchedule(ctx context.Context, providerConfig VAIProviderConfig, scheduleId string) error
  • func (vaip VAIProvider) UpdateExperiment(_ context.Context, _ VAIProviderConfig, _ ExperimentDefinition, _ string) (string, error)
  • func (vaip VAIProvider) UpdatePipeline(ctx context.Context, providerConfig VAIProviderConfig, ...) (string, error)
  • func (vaip VAIProvider) UpdateRunSchedule(ctx context.Context, providerConfig VAIProviderConfig, ...) (string, error)
• type VAIProviderConfig
• type VAIResource

Types

type Parameters

type Parameters struct {
	VaiProject                            string `yaml:"vaiProject"`
	VaiLocation                           string `yaml:"vaiLocation"`
	VaiJobServiceAccount                  string `yaml:"vaiJobServiceAccount"`
	GcsEndpoint                           string `yaml:"gcsEndpoint"`
	PipelineBucket                        string `yaml:"pipelineBucket"`
	EventsourcePipelineEventsSubscription string `yaml:"eventsourcePipelineEventsSubscription"`
	MaxConcurrentRunCount                 int64  `yaml:"maxConcurrentRunCount"`
}

type VAILogEntry

type VAILogEntry struct {
	Labels   map[string]string `json:"labels"`
	Resource VAIResource       `json:"resource"`
}

type VAIProvider

type VAIProvider struct {
}

func (VAIProvider) CreateExperiment

func (vaip VAIProvider) CreateExperiment(_ context.Context, _ VAIProviderConfig, _ ExperimentDefinition) (string, error)

func (VAIProvider) CreatePipeline

func (vaip VAIProvider) CreatePipeline(ctx context.Context, providerConfig VAIProviderConfig, pipelineDefinition PipelineDefinition, pipelineFilePath string) (string, error)

func (VAIProvider) CreateRun

func (vaip VAIProvider) CreateRun(ctx context.Context, providerConfig VAIProviderConfig, runDefinition RunDefinition) (string, error)

func (VAIProvider) CreateRunSchedule

func (vaip VAIProvider) CreateRunSchedule(ctx context.Context, providerConfig VAIProviderConfig, runScheduleDefinition RunScheduleDefinition) (string, error)

func (VAIProvider) DeleteExperiment

func (vaip VAIProvider) DeleteExperiment(_ context.Context, _ VAIProviderConfig, _ string) error

func (VAIProvider) DeletePipeline

func (vaip VAIProvider) DeletePipeline(ctx context.Context, providerConfig VAIProviderConfig, id string) error

func (VAIProvider) DeleteRun

func (vaip VAIProvider) DeleteRun(_ context.Context, _ VAIProviderConfig, _ string) error

func (VAIProvider) DeleteRunSchedule

func (vaip VAIProvider) DeleteRunSchedule(ctx context.Context, providerConfig VAIProviderConfig, scheduleId string) error

func (VAIProvider) UpdateExperiment

func (vaip VAIProvider) UpdateExperiment(_ context.Context, _ VAIProviderConfig, _ ExperimentDefinition, _ string) (string, error)

func (VAIProvider) UpdatePipeline

func (vaip VAIProvider) UpdatePipeline(ctx context.Context, providerConfig VAIProviderConfig, pipelineDefinition PipelineDefinition, _ string, pipelineFilePath string) (string, error)

func (VAIProvider) UpdateRunSchedule

func (vaip VAIProvider) UpdateRunSchedule(ctx context.Context, providerConfig VAIProviderConfig, runScheduleDefinition RunScheduleDefinition, scheduleId string) (string, error)

type VAIProviderConfig

type VAIProviderConfig struct {
	Name       string     `yaml:"name"`
	Parameters Parameters `yaml:"parameters"`
}

type VAIResource

type VAIResource struct {
	Labels map[string]string `json:"labels"`
}