IHostedService

IHostedLifecycleService.cs (1)

14public interface IHostedLifecycleService : IHostedService

Telemetry\AspireCliTelemetry.cs (1)

17internal sealed class AspireCliTelemetry : IHostedService

Dashboard\DashboardServiceHost.cs (1)

27internal sealed class DashboardServiceHost : IHostedService

tests\Shared\DistributedApplicationTestingBuilderExtensions.cs (1)

103internal sealed class DcpLogForwarder : IHostedService

tests\Shared\DistributedApplicationTestingBuilderExtensions.cs (1)

103internal sealed class DcpLogForwarder : IHostedService

Infrastructure\DistributedApplicationTestFactory.cs (1)

51internal sealed class ContainerRegistryHook(DistributedApplicationEventing eventing) : IHostedService

Infrastructure\ReadinessNotificationService.cs (1)

13internal class ReadinessNotificationService : IHostedService

Internal\DataProtectionHostedService.cs (1)

14internal sealed class DataProtectionHostedService : IHostedService

GenericHost\GenericWebHostService.cs (1)

17internal sealed partial class GenericWebHostService : IHostedService

AutoActivationHostedService.cs (1)

13internal sealed class AutoActivationHostedService : IHostedService

HealthCheckPublisherHostedService.cs (1)

19internal sealed partial class HealthCheckPublisherHostedService : IHostedService

BackgroundService.cs (1)

13public abstract class BackgroundService : IHostedService, IDisposable

Program.cs (1)

20public class AppEventsBackendService(INatsConnection nats, ILogger<AppEventsBackendService> logger) : IHostedService

Utils\CliTestHelper.cs (1)

123services.AddSingleton<IHostedService>(sp => sp.GetRequiredService<NuGetPackagePrefetcher>());

Dashboard\DashboardServiceHost.cs (2)

201async Task IHostedService.StartAsync(CancellationToken cancellationToken) 219async Task IHostedService.StopAsync(CancellationToken cancellationToken)

DistributedApplication.cs (4)

457/// triggered and all <see cref="IHostedService" /> instances are stopped. 475/// of <see cref="IHostedService"/> instances which are added to the dependency injection 498/// <see cref="IHostedService"/> instances are stopped. 514/// of <see cref="IHostedService"/> instances which are added to the dependency injection

ResourceLoggerForwarderServiceTests.cs (1)

23sd.ServiceType == typeof(IHostedService)

tests\Shared\DistributedApplicationTestingBuilderExtensions.cs (1)

78services.AddSingleton<IHostedService>(sp => new DcpLogForwarder(testOutputHelper, uniqueFolder));

tests\Shared\DistributedApplicationTestingBuilderExtensions.cs (1)

78services.AddSingleton<IHostedService>(sp => new DcpLogForwarder(testOutputHelper, uniqueFolder));

BootstrapHostBuilder.cs (1)

109if (descriptor.ServiceType == typeof(IHostedService))

Hosting\HostedServiceExecutor.cs (4)

11private readonly IEnumerable<IHostedService> _services; 14public HostedServiceExecutor(IEnumerable<IHostedService> services, ILogger<HostedServiceExecutor> logger) 22foreach (var service in _services) 32foreach (var service in _services)

DataProtectionServiceCollectionExtensions.cs (1)

77services.TryAddEnumerable(ServiceDescriptor.Singleton<IHostedService, DataProtectionHostedService>());

Internal\HostedServiceExecutor.cs (4)

10private readonly IEnumerable<IHostedService> _services; 12public HostedServiceExecutor(IEnumerable<IHostedService> services) 19foreach (var service in _services) 29foreach (var service in _services)

DependencyInjection\HealthCheckServiceCollectionExtensions.cs (1)

29services.TryAddEnumerable(ServiceDescriptor.Singleton<IHostedService, HealthCheckPublisherHostedService>());

TcpEndpointProbesExtensions.cs (1)

49_ = services.AddSingleton<IHostedService>(provider =>

KubernetesProbesExtensionsTests.cs (3)

36var hostedServices = host.Services.GetServices<IHostedService>().Where(service => service.GetType().Name == "TcpEndpointProbesService"); 80var hostedServices = host.Services.GetServices<IHostedService>().Where(service => service.GetType().Name == "TcpEndpointProbesService"); 108var hostedServices = host.Services.GetServices<IHostedService>().Where(service => service.GetType().Name == "TcpEndpointProbesService");

TcpEndpointProbesExtensionsTests.cs (7)

36var hostedServices = host.Services.GetServices<IHostedService>().Where(x => x is TcpEndpointProbesService); 55var hostedServices = host.Services.GetServices<IHostedService>().Where(x => x is TcpEndpointProbesService); 73var hostedServices = host.Services.GetServices<IHostedService>().Where(x => x is TcpEndpointProbesService); 92var hostedServices = host.Services.GetServices<IHostedService>().Where(x => x is TcpEndpointProbesService); 118var hostedServices = host.Services.GetServices<IHostedService>().Where(x => x is TcpEndpointProbesService); 143var hostedServices = host.Services.GetServices<IHostedService>().Where(x => x is TcpEndpointProbesService); 164var hostedServices = host.Services.GetServices<IHostedService>().Where(x => x is TcpEndpointProbesService);

ResourceMonitorBuilder.cs (1)

20services.TryAddEnumerable(ServiceDescriptor.Singleton<IHostedService, ResourceMonitorService>(static sp => sp.GetRequiredService<ResourceMonitorService>()));

ResourceMonitoringExtensionsTests.cs (2)

85var allHostedServices = provider.GetServices<IHostedService>(); 206var backgrounds = host.Services.GetServices<IHostedService>().Where(x => x is ResourceMonitorService).ToArray();

HostOptions.cs (4)

37/// Gets or sets a value that indicates if the <see cref="IHost"/> will start registered instances of <see cref="IHostedService"/> concurrently or sequentially. 40/// <see langword="true"/> if the <see cref="IHost"/> will start registered instances of <see cref="IHostedService"/> concurrently; <see langword="false"/> if the <see cref="IHost"/> will start registered instances sequentially. The default is <see langword="false"/> . 45/// Gets or sets a value that indicates if the <see cref="IHost"/> will stop registered instances of <see cref="IHostedService"/> concurrently or sequentially. 48/// <see langword="true"/> if the <see cref="IHost"/> will stop registered instances of <see cref="IHostedService"/> concurrently; <see langword="false"/> if the <see cref="IHost"/> will stop registered instances sequentially. The default is <see langword="false"/> .

Internal\Host.cs (8)

29private IEnumerable<IHostedService>? _hostedServices; 97_hostedServices ??= Services.GetRequiredService<IEnumerable<IHostedService>>(); 275IEnumerable<IHostedService> reversedServices = _hostedServices.Reverse(); 455private static List<IHostedLifecycleService>? GetHostLifecycles(IEnumerable<IHostedService> hostedServices) 459foreach (IHostedService hostedService in hostedServices) 519public List<IHostedService> HostedServices => new List<IHostedService>(host._hostedServices ??= host.Services.GetRequiredService<IEnumerable<IHostedService>>());

BackgroundService.cs (3)

11/// Base class for implementing a long running <see cref="IHostedService"/>. 27/// This method is called when the <see cref="IHostedService"/> starts. The implementation should return a task that represents 30/// <param name="stoppingToken">Triggered when <see cref="IHostedService.StopAsync(CancellationToken)"/> is called.</param>

IHost.cs (1)

21/// Starts the <see cref="IHostedService" /> objects configured for the program.

IHostedLifecycleService.cs (6)

11/// <see cref="IHostedService.StartAsync(CancellationToken)"/> and 12/// <see cref="IHostedService.StopAsync(CancellationToken)"/>. 17/// Triggered before <see cref="IHostedService.StartAsync(CancellationToken)"/>. 24/// Triggered after <see cref="IHostedService.StartAsync(CancellationToken)"/>. 31/// Triggered before <see cref="IHostedService.StopAsync(CancellationToken)"/>. 38/// Triggered after <see cref="IHostedService.StopAsync(CancellationToken)"/>.

ServiceCollectionHostedServiceExtensions.cs (10)

17/// Add an <see cref="IHostedService"/> registration for the given type. 20/// Note that this creates registration for <see cref="IHostedService"/> specifically. Not for the actual <c>THostedService</c> type. 32/// <typeparam name="THostedService">An <see cref="IHostedService"/> to register.</typeparam> 36where THostedService : class, IHostedService 38services.TryAddEnumerable(ServiceDescriptor.Singleton<IHostedService, THostedService>()); 44/// Add an <see cref="IHostedService"/> registration for the given type. 47/// Note that this creates registration for <see cref="IHostedService"/> specifically. Not for the actual <c>THostedService</c> type. 59/// <typeparam name="THostedService">An <see cref="IHostedService"/> to register.</typeparam> 64where THostedService : class, IHostedService 66services.TryAddEnumerable(ServiceDescriptor.Singleton<IHostedService>(implementationFactory));

FakeHostingExtensions.cs (1)

32public static async Task StartAndStopAsync(this IHostedService service, CancellationToken cancellationToken = default)

HostTerminatorService.cs (1)

40/// <param name="stoppingToken">Triggered when <see cref="IHostedService.StopAsync(CancellationToken)"/> is called.</param>

FakeHostBuilderTests.cs (1)

39Assert.Contains(hostBuilderServices.GetServices<IHostedService>(), x => x is HostTerminatorService);

HostingFakesExtensionsTests.cs (2)

21var exception = await Record.ExceptionAsync(() => ((IHostedService)null!).StartAndStopAsync()); 30var serviceMock = new Mock<IHostedService>(MockBehavior.Strict);

Logging\HttpClientLoggingExtensionsTest.cs (1)

327.GetRequiredService<IHostedService>()