SpringCloud/spring-cloud-function
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Add reflection service to grpc server

Browse Source 
User can now inspect service definitions (e.g. with grpcurl).
This commit is contained in:
Dave Syer
2021-10-11 15:42:15 +01:00
parent 7fc755e157
commit 78f485d7c0
2 changed files with 14 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
spring-cloud-function-grpc/pom.xml
View File

@@ -31,6 +31,11 @@
<artifactId>grpc-protobuf</artifactId> <artifactId>grpc-protobuf</artifactId>
<version>${grpc.version}</version> <version>${grpc.version}</version>
</dependency> </dependency>
<dependency>
<groupId>io.grpc</groupId>
<artifactId>grpc-services</artifactId>
<version>${grpc.version}</version>
</dependency>
<dependency> <dependency>
<groupId>io.grpc</groupId> <groupId>io.grpc</groupId>
<artifactId>grpc-stub</artifactId> <artifactId>grpc-stub</artifactId>

13
spring-cloud-function-grpc/src/main/java/org/springframework/cloud/function/grpc/GrpcServer.java
View File

@@ -19,13 +19,15 @@ package org.springframework.cloud.function.grpc;
import java.util.concurrent.ExecutorService; import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors; import java.util.concurrent.Executors;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.springframework.context.SmartLifecycle;
import org.springframework.util.ClassUtils;
import io.grpc.BindableService; import io.grpc.BindableService;
import io.grpc.Server; import io.grpc.Server;
import io.grpc.ServerBuilder; import io.grpc.ServerBuilder;
import org.apache.commons.logging.Log; import io.grpc.protobuf.services.ProtoReflectionService;
import org.apache.commons.logging.LogFactory;
import org.springframework.context.SmartLifecycle;
/** /**
* *
@@ -58,6 +60,9 @@ class GrpcServer implements SmartLifecycle {
BindableService bindableService = this.grpcMessageServices[i]; BindableService bindableService = this.grpcMessageServices[i];
serverBuilder.addService(bindableService); serverBuilder.addService(bindableService);
} }
if (ClassUtils.isPresent("io.grpc.protobuf.services.ProtoReflectionService", null)) {
serverBuilder.addService(ProtoReflectionService.newInstance());
}
this.server = serverBuilder.build(); this.server = serverBuilder.build();
logger.info("Starting gRPC server"); logger.info("Starting gRPC server");