Akka.Discovery.Dns

Akka.Management.sln

@@ -80,6 +80,14 @@ Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "Azure.StressTest", "src\coo
 EndProject
 Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "HoconKubernetesCluster", "src\cluster.bootstrap\examples\discovery\hocon-kubernetes\src\HoconKubernetesCluster\HoconKubernetesCluster.csproj", "{7015572E-6225-4F32-A00C-4D52280E6C94}"
 EndProject
+Project("{2150E333-8FDC-42A3-9474-1A3956D46DE8}") = "dns", "dns", "{CF2BA83A-4CF9-4E29-9128-A7A3D3ADBB35}"
+EndProject
+Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "Akka.Discovery.Dns", "src\discovery\dns\Akka.Discovery.Dns\Akka.Discovery.Dns.csproj", "{5C5403F4-F496-4246-8BEC-E125E1A2BC94}"
+EndProject
+Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "Akka.Discovery.Dns.Tests", "src\discovery\dns\Akka.Discovery.Dns.Tests\Akka.Discovery.Dns.Tests.csproj", "{2E13DE8F-0001-4008-A066-B66B4B640915}"
+EndProject
+Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "DnsCluster", "src\cluster.bootstrap\examples\discovery\dns\src\DnsCluster.csproj", "{24B1214E-CFE2-44C0-9B0D-8139C269EED5}"
+EndProject
 Global
 	GlobalSection(SolutionConfigurationPlatforms) = preSolution
 		Debug|Any CPU = Debug|Any CPU
@@ -174,6 +182,18 @@ Global
 		{7015572E-6225-4F32-A00C-4D52280E6C94}.Debug|Any CPU.Build.0 = Debug|Any CPU
 		{7015572E-6225-4F32-A00C-4D52280E6C94}.Release|Any CPU.ActiveCfg = Release|Any CPU
 		{7015572E-6225-4F32-A00C-4D52280E6C94}.Release|Any CPU.Build.0 = Release|Any CPU
+		{5C5403F4-F496-4246-8BEC-E125E1A2BC94}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+		{5C5403F4-F496-4246-8BEC-E125E1A2BC94}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{5C5403F4-F496-4246-8BEC-E125E1A2BC94}.Release|Any CPU.ActiveCfg = Release|Any CPU
+		{5C5403F4-F496-4246-8BEC-E125E1A2BC94}.Release|Any CPU.Build.0 = Release|Any CPU
+		{2E13DE8F-0001-4008-A066-B66B4B640915}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+		{2E13DE8F-0001-4008-A066-B66B4B640915}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{2E13DE8F-0001-4008-A066-B66B4B640915}.Release|Any CPU.ActiveCfg = Release|Any CPU
+		{2E13DE8F-0001-4008-A066-B66B4B640915}.Release|Any CPU.Build.0 = Release|Any CPU
+		{24B1214E-CFE2-44C0-9B0D-8139C269EED5}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+		{24B1214E-CFE2-44C0-9B0D-8139C269EED5}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{24B1214E-CFE2-44C0-9B0D-8139C269EED5}.Release|Any CPU.ActiveCfg = Release|Any CPU
+		{24B1214E-CFE2-44C0-9B0D-8139C269EED5}.Release|Any CPU.Build.0 = Release|Any CPU
 	EndGlobalSection
 	GlobalSection(SolutionProperties) = preSolution
 		HideSolutionNode = FALSE
@@ -209,6 +229,10 @@ Global
 		{296A0309-2370-4153-B3B0-A4105622CC9A} = {C4C8BE03-A7C0-4F2E-8922-92854FE7A5BF}
 		{24FEBA95-1FC2-4AC2-8386-6AB13AE87056} = {9B10ADF5-60D1-4EED-9E98-9CB2E1E84E98}
 		{7015572E-6225-4F32-A00C-4D52280E6C94} = {24FEBA95-1FC2-4AC2-8386-6AB13AE87056}
+		{CF2BA83A-4CF9-4E29-9128-A7A3D3ADBB35} = {52ACBC5B-D5F0-4FEA-A27B-0A8577204E64}
+		{5C5403F4-F496-4246-8BEC-E125E1A2BC94} = {CF2BA83A-4CF9-4E29-9128-A7A3D3ADBB35}
+		{2E13DE8F-0001-4008-A066-B66B4B640915} = {CF2BA83A-4CF9-4E29-9128-A7A3D3ADBB35}
+		{24B1214E-CFE2-44C0-9B0D-8139C269EED5} = {24FEBA95-1FC2-4AC2-8386-6AB13AE87056}
 	EndGlobalSection
 	GlobalSection(ExtensibilityGlobals) = postSolution
 		SolutionGuid = {B99E6BB8-642A-4A68-86DF-69567CBA700A}

README.md

@@ -14,6 +14,7 @@ These tools aims to help with cluster management in various dynamic environments
 * [`Akka.Discovery.AwsApi`](/src/discovery/aws/Akka.Discovery.AwsApi) - Akka.Cluster bootstrapping discovery service using EC2, ECS, and the AWS API. You can read more in the documentation [here](https://github.com/akkadotnet/Akka.Management/blob/dev/src/discovery/aws/Akka.Discovery.AwsApi/README.md).
 * [`Akka.Discovery.KubernetesApi`](/src/discovery/kubernetes/Akka.Discovery.KubernetesApi) - Akka.Cluster bootstrapping discovery service using Kubernetes API. You can read more in the documentation [here](https://github.com/akkadotnet/Akka.Management/blob/dev/src/discovery/kubernetes/Akka.Discovery.KubernetesApi/README.md).
 * [`Akka.Discovery.Azure`](src/discovery/azure/Akka.Discovery.Azure) - Akka.Cluster bootstrapping discovery service using Azure Table Storage. You can read more in the documentation [here](https://github.com/akkadotnet/Akka.Management/blob/dev/src/discovery/azure/Akka.Discovery.Azure/README.md).
+* [`Akka.Discovery.Dns`](src/discovery/dns/Akka.Discovery.Dns) - Akka.Cluster bootstrapping discovery service using DNS. You can read more in the documentation [here](https://github.com/akkadotnet/Akka.Management/blob/dev/src/discovery/dns/Akka.Discovery.Dns/README.md).
 * [`Akka.Coordination.KubernetesApi`](https://github.com/akkadotnet/Akka.Management/tree/dev/src/coordination/kubernetes/Akka.Coordination.KubernetesApi) - provides a lease-based distributed lock mechanism backed by [Kubernetes CRD](https://kubernetes.io/docs/tasks/extend-kubernetes/custom-resources/custom-resource-definitions/) for [Akka.NET Split Brain Resolver](https://getakka.net/articles/clustering/split-brain-resolver.html), [Akka.Cluster.Sharding](https://getakka.net/articles/clustering/cluster-sharding.html), and [Akka.Cluster.Singleton](https://getakka.net/articles/clustering/cluster-singleton.html). Documentation can be read [here](https://github.com/akkadotnet/Akka.Management/blob/dev/src/coordination/kubernetes/Akka.Coordination.KubernetesApi/README.md)
 * [`Akka.Coordination.Azure`](https://github.com/akkadotnet/Akka.Management/tree/dev/src/coordination/azure/Akka.Coordination.Azure) - provides a lease-based distributed lock mechanism backed by [Microsoft Azure Blob Storage](https://learn.microsoft.com/en-us/azure/storage/blobs/storage-blobs-overview) for [Akka.NET Split Brain Resolver](https://getakka.net/articles/clustering/split-brain-resolver.html), [Akka.Cluster.Sharding](https://getakka.net/articles/clustering/cluster-sharding.html), and [Akka.Cluster.Singleton](https://getakka.net/articles/clustering/cluster-singleton.html). Documentation can be read [here](https://github.com/akkadotnet/Akka.Management/blob/dev/src/coordination/azure/Akka.Coordination.Azure/README.md)
 

src/cluster.bootstrap/examples/discovery/dns/README.md

@@ -0,0 +1,11 @@
+# DNS Cluster Bootstrap Example
+
+This example demonstrates how to use DNS-based service discovery with Akka.Management Cluster Bootstrap to form an Akka.NET Cluster.
+
+Three types of records are supported: A, AAAA and SRV.
+
+To run exmample use:
+```pwsh
+./build.ps1 [a|aaaa|srv] 
+```
+This will build example on your host machine and spawn dedicated docker-compose file for each record type.

src/cluster.bootstrap/examples/discovery/dns/build.ps1

@@ -0,0 +1,21 @@
+#!/usr/bin/env pwsh
+
+param(
+    [Parameter(Mandatory=$false)]
+    [string]$recordType = "srv"
+)
+
+if ($recordType -ne "srv" -and $recordType -ne "a" -and $recordType -ne "aaaa") {
+    Write-Error "Invalid record type. Must be 'srv' or 'a' or 'aaaa'."
+    exit 1
+}
+Write-Output "Cleaning up previous containers (ignore errors if containers do not exist)...."
+docker-compose -f "$(pwd)/src/docker-compose.srv.yml" down
+docker-compose -f "$(pwd)/src/docker-compose.aaaa.yml" down
+docker-compose -f "$(pwd)/src/docker-compose.a.yml" down
+
+Write-Output "Building and publishing example..."
+dotnet publish --os linux --arch x64 -c Release /t:PublishContainer ./src/DnsCluster.csproj
+
+Write-Output "Start $recordType example"
+docker-compose -f "$(pwd)/src/docker-compose.$recordType.yml" up --build 

src/cluster.bootstrap/examples/discovery/dns/src/DnsCluster.csproj

@@ -0,0 +1,39 @@
+<Project Sdk="Microsoft.NET.Sdk">
+
+  <PropertyGroup>
+    <OutputType>Exe</OutputType>
+    <TargetFramework>$(TestsNet)</TargetFramework>
+    <DockerDefaultTargetOS>Linux</DockerDefaultTargetOS>
+    <IsPackable>false</IsPackable>
+    <LangVersion>latest</LangVersion>
+  </PropertyGroup>
+
+  <ItemGroup>
+    <PackageReference Include="Microsoft.Extensions.Hosting" Version="6.0.0" />
+    <PackageReference Include="Akka.Hosting" Version="$(AkkaHostingVersion)" />
+    <PackageReference Include="Akka.Cluster.Hosting" Version="$(AkkaHostingVersion)" />
+    <PackageReference Include="Akka.Cluster.Tools" Version="$(AkkaVersion)" />
+    <PackageReference Include="Akka.DependencyInjection" Version="$(AkkaVersion)" />
+    <PackageReference Include="Petabridge.Cmd.Cluster" Version="$(PbmVersion)" />
+    <PackageReference Include="Petabridge.Cmd.Remote" Version="$(PbmVersion)" />
+  </ItemGroup>
+
+  <ItemGroup>
+    <ProjectReference Include="..\..\..\..\..\discovery\dns\Akka.Discovery.Dns\Akka.Discovery.Dns.csproj" />
+    <ProjectReference Include="..\..\..\..\..\management\Akka.Management\Akka.Management.csproj" />
+
+  </ItemGroup>
+
+  <ItemGroup>
+    <Compile Include="..\..\kubernetes\src\KubernetesCluster\Actors\ChaosActor.cs">
+      <Link>Actors\ChaosActor.cs</Link>
+    </Compile>
+    <Compile Include="..\..\kubernetes\src\KubernetesCluster\Actors\ClusterListener.cs">
+      <Link>Actors\ClusterListener.cs</Link>
+    </Compile>
+    <Compile Include="..\..\kubernetes\src\KubernetesCluster\Actors\SubscriberActor.cs">
+      <Link>Actors\SubscriberActor.cs</Link>
+    </Compile>
+  </ItemGroup>
+
+</Project>

src/cluster.bootstrap/examples/discovery/dns/src/Dockerfile

@@ -0,0 +1,18 @@
+FROM mcr.microsoft.com/dotnet/aspnet:9.0
+
+# Install DNS utilities and diagnostic tools
+RUN apt-get update && apt-get install -y \
+    dnsutils \
+    iputils-ping \
+    net-tools \
+    && rm -rf /var/lib/apt/lists/*
+# Copy published app
+COPY bin/Release/net9.0/linux-x64/publish/ /app
+
+# Copy entrypoint script
+COPY entrypoint.sh /entrypoint.sh
+RUN chmod +x /entrypoint.sh
+
+# Configure entry point
+# ENTRYPOINT ["dotnet", "/app/DnsCluster.dll"]
+ENTRYPOINT ["/entrypoint.sh"]