engine

type DAGStoreFactory func(context.Context, *config.Config, DAGStoreFactoryOptions) (exec.DAGStore, error)

type DAGStoreFactoryOptions struct {
	SearchPaths []string
}

type DistributedOptions struct {
	Coordinators    []string
	TLS             TLSOptions
	WorkerSelector  map[string]string
	PollInterval    time.Duration
	MaxStatusErrors int
}

type Engine struct {
	// contains filtered or unexported fields
}

type ExecutionMode string

type Options struct {
	HomeDir     string
	ConfigFile  string
	DAGsDir     string
	DataDir     string
	LogDir      string
	ArtifactDir string
	BaseConfig  string
	Logger      *slog.Logger

	Persistence        Persistence
	PersistenceFactory PersistenceFactory
	RunStateStore      runstate.Store
	DAGRunStore        coreexec.DAGRunStore
	DefaultMode        ExecutionMode
	Distributed        *DistributedOptions
}

type Persistence struct {
	DAGStore             exec.DAGStore
	DAGRunStore          exec.DAGRunStore
	RunStateStore        runstate.Store
	ProcStore            exec.ProcStore
	StateStore           dagstate.Store
	ServiceRegistry      exec.ServiceRegistry
	DAGStoreFactory      DAGStoreFactory
	RuntimeStoresFactory RuntimeStoresFactory
}

type PersistenceFactory func(context.Context, *config.Config) (Persistence, error)

type Run struct {
	// contains filtered or unexported fields
}

type RunOptions struct {
	RunID             string
	Name              string
	Params            map[string]string
	ParamsList        []string
	DefaultWorkingDir string
	Mode              ExecutionMode
	WorkerSelector    map[string]string
	Labels            []string
	DryRun            bool
}

type RunRef struct {
	Name string
	ID   string
}

type RuntimeStores struct {
	SecretStore  secret.Store
	ProfileStore profile.Store
}

type RuntimeStoresFactory func(context.Context, *config.Config) RuntimeStores

type Status struct {
	Name        string
	RunID       string
	AttemptID   string
	Status      string
	StartedAt   time.Time
	FinishedAt  time.Time
	Error       string
	LogFile     string
	ArchiveDir  string
	WorkerID    string
	TriggerType string
}

type TLSOptions struct {
	Insecure      bool
	CertFile      string
	KeyFile       string
	ClientCAFile  string
	SkipTLSVerify bool
}

type Worker struct {
	// contains filtered or unexported fields
}

type WorkerOptions struct {
	ID            string
	MaxActiveRuns int
	Labels        map[string]string
	Coordinators  []string
	TLS           TLSOptions
	HealthPort    int
}