Skip to content

Commit 7d019b4

Browse files
m3naxm3nax
authored
.NET Core service worker DI example (#951)
* Added example source code * Fix namespace name * Added example source code * Fix namespace name * Fix sln file * Update Program.cs * Updated IKubernetes DI registration
1 parent e7441f0 commit 7d019b4

File tree

7 files changed

+101
-2
lines changed

7 files changed

+101
-2
lines changed

‎examples/webApiDependencyInjection/Program.cs‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -6,7 +6,7 @@
66
var kubernetesClientConfig = KubernetesClientConfiguration.BuildDefaultConfig();
77

88
// Register Kubernetes client interface as sigleton
9-
builder.Services.AddSingleton<IKubernetes>(new Kubernetes(kubernetesClientConfig));
9+
builder.Services.AddSingleton<IKubernetes>(_ => new Kubernetes(kubernetesClientConfig));
1010

1111
// Add services to the container.
1212
builder.Services.AddEndpointsApiExplorer();

‎examples/workerServiceDependencyInjection/Program.cs‎

Lines changed: 17 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,17 @@
1+
using k8s;
2+
using workerServiceDependencyInjection;
3+
4+
IHost host = Host.CreateDefaultBuilder(args)
5+
.ConfigureServices(services =>
6+
{
7+
// Load kubernetes configuration
8+
var kubernetesClientConfig = KubernetesClientConfiguration.BuildDefaultConfig();
9+
10+
// Register Kubernetes client interface as sigleton
11+
services.AddSingleton<IKubernetes>(_ => new Kubernetes(kubernetesClientConfig));
12+
13+
services.AddHostedService<Worker>();
14+
})
15+
.Build();
16+
17+
await host.RunAsync();

‎examples/workerServiceDependencyInjection/Worker.cs‎

Lines changed: 40 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,40 @@
1+
using k8s;
2+
3+
namespace workerServiceDependencyInjection
4+
{
5+
public class Worker : BackgroundService
6+
{
7+
private readonly ILogger<Worker> logger;
8+
private readonly IKubernetes kubernetesClient;
9+
10+
/// <summary>
11+
/// Inject in the constructor the IKubernetes interface.
12+
/// </summary>
13+
/// <param name="logger"></param>
14+
/// <param name="kubernetesClient"></param>
15+
public Worker(ILogger<Worker> logger, IKubernetes kubernetesClient)
16+
{
17+
this.logger = logger;
18+
this.kubernetesClient = kubernetesClient;
19+
}
20+
21+
protected override async Task ExecuteAsync(CancellationToken stoppingToken)
22+
{
23+
while (!stoppingToken.IsCancellationRequested)
24+
{
25+
logger.LogInformation("Worker running at: {time}", DateTimeOffset.Now);
26+
27+
// Read the list of pods contained in default namespace
28+
var podList = kubernetesClient.CoreV1.ListNamespacedPod("default");
29+
30+
// Print pods names
31+
foreach (var pod in podList.Items)
32+
{
33+
Console.WriteLine(pod.Metadata.Name);
34+
}
35+
36+
await Task.Delay(1000, stoppingToken);
37+
}
38+
}
39+
}
40+
}

‎examples/workerServiceDependencyInjection/appsettings.Development.json‎

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,8 @@
1+
{
2+
"Logging": {
3+
"LogLevel": {
4+
"Default": "Information",
5+
"Microsoft.Hosting.Lifetime": "Information"
6+
}
7+
}
8+
}

‎examples/workerServiceDependencyInjection/appsettings.json‎

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,8 @@
1+
{
2+
"Logging": {
3+
"LogLevel": {
4+
"Default": "Information",
5+
"Microsoft.Hosting.Lifetime": "Information"
6+
}
7+
}
8+
}

‎examples/workerServiceDependencyInjection/workerServiceDependencyInjection.csproj‎

Lines changed: 11 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,11 @@
1+
<Project Sdk="Microsoft.NET.Sdk.Worker">
2+
3+
<PropertyGroup>
4+
<Nullable>enable</Nullable>
5+
<ImplicitUsings>enable</ImplicitUsings>
6+
</PropertyGroup>
7+
8+
<ItemGroup>
9+
<PackageReference Include="Microsoft.Extensions.Hosting" Version="6.0.1" />
10+
</ItemGroup>
11+
</Project>

‎kubernetes-client.sln‎

Lines changed: 16 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -67,7 +67,9 @@ Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "Kubectl.Tests", "tests\Kube
6767
EndProject
6868
Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "openTelemetryConsole", "examples\openTelemetryConsole\openTelemetryConsole.csproj", "{8E266190-AE6E-44A8-948D-BD974AA82428}"
6969
EndProject
70-
Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "webApiDependencyInjection", "examples\webApiDependencyInjection\webApiDependencyInjection.csproj", "{C0759F88-A010-4DEF-BD3B-E183D3328FFC}"
70+
Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "webApiDependencyInjection", "examples\webApiDependencyInjection\webApiDependencyInjection.csproj", "{C0759F88-A010-4DEF-BD3B-E183D3328FFC}"
71+
EndProject
72+
Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "workerServiceDependencyInjection", "examples\workerServiceDependencyInjection\workerServiceDependencyInjection.csproj", "{05DC8884-AC54-4603-AC25-AE9D9F24E7AE}"
7173
EndProject
7274
Global
7375
GlobalSection(SolutionConfigurationPlatforms) = preSolution
@@ -439,6 +441,18 @@ Global
439441
{C0759F88-A010-4DEF-BD3B-E183D3328FFC}.Release|x64.Build.0 = Release|Any CPU
440442
{C0759F88-A010-4DEF-BD3B-E183D3328FFC}.Release|x86.ActiveCfg = Release|Any CPU
441443
{C0759F88-A010-4DEF-BD3B-E183D3328FFC}.Release|x86.Build.0 = Release|Any CPU
444+
{05DC8884-AC54-4603-AC25-AE9D9F24E7AE}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
445+
{05DC8884-AC54-4603-AC25-AE9D9F24E7AE}.Debug|Any CPU.Build.0 = Debug|Any CPU
446+
{05DC8884-AC54-4603-AC25-AE9D9F24E7AE}.Debug|x64.ActiveCfg = Debug|Any CPU
447+
{05DC8884-AC54-4603-AC25-AE9D9F24E7AE}.Debug|x64.Build.0 = Debug|Any CPU
448+
{05DC8884-AC54-4603-AC25-AE9D9F24E7AE}.Debug|x86.ActiveCfg = Debug|Any CPU
449+
{05DC8884-AC54-4603-AC25-AE9D9F24E7AE}.Debug|x86.Build.0 = Debug|Any CPU
450+
{05DC8884-AC54-4603-AC25-AE9D9F24E7AE}.Release|Any CPU.ActiveCfg = Release|Any CPU
451+
{05DC8884-AC54-4603-AC25-AE9D9F24E7AE}.Release|Any CPU.Build.0 = Release|Any CPU
452+
{05DC8884-AC54-4603-AC25-AE9D9F24E7AE}.Release|x64.ActiveCfg = Release|Any CPU
453+
{05DC8884-AC54-4603-AC25-AE9D9F24E7AE}.Release|x64.Build.0 = Release|Any CPU
454+
{05DC8884-AC54-4603-AC25-AE9D9F24E7AE}.Release|x86.ActiveCfg = Release|Any CPU
455+
{05DC8884-AC54-4603-AC25-AE9D9F24E7AE}.Release|x86.Build.0 = Release|Any CPU
442456
EndGlobalSection
443457
GlobalSection(SolutionProperties) = preSolution
444458
HideSolutionNode = FALSE
@@ -474,6 +488,7 @@ Global
474488
{9128F6DC-6B7A-417F-937A-90461D6989A8} = {8AF4A5C2-F0CE-47D5-A4C5-FE4AB83CA509}
475489
{8E266190-AE6E-44A8-948D-BD974AA82428} = {B70AFB57-57C9-46DC-84BE-11B7DDD34B40}
476490
{C0759F88-A010-4DEF-BD3B-E183D3328FFC} = {B70AFB57-57C9-46DC-84BE-11B7DDD34B40}
491+
{05DC8884-AC54-4603-AC25-AE9D9F24E7AE} = {B70AFB57-57C9-46DC-84BE-11B7DDD34B40}
477492
EndGlobalSection
478493
GlobalSection(ExtensibilityGlobals) = postSolution
479494
SolutionGuid = {049A763A-C891-4E8D-80CF-89DD3E22ADC7}

0 commit comments

Comments
 (0)