Class PullIngestQueryService
Queries for top crashes and queues them for ingestion.
Inheritance
PullIngestQueryService
Assembly: CrashCABN.PullIngestion.dll
Syntax
public sealed record PullIngestQueryService : IEquatable<PullIngestQueryService>
Constructors
View Source
PullIngestQueryService(IWatsonODataClientFactory, IngestFromFailureService, ILogger<PullIngestQueryService>, ITitleConfigurationFactory, IBugFilerFactories, IQueueTitleStorageProvider?, IActivitySource?)
Queries for top crashes and queues them for ingestion.
Declaration
public PullIngestQueryService(IWatsonODataClientFactory WatsonODataClientFactory, IngestFromFailureService IngestFromFailureService, ILogger<PullIngestQueryService> Logger, ITitleConfigurationFactory ConfigFactory, IBugFilerFactories BugFilerFactories, IQueueTitleStorageProvider? Forwarder = null, IActivitySource? ActivitySource = null)
Parameters
Properties
View Source
ActivitySource
Declaration
public IActivitySource? ActivitySource { get; init; }
Property Value
| Type |
Description |
| IActivitySource |
|
View Source
BugFilerFactories
Declaration
public IBugFilerFactories BugFilerFactories { get; init; }
Property Value
View Source
ConfigFactory
Declaration
public ITitleConfigurationFactory ConfigFactory { get; init; }
Property Value
View Source
Forwarder
Declaration
public IQueueTitleStorageProvider? Forwarder { get; init; }
Property Value
View Source
IngestFromFailureService
Declaration
public IngestFromFailureService IngestFromFailureService { get; init; }
Property Value
View Source
Logger
Declaration
public ILogger<PullIngestQueryService> Logger { get; init; }
Property Value
View Source
WatsonODataClientFactory
Declaration
public IWatsonODataClientFactory WatsonODataClientFactory { get; init; }
Property Value
| Type |
Description |
| IWatsonODataClientFactory |
|
Methods
View Source
GetAndForwardFailures<T>(string, Func<TitleConfiguration, PullIngestionConfig, IWatsonODataClient, IBugSearch?, IAsyncEnumerable<T>>, CancellationToken)
Declaration
public IAsyncEnumerable<T> GetAndForwardFailures<T>(string titleName, Func<TitleConfiguration, PullIngestionConfig, IWatsonODataClient, IBugSearch?, IAsyncEnumerable<T>> func, CancellationToken cancellationToken = default)
Parameters
Returns
Type Parameters
View Source
Run(string, string?, CancellationToken)
Grabs the most recent top crashes and prepares to queue them for ingestion.
Declaration
public IAsyncEnumerable<IngestCrashMessage> Run(string titleName, string? invocationID = null, CancellationToken cancellationToken = default)
Parameters
Returns
View Source
ShouldIngest(FailureInfo, string, ApplicationConfig, PullIngestionQuerySettings, IBugSearch, string?, CancellationToken)
Declaration
public ValueTask<CrashAndBugDetails> ShouldIngest(FailureInfo failure, string titleName, ApplicationConfig app, PullIngestionQuerySettings querySettings, IBugSearch bugSearch, string? bucketByTemplate, CancellationToken cancellationToken)
Parameters
Returns
Implements