dagsettings

type BaseConfigProvider func(workspaceName string) (BaseConfigStore, error)

type BaseConfigStore interface {
	// GetSpec returns the raw YAML content, or an empty string when no configuration exists.
	GetSpec(ctx context.Context) (string, error)
	// UpdateSpec writes the raw YAML content.
	UpdateSpec(ctx context.Context, spec []byte) error
}

type ProfileReferenceError struct {
	Name string
	Err  error
}

type Settings struct {
	DAGName   string
	Profile   string
	CreatedBy string
	CreatedAt time.Time
	UpdatedBy string
	UpdatedAt time.Time
}

type Store interface {
	Get(ctx context.Context, dagName string) (*Settings, error)
	Upsert(ctx context.Context, settings *Settings) error
	Delete(ctx context.Context, dagName string) error
}

type UpdateInput struct {
	DAGName   string
	Profile   string
	UpdatedBy string
}