diff --git a/pkg/srv/grpc/gateway.go b/pkg/srv/grpc/gateway.go index c9280ea..97aae1d 100644 --- a/pkg/srv/grpc/gateway.go +++ b/pkg/srv/grpc/gateway.go @@ -18,7 +18,7 @@ func (a *appGRPCServer) registerServiceGatewayHandlers(ctx context.Context, serv if len(service.GwRegistrationFuncs) < 1 { return } else if a.gatewayMux == nil { - a.gatewayMux = runtime.NewServeMux() + a.gatewayMux = runtime.NewServeMux(a.opts.GRPCGatewayOpts...) } ctx, span := a.tracer.Start(ctx, "appgrpc.init.prepare.service.gwHandlers", trace.WithAttributes( @@ -50,6 +50,7 @@ func (a *appGRPCServer) GetClientConn(ctx context.Context) *grpc.ClientConn { if err != nil { span.RecordError(err) span.SetStatus(codes.Error, err.Error()) + panic(err) } return clientConn diff --git a/pkg/srv/grpc/opts/config.go b/pkg/srv/grpc/opts/config.go index 1436fda..72a8591 100644 --- a/pkg/srv/grpc/opts/config.go +++ b/pkg/srv/grpc/opts/config.go @@ -19,7 +19,8 @@ type AppGRPC struct { UnaryInterceptors []grpc.UnaryServerInterceptor StreamInterceptors []grpc.StreamServerInterceptor GRPCOpts []grpc.ServerOption - GRPCDialOpts []grpc.DialOption // Map ServerOptions to DialOpts for GRPC Gateway support + GRPCDialOpts []grpc.DialOption // Map ServerOptions to DialOpts for GRPC Gateway support + GRPCGatewayOpts []runtime.ServeMuxOption // Configure grpc-gateway ServeMux GRPCDone <-chan error gatewayMux *runtime.ServeMux }