1 instantiation of LogStreamState
Aspire.Hosting (1)
Dcp\DcpResourceWatcher.cs (1)
611
var logStream = new
LogStreamState
(resource.Metadata.Uid);
13 references to LogStreamState
Aspire.Hosting (13)
Dcp\DcpResourceWatcher.cs (13)
40
private readonly ConcurrentDictionary<string,
LogStreamState
> _logStreams = new();
68
return _logStreams.TryGetValue(resourceName, out
var
logStream) ? logStream.Task : null;
76
return _logStreams.TryGetValue(resourceName, out
var
logStream) &&
399
var
logStream = CancelLogStream(resourceName);
410
private
LogStreamState
? CancelLogStream(string resourceName)
412
if (_logStreams.TryGetValue(resourceName, out
var
logStream))
611
var
logStream = new LogStreamState(resource.Metadata.Uid);
742
if (_logStreams.TryGetValue(resourceName, out
var
logStream) &&
750
private void ObservePendingFollowLogDeduplication(string resourceName,
LogStreamState
logStream)
761
private List<LogEntry> DeduplicateFollowBatch(string resourceName,
LogStreamState
logStream, List<LogEntry> logEntries)
809
private void RemovePendingFollowLogDeduplication(string resourceName,
LogStreamState
logStream)
819
_logStreams.TryGetValue(resourceName, out
var
currentLogStream) &&
847
if (_logStreams.TryGetValue(resourceName, out
var
logStream) &&