Skip to content

M
Message-Priority-Queue
Commit 77603946 authored by mohammad.salama's avatar mohammad.salama
Browse files
Options

A File of Dependencies to save grpc Calls in jaegar

parent a7e6bfd6
Expand all Hide whitespace changes
Inline Side-by-side
Showing with 1910 additions and 517 deletions
HTTPMessageNode/HTTPMessageNode.csproj
View file @ 77603946
...@@ -34,8 +34,13 @@ ...@@ -34,8 +34,13 @@
<ItemGroup> <ItemGroup>
<PackageReference Include="Steeltoe.Connector.ConnectorCore" Version="$(SteeltoeVersion)" /> <PackageReference Include="Steeltoe.Connector.ConnectorCore" Version="$(SteeltoeVersion)" />
<PackageReference Include="Steeltoe.Discovery.Eureka" Version="$(SteeltoeVersion)" /> <PackageReference Include="Steeltoe.Discovery.Eureka" Version="$(SteeltoeVersion)" />
<PackageReference Include="OpenTelemetry.Exporter.Jaeger" />
<PackageReference Include="OpenTelemetry.Extensions.Hosting" Version="1.9.0" />
<PackageReference Include="OpenTelemetry.Instrumentation.AspNetCore" Version="1.9.0" />
</ItemGroup> </ItemGroup>
<ItemGroup> <ItemGroup>
<Protobuf Include="Protos\schema.proto" GrpcServices="Client" /> <Protobuf Include="Protos\schema.proto" GrpcServices="Client" />
<Protobuf Include="Protos\validator.proto" GrpcServices="Client" /> <Protobuf Include="Protos\validator.proto" GrpcServices="Client" />
......
HTTPMessageNode/Program.cs
View file @ 77603946
...@@ -9,7 +9,7 @@ builder.Services.AddControllers(); ...@@ -9,7 +9,7 @@ builder.Services.AddControllers();
builder.Services.AddEndpointsApiExplorer(); builder.Services.AddEndpointsApiExplorer();
builder.Services.AddSwaggerGen(); builder.Services.AddSwaggerGen();
builder.Services.AddDiscoveryClient(); builder.Services.AddDiscoveryClient();
builder.Configuration.GetValue<string>("database:conn"); //builder.Configuration.GetValue<string>("database:conn");
......
HTTPMessageNode/obj/Debug/net6.0/HTTPMessageNode.csproj.CoreCompileInputs.cache
View file @ 77603946
6f8efc80d26826db09c37cfadc07ee5cd0181d02 be2e6d7baf1c3b872ca4005464549a84ca79a196
HTTPMessageNode/obj/Debug/net6.0/HTTPMessageNode.csproj.FileListAbsolute.txt
View file @ 77603946
...@@ -43,3 +43,24 @@ D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\HTTPMessage ...@@ -43,3 +43,24 @@ D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\HTTPMessage
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\HTTPMessageNode\obj\Debug\net6.0\ref\HTTPMessageNode.dll D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\HTTPMessageNode\obj\Debug\net6.0\ref\HTTPMessageNode.dll
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\HTTPMessageNode\obj\Debug\net6.0\HTTPMessageNode.pdb D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\HTTPMessageNode\obj\Debug\net6.0\HTTPMessageNode.pdb
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\HTTPMessageNode\obj\Debug\net6.0\HTTPMessageNode.genruntimeconfig.cache D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\HTTPMessageNode\obj\Debug\net6.0\HTTPMessageNode.genruntimeconfig.cache
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\HTTPMessageNode\bin\Debug\net6.0\Microsoft.Extensions.Configuration.dll
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\HTTPMessageNode\bin\Debug\net6.0\Microsoft.Extensions.Configuration.Abstractions.dll
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\HTTPMessageNode\bin\Debug\net6.0\Microsoft.Extensions.Configuration.Binder.dll
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\HTTPMessageNode\bin\Debug\net6.0\Microsoft.Extensions.DependencyInjection.dll
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\HTTPMessageNode\bin\Debug\net6.0\Microsoft.Extensions.DependencyInjection.Abstractions.dll
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\HTTPMessageNode\bin\Debug\net6.0\Microsoft.Extensions.Diagnostics.Abstractions.dll
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\HTTPMessageNode\bin\Debug\net6.0\Microsoft.Extensions.FileProviders.Abstractions.dll
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\HTTPMessageNode\bin\Debug\net6.0\Microsoft.Extensions.Hosting.Abstractions.dll
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\HTTPMessageNode\bin\Debug\net6.0\Microsoft.Extensions.Logging.dll
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\HTTPMessageNode\bin\Debug\net6.0\Microsoft.Extensions.Logging.Abstractions.dll
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\HTTPMessageNode\bin\Debug\net6.0\Microsoft.Extensions.Logging.Configuration.dll
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\HTTPMessageNode\bin\Debug\net6.0\Microsoft.Extensions.Options.dll
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\HTTPMessageNode\bin\Debug\net6.0\Microsoft.Extensions.Options.ConfigurationExtensions.dll
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\HTTPMessageNode\bin\Debug\net6.0\Microsoft.Extensions.Primitives.dll
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\HTTPMessageNode\bin\Debug\net6.0\OpenTelemetry.dll
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\HTTPMessageNode\bin\Debug\net6.0\OpenTelemetry.Api.dll
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\HTTPMessageNode\bin\Debug\net6.0\OpenTelemetry.Api.ProviderBuilderExtensions.dll
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\HTTPMessageNode\bin\Debug\net6.0\OpenTelemetry.Exporter.Jaeger.dll
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\HTTPMessageNode\bin\Debug\net6.0\OpenTelemetry.Extensions.Hosting.dll
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\HTTPMessageNode\bin\Debug\net6.0\OpenTelemetry.Instrumentation.AspNetCore.dll
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\HTTPMessageNode\bin\Debug\net6.0\System.Diagnostics.DiagnosticSource.dll
HTTPMessageNode/obj/HTTPMessageNode.csproj.nuget.dgspec.json
View file @ 77603946
...@@ -62,6 +62,18 @@ ...@@ -62,6 +62,18 @@
"target": "Package", "target": "Package",
"version": "[2.64.0, )" "version": "[2.64.0, )"
}, },
"OpenTelemetry.Exporter.Jaeger": {
"target": "Package",
"version": "(, )"
},
"OpenTelemetry.Extensions.Hosting": {
"target": "Package",
"version": "[1.9.0, )"
},
"OpenTelemetry.Instrumentation.AspNetCore": {
"target": "Package",
"version": "[1.9.0, )"
},
"Steeltoe.Connector.ConnectorCore": { "Steeltoe.Connector.ConnectorCore": {
"target": "Package", "target": "Package",
"version": "[3.2.6, )" "version": "[3.2.6, )"
......
HTTPMessageNode/obj/HTTPMessageNode.csproj.nuget.g.targets
View file @ 77603946
...@@ -2,6 +2,9 @@ ...@@ -2,6 +2,9 @@
<Project ToolsVersion="14.0" xmlns="http://schemas.microsoft.com/developer/msbuild/2003"> <Project ToolsVersion="14.0" xmlns="http://schemas.microsoft.com/developer/msbuild/2003">
<ImportGroup Condition=" '$(ExcludeRestorePackageImports)' != 'true' "> <ImportGroup Condition=" '$(ExcludeRestorePackageImports)' != 'true' ">
<Import Project="$(NuGetPackageRoot)microsoft.extensions.apidescription.server\6.0.5\build\Microsoft.Extensions.ApiDescription.Server.targets" Condition="Exists('$(NuGetPackageRoot)microsoft.extensions.apidescription.server\6.0.5\build\Microsoft.Extensions.ApiDescription.Server.targets')" /> <Import Project="$(NuGetPackageRoot)microsoft.extensions.apidescription.server\6.0.5\build\Microsoft.Extensions.ApiDescription.Server.targets" Condition="Exists('$(NuGetPackageRoot)microsoft.extensions.apidescription.server\6.0.5\build\Microsoft.Extensions.ApiDescription.Server.targets')" />
<Import Project="$(NuGetPackageRoot)microsoft.extensions.configuration.binder\8.0.0\buildTransitive\netstandard2.0\Microsoft.Extensions.Configuration.Binder.targets" Condition="Exists('$(NuGetPackageRoot)microsoft.extensions.configuration.binder\8.0.0\buildTransitive\netstandard2.0\Microsoft.Extensions.Configuration.Binder.targets')" />
<Import Project="$(NuGetPackageRoot)microsoft.extensions.options\8.0.0\buildTransitive\net6.0\Microsoft.Extensions.Options.targets" Condition="Exists('$(NuGetPackageRoot)microsoft.extensions.options\8.0.0\buildTransitive\net6.0\Microsoft.Extensions.Options.targets')" />
<Import Project="$(NuGetPackageRoot)microsoft.extensions.logging.abstractions\8.0.0\buildTransitive\net6.0\Microsoft.Extensions.Logging.Abstractions.targets" Condition="Exists('$(NuGetPackageRoot)microsoft.extensions.logging.abstractions\8.0.0\buildTransitive\net6.0\Microsoft.Extensions.Logging.Abstractions.targets')" />
<Import Project="$(NuGetPackageRoot)grpc.tools\2.64.0\build\Grpc.Tools.targets" Condition="Exists('$(NuGetPackageRoot)grpc.tools\2.64.0\build\Grpc.Tools.targets')" /> <Import Project="$(NuGetPackageRoot)grpc.tools\2.64.0\build\Grpc.Tools.targets" Condition="Exists('$(NuGetPackageRoot)grpc.tools\2.64.0\build\Grpc.Tools.targets')" />
</ImportGroup> </ImportGroup>
</Project> </Project>
\ No newline at end of file
HTTPMessageNode/obj/project.assets.json
View file @ 77603946
This diff is collapsed.
HTTPMessageNode/obj/project.nuget.cache
View file @ 77603946
This diff is collapsed.
HTTPMessageNode/obj/staticwebassets.pack.sentinel
View file @ 77603946
...@@ -22,3 +22,4 @@ ...@@ -22,3 +22,4 @@
2.0 2.0
2.0 2.0
2.0 2.0
2.0
QueuerNode/Scheduler.csproj
View file @ 77603946
...@@ -21,6 +21,10 @@ ...@@ -21,6 +21,10 @@
<IncludeAssets>runtime; build; native; contentfiles; analyzers; buildtransitive</IncludeAssets> <IncludeAssets>runtime; build; native; contentfiles; analyzers; buildtransitive</IncludeAssets>
</PackageReference> </PackageReference>
<PackageReference Include="MongoDB.Driver" Version="2.27.0" /> <PackageReference Include="MongoDB.Driver" Version="2.27.0" />
<PackageReference Include="OpenTelemetry.Exporter.Jaeger" Version="1.5.1" />
<PackageReference Include="OpenTelemetry.Exporter.OpenTelemetryProtocol" Version="1.9.0" />
<PackageReference Include="OpenTelemetry.Extensions.Hosting" Version="1.9.0" />
<PackageReference Include="OpenTelemetry.Instrumentation.AspNetCore" Version="1.9.0" />
</ItemGroup> </ItemGroup>
<PropertyGroup> <PropertyGroup>
......
QueuerNode/obj/Scheduler.csproj.nuget.dgspec.json
View file @ 77603946
...@@ -70,6 +70,22 @@ ...@@ -70,6 +70,22 @@
"target": "Package", "target": "Package",
"version": "[2.27.0, )" "version": "[2.27.0, )"
}, },
"OpenTelemetry.Exporter.Jaeger": {
"target": "Package",
"version": "[1.5.1, )"
},
"OpenTelemetry.Exporter.OpenTelemetryProtocol": {
"target": "Package",
"version": "[1.9.0, )"
},
"OpenTelemetry.Extensions.Hosting": {
"target": "Package",
"version": "[1.9.0, )"
},
"OpenTelemetry.Instrumentation.AspNetCore": {
"target": "Package",
"version": "[1.9.0, )"
},
"StackExchange.Redis": { "StackExchange.Redis": {
"target": "Package", "target": "Package",
"version": "[2.8.0, )" "version": "[2.8.0, )"
......
QueuerNode/obj/Scheduler.csproj.nuget.g.targets
View file @ 77603946
...@@ -2,6 +2,9 @@ ...@@ -2,6 +2,9 @@
<Project ToolsVersion="14.0" xmlns="http://schemas.microsoft.com/developer/msbuild/2003"> <Project ToolsVersion="14.0" xmlns="http://schemas.microsoft.com/developer/msbuild/2003">
<ImportGroup Condition=" '$(ExcludeRestorePackageImports)' != 'true' "> <ImportGroup Condition=" '$(ExcludeRestorePackageImports)' != 'true' ">
<Import Project="$(NuGetPackageRoot)microsoft.extensions.apidescription.server\6.0.5\build\Microsoft.Extensions.ApiDescription.Server.targets" Condition="Exists('$(NuGetPackageRoot)microsoft.extensions.apidescription.server\6.0.5\build\Microsoft.Extensions.ApiDescription.Server.targets')" /> <Import Project="$(NuGetPackageRoot)microsoft.extensions.apidescription.server\6.0.5\build\Microsoft.Extensions.ApiDescription.Server.targets" Condition="Exists('$(NuGetPackageRoot)microsoft.extensions.apidescription.server\6.0.5\build\Microsoft.Extensions.ApiDescription.Server.targets')" />
<Import Project="$(NuGetPackageRoot)microsoft.extensions.configuration.binder\8.0.1\buildTransitive\netstandard2.0\Microsoft.Extensions.Configuration.Binder.targets" Condition="Exists('$(NuGetPackageRoot)microsoft.extensions.configuration.binder\8.0.1\buildTransitive\netstandard2.0\Microsoft.Extensions.Configuration.Binder.targets')" />
<Import Project="$(NuGetPackageRoot)microsoft.extensions.options\8.0.0\buildTransitive\net6.0\Microsoft.Extensions.Options.targets" Condition="Exists('$(NuGetPackageRoot)microsoft.extensions.options\8.0.0\buildTransitive\net6.0\Microsoft.Extensions.Options.targets')" />
<Import Project="$(NuGetPackageRoot)microsoft.extensions.logging.abstractions\8.0.0\buildTransitive\net6.0\Microsoft.Extensions.Logging.Abstractions.targets" Condition="Exists('$(NuGetPackageRoot)microsoft.extensions.logging.abstractions\8.0.0\buildTransitive\net6.0\Microsoft.Extensions.Logging.Abstractions.targets')" />
<Import Project="$(NuGetPackageRoot)grpc.tools\2.64.0\build\Grpc.Tools.targets" Condition="Exists('$(NuGetPackageRoot)grpc.tools\2.64.0\build\Grpc.Tools.targets')" /> <Import Project="$(NuGetPackageRoot)grpc.tools\2.64.0\build\Grpc.Tools.targets" Condition="Exists('$(NuGetPackageRoot)grpc.tools\2.64.0\build\Grpc.Tools.targets')" />
</ImportGroup> </ImportGroup>
</Project> </Project>
\ No newline at end of file
QueuerNode/obj/project.assets.json
View file @ 77603946
This diff is collapsed.
QueuerNode/obj/project.nuget.cache
View file @ 77603946
This diff is collapsed.
ScheduledMessagesHandler/Class1.cs 0 → 100644
View file @ 77603946
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
namespace ScheduledMessagesHandler
{
public static class RedisInitializeExtentions
{
//Extention methods
public static IHost InitRedis(this IHost host)
{
return host;
}
}
}
ScheduledMessagesHandler/Program.cs
View file @ 77603946
...@@ -4,6 +4,8 @@ using ScheduledMessagesHandler.MongoMessages; ...@@ -4,6 +4,8 @@ using ScheduledMessagesHandler.MongoMessages;
using ScheduledMessagesHandler.RedisQueuer; using ScheduledMessagesHandler.RedisQueuer;
using Steeltoe.Discovery.Client; using Steeltoe.Discovery.Client;
IConfiguration config;
IHost host = Host.CreateDefaultBuilder(args) IHost host = Host.CreateDefaultBuilder(args)
.ConfigureServices(services => .ConfigureServices(services =>
{ {
...@@ -12,7 +14,10 @@ IHost host = Host.CreateDefaultBuilder(args) ...@@ -12,7 +14,10 @@ IHost host = Host.CreateDefaultBuilder(args)
}) })
.Build(); .Build();
config = host.Services.GetRequiredService<IConfiguration>();
host.InitRedis();
MessageQueues.init(); MessageQueues.init();
MongoMessagesShceduler.init(); MongoMessagesShceduler.init();
......
ScheduledMessagesHandler/RedisInitializationService.cs 0 → 100644
View file @ 77603946
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
namespace ScheduledMessagesHandler
{
public class RedisInitializationService : BackgroundService
{
protected override Task ExecuteAsync(CancellationToken stoppingToken)
{
throw new NotImplementedException();
}
}
}
activate-grpc-jaegar-dependencies.txt 0 → 100644
View file @ 77603946
<ItemGroup>
<PackageReference Include="Grpc.AspNetCore" Version="2.40.0" />
<PackageReference Include="OpenTelemetry.Collector.AspNetCore" Version="0.2.0-alpha.179" />
<PackageReference Include="OpenTelemetry.Collector.Dependencies" Version="0.2.0-alpha.179" />
<PackageReference Include="OpenTelemetry.Exporter.ApplicationInsights" Version="0.2.0-alpha.179" />
</ItemGroup>
<ItemGroup>
<PackageReference Include="Swashbuckle.AspNetCore" Version="6.2.3" />
<PackageReference Include="OpenTelemetry.Exporter.Jaeger" />
<PackageReference Include="OpenTelemetry.Exporter.Console" />
<PackageReference Include="OpenTelemetry.Extensions.Hosting" Version="1.9.0" />
<PackageReference Include="OpenTelemetry.Instrumentation.AspNetCore" Version="1.9.0" />
<PackageReference Include="OpenTelemetry.Instrumentation.GrpcNetClient" Version="1.9.0-beta.1" />
</ItemGroup>
\ No newline at end of file
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment

HIAST - GitLab