...

Source file src/cloud.google.com/go/bigquery/migration/apiv2alpha/migrationpb/migration_service.pb.go

Documentation: cloud.google.com/go/bigquery/migration/apiv2alpha/migrationpb

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

View as plain text