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