engine

type DAGRepositoryFactory func(context.Context, *config.Config, DAGRepositoryFactoryOptions) (*persis.DAGRepository, error)

type DAGRepositoryFactoryOptions 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
	DAGRunRepository   *persis.DAGRunRepository
	DefaultMode        ExecutionMode
	Distributed        *DistributedOptions
}

type Persistence struct {
	DAGRepository        *persis.DAGRepository
	DAGRunRepository     *persis.DAGRunRepository
	RunStateStore        runstate.Store
	ProcRepository       *persis.ProcRepository
	StateStore           dagrun.StateStore
	ServiceRegistry      serviceregistry.ServiceRegistry
	DAGRepositoryFactory DAGRepositoryFactory
	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
	NoReuse           bool
}

type RunRef struct {
	Name string
	ID   string
}

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

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
}