27 references to Chunk
aspire (1)
Documentation\ApiDocs\ApiDocsIndexService.cs (1)
493
foreach (var candidateContainerIds in GetCandidateMemberContainerIds(routeResults, queryTokens, normalizedLanguage).
Chunk
(MemberSearchBatchSize))
Aspire.Cli.Tests (1)
Agents\TelemetryHookScriptTests.cs (1)
549
static KeyValuePair<string, string>[] Tags(string[] args) => args.Skip(2).
Chunk
(2)
Aspire.Dashboard (23)
Otlp\Storage\SqliteTelemetryRepository.Caching.cs (1)
364
foreach (var batch in pendingMetrics.Take(availableCount).
Chunk
(MaxInstrumentBatchSize))
Otlp\Storage\SqliteTelemetryRepository.Logs.cs (2)
170
foreach (var batch in resourcesToUpdate.
Chunk
(MaxLogAttributeBatchSize))
680
foreach (var logIdBatch in logIds.
Chunk
(MaxLogAttributeReadBatchSize))
Otlp\Storage\SqliteTelemetryRepository.Metrics.Reads.cs (1)
473
foreach (var exemplarIdBatch in exemplarIds.
Chunk
(MaxMetricReadBatchSize))
Otlp\Storage\SqliteTelemetryRepository.Metrics.Writes.cs (3)
320
foreach (var updates in pointBatch.Updates.Values.
Chunk
(MaxMetricPointBatchSize))
676
foreach (var batch in exemplars.Values.
Chunk
(MaxMetricPointBatchSize))
736
foreach (var batch in dimensions.
Chunk
(MaxMetricPointBatchSize))
Otlp\Storage\SqliteTelemetryRepository.Resources.cs (1)
57
foreach (var traceBatch in affectedTraceIds.
Chunk
(MaxTraceBatchSize))
Otlp\Storage\SqliteTelemetryRepository.Runtime.cs (2)
347
foreach (var identityBatch in spanIdentities.
Chunk
(MaxSpanDetailBatchSize))
384
foreach (var logIdBatch in logIds.
Chunk
(MaxLogAttributeReadBatchSize))
Otlp\Storage\SqliteTelemetryRepository.Traces.Reads.cs (3)
40
foreach (var batch in records.
Chunk
(MaxTraceBatchSize))
746
foreach (var eventIdBatch in eventRecords.Select(record => record.EventId).
Chunk
(MaxSpanDetailBatchSize))
770
foreach (var linkIdBatch in linkRecords.Select(record => record.LinkId).
Chunk
(MaxSpanDetailBatchSize))
Otlp\Storage\SqliteTelemetryRepository.Traces.Writes.cs (10)
138
foreach (var batch in traceIds.
Chunk
(MaxTraceBatchSize))
186
foreach (var traceBatch in existingTraces.Keys.
Chunk
(MaxTraceBatchSize))
197
foreach (var spanIdBatch in relevantSpanIds.
Chunk
(MaxSpanDetailBatchSize))
220
.
Chunk
(MaxSpanDetailBatchSize))
242
.
Chunk
(MaxSpanDetailBatchSize))
361
.
Chunk
(MaxTraceBatchSize))
527
foreach (var batch in resourcesToUpdate.
Chunk
(MaxTraceBatchSize))
613
foreach (var batch in spanUpdates.
Chunk
(MaxSpanDetailBatchSize))
699
foreach (var deltaBatch in deltas.
Chunk
(MaxSpanDetailBatchSize))
723
foreach (var deltaBatch in deltas.
Chunk
(MaxSpanDetailBatchSize))
Aspire.Hosting.Tests (1)
Terminals\Hex1bAspireTerminalTests.cs (1)
376
Assert.Equal(string.Join('\n', main.
Chunk
(20).Select(chunk => new string(chunk).PadRight(20)).Append("ready")),
Microsoft.CodeAnalysis.Workspaces (1)
Workspace\Solution\SolutionCompilationState.RegularCompilationTracker.cs (1)
327
foreach (var chunk in this.ProjectState.DocumentStates.GetStatesInCompilationOrder().
Chunk
(TranslationAction.AddDocumentsAction.AddDocumentsBatchSize))