IntelligenceX

API Reference

Class

UsageTelemetryImportCoordinator

Edit on GitHub
Namespace IntelligenceX.Telemetry.Usage
Assembly IntelligenceX
Source IntelligenceX/Telemetry/Usage/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) #
IntelligenceX/Telemetry/Usage/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 = null) #
IntelligenceX/Telemetry/Usage/UsageTelemetryImportCoordinator.cs:126
Returns: Task<IReadOnlyList<SourceRootRecord>>

Discovers and registers default source roots.

Parameters

providerId System.String = null optionalposition: 0
cancellationToken System.Threading.CancellationToken = null optionalposition: 1
public async Task<UsageImportBatchResult> ImportAllAsync(UsageImportContext context = null, String providerId = null, CancellationToken cancellationToken = null) #
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 = null optionalposition: 2
ImportRootAsync 2 overloads
public async Task<UsageImportRootResult> ImportRootAsync(SourceRootRecord root, UsageImportContext context = null, CancellationToken cancellationToken = null) #
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 = null optionalposition: 2
ImportRootAsync(IntelligenceX.Telemetry.Usage.SourceRootRecord root, IntelligenceX.Telemetry.Usage.UsageImportContext context, System.Threading.CancellationToken cancellationToken) #

Imports a specific source root instance.

Parameters

root IntelligenceX.Telemetry.Usage.SourceRootRecord required
context IntelligenceX.Telemetry.Usage.UsageImportContext required
cancellationToken System.Threading.CancellationToken required
public SourceRootRecord RegisterRoot(String providerId, UsageSourceKind sourceKind, String path, String platformHint = null, String machineLabel = null, String accountHint = null, Boolean enabled = true) #
IntelligenceX/Telemetry/Usage/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