Skip to content

Commit 17a5c8d

Browse files
gcf-owl-bot[bot]gcf-owl-bot[bot]
authored
feat: [analyticshub] add Subscription resource and RPCs (#9883)
* feat: add Subscription resource and RPCs feat: add support for sharing_environment_config using which you can create data clean rooms. feat: support restricted egress on Listings. PiperOrigin-RevId: 568259024 Source-Link: googleapis/googleapis@26392c8 Source-Link: https://github.com/googleapis/googleapis-gen/commit/dbdc394dcaa675170a1b0cf3858f56c95e17b3aa Copy-Tag: eyJwIjoiamF2YS1hbmFseXRpY3NodWIvLk93bEJvdC55YW1sIiwiaCI6ImRiZGMzOTRkY2FhNjc1MTcwYTFiMGNmMzg1OGY1NmM5NWUxN2IzYWEifQ== * 🦉 Updates from OwlBot post-processor See https://github.com/googleapis/repo-automation-bots/blob/main/packages/owl-bot/README.md --------- Co-authored-by: Owl Bot <gcf-owl-bot[bot]@users.noreply.github.com>
1 parent 255469c commit 17a5c8d

File tree

90 files changed

+30981
-670
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

90 files changed

+30981
-670
lines changed

‎java-analyticshub/google-cloud-analyticshub/src/main/java/com/google/cloud/bigquery/analyticshub/v1/AnalyticsHubServiceClient.java

Lines changed: 1352 additions & 94 deletions
Large diffs are not rendered by default.

‎java-analyticshub/google-cloud-analyticshub/src/main/java/com/google/cloud/bigquery/analyticshub/v1/AnalyticsHubServiceSettings.java

Lines changed: 137 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -19,6 +19,8 @@
1919
import static com.google.cloud.bigquery.analyticshub.v1.AnalyticsHubServiceClient.ListDataExchangesPagedResponse;
2020
import static com.google.cloud.bigquery.analyticshub.v1.AnalyticsHubServiceClient.ListListingsPagedResponse;
2121
import static com.google.cloud.bigquery.analyticshub.v1.AnalyticsHubServiceClient.ListOrgDataExchangesPagedResponse;
22+
import static com.google.cloud.bigquery.analyticshub.v1.AnalyticsHubServiceClient.ListSharedResourceSubscriptionsPagedResponse;
23+
import static com.google.cloud.bigquery.analyticshub.v1.AnalyticsHubServiceClient.ListSubscriptionsPagedResponse;
2224

2325
import com.google.api.core.ApiFunction;
2426
import com.google.api.core.BetaApi;
@@ -29,6 +31,7 @@
2931
import com.google.api.gax.rpc.ApiClientHeaderProvider;
3032
import com.google.api.gax.rpc.ClientContext;
3133
import com.google.api.gax.rpc.ClientSettings;
34+
import com.google.api.gax.rpc.OperationCallSettings;
3235
import com.google.api.gax.rpc.PagedCallSettings;
3336
import com.google.api.gax.rpc.TransportChannelProvider;
3437
import com.google.api.gax.rpc.UnaryCallSettings;
@@ -38,6 +41,7 @@
3841
import com.google.iam.v1.SetIamPolicyRequest;
3942
import com.google.iam.v1.TestIamPermissionsRequest;
4043
import com.google.iam.v1.TestIamPermissionsResponse;
44+
import com.google.longrunning.Operation;
4145
import com.google.protobuf.Empty;
4246
import java.io.IOException;
4347
import java.util.List;
@@ -152,6 +156,73 @@ public UnaryCallSettings<DeleteListingRequest, Empty> deleteListingSettings() {
152156
return ((AnalyticsHubServiceStubSettings) getStubSettings()).subscribeListingSettings();
153157
}
154158

159+
/** Returns the object with the settings used for calls to subscribeDataExchange. */
160+
public UnaryCallSettings<SubscribeDataExchangeRequest, Operation>
161+
subscribeDataExchangeSettings() {
162+
return ((AnalyticsHubServiceStubSettings) getStubSettings()).subscribeDataExchangeSettings();
163+
}
164+
165+
/** Returns the object with the settings used for calls to subscribeDataExchange. */
166+
public OperationCallSettings<
167+
SubscribeDataExchangeRequest, SubscribeDataExchangeResponse, OperationMetadata>
168+
subscribeDataExchangeOperationSettings() {
169+
return ((AnalyticsHubServiceStubSettings) getStubSettings())
170+
.subscribeDataExchangeOperationSettings();
171+
}
172+
173+
/** Returns the object with the settings used for calls to refreshSubscription. */
174+
public UnaryCallSettings<RefreshSubscriptionRequest, Operation> refreshSubscriptionSettings() {
175+
return ((AnalyticsHubServiceStubSettings) getStubSettings()).refreshSubscriptionSettings();
176+
}
177+
178+
/** Returns the object with the settings used for calls to refreshSubscription. */
179+
public OperationCallSettings<
180+
RefreshSubscriptionRequest, RefreshSubscriptionResponse, OperationMetadata>
181+
refreshSubscriptionOperationSettings() {
182+
return ((AnalyticsHubServiceStubSettings) getStubSettings())
183+
.refreshSubscriptionOperationSettings();
184+
}
185+
186+
/** Returns the object with the settings used for calls to getSubscription. */
187+
public UnaryCallSettings<GetSubscriptionRequest, Subscription> getSubscriptionSettings() {
188+
return ((AnalyticsHubServiceStubSettings) getStubSettings()).getSubscriptionSettings();
189+
}
190+
191+
/** Returns the object with the settings used for calls to listSubscriptions. */
192+
public PagedCallSettings<
193+
ListSubscriptionsRequest, ListSubscriptionsResponse, ListSubscriptionsPagedResponse>
194+
listSubscriptionsSettings() {
195+
return ((AnalyticsHubServiceStubSettings) getStubSettings()).listSubscriptionsSettings();
196+
}
197+
198+
/** Returns the object with the settings used for calls to listSharedResourceSubscriptions. */
199+
public PagedCallSettings<
200+
ListSharedResourceSubscriptionsRequest,
201+
ListSharedResourceSubscriptionsResponse,
202+
ListSharedResourceSubscriptionsPagedResponse>
203+
listSharedResourceSubscriptionsSettings() {
204+
return ((AnalyticsHubServiceStubSettings) getStubSettings())
205+
.listSharedResourceSubscriptionsSettings();
206+
}
207+
208+
/** Returns the object with the settings used for calls to revokeSubscription. */
209+
public UnaryCallSettings<RevokeSubscriptionRequest, RevokeSubscriptionResponse>
210+
revokeSubscriptionSettings() {
211+
return ((AnalyticsHubServiceStubSettings) getStubSettings()).revokeSubscriptionSettings();
212+
}
213+
214+
/** Returns the object with the settings used for calls to deleteSubscription. */
215+
public UnaryCallSettings<DeleteSubscriptionRequest, Operation> deleteSubscriptionSettings() {
216+
return ((AnalyticsHubServiceStubSettings) getStubSettings()).deleteSubscriptionSettings();
217+
}
218+
219+
/** Returns the object with the settings used for calls to deleteSubscription. */
220+
public OperationCallSettings<DeleteSubscriptionRequest, Empty, OperationMetadata>
221+
deleteSubscriptionOperationSettings() {
222+
return ((AnalyticsHubServiceStubSettings) getStubSettings())
223+
.deleteSubscriptionOperationSettings();
224+
}
225+
155226
/** Returns the object with the settings used for calls to getIamPolicy. */
156227
public UnaryCallSettings<GetIamPolicyRequest, Policy> getIamPolicySettings() {
157228
return ((AnalyticsHubServiceStubSettings) getStubSettings()).getIamPolicySettings();
@@ -356,6 +427,72 @@ public UnaryCallSettings.Builder<DeleteListingRequest, Empty> deleteListingSetti
356427
return getStubSettingsBuilder().subscribeListingSettings();
357428
}
358429

430+
/** Returns the builder for the settings used for calls to subscribeDataExchange. */
431+
public UnaryCallSettings.Builder<SubscribeDataExchangeRequest, Operation>
432+
subscribeDataExchangeSettings() {
433+
return getStubSettingsBuilder().subscribeDataExchangeSettings();
434+
}
435+
436+
/** Returns the builder for the settings used for calls to subscribeDataExchange. */
437+
public OperationCallSettings.Builder<
438+
SubscribeDataExchangeRequest, SubscribeDataExchangeResponse, OperationMetadata>
439+
subscribeDataExchangeOperationSettings() {
440+
return getStubSettingsBuilder().subscribeDataExchangeOperationSettings();
441+
}
442+
443+
/** Returns the builder for the settings used for calls to refreshSubscription. */
444+
public UnaryCallSettings.Builder<RefreshSubscriptionRequest, Operation>
445+
refreshSubscriptionSettings() {
446+
return getStubSettingsBuilder().refreshSubscriptionSettings();
447+
}
448+
449+
/** Returns the builder for the settings used for calls to refreshSubscription. */
450+
public OperationCallSettings.Builder<
451+
RefreshSubscriptionRequest, RefreshSubscriptionResponse, OperationMetadata>
452+
refreshSubscriptionOperationSettings() {
453+
return getStubSettingsBuilder().refreshSubscriptionOperationSettings();
454+
}
455+
456+
/** Returns the builder for the settings used for calls to getSubscription. */
457+
public UnaryCallSettings.Builder<GetSubscriptionRequest, Subscription>
458+
getSubscriptionSettings() {
459+
return getStubSettingsBuilder().getSubscriptionSettings();
460+
}
461+
462+
/** Returns the builder for the settings used for calls to listSubscriptions. */
463+
public PagedCallSettings.Builder<
464+
ListSubscriptionsRequest, ListSubscriptionsResponse, ListSubscriptionsPagedResponse>
465+
listSubscriptionsSettings() {
466+
return getStubSettingsBuilder().listSubscriptionsSettings();
467+
}
468+
469+
/** Returns the builder for the settings used for calls to listSharedResourceSubscriptions. */
470+
public PagedCallSettings.Builder<
471+
ListSharedResourceSubscriptionsRequest,
472+
ListSharedResourceSubscriptionsResponse,
473+
ListSharedResourceSubscriptionsPagedResponse>
474+
listSharedResourceSubscriptionsSettings() {
475+
return getStubSettingsBuilder().listSharedResourceSubscriptionsSettings();
476+
}
477+
478+
/** Returns the builder for the settings used for calls to revokeSubscription. */
479+
public UnaryCallSettings.Builder<RevokeSubscriptionRequest, RevokeSubscriptionResponse>
480+
revokeSubscriptionSettings() {
481+
return getStubSettingsBuilder().revokeSubscriptionSettings();
482+
}
483+
484+
/** Returns the builder for the settings used for calls to deleteSubscription. */
485+
public UnaryCallSettings.Builder<DeleteSubscriptionRequest, Operation>
486+
deleteSubscriptionSettings() {
487+
return getStubSettingsBuilder().deleteSubscriptionSettings();
488+
}
489+
490+
/** Returns the builder for the settings used for calls to deleteSubscription. */
491+
public OperationCallSettings.Builder<DeleteSubscriptionRequest, Empty, OperationMetadata>
492+
deleteSubscriptionOperationSettings() {
493+
return getStubSettingsBuilder().deleteSubscriptionOperationSettings();
494+
}
495+
359496
/** Returns the builder for the settings used for calls to getIamPolicy. */
360497
public UnaryCallSettings.Builder<GetIamPolicyRequest, Policy> getIamPolicySettings() {
361498
return getStubSettingsBuilder().getIamPolicySettings();

‎java-analyticshub/google-cloud-analyticshub/src/main/java/com/google/cloud/bigquery/analyticshub/v1/gapic_metadata.json

Lines changed: 21 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -22,6 +22,9 @@
2222
"DeleteListing": {
2323
"methods": ["deleteListing", "deleteListing", "deleteListing", "deleteListingCallable"]
2424
},
25+
"DeleteSubscription": {
26+
"methods": ["deleteSubscriptionAsync", "deleteSubscriptionAsync", "deleteSubscriptionAsync", "deleteSubscriptionOperationCallable", "deleteSubscriptionCallable"]
27+
},
2528
"GetDataExchange": {
2629
"methods": ["getDataExchange", "getDataExchange", "getDataExchange", "getDataExchangeCallable"]
2730
},
@@ -31,6 +34,9 @@
3134
"GetListing": {
3235
"methods": ["getListing", "getListing", "getListing", "getListingCallable"]
3336
},
37+
"GetSubscription": {
38+
"methods": ["getSubscription", "getSubscription", "getSubscription", "getSubscriptionCallable"]
39+
},
3440
"ListDataExchanges": {
3541
"methods": ["listDataExchanges", "listDataExchanges", "listDataExchanges", "listDataExchangesPagedCallable", "listDataExchangesCallable"]
3642
},
@@ -40,9 +46,24 @@
4046
"ListOrgDataExchanges": {
4147
"methods": ["listOrgDataExchanges", "listOrgDataExchanges", "listOrgDataExchangesPagedCallable", "listOrgDataExchangesCallable"]
4248
},
49+
"ListSharedResourceSubscriptions": {
50+
"methods": ["listSharedResourceSubscriptions", "listSharedResourceSubscriptions", "listSharedResourceSubscriptions", "listSharedResourceSubscriptionsPagedCallable", "listSharedResourceSubscriptionsCallable"]
51+
},
52+
"ListSubscriptions": {
53+
"methods": ["listSubscriptions", "listSubscriptions", "listSubscriptions", "listSubscriptionsPagedCallable", "listSubscriptionsCallable"]
54+
},
55+
"RefreshSubscription": {
56+
"methods": ["refreshSubscriptionAsync", "refreshSubscriptionAsync", "refreshSubscriptionAsync", "refreshSubscriptionOperationCallable", "refreshSubscriptionCallable"]
57+
},
58+
"RevokeSubscription": {
59+
"methods": ["revokeSubscription", "revokeSubscription", "revokeSubscription", "revokeSubscriptionCallable"]
60+
},
4361
"SetIamPolicy": {
4462
"methods": ["setIamPolicy", "setIamPolicyCallable"]
4563
},
64+
"SubscribeDataExchange": {
65+
"methods": ["subscribeDataExchangeAsync", "subscribeDataExchangeAsync", "subscribeDataExchangeAsync", "subscribeDataExchangeOperationCallable", "subscribeDataExchangeCallable"]
66+
},
4667
"SubscribeListing": {
4768
"methods": ["subscribeListing", "subscribeListing", "subscribeListing", "subscribeListingCallable"]
4869
},

‎java-analyticshub/google-cloud-analyticshub/src/main/java/com/google/cloud/bigquery/analyticshub/v1/stub/AnalyticsHubServiceStub.java

Lines changed: 92 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -19,32 +19,51 @@
1919
import static com.google.cloud.bigquery.analyticshub.v1.AnalyticsHubServiceClient.ListDataExchangesPagedResponse;
2020
import static com.google.cloud.bigquery.analyticshub.v1.AnalyticsHubServiceClient.ListListingsPagedResponse;
2121
import static com.google.cloud.bigquery.analyticshub.v1.AnalyticsHubServiceClient.ListOrgDataExchangesPagedResponse;
22+
import static com.google.cloud.bigquery.analyticshub.v1.AnalyticsHubServiceClient.ListSharedResourceSubscriptionsPagedResponse;
23+
import static com.google.cloud.bigquery.analyticshub.v1.AnalyticsHubServiceClient.ListSubscriptionsPagedResponse;
2224

2325
import com.google.api.gax.core.BackgroundResource;
26+
import com.google.api.gax.rpc.OperationCallable;
2427
import com.google.api.gax.rpc.UnaryCallable;
2528
import com.google.cloud.bigquery.analyticshub.v1.CreateDataExchangeRequest;
2629
import com.google.cloud.bigquery.analyticshub.v1.CreateListingRequest;
2730
import com.google.cloud.bigquery.analyticshub.v1.DataExchange;
2831
import com.google.cloud.bigquery.analyticshub.v1.DeleteDataExchangeRequest;
2932
import com.google.cloud.bigquery.analyticshub.v1.DeleteListingRequest;
33+
import com.google.cloud.bigquery.analyticshub.v1.DeleteSubscriptionRequest;
3034
import com.google.cloud.bigquery.analyticshub.v1.GetDataExchangeRequest;
3135
import com.google.cloud.bigquery.analyticshub.v1.GetListingRequest;
36+
import com.google.cloud.bigquery.analyticshub.v1.GetSubscriptionRequest;
3237
import com.google.cloud.bigquery.analyticshub.v1.ListDataExchangesRequest;
3338
import com.google.cloud.bigquery.analyticshub.v1.ListDataExchangesResponse;
3439
import com.google.cloud.bigquery.analyticshub.v1.ListListingsRequest;
3540
import com.google.cloud.bigquery.analyticshub.v1.ListListingsResponse;
3641
import com.google.cloud.bigquery.analyticshub.v1.ListOrgDataExchangesRequest;
3742
import com.google.cloud.bigquery.analyticshub.v1.ListOrgDataExchangesResponse;
43+
import com.google.cloud.bigquery.analyticshub.v1.ListSharedResourceSubscriptionsRequest;
44+
import com.google.cloud.bigquery.analyticshub.v1.ListSharedResourceSubscriptionsResponse;
45+
import com.google.cloud.bigquery.analyticshub.v1.ListSubscriptionsRequest;
46+
import com.google.cloud.bigquery.analyticshub.v1.ListSubscriptionsResponse;
3847
import com.google.cloud.bigquery.analyticshub.v1.Listing;
48+
import com.google.cloud.bigquery.analyticshub.v1.OperationMetadata;
49+
import com.google.cloud.bigquery.analyticshub.v1.RefreshSubscriptionRequest;
50+
import com.google.cloud.bigquery.analyticshub.v1.RefreshSubscriptionResponse;
51+
import com.google.cloud.bigquery.analyticshub.v1.RevokeSubscriptionRequest;
52+
import com.google.cloud.bigquery.analyticshub.v1.RevokeSubscriptionResponse;
53+
import com.google.cloud.bigquery.analyticshub.v1.SubscribeDataExchangeRequest;
54+
import com.google.cloud.bigquery.analyticshub.v1.SubscribeDataExchangeResponse;
3955
import com.google.cloud.bigquery.analyticshub.v1.SubscribeListingRequest;
4056
import com.google.cloud.bigquery.analyticshub.v1.SubscribeListingResponse;
57+
import com.google.cloud.bigquery.analyticshub.v1.Subscription;
4158
import com.google.cloud.bigquery.analyticshub.v1.UpdateDataExchangeRequest;
4259
import com.google.cloud.bigquery.analyticshub.v1.UpdateListingRequest;
4360
import com.google.iam.v1.GetIamPolicyRequest;
4461
import com.google.iam.v1.Policy;
4562
import com.google.iam.v1.SetIamPolicyRequest;
4663
import com.google.iam.v1.TestIamPermissionsRequest;
4764
import com.google.iam.v1.TestIamPermissionsResponse;
65+
import com.google.longrunning.Operation;
66+
import com.google.longrunning.stub.OperationsStub;
4867
import com.google.protobuf.Empty;
4968
import javax.annotation.Generated;
5069

@@ -57,6 +76,14 @@
5776
@Generated("by gapic-generator-java")
5877
public abstract class AnalyticsHubServiceStub implements BackgroundResource {
5978

79+
public OperationsStub getOperationsStub() {
80+
return null;
81+
}
82+
83+
public com.google.api.gax.httpjson.longrunning.stub.OperationsStub getHttpJsonOperationsStub() {
84+
return null;
85+
}
86+
6087
public UnaryCallable<ListDataExchangesRequest, ListDataExchangesPagedResponse>
6188
listDataExchangesPagedCallable() {
6289
throw new UnsupportedOperationException("Not implemented: listDataExchangesPagedCallable()");
@@ -122,6 +149,71 @@ public UnaryCallable<DeleteListingRequest, Empty> deleteListingCallable() {
122149
throw new UnsupportedOperationException("Not implemented: subscribeListingCallable()");
123150
}
124151

152+
public OperationCallable<
153+
SubscribeDataExchangeRequest, SubscribeDataExchangeResponse, OperationMetadata>
154+
subscribeDataExchangeOperationCallable() {
155+
throw new UnsupportedOperationException(
156+
"Not implemented: subscribeDataExchangeOperationCallable()");
157+
}
158+
159+
public UnaryCallable<SubscribeDataExchangeRequest, Operation> subscribeDataExchangeCallable() {
160+
throw new UnsupportedOperationException("Not implemented: subscribeDataExchangeCallable()");
161+
}
162+
163+
public OperationCallable<
164+
RefreshSubscriptionRequest, RefreshSubscriptionResponse, OperationMetadata>
165+
refreshSubscriptionOperationCallable() {
166+
throw new UnsupportedOperationException(
167+
"Not implemented: refreshSubscriptionOperationCallable()");
168+
}
169+
170+
public UnaryCallable<RefreshSubscriptionRequest, Operation> refreshSubscriptionCallable() {
171+
throw new UnsupportedOperationException("Not implemented: refreshSubscriptionCallable()");
172+
}
173+
174+
public UnaryCallable<GetSubscriptionRequest, Subscription> getSubscriptionCallable() {
175+
throw new UnsupportedOperationException("Not implemented: getSubscriptionCallable()");
176+
}
177+
178+
public UnaryCallable<ListSubscriptionsRequest, ListSubscriptionsPagedResponse>
179+
listSubscriptionsPagedCallable() {
180+
throw new UnsupportedOperationException("Not implemented: listSubscriptionsPagedCallable()");
181+
}
182+
183+
public UnaryCallable<ListSubscriptionsRequest, ListSubscriptionsResponse>
184+
listSubscriptionsCallable() {
185+
throw new UnsupportedOperationException("Not implemented: listSubscriptionsCallable()");
186+
}
187+
188+
public UnaryCallable<
189+
ListSharedResourceSubscriptionsRequest, ListSharedResourceSubscriptionsPagedResponse>
190+
listSharedResourceSubscriptionsPagedCallable() {
191+
throw new UnsupportedOperationException(
192+
"Not implemented: listSharedResourceSubscriptionsPagedCallable()");
193+
}
194+
195+
public UnaryCallable<
196+
ListSharedResourceSubscriptionsRequest, ListSharedResourceSubscriptionsResponse>
197+
listSharedResourceSubscriptionsCallable() {
198+
throw new UnsupportedOperationException(
199+
"Not implemented: listSharedResourceSubscriptionsCallable()");
200+
}
201+
202+
public UnaryCallable<RevokeSubscriptionRequest, RevokeSubscriptionResponse>
203+
revokeSubscriptionCallable() {
204+
throw new UnsupportedOperationException("Not implemented: revokeSubscriptionCallable()");
205+
}
206+
207+
public OperationCallable<DeleteSubscriptionRequest, Empty, OperationMetadata>
208+
deleteSubscriptionOperationCallable() {
209+
throw new UnsupportedOperationException(
210+
"Not implemented: deleteSubscriptionOperationCallable()");
211+
}
212+
213+
public UnaryCallable<DeleteSubscriptionRequest, Operation> deleteSubscriptionCallable() {
214+
throw new UnsupportedOperationException("Not implemented: deleteSubscriptionCallable()");
215+
}
216+
125217
public UnaryCallable<GetIamPolicyRequest, Policy> getIamPolicyCallable() {
126218
throw new UnsupportedOperationException("Not implemented: getIamPolicyCallable()");
127219
}

0 commit comments

Comments
 (0)