models

type Config struct {
	External       ExternalConfig       `yaml:"external"`
	Transformation TransformationConfig `yaml:"transformations"`
}

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
	GetDependencies(id string) []string

	// 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
	GetValue() string
	SetDefaultDatabase(defaultDB string)
}

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

type ExternalType string

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

type Node struct {
	NodeType NodeType
	Model    interface{}
}

type NodeType string

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
	GetValue() string
	SetDefaultDatabase(defaultDB string)
}

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

type TransformationType string