diff --git a/README.md b/README.md index 80087ac0..d26d3d8b 100644 --- a/README.md +++ b/README.md @@ -2,7 +2,7 @@ [![Build status](https://ci.appveyor.com/api/projects/status/5heds9x31qc688b9?svg=true)](https://ci.appveyor.com/project/simpleidserver/faasnet) -FaasNet is an open-source implementation of EventMesh implemented in DOTNET CORE. +FaasNet is an open-source implementation of EventMesh. For project documentation, please visit [docs](https://simpleidserver.github.io/FaasNet/documentation/eventmesh/glossary.html). diff --git a/default.ps1 b/default.ps1 index cb0ecf1b..f5a84bb0 100644 --- a/default.ps1 +++ b/default.ps1 @@ -69,6 +69,7 @@ task publishWebsite { exec { git checkout master } } +# Test task test { Push-Location -Path $base_dir\tests\FaasNet.EventMesh.Runtime.Tests @@ -85,4 +86,12 @@ task test { } finally { Pop-Location } +} + +# Publish Docker +task publishDockerEventMesh { + [xml]$XmlDoc = Get-Content -Path .\Directory.Build.props + $VersionPrefix = $XmlDoc.Project.PropertyGroup.VersionPrefix + docker build -t simpleidserver/faaseventmesh:$VersionPrefix -f EventMeshDockerFile . + docker push simpleidserver/faaseventmesh:$VersionPrefix } \ No newline at end of file diff --git a/docs/documentation/eventmesh/installclionwindows.md b/docs/documentation/eventmesh/installclionwindows.md index b192afd1..5105e625 100644 --- a/docs/documentation/eventmesh/installclionwindows.md +++ b/docs/documentation/eventmesh/installclionwindows.md @@ -6,7 +6,7 @@ The CLI is used to manage one local or remote instance of an EventMesh Peer. ## Download zip -Download the ZIP file [EventMeshCLI.zip](#) and extract its content into a new Directory. +Download the ZIP file [EventMeshCLI.zip](https://github.com/simpleidserver/FaasNet/releases/latest/download/EventMeshCLI.zip) and extract its content into a new Directory. The windows account must have READ and WRITE access to this directory otherwise the configuration file cannot be updated or read. ## Register the service diff --git a/docs/documentation/eventmesh/installserverondocker.md b/docs/documentation/eventmesh/installserverondocker.md index cae26fdb..149053ed 100644 --- a/docs/documentation/eventmesh/installserverondocker.md +++ b/docs/documentation/eventmesh/installserverondocker.md @@ -10,5 +10,5 @@ This guide describes how EventMesh peer can be installed on Docker. Open a command prompt and execute the following command line. An EventMesh peer will be deployed and listening the port 4000. ``` -docker run --name eventmesh -p 4000:4000/udp eventmesh +docker run --name eventmesh -p 4000:4000/udp simpleidserver/faaseventmesh:0.0.6 ``` \ No newline at end of file diff --git a/docs/documentation/eventmesh/installserveronwindows.md b/docs/documentation/eventmesh/installserveronwindows.md index 94b09a5d..c0fc26f4 100644 --- a/docs/documentation/eventmesh/installserveronwindows.md +++ b/docs/documentation/eventmesh/installserveronwindows.md @@ -1,12 +1,12 @@ # Installing on Windows Manually -This guide describes how EventMesh peer node can be installed and configured manually on Windows. +This guide describes how EventMesh Peer Node can be installed and configured manually on Windows. ## Download zip -Download the zip file [EventMeshServer.zip](TODO) and extract its content into a new directory. +Download the zip file [EventMeshService.zip](https://github.com/simpleidserver/FaasNet/releases/latest/download/EventMeshService.zip) and extract its content into a new directory. -## Deploy the windows service +## Deploy the Windows Service As an administrator, open a command prompt and execute the following command. The parameter `$result_dir` must be replaced by the full path of the new directory. The windows account used to run the windows service must have READ and WRITE access to this new directory otherwise the key-value storage cannot be created. diff --git a/docs/documentation/eventmesh/pluginamqp.md b/docs/documentation/eventmesh/pluginamqp.md index b4c7084a..573b9fa2 100644 --- a/docs/documentation/eventmesh/pluginamqp.md +++ b/docs/documentation/eventmesh/pluginamqp.md @@ -10,7 +10,7 @@ AMQP 1.0 protocol. **Link** -The ZIP file can be downloaded [here](). +The ZIP file can be downloaded [here](https://github.com/simpleidserver/FaasNet/releases/latest/download/EventMeshProtocolsAMQP.zip). **Options** @@ -67,7 +67,7 @@ When the configuration is finished, a client can be created and can start publis ## Source Code -The source code of this project can be found [here](). +The source code of this project can be found [here](https://github.com/simpleidserver/FaasNet/tree/master/src/Samples/FaasNet.EventMesh.AMQPClient). ## Create a client diff --git a/docs/documentation/eventmesh/plugindiscoveryconfig.md b/docs/documentation/eventmesh/plugindiscoveryconfig.md index e78d6eec..59314b63 100644 --- a/docs/documentation/eventmesh/plugindiscoveryconfig.md +++ b/docs/documentation/eventmesh/plugindiscoveryconfig.md @@ -10,7 +10,7 @@ Use configuration file to discover peers. **Link** -The ZIP file can be downloaded [here](). +The ZIP file can be downloaded [here](https://github.com/simpleidserver/FaasNet/releases/latest/download/EventMeshDiscoveryConfig.zip). **Options** diff --git a/docs/documentation/eventmesh/plugindiscoveryetcd.md b/docs/documentation/eventmesh/plugindiscoveryetcd.md index b7a25470..c5a5d608 100644 --- a/docs/documentation/eventmesh/plugindiscoveryetcd.md +++ b/docs/documentation/eventmesh/plugindiscoveryetcd.md @@ -10,7 +10,7 @@ Use Etcd to discover peers. **Link** -The ZIP file can be downloaded [here](). +The ZIP file can be downloaded [here](https://github.com/simpleidserver/FaasNet/releases/latest/download/EventMeshDiscoveryEtcd.zip). **Options** diff --git a/docs/documentation/eventmesh/pluginsinkamqp.md b/docs/documentation/eventmesh/pluginsinkamqp.md index 2d9ef050..ec4b8258 100644 --- a/docs/documentation/eventmesh/pluginsinkamqp.md +++ b/docs/documentation/eventmesh/pluginsinkamqp.md @@ -10,7 +10,7 @@ Consume events from AMQP 1.0 server. **Link** -The ZIP file can be downloaded [here](). +The ZIP file can be downloaded [here](https://github.com/simpleidserver/FaasNet/releases/latest/download/EventMeshSinksAMQP.zip). **Options** @@ -55,7 +55,7 @@ FaasNet.EventMeshCTL.CLI.exe add_client --vpn=default --identifier=publishClient Download the Docker file ``` -https://raw.githubusercontent.com/simpleidserver/FaasNet/master/Samples/FaasNet.EventMesh.AmqpSink/AmqpServerDockerFile +https://raw.githubusercontent.com/simpleidserver/FaasNet/master/src/Samples/FaasNet.EventMesh.AmqpSink/AmqpServerDockerFile ``` Open a command prompt and build the docker image diff --git a/docs/documentation/eventmesh/pluginsinkkafka.md b/docs/documentation/eventmesh/pluginsinkkafka.md index 1fe373d9..04cbad31 100644 --- a/docs/documentation/eventmesh/pluginsinkkafka.md +++ b/docs/documentation/eventmesh/pluginsinkkafka.md @@ -10,7 +10,7 @@ Consume events from Kafka server. **Link** -The ZIP file can be downloaded [here](). +The ZIP file can be downloaded [here](https://github.com/simpleidserver/FaasNet/releases/latest/download/EventMeshSinksKafka.zip). **Options** @@ -54,7 +54,7 @@ FaasNet.EventMeshCTL.CLI.exe add_client --vpn=default --identifier=publishClient Download the file ``` -https://raw.githubusercontent.com/simpleidserver/FaasNet/master/Samples/FaasNet.EventMesh.KafkaSink/docker-compose.yml +https://raw.githubusercontent.com/simpleidserver/FaasNet/master/src/Samples/FaasNet.EventMesh.KafkaSink/docker-compose.yml ``` Open a command prompt and execute the command below to deploy Apache Kafka diff --git a/docs/documentation/eventmesh/pluginsinkvpnbridge.md b/docs/documentation/eventmesh/pluginsinkvpnbridge.md index 5e3baab1..60311a9c 100644 --- a/docs/documentation/eventmesh/pluginsinkvpnbridge.md +++ b/docs/documentation/eventmesh/pluginsinkvpnbridge.md @@ -10,7 +10,7 @@ Consume events from VPN bridge **Link** -The ZIP file can be downloaded [here](). +The ZIP file can be downloaded [here](https://github.com/simpleidserver/FaasNet/releases/latest/download/EventMeshSinksKafka.zip). **Options** diff --git a/docs/documentation/eventmesh/pluginwebsocket.md b/docs/documentation/eventmesh/pluginwebsocket.md index 6e3ec610..20cc3683 100644 --- a/docs/documentation/eventmesh/pluginwebsocket.md +++ b/docs/documentation/eventmesh/pluginwebsocket.md @@ -10,7 +10,7 @@ Support Websocket protocol. **Link** -The ZIP file can be downloaded [here](). +The ZIP file can be downloaded [here](https://github.com/simpleidserver/FaasNet/releases/latest/download/EventMeshProtocolsWebsocket.zip). **Options** @@ -63,7 +63,7 @@ When the configuration is finished, a client can be created and can start publis ## Source code -The source code of this project can be found [here](). +The source code of this project can be found [here](https://github.com/simpleidserver/FaasNet/tree/master/src/Samples/FaasNet.EventMesh.WebSocketClient). ## Create a client diff --git a/docs/index.md b/docs/index.md index 773c8346..6be180cb 100644 --- a/docs/index.md +++ b/docs/index.md @@ -1 +1 @@ -[EventMesh documentation](/documentation/eventmesh/glossary.html) \ No newline at end of file +[EventMesh documentation](/FaasNet/documentation/eventmesh/glossary.html) \ No newline at end of file diff --git a/samples/EventMeshClientPublish/QuickStart.sln b/samples/EventMeshClientPublish/QuickStart.sln deleted file mode 100644 index 5b9c76c6..00000000 --- a/samples/EventMeshClientPublish/QuickStart.sln +++ /dev/null @@ -1,30 +0,0 @@ - -Microsoft Visual Studio Solution File, Format Version 12.00 -# Visual Studio Version 16 -VisualStudioVersion = 16.0.30114.105 -MinimumVisualStudioVersion = 10.0.40219.1 -Project("{2150E333-8FDC-42A3-9474-1A3956D46DE8}") = "src", "src", "{49FB5DB2-BA85-4CEE-8939-8066843540A4}" -EndProject -Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "EventMeshClientPublish", "src\EventMeshClientPublish\EventMeshClientPublish.csproj", "{BD78F72E-05D0-485D-ACE5-65FE566F70CC}" -EndProject -Global - GlobalSection(SolutionConfigurationPlatforms) = preSolution - Debug|Any CPU = Debug|Any CPU - Release|Any CPU = Release|Any CPU - EndGlobalSection - GlobalSection(ProjectConfigurationPlatforms) = postSolution - {BD78F72E-05D0-485D-ACE5-65FE566F70CC}.Debug|Any CPU.ActiveCfg = Debug|Any CPU - {BD78F72E-05D0-485D-ACE5-65FE566F70CC}.Debug|Any CPU.Build.0 = Debug|Any CPU - {BD78F72E-05D0-485D-ACE5-65FE566F70CC}.Release|Any CPU.ActiveCfg = Release|Any CPU - {BD78F72E-05D0-485D-ACE5-65FE566F70CC}.Release|Any CPU.Build.0 = Release|Any CPU - EndGlobalSection - GlobalSection(SolutionProperties) = preSolution - HideSolutionNode = FALSE - EndGlobalSection - GlobalSection(NestedProjects) = preSolution - {BD78F72E-05D0-485D-ACE5-65FE566F70CC} = {49FB5DB2-BA85-4CEE-8939-8066843540A4} - EndGlobalSection - GlobalSection(ExtensibilityGlobals) = postSolution - SolutionGuid = {0B40F9BB-F646-4446-B4E0-283452D08D02} - EndGlobalSection -EndGlobal diff --git a/samples/EventMeshClientPublish/src/EventMeshClientPublish/EventMeshClientPublish.csproj b/samples/EventMeshClientPublish/src/EventMeshClientPublish/EventMeshClientPublish.csproj deleted file mode 100644 index a5fded17..00000000 --- a/samples/EventMeshClientPublish/src/EventMeshClientPublish/EventMeshClientPublish.csproj +++ /dev/null @@ -1,9 +0,0 @@ - - - Exe - net5.0 - - - - - diff --git a/samples/EventMeshClientPublish/src/EventMeshClientPublish/Program.cs b/samples/EventMeshClientPublish/src/EventMeshClientPublish/Program.cs deleted file mode 100644 index e6ac4724..00000000 --- a/samples/EventMeshClientPublish/src/EventMeshClientPublish/Program.cs +++ /dev/null @@ -1,51 +0,0 @@ -using CloudNative.CloudEvents; -using FaasNet.EventMesh.Runtime; -using FaasNet.EventMesh.Runtime.Messages; -using System; -using System.Threading.Tasks; - -namespace EventMeshClientPublish -{ - public static class Program - { - public static void Main(string[] args) - { - var runtimeClient = new RuntimeClient("localhost", 4000); - var sessionId = CreateSession(runtimeClient).Result; - PublishMessage(runtimeClient, sessionId).Wait(); - Console.WriteLine("Please press enter to quit the application ..."); - Console.ReadLine(); - runtimeClient.Disconnect("pubClientId", sessionId).Wait(); - } - - private static async Task CreateSession(RuntimeClient runtimeClient) - { - var helloResponse = await runtimeClient.Hello(new UserAgent - { - ClientId = "pubClientId", - Environment = "TST", - Password = "password", - Pid = 2000, - BufferCloudEvents = 1, - Version = "0", - Purpose = UserAgentPurpose.PUB - }); - return helloResponse.SessionId; - } - private static Task PublishMessage(RuntimeClient runtimeClient, string sessionId) - { - var cloudEvent = new CloudEvent - { - Type = "com.github.pull.create", - Source = new Uri("https://github.com/cloudevents/spec/pull"), - Subject = "123", - Id = "A234-1234-1234", - Time = new DateTimeOffset(2018, 4, 5, 17, 31, 0, TimeSpan.Zero), - DataContentType = "application/json", - Data = "person is created", - ["comexampleextension1"] = "value" - }; - return runtimeClient.PublishMessage("pubClientId", sessionId, "Person.Created", cloudEvent); - } - } -} diff --git a/samples/EventMeshClientSubscribe/QuickStart.sln b/samples/EventMeshClientSubscribe/QuickStart.sln deleted file mode 100644 index 0d385c5f..00000000 --- a/samples/EventMeshClientSubscribe/QuickStart.sln +++ /dev/null @@ -1,30 +0,0 @@ - -Microsoft Visual Studio Solution File, Format Version 12.00 -# Visual Studio Version 16 -VisualStudioVersion = 16.0.30114.105 -MinimumVisualStudioVersion = 10.0.40219.1 -Project("{2150E333-8FDC-42A3-9474-1A3956D46DE8}") = "src", "src", "{59D7B5DC-BCAA-4D92-BAFE-B8ACB3938CF1}" -EndProject -Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "EventMeshClientSubscribe", "src\EventMeshClientSubscribe\EventMeshClientSubscribe.csproj", "{B69700FE-44B7-49E3-BFE6-D4EB29A3A549}" -EndProject -Global - GlobalSection(SolutionConfigurationPlatforms) = preSolution - Debug|Any CPU = Debug|Any CPU - Release|Any CPU = Release|Any CPU - EndGlobalSection - GlobalSection(ProjectConfigurationPlatforms) = postSolution - {B69700FE-44B7-49E3-BFE6-D4EB29A3A549}.Debug|Any CPU.ActiveCfg = Debug|Any CPU - {B69700FE-44B7-49E3-BFE6-D4EB29A3A549}.Debug|Any CPU.Build.0 = Debug|Any CPU - {B69700FE-44B7-49E3-BFE6-D4EB29A3A549}.Release|Any CPU.ActiveCfg = Release|Any CPU - {B69700FE-44B7-49E3-BFE6-D4EB29A3A549}.Release|Any CPU.Build.0 = Release|Any CPU - EndGlobalSection - GlobalSection(SolutionProperties) = preSolution - HideSolutionNode = FALSE - EndGlobalSection - GlobalSection(NestedProjects) = preSolution - {B69700FE-44B7-49E3-BFE6-D4EB29A3A549} = {59D7B5DC-BCAA-4D92-BAFE-B8ACB3938CF1} - EndGlobalSection - GlobalSection(ExtensibilityGlobals) = postSolution - SolutionGuid = {39996192-2263-4EA5-8E34-B6F564446302} - EndGlobalSection -EndGlobal diff --git a/samples/EventMeshClientSubscribe/src/EventMeshClientSubscribe/EventMeshClientSubscribe.csproj b/samples/EventMeshClientSubscribe/src/EventMeshClientSubscribe/EventMeshClientSubscribe.csproj deleted file mode 100644 index a5fded17..00000000 --- a/samples/EventMeshClientSubscribe/src/EventMeshClientSubscribe/EventMeshClientSubscribe.csproj +++ /dev/null @@ -1,9 +0,0 @@ - - - Exe - net5.0 - - - - - diff --git a/samples/EventMeshClientSubscribe/src/EventMeshClientSubscribe/Program.cs b/samples/EventMeshClientSubscribe/src/EventMeshClientSubscribe/Program.cs deleted file mode 100644 index 465661da..00000000 --- a/samples/EventMeshClientSubscribe/src/EventMeshClientSubscribe/Program.cs +++ /dev/null @@ -1,53 +0,0 @@ -using FaasNet.EventMesh.Runtime; -using FaasNet.EventMesh.Runtime.Messages; -using System; -using System.Collections.Generic; -using System.Linq; -using System.Threading.Tasks; - -namespace EventMeshClientSubscribe -{ - public static class Program - { - public static void Main(string[] args) - { - var runtimeClient = new RuntimeClient("localhost", 4000); - var sessionId = CreateSession(runtimeClient).Result; - var subscriptionResult = SubscribeTopic(runtimeClient, sessionId).Result; - Console.WriteLine("Please press enter to quit the application ..."); - Console.ReadLine(); - subscriptionResult.Stop(); - runtimeClient.Disconnect("clientId", sessionId).Wait(); - } - - private static async Task CreateSession(RuntimeClient runtimeClient) - { - var helloResponse = await runtimeClient.Hello(new UserAgent - { - ClientId = "clientId", - Environment = "TST", - Password = "password", - Pid = 2000, - BufferCloudEvents = 1, - Version = "0", - Purpose = UserAgentPurpose.SUB - }); - return helloResponse.SessionId; - } - - private static async Task SubscribeTopic(RuntimeClient runtimeClient, string sessionId) - { - return await runtimeClient.Subscribe("clientId", sessionId, new List - { - new SubscriptionItem - { - Topic = "Person.Created", - } - }, (msg) => - { - var cloudEvts = string.Join(",", msg.CloudEvents.Select(c => c.Data)); - Console.WriteLine($"Receive '{msg.CloudEvents.Count()}' messages: {cloudEvts}, BrokerName : {msg.BrokerName}, urn : {string.Join(',', msg.BridgeServers.Select(b => b.Urn))}"); - }); - } - } -} diff --git a/samples/EventMeshServerInMemory/QuickStart.sln b/samples/EventMeshServerInMemory/QuickStart.sln deleted file mode 100644 index c9b2b901..00000000 --- a/samples/EventMeshServerInMemory/QuickStart.sln +++ /dev/null @@ -1,30 +0,0 @@ - -Microsoft Visual Studio Solution File, Format Version 12.00 -# Visual Studio Version 16 -VisualStudioVersion = 16.0.30114.105 -MinimumVisualStudioVersion = 10.0.40219.1 -Project("{2150E333-8FDC-42A3-9474-1A3956D46DE8}") = "src", "src", "{B5CF35CA-56BA-4B02-9203-0A96AD268D74}" -EndProject -Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "EventMeshServer", "src\EventMeshServer\EventMeshServer.csproj", "{451E8741-AE59-4EA9-8FD3-337DE8697A58}" -EndProject -Global - GlobalSection(SolutionConfigurationPlatforms) = preSolution - Debug|Any CPU = Debug|Any CPU - Release|Any CPU = Release|Any CPU - EndGlobalSection - GlobalSection(ProjectConfigurationPlatforms) = postSolution - {451E8741-AE59-4EA9-8FD3-337DE8697A58}.Debug|Any CPU.ActiveCfg = Debug|Any CPU - {451E8741-AE59-4EA9-8FD3-337DE8697A58}.Debug|Any CPU.Build.0 = Debug|Any CPU - {451E8741-AE59-4EA9-8FD3-337DE8697A58}.Release|Any CPU.ActiveCfg = Release|Any CPU - {451E8741-AE59-4EA9-8FD3-337DE8697A58}.Release|Any CPU.Build.0 = Release|Any CPU - EndGlobalSection - GlobalSection(SolutionProperties) = preSolution - HideSolutionNode = FALSE - EndGlobalSection - GlobalSection(NestedProjects) = preSolution - {451E8741-AE59-4EA9-8FD3-337DE8697A58} = {B5CF35CA-56BA-4B02-9203-0A96AD268D74} - EndGlobalSection - GlobalSection(ExtensibilityGlobals) = postSolution - SolutionGuid = {EB3C5596-5570-4E5E-81B9-7B4B7A72B418} - EndGlobalSection -EndGlobal diff --git a/samples/EventMeshServerInMemory/src/EventMeshServer/EventMeshServer.csproj b/samples/EventMeshServerInMemory/src/EventMeshServer/EventMeshServer.csproj deleted file mode 100644 index a5fded17..00000000 --- a/samples/EventMeshServerInMemory/src/EventMeshServer/EventMeshServer.csproj +++ /dev/null @@ -1,9 +0,0 @@ - - - Exe - net5.0 - - - - - diff --git a/samples/EventMeshServerInMemory/src/EventMeshServer/Program.cs b/samples/EventMeshServerInMemory/src/EventMeshServer/Program.cs deleted file mode 100644 index 27c60143..00000000 --- a/samples/EventMeshServerInMemory/src/EventMeshServer/Program.cs +++ /dev/null @@ -1,36 +0,0 @@ -using FaasNet.EventMesh.Runtime; -using FaasNet.EventMesh.Runtime.MessageBroker; -using System; -using System.Collections.Concurrent; - -namespace EventMeshServer -{ - public static class Program - { - public static void Main(string[] args) - { - var host = RunInMemoryEventMeshServer(); - Console.WriteLine("Please press Enter to stop the EventMeshServer"); - Console.ReadLine(); - host.Stop(); - Console.WriteLine("The EventMeshServer is stopped..."); - Console.WriteLine("Please press Enter to quit the application"); - Console.ReadLine(); - } - - private static IRuntimeHost RunInMemoryEventMeshServer() - { - const int port = 4000; - const string urn = "localhost"; - var builder = new RuntimeHostBuilder(opt => - { - opt.Port = port; - opt.Urn = urn; - }).AddInMemoryMessageBroker(new ConcurrentBag()); - var host = builder.Build(); - host.Run(); - Console.WriteLine($"The EventMeshServer is started on '{urn}:{port}'"); - return host; - } - } -} diff --git a/samples/EventMeshServerKafka/QuickStart/QuickStart.sln b/samples/EventMeshServerKafka/QuickStart/QuickStart.sln deleted file mode 100644 index dd9283e4..00000000 --- a/samples/EventMeshServerKafka/QuickStart/QuickStart.sln +++ /dev/null @@ -1,39 +0,0 @@ - -Microsoft Visual Studio Solution File, Format Version 12.00 -# Visual Studio Version 16 -VisualStudioVersion = 16.0.30114.105 -MinimumVisualStudioVersion = 10.0.40219.1 -Project("{2150E333-8FDC-42A3-9474-1A3956D46DE8}") = "src", "src", "{33C7B783-B72D-4ED3-B1D1-E503FE96905B}" -EndProject -Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "EventMeshServer", "src\EventMeshServer\EventMeshServer.csproj", "{C22FC568-BB87-4BDF-B05C-0E82126F947C}" -EndProject -Global - GlobalSection(SolutionConfigurationPlatforms) = preSolution - Debug|Any CPU = Debug|Any CPU - Debug|x64 = Debug|x64 - Debug|x86 = Debug|x86 - Release|Any CPU = Release|Any CPU - Release|x64 = Release|x64 - Release|x86 = Release|x86 - EndGlobalSection - GlobalSection(SolutionProperties) = preSolution - HideSolutionNode = FALSE - EndGlobalSection - GlobalSection(ProjectConfigurationPlatforms) = postSolution - {C22FC568-BB87-4BDF-B05C-0E82126F947C}.Debug|Any CPU.ActiveCfg = Debug|Any CPU - {C22FC568-BB87-4BDF-B05C-0E82126F947C}.Debug|Any CPU.Build.0 = Debug|Any CPU - {C22FC568-BB87-4BDF-B05C-0E82126F947C}.Debug|x64.ActiveCfg = Debug|Any CPU - {C22FC568-BB87-4BDF-B05C-0E82126F947C}.Debug|x64.Build.0 = Debug|Any CPU - {C22FC568-BB87-4BDF-B05C-0E82126F947C}.Debug|x86.ActiveCfg = Debug|Any CPU - {C22FC568-BB87-4BDF-B05C-0E82126F947C}.Debug|x86.Build.0 = Debug|Any CPU - {C22FC568-BB87-4BDF-B05C-0E82126F947C}.Release|Any CPU.ActiveCfg = Release|Any CPU - {C22FC568-BB87-4BDF-B05C-0E82126F947C}.Release|Any CPU.Build.0 = Release|Any CPU - {C22FC568-BB87-4BDF-B05C-0E82126F947C}.Release|x64.ActiveCfg = Release|Any CPU - {C22FC568-BB87-4BDF-B05C-0E82126F947C}.Release|x64.Build.0 = Release|Any CPU - {C22FC568-BB87-4BDF-B05C-0E82126F947C}.Release|x86.ActiveCfg = Release|Any CPU - {C22FC568-BB87-4BDF-B05C-0E82126F947C}.Release|x86.Build.0 = Release|Any CPU - EndGlobalSection - GlobalSection(NestedProjects) = preSolution - {C22FC568-BB87-4BDF-B05C-0E82126F947C} = {33C7B783-B72D-4ED3-B1D1-E503FE96905B} - EndGlobalSection -EndGlobal diff --git a/samples/EventMeshServerKafka/QuickStart/src/EventMeshServer/EventMeshServer.csproj b/samples/EventMeshServerKafka/QuickStart/src/EventMeshServer/EventMeshServer.csproj deleted file mode 100644 index 03888458..00000000 --- a/samples/EventMeshServerKafka/QuickStart/src/EventMeshServer/EventMeshServer.csproj +++ /dev/null @@ -1,9 +0,0 @@ - - - Exe - net5.0 - - - - - diff --git a/samples/EventMeshServerKafka/QuickStart/src/EventMeshServer/Program.cs b/samples/EventMeshServerKafka/QuickStart/src/EventMeshServer/Program.cs deleted file mode 100644 index db0b415e..00000000 --- a/samples/EventMeshServerKafka/QuickStart/src/EventMeshServer/Program.cs +++ /dev/null @@ -1,34 +0,0 @@ -using FaasNet.EventMesh.Runtime; -using System; - -namespace EventMeshServer -{ - public static class Program - { - public static void Main(string[] args) - { - var host = RunKafkaEventMeshServer(); - Console.WriteLine("Please press Enter to stop the EventMeshServer"); - Console.ReadLine(); - host.Stop(); - Console.WriteLine("The EventMeshServer is stopped..."); - Console.WriteLine("Please press Enter to quit the application"); - Console.ReadLine(); - } - - private static IRuntimeHost RunKafkaEventMeshServer() - { - const int port = 4000; - const string urn = "localhost"; - var builder = new RuntimeHostBuilder(opt => - { - opt.Port = port; - opt.Urn = urn; - }).AddKafka(); - var host = builder.Build(); - host.Run(); - Console.WriteLine($"The EventMeshServer is started on '{urn}:{port}'"); - return host; - } - } -} diff --git a/samples/EventMeshServerRabbitMQ/QuickStart/QuickStart.sln b/samples/EventMeshServerRabbitMQ/QuickStart/QuickStart.sln deleted file mode 100644 index 8bd5dfaf..00000000 --- a/samples/EventMeshServerRabbitMQ/QuickStart/QuickStart.sln +++ /dev/null @@ -1,39 +0,0 @@ - -Microsoft Visual Studio Solution File, Format Version 12.00 -# Visual Studio Version 16 -VisualStudioVersion = 16.0.30114.105 -MinimumVisualStudioVersion = 10.0.40219.1 -Project("{2150E333-8FDC-42A3-9474-1A3956D46DE8}") = "src", "src", "{4C6EBAD3-E844-4707-AE03-2346A28E59AF}" -EndProject -Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "EventMeshServer", "src\EventMeshServer\EventMeshServer.csproj", "{AE2A36F4-2959-4029-B886-16470A0FD564}" -EndProject -Global - GlobalSection(SolutionConfigurationPlatforms) = preSolution - Debug|Any CPU = Debug|Any CPU - Debug|x64 = Debug|x64 - Debug|x86 = Debug|x86 - Release|Any CPU = Release|Any CPU - Release|x64 = Release|x64 - Release|x86 = Release|x86 - EndGlobalSection - GlobalSection(SolutionProperties) = preSolution - HideSolutionNode = FALSE - EndGlobalSection - GlobalSection(ProjectConfigurationPlatforms) = postSolution - {AE2A36F4-2959-4029-B886-16470A0FD564}.Debug|Any CPU.ActiveCfg = Debug|Any CPU - {AE2A36F4-2959-4029-B886-16470A0FD564}.Debug|Any CPU.Build.0 = Debug|Any CPU - {AE2A36F4-2959-4029-B886-16470A0FD564}.Debug|x64.ActiveCfg = Debug|Any CPU - {AE2A36F4-2959-4029-B886-16470A0FD564}.Debug|x64.Build.0 = Debug|Any CPU - {AE2A36F4-2959-4029-B886-16470A0FD564}.Debug|x86.ActiveCfg = Debug|Any CPU - {AE2A36F4-2959-4029-B886-16470A0FD564}.Debug|x86.Build.0 = Debug|Any CPU - {AE2A36F4-2959-4029-B886-16470A0FD564}.Release|Any CPU.ActiveCfg = Release|Any CPU - {AE2A36F4-2959-4029-B886-16470A0FD564}.Release|Any CPU.Build.0 = Release|Any CPU - {AE2A36F4-2959-4029-B886-16470A0FD564}.Release|x64.ActiveCfg = Release|Any CPU - {AE2A36F4-2959-4029-B886-16470A0FD564}.Release|x64.Build.0 = Release|Any CPU - {AE2A36F4-2959-4029-B886-16470A0FD564}.Release|x86.ActiveCfg = Release|Any CPU - {AE2A36F4-2959-4029-B886-16470A0FD564}.Release|x86.Build.0 = Release|Any CPU - EndGlobalSection - GlobalSection(NestedProjects) = preSolution - {AE2A36F4-2959-4029-B886-16470A0FD564} = {4C6EBAD3-E844-4707-AE03-2346A28E59AF} - EndGlobalSection -EndGlobal diff --git a/samples/EventMeshServerRabbitMQ/QuickStart/src/EventMeshServer/EventMeshServer.csproj b/samples/EventMeshServerRabbitMQ/QuickStart/src/EventMeshServer/EventMeshServer.csproj deleted file mode 100644 index a86e778e..00000000 --- a/samples/EventMeshServerRabbitMQ/QuickStart/src/EventMeshServer/EventMeshServer.csproj +++ /dev/null @@ -1,9 +0,0 @@ - - - Exe - net5.0 - - - - - diff --git a/samples/EventMeshServerRabbitMQ/QuickStart/src/EventMeshServer/Program.cs b/samples/EventMeshServerRabbitMQ/QuickStart/src/EventMeshServer/Program.cs deleted file mode 100644 index b2c4d14c..00000000 --- a/samples/EventMeshServerRabbitMQ/QuickStart/src/EventMeshServer/Program.cs +++ /dev/null @@ -1,34 +0,0 @@ -using FaasNet.EventMesh.Runtime; -using System; - -namespace EventMeshServer -{ - public static class Program - { - public static void Main(string[] args) - { - var host = RunRabbitMQEventMeshServer(); - Console.WriteLine("Please press Enter to stop the EventMeshServer"); - Console.ReadLine(); - host.Stop(); - Console.WriteLine("The EventMeshServer is stopped..."); - Console.WriteLine("Please press Enter to quit the application"); - Console.ReadLine(); - } - - private static IRuntimeHost RunRabbitMQEventMeshServer() - { - const int port = 4000; - const string urn = "localhost"; - var builder = new RuntimeHostBuilder(opt => - { - opt.Port = port; - opt.Urn = urn; - }).AddAMQP(); - var host = builder.Build(); - host.Run(); - Console.WriteLine($"The EventMeshServer is started on '{urn}:{port}'"); - return host; - } - } -} diff --git a/src/Samples/FaasNet.EventMesh.EtcdCluster/docker-compose.yml b/src/Samples/FaasNet.EventMesh.EtcdCluster/docker-compose.yml index 56d74110..73fac4c9 100644 --- a/src/Samples/FaasNet.EventMesh.EtcdCluster/docker-compose.yml +++ b/src/Samples/FaasNet.EventMesh.EtcdCluster/docker-compose.yml @@ -1,14 +1,14 @@ version: '2' services: evtmeshnode1: - image: 'eventmesh' + image: 'simpleidserver/faaseventmesh:0.0.6' environment: EVENTMESH_PLUGIN: "discoveryetcd" ASPNETCORE_ENVIRONMENT: "dockerfirstnode" ports: - "4001:4000/udp" evtmeshnode2: - image: 'eventmesh' + image: 'simpleidserver/faaseventmesh:0.0.6' environment: EVENTMESH_PLUGIN: "discoveryetcd" ASPNETCORE_ENVIRONMENT: "dockersecondnode" diff --git a/src/Samples/FaasNet.EventMesh.TwoCluster/docker-compose.yml b/src/Samples/FaasNet.EventMesh.TwoCluster/docker-compose.yml index 25e29b59..03cf1c8b 100644 --- a/src/Samples/FaasNet.EventMesh.TwoCluster/docker-compose.yml +++ b/src/Samples/FaasNet.EventMesh.TwoCluster/docker-compose.yml @@ -1,13 +1,13 @@ version: '2' services: evtmeshnode1: - image: 'eventmesh' + image: 'simpleidserver/faaseventmesh:0.0.6' environment: ASPNETCORE_ENVIRONMENT: "dockerfirstnode" ports: - "4001:4000/udp" evtmeshnode2: - image: 'eventmesh' + image: 'simpleidserver/faaseventmesh:0.0.6' environment: ASPNETCORE_ENVIRONMENT: "dockersecondnode" ports: