Monq.Core.GrpcClientExtensions 0.1.0-rev-41121789246

Monq.Core.GrpcClientExtensions

Monq.Core.GrpcClientExtensions registers gRPC clients that resolve their addresses through Monq.Core.MicroserviceAddressing. It is the gRPC counterpart of Monq.Core.HttpClientExtensions for the HTTP side and centralizes the transport rules that every MONQ service otherwise had to duplicate:

• scheme-aware channel credentials — grpc-dotnet requires explicit credentials for any address scheme other than http/https (dns:/// from Service Discovery, but also ipv4:///, unix:/ and custom resolver schemes), so non-http addresses get ChannelCredentials.Insecure;
• round-robin balancing — enabled exactly for load-balanced addresses (resolution mode ServiceDiscovery or the dns scheme); Direct (ClusterIP) addresses keep kube-proxy balancing;
• client-side service discovery — a DNS resolver with a configurable refresh interval shared by all clients;
• static authorization fallback for background/console clients — the incoming Authorization header is forwarded, and when no HTTP context is present a token is obtained through Monq.Core.HttpClientExtensions.RestHttpClient.

Quick start

builder.Services.AddMicroserviceAddressing();
builder.Host.UseGrpcMicroserviceAddressResolver(new KubernetesServiceDiscoveryAddressResolver());

// Address resolved by application name on the first client creation.
builder.Services.AddMonqGrpcClient<SampleService.SampleServiceClient>("sample-api-service");

// Named registration for several clients of the same type.
builder.Services.AddMonqGrpcClient<SampleService.SampleServiceClient>(
    name: "secondary",
    applicationName: "sample-api-service",
    port: 5006,
    addressResolver: new FixedMicroserviceAddressResolver(new Uri("http://localhost:5006")));

// Settings resolved lazily — for composed libraries.
builder.Services.AddMonqGrpcClient<SampleService.SampleServiceClient>(
    "sample",
    provider => new GrpcClientAddressSettings("sample-api-service", 5006));

// Fixed address for local debugging.
builder.Services.AddMonqGrpcClient<SampleService.SampleServiceClient>(
    new Uri("http://localhost:5006"));

// Additional client/channel configuration via a lambda.
builder.Services.AddMonqGrpcClient<SampleService.SampleServiceClient>(
    "sample-api-service",
    configureOptions: options => options.ChannelOptionsAction =
        channelOptions => channelOptions.MaxReceiveMessageSize = null);

Background and console clients use the console variants and receive call credentials with static token fallback:

builder.Services.AddMonqGrpcConsoleClient<SampleService.SampleServiceClient>(
    "sample-api-service");

Service discovery options

builder.Services.ConfigureMonqGrpcServiceDiscovery(options =>
    options.DnsRefreshInterval = TimeSpan.FromSeconds(15));

Behavior summary

Roadmap

MONQ service frameworks move their gRPC registration internals onto this package without changing their public APIs; composed server libraries are expected to use it directly.