Class PipelineExecutionService

Namespace

FoundationaLLM.Vectorization.Services.Pipelines

Assembly

FoundationaLLM.Vectorization.Engine.dll

Executes active vectorization data pipelines.

public class PipelineExecutionService : IPipelineExecutionService

Inheritance

object

PipelineExecutionService

Implements

IPipelineExecutionService

Inherited Members

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Extension Methods

ObjectExtensions.GetPropertyValues(object, List<string>)

Constructors

PipelineExecutionService(IOptions<InstanceSettings>, IConfiguration, IServiceProvider, IEnumerable<IResourceProviderService>, ILoggerFactory, ILogger<PipelineExecutionService>)

Executes active vectorization data pipelines.

public PipelineExecutionService(IOptions<InstanceSettings> instanceOptions, IConfiguration configuration, IServiceProvider serviceProvider, IEnumerable<IResourceProviderService> resourceProviderServices, ILoggerFactory loggerFactory, ILogger<PipelineExecutionService> logger)

Parameters

instanceOptions IOptions<InstanceSettings>

The IOptions<TOptions> value providing InstanceSettings settings.

configuration IConfiguration

The global configuration provider.

serviceProvider IServiceProvider

The IServiceProvider providing dependency injection services..

resourceProviderServices IEnumerable<IResourceProviderService>

The list of resurce providers registered with the main dependency injection container.

loggerFactory ILoggerFactory

Factory responsible for creating loggers.

logger ILogger<PipelineExecutionService>

The ILogger used for logging.

Methods

ExecuteAsync(CancellationToken)

Executes the pipeline execution service until cancellation is signaled.

public Task ExecuteAsync(CancellationToken cancellationToken)

Parameters

cancellationToken CancellationToken

The CancellationToken signaling cancellation.

Returns

Task

StopAsync(CancellationToken)

Stops the pipeline execution service, allowing it to cleanup.

public Task StopAsync(CancellationToken cancellationToken)

Parameters

cancellationToken CancellationToken

The CancellationToken signaling cancellation.

Returns

Task