@@ -110,8 +110,8 @@ class FeatureOnlineStoreServiceClient {
110110 // / [`future`]: @ref google::cloud::future
111111 // / [`StatusOr`]: @ref google::cloud::StatusOr
112112 // / [`Status`]: @ref google::cloud::Status
113- // / [google.cloud.aiplatform.v1.FetchFeatureValuesRequest]: @googleapis_reference_link{google/cloud/aiplatform/v1/feature_online_store_service.proto#L96 }
114- // / [google.cloud.aiplatform.v1.FetchFeatureValuesResponse]: @googleapis_reference_link{google/cloud/aiplatform/v1/feature_online_store_service.proto#L118 }
113+ // / [google.cloud.aiplatform.v1.FetchFeatureValuesRequest]: @googleapis_reference_link{google/cloud/aiplatform/v1/feature_online_store_service.proto#L109 }
114+ // / [google.cloud.aiplatform.v1.FetchFeatureValuesResponse]: @googleapis_reference_link{google/cloud/aiplatform/v1/feature_online_store_service.proto#L131 }
115115 // /
116116 // clang-format on
117117 StatusOr<google::cloud::aiplatform::v1::FetchFeatureValuesResponse>
@@ -143,8 +143,8 @@ class FeatureOnlineStoreServiceClient {
143143 // / [`future`]: @ref google::cloud::future
144144 // / [`StatusOr`]: @ref google::cloud::StatusOr
145145 // / [`Status`]: @ref google::cloud::Status
146- // / [google.cloud.aiplatform.v1.FetchFeatureValuesRequest]: @googleapis_reference_link{google/cloud/aiplatform/v1/feature_online_store_service.proto#L96 }
147- // / [google.cloud.aiplatform.v1.FetchFeatureValuesResponse]: @googleapis_reference_link{google/cloud/aiplatform/v1/feature_online_store_service.proto#L118 }
146+ // / [google.cloud.aiplatform.v1.FetchFeatureValuesRequest]: @googleapis_reference_link{google/cloud/aiplatform/v1/feature_online_store_service.proto#L109 }
147+ // / [google.cloud.aiplatform.v1.FetchFeatureValuesResponse]: @googleapis_reference_link{google/cloud/aiplatform/v1/feature_online_store_service.proto#L131 }
148148 // /
149149 // clang-format on
150150 StatusOr<google::cloud::aiplatform::v1::FetchFeatureValuesResponse>
@@ -177,8 +177,8 @@ class FeatureOnlineStoreServiceClient {
177177 // / [`future`]: @ref google::cloud::future
178178 // / [`StatusOr`]: @ref google::cloud::StatusOr
179179 // / [`Status`]: @ref google::cloud::Status
180- // / [google.cloud.aiplatform.v1.SearchNearestEntitiesRequest]: @googleapis_reference_link{google/cloud/aiplatform/v1/feature_online_store_service.proto#L285 }
181- // / [google.cloud.aiplatform.v1.SearchNearestEntitiesResponse]: @googleapis_reference_link{google/cloud/aiplatform/v1/feature_online_store_service.proto#L328 }
180+ // / [google.cloud.aiplatform.v1.SearchNearestEntitiesRequest]: @googleapis_reference_link{google/cloud/aiplatform/v1/feature_online_store_service.proto#L298 }
181+ // / [google.cloud.aiplatform.v1.SearchNearestEntitiesResponse]: @googleapis_reference_link{google/cloud/aiplatform/v1/feature_online_store_service.proto#L341 }
182182 // /
183183 // clang-format on
184184 StatusOr<google::cloud::aiplatform::v1::SearchNearestEntitiesResponse>
@@ -187,6 +187,38 @@ class FeatureOnlineStoreServiceClient {
187187 request,
188188 Options opts = {});
189189
190+ // clang-format off
191+ // /
192+ // / Bidirectional streaming RPC to directly write to feature values in a
193+ // / feature view. Requests may not have a one-to-one mapping to responses and
194+ // / responses may be returned out-of-order to reduce latency.
195+ // /
196+ // / @param opts Optional. Override the class-level options, such as retry and
197+ // / backoff policies.
198+ // / @return An object representing the bidirectional streaming
199+ // / RPC. Applications can send multiple request messages and receive
200+ // / multiple response messages through this API. Bidirectional streaming
201+ // / RPCs can impose restrictions on the sequence of request and response
202+ // / messages. Please consult the service documentation for details.
203+ // / The request message type ([google.cloud.aiplatform.v1.FeatureViewDirectWriteRequest]) and response messages
204+ // / ([google.cloud.aiplatform.v1.FeatureViewDirectWriteResponse]) are mapped to C++ classes using the
205+ // / [Protobuf mapping rules].
206+ // /
207+ // / [Protobuf mapping rules]: https://protobuf.dev/reference/cpp/cpp-generated/
208+ // / [input iterator requirements]: https://en.cppreference.com/w/cpp/named_req/InputIterator
209+ // / [`std::string`]: https://en.cppreference.com/w/cpp/string/basic_string
210+ // / [`future`]: @ref google::cloud::future
211+ // / [`StatusOr`]: @ref google::cloud::StatusOr
212+ // / [`Status`]: @ref google::cloud::Status
213+ // / [google.cloud.aiplatform.v1.FeatureViewDirectWriteRequest]: @googleapis_reference_link{google/cloud/aiplatform/v1/feature_online_store_service.proto#L348}
214+ // / [google.cloud.aiplatform.v1.FeatureViewDirectWriteResponse]: @googleapis_reference_link{google/cloud/aiplatform/v1/feature_online_store_service.proto#L384}
215+ // /
216+ // clang-format on
217+ std::unique_ptr<::google::cloud::AsyncStreamingReadWriteRpc<
218+ google::cloud::aiplatform::v1::FeatureViewDirectWriteRequest,
219+ google::cloud::aiplatform::v1::FeatureViewDirectWriteResponse>>
220+ AsyncFeatureViewDirectWrite (Options opts = {});
221+
190222 // clang-format off
191223 // /
192224 // / Lists information about the supported locations for this service.
0 commit comments