implements health check service

resolves #647

interop-testing/src/main/java/io/grpc/testing/integration/TestServiceImpl.java

@@ -79,7 +79,7 @@ public TestServiceImpl(ScheduledExecutorService executor) {
 
   @Override
   public void emptyCall(EmptyProtos.Empty empty,
-                        StreamObserver<EmptyProtos.Empty> responseObserver) {
+      StreamObserver<EmptyProtos.Empty> responseObserver) {
     responseObserver.onNext(EmptyProtos.Empty.getDefaultInstance());
     responseObserver.onCompleted();
   }

services/build.gradle

@@ -0,0 +1,35 @@
+// Add dependency on the protobuf plugin
+buildscript {
+    repositories {
+        mavenCentral()
+    }
+    dependencies {
+        classpath libraries.protobuf_plugin
+    }
+}
+
+plugins {
+    id "be.insaneprogramming.gradle.animalsniffer" version "1.4.0"
+}
+
+description = "gRPC: Services"
+
+dependencies {
+    compile project(':grpc-protobuf'),
+            project(':grpc-stub')
+}
+
+configureProtoCompilation()
+
+// Configure the animal sniffer plugin
+animalsniffer {
+    signature = "org.codehaus.mojo.signature:java16:+@signature"
+}
+
+// Let intellij projects refer to generated code
+idea {
+    module {
+        sourceDirs += file("${projectDir}/src/generated/main/java");
+        sourceDirs += file("${projectDir}/src/generated/main/grpc");
+    }
+}

services/src/generated/main/grpc/io/grpc/health/v1/HealthGrpc.java

@@ -0,0 +1,231 @@
+package io.grpc.health.v1;
+
+import static io.grpc.stub.ClientCalls.asyncUnaryCall;
+import static io.grpc.stub.ClientCalls.asyncServerStreamingCall;
+import static io.grpc.stub.ClientCalls.asyncClientStreamingCall;
+import static io.grpc.stub.ClientCalls.asyncBidiStreamingCall;
+import static io.grpc.stub.ClientCalls.blockingUnaryCall;
+import static io.grpc.stub.ClientCalls.blockingServerStreamingCall;
+import static io.grpc.stub.ClientCalls.futureUnaryCall;
+import static io.grpc.MethodDescriptor.generateFullMethodName;
+import static io.grpc.stub.ServerCalls.asyncUnaryCall;
+import static io.grpc.stub.ServerCalls.asyncServerStreamingCall;
+import static io.grpc.stub.ServerCalls.asyncClientStreamingCall;
+import static io.grpc.stub.ServerCalls.asyncBidiStreamingCall;
+import static io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall;
+import static io.grpc.stub.ServerCalls.asyncUnimplementedStreamingCall;
+
+/**
+ */
+@javax.annotation.Generated(
+    value = "by gRPC proto compiler (version 0.15.0-SNAPSHOT)",
+    comments = "Source: health.proto")
+public class HealthGrpc {
+
+  private HealthGrpc() {}
+
+  public static final String SERVICE_NAME = "grpc.health.v1.Health";
+
+  // Static method descriptors that strictly reflect the proto.
+  @io.grpc.ExperimentalApi
+  public static final io.grpc.MethodDescriptor<io.grpc.health.v1.HealthCheckRequest,
+      io.grpc.health.v1.HealthCheckResponse> METHOD_CHECK =
+      io.grpc.MethodDescriptor.create(
+          io.grpc.MethodDescriptor.MethodType.UNARY,
+          generateFullMethodName(
+              "grpc.health.v1.Health", "Check"),
+          io.grpc.protobuf.ProtoUtils.marshaller(io.grpc.health.v1.HealthCheckRequest.getDefaultInstance()),
+          io.grpc.protobuf.ProtoUtils.marshaller(io.grpc.health.v1.HealthCheckResponse.getDefaultInstance()));
+
+  /**
+   * Creates a new async stub that supports all call types for the service
+   */
+  public static HealthStub newStub(io.grpc.Channel channel) {
+    return new HealthStub(channel);
+  }
+
+  /**
+   * Creates a new blocking-style stub that supports unary and streaming output calls on the service
+   */
+  public static HealthBlockingStub newBlockingStub(
+      io.grpc.Channel channel) {
+    return new HealthBlockingStub(channel);
+  }
+
+  /**
+   * Creates a new ListenableFuture-style stub that supports unary and streaming output calls on the service
+   */
+  public static HealthFutureStub newFutureStub(
+      io.grpc.Channel channel) {
+    return new HealthFutureStub(channel);
+  }
+
+  /**
+   */
+  public static interface Health {
+
+    /**
+     */
+    public void check(io.grpc.health.v1.HealthCheckRequest request,
+        io.grpc.stub.StreamObserver<io.grpc.health.v1.HealthCheckResponse> responseObserver);
+  }
+
+  @io.grpc.ExperimentalApi
+  public static abstract class AbstractHealth implements Health, io.grpc.BindableService {
+
+    @java.lang.Override
+    public void check(io.grpc.health.v1.HealthCheckRequest request,
+        io.grpc.stub.StreamObserver<io.grpc.health.v1.HealthCheckResponse> responseObserver) {
+      asyncUnimplementedUnaryCall(METHOD_CHECK, responseObserver);
+    }
+
+    @java.lang.Override public io.grpc.ServerServiceDefinition bindService() {
+      return HealthGrpc.bindService(this);
+    }
+  }
+
+  /**
+   */
+  public static interface HealthBlockingClient {
+
+    /**
+     */
+    public io.grpc.health.v1.HealthCheckResponse check(io.grpc.health.v1.HealthCheckRequest request);
+  }
+
+  /**
+   */
+  public static interface HealthFutureClient {
+
+    /**
+     */
+    public com.google.common.util.concurrent.ListenableFuture<io.grpc.health.v1.HealthCheckResponse> check(
+        io.grpc.health.v1.HealthCheckRequest request);
+  }
+
+  public static class HealthStub extends io.grpc.stub.AbstractStub<HealthStub>
+      implements Health {
+    private HealthStub(io.grpc.Channel channel) {
+      super(channel);
+    }
+
+    private HealthStub(io.grpc.Channel channel,
+        io.grpc.CallOptions callOptions) {
+      super(channel, callOptions);
+    }
+
+    @java.lang.Override
+    protected HealthStub build(io.grpc.Channel channel,
+        io.grpc.CallOptions callOptions) {
+      return new HealthStub(channel, callOptions);
+    }
+
+    @java.lang.Override
+    public void check(io.grpc.health.v1.HealthCheckRequest request,
+        io.grpc.stub.StreamObserver<io.grpc.health.v1.HealthCheckResponse> responseObserver) {
+      asyncUnaryCall(
+          getChannel().newCall(METHOD_CHECK, getCallOptions()), request, responseObserver);
+    }
+  }
+
+  public static class HealthBlockingStub extends io.grpc.stub.AbstractStub<HealthBlockingStub>
+      implements HealthBlockingClient {
+    private HealthBlockingStub(io.grpc.Channel channel) {
+      super(channel);
+    }
+
+    private HealthBlockingStub(io.grpc.Channel channel,
+        io.grpc.CallOptions callOptions) {
+      super(channel, callOptions);
+    }
+
+    @java.lang.Override
+    protected HealthBlockingStub build(io.grpc.Channel channel,
+        io.grpc.CallOptions callOptions) {
+      return new HealthBlockingStub(channel, callOptions);
+    }
+
+    @java.lang.Override
+    public io.grpc.health.v1.HealthCheckResponse check(io.grpc.health.v1.HealthCheckRequest request) {
+      return blockingUnaryCall(
+          getChannel(), METHOD_CHECK, getCallOptions(), request);
+    }
+  }
+
+  public static class HealthFutureStub extends io.grpc.stub.AbstractStub<HealthFutureStub>
+      implements HealthFutureClient {
+    private HealthFutureStub(io.grpc.Channel channel) {
+      super(channel);
+    }
+
+    private HealthFutureStub(io.grpc.Channel channel,
+        io.grpc.CallOptions callOptions) {
+      super(channel, callOptions);
+    }
+
+    @java.lang.Override
+    protected HealthFutureStub build(io.grpc.Channel channel,
+        io.grpc.CallOptions callOptions) {
+      return new HealthFutureStub(channel, callOptions);
+    }
+
+    @java.lang.Override
+    public com.google.common.util.concurrent.ListenableFuture<io.grpc.health.v1.HealthCheckResponse> check(
+        io.grpc.health.v1.HealthCheckRequest request) {
+      return futureUnaryCall(
+          getChannel().newCall(METHOD_CHECK, getCallOptions()), request);
+    }
+  }
+
+  private static final int METHODID_CHECK = 0;
+
+  private static class MethodHandlers<Req, Resp> implements
+      io.grpc.stub.ServerCalls.UnaryMethod<Req, Resp>,
+      io.grpc.stub.ServerCalls.ServerStreamingMethod<Req, Resp>,
+      io.grpc.stub.ServerCalls.ClientStreamingMethod<Req, Resp>,
+      io.grpc.stub.ServerCalls.BidiStreamingMethod<Req, Resp> {
+    private final Health serviceImpl;
+    private final int methodId;
+
+    public MethodHandlers(Health serviceImpl, int methodId) {
+      this.serviceImpl = serviceImpl;
+      this.methodId = methodId;
+    }
+
+    @java.lang.Override
+    @java.lang.SuppressWarnings("unchecked")
+    public void invoke(Req request, io.grpc.stub.StreamObserver<Resp> responseObserver) {
+      switch (methodId) {
+        case METHODID_CHECK:
+          serviceImpl.check((io.grpc.health.v1.HealthCheckRequest) request,
+              (io.grpc.stub.StreamObserver<io.grpc.health.v1.HealthCheckResponse>) responseObserver);
+          break;
+        default:
+          throw new AssertionError();
+      }
+    }
+
+    @java.lang.Override
+    @java.lang.SuppressWarnings("unchecked")
+    public io.grpc.stub.StreamObserver<Req> invoke(
+        io.grpc.stub.StreamObserver<Resp> responseObserver) {
+      switch (methodId) {
+        default:
+          throw new AssertionError();
+      }
+    }
+  }
+
+  public static io.grpc.ServerServiceDefinition bindService(
+      final Health serviceImpl) {
+    return io.grpc.ServerServiceDefinition.builder(SERVICE_NAME)
+        .addMethod(
+          METHOD_CHECK,
+          asyncUnaryCall(
+            new MethodHandlers<
+              io.grpc.health.v1.HealthCheckRequest,
+              io.grpc.health.v1.HealthCheckResponse>(
+                serviceImpl, METHODID_CHECK)))
+        .build();
+  }
+}