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, 0x98, 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, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33, 871} 872 873var ( 874 file_google_cloud_bigquery_migration_v2alpha_migration_service_proto_rawDescOnce sync.Once 875 file_google_cloud_bigquery_migration_v2alpha_migration_service_proto_rawDescData = file_google_cloud_bigquery_migration_v2alpha_migration_service_proto_rawDesc 876) 877 878func file_google_cloud_bigquery_migration_v2alpha_migration_service_proto_rawDescGZIP() []byte { 879 file_google_cloud_bigquery_migration_v2alpha_migration_service_proto_rawDescOnce.Do(func() { 880 file_google_cloud_bigquery_migration_v2alpha_migration_service_proto_rawDescData = protoimpl.X.CompressGZIP(file_google_cloud_bigquery_migration_v2alpha_migration_service_proto_rawDescData) 881 }) 882 return file_google_cloud_bigquery_migration_v2alpha_migration_service_proto_rawDescData 883} 884 885var file_google_cloud_bigquery_migration_v2alpha_migration_service_proto_msgTypes = make([]protoimpl.MessageInfo, 9) 886var file_google_cloud_bigquery_migration_v2alpha_migration_service_proto_goTypes = []interface{}{ 887 (*CreateMigrationWorkflowRequest)(nil), // 0: google.cloud.bigquery.migration.v2alpha.CreateMigrationWorkflowRequest 888 (*GetMigrationWorkflowRequest)(nil), // 1: google.cloud.bigquery.migration.v2alpha.GetMigrationWorkflowRequest 889 (*ListMigrationWorkflowsRequest)(nil), // 2: google.cloud.bigquery.migration.v2alpha.ListMigrationWorkflowsRequest 890 (*ListMigrationWorkflowsResponse)(nil), // 3: google.cloud.bigquery.migration.v2alpha.ListMigrationWorkflowsResponse 891 (*DeleteMigrationWorkflowRequest)(nil), // 4: google.cloud.bigquery.migration.v2alpha.DeleteMigrationWorkflowRequest 892 (*StartMigrationWorkflowRequest)(nil), // 5: google.cloud.bigquery.migration.v2alpha.StartMigrationWorkflowRequest 893 (*GetMigrationSubtaskRequest)(nil), // 6: google.cloud.bigquery.migration.v2alpha.GetMigrationSubtaskRequest 894 (*ListMigrationSubtasksRequest)(nil), // 7: google.cloud.bigquery.migration.v2alpha.ListMigrationSubtasksRequest 895 (*ListMigrationSubtasksResponse)(nil), // 8: google.cloud.bigquery.migration.v2alpha.ListMigrationSubtasksResponse 896 (*MigrationWorkflow)(nil), // 9: google.cloud.bigquery.migration.v2alpha.MigrationWorkflow 897 (*fieldmaskpb.FieldMask)(nil), // 10: google.protobuf.FieldMask 898 (*MigrationSubtask)(nil), // 11: google.cloud.bigquery.migration.v2alpha.MigrationSubtask 899 (*emptypb.Empty)(nil), // 12: google.protobuf.Empty 900} 901var file_google_cloud_bigquery_migration_v2alpha_migration_service_proto_depIdxs = []int32{ 902 9, // 0: google.cloud.bigquery.migration.v2alpha.CreateMigrationWorkflowRequest.migration_workflow:type_name -> google.cloud.bigquery.migration.v2alpha.MigrationWorkflow 903 10, // 1: google.cloud.bigquery.migration.v2alpha.GetMigrationWorkflowRequest.read_mask:type_name -> google.protobuf.FieldMask 904 10, // 2: google.cloud.bigquery.migration.v2alpha.ListMigrationWorkflowsRequest.read_mask:type_name -> google.protobuf.FieldMask 905 9, // 3: google.cloud.bigquery.migration.v2alpha.ListMigrationWorkflowsResponse.migration_workflows:type_name -> google.cloud.bigquery.migration.v2alpha.MigrationWorkflow 906 10, // 4: google.cloud.bigquery.migration.v2alpha.GetMigrationSubtaskRequest.read_mask:type_name -> google.protobuf.FieldMask 907 10, // 5: google.cloud.bigquery.migration.v2alpha.ListMigrationSubtasksRequest.read_mask:type_name -> google.protobuf.FieldMask 908 11, // 6: google.cloud.bigquery.migration.v2alpha.ListMigrationSubtasksResponse.migration_subtasks:type_name -> google.cloud.bigquery.migration.v2alpha.MigrationSubtask 909 0, // 7: google.cloud.bigquery.migration.v2alpha.MigrationService.CreateMigrationWorkflow:input_type -> google.cloud.bigquery.migration.v2alpha.CreateMigrationWorkflowRequest 910 1, // 8: google.cloud.bigquery.migration.v2alpha.MigrationService.GetMigrationWorkflow:input_type -> google.cloud.bigquery.migration.v2alpha.GetMigrationWorkflowRequest 911 2, // 9: google.cloud.bigquery.migration.v2alpha.MigrationService.ListMigrationWorkflows:input_type -> google.cloud.bigquery.migration.v2alpha.ListMigrationWorkflowsRequest 912 4, // 10: google.cloud.bigquery.migration.v2alpha.MigrationService.DeleteMigrationWorkflow:input_type -> google.cloud.bigquery.migration.v2alpha.DeleteMigrationWorkflowRequest 913 5, // 11: google.cloud.bigquery.migration.v2alpha.MigrationService.StartMigrationWorkflow:input_type -> google.cloud.bigquery.migration.v2alpha.StartMigrationWorkflowRequest 914 6, // 12: google.cloud.bigquery.migration.v2alpha.MigrationService.GetMigrationSubtask:input_type -> google.cloud.bigquery.migration.v2alpha.GetMigrationSubtaskRequest 915 7, // 13: google.cloud.bigquery.migration.v2alpha.MigrationService.ListMigrationSubtasks:input_type -> google.cloud.bigquery.migration.v2alpha.ListMigrationSubtasksRequest 916 9, // 14: google.cloud.bigquery.migration.v2alpha.MigrationService.CreateMigrationWorkflow:output_type -> google.cloud.bigquery.migration.v2alpha.MigrationWorkflow 917 9, // 15: google.cloud.bigquery.migration.v2alpha.MigrationService.GetMigrationWorkflow:output_type -> google.cloud.bigquery.migration.v2alpha.MigrationWorkflow 918 3, // 16: google.cloud.bigquery.migration.v2alpha.MigrationService.ListMigrationWorkflows:output_type -> google.cloud.bigquery.migration.v2alpha.ListMigrationWorkflowsResponse 919 12, // 17: google.cloud.bigquery.migration.v2alpha.MigrationService.DeleteMigrationWorkflow:output_type -> google.protobuf.Empty 920 12, // 18: google.cloud.bigquery.migration.v2alpha.MigrationService.StartMigrationWorkflow:output_type -> google.protobuf.Empty 921 11, // 19: google.cloud.bigquery.migration.v2alpha.MigrationService.GetMigrationSubtask:output_type -> google.cloud.bigquery.migration.v2alpha.MigrationSubtask 922 8, // 20: google.cloud.bigquery.migration.v2alpha.MigrationService.ListMigrationSubtasks:output_type -> google.cloud.bigquery.migration.v2alpha.ListMigrationSubtasksResponse 923 14, // [14:21] is the sub-list for method output_type 924 7, // [7:14] is the sub-list for method input_type 925 7, // [7:7] is the sub-list for extension type_name 926 7, // [7:7] is the sub-list for extension extendee 927 0, // [0:7] is the sub-list for field type_name 928} 929 930func init() { file_google_cloud_bigquery_migration_v2alpha_migration_service_proto_init() } 931func file_google_cloud_bigquery_migration_v2alpha_migration_service_proto_init() { 932 if File_google_cloud_bigquery_migration_v2alpha_migration_service_proto != nil { 933 return 934 } 935 file_google_cloud_bigquery_migration_v2alpha_migration_entities_proto_init() 936 file_google_cloud_bigquery_migration_v2alpha_migration_error_details_proto_init() 937 file_google_cloud_bigquery_migration_v2alpha_migration_metrics_proto_init() 938 if !protoimpl.UnsafeEnabled { 939 file_google_cloud_bigquery_migration_v2alpha_migration_service_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} { 940 switch v := v.(*CreateMigrationWorkflowRequest); i { 941 case 0: 942 return &v.state 943 case 1: 944 return &v.sizeCache 945 case 2: 946 return &v.unknownFields 947 default: 948 return nil 949 } 950 } 951 file_google_cloud_bigquery_migration_v2alpha_migration_service_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} { 952 switch v := v.(*GetMigrationWorkflowRequest); i { 953 case 0: 954 return &v.state 955 case 1: 956 return &v.sizeCache 957 case 2: 958 return &v.unknownFields 959 default: 960 return nil 961 } 962 } 963 file_google_cloud_bigquery_migration_v2alpha_migration_service_proto_msgTypes[2].Exporter = func(v interface{}, i int) interface{} { 964 switch v := v.(*ListMigrationWorkflowsRequest); i { 965 case 0: 966 return &v.state 967 case 1: 968 return &v.sizeCache 969 case 2: 970 return &v.unknownFields 971 default: 972 return nil 973 } 974 } 975 file_google_cloud_bigquery_migration_v2alpha_migration_service_proto_msgTypes[3].Exporter = func(v interface{}, i int) interface{} { 976 switch v := v.(*ListMigrationWorkflowsResponse); i { 977 case 0: 978 return &v.state 979 case 1: 980 return &v.sizeCache 981 case 2: 982 return &v.unknownFields 983 default: 984 return nil 985 } 986 } 987 file_google_cloud_bigquery_migration_v2alpha_migration_service_proto_msgTypes[4].Exporter = func(v interface{}, i int) interface{} { 988 switch v := v.(*DeleteMigrationWorkflowRequest); i { 989 case 0: 990 return &v.state 991 case 1: 992 return &v.sizeCache 993 case 2: 994 return &v.unknownFields 995 default: 996 return nil 997 } 998 } 999 file_google_cloud_bigquery_migration_v2alpha_migration_service_proto_msgTypes[5].Exporter = func(v interface{}, i int) interface{} { 1000 switch v := v.(*StartMigrationWorkflowRequest); i { 1001 case 0: 1002 return &v.state 1003 case 1: 1004 return &v.sizeCache 1005 case 2: 1006 return &v.unknownFields 1007 default: 1008 return nil 1009 } 1010 } 1011 file_google_cloud_bigquery_migration_v2alpha_migration_service_proto_msgTypes[6].Exporter = func(v interface{}, i int) interface{} { 1012 switch v := v.(*GetMigrationSubtaskRequest); i { 1013 case 0: 1014 return &v.state 1015 case 1: 1016 return &v.sizeCache 1017 case 2: 1018 return &v.unknownFields 1019 default: 1020 return nil 1021 } 1022 } 1023 file_google_cloud_bigquery_migration_v2alpha_migration_service_proto_msgTypes[7].Exporter = func(v interface{}, i int) interface{} { 1024 switch v := v.(*ListMigrationSubtasksRequest); i { 1025 case 0: 1026 return &v.state 1027 case 1: 1028 return &v.sizeCache 1029 case 2: 1030 return &v.unknownFields 1031 default: 1032 return nil 1033 } 1034 } 1035 file_google_cloud_bigquery_migration_v2alpha_migration_service_proto_msgTypes[8].Exporter = func(v interface{}, i int) interface{} { 1036 switch v := v.(*ListMigrationSubtasksResponse); i { 1037 case 0: 1038 return &v.state 1039 case 1: 1040 return &v.sizeCache 1041 case 2: 1042 return &v.unknownFields 1043 default: 1044 return nil 1045 } 1046 } 1047 } 1048 type x struct{} 1049 out := protoimpl.TypeBuilder{ 1050 File: protoimpl.DescBuilder{ 1051 GoPackagePath: reflect.TypeOf(x{}).PkgPath(), 1052 RawDescriptor: file_google_cloud_bigquery_migration_v2alpha_migration_service_proto_rawDesc, 1053 NumEnums: 0, 1054 NumMessages: 9, 1055 NumExtensions: 0, 1056 NumServices: 1, 1057 }, 1058 GoTypes: file_google_cloud_bigquery_migration_v2alpha_migration_service_proto_goTypes, 1059 DependencyIndexes: file_google_cloud_bigquery_migration_v2alpha_migration_service_proto_depIdxs, 1060 MessageInfos: file_google_cloud_bigquery_migration_v2alpha_migration_service_proto_msgTypes, 1061 }.Build() 1062 File_google_cloud_bigquery_migration_v2alpha_migration_service_proto = out.File 1063 file_google_cloud_bigquery_migration_v2alpha_migration_service_proto_rawDesc = nil 1064 file_google_cloud_bigquery_migration_v2alpha_migration_service_proto_goTypes = nil 1065 file_google_cloud_bigquery_migration_v2alpha_migration_service_proto_depIdxs = nil 1066} 1067 1068// Reference imports to suppress errors if they are not otherwise used. 1069var _ context.Context 1070var _ grpc.ClientConnInterface 1071 1072// This is a compile-time assertion to ensure that this generated file 1073// is compatible with the grpc package it is being compiled against. 1074const _ = grpc.SupportPackageIsVersion6 1075 1076// MigrationServiceClient is the client API for MigrationService service. 1077// 1078// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream. 1079type MigrationServiceClient interface { 1080 // Creates a migration workflow. 1081 CreateMigrationWorkflow(ctx context.Context, in *CreateMigrationWorkflowRequest, opts ...grpc.CallOption) (*MigrationWorkflow, error) 1082 // Gets a previously created migration workflow. 1083 GetMigrationWorkflow(ctx context.Context, in *GetMigrationWorkflowRequest, opts ...grpc.CallOption) (*MigrationWorkflow, error) 1084 // Lists previously created migration workflow. 1085 ListMigrationWorkflows(ctx context.Context, in *ListMigrationWorkflowsRequest, opts ...grpc.CallOption) (*ListMigrationWorkflowsResponse, error) 1086 // Deletes a migration workflow by name. 1087 DeleteMigrationWorkflow(ctx context.Context, in *DeleteMigrationWorkflowRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) 1088 // Starts a previously created migration workflow. I.e., the state transitions 1089 // from DRAFT to RUNNING. This is a no-op if the state is already RUNNING. 1090 // An error will be signaled if the state is anything other than DRAFT or 1091 // RUNNING. 1092 StartMigrationWorkflow(ctx context.Context, in *StartMigrationWorkflowRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) 1093 // Gets a previously created migration subtask. 1094 GetMigrationSubtask(ctx context.Context, in *GetMigrationSubtaskRequest, opts ...grpc.CallOption) (*MigrationSubtask, error) 1095 // Lists previously created migration subtasks. 1096 ListMigrationSubtasks(ctx context.Context, in *ListMigrationSubtasksRequest, opts ...grpc.CallOption) (*ListMigrationSubtasksResponse, error) 1097} 1098 1099type migrationServiceClient struct { 1100 cc grpc.ClientConnInterface 1101} 1102 1103func NewMigrationServiceClient(cc grpc.ClientConnInterface) MigrationServiceClient { 1104 return &migrationServiceClient{cc} 1105} 1106 1107func (c *migrationServiceClient) CreateMigrationWorkflow(ctx context.Context, in *CreateMigrationWorkflowRequest, opts ...grpc.CallOption) (*MigrationWorkflow, error) { 1108 out := new(MigrationWorkflow) 1109 err := c.cc.Invoke(ctx, "/google.cloud.bigquery.migration.v2alpha.MigrationService/CreateMigrationWorkflow", in, out, opts...) 1110 if err != nil { 1111 return nil, err 1112 } 1113 return out, nil 1114} 1115 1116func (c *migrationServiceClient) GetMigrationWorkflow(ctx context.Context, in *GetMigrationWorkflowRequest, opts ...grpc.CallOption) (*MigrationWorkflow, error) { 1117 out := new(MigrationWorkflow) 1118 err := c.cc.Invoke(ctx, "/google.cloud.bigquery.migration.v2alpha.MigrationService/GetMigrationWorkflow", in, out, opts...) 1119 if err != nil { 1120 return nil, err 1121 } 1122 return out, nil 1123} 1124 1125func (c *migrationServiceClient) ListMigrationWorkflows(ctx context.Context, in *ListMigrationWorkflowsRequest, opts ...grpc.CallOption) (*ListMigrationWorkflowsResponse, error) { 1126 out := new(ListMigrationWorkflowsResponse) 1127 err := c.cc.Invoke(ctx, "/google.cloud.bigquery.migration.v2alpha.MigrationService/ListMigrationWorkflows", in, out, opts...) 1128 if err != nil { 1129 return nil, err 1130 } 1131 return out, nil 1132} 1133 1134func (c *migrationServiceClient) DeleteMigrationWorkflow(ctx context.Context, in *DeleteMigrationWorkflowRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) { 1135 out := new(emptypb.Empty) 1136 err := c.cc.Invoke(ctx, "/google.cloud.bigquery.migration.v2alpha.MigrationService/DeleteMigrationWorkflow", in, out, opts...) 1137 if err != nil { 1138 return nil, err 1139 } 1140 return out, nil 1141} 1142 1143func (c *migrationServiceClient) StartMigrationWorkflow(ctx context.Context, in *StartMigrationWorkflowRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) { 1144 out := new(emptypb.Empty) 1145 err := c.cc.Invoke(ctx, "/google.cloud.bigquery.migration.v2alpha.MigrationService/StartMigrationWorkflow", in, out, opts...) 1146 if err != nil { 1147 return nil, err 1148 } 1149 return out, nil 1150} 1151 1152func (c *migrationServiceClient) GetMigrationSubtask(ctx context.Context, in *GetMigrationSubtaskRequest, opts ...grpc.CallOption) (*MigrationSubtask, error) { 1153 out := new(MigrationSubtask) 1154 err := c.cc.Invoke(ctx, "/google.cloud.bigquery.migration.v2alpha.MigrationService/GetMigrationSubtask", in, out, opts...) 1155 if err != nil { 1156 return nil, err 1157 } 1158 return out, nil 1159} 1160 1161func (c *migrationServiceClient) ListMigrationSubtasks(ctx context.Context, in *ListMigrationSubtasksRequest, opts ...grpc.CallOption) (*ListMigrationSubtasksResponse, error) { 1162 out := new(ListMigrationSubtasksResponse) 1163 err := c.cc.Invoke(ctx, "/google.cloud.bigquery.migration.v2alpha.MigrationService/ListMigrationSubtasks", in, out, opts...) 1164 if err != nil { 1165 return nil, err 1166 } 1167 return out, nil 1168} 1169 1170// MigrationServiceServer is the server API for MigrationService service. 1171type MigrationServiceServer interface { 1172 // Creates a migration workflow. 1173 CreateMigrationWorkflow(context.Context, *CreateMigrationWorkflowRequest) (*MigrationWorkflow, error) 1174 // Gets a previously created migration workflow. 1175 GetMigrationWorkflow(context.Context, *GetMigrationWorkflowRequest) (*MigrationWorkflow, error) 1176 // Lists previously created migration workflow. 1177 ListMigrationWorkflows(context.Context, *ListMigrationWorkflowsRequest) (*ListMigrationWorkflowsResponse, error) 1178 // Deletes a migration workflow by name. 1179 DeleteMigrationWorkflow(context.Context, *DeleteMigrationWorkflowRequest) (*emptypb.Empty, error) 1180 // Starts a previously created migration workflow. I.e., the state transitions 1181 // from DRAFT to RUNNING. This is a no-op if the state is already RUNNING. 1182 // An error will be signaled if the state is anything other than DRAFT or 1183 // RUNNING. 1184 StartMigrationWorkflow(context.Context, *StartMigrationWorkflowRequest) (*emptypb.Empty, error) 1185 // Gets a previously created migration subtask. 1186 GetMigrationSubtask(context.Context, *GetMigrationSubtaskRequest) (*MigrationSubtask, error) 1187 // Lists previously created migration subtasks. 1188 ListMigrationSubtasks(context.Context, *ListMigrationSubtasksRequest) (*ListMigrationSubtasksResponse, error) 1189} 1190 1191// UnimplementedMigrationServiceServer can be embedded to have forward compatible implementations. 1192type UnimplementedMigrationServiceServer struct { 1193} 1194 1195func (*UnimplementedMigrationServiceServer) CreateMigrationWorkflow(context.Context, *CreateMigrationWorkflowRequest) (*MigrationWorkflow, error) { 1196 return nil, status.Errorf(codes.Unimplemented, "method CreateMigrationWorkflow not implemented") 1197} 1198func (*UnimplementedMigrationServiceServer) GetMigrationWorkflow(context.Context, *GetMigrationWorkflowRequest) (*MigrationWorkflow, error) { 1199 return nil, status.Errorf(codes.Unimplemented, "method GetMigrationWorkflow not implemented") 1200} 1201func (*UnimplementedMigrationServiceServer) ListMigrationWorkflows(context.Context, *ListMigrationWorkflowsRequest) (*ListMigrationWorkflowsResponse, error) { 1202 return nil, status.Errorf(codes.Unimplemented, "method ListMigrationWorkflows not implemented") 1203} 1204func (*UnimplementedMigrationServiceServer) DeleteMigrationWorkflow(context.Context, *DeleteMigrationWorkflowRequest) (*emptypb.Empty, error) { 1205 return nil, status.Errorf(codes.Unimplemented, "method DeleteMigrationWorkflow not implemented") 1206} 1207func (*UnimplementedMigrationServiceServer) StartMigrationWorkflow(context.Context, *StartMigrationWorkflowRequest) (*emptypb.Empty, error) { 1208 return nil, status.Errorf(codes.Unimplemented, "method StartMigrationWorkflow not implemented") 1209} 1210func (*UnimplementedMigrationServiceServer) GetMigrationSubtask(context.Context, *GetMigrationSubtaskRequest) (*MigrationSubtask, error) { 1211 return nil, status.Errorf(codes.Unimplemented, "method GetMigrationSubtask not implemented") 1212} 1213func (*UnimplementedMigrationServiceServer) ListMigrationSubtasks(context.Context, *ListMigrationSubtasksRequest) (*ListMigrationSubtasksResponse, error) { 1214 return nil, status.Errorf(codes.Unimplemented, "method ListMigrationSubtasks not implemented") 1215} 1216 1217func RegisterMigrationServiceServer(s *grpc.Server, srv MigrationServiceServer) { 1218 s.RegisterService(&_MigrationService_serviceDesc, srv) 1219} 1220 1221func _MigrationService_CreateMigrationWorkflow_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 1222 in := new(CreateMigrationWorkflowRequest) 1223 if err := dec(in); err != nil { 1224 return nil, err 1225 } 1226 if interceptor == nil { 1227 return srv.(MigrationServiceServer).CreateMigrationWorkflow(ctx, in) 1228 } 1229 info := &grpc.UnaryServerInfo{ 1230 Server: srv, 1231 FullMethod: "/google.cloud.bigquery.migration.v2alpha.MigrationService/CreateMigrationWorkflow", 1232 } 1233 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 1234 return srv.(MigrationServiceServer).CreateMigrationWorkflow(ctx, req.(*CreateMigrationWorkflowRequest)) 1235 } 1236 return interceptor(ctx, in, info, handler) 1237} 1238 1239func _MigrationService_GetMigrationWorkflow_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 1240 in := new(GetMigrationWorkflowRequest) 1241 if err := dec(in); err != nil { 1242 return nil, err 1243 } 1244 if interceptor == nil { 1245 return srv.(MigrationServiceServer).GetMigrationWorkflow(ctx, in) 1246 } 1247 info := &grpc.UnaryServerInfo{ 1248 Server: srv, 1249 FullMethod: "/google.cloud.bigquery.migration.v2alpha.MigrationService/GetMigrationWorkflow", 1250 } 1251 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 1252 return srv.(MigrationServiceServer).GetMigrationWorkflow(ctx, req.(*GetMigrationWorkflowRequest)) 1253 } 1254 return interceptor(ctx, in, info, handler) 1255} 1256 1257func _MigrationService_ListMigrationWorkflows_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 1258 in := new(ListMigrationWorkflowsRequest) 1259 if err := dec(in); err != nil { 1260 return nil, err 1261 } 1262 if interceptor == nil { 1263 return srv.(MigrationServiceServer).ListMigrationWorkflows(ctx, in) 1264 } 1265 info := &grpc.UnaryServerInfo{ 1266 Server: srv, 1267 FullMethod: "/google.cloud.bigquery.migration.v2alpha.MigrationService/ListMigrationWorkflows", 1268 } 1269 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 1270 return srv.(MigrationServiceServer).ListMigrationWorkflows(ctx, req.(*ListMigrationWorkflowsRequest)) 1271 } 1272 return interceptor(ctx, in, info, handler) 1273} 1274 1275func _MigrationService_DeleteMigrationWorkflow_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 1276 in := new(DeleteMigrationWorkflowRequest) 1277 if err := dec(in); err != nil { 1278 return nil, err 1279 } 1280 if interceptor == nil { 1281 return srv.(MigrationServiceServer).DeleteMigrationWorkflow(ctx, in) 1282 } 1283 info := &grpc.UnaryServerInfo{ 1284 Server: srv, 1285 FullMethod: "/google.cloud.bigquery.migration.v2alpha.MigrationService/DeleteMigrationWorkflow", 1286 } 1287 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 1288 return srv.(MigrationServiceServer).DeleteMigrationWorkflow(ctx, req.(*DeleteMigrationWorkflowRequest)) 1289 } 1290 return interceptor(ctx, in, info, handler) 1291} 1292 1293func _MigrationService_StartMigrationWorkflow_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 1294 in := new(StartMigrationWorkflowRequest) 1295 if err := dec(in); err != nil { 1296 return nil, err 1297 } 1298 if interceptor == nil { 1299 return srv.(MigrationServiceServer).StartMigrationWorkflow(ctx, in) 1300 } 1301 info := &grpc.UnaryServerInfo{ 1302 Server: srv, 1303 FullMethod: "/google.cloud.bigquery.migration.v2alpha.MigrationService/StartMigrationWorkflow", 1304 } 1305 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 1306 return srv.(MigrationServiceServer).StartMigrationWorkflow(ctx, req.(*StartMigrationWorkflowRequest)) 1307 } 1308 return interceptor(ctx, in, info, handler) 1309} 1310 1311func _MigrationService_GetMigrationSubtask_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 1312 in := new(GetMigrationSubtaskRequest) 1313 if err := dec(in); err != nil { 1314 return nil, err 1315 } 1316 if interceptor == nil { 1317 return srv.(MigrationServiceServer).GetMigrationSubtask(ctx, in) 1318 } 1319 info := &grpc.UnaryServerInfo{ 1320 Server: srv, 1321 FullMethod: "/google.cloud.bigquery.migration.v2alpha.MigrationService/GetMigrationSubtask", 1322 } 1323 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 1324 return srv.(MigrationServiceServer).GetMigrationSubtask(ctx, req.(*GetMigrationSubtaskRequest)) 1325 } 1326 return interceptor(ctx, in, info, handler) 1327} 1328 1329func _MigrationService_ListMigrationSubtasks_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 1330 in := new(ListMigrationSubtasksRequest) 1331 if err := dec(in); err != nil { 1332 return nil, err 1333 } 1334 if interceptor == nil { 1335 return srv.(MigrationServiceServer).ListMigrationSubtasks(ctx, in) 1336 } 1337 info := &grpc.UnaryServerInfo{ 1338 Server: srv, 1339 FullMethod: "/google.cloud.bigquery.migration.v2alpha.MigrationService/ListMigrationSubtasks", 1340 } 1341 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 1342 return srv.(MigrationServiceServer).ListMigrationSubtasks(ctx, req.(*ListMigrationSubtasksRequest)) 1343 } 1344 return interceptor(ctx, in, info, handler) 1345} 1346 1347var _MigrationService_serviceDesc = grpc.ServiceDesc{ 1348 ServiceName: "google.cloud.bigquery.migration.v2alpha.MigrationService", 1349 HandlerType: (*MigrationServiceServer)(nil), 1350 Methods: []grpc.MethodDesc{ 1351 { 1352 MethodName: "CreateMigrationWorkflow", 1353 Handler: _MigrationService_CreateMigrationWorkflow_Handler, 1354 }, 1355 { 1356 MethodName: "GetMigrationWorkflow", 1357 Handler: _MigrationService_GetMigrationWorkflow_Handler, 1358 }, 1359 { 1360 MethodName: "ListMigrationWorkflows", 1361 Handler: _MigrationService_ListMigrationWorkflows_Handler, 1362 }, 1363 { 1364 MethodName: "DeleteMigrationWorkflow", 1365 Handler: _MigrationService_DeleteMigrationWorkflow_Handler, 1366 }, 1367 { 1368 MethodName: "StartMigrationWorkflow", 1369 Handler: _MigrationService_StartMigrationWorkflow_Handler, 1370 }, 1371 { 1372 MethodName: "GetMigrationSubtask", 1373 Handler: _MigrationService_GetMigrationSubtask_Handler, 1374 }, 1375 { 1376 MethodName: "ListMigrationSubtasks", 1377 Handler: _MigrationService_ListMigrationSubtasks_Handler, 1378 }, 1379 }, 1380 Streams: []grpc.StreamDesc{}, 1381 Metadata: "google/cloud/bigquery/migration/v2alpha/migration_service.proto", 1382} 1383