Add Cloud Video Intelligence v1p3beta1 API.

google-api-grpc/grpc-google-cloud-video-intelligence-v1p3beta1/pom.xml

@@ -0,0 +1,31 @@
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <modelVersion>4.0.0</modelVersion>
+    <artifactId>grpc-google-cloud-video-intelligence-v1p3beta1</artifactId>
+    <version>0.48.1-SNAPSHOT</version><!-- {x-version-update:grpc-google-cloud-video-intelligence-v1p3beta1:current} -->
+    <name>grpc-google-cloud-video-intelligence-v1p3beta1</name>
+    <description>GRPC library for grpc-google-cloud-video-intelligence-v1p3beta1</description>
+    <parent>
+        <groupId>com.google.api.grpc</groupId>
+        <artifactId>google-api-grpc</artifactId>
+        <version>0.48.1-SNAPSHOT</version><!-- {x-version-update:google-api-grpc:current} -->
+    </parent>
+    <dependencies>
+        <dependency>
+            <groupId>io.grpc</groupId>
+            <artifactId>grpc-stub</artifactId>
+            <scope>compile</scope>
+        </dependency>
+        <dependency>
+            <groupId>io.grpc</groupId>
+            <artifactId>grpc-protobuf</artifactId>
+            <scope>compile</scope>
+        </dependency>
+        <dependency>
+            <groupId>com.google.api.grpc</groupId>
+            <artifactId>proto-google-cloud-video-intelligence-v1p3beta1</artifactId>
+            <scope>compile</scope>
+        </dependency>
+    </dependencies>
+</project>

google-api-grpc/grpc-google-cloud-video-intelligence-v1p3beta1/src/main/java/com/google/cloud/videointelligence/v1p3beta1/StreamingVideoIntelligenceServiceGrpc.java

@@ -0,0 +1,347 @@
+package com.google.cloud.videointelligence.v1p3beta1;
+
+import static io.grpc.MethodDescriptor.generateFullMethodName;
+import static io.grpc.stub.ClientCalls.asyncBidiStreamingCall;
+import static io.grpc.stub.ServerCalls.asyncBidiStreamingCall;
+import static io.grpc.stub.ServerCalls.asyncUnimplementedStreamingCall;
+
+/**
+ *
+ *
+ * <pre>
+ * Service that implements Google Cloud Video Intelligence Streaming API.
+ * </pre>
+ */
+@javax.annotation.Generated(
+    value = "by gRPC proto compiler (version 1.10.0)",
+    comments = "Source: google/cloud/videointelligence/v1p3beta1/video_intelligence.proto")
+public final class StreamingVideoIntelligenceServiceGrpc {
+
+  private StreamingVideoIntelligenceServiceGrpc() {}
+
+  public static final String SERVICE_NAME =
+      "google.cloud.videointelligence.v1p3beta1.StreamingVideoIntelligenceService";
+
+  // Static method descriptors that strictly reflect the proto.
+  @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
+  @java.lang.Deprecated // Use {@link #getStreamingAnnotateVideoMethod()} instead.
+  public static final io.grpc.MethodDescriptor<
+          com.google.cloud.videointelligence.v1p3beta1.StreamingAnnotateVideoRequest,
+          com.google.cloud.videointelligence.v1p3beta1.StreamingAnnotateVideoResponse>
+      METHOD_STREAMING_ANNOTATE_VIDEO = getStreamingAnnotateVideoMethodHelper();
+
+  private static volatile io.grpc.MethodDescriptor<
+          com.google.cloud.videointelligence.v1p3beta1.StreamingAnnotateVideoRequest,
+          com.google.cloud.videointelligence.v1p3beta1.StreamingAnnotateVideoResponse>
+      getStreamingAnnotateVideoMethod;
+
+  @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
+  public static io.grpc.MethodDescriptor<
+          com.google.cloud.videointelligence.v1p3beta1.StreamingAnnotateVideoRequest,
+          com.google.cloud.videointelligence.v1p3beta1.StreamingAnnotateVideoResponse>
+      getStreamingAnnotateVideoMethod() {
+    return getStreamingAnnotateVideoMethodHelper();
+  }
+
+  private static io.grpc.MethodDescriptor<
+          com.google.cloud.videointelligence.v1p3beta1.StreamingAnnotateVideoRequest,
+          com.google.cloud.videointelligence.v1p3beta1.StreamingAnnotateVideoResponse>
+      getStreamingAnnotateVideoMethodHelper() {
+    io.grpc.MethodDescriptor<
+            com.google.cloud.videointelligence.v1p3beta1.StreamingAnnotateVideoRequest,
+            com.google.cloud.videointelligence.v1p3beta1.StreamingAnnotateVideoResponse>
+        getStreamingAnnotateVideoMethod;
+    if ((getStreamingAnnotateVideoMethod =
+            StreamingVideoIntelligenceServiceGrpc.getStreamingAnnotateVideoMethod)
+        == null) {
+      synchronized (StreamingVideoIntelligenceServiceGrpc.class) {
+        if ((getStreamingAnnotateVideoMethod =
+                StreamingVideoIntelligenceServiceGrpc.getStreamingAnnotateVideoMethod)
+            == null) {
+          StreamingVideoIntelligenceServiceGrpc.getStreamingAnnotateVideoMethod =
+              getStreamingAnnotateVideoMethod =
+                  io.grpc.MethodDescriptor
+                      .<com.google.cloud.videointelligence.v1p3beta1.StreamingAnnotateVideoRequest,
+                          com.google.cloud.videointelligence.v1p3beta1
+                              .StreamingAnnotateVideoResponse>
+                          newBuilder()
+                      .setType(io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING)
+                      .setFullMethodName(
+                          generateFullMethodName(
+                              "google.cloud.videointelligence.v1p3beta1.StreamingVideoIntelligenceService",
+                              "StreamingAnnotateVideo"))
+                      .setSampledToLocalTracing(true)
+                      .setRequestMarshaller(
+                          io.grpc.protobuf.ProtoUtils.marshaller(
+                              com.google.cloud.videointelligence.v1p3beta1
+                                  .StreamingAnnotateVideoRequest.getDefaultInstance()))
+                      .setResponseMarshaller(
+                          io.grpc.protobuf.ProtoUtils.marshaller(
+                              com.google.cloud.videointelligence.v1p3beta1
+                                  .StreamingAnnotateVideoResponse.getDefaultInstance()))
+                      .setSchemaDescriptor(
+                          new StreamingVideoIntelligenceServiceMethodDescriptorSupplier(
+                              "StreamingAnnotateVideo"))
+                      .build();
+        }
+      }
+    }
+    return getStreamingAnnotateVideoMethod;
+  }
+
+  /** Creates a new async stub that supports all call types for the service */
+  public static StreamingVideoIntelligenceServiceStub newStub(io.grpc.Channel channel) {
+    return new StreamingVideoIntelligenceServiceStub(channel);
+  }
+
+  /**
+   * Creates a new blocking-style stub that supports unary and streaming output calls on the service
+   */
+  public static StreamingVideoIntelligenceServiceBlockingStub newBlockingStub(
+      io.grpc.Channel channel) {
+    return new StreamingVideoIntelligenceServiceBlockingStub(channel);
+  }
+
+  /** Creates a new ListenableFuture-style stub that supports unary calls on the service */
+  public static StreamingVideoIntelligenceServiceFutureStub newFutureStub(io.grpc.Channel channel) {
+    return new StreamingVideoIntelligenceServiceFutureStub(channel);
+  }
+
+  /**
+   *
+   *
+   * <pre>
+   * Service that implements Google Cloud Video Intelligence Streaming API.
+   * </pre>
+   */
+  public abstract static class StreamingVideoIntelligenceServiceImplBase
+      implements io.grpc.BindableService {
+
+    /**
+     *
+     *
+     * <pre>
+     * Performs video annotation with bidirectional streaming: emitting results
+     * while sending video/audio bytes.
+     * This method is only available via the gRPC API (not REST).
+     * </pre>
+     */
+    public io.grpc.stub.StreamObserver<
+            com.google.cloud.videointelligence.v1p3beta1.StreamingAnnotateVideoRequest>
+        streamingAnnotateVideo(
+            io.grpc.stub.StreamObserver<
+                    com.google.cloud.videointelligence.v1p3beta1.StreamingAnnotateVideoResponse>
+                responseObserver) {
+      return asyncUnimplementedStreamingCall(
+          getStreamingAnnotateVideoMethodHelper(), responseObserver);
+    }
+
+    @java.lang.Override
+    public final io.grpc.ServerServiceDefinition bindService() {
+      return io.grpc.ServerServiceDefinition.builder(getServiceDescriptor())
+          .addMethod(
+              getStreamingAnnotateVideoMethodHelper(),
+              asyncBidiStreamingCall(
+                  new MethodHandlers<
+                      com.google.cloud.videointelligence.v1p3beta1.StreamingAnnotateVideoRequest,
+                      com.google.cloud.videointelligence.v1p3beta1.StreamingAnnotateVideoResponse>(
+                      this, METHODID_STREAMING_ANNOTATE_VIDEO)))
+          .build();
+    }
+  }
+
+  /**
+   *
+   *
+   * <pre>
+   * Service that implements Google Cloud Video Intelligence Streaming API.
+   * </pre>
+   */
+  public static final class StreamingVideoIntelligenceServiceStub
+      extends io.grpc.stub.AbstractStub<StreamingVideoIntelligenceServiceStub> {
+    private StreamingVideoIntelligenceServiceStub(io.grpc.Channel channel) {
+      super(channel);
+    }
+
+    private StreamingVideoIntelligenceServiceStub(
+        io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
+      super(channel, callOptions);
+    }
+
+    @java.lang.Override
+    protected StreamingVideoIntelligenceServiceStub build(
+        io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
+      return new StreamingVideoIntelligenceServiceStub(channel, callOptions);
+    }
+
+    /**
+     *
+     *
+     * <pre>
+     * Performs video annotation with bidirectional streaming: emitting results
+     * while sending video/audio bytes.
+     * This method is only available via the gRPC API (not REST).
+     * </pre>
+     */
+    public io.grpc.stub.StreamObserver<
+            com.google.cloud.videointelligence.v1p3beta1.StreamingAnnotateVideoRequest>
+        streamingAnnotateVideo(
+            io.grpc.stub.StreamObserver<
+                    com.google.cloud.videointelligence.v1p3beta1.StreamingAnnotateVideoResponse>
+                responseObserver) {
+      return asyncBidiStreamingCall(
+          getChannel().newCall(getStreamingAnnotateVideoMethodHelper(), getCallOptions()),
+          responseObserver);
+    }
+  }
+
+  /**
+   *
+   *
+   * <pre>
+   * Service that implements Google Cloud Video Intelligence Streaming API.
+   * </pre>
+   */
+  public static final class StreamingVideoIntelligenceServiceBlockingStub
+      extends io.grpc.stub.AbstractStub<StreamingVideoIntelligenceServiceBlockingStub> {
+    private StreamingVideoIntelligenceServiceBlockingStub(io.grpc.Channel channel) {
+      super(channel);
+    }
+
+    private StreamingVideoIntelligenceServiceBlockingStub(
+        io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
+      super(channel, callOptions);
+    }
+
+    @java.lang.Override
+    protected StreamingVideoIntelligenceServiceBlockingStub build(
+        io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
+      return new StreamingVideoIntelligenceServiceBlockingStub(channel, callOptions);
+    }
+  }
+
+  /**
+   *
+   *
+   * <pre>
+   * Service that implements Google Cloud Video Intelligence Streaming API.
+   * </pre>
+   */
+  public static final class StreamingVideoIntelligenceServiceFutureStub
+      extends io.grpc.stub.AbstractStub<StreamingVideoIntelligenceServiceFutureStub> {
+    private StreamingVideoIntelligenceServiceFutureStub(io.grpc.Channel channel) {
+      super(channel);
+    }
+
+    private StreamingVideoIntelligenceServiceFutureStub(
+        io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
+      super(channel, callOptions);
+    }
+
+    @java.lang.Override
+    protected StreamingVideoIntelligenceServiceFutureStub build(
+        io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
+      return new StreamingVideoIntelligenceServiceFutureStub(channel, callOptions);
+    }
+  }
+
+  private static final int METHODID_STREAMING_ANNOTATE_VIDEO = 0;
+
+  private static final 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 StreamingVideoIntelligenceServiceImplBase serviceImpl;
+    private final int methodId;
+
+    MethodHandlers(StreamingVideoIntelligenceServiceImplBase 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) {
+        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) {
+        case METHODID_STREAMING_ANNOTATE_VIDEO:
+          return (io.grpc.stub.StreamObserver<Req>)
+              serviceImpl.streamingAnnotateVideo(
+                  (io.grpc.stub.StreamObserver<
+                          com.google.cloud.videointelligence.v1p3beta1
+                              .StreamingAnnotateVideoResponse>)
+                      responseObserver);
+        default:
+          throw new AssertionError();
+      }
+    }
+  }
+
+  private abstract static class StreamingVideoIntelligenceServiceBaseDescriptorSupplier
+      implements io.grpc.protobuf.ProtoFileDescriptorSupplier,
+          io.grpc.protobuf.ProtoServiceDescriptorSupplier {
+    StreamingVideoIntelligenceServiceBaseDescriptorSupplier() {}
+
+    @java.lang.Override
+    public com.google.protobuf.Descriptors.FileDescriptor getFileDescriptor() {
+      return com.google.cloud.videointelligence.v1p3beta1.VideoIntelligenceServiceProto
+          .getDescriptor();
+    }
+
+    @java.lang.Override
+    public com.google.protobuf.Descriptors.ServiceDescriptor getServiceDescriptor() {
+      return getFileDescriptor().findServiceByName("StreamingVideoIntelligenceService");
+    }
+  }
+
+  private static final class StreamingVideoIntelligenceServiceFileDescriptorSupplier
+      extends StreamingVideoIntelligenceServiceBaseDescriptorSupplier {
+    StreamingVideoIntelligenceServiceFileDescriptorSupplier() {}
+  }
+
+  private static final class StreamingVideoIntelligenceServiceMethodDescriptorSupplier
+      extends StreamingVideoIntelligenceServiceBaseDescriptorSupplier
+      implements io.grpc.protobuf.ProtoMethodDescriptorSupplier {
+    private final String methodName;
+
+    StreamingVideoIntelligenceServiceMethodDescriptorSupplier(String methodName) {
+      this.methodName = methodName;
+    }
+
+    @java.lang.Override
+    public com.google.protobuf.Descriptors.MethodDescriptor getMethodDescriptor() {
+      return getServiceDescriptor().findMethodByName(methodName);
+    }
+  }
+
+  private static volatile io.grpc.ServiceDescriptor serviceDescriptor;
+
+  public static io.grpc.ServiceDescriptor getServiceDescriptor() {
+    io.grpc.ServiceDescriptor result = serviceDescriptor;
+    if (result == null) {
+      synchronized (StreamingVideoIntelligenceServiceGrpc.class) {
+        result = serviceDescriptor;
+        if (result == null) {
+          serviceDescriptor =
+              result =
+                  io.grpc.ServiceDescriptor.newBuilder(SERVICE_NAME)
+                      .setSchemaDescriptor(
+                          new StreamingVideoIntelligenceServiceFileDescriptorSupplier())
+                      .addMethod(getStreamingAnnotateVideoMethodHelper())
+                      .build();
+        }
+      }
+    }
+    return result;
+  }
+}