IntelligenceX

API Reference

Class

UsageTelemetryImportCoordinator

Edit on GitHub
Namespace IntelligenceX.Telemetry.Usage
Assembly IntelligenceX
Source UsageTelemetryImportCoordinator.cs:81
Modifiers sealed

Coordinates source-root registration, discovery, and adapter-driven imports.

Inheritance

  • Object
  • UsageTelemetryImportCoordinator

Constructors

public UsageTelemetryImportCoordinator(ISourceRootStore sourceRootStore, IUsageEventStore usageEventStore, UsageTelemetryProviderRegistry registry, IEnumerable<IUsageTelemetryRootDiscovery>? rootDiscoveries = null) #
UsageTelemetryImportCoordinator.cs:81

Initializes a new import coordinator.

Parameters

sourceRootStore IntelligenceX.Telemetry.Usage.ISourceRootStore requiredposition: 0
usageEventStore IntelligenceX.Telemetry.Usage.IUsageEventStore requiredposition: 1
registry IntelligenceX.Telemetry.Usage.UsageTelemetryProviderRegistry requiredposition: 2
rootDiscoveries System.Collections.Generic.IEnumerable<IntelligenceX.Telemetry.Usage.IUsageTelemetryRootDiscovery>? = null optionalposition: 3

Methods

public Task<IReadOnlyList<SourceRootRecord>> DiscoverRootsAsync(String? providerId = null, CancellationToken cancellationToken = default) #
UsageTelemetryImportCoordinator.cs:126
Returns: Task<IReadOnlyList<SourceRootRecord>>

Discovers and registers default source roots.

Parameters

providerId System.String? = null optionalposition: 0
cancellationToken System.Threading.CancellationToken = default optionalposition: 1
public async Task<UsageImportBatchResult> ImportAllAsync(UsageImportContext? context = null, String? providerId = null, CancellationToken cancellationToken = default) #
Returns: Task<UsageImportBatchResult>

Imports all enabled roots currently registered in the source-root store.

Parameters

context IntelligenceX.Telemetry.Usage.UsageImportContext? = null optionalposition: 0
providerId System.String? = null optionalposition: 1
cancellationToken System.Threading.CancellationToken = default optionalposition: 2
ImportRootAsync 2 overloads
public Task<UsageImportRootResult> ImportRootAsync(String rootId, UsageImportContext? context = null, CancellationToken cancellationToken = default) #
UsageTelemetryImportCoordinator.cs:193
Returns: Task<UsageImportRootResult>

Imports a registered source root by id.

Parameters

rootId System.String requiredposition: 0
context IntelligenceX.Telemetry.Usage.UsageImportContext? = null optionalposition: 1
cancellationToken System.Threading.CancellationToken = default optionalposition: 2
public async Task<UsageImportRootResult> ImportRootAsync(SourceRootRecord root, UsageImportContext? context = null, CancellationToken cancellationToken = default) #
Returns: Task<UsageImportRootResult>

Imports a specific source root instance.

Parameters

root IntelligenceX.Telemetry.Usage.SourceRootRecord requiredposition: 0
context IntelligenceX.Telemetry.Usage.UsageImportContext? = null optionalposition: 1
cancellationToken System.Threading.CancellationToken = default optionalposition: 2
public SourceRootRecord RegisterRoot(String providerId, UsageSourceKind sourceKind, String path, String? platformHint = null, String? machineLabel = null, String? accountHint = null, Boolean enabled = true) #
UsageTelemetryImportCoordinator.cs:105
Returns: SourceRootRecord

Registers or updates a source root.

Parameters

providerId System.String requiredposition: 0
sourceKind IntelligenceX.Telemetry.Usage.UsageSourceKind requiredposition: 1
path System.String requiredposition: 2
platformHint System.String? = null optionalposition: 3
machineLabel System.String? = null optionalposition: 4
accountHint System.String? = null optionalposition: 5
enabled System.Boolean = true optionalposition: 6