BuildPipeline creates a Pipeline from its configuration.

LoadPipelineConfig loads pipeline configuration from a file.

NewCoreEngine creates the engine by loading plugins and pipelines.

NewPluginManager creates a new plugin manager.

NewPluginRegistry creates a new plugin registry.

RegisterSchemas registers plugin schemas with the schema registry.

CoreEngine holds pipelines and provides a production interface.

InstanceConfig holds configuration for a Flow instance.

Pipeline represents a configured data processing pipeline.

PipelineConfig holds the configuration for all pipelines.

PipelineDefinition defines a single pipeline.

PluginManager manages loading and initializing plugins.

PluginRegistry holds references to all loaded plugins.