dagsettings

package
v2.11.3 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Aug 2, 2026 License: GPL-3.0 Imports: 7 Imported by: 0

Documentation

Overview

Package dagsettings contains server-side DAG settings.

Index

Constants

This section is empty.

Variables

View Source
var (
	ErrInvalidDAGName = errors.New("invalid DAG name")
	ErrNotFound       = errors.New("DAG settings not found")
)
View Source
var ErrProfileStoreUnavailable = errors.New("runtime profile store is not configured")

ErrProfileStoreUnavailable means a selected runtime profile cannot be checked.

Functions

func ResolveProfile

func ResolveProfile(
	ctx context.Context,
	settingsStore Store,
	profileStore profile.Store,
	dagName string,
	workspaceName string,
) (string, error)

func ValidateDAGName

func ValidateDAGName(name string) error

Types

type ProfileReferenceError

type ProfileReferenceError struct {
	Name string
	Err  error
}

func (*ProfileReferenceError) Error

func (e *ProfileReferenceError) Error() string

func (*ProfileReferenceError) Unwrap

func (e *ProfileReferenceError) Unwrap() error

type Settings

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

func New

func New(input UpdateInput, now time.Time) (*Settings, error)

func (*Settings) ApplyUpdate

func (s *Settings) ApplyUpdate(input UpdateInput, now time.Time) error

func (*Settings) Clone

func (s *Settings) Clone() *Settings

type Store

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

type UpdateInput struct {
	DAGName   string
	Profile   string
	UpdatedBy string
}

Jump to

Keyboard shortcuts

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