This class provides the ability to make remote calls to the backing service through method - * calls that map to API methods. Sample code to get started: - * - *
- *
- * try (ConfigServiceV2Api configServiceV2Api = ConfigServiceV2Api.create()) {
- * String formattedSinkName = ConfigServiceV2Api.formatSinkName("[PROJECT]", "[SINK]");
- * LogSink response = configServiceV2Api.getSink(formattedSinkName);
- * }
- *
- *
- *
- * Note: close() needs to be called on the configServiceV2Api object to clean up resources such - * as threads. In the example above, try-with-resources is used, which automatically calls - * close(). - * - *
The surface of this class includes several types of Java methods for each of the API's methods: - * - *
See the individual methods for example code. - * - *
Many parameters require resource names to be formatted in a particular way. To assist - * with these names, this class includes a format method for each type of name, and additionally - * a parse method to extract the individual identifiers contained within names that are - * returned. - * - *
This class can be customized by passing in a custom instance of ConfigServiceV2Settings to - * create(). For example: - * - *
- *
- * ConfigServiceV2Settings configServiceV2Settings = ConfigServiceV2Settings.defaultBuilder()
- * .provideChannelWith(myCredentials)
- * .build();
- * ConfigServiceV2Api configServiceV2Api = ConfigServiceV2Api.create(configServiceV2Settings);
- *
- *
- */
-@javax.annotation.Generated("by GAPIC")
-public class ConfigServiceV2Api implements AutoCloseable {
- private final ConfigServiceV2Settings settings;
- private final ManagedChannel channel;
- private final ScheduledExecutorService executor;
- private final List
- * try (ConfigServiceV2Api configServiceV2Api = ConfigServiceV2Api.create()) {
- * String formattedParent = ConfigServiceV2Api.formatParentName("[PROJECT]");
- * for (LogSink element : configServiceV2Api.listSinks(formattedParent)) {
- * // doThingsWith(element);
- * }
- * }
- *
- * try (ConfigServiceV2Api configServiceV2Api = ConfigServiceV2Api.create()) {
- * String formattedParent = ConfigServiceV2Api.formatParentName("[PROJECT]");
- * ListSinksRequest request = ListSinksRequest.newBuilder()
- * .setParent(formattedParent)
- * .build();
- * for (LogSink element : configServiceV2Api.listSinks(request)) {
- * // doThingsWith(element);
- * }
- * }
- *
- * try (ConfigServiceV2Api configServiceV2Api = ConfigServiceV2Api.create()) {
- * String formattedParent = ConfigServiceV2Api.formatParentName("[PROJECT]");
- * ListSinksRequest request = ListSinksRequest.newBuilder()
- * .setParent(formattedParent)
- * .build();
- * ListenableFuture<PageAccessor<LogSink>> future = configServiceV2Api.listSinksPagedCallable().futureCall(request);
- * // Do something
- * for (LogSink element : future.get()) {
- * // doThingsWith(element);
- * }
- * }
- *
- * try (ConfigServiceV2Api configServiceV2Api = ConfigServiceV2Api.create()) {
- * String formattedParent = ConfigServiceV2Api.formatParentName("[PROJECT]");
- * ListSinksRequest request = ListSinksRequest.newBuilder()
- * .setParent(formattedParent)
- * .build();
- * while (true) {
- * ListSinksResponse response = configServiceV2Api.listSinksCallable().call(request);
- * for (LogSink element : response.getSinksList()) {
- * // doThingsWith(element);
- * }
- * String nextPageToken = response.getNextPageToken();
- * if (!Strings.isNullOrEmpty(nextPageToken)) {
- * request = request.toBuilder().setPageToken(nextPageToken).build();
- * } else {
- * break;
- * }
- * }
- * }
- *
- * try (ConfigServiceV2Api configServiceV2Api = ConfigServiceV2Api.create()) {
- * String formattedSinkName = ConfigServiceV2Api.formatSinkName("[PROJECT]", "[SINK]");
- * LogSink response = configServiceV2Api.getSink(formattedSinkName);
- * }
- *
- * try (ConfigServiceV2Api configServiceV2Api = ConfigServiceV2Api.create()) {
- * String formattedSinkName = ConfigServiceV2Api.formatSinkName("[PROJECT]", "[SINK]");
- * GetSinkRequest request = GetSinkRequest.newBuilder()
- * .setSinkName(formattedSinkName)
- * .build();
- * LogSink response = configServiceV2Api.getSink(request);
- * }
- *
- * try (ConfigServiceV2Api configServiceV2Api = ConfigServiceV2Api.create()) {
- * String formattedSinkName = ConfigServiceV2Api.formatSinkName("[PROJECT]", "[SINK]");
- * GetSinkRequest request = GetSinkRequest.newBuilder()
- * .setSinkName(formattedSinkName)
- * .build();
- * ListenableFuture<LogSink> future = configServiceV2Api.getSinkCallable().futureCall(request);
- * // Do something
- * LogSink response = future.get();
- * }
- *
- * try (ConfigServiceV2Api configServiceV2Api = ConfigServiceV2Api.create()) {
- * String formattedParent = ConfigServiceV2Api.formatParentName("[PROJECT]");
- * LogSink sink = LogSink.newBuilder().build();
- * LogSink response = configServiceV2Api.createSink(formattedParent, sink);
- * }
- *
- * try (ConfigServiceV2Api configServiceV2Api = ConfigServiceV2Api.create()) {
- * String formattedParent = ConfigServiceV2Api.formatParentName("[PROJECT]");
- * LogSink sink = LogSink.newBuilder().build();
- * CreateSinkRequest request = CreateSinkRequest.newBuilder()
- * .setParent(formattedParent)
- * .setSink(sink)
- * .build();
- * LogSink response = configServiceV2Api.createSink(request);
- * }
- *
- * try (ConfigServiceV2Api configServiceV2Api = ConfigServiceV2Api.create()) {
- * String formattedParent = ConfigServiceV2Api.formatParentName("[PROJECT]");
- * LogSink sink = LogSink.newBuilder().build();
- * CreateSinkRequest request = CreateSinkRequest.newBuilder()
- * .setParent(formattedParent)
- * .setSink(sink)
- * .build();
- * ListenableFuture<LogSink> future = configServiceV2Api.createSinkCallable().futureCall(request);
- * // Do something
- * LogSink response = future.get();
- * }
- *
- * try (ConfigServiceV2Api configServiceV2Api = ConfigServiceV2Api.create()) {
- * String formattedSinkName = ConfigServiceV2Api.formatSinkName("[PROJECT]", "[SINK]");
- * LogSink sink = LogSink.newBuilder().build();
- * LogSink response = configServiceV2Api.updateSink(formattedSinkName, sink);
- * }
- *
- * try (ConfigServiceV2Api configServiceV2Api = ConfigServiceV2Api.create()) {
- * String formattedSinkName = ConfigServiceV2Api.formatSinkName("[PROJECT]", "[SINK]");
- * LogSink sink = LogSink.newBuilder().build();
- * UpdateSinkRequest request = UpdateSinkRequest.newBuilder()
- * .setSinkName(formattedSinkName)
- * .setSink(sink)
- * .build();
- * LogSink response = configServiceV2Api.updateSink(request);
- * }
- *
- * try (ConfigServiceV2Api configServiceV2Api = ConfigServiceV2Api.create()) {
- * String formattedSinkName = ConfigServiceV2Api.formatSinkName("[PROJECT]", "[SINK]");
- * LogSink sink = LogSink.newBuilder().build();
- * UpdateSinkRequest request = UpdateSinkRequest.newBuilder()
- * .setSinkName(formattedSinkName)
- * .setSink(sink)
- * .build();
- * ListenableFuture<LogSink> future = configServiceV2Api.updateSinkCallable().futureCall(request);
- * // Do something
- * LogSink response = future.get();
- * }
- *
- * try (ConfigServiceV2Api configServiceV2Api = ConfigServiceV2Api.create()) {
- * String formattedSinkName = ConfigServiceV2Api.formatSinkName("[PROJECT]", "[SINK]");
- * configServiceV2Api.deleteSink(formattedSinkName);
- * }
- *
- * try (ConfigServiceV2Api configServiceV2Api = ConfigServiceV2Api.create()) {
- * String formattedSinkName = ConfigServiceV2Api.formatSinkName("[PROJECT]", "[SINK]");
- * DeleteSinkRequest request = DeleteSinkRequest.newBuilder()
- * .setSinkName(formattedSinkName)
- * .build();
- * configServiceV2Api.deleteSink(request);
- * }
- *
- * try (ConfigServiceV2Api configServiceV2Api = ConfigServiceV2Api.create()) {
- * String formattedSinkName = ConfigServiceV2Api.formatSinkName("[PROJECT]", "[SINK]");
- * DeleteSinkRequest request = DeleteSinkRequest.newBuilder()
- * .setSinkName(formattedSinkName)
- * .build();
- * ListenableFuture<Void> future = configServiceV2Api.deleteSinkCallable().futureCall(request);
- * // Do something
- * future.get();
- * }
- * The default instance has everything set to sensible defaults: - * - *
The builder of this class is recursive, so contained classes are themselves builders. - * When build() is called, the tree of builders is called to create the complete settings - * object. For example, to set the total timeout of getSink to 30 seconds: - * - *
- *
- * ConfigServiceV2Settings.Builder configServiceV2SettingsBuilder =
- * ConfigServiceV2Settings.defaultBuilder();
- * configServiceV2SettingsBuilder.getSinkSettings().getRetrySettingsBuilder()
- * .setTotalTimeout(Duration.standardSeconds(30));
- * ConfigServiceV2Settings configServiceV2Settings = configServiceV2SettingsBuilder.build();
- *
- *
- */
-@javax.annotation.Generated("by GAPIC")
-public class ConfigServiceV2Settings extends ServiceApiSettings {
- /**
- * The default address of the service.
- */
- private static final String DEFAULT_SERVICE_ADDRESS = "logging.googleapis.com";
-
- /**
- * The default port of the service.
- */
- private static final int DEFAULT_SERVICE_PORT = 443;
-
- /**
- * The default scopes of the service.
- */
- private static final ImmutableListThis class provides the ability to make remote calls to the backing service through method - * calls that map to API methods. Sample code to get started: - * - *
- *
- * try (LoggingServiceV2Api loggingServiceV2Api = LoggingServiceV2Api.create()) {
- * String formattedLogName = LoggingServiceV2Api.formatLogName("[PROJECT]", "[LOG]");
- * loggingServiceV2Api.deleteLog(formattedLogName);
- * }
- *
- *
- *
- * Note: close() needs to be called on the loggingServiceV2Api object to clean up resources such - * as threads. In the example above, try-with-resources is used, which automatically calls - * close(). - * - *
The surface of this class includes several types of Java methods for each of the API's methods: - * - *
See the individual methods for example code. - * - *
Many parameters require resource names to be formatted in a particular way. To assist - * with these names, this class includes a format method for each type of name, and additionally - * a parse method to extract the individual identifiers contained within names that are - * returned. - * - *
This class can be customized by passing in a custom instance of LoggingServiceV2Settings to - * create(). For example: - * - *
- *
- * LoggingServiceV2Settings loggingServiceV2Settings = LoggingServiceV2Settings.defaultBuilder()
- * .provideChannelWith(myCredentials)
- * .build();
- * LoggingServiceV2Api loggingServiceV2Api = LoggingServiceV2Api.create(loggingServiceV2Settings);
- *
- *
- */
-@javax.annotation.Generated("by GAPIC")
-public class LoggingServiceV2Api implements AutoCloseable {
- private final LoggingServiceV2Settings settings;
- private final ManagedChannel channel;
- private final ScheduledExecutorService executor;
- private final List
- * try (LoggingServiceV2Api loggingServiceV2Api = LoggingServiceV2Api.create()) {
- * String formattedLogName = LoggingServiceV2Api.formatLogName("[PROJECT]", "[LOG]");
- * loggingServiceV2Api.deleteLog(formattedLogName);
- * }
- *
- * try (LoggingServiceV2Api loggingServiceV2Api = LoggingServiceV2Api.create()) {
- * String formattedLogName = LoggingServiceV2Api.formatLogName("[PROJECT]", "[LOG]");
- * DeleteLogRequest request = DeleteLogRequest.newBuilder()
- * .setLogName(formattedLogName)
- * .build();
- * loggingServiceV2Api.deleteLog(request);
- * }
- *
- * try (LoggingServiceV2Api loggingServiceV2Api = LoggingServiceV2Api.create()) {
- * String formattedLogName = LoggingServiceV2Api.formatLogName("[PROJECT]", "[LOG]");
- * DeleteLogRequest request = DeleteLogRequest.newBuilder()
- * .setLogName(formattedLogName)
- * .build();
- * ListenableFuture<Void> future = loggingServiceV2Api.deleteLogCallable().futureCall(request);
- * // Do something
- * future.get();
- * }
- *
- * try (LoggingServiceV2Api loggingServiceV2Api = LoggingServiceV2Api.create()) {
- * String logName = "";
- * MonitoredResource resource = MonitoredResource.newBuilder().build();
- * Map<String, String> labels = new HashMap<>();
- * List<LogEntry> entries = new ArrayList<>();
- * WriteLogEntriesResponse response = loggingServiceV2Api.writeLogEntries(logName, resource, labels, entries);
- * }
- *
- * try (LoggingServiceV2Api loggingServiceV2Api = LoggingServiceV2Api.create()) {
- * List<LogEntry> entries = new ArrayList<>();
- * WriteLogEntriesRequest request = WriteLogEntriesRequest.newBuilder()
- * .addAllEntries(entries)
- * .build();
- * WriteLogEntriesResponse response = loggingServiceV2Api.writeLogEntries(request);
- * }
- *
- * try (LoggingServiceV2Api loggingServiceV2Api = LoggingServiceV2Api.create()) {
- * List<LogEntry> entries = new ArrayList<>();
- * WriteLogEntriesRequest request = WriteLogEntriesRequest.newBuilder()
- * .addAllEntries(entries)
- * .build();
- * ListenableFuture<WriteLogEntriesResponse> future = loggingServiceV2Api.writeLogEntriesCallable().futureCall(request);
- * // Do something
- * WriteLogEntriesResponse response = future.get();
- * }
- *
- * try (LoggingServiceV2Api loggingServiceV2Api = LoggingServiceV2Api.create()) {
- * List<String> projectIds = new ArrayList<>();
- * String filter = "";
- * String orderBy = "";
- * for (LogEntry element : loggingServiceV2Api.listLogEntries(projectIds, filter, orderBy)) {
- * // doThingsWith(element);
- * }
- * }
- *
- * try (LoggingServiceV2Api loggingServiceV2Api = LoggingServiceV2Api.create()) {
- * List<String> projectIds = new ArrayList<>();
- * ListLogEntriesRequest request = ListLogEntriesRequest.newBuilder()
- * .addAllProjectIds(projectIds)
- * .build();
- * for (LogEntry element : loggingServiceV2Api.listLogEntries(request)) {
- * // doThingsWith(element);
- * }
- * }
- *
- * try (LoggingServiceV2Api loggingServiceV2Api = LoggingServiceV2Api.create()) {
- * List<String> projectIds = new ArrayList<>();
- * ListLogEntriesRequest request = ListLogEntriesRequest.newBuilder()
- * .addAllProjectIds(projectIds)
- * .build();
- * ListenableFuture<PageAccessor<LogEntry>> future = loggingServiceV2Api.listLogEntriesPagedCallable().futureCall(request);
- * // Do something
- * for (LogEntry element : future.get()) {
- * // doThingsWith(element);
- * }
- * }
- *
- * try (LoggingServiceV2Api loggingServiceV2Api = LoggingServiceV2Api.create()) {
- * List<String> projectIds = new ArrayList<>();
- * ListLogEntriesRequest request = ListLogEntriesRequest.newBuilder()
- * .addAllProjectIds(projectIds)
- * .build();
- * while (true) {
- * ListLogEntriesResponse response = loggingServiceV2Api.listLogEntriesCallable().call(request);
- * for (LogEntry element : response.getEntriesList()) {
- * // doThingsWith(element);
- * }
- * String nextPageToken = response.getNextPageToken();
- * if (!Strings.isNullOrEmpty(nextPageToken)) {
- * request = request.toBuilder().setPageToken(nextPageToken).build();
- * } else {
- * break;
- * }
- * }
- * }
- *
- * try (LoggingServiceV2Api loggingServiceV2Api = LoggingServiceV2Api.create()) {
- * ListMonitoredResourceDescriptorsRequest request = ListMonitoredResourceDescriptorsRequest.newBuilder()
- * .build();
- * for (MonitoredResourceDescriptor element : loggingServiceV2Api.listMonitoredResourceDescriptors(request)) {
- * // doThingsWith(element);
- * }
- * }
- *
- * try (LoggingServiceV2Api loggingServiceV2Api = LoggingServiceV2Api.create()) {
- * ListMonitoredResourceDescriptorsRequest request = ListMonitoredResourceDescriptorsRequest.newBuilder()
- * .build();
- * ListenableFuture<PageAccessor<MonitoredResourceDescriptor>> future = loggingServiceV2Api.listMonitoredResourceDescriptorsPagedCallable().futureCall(request);
- * // Do something
- * for (MonitoredResourceDescriptor element : future.get()) {
- * // doThingsWith(element);
- * }
- * }
- *
- * try (LoggingServiceV2Api loggingServiceV2Api = LoggingServiceV2Api.create()) {
- * ListMonitoredResourceDescriptorsRequest request = ListMonitoredResourceDescriptorsRequest.newBuilder()
- * .build();
- * while (true) {
- * ListMonitoredResourceDescriptorsResponse response = loggingServiceV2Api.listMonitoredResourceDescriptorsCallable().call(request);
- * for (MonitoredResourceDescriptor element : response.getResourceDescriptorsList()) {
- * // doThingsWith(element);
- * }
- * String nextPageToken = response.getNextPageToken();
- * if (!Strings.isNullOrEmpty(nextPageToken)) {
- * request = request.toBuilder().setPageToken(nextPageToken).build();
- * } else {
- * break;
- * }
- * }
- * }
- * The default instance has everything set to sensible defaults: - * - *
The builder of this class is recursive, so contained classes are themselves builders. - * When build() is called, the tree of builders is called to create the complete settings - * object. For example, to set the total timeout of deleteLog to 30 seconds: - * - *
- *
- * LoggingServiceV2Settings.Builder loggingServiceV2SettingsBuilder =
- * LoggingServiceV2Settings.defaultBuilder();
- * loggingServiceV2SettingsBuilder.deleteLogSettings().getRetrySettingsBuilder()
- * .setTotalTimeout(Duration.standardSeconds(30));
- * LoggingServiceV2Settings loggingServiceV2Settings = loggingServiceV2SettingsBuilder.build();
- *
- *
- */
-@javax.annotation.Generated("by GAPIC")
-public class LoggingServiceV2Settings extends ServiceApiSettings {
- /**
- * The default address of the service.
- */
- private static final String DEFAULT_SERVICE_ADDRESS = "logging.googleapis.com";
-
- /**
- * The default port of the service.
- */
- private static final int DEFAULT_SERVICE_PORT = 443;
-
- /**
- * The default scopes of the service.
- */
- private static final ImmutableListThis class provides the ability to make remote calls to the backing service through method - * calls that map to API methods. Sample code to get started: - * - *
- *
- * try (MetricsServiceV2Api metricsServiceV2Api = MetricsServiceV2Api.create()) {
- * String formattedMetricName = MetricsServiceV2Api.formatMetricName("[PROJECT]", "[METRIC]");
- * LogMetric response = metricsServiceV2Api.getLogMetric(formattedMetricName);
- * }
- *
- *
- *
- * Note: close() needs to be called on the metricsServiceV2Api object to clean up resources such - * as threads. In the example above, try-with-resources is used, which automatically calls - * close(). - * - *
The surface of this class includes several types of Java methods for each of the API's methods: - * - *
See the individual methods for example code. - * - *
Many parameters require resource names to be formatted in a particular way. To assist - * with these names, this class includes a format method for each type of name, and additionally - * a parse method to extract the individual identifiers contained within names that are - * returned. - * - *
This class can be customized by passing in a custom instance of MetricsServiceV2Settings to - * create(). For example: - * - *
- *
- * MetricsServiceV2Settings metricsServiceV2Settings = MetricsServiceV2Settings.defaultBuilder()
- * .provideChannelWith(myCredentials)
- * .build();
- * MetricsServiceV2Api metricsServiceV2Api = MetricsServiceV2Api.create(metricsServiceV2Settings);
- *
- *
- */
-@javax.annotation.Generated("by GAPIC")
-public class MetricsServiceV2Api implements AutoCloseable {
- private final MetricsServiceV2Settings settings;
- private final ManagedChannel channel;
- private final ScheduledExecutorService executor;
- private final List
- * try (MetricsServiceV2Api metricsServiceV2Api = MetricsServiceV2Api.create()) {
- * String formattedParent = MetricsServiceV2Api.formatParentName("[PROJECT]");
- * for (LogMetric element : metricsServiceV2Api.listLogMetrics(formattedParent)) {
- * // doThingsWith(element);
- * }
- * }
- *
- * try (MetricsServiceV2Api metricsServiceV2Api = MetricsServiceV2Api.create()) {
- * String formattedParent = MetricsServiceV2Api.formatParentName("[PROJECT]");
- * ListLogMetricsRequest request = ListLogMetricsRequest.newBuilder()
- * .setParent(formattedParent)
- * .build();
- * for (LogMetric element : metricsServiceV2Api.listLogMetrics(request)) {
- * // doThingsWith(element);
- * }
- * }
- *
- * try (MetricsServiceV2Api metricsServiceV2Api = MetricsServiceV2Api.create()) {
- * String formattedParent = MetricsServiceV2Api.formatParentName("[PROJECT]");
- * ListLogMetricsRequest request = ListLogMetricsRequest.newBuilder()
- * .setParent(formattedParent)
- * .build();
- * ListenableFuture<PageAccessor<LogMetric>> future = metricsServiceV2Api.listLogMetricsPagedCallable().futureCall(request);
- * // Do something
- * for (LogMetric element : future.get()) {
- * // doThingsWith(element);
- * }
- * }
- *
- * try (MetricsServiceV2Api metricsServiceV2Api = MetricsServiceV2Api.create()) {
- * String formattedParent = MetricsServiceV2Api.formatParentName("[PROJECT]");
- * ListLogMetricsRequest request = ListLogMetricsRequest.newBuilder()
- * .setParent(formattedParent)
- * .build();
- * while (true) {
- * ListLogMetricsResponse response = metricsServiceV2Api.listLogMetricsCallable().call(request);
- * for (LogMetric element : response.getMetricsList()) {
- * // doThingsWith(element);
- * }
- * String nextPageToken = response.getNextPageToken();
- * if (!Strings.isNullOrEmpty(nextPageToken)) {
- * request = request.toBuilder().setPageToken(nextPageToken).build();
- * } else {
- * break;
- * }
- * }
- * }
- *
- * try (MetricsServiceV2Api metricsServiceV2Api = MetricsServiceV2Api.create()) {
- * String formattedMetricName = MetricsServiceV2Api.formatMetricName("[PROJECT]", "[METRIC]");
- * LogMetric response = metricsServiceV2Api.getLogMetric(formattedMetricName);
- * }
- *
- * try (MetricsServiceV2Api metricsServiceV2Api = MetricsServiceV2Api.create()) {
- * String formattedMetricName = MetricsServiceV2Api.formatMetricName("[PROJECT]", "[METRIC]");
- * GetLogMetricRequest request = GetLogMetricRequest.newBuilder()
- * .setMetricName(formattedMetricName)
- * .build();
- * LogMetric response = metricsServiceV2Api.getLogMetric(request);
- * }
- *
- * try (MetricsServiceV2Api metricsServiceV2Api = MetricsServiceV2Api.create()) {
- * String formattedMetricName = MetricsServiceV2Api.formatMetricName("[PROJECT]", "[METRIC]");
- * GetLogMetricRequest request = GetLogMetricRequest.newBuilder()
- * .setMetricName(formattedMetricName)
- * .build();
- * ListenableFuture<LogMetric> future = metricsServiceV2Api.getLogMetricCallable().futureCall(request);
- * // Do something
- * LogMetric response = future.get();
- * }
- *
- * try (MetricsServiceV2Api metricsServiceV2Api = MetricsServiceV2Api.create()) {
- * String formattedParent = MetricsServiceV2Api.formatParentName("[PROJECT]");
- * LogMetric metric = LogMetric.newBuilder().build();
- * LogMetric response = metricsServiceV2Api.createLogMetric(formattedParent, metric);
- * }
- *
- * try (MetricsServiceV2Api metricsServiceV2Api = MetricsServiceV2Api.create()) {
- * String formattedParent = MetricsServiceV2Api.formatParentName("[PROJECT]");
- * LogMetric metric = LogMetric.newBuilder().build();
- * CreateLogMetricRequest request = CreateLogMetricRequest.newBuilder()
- * .setParent(formattedParent)
- * .setMetric(metric)
- * .build();
- * LogMetric response = metricsServiceV2Api.createLogMetric(request);
- * }
- *
- * try (MetricsServiceV2Api metricsServiceV2Api = MetricsServiceV2Api.create()) {
- * String formattedParent = MetricsServiceV2Api.formatParentName("[PROJECT]");
- * LogMetric metric = LogMetric.newBuilder().build();
- * CreateLogMetricRequest request = CreateLogMetricRequest.newBuilder()
- * .setParent(formattedParent)
- * .setMetric(metric)
- * .build();
- * ListenableFuture<LogMetric> future = metricsServiceV2Api.createLogMetricCallable().futureCall(request);
- * // Do something
- * LogMetric response = future.get();
- * }
- *
- * try (MetricsServiceV2Api metricsServiceV2Api = MetricsServiceV2Api.create()) {
- * String formattedMetricName = MetricsServiceV2Api.formatMetricName("[PROJECT]", "[METRIC]");
- * LogMetric metric = LogMetric.newBuilder().build();
- * LogMetric response = metricsServiceV2Api.updateLogMetric(formattedMetricName, metric);
- * }
- *
- * try (MetricsServiceV2Api metricsServiceV2Api = MetricsServiceV2Api.create()) {
- * String formattedMetricName = MetricsServiceV2Api.formatMetricName("[PROJECT]", "[METRIC]");
- * LogMetric metric = LogMetric.newBuilder().build();
- * UpdateLogMetricRequest request = UpdateLogMetricRequest.newBuilder()
- * .setMetricName(formattedMetricName)
- * .setMetric(metric)
- * .build();
- * LogMetric response = metricsServiceV2Api.updateLogMetric(request);
- * }
- *
- * try (MetricsServiceV2Api metricsServiceV2Api = MetricsServiceV2Api.create()) {
- * String formattedMetricName = MetricsServiceV2Api.formatMetricName("[PROJECT]", "[METRIC]");
- * LogMetric metric = LogMetric.newBuilder().build();
- * UpdateLogMetricRequest request = UpdateLogMetricRequest.newBuilder()
- * .setMetricName(formattedMetricName)
- * .setMetric(metric)
- * .build();
- * ListenableFuture<LogMetric> future = metricsServiceV2Api.updateLogMetricCallable().futureCall(request);
- * // Do something
- * LogMetric response = future.get();
- * }
- *
- * try (MetricsServiceV2Api metricsServiceV2Api = MetricsServiceV2Api.create()) {
- * String formattedMetricName = MetricsServiceV2Api.formatMetricName("[PROJECT]", "[METRIC]");
- * metricsServiceV2Api.deleteLogMetric(formattedMetricName);
- * }
- *
- * try (MetricsServiceV2Api metricsServiceV2Api = MetricsServiceV2Api.create()) {
- * String formattedMetricName = MetricsServiceV2Api.formatMetricName("[PROJECT]", "[METRIC]");
- * DeleteLogMetricRequest request = DeleteLogMetricRequest.newBuilder()
- * .setMetricName(formattedMetricName)
- * .build();
- * metricsServiceV2Api.deleteLogMetric(request);
- * }
- *
- * try (MetricsServiceV2Api metricsServiceV2Api = MetricsServiceV2Api.create()) {
- * String formattedMetricName = MetricsServiceV2Api.formatMetricName("[PROJECT]", "[METRIC]");
- * DeleteLogMetricRequest request = DeleteLogMetricRequest.newBuilder()
- * .setMetricName(formattedMetricName)
- * .build();
- * ListenableFuture<Void> future = metricsServiceV2Api.deleteLogMetricCallable().futureCall(request);
- * // Do something
- * future.get();
- * }
- * The default instance has everything set to sensible defaults: - * - *
The builder of this class is recursive, so contained classes are themselves builders. - * When build() is called, the tree of builders is called to create the complete settings - * object. For example, to set the total timeout of getLogMetric to 30 seconds: - * - *
- *
- * MetricsServiceV2Settings.Builder metricsServiceV2SettingsBuilder =
- * MetricsServiceV2Settings.defaultBuilder();
- * metricsServiceV2SettingsBuilder.getLogMetricSettings().getRetrySettingsBuilder()
- * .setTotalTimeout(Duration.standardSeconds(30));
- * MetricsServiceV2Settings metricsServiceV2Settings = metricsServiceV2SettingsBuilder.build();
- *
- *
- */
-@javax.annotation.Generated("by GAPIC")
-public class MetricsServiceV2Settings extends ServiceApiSettings {
- /**
- * The default address of the service.
- */
- private static final String DEFAULT_SERVICE_ADDRESS = "logging.googleapis.com";
-
- /**
- * The default port of the service.
- */
- private static final int DEFAULT_SERVICE_PORT = 443;
-
- /**
- * The default scopes of the service.
- */
- private static final ImmutableList
- *
- * try (ConfigServiceV2Api configServiceV2Api = ConfigServiceV2Api.create()) {
- * String formattedSinkName = ConfigServiceV2Api.formatSinkName("[PROJECT]", "[SINK]");
- * LogSink response = configServiceV2Api.getSink(formattedSinkName);
- * }
- *
- *
- *
- * ===================
- * MetricsServiceV2Api
- * ===================
- *
- * Service Description: Service for configuring logs-based metrics.
- *
- * Sample for MetricsServiceV2Api:
- *
- *
- * try (MetricsServiceV2Api metricsServiceV2Api = MetricsServiceV2Api.create()) {
- * String formattedMetricName = MetricsServiceV2Api.formatMetricName("[PROJECT]", "[METRIC]");
- * LogMetric response = metricsServiceV2Api.getLogMetric(formattedMetricName);
- * }
- *
- *
- *
- * ===================
- * LoggingServiceV2Api
- * ===================
- *
- * Service Description: Service for ingesting and querying logs.
- *
- * Sample for LoggingServiceV2Api:
- *
- *
- * try (LoggingServiceV2Api loggingServiceV2Api = LoggingServiceV2Api.create()) {
- * String formattedLogName = LoggingServiceV2Api.formatLogName("[PROJECT]", "[LOG]");
- * loggingServiceV2Api.deleteLog(formattedLogName);
- * }
- *
- *
- *
- */
-package com.google.cloud.logging.spi.v2;
diff --git a/gcloud-java-pubsub/baseline/src/main/java/com/google/cloud/pubsub/spi/v1/PublisherApi.java b/gcloud-java-pubsub/baseline/src/main/java/com/google/cloud/pubsub/spi/v1/PublisherApi.java
deleted file mode 100644
index 199280657158..000000000000
--- a/gcloud-java-pubsub/baseline/src/main/java/com/google/cloud/pubsub/spi/v1/PublisherApi.java
+++ /dev/null
@@ -1,739 +0,0 @@
-/*
- * Copyright 2016 Google Inc. All Rights Reserved.
- *
- * 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.google.cloud.pubsub.spi.v1;
-
-import com.google.api.gax.core.PageAccessor;
-import com.google.api.gax.grpc.ApiCallable;
-import com.google.api.gax.protobuf.PathTemplate;
-import com.google.protobuf.ByteString;
-import com.google.protobuf.Empty;
-import com.google.pubsub.v1.DeleteTopicRequest;
-import com.google.pubsub.v1.GetTopicRequest;
-import com.google.pubsub.v1.ListTopicSubscriptionsRequest;
-import com.google.pubsub.v1.ListTopicSubscriptionsResponse;
-import com.google.pubsub.v1.ListTopicsRequest;
-import com.google.pubsub.v1.ListTopicsResponse;
-import com.google.pubsub.v1.PublishRequest;
-import com.google.pubsub.v1.PublishResponse;
-import com.google.pubsub.v1.PubsubMessage;
-import com.google.pubsub.v1.Topic;
-import io.grpc.ManagedChannel;
-import java.io.Closeable;
-import java.io.IOException;
-import java.util.ArrayList;
-import java.util.List;
-import java.util.concurrent.ScheduledExecutorService;
-
-// AUTO-GENERATED DOCUMENTATION AND SERVICE
-/**
- * Service Description: The service that an application uses to manipulate topics, and to send
- * messages to a topic.
- *
- * This class provides the ability to make remote calls to the backing service through method - * calls that map to API methods. Sample code to get started: - * - *
- *
- * try (PublisherApi publisherApi = PublisherApi.create()) {
- * String formattedName = PublisherApi.formatTopicName("[PROJECT]", "[TOPIC]");
- * Topic response = publisherApi.createTopic(formattedName);
- * }
- *
- *
- *
- * Note: close() needs to be called on the publisherApi object to clean up resources such - * as threads. In the example above, try-with-resources is used, which automatically calls - * close(). - * - *
The surface of this class includes several types of Java methods for each of the API's methods: - * - *
See the individual methods for example code. - * - *
Many parameters require resource names to be formatted in a particular way. To assist - * with these names, this class includes a format method for each type of name, and additionally - * a parse method to extract the individual identifiers contained within names that are - * returned. - * - *
This class can be customized by passing in a custom instance of PublisherSettings to - * create(). For example: - * - *
- *
- * PublisherSettings publisherSettings = PublisherSettings.defaultBuilder()
- * .provideChannelWith(myCredentials)
- * .build();
- * PublisherApi publisherApi = PublisherApi.create(publisherSettings);
- *
- *
- */
-@javax.annotation.Generated("by GAPIC")
-public class PublisherApi implements AutoCloseable {
- private final PublisherSettings settings;
- private final ManagedChannel channel;
- private final ScheduledExecutorService executor;
- private final List
- * try (PublisherApi publisherApi = PublisherApi.create()) {
- * String formattedName = PublisherApi.formatTopicName("[PROJECT]", "[TOPIC]");
- * Topic response = publisherApi.createTopic(formattedName);
- * }
- *
- * try (PublisherApi publisherApi = PublisherApi.create()) {
- * String formattedName = PublisherApi.formatTopicName("[PROJECT]", "[TOPIC]");
- * Topic request = Topic.newBuilder()
- * .setName(formattedName)
- * .build();
- * Topic response = publisherApi.createTopic(request);
- * }
- *
- * try (PublisherApi publisherApi = PublisherApi.create()) {
- * String formattedName = PublisherApi.formatTopicName("[PROJECT]", "[TOPIC]");
- * Topic request = Topic.newBuilder()
- * .setName(formattedName)
- * .build();
- * ListenableFuture<Topic> future = publisherApi.createTopicCallable().futureCall(request);
- * // Do something
- * Topic response = future.get();
- * }
- *
- * try (PublisherApi publisherApi = PublisherApi.create()) {
- * String formattedTopic = PublisherApi.formatTopicName("[PROJECT]", "[TOPIC]");
- * ByteString data = ByteString.copyFromUtf8("");
- * PubsubMessage messagesElement = PubsubMessage.newBuilder()
- * .setData(data)
- * .build();
- * List<PubsubMessage> messages = Arrays.asList(messagesElement);
- * PublishResponse response = publisherApi.publish(formattedTopic, messages);
- * }
- *
- * try (PublisherApi publisherApi = PublisherApi.create()) {
- * String formattedTopic = PublisherApi.formatTopicName("[PROJECT]", "[TOPIC]");
- * ByteString data = ByteString.copyFromUtf8("");
- * PubsubMessage messagesElement = PubsubMessage.newBuilder()
- * .setData(data)
- * .build();
- * List<PubsubMessage> messages = Arrays.asList(messagesElement);
- * PublishRequest request = PublishRequest.newBuilder()
- * .setTopic(formattedTopic)
- * .addAllMessages(messages)
- * .build();
- * PublishResponse response = publisherApi.publish(request);
- * }
- *
- * try (PublisherApi publisherApi = PublisherApi.create()) {
- * String formattedTopic = PublisherApi.formatTopicName("[PROJECT]", "[TOPIC]");
- * ByteString data = ByteString.copyFromUtf8("");
- * PubsubMessage messagesElement = PubsubMessage.newBuilder()
- * .setData(data)
- * .build();
- * List<PubsubMessage> messages = Arrays.asList(messagesElement);
- * PublishRequest request = PublishRequest.newBuilder()
- * .setTopic(formattedTopic)
- * .addAllMessages(messages)
- * .build();
- * ListenableFuture<PublishResponse> future = publisherApi.publishCallable().futureCall(request);
- * // Do something
- * PublishResponse response = future.get();
- * }
- *
- * try (PublisherApi publisherApi = PublisherApi.create()) {
- * String formattedTopic = PublisherApi.formatTopicName("[PROJECT]", "[TOPIC]");
- * Topic response = publisherApi.getTopic(formattedTopic);
- * }
- *
- * try (PublisherApi publisherApi = PublisherApi.create()) {
- * String formattedTopic = PublisherApi.formatTopicName("[PROJECT]", "[TOPIC]");
- * GetTopicRequest request = GetTopicRequest.newBuilder()
- * .setTopic(formattedTopic)
- * .build();
- * Topic response = publisherApi.getTopic(request);
- * }
- *
- * try (PublisherApi publisherApi = PublisherApi.create()) {
- * String formattedTopic = PublisherApi.formatTopicName("[PROJECT]", "[TOPIC]");
- * GetTopicRequest request = GetTopicRequest.newBuilder()
- * .setTopic(formattedTopic)
- * .build();
- * ListenableFuture<Topic> future = publisherApi.getTopicCallable().futureCall(request);
- * // Do something
- * Topic response = future.get();
- * }
- *
- * try (PublisherApi publisherApi = PublisherApi.create()) {
- * String formattedProject = PublisherApi.formatProjectName("[PROJECT]");
- * for (Topic element : publisherApi.listTopics(formattedProject)) {
- * // doThingsWith(element);
- * }
- * }
- *
- * try (PublisherApi publisherApi = PublisherApi.create()) {
- * String formattedProject = PublisherApi.formatProjectName("[PROJECT]");
- * ListTopicsRequest request = ListTopicsRequest.newBuilder()
- * .setProject(formattedProject)
- * .build();
- * for (Topic element : publisherApi.listTopics(request)) {
- * // doThingsWith(element);
- * }
- * }
- *
- * try (PublisherApi publisherApi = PublisherApi.create()) {
- * String formattedProject = PublisherApi.formatProjectName("[PROJECT]");
- * ListTopicsRequest request = ListTopicsRequest.newBuilder()
- * .setProject(formattedProject)
- * .build();
- * ListenableFuture<PageAccessor<Topic>> future = publisherApi.listTopicsPagedCallable().futureCall(request);
- * // Do something
- * for (Topic element : future.get()) {
- * // doThingsWith(element);
- * }
- * }
- *
- * try (PublisherApi publisherApi = PublisherApi.create()) {
- * String formattedProject = PublisherApi.formatProjectName("[PROJECT]");
- * ListTopicsRequest request = ListTopicsRequest.newBuilder()
- * .setProject(formattedProject)
- * .build();
- * while (true) {
- * ListTopicsResponse response = publisherApi.listTopicsCallable().call(request);
- * for (Topic element : response.getTopicsList()) {
- * // doThingsWith(element);
- * }
- * String nextPageToken = response.getNextPageToken();
- * if (!Strings.isNullOrEmpty(nextPageToken)) {
- * request = request.toBuilder().setPageToken(nextPageToken).build();
- * } else {
- * break;
- * }
- * }
- * }
- *
- * try (PublisherApi publisherApi = PublisherApi.create()) {
- * String formattedTopic = PublisherApi.formatTopicName("[PROJECT]", "[TOPIC]");
- * for (String element : publisherApi.listTopicSubscriptions(formattedTopic)) {
- * // doThingsWith(element);
- * }
- * }
- *
- * try (PublisherApi publisherApi = PublisherApi.create()) {
- * String formattedTopic = PublisherApi.formatTopicName("[PROJECT]", "[TOPIC]");
- * ListTopicSubscriptionsRequest request = ListTopicSubscriptionsRequest.newBuilder()
- * .setTopic(formattedTopic)
- * .build();
- * for (String element : publisherApi.listTopicSubscriptions(request)) {
- * // doThingsWith(element);
- * }
- * }
- *
- * try (PublisherApi publisherApi = PublisherApi.create()) {
- * String formattedTopic = PublisherApi.formatTopicName("[PROJECT]", "[TOPIC]");
- * ListTopicSubscriptionsRequest request = ListTopicSubscriptionsRequest.newBuilder()
- * .setTopic(formattedTopic)
- * .build();
- * ListenableFuture<PageAccessor<String>> future = publisherApi.listTopicSubscriptionsPagedCallable().futureCall(request);
- * // Do something
- * for (String element : future.get()) {
- * // doThingsWith(element);
- * }
- * }
- *
- * try (PublisherApi publisherApi = PublisherApi.create()) {
- * String formattedTopic = PublisherApi.formatTopicName("[PROJECT]", "[TOPIC]");
- * ListTopicSubscriptionsRequest request = ListTopicSubscriptionsRequest.newBuilder()
- * .setTopic(formattedTopic)
- * .build();
- * while (true) {
- * ListTopicSubscriptionsResponse response = publisherApi.listTopicSubscriptionsCallable().call(request);
- * for (String element : response.getSubscriptionsList()) {
- * // doThingsWith(element);
- * }
- * String nextPageToken = response.getNextPageToken();
- * if (!Strings.isNullOrEmpty(nextPageToken)) {
- * request = request.toBuilder().setPageToken(nextPageToken).build();
- * } else {
- * break;
- * }
- * }
- * }
- *
- * try (PublisherApi publisherApi = PublisherApi.create()) {
- * String formattedTopic = PublisherApi.formatTopicName("[PROJECT]", "[TOPIC]");
- * publisherApi.deleteTopic(formattedTopic);
- * }
- *
- * try (PublisherApi publisherApi = PublisherApi.create()) {
- * String formattedTopic = PublisherApi.formatTopicName("[PROJECT]", "[TOPIC]");
- * DeleteTopicRequest request = DeleteTopicRequest.newBuilder()
- * .setTopic(formattedTopic)
- * .build();
- * publisherApi.deleteTopic(request);
- * }
- *
- * try (PublisherApi publisherApi = PublisherApi.create()) {
- * String formattedTopic = PublisherApi.formatTopicName("[PROJECT]", "[TOPIC]");
- * DeleteTopicRequest request = DeleteTopicRequest.newBuilder()
- * .setTopic(formattedTopic)
- * .build();
- * ListenableFuture<Void> future = publisherApi.deleteTopicCallable().futureCall(request);
- * // Do something
- * future.get();
- * }
- * The default instance has everything set to sensible defaults: - * - *
The builder of this class is recursive, so contained classes are themselves builders. - * When build() is called, the tree of builders is called to create the complete settings - * object. For example, to set the total timeout of createTopic to 30 seconds: - * - *
- *
- * PublisherSettings.Builder publisherSettingsBuilder =
- * PublisherSettings.defaultBuilder();
- * publisherSettingsBuilder.createTopicSettings().getRetrySettingsBuilder()
- * .setTotalTimeout(Duration.standardSeconds(30));
- * PublisherSettings publisherSettings = publisherSettingsBuilder.build();
- *
- *
- */
-@javax.annotation.Generated("by GAPIC")
-public class PublisherSettings extends ServiceApiSettings {
- /**
- * The default address of the service.
- */
- private static final String DEFAULT_SERVICE_ADDRESS = "pubsub.googleapis.com";
-
- /**
- * The default port of the service.
- */
- private static final int DEFAULT_SERVICE_PORT = 443;
-
- /**
- * The default scopes of the service.
- */
- private static final ImmutableListThis class provides the ability to make remote calls to the backing service through method - * calls that map to API methods. Sample code to get started: - * - *
- *
- * try (SubscriberApi subscriberApi = SubscriberApi.create()) {
- * String formattedName = SubscriberApi.formatSubscriptionName("[PROJECT]", "[SUBSCRIPTION]");
- * String formattedTopic = SubscriberApi.formatTopicName("[PROJECT]", "[TOPIC]");
- * PushConfig pushConfig = PushConfig.newBuilder().build();
- * int ackDeadlineSeconds = 0;
- * Subscription response = subscriberApi.createSubscription(formattedName, formattedTopic, pushConfig, ackDeadlineSeconds);
- * }
- *
- *
- *
- * Note: close() needs to be called on the subscriberApi object to clean up resources such - * as threads. In the example above, try-with-resources is used, which automatically calls - * close(). - * - *
The surface of this class includes several types of Java methods for each of the API's methods: - * - *
See the individual methods for example code. - * - *
Many parameters require resource names to be formatted in a particular way. To assist - * with these names, this class includes a format method for each type of name, and additionally - * a parse method to extract the individual identifiers contained within names that are - * returned. - * - *
This class can be customized by passing in a custom instance of SubscriberSettings to - * create(). For example: - * - *
- *
- * SubscriberSettings subscriberSettings = SubscriberSettings.defaultBuilder()
- * .provideChannelWith(myCredentials)
- * .build();
- * SubscriberApi subscriberApi = SubscriberApi.create(subscriberSettings);
- *
- *
- */
-@javax.annotation.Generated("by GAPIC")
-public class SubscriberApi implements AutoCloseable {
- private final SubscriberSettings settings;
- private final ManagedChannel channel;
- private final ScheduledExecutorService executor;
- private final List
- * try (SubscriberApi subscriberApi = SubscriberApi.create()) {
- * String formattedName = SubscriberApi.formatSubscriptionName("[PROJECT]", "[SUBSCRIPTION]");
- * String formattedTopic = SubscriberApi.formatTopicName("[PROJECT]", "[TOPIC]");
- * PushConfig pushConfig = PushConfig.newBuilder().build();
- * int ackDeadlineSeconds = 0;
- * Subscription response = subscriberApi.createSubscription(formattedName, formattedTopic, pushConfig, ackDeadlineSeconds);
- * }
- *
- * try (SubscriberApi subscriberApi = SubscriberApi.create()) {
- * String formattedName = SubscriberApi.formatSubscriptionName("[PROJECT]", "[SUBSCRIPTION]");
- * String formattedTopic = SubscriberApi.formatTopicName("[PROJECT]", "[TOPIC]");
- * Subscription request = Subscription.newBuilder()
- * .setName(formattedName)
- * .setTopic(formattedTopic)
- * .build();
- * Subscription response = subscriberApi.createSubscription(request);
- * }
- *
- * try (SubscriberApi subscriberApi = SubscriberApi.create()) {
- * String formattedName = SubscriberApi.formatSubscriptionName("[PROJECT]", "[SUBSCRIPTION]");
- * String formattedTopic = SubscriberApi.formatTopicName("[PROJECT]", "[TOPIC]");
- * Subscription request = Subscription.newBuilder()
- * .setName(formattedName)
- * .setTopic(formattedTopic)
- * .build();
- * ListenableFuture<Subscription> future = subscriberApi.createSubscriptionCallable().futureCall(request);
- * // Do something
- * Subscription response = future.get();
- * }
- *
- * try (SubscriberApi subscriberApi = SubscriberApi.create()) {
- * String formattedSubscription = SubscriberApi.formatSubscriptionName("[PROJECT]", "[SUBSCRIPTION]");
- * Subscription response = subscriberApi.getSubscription(formattedSubscription);
- * }
- *
- * try (SubscriberApi subscriberApi = SubscriberApi.create()) {
- * String formattedSubscription = SubscriberApi.formatSubscriptionName("[PROJECT]", "[SUBSCRIPTION]");
- * GetSubscriptionRequest request = GetSubscriptionRequest.newBuilder()
- * .setSubscription(formattedSubscription)
- * .build();
- * Subscription response = subscriberApi.getSubscription(request);
- * }
- *
- * try (SubscriberApi subscriberApi = SubscriberApi.create()) {
- * String formattedSubscription = SubscriberApi.formatSubscriptionName("[PROJECT]", "[SUBSCRIPTION]");
- * GetSubscriptionRequest request = GetSubscriptionRequest.newBuilder()
- * .setSubscription(formattedSubscription)
- * .build();
- * ListenableFuture<Subscription> future = subscriberApi.getSubscriptionCallable().futureCall(request);
- * // Do something
- * Subscription response = future.get();
- * }
- *
- * try (SubscriberApi subscriberApi = SubscriberApi.create()) {
- * String formattedProject = SubscriberApi.formatProjectName("[PROJECT]");
- * for (Subscription element : subscriberApi.listSubscriptions(formattedProject)) {
- * // doThingsWith(element);
- * }
- * }
- *
- * try (SubscriberApi subscriberApi = SubscriberApi.create()) {
- * String formattedProject = SubscriberApi.formatProjectName("[PROJECT]");
- * ListSubscriptionsRequest request = ListSubscriptionsRequest.newBuilder()
- * .setProject(formattedProject)
- * .build();
- * for (Subscription element : subscriberApi.listSubscriptions(request)) {
- * // doThingsWith(element);
- * }
- * }
- *
- * try (SubscriberApi subscriberApi = SubscriberApi.create()) {
- * String formattedProject = SubscriberApi.formatProjectName("[PROJECT]");
- * ListSubscriptionsRequest request = ListSubscriptionsRequest.newBuilder()
- * .setProject(formattedProject)
- * .build();
- * ListenableFuture<PageAccessor<Subscription>> future = subscriberApi.listSubscriptionsPagedCallable().futureCall(request);
- * // Do something
- * for (Subscription element : future.get()) {
- * // doThingsWith(element);
- * }
- * }
- *
- * try (SubscriberApi subscriberApi = SubscriberApi.create()) {
- * String formattedProject = SubscriberApi.formatProjectName("[PROJECT]");
- * ListSubscriptionsRequest request = ListSubscriptionsRequest.newBuilder()
- * .setProject(formattedProject)
- * .build();
- * while (true) {
- * ListSubscriptionsResponse response = subscriberApi.listSubscriptionsCallable().call(request);
- * for (Subscription element : response.getSubscriptionsList()) {
- * // doThingsWith(element);
- * }
- * String nextPageToken = response.getNextPageToken();
- * if (!Strings.isNullOrEmpty(nextPageToken)) {
- * request = request.toBuilder().setPageToken(nextPageToken).build();
- * } else {
- * break;
- * }
- * }
- * }
- *
- * try (SubscriberApi subscriberApi = SubscriberApi.create()) {
- * String formattedSubscription = SubscriberApi.formatSubscriptionName("[PROJECT]", "[SUBSCRIPTION]");
- * subscriberApi.deleteSubscription(formattedSubscription);
- * }
- *
- * try (SubscriberApi subscriberApi = SubscriberApi.create()) {
- * String formattedSubscription = SubscriberApi.formatSubscriptionName("[PROJECT]", "[SUBSCRIPTION]");
- * DeleteSubscriptionRequest request = DeleteSubscriptionRequest.newBuilder()
- * .setSubscription(formattedSubscription)
- * .build();
- * subscriberApi.deleteSubscription(request);
- * }
- *
- * try (SubscriberApi subscriberApi = SubscriberApi.create()) {
- * String formattedSubscription = SubscriberApi.formatSubscriptionName("[PROJECT]", "[SUBSCRIPTION]");
- * DeleteSubscriptionRequest request = DeleteSubscriptionRequest.newBuilder()
- * .setSubscription(formattedSubscription)
- * .build();
- * ListenableFuture<Void> future = subscriberApi.deleteSubscriptionCallable().futureCall(request);
- * // Do something
- * future.get();
- * }
- *
- * try (SubscriberApi subscriberApi = SubscriberApi.create()) {
- * String formattedSubscription = SubscriberApi.formatSubscriptionName("[PROJECT]", "[SUBSCRIPTION]");
- * List<String> ackIds = new ArrayList<>();
- * int ackDeadlineSeconds = 0;
- * subscriberApi.modifyAckDeadline(formattedSubscription, ackIds, ackDeadlineSeconds);
- * }
- *
- * try (SubscriberApi subscriberApi = SubscriberApi.create()) {
- * String formattedSubscription = SubscriberApi.formatSubscriptionName("[PROJECT]", "[SUBSCRIPTION]");
- * List<String> ackIds = new ArrayList<>();
- * int ackDeadlineSeconds = 0;
- * ModifyAckDeadlineRequest request = ModifyAckDeadlineRequest.newBuilder()
- * .setSubscription(formattedSubscription)
- * .addAllAckIds(ackIds)
- * .setAckDeadlineSeconds(ackDeadlineSeconds)
- * .build();
- * subscriberApi.modifyAckDeadline(request);
- * }
- *
- * try (SubscriberApi subscriberApi = SubscriberApi.create()) {
- * String formattedSubscription = SubscriberApi.formatSubscriptionName("[PROJECT]", "[SUBSCRIPTION]");
- * List<String> ackIds = new ArrayList<>();
- * int ackDeadlineSeconds = 0;
- * ModifyAckDeadlineRequest request = ModifyAckDeadlineRequest.newBuilder()
- * .setSubscription(formattedSubscription)
- * .addAllAckIds(ackIds)
- * .setAckDeadlineSeconds(ackDeadlineSeconds)
- * .build();
- * ListenableFuture<Void> future = subscriberApi.modifyAckDeadlineCallable().futureCall(request);
- * // Do something
- * future.get();
- * }
- *
- * try (SubscriberApi subscriberApi = SubscriberApi.create()) {
- * String formattedSubscription = SubscriberApi.formatSubscriptionName("[PROJECT]", "[SUBSCRIPTION]");
- * List<String> ackIds = new ArrayList<>();
- * subscriberApi.acknowledge(formattedSubscription, ackIds);
- * }
- *
- * try (SubscriberApi subscriberApi = SubscriberApi.create()) {
- * String formattedSubscription = SubscriberApi.formatSubscriptionName("[PROJECT]", "[SUBSCRIPTION]");
- * List<String> ackIds = new ArrayList<>();
- * AcknowledgeRequest request = AcknowledgeRequest.newBuilder()
- * .setSubscription(formattedSubscription)
- * .addAllAckIds(ackIds)
- * .build();
- * subscriberApi.acknowledge(request);
- * }
- *
- * try (SubscriberApi subscriberApi = SubscriberApi.create()) {
- * String formattedSubscription = SubscriberApi.formatSubscriptionName("[PROJECT]", "[SUBSCRIPTION]");
- * List<String> ackIds = new ArrayList<>();
- * AcknowledgeRequest request = AcknowledgeRequest.newBuilder()
- * .setSubscription(formattedSubscription)
- * .addAllAckIds(ackIds)
- * .build();
- * ListenableFuture<Void> future = subscriberApi.acknowledgeCallable().futureCall(request);
- * // Do something
- * future.get();
- * }
- *
- * try (SubscriberApi subscriberApi = SubscriberApi.create()) {
- * String formattedSubscription = SubscriberApi.formatSubscriptionName("[PROJECT]", "[SUBSCRIPTION]");
- * boolean returnImmediately = false;
- * int maxMessages = 0;
- * PullResponse response = subscriberApi.pull(formattedSubscription, returnImmediately, maxMessages);
- * }
- *
- * try (SubscriberApi subscriberApi = SubscriberApi.create()) {
- * String formattedSubscription = SubscriberApi.formatSubscriptionName("[PROJECT]", "[SUBSCRIPTION]");
- * int maxMessages = 0;
- * PullRequest request = PullRequest.newBuilder()
- * .setSubscription(formattedSubscription)
- * .setMaxMessages(maxMessages)
- * .build();
- * PullResponse response = subscriberApi.pull(request);
- * }
- *
- * try (SubscriberApi subscriberApi = SubscriberApi.create()) {
- * String formattedSubscription = SubscriberApi.formatSubscriptionName("[PROJECT]", "[SUBSCRIPTION]");
- * int maxMessages = 0;
- * PullRequest request = PullRequest.newBuilder()
- * .setSubscription(formattedSubscription)
- * .setMaxMessages(maxMessages)
- * .build();
- * ListenableFuture<PullResponse> future = subscriberApi.pullCallable().futureCall(request);
- * // Do something
- * PullResponse response = future.get();
- * }
- *
- * try (SubscriberApi subscriberApi = SubscriberApi.create()) {
- * String formattedSubscription = SubscriberApi.formatSubscriptionName("[PROJECT]", "[SUBSCRIPTION]");
- * PushConfig pushConfig = PushConfig.newBuilder().build();
- * subscriberApi.modifyPushConfig(formattedSubscription, pushConfig);
- * }
- *
- * try (SubscriberApi subscriberApi = SubscriberApi.create()) {
- * String formattedSubscription = SubscriberApi.formatSubscriptionName("[PROJECT]", "[SUBSCRIPTION]");
- * PushConfig pushConfig = PushConfig.newBuilder().build();
- * ModifyPushConfigRequest request = ModifyPushConfigRequest.newBuilder()
- * .setSubscription(formattedSubscription)
- * .setPushConfig(pushConfig)
- * .build();
- * subscriberApi.modifyPushConfig(request);
- * }
- *
- * try (SubscriberApi subscriberApi = SubscriberApi.create()) {
- * String formattedSubscription = SubscriberApi.formatSubscriptionName("[PROJECT]", "[SUBSCRIPTION]");
- * PushConfig pushConfig = PushConfig.newBuilder().build();
- * ModifyPushConfigRequest request = ModifyPushConfigRequest.newBuilder()
- * .setSubscription(formattedSubscription)
- * .setPushConfig(pushConfig)
- * .build();
- * ListenableFuture<Void> future = subscriberApi.modifyPushConfigCallable().futureCall(request);
- * // Do something
- * future.get();
- * }
- * The default instance has everything set to sensible defaults: - * - *
The builder of this class is recursive, so contained classes are themselves builders. - * When build() is called, the tree of builders is called to create the complete settings - * object. For example, to set the total timeout of createSubscription to 30 seconds: - * - *
- *
- * SubscriberSettings.Builder subscriberSettingsBuilder =
- * SubscriberSettings.defaultBuilder();
- * subscriberSettingsBuilder.createSubscriptionSettings().getRetrySettingsBuilder()
- * .setTotalTimeout(Duration.standardSeconds(30));
- * SubscriberSettings subscriberSettings = subscriberSettingsBuilder.build();
- *
- *
- */
-@javax.annotation.Generated("by GAPIC")
-public class SubscriberSettings extends ServiceApiSettings {
- /**
- * The default address of the service.
- */
- private static final String DEFAULT_SERVICE_ADDRESS = "pubsub.googleapis.com";
-
- /**
- * The default port of the service.
- */
- private static final int DEFAULT_SERVICE_PORT = 443;
-
- /**
- * The default scopes of the service.
- */
- private static final ImmutableList