1 instantiation of LogStreamState
Aspire.Hosting (1)
Dcp\DcpResourceWatcher.cs (1)
665
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();
76
return _logStreams.TryGetValue(resourceName, out
var
logStream) ? logStream.Task : null;
84
return _logStreams.TryGetValue(resourceName, out
var
logStream) &&
453
var
logStream = CancelLogStream(resourceName);
464
private
LogStreamState
? CancelLogStream(string resourceName)
466
if (_logStreams.TryGetValue(resourceName, out
var
logStream))
665
var
logStream = new LogStreamState(resource.Metadata.Uid);
796
if (_logStreams.TryGetValue(resourceName, out
var
logStream) &&
804
private void ObservePendingFollowLogDeduplication(string resourceName,
LogStreamState
logStream)
815
private List<LogEntry> DeduplicateFollowBatch(string resourceName,
LogStreamState
logStream, List<LogEntry> logEntries)
863
private void RemovePendingFollowLogDeduplication(string resourceName,
LogStreamState
logStream)
873
_logStreams.TryGetValue(resourceName, out
var
currentLogStream) &&
901
if (_logStreams.TryGetValue(resourceName, out
var
logStream) &&