userver: ugrpc::client::ClientFactoryComponent Class Reference
Loading...
Searching...
No Matches
ugrpc::client::ClientFactoryComponent Class Referencefinal

#include <userver/ugrpc/client/client_factory_component.hpp>

Detailed Description

Provides a ClientFactory in the component system.

Multiple ClientFactoryComponent instances may be created if different parameters are required for different clients.

Requires ugrpc::client::CommonComponent.

Authentication

Authentication is controlled by auth-type static config field. Possible values:

  • insecure (InsecureChannelCredentials - default)
  • ssl (SslCredentials)

Default (system) authentication keys are used regardless of the chosen auth-type.

Service config

As per https://github.com/grpc/grpc/blob/master/doc/service_config.md service config should be distributed via the name resolution process. We allow setting default service_config: pass desired JSON literal to default-service-config parameter

Dynamic config bootstrap

By default this component waits for components::DynamicConfig to load the first successful dynamic config update (via GetSource()), which may block component construction. Set use-constant-dynamic-configs: true to instead use GetDefaultsAsConstantSource() — a non-blocking, constant dynamic_config::Source built from components::DynamicConfig's own fallback defaults. This is useful e.g. for a gRPC client used to deliver dynamic configs to the service itself, where waiting for components::DynamicConfig would create a bootstrap cycle.

When use-constant-dynamic-configs is in effect, this component also skips ugrpc::client::CommonComponent's shared default retry-limiter (as set by grpc-client-common's retry-limiter/retry-limiter-enabled options), since that default implementation may itself depend on components::DynamicConfig (e.g. the standard statistics-retry-limiter component), which would reintroduce the same bootstrap dependency. An explicit retry-limiter specified directly in this component's own static config is still always honored, regardless of use-constant-dynamic-configs; set it to none to force no retry-limiter at all for this factory, even if a grpc-client-common default is configured.

Example: a "light" client factory used to deliver dynamic configs to the service itself

# A "light" client factory: uses GetDefaultsAsConstantSource()
# instead of GetSource(), and skips grpc-client-common's shared
# default retry-limiter. Nothing here is special-cased by component
# name -- only use-constant-dynamic-configs below matters.
light-client-factory:
use-constant-dynamic-configs: true

Static options of ugrpc::client::ClientFactoryComponent :

Name Description Default value
auth-type An optional authentication method. Possible values: insecure, ssl. insecure
ssl-credentials-options SSL options for cases when auth-type is ssl. {}
ssl-credentials-options.pem-root-certs The path to file containing the PEM encoding of the server root certificates. absent
ssl-credentials-options.pem-private-key The path to file containing the PEM encoding of the client's private key. absent
ssl-credentials-options.pem-cert-chain The path to file containing the PEM encoding of the client's certificate chain. absent
retry-limiter Component that will be used as retry-limiter for this client. Retry limiter tracks success/failure rates and decides whether retries should be allowed If ommited (or explicitly set to 'null'), the default retry-limiter from grpc-client-common (if any) is used, unless 'use-constant-dynamic-configs' is in effect, in which case the grpc-client-common default is skipped (it may itself depend on components::DynamicConfig). Set to 'none' to explicitly force no retry-limiter for this client, even if a grpc-client-common default is configured.
retry-config Retry configuration for outgoing RPCs. {}
retry-config.attempts The maximum number of RPC attempts, including the original attempt. 1
channel-args.* A map of channel arguments, see gRPC Core docs. Each of the elements: value of channel argument, must be a string or an integer. {}
default-service-config Default value for gRPC service config. See https://github.com/grpc/grpc/blob/master/doc/service_config.md This value is used if the name resolution process can't get value from DNS. absent
channel-count Number of channels created for each endpoint. 1
use-constant-dynamic-configs Whether to use a constant dynamic_config::Source built from components::DynamicConfig's own fallback defaults (dynamic-config.defaults/defaults-path), instead of waiting for the first successful dynamic config update via GetSource(). Defaults to false. Also affects the retry-limiter default: see the description of 'retry-limiter' above.

Options inherited from middlewares::RunnerComponentBase :

Name Description Default value
disable-user-pipeline-middlewares Flag to disable groups::User middlewares from pipeline. false
disable-all-pipeline-middlewares Flag to disable all middlewares from pipeline. false
middlewares.*.enabled Enable middleware in the list.
middlewares.*.* A middleware config.

Options inherited from components::ComponentBase :

Name Description Default value
load-enabled Set to false to disable loading of the component. true

The default component name for static config is "grpc-client-factory".

See also
https://grpc.github.io/grpc/core/group__grpc__arg__keys.html
Examples
grpc-generic-proxy/main.cpp, samples/grpc_middleware_service/main.cpp, and samples/grpc_service/main.cpp.

Definition at line 78 of file client_factory_component.hpp.

Inheritance diagram for ugrpc::client::ClientFactoryComponent:

Public Member Functions

 ClientFactoryComponent (const components::ComponentConfig &config, const components::ComponentContext &context)
ClientFactoryGetFactory ()
ComponentHealth GetComponentHealth () const override
void OnLoadingCancelled () override
void OnAllComponentsLoaded () override
void OnGracefulShutdown (engine::Deadline serving_shutdown_deadline) override
void OnAllComponentsAreStopping () override

Static Public Member Functions

static yaml_config::Schema GetStaticConfigSchema ()

Static Public Attributes

static constexpr std::string_view kName = "grpc-client-factory"
 The default name of ugrpc::client::middlewares::log::Component.

Protected Types

using MiddlewareFactory
using LoggableComponentBase = ComponentBase

Member Typedef Documentation

◆ LoggableComponentBase

using components::ComponentBase::LoggableComponentBase = ComponentBase
protectedinherited
Deprecated
use components::ComponentBase instead.

Definition at line 79 of file component_base.hpp.

◆ MiddlewareFactory

using middlewares::RunnerComponentBase< MiddlewareBase, ClientInfo >::MiddlewareFactory
protectedinherited

Definition at line 139 of file runner.hpp.

Member Function Documentation

◆ GetComponentHealth()

ComponentHealth components::ComponentBase::GetComponentHealth ( ) const
inlineoverridevirtualinherited

Override this function to inform the world of the state of your component.

Warning
The function is called concurrently from multiple threads.

Reimplemented from components::RawComponentBase.

Reimplemented in components::Redis, and server::handlers::Restart.

Definition at line 35 of file component_base.hpp.

◆ OnAllComponentsAreStopping()

void components::ComponentBase::OnAllComponentsAreStopping ( )
inlineoverridevirtualinherited

Component may use this function to stop doing work before the stop of the components that depend on it.

Base components may override it and make final to do some work before the derived object constructor is called. Don't use it otherwise.

Reimplemented from components::RawComponentBase.

Reimplemented in components::Server, and urabbitmq::ConsumerComponentBase.

Definition at line 70 of file component_base.hpp.

◆ OnAllComponentsLoaded()

void components::ComponentBase::OnAllComponentsLoaded ( )
inlineoverridevirtualinherited

Component may use this function to finalize registration of other components that depend on it (for example, handler components register in server component, and the latter uses OnAllComponentsLoaded() to start processing requests).

Base components may override it and make final to do some work after the derived object constructor is called. Don't use it otherwise.

Reimplemented from components::RawComponentBase.

Reimplemented in components::Server, server::handlers::Ping, and urabbitmq::ConsumerComponentBase.

Definition at line 51 of file component_base.hpp.

◆ OnGracefulShutdown()

void components::ComponentBase::OnGracefulShutdown ( engine::Deadline serving_shutdown_deadline)
overridevirtualinherited

Serving components like HTTP and gRPC servers may use this function to stop accepting new requests and shutdown serving in the given time interval. Application components likely do not need to override it.

Parameters
[in]serving_shutdown_deadlineThe deadline until already running requests should be allowed to complete. The component is supposed to stop accepting new requests and continue processing of already active requests until this deadline (unless those requests finish earlier). And it might completely shutdown requests processing when the deadline is reached (or when no active requests left).

Reimplemented from components::RawComponentBase.

Reimplemented in components::Server.

◆ OnLoadingCancelled()

void components::ComponentBase::OnLoadingCancelled ( )
inlineoverridevirtualinherited

Called once if the creation of any other component failed. If the current component expects some other component to take any action with the current component, this call is a signal that such action may never happen due to components loading was cancelled. Application components might not want to override it.

Reimplemented from components::RawComponentBase.

Definition at line 42 of file component_base.hpp.


The documentation for this class was generated from the following file: