Class PipelineManager

Orchestrates the Listener → Store → API → Plugin pipeline. Manages listener lifecycle, schema matching, message routing, and plugin execution.

Hierarchy

EventEmitter
- PipelineManager

Index

Constructors

Accessors

activeListeners isActive

Methods

getPluginLoader loadPlugins registerListener registerPlugin start stop unregisterListener

Constructors

constructor

new PipelineManager(store: Store): PipelineManager
Parameters
- store: Store
Returns PipelineManager
Overrides EventEmitter.constructor
- Defined in packages/core/src/pipeline/PipelineManager.ts:21

Accessors

activeListeners

get activeListeners(): number
Returns number
- Defined in packages/core/src/pipeline/PipelineManager.ts:239

isActive

get isActive(): boolean
Returns boolean
- Defined in packages/core/src/pipeline/PipelineManager.ts:243

Methods

getPluginLoader

getPluginLoader(): PluginLoader
Returns PluginLoader
- Defined in packages/core/src/pipeline/PipelineManager.ts:28

loadPlugins

loadPlugins(sources: string[]): void
Load plugins from config (npm packages or local paths).
Parameters
- sources: string[]
Returns void
- Defined in packages/core/src/pipeline/PipelineManager.ts:35

registerListener

registerListener(listener: IListener): void
Register a listener with the pipeline.
Parameters
- listener: IListener
Returns void
- Defined in packages/core/src/pipeline/PipelineManager.ts:51

registerPlugin

registerPlugin(plugin: LesselPlugin): void
Register a plugin directly.
Parameters
- plugin: LesselPlugin
Returns void
- Defined in packages/core/src/pipeline/PipelineManager.ts:44

start

start(config?: Record<string, unknown>): Promise<void>
Parameters
- config: Record<string, unknown> = {}
Returns Promise<void>
- Defined in packages/core/src/pipeline/PipelineManager.ts:78

stop

stop(): Promise<void>
Stop the pipeline — stops all listeners and plugins.

Returns Promise<void>
- Defined in packages/core/src/pipeline/PipelineManager.ts:116

unregisterListener

unregisterListener(id: string): void
Unregister a listener.
Parameters
- id: string
Returns void
- Defined in packages/core/src/pipeline/PipelineManager.ts:64