1// Code generated by protoc-gen-go. DO NOT EDIT. 2// source: google/datastore/admin/v1beta1/datastore_admin.proto 3 4package admin 5 6import ( 7 context "context" 8 fmt "fmt" 9 math "math" 10 11 proto "github.com/golang/protobuf/proto" 12 timestamp "github.com/golang/protobuf/ptypes/timestamp" 13 _ "google.golang.org/genproto/googleapis/api/annotations" 14 longrunning "google.golang.org/genproto/googleapis/longrunning" 15 grpc "google.golang.org/grpc" 16) 17 18// Reference imports to suppress errors if they are not otherwise used. 19var _ = proto.Marshal 20var _ = fmt.Errorf 21var _ = math.Inf 22 23// This is a compile-time assertion to ensure that this generated file 24// is compatible with the proto package it is being compiled against. 25// A compilation error at this line likely means your copy of the 26// proto package needs to be updated. 27const _ = proto.ProtoPackageIsVersion3 // please upgrade the proto package 28 29// Operation types. 30type OperationType int32 31 32const ( 33 // Unspecified. 34 OperationType_OPERATION_TYPE_UNSPECIFIED OperationType = 0 35 // ExportEntities. 36 OperationType_EXPORT_ENTITIES OperationType = 1 37 // ImportEntities. 38 OperationType_IMPORT_ENTITIES OperationType = 2 39) 40 41var OperationType_name = map[int32]string{ 42 0: "OPERATION_TYPE_UNSPECIFIED", 43 1: "EXPORT_ENTITIES", 44 2: "IMPORT_ENTITIES", 45} 46 47var OperationType_value = map[string]int32{ 48 "OPERATION_TYPE_UNSPECIFIED": 0, 49 "EXPORT_ENTITIES": 1, 50 "IMPORT_ENTITIES": 2, 51} 52 53func (x OperationType) String() string { 54 return proto.EnumName(OperationType_name, int32(x)) 55} 56 57func (OperationType) EnumDescriptor() ([]byte, []int) { 58 return fileDescriptor_b63216f38706ce20, []int{0} 59} 60 61// The various possible states for an ongoing Operation. 62type CommonMetadata_State int32 63 64const ( 65 // Unspecified. 66 CommonMetadata_STATE_UNSPECIFIED CommonMetadata_State = 0 67 // Request is being prepared for processing. 68 CommonMetadata_INITIALIZING CommonMetadata_State = 1 69 // Request is actively being processed. 70 CommonMetadata_PROCESSING CommonMetadata_State = 2 71 // Request is in the process of being cancelled after user called 72 // google.longrunning.Operations.CancelOperation on the operation. 73 CommonMetadata_CANCELLING CommonMetadata_State = 3 74 // Request has been processed and is in its finalization stage. 75 CommonMetadata_FINALIZING CommonMetadata_State = 4 76 // Request has completed successfully. 77 CommonMetadata_SUCCESSFUL CommonMetadata_State = 5 78 // Request has finished being processed, but encountered an error. 79 CommonMetadata_FAILED CommonMetadata_State = 6 80 // Request has finished being cancelled after user called 81 // google.longrunning.Operations.CancelOperation. 82 CommonMetadata_CANCELLED CommonMetadata_State = 7 83) 84 85var CommonMetadata_State_name = map[int32]string{ 86 0: "STATE_UNSPECIFIED", 87 1: "INITIALIZING", 88 2: "PROCESSING", 89 3: "CANCELLING", 90 4: "FINALIZING", 91 5: "SUCCESSFUL", 92 6: "FAILED", 93 7: "CANCELLED", 94} 95 96var CommonMetadata_State_value = map[string]int32{ 97 "STATE_UNSPECIFIED": 0, 98 "INITIALIZING": 1, 99 "PROCESSING": 2, 100 "CANCELLING": 3, 101 "FINALIZING": 4, 102 "SUCCESSFUL": 5, 103 "FAILED": 6, 104 "CANCELLED": 7, 105} 106 107func (x CommonMetadata_State) String() string { 108 return proto.EnumName(CommonMetadata_State_name, int32(x)) 109} 110 111func (CommonMetadata_State) EnumDescriptor() ([]byte, []int) { 112 return fileDescriptor_b63216f38706ce20, []int{0, 0} 113} 114 115// Metadata common to all Datastore Admin operations. 116type CommonMetadata struct { 117 // The time that work began on the operation. 118 StartTime *timestamp.Timestamp `protobuf:"bytes,1,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"` 119 // The time the operation ended, either successfully or otherwise. 120 EndTime *timestamp.Timestamp `protobuf:"bytes,2,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"` 121 // The type of the operation. Can be used as a filter in 122 // ListOperationsRequest. 123 OperationType OperationType `protobuf:"varint,3,opt,name=operation_type,json=operationType,proto3,enum=google.datastore.admin.v1beta1.OperationType" json:"operation_type,omitempty"` 124 // The client-assigned labels which were provided when the operation was 125 // created. May also include additional labels. 126 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"` 127 // The current state of the Operation. 128 State CommonMetadata_State `protobuf:"varint,5,opt,name=state,proto3,enum=google.datastore.admin.v1beta1.CommonMetadata_State" json:"state,omitempty"` 129 XXX_NoUnkeyedLiteral struct{} `json:"-"` 130 XXX_unrecognized []byte `json:"-"` 131 XXX_sizecache int32 `json:"-"` 132} 133 134func (m *CommonMetadata) Reset() { *m = CommonMetadata{} } 135func (m *CommonMetadata) String() string { return proto.CompactTextString(m) } 136func (*CommonMetadata) ProtoMessage() {} 137func (*CommonMetadata) Descriptor() ([]byte, []int) { 138 return fileDescriptor_b63216f38706ce20, []int{0} 139} 140 141func (m *CommonMetadata) XXX_Unmarshal(b []byte) error { 142 return xxx_messageInfo_CommonMetadata.Unmarshal(m, b) 143} 144func (m *CommonMetadata) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 145 return xxx_messageInfo_CommonMetadata.Marshal(b, m, deterministic) 146} 147func (m *CommonMetadata) XXX_Merge(src proto.Message) { 148 xxx_messageInfo_CommonMetadata.Merge(m, src) 149} 150func (m *CommonMetadata) XXX_Size() int { 151 return xxx_messageInfo_CommonMetadata.Size(m) 152} 153func (m *CommonMetadata) XXX_DiscardUnknown() { 154 xxx_messageInfo_CommonMetadata.DiscardUnknown(m) 155} 156 157var xxx_messageInfo_CommonMetadata proto.InternalMessageInfo 158 159func (m *CommonMetadata) GetStartTime() *timestamp.Timestamp { 160 if m != nil { 161 return m.StartTime 162 } 163 return nil 164} 165 166func (m *CommonMetadata) GetEndTime() *timestamp.Timestamp { 167 if m != nil { 168 return m.EndTime 169 } 170 return nil 171} 172 173func (m *CommonMetadata) GetOperationType() OperationType { 174 if m != nil { 175 return m.OperationType 176 } 177 return OperationType_OPERATION_TYPE_UNSPECIFIED 178} 179 180func (m *CommonMetadata) GetLabels() map[string]string { 181 if m != nil { 182 return m.Labels 183 } 184 return nil 185} 186 187func (m *CommonMetadata) GetState() CommonMetadata_State { 188 if m != nil { 189 return m.State 190 } 191 return CommonMetadata_STATE_UNSPECIFIED 192} 193 194// Measures the progress of a particular metric. 195type Progress struct { 196 // The amount of work that has been completed. Note that this may be greater 197 // than work_estimated. 198 WorkCompleted int64 `protobuf:"varint,1,opt,name=work_completed,json=workCompleted,proto3" json:"work_completed,omitempty"` 199 // An estimate of how much work needs to be performed. May be zero if the 200 // work estimate is unavailable. 201 WorkEstimated int64 `protobuf:"varint,2,opt,name=work_estimated,json=workEstimated,proto3" json:"work_estimated,omitempty"` 202 XXX_NoUnkeyedLiteral struct{} `json:"-"` 203 XXX_unrecognized []byte `json:"-"` 204 XXX_sizecache int32 `json:"-"` 205} 206 207func (m *Progress) Reset() { *m = Progress{} } 208func (m *Progress) String() string { return proto.CompactTextString(m) } 209func (*Progress) ProtoMessage() {} 210func (*Progress) Descriptor() ([]byte, []int) { 211 return fileDescriptor_b63216f38706ce20, []int{1} 212} 213 214func (m *Progress) XXX_Unmarshal(b []byte) error { 215 return xxx_messageInfo_Progress.Unmarshal(m, b) 216} 217func (m *Progress) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 218 return xxx_messageInfo_Progress.Marshal(b, m, deterministic) 219} 220func (m *Progress) XXX_Merge(src proto.Message) { 221 xxx_messageInfo_Progress.Merge(m, src) 222} 223func (m *Progress) XXX_Size() int { 224 return xxx_messageInfo_Progress.Size(m) 225} 226func (m *Progress) XXX_DiscardUnknown() { 227 xxx_messageInfo_Progress.DiscardUnknown(m) 228} 229 230var xxx_messageInfo_Progress proto.InternalMessageInfo 231 232func (m *Progress) GetWorkCompleted() int64 { 233 if m != nil { 234 return m.WorkCompleted 235 } 236 return 0 237} 238 239func (m *Progress) GetWorkEstimated() int64 { 240 if m != nil { 241 return m.WorkEstimated 242 } 243 return 0 244} 245 246// The request for 247// [google.datastore.admin.v1beta1.DatastoreAdmin.ExportEntities][google.datastore.admin.v1beta1.DatastoreAdmin.ExportEntities]. 248type ExportEntitiesRequest struct { 249 // Project ID against which to make the request. 250 ProjectId string `protobuf:"bytes,1,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"` 251 // Client-assigned labels. 252 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"` 253 // Description of what data from the project is included in the export. 254 EntityFilter *EntityFilter `protobuf:"bytes,3,opt,name=entity_filter,json=entityFilter,proto3" json:"entity_filter,omitempty"` 255 // Location for the export metadata and data files. 256 // 257 // The full resource URL of the external storage location. Currently, only 258 // Google Cloud Storage is supported. So output_url_prefix should be of the 259 // form: `gs://BUCKET_NAME[/NAMESPACE_PATH]`, where `BUCKET_NAME` is the 260 // name of the Cloud Storage bucket and `NAMESPACE_PATH` is an optional Cloud 261 // Storage namespace path (this is not a Cloud Datastore namespace). For more 262 // information about Cloud Storage namespace paths, see 263 // [Object name 264 // considerations](https://cloud.google.com/storage/docs/naming#object-considerations). 265 // 266 // The resulting files will be nested deeper than the specified URL prefix. 267 // The final output URL will be provided in the 268 // [google.datastore.admin.v1beta1.ExportEntitiesResponse.output_url][google.datastore.admin.v1beta1.ExportEntitiesResponse.output_url] 269 // field. That value should be used for subsequent ImportEntities operations. 270 // 271 // By nesting the data files deeper, the same Cloud Storage bucket can be used 272 // in multiple ExportEntities operations without conflict. 273 OutputUrlPrefix string `protobuf:"bytes,4,opt,name=output_url_prefix,json=outputUrlPrefix,proto3" json:"output_url_prefix,omitempty"` 274 XXX_NoUnkeyedLiteral struct{} `json:"-"` 275 XXX_unrecognized []byte `json:"-"` 276 XXX_sizecache int32 `json:"-"` 277} 278 279func (m *ExportEntitiesRequest) Reset() { *m = ExportEntitiesRequest{} } 280func (m *ExportEntitiesRequest) String() string { return proto.CompactTextString(m) } 281func (*ExportEntitiesRequest) ProtoMessage() {} 282func (*ExportEntitiesRequest) Descriptor() ([]byte, []int) { 283 return fileDescriptor_b63216f38706ce20, []int{2} 284} 285 286func (m *ExportEntitiesRequest) XXX_Unmarshal(b []byte) error { 287 return xxx_messageInfo_ExportEntitiesRequest.Unmarshal(m, b) 288} 289func (m *ExportEntitiesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 290 return xxx_messageInfo_ExportEntitiesRequest.Marshal(b, m, deterministic) 291} 292func (m *ExportEntitiesRequest) XXX_Merge(src proto.Message) { 293 xxx_messageInfo_ExportEntitiesRequest.Merge(m, src) 294} 295func (m *ExportEntitiesRequest) XXX_Size() int { 296 return xxx_messageInfo_ExportEntitiesRequest.Size(m) 297} 298func (m *ExportEntitiesRequest) XXX_DiscardUnknown() { 299 xxx_messageInfo_ExportEntitiesRequest.DiscardUnknown(m) 300} 301 302var xxx_messageInfo_ExportEntitiesRequest proto.InternalMessageInfo 303 304func (m *ExportEntitiesRequest) GetProjectId() string { 305 if m != nil { 306 return m.ProjectId 307 } 308 return "" 309} 310 311func (m *ExportEntitiesRequest) GetLabels() map[string]string { 312 if m != nil { 313 return m.Labels 314 } 315 return nil 316} 317 318func (m *ExportEntitiesRequest) GetEntityFilter() *EntityFilter { 319 if m != nil { 320 return m.EntityFilter 321 } 322 return nil 323} 324 325func (m *ExportEntitiesRequest) GetOutputUrlPrefix() string { 326 if m != nil { 327 return m.OutputUrlPrefix 328 } 329 return "" 330} 331 332// The request for 333// [google.datastore.admin.v1beta1.DatastoreAdmin.ImportEntities][google.datastore.admin.v1beta1.DatastoreAdmin.ImportEntities]. 334type ImportEntitiesRequest struct { 335 // Project ID against which to make the request. 336 ProjectId string `protobuf:"bytes,1,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"` 337 // Client-assigned labels. 338 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"` 339 // The full resource URL of the external storage location. Currently, only 340 // Google Cloud Storage is supported. So input_url should be of the form: 341 // `gs://BUCKET_NAME[/NAMESPACE_PATH]/OVERALL_EXPORT_METADATA_FILE`, where 342 // `BUCKET_NAME` is the name of the Cloud Storage bucket, `NAMESPACE_PATH` is 343 // an optional Cloud Storage namespace path (this is not a Cloud Datastore 344 // namespace), and `OVERALL_EXPORT_METADATA_FILE` is the metadata file written 345 // by the ExportEntities operation. For more information about Cloud Storage 346 // namespace paths, see 347 // [Object name 348 // considerations](https://cloud.google.com/storage/docs/naming#object-considerations). 349 // 350 // For more information, see 351 // [google.datastore.admin.v1beta1.ExportEntitiesResponse.output_url][google.datastore.admin.v1beta1.ExportEntitiesResponse.output_url]. 352 InputUrl string `protobuf:"bytes,3,opt,name=input_url,json=inputUrl,proto3" json:"input_url,omitempty"` 353 // Optionally specify which kinds/namespaces are to be imported. If provided, 354 // the list must be a subset of the EntityFilter used in creating the export, 355 // otherwise a FAILED_PRECONDITION error will be returned. If no filter is 356 // specified then all entities from the export are imported. 357 EntityFilter *EntityFilter `protobuf:"bytes,4,opt,name=entity_filter,json=entityFilter,proto3" json:"entity_filter,omitempty"` 358 XXX_NoUnkeyedLiteral struct{} `json:"-"` 359 XXX_unrecognized []byte `json:"-"` 360 XXX_sizecache int32 `json:"-"` 361} 362 363func (m *ImportEntitiesRequest) Reset() { *m = ImportEntitiesRequest{} } 364func (m *ImportEntitiesRequest) String() string { return proto.CompactTextString(m) } 365func (*ImportEntitiesRequest) ProtoMessage() {} 366func (*ImportEntitiesRequest) Descriptor() ([]byte, []int) { 367 return fileDescriptor_b63216f38706ce20, []int{3} 368} 369 370func (m *ImportEntitiesRequest) XXX_Unmarshal(b []byte) error { 371 return xxx_messageInfo_ImportEntitiesRequest.Unmarshal(m, b) 372} 373func (m *ImportEntitiesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 374 return xxx_messageInfo_ImportEntitiesRequest.Marshal(b, m, deterministic) 375} 376func (m *ImportEntitiesRequest) XXX_Merge(src proto.Message) { 377 xxx_messageInfo_ImportEntitiesRequest.Merge(m, src) 378} 379func (m *ImportEntitiesRequest) XXX_Size() int { 380 return xxx_messageInfo_ImportEntitiesRequest.Size(m) 381} 382func (m *ImportEntitiesRequest) XXX_DiscardUnknown() { 383 xxx_messageInfo_ImportEntitiesRequest.DiscardUnknown(m) 384} 385 386var xxx_messageInfo_ImportEntitiesRequest proto.InternalMessageInfo 387 388func (m *ImportEntitiesRequest) GetProjectId() string { 389 if m != nil { 390 return m.ProjectId 391 } 392 return "" 393} 394 395func (m *ImportEntitiesRequest) GetLabels() map[string]string { 396 if m != nil { 397 return m.Labels 398 } 399 return nil 400} 401 402func (m *ImportEntitiesRequest) GetInputUrl() string { 403 if m != nil { 404 return m.InputUrl 405 } 406 return "" 407} 408 409func (m *ImportEntitiesRequest) GetEntityFilter() *EntityFilter { 410 if m != nil { 411 return m.EntityFilter 412 } 413 return nil 414} 415 416// The response for 417// [google.datastore.admin.v1beta1.DatastoreAdmin.ExportEntities][google.datastore.admin.v1beta1.DatastoreAdmin.ExportEntities]. 418type ExportEntitiesResponse struct { 419 // Location of the output metadata file. This can be used to begin an import 420 // into Cloud Datastore (this project or another project). See 421 // [google.datastore.admin.v1beta1.ImportEntitiesRequest.input_url][google.datastore.admin.v1beta1.ImportEntitiesRequest.input_url]. 422 // Only present if the operation completed successfully. 423 OutputUrl string `protobuf:"bytes,1,opt,name=output_url,json=outputUrl,proto3" json:"output_url,omitempty"` 424 XXX_NoUnkeyedLiteral struct{} `json:"-"` 425 XXX_unrecognized []byte `json:"-"` 426 XXX_sizecache int32 `json:"-"` 427} 428 429func (m *ExportEntitiesResponse) Reset() { *m = ExportEntitiesResponse{} } 430func (m *ExportEntitiesResponse) String() string { return proto.CompactTextString(m) } 431func (*ExportEntitiesResponse) ProtoMessage() {} 432func (*ExportEntitiesResponse) Descriptor() ([]byte, []int) { 433 return fileDescriptor_b63216f38706ce20, []int{4} 434} 435 436func (m *ExportEntitiesResponse) XXX_Unmarshal(b []byte) error { 437 return xxx_messageInfo_ExportEntitiesResponse.Unmarshal(m, b) 438} 439func (m *ExportEntitiesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 440 return xxx_messageInfo_ExportEntitiesResponse.Marshal(b, m, deterministic) 441} 442func (m *ExportEntitiesResponse) XXX_Merge(src proto.Message) { 443 xxx_messageInfo_ExportEntitiesResponse.Merge(m, src) 444} 445func (m *ExportEntitiesResponse) XXX_Size() int { 446 return xxx_messageInfo_ExportEntitiesResponse.Size(m) 447} 448func (m *ExportEntitiesResponse) XXX_DiscardUnknown() { 449 xxx_messageInfo_ExportEntitiesResponse.DiscardUnknown(m) 450} 451 452var xxx_messageInfo_ExportEntitiesResponse proto.InternalMessageInfo 453 454func (m *ExportEntitiesResponse) GetOutputUrl() string { 455 if m != nil { 456 return m.OutputUrl 457 } 458 return "" 459} 460 461// Metadata for ExportEntities operations. 462type ExportEntitiesMetadata struct { 463 // Metadata common to all Datastore Admin operations. 464 Common *CommonMetadata `protobuf:"bytes,1,opt,name=common,proto3" json:"common,omitempty"` 465 // An estimate of the number of entities processed. 466 ProgressEntities *Progress `protobuf:"bytes,2,opt,name=progress_entities,json=progressEntities,proto3" json:"progress_entities,omitempty"` 467 // An estimate of the number of bytes processed. 468 ProgressBytes *Progress `protobuf:"bytes,3,opt,name=progress_bytes,json=progressBytes,proto3" json:"progress_bytes,omitempty"` 469 // Description of which entities are being exported. 470 EntityFilter *EntityFilter `protobuf:"bytes,4,opt,name=entity_filter,json=entityFilter,proto3" json:"entity_filter,omitempty"` 471 // Location for the export metadata and data files. This will be the same 472 // value as the 473 // [google.datastore.admin.v1beta1.ExportEntitiesRequest.output_url_prefix][google.datastore.admin.v1beta1.ExportEntitiesRequest.output_url_prefix] 474 // field. The final output location is provided in 475 // [google.datastore.admin.v1beta1.ExportEntitiesResponse.output_url][google.datastore.admin.v1beta1.ExportEntitiesResponse.output_url]. 476 OutputUrlPrefix string `protobuf:"bytes,5,opt,name=output_url_prefix,json=outputUrlPrefix,proto3" json:"output_url_prefix,omitempty"` 477 XXX_NoUnkeyedLiteral struct{} `json:"-"` 478 XXX_unrecognized []byte `json:"-"` 479 XXX_sizecache int32 `json:"-"` 480} 481 482func (m *ExportEntitiesMetadata) Reset() { *m = ExportEntitiesMetadata{} } 483func (m *ExportEntitiesMetadata) String() string { return proto.CompactTextString(m) } 484func (*ExportEntitiesMetadata) ProtoMessage() {} 485func (*ExportEntitiesMetadata) Descriptor() ([]byte, []int) { 486 return fileDescriptor_b63216f38706ce20, []int{5} 487} 488 489func (m *ExportEntitiesMetadata) XXX_Unmarshal(b []byte) error { 490 return xxx_messageInfo_ExportEntitiesMetadata.Unmarshal(m, b) 491} 492func (m *ExportEntitiesMetadata) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 493 return xxx_messageInfo_ExportEntitiesMetadata.Marshal(b, m, deterministic) 494} 495func (m *ExportEntitiesMetadata) XXX_Merge(src proto.Message) { 496 xxx_messageInfo_ExportEntitiesMetadata.Merge(m, src) 497} 498func (m *ExportEntitiesMetadata) XXX_Size() int { 499 return xxx_messageInfo_ExportEntitiesMetadata.Size(m) 500} 501func (m *ExportEntitiesMetadata) XXX_DiscardUnknown() { 502 xxx_messageInfo_ExportEntitiesMetadata.DiscardUnknown(m) 503} 504 505var xxx_messageInfo_ExportEntitiesMetadata proto.InternalMessageInfo 506 507func (m *ExportEntitiesMetadata) GetCommon() *CommonMetadata { 508 if m != nil { 509 return m.Common 510 } 511 return nil 512} 513 514func (m *ExportEntitiesMetadata) GetProgressEntities() *Progress { 515 if m != nil { 516 return m.ProgressEntities 517 } 518 return nil 519} 520 521func (m *ExportEntitiesMetadata) GetProgressBytes() *Progress { 522 if m != nil { 523 return m.ProgressBytes 524 } 525 return nil 526} 527 528func (m *ExportEntitiesMetadata) GetEntityFilter() *EntityFilter { 529 if m != nil { 530 return m.EntityFilter 531 } 532 return nil 533} 534 535func (m *ExportEntitiesMetadata) GetOutputUrlPrefix() string { 536 if m != nil { 537 return m.OutputUrlPrefix 538 } 539 return "" 540} 541 542// Metadata for ImportEntities operations. 543type ImportEntitiesMetadata struct { 544 // Metadata common to all Datastore Admin operations. 545 Common *CommonMetadata `protobuf:"bytes,1,opt,name=common,proto3" json:"common,omitempty"` 546 // An estimate of the number of entities processed. 547 ProgressEntities *Progress `protobuf:"bytes,2,opt,name=progress_entities,json=progressEntities,proto3" json:"progress_entities,omitempty"` 548 // An estimate of the number of bytes processed. 549 ProgressBytes *Progress `protobuf:"bytes,3,opt,name=progress_bytes,json=progressBytes,proto3" json:"progress_bytes,omitempty"` 550 // Description of which entities are being imported. 551 EntityFilter *EntityFilter `protobuf:"bytes,4,opt,name=entity_filter,json=entityFilter,proto3" json:"entity_filter,omitempty"` 552 // The location of the import metadata file. This will be the same value as 553 // the 554 // [google.datastore.admin.v1beta1.ExportEntitiesResponse.output_url][google.datastore.admin.v1beta1.ExportEntitiesResponse.output_url] 555 // field. 556 InputUrl string `protobuf:"bytes,5,opt,name=input_url,json=inputUrl,proto3" json:"input_url,omitempty"` 557 XXX_NoUnkeyedLiteral struct{} `json:"-"` 558 XXX_unrecognized []byte `json:"-"` 559 XXX_sizecache int32 `json:"-"` 560} 561 562func (m *ImportEntitiesMetadata) Reset() { *m = ImportEntitiesMetadata{} } 563func (m *ImportEntitiesMetadata) String() string { return proto.CompactTextString(m) } 564func (*ImportEntitiesMetadata) ProtoMessage() {} 565func (*ImportEntitiesMetadata) Descriptor() ([]byte, []int) { 566 return fileDescriptor_b63216f38706ce20, []int{6} 567} 568 569func (m *ImportEntitiesMetadata) XXX_Unmarshal(b []byte) error { 570 return xxx_messageInfo_ImportEntitiesMetadata.Unmarshal(m, b) 571} 572func (m *ImportEntitiesMetadata) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 573 return xxx_messageInfo_ImportEntitiesMetadata.Marshal(b, m, deterministic) 574} 575func (m *ImportEntitiesMetadata) XXX_Merge(src proto.Message) { 576 xxx_messageInfo_ImportEntitiesMetadata.Merge(m, src) 577} 578func (m *ImportEntitiesMetadata) XXX_Size() int { 579 return xxx_messageInfo_ImportEntitiesMetadata.Size(m) 580} 581func (m *ImportEntitiesMetadata) XXX_DiscardUnknown() { 582 xxx_messageInfo_ImportEntitiesMetadata.DiscardUnknown(m) 583} 584 585var xxx_messageInfo_ImportEntitiesMetadata proto.InternalMessageInfo 586 587func (m *ImportEntitiesMetadata) GetCommon() *CommonMetadata { 588 if m != nil { 589 return m.Common 590 } 591 return nil 592} 593 594func (m *ImportEntitiesMetadata) GetProgressEntities() *Progress { 595 if m != nil { 596 return m.ProgressEntities 597 } 598 return nil 599} 600 601func (m *ImportEntitiesMetadata) GetProgressBytes() *Progress { 602 if m != nil { 603 return m.ProgressBytes 604 } 605 return nil 606} 607 608func (m *ImportEntitiesMetadata) GetEntityFilter() *EntityFilter { 609 if m != nil { 610 return m.EntityFilter 611 } 612 return nil 613} 614 615func (m *ImportEntitiesMetadata) GetInputUrl() string { 616 if m != nil { 617 return m.InputUrl 618 } 619 return "" 620} 621 622// Identifies a subset of entities in a project. This is specified as 623// combinations of kinds and namespaces (either or both of which may be all, as 624// described in the following examples). 625// Example usage: 626// 627// Entire project: 628// kinds=[], namespace_ids=[] 629// 630// Kinds Foo and Bar in all namespaces: 631// kinds=['Foo', 'Bar'], namespace_ids=[] 632// 633// Kinds Foo and Bar only in the default namespace: 634// kinds=['Foo', 'Bar'], namespace_ids=[''] 635// 636// Kinds Foo and Bar in both the default and Baz namespaces: 637// kinds=['Foo', 'Bar'], namespace_ids=['', 'Baz'] 638// 639// The entire Baz namespace: 640// kinds=[], namespace_ids=['Baz'] 641type EntityFilter struct { 642 // If empty, then this represents all kinds. 643 Kinds []string `protobuf:"bytes,1,rep,name=kinds,proto3" json:"kinds,omitempty"` 644 // An empty list represents all namespaces. This is the preferred 645 // usage for projects that don't use namespaces. 646 // 647 // An empty string element represents the default namespace. This should be 648 // used if the project has data in non-default namespaces, but doesn't want to 649 // include them. 650 // Each namespace in this list must be unique. 651 NamespaceIds []string `protobuf:"bytes,2,rep,name=namespace_ids,json=namespaceIds,proto3" json:"namespace_ids,omitempty"` 652 XXX_NoUnkeyedLiteral struct{} `json:"-"` 653 XXX_unrecognized []byte `json:"-"` 654 XXX_sizecache int32 `json:"-"` 655} 656 657func (m *EntityFilter) Reset() { *m = EntityFilter{} } 658func (m *EntityFilter) String() string { return proto.CompactTextString(m) } 659func (*EntityFilter) ProtoMessage() {} 660func (*EntityFilter) Descriptor() ([]byte, []int) { 661 return fileDescriptor_b63216f38706ce20, []int{7} 662} 663 664func (m *EntityFilter) XXX_Unmarshal(b []byte) error { 665 return xxx_messageInfo_EntityFilter.Unmarshal(m, b) 666} 667func (m *EntityFilter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 668 return xxx_messageInfo_EntityFilter.Marshal(b, m, deterministic) 669} 670func (m *EntityFilter) XXX_Merge(src proto.Message) { 671 xxx_messageInfo_EntityFilter.Merge(m, src) 672} 673func (m *EntityFilter) XXX_Size() int { 674 return xxx_messageInfo_EntityFilter.Size(m) 675} 676func (m *EntityFilter) XXX_DiscardUnknown() { 677 xxx_messageInfo_EntityFilter.DiscardUnknown(m) 678} 679 680var xxx_messageInfo_EntityFilter proto.InternalMessageInfo 681 682func (m *EntityFilter) GetKinds() []string { 683 if m != nil { 684 return m.Kinds 685 } 686 return nil 687} 688 689func (m *EntityFilter) GetNamespaceIds() []string { 690 if m != nil { 691 return m.NamespaceIds 692 } 693 return nil 694} 695 696func init() { 697 proto.RegisterEnum("google.datastore.admin.v1beta1.OperationType", OperationType_name, OperationType_value) 698 proto.RegisterEnum("google.datastore.admin.v1beta1.CommonMetadata_State", CommonMetadata_State_name, CommonMetadata_State_value) 699 proto.RegisterType((*CommonMetadata)(nil), "google.datastore.admin.v1beta1.CommonMetadata") 700 proto.RegisterMapType((map[string]string)(nil), "google.datastore.admin.v1beta1.CommonMetadata.LabelsEntry") 701 proto.RegisterType((*Progress)(nil), "google.datastore.admin.v1beta1.Progress") 702 proto.RegisterType((*ExportEntitiesRequest)(nil), "google.datastore.admin.v1beta1.ExportEntitiesRequest") 703 proto.RegisterMapType((map[string]string)(nil), "google.datastore.admin.v1beta1.ExportEntitiesRequest.LabelsEntry") 704 proto.RegisterType((*ImportEntitiesRequest)(nil), "google.datastore.admin.v1beta1.ImportEntitiesRequest") 705 proto.RegisterMapType((map[string]string)(nil), "google.datastore.admin.v1beta1.ImportEntitiesRequest.LabelsEntry") 706 proto.RegisterType((*ExportEntitiesResponse)(nil), "google.datastore.admin.v1beta1.ExportEntitiesResponse") 707 proto.RegisterType((*ExportEntitiesMetadata)(nil), "google.datastore.admin.v1beta1.ExportEntitiesMetadata") 708 proto.RegisterType((*ImportEntitiesMetadata)(nil), "google.datastore.admin.v1beta1.ImportEntitiesMetadata") 709 proto.RegisterType((*EntityFilter)(nil), "google.datastore.admin.v1beta1.EntityFilter") 710} 711 712func init() { 713 proto.RegisterFile("google/datastore/admin/v1beta1/datastore_admin.proto", fileDescriptor_b63216f38706ce20) 714} 715 716var fileDescriptor_b63216f38706ce20 = []byte{ 717 // 996 bytes of a gzipped FileDescriptorProto 718 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xec, 0x56, 0x41, 0x8f, 0xdb, 0x44, 719 0x14, 0xc6, 0xce, 0x26, 0x6d, 0xde, 0x6e, 0xd2, 0xec, 0x94, 0xad, 0xa2, 0x40, 0xcb, 0xca, 0xa5, 720 0xd2, 0x6a, 0x05, 0x0e, 0x1b, 0x5a, 0x41, 0x97, 0x53, 0x36, 0xeb, 0x54, 0x46, 0x69, 0x12, 0x1c, 721 0x07, 0x75, 0x7b, 0xb1, 0x9c, 0x78, 0x36, 0x32, 0x6b, 0x7b, 0x8c, 0x3d, 0x29, 0x8d, 0x10, 0x17, 722 0x2e, 0x1c, 0x38, 0x72, 0xe1, 0x1f, 0x20, 0xf1, 0x1b, 0xb8, 0x70, 0xe1, 0xc2, 0x91, 0xbf, 0xc0, 723 0x8f, 0xe0, 0x88, 0x66, 0x3c, 0x76, 0xe2, 0x25, 0x10, 0xca, 0x16, 0x4e, 0xdc, 0xfc, 0xde, 0xbc, 724 0xef, 0x9b, 0x37, 0xdf, 0x9b, 0xf7, 0x3c, 0x70, 0x7f, 0x46, 0xc8, 0xcc, 0xc3, 0x4d, 0xc7, 0xa6, 725 0x76, 0x4c, 0x49, 0x84, 0x9b, 0xb6, 0xe3, 0xbb, 0x41, 0xf3, 0xd9, 0xd1, 0x04, 0x53, 0xfb, 0x68, 726 0xe9, 0xb7, 0xb8, 0x5f, 0x0d, 0x23, 0x42, 0x09, 0xba, 0x93, 0xa0, 0xd4, 0x6c, 0x55, 0x4d, 0x56, 727 0x05, 0xaa, 0xf1, 0xba, 0x60, 0xb5, 0x43, 0xb7, 0x69, 0x07, 0x01, 0xa1, 0x36, 0x75, 0x49, 0x10, 728 0x27, 0xe8, 0xc6, 0x5d, 0xb1, 0xea, 0x91, 0x60, 0x16, 0xcd, 0x83, 0xc0, 0x0d, 0x66, 0x4d, 0x12, 729 0xe2, 0x28, 0x17, 0xf4, 0x86, 0x08, 0xe2, 0xd6, 0x64, 0x7e, 0xde, 0xa4, 0xae, 0x8f, 0x63, 0x6a, 730 0xfb, 0x61, 0x12, 0xa0, 0xfc, 0xb8, 0x05, 0xd5, 0x0e, 0xf1, 0x7d, 0x12, 0x3c, 0xc6, 0xd4, 0x66, 731 0x99, 0xa0, 0x87, 0x00, 0x31, 0xb5, 0x23, 0x6a, 0xb1, 0xd8, 0xba, 0xb4, 0x2f, 0x1d, 0x6c, 0xb7, 732 0x1a, 0xaa, 0xc8, 0x35, 0x25, 0x52, 0xcd, 0x94, 0xc8, 0x28, 0xf3, 0x68, 0x66, 0xa3, 0x07, 0x70, 733 0x1d, 0x07, 0x4e, 0x02, 0x94, 0x37, 0x02, 0xaf, 0xe1, 0xc0, 0xe1, 0x30, 0x13, 0xaa, 0x59, 0xe6, 734 0x16, 0x5d, 0x84, 0xb8, 0x5e, 0xd8, 0x97, 0x0e, 0xaa, 0xad, 0xb7, 0xd5, 0xbf, 0x56, 0x48, 0x1d, 735 0xa4, 0x28, 0x73, 0x11, 0x62, 0xa3, 0x42, 0x56, 0x4d, 0x64, 0x40, 0xc9, 0xb3, 0x27, 0xd8, 0x8b, 736 0xeb, 0x5b, 0xfb, 0x85, 0x83, 0xed, 0xd6, 0xf1, 0x26, 0xb6, 0xbc, 0x0e, 0x6a, 0x8f, 0x83, 0xb5, 737 0x80, 0x46, 0x0b, 0x43, 0x30, 0xa1, 0x0f, 0xa1, 0x18, 0x53, 0x9b, 0xe2, 0x7a, 0x91, 0x27, 0x78, 738 0xff, 0x05, 0x29, 0x47, 0x0c, 0x6b, 0x24, 0x14, 0x8d, 0x87, 0xb0, 0xbd, 0xb2, 0x05, 0xaa, 0x41, 739 0xe1, 0x02, 0x2f, 0xb8, 0xde, 0x65, 0x83, 0x7d, 0xa2, 0x57, 0xa1, 0xf8, 0xcc, 0xf6, 0xe6, 0x89, 740 0x94, 0x65, 0x23, 0x31, 0x8e, 0xe5, 0xf7, 0x25, 0xe5, 0x6b, 0x09, 0x8a, 0x9c, 0x0b, 0xed, 0xc1, 741 0xee, 0xc8, 0x6c, 0x9b, 0x9a, 0x35, 0xee, 0x8f, 0x86, 0x5a, 0x47, 0xef, 0xea, 0xda, 0x69, 0xed, 742 0x15, 0x54, 0x83, 0x1d, 0xbd, 0xaf, 0x9b, 0x7a, 0xbb, 0xa7, 0x3f, 0xd5, 0xfb, 0x8f, 0x6a, 0x12, 743 0xaa, 0x02, 0x0c, 0x8d, 0x41, 0x47, 0x1b, 0x8d, 0x98, 0x2d, 0x33, 0xbb, 0xd3, 0xee, 0x77, 0xb4, 744 0x5e, 0x8f, 0xd9, 0x05, 0x66, 0x77, 0xf5, 0x7e, 0x1a, 0xbf, 0xc5, 0xec, 0xd1, 0xb8, 0xc3, 0xe2, 745 0xbb, 0xe3, 0x5e, 0xad, 0x88, 0x00, 0x4a, 0xdd, 0xb6, 0xde, 0xd3, 0x4e, 0x6b, 0x25, 0x54, 0x81, 746 0xb2, 0xc0, 0x6a, 0xa7, 0xb5, 0x6b, 0xca, 0x13, 0xb8, 0x3e, 0x8c, 0xc8, 0x2c, 0xc2, 0x71, 0x8c, 747 0xee, 0x41, 0xf5, 0x33, 0x12, 0x5d, 0x58, 0x53, 0xe2, 0x87, 0x1e, 0xa6, 0xd8, 0xe1, 0x07, 0x2a, 748 0x18, 0x15, 0xe6, 0xed, 0xa4, 0xce, 0x2c, 0x0c, 0xc7, 0xd4, 0xf5, 0x6d, 0x16, 0x26, 0x2f, 0xc3, 749 0xb4, 0xd4, 0xa9, 0xfc, 0x2c, 0xc3, 0x9e, 0xf6, 0x3c, 0x24, 0x11, 0xd5, 0x02, 0xea, 0x52, 0x17, 750 0xc7, 0x06, 0xfe, 0x74, 0x8e, 0x63, 0x8a, 0x6e, 0x03, 0x84, 0x11, 0xf9, 0x04, 0x4f, 0xa9, 0xe5, 751 0x3a, 0x42, 0xb4, 0xb2, 0xf0, 0xe8, 0x0e, 0x3a, 0xcb, 0x6a, 0x2f, 0xf3, 0xda, 0xb7, 0x37, 0x15, 752 0x6a, 0xed, 0x2e, 0x6b, 0xaf, 0xc0, 0x47, 0x50, 0xc1, 0x2c, 0x6c, 0x61, 0x9d, 0xbb, 0x1e, 0xc5, 753 0x11, 0xbf, 0xab, 0xdb, 0xad, 0xb7, 0x36, 0xee, 0xc0, 0x41, 0x5d, 0x8e, 0x31, 0x76, 0xf0, 0x8a, 754 0x85, 0x0e, 0x61, 0x97, 0xcc, 0x69, 0x38, 0xa7, 0xd6, 0x3c, 0xf2, 0xac, 0x30, 0xc2, 0xe7, 0xee, 755 0xf3, 0xfa, 0x16, 0x3f, 0xd3, 0x8d, 0x64, 0x61, 0x1c, 0x79, 0x43, 0xee, 0xbe, 0xca, 0xad, 0xf9, 756 0x41, 0x86, 0x3d, 0xdd, 0xff, 0x2f, 0xd4, 0x5c, 0xbb, 0xcb, 0x5a, 0x35, 0x5f, 0x83, 0xb2, 0x1b, 757 0x88, 0x93, 0x73, 0x25, 0xcb, 0xc6, 0x75, 0xee, 0x18, 0x47, 0xde, 0x1f, 0xa5, 0xde, 0xba, 0xaa, 758 0xd4, 0x57, 0x91, 0xef, 0x3d, 0xb8, 0x75, 0xf9, 0x96, 0xc4, 0x21, 0x09, 0x62, 0xcc, 0xe4, 0x5b, 759 0xd6, 0x2f, 0x95, 0x2f, 0x2b, 0x9c, 0xf2, 0x55, 0xe1, 0x32, 0x32, 0x9b, 0xb5, 0x5d, 0x28, 0x4d, 760 0xf9, 0x88, 0x10, 0x73, 0x56, 0x7d, 0xb1, 0x81, 0x62, 0x08, 0x34, 0x1a, 0xc3, 0x6e, 0x28, 0x5a, 761 0xd0, 0xc2, 0x62, 0x13, 0x31, 0x81, 0x0f, 0x36, 0x51, 0xa6, 0xbd, 0x6b, 0xd4, 0x52, 0x8a, 0x34, 762 0x4d, 0x34, 0x80, 0x6a, 0x46, 0x3b, 0x59, 0x50, 0x1c, 0x8b, 0xcb, 0xfe, 0xf7, 0x39, 0x2b, 0x29, 763 0xfe, 0x84, 0xc1, 0xff, 0x85, 0x8a, 0xae, 0x6f, 0x9e, 0xe2, 0xda, 0xe6, 0x51, 0x7e, 0x93, 0xe1, 764 0x56, 0xfe, 0x6e, 0xfe, 0x5f, 0x89, 0x97, 0x57, 0x89, 0x5c, 0x2f, 0x17, 0xf3, 0xbd, 0xac, 0xe8, 765 0xb0, 0xb3, 0x0a, 0x65, 0x7d, 0x76, 0xe1, 0x06, 0x4e, 0x5c, 0x97, 0xf6, 0x0b, 0xac, 0xcf, 0xb8, 766 0x81, 0xee, 0x42, 0x25, 0xb0, 0x7d, 0x1c, 0x87, 0xf6, 0x14, 0x5b, 0xae, 0x93, 0x0c, 0x9c, 0xb2, 767 0xb1, 0x93, 0x39, 0x75, 0x27, 0x3e, 0x3c, 0x83, 0x4a, 0xee, 0xc7, 0x8f, 0xee, 0x40, 0x63, 0x30, 768 0xd4, 0x8c, 0xb6, 0xa9, 0x0f, 0xfa, 0x96, 0x79, 0x36, 0xbc, 0xfc, 0x37, 0xbc, 0x09, 0x37, 0xb4, 769 0x27, 0xc3, 0x81, 0x61, 0x5a, 0x5a, 0xdf, 0xd4, 0x4d, 0x5d, 0x1b, 0xd5, 0x24, 0xe6, 0xd4, 0x1f, 770 0xe7, 0x9d, 0x72, 0xeb, 0x27, 0x19, 0xaa, 0xa7, 0xe9, 0xc9, 0xdb, 0xec, 0xe0, 0xe8, 0x5b, 0x09, 771 0xaa, 0xf9, 0xee, 0x45, 0x0f, 0xfe, 0xd1, 0xdf, 0xa4, 0x71, 0x3b, 0x85, 0xad, 0x3c, 0xd9, 0x96, 772 0x4f, 0x18, 0xe5, 0x9d, 0x2f, 0x7f, 0xf9, 0xf5, 0x1b, 0xf9, 0x50, 0xb9, 0x97, 0x3d, 0x1b, 0xc5, 773 0x04, 0x8e, 0x9b, 0x9f, 0x2f, 0xa7, 0xf3, 0x17, 0xc7, 0x98, 0x93, 0x1f, 0x4b, 0x87, 0x3c, 0xb5, 774 0xfc, 0x75, 0xde, 0x9c, 0xda, 0xda, 0xd1, 0xfc, 0xb2, 0x52, 0x73, 0x7d, 0x91, 0xda, 0xc9, 0x77, 775 0x12, 0x28, 0x53, 0xe2, 0x6f, 0xc8, 0xe6, 0xe4, 0x66, 0x5e, 0xec, 0x21, 0x7b, 0x24, 0x0e, 0xa5, 776 0xa7, 0x1d, 0x01, 0x9b, 0x11, 0xcf, 0x0e, 0x66, 0x2a, 0x89, 0x66, 0xcd, 0x19, 0x0e, 0xf8, 0x13, 777 0xb2, 0x99, 0x2c, 0xd9, 0xa1, 0x1b, 0xff, 0xd9, 0x73, 0xfb, 0x03, 0x6e, 0x7d, 0x2f, 0xbf, 0xf9, 778 0x28, 0x61, 0xe9, 0x78, 0x64, 0xee, 0xa8, 0xd9, 0x4e, 0x2a, 0xdf, 0x4a, 0xfd, 0xf8, 0xe8, 0x84, 779 0x05, 0x4f, 0x4a, 0x9c, 0xf6, 0xdd, 0xdf, 0x03, 0x00, 0x00, 0xff, 0xff, 0x77, 0x71, 0x2d, 0x88, 780 0xc4, 0x0b, 0x00, 0x00, 781} 782 783// Reference imports to suppress errors if they are not otherwise used. 784var _ context.Context 785var _ grpc.ClientConn 786 787// This is a compile-time assertion to ensure that this generated file 788// is compatible with the grpc package it is being compiled against. 789const _ = grpc.SupportPackageIsVersion4 790 791// DatastoreAdminClient is the client API for DatastoreAdmin service. 792// 793// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream. 794type DatastoreAdminClient interface { 795 // Exports a copy of all or a subset of entities from Google Cloud Datastore 796 // to another storage system, such as Google Cloud Storage. Recent updates to 797 // entities may not be reflected in the export. The export occurs in the 798 // background and its progress can be monitored and managed via the 799 // Operation resource that is created. The output of an export may only be 800 // used once the associated operation is done. If an export operation is 801 // cancelled before completion it may leave partial data behind in Google 802 // Cloud Storage. 803 ExportEntities(ctx context.Context, in *ExportEntitiesRequest, opts ...grpc.CallOption) (*longrunning.Operation, error) 804 // Imports entities into Google Cloud Datastore. Existing entities with the 805 // same key are overwritten. The import occurs in the background and its 806 // progress can be monitored and managed via the Operation resource that is 807 // created. If an ImportEntities operation is cancelled, it is possible 808 // that a subset of the data has already been imported to Cloud Datastore. 809 ImportEntities(ctx context.Context, in *ImportEntitiesRequest, opts ...grpc.CallOption) (*longrunning.Operation, error) 810} 811 812type datastoreAdminClient struct { 813 cc *grpc.ClientConn 814} 815 816func NewDatastoreAdminClient(cc *grpc.ClientConn) DatastoreAdminClient { 817 return &datastoreAdminClient{cc} 818} 819 820func (c *datastoreAdminClient) ExportEntities(ctx context.Context, in *ExportEntitiesRequest, opts ...grpc.CallOption) (*longrunning.Operation, error) { 821 out := new(longrunning.Operation) 822 err := c.cc.Invoke(ctx, "/google.datastore.admin.v1beta1.DatastoreAdmin/ExportEntities", in, out, opts...) 823 if err != nil { 824 return nil, err 825 } 826 return out, nil 827} 828 829func (c *datastoreAdminClient) ImportEntities(ctx context.Context, in *ImportEntitiesRequest, opts ...grpc.CallOption) (*longrunning.Operation, error) { 830 out := new(longrunning.Operation) 831 err := c.cc.Invoke(ctx, "/google.datastore.admin.v1beta1.DatastoreAdmin/ImportEntities", in, out, opts...) 832 if err != nil { 833 return nil, err 834 } 835 return out, nil 836} 837 838// DatastoreAdminServer is the server API for DatastoreAdmin service. 839type DatastoreAdminServer interface { 840 // Exports a copy of all or a subset of entities from Google Cloud Datastore 841 // to another storage system, such as Google Cloud Storage. Recent updates to 842 // entities may not be reflected in the export. The export occurs in the 843 // background and its progress can be monitored and managed via the 844 // Operation resource that is created. The output of an export may only be 845 // used once the associated operation is done. If an export operation is 846 // cancelled before completion it may leave partial data behind in Google 847 // Cloud Storage. 848 ExportEntities(context.Context, *ExportEntitiesRequest) (*longrunning.Operation, error) 849 // Imports entities into Google Cloud Datastore. Existing entities with the 850 // same key are overwritten. The import occurs in the background and its 851 // progress can be monitored and managed via the Operation resource that is 852 // created. If an ImportEntities operation is cancelled, it is possible 853 // that a subset of the data has already been imported to Cloud Datastore. 854 ImportEntities(context.Context, *ImportEntitiesRequest) (*longrunning.Operation, error) 855} 856 857func RegisterDatastoreAdminServer(s *grpc.Server, srv DatastoreAdminServer) { 858 s.RegisterService(&_DatastoreAdmin_serviceDesc, srv) 859} 860 861func _DatastoreAdmin_ExportEntities_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 862 in := new(ExportEntitiesRequest) 863 if err := dec(in); err != nil { 864 return nil, err 865 } 866 if interceptor == nil { 867 return srv.(DatastoreAdminServer).ExportEntities(ctx, in) 868 } 869 info := &grpc.UnaryServerInfo{ 870 Server: srv, 871 FullMethod: "/google.datastore.admin.v1beta1.DatastoreAdmin/ExportEntities", 872 } 873 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 874 return srv.(DatastoreAdminServer).ExportEntities(ctx, req.(*ExportEntitiesRequest)) 875 } 876 return interceptor(ctx, in, info, handler) 877} 878 879func _DatastoreAdmin_ImportEntities_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 880 in := new(ImportEntitiesRequest) 881 if err := dec(in); err != nil { 882 return nil, err 883 } 884 if interceptor == nil { 885 return srv.(DatastoreAdminServer).ImportEntities(ctx, in) 886 } 887 info := &grpc.UnaryServerInfo{ 888 Server: srv, 889 FullMethod: "/google.datastore.admin.v1beta1.DatastoreAdmin/ImportEntities", 890 } 891 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 892 return srv.(DatastoreAdminServer).ImportEntities(ctx, req.(*ImportEntitiesRequest)) 893 } 894 return interceptor(ctx, in, info, handler) 895} 896 897var _DatastoreAdmin_serviceDesc = grpc.ServiceDesc{ 898 ServiceName: "google.datastore.admin.v1beta1.DatastoreAdmin", 899 HandlerType: (*DatastoreAdminServer)(nil), 900 Methods: []grpc.MethodDesc{ 901 { 902 MethodName: "ExportEntities", 903 Handler: _DatastoreAdmin_ExportEntities_Handler, 904 }, 905 { 906 MethodName: "ImportEntities", 907 Handler: _DatastoreAdmin_ImportEntities_Handler, 908 }, 909 }, 910 Streams: []grpc.StreamDesc{}, 911 Metadata: "google/datastore/admin/v1beta1/datastore_admin.proto", 912} 913