1// Copyright 2018 Google Inc. 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 18// protoc v3.13.0 19// source: google/datastore/admin/v1beta1/datastore_admin.proto 20 21package admin 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 longrunning "google.golang.org/genproto/googleapis/longrunning" 31 grpc "google.golang.org/grpc" 32 codes "google.golang.org/grpc/codes" 33 status "google.golang.org/grpc/status" 34 protoreflect "google.golang.org/protobuf/reflect/protoreflect" 35 protoimpl "google.golang.org/protobuf/runtime/protoimpl" 36 timestamppb "google.golang.org/protobuf/types/known/timestamppb" 37) 38 39const ( 40 // Verify that this generated code is sufficiently up-to-date. 41 _ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion) 42 // Verify that runtime/protoimpl is sufficiently up-to-date. 43 _ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20) 44) 45 46// This is a compile-time assertion that a sufficiently up-to-date version 47// of the legacy proto package is being used. 48const _ = proto.ProtoPackageIsVersion4 49 50// Operation types. 51type OperationType int32 52 53const ( 54 // Unspecified. 55 OperationType_OPERATION_TYPE_UNSPECIFIED OperationType = 0 56 // ExportEntities. 57 OperationType_EXPORT_ENTITIES OperationType = 1 58 // ImportEntities. 59 OperationType_IMPORT_ENTITIES OperationType = 2 60) 61 62// Enum value maps for OperationType. 63var ( 64 OperationType_name = map[int32]string{ 65 0: "OPERATION_TYPE_UNSPECIFIED", 66 1: "EXPORT_ENTITIES", 67 2: "IMPORT_ENTITIES", 68 } 69 OperationType_value = map[string]int32{ 70 "OPERATION_TYPE_UNSPECIFIED": 0, 71 "EXPORT_ENTITIES": 1, 72 "IMPORT_ENTITIES": 2, 73 } 74) 75 76func (x OperationType) Enum() *OperationType { 77 p := new(OperationType) 78 *p = x 79 return p 80} 81 82func (x OperationType) String() string { 83 return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x)) 84} 85 86func (OperationType) Descriptor() protoreflect.EnumDescriptor { 87 return file_google_datastore_admin_v1beta1_datastore_admin_proto_enumTypes[0].Descriptor() 88} 89 90func (OperationType) Type() protoreflect.EnumType { 91 return &file_google_datastore_admin_v1beta1_datastore_admin_proto_enumTypes[0] 92} 93 94func (x OperationType) Number() protoreflect.EnumNumber { 95 return protoreflect.EnumNumber(x) 96} 97 98// Deprecated: Use OperationType.Descriptor instead. 99func (OperationType) EnumDescriptor() ([]byte, []int) { 100 return file_google_datastore_admin_v1beta1_datastore_admin_proto_rawDescGZIP(), []int{0} 101} 102 103// The various possible states for an ongoing Operation. 104type CommonMetadata_State int32 105 106const ( 107 // Unspecified. 108 CommonMetadata_STATE_UNSPECIFIED CommonMetadata_State = 0 109 // Request is being prepared for processing. 110 CommonMetadata_INITIALIZING CommonMetadata_State = 1 111 // Request is actively being processed. 112 CommonMetadata_PROCESSING CommonMetadata_State = 2 113 // Request is in the process of being cancelled after user called 114 // google.longrunning.Operations.CancelOperation on the operation. 115 CommonMetadata_CANCELLING CommonMetadata_State = 3 116 // Request has been processed and is in its finalization stage. 117 CommonMetadata_FINALIZING CommonMetadata_State = 4 118 // Request has completed successfully. 119 CommonMetadata_SUCCESSFUL CommonMetadata_State = 5 120 // Request has finished being processed, but encountered an error. 121 CommonMetadata_FAILED CommonMetadata_State = 6 122 // Request has finished being cancelled after user called 123 // google.longrunning.Operations.CancelOperation. 124 CommonMetadata_CANCELLED CommonMetadata_State = 7 125) 126 127// Enum value maps for CommonMetadata_State. 128var ( 129 CommonMetadata_State_name = map[int32]string{ 130 0: "STATE_UNSPECIFIED", 131 1: "INITIALIZING", 132 2: "PROCESSING", 133 3: "CANCELLING", 134 4: "FINALIZING", 135 5: "SUCCESSFUL", 136 6: "FAILED", 137 7: "CANCELLED", 138 } 139 CommonMetadata_State_value = map[string]int32{ 140 "STATE_UNSPECIFIED": 0, 141 "INITIALIZING": 1, 142 "PROCESSING": 2, 143 "CANCELLING": 3, 144 "FINALIZING": 4, 145 "SUCCESSFUL": 5, 146 "FAILED": 6, 147 "CANCELLED": 7, 148 } 149) 150 151func (x CommonMetadata_State) Enum() *CommonMetadata_State { 152 p := new(CommonMetadata_State) 153 *p = x 154 return p 155} 156 157func (x CommonMetadata_State) String() string { 158 return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x)) 159} 160 161func (CommonMetadata_State) Descriptor() protoreflect.EnumDescriptor { 162 return file_google_datastore_admin_v1beta1_datastore_admin_proto_enumTypes[1].Descriptor() 163} 164 165func (CommonMetadata_State) Type() protoreflect.EnumType { 166 return &file_google_datastore_admin_v1beta1_datastore_admin_proto_enumTypes[1] 167} 168 169func (x CommonMetadata_State) Number() protoreflect.EnumNumber { 170 return protoreflect.EnumNumber(x) 171} 172 173// Deprecated: Use CommonMetadata_State.Descriptor instead. 174func (CommonMetadata_State) EnumDescriptor() ([]byte, []int) { 175 return file_google_datastore_admin_v1beta1_datastore_admin_proto_rawDescGZIP(), []int{0, 0} 176} 177 178// Metadata common to all Datastore Admin operations. 179type CommonMetadata struct { 180 state protoimpl.MessageState 181 sizeCache protoimpl.SizeCache 182 unknownFields protoimpl.UnknownFields 183 184 // The time that work began on the operation. 185 StartTime *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"` 186 // The time the operation ended, either successfully or otherwise. 187 EndTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"` 188 // The type of the operation. Can be used as a filter in 189 // ListOperationsRequest. 190 OperationType OperationType `protobuf:"varint,3,opt,name=operation_type,json=operationType,proto3,enum=google.datastore.admin.v1beta1.OperationType" json:"operation_type,omitempty"` 191 // The client-assigned labels which were provided when the operation was 192 // created. May also include additional labels. 193 Labels map[string]string `protobuf:"bytes,4,rep,name=labels,proto3" json:"labels,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"` 194 // The current state of the Operation. 195 State CommonMetadata_State `protobuf:"varint,5,opt,name=state,proto3,enum=google.datastore.admin.v1beta1.CommonMetadata_State" json:"state,omitempty"` 196} 197 198func (x *CommonMetadata) Reset() { 199 *x = CommonMetadata{} 200 if protoimpl.UnsafeEnabled { 201 mi := &file_google_datastore_admin_v1beta1_datastore_admin_proto_msgTypes[0] 202 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 203 ms.StoreMessageInfo(mi) 204 } 205} 206 207func (x *CommonMetadata) String() string { 208 return protoimpl.X.MessageStringOf(x) 209} 210 211func (*CommonMetadata) ProtoMessage() {} 212 213func (x *CommonMetadata) ProtoReflect() protoreflect.Message { 214 mi := &file_google_datastore_admin_v1beta1_datastore_admin_proto_msgTypes[0] 215 if protoimpl.UnsafeEnabled && x != nil { 216 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 217 if ms.LoadMessageInfo() == nil { 218 ms.StoreMessageInfo(mi) 219 } 220 return ms 221 } 222 return mi.MessageOf(x) 223} 224 225// Deprecated: Use CommonMetadata.ProtoReflect.Descriptor instead. 226func (*CommonMetadata) Descriptor() ([]byte, []int) { 227 return file_google_datastore_admin_v1beta1_datastore_admin_proto_rawDescGZIP(), []int{0} 228} 229 230func (x *CommonMetadata) GetStartTime() *timestamppb.Timestamp { 231 if x != nil { 232 return x.StartTime 233 } 234 return nil 235} 236 237func (x *CommonMetadata) GetEndTime() *timestamppb.Timestamp { 238 if x != nil { 239 return x.EndTime 240 } 241 return nil 242} 243 244func (x *CommonMetadata) GetOperationType() OperationType { 245 if x != nil { 246 return x.OperationType 247 } 248 return OperationType_OPERATION_TYPE_UNSPECIFIED 249} 250 251func (x *CommonMetadata) GetLabels() map[string]string { 252 if x != nil { 253 return x.Labels 254 } 255 return nil 256} 257 258func (x *CommonMetadata) GetState() CommonMetadata_State { 259 if x != nil { 260 return x.State 261 } 262 return CommonMetadata_STATE_UNSPECIFIED 263} 264 265// Measures the progress of a particular metric. 266type Progress struct { 267 state protoimpl.MessageState 268 sizeCache protoimpl.SizeCache 269 unknownFields protoimpl.UnknownFields 270 271 // The amount of work that has been completed. Note that this may be greater 272 // than work_estimated. 273 WorkCompleted int64 `protobuf:"varint,1,opt,name=work_completed,json=workCompleted,proto3" json:"work_completed,omitempty"` 274 // An estimate of how much work needs to be performed. May be zero if the 275 // work estimate is unavailable. 276 WorkEstimated int64 `protobuf:"varint,2,opt,name=work_estimated,json=workEstimated,proto3" json:"work_estimated,omitempty"` 277} 278 279func (x *Progress) Reset() { 280 *x = Progress{} 281 if protoimpl.UnsafeEnabled { 282 mi := &file_google_datastore_admin_v1beta1_datastore_admin_proto_msgTypes[1] 283 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 284 ms.StoreMessageInfo(mi) 285 } 286} 287 288func (x *Progress) String() string { 289 return protoimpl.X.MessageStringOf(x) 290} 291 292func (*Progress) ProtoMessage() {} 293 294func (x *Progress) ProtoReflect() protoreflect.Message { 295 mi := &file_google_datastore_admin_v1beta1_datastore_admin_proto_msgTypes[1] 296 if protoimpl.UnsafeEnabled && x != nil { 297 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 298 if ms.LoadMessageInfo() == nil { 299 ms.StoreMessageInfo(mi) 300 } 301 return ms 302 } 303 return mi.MessageOf(x) 304} 305 306// Deprecated: Use Progress.ProtoReflect.Descriptor instead. 307func (*Progress) Descriptor() ([]byte, []int) { 308 return file_google_datastore_admin_v1beta1_datastore_admin_proto_rawDescGZIP(), []int{1} 309} 310 311func (x *Progress) GetWorkCompleted() int64 { 312 if x != nil { 313 return x.WorkCompleted 314 } 315 return 0 316} 317 318func (x *Progress) GetWorkEstimated() int64 { 319 if x != nil { 320 return x.WorkEstimated 321 } 322 return 0 323} 324 325// The request for 326// [google.datastore.admin.v1beta1.DatastoreAdmin.ExportEntities][google.datastore.admin.v1beta1.DatastoreAdmin.ExportEntities]. 327type ExportEntitiesRequest struct { 328 state protoimpl.MessageState 329 sizeCache protoimpl.SizeCache 330 unknownFields protoimpl.UnknownFields 331 332 // Project ID against which to make the request. 333 ProjectId string `protobuf:"bytes,1,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"` 334 // Client-assigned labels. 335 Labels map[string]string `protobuf:"bytes,2,rep,name=labels,proto3" json:"labels,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"` 336 // Description of what data from the project is included in the export. 337 EntityFilter *EntityFilter `protobuf:"bytes,3,opt,name=entity_filter,json=entityFilter,proto3" json:"entity_filter,omitempty"` 338 // Location for the export metadata and data files. 339 // 340 // The full resource URL of the external storage location. Currently, only 341 // Google Cloud Storage is supported. So output_url_prefix should be of the 342 // form: `gs://BUCKET_NAME[/NAMESPACE_PATH]`, where `BUCKET_NAME` is the 343 // name of the Cloud Storage bucket and `NAMESPACE_PATH` is an optional Cloud 344 // Storage namespace path (this is not a Cloud Datastore namespace). For more 345 // information about Cloud Storage namespace paths, see 346 // [Object name 347 // considerations](https://cloud.google.com/storage/docs/naming#object-considerations). 348 // 349 // The resulting files will be nested deeper than the specified URL prefix. 350 // The final output URL will be provided in the 351 // [google.datastore.admin.v1beta1.ExportEntitiesResponse.output_url][google.datastore.admin.v1beta1.ExportEntitiesResponse.output_url] 352 // field. That value should be used for subsequent ImportEntities operations. 353 // 354 // By nesting the data files deeper, the same Cloud Storage bucket can be used 355 // in multiple ExportEntities operations without conflict. 356 OutputUrlPrefix string `protobuf:"bytes,4,opt,name=output_url_prefix,json=outputUrlPrefix,proto3" json:"output_url_prefix,omitempty"` 357} 358 359func (x *ExportEntitiesRequest) Reset() { 360 *x = ExportEntitiesRequest{} 361 if protoimpl.UnsafeEnabled { 362 mi := &file_google_datastore_admin_v1beta1_datastore_admin_proto_msgTypes[2] 363 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 364 ms.StoreMessageInfo(mi) 365 } 366} 367 368func (x *ExportEntitiesRequest) String() string { 369 return protoimpl.X.MessageStringOf(x) 370} 371 372func (*ExportEntitiesRequest) ProtoMessage() {} 373 374func (x *ExportEntitiesRequest) ProtoReflect() protoreflect.Message { 375 mi := &file_google_datastore_admin_v1beta1_datastore_admin_proto_msgTypes[2] 376 if protoimpl.UnsafeEnabled && x != nil { 377 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 378 if ms.LoadMessageInfo() == nil { 379 ms.StoreMessageInfo(mi) 380 } 381 return ms 382 } 383 return mi.MessageOf(x) 384} 385 386// Deprecated: Use ExportEntitiesRequest.ProtoReflect.Descriptor instead. 387func (*ExportEntitiesRequest) Descriptor() ([]byte, []int) { 388 return file_google_datastore_admin_v1beta1_datastore_admin_proto_rawDescGZIP(), []int{2} 389} 390 391func (x *ExportEntitiesRequest) GetProjectId() string { 392 if x != nil { 393 return x.ProjectId 394 } 395 return "" 396} 397 398func (x *ExportEntitiesRequest) GetLabels() map[string]string { 399 if x != nil { 400 return x.Labels 401 } 402 return nil 403} 404 405func (x *ExportEntitiesRequest) GetEntityFilter() *EntityFilter { 406 if x != nil { 407 return x.EntityFilter 408 } 409 return nil 410} 411 412func (x *ExportEntitiesRequest) GetOutputUrlPrefix() string { 413 if x != nil { 414 return x.OutputUrlPrefix 415 } 416 return "" 417} 418 419// The request for 420// [google.datastore.admin.v1beta1.DatastoreAdmin.ImportEntities][google.datastore.admin.v1beta1.DatastoreAdmin.ImportEntities]. 421type ImportEntitiesRequest struct { 422 state protoimpl.MessageState 423 sizeCache protoimpl.SizeCache 424 unknownFields protoimpl.UnknownFields 425 426 // Project ID against which to make the request. 427 ProjectId string `protobuf:"bytes,1,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"` 428 // Client-assigned labels. 429 Labels map[string]string `protobuf:"bytes,2,rep,name=labels,proto3" json:"labels,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"` 430 // The full resource URL of the external storage location. Currently, only 431 // Google Cloud Storage is supported. So input_url should be of the form: 432 // `gs://BUCKET_NAME[/NAMESPACE_PATH]/OVERALL_EXPORT_METADATA_FILE`, where 433 // `BUCKET_NAME` is the name of the Cloud Storage bucket, `NAMESPACE_PATH` is 434 // an optional Cloud Storage namespace path (this is not a Cloud Datastore 435 // namespace), and `OVERALL_EXPORT_METADATA_FILE` is the metadata file written 436 // by the ExportEntities operation. For more information about Cloud Storage 437 // namespace paths, see 438 // [Object name 439 // considerations](https://cloud.google.com/storage/docs/naming#object-considerations). 440 // 441 // For more information, see 442 // [google.datastore.admin.v1beta1.ExportEntitiesResponse.output_url][google.datastore.admin.v1beta1.ExportEntitiesResponse.output_url]. 443 InputUrl string `protobuf:"bytes,3,opt,name=input_url,json=inputUrl,proto3" json:"input_url,omitempty"` 444 // Optionally specify which kinds/namespaces are to be imported. If provided, 445 // the list must be a subset of the EntityFilter used in creating the export, 446 // otherwise a FAILED_PRECONDITION error will be returned. If no filter is 447 // specified then all entities from the export are imported. 448 EntityFilter *EntityFilter `protobuf:"bytes,4,opt,name=entity_filter,json=entityFilter,proto3" json:"entity_filter,omitempty"` 449} 450 451func (x *ImportEntitiesRequest) Reset() { 452 *x = ImportEntitiesRequest{} 453 if protoimpl.UnsafeEnabled { 454 mi := &file_google_datastore_admin_v1beta1_datastore_admin_proto_msgTypes[3] 455 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 456 ms.StoreMessageInfo(mi) 457 } 458} 459 460func (x *ImportEntitiesRequest) String() string { 461 return protoimpl.X.MessageStringOf(x) 462} 463 464func (*ImportEntitiesRequest) ProtoMessage() {} 465 466func (x *ImportEntitiesRequest) ProtoReflect() protoreflect.Message { 467 mi := &file_google_datastore_admin_v1beta1_datastore_admin_proto_msgTypes[3] 468 if protoimpl.UnsafeEnabled && x != nil { 469 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 470 if ms.LoadMessageInfo() == nil { 471 ms.StoreMessageInfo(mi) 472 } 473 return ms 474 } 475 return mi.MessageOf(x) 476} 477 478// Deprecated: Use ImportEntitiesRequest.ProtoReflect.Descriptor instead. 479func (*ImportEntitiesRequest) Descriptor() ([]byte, []int) { 480 return file_google_datastore_admin_v1beta1_datastore_admin_proto_rawDescGZIP(), []int{3} 481} 482 483func (x *ImportEntitiesRequest) GetProjectId() string { 484 if x != nil { 485 return x.ProjectId 486 } 487 return "" 488} 489 490func (x *ImportEntitiesRequest) GetLabels() map[string]string { 491 if x != nil { 492 return x.Labels 493 } 494 return nil 495} 496 497func (x *ImportEntitiesRequest) GetInputUrl() string { 498 if x != nil { 499 return x.InputUrl 500 } 501 return "" 502} 503 504func (x *ImportEntitiesRequest) GetEntityFilter() *EntityFilter { 505 if x != nil { 506 return x.EntityFilter 507 } 508 return nil 509} 510 511// The response for 512// [google.datastore.admin.v1beta1.DatastoreAdmin.ExportEntities][google.datastore.admin.v1beta1.DatastoreAdmin.ExportEntities]. 513type ExportEntitiesResponse struct { 514 state protoimpl.MessageState 515 sizeCache protoimpl.SizeCache 516 unknownFields protoimpl.UnknownFields 517 518 // Location of the output metadata file. This can be used to begin an import 519 // into Cloud Datastore (this project or another project). See 520 // [google.datastore.admin.v1beta1.ImportEntitiesRequest.input_url][google.datastore.admin.v1beta1.ImportEntitiesRequest.input_url]. 521 // Only present if the operation completed successfully. 522 OutputUrl string `protobuf:"bytes,1,opt,name=output_url,json=outputUrl,proto3" json:"output_url,omitempty"` 523} 524 525func (x *ExportEntitiesResponse) Reset() { 526 *x = ExportEntitiesResponse{} 527 if protoimpl.UnsafeEnabled { 528 mi := &file_google_datastore_admin_v1beta1_datastore_admin_proto_msgTypes[4] 529 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 530 ms.StoreMessageInfo(mi) 531 } 532} 533 534func (x *ExportEntitiesResponse) String() string { 535 return protoimpl.X.MessageStringOf(x) 536} 537 538func (*ExportEntitiesResponse) ProtoMessage() {} 539 540func (x *ExportEntitiesResponse) ProtoReflect() protoreflect.Message { 541 mi := &file_google_datastore_admin_v1beta1_datastore_admin_proto_msgTypes[4] 542 if protoimpl.UnsafeEnabled && x != nil { 543 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 544 if ms.LoadMessageInfo() == nil { 545 ms.StoreMessageInfo(mi) 546 } 547 return ms 548 } 549 return mi.MessageOf(x) 550} 551 552// Deprecated: Use ExportEntitiesResponse.ProtoReflect.Descriptor instead. 553func (*ExportEntitiesResponse) Descriptor() ([]byte, []int) { 554 return file_google_datastore_admin_v1beta1_datastore_admin_proto_rawDescGZIP(), []int{4} 555} 556 557func (x *ExportEntitiesResponse) GetOutputUrl() string { 558 if x != nil { 559 return x.OutputUrl 560 } 561 return "" 562} 563 564// Metadata for ExportEntities operations. 565type ExportEntitiesMetadata struct { 566 state protoimpl.MessageState 567 sizeCache protoimpl.SizeCache 568 unknownFields protoimpl.UnknownFields 569 570 // Metadata common to all Datastore Admin operations. 571 Common *CommonMetadata `protobuf:"bytes,1,opt,name=common,proto3" json:"common,omitempty"` 572 // An estimate of the number of entities processed. 573 ProgressEntities *Progress `protobuf:"bytes,2,opt,name=progress_entities,json=progressEntities,proto3" json:"progress_entities,omitempty"` 574 // An estimate of the number of bytes processed. 575 ProgressBytes *Progress `protobuf:"bytes,3,opt,name=progress_bytes,json=progressBytes,proto3" json:"progress_bytes,omitempty"` 576 // Description of which entities are being exported. 577 EntityFilter *EntityFilter `protobuf:"bytes,4,opt,name=entity_filter,json=entityFilter,proto3" json:"entity_filter,omitempty"` 578 // Location for the export metadata and data files. This will be the same 579 // value as the 580 // [google.datastore.admin.v1beta1.ExportEntitiesRequest.output_url_prefix][google.datastore.admin.v1beta1.ExportEntitiesRequest.output_url_prefix] 581 // field. The final output location is provided in 582 // [google.datastore.admin.v1beta1.ExportEntitiesResponse.output_url][google.datastore.admin.v1beta1.ExportEntitiesResponse.output_url]. 583 OutputUrlPrefix string `protobuf:"bytes,5,opt,name=output_url_prefix,json=outputUrlPrefix,proto3" json:"output_url_prefix,omitempty"` 584} 585 586func (x *ExportEntitiesMetadata) Reset() { 587 *x = ExportEntitiesMetadata{} 588 if protoimpl.UnsafeEnabled { 589 mi := &file_google_datastore_admin_v1beta1_datastore_admin_proto_msgTypes[5] 590 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 591 ms.StoreMessageInfo(mi) 592 } 593} 594 595func (x *ExportEntitiesMetadata) String() string { 596 return protoimpl.X.MessageStringOf(x) 597} 598 599func (*ExportEntitiesMetadata) ProtoMessage() {} 600 601func (x *ExportEntitiesMetadata) ProtoReflect() protoreflect.Message { 602 mi := &file_google_datastore_admin_v1beta1_datastore_admin_proto_msgTypes[5] 603 if protoimpl.UnsafeEnabled && x != nil { 604 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 605 if ms.LoadMessageInfo() == nil { 606 ms.StoreMessageInfo(mi) 607 } 608 return ms 609 } 610 return mi.MessageOf(x) 611} 612 613// Deprecated: Use ExportEntitiesMetadata.ProtoReflect.Descriptor instead. 614func (*ExportEntitiesMetadata) Descriptor() ([]byte, []int) { 615 return file_google_datastore_admin_v1beta1_datastore_admin_proto_rawDescGZIP(), []int{5} 616} 617 618func (x *ExportEntitiesMetadata) GetCommon() *CommonMetadata { 619 if x != nil { 620 return x.Common 621 } 622 return nil 623} 624 625func (x *ExportEntitiesMetadata) GetProgressEntities() *Progress { 626 if x != nil { 627 return x.ProgressEntities 628 } 629 return nil 630} 631 632func (x *ExportEntitiesMetadata) GetProgressBytes() *Progress { 633 if x != nil { 634 return x.ProgressBytes 635 } 636 return nil 637} 638 639func (x *ExportEntitiesMetadata) GetEntityFilter() *EntityFilter { 640 if x != nil { 641 return x.EntityFilter 642 } 643 return nil 644} 645 646func (x *ExportEntitiesMetadata) GetOutputUrlPrefix() string { 647 if x != nil { 648 return x.OutputUrlPrefix 649 } 650 return "" 651} 652 653// Metadata for ImportEntities operations. 654type ImportEntitiesMetadata struct { 655 state protoimpl.MessageState 656 sizeCache protoimpl.SizeCache 657 unknownFields protoimpl.UnknownFields 658 659 // Metadata common to all Datastore Admin operations. 660 Common *CommonMetadata `protobuf:"bytes,1,opt,name=common,proto3" json:"common,omitempty"` 661 // An estimate of the number of entities processed. 662 ProgressEntities *Progress `protobuf:"bytes,2,opt,name=progress_entities,json=progressEntities,proto3" json:"progress_entities,omitempty"` 663 // An estimate of the number of bytes processed. 664 ProgressBytes *Progress `protobuf:"bytes,3,opt,name=progress_bytes,json=progressBytes,proto3" json:"progress_bytes,omitempty"` 665 // Description of which entities are being imported. 666 EntityFilter *EntityFilter `protobuf:"bytes,4,opt,name=entity_filter,json=entityFilter,proto3" json:"entity_filter,omitempty"` 667 // The location of the import metadata file. This will be the same value as 668 // the 669 // [google.datastore.admin.v1beta1.ExportEntitiesResponse.output_url][google.datastore.admin.v1beta1.ExportEntitiesResponse.output_url] 670 // field. 671 InputUrl string `protobuf:"bytes,5,opt,name=input_url,json=inputUrl,proto3" json:"input_url,omitempty"` 672} 673 674func (x *ImportEntitiesMetadata) Reset() { 675 *x = ImportEntitiesMetadata{} 676 if protoimpl.UnsafeEnabled { 677 mi := &file_google_datastore_admin_v1beta1_datastore_admin_proto_msgTypes[6] 678 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 679 ms.StoreMessageInfo(mi) 680 } 681} 682 683func (x *ImportEntitiesMetadata) String() string { 684 return protoimpl.X.MessageStringOf(x) 685} 686 687func (*ImportEntitiesMetadata) ProtoMessage() {} 688 689func (x *ImportEntitiesMetadata) ProtoReflect() protoreflect.Message { 690 mi := &file_google_datastore_admin_v1beta1_datastore_admin_proto_msgTypes[6] 691 if protoimpl.UnsafeEnabled && x != nil { 692 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 693 if ms.LoadMessageInfo() == nil { 694 ms.StoreMessageInfo(mi) 695 } 696 return ms 697 } 698 return mi.MessageOf(x) 699} 700 701// Deprecated: Use ImportEntitiesMetadata.ProtoReflect.Descriptor instead. 702func (*ImportEntitiesMetadata) Descriptor() ([]byte, []int) { 703 return file_google_datastore_admin_v1beta1_datastore_admin_proto_rawDescGZIP(), []int{6} 704} 705 706func (x *ImportEntitiesMetadata) GetCommon() *CommonMetadata { 707 if x != nil { 708 return x.Common 709 } 710 return nil 711} 712 713func (x *ImportEntitiesMetadata) GetProgressEntities() *Progress { 714 if x != nil { 715 return x.ProgressEntities 716 } 717 return nil 718} 719 720func (x *ImportEntitiesMetadata) GetProgressBytes() *Progress { 721 if x != nil { 722 return x.ProgressBytes 723 } 724 return nil 725} 726 727func (x *ImportEntitiesMetadata) GetEntityFilter() *EntityFilter { 728 if x != nil { 729 return x.EntityFilter 730 } 731 return nil 732} 733 734func (x *ImportEntitiesMetadata) GetInputUrl() string { 735 if x != nil { 736 return x.InputUrl 737 } 738 return "" 739} 740 741// Identifies a subset of entities in a project. This is specified as 742// combinations of kinds and namespaces (either or both of which may be all, as 743// described in the following examples). 744// Example usage: 745// 746// Entire project: 747// kinds=[], namespace_ids=[] 748// 749// Kinds Foo and Bar in all namespaces: 750// kinds=['Foo', 'Bar'], namespace_ids=[] 751// 752// Kinds Foo and Bar only in the default namespace: 753// kinds=['Foo', 'Bar'], namespace_ids=[''] 754// 755// Kinds Foo and Bar in both the default and Baz namespaces: 756// kinds=['Foo', 'Bar'], namespace_ids=['', 'Baz'] 757// 758// The entire Baz namespace: 759// kinds=[], namespace_ids=['Baz'] 760type EntityFilter struct { 761 state protoimpl.MessageState 762 sizeCache protoimpl.SizeCache 763 unknownFields protoimpl.UnknownFields 764 765 // If empty, then this represents all kinds. 766 Kinds []string `protobuf:"bytes,1,rep,name=kinds,proto3" json:"kinds,omitempty"` 767 // An empty list represents all namespaces. This is the preferred 768 // usage for projects that don't use namespaces. 769 // 770 // An empty string element represents the default namespace. This should be 771 // used if the project has data in non-default namespaces, but doesn't want to 772 // include them. 773 // Each namespace in this list must be unique. 774 NamespaceIds []string `protobuf:"bytes,2,rep,name=namespace_ids,json=namespaceIds,proto3" json:"namespace_ids,omitempty"` 775} 776 777func (x *EntityFilter) Reset() { 778 *x = EntityFilter{} 779 if protoimpl.UnsafeEnabled { 780 mi := &file_google_datastore_admin_v1beta1_datastore_admin_proto_msgTypes[7] 781 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 782 ms.StoreMessageInfo(mi) 783 } 784} 785 786func (x *EntityFilter) String() string { 787 return protoimpl.X.MessageStringOf(x) 788} 789 790func (*EntityFilter) ProtoMessage() {} 791 792func (x *EntityFilter) ProtoReflect() protoreflect.Message { 793 mi := &file_google_datastore_admin_v1beta1_datastore_admin_proto_msgTypes[7] 794 if protoimpl.UnsafeEnabled && x != nil { 795 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 796 if ms.LoadMessageInfo() == nil { 797 ms.StoreMessageInfo(mi) 798 } 799 return ms 800 } 801 return mi.MessageOf(x) 802} 803 804// Deprecated: Use EntityFilter.ProtoReflect.Descriptor instead. 805func (*EntityFilter) Descriptor() ([]byte, []int) { 806 return file_google_datastore_admin_v1beta1_datastore_admin_proto_rawDescGZIP(), []int{7} 807} 808 809func (x *EntityFilter) GetKinds() []string { 810 if x != nil { 811 return x.Kinds 812 } 813 return nil 814} 815 816func (x *EntityFilter) GetNamespaceIds() []string { 817 if x != nil { 818 return x.NamespaceIds 819 } 820 return nil 821} 822 823var File_google_datastore_admin_v1beta1_datastore_admin_proto protoreflect.FileDescriptor 824 825var file_google_datastore_admin_v1beta1_datastore_admin_proto_rawDesc = []byte{ 826 0x0a, 0x34, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x64, 0x61, 0x74, 0x61, 0x73, 0x74, 0x6f, 827 0x72, 0x65, 0x2f, 0x61, 0x64, 0x6d, 0x69, 0x6e, 0x2f, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 828 0x2f, 0x64, 0x61, 0x74, 0x61, 0x73, 0x74, 0x6f, 0x72, 0x65, 0x5f, 0x61, 0x64, 0x6d, 0x69, 0x6e, 829 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x12, 0x1e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x64, 830 0x61, 0x74, 0x61, 0x73, 0x74, 0x6f, 0x72, 0x65, 0x2e, 0x61, 0x64, 0x6d, 0x69, 0x6e, 0x2e, 0x76, 831 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 0x1a, 0x1c, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x61, 832 0x70, 0x69, 0x2f, 0x61, 0x6e, 0x6e, 0x6f, 0x74, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2e, 0x70, 833 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x23, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x6c, 0x6f, 0x6e, 834 0x67, 0x72, 0x75, 0x6e, 0x6e, 0x69, 0x6e, 0x67, 0x2f, 0x6f, 0x70, 0x65, 0x72, 0x61, 0x74, 0x69, 835 0x6f, 0x6e, 0x73, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x1f, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 836 0x65, 0x2f, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2f, 0x74, 0x69, 0x6d, 0x65, 0x73, 837 0x74, 0x61, 0x6d, 0x70, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x22, 0xc1, 0x04, 0x0a, 0x0e, 0x43, 838 0x6f, 0x6d, 0x6d, 0x6f, 0x6e, 0x4d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0x12, 0x39, 0x0a, 839 0x0a, 0x73, 0x74, 0x61, 0x72, 0x74, 0x5f, 0x74, 0x69, 0x6d, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 840 0x0b, 0x32, 0x1a, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 841 0x62, 0x75, 0x66, 0x2e, 0x54, 0x69, 0x6d, 0x65, 0x73, 0x74, 0x61, 0x6d, 0x70, 0x52, 0x09, 0x73, 842 0x74, 0x61, 0x72, 0x74, 0x54, 0x69, 0x6d, 0x65, 0x12, 0x35, 0x0a, 0x08, 0x65, 0x6e, 0x64, 0x5f, 843 0x74, 0x69, 0x6d, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1a, 0x2e, 0x67, 0x6f, 0x6f, 844 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x54, 0x69, 0x6d, 845 0x65, 0x73, 0x74, 0x61, 0x6d, 0x70, 0x52, 0x07, 0x65, 0x6e, 0x64, 0x54, 0x69, 0x6d, 0x65, 0x12, 846 0x54, 0x0a, 0x0e, 0x6f, 0x70, 0x65, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x5f, 0x74, 0x79, 0x70, 847 0x65, 0x18, 0x03, 0x20, 0x01, 0x28, 0x0e, 0x32, 0x2d, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 848 0x2e, 0x64, 0x61, 0x74, 0x61, 0x73, 0x74, 0x6f, 0x72, 0x65, 0x2e, 0x61, 0x64, 0x6d, 0x69, 0x6e, 849 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 0x2e, 0x4f, 0x70, 0x65, 0x72, 0x61, 0x74, 0x69, 850 0x6f, 0x6e, 0x54, 0x79, 0x70, 0x65, 0x52, 0x0d, 0x6f, 0x70, 0x65, 0x72, 0x61, 0x74, 0x69, 0x6f, 851 0x6e, 0x54, 0x79, 0x70, 0x65, 0x12, 0x52, 0x0a, 0x06, 0x6c, 0x61, 0x62, 0x65, 0x6c, 0x73, 0x18, 852 0x04, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x3a, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x64, 853 0x61, 0x74, 0x61, 0x73, 0x74, 0x6f, 0x72, 0x65, 0x2e, 0x61, 0x64, 0x6d, 0x69, 0x6e, 0x2e, 0x76, 854 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 0x2e, 0x43, 0x6f, 0x6d, 0x6d, 0x6f, 0x6e, 0x4d, 0x65, 0x74, 855 0x61, 0x64, 0x61, 0x74, 0x61, 0x2e, 0x4c, 0x61, 0x62, 0x65, 0x6c, 0x73, 0x45, 0x6e, 0x74, 0x72, 856 0x79, 0x52, 0x06, 0x6c, 0x61, 0x62, 0x65, 0x6c, 0x73, 0x12, 0x4a, 0x0a, 0x05, 0x73, 0x74, 0x61, 857 0x74, 0x65, 0x18, 0x05, 0x20, 0x01, 0x28, 0x0e, 0x32, 0x34, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 858 0x65, 0x2e, 0x64, 0x61, 0x74, 0x61, 0x73, 0x74, 0x6f, 0x72, 0x65, 0x2e, 0x61, 0x64, 0x6d, 0x69, 859 0x6e, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 0x2e, 0x43, 0x6f, 0x6d, 0x6d, 0x6f, 0x6e, 860 0x4d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0x2e, 0x53, 0x74, 0x61, 0x74, 0x65, 0x52, 0x05, 861 0x73, 0x74, 0x61, 0x74, 0x65, 0x1a, 0x39, 0x0a, 0x0b, 0x4c, 0x61, 0x62, 0x65, 0x6c, 0x73, 0x45, 862 0x6e, 0x74, 0x72, 0x79, 0x12, 0x10, 0x0a, 0x03, 0x6b, 0x65, 0x79, 0x18, 0x01, 0x20, 0x01, 0x28, 863 0x09, 0x52, 0x03, 0x6b, 0x65, 0x79, 0x12, 0x14, 0x0a, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x18, 864 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x3a, 0x02, 0x38, 0x01, 865 0x22, 0x8b, 0x01, 0x0a, 0x05, 0x53, 0x74, 0x61, 0x74, 0x65, 0x12, 0x15, 0x0a, 0x11, 0x53, 0x54, 866 0x41, 0x54, 0x45, 0x5f, 0x55, 0x4e, 0x53, 0x50, 0x45, 0x43, 0x49, 0x46, 0x49, 0x45, 0x44, 0x10, 867 0x00, 0x12, 0x10, 0x0a, 0x0c, 0x49, 0x4e, 0x49, 0x54, 0x49, 0x41, 0x4c, 0x49, 0x5a, 0x49, 0x4e, 868 0x47, 0x10, 0x01, 0x12, 0x0e, 0x0a, 0x0a, 0x50, 0x52, 0x4f, 0x43, 0x45, 0x53, 0x53, 0x49, 0x4e, 869 0x47, 0x10, 0x02, 0x12, 0x0e, 0x0a, 0x0a, 0x43, 0x41, 0x4e, 0x43, 0x45, 0x4c, 0x4c, 0x49, 0x4e, 870 0x47, 0x10, 0x03, 0x12, 0x0e, 0x0a, 0x0a, 0x46, 0x49, 0x4e, 0x41, 0x4c, 0x49, 0x5a, 0x49, 0x4e, 871 0x47, 0x10, 0x04, 0x12, 0x0e, 0x0a, 0x0a, 0x53, 0x55, 0x43, 0x43, 0x45, 0x53, 0x53, 0x46, 0x55, 872 0x4c, 0x10, 0x05, 0x12, 0x0a, 0x0a, 0x06, 0x46, 0x41, 0x49, 0x4c, 0x45, 0x44, 0x10, 0x06, 0x12, 873 0x0d, 0x0a, 0x09, 0x43, 0x41, 0x4e, 0x43, 0x45, 0x4c, 0x4c, 0x45, 0x44, 0x10, 0x07, 0x22, 0x58, 874 0x0a, 0x08, 0x50, 0x72, 0x6f, 0x67, 0x72, 0x65, 0x73, 0x73, 0x12, 0x25, 0x0a, 0x0e, 0x77, 0x6f, 875 0x72, 0x6b, 0x5f, 0x63, 0x6f, 0x6d, 0x70, 0x6c, 0x65, 0x74, 0x65, 0x64, 0x18, 0x01, 0x20, 0x01, 876 0x28, 0x03, 0x52, 0x0d, 0x77, 0x6f, 0x72, 0x6b, 0x43, 0x6f, 0x6d, 0x70, 0x6c, 0x65, 0x74, 0x65, 877 0x64, 0x12, 0x25, 0x0a, 0x0e, 0x77, 0x6f, 0x72, 0x6b, 0x5f, 0x65, 0x73, 0x74, 0x69, 0x6d, 0x61, 878 0x74, 0x65, 0x64, 0x18, 0x02, 0x20, 0x01, 0x28, 0x03, 0x52, 0x0d, 0x77, 0x6f, 0x72, 0x6b, 0x45, 879 0x73, 0x74, 0x69, 0x6d, 0x61, 0x74, 0x65, 0x64, 0x22, 0xcb, 0x02, 0x0a, 0x15, 0x45, 0x78, 0x70, 880 0x6f, 0x72, 0x74, 0x45, 0x6e, 0x74, 0x69, 0x74, 0x69, 0x65, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 881 0x73, 0x74, 0x12, 0x1d, 0x0a, 0x0a, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x5f, 0x69, 0x64, 882 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x09, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x49, 883 0x64, 0x12, 0x59, 0x0a, 0x06, 0x6c, 0x61, 0x62, 0x65, 0x6c, 0x73, 0x18, 0x02, 0x20, 0x03, 0x28, 884 0x0b, 0x32, 0x41, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x64, 0x61, 0x74, 0x61, 0x73, 885 0x74, 0x6f, 0x72, 0x65, 0x2e, 0x61, 0x64, 0x6d, 0x69, 0x6e, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 886 0x61, 0x31, 0x2e, 0x45, 0x78, 0x70, 0x6f, 0x72, 0x74, 0x45, 0x6e, 0x74, 0x69, 0x74, 0x69, 0x65, 887 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x2e, 0x4c, 0x61, 0x62, 0x65, 0x6c, 0x73, 0x45, 888 0x6e, 0x74, 0x72, 0x79, 0x52, 0x06, 0x6c, 0x61, 0x62, 0x65, 0x6c, 0x73, 0x12, 0x51, 0x0a, 0x0d, 889 0x65, 0x6e, 0x74, 0x69, 0x74, 0x79, 0x5f, 0x66, 0x69, 0x6c, 0x74, 0x65, 0x72, 0x18, 0x03, 0x20, 890 0x01, 0x28, 0x0b, 0x32, 0x2c, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x64, 0x61, 0x74, 891 0x61, 0x73, 0x74, 0x6f, 0x72, 0x65, 0x2e, 0x61, 0x64, 0x6d, 0x69, 0x6e, 0x2e, 0x76, 0x31, 0x62, 892 0x65, 0x74, 0x61, 0x31, 0x2e, 0x45, 0x6e, 0x74, 0x69, 0x74, 0x79, 0x46, 0x69, 0x6c, 0x74, 0x65, 893 0x72, 0x52, 0x0c, 0x65, 0x6e, 0x74, 0x69, 0x74, 0x79, 0x46, 0x69, 0x6c, 0x74, 0x65, 0x72, 0x12, 894 0x2a, 0x0a, 0x11, 0x6f, 0x75, 0x74, 0x70, 0x75, 0x74, 0x5f, 0x75, 0x72, 0x6c, 0x5f, 0x70, 0x72, 895 0x65, 0x66, 0x69, 0x78, 0x18, 0x04, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0f, 0x6f, 0x75, 0x74, 0x70, 896 0x75, 0x74, 0x55, 0x72, 0x6c, 0x50, 0x72, 0x65, 0x66, 0x69, 0x78, 0x1a, 0x39, 0x0a, 0x0b, 0x4c, 897 0x61, 0x62, 0x65, 0x6c, 0x73, 0x45, 0x6e, 0x74, 0x72, 0x79, 0x12, 0x10, 0x0a, 0x03, 0x6b, 0x65, 898 0x79, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x03, 0x6b, 0x65, 0x79, 0x12, 0x14, 0x0a, 0x05, 899 0x76, 0x61, 0x6c, 0x75, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x05, 0x76, 0x61, 0x6c, 900 0x75, 0x65, 0x3a, 0x02, 0x38, 0x01, 0x22, 0xbc, 0x02, 0x0a, 0x15, 0x49, 0x6d, 0x70, 0x6f, 0x72, 901 0x74, 0x45, 0x6e, 0x74, 0x69, 0x74, 0x69, 0x65, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 902 0x12, 0x1d, 0x0a, 0x0a, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x5f, 0x69, 0x64, 0x18, 0x01, 903 0x20, 0x01, 0x28, 0x09, 0x52, 0x09, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x49, 0x64, 0x12, 904 0x59, 0x0a, 0x06, 0x6c, 0x61, 0x62, 0x65, 0x6c, 0x73, 0x18, 0x02, 0x20, 0x03, 0x28, 0x0b, 0x32, 905 0x41, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x64, 0x61, 0x74, 0x61, 0x73, 0x74, 0x6f, 906 0x72, 0x65, 0x2e, 0x61, 0x64, 0x6d, 0x69, 0x6e, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 907 0x2e, 0x49, 0x6d, 0x70, 0x6f, 0x72, 0x74, 0x45, 0x6e, 0x74, 0x69, 0x74, 0x69, 0x65, 0x73, 0x52, 908 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x2e, 0x4c, 0x61, 0x62, 0x65, 0x6c, 0x73, 0x45, 0x6e, 0x74, 909 0x72, 0x79, 0x52, 0x06, 0x6c, 0x61, 0x62, 0x65, 0x6c, 0x73, 0x12, 0x1b, 0x0a, 0x09, 0x69, 0x6e, 910 0x70, 0x75, 0x74, 0x5f, 0x75, 0x72, 0x6c, 0x18, 0x03, 0x20, 0x01, 0x28, 0x09, 0x52, 0x08, 0x69, 911 0x6e, 0x70, 0x75, 0x74, 0x55, 0x72, 0x6c, 0x12, 0x51, 0x0a, 0x0d, 0x65, 0x6e, 0x74, 0x69, 0x74, 912 0x79, 0x5f, 0x66, 0x69, 0x6c, 0x74, 0x65, 0x72, 0x18, 0x04, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x2c, 913 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x64, 0x61, 0x74, 0x61, 0x73, 0x74, 0x6f, 0x72, 914 0x65, 0x2e, 0x61, 0x64, 0x6d, 0x69, 0x6e, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 0x2e, 915 0x45, 0x6e, 0x74, 0x69, 0x74, 0x79, 0x46, 0x69, 0x6c, 0x74, 0x65, 0x72, 0x52, 0x0c, 0x65, 0x6e, 916 0x74, 0x69, 0x74, 0x79, 0x46, 0x69, 0x6c, 0x74, 0x65, 0x72, 0x1a, 0x39, 0x0a, 0x0b, 0x4c, 0x61, 917 0x62, 0x65, 0x6c, 0x73, 0x45, 0x6e, 0x74, 0x72, 0x79, 0x12, 0x10, 0x0a, 0x03, 0x6b, 0x65, 0x79, 918 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x03, 0x6b, 0x65, 0x79, 0x12, 0x14, 0x0a, 0x05, 0x76, 919 0x61, 0x6c, 0x75, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x05, 0x76, 0x61, 0x6c, 0x75, 920 0x65, 0x3a, 0x02, 0x38, 0x01, 0x22, 0x37, 0x0a, 0x16, 0x45, 0x78, 0x70, 0x6f, 0x72, 0x74, 0x45, 921 0x6e, 0x74, 0x69, 0x74, 0x69, 0x65, 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 922 0x1d, 0x0a, 0x0a, 0x6f, 0x75, 0x74, 0x70, 0x75, 0x74, 0x5f, 0x75, 0x72, 0x6c, 0x18, 0x01, 0x20, 923 0x01, 0x28, 0x09, 0x52, 0x09, 0x6f, 0x75, 0x74, 0x70, 0x75, 0x74, 0x55, 0x72, 0x6c, 0x22, 0x87, 924 0x03, 0x0a, 0x16, 0x45, 0x78, 0x70, 0x6f, 0x72, 0x74, 0x45, 0x6e, 0x74, 0x69, 0x74, 0x69, 0x65, 925 0x73, 0x4d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0x12, 0x46, 0x0a, 0x06, 0x63, 0x6f, 0x6d, 926 0x6d, 0x6f, 0x6e, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x2e, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 927 0x6c, 0x65, 0x2e, 0x64, 0x61, 0x74, 0x61, 0x73, 0x74, 0x6f, 0x72, 0x65, 0x2e, 0x61, 0x64, 0x6d, 928 0x69, 0x6e, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 0x2e, 0x43, 0x6f, 0x6d, 0x6d, 0x6f, 929 0x6e, 0x4d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0x52, 0x06, 0x63, 0x6f, 0x6d, 0x6d, 0x6f, 930 0x6e, 0x12, 0x55, 0x0a, 0x11, 0x70, 0x72, 0x6f, 0x67, 0x72, 0x65, 0x73, 0x73, 0x5f, 0x65, 0x6e, 931 0x74, 0x69, 0x74, 0x69, 0x65, 0x73, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x28, 0x2e, 0x67, 932 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x64, 0x61, 0x74, 0x61, 0x73, 0x74, 0x6f, 0x72, 0x65, 0x2e, 933 0x61, 0x64, 0x6d, 0x69, 0x6e, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 0x2e, 0x50, 0x72, 934 0x6f, 0x67, 0x72, 0x65, 0x73, 0x73, 0x52, 0x10, 0x70, 0x72, 0x6f, 0x67, 0x72, 0x65, 0x73, 0x73, 935 0x45, 0x6e, 0x74, 0x69, 0x74, 0x69, 0x65, 0x73, 0x12, 0x4f, 0x0a, 0x0e, 0x70, 0x72, 0x6f, 0x67, 936 0x72, 0x65, 0x73, 0x73, 0x5f, 0x62, 0x79, 0x74, 0x65, 0x73, 0x18, 0x03, 0x20, 0x01, 0x28, 0x0b, 937 0x32, 0x28, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x64, 0x61, 0x74, 0x61, 0x73, 0x74, 938 0x6f, 0x72, 0x65, 0x2e, 0x61, 0x64, 0x6d, 0x69, 0x6e, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 939 0x31, 0x2e, 0x50, 0x72, 0x6f, 0x67, 0x72, 0x65, 0x73, 0x73, 0x52, 0x0d, 0x70, 0x72, 0x6f, 0x67, 940 0x72, 0x65, 0x73, 0x73, 0x42, 0x79, 0x74, 0x65, 0x73, 0x12, 0x51, 0x0a, 0x0d, 0x65, 0x6e, 0x74, 941 0x69, 0x74, 0x79, 0x5f, 0x66, 0x69, 0x6c, 0x74, 0x65, 0x72, 0x18, 0x04, 0x20, 0x01, 0x28, 0x0b, 942 0x32, 0x2c, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x64, 0x61, 0x74, 0x61, 0x73, 0x74, 943 0x6f, 0x72, 0x65, 0x2e, 0x61, 0x64, 0x6d, 0x69, 0x6e, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 944 0x31, 0x2e, 0x45, 0x6e, 0x74, 0x69, 0x74, 0x79, 0x46, 0x69, 0x6c, 0x74, 0x65, 0x72, 0x52, 0x0c, 945 0x65, 0x6e, 0x74, 0x69, 0x74, 0x79, 0x46, 0x69, 0x6c, 0x74, 0x65, 0x72, 0x12, 0x2a, 0x0a, 0x11, 946 0x6f, 0x75, 0x74, 0x70, 0x75, 0x74, 0x5f, 0x75, 0x72, 0x6c, 0x5f, 0x70, 0x72, 0x65, 0x66, 0x69, 947 0x78, 0x18, 0x05, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0f, 0x6f, 0x75, 0x74, 0x70, 0x75, 0x74, 0x55, 948 0x72, 0x6c, 0x50, 0x72, 0x65, 0x66, 0x69, 0x78, 0x22, 0xf8, 0x02, 0x0a, 0x16, 0x49, 0x6d, 0x70, 949 0x6f, 0x72, 0x74, 0x45, 0x6e, 0x74, 0x69, 0x74, 0x69, 0x65, 0x73, 0x4d, 0x65, 0x74, 0x61, 0x64, 950 0x61, 0x74, 0x61, 0x12, 0x46, 0x0a, 0x06, 0x63, 0x6f, 0x6d, 0x6d, 0x6f, 0x6e, 0x18, 0x01, 0x20, 951 0x01, 0x28, 0x0b, 0x32, 0x2e, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x64, 0x61, 0x74, 952 0x61, 0x73, 0x74, 0x6f, 0x72, 0x65, 0x2e, 0x61, 0x64, 0x6d, 0x69, 0x6e, 0x2e, 0x76, 0x31, 0x62, 953 0x65, 0x74, 0x61, 0x31, 0x2e, 0x43, 0x6f, 0x6d, 0x6d, 0x6f, 0x6e, 0x4d, 0x65, 0x74, 0x61, 0x64, 954 0x61, 0x74, 0x61, 0x52, 0x06, 0x63, 0x6f, 0x6d, 0x6d, 0x6f, 0x6e, 0x12, 0x55, 0x0a, 0x11, 0x70, 955 0x72, 0x6f, 0x67, 0x72, 0x65, 0x73, 0x73, 0x5f, 0x65, 0x6e, 0x74, 0x69, 0x74, 0x69, 0x65, 0x73, 956 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x28, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 957 0x64, 0x61, 0x74, 0x61, 0x73, 0x74, 0x6f, 0x72, 0x65, 0x2e, 0x61, 0x64, 0x6d, 0x69, 0x6e, 0x2e, 958 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 0x2e, 0x50, 0x72, 0x6f, 0x67, 0x72, 0x65, 0x73, 0x73, 959 0x52, 0x10, 0x70, 0x72, 0x6f, 0x67, 0x72, 0x65, 0x73, 0x73, 0x45, 0x6e, 0x74, 0x69, 0x74, 0x69, 960 0x65, 0x73, 0x12, 0x4f, 0x0a, 0x0e, 0x70, 0x72, 0x6f, 0x67, 0x72, 0x65, 0x73, 0x73, 0x5f, 0x62, 961 0x79, 0x74, 0x65, 0x73, 0x18, 0x03, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x28, 0x2e, 0x67, 0x6f, 0x6f, 962 0x67, 0x6c, 0x65, 0x2e, 0x64, 0x61, 0x74, 0x61, 0x73, 0x74, 0x6f, 0x72, 0x65, 0x2e, 0x61, 0x64, 963 0x6d, 0x69, 0x6e, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 0x2e, 0x50, 0x72, 0x6f, 0x67, 964 0x72, 0x65, 0x73, 0x73, 0x52, 0x0d, 0x70, 0x72, 0x6f, 0x67, 0x72, 0x65, 0x73, 0x73, 0x42, 0x79, 965 0x74, 0x65, 0x73, 0x12, 0x51, 0x0a, 0x0d, 0x65, 0x6e, 0x74, 0x69, 0x74, 0x79, 0x5f, 0x66, 0x69, 966 0x6c, 0x74, 0x65, 0x72, 0x18, 0x04, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x2c, 0x2e, 0x67, 0x6f, 0x6f, 967 0x67, 0x6c, 0x65, 0x2e, 0x64, 0x61, 0x74, 0x61, 0x73, 0x74, 0x6f, 0x72, 0x65, 0x2e, 0x61, 0x64, 968 0x6d, 0x69, 0x6e, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 0x2e, 0x45, 0x6e, 0x74, 0x69, 969 0x74, 0x79, 0x46, 0x69, 0x6c, 0x74, 0x65, 0x72, 0x52, 0x0c, 0x65, 0x6e, 0x74, 0x69, 0x74, 0x79, 970 0x46, 0x69, 0x6c, 0x74, 0x65, 0x72, 0x12, 0x1b, 0x0a, 0x09, 0x69, 0x6e, 0x70, 0x75, 0x74, 0x5f, 971 0x75, 0x72, 0x6c, 0x18, 0x05, 0x20, 0x01, 0x28, 0x09, 0x52, 0x08, 0x69, 0x6e, 0x70, 0x75, 0x74, 972 0x55, 0x72, 0x6c, 0x22, 0x49, 0x0a, 0x0c, 0x45, 0x6e, 0x74, 0x69, 0x74, 0x79, 0x46, 0x69, 0x6c, 973 0x74, 0x65, 0x72, 0x12, 0x14, 0x0a, 0x05, 0x6b, 0x69, 0x6e, 0x64, 0x73, 0x18, 0x01, 0x20, 0x03, 974 0x28, 0x09, 0x52, 0x05, 0x6b, 0x69, 0x6e, 0x64, 0x73, 0x12, 0x23, 0x0a, 0x0d, 0x6e, 0x61, 0x6d, 975 0x65, 0x73, 0x70, 0x61, 0x63, 0x65, 0x5f, 0x69, 0x64, 0x73, 0x18, 0x02, 0x20, 0x03, 0x28, 0x09, 976 0x52, 0x0c, 0x6e, 0x61, 0x6d, 0x65, 0x73, 0x70, 0x61, 0x63, 0x65, 0x49, 0x64, 0x73, 0x2a, 0x59, 977 0x0a, 0x0d, 0x4f, 0x70, 0x65, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x54, 0x79, 0x70, 0x65, 0x12, 978 0x1e, 0x0a, 0x1a, 0x4f, 0x50, 0x45, 0x52, 0x41, 0x54, 0x49, 0x4f, 0x4e, 0x5f, 0x54, 0x59, 0x50, 979 0x45, 0x5f, 0x55, 0x4e, 0x53, 0x50, 0x45, 0x43, 0x49, 0x46, 0x49, 0x45, 0x44, 0x10, 0x00, 0x12, 980 0x13, 0x0a, 0x0f, 0x45, 0x58, 0x50, 0x4f, 0x52, 0x54, 0x5f, 0x45, 0x4e, 0x54, 0x49, 0x54, 0x49, 981 0x45, 0x53, 0x10, 0x01, 0x12, 0x13, 0x0a, 0x0f, 0x49, 0x4d, 0x50, 0x4f, 0x52, 0x54, 0x5f, 0x45, 982 0x4e, 0x54, 0x49, 0x54, 0x49, 0x45, 0x53, 0x10, 0x02, 0x32, 0xc6, 0x02, 0x0a, 0x0e, 0x44, 0x61, 983 0x74, 0x61, 0x73, 0x74, 0x6f, 0x72, 0x65, 0x41, 0x64, 0x6d, 0x69, 0x6e, 0x12, 0x98, 0x01, 0x0a, 984 0x0e, 0x45, 0x78, 0x70, 0x6f, 0x72, 0x74, 0x45, 0x6e, 0x74, 0x69, 0x74, 0x69, 0x65, 0x73, 0x12, 985 0x35, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x64, 0x61, 0x74, 0x61, 0x73, 0x74, 0x6f, 986 0x72, 0x65, 0x2e, 0x61, 0x64, 0x6d, 0x69, 0x6e, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 987 0x2e, 0x45, 0x78, 0x70, 0x6f, 0x72, 0x74, 0x45, 0x6e, 0x74, 0x69, 0x74, 0x69, 0x65, 0x73, 0x52, 988 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x1d, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 989 0x6c, 0x6f, 0x6e, 0x67, 0x72, 0x75, 0x6e, 0x6e, 0x69, 0x6e, 0x67, 0x2e, 0x4f, 0x70, 0x65, 0x72, 990 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x22, 0x30, 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x2a, 0x22, 0x25, 0x2f, 991 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 0x2f, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x73, 992 0x2f, 0x7b, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x5f, 0x69, 0x64, 0x7d, 0x3a, 0x65, 0x78, 993 0x70, 0x6f, 0x72, 0x74, 0x3a, 0x01, 0x2a, 0x12, 0x98, 0x01, 0x0a, 0x0e, 0x49, 0x6d, 0x70, 0x6f, 994 0x72, 0x74, 0x45, 0x6e, 0x74, 0x69, 0x74, 0x69, 0x65, 0x73, 0x12, 0x35, 0x2e, 0x67, 0x6f, 0x6f, 995 0x67, 0x6c, 0x65, 0x2e, 0x64, 0x61, 0x74, 0x61, 0x73, 0x74, 0x6f, 0x72, 0x65, 0x2e, 0x61, 0x64, 996 0x6d, 0x69, 0x6e, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 0x2e, 0x49, 0x6d, 0x70, 0x6f, 997 0x72, 0x74, 0x45, 0x6e, 0x74, 0x69, 0x74, 0x69, 0x65, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 998 0x74, 0x1a, 0x1d, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x6c, 0x6f, 0x6e, 0x67, 0x72, 999 0x75, 0x6e, 0x6e, 0x69, 0x6e, 0x67, 0x2e, 0x4f, 0x70, 0x65, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 1000 0x22, 0x30, 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x2a, 0x22, 0x25, 0x2f, 0x76, 0x31, 0x62, 0x65, 0x74, 1001 0x61, 0x31, 0x2f, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x73, 0x2f, 0x7b, 0x70, 0x72, 0x6f, 1002 0x6a, 0x65, 0x63, 0x74, 0x5f, 0x69, 0x64, 0x7d, 0x3a, 0x69, 0x6d, 0x70, 0x6f, 0x72, 0x74, 0x3a, 1003 0x01, 0x2a, 0x42, 0xd2, 0x01, 0x0a, 0x22, 0x63, 0x6f, 0x6d, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 1004 0x65, 0x2e, 0x64, 0x61, 0x74, 0x61, 0x73, 0x74, 0x6f, 0x72, 0x65, 0x2e, 0x61, 0x64, 0x6d, 0x69, 1005 0x6e, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 0x42, 0x13, 0x44, 0x61, 0x74, 0x61, 0x73, 1006 0x74, 0x6f, 0x72, 0x65, 0x41, 0x64, 0x6d, 0x69, 0x6e, 0x50, 0x72, 0x6f, 0x74, 0x6f, 0x50, 0x01, 1007 0x5a, 0x43, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x67, 0x6f, 0x6c, 0x61, 0x6e, 0x67, 0x2e, 1008 0x6f, 0x72, 0x67, 0x2f, 0x67, 0x65, 0x6e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x2f, 0x67, 0x6f, 0x6f, 1009 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2f, 0x64, 0x61, 0x74, 0x61, 0x73, 0x74, 0x6f, 0x72, 1010 0x65, 0x2f, 0x61, 0x64, 0x6d, 0x69, 0x6e, 0x2f, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 0x3b, 1011 0x61, 0x64, 0x6d, 0x69, 0x6e, 0xaa, 0x02, 0x24, 0x47, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x43, 1012 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x44, 0x61, 0x74, 0x61, 0x73, 0x74, 0x6f, 0x72, 0x65, 0x2e, 0x41, 1013 0x64, 0x6d, 0x69, 0x6e, 0x2e, 0x56, 0x31, 0x42, 0x65, 0x74, 0x61, 0x31, 0xea, 0x02, 0x28, 0x47, 1014 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x3a, 0x3a, 0x43, 0x6c, 0x6f, 0x75, 0x64, 0x3a, 0x3a, 0x44, 0x61, 1015 0x74, 0x61, 0x73, 0x74, 0x6f, 0x72, 0x65, 0x3a, 0x3a, 0x41, 0x64, 0x6d, 0x69, 0x6e, 0x3a, 0x3a, 1016 0x56, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33, 1017} 1018 1019var ( 1020 file_google_datastore_admin_v1beta1_datastore_admin_proto_rawDescOnce sync.Once 1021 file_google_datastore_admin_v1beta1_datastore_admin_proto_rawDescData = file_google_datastore_admin_v1beta1_datastore_admin_proto_rawDesc 1022) 1023 1024func file_google_datastore_admin_v1beta1_datastore_admin_proto_rawDescGZIP() []byte { 1025 file_google_datastore_admin_v1beta1_datastore_admin_proto_rawDescOnce.Do(func() { 1026 file_google_datastore_admin_v1beta1_datastore_admin_proto_rawDescData = protoimpl.X.CompressGZIP(file_google_datastore_admin_v1beta1_datastore_admin_proto_rawDescData) 1027 }) 1028 return file_google_datastore_admin_v1beta1_datastore_admin_proto_rawDescData 1029} 1030 1031var file_google_datastore_admin_v1beta1_datastore_admin_proto_enumTypes = make([]protoimpl.EnumInfo, 2) 1032var file_google_datastore_admin_v1beta1_datastore_admin_proto_msgTypes = make([]protoimpl.MessageInfo, 11) 1033var file_google_datastore_admin_v1beta1_datastore_admin_proto_goTypes = []interface{}{ 1034 (OperationType)(0), // 0: google.datastore.admin.v1beta1.OperationType 1035 (CommonMetadata_State)(0), // 1: google.datastore.admin.v1beta1.CommonMetadata.State 1036 (*CommonMetadata)(nil), // 2: google.datastore.admin.v1beta1.CommonMetadata 1037 (*Progress)(nil), // 3: google.datastore.admin.v1beta1.Progress 1038 (*ExportEntitiesRequest)(nil), // 4: google.datastore.admin.v1beta1.ExportEntitiesRequest 1039 (*ImportEntitiesRequest)(nil), // 5: google.datastore.admin.v1beta1.ImportEntitiesRequest 1040 (*ExportEntitiesResponse)(nil), // 6: google.datastore.admin.v1beta1.ExportEntitiesResponse 1041 (*ExportEntitiesMetadata)(nil), // 7: google.datastore.admin.v1beta1.ExportEntitiesMetadata 1042 (*ImportEntitiesMetadata)(nil), // 8: google.datastore.admin.v1beta1.ImportEntitiesMetadata 1043 (*EntityFilter)(nil), // 9: google.datastore.admin.v1beta1.EntityFilter 1044 nil, // 10: google.datastore.admin.v1beta1.CommonMetadata.LabelsEntry 1045 nil, // 11: google.datastore.admin.v1beta1.ExportEntitiesRequest.LabelsEntry 1046 nil, // 12: google.datastore.admin.v1beta1.ImportEntitiesRequest.LabelsEntry 1047 (*timestamppb.Timestamp)(nil), // 13: google.protobuf.Timestamp 1048 (*longrunning.Operation)(nil), // 14: google.longrunning.Operation 1049} 1050var file_google_datastore_admin_v1beta1_datastore_admin_proto_depIdxs = []int32{ 1051 13, // 0: google.datastore.admin.v1beta1.CommonMetadata.start_time:type_name -> google.protobuf.Timestamp 1052 13, // 1: google.datastore.admin.v1beta1.CommonMetadata.end_time:type_name -> google.protobuf.Timestamp 1053 0, // 2: google.datastore.admin.v1beta1.CommonMetadata.operation_type:type_name -> google.datastore.admin.v1beta1.OperationType 1054 10, // 3: google.datastore.admin.v1beta1.CommonMetadata.labels:type_name -> google.datastore.admin.v1beta1.CommonMetadata.LabelsEntry 1055 1, // 4: google.datastore.admin.v1beta1.CommonMetadata.state:type_name -> google.datastore.admin.v1beta1.CommonMetadata.State 1056 11, // 5: google.datastore.admin.v1beta1.ExportEntitiesRequest.labels:type_name -> google.datastore.admin.v1beta1.ExportEntitiesRequest.LabelsEntry 1057 9, // 6: google.datastore.admin.v1beta1.ExportEntitiesRequest.entity_filter:type_name -> google.datastore.admin.v1beta1.EntityFilter 1058 12, // 7: google.datastore.admin.v1beta1.ImportEntitiesRequest.labels:type_name -> google.datastore.admin.v1beta1.ImportEntitiesRequest.LabelsEntry 1059 9, // 8: google.datastore.admin.v1beta1.ImportEntitiesRequest.entity_filter:type_name -> google.datastore.admin.v1beta1.EntityFilter 1060 2, // 9: google.datastore.admin.v1beta1.ExportEntitiesMetadata.common:type_name -> google.datastore.admin.v1beta1.CommonMetadata 1061 3, // 10: google.datastore.admin.v1beta1.ExportEntitiesMetadata.progress_entities:type_name -> google.datastore.admin.v1beta1.Progress 1062 3, // 11: google.datastore.admin.v1beta1.ExportEntitiesMetadata.progress_bytes:type_name -> google.datastore.admin.v1beta1.Progress 1063 9, // 12: google.datastore.admin.v1beta1.ExportEntitiesMetadata.entity_filter:type_name -> google.datastore.admin.v1beta1.EntityFilter 1064 2, // 13: google.datastore.admin.v1beta1.ImportEntitiesMetadata.common:type_name -> google.datastore.admin.v1beta1.CommonMetadata 1065 3, // 14: google.datastore.admin.v1beta1.ImportEntitiesMetadata.progress_entities:type_name -> google.datastore.admin.v1beta1.Progress 1066 3, // 15: google.datastore.admin.v1beta1.ImportEntitiesMetadata.progress_bytes:type_name -> google.datastore.admin.v1beta1.Progress 1067 9, // 16: google.datastore.admin.v1beta1.ImportEntitiesMetadata.entity_filter:type_name -> google.datastore.admin.v1beta1.EntityFilter 1068 4, // 17: google.datastore.admin.v1beta1.DatastoreAdmin.ExportEntities:input_type -> google.datastore.admin.v1beta1.ExportEntitiesRequest 1069 5, // 18: google.datastore.admin.v1beta1.DatastoreAdmin.ImportEntities:input_type -> google.datastore.admin.v1beta1.ImportEntitiesRequest 1070 14, // 19: google.datastore.admin.v1beta1.DatastoreAdmin.ExportEntities:output_type -> google.longrunning.Operation 1071 14, // 20: google.datastore.admin.v1beta1.DatastoreAdmin.ImportEntities:output_type -> google.longrunning.Operation 1072 19, // [19:21] is the sub-list for method output_type 1073 17, // [17:19] is the sub-list for method input_type 1074 17, // [17:17] is the sub-list for extension type_name 1075 17, // [17:17] is the sub-list for extension extendee 1076 0, // [0:17] is the sub-list for field type_name 1077} 1078 1079func init() { file_google_datastore_admin_v1beta1_datastore_admin_proto_init() } 1080func file_google_datastore_admin_v1beta1_datastore_admin_proto_init() { 1081 if File_google_datastore_admin_v1beta1_datastore_admin_proto != nil { 1082 return 1083 } 1084 if !protoimpl.UnsafeEnabled { 1085 file_google_datastore_admin_v1beta1_datastore_admin_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} { 1086 switch v := v.(*CommonMetadata); i { 1087 case 0: 1088 return &v.state 1089 case 1: 1090 return &v.sizeCache 1091 case 2: 1092 return &v.unknownFields 1093 default: 1094 return nil 1095 } 1096 } 1097 file_google_datastore_admin_v1beta1_datastore_admin_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} { 1098 switch v := v.(*Progress); 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_datastore_admin_v1beta1_datastore_admin_proto_msgTypes[2].Exporter = func(v interface{}, i int) interface{} { 1110 switch v := v.(*ExportEntitiesRequest); 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_datastore_admin_v1beta1_datastore_admin_proto_msgTypes[3].Exporter = func(v interface{}, i int) interface{} { 1122 switch v := v.(*ImportEntitiesRequest); 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_datastore_admin_v1beta1_datastore_admin_proto_msgTypes[4].Exporter = func(v interface{}, i int) interface{} { 1134 switch v := v.(*ExportEntitiesResponse); 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_datastore_admin_v1beta1_datastore_admin_proto_msgTypes[5].Exporter = func(v interface{}, i int) interface{} { 1146 switch v := v.(*ExportEntitiesMetadata); 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_datastore_admin_v1beta1_datastore_admin_proto_msgTypes[6].Exporter = func(v interface{}, i int) interface{} { 1158 switch v := v.(*ImportEntitiesMetadata); 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_datastore_admin_v1beta1_datastore_admin_proto_msgTypes[7].Exporter = func(v interface{}, i int) interface{} { 1170 switch v := v.(*EntityFilter); 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 } 1182 type x struct{} 1183 out := protoimpl.TypeBuilder{ 1184 File: protoimpl.DescBuilder{ 1185 GoPackagePath: reflect.TypeOf(x{}).PkgPath(), 1186 RawDescriptor: file_google_datastore_admin_v1beta1_datastore_admin_proto_rawDesc, 1187 NumEnums: 2, 1188 NumMessages: 11, 1189 NumExtensions: 0, 1190 NumServices: 1, 1191 }, 1192 GoTypes: file_google_datastore_admin_v1beta1_datastore_admin_proto_goTypes, 1193 DependencyIndexes: file_google_datastore_admin_v1beta1_datastore_admin_proto_depIdxs, 1194 EnumInfos: file_google_datastore_admin_v1beta1_datastore_admin_proto_enumTypes, 1195 MessageInfos: file_google_datastore_admin_v1beta1_datastore_admin_proto_msgTypes, 1196 }.Build() 1197 File_google_datastore_admin_v1beta1_datastore_admin_proto = out.File 1198 file_google_datastore_admin_v1beta1_datastore_admin_proto_rawDesc = nil 1199 file_google_datastore_admin_v1beta1_datastore_admin_proto_goTypes = nil 1200 file_google_datastore_admin_v1beta1_datastore_admin_proto_depIdxs = nil 1201} 1202 1203// Reference imports to suppress errors if they are not otherwise used. 1204var _ context.Context 1205var _ grpc.ClientConnInterface 1206 1207// This is a compile-time assertion to ensure that this generated file 1208// is compatible with the grpc package it is being compiled against. 1209const _ = grpc.SupportPackageIsVersion6 1210 1211// DatastoreAdminClient is the client API for DatastoreAdmin service. 1212// 1213// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream. 1214type DatastoreAdminClient interface { 1215 // Exports a copy of all or a subset of entities from Google Cloud Datastore 1216 // to another storage system, such as Google Cloud Storage. Recent updates to 1217 // entities may not be reflected in the export. The export occurs in the 1218 // background and its progress can be monitored and managed via the 1219 // Operation resource that is created. The output of an export may only be 1220 // used once the associated operation is done. If an export operation is 1221 // cancelled before completion it may leave partial data behind in Google 1222 // Cloud Storage. 1223 ExportEntities(ctx context.Context, in *ExportEntitiesRequest, opts ...grpc.CallOption) (*longrunning.Operation, error) 1224 // Imports entities into Google Cloud Datastore. Existing entities with the 1225 // same key are overwritten. The import occurs in the background and its 1226 // progress can be monitored and managed via the Operation resource that is 1227 // created. If an ImportEntities operation is cancelled, it is possible 1228 // that a subset of the data has already been imported to Cloud Datastore. 1229 ImportEntities(ctx context.Context, in *ImportEntitiesRequest, opts ...grpc.CallOption) (*longrunning.Operation, error) 1230} 1231 1232type datastoreAdminClient struct { 1233 cc grpc.ClientConnInterface 1234} 1235 1236func NewDatastoreAdminClient(cc grpc.ClientConnInterface) DatastoreAdminClient { 1237 return &datastoreAdminClient{cc} 1238} 1239 1240func (c *datastoreAdminClient) ExportEntities(ctx context.Context, in *ExportEntitiesRequest, opts ...grpc.CallOption) (*longrunning.Operation, error) { 1241 out := new(longrunning.Operation) 1242 err := c.cc.Invoke(ctx, "/google.datastore.admin.v1beta1.DatastoreAdmin/ExportEntities", in, out, opts...) 1243 if err != nil { 1244 return nil, err 1245 } 1246 return out, nil 1247} 1248 1249func (c *datastoreAdminClient) ImportEntities(ctx context.Context, in *ImportEntitiesRequest, opts ...grpc.CallOption) (*longrunning.Operation, error) { 1250 out := new(longrunning.Operation) 1251 err := c.cc.Invoke(ctx, "/google.datastore.admin.v1beta1.DatastoreAdmin/ImportEntities", in, out, opts...) 1252 if err != nil { 1253 return nil, err 1254 } 1255 return out, nil 1256} 1257 1258// DatastoreAdminServer is the server API for DatastoreAdmin service. 1259type DatastoreAdminServer interface { 1260 // Exports a copy of all or a subset of entities from Google Cloud Datastore 1261 // to another storage system, such as Google Cloud Storage. Recent updates to 1262 // entities may not be reflected in the export. The export occurs in the 1263 // background and its progress can be monitored and managed via the 1264 // Operation resource that is created. The output of an export may only be 1265 // used once the associated operation is done. If an export operation is 1266 // cancelled before completion it may leave partial data behind in Google 1267 // Cloud Storage. 1268 ExportEntities(context.Context, *ExportEntitiesRequest) (*longrunning.Operation, error) 1269 // Imports entities into Google Cloud Datastore. Existing entities with the 1270 // same key are overwritten. The import occurs in the background and its 1271 // progress can be monitored and managed via the Operation resource that is 1272 // created. If an ImportEntities operation is cancelled, it is possible 1273 // that a subset of the data has already been imported to Cloud Datastore. 1274 ImportEntities(context.Context, *ImportEntitiesRequest) (*longrunning.Operation, error) 1275} 1276 1277// UnimplementedDatastoreAdminServer can be embedded to have forward compatible implementations. 1278type UnimplementedDatastoreAdminServer struct { 1279} 1280 1281func (*UnimplementedDatastoreAdminServer) ExportEntities(context.Context, *ExportEntitiesRequest) (*longrunning.Operation, error) { 1282 return nil, status.Errorf(codes.Unimplemented, "method ExportEntities not implemented") 1283} 1284func (*UnimplementedDatastoreAdminServer) ImportEntities(context.Context, *ImportEntitiesRequest) (*longrunning.Operation, error) { 1285 return nil, status.Errorf(codes.Unimplemented, "method ImportEntities not implemented") 1286} 1287 1288func RegisterDatastoreAdminServer(s *grpc.Server, srv DatastoreAdminServer) { 1289 s.RegisterService(&_DatastoreAdmin_serviceDesc, srv) 1290} 1291 1292func _DatastoreAdmin_ExportEntities_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 1293 in := new(ExportEntitiesRequest) 1294 if err := dec(in); err != nil { 1295 return nil, err 1296 } 1297 if interceptor == nil { 1298 return srv.(DatastoreAdminServer).ExportEntities(ctx, in) 1299 } 1300 info := &grpc.UnaryServerInfo{ 1301 Server: srv, 1302 FullMethod: "/google.datastore.admin.v1beta1.DatastoreAdmin/ExportEntities", 1303 } 1304 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 1305 return srv.(DatastoreAdminServer).ExportEntities(ctx, req.(*ExportEntitiesRequest)) 1306 } 1307 return interceptor(ctx, in, info, handler) 1308} 1309 1310func _DatastoreAdmin_ImportEntities_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 1311 in := new(ImportEntitiesRequest) 1312 if err := dec(in); err != nil { 1313 return nil, err 1314 } 1315 if interceptor == nil { 1316 return srv.(DatastoreAdminServer).ImportEntities(ctx, in) 1317 } 1318 info := &grpc.UnaryServerInfo{ 1319 Server: srv, 1320 FullMethod: "/google.datastore.admin.v1beta1.DatastoreAdmin/ImportEntities", 1321 } 1322 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 1323 return srv.(DatastoreAdminServer).ImportEntities(ctx, req.(*ImportEntitiesRequest)) 1324 } 1325 return interceptor(ctx, in, info, handler) 1326} 1327 1328var _DatastoreAdmin_serviceDesc = grpc.ServiceDesc{ 1329 ServiceName: "google.datastore.admin.v1beta1.DatastoreAdmin", 1330 HandlerType: (*DatastoreAdminServer)(nil), 1331 Methods: []grpc.MethodDesc{ 1332 { 1333 MethodName: "ExportEntities", 1334 Handler: _DatastoreAdmin_ExportEntities_Handler, 1335 }, 1336 { 1337 MethodName: "ImportEntities", 1338 Handler: _DatastoreAdmin_ImportEntities_Handler, 1339 }, 1340 }, 1341 Streams: []grpc.StreamDesc{}, 1342 Metadata: "google/datastore/admin/v1beta1/datastore_admin.proto", 1343} 1344