| | | 1 | | using System; |
| | | 2 | | using System.Linq; |
| | | 3 | | using System.Net.Http; |
| | | 4 | | using System.Net.Security; |
| | | 5 | | using Grpc.Core; |
| | | 6 | | using Grpc.Net.Client; |
| | | 7 | | using Grpc.Net.Client.Balancer; |
| | | 8 | | using Grpc.Net.Client.Configuration; |
| | | 9 | | using Microsoft.Extensions.DependencyInjection; |
| | | 10 | | |
| | | 11 | | namespace dotnet_etcd; |
| | | 12 | | |
| | | 13 | | /// <summary> |
| | | 14 | | /// Factory for creating gRPC channels |
| | | 15 | | /// </summary> |
| | | 16 | | public class GrpcChannelFactory |
| | | 17 | | { |
| | 2 | 18 | | private static readonly MethodConfig DefaultGrpcMethodConfig = new() |
| | 2 | 19 | | { |
| | 2 | 20 | | Names = { MethodName.Default }, |
| | 2 | 21 | | RetryPolicy = new RetryPolicy |
| | 2 | 22 | | { |
| | 2 | 23 | | MaxAttempts = 5, |
| | 2 | 24 | | InitialBackoff = TimeSpan.FromSeconds(1), |
| | 2 | 25 | | MaxBackoff = TimeSpan.FromSeconds(5), |
| | 2 | 26 | | BackoffMultiplier = 1.5, |
| | 2 | 27 | | RetryableStatusCodes = { StatusCode.Unavailable } |
| | 2 | 28 | | } |
| | 2 | 29 | | }; |
| | | 30 | | |
| | 2 | 31 | | private static readonly RetryThrottlingPolicy DefaultRetryThrottlingPolicy = new() |
| | 2 | 32 | | { |
| | 2 | 33 | | MaxTokens = 10, |
| | 2 | 34 | | TokenRatio = 0.1 |
| | 2 | 35 | | }; |
| | | 36 | | |
| | | 37 | | private const string StaticHostsPrefix = "static://"; |
| | | 38 | | |
| | | 39 | | /// <summary> |
| | | 40 | | /// Creates a gRPC channel with the specified configuration |
| | | 41 | | /// </summary> |
| | | 42 | | /// <param name="connectionString">The connection string</param> |
| | | 43 | | /// <param name="port">The port to use</param> |
| | | 44 | | /// <param name="serverName">The server name</param> |
| | | 45 | | /// <param name="credentials">The credentials to use</param> |
| | | 46 | | /// <param name="configureChannelOptions">Optional configuration for channel options</param> |
| | | 47 | | /// <param name="configureSslOptions">Optional configuration for SSL options (for custom SSL certificates)</param> |
| | | 48 | | /// <returns>A gRPC channel</returns> |
| | | 49 | | public GrpcChannel CreateChannel( |
| | | 50 | | string connectionString, |
| | | 51 | | int port, |
| | | 52 | | string serverName, |
| | | 53 | | ChannelCredentials credentials, |
| | | 54 | | Action<GrpcChannelOptions> configureChannelOptions = null, |
| | | 55 | | Action<SslClientAuthenticationOptions> configureSslOptions = null) |
| | 109 | 56 | | { |
| | 109 | 57 | | var parser = new ConnectionStringParser(); |
| | 109 | 58 | | var (uris, isDnsConnection) = parser.ParseConnectionString(connectionString, port, credentials); |
| | | 59 | | |
| | 109 | 60 | | var httpHandler = new SocketsHttpHandler |
| | 109 | 61 | | { |
| | 109 | 62 | | KeepAlivePingDelay = TimeSpan.FromSeconds(30), |
| | 109 | 63 | | KeepAlivePingTimeout = TimeSpan.FromSeconds(30), |
| | 109 | 64 | | KeepAlivePingPolicy = HttpKeepAlivePingPolicy.Always |
| | 109 | 65 | | }; |
| | | 66 | | |
| | | 67 | | // Configure SSL options if provided - this is the correct way for gRPC .NET |
| | 109 | 68 | | if (configureSslOptions != null) |
| | 3 | 69 | | { |
| | 3 | 70 | | var sslOptions = new SslClientAuthenticationOptions(); |
| | 3 | 71 | | configureSslOptions(sslOptions); |
| | 3 | 72 | | httpHandler.SslOptions = sslOptions; |
| | 3 | 73 | | } |
| | | 74 | | |
| | 109 | 75 | | var options = new GrpcChannelOptions |
| | 109 | 76 | | { |
| | 109 | 77 | | ServiceConfig = new ServiceConfig |
| | 109 | 78 | | { |
| | 109 | 79 | | MethodConfigs = { DefaultGrpcMethodConfig }, |
| | 109 | 80 | | RetryThrottling = DefaultRetryThrottlingPolicy, |
| | 109 | 81 | | LoadBalancingConfigs = { new RoundRobinConfig() } |
| | 109 | 82 | | }, |
| | 109 | 83 | | HttpHandler = httpHandler, |
| | 109 | 84 | | DisposeHttpClient = true, |
| | 109 | 85 | | ThrowOperationCanceledOnCancellation = true, |
| | 109 | 86 | | Credentials = credentials |
| | 109 | 87 | | }; |
| | | 88 | | |
| | 109 | 89 | | configureChannelOptions?.Invoke(options); |
| | | 90 | | |
| | 109 | 91 | | if (isDnsConnection) |
| | 1 | 92 | | { |
| | 1 | 93 | | return GrpcChannel.ForAddress(uris[0].ToString(), options); |
| | | 94 | | } |
| | | 95 | | |
| | 327 | 96 | | var factory = new StaticResolverFactory(addr => uris.Select(i => new BalancerAddress(i.Host, i.Port)).ToArray()) |
| | 108 | 97 | | var services = new ServiceCollection(); |
| | 108 | 98 | | services.AddSingleton<ResolverFactory>(factory); |
| | 108 | 99 | | options.ServiceProvider = services.BuildServiceProvider(); |
| | | 100 | | |
| | 108 | 101 | | return GrpcChannel.ForAddress($"{StaticHostsPrefix}{serverName}", options); |
| | 109 | 102 | | } |
| | | 103 | | } |