setupGRPCHeaderForwarding appends a gRPC middleware used to enable the propagation of HTTP Headers through child gRPC calls
()
| 408 | // setupGRPCHeaderForwarding appends a gRPC middleware used to enable the propagation of |
| 409 | // HTTP Headers through child gRPC calls |
| 410 | func (t *Cortex) setupGRPCHeaderForwarding() { |
| 411 | t.Cfg.Server.GRPCMiddleware = append(t.Cfg.Server.GRPCMiddleware, grpcutil.HTTPHeaderPropagationServerInterceptor) |
| 412 | t.Cfg.Server.GRPCStreamMiddleware = append(t.Cfg.Server.GRPCStreamMiddleware, grpcutil.HTTPHeaderPropagationStreamServerInterceptor) |
| 413 | } |
| 414 | |
| 415 | func (t *Cortex) setupRequestSigning() { |
| 416 | if t.Cfg.Distributor.SignWriteRequestsEnabled { |