GoogleCloudPlatform · irataxy · May 20, 2022 · May 20, 2022 · May 20, 2022 · May 20, 2022
@@ -0,0 +1,75 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!--
+  Copyright 2020 Google LLC
+
+  Licensed under the Apache License, Version 2.0 (the "License");
+  you may not use this file except in compliance with the License.
+  You may obtain a copy of the License at
+
+       http://www.apache.org/licenses/LICENSE-2.0
+
+  Unless required by applicable law or agreed to in writing, software
+  distributed under the License is distributed on an "AS IS" BASIS,
+  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+  See the License for the specific language governing permissions and
+  limitations under the License.
+-->
+<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>
+  <groupId>com.example</groupId>
+  <artifactId>livestream</artifactId>
+  <version>1.0-SNAPSHOT</version>
+  <packaging>jar</packaging>
+  <!--
+  The parent pom defines common style checks and testing strategies for our samples.
+  Removing or replacing it should not affect the execution of the samples in any way.
+  -->
+  <parent>
+    <groupId>com.google.cloud.samples</groupId>
+    <artifactId>shared-configuration</artifactId>
+    <version>1.2.0</version>
+  </parent>
+  <properties>
+    <maven.compiler.target>11</maven.compiler.target>
+    <maven.compiler.source>11</maven.compiler.source>
+  </properties>
+  <!--  Using libraries-bom to manage versions.
+  See https://github.com/GoogleCloudPlatform/cloud-opensource-java/wiki/The-Google-Cloud-Platform-Libraries-BOM -->
+  <dependencyManagement>
+    <dependencies>
+      <dependency>
+        <groupId>com.google.cloud</groupId>
+        <artifactId>libraries-bom</artifactId>
+        <version>25.2.0</version>
+        <type>pom</type>
+        <scope>import</scope>
+      </dependency>
+    </dependencies>
+  </dependencyManagement>
+  <dependencies>
+    <dependency>
+      <groupId>com.google.cloud</groupId>
+      <artifactId>google-cloud-live-stream</artifactId>
+      <version>0.3.0</version>
+    </dependency>
+    <dependency>
+      <groupId>com.google.cloud</groupId>
+      <artifactId>google-cloud-core</artifactId>
+      <scope>compile</scope>
+    </dependency>
+    <dependency>
+      <groupId>org.apache.maven.plugins</groupId>
+      <artifactId>maven-compiler-plugin</artifactId>
+      <version>3.8.1</version>
+    </dependency>
+    <!-- Test dependencies -->
+    <dependency>
+      <groupId>junit</groupId>
+      <artifactId>junit</artifactId>
+      <version>4.13.2</version>
+      <scope>test</scope>
+    </dependency>
+  </dependencies>
+</project>
@@ -0,0 +1,63 @@
+/*
+ * Copyright 2022 Google LLC
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package com.example.livestream;
+
+// [START livestream_create_input]
+
+import com.google.api.gax.longrunning.OperationFuture;
+import com.google.cloud.video.livestream.v1.CreateInputRequest;
+import com.google.cloud.video.livestream.v1.Input;
+import com.google.cloud.video.livestream.v1.LivestreamServiceClient;
+import com.google.cloud.video.livestream.v1.LocationName;
+import com.google.cloud.video.livestream.v1.OperationMetadata;
+import java.io.IOException;
+import java.util.concurrent.ExecutionException;
+import java.util.concurrent.TimeUnit;
+import java.util.concurrent.TimeoutException;
+
+public class CreateInput {
+
+  public static void main(String[] args) throws Exception {
+    // TODO(developer): Replace these variables before running the sample.
+    String projectId = "my-project-id";
+    String location = "us-central1";
+    String inputId = "my-input-id";
+
+    createInput(projectId, location, inputId);
+  }
+
+  public static void createInput(String projectId, String location, String inputId)
+      throws InterruptedException, ExecutionException, TimeoutException, IOException {
+    // Initialize client that will be used to send requests. This client only needs to be created
+    // once, and can be reused for multiple requests. After completing all of your requests, call
+    // the "close" method on the client to safely clean up any remaining background resources.
+    try (LivestreamServiceClient livestreamServiceClient = LivestreamServiceClient.create()) {
+      var createInputRequest =
+          CreateInputRequest.newBuilder()
+              .setParent(LocationName.of(projectId, location).toString())
+              .setInputId(inputId)
+              .setInput(Input.newBuilder().setType(Input.Type.RTMP_PUSH).build())
+              .build();
+
+      OperationFuture<Input, OperationMetadata> call =
+          livestreamServiceClient.createInputAsync(createInputRequest);
+      Input result = call.get(1, TimeUnit.MINUTES);
+      System.out.println("Input: " + result.getName());
+    }
+  }
+}
+// [END livestream_create_input]
@@ -0,0 +1,56 @@
+/*
+ * Copyright 2022 Google LLC
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package com.example.livestream;
+
+// [START livestream_delete_input]
+
+import com.google.cloud.video.livestream.v1.DeleteInputRequest;
+import com.google.cloud.video.livestream.v1.InputName;
+import com.google.cloud.video.livestream.v1.LivestreamServiceClient;
+import java.io.IOException;
+import java.util.concurrent.ExecutionException;
+import java.util.concurrent.TimeUnit;
+import java.util.concurrent.TimeoutException;
+
+public class DeleteInput {
+
+  public static void main(String[] args) throws Exception {
+    // TODO(developer): Replace these variables before running the sample.
+    String projectId = "my-project-id";
+    String location = "us-central1";
+    String inputId = "my-input-id";
+
+    deleteInput(projectId, location, inputId);
+  }
+
+  public static void deleteInput(String projectId, String location, String inputId)
+      throws InterruptedException, ExecutionException, TimeoutException, IOException {
+    // Initialize client that will be used to send requests. This client only needs to be created
+    // once, and can be reused for multiple requests. After completing all of your requests, call
+    // the "close" method on the client to safely clean up any remaining background resources.
+    try (LivestreamServiceClient livestreamServiceClient = LivestreamServiceClient.create()) {
+      var deleteInputRequest =
+          DeleteInputRequest.newBuilder()
+              .setName(InputName.of(projectId, location, inputId).toString())
+              .build();
+
+      livestreamServiceClient.deleteInputAsync(deleteInputRequest).get(1, TimeUnit.MINUTES);
+      System.out.println("Deleted input");
+    }
+  }
+}
+// [END livestream_delete_input]
@@ -0,0 +1,49 @@
+/*
+ * Copyright 2022 Google LLC
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package com.example.livestream;
+
+// [START livestream_get_input]
+
+import com.google.cloud.video.livestream.v1.Input;
+import com.google.cloud.video.livestream.v1.InputName;
+import com.google.cloud.video.livestream.v1.LivestreamServiceClient;
+import java.io.IOException;
+
+public class GetInput {
+
+  public static void main(String[] args) throws Exception {
+    // TODO(developer): Replace these variables before running the sample.
+    String projectId = "my-project-id";
+    String location = "us-central1";
+    String inputId = "my-input-id";
+
+    getInput(projectId, location, inputId);
+  }
+
+  public static void getInput(String projectId, String location, String inputId)
+      throws IOException {
+    // Initialize client that will be used to send requests. This client only needs to be created
+    // once, and can be reused for multiple requests. After completing all of your requests, call
+    // the "close" method on the client to safely clean up any remaining background resources.
+    try (LivestreamServiceClient livestreamServiceClient = LivestreamServiceClient.create()) {
+      InputName name = InputName.of(projectId, location, inputId);
+      Input response = livestreamServiceClient.getInput(name);
+      System.out.println("Input: " + response.getName());
+    }
+  }
+}
+// [END livestream_get_input]
@@ -0,0 +1,57 @@
+/*
+ * Copyright 2022 Google LLC
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package com.example.livestream;
+
+// [START livestream_list_inputs]
+
+import com.google.cloud.video.livestream.v1.Input;
+import com.google.cloud.video.livestream.v1.ListInputsRequest;
+import com.google.cloud.video.livestream.v1.LivestreamServiceClient;
+import com.google.cloud.video.livestream.v1.LocationName;
+import java.io.IOException;
+
+public class ListInputs {
+
+  public static void main(String[] args) throws Exception {
+    // TODO(developer): Replace these variables before running the sample.
+    String projectId = "my-project-id";
+    String location = "us-central1";
+
+    listInputs(projectId, location);
+  }
+
+  public static void listInputs(String projectId, String location) throws IOException {
+    // Initialize client that will be used to send requests. This client only needs to be created
+    // once, and can be reused for multiple requests. After completing all of your requests, call
+    // the "close" method on the client to safely clean up any remaining background resources.
+    try (LivestreamServiceClient livestreamServiceClient = LivestreamServiceClient.create()) {
+      var listInputsRequest =
+          ListInputsRequest.newBuilder()
+              .setParent(LocationName.of(projectId, location).toString())
+              .build();
+
+      LivestreamServiceClient.ListInputsPagedResponse response =
+          livestreamServiceClient.listInputs(listInputsRequest);
+      System.out.println("Inputs:");
+
+      for (Input input : response.iterateAll()) {
+        System.out.println(input.getName());
+      }
+    }
+  }
+}
+// [END livestream_list_inputs]
@@ -0,0 +1,72 @@
+/*
+ * Copyright 2022 Google LLC
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package com.example.livestream;
+
+// [START livestream_update_input]
+
+import com.google.api.gax.longrunning.OperationFuture;
+import com.google.cloud.video.livestream.v1.Input;
+import com.google.cloud.video.livestream.v1.InputName;
+import com.google.cloud.video.livestream.v1.LivestreamServiceClient;
+import com.google.cloud.video.livestream.v1.OperationMetadata;
+import com.google.cloud.video.livestream.v1.PreprocessingConfig;
+import com.google.cloud.video.livestream.v1.PreprocessingConfig.Crop;
+import com.google.cloud.video.livestream.v1.UpdateInputRequest;
+import com.google.protobuf.FieldMask;
+import java.io.IOException;
+import java.util.concurrent.ExecutionException;
+import java.util.concurrent.TimeUnit;
+import java.util.concurrent.TimeoutException;
+
+public class UpdateInput {
+
+  public static void main(String[] args) throws Exception {
+    // TODO(developer): Replace these variables before running the sample.
+    String projectId = "my-project-id";
+    String location = "us-central1";
+    String inputId = "my-input-id";
+
+    updateInput(projectId, location, inputId);
+  }
+
+  public static void updateInput(String projectId, String location, String inputId)
+      throws InterruptedException, ExecutionException, TimeoutException, IOException {
+    // Initialize client that will be used to send requests. This client only needs to be created
+    // once, and can be reused for multiple requests. After completing all of your requests, call
+    // the "close" method on the client to safely clean up any remaining background resources.
+    try (LivestreamServiceClient livestreamServiceClient = LivestreamServiceClient.create()) {
+      var updateInputRequest =
+          UpdateInputRequest.newBuilder()
+              .setInput(
+                  Input.newBuilder()
+                      .setName(InputName.of(projectId, location, inputId).toString())
+                      .setPreprocessingConfig(
+                          PreprocessingConfig.newBuilder()
+                              .setCrop(Crop.newBuilder().setTopPixels(5).setBottomPixels(5).build())
+                              .build())
+                      .build())
+              .setUpdateMask(FieldMask.newBuilder().addPaths("preprocessing_config").build())
+              .build();
+
+      OperationFuture<Input, OperationMetadata> call =
+          livestreamServiceClient.updateInputAsync(updateInputRequest);
+      Input result = call.get(1, TimeUnit.MINUTES);
+      System.out.println("Updated input: " + result.getName());
+    }
+  }
+}
+// [END livestream_update_input]