@@ -1016,6 +1016,104 @@ ConfigConnectionImpl::GetTerraformVersion(
10161016 *current, request, __func__);
10171017}
10181018
1019+ StreamRange<google::cloud::config::v1::ResourceChange>
1020+ ConfigConnectionImpl::ListResourceChanges (
1021+ google::cloud::config::v1::ListResourceChangesRequest request) {
1022+ request.clear_page_token ();
1023+ auto current = google::cloud::internal::SaveCurrentOptions ();
1024+ auto idempotency = idempotency_policy (*current)->ListResourceChanges (request);
1025+ char const * function_name = __func__;
1026+ return google::cloud::internal::MakePaginationRange<
1027+ StreamRange<google::cloud::config::v1::ResourceChange>>(
1028+ current, std::move (request),
1029+ [idempotency, function_name, stub = stub_,
1030+ retry = std::shared_ptr<config_v1::ConfigRetryPolicy>(
1031+ retry_policy (*current)),
1032+ backoff = std::shared_ptr<BackoffPolicy>(backoff_policy (*current))](
1033+ Options const & options,
1034+ google::cloud::config::v1::ListResourceChangesRequest const & r) {
1035+ return google::cloud::internal::RetryLoop (
1036+ retry->clone (), backoff->clone (), idempotency,
1037+ [stub](grpc::ClientContext& context, Options const & options,
1038+ google::cloud::config::v1::ListResourceChangesRequest const &
1039+ request) {
1040+ return stub->ListResourceChanges (context, options, request);
1041+ },
1042+ options, r, function_name);
1043+ },
1044+ [](google::cloud::config::v1::ListResourceChangesResponse r) {
1045+ std::vector<google::cloud::config::v1::ResourceChange> result (
1046+ r.resource_changes ().size ());
1047+ auto & messages = *r.mutable_resource_changes ();
1048+ std::move (messages.begin (), messages.end (), result.begin ());
1049+ return result;
1050+ });
1051+ }
1052+
1053+ StatusOr<google::cloud::config::v1::ResourceChange>
1054+ ConfigConnectionImpl::GetResourceChange (
1055+ google::cloud::config::v1::GetResourceChangeRequest const & request) {
1056+ auto current = google::cloud::internal::SaveCurrentOptions ();
1057+ return google::cloud::internal::RetryLoop (
1058+ retry_policy (*current), backoff_policy (*current),
1059+ idempotency_policy (*current)->GetResourceChange (request),
1060+ [this ](
1061+ grpc::ClientContext& context, Options const & options,
1062+ google::cloud::config::v1::GetResourceChangeRequest const & request) {
1063+ return stub_->GetResourceChange (context, options, request);
1064+ },
1065+ *current, request, __func__);
1066+ }
1067+
1068+ StreamRange<google::cloud::config::v1::ResourceDrift>
1069+ ConfigConnectionImpl::ListResourceDrifts (
1070+ google::cloud::config::v1::ListResourceDriftsRequest request) {
1071+ request.clear_page_token ();
1072+ auto current = google::cloud::internal::SaveCurrentOptions ();
1073+ auto idempotency = idempotency_policy (*current)->ListResourceDrifts (request);
1074+ char const * function_name = __func__;
1075+ return google::cloud::internal::MakePaginationRange<
1076+ StreamRange<google::cloud::config::v1::ResourceDrift>>(
1077+ current, std::move (request),
1078+ [idempotency, function_name, stub = stub_,
1079+ retry = std::shared_ptr<config_v1::ConfigRetryPolicy>(
1080+ retry_policy (*current)),
1081+ backoff = std::shared_ptr<BackoffPolicy>(backoff_policy (*current))](
1082+ Options const & options,
1083+ google::cloud::config::v1::ListResourceDriftsRequest const & r) {
1084+ return google::cloud::internal::RetryLoop (
1085+ retry->clone (), backoff->clone (), idempotency,
1086+ [stub](grpc::ClientContext& context, Options const & options,
1087+ google::cloud::config::v1::ListResourceDriftsRequest const &
1088+ request) {
1089+ return stub->ListResourceDrifts (context, options, request);
1090+ },
1091+ options, r, function_name);
1092+ },
1093+ [](google::cloud::config::v1::ListResourceDriftsResponse r) {
1094+ std::vector<google::cloud::config::v1::ResourceDrift> result (
1095+ r.resource_drifts ().size ());
1096+ auto & messages = *r.mutable_resource_drifts ();
1097+ std::move (messages.begin (), messages.end (), result.begin ());
1098+ return result;
1099+ });
1100+ }
1101+
1102+ StatusOr<google::cloud::config::v1::ResourceDrift>
1103+ ConfigConnectionImpl::GetResourceDrift (
1104+ google::cloud::config::v1::GetResourceDriftRequest const & request) {
1105+ auto current = google::cloud::internal::SaveCurrentOptions ();
1106+ return google::cloud::internal::RetryLoop (
1107+ retry_policy (*current), backoff_policy (*current),
1108+ idempotency_policy (*current)->GetResourceDrift (request),
1109+ [this ](
1110+ grpc::ClientContext& context, Options const & options,
1111+ google::cloud::config::v1::GetResourceDriftRequest const & request) {
1112+ return stub_->GetResourceDrift (context, options, request);
1113+ },
1114+ *current, request, __func__);
1115+ }
1116+
10191117StreamRange<google::cloud::location::Location>
10201118ConfigConnectionImpl::ListLocations (
10211119 google::cloud::location::ListLocationsRequest request) {
0 commit comments