models

type CacheOverride struct {
	IncrementalScanInterval *time.Duration `yaml:"incremental_scan_interval,omitempty"`
	FullScanInterval        *time.Duration `yaml:"full_scan_interval,omitempty"`
}

type Config struct {
	External       ExternalConfig            `yaml:"external"`
	Transformation TransformationConfig      `yaml:"transformations"`
	Overrides      map[string]*ModelOverride `yaml:"overrides,omitempty"`
	Env            map[string]string         `yaml:"env,omitempty"`
}

type DAGReader interface {
	// GetNode retrieves a node by its ID
	GetNode(id string) (Node, error)

	// GetTransformationNode retrieves a transformation node by its ID
	GetTransformationNode(id string) (Transformation, error)

	// GetExternalNode retrieves an external node by its ID
	GetExternalNode(id string) (External, error)

	// GetDependencies returns direct dependencies of a node (flattened)
	GetDependencies(id string) []string

	// GetStructuredDependencies returns direct dependencies preserving OR groups
	GetStructuredDependencies(id string) []transformation.Dependency

	// GetDependents returns nodes that depend on the given node
	GetDependents(id string) []string

	// GetAllDependencies returns all transitive dependencies
	GetAllDependencies(id string) []string

	// GetAllDependents returns all transitive dependents
	GetAllDependents(id string) []string

	// GetTransformationNodes returns all transformation nodes
	GetTransformationNodes() []Transformation

	// GetExternalNodes returns all external nodes
	GetExternalNodes() []Node

	// IsPathBetween checks if there's a path between two nodes
	IsPathBetween(from, to string) bool
}

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

type External interface {
	GetType() string
	GetID() string
	GetConfig() external.Config
	GetConfigMutable() *external.Config
	GetValue() string
	SetDefaults(defaultCluster, defaultDB string)
}

type ExternalConfig struct {
	Paths           []string `yaml:"paths"`
	DefaultCluster  string   `yaml:"defaultCluster"`
	DefaultDatabase string   `yaml:"defaultDatabase"`
}

type ExternalOverride struct {
	Lag   *uint64        `yaml:"lag,omitempty"`
	Cache *CacheOverride `yaml:"cache,omitempty"`
}

type ExternalType string

type IntervalOverride struct {
	Max *uint64 `yaml:"max,omitempty"`
	Min *uint64 `yaml:"min,omitempty"`
}

type LimitsOverride struct {
	Min *uint64 `yaml:"min,omitempty"`
	Max *uint64 `yaml:"max,omitempty"`
}

type ModelFile struct {
	FilePath  string
	Extension string
	Content   []byte
}

type ModelOverride struct {
	Enabled *bool

	Config OverrideConfig
	// contains filtered or unexported fields
}

type ModelType string

type Node struct {
	NodeType NodeType
	Model    interface{}
}

type NodeType string

type OverrideConfig interface {
	// contains filtered or unexported methods
}

type SchedulesOverride struct {
	ForwardFill *string `yaml:"forwardfill"`
	Backfill    *string `yaml:"backfill"`
}

type Service interface {
	// Lifecycle methods
	Start() error
	Stop() error

	// DAG operations
	GetDAG() DAGReader

	// Rendering operations
	RenderTransformation(model Transformation, position, interval uint64, startTime time.Time) (string, error)
	RenderExternal(model External, cacheState map[string]interface{}) (string, error)
	GetTransformationEnvironmentVariables(model Transformation, position, interval uint64, startTime time.Time) (*[]string, error)
}

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

type Transformation interface {
	GetType() string
	GetID() string
	GetConfig() *transformation.Config
	GetHandler() transformation.Handler
	GetValue() string
	SetDefaultDatabase(defaultDB string)
}

type TransformationConfig struct {
	Paths           []string `yaml:"paths"`
	DefaultDatabase string   `yaml:"defaultDatabase"`
}

type TransformationOverride struct {
	// Incremental transformation fields
	Interval  *IntervalOverride  `yaml:"interval,omitempty"`
	Schedules *SchedulesOverride `yaml:"schedules,omitempty"`
	Limits    *LimitsOverride    `yaml:"limits,omitempty"`

	// Scheduled transformation fields
	Schedule *string `yaml:"schedule,omitempty"`

	// Common fields (both types)
	Tags []string `yaml:"tags,omitempty"`
}

type TransformationType string