1// Copyright 2021 Google LLC 2// 3// Licensed under the Apache License, Version 2.0 (the "License"); 4// you may not use this file except in compliance with the License. 5// You may obtain a copy of the License at 6// 7// http://www.apache.org/licenses/LICENSE-2.0 8// 9// Unless required by applicable law or agreed to in writing, software 10// distributed under the License is distributed on an "AS IS" BASIS, 11// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. 12// See the License for the specific language governing permissions and 13// limitations under the License. 14 15// Code generated by protoc-gen-go. DO NOT EDIT. 16// versions: 17// protoc-gen-go v1.26.0 18// protoc v3.12.2 19// source: google/cloud/bigquery/migration/v2alpha/migration_service.proto 20 21package migration 22 23import ( 24 context "context" 25 reflect "reflect" 26 sync "sync" 27 28 _ "google.golang.org/genproto/googleapis/api/annotations" 29 _ "google.golang.org/genproto/googleapis/rpc/errdetails" 30 grpc "google.golang.org/grpc" 31 codes "google.golang.org/grpc/codes" 32 status "google.golang.org/grpc/status" 33 protoreflect "google.golang.org/protobuf/reflect/protoreflect" 34 protoimpl "google.golang.org/protobuf/runtime/protoimpl" 35 emptypb "google.golang.org/protobuf/types/known/emptypb" 36 fieldmaskpb "google.golang.org/protobuf/types/known/fieldmaskpb" 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// Request to create a migration workflow resource. 47type CreateMigrationWorkflowRequest struct { 48 state protoimpl.MessageState 49 sizeCache protoimpl.SizeCache 50 unknownFields protoimpl.UnknownFields 51 52 // Required. The name of the project to which this migration workflow belongs. 53 // Example: `projects/foo/locations/bar` 54 Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"` 55 // Required. The migration workflow to create. 56 MigrationWorkflow *MigrationWorkflow `protobuf:"bytes,2,opt,name=migration_workflow,json=migrationWorkflow,proto3" json:"migration_workflow,omitempty"` 57} 58 59func (x *CreateMigrationWorkflowRequest) Reset() { 60 *x = CreateMigrationWorkflowRequest{} 61 if protoimpl.UnsafeEnabled { 62 mi := &file_google_cloud_bigquery_migration_v2alpha_migration_service_proto_msgTypes[0] 63 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 64 ms.StoreMessageInfo(mi) 65 } 66} 67 68func (x *CreateMigrationWorkflowRequest) String() string { 69 return protoimpl.X.MessageStringOf(x) 70} 71 72func (*CreateMigrationWorkflowRequest) ProtoMessage() {} 73 74func (x *CreateMigrationWorkflowRequest) ProtoReflect() protoreflect.Message { 75 mi := &file_google_cloud_bigquery_migration_v2alpha_migration_service_proto_msgTypes[0] 76 if protoimpl.UnsafeEnabled && x != nil { 77 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 78 if ms.LoadMessageInfo() == nil { 79 ms.StoreMessageInfo(mi) 80 } 81 return ms 82 } 83 return mi.MessageOf(x) 84} 85 86// Deprecated: Use CreateMigrationWorkflowRequest.ProtoReflect.Descriptor instead. 87func (*CreateMigrationWorkflowRequest) Descriptor() ([]byte, []int) { 88 return file_google_cloud_bigquery_migration_v2alpha_migration_service_proto_rawDescGZIP(), []int{0} 89} 90 91func (x *CreateMigrationWorkflowRequest) GetParent() string { 92 if x != nil { 93 return x.Parent 94 } 95 return "" 96} 97 98func (x *CreateMigrationWorkflowRequest) GetMigrationWorkflow() *MigrationWorkflow { 99 if x != nil { 100 return x.MigrationWorkflow 101 } 102 return nil 103} 104 105// A request to get a previously created migration workflow. 106type GetMigrationWorkflowRequest struct { 107 state protoimpl.MessageState 108 sizeCache protoimpl.SizeCache 109 unknownFields protoimpl.UnknownFields 110 111 // Required. The unique identifier for the migration workflow. 112 // Example: `projects/123/locations/us/workflows/1234` 113 Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` 114 // The list of fields to be retrieved. 115 ReadMask *fieldmaskpb.FieldMask `protobuf:"bytes,2,opt,name=read_mask,json=readMask,proto3" json:"read_mask,omitempty"` 116} 117 118func (x *GetMigrationWorkflowRequest) Reset() { 119 *x = GetMigrationWorkflowRequest{} 120 if protoimpl.UnsafeEnabled { 121 mi := &file_google_cloud_bigquery_migration_v2alpha_migration_service_proto_msgTypes[1] 122 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 123 ms.StoreMessageInfo(mi) 124 } 125} 126 127func (x *GetMigrationWorkflowRequest) String() string { 128 return protoimpl.X.MessageStringOf(x) 129} 130 131func (*GetMigrationWorkflowRequest) ProtoMessage() {} 132 133func (x *GetMigrationWorkflowRequest) ProtoReflect() protoreflect.Message { 134 mi := &file_google_cloud_bigquery_migration_v2alpha_migration_service_proto_msgTypes[1] 135 if protoimpl.UnsafeEnabled && x != nil { 136 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 137 if ms.LoadMessageInfo() == nil { 138 ms.StoreMessageInfo(mi) 139 } 140 return ms 141 } 142 return mi.MessageOf(x) 143} 144 145// Deprecated: Use GetMigrationWorkflowRequest.ProtoReflect.Descriptor instead. 146func (*GetMigrationWorkflowRequest) Descriptor() ([]byte, []int) { 147 return file_google_cloud_bigquery_migration_v2alpha_migration_service_proto_rawDescGZIP(), []int{1} 148} 149 150func (x *GetMigrationWorkflowRequest) GetName() string { 151 if x != nil { 152 return x.Name 153 } 154 return "" 155} 156 157func (x *GetMigrationWorkflowRequest) GetReadMask() *fieldmaskpb.FieldMask { 158 if x != nil { 159 return x.ReadMask 160 } 161 return nil 162} 163 164// A request to list previously created migration workflows. 165type ListMigrationWorkflowsRequest struct { 166 state protoimpl.MessageState 167 sizeCache protoimpl.SizeCache 168 unknownFields protoimpl.UnknownFields 169 170 // Required. The project and location of the migration workflows to list. 171 // Example: `projects/123/locations/us` 172 Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"` 173 // The list of fields to be retrieved. 174 ReadMask *fieldmaskpb.FieldMask `protobuf:"bytes,2,opt,name=read_mask,json=readMask,proto3" json:"read_mask,omitempty"` 175 // The maximum number of migration workflows to return. The service may return 176 // fewer than this number. 177 PageSize int32 `protobuf:"varint,3,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"` 178 // A page token, received from previous `ListMigrationWorkflows` call. 179 // Provide this to retrieve the subsequent page. 180 // 181 // When paginating, all other parameters provided to `ListMigrationWorkflows` 182 // must match the call that provided the page token. 183 PageToken string `protobuf:"bytes,4,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"` 184} 185 186func (x *ListMigrationWorkflowsRequest) Reset() { 187 *x = ListMigrationWorkflowsRequest{} 188 if protoimpl.UnsafeEnabled { 189 mi := &file_google_cloud_bigquery_migration_v2alpha_migration_service_proto_msgTypes[2] 190 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 191 ms.StoreMessageInfo(mi) 192 } 193} 194 195func (x *ListMigrationWorkflowsRequest) String() string { 196 return protoimpl.X.MessageStringOf(x) 197} 198 199func (*ListMigrationWorkflowsRequest) ProtoMessage() {} 200 201func (x *ListMigrationWorkflowsRequest) ProtoReflect() protoreflect.Message { 202 mi := &file_google_cloud_bigquery_migration_v2alpha_migration_service_proto_msgTypes[2] 203 if protoimpl.UnsafeEnabled && x != nil { 204 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 205 if ms.LoadMessageInfo() == nil { 206 ms.StoreMessageInfo(mi) 207 } 208 return ms 209 } 210 return mi.MessageOf(x) 211} 212 213// Deprecated: Use ListMigrationWorkflowsRequest.ProtoReflect.Descriptor instead. 214func (*ListMigrationWorkflowsRequest) Descriptor() ([]byte, []int) { 215 return file_google_cloud_bigquery_migration_v2alpha_migration_service_proto_rawDescGZIP(), []int{2} 216} 217 218func (x *ListMigrationWorkflowsRequest) GetParent() string { 219 if x != nil { 220 return x.Parent 221 } 222 return "" 223} 224 225func (x *ListMigrationWorkflowsRequest) GetReadMask() *fieldmaskpb.FieldMask { 226 if x != nil { 227 return x.ReadMask 228 } 229 return nil 230} 231 232func (x *ListMigrationWorkflowsRequest) GetPageSize() int32 { 233 if x != nil { 234 return x.PageSize 235 } 236 return 0 237} 238 239func (x *ListMigrationWorkflowsRequest) GetPageToken() string { 240 if x != nil { 241 return x.PageToken 242 } 243 return "" 244} 245 246// Response object for a `ListMigrationWorkflows` call. 247type ListMigrationWorkflowsResponse struct { 248 state protoimpl.MessageState 249 sizeCache protoimpl.SizeCache 250 unknownFields protoimpl.UnknownFields 251 252 // The migration workflows for the specified project / location. 253 MigrationWorkflows []*MigrationWorkflow `protobuf:"bytes,1,rep,name=migration_workflows,json=migrationWorkflows,proto3" json:"migration_workflows,omitempty"` 254 // A token, which can be sent as `page_token` to retrieve the next page. 255 // If this field is omitted, there are no subsequent pages. 256 NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"` 257} 258 259func (x *ListMigrationWorkflowsResponse) Reset() { 260 *x = ListMigrationWorkflowsResponse{} 261 if protoimpl.UnsafeEnabled { 262 mi := &file_google_cloud_bigquery_migration_v2alpha_migration_service_proto_msgTypes[3] 263 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 264 ms.StoreMessageInfo(mi) 265 } 266} 267 268func (x *ListMigrationWorkflowsResponse) String() string { 269 return protoimpl.X.MessageStringOf(x) 270} 271 272func (*ListMigrationWorkflowsResponse) ProtoMessage() {} 273 274func (x *ListMigrationWorkflowsResponse) ProtoReflect() protoreflect.Message { 275 mi := &file_google_cloud_bigquery_migration_v2alpha_migration_service_proto_msgTypes[3] 276 if protoimpl.UnsafeEnabled && x != nil { 277 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 278 if ms.LoadMessageInfo() == nil { 279 ms.StoreMessageInfo(mi) 280 } 281 return ms 282 } 283 return mi.MessageOf(x) 284} 285 286// Deprecated: Use ListMigrationWorkflowsResponse.ProtoReflect.Descriptor instead. 287func (*ListMigrationWorkflowsResponse) Descriptor() ([]byte, []int) { 288 return file_google_cloud_bigquery_migration_v2alpha_migration_service_proto_rawDescGZIP(), []int{3} 289} 290 291func (x *ListMigrationWorkflowsResponse) GetMigrationWorkflows() []*MigrationWorkflow { 292 if x != nil { 293 return x.MigrationWorkflows 294 } 295 return nil 296} 297 298func (x *ListMigrationWorkflowsResponse) GetNextPageToken() string { 299 if x != nil { 300 return x.NextPageToken 301 } 302 return "" 303} 304 305// A request to delete a previously created migration workflow. 306type DeleteMigrationWorkflowRequest struct { 307 state protoimpl.MessageState 308 sizeCache protoimpl.SizeCache 309 unknownFields protoimpl.UnknownFields 310 311 // Required. The unique identifier for the migration workflow. 312 // Example: `projects/123/locations/us/workflows/1234` 313 Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` 314} 315 316func (x *DeleteMigrationWorkflowRequest) Reset() { 317 *x = DeleteMigrationWorkflowRequest{} 318 if protoimpl.UnsafeEnabled { 319 mi := &file_google_cloud_bigquery_migration_v2alpha_migration_service_proto_msgTypes[4] 320 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 321 ms.StoreMessageInfo(mi) 322 } 323} 324 325func (x *DeleteMigrationWorkflowRequest) String() string { 326 return protoimpl.X.MessageStringOf(x) 327} 328 329func (*DeleteMigrationWorkflowRequest) ProtoMessage() {} 330 331func (x *DeleteMigrationWorkflowRequest) ProtoReflect() protoreflect.Message { 332 mi := &file_google_cloud_bigquery_migration_v2alpha_migration_service_proto_msgTypes[4] 333 if protoimpl.UnsafeEnabled && x != nil { 334 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 335 if ms.LoadMessageInfo() == nil { 336 ms.StoreMessageInfo(mi) 337 } 338 return ms 339 } 340 return mi.MessageOf(x) 341} 342 343// Deprecated: Use DeleteMigrationWorkflowRequest.ProtoReflect.Descriptor instead. 344func (*DeleteMigrationWorkflowRequest) Descriptor() ([]byte, []int) { 345 return file_google_cloud_bigquery_migration_v2alpha_migration_service_proto_rawDescGZIP(), []int{4} 346} 347 348func (x *DeleteMigrationWorkflowRequest) GetName() string { 349 if x != nil { 350 return x.Name 351 } 352 return "" 353} 354 355// A request to start a previously created migration workflow. 356type StartMigrationWorkflowRequest struct { 357 state protoimpl.MessageState 358 sizeCache protoimpl.SizeCache 359 unknownFields protoimpl.UnknownFields 360 361 // Required. The unique identifier for the migration workflow. 362 // Example: `projects/123/locations/us/workflows/1234` 363 Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` 364} 365 366func (x *StartMigrationWorkflowRequest) Reset() { 367 *x = StartMigrationWorkflowRequest{} 368 if protoimpl.UnsafeEnabled { 369 mi := &file_google_cloud_bigquery_migration_v2alpha_migration_service_proto_msgTypes[5] 370 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 371 ms.StoreMessageInfo(mi) 372 } 373} 374 375func (x *StartMigrationWorkflowRequest) String() string { 376 return protoimpl.X.MessageStringOf(x) 377} 378 379func (*StartMigrationWorkflowRequest) ProtoMessage() {} 380 381func (x *StartMigrationWorkflowRequest) ProtoReflect() protoreflect.Message { 382 mi := &file_google_cloud_bigquery_migration_v2alpha_migration_service_proto_msgTypes[5] 383 if protoimpl.UnsafeEnabled && x != nil { 384 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 385 if ms.LoadMessageInfo() == nil { 386 ms.StoreMessageInfo(mi) 387 } 388 return ms 389 } 390 return mi.MessageOf(x) 391} 392 393// Deprecated: Use StartMigrationWorkflowRequest.ProtoReflect.Descriptor instead. 394func (*StartMigrationWorkflowRequest) Descriptor() ([]byte, []int) { 395 return file_google_cloud_bigquery_migration_v2alpha_migration_service_proto_rawDescGZIP(), []int{5} 396} 397 398func (x *StartMigrationWorkflowRequest) GetName() string { 399 if x != nil { 400 return x.Name 401 } 402 return "" 403} 404 405// A request to get a previously created migration subtasks. 406type GetMigrationSubtaskRequest struct { 407 state protoimpl.MessageState 408 sizeCache protoimpl.SizeCache 409 unknownFields protoimpl.UnknownFields 410 411 // Required. The unique identifier for the migration subtask. 412 // Example: `projects/123/locations/us/workflows/1234/subtasks/543` 413 Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` 414 // Optional. The list of fields to be retrieved. 415 ReadMask *fieldmaskpb.FieldMask `protobuf:"bytes,2,opt,name=read_mask,json=readMask,proto3" json:"read_mask,omitempty"` 416} 417 418func (x *GetMigrationSubtaskRequest) Reset() { 419 *x = GetMigrationSubtaskRequest{} 420 if protoimpl.UnsafeEnabled { 421 mi := &file_google_cloud_bigquery_migration_v2alpha_migration_service_proto_msgTypes[6] 422 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 423 ms.StoreMessageInfo(mi) 424 } 425} 426 427func (x *GetMigrationSubtaskRequest) String() string { 428 return protoimpl.X.MessageStringOf(x) 429} 430 431func (*GetMigrationSubtaskRequest) ProtoMessage() {} 432 433func (x *GetMigrationSubtaskRequest) ProtoReflect() protoreflect.Message { 434 mi := &file_google_cloud_bigquery_migration_v2alpha_migration_service_proto_msgTypes[6] 435 if protoimpl.UnsafeEnabled && x != nil { 436 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 437 if ms.LoadMessageInfo() == nil { 438 ms.StoreMessageInfo(mi) 439 } 440 return ms 441 } 442 return mi.MessageOf(x) 443} 444 445// Deprecated: Use GetMigrationSubtaskRequest.ProtoReflect.Descriptor instead. 446func (*GetMigrationSubtaskRequest) Descriptor() ([]byte, []int) { 447 return file_google_cloud_bigquery_migration_v2alpha_migration_service_proto_rawDescGZIP(), []int{6} 448} 449 450func (x *GetMigrationSubtaskRequest) GetName() string { 451 if x != nil { 452 return x.Name 453 } 454 return "" 455} 456 457func (x *GetMigrationSubtaskRequest) GetReadMask() *fieldmaskpb.FieldMask { 458 if x != nil { 459 return x.ReadMask 460 } 461 return nil 462} 463 464// A request to list previously created migration subtasks. 465type ListMigrationSubtasksRequest struct { 466 state protoimpl.MessageState 467 sizeCache protoimpl.SizeCache 468 unknownFields protoimpl.UnknownFields 469 470 // Required. The migration task of the subtasks to list. 471 // Example: `projects/123/locations/us/workflows/1234` 472 Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"` 473 // Optional. The list of fields to be retrieved. 474 ReadMask *fieldmaskpb.FieldMask `protobuf:"bytes,2,opt,name=read_mask,json=readMask,proto3" json:"read_mask,omitempty"` 475 // Optional. The maximum number of migration tasks to return. The service may return 476 // fewer than this number. 477 PageSize int32 `protobuf:"varint,3,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"` 478 // Optional. A page token, received from previous `ListMigrationSubtasks` call. 479 // Provide this to retrieve the subsequent page. 480 // 481 // When paginating, all other parameters provided to `ListMigrationSubtasks` 482 // must match the call that provided the page token. 483 PageToken string `protobuf:"bytes,4,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"` 484 // Optional. The filter to apply. This can be used to get the subtasks of a specific 485 // tasks in a workflow, e.g. `migration_task = "ab012"` where `"ab012"` is the 486 // task ID (not the name in the named map). 487 Filter string `protobuf:"bytes,5,opt,name=filter,proto3" json:"filter,omitempty"` 488} 489 490func (x *ListMigrationSubtasksRequest) Reset() { 491 *x = ListMigrationSubtasksRequest{} 492 if protoimpl.UnsafeEnabled { 493 mi := &file_google_cloud_bigquery_migration_v2alpha_migration_service_proto_msgTypes[7] 494 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 495 ms.StoreMessageInfo(mi) 496 } 497} 498 499func (x *ListMigrationSubtasksRequest) String() string { 500 return protoimpl.X.MessageStringOf(x) 501} 502 503func (*ListMigrationSubtasksRequest) ProtoMessage() {} 504 505func (x *ListMigrationSubtasksRequest) ProtoReflect() protoreflect.Message { 506 mi := &file_google_cloud_bigquery_migration_v2alpha_migration_service_proto_msgTypes[7] 507 if protoimpl.UnsafeEnabled && x != nil { 508 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 509 if ms.LoadMessageInfo() == nil { 510 ms.StoreMessageInfo(mi) 511 } 512 return ms 513 } 514 return mi.MessageOf(x) 515} 516 517// Deprecated: Use ListMigrationSubtasksRequest.ProtoReflect.Descriptor instead. 518func (*ListMigrationSubtasksRequest) Descriptor() ([]byte, []int) { 519 return file_google_cloud_bigquery_migration_v2alpha_migration_service_proto_rawDescGZIP(), []int{7} 520} 521 522func (x *ListMigrationSubtasksRequest) GetParent() string { 523 if x != nil { 524 return x.Parent 525 } 526 return "" 527} 528 529func (x *ListMigrationSubtasksRequest) GetReadMask() *fieldmaskpb.FieldMask { 530 if x != nil { 531 return x.ReadMask 532 } 533 return nil 534} 535 536func (x *ListMigrationSubtasksRequest) GetPageSize() int32 { 537 if x != nil { 538 return x.PageSize 539 } 540 return 0 541} 542 543func (x *ListMigrationSubtasksRequest) GetPageToken() string { 544 if x != nil { 545 return x.PageToken 546 } 547 return "" 548} 549 550func (x *ListMigrationSubtasksRequest) GetFilter() string { 551 if x != nil { 552 return x.Filter 553 } 554 return "" 555} 556 557// Response object for a `ListMigrationSubtasks` call. 558type ListMigrationSubtasksResponse struct { 559 state protoimpl.MessageState 560 sizeCache protoimpl.SizeCache 561 unknownFields protoimpl.UnknownFields 562 563 // The migration subtasks for the specified task. 564 MigrationSubtasks []*MigrationSubtask `protobuf:"bytes,1,rep,name=migration_subtasks,json=migrationSubtasks,proto3" json:"migration_subtasks,omitempty"` 565 // A token, which can be sent as `page_token` to retrieve the next page. 566 // If this field is omitted, there are no subsequent pages. 567 NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"` 568} 569 570func (x *ListMigrationSubtasksResponse) Reset() { 571 *x = ListMigrationSubtasksResponse{} 572 if protoimpl.UnsafeEnabled { 573 mi := &file_google_cloud_bigquery_migration_v2alpha_migration_service_proto_msgTypes[8] 574 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 575 ms.StoreMessageInfo(mi) 576 } 577} 578 579func (x *ListMigrationSubtasksResponse) String() string { 580 return protoimpl.X.MessageStringOf(x) 581} 582 583func (*ListMigrationSubtasksResponse) ProtoMessage() {} 584 585func (x *ListMigrationSubtasksResponse) ProtoReflect() protoreflect.Message { 586 mi := &file_google_cloud_bigquery_migration_v2alpha_migration_service_proto_msgTypes[8] 587 if protoimpl.UnsafeEnabled && x != nil { 588 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 589 if ms.LoadMessageInfo() == nil { 590 ms.StoreMessageInfo(mi) 591 } 592 return ms 593 } 594 return mi.MessageOf(x) 595} 596 597// Deprecated: Use ListMigrationSubtasksResponse.ProtoReflect.Descriptor instead. 598func (*ListMigrationSubtasksResponse) Descriptor() ([]byte, []int) { 599 return file_google_cloud_bigquery_migration_v2alpha_migration_service_proto_rawDescGZIP(), []int{8} 600} 601 602func (x *ListMigrationSubtasksResponse) GetMigrationSubtasks() []*MigrationSubtask { 603 if x != nil { 604 return x.MigrationSubtasks 605 } 606 return nil 607} 608 609func (x *ListMigrationSubtasksResponse) GetNextPageToken() string { 610 if x != nil { 611 return x.NextPageToken 612 } 613 return "" 614} 615 616var File_google_cloud_bigquery_migration_v2alpha_migration_service_proto protoreflect.FileDescriptor 617 618var file_google_cloud_bigquery_migration_v2alpha_migration_service_proto_rawDesc = []byte{ 619 0x0a, 0x3f, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2f, 0x62, 620 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2f, 0x6d, 0x69, 0x67, 0x72, 0x61, 0x74, 0x69, 0x6f, 621 0x6e, 0x2f, 0x76, 0x32, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x2f, 0x6d, 0x69, 0x67, 0x72, 0x61, 0x74, 622 0x69, 0x6f, 0x6e, 0x5f, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 623 0x6f, 0x12, 0x27, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 624 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x6d, 0x69, 0x67, 0x72, 0x61, 0x74, 0x69, 625 0x6f, 0x6e, 0x2e, 0x76, 0x32, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x1a, 0x1c, 0x67, 0x6f, 0x6f, 0x67, 626 0x6c, 0x65, 0x2f, 0x61, 0x70, 0x69, 0x2f, 0x61, 0x6e, 0x6e, 0x6f, 0x74, 0x61, 0x74, 0x69, 0x6f, 627 0x6e, 0x73, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x17, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 628 0x2f, 0x61, 0x70, 0x69, 0x2f, 0x63, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x2e, 0x70, 0x72, 0x6f, 0x74, 629 0x6f, 0x1a, 0x1f, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x61, 0x70, 0x69, 0x2f, 0x66, 0x69, 630 0x65, 0x6c, 0x64, 0x5f, 0x62, 0x65, 0x68, 0x61, 0x76, 0x69, 0x6f, 0x72, 0x2e, 0x70, 0x72, 0x6f, 631 0x74, 0x6f, 0x1a, 0x19, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x61, 0x70, 0x69, 0x2f, 0x72, 632 0x65, 0x73, 0x6f, 0x75, 0x72, 0x63, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x40, 0x67, 633 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2f, 0x62, 0x69, 0x67, 0x71, 634 0x75, 0x65, 0x72, 0x79, 0x2f, 0x6d, 0x69, 0x67, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x2f, 0x76, 635 0x32, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x2f, 0x6d, 0x69, 0x67, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 636 0x5f, 0x65, 0x6e, 0x74, 0x69, 0x74, 0x69, 0x65, 0x73, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 637 0x45, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2f, 0x62, 0x69, 638 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2f, 0x6d, 0x69, 0x67, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 639 0x2f, 0x76, 0x32, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x2f, 0x6d, 0x69, 0x67, 0x72, 0x61, 0x74, 0x69, 640 0x6f, 0x6e, 0x5f, 0x65, 0x72, 0x72, 0x6f, 0x72, 0x5f, 0x64, 0x65, 0x74, 0x61, 0x69, 0x6c, 0x73, 641 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x3f, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x63, 642 0x6c, 0x6f, 0x75, 0x64, 0x2f, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2f, 0x6d, 0x69, 643 0x67, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x2f, 0x76, 0x32, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x2f, 644 0x6d, 0x69, 0x67, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x5f, 0x6d, 0x65, 0x74, 0x72, 0x69, 0x63, 645 0x73, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x1b, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 646 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2f, 0x65, 0x6d, 0x70, 0x74, 0x79, 0x2e, 0x70, 647 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x20, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x70, 0x72, 0x6f, 648 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2f, 0x66, 0x69, 0x65, 0x6c, 0x64, 0x5f, 0x6d, 0x61, 0x73, 0x6b, 649 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x1e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x72, 650 0x70, 0x63, 0x2f, 0x65, 0x72, 0x72, 0x6f, 0x72, 0x5f, 0x64, 0x65, 0x74, 0x61, 0x69, 0x6c, 0x73, 651 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x22, 0xd3, 0x01, 0x0a, 0x1e, 0x43, 0x72, 0x65, 0x61, 0x74, 652 0x65, 0x4d, 0x69, 0x67, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x57, 0x6f, 0x72, 0x6b, 0x66, 0x6c, 653 0x6f, 0x77, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x41, 0x0a, 0x06, 0x70, 0x61, 0x72, 654 0x65, 0x6e, 0x74, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x42, 0x29, 0xe0, 0x41, 0x02, 0xfa, 0x41, 655 0x23, 0x0a, 0x21, 0x6c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2e, 0x67, 0x6f, 0x6f, 656 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x4c, 0x6f, 0x63, 0x61, 657 0x74, 0x69, 0x6f, 0x6e, 0x52, 0x06, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x12, 0x6e, 0x0a, 0x12, 658 0x6d, 0x69, 0x67, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x5f, 0x77, 0x6f, 0x72, 0x6b, 0x66, 0x6c, 659 0x6f, 0x77, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x3a, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 660 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 661 0x2e, 0x6d, 0x69, 0x67, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x2e, 0x76, 0x32, 0x61, 0x6c, 0x70, 662 0x68, 0x61, 0x2e, 0x4d, 0x69, 0x67, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x57, 0x6f, 0x72, 0x6b, 663 0x66, 0x6c, 0x6f, 0x77, 0x42, 0x03, 0xe0, 0x41, 0x02, 0x52, 0x11, 0x6d, 0x69, 0x67, 0x72, 0x61, 664 0x74, 0x69, 0x6f, 0x6e, 0x57, 0x6f, 0x72, 0x6b, 0x66, 0x6c, 0x6f, 0x77, 0x22, 0xa6, 0x01, 0x0a, 665 0x1b, 0x47, 0x65, 0x74, 0x4d, 0x69, 0x67, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x57, 0x6f, 0x72, 666 0x6b, 0x66, 0x6c, 0x6f, 0x77, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x4e, 0x0a, 0x04, 667 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x42, 0x3a, 0xe0, 0x41, 0x02, 0xfa, 668 0x41, 0x34, 0x0a, 0x32, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x6d, 0x69, 0x67, 0x72, 669 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 670 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x4d, 0x69, 0x67, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x57, 0x6f, 671 0x72, 0x6b, 0x66, 0x6c, 0x6f, 0x77, 0x52, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x12, 0x37, 0x0a, 0x09, 672 0x72, 0x65, 0x61, 0x64, 0x5f, 0x6d, 0x61, 0x73, 0x6b, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 673 0x1a, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 674 0x66, 0x2e, 0x46, 0x69, 0x65, 0x6c, 0x64, 0x4d, 0x61, 0x73, 0x6b, 0x52, 0x08, 0x72, 0x65, 0x61, 675 0x64, 0x4d, 0x61, 0x73, 0x6b, 0x22, 0xd7, 0x01, 0x0a, 0x1d, 0x4c, 0x69, 0x73, 0x74, 0x4d, 0x69, 676 0x67, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x57, 0x6f, 0x72, 0x6b, 0x66, 0x6c, 0x6f, 0x77, 0x73, 677 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x41, 0x0a, 0x06, 0x70, 0x61, 0x72, 0x65, 0x6e, 678 0x74, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x42, 0x29, 0xe0, 0x41, 0x02, 0xfa, 0x41, 0x23, 0x0a, 679 0x21, 0x6c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 680 0x65, 0x61, 0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x4c, 0x6f, 0x63, 0x61, 0x74, 0x69, 681 0x6f, 0x6e, 0x52, 0x06, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x12, 0x37, 0x0a, 0x09, 0x72, 0x65, 682 0x61, 0x64, 0x5f, 0x6d, 0x61, 0x73, 0x6b, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1a, 0x2e, 683 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e, 684 0x46, 0x69, 0x65, 0x6c, 0x64, 0x4d, 0x61, 0x73, 0x6b, 0x52, 0x08, 0x72, 0x65, 0x61, 0x64, 0x4d, 685 0x61, 0x73, 0x6b, 0x12, 0x1b, 0x0a, 0x09, 0x70, 0x61, 0x67, 0x65, 0x5f, 0x73, 0x69, 0x7a, 0x65, 686 0x18, 0x03, 0x20, 0x01, 0x28, 0x05, 0x52, 0x08, 0x70, 0x61, 0x67, 0x65, 0x53, 0x69, 0x7a, 0x65, 687 0x12, 0x1d, 0x0a, 0x0a, 0x70, 0x61, 0x67, 0x65, 0x5f, 0x74, 0x6f, 0x6b, 0x65, 0x6e, 0x18, 0x04, 688 0x20, 0x01, 0x28, 0x09, 0x52, 0x09, 0x70, 0x61, 0x67, 0x65, 0x54, 0x6f, 0x6b, 0x65, 0x6e, 0x22, 689 0xb5, 0x01, 0x0a, 0x1e, 0x4c, 0x69, 0x73, 0x74, 0x4d, 0x69, 0x67, 0x72, 0x61, 0x74, 0x69, 0x6f, 690 0x6e, 0x57, 0x6f, 0x72, 0x6b, 0x66, 0x6c, 0x6f, 0x77, 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 691 0x73, 0x65, 0x12, 0x6b, 0x0a, 0x13, 0x6d, 0x69, 0x67, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x5f, 692 0x77, 0x6f, 0x72, 0x6b, 0x66, 0x6c, 0x6f, 0x77, 0x73, 0x18, 0x01, 0x20, 0x03, 0x28, 0x0b, 0x32, 693 0x3a, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x62, 694 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x6d, 0x69, 0x67, 0x72, 0x61, 0x74, 0x69, 0x6f, 695 0x6e, 0x2e, 0x76, 0x32, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x2e, 0x4d, 0x69, 0x67, 0x72, 0x61, 0x74, 696 0x69, 0x6f, 0x6e, 0x57, 0x6f, 0x72, 0x6b, 0x66, 0x6c, 0x6f, 0x77, 0x52, 0x12, 0x6d, 0x69, 0x67, 697 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x57, 0x6f, 0x72, 0x6b, 0x66, 0x6c, 0x6f, 0x77, 0x73, 0x12, 698 0x26, 0x0a, 0x0f, 0x6e, 0x65, 0x78, 0x74, 0x5f, 0x70, 0x61, 0x67, 0x65, 0x5f, 0x74, 0x6f, 0x6b, 699 0x65, 0x6e, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0d, 0x6e, 0x65, 0x78, 0x74, 0x50, 0x61, 700 0x67, 0x65, 0x54, 0x6f, 0x6b, 0x65, 0x6e, 0x22, 0x70, 0x0a, 0x1e, 0x44, 0x65, 0x6c, 0x65, 0x74, 701 0x65, 0x4d, 0x69, 0x67, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x57, 0x6f, 0x72, 0x6b, 0x66, 0x6c, 702 0x6f, 0x77, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x4e, 0x0a, 0x04, 0x6e, 0x61, 0x6d, 703 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x42, 0x3a, 0xe0, 0x41, 0x02, 0xfa, 0x41, 0x34, 0x0a, 704 0x32, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x6d, 0x69, 0x67, 0x72, 0x61, 0x74, 0x69, 705 0x6f, 0x6e, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f, 706 0x6d, 0x2f, 0x4d, 0x69, 0x67, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x57, 0x6f, 0x72, 0x6b, 0x66, 707 0x6c, 0x6f, 0x77, 0x52, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x22, 0x6f, 0x0a, 0x1d, 0x53, 0x74, 0x61, 708 0x72, 0x74, 0x4d, 0x69, 0x67, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x57, 0x6f, 0x72, 0x6b, 0x66, 709 0x6c, 0x6f, 0x77, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x4e, 0x0a, 0x04, 0x6e, 0x61, 710 0x6d, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x42, 0x3a, 0xe0, 0x41, 0x02, 0xfa, 0x41, 0x34, 711 0x0a, 0x32, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x6d, 0x69, 0x67, 0x72, 0x61, 0x74, 712 0x69, 0x6f, 0x6e, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2e, 0x63, 713 0x6f, 0x6d, 0x2f, 0x4d, 0x69, 0x67, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x57, 0x6f, 0x72, 0x6b, 714 0x66, 0x6c, 0x6f, 0x77, 0x52, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x22, 0xa9, 0x01, 0x0a, 0x1a, 0x47, 715 0x65, 0x74, 0x4d, 0x69, 0x67, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x53, 0x75, 0x62, 0x74, 0x61, 716 0x73, 0x6b, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x4d, 0x0a, 0x04, 0x6e, 0x61, 0x6d, 717 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x42, 0x39, 0xe0, 0x41, 0x02, 0xfa, 0x41, 0x33, 0x0a, 718 0x31, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x6d, 0x69, 0x67, 0x72, 0x61, 0x74, 0x69, 719 0x6f, 0x6e, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f, 720 0x6d, 0x2f, 0x4d, 0x69, 0x67, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x53, 0x75, 0x62, 0x74, 0x61, 721 0x73, 0x6b, 0x52, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x12, 0x3c, 0x0a, 0x09, 0x72, 0x65, 0x61, 0x64, 722 0x5f, 0x6d, 0x61, 0x73, 0x6b, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1a, 0x2e, 0x67, 0x6f, 723 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x46, 0x69, 724 0x65, 0x6c, 0x64, 0x4d, 0x61, 0x73, 0x6b, 0x42, 0x03, 0xe0, 0x41, 0x01, 0x52, 0x08, 0x72, 0x65, 725 0x61, 0x64, 0x4d, 0x61, 0x73, 0x6b, 0x22, 0x93, 0x02, 0x0a, 0x1c, 0x4c, 0x69, 0x73, 0x74, 0x4d, 726 0x69, 0x67, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x53, 0x75, 0x62, 0x74, 0x61, 0x73, 0x6b, 0x73, 727 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x52, 0x0a, 0x06, 0x70, 0x61, 0x72, 0x65, 0x6e, 728 0x74, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x42, 0x3a, 0xe0, 0x41, 0x02, 0xfa, 0x41, 0x34, 0x0a, 729 0x32, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x6d, 0x69, 0x67, 0x72, 0x61, 0x74, 0x69, 730 0x6f, 0x6e, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f, 731 0x6d, 0x2f, 0x4d, 0x69, 0x67, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x57, 0x6f, 0x72, 0x6b, 0x66, 732 0x6c, 0x6f, 0x77, 0x52, 0x06, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x12, 0x3c, 0x0a, 0x09, 0x72, 733 0x65, 0x61, 0x64, 0x5f, 0x6d, 0x61, 0x73, 0x6b, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1a, 734 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 735 0x2e, 0x46, 0x69, 0x65, 0x6c, 0x64, 0x4d, 0x61, 0x73, 0x6b, 0x42, 0x03, 0xe0, 0x41, 0x01, 0x52, 736 0x08, 0x72, 0x65, 0x61, 0x64, 0x4d, 0x61, 0x73, 0x6b, 0x12, 0x20, 0x0a, 0x09, 0x70, 0x61, 0x67, 737 0x65, 0x5f, 0x73, 0x69, 0x7a, 0x65, 0x18, 0x03, 0x20, 0x01, 0x28, 0x05, 0x42, 0x03, 0xe0, 0x41, 738 0x01, 0x52, 0x08, 0x70, 0x61, 0x67, 0x65, 0x53, 0x69, 0x7a, 0x65, 0x12, 0x22, 0x0a, 0x0a, 0x70, 739 0x61, 0x67, 0x65, 0x5f, 0x74, 0x6f, 0x6b, 0x65, 0x6e, 0x18, 0x04, 0x20, 0x01, 0x28, 0x09, 0x42, 740 0x03, 0xe0, 0x41, 0x01, 0x52, 0x09, 0x70, 0x61, 0x67, 0x65, 0x54, 0x6f, 0x6b, 0x65, 0x6e, 0x12, 741 0x1b, 0x0a, 0x06, 0x66, 0x69, 0x6c, 0x74, 0x65, 0x72, 0x18, 0x05, 0x20, 0x01, 0x28, 0x09, 0x42, 742 0x03, 0xe0, 0x41, 0x01, 0x52, 0x06, 0x66, 0x69, 0x6c, 0x74, 0x65, 0x72, 0x22, 0xb1, 0x01, 0x0a, 743 0x1d, 0x4c, 0x69, 0x73, 0x74, 0x4d, 0x69, 0x67, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x53, 0x75, 744 0x62, 0x74, 0x61, 0x73, 0x6b, 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x68, 745 0x0a, 0x12, 0x6d, 0x69, 0x67, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x5f, 0x73, 0x75, 0x62, 0x74, 746 0x61, 0x73, 0x6b, 0x73, 0x18, 0x01, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x39, 0x2e, 0x67, 0x6f, 0x6f, 747 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 748 0x72, 0x79, 0x2e, 0x6d, 0x69, 0x67, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x2e, 0x76, 0x32, 0x61, 749 0x6c, 0x70, 0x68, 0x61, 0x2e, 0x4d, 0x69, 0x67, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x53, 0x75, 750 0x62, 0x74, 0x61, 0x73, 0x6b, 0x52, 0x11, 0x6d, 0x69, 0x67, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 751 0x53, 0x75, 0x62, 0x74, 0x61, 0x73, 0x6b, 0x73, 0x12, 0x26, 0x0a, 0x0f, 0x6e, 0x65, 0x78, 0x74, 752 0x5f, 0x70, 0x61, 0x67, 0x65, 0x5f, 0x74, 0x6f, 0x6b, 0x65, 0x6e, 0x18, 0x02, 0x20, 0x01, 0x28, 753 0x09, 0x52, 0x0d, 0x6e, 0x65, 0x78, 0x74, 0x50, 0x61, 0x67, 0x65, 0x54, 0x6f, 0x6b, 0x65, 0x6e, 754 0x32, 0xaa, 0x0d, 0x0a, 0x10, 0x4d, 0x69, 0x67, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x53, 0x65, 755 0x72, 0x76, 0x69, 0x63, 0x65, 0x12, 0x8a, 0x02, 0x0a, 0x17, 0x43, 0x72, 0x65, 0x61, 0x74, 0x65, 756 0x4d, 0x69, 0x67, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x57, 0x6f, 0x72, 0x6b, 0x66, 0x6c, 0x6f, 757 0x77, 0x12, 0x47, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 758 0x2e, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x6d, 0x69, 0x67, 0x72, 0x61, 0x74, 759 0x69, 0x6f, 0x6e, 0x2e, 0x76, 0x32, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x2e, 0x43, 0x72, 0x65, 0x61, 760 0x74, 0x65, 0x4d, 0x69, 0x67, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x57, 0x6f, 0x72, 0x6b, 0x66, 761 0x6c, 0x6f, 0x77, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x3a, 0x2e, 0x67, 0x6f, 0x6f, 762 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 763 0x72, 0x79, 0x2e, 0x6d, 0x69, 0x67, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x2e, 0x76, 0x32, 0x61, 764 0x6c, 0x70, 0x68, 0x61, 0x2e, 0x4d, 0x69, 0x67, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x57, 0x6f, 765 0x72, 0x6b, 0x66, 0x6c, 0x6f, 0x77, 0x22, 0x6a, 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x48, 0x22, 0x32, 766 0x2f, 0x76, 0x32, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x2f, 0x7b, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 767 0x3d, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x73, 0x2f, 0x2a, 0x2f, 0x6c, 0x6f, 0x63, 0x61, 768 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x2a, 0x7d, 0x2f, 0x77, 0x6f, 0x72, 0x6b, 0x66, 0x6c, 0x6f, 769 0x77, 0x73, 0x3a, 0x12, 0x6d, 0x69, 0x67, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x5f, 0x77, 0x6f, 770 0x72, 0x6b, 0x66, 0x6c, 0x6f, 0x77, 0xda, 0x41, 0x19, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x2c, 771 0x6d, 0x69, 0x67, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x5f, 0x77, 0x6f, 0x72, 0x6b, 0x66, 0x6c, 772 0x6f, 0x77, 0x12, 0xdb, 0x01, 0x0a, 0x14, 0x47, 0x65, 0x74, 0x4d, 0x69, 0x67, 0x72, 0x61, 0x74, 773 0x69, 0x6f, 0x6e, 0x57, 0x6f, 0x72, 0x6b, 0x66, 0x6c, 0x6f, 0x77, 0x12, 0x44, 0x2e, 0x67, 0x6f, 774 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x62, 0x69, 0x67, 0x71, 0x75, 775 0x65, 0x72, 0x79, 0x2e, 0x6d, 0x69, 0x67, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x2e, 0x76, 0x32, 776 0x61, 0x6c, 0x70, 0x68, 0x61, 0x2e, 0x47, 0x65, 0x74, 0x4d, 0x69, 0x67, 0x72, 0x61, 0x74, 0x69, 777 0x6f, 0x6e, 0x57, 0x6f, 0x72, 0x6b, 0x66, 0x6c, 0x6f, 0x77, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 778 0x74, 0x1a, 0x3a, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 779 0x2e, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x6d, 0x69, 0x67, 0x72, 0x61, 0x74, 780 0x69, 0x6f, 0x6e, 0x2e, 0x76, 0x32, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x2e, 0x4d, 0x69, 0x67, 0x72, 781 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x57, 0x6f, 0x72, 0x6b, 0x66, 0x6c, 0x6f, 0x77, 0x22, 0x41, 0x82, 782 0xd3, 0xe4, 0x93, 0x02, 0x34, 0x12, 0x32, 0x2f, 0x76, 0x32, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x2f, 783 0x7b, 0x6e, 0x61, 0x6d, 0x65, 0x3d, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x73, 0x2f, 0x2a, 784 0x2f, 0x6c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x2a, 0x2f, 0x77, 0x6f, 0x72, 785 0x6b, 0x66, 0x6c, 0x6f, 0x77, 0x73, 0x2f, 0x2a, 0x7d, 0xda, 0x41, 0x04, 0x6e, 0x61, 0x6d, 0x65, 786 0x12, 0xee, 0x01, 0x0a, 0x16, 0x4c, 0x69, 0x73, 0x74, 0x4d, 0x69, 0x67, 0x72, 0x61, 0x74, 0x69, 787 0x6f, 0x6e, 0x57, 0x6f, 0x72, 0x6b, 0x66, 0x6c, 0x6f, 0x77, 0x73, 0x12, 0x46, 0x2e, 0x67, 0x6f, 788 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x62, 0x69, 0x67, 0x71, 0x75, 789 0x65, 0x72, 0x79, 0x2e, 0x6d, 0x69, 0x67, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x2e, 0x76, 0x32, 790 0x61, 0x6c, 0x70, 0x68, 0x61, 0x2e, 0x4c, 0x69, 0x73, 0x74, 0x4d, 0x69, 0x67, 0x72, 0x61, 0x74, 791 0x69, 0x6f, 0x6e, 0x57, 0x6f, 0x72, 0x6b, 0x66, 0x6c, 0x6f, 0x77, 0x73, 0x52, 0x65, 0x71, 0x75, 792 0x65, 0x73, 0x74, 0x1a, 0x47, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 793 0x75, 0x64, 0x2e, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x6d, 0x69, 0x67, 0x72, 794 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x2e, 0x76, 0x32, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x2e, 0x4c, 0x69, 795 0x73, 0x74, 0x4d, 0x69, 0x67, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x57, 0x6f, 0x72, 0x6b, 0x66, 796 0x6c, 0x6f, 0x77, 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x43, 0x82, 0xd3, 797 0xe4, 0x93, 0x02, 0x34, 0x12, 0x32, 0x2f, 0x76, 0x32, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x2f, 0x7b, 798 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x3d, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x73, 0x2f, 799 0x2a, 0x2f, 0x6c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x2a, 0x7d, 0x2f, 0x77, 800 0x6f, 0x72, 0x6b, 0x66, 0x6c, 0x6f, 0x77, 0x73, 0xda, 0x41, 0x06, 0x70, 0x61, 0x72, 0x65, 0x6e, 801 0x74, 0x12, 0xbd, 0x01, 0x0a, 0x17, 0x44, 0x65, 0x6c, 0x65, 0x74, 0x65, 0x4d, 0x69, 0x67, 0x72, 802 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x57, 0x6f, 0x72, 0x6b, 0x66, 0x6c, 0x6f, 0x77, 0x12, 0x47, 0x2e, 803 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x62, 0x69, 0x67, 804 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x6d, 0x69, 0x67, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x2e, 805 0x76, 0x32, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x2e, 0x44, 0x65, 0x6c, 0x65, 0x74, 0x65, 0x4d, 0x69, 806 0x67, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x57, 0x6f, 0x72, 0x6b, 0x66, 0x6c, 0x6f, 0x77, 0x52, 807 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x16, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 808 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x45, 0x6d, 0x70, 0x74, 0x79, 0x22, 0x41, 809 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x34, 0x2a, 0x32, 0x2f, 0x76, 0x32, 0x61, 0x6c, 0x70, 0x68, 0x61, 810 0x2f, 0x7b, 0x6e, 0x61, 0x6d, 0x65, 0x3d, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x73, 0x2f, 811 0x2a, 0x2f, 0x6c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x2a, 0x2f, 0x77, 0x6f, 812 0x72, 0x6b, 0x66, 0x6c, 0x6f, 0x77, 0x73, 0x2f, 0x2a, 0x7d, 0xda, 0x41, 0x04, 0x6e, 0x61, 0x6d, 813 0x65, 0x12, 0xc4, 0x01, 0x0a, 0x16, 0x53, 0x74, 0x61, 0x72, 0x74, 0x4d, 0x69, 0x67, 0x72, 0x61, 814 0x74, 0x69, 0x6f, 0x6e, 0x57, 0x6f, 0x72, 0x6b, 0x66, 0x6c, 0x6f, 0x77, 0x12, 0x46, 0x2e, 0x67, 815 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x62, 0x69, 0x67, 0x71, 816 0x75, 0x65, 0x72, 0x79, 0x2e, 0x6d, 0x69, 0x67, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x2e, 0x76, 817 0x32, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x2e, 0x53, 0x74, 0x61, 0x72, 0x74, 0x4d, 0x69, 0x67, 0x72, 818 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x57, 0x6f, 0x72, 0x6b, 0x66, 0x6c, 0x6f, 0x77, 0x52, 0x65, 0x71, 819 0x75, 0x65, 0x73, 0x74, 0x1a, 0x16, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72, 820 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x45, 0x6d, 0x70, 0x74, 0x79, 0x22, 0x4a, 0x82, 0xd3, 821 0xe4, 0x93, 0x02, 0x3d, 0x22, 0x38, 0x2f, 0x76, 0x32, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x2f, 0x7b, 822 0x6e, 0x61, 0x6d, 0x65, 0x3d, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x73, 0x2f, 0x2a, 0x2f, 823 0x6c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x2a, 0x2f, 0x77, 0x6f, 0x72, 0x6b, 824 0x66, 0x6c, 0x6f, 0x77, 0x73, 0x2f, 0x2a, 0x7d, 0x3a, 0x73, 0x74, 0x61, 0x72, 0x74, 0x3a, 0x01, 825 0x2a, 0xda, 0x41, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x12, 0xe3, 0x01, 0x0a, 0x13, 0x47, 0x65, 0x74, 826 0x4d, 0x69, 0x67, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x53, 0x75, 0x62, 0x74, 0x61, 0x73, 0x6b, 827 0x12, 0x43, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 828 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x6d, 0x69, 0x67, 0x72, 0x61, 0x74, 0x69, 829 0x6f, 0x6e, 0x2e, 0x76, 0x32, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x2e, 0x47, 0x65, 0x74, 0x4d, 0x69, 830 0x67, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x53, 0x75, 0x62, 0x74, 0x61, 0x73, 0x6b, 0x52, 0x65, 831 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x39, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 832 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x6d, 0x69, 833 0x67, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x2e, 0x76, 0x32, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x2e, 834 0x4d, 0x69, 0x67, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x53, 0x75, 0x62, 0x74, 0x61, 0x73, 0x6b, 835 0x22, 0x4c, 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x3f, 0x12, 0x3d, 0x2f, 0x76, 0x32, 0x61, 0x6c, 0x70, 836 0x68, 0x61, 0x2f, 0x7b, 0x6e, 0x61, 0x6d, 0x65, 0x3d, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 837 0x73, 0x2f, 0x2a, 0x2f, 0x6c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x2a, 0x2f, 838 0x77, 0x6f, 0x72, 0x6b, 0x66, 0x6c, 0x6f, 0x77, 0x73, 0x2f, 0x2a, 0x2f, 0x73, 0x75, 0x62, 0x74, 839 0x61, 0x73, 0x6b, 0x73, 0x2f, 0x2a, 0x7d, 0xda, 0x41, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x12, 0xf6, 840 0x01, 0x0a, 0x15, 0x4c, 0x69, 0x73, 0x74, 0x4d, 0x69, 0x67, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 841 0x53, 0x75, 0x62, 0x74, 0x61, 0x73, 0x6b, 0x73, 0x12, 0x45, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 842 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 843 0x2e, 0x6d, 0x69, 0x67, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x2e, 0x76, 0x32, 0x61, 0x6c, 0x70, 844 0x68, 0x61, 0x2e, 0x4c, 0x69, 0x73, 0x74, 0x4d, 0x69, 0x67, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 845 0x53, 0x75, 0x62, 0x74, 0x61, 0x73, 0x6b, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 846 0x46, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x62, 847 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x6d, 0x69, 0x67, 0x72, 0x61, 0x74, 0x69, 0x6f, 848 0x6e, 0x2e, 0x76, 0x32, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x2e, 0x4c, 0x69, 0x73, 0x74, 0x4d, 0x69, 849 0x67, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x53, 0x75, 0x62, 0x74, 0x61, 0x73, 0x6b, 0x73, 0x52, 850 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x4e, 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x3f, 0x12, 851 0x3d, 0x2f, 0x76, 0x32, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x2f, 0x7b, 0x70, 0x61, 0x72, 0x65, 0x6e, 852 0x74, 0x3d, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x73, 0x2f, 0x2a, 0x2f, 0x6c, 0x6f, 0x63, 853 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x2a, 0x2f, 0x77, 0x6f, 0x72, 0x6b, 0x66, 0x6c, 0x6f, 854 0x77, 0x73, 0x2f, 0x2a, 0x7d, 0x2f, 0x73, 0x75, 0x62, 0x74, 0x61, 0x73, 0x6b, 0x73, 0xda, 0x41, 855 0x06, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x1a, 0x54, 0xca, 0x41, 0x20, 0x62, 0x69, 0x67, 0x71, 856 0x75, 0x65, 0x72, 0x79, 0x6d, 0x69, 0x67, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x2e, 0x67, 0x6f, 857 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f, 0x6d, 0xd2, 0x41, 0x2e, 0x68, 858 0x74, 0x74, 0x70, 0x73, 0x3a, 0x2f, 0x2f, 0x77, 0x77, 0x77, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 859 0x65, 0x61, 0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x61, 0x75, 0x74, 0x68, 0x2f, 0x63, 860 0x6c, 0x6f, 0x75, 0x64, 0x2d, 0x70, 0x6c, 0x61, 0x74, 0x66, 0x6f, 0x72, 0x6d, 0x42, 0xec, 0x01, 861 0x0a, 0x2b, 0x63, 0x6f, 0x6d, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 862 0x75, 0x64, 0x2e, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x6d, 0x69, 0x67, 0x72, 863 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x2e, 0x76, 0x32, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x42, 0x15, 0x4d, 864 0x69, 0x67, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x53, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x50, 865 0x72, 0x6f, 0x74, 0x6f, 0x50, 0x01, 0x5a, 0x50, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x67, 866 0x6f, 0x6c, 0x61, 0x6e, 0x67, 0x2e, 0x6f, 0x72, 0x67, 0x2f, 0x67, 0x65, 0x6e, 0x70, 0x72, 0x6f, 867 0x74, 0x6f, 0x2f, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2f, 0x63, 0x6c, 868 0x6f, 0x75, 0x64, 0x2f, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2f, 0x6d, 0x69, 0x67, 869 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x2f, 0x76, 0x32, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x3b, 0x6d, 870 0x69, 0x67, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0xaa, 0x02, 0x27, 0x47, 0x6f, 0x6f, 0x67, 0x6c, 871 0x65, 0x2e, 0x43, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x42, 0x69, 0x67, 0x51, 0x75, 0x65, 0x72, 0x79, 872 0x2e, 0x4d, 0x69, 0x67, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x2e, 0x56, 0x32, 0x41, 0x6c, 0x70, 873 0x68, 0x61, 0xca, 0x02, 0x27, 0x47, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x5c, 0x43, 0x6c, 0x6f, 0x75, 874 0x64, 0x5c, 0x42, 0x69, 0x67, 0x51, 0x75, 0x65, 0x72, 0x79, 0x5c, 0x4d, 0x69, 0x67, 0x72, 0x61, 875 0x74, 0x69, 0x6f, 0x6e, 0x5c, 0x56, 0x32, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x62, 0x06, 0x70, 0x72, 876 0x6f, 0x74, 0x6f, 0x33, 877} 878 879var ( 880 file_google_cloud_bigquery_migration_v2alpha_migration_service_proto_rawDescOnce sync.Once 881 file_google_cloud_bigquery_migration_v2alpha_migration_service_proto_rawDescData = file_google_cloud_bigquery_migration_v2alpha_migration_service_proto_rawDesc 882) 883 884func file_google_cloud_bigquery_migration_v2alpha_migration_service_proto_rawDescGZIP() []byte { 885 file_google_cloud_bigquery_migration_v2alpha_migration_service_proto_rawDescOnce.Do(func() { 886 file_google_cloud_bigquery_migration_v2alpha_migration_service_proto_rawDescData = protoimpl.X.CompressGZIP(file_google_cloud_bigquery_migration_v2alpha_migration_service_proto_rawDescData) 887 }) 888 return file_google_cloud_bigquery_migration_v2alpha_migration_service_proto_rawDescData 889} 890 891var file_google_cloud_bigquery_migration_v2alpha_migration_service_proto_msgTypes = make([]protoimpl.MessageInfo, 9) 892var file_google_cloud_bigquery_migration_v2alpha_migration_service_proto_goTypes = []interface{}{ 893 (*CreateMigrationWorkflowRequest)(nil), // 0: google.cloud.bigquery.migration.v2alpha.CreateMigrationWorkflowRequest 894 (*GetMigrationWorkflowRequest)(nil), // 1: google.cloud.bigquery.migration.v2alpha.GetMigrationWorkflowRequest 895 (*ListMigrationWorkflowsRequest)(nil), // 2: google.cloud.bigquery.migration.v2alpha.ListMigrationWorkflowsRequest 896 (*ListMigrationWorkflowsResponse)(nil), // 3: google.cloud.bigquery.migration.v2alpha.ListMigrationWorkflowsResponse 897 (*DeleteMigrationWorkflowRequest)(nil), // 4: google.cloud.bigquery.migration.v2alpha.DeleteMigrationWorkflowRequest 898 (*StartMigrationWorkflowRequest)(nil), // 5: google.cloud.bigquery.migration.v2alpha.StartMigrationWorkflowRequest 899 (*GetMigrationSubtaskRequest)(nil), // 6: google.cloud.bigquery.migration.v2alpha.GetMigrationSubtaskRequest 900 (*ListMigrationSubtasksRequest)(nil), // 7: google.cloud.bigquery.migration.v2alpha.ListMigrationSubtasksRequest 901 (*ListMigrationSubtasksResponse)(nil), // 8: google.cloud.bigquery.migration.v2alpha.ListMigrationSubtasksResponse 902 (*MigrationWorkflow)(nil), // 9: google.cloud.bigquery.migration.v2alpha.MigrationWorkflow 903 (*fieldmaskpb.FieldMask)(nil), // 10: google.protobuf.FieldMask 904 (*MigrationSubtask)(nil), // 11: google.cloud.bigquery.migration.v2alpha.MigrationSubtask 905 (*emptypb.Empty)(nil), // 12: google.protobuf.Empty 906} 907var file_google_cloud_bigquery_migration_v2alpha_migration_service_proto_depIdxs = []int32{ 908 9, // 0: google.cloud.bigquery.migration.v2alpha.CreateMigrationWorkflowRequest.migration_workflow:type_name -> google.cloud.bigquery.migration.v2alpha.MigrationWorkflow 909 10, // 1: google.cloud.bigquery.migration.v2alpha.GetMigrationWorkflowRequest.read_mask:type_name -> google.protobuf.FieldMask 910 10, // 2: google.cloud.bigquery.migration.v2alpha.ListMigrationWorkflowsRequest.read_mask:type_name -> google.protobuf.FieldMask 911 9, // 3: google.cloud.bigquery.migration.v2alpha.ListMigrationWorkflowsResponse.migration_workflows:type_name -> google.cloud.bigquery.migration.v2alpha.MigrationWorkflow 912 10, // 4: google.cloud.bigquery.migration.v2alpha.GetMigrationSubtaskRequest.read_mask:type_name -> google.protobuf.FieldMask 913 10, // 5: google.cloud.bigquery.migration.v2alpha.ListMigrationSubtasksRequest.read_mask:type_name -> google.protobuf.FieldMask 914 11, // 6: google.cloud.bigquery.migration.v2alpha.ListMigrationSubtasksResponse.migration_subtasks:type_name -> google.cloud.bigquery.migration.v2alpha.MigrationSubtask 915 0, // 7: google.cloud.bigquery.migration.v2alpha.MigrationService.CreateMigrationWorkflow:input_type -> google.cloud.bigquery.migration.v2alpha.CreateMigrationWorkflowRequest 916 1, // 8: google.cloud.bigquery.migration.v2alpha.MigrationService.GetMigrationWorkflow:input_type -> google.cloud.bigquery.migration.v2alpha.GetMigrationWorkflowRequest 917 2, // 9: google.cloud.bigquery.migration.v2alpha.MigrationService.ListMigrationWorkflows:input_type -> google.cloud.bigquery.migration.v2alpha.ListMigrationWorkflowsRequest 918 4, // 10: google.cloud.bigquery.migration.v2alpha.MigrationService.DeleteMigrationWorkflow:input_type -> google.cloud.bigquery.migration.v2alpha.DeleteMigrationWorkflowRequest 919 5, // 11: google.cloud.bigquery.migration.v2alpha.MigrationService.StartMigrationWorkflow:input_type -> google.cloud.bigquery.migration.v2alpha.StartMigrationWorkflowRequest 920 6, // 12: google.cloud.bigquery.migration.v2alpha.MigrationService.GetMigrationSubtask:input_type -> google.cloud.bigquery.migration.v2alpha.GetMigrationSubtaskRequest 921 7, // 13: google.cloud.bigquery.migration.v2alpha.MigrationService.ListMigrationSubtasks:input_type -> google.cloud.bigquery.migration.v2alpha.ListMigrationSubtasksRequest 922 9, // 14: google.cloud.bigquery.migration.v2alpha.MigrationService.CreateMigrationWorkflow:output_type -> google.cloud.bigquery.migration.v2alpha.MigrationWorkflow 923 9, // 15: google.cloud.bigquery.migration.v2alpha.MigrationService.GetMigrationWorkflow:output_type -> google.cloud.bigquery.migration.v2alpha.MigrationWorkflow 924 3, // 16: google.cloud.bigquery.migration.v2alpha.MigrationService.ListMigrationWorkflows:output_type -> google.cloud.bigquery.migration.v2alpha.ListMigrationWorkflowsResponse 925 12, // 17: google.cloud.bigquery.migration.v2alpha.MigrationService.DeleteMigrationWorkflow:output_type -> google.protobuf.Empty 926 12, // 18: google.cloud.bigquery.migration.v2alpha.MigrationService.StartMigrationWorkflow:output_type -> google.protobuf.Empty 927 11, // 19: google.cloud.bigquery.migration.v2alpha.MigrationService.GetMigrationSubtask:output_type -> google.cloud.bigquery.migration.v2alpha.MigrationSubtask 928 8, // 20: google.cloud.bigquery.migration.v2alpha.MigrationService.ListMigrationSubtasks:output_type -> google.cloud.bigquery.migration.v2alpha.ListMigrationSubtasksResponse 929 14, // [14:21] is the sub-list for method output_type 930 7, // [7:14] is the sub-list for method input_type 931 7, // [7:7] is the sub-list for extension type_name 932 7, // [7:7] is the sub-list for extension extendee 933 0, // [0:7] is the sub-list for field type_name 934} 935 936func init() { file_google_cloud_bigquery_migration_v2alpha_migration_service_proto_init() } 937func file_google_cloud_bigquery_migration_v2alpha_migration_service_proto_init() { 938 if File_google_cloud_bigquery_migration_v2alpha_migration_service_proto != nil { 939 return 940 } 941 file_google_cloud_bigquery_migration_v2alpha_migration_entities_proto_init() 942 file_google_cloud_bigquery_migration_v2alpha_migration_error_details_proto_init() 943 file_google_cloud_bigquery_migration_v2alpha_migration_metrics_proto_init() 944 if !protoimpl.UnsafeEnabled { 945 file_google_cloud_bigquery_migration_v2alpha_migration_service_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} { 946 switch v := v.(*CreateMigrationWorkflowRequest); i { 947 case 0: 948 return &v.state 949 case 1: 950 return &v.sizeCache 951 case 2: 952 return &v.unknownFields 953 default: 954 return nil 955 } 956 } 957 file_google_cloud_bigquery_migration_v2alpha_migration_service_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} { 958 switch v := v.(*GetMigrationWorkflowRequest); i { 959 case 0: 960 return &v.state 961 case 1: 962 return &v.sizeCache 963 case 2: 964 return &v.unknownFields 965 default: 966 return nil 967 } 968 } 969 file_google_cloud_bigquery_migration_v2alpha_migration_service_proto_msgTypes[2].Exporter = func(v interface{}, i int) interface{} { 970 switch v := v.(*ListMigrationWorkflowsRequest); i { 971 case 0: 972 return &v.state 973 case 1: 974 return &v.sizeCache 975 case 2: 976 return &v.unknownFields 977 default: 978 return nil 979 } 980 } 981 file_google_cloud_bigquery_migration_v2alpha_migration_service_proto_msgTypes[3].Exporter = func(v interface{}, i int) interface{} { 982 switch v := v.(*ListMigrationWorkflowsResponse); i { 983 case 0: 984 return &v.state 985 case 1: 986 return &v.sizeCache 987 case 2: 988 return &v.unknownFields 989 default: 990 return nil 991 } 992 } 993 file_google_cloud_bigquery_migration_v2alpha_migration_service_proto_msgTypes[4].Exporter = func(v interface{}, i int) interface{} { 994 switch v := v.(*DeleteMigrationWorkflowRequest); i { 995 case 0: 996 return &v.state 997 case 1: 998 return &v.sizeCache 999 case 2: 1000 return &v.unknownFields 1001 default: 1002 return nil 1003 } 1004 } 1005 file_google_cloud_bigquery_migration_v2alpha_migration_service_proto_msgTypes[5].Exporter = func(v interface{}, i int) interface{} { 1006 switch v := v.(*StartMigrationWorkflowRequest); i { 1007 case 0: 1008 return &v.state 1009 case 1: 1010 return &v.sizeCache 1011 case 2: 1012 return &v.unknownFields 1013 default: 1014 return nil 1015 } 1016 } 1017 file_google_cloud_bigquery_migration_v2alpha_migration_service_proto_msgTypes[6].Exporter = func(v interface{}, i int) interface{} { 1018 switch v := v.(*GetMigrationSubtaskRequest); i { 1019 case 0: 1020 return &v.state 1021 case 1: 1022 return &v.sizeCache 1023 case 2: 1024 return &v.unknownFields 1025 default: 1026 return nil 1027 } 1028 } 1029 file_google_cloud_bigquery_migration_v2alpha_migration_service_proto_msgTypes[7].Exporter = func(v interface{}, i int) interface{} { 1030 switch v := v.(*ListMigrationSubtasksRequest); i { 1031 case 0: 1032 return &v.state 1033 case 1: 1034 return &v.sizeCache 1035 case 2: 1036 return &v.unknownFields 1037 default: 1038 return nil 1039 } 1040 } 1041 file_google_cloud_bigquery_migration_v2alpha_migration_service_proto_msgTypes[8].Exporter = func(v interface{}, i int) interface{} { 1042 switch v := v.(*ListMigrationSubtasksResponse); i { 1043 case 0: 1044 return &v.state 1045 case 1: 1046 return &v.sizeCache 1047 case 2: 1048 return &v.unknownFields 1049 default: 1050 return nil 1051 } 1052 } 1053 } 1054 type x struct{} 1055 out := protoimpl.TypeBuilder{ 1056 File: protoimpl.DescBuilder{ 1057 GoPackagePath: reflect.TypeOf(x{}).PkgPath(), 1058 RawDescriptor: file_google_cloud_bigquery_migration_v2alpha_migration_service_proto_rawDesc, 1059 NumEnums: 0, 1060 NumMessages: 9, 1061 NumExtensions: 0, 1062 NumServices: 1, 1063 }, 1064 GoTypes: file_google_cloud_bigquery_migration_v2alpha_migration_service_proto_goTypes, 1065 DependencyIndexes: file_google_cloud_bigquery_migration_v2alpha_migration_service_proto_depIdxs, 1066 MessageInfos: file_google_cloud_bigquery_migration_v2alpha_migration_service_proto_msgTypes, 1067 }.Build() 1068 File_google_cloud_bigquery_migration_v2alpha_migration_service_proto = out.File 1069 file_google_cloud_bigquery_migration_v2alpha_migration_service_proto_rawDesc = nil 1070 file_google_cloud_bigquery_migration_v2alpha_migration_service_proto_goTypes = nil 1071 file_google_cloud_bigquery_migration_v2alpha_migration_service_proto_depIdxs = nil 1072} 1073 1074// Reference imports to suppress errors if they are not otherwise used. 1075var _ context.Context 1076var _ grpc.ClientConnInterface 1077 1078// This is a compile-time assertion to ensure that this generated file 1079// is compatible with the grpc package it is being compiled against. 1080const _ = grpc.SupportPackageIsVersion6 1081 1082// MigrationServiceClient is the client API for MigrationService service. 1083// 1084// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream. 1085type MigrationServiceClient interface { 1086 // Creates a migration workflow. 1087 CreateMigrationWorkflow(ctx context.Context, in *CreateMigrationWorkflowRequest, opts ...grpc.CallOption) (*MigrationWorkflow, error) 1088 // Gets a previously created migration workflow. 1089 GetMigrationWorkflow(ctx context.Context, in *GetMigrationWorkflowRequest, opts ...grpc.CallOption) (*MigrationWorkflow, error) 1090 // Lists previously created migration workflow. 1091 ListMigrationWorkflows(ctx context.Context, in *ListMigrationWorkflowsRequest, opts ...grpc.CallOption) (*ListMigrationWorkflowsResponse, error) 1092 // Deletes a migration workflow by name. 1093 DeleteMigrationWorkflow(ctx context.Context, in *DeleteMigrationWorkflowRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) 1094 // Starts a previously created migration workflow. I.e., the state transitions 1095 // from DRAFT to RUNNING. This is a no-op if the state is already RUNNING. 1096 // An error will be signaled if the state is anything other than DRAFT or 1097 // RUNNING. 1098 StartMigrationWorkflow(ctx context.Context, in *StartMigrationWorkflowRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) 1099 // Gets a previously created migration subtask. 1100 GetMigrationSubtask(ctx context.Context, in *GetMigrationSubtaskRequest, opts ...grpc.CallOption) (*MigrationSubtask, error) 1101 // Lists previously created migration subtasks. 1102 ListMigrationSubtasks(ctx context.Context, in *ListMigrationSubtasksRequest, opts ...grpc.CallOption) (*ListMigrationSubtasksResponse, error) 1103} 1104 1105type migrationServiceClient struct { 1106 cc grpc.ClientConnInterface 1107} 1108 1109func NewMigrationServiceClient(cc grpc.ClientConnInterface) MigrationServiceClient { 1110 return &migrationServiceClient{cc} 1111} 1112 1113func (c *migrationServiceClient) CreateMigrationWorkflow(ctx context.Context, in *CreateMigrationWorkflowRequest, opts ...grpc.CallOption) (*MigrationWorkflow, error) { 1114 out := new(MigrationWorkflow) 1115 err := c.cc.Invoke(ctx, "/google.cloud.bigquery.migration.v2alpha.MigrationService/CreateMigrationWorkflow", in, out, opts...) 1116 if err != nil { 1117 return nil, err 1118 } 1119 return out, nil 1120} 1121 1122func (c *migrationServiceClient) GetMigrationWorkflow(ctx context.Context, in *GetMigrationWorkflowRequest, opts ...grpc.CallOption) (*MigrationWorkflow, error) { 1123 out := new(MigrationWorkflow) 1124 err := c.cc.Invoke(ctx, "/google.cloud.bigquery.migration.v2alpha.MigrationService/GetMigrationWorkflow", in, out, opts...) 1125 if err != nil { 1126 return nil, err 1127 } 1128 return out, nil 1129} 1130 1131func (c *migrationServiceClient) ListMigrationWorkflows(ctx context.Context, in *ListMigrationWorkflowsRequest, opts ...grpc.CallOption) (*ListMigrationWorkflowsResponse, error) { 1132 out := new(ListMigrationWorkflowsResponse) 1133 err := c.cc.Invoke(ctx, "/google.cloud.bigquery.migration.v2alpha.MigrationService/ListMigrationWorkflows", in, out, opts...) 1134 if err != nil { 1135 return nil, err 1136 } 1137 return out, nil 1138} 1139 1140func (c *migrationServiceClient) DeleteMigrationWorkflow(ctx context.Context, in *DeleteMigrationWorkflowRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) { 1141 out := new(emptypb.Empty) 1142 err := c.cc.Invoke(ctx, "/google.cloud.bigquery.migration.v2alpha.MigrationService/DeleteMigrationWorkflow", in, out, opts...) 1143 if err != nil { 1144 return nil, err 1145 } 1146 return out, nil 1147} 1148 1149func (c *migrationServiceClient) StartMigrationWorkflow(ctx context.Context, in *StartMigrationWorkflowRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) { 1150 out := new(emptypb.Empty) 1151 err := c.cc.Invoke(ctx, "/google.cloud.bigquery.migration.v2alpha.MigrationService/StartMigrationWorkflow", in, out, opts...) 1152 if err != nil { 1153 return nil, err 1154 } 1155 return out, nil 1156} 1157 1158func (c *migrationServiceClient) GetMigrationSubtask(ctx context.Context, in *GetMigrationSubtaskRequest, opts ...grpc.CallOption) (*MigrationSubtask, error) { 1159 out := new(MigrationSubtask) 1160 err := c.cc.Invoke(ctx, "/google.cloud.bigquery.migration.v2alpha.MigrationService/GetMigrationSubtask", in, out, opts...) 1161 if err != nil { 1162 return nil, err 1163 } 1164 return out, nil 1165} 1166 1167func (c *migrationServiceClient) ListMigrationSubtasks(ctx context.Context, in *ListMigrationSubtasksRequest, opts ...grpc.CallOption) (*ListMigrationSubtasksResponse, error) { 1168 out := new(ListMigrationSubtasksResponse) 1169 err := c.cc.Invoke(ctx, "/google.cloud.bigquery.migration.v2alpha.MigrationService/ListMigrationSubtasks", in, out, opts...) 1170 if err != nil { 1171 return nil, err 1172 } 1173 return out, nil 1174} 1175 1176// MigrationServiceServer is the server API for MigrationService service. 1177type MigrationServiceServer interface { 1178 // Creates a migration workflow. 1179 CreateMigrationWorkflow(context.Context, *CreateMigrationWorkflowRequest) (*MigrationWorkflow, error) 1180 // Gets a previously created migration workflow. 1181 GetMigrationWorkflow(context.Context, *GetMigrationWorkflowRequest) (*MigrationWorkflow, error) 1182 // Lists previously created migration workflow. 1183 ListMigrationWorkflows(context.Context, *ListMigrationWorkflowsRequest) (*ListMigrationWorkflowsResponse, error) 1184 // Deletes a migration workflow by name. 1185 DeleteMigrationWorkflow(context.Context, *DeleteMigrationWorkflowRequest) (*emptypb.Empty, error) 1186 // Starts a previously created migration workflow. I.e., the state transitions 1187 // from DRAFT to RUNNING. This is a no-op if the state is already RUNNING. 1188 // An error will be signaled if the state is anything other than DRAFT or 1189 // RUNNING. 1190 StartMigrationWorkflow(context.Context, *StartMigrationWorkflowRequest) (*emptypb.Empty, error) 1191 // Gets a previously created migration subtask. 1192 GetMigrationSubtask(context.Context, *GetMigrationSubtaskRequest) (*MigrationSubtask, error) 1193 // Lists previously created migration subtasks. 1194 ListMigrationSubtasks(context.Context, *ListMigrationSubtasksRequest) (*ListMigrationSubtasksResponse, error) 1195} 1196 1197// UnimplementedMigrationServiceServer can be embedded to have forward compatible implementations. 1198type UnimplementedMigrationServiceServer struct { 1199} 1200 1201func (*UnimplementedMigrationServiceServer) CreateMigrationWorkflow(context.Context, *CreateMigrationWorkflowRequest) (*MigrationWorkflow, error) { 1202 return nil, status.Errorf(codes.Unimplemented, "method CreateMigrationWorkflow not implemented") 1203} 1204func (*UnimplementedMigrationServiceServer) GetMigrationWorkflow(context.Context, *GetMigrationWorkflowRequest) (*MigrationWorkflow, error) { 1205 return nil, status.Errorf(codes.Unimplemented, "method GetMigrationWorkflow not implemented") 1206} 1207func (*UnimplementedMigrationServiceServer) ListMigrationWorkflows(context.Context, *ListMigrationWorkflowsRequest) (*ListMigrationWorkflowsResponse, error) { 1208 return nil, status.Errorf(codes.Unimplemented, "method ListMigrationWorkflows not implemented") 1209} 1210func (*UnimplementedMigrationServiceServer) DeleteMigrationWorkflow(context.Context, *DeleteMigrationWorkflowRequest) (*emptypb.Empty, error) { 1211 return nil, status.Errorf(codes.Unimplemented, "method DeleteMigrationWorkflow not implemented") 1212} 1213func (*UnimplementedMigrationServiceServer) StartMigrationWorkflow(context.Context, *StartMigrationWorkflowRequest) (*emptypb.Empty, error) { 1214 return nil, status.Errorf(codes.Unimplemented, "method StartMigrationWorkflow not implemented") 1215} 1216func (*UnimplementedMigrationServiceServer) GetMigrationSubtask(context.Context, *GetMigrationSubtaskRequest) (*MigrationSubtask, error) { 1217 return nil, status.Errorf(codes.Unimplemented, "method GetMigrationSubtask not implemented") 1218} 1219func (*UnimplementedMigrationServiceServer) ListMigrationSubtasks(context.Context, *ListMigrationSubtasksRequest) (*ListMigrationSubtasksResponse, error) { 1220 return nil, status.Errorf(codes.Unimplemented, "method ListMigrationSubtasks not implemented") 1221} 1222 1223func RegisterMigrationServiceServer(s *grpc.Server, srv MigrationServiceServer) { 1224 s.RegisterService(&_MigrationService_serviceDesc, srv) 1225} 1226 1227func _MigrationService_CreateMigrationWorkflow_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 1228 in := new(CreateMigrationWorkflowRequest) 1229 if err := dec(in); err != nil { 1230 return nil, err 1231 } 1232 if interceptor == nil { 1233 return srv.(MigrationServiceServer).CreateMigrationWorkflow(ctx, in) 1234 } 1235 info := &grpc.UnaryServerInfo{ 1236 Server: srv, 1237 FullMethod: "/google.cloud.bigquery.migration.v2alpha.MigrationService/CreateMigrationWorkflow", 1238 } 1239 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 1240 return srv.(MigrationServiceServer).CreateMigrationWorkflow(ctx, req.(*CreateMigrationWorkflowRequest)) 1241 } 1242 return interceptor(ctx, in, info, handler) 1243} 1244 1245func _MigrationService_GetMigrationWorkflow_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 1246 in := new(GetMigrationWorkflowRequest) 1247 if err := dec(in); err != nil { 1248 return nil, err 1249 } 1250 if interceptor == nil { 1251 return srv.(MigrationServiceServer).GetMigrationWorkflow(ctx, in) 1252 } 1253 info := &grpc.UnaryServerInfo{ 1254 Server: srv, 1255 FullMethod: "/google.cloud.bigquery.migration.v2alpha.MigrationService/GetMigrationWorkflow", 1256 } 1257 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 1258 return srv.(MigrationServiceServer).GetMigrationWorkflow(ctx, req.(*GetMigrationWorkflowRequest)) 1259 } 1260 return interceptor(ctx, in, info, handler) 1261} 1262 1263func _MigrationService_ListMigrationWorkflows_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 1264 in := new(ListMigrationWorkflowsRequest) 1265 if err := dec(in); err != nil { 1266 return nil, err 1267 } 1268 if interceptor == nil { 1269 return srv.(MigrationServiceServer).ListMigrationWorkflows(ctx, in) 1270 } 1271 info := &grpc.UnaryServerInfo{ 1272 Server: srv, 1273 FullMethod: "/google.cloud.bigquery.migration.v2alpha.MigrationService/ListMigrationWorkflows", 1274 } 1275 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 1276 return srv.(MigrationServiceServer).ListMigrationWorkflows(ctx, req.(*ListMigrationWorkflowsRequest)) 1277 } 1278 return interceptor(ctx, in, info, handler) 1279} 1280 1281func _MigrationService_DeleteMigrationWorkflow_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 1282 in := new(DeleteMigrationWorkflowRequest) 1283 if err := dec(in); err != nil { 1284 return nil, err 1285 } 1286 if interceptor == nil { 1287 return srv.(MigrationServiceServer).DeleteMigrationWorkflow(ctx, in) 1288 } 1289 info := &grpc.UnaryServerInfo{ 1290 Server: srv, 1291 FullMethod: "/google.cloud.bigquery.migration.v2alpha.MigrationService/DeleteMigrationWorkflow", 1292 } 1293 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 1294 return srv.(MigrationServiceServer).DeleteMigrationWorkflow(ctx, req.(*DeleteMigrationWorkflowRequest)) 1295 } 1296 return interceptor(ctx, in, info, handler) 1297} 1298 1299func _MigrationService_StartMigrationWorkflow_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 1300 in := new(StartMigrationWorkflowRequest) 1301 if err := dec(in); err != nil { 1302 return nil, err 1303 } 1304 if interceptor == nil { 1305 return srv.(MigrationServiceServer).StartMigrationWorkflow(ctx, in) 1306 } 1307 info := &grpc.UnaryServerInfo{ 1308 Server: srv, 1309 FullMethod: "/google.cloud.bigquery.migration.v2alpha.MigrationService/StartMigrationWorkflow", 1310 } 1311 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 1312 return srv.(MigrationServiceServer).StartMigrationWorkflow(ctx, req.(*StartMigrationWorkflowRequest)) 1313 } 1314 return interceptor(ctx, in, info, handler) 1315} 1316 1317func _MigrationService_GetMigrationSubtask_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 1318 in := new(GetMigrationSubtaskRequest) 1319 if err := dec(in); err != nil { 1320 return nil, err 1321 } 1322 if interceptor == nil { 1323 return srv.(MigrationServiceServer).GetMigrationSubtask(ctx, in) 1324 } 1325 info := &grpc.UnaryServerInfo{ 1326 Server: srv, 1327 FullMethod: "/google.cloud.bigquery.migration.v2alpha.MigrationService/GetMigrationSubtask", 1328 } 1329 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 1330 return srv.(MigrationServiceServer).GetMigrationSubtask(ctx, req.(*GetMigrationSubtaskRequest)) 1331 } 1332 return interceptor(ctx, in, info, handler) 1333} 1334 1335func _MigrationService_ListMigrationSubtasks_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 1336 in := new(ListMigrationSubtasksRequest) 1337 if err := dec(in); err != nil { 1338 return nil, err 1339 } 1340 if interceptor == nil { 1341 return srv.(MigrationServiceServer).ListMigrationSubtasks(ctx, in) 1342 } 1343 info := &grpc.UnaryServerInfo{ 1344 Server: srv, 1345 FullMethod: "/google.cloud.bigquery.migration.v2alpha.MigrationService/ListMigrationSubtasks", 1346 } 1347 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 1348 return srv.(MigrationServiceServer).ListMigrationSubtasks(ctx, req.(*ListMigrationSubtasksRequest)) 1349 } 1350 return interceptor(ctx, in, info, handler) 1351} 1352 1353var _MigrationService_serviceDesc = grpc.ServiceDesc{ 1354 ServiceName: "google.cloud.bigquery.migration.v2alpha.MigrationService", 1355 HandlerType: (*MigrationServiceServer)(nil), 1356 Methods: []grpc.MethodDesc{ 1357 { 1358 MethodName: "CreateMigrationWorkflow", 1359 Handler: _MigrationService_CreateMigrationWorkflow_Handler, 1360 }, 1361 { 1362 MethodName: "GetMigrationWorkflow", 1363 Handler: _MigrationService_GetMigrationWorkflow_Handler, 1364 }, 1365 { 1366 MethodName: "ListMigrationWorkflows", 1367 Handler: _MigrationService_ListMigrationWorkflows_Handler, 1368 }, 1369 { 1370 MethodName: "DeleteMigrationWorkflow", 1371 Handler: _MigrationService_DeleteMigrationWorkflow_Handler, 1372 }, 1373 { 1374 MethodName: "StartMigrationWorkflow", 1375 Handler: _MigrationService_StartMigrationWorkflow_Handler, 1376 }, 1377 { 1378 MethodName: "GetMigrationSubtask", 1379 Handler: _MigrationService_GetMigrationSubtask_Handler, 1380 }, 1381 { 1382 MethodName: "ListMigrationSubtasks", 1383 Handler: _MigrationService_ListMigrationSubtasks_Handler, 1384 }, 1385 }, 1386 Streams: []grpc.StreamDesc{}, 1387 Metadata: "google/cloud/bigquery/migration/v2alpha/migration_service.proto", 1388} 1389