1// Copyright 2021 Google LLC 2// 3// Licensed under the Apache License, Version 2.0 (the "License"); 4// you may not use this file except in compliance with the License. 5// You may obtain a copy of the License at 6// 7// http://www.apache.org/licenses/LICENSE-2.0 8// 9// Unless required by applicable law or agreed to in writing, software 10// distributed under the License is distributed on an "AS IS" BASIS, 11// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. 12// See the License for the specific language governing permissions and 13// limitations under the License. 14 15// Code generated by protoc-gen-go. DO NOT EDIT. 16// versions: 17// protoc-gen-go v1.25.0-devel 18// protoc v3.12.2 19// source: google/cloud/aiplatform/v1beta1/featurestore_online_service.proto 20 21package aiplatform 22 23import ( 24 context "context" 25 reflect "reflect" 26 sync "sync" 27 28 proto "github.com/golang/protobuf/proto" 29 _ "google.golang.org/genproto/googleapis/api/annotations" 30 grpc "google.golang.org/grpc" 31 codes "google.golang.org/grpc/codes" 32 status "google.golang.org/grpc/status" 33 protoreflect "google.golang.org/protobuf/reflect/protoreflect" 34 protoimpl "google.golang.org/protobuf/runtime/protoimpl" 35 timestamppb "google.golang.org/protobuf/types/known/timestamppb" 36) 37 38const ( 39 // Verify that this generated code is sufficiently up-to-date. 40 _ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion) 41 // Verify that runtime/protoimpl is sufficiently up-to-date. 42 _ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20) 43) 44 45// This is a compile-time assertion that a sufficiently up-to-date version 46// of the legacy proto package is being used. 47const _ = proto.ProtoPackageIsVersion4 48 49// Request message for [FeaturestoreOnlineServingService.ReadFeatureValues][google.cloud.aiplatform.v1beta1.FeaturestoreOnlineServingService.ReadFeatureValues]. 50type ReadFeatureValuesRequest struct { 51 state protoimpl.MessageState 52 sizeCache protoimpl.SizeCache 53 unknownFields protoimpl.UnknownFields 54 55 // Required. The resource name of the EntityType for the entity being read. 56 // Value format: `projects/{project}/locations/{location}/featurestores/ 57 // {featurestore}/entityTypes/{entityType}`. For example, 58 // for a machine learning model predicting user clicks on a website, an 59 // EntityType ID could be "user". 60 EntityType string `protobuf:"bytes,1,opt,name=entity_type,json=entityType,proto3" json:"entity_type,omitempty"` 61 // Required. ID for a specific entity. For example, 62 // for a machine learning model predicting user clicks on a website, an entity 63 // ID could be "user_123". 64 EntityId string `protobuf:"bytes,2,opt,name=entity_id,json=entityId,proto3" json:"entity_id,omitempty"` 65 // Required. Selector choosing Features of the target EntityType. 66 FeatureSelector *FeatureSelector `protobuf:"bytes,3,opt,name=feature_selector,json=featureSelector,proto3" json:"feature_selector,omitempty"` 67} 68 69func (x *ReadFeatureValuesRequest) Reset() { 70 *x = ReadFeatureValuesRequest{} 71 if protoimpl.UnsafeEnabled { 72 mi := &file_google_cloud_aiplatform_v1beta1_featurestore_online_service_proto_msgTypes[0] 73 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 74 ms.StoreMessageInfo(mi) 75 } 76} 77 78func (x *ReadFeatureValuesRequest) String() string { 79 return protoimpl.X.MessageStringOf(x) 80} 81 82func (*ReadFeatureValuesRequest) ProtoMessage() {} 83 84func (x *ReadFeatureValuesRequest) ProtoReflect() protoreflect.Message { 85 mi := &file_google_cloud_aiplatform_v1beta1_featurestore_online_service_proto_msgTypes[0] 86 if protoimpl.UnsafeEnabled && x != nil { 87 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 88 if ms.LoadMessageInfo() == nil { 89 ms.StoreMessageInfo(mi) 90 } 91 return ms 92 } 93 return mi.MessageOf(x) 94} 95 96// Deprecated: Use ReadFeatureValuesRequest.ProtoReflect.Descriptor instead. 97func (*ReadFeatureValuesRequest) Descriptor() ([]byte, []int) { 98 return file_google_cloud_aiplatform_v1beta1_featurestore_online_service_proto_rawDescGZIP(), []int{0} 99} 100 101func (x *ReadFeatureValuesRequest) GetEntityType() string { 102 if x != nil { 103 return x.EntityType 104 } 105 return "" 106} 107 108func (x *ReadFeatureValuesRequest) GetEntityId() string { 109 if x != nil { 110 return x.EntityId 111 } 112 return "" 113} 114 115func (x *ReadFeatureValuesRequest) GetFeatureSelector() *FeatureSelector { 116 if x != nil { 117 return x.FeatureSelector 118 } 119 return nil 120} 121 122// Response message for [FeaturestoreOnlineServingService.ReadFeatureValues][google.cloud.aiplatform.v1beta1.FeaturestoreOnlineServingService.ReadFeatureValues]. 123type ReadFeatureValuesResponse struct { 124 state protoimpl.MessageState 125 sizeCache protoimpl.SizeCache 126 unknownFields protoimpl.UnknownFields 127 128 // Response header. 129 Header *ReadFeatureValuesResponse_Header `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"` 130 // Entity view with Feature values. This may be the entity in the 131 // Featurestore if values for all Features were requested, or a projection 132 // of the entity in the Featurestore if values for only some Features were 133 // requested. 134 EntityView *ReadFeatureValuesResponse_EntityView `protobuf:"bytes,2,opt,name=entity_view,json=entityView,proto3" json:"entity_view,omitempty"` 135} 136 137func (x *ReadFeatureValuesResponse) Reset() { 138 *x = ReadFeatureValuesResponse{} 139 if protoimpl.UnsafeEnabled { 140 mi := &file_google_cloud_aiplatform_v1beta1_featurestore_online_service_proto_msgTypes[1] 141 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 142 ms.StoreMessageInfo(mi) 143 } 144} 145 146func (x *ReadFeatureValuesResponse) String() string { 147 return protoimpl.X.MessageStringOf(x) 148} 149 150func (*ReadFeatureValuesResponse) ProtoMessage() {} 151 152func (x *ReadFeatureValuesResponse) ProtoReflect() protoreflect.Message { 153 mi := &file_google_cloud_aiplatform_v1beta1_featurestore_online_service_proto_msgTypes[1] 154 if protoimpl.UnsafeEnabled && x != nil { 155 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 156 if ms.LoadMessageInfo() == nil { 157 ms.StoreMessageInfo(mi) 158 } 159 return ms 160 } 161 return mi.MessageOf(x) 162} 163 164// Deprecated: Use ReadFeatureValuesResponse.ProtoReflect.Descriptor instead. 165func (*ReadFeatureValuesResponse) Descriptor() ([]byte, []int) { 166 return file_google_cloud_aiplatform_v1beta1_featurestore_online_service_proto_rawDescGZIP(), []int{1} 167} 168 169func (x *ReadFeatureValuesResponse) GetHeader() *ReadFeatureValuesResponse_Header { 170 if x != nil { 171 return x.Header 172 } 173 return nil 174} 175 176func (x *ReadFeatureValuesResponse) GetEntityView() *ReadFeatureValuesResponse_EntityView { 177 if x != nil { 178 return x.EntityView 179 } 180 return nil 181} 182 183// Request message for 184// [FeaturestoreOnlineServingService.StreamingFeatureValuesRead][]. 185type StreamingReadFeatureValuesRequest struct { 186 state protoimpl.MessageState 187 sizeCache protoimpl.SizeCache 188 unknownFields protoimpl.UnknownFields 189 190 // Required. The resource name of the entities' type. 191 // Value format: `projects/{project}/locations/{location}/featurestores/ 192 // {featurestore}/entityTypes/{entityType}`. For example, 193 // for a machine learning model predicting user clicks on a website, an 194 // EntityType ID could be "user". 195 EntityType string `protobuf:"bytes,1,opt,name=entity_type,json=entityType,proto3" json:"entity_type,omitempty"` 196 // Required. IDs of entities to read Feature values of. For example, 197 // for a machine learning model predicting user clicks on a website, an 198 // entity ID could be "user_123". 199 EntityIds []string `protobuf:"bytes,2,rep,name=entity_ids,json=entityIds,proto3" json:"entity_ids,omitempty"` 200 // Required. Selector choosing Features of the target EntityType. 201 FeatureSelector *FeatureSelector `protobuf:"bytes,3,opt,name=feature_selector,json=featureSelector,proto3" json:"feature_selector,omitempty"` 202} 203 204func (x *StreamingReadFeatureValuesRequest) Reset() { 205 *x = StreamingReadFeatureValuesRequest{} 206 if protoimpl.UnsafeEnabled { 207 mi := &file_google_cloud_aiplatform_v1beta1_featurestore_online_service_proto_msgTypes[2] 208 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 209 ms.StoreMessageInfo(mi) 210 } 211} 212 213func (x *StreamingReadFeatureValuesRequest) String() string { 214 return protoimpl.X.MessageStringOf(x) 215} 216 217func (*StreamingReadFeatureValuesRequest) ProtoMessage() {} 218 219func (x *StreamingReadFeatureValuesRequest) ProtoReflect() protoreflect.Message { 220 mi := &file_google_cloud_aiplatform_v1beta1_featurestore_online_service_proto_msgTypes[2] 221 if protoimpl.UnsafeEnabled && x != nil { 222 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 223 if ms.LoadMessageInfo() == nil { 224 ms.StoreMessageInfo(mi) 225 } 226 return ms 227 } 228 return mi.MessageOf(x) 229} 230 231// Deprecated: Use StreamingReadFeatureValuesRequest.ProtoReflect.Descriptor instead. 232func (*StreamingReadFeatureValuesRequest) Descriptor() ([]byte, []int) { 233 return file_google_cloud_aiplatform_v1beta1_featurestore_online_service_proto_rawDescGZIP(), []int{2} 234} 235 236func (x *StreamingReadFeatureValuesRequest) GetEntityType() string { 237 if x != nil { 238 return x.EntityType 239 } 240 return "" 241} 242 243func (x *StreamingReadFeatureValuesRequest) GetEntityIds() []string { 244 if x != nil { 245 return x.EntityIds 246 } 247 return nil 248} 249 250func (x *StreamingReadFeatureValuesRequest) GetFeatureSelector() *FeatureSelector { 251 if x != nil { 252 return x.FeatureSelector 253 } 254 return nil 255} 256 257// Value for a feature. 258// NEXT ID: 15 259type FeatureValue struct { 260 state protoimpl.MessageState 261 sizeCache protoimpl.SizeCache 262 unknownFields protoimpl.UnknownFields 263 264 // Value for the feature. 265 // 266 // Types that are assignable to Value: 267 // *FeatureValue_BoolValue 268 // *FeatureValue_DoubleValue 269 // *FeatureValue_Int64Value 270 // *FeatureValue_StringValue 271 // *FeatureValue_BoolArrayValue 272 // *FeatureValue_DoubleArrayValue 273 // *FeatureValue_Int64ArrayValue 274 // *FeatureValue_StringArrayValue 275 // *FeatureValue_BytesValue 276 Value isFeatureValue_Value `protobuf_oneof:"value"` 277 // Output only. Metadata of feature value. 278 Metadata *FeatureValue_Metadata `protobuf:"bytes,14,opt,name=metadata,proto3" json:"metadata,omitempty"` 279} 280 281func (x *FeatureValue) Reset() { 282 *x = FeatureValue{} 283 if protoimpl.UnsafeEnabled { 284 mi := &file_google_cloud_aiplatform_v1beta1_featurestore_online_service_proto_msgTypes[3] 285 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 286 ms.StoreMessageInfo(mi) 287 } 288} 289 290func (x *FeatureValue) String() string { 291 return protoimpl.X.MessageStringOf(x) 292} 293 294func (*FeatureValue) ProtoMessage() {} 295 296func (x *FeatureValue) ProtoReflect() protoreflect.Message { 297 mi := &file_google_cloud_aiplatform_v1beta1_featurestore_online_service_proto_msgTypes[3] 298 if protoimpl.UnsafeEnabled && x != nil { 299 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 300 if ms.LoadMessageInfo() == nil { 301 ms.StoreMessageInfo(mi) 302 } 303 return ms 304 } 305 return mi.MessageOf(x) 306} 307 308// Deprecated: Use FeatureValue.ProtoReflect.Descriptor instead. 309func (*FeatureValue) Descriptor() ([]byte, []int) { 310 return file_google_cloud_aiplatform_v1beta1_featurestore_online_service_proto_rawDescGZIP(), []int{3} 311} 312 313func (m *FeatureValue) GetValue() isFeatureValue_Value { 314 if m != nil { 315 return m.Value 316 } 317 return nil 318} 319 320func (x *FeatureValue) GetBoolValue() bool { 321 if x, ok := x.GetValue().(*FeatureValue_BoolValue); ok { 322 return x.BoolValue 323 } 324 return false 325} 326 327func (x *FeatureValue) GetDoubleValue() float64 { 328 if x, ok := x.GetValue().(*FeatureValue_DoubleValue); ok { 329 return x.DoubleValue 330 } 331 return 0 332} 333 334func (x *FeatureValue) GetInt64Value() int64 { 335 if x, ok := x.GetValue().(*FeatureValue_Int64Value); ok { 336 return x.Int64Value 337 } 338 return 0 339} 340 341func (x *FeatureValue) GetStringValue() string { 342 if x, ok := x.GetValue().(*FeatureValue_StringValue); ok { 343 return x.StringValue 344 } 345 return "" 346} 347 348func (x *FeatureValue) GetBoolArrayValue() *BoolArray { 349 if x, ok := x.GetValue().(*FeatureValue_BoolArrayValue); ok { 350 return x.BoolArrayValue 351 } 352 return nil 353} 354 355func (x *FeatureValue) GetDoubleArrayValue() *DoubleArray { 356 if x, ok := x.GetValue().(*FeatureValue_DoubleArrayValue); ok { 357 return x.DoubleArrayValue 358 } 359 return nil 360} 361 362func (x *FeatureValue) GetInt64ArrayValue() *Int64Array { 363 if x, ok := x.GetValue().(*FeatureValue_Int64ArrayValue); ok { 364 return x.Int64ArrayValue 365 } 366 return nil 367} 368 369func (x *FeatureValue) GetStringArrayValue() *StringArray { 370 if x, ok := x.GetValue().(*FeatureValue_StringArrayValue); ok { 371 return x.StringArrayValue 372 } 373 return nil 374} 375 376func (x *FeatureValue) GetBytesValue() []byte { 377 if x, ok := x.GetValue().(*FeatureValue_BytesValue); ok { 378 return x.BytesValue 379 } 380 return nil 381} 382 383func (x *FeatureValue) GetMetadata() *FeatureValue_Metadata { 384 if x != nil { 385 return x.Metadata 386 } 387 return nil 388} 389 390type isFeatureValue_Value interface { 391 isFeatureValue_Value() 392} 393 394type FeatureValue_BoolValue struct { 395 // Bool type feature value. 396 BoolValue bool `protobuf:"varint,1,opt,name=bool_value,json=boolValue,proto3,oneof"` 397} 398 399type FeatureValue_DoubleValue struct { 400 // Double type feature value. 401 DoubleValue float64 `protobuf:"fixed64,2,opt,name=double_value,json=doubleValue,proto3,oneof"` 402} 403 404type FeatureValue_Int64Value struct { 405 // Int64 feature value. 406 Int64Value int64 `protobuf:"varint,5,opt,name=int64_value,json=int64Value,proto3,oneof"` 407} 408 409type FeatureValue_StringValue struct { 410 // String feature value. 411 StringValue string `protobuf:"bytes,6,opt,name=string_value,json=stringValue,proto3,oneof"` 412} 413 414type FeatureValue_BoolArrayValue struct { 415 // A list of bool type feature value. 416 BoolArrayValue *BoolArray `protobuf:"bytes,7,opt,name=bool_array_value,json=boolArrayValue,proto3,oneof"` 417} 418 419type FeatureValue_DoubleArrayValue struct { 420 // A list of double type feature value. 421 DoubleArrayValue *DoubleArray `protobuf:"bytes,8,opt,name=double_array_value,json=doubleArrayValue,proto3,oneof"` 422} 423 424type FeatureValue_Int64ArrayValue struct { 425 // A list of int64 type feature value. 426 Int64ArrayValue *Int64Array `protobuf:"bytes,11,opt,name=int64_array_value,json=int64ArrayValue,proto3,oneof"` 427} 428 429type FeatureValue_StringArrayValue struct { 430 // A list of string type feature value. 431 StringArrayValue *StringArray `protobuf:"bytes,12,opt,name=string_array_value,json=stringArrayValue,proto3,oneof"` 432} 433 434type FeatureValue_BytesValue struct { 435 // Bytes feature value. 436 BytesValue []byte `protobuf:"bytes,13,opt,name=bytes_value,json=bytesValue,proto3,oneof"` 437} 438 439func (*FeatureValue_BoolValue) isFeatureValue_Value() {} 440 441func (*FeatureValue_DoubleValue) isFeatureValue_Value() {} 442 443func (*FeatureValue_Int64Value) isFeatureValue_Value() {} 444 445func (*FeatureValue_StringValue) isFeatureValue_Value() {} 446 447func (*FeatureValue_BoolArrayValue) isFeatureValue_Value() {} 448 449func (*FeatureValue_DoubleArrayValue) isFeatureValue_Value() {} 450 451func (*FeatureValue_Int64ArrayValue) isFeatureValue_Value() {} 452 453func (*FeatureValue_StringArrayValue) isFeatureValue_Value() {} 454 455func (*FeatureValue_BytesValue) isFeatureValue_Value() {} 456 457// Container for list of values. 458type FeatureValueList struct { 459 state protoimpl.MessageState 460 sizeCache protoimpl.SizeCache 461 unknownFields protoimpl.UnknownFields 462 463 // A list of feature values. All of them should be the same data type. 464 Values []*FeatureValue `protobuf:"bytes,1,rep,name=values,proto3" json:"values,omitempty"` 465} 466 467func (x *FeatureValueList) Reset() { 468 *x = FeatureValueList{} 469 if protoimpl.UnsafeEnabled { 470 mi := &file_google_cloud_aiplatform_v1beta1_featurestore_online_service_proto_msgTypes[4] 471 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 472 ms.StoreMessageInfo(mi) 473 } 474} 475 476func (x *FeatureValueList) String() string { 477 return protoimpl.X.MessageStringOf(x) 478} 479 480func (*FeatureValueList) ProtoMessage() {} 481 482func (x *FeatureValueList) ProtoReflect() protoreflect.Message { 483 mi := &file_google_cloud_aiplatform_v1beta1_featurestore_online_service_proto_msgTypes[4] 484 if protoimpl.UnsafeEnabled && x != nil { 485 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 486 if ms.LoadMessageInfo() == nil { 487 ms.StoreMessageInfo(mi) 488 } 489 return ms 490 } 491 return mi.MessageOf(x) 492} 493 494// Deprecated: Use FeatureValueList.ProtoReflect.Descriptor instead. 495func (*FeatureValueList) Descriptor() ([]byte, []int) { 496 return file_google_cloud_aiplatform_v1beta1_featurestore_online_service_proto_rawDescGZIP(), []int{4} 497} 498 499func (x *FeatureValueList) GetValues() []*FeatureValue { 500 if x != nil { 501 return x.Values 502 } 503 return nil 504} 505 506// Metadata for requested Features. 507type ReadFeatureValuesResponse_FeatureDescriptor struct { 508 state protoimpl.MessageState 509 sizeCache protoimpl.SizeCache 510 unknownFields protoimpl.UnknownFields 511 512 // Feature ID. 513 Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` 514} 515 516func (x *ReadFeatureValuesResponse_FeatureDescriptor) Reset() { 517 *x = ReadFeatureValuesResponse_FeatureDescriptor{} 518 if protoimpl.UnsafeEnabled { 519 mi := &file_google_cloud_aiplatform_v1beta1_featurestore_online_service_proto_msgTypes[5] 520 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 521 ms.StoreMessageInfo(mi) 522 } 523} 524 525func (x *ReadFeatureValuesResponse_FeatureDescriptor) String() string { 526 return protoimpl.X.MessageStringOf(x) 527} 528 529func (*ReadFeatureValuesResponse_FeatureDescriptor) ProtoMessage() {} 530 531func (x *ReadFeatureValuesResponse_FeatureDescriptor) ProtoReflect() protoreflect.Message { 532 mi := &file_google_cloud_aiplatform_v1beta1_featurestore_online_service_proto_msgTypes[5] 533 if protoimpl.UnsafeEnabled && x != nil { 534 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 535 if ms.LoadMessageInfo() == nil { 536 ms.StoreMessageInfo(mi) 537 } 538 return ms 539 } 540 return mi.MessageOf(x) 541} 542 543// Deprecated: Use ReadFeatureValuesResponse_FeatureDescriptor.ProtoReflect.Descriptor instead. 544func (*ReadFeatureValuesResponse_FeatureDescriptor) Descriptor() ([]byte, []int) { 545 return file_google_cloud_aiplatform_v1beta1_featurestore_online_service_proto_rawDescGZIP(), []int{1, 0} 546} 547 548func (x *ReadFeatureValuesResponse_FeatureDescriptor) GetId() string { 549 if x != nil { 550 return x.Id 551 } 552 return "" 553} 554 555// Response header with metadata for the requested 556// [ReadFeatureValuesRequest.entity_type][google.cloud.aiplatform.v1beta1.ReadFeatureValuesRequest.entity_type] and Features. 557type ReadFeatureValuesResponse_Header struct { 558 state protoimpl.MessageState 559 sizeCache protoimpl.SizeCache 560 unknownFields protoimpl.UnknownFields 561 562 // The resource name of the EntityType from the 563 // [ReadFeatureValuesRequest][google.cloud.aiplatform.v1beta1.ReadFeatureValuesRequest]. Value format: 564 // `projects/{project}/locations/{location}/featurestores/ 565 // {featurestore}/entityTypes/{entityType}`. 566 EntityType string `protobuf:"bytes,1,opt,name=entity_type,json=entityType,proto3" json:"entity_type,omitempty"` 567 // List of Feature metadata corresponding to each piece of 568 // [ReadFeatureValuesResponse.data][]. 569 FeatureDescriptors []*ReadFeatureValuesResponse_FeatureDescriptor `protobuf:"bytes,2,rep,name=feature_descriptors,json=featureDescriptors,proto3" json:"feature_descriptors,omitempty"` 570} 571 572func (x *ReadFeatureValuesResponse_Header) Reset() { 573 *x = ReadFeatureValuesResponse_Header{} 574 if protoimpl.UnsafeEnabled { 575 mi := &file_google_cloud_aiplatform_v1beta1_featurestore_online_service_proto_msgTypes[6] 576 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 577 ms.StoreMessageInfo(mi) 578 } 579} 580 581func (x *ReadFeatureValuesResponse_Header) String() string { 582 return protoimpl.X.MessageStringOf(x) 583} 584 585func (*ReadFeatureValuesResponse_Header) ProtoMessage() {} 586 587func (x *ReadFeatureValuesResponse_Header) ProtoReflect() protoreflect.Message { 588 mi := &file_google_cloud_aiplatform_v1beta1_featurestore_online_service_proto_msgTypes[6] 589 if protoimpl.UnsafeEnabled && x != nil { 590 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 591 if ms.LoadMessageInfo() == nil { 592 ms.StoreMessageInfo(mi) 593 } 594 return ms 595 } 596 return mi.MessageOf(x) 597} 598 599// Deprecated: Use ReadFeatureValuesResponse_Header.ProtoReflect.Descriptor instead. 600func (*ReadFeatureValuesResponse_Header) Descriptor() ([]byte, []int) { 601 return file_google_cloud_aiplatform_v1beta1_featurestore_online_service_proto_rawDescGZIP(), []int{1, 1} 602} 603 604func (x *ReadFeatureValuesResponse_Header) GetEntityType() string { 605 if x != nil { 606 return x.EntityType 607 } 608 return "" 609} 610 611func (x *ReadFeatureValuesResponse_Header) GetFeatureDescriptors() []*ReadFeatureValuesResponse_FeatureDescriptor { 612 if x != nil { 613 return x.FeatureDescriptors 614 } 615 return nil 616} 617 618// Entity view with Feature values. 619type ReadFeatureValuesResponse_EntityView struct { 620 state protoimpl.MessageState 621 sizeCache protoimpl.SizeCache 622 unknownFields protoimpl.UnknownFields 623 624 // ID of the requested entity. 625 EntityId string `protobuf:"bytes,1,opt,name=entity_id,json=entityId,proto3" json:"entity_id,omitempty"` 626 // Each piece of data holds the k 627 // requested values for one requested Feature. If no values 628 // for the requested Feature exist, the corresponding cell will be empty. 629 // This has the same size and is in the same order as the features from the 630 // header [ReadFeatureValuesResponse.header][google.cloud.aiplatform.v1beta1.ReadFeatureValuesResponse.header]. 631 Data []*ReadFeatureValuesResponse_EntityView_Data `protobuf:"bytes,2,rep,name=data,proto3" json:"data,omitempty"` 632} 633 634func (x *ReadFeatureValuesResponse_EntityView) Reset() { 635 *x = ReadFeatureValuesResponse_EntityView{} 636 if protoimpl.UnsafeEnabled { 637 mi := &file_google_cloud_aiplatform_v1beta1_featurestore_online_service_proto_msgTypes[7] 638 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 639 ms.StoreMessageInfo(mi) 640 } 641} 642 643func (x *ReadFeatureValuesResponse_EntityView) String() string { 644 return protoimpl.X.MessageStringOf(x) 645} 646 647func (*ReadFeatureValuesResponse_EntityView) ProtoMessage() {} 648 649func (x *ReadFeatureValuesResponse_EntityView) ProtoReflect() protoreflect.Message { 650 mi := &file_google_cloud_aiplatform_v1beta1_featurestore_online_service_proto_msgTypes[7] 651 if protoimpl.UnsafeEnabled && x != nil { 652 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 653 if ms.LoadMessageInfo() == nil { 654 ms.StoreMessageInfo(mi) 655 } 656 return ms 657 } 658 return mi.MessageOf(x) 659} 660 661// Deprecated: Use ReadFeatureValuesResponse_EntityView.ProtoReflect.Descriptor instead. 662func (*ReadFeatureValuesResponse_EntityView) Descriptor() ([]byte, []int) { 663 return file_google_cloud_aiplatform_v1beta1_featurestore_online_service_proto_rawDescGZIP(), []int{1, 2} 664} 665 666func (x *ReadFeatureValuesResponse_EntityView) GetEntityId() string { 667 if x != nil { 668 return x.EntityId 669 } 670 return "" 671} 672 673func (x *ReadFeatureValuesResponse_EntityView) GetData() []*ReadFeatureValuesResponse_EntityView_Data { 674 if x != nil { 675 return x.Data 676 } 677 return nil 678} 679 680// Container to hold value(s), successive in time, for one Feature from the 681// request. 682type ReadFeatureValuesResponse_EntityView_Data struct { 683 state protoimpl.MessageState 684 sizeCache protoimpl.SizeCache 685 unknownFields protoimpl.UnknownFields 686 687 // Types that are assignable to Data: 688 // *ReadFeatureValuesResponse_EntityView_Data_Value 689 // *ReadFeatureValuesResponse_EntityView_Data_Values 690 Data isReadFeatureValuesResponse_EntityView_Data_Data `protobuf_oneof:"data"` 691} 692 693func (x *ReadFeatureValuesResponse_EntityView_Data) Reset() { 694 *x = ReadFeatureValuesResponse_EntityView_Data{} 695 if protoimpl.UnsafeEnabled { 696 mi := &file_google_cloud_aiplatform_v1beta1_featurestore_online_service_proto_msgTypes[8] 697 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 698 ms.StoreMessageInfo(mi) 699 } 700} 701 702func (x *ReadFeatureValuesResponse_EntityView_Data) String() string { 703 return protoimpl.X.MessageStringOf(x) 704} 705 706func (*ReadFeatureValuesResponse_EntityView_Data) ProtoMessage() {} 707 708func (x *ReadFeatureValuesResponse_EntityView_Data) ProtoReflect() protoreflect.Message { 709 mi := &file_google_cloud_aiplatform_v1beta1_featurestore_online_service_proto_msgTypes[8] 710 if protoimpl.UnsafeEnabled && x != nil { 711 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 712 if ms.LoadMessageInfo() == nil { 713 ms.StoreMessageInfo(mi) 714 } 715 return ms 716 } 717 return mi.MessageOf(x) 718} 719 720// Deprecated: Use ReadFeatureValuesResponse_EntityView_Data.ProtoReflect.Descriptor instead. 721func (*ReadFeatureValuesResponse_EntityView_Data) Descriptor() ([]byte, []int) { 722 return file_google_cloud_aiplatform_v1beta1_featurestore_online_service_proto_rawDescGZIP(), []int{1, 2, 0} 723} 724 725func (m *ReadFeatureValuesResponse_EntityView_Data) GetData() isReadFeatureValuesResponse_EntityView_Data_Data { 726 if m != nil { 727 return m.Data 728 } 729 return nil 730} 731 732func (x *ReadFeatureValuesResponse_EntityView_Data) GetValue() *FeatureValue { 733 if x, ok := x.GetData().(*ReadFeatureValuesResponse_EntityView_Data_Value); ok { 734 return x.Value 735 } 736 return nil 737} 738 739func (x *ReadFeatureValuesResponse_EntityView_Data) GetValues() *FeatureValueList { 740 if x, ok := x.GetData().(*ReadFeatureValuesResponse_EntityView_Data_Values); ok { 741 return x.Values 742 } 743 return nil 744} 745 746type isReadFeatureValuesResponse_EntityView_Data_Data interface { 747 isReadFeatureValuesResponse_EntityView_Data_Data() 748} 749 750type ReadFeatureValuesResponse_EntityView_Data_Value struct { 751 // Feature value if a single value is requested. 752 Value *FeatureValue `protobuf:"bytes,1,opt,name=value,proto3,oneof"` 753} 754 755type ReadFeatureValuesResponse_EntityView_Data_Values struct { 756 // Feature values list if values, successive in time, are requested. 757 // If the requested number of values is greater than the number of 758 // existing Feature values, nonexistent values are omitted instead of 759 // being returned as empty. 760 Values *FeatureValueList `protobuf:"bytes,2,opt,name=values,proto3,oneof"` 761} 762 763func (*ReadFeatureValuesResponse_EntityView_Data_Value) isReadFeatureValuesResponse_EntityView_Data_Data() { 764} 765 766func (*ReadFeatureValuesResponse_EntityView_Data_Values) isReadFeatureValuesResponse_EntityView_Data_Data() { 767} 768 769// Metadata of feature value. 770type FeatureValue_Metadata struct { 771 state protoimpl.MessageState 772 sizeCache protoimpl.SizeCache 773 unknownFields protoimpl.UnknownFields 774 775 // Feature generation timestamp. Typically, it is provided by user at 776 // feature ingestion time. If not, feature store 777 // will use the system timestamp when the data is ingested into feature 778 // store. 779 GenerateTime *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=generate_time,json=generateTime,proto3" json:"generate_time,omitempty"` 780} 781 782func (x *FeatureValue_Metadata) Reset() { 783 *x = FeatureValue_Metadata{} 784 if protoimpl.UnsafeEnabled { 785 mi := &file_google_cloud_aiplatform_v1beta1_featurestore_online_service_proto_msgTypes[9] 786 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 787 ms.StoreMessageInfo(mi) 788 } 789} 790 791func (x *FeatureValue_Metadata) String() string { 792 return protoimpl.X.MessageStringOf(x) 793} 794 795func (*FeatureValue_Metadata) ProtoMessage() {} 796 797func (x *FeatureValue_Metadata) ProtoReflect() protoreflect.Message { 798 mi := &file_google_cloud_aiplatform_v1beta1_featurestore_online_service_proto_msgTypes[9] 799 if protoimpl.UnsafeEnabled && x != nil { 800 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 801 if ms.LoadMessageInfo() == nil { 802 ms.StoreMessageInfo(mi) 803 } 804 return ms 805 } 806 return mi.MessageOf(x) 807} 808 809// Deprecated: Use FeatureValue_Metadata.ProtoReflect.Descriptor instead. 810func (*FeatureValue_Metadata) Descriptor() ([]byte, []int) { 811 return file_google_cloud_aiplatform_v1beta1_featurestore_online_service_proto_rawDescGZIP(), []int{3, 0} 812} 813 814func (x *FeatureValue_Metadata) GetGenerateTime() *timestamppb.Timestamp { 815 if x != nil { 816 return x.GenerateTime 817 } 818 return nil 819} 820 821var File_google_cloud_aiplatform_v1beta1_featurestore_online_service_proto protoreflect.FileDescriptor 822 823var file_google_cloud_aiplatform_v1beta1_featurestore_online_service_proto_rawDesc = []byte{ 824 0x0a, 0x41, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2f, 0x61, 825 0x69, 0x70, 0x6c, 0x61, 0x74, 0x66, 0x6f, 0x72, 0x6d, 0x2f, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 826 0x31, 0x2f, 0x66, 0x65, 0x61, 0x74, 0x75, 0x72, 0x65, 0x73, 0x74, 0x6f, 0x72, 0x65, 0x5f, 0x6f, 827 0x6e, 0x6c, 0x69, 0x6e, 0x65, 0x5f, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2e, 0x70, 0x72, 828 0x6f, 0x74, 0x6f, 0x12, 0x1f, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 829 0x64, 0x2e, 0x61, 0x69, 0x70, 0x6c, 0x61, 0x74, 0x66, 0x6f, 0x72, 0x6d, 0x2e, 0x76, 0x31, 0x62, 830 0x65, 0x74, 0x61, 0x31, 0x1a, 0x1c, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x61, 0x70, 0x69, 831 0x2f, 0x61, 0x6e, 0x6e, 0x6f, 0x74, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2e, 0x70, 0x72, 0x6f, 832 0x74, 0x6f, 0x1a, 0x17, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x61, 0x70, 0x69, 0x2f, 0x63, 833 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x1f, 0x67, 0x6f, 0x6f, 834 0x67, 0x6c, 0x65, 0x2f, 0x61, 0x70, 0x69, 0x2f, 0x66, 0x69, 0x65, 0x6c, 0x64, 0x5f, 0x62, 0x65, 835 0x68, 0x61, 0x76, 0x69, 0x6f, 0x72, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x19, 0x67, 0x6f, 836 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x61, 0x70, 0x69, 0x2f, 0x72, 0x65, 0x73, 0x6f, 0x75, 0x72, 0x63, 837 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x36, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 838 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2f, 0x61, 0x69, 0x70, 0x6c, 0x61, 0x74, 0x66, 0x6f, 0x72, 0x6d, 839 0x2f, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 0x2f, 0x66, 0x65, 0x61, 0x74, 0x75, 0x72, 0x65, 840 0x5f, 0x73, 0x65, 0x6c, 0x65, 0x63, 0x74, 0x6f, 0x72, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 841 0x2b, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2f, 0x61, 0x69, 842 0x70, 0x6c, 0x61, 0x74, 0x66, 0x6f, 0x72, 0x6d, 0x2f, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 843 0x2f, 0x74, 0x79, 0x70, 0x65, 0x73, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x1f, 0x67, 0x6f, 844 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2f, 0x74, 0x69, 845 0x6d, 0x65, 0x73, 0x74, 0x61, 0x6d, 0x70, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x22, 0xed, 0x01, 846 0x0a, 0x18, 0x52, 0x65, 0x61, 0x64, 0x46, 0x65, 0x61, 0x74, 0x75, 0x72, 0x65, 0x56, 0x61, 0x6c, 847 0x75, 0x65, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x4d, 0x0a, 0x0b, 0x65, 0x6e, 848 0x74, 0x69, 0x74, 0x79, 0x5f, 0x74, 0x79, 0x70, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x42, 849 0x2c, 0xe0, 0x41, 0x02, 0xfa, 0x41, 0x26, 0x0a, 0x24, 0x61, 0x69, 0x70, 0x6c, 0x61, 0x74, 0x66, 850 0x6f, 0x72, 0x6d, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2e, 0x63, 851 0x6f, 0x6d, 0x2f, 0x45, 0x6e, 0x74, 0x69, 0x74, 0x79, 0x54, 0x79, 0x70, 0x65, 0x52, 0x0a, 0x65, 852 0x6e, 0x74, 0x69, 0x74, 0x79, 0x54, 0x79, 0x70, 0x65, 0x12, 0x20, 0x0a, 0x09, 0x65, 0x6e, 0x74, 853 0x69, 0x74, 0x79, 0x5f, 0x69, 0x64, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x42, 0x03, 0xe0, 0x41, 854 0x02, 0x52, 0x08, 0x65, 0x6e, 0x74, 0x69, 0x74, 0x79, 0x49, 0x64, 0x12, 0x60, 0x0a, 0x10, 0x66, 855 0x65, 0x61, 0x74, 0x75, 0x72, 0x65, 0x5f, 0x73, 0x65, 0x6c, 0x65, 0x63, 0x74, 0x6f, 0x72, 0x18, 856 0x03, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x30, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 857 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x61, 0x69, 0x70, 0x6c, 0x61, 0x74, 0x66, 0x6f, 0x72, 0x6d, 0x2e, 858 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 0x2e, 0x46, 0x65, 0x61, 0x74, 0x75, 0x72, 0x65, 0x53, 859 0x65, 0x6c, 0x65, 0x63, 0x74, 0x6f, 0x72, 0x42, 0x03, 0xe0, 0x41, 0x02, 0x52, 0x0f, 0x66, 0x65, 860 0x61, 0x74, 0x75, 0x72, 0x65, 0x53, 0x65, 0x6c, 0x65, 0x63, 0x74, 0x6f, 0x72, 0x22, 0x8a, 0x06, 861 0x0a, 0x19, 0x52, 0x65, 0x61, 0x64, 0x46, 0x65, 0x61, 0x74, 0x75, 0x72, 0x65, 0x56, 0x61, 0x6c, 862 0x75, 0x65, 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x59, 0x0a, 0x06, 0x68, 863 0x65, 0x61, 0x64, 0x65, 0x72, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x41, 0x2e, 0x67, 0x6f, 864 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x61, 0x69, 0x70, 0x6c, 0x61, 865 0x74, 0x66, 0x6f, 0x72, 0x6d, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 0x2e, 0x52, 0x65, 866 0x61, 0x64, 0x46, 0x65, 0x61, 0x74, 0x75, 0x72, 0x65, 0x56, 0x61, 0x6c, 0x75, 0x65, 0x73, 0x52, 867 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x2e, 0x48, 0x65, 0x61, 0x64, 0x65, 0x72, 0x52, 0x06, 868 0x68, 0x65, 0x61, 0x64, 0x65, 0x72, 0x12, 0x66, 0x0a, 0x0b, 0x65, 0x6e, 0x74, 0x69, 0x74, 0x79, 869 0x5f, 0x76, 0x69, 0x65, 0x77, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x45, 0x2e, 0x67, 0x6f, 870 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x61, 0x69, 0x70, 0x6c, 0x61, 871 0x74, 0x66, 0x6f, 0x72, 0x6d, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 0x2e, 0x52, 0x65, 872 0x61, 0x64, 0x46, 0x65, 0x61, 0x74, 0x75, 0x72, 0x65, 0x56, 0x61, 0x6c, 0x75, 0x65, 0x73, 0x52, 873 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x2e, 0x45, 0x6e, 0x74, 0x69, 0x74, 0x79, 0x56, 0x69, 874 0x65, 0x77, 0x52, 0x0a, 0x65, 0x6e, 0x74, 0x69, 0x74, 0x79, 0x56, 0x69, 0x65, 0x77, 0x1a, 0x23, 875 0x0a, 0x11, 0x46, 0x65, 0x61, 0x74, 0x75, 0x72, 0x65, 0x44, 0x65, 0x73, 0x63, 0x72, 0x69, 0x70, 876 0x74, 0x6f, 0x72, 0x12, 0x0e, 0x0a, 0x02, 0x69, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 877 0x02, 0x69, 0x64, 0x1a, 0xd3, 0x01, 0x0a, 0x06, 0x48, 0x65, 0x61, 0x64, 0x65, 0x72, 0x12, 0x4a, 878 0x0a, 0x0b, 0x65, 0x6e, 0x74, 0x69, 0x74, 0x79, 0x5f, 0x74, 0x79, 0x70, 0x65, 0x18, 0x01, 0x20, 879 0x01, 0x28, 0x09, 0x42, 0x29, 0xfa, 0x41, 0x26, 0x0a, 0x24, 0x61, 0x69, 0x70, 0x6c, 0x61, 0x74, 880 0x66, 0x6f, 0x72, 0x6d, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2e, 881 0x63, 0x6f, 0x6d, 0x2f, 0x45, 0x6e, 0x74, 0x69, 0x74, 0x79, 0x54, 0x79, 0x70, 0x65, 0x52, 0x0a, 882 0x65, 0x6e, 0x74, 0x69, 0x74, 0x79, 0x54, 0x79, 0x70, 0x65, 0x12, 0x7d, 0x0a, 0x13, 0x66, 0x65, 883 0x61, 0x74, 0x75, 0x72, 0x65, 0x5f, 0x64, 0x65, 0x73, 0x63, 0x72, 0x69, 0x70, 0x74, 0x6f, 0x72, 884 0x73, 0x18, 0x02, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x4c, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 885 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x61, 0x69, 0x70, 0x6c, 0x61, 0x74, 0x66, 0x6f, 0x72, 886 0x6d, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 0x2e, 0x52, 0x65, 0x61, 0x64, 0x46, 0x65, 887 0x61, 0x74, 0x75, 0x72, 0x65, 0x56, 0x61, 0x6c, 0x75, 0x65, 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 888 0x6e, 0x73, 0x65, 0x2e, 0x46, 0x65, 0x61, 0x74, 0x75, 0x72, 0x65, 0x44, 0x65, 0x73, 0x63, 0x72, 889 0x69, 0x70, 0x74, 0x6f, 0x72, 0x52, 0x12, 0x66, 0x65, 0x61, 0x74, 0x75, 0x72, 0x65, 0x44, 0x65, 890 0x73, 0x63, 0x72, 0x69, 0x70, 0x74, 0x6f, 0x72, 0x73, 0x1a, 0xae, 0x02, 0x0a, 0x0a, 0x45, 0x6e, 891 0x74, 0x69, 0x74, 0x79, 0x56, 0x69, 0x65, 0x77, 0x12, 0x1b, 0x0a, 0x09, 0x65, 0x6e, 0x74, 0x69, 892 0x74, 0x79, 0x5f, 0x69, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x08, 0x65, 0x6e, 0x74, 893 0x69, 0x74, 0x79, 0x49, 0x64, 0x12, 0x5e, 0x0a, 0x04, 0x64, 0x61, 0x74, 0x61, 0x18, 0x02, 0x20, 894 0x03, 0x28, 0x0b, 0x32, 0x4a, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 895 0x75, 0x64, 0x2e, 0x61, 0x69, 0x70, 0x6c, 0x61, 0x74, 0x66, 0x6f, 0x72, 0x6d, 0x2e, 0x76, 0x31, 896 0x62, 0x65, 0x74, 0x61, 0x31, 0x2e, 0x52, 0x65, 0x61, 0x64, 0x46, 0x65, 0x61, 0x74, 0x75, 0x72, 897 0x65, 0x56, 0x61, 0x6c, 0x75, 0x65, 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x2e, 898 0x45, 0x6e, 0x74, 0x69, 0x74, 0x79, 0x56, 0x69, 0x65, 0x77, 0x2e, 0x44, 0x61, 0x74, 0x61, 0x52, 899 0x04, 0x64, 0x61, 0x74, 0x61, 0x1a, 0xa2, 0x01, 0x0a, 0x04, 0x44, 0x61, 0x74, 0x61, 0x12, 0x45, 900 0x0a, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x2d, 0x2e, 901 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x61, 0x69, 0x70, 902 0x6c, 0x61, 0x74, 0x66, 0x6f, 0x72, 0x6d, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 0x2e, 903 0x46, 0x65, 0x61, 0x74, 0x75, 0x72, 0x65, 0x56, 0x61, 0x6c, 0x75, 0x65, 0x48, 0x00, 0x52, 0x05, 904 0x76, 0x61, 0x6c, 0x75, 0x65, 0x12, 0x4b, 0x0a, 0x06, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x73, 0x18, 905 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x31, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 906 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x61, 0x69, 0x70, 0x6c, 0x61, 0x74, 0x66, 0x6f, 0x72, 0x6d, 0x2e, 907 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 0x2e, 0x46, 0x65, 0x61, 0x74, 0x75, 0x72, 0x65, 0x56, 908 0x61, 0x6c, 0x75, 0x65, 0x4c, 0x69, 0x73, 0x74, 0x48, 0x00, 0x52, 0x06, 0x76, 0x61, 0x6c, 0x75, 909 0x65, 0x73, 0x42, 0x06, 0x0a, 0x04, 0x64, 0x61, 0x74, 0x61, 0x22, 0xf8, 0x01, 0x0a, 0x21, 0x53, 910 0x74, 0x72, 0x65, 0x61, 0x6d, 0x69, 0x6e, 0x67, 0x52, 0x65, 0x61, 0x64, 0x46, 0x65, 0x61, 0x74, 911 0x75, 0x72, 0x65, 0x56, 0x61, 0x6c, 0x75, 0x65, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 912 0x12, 0x4d, 0x0a, 0x0b, 0x65, 0x6e, 0x74, 0x69, 0x74, 0x79, 0x5f, 0x74, 0x79, 0x70, 0x65, 0x18, 913 0x01, 0x20, 0x01, 0x28, 0x09, 0x42, 0x2c, 0xe0, 0x41, 0x02, 0xfa, 0x41, 0x26, 0x0a, 0x24, 0x61, 914 0x69, 0x70, 0x6c, 0x61, 0x74, 0x66, 0x6f, 0x72, 0x6d, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 915 0x61, 0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x45, 0x6e, 0x74, 0x69, 0x74, 0x79, 0x54, 916 0x79, 0x70, 0x65, 0x52, 0x0a, 0x65, 0x6e, 0x74, 0x69, 0x74, 0x79, 0x54, 0x79, 0x70, 0x65, 0x12, 917 0x22, 0x0a, 0x0a, 0x65, 0x6e, 0x74, 0x69, 0x74, 0x79, 0x5f, 0x69, 0x64, 0x73, 0x18, 0x02, 0x20, 918 0x03, 0x28, 0x09, 0x42, 0x03, 0xe0, 0x41, 0x02, 0x52, 0x09, 0x65, 0x6e, 0x74, 0x69, 0x74, 0x79, 919 0x49, 0x64, 0x73, 0x12, 0x60, 0x0a, 0x10, 0x66, 0x65, 0x61, 0x74, 0x75, 0x72, 0x65, 0x5f, 0x73, 920 0x65, 0x6c, 0x65, 0x63, 0x74, 0x6f, 0x72, 0x18, 0x03, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x30, 0x2e, 921 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x61, 0x69, 0x70, 922 0x6c, 0x61, 0x74, 0x66, 0x6f, 0x72, 0x6d, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 0x2e, 923 0x46, 0x65, 0x61, 0x74, 0x75, 0x72, 0x65, 0x53, 0x65, 0x6c, 0x65, 0x63, 0x74, 0x6f, 0x72, 0x42, 924 0x03, 0xe0, 0x41, 0x02, 0x52, 0x0f, 0x66, 0x65, 0x61, 0x74, 0x75, 0x72, 0x65, 0x53, 0x65, 0x6c, 925 0x65, 0x63, 0x74, 0x6f, 0x72, 0x22, 0xdd, 0x05, 0x0a, 0x0c, 0x46, 0x65, 0x61, 0x74, 0x75, 0x72, 926 0x65, 0x56, 0x61, 0x6c, 0x75, 0x65, 0x12, 0x1f, 0x0a, 0x0a, 0x62, 0x6f, 0x6f, 0x6c, 0x5f, 0x76, 927 0x61, 0x6c, 0x75, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x08, 0x48, 0x00, 0x52, 0x09, 0x62, 0x6f, 928 0x6f, 0x6c, 0x56, 0x61, 0x6c, 0x75, 0x65, 0x12, 0x23, 0x0a, 0x0c, 0x64, 0x6f, 0x75, 0x62, 0x6c, 929 0x65, 0x5f, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x01, 0x48, 0x00, 0x52, 930 0x0b, 0x64, 0x6f, 0x75, 0x62, 0x6c, 0x65, 0x56, 0x61, 0x6c, 0x75, 0x65, 0x12, 0x21, 0x0a, 0x0b, 931 0x69, 0x6e, 0x74, 0x36, 0x34, 0x5f, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x18, 0x05, 0x20, 0x01, 0x28, 932 0x03, 0x48, 0x00, 0x52, 0x0a, 0x69, 0x6e, 0x74, 0x36, 0x34, 0x56, 0x61, 0x6c, 0x75, 0x65, 0x12, 933 0x23, 0x0a, 0x0c, 0x73, 0x74, 0x72, 0x69, 0x6e, 0x67, 0x5f, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x18, 934 0x06, 0x20, 0x01, 0x28, 0x09, 0x48, 0x00, 0x52, 0x0b, 0x73, 0x74, 0x72, 0x69, 0x6e, 0x67, 0x56, 935 0x61, 0x6c, 0x75, 0x65, 0x12, 0x56, 0x0a, 0x10, 0x62, 0x6f, 0x6f, 0x6c, 0x5f, 0x61, 0x72, 0x72, 936 0x61, 0x79, 0x5f, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x18, 0x07, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x2a, 937 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x61, 0x69, 938 0x70, 0x6c, 0x61, 0x74, 0x66, 0x6f, 0x72, 0x6d, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 939 0x2e, 0x42, 0x6f, 0x6f, 0x6c, 0x41, 0x72, 0x72, 0x61, 0x79, 0x48, 0x00, 0x52, 0x0e, 0x62, 0x6f, 940 0x6f, 0x6c, 0x41, 0x72, 0x72, 0x61, 0x79, 0x56, 0x61, 0x6c, 0x75, 0x65, 0x12, 0x5c, 0x0a, 0x12, 941 0x64, 0x6f, 0x75, 0x62, 0x6c, 0x65, 0x5f, 0x61, 0x72, 0x72, 0x61, 0x79, 0x5f, 0x76, 0x61, 0x6c, 942 0x75, 0x65, 0x18, 0x08, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x2c, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 943 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x61, 0x69, 0x70, 0x6c, 0x61, 0x74, 0x66, 0x6f, 944 0x72, 0x6d, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 0x2e, 0x44, 0x6f, 0x75, 0x62, 0x6c, 945 0x65, 0x41, 0x72, 0x72, 0x61, 0x79, 0x48, 0x00, 0x52, 0x10, 0x64, 0x6f, 0x75, 0x62, 0x6c, 0x65, 946 0x41, 0x72, 0x72, 0x61, 0x79, 0x56, 0x61, 0x6c, 0x75, 0x65, 0x12, 0x59, 0x0a, 0x11, 0x69, 0x6e, 947 0x74, 0x36, 0x34, 0x5f, 0x61, 0x72, 0x72, 0x61, 0x79, 0x5f, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x18, 948 0x0b, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x2b, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 949 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x61, 0x69, 0x70, 0x6c, 0x61, 0x74, 0x66, 0x6f, 0x72, 0x6d, 0x2e, 950 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 0x2e, 0x49, 0x6e, 0x74, 0x36, 0x34, 0x41, 0x72, 0x72, 951 0x61, 0x79, 0x48, 0x00, 0x52, 0x0f, 0x69, 0x6e, 0x74, 0x36, 0x34, 0x41, 0x72, 0x72, 0x61, 0x79, 952 0x56, 0x61, 0x6c, 0x75, 0x65, 0x12, 0x5c, 0x0a, 0x12, 0x73, 0x74, 0x72, 0x69, 0x6e, 0x67, 0x5f, 953 0x61, 0x72, 0x72, 0x61, 0x79, 0x5f, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x18, 0x0c, 0x20, 0x01, 0x28, 954 0x0b, 0x32, 0x2c, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 955 0x2e, 0x61, 0x69, 0x70, 0x6c, 0x61, 0x74, 0x66, 0x6f, 0x72, 0x6d, 0x2e, 0x76, 0x31, 0x62, 0x65, 956 0x74, 0x61, 0x31, 0x2e, 0x53, 0x74, 0x72, 0x69, 0x6e, 0x67, 0x41, 0x72, 0x72, 0x61, 0x79, 0x48, 957 0x00, 0x52, 0x10, 0x73, 0x74, 0x72, 0x69, 0x6e, 0x67, 0x41, 0x72, 0x72, 0x61, 0x79, 0x56, 0x61, 958 0x6c, 0x75, 0x65, 0x12, 0x21, 0x0a, 0x0b, 0x62, 0x79, 0x74, 0x65, 0x73, 0x5f, 0x76, 0x61, 0x6c, 959 0x75, 0x65, 0x18, 0x0d, 0x20, 0x01, 0x28, 0x0c, 0x48, 0x00, 0x52, 0x0a, 0x62, 0x79, 0x74, 0x65, 960 0x73, 0x56, 0x61, 0x6c, 0x75, 0x65, 0x12, 0x57, 0x0a, 0x08, 0x6d, 0x65, 0x74, 0x61, 0x64, 0x61, 961 0x74, 0x61, 0x18, 0x0e, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x36, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 962 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x61, 0x69, 0x70, 0x6c, 0x61, 0x74, 0x66, 0x6f, 963 0x72, 0x6d, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 0x2e, 0x46, 0x65, 0x61, 0x74, 0x75, 964 0x72, 0x65, 0x56, 0x61, 0x6c, 0x75, 0x65, 0x2e, 0x4d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 965 0x42, 0x03, 0xe0, 0x41, 0x03, 0x52, 0x08, 0x6d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0x1a, 966 0x4b, 0x0a, 0x08, 0x4d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0x12, 0x3f, 0x0a, 0x0d, 0x67, 967 0x65, 0x6e, 0x65, 0x72, 0x61, 0x74, 0x65, 0x5f, 0x74, 0x69, 0x6d, 0x65, 0x18, 0x01, 0x20, 0x01, 968 0x28, 0x0b, 0x32, 0x1a, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 969 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x54, 0x69, 0x6d, 0x65, 0x73, 0x74, 0x61, 0x6d, 0x70, 0x52, 0x0c, 970 0x67, 0x65, 0x6e, 0x65, 0x72, 0x61, 0x74, 0x65, 0x54, 0x69, 0x6d, 0x65, 0x42, 0x07, 0x0a, 0x05, 971 0x76, 0x61, 0x6c, 0x75, 0x65, 0x22, 0x59, 0x0a, 0x10, 0x46, 0x65, 0x61, 0x74, 0x75, 0x72, 0x65, 972 0x56, 0x61, 0x6c, 0x75, 0x65, 0x4c, 0x69, 0x73, 0x74, 0x12, 0x45, 0x0a, 0x06, 0x76, 0x61, 0x6c, 973 0x75, 0x65, 0x73, 0x18, 0x01, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x2d, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 974 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x61, 0x69, 0x70, 0x6c, 0x61, 0x74, 0x66, 975 0x6f, 0x72, 0x6d, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 0x2e, 0x46, 0x65, 0x61, 0x74, 976 0x75, 0x72, 0x65, 0x56, 0x61, 0x6c, 0x75, 0x65, 0x52, 0x06, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x73, 977 0x32, 0x98, 0x05, 0x0a, 0x20, 0x46, 0x65, 0x61, 0x74, 0x75, 0x72, 0x65, 0x73, 0x74, 0x6f, 0x72, 978 0x65, 0x4f, 0x6e, 0x6c, 0x69, 0x6e, 0x65, 0x53, 0x65, 0x72, 0x76, 0x69, 0x6e, 0x67, 0x53, 0x65, 979 0x72, 0x76, 0x69, 0x63, 0x65, 0x12, 0x82, 0x02, 0x0a, 0x11, 0x52, 0x65, 0x61, 0x64, 0x46, 0x65, 980 0x61, 0x74, 0x75, 0x72, 0x65, 0x56, 0x61, 0x6c, 0x75, 0x65, 0x73, 0x12, 0x39, 0x2e, 0x67, 0x6f, 981 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x61, 0x69, 0x70, 0x6c, 0x61, 982 0x74, 0x66, 0x6f, 0x72, 0x6d, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 0x2e, 0x52, 0x65, 983 0x61, 0x64, 0x46, 0x65, 0x61, 0x74, 0x75, 0x72, 0x65, 0x56, 0x61, 0x6c, 0x75, 0x65, 0x73, 0x52, 984 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x3a, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 985 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x61, 0x69, 0x70, 0x6c, 0x61, 0x74, 0x66, 0x6f, 0x72, 0x6d, 986 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 0x2e, 0x52, 0x65, 0x61, 0x64, 0x46, 0x65, 0x61, 987 0x74, 0x75, 0x72, 0x65, 0x56, 0x61, 0x6c, 0x75, 0x65, 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 988 0x73, 0x65, 0x22, 0x76, 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x62, 0x22, 0x5d, 0x2f, 0x76, 0x31, 0x62, 989 0x65, 0x74, 0x61, 0x31, 0x2f, 0x7b, 0x65, 0x6e, 0x74, 0x69, 0x74, 0x79, 0x5f, 0x74, 0x79, 0x70, 990 0x65, 0x3d, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x73, 0x2f, 0x2a, 0x2f, 0x6c, 0x6f, 0x63, 991 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x2a, 0x2f, 0x66, 0x65, 0x61, 0x74, 0x75, 0x72, 0x65, 992 0x73, 0x74, 0x6f, 0x72, 0x65, 0x73, 0x2f, 0x2a, 0x2f, 0x65, 0x6e, 0x74, 0x69, 0x74, 0x79, 0x54, 993 0x79, 0x70, 0x65, 0x73, 0x2f, 0x2a, 0x7d, 0x3a, 0x72, 0x65, 0x61, 0x64, 0x46, 0x65, 0x61, 0x74, 994 0x75, 0x72, 0x65, 0x56, 0x61, 0x6c, 0x75, 0x65, 0x73, 0x3a, 0x01, 0x2a, 0xda, 0x41, 0x0b, 0x65, 995 0x6e, 0x74, 0x69, 0x74, 0x79, 0x5f, 0x74, 0x79, 0x70, 0x65, 0x12, 0x9f, 0x02, 0x0a, 0x1a, 0x53, 996 0x74, 0x72, 0x65, 0x61, 0x6d, 0x69, 0x6e, 0x67, 0x52, 0x65, 0x61, 0x64, 0x46, 0x65, 0x61, 0x74, 997 0x75, 0x72, 0x65, 0x56, 0x61, 0x6c, 0x75, 0x65, 0x73, 0x12, 0x42, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 998 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x61, 0x69, 0x70, 0x6c, 0x61, 0x74, 0x66, 999 0x6f, 0x72, 0x6d, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 0x2e, 0x53, 0x74, 0x72, 0x65, 1000 0x61, 0x6d, 0x69, 0x6e, 0x67, 0x52, 0x65, 0x61, 0x64, 0x46, 0x65, 0x61, 0x74, 0x75, 0x72, 0x65, 1001 0x56, 0x61, 0x6c, 0x75, 0x65, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x3a, 0x2e, 1002 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x61, 0x69, 0x70, 1003 0x6c, 0x61, 0x74, 0x66, 0x6f, 0x72, 0x6d, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 0x2e, 1004 0x52, 0x65, 0x61, 0x64, 0x46, 0x65, 0x61, 0x74, 0x75, 0x72, 0x65, 0x56, 0x61, 0x6c, 0x75, 0x65, 1005 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x7f, 0x82, 0xd3, 0xe4, 0x93, 0x02, 1006 0x6b, 0x22, 0x66, 0x2f, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 0x2f, 0x7b, 0x65, 0x6e, 0x74, 1007 0x69, 0x74, 0x79, 0x5f, 0x74, 0x79, 0x70, 0x65, 0x3d, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 1008 0x73, 0x2f, 0x2a, 0x2f, 0x6c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x2a, 0x2f, 1009 0x66, 0x65, 0x61, 0x74, 0x75, 0x72, 0x65, 0x73, 0x74, 0x6f, 0x72, 0x65, 0x73, 0x2f, 0x2a, 0x2f, 1010 0x65, 0x6e, 0x74, 0x69, 0x74, 0x79, 0x54, 0x79, 0x70, 0x65, 0x73, 0x2f, 0x2a, 0x7d, 0x3a, 0x73, 1011 0x74, 0x72, 0x65, 0x61, 0x6d, 0x69, 0x6e, 0x67, 0x52, 0x65, 0x61, 0x64, 0x46, 0x65, 0x61, 0x74, 1012 0x75, 0x72, 0x65, 0x56, 0x61, 0x6c, 0x75, 0x65, 0x73, 0x3a, 0x01, 0x2a, 0xda, 0x41, 0x0b, 0x65, 1013 0x6e, 0x74, 0x69, 0x74, 0x79, 0x5f, 0x74, 0x79, 0x70, 0x65, 0x30, 0x01, 0x1a, 0x4d, 0xca, 0x41, 1014 0x19, 0x61, 0x69, 0x70, 0x6c, 0x61, 0x74, 0x66, 0x6f, 0x72, 0x6d, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 1015 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f, 0x6d, 0xd2, 0x41, 0x2e, 0x68, 0x74, 0x74, 1016 0x70, 0x73, 0x3a, 0x2f, 0x2f, 0x77, 0x77, 0x77, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 1017 0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x61, 0x75, 0x74, 0x68, 0x2f, 0x63, 0x6c, 0x6f, 1018 0x75, 0x64, 0x2d, 0x70, 0x6c, 0x61, 0x74, 0x66, 0x6f, 0x72, 0x6d, 0x42, 0x92, 0x01, 0x0a, 0x23, 1019 0x63, 0x6f, 0x6d, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 1020 0x2e, 0x61, 0x69, 0x70, 0x6c, 0x61, 0x74, 0x66, 0x6f, 0x72, 0x6d, 0x2e, 0x76, 0x31, 0x62, 0x65, 1021 0x74, 0x61, 0x31, 0x42, 0x1e, 0x46, 0x65, 0x61, 0x74, 0x75, 0x72, 0x65, 0x73, 0x74, 0x6f, 0x72, 1022 0x65, 0x4f, 0x6e, 0x6c, 0x69, 0x6e, 0x65, 0x53, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x50, 0x72, 1023 0x6f, 0x74, 0x6f, 0x50, 0x01, 0x5a, 0x49, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x67, 0x6f, 1024 0x6c, 0x61, 0x6e, 0x67, 0x2e, 0x6f, 0x72, 0x67, 0x2f, 0x67, 0x65, 0x6e, 0x70, 0x72, 0x6f, 0x74, 1025 0x6f, 0x2f, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2f, 0x63, 0x6c, 0x6f, 1026 0x75, 0x64, 0x2f, 0x61, 0x69, 0x70, 0x6c, 0x61, 0x74, 0x66, 0x6f, 0x72, 0x6d, 0x2f, 0x76, 0x31, 1027 0x62, 0x65, 0x74, 0x61, 0x31, 0x3b, 0x61, 0x69, 0x70, 0x6c, 0x61, 0x74, 0x66, 0x6f, 0x72, 0x6d, 1028 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33, 1029} 1030 1031var ( 1032 file_google_cloud_aiplatform_v1beta1_featurestore_online_service_proto_rawDescOnce sync.Once 1033 file_google_cloud_aiplatform_v1beta1_featurestore_online_service_proto_rawDescData = file_google_cloud_aiplatform_v1beta1_featurestore_online_service_proto_rawDesc 1034) 1035 1036func file_google_cloud_aiplatform_v1beta1_featurestore_online_service_proto_rawDescGZIP() []byte { 1037 file_google_cloud_aiplatform_v1beta1_featurestore_online_service_proto_rawDescOnce.Do(func() { 1038 file_google_cloud_aiplatform_v1beta1_featurestore_online_service_proto_rawDescData = protoimpl.X.CompressGZIP(file_google_cloud_aiplatform_v1beta1_featurestore_online_service_proto_rawDescData) 1039 }) 1040 return file_google_cloud_aiplatform_v1beta1_featurestore_online_service_proto_rawDescData 1041} 1042 1043var file_google_cloud_aiplatform_v1beta1_featurestore_online_service_proto_msgTypes = make([]protoimpl.MessageInfo, 10) 1044var file_google_cloud_aiplatform_v1beta1_featurestore_online_service_proto_goTypes = []interface{}{ 1045 (*ReadFeatureValuesRequest)(nil), // 0: google.cloud.aiplatform.v1beta1.ReadFeatureValuesRequest 1046 (*ReadFeatureValuesResponse)(nil), // 1: google.cloud.aiplatform.v1beta1.ReadFeatureValuesResponse 1047 (*StreamingReadFeatureValuesRequest)(nil), // 2: google.cloud.aiplatform.v1beta1.StreamingReadFeatureValuesRequest 1048 (*FeatureValue)(nil), // 3: google.cloud.aiplatform.v1beta1.FeatureValue 1049 (*FeatureValueList)(nil), // 4: google.cloud.aiplatform.v1beta1.FeatureValueList 1050 (*ReadFeatureValuesResponse_FeatureDescriptor)(nil), // 5: google.cloud.aiplatform.v1beta1.ReadFeatureValuesResponse.FeatureDescriptor 1051 (*ReadFeatureValuesResponse_Header)(nil), // 6: google.cloud.aiplatform.v1beta1.ReadFeatureValuesResponse.Header 1052 (*ReadFeatureValuesResponse_EntityView)(nil), // 7: google.cloud.aiplatform.v1beta1.ReadFeatureValuesResponse.EntityView 1053 (*ReadFeatureValuesResponse_EntityView_Data)(nil), // 8: google.cloud.aiplatform.v1beta1.ReadFeatureValuesResponse.EntityView.Data 1054 (*FeatureValue_Metadata)(nil), // 9: google.cloud.aiplatform.v1beta1.FeatureValue.Metadata 1055 (*FeatureSelector)(nil), // 10: google.cloud.aiplatform.v1beta1.FeatureSelector 1056 (*BoolArray)(nil), // 11: google.cloud.aiplatform.v1beta1.BoolArray 1057 (*DoubleArray)(nil), // 12: google.cloud.aiplatform.v1beta1.DoubleArray 1058 (*Int64Array)(nil), // 13: google.cloud.aiplatform.v1beta1.Int64Array 1059 (*StringArray)(nil), // 14: google.cloud.aiplatform.v1beta1.StringArray 1060 (*timestamppb.Timestamp)(nil), // 15: google.protobuf.Timestamp 1061} 1062var file_google_cloud_aiplatform_v1beta1_featurestore_online_service_proto_depIdxs = []int32{ 1063 10, // 0: google.cloud.aiplatform.v1beta1.ReadFeatureValuesRequest.feature_selector:type_name -> google.cloud.aiplatform.v1beta1.FeatureSelector 1064 6, // 1: google.cloud.aiplatform.v1beta1.ReadFeatureValuesResponse.header:type_name -> google.cloud.aiplatform.v1beta1.ReadFeatureValuesResponse.Header 1065 7, // 2: google.cloud.aiplatform.v1beta1.ReadFeatureValuesResponse.entity_view:type_name -> google.cloud.aiplatform.v1beta1.ReadFeatureValuesResponse.EntityView 1066 10, // 3: google.cloud.aiplatform.v1beta1.StreamingReadFeatureValuesRequest.feature_selector:type_name -> google.cloud.aiplatform.v1beta1.FeatureSelector 1067 11, // 4: google.cloud.aiplatform.v1beta1.FeatureValue.bool_array_value:type_name -> google.cloud.aiplatform.v1beta1.BoolArray 1068 12, // 5: google.cloud.aiplatform.v1beta1.FeatureValue.double_array_value:type_name -> google.cloud.aiplatform.v1beta1.DoubleArray 1069 13, // 6: google.cloud.aiplatform.v1beta1.FeatureValue.int64_array_value:type_name -> google.cloud.aiplatform.v1beta1.Int64Array 1070 14, // 7: google.cloud.aiplatform.v1beta1.FeatureValue.string_array_value:type_name -> google.cloud.aiplatform.v1beta1.StringArray 1071 9, // 8: google.cloud.aiplatform.v1beta1.FeatureValue.metadata:type_name -> google.cloud.aiplatform.v1beta1.FeatureValue.Metadata 1072 3, // 9: google.cloud.aiplatform.v1beta1.FeatureValueList.values:type_name -> google.cloud.aiplatform.v1beta1.FeatureValue 1073 5, // 10: google.cloud.aiplatform.v1beta1.ReadFeatureValuesResponse.Header.feature_descriptors:type_name -> google.cloud.aiplatform.v1beta1.ReadFeatureValuesResponse.FeatureDescriptor 1074 8, // 11: google.cloud.aiplatform.v1beta1.ReadFeatureValuesResponse.EntityView.data:type_name -> google.cloud.aiplatform.v1beta1.ReadFeatureValuesResponse.EntityView.Data 1075 3, // 12: google.cloud.aiplatform.v1beta1.ReadFeatureValuesResponse.EntityView.Data.value:type_name -> google.cloud.aiplatform.v1beta1.FeatureValue 1076 4, // 13: google.cloud.aiplatform.v1beta1.ReadFeatureValuesResponse.EntityView.Data.values:type_name -> google.cloud.aiplatform.v1beta1.FeatureValueList 1077 15, // 14: google.cloud.aiplatform.v1beta1.FeatureValue.Metadata.generate_time:type_name -> google.protobuf.Timestamp 1078 0, // 15: google.cloud.aiplatform.v1beta1.FeaturestoreOnlineServingService.ReadFeatureValues:input_type -> google.cloud.aiplatform.v1beta1.ReadFeatureValuesRequest 1079 2, // 16: google.cloud.aiplatform.v1beta1.FeaturestoreOnlineServingService.StreamingReadFeatureValues:input_type -> google.cloud.aiplatform.v1beta1.StreamingReadFeatureValuesRequest 1080 1, // 17: google.cloud.aiplatform.v1beta1.FeaturestoreOnlineServingService.ReadFeatureValues:output_type -> google.cloud.aiplatform.v1beta1.ReadFeatureValuesResponse 1081 1, // 18: google.cloud.aiplatform.v1beta1.FeaturestoreOnlineServingService.StreamingReadFeatureValues:output_type -> google.cloud.aiplatform.v1beta1.ReadFeatureValuesResponse 1082 17, // [17:19] is the sub-list for method output_type 1083 15, // [15:17] is the sub-list for method input_type 1084 15, // [15:15] is the sub-list for extension type_name 1085 15, // [15:15] is the sub-list for extension extendee 1086 0, // [0:15] is the sub-list for field type_name 1087} 1088 1089func init() { file_google_cloud_aiplatform_v1beta1_featurestore_online_service_proto_init() } 1090func file_google_cloud_aiplatform_v1beta1_featurestore_online_service_proto_init() { 1091 if File_google_cloud_aiplatform_v1beta1_featurestore_online_service_proto != nil { 1092 return 1093 } 1094 file_google_cloud_aiplatform_v1beta1_feature_selector_proto_init() 1095 file_google_cloud_aiplatform_v1beta1_types_proto_init() 1096 if !protoimpl.UnsafeEnabled { 1097 file_google_cloud_aiplatform_v1beta1_featurestore_online_service_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} { 1098 switch v := v.(*ReadFeatureValuesRequest); i { 1099 case 0: 1100 return &v.state 1101 case 1: 1102 return &v.sizeCache 1103 case 2: 1104 return &v.unknownFields 1105 default: 1106 return nil 1107 } 1108 } 1109 file_google_cloud_aiplatform_v1beta1_featurestore_online_service_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} { 1110 switch v := v.(*ReadFeatureValuesResponse); i { 1111 case 0: 1112 return &v.state 1113 case 1: 1114 return &v.sizeCache 1115 case 2: 1116 return &v.unknownFields 1117 default: 1118 return nil 1119 } 1120 } 1121 file_google_cloud_aiplatform_v1beta1_featurestore_online_service_proto_msgTypes[2].Exporter = func(v interface{}, i int) interface{} { 1122 switch v := v.(*StreamingReadFeatureValuesRequest); i { 1123 case 0: 1124 return &v.state 1125 case 1: 1126 return &v.sizeCache 1127 case 2: 1128 return &v.unknownFields 1129 default: 1130 return nil 1131 } 1132 } 1133 file_google_cloud_aiplatform_v1beta1_featurestore_online_service_proto_msgTypes[3].Exporter = func(v interface{}, i int) interface{} { 1134 switch v := v.(*FeatureValue); i { 1135 case 0: 1136 return &v.state 1137 case 1: 1138 return &v.sizeCache 1139 case 2: 1140 return &v.unknownFields 1141 default: 1142 return nil 1143 } 1144 } 1145 file_google_cloud_aiplatform_v1beta1_featurestore_online_service_proto_msgTypes[4].Exporter = func(v interface{}, i int) interface{} { 1146 switch v := v.(*FeatureValueList); i { 1147 case 0: 1148 return &v.state 1149 case 1: 1150 return &v.sizeCache 1151 case 2: 1152 return &v.unknownFields 1153 default: 1154 return nil 1155 } 1156 } 1157 file_google_cloud_aiplatform_v1beta1_featurestore_online_service_proto_msgTypes[5].Exporter = func(v interface{}, i int) interface{} { 1158 switch v := v.(*ReadFeatureValuesResponse_FeatureDescriptor); i { 1159 case 0: 1160 return &v.state 1161 case 1: 1162 return &v.sizeCache 1163 case 2: 1164 return &v.unknownFields 1165 default: 1166 return nil 1167 } 1168 } 1169 file_google_cloud_aiplatform_v1beta1_featurestore_online_service_proto_msgTypes[6].Exporter = func(v interface{}, i int) interface{} { 1170 switch v := v.(*ReadFeatureValuesResponse_Header); i { 1171 case 0: 1172 return &v.state 1173 case 1: 1174 return &v.sizeCache 1175 case 2: 1176 return &v.unknownFields 1177 default: 1178 return nil 1179 } 1180 } 1181 file_google_cloud_aiplatform_v1beta1_featurestore_online_service_proto_msgTypes[7].Exporter = func(v interface{}, i int) interface{} { 1182 switch v := v.(*ReadFeatureValuesResponse_EntityView); i { 1183 case 0: 1184 return &v.state 1185 case 1: 1186 return &v.sizeCache 1187 case 2: 1188 return &v.unknownFields 1189 default: 1190 return nil 1191 } 1192 } 1193 file_google_cloud_aiplatform_v1beta1_featurestore_online_service_proto_msgTypes[8].Exporter = func(v interface{}, i int) interface{} { 1194 switch v := v.(*ReadFeatureValuesResponse_EntityView_Data); i { 1195 case 0: 1196 return &v.state 1197 case 1: 1198 return &v.sizeCache 1199 case 2: 1200 return &v.unknownFields 1201 default: 1202 return nil 1203 } 1204 } 1205 file_google_cloud_aiplatform_v1beta1_featurestore_online_service_proto_msgTypes[9].Exporter = func(v interface{}, i int) interface{} { 1206 switch v := v.(*FeatureValue_Metadata); i { 1207 case 0: 1208 return &v.state 1209 case 1: 1210 return &v.sizeCache 1211 case 2: 1212 return &v.unknownFields 1213 default: 1214 return nil 1215 } 1216 } 1217 } 1218 file_google_cloud_aiplatform_v1beta1_featurestore_online_service_proto_msgTypes[3].OneofWrappers = []interface{}{ 1219 (*FeatureValue_BoolValue)(nil), 1220 (*FeatureValue_DoubleValue)(nil), 1221 (*FeatureValue_Int64Value)(nil), 1222 (*FeatureValue_StringValue)(nil), 1223 (*FeatureValue_BoolArrayValue)(nil), 1224 (*FeatureValue_DoubleArrayValue)(nil), 1225 (*FeatureValue_Int64ArrayValue)(nil), 1226 (*FeatureValue_StringArrayValue)(nil), 1227 (*FeatureValue_BytesValue)(nil), 1228 } 1229 file_google_cloud_aiplatform_v1beta1_featurestore_online_service_proto_msgTypes[8].OneofWrappers = []interface{}{ 1230 (*ReadFeatureValuesResponse_EntityView_Data_Value)(nil), 1231 (*ReadFeatureValuesResponse_EntityView_Data_Values)(nil), 1232 } 1233 type x struct{} 1234 out := protoimpl.TypeBuilder{ 1235 File: protoimpl.DescBuilder{ 1236 GoPackagePath: reflect.TypeOf(x{}).PkgPath(), 1237 RawDescriptor: file_google_cloud_aiplatform_v1beta1_featurestore_online_service_proto_rawDesc, 1238 NumEnums: 0, 1239 NumMessages: 10, 1240 NumExtensions: 0, 1241 NumServices: 1, 1242 }, 1243 GoTypes: file_google_cloud_aiplatform_v1beta1_featurestore_online_service_proto_goTypes, 1244 DependencyIndexes: file_google_cloud_aiplatform_v1beta1_featurestore_online_service_proto_depIdxs, 1245 MessageInfos: file_google_cloud_aiplatform_v1beta1_featurestore_online_service_proto_msgTypes, 1246 }.Build() 1247 File_google_cloud_aiplatform_v1beta1_featurestore_online_service_proto = out.File 1248 file_google_cloud_aiplatform_v1beta1_featurestore_online_service_proto_rawDesc = nil 1249 file_google_cloud_aiplatform_v1beta1_featurestore_online_service_proto_goTypes = nil 1250 file_google_cloud_aiplatform_v1beta1_featurestore_online_service_proto_depIdxs = nil 1251} 1252 1253// Reference imports to suppress errors if they are not otherwise used. 1254var _ context.Context 1255var _ grpc.ClientConnInterface 1256 1257// This is a compile-time assertion to ensure that this generated file 1258// is compatible with the grpc package it is being compiled against. 1259const _ = grpc.SupportPackageIsVersion6 1260 1261// FeaturestoreOnlineServingServiceClient is the client API for FeaturestoreOnlineServingService service. 1262// 1263// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream. 1264type FeaturestoreOnlineServingServiceClient interface { 1265 // Reads Feature values of a specific entity of an EntityType. For reading 1266 // feature values of multiple entities of an EntityType, please use 1267 // StreamingReadFeatureValues. 1268 ReadFeatureValues(ctx context.Context, in *ReadFeatureValuesRequest, opts ...grpc.CallOption) (*ReadFeatureValuesResponse, error) 1269 // Reads Feature values for multiple entities. Depending on their size, data 1270 // for different entities may be broken 1271 // up across multiple responses. 1272 StreamingReadFeatureValues(ctx context.Context, in *StreamingReadFeatureValuesRequest, opts ...grpc.CallOption) (FeaturestoreOnlineServingService_StreamingReadFeatureValuesClient, error) 1273} 1274 1275type featurestoreOnlineServingServiceClient struct { 1276 cc grpc.ClientConnInterface 1277} 1278 1279func NewFeaturestoreOnlineServingServiceClient(cc grpc.ClientConnInterface) FeaturestoreOnlineServingServiceClient { 1280 return &featurestoreOnlineServingServiceClient{cc} 1281} 1282 1283func (c *featurestoreOnlineServingServiceClient) ReadFeatureValues(ctx context.Context, in *ReadFeatureValuesRequest, opts ...grpc.CallOption) (*ReadFeatureValuesResponse, error) { 1284 out := new(ReadFeatureValuesResponse) 1285 err := c.cc.Invoke(ctx, "/google.cloud.aiplatform.v1beta1.FeaturestoreOnlineServingService/ReadFeatureValues", in, out, opts...) 1286 if err != nil { 1287 return nil, err 1288 } 1289 return out, nil 1290} 1291 1292func (c *featurestoreOnlineServingServiceClient) StreamingReadFeatureValues(ctx context.Context, in *StreamingReadFeatureValuesRequest, opts ...grpc.CallOption) (FeaturestoreOnlineServingService_StreamingReadFeatureValuesClient, error) { 1293 stream, err := c.cc.NewStream(ctx, &_FeaturestoreOnlineServingService_serviceDesc.Streams[0], "/google.cloud.aiplatform.v1beta1.FeaturestoreOnlineServingService/StreamingReadFeatureValues", opts...) 1294 if err != nil { 1295 return nil, err 1296 } 1297 x := &featurestoreOnlineServingServiceStreamingReadFeatureValuesClient{stream} 1298 if err := x.ClientStream.SendMsg(in); err != nil { 1299 return nil, err 1300 } 1301 if err := x.ClientStream.CloseSend(); err != nil { 1302 return nil, err 1303 } 1304 return x, nil 1305} 1306 1307type FeaturestoreOnlineServingService_StreamingReadFeatureValuesClient interface { 1308 Recv() (*ReadFeatureValuesResponse, error) 1309 grpc.ClientStream 1310} 1311 1312type featurestoreOnlineServingServiceStreamingReadFeatureValuesClient struct { 1313 grpc.ClientStream 1314} 1315 1316func (x *featurestoreOnlineServingServiceStreamingReadFeatureValuesClient) Recv() (*ReadFeatureValuesResponse, error) { 1317 m := new(ReadFeatureValuesResponse) 1318 if err := x.ClientStream.RecvMsg(m); err != nil { 1319 return nil, err 1320 } 1321 return m, nil 1322} 1323 1324// FeaturestoreOnlineServingServiceServer is the server API for FeaturestoreOnlineServingService service. 1325type FeaturestoreOnlineServingServiceServer interface { 1326 // Reads Feature values of a specific entity of an EntityType. For reading 1327 // feature values of multiple entities of an EntityType, please use 1328 // StreamingReadFeatureValues. 1329 ReadFeatureValues(context.Context, *ReadFeatureValuesRequest) (*ReadFeatureValuesResponse, error) 1330 // Reads Feature values for multiple entities. Depending on their size, data 1331 // for different entities may be broken 1332 // up across multiple responses. 1333 StreamingReadFeatureValues(*StreamingReadFeatureValuesRequest, FeaturestoreOnlineServingService_StreamingReadFeatureValuesServer) error 1334} 1335 1336// UnimplementedFeaturestoreOnlineServingServiceServer can be embedded to have forward compatible implementations. 1337type UnimplementedFeaturestoreOnlineServingServiceServer struct { 1338} 1339 1340func (*UnimplementedFeaturestoreOnlineServingServiceServer) ReadFeatureValues(context.Context, *ReadFeatureValuesRequest) (*ReadFeatureValuesResponse, error) { 1341 return nil, status.Errorf(codes.Unimplemented, "method ReadFeatureValues not implemented") 1342} 1343func (*UnimplementedFeaturestoreOnlineServingServiceServer) StreamingReadFeatureValues(*StreamingReadFeatureValuesRequest, FeaturestoreOnlineServingService_StreamingReadFeatureValuesServer) error { 1344 return status.Errorf(codes.Unimplemented, "method StreamingReadFeatureValues not implemented") 1345} 1346 1347func RegisterFeaturestoreOnlineServingServiceServer(s *grpc.Server, srv FeaturestoreOnlineServingServiceServer) { 1348 s.RegisterService(&_FeaturestoreOnlineServingService_serviceDesc, srv) 1349} 1350 1351func _FeaturestoreOnlineServingService_ReadFeatureValues_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 1352 in := new(ReadFeatureValuesRequest) 1353 if err := dec(in); err != nil { 1354 return nil, err 1355 } 1356 if interceptor == nil { 1357 return srv.(FeaturestoreOnlineServingServiceServer).ReadFeatureValues(ctx, in) 1358 } 1359 info := &grpc.UnaryServerInfo{ 1360 Server: srv, 1361 FullMethod: "/google.cloud.aiplatform.v1beta1.FeaturestoreOnlineServingService/ReadFeatureValues", 1362 } 1363 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 1364 return srv.(FeaturestoreOnlineServingServiceServer).ReadFeatureValues(ctx, req.(*ReadFeatureValuesRequest)) 1365 } 1366 return interceptor(ctx, in, info, handler) 1367} 1368 1369func _FeaturestoreOnlineServingService_StreamingReadFeatureValues_Handler(srv interface{}, stream grpc.ServerStream) error { 1370 m := new(StreamingReadFeatureValuesRequest) 1371 if err := stream.RecvMsg(m); err != nil { 1372 return err 1373 } 1374 return srv.(FeaturestoreOnlineServingServiceServer).StreamingReadFeatureValues(m, &featurestoreOnlineServingServiceStreamingReadFeatureValuesServer{stream}) 1375} 1376 1377type FeaturestoreOnlineServingService_StreamingReadFeatureValuesServer interface { 1378 Send(*ReadFeatureValuesResponse) error 1379 grpc.ServerStream 1380} 1381 1382type featurestoreOnlineServingServiceStreamingReadFeatureValuesServer struct { 1383 grpc.ServerStream 1384} 1385 1386func (x *featurestoreOnlineServingServiceStreamingReadFeatureValuesServer) Send(m *ReadFeatureValuesResponse) error { 1387 return x.ServerStream.SendMsg(m) 1388} 1389 1390var _FeaturestoreOnlineServingService_serviceDesc = grpc.ServiceDesc{ 1391 ServiceName: "google.cloud.aiplatform.v1beta1.FeaturestoreOnlineServingService", 1392 HandlerType: (*FeaturestoreOnlineServingServiceServer)(nil), 1393 Methods: []grpc.MethodDesc{ 1394 { 1395 MethodName: "ReadFeatureValues", 1396 Handler: _FeaturestoreOnlineServingService_ReadFeatureValues_Handler, 1397 }, 1398 }, 1399 Streams: []grpc.StreamDesc{ 1400 { 1401 StreamName: "StreamingReadFeatureValues", 1402 Handler: _FeaturestoreOnlineServingService_StreamingReadFeatureValues_Handler, 1403 ServerStreams: true, 1404 }, 1405 }, 1406 Metadata: "google/cloud/aiplatform/v1beta1/featurestore_online_service.proto", 1407} 1408