Method initGRPC

pkg/component/grpc.go:33–47

()

)

func (c *Component) initGRPC() {
	if c.grpcLogger == nil {
		c.grpcLogger = c.logger.WithField("namespace", "grpc")
	}
	rpclog.ReplaceGrpcLogger(c.grpcLogger)

	c.GRPC = rpcserver.New(
		c.ctx,
		rpcserver.WithContextFiller(c.FillContext),
		rpcserver.WithTrustedProxies(c.config.GRPC.TrustedProxies...),
		rpcserver.WithLogIgnoreMethods(c.config.GRPC.LogIgnoreMethods),
		rpcserver.WithCorrelationIDsIgnoreMethods(c.config.GRPC.CorrelationIDsIgnoreMethods),
		rpcserver.WithRateLimiter(c.RateLimiter()),
	)
}

func (c *Component) setupGRPC() (err error) {
	for _, sub := range c.grpcSubsystems {