Skip to content

Commit d56cd24

Browse files
habarthierry-huehabarthierry-hue
committed
Ticket #111 : WIP
1 parent 126e514 commit d56cd24

55 files changed

Lines changed: 260 additions & 173 deletions

File tree

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

‎FaasNet.EventMesh.sln‎

Lines changed: 35 additions & 42 deletions
Original file line numberDiff line numberDiff line change
@@ -29,26 +29,16 @@ Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "FaasNet.RaftConsensus.Clien
2929
EndProject
3030
Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "FaasNet.RaftConsensus.RocksDB", "src\RaftConsensus\FaasNet.RaftConsensus.RocksDB\FaasNet.RaftConsensus.RocksDB.csproj", "{7C4A643C-FEE8-484E-BE0B-8842FB986F20}"
3131
EndProject
32-
Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "FaasNet.EventMesh.Seed", "src\EventMesh\FaasNet.EventMesh.Seed\FaasNet.EventMesh.Seed.csproj", "{667C381E-E073-4D5C-A6F4-ADFC8EA9D4A0}"
33-
EndProject
34-
Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "FaasNet.EventMesh.Seed.AMQP", "src\EventMesh\FaasNet.EventMesh.Seed.AMQP\FaasNet.EventMesh.Seed.AMQP.csproj", "{2DDF1EB1-B20F-419F-9A09-34A5550D4467}"
35-
EndProject
36-
Project("{2150E333-8FDC-42A3-9474-1A3956D46DE8}") = "01. Seeds", "01. Seeds", "{B7CDEBEF-C508-4EFA-BEC9-9D9D6E5D80C5}"
32+
Project("{2150E333-8FDC-42A3-9474-1A3956D46DE8}") = "01. Sinks", "01. Sinks", "{B7CDEBEF-C508-4EFA-BEC9-9D9D6E5D80C5}"
3733
EndProject
3834
Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "FaasNet.Common", "src\Common\FaasNet.Common\FaasNet.Common.csproj", "{2D703121-6391-42AB-8D68-8AD85EB5BB4B}"
3935
EndProject
40-
Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "FaasNet.EventMesh.Seed.Kafka", "src\EventMesh\FaasNet.EventMesh.Seed.Kafka\FaasNet.EventMesh.Seed.Kafka.csproj", "{07C9335C-511F-49A1-AD60-BB0C709971C4}"
41-
EndProject
4236
Project("{2150E333-8FDC-42A3-9474-1A3956D46DE8}") = "02. Protocols", "02. Protocols", "{225E35C4-C3C2-4319-96BF-CBF86DCB5C46}"
4337
EndProject
4438
Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "FaasNet.EventMesh.Protocols.AMQP", "src\EventMesh\FaasNet.EventMesh.Protocols.AMQP\FaasNet.EventMesh.Protocols.AMQP.csproj", "{3442A638-E7C0-45CC-8A7D-F2A40D65AB93}"
4539
EndProject
4640
Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "FaasNet.EventMesh.Protocols", "src\EventMesh\FaasNet.EventMesh.Protocols\FaasNet.EventMesh.Protocols.csproj", "{E90801D3-9D40-4B3F-AA3F-4015C03262A5}"
4741
EndProject
48-
Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "FaasNet.EventMesh.Seed.RocksDB", "src\EventMesh\FaasNet.EventMesh.Seed.RocksDB\FaasNet.EventMesh.Seed.RocksDB.csproj", "{BC11A4F8-00BE-431C-9F15-75D4F8106DFF}"
49-
EndProject
50-
Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "FaasNet.EventMesh.Seed.VpnBridge", "src\EventMesh\FaasNet.EventMesh.Seed.VpnBridge\FaasNet.EventMesh.Seed.VpnBridge.csproj", "{FC1A6988-7E69-492A-B7EF-73E481D80FEB}"
51-
EndProject
5242
Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "FaasNet.EventMesh.Common", "src\EventMesh\FaasNet.EventMesh.Common\FaasNet.EventMesh.Common.csproj", "{6884598F-5743-4A2A-B3B9-679FEDA81D6B}"
5343
EndProject
5444
Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "FaasNet.EventMesh.FirstConsole", "src\EventMesh\FaasNet.EventMesh.FirstConsole\FaasNet.EventMesh.FirstConsole.csproj", "{394401D8-D005-49E1-A735-47284C034D44}"
@@ -69,7 +59,15 @@ Project("{2150E333-8FDC-42A3-9474-1A3956D46DE8}") = "05. CLI Layer", "05. CLI La
6959
EndProject
7060
Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "FaasNet.EventMeshCTL.CLI", "src\EventMesh\FaasNet.EventMeshCTL.CLI\FaasNet.EventMeshCTL.CLI.csproj", "{294141B6-1F8D-43D9-BF3E-5A86FFD8F38D}"
7161
EndProject
72-
Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "FaasNet.Plugin", "src\Common\FaasNet.Plugin\FaasNet.Plugin.csproj", "{EEAF94A6-E863-4349-8A44-74DCC55F6607}"
62+
Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "FaasNet.EventMesh.Sink", "src\EventMesh\FaasNet.EventMesh.Sink\FaasNet.EventMesh.Sink.csproj", "{71DE726F-A922-4180-A154-6144906ADCF0}"
63+
EndProject
64+
Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "FaasNet.EventMesh.Sink.AMQP", "src\EventMesh\FaasNet.EventMesh.Sink.AMQP\FaasNet.EventMesh.Sink.AMQP.csproj", "{D2869D6E-AB7B-4E12-B34C-325FB91BC560}"
65+
EndProject
66+
Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "FaasNet.EventMesh.Sink.Kafka", "src\EventMesh\FaasNet.EventMesh.Sink.Kafka\FaasNet.EventMesh.Sink.Kafka.csproj", "{2DCA720C-ABB8-4917-B5FE-A2393E79A76F}"
67+
EndProject
68+
Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "FaasNet.EventMesh.Sink.VpnBridge", "src\EventMesh\FaasNet.EventMesh.Sink.VpnBridge\FaasNet.EventMesh.Sink.VpnBridge.csproj", "{01E4D8EF-A594-4497-B1CA-D17372656006}"
69+
EndProject
70+
Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "FaasNet.EventMesh.Sink.RocksDB", "src\EventMesh\FaasNet.EventMesh.Sink.RocksDB\FaasNet.EventMesh.Sink.RocksDB.csproj", "{810659FD-5FAE-41B8-BC14-4499B6993CFB}"
7371
EndProject
7472
Global
7573
GlobalSection(SolutionConfigurationPlatforms) = preSolution
@@ -109,22 +107,10 @@ Global
109107
{7C4A643C-FEE8-484E-BE0B-8842FB986F20}.Debug|Any CPU.Build.0 = Debug|Any CPU
110108
{7C4A643C-FEE8-484E-BE0B-8842FB986F20}.Release|Any CPU.ActiveCfg = Release|Any CPU
111109
{7C4A643C-FEE8-484E-BE0B-8842FB986F20}.Release|Any CPU.Build.0 = Release|Any CPU
112-
{667C381E-E073-4D5C-A6F4-ADFC8EA9D4A0}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
113-
{667C381E-E073-4D5C-A6F4-ADFC8EA9D4A0}.Debug|Any CPU.Build.0 = Debug|Any CPU
114-
{667C381E-E073-4D5C-A6F4-ADFC8EA9D4A0}.Release|Any CPU.ActiveCfg = Release|Any CPU
115-
{667C381E-E073-4D5C-A6F4-ADFC8EA9D4A0}.Release|Any CPU.Build.0 = Release|Any CPU
116-
{2DDF1EB1-B20F-419F-9A09-34A5550D4467}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
117-
{2DDF1EB1-B20F-419F-9A09-34A5550D4467}.Debug|Any CPU.Build.0 = Debug|Any CPU
118-
{2DDF1EB1-B20F-419F-9A09-34A5550D4467}.Release|Any CPU.ActiveCfg = Release|Any CPU
119-
{2DDF1EB1-B20F-419F-9A09-34A5550D4467}.Release|Any CPU.Build.0 = Release|Any CPU
120110
{2D703121-6391-42AB-8D68-8AD85EB5BB4B}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
121111
{2D703121-6391-42AB-8D68-8AD85EB5BB4B}.Debug|Any CPU.Build.0 = Debug|Any CPU
122112
{2D703121-6391-42AB-8D68-8AD85EB5BB4B}.Release|Any CPU.ActiveCfg = Release|Any CPU
123113
{2D703121-6391-42AB-8D68-8AD85EB5BB4B}.Release|Any CPU.Build.0 = Release|Any CPU
124-
{07C9335C-511F-49A1-AD60-BB0C709971C4}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
125-
{07C9335C-511F-49A1-AD60-BB0C709971C4}.Debug|Any CPU.Build.0 = Debug|Any CPU
126-
{07C9335C-511F-49A1-AD60-BB0C709971C4}.Release|Any CPU.ActiveCfg = Release|Any CPU
127-
{07C9335C-511F-49A1-AD60-BB0C709971C4}.Release|Any CPU.Build.0 = Release|Any CPU
128114
{3442A638-E7C0-45CC-8A7D-F2A40D65AB93}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
129115
{3442A638-E7C0-45CC-8A7D-F2A40D65AB93}.Debug|Any CPU.Build.0 = Debug|Any CPU
130116
{3442A638-E7C0-45CC-8A7D-F2A40D65AB93}.Release|Any CPU.ActiveCfg = Release|Any CPU
@@ -133,14 +119,6 @@ Global
133119
{E90801D3-9D40-4B3F-AA3F-4015C03262A5}.Debug|Any CPU.Build.0 = Debug|Any CPU
134120
{E90801D3-9D40-4B3F-AA3F-4015C03262A5}.Release|Any CPU.ActiveCfg = Release|Any CPU
135121
{E90801D3-9D40-4B3F-AA3F-4015C03262A5}.Release|Any CPU.Build.0 = Release|Any CPU
136-
{BC11A4F8-00BE-431C-9F15-75D4F8106DFF}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
137-
{BC11A4F8-00BE-431C-9F15-75D4F8106DFF}.Debug|Any CPU.Build.0 = Debug|Any CPU
138-
{BC11A4F8-00BE-431C-9F15-75D4F8106DFF}.Release|Any CPU.ActiveCfg = Release|Any CPU
139-
{BC11A4F8-00BE-431C-9F15-75D4F8106DFF}.Release|Any CPU.Build.0 = Release|Any CPU
140-
{FC1A6988-7E69-492A-B7EF-73E481D80FEB}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
141-
{FC1A6988-7E69-492A-B7EF-73E481D80FEB}.Debug|Any CPU.Build.0 = Debug|Any CPU
142-
{FC1A6988-7E69-492A-B7EF-73E481D80FEB}.Release|Any CPU.ActiveCfg = Release|Any CPU
143-
{FC1A6988-7E69-492A-B7EF-73E481D80FEB}.Release|Any CPU.Build.0 = Release|Any CPU
144122
{6884598F-5743-4A2A-B3B9-679FEDA81D6B}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
145123
{6884598F-5743-4A2A-B3B9-679FEDA81D6B}.Debug|Any CPU.Build.0 = Debug|Any CPU
146124
{6884598F-5743-4A2A-B3B9-679FEDA81D6B}.Release|Any CPU.ActiveCfg = Release|Any CPU
@@ -169,10 +147,26 @@ Global
169147
{294141B6-1F8D-43D9-BF3E-5A86FFD8F38D}.Debug|Any CPU.Build.0 = Debug|Any CPU
170148
{294141B6-1F8D-43D9-BF3E-5A86FFD8F38D}.Release|Any CPU.ActiveCfg = Release|Any CPU
171149
{294141B6-1F8D-43D9-BF3E-5A86FFD8F38D}.Release|Any CPU.Build.0 = Release|Any CPU
172-
{EEAF94A6-E863-4349-8A44-74DCC55F6607}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
173-
{EEAF94A6-E863-4349-8A44-74DCC55F6607}.Debug|Any CPU.Build.0 = Debug|Any CPU
174-
{EEAF94A6-E863-4349-8A44-74DCC55F6607}.Release|Any CPU.ActiveCfg = Release|Any CPU
175-
{EEAF94A6-E863-4349-8A44-74DCC55F6607}.Release|Any CPU.Build.0 = Release|Any CPU
150+
{71DE726F-A922-4180-A154-6144906ADCF0}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
151+
{71DE726F-A922-4180-A154-6144906ADCF0}.Debug|Any CPU.Build.0 = Debug|Any CPU
152+
{71DE726F-A922-4180-A154-6144906ADCF0}.Release|Any CPU.ActiveCfg = Release|Any CPU
153+
{71DE726F-A922-4180-A154-6144906ADCF0}.Release|Any CPU.Build.0 = Release|Any CPU
154+
{D2869D6E-AB7B-4E12-B34C-325FB91BC560}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
155+
{D2869D6E-AB7B-4E12-B34C-325FB91BC560}.Debug|Any CPU.Build.0 = Debug|Any CPU
156+
{D2869D6E-AB7B-4E12-B34C-325FB91BC560}.Release|Any CPU.ActiveCfg = Release|Any CPU
157+
{D2869D6E-AB7B-4E12-B34C-325FB91BC560}.Release|Any CPU.Build.0 = Release|Any CPU
158+
{2DCA720C-ABB8-4917-B5FE-A2393E79A76F}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
159+
{2DCA720C-ABB8-4917-B5FE-A2393E79A76F}.Debug|Any CPU.Build.0 = Debug|Any CPU
160+
{2DCA720C-ABB8-4917-B5FE-A2393E79A76F}.Release|Any CPU.ActiveCfg = Release|Any CPU
161+
{2DCA720C-ABB8-4917-B5FE-A2393E79A76F}.Release|Any CPU.Build.0 = Release|Any CPU
162+
{01E4D8EF-A594-4497-B1CA-D17372656006}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
163+
{01E4D8EF-A594-4497-B1CA-D17372656006}.Debug|Any CPU.Build.0 = Debug|Any CPU
164+
{01E4D8EF-A594-4497-B1CA-D17372656006}.Release|Any CPU.ActiveCfg = Release|Any CPU
165+
{01E4D8EF-A594-4497-B1CA-D17372656006}.Release|Any CPU.Build.0 = Release|Any CPU
166+
{810659FD-5FAE-41B8-BC14-4499B6993CFB}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
167+
{810659FD-5FAE-41B8-BC14-4499B6993CFB}.Debug|Any CPU.Build.0 = Debug|Any CPU
168+
{810659FD-5FAE-41B8-BC14-4499B6993CFB}.Release|Any CPU.ActiveCfg = Release|Any CPU
169+
{810659FD-5FAE-41B8-BC14-4499B6993CFB}.Release|Any CPU.Build.0 = Release|Any CPU
176170
EndGlobalSection
177171
GlobalSection(SolutionProperties) = preSolution
178172
HideSolutionNode = FALSE
@@ -186,16 +180,11 @@ Global
186180
{69259CDF-1E32-4310-9155-BC095FFDBECD} = {7A13262A-D1E6-4210-BA95-03A0741CBFA4}
187181
{9FD70B89-220D-47E7-958D-E10F493F9436} = {7A13262A-D1E6-4210-BA95-03A0741CBFA4}
188182
{7C4A643C-FEE8-484E-BE0B-8842FB986F20} = {7A13262A-D1E6-4210-BA95-03A0741CBFA4}
189-
{667C381E-E073-4D5C-A6F4-ADFC8EA9D4A0} = {B7CDEBEF-C508-4EFA-BEC9-9D9D6E5D80C5}
190-
{2DDF1EB1-B20F-419F-9A09-34A5550D4467} = {B7CDEBEF-C508-4EFA-BEC9-9D9D6E5D80C5}
191183
{B7CDEBEF-C508-4EFA-BEC9-9D9D6E5D80C5} = {6E495E0A-0DC8-4E42-8C58-3C48506D3D24}
192184
{2D703121-6391-42AB-8D68-8AD85EB5BB4B} = {7A13262A-D1E6-4210-BA95-03A0741CBFA4}
193-
{07C9335C-511F-49A1-AD60-BB0C709971C4} = {B7CDEBEF-C508-4EFA-BEC9-9D9D6E5D80C5}
194185
{225E35C4-C3C2-4319-96BF-CBF86DCB5C46} = {6E495E0A-0DC8-4E42-8C58-3C48506D3D24}
195186
{3442A638-E7C0-45CC-8A7D-F2A40D65AB93} = {225E35C4-C3C2-4319-96BF-CBF86DCB5C46}
196187
{E90801D3-9D40-4B3F-AA3F-4015C03262A5} = {225E35C4-C3C2-4319-96BF-CBF86DCB5C46}
197-
{BC11A4F8-00BE-431C-9F15-75D4F8106DFF} = {B7CDEBEF-C508-4EFA-BEC9-9D9D6E5D80C5}
198-
{FC1A6988-7E69-492A-B7EF-73E481D80FEB} = {B7CDEBEF-C508-4EFA-BEC9-9D9D6E5D80C5}
199188
{6884598F-5743-4A2A-B3B9-679FEDA81D6B} = {20A0BD99-A4F3-4FD5-A6FA-1935D7464DB8}
200189
{394401D8-D005-49E1-A735-47284C034D44} = {20A0BD99-A4F3-4FD5-A6FA-1935D7464DB8}
201190
{FBD50A91-127A-44F7-BF12-4666448086B9} = {20A0BD99-A4F3-4FD5-A6FA-1935D7464DB8}
@@ -204,7 +193,11 @@ Global
204193
{D581D830-5A97-451F-96C5-8AC513EC308D} = {8B617B76-FFD2-4DBE-921E-B7DB73309530}
205194
{21CC76FF-FA0A-4FF2-A0A1-78A8C107FCEE} = {F9148CB9-8CA8-43BA-85F2-46C94AF624D7}
206195
{294141B6-1F8D-43D9-BF3E-5A86FFD8F38D} = {E7E305E3-DDFE-4523-8343-82C62884A323}
207-
{EEAF94A6-E863-4349-8A44-74DCC55F6607} = {7A13262A-D1E6-4210-BA95-03A0741CBFA4}
196+
{71DE726F-A922-4180-A154-6144906ADCF0} = {B7CDEBEF-C508-4EFA-BEC9-9D9D6E5D80C5}
197+
{D2869D6E-AB7B-4E12-B34C-325FB91BC560} = {B7CDEBEF-C508-4EFA-BEC9-9D9D6E5D80C5}
198+
{2DCA720C-ABB8-4917-B5FE-A2393E79A76F} = {B7CDEBEF-C508-4EFA-BEC9-9D9D6E5D80C5}
199+
{01E4D8EF-A594-4497-B1CA-D17372656006} = {B7CDEBEF-C508-4EFA-BEC9-9D9D6E5D80C5}
200+
{810659FD-5FAE-41B8-BC14-4499B6993CFB} = {B7CDEBEF-C508-4EFA-BEC9-9D9D6E5D80C5}
208201
EndGlobalSection
209202
GlobalSection(ExtensibilityGlobals) = postSolution
210203
SolutionGuid = {B9BD3B8C-B2C9-468F-BF54-66BFE9B565EC}

‎default.ps1‎

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -61,7 +61,8 @@ task publishDocker {
6161
}
6262

6363
task publishEventMeshPlugins {
64-
exec { dotnet publish $source_dir\EventMesh\FaasNet.EventMesh.Protocols.AMQP\FaasNet.EventMesh.Protocols.AMQP.csproj -c $config -o $result_dir\eventMeshServicePlugins\FaasNet.EventMesh.Protocols.AMQP }
64+
exec { dotnet publish $source_dir\EventMesh\FaasNet.EventMesh.Protocols.AMQP\FaasNet.EventMesh.Protocols.AMQP.csproj -c $config -o $result_dir\protocolPlugins\FaasNet.EventMesh.Protocols.AMQP }
65+
exec { dotnet publish $source_dir\EventMesh\FaasNet.EventMesh.Protocols.WebSocket\FaasNet.EventMesh.Protocols.WebSocket.csproj -c $config -o $result_dir\protocolPlugins\FaasNet.EventMesh.Protocols.WebSocket }
6566
}
6667

6768
task publishEventMeshService {

‎src/Common/FaasNet.Plugin/FaasNet.Plugin.csproj‎

Lines changed: 0 additions & 11 deletions
This file was deleted.

‎src/EventMesh/FaasNet.EventMesh.Common/ConsoleHelper.cs‎

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -2,7 +2,7 @@
22
using FaasNet.EventMesh.Client;
33
using FaasNet.EventMesh.Client.Messages;
44
using FaasNet.EventMesh.Protocols;
5-
using FaasNet.EventMesh.Seed;
5+
using FaasNet.EventMesh.Sink;
66
using FaasNet.RaftConsensus.Core;
77
using Microsoft.Extensions.DependencyInjection;
88
using System;
@@ -269,7 +269,7 @@ private static async Task StartAMQPSeed()
269269
};
270270
}).UseSeedRocksDB();
271271
var serviceProvider = serviceCollection.BuildServiceProvider();
272-
var seedJob = serviceProvider.GetRequiredService<ISeedJob>();
272+
var seedJob = serviceProvider.GetRequiredService<ISinkJob>();
273273
await seedJob.Start(CancellationToken.None);
274274
}
275275

@@ -281,7 +281,7 @@ private static async Task StartVpnBridgeSeed()
281281
o.EventMeshPort = _seedPort;
282282
}).UseSeedRocksDB(); ;
283283
var serviceProvider = serviceCollection.BuildServiceProvider();
284-
var seedJob = serviceProvider.GetRequiredService<ISeedJob>();
284+
var seedJob = serviceProvider.GetRequiredService<ISinkJob>();
285285
await seedJob.Start(CancellationToken.None);
286286
}
287287

@@ -299,7 +299,7 @@ private static async Task StartKafkaSeed()
299299
kafka.BootstrapServers = "localhost:29092";
300300
}).UseSeedRocksDB();
301301
var serviceProvider = serviceCollection.BuildServiceProvider();
302-
var seedJob = serviceProvider.GetRequiredService<ISeedJob>();
302+
var seedJob = serviceProvider.GetRequiredService<ISinkJob>();
303303
await seedJob.Start(CancellationToken.None);
304304
}
305305
}

‎src/EventMesh/FaasNet.EventMesh.Common/FaasNet.EventMesh.Common.csproj‎

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -15,9 +15,9 @@
1515
<ProjectReference Include="..\FaasNet.EventMesh.Protocols.AMQP\FaasNet.EventMesh.Protocols.AMQP.csproj" />
1616
<ProjectReference Include="..\FaasNet.EventMesh.Protocols.WebSocket\FaasNet.EventMesh.Protocols.WebSocket.csproj" />
1717
<ProjectReference Include="..\FaasNet.EventMesh.Runtime\FaasNet.EventMesh.Runtime.csproj" />
18-
<ProjectReference Include="..\FaasNet.EventMesh.Seed.AMQP\FaasNet.EventMesh.Seed.AMQP.csproj" />
19-
<ProjectReference Include="..\FaasNet.EventMesh.Seed.Kafka\FaasNet.EventMesh.Seed.Kafka.csproj" />
20-
<ProjectReference Include="..\FaasNet.EventMesh.Seed.RocksDB\FaasNet.EventMesh.Seed.RocksDB.csproj" />
21-
<ProjectReference Include="..\FaasNet.EventMesh.Seed.VpnBridge\FaasNet.EventMesh.Seed.VpnBridge.csproj" />
18+
<ProjectReference Include="..\FaasNet.EventMesh.Sink.AMQP\FaasNet.EventMesh.Sink.AMQP.csproj" />
19+
<ProjectReference Include="..\FaasNet.EventMesh.Sink.Kafka\FaasNet.EventMesh.Sink.Kafka.csproj" />
20+
<ProjectReference Include="..\FaasNet.EventMesh.Sink.RocksDB\FaasNet.EventMesh.Sink.RocksDB.csproj" />
21+
<ProjectReference Include="..\FaasNet.EventMesh.Sink.VpnBridge\FaasNet.EventMesh.Sink.VpnBridge.csproj" />
2222
</ItemGroup>
2323
</Project>

‎src/EventMesh/FaasNet.EventMesh.Protocols.AMQP/EventMeshAMQPPlugin.cs‎

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1,9 +1,8 @@
1-
using FaasNet.Plugin;
2-
using Microsoft.Extensions.DependencyInjection;
1+
using Microsoft.Extensions.DependencyInjection;
32

43
namespace FaasNet.EventMesh.Protocols.AMQP
54
{
6-
public class EventMeshAMQPPlugin : IPlugin<EventMeshAMQPOptions>
5+
public class EventMeshAMQPPlugin : IProtocolPlugin<EventMeshAMQPOptions>
76
{
87
public void Load(IServiceCollection services, EventMeshAMQPOptions options)
98
{

‎src/EventMesh/FaasNet.EventMesh.Protocols.AMQP/FaasNet.EventMesh.Protocols.AMQP.csproj‎

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -9,7 +9,6 @@
99
<PackageReference Include="Microsoft.Extensions.Logging" Version="6.0.0" />
1010
</ItemGroup>
1111
<ItemGroup>
12-
<ProjectReference Include="..\..\Common\FaasNet.Plugin\FaasNet.Plugin.csproj" />
1312
<ProjectReference Include="..\FaasNet.EventMesh.Protocols\FaasNet.EventMesh.Protocols.csproj" />
1413
</ItemGroup>
1514
<ItemGroup>

‎src/EventMesh/FaasNet.EventMesh.Protocols.WebSocket/EventMeshWebSocketPlugin.cs‎

Lines changed: 17 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,17 @@
1+
using Microsoft.Extensions.DependencyInjection;
2+
3+
namespace FaasNet.EventMesh.Protocols.WebSocket
4+
{
5+
public class EventMeshWebSocketPlugin : IProtocolPlugin<EventMeshWebSocketOptions>
6+
{
7+
public void Load(IServiceCollection services, EventMeshWebSocketOptions options)
8+
{
9+
services.AddWebSocket(o =>
10+
{
11+
o.Port = options.Port;
12+
o.EventMeshPort = options.EventMeshPort;
13+
o.EventMeshUrl = options.EventMeshUrl;
14+
});
15+
}
16+
}
17+
}

‎src/EventMesh/FaasNet.EventMesh.Protocols.WebSocket/FaasNet.EventMesh.Protocols.WebSocket.csproj‎

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -10,4 +10,9 @@
1010
<ItemGroup>
1111
<ProjectReference Include="..\FaasNet.EventMesh.Protocols\FaasNet.EventMesh.Protocols.csproj" />
1212
</ItemGroup>
13+
<ItemGroup>
14+
<None Update="appsettings.json">
15+
<CopyToOutputDirectory>PreserveNewest</CopyToOutputDirectory>
16+
</None>
17+
</ItemGroup>
1318
</Project>

‎src/EventMesh/FaasNet.EventMesh.Protocols.WebSocket/appsettings.json‎

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,6 @@
1+
{
2+
"DllName": "FaasNet.EventMesh.Protocols.WebSocket.dll",
3+
"Configuration": {
4+
"Port": 2803
5+
}
6+
}

0 commit comments

Comments
 (0)