Package cloud.google.com/go/bigquery/migration/apiv2alpha/migrationpb (v1.65.0)

var (
	MigrationWorkflow_State_name = map[int32]string{
		0: "STATE_UNSPECIFIED",
		1: "DRAFT",
		2: "RUNNING",
		3: "PAUSED",
		4: "COMPLETED",
	}
	MigrationWorkflow_State_value = map[string]int32{
		"STATE_UNSPECIFIED": 0,
		"DRAFT":             1,
		"RUNNING":           2,
		"PAUSED":            3,
		"COMPLETED":         4,
	}
)

var (
	MigrationTask_State_name = map[int32]string{
		0: "STATE_UNSPECIFIED",
		1: "PENDING",
		2: "ORCHESTRATING",
		3: "RUNNING",
		4: "PAUSED",
		5: "SUCCEEDED",
		6: "FAILED",
	}
	MigrationTask_State_value = map[string]int32{
		"STATE_UNSPECIFIED": 0,
		"PENDING":           1,
		"ORCHESTRATING":     2,
		"RUNNING":           3,
		"PAUSED":            4,
		"SUCCEEDED":         5,
		"FAILED":            6,
	}
)

var (
	MigrationSubtask_State_name = map[int32]string{
		0: "STATE_UNSPECIFIED",
		1: "ACTIVE",
		2: "RUNNING",
		3: "SUCCEEDED",
		4: "FAILED",
		5: "PAUSED",
	}
	MigrationSubtask_State_value = map[string]int32{
		"STATE_UNSPECIFIED": 0,
		"ACTIVE":            1,
		"RUNNING":           2,
		"SUCCEEDED":         3,
		"FAILED":            4,
		"PAUSED":            5,
	}
)

var (
	TranslateQueryRequest_SqlTranslationSourceDialect_name = map[int32]string{
		0: "SQL_TRANSLATION_SOURCE_DIALECT_UNSPECIFIED",
		1: "TERADATA",
	}
	TranslateQueryRequest_SqlTranslationSourceDialect_value = map[string]int32{
		"SQL_TRANSLATION_SOURCE_DIALECT_UNSPECIFIED": 0,
		"TERADATA": 1,
	}
)

var (
	SqlTranslationError_SqlTranslationErrorType_name = map[int32]string{
		0: "SQL_TRANSLATION_ERROR_TYPE_UNSPECIFIED",
		1: "SQL_PARSE_ERROR",
		2: "UNSUPPORTED_SQL_FUNCTION",
	}
	SqlTranslationError_SqlTranslationErrorType_value = map[string]int32{
		"SQL_TRANSLATION_ERROR_TYPE_UNSPECIFIED": 0,
		"SQL_PARSE_ERROR":                        1,
		"UNSUPPORTED_SQL_FUNCTION":               2,
	}
)

var (
	TranslationTaskDetails_FileEncoding_name = map[int32]string{
		0: "FILE_ENCODING_UNSPECIFIED",
		1: "UTF_8",
		2: "ISO_8859_1",
		3: "US_ASCII",
		4: "UTF_16",
		5: "UTF_16LE",
		6: "UTF_16BE",
	}
	TranslationTaskDetails_FileEncoding_value = map[string]int32{
		"FILE_ENCODING_UNSPECIFIED": 0,
		"UTF_8":                     1,
		"ISO_8859_1":                2,
		"US_ASCII":                  3,
		"UTF_16":                    4,
		"UTF_16LE":                  5,
		"UTF_16BE":                  6,
	}
)

var (
	TranslationTaskDetails_TokenType_name = map[int32]string{
		0: "TOKEN_TYPE_UNSPECIFIED",
		1: "STRING",
		2: "INT64",
		3: "NUMERIC",
		4: "BOOL",
		5: "FLOAT64",
		6: "DATE",
		7: "TIMESTAMP",
	}
	TranslationTaskDetails_TokenType_value = map[string]int32{
		"TOKEN_TYPE_UNSPECIFIED": 0,
		"STRING":                 1,
		"INT64":                  2,
		"NUMERIC":                3,
		"BOOL":                   4,
		"FLOAT64":                5,
		"DATE":                   6,
		"TIMESTAMP":              7,
	}
)

var (
	IdentifierSettings_IdentifierCase_name = map[int32]string{
		0: "IDENTIFIER_CASE_UNSPECIFIED",
		1: "ORIGINAL",
		2: "UPPER",
		3: "LOWER",
	}
	IdentifierSettings_IdentifierCase_value = map[string]int32{
		"IDENTIFIER_CASE_UNSPECIFIED": 0,
		"ORIGINAL":                    1,
		"UPPER":                       2,
		"LOWER":                       3,
	}
)

var (
	IdentifierSettings_IdentifierRewriteMode_name = map[int32]string{
		0: "IDENTIFIER_REWRITE_MODE_UNSPECIFIED",
		1: "NONE",
		2: "REWRITE_ALL",
	}
	IdentifierSettings_IdentifierRewriteMode_value = map[string]int32{
		"IDENTIFIER_REWRITE_MODE_UNSPECIFIED": 0,
		"NONE":                                1,
		"REWRITE_ALL":                         2,
	}
)

var File_google_cloud_bigquery_migration_v2alpha_assessment_task_proto protoreflect.FileDescriptor

var File_google_cloud_bigquery_migration_v2alpha_migration_entities_proto protoreflect.FileDescriptor

var File_google_cloud_bigquery_migration_v2alpha_migration_error_details_proto protoreflect.FileDescriptor

var File_google_cloud_bigquery_migration_v2alpha_migration_metrics_proto protoreflect.FileDescriptor

var File_google_cloud_bigquery_migration_v2alpha_migration_service_proto protoreflect.FileDescriptor

var File_google_cloud_bigquery_migration_v2alpha_translation_service_proto protoreflect.FileDescriptor

var File_google_cloud_bigquery_migration_v2alpha_translation_task_proto protoreflect.FileDescriptor

func RegisterMigrationServiceServer(s *grpc.Server, srv MigrationServiceServer)

func RegisterSqlTranslationServiceServer(s *grpc.Server, srv SqlTranslationServiceServer)

type AssessmentOrchestrationResultDetails struct {
	OutputTablesSchemaVersion string "" /* 140 byte string literal not displayed */

}

func (*AssessmentOrchestrationResultDetails) Descriptor() ([]byte, []int)

func (x *AssessmentOrchestrationResultDetails) GetOutputTablesSchemaVersion() string

func (*AssessmentOrchestrationResultDetails) ProtoMessage()

func (x *AssessmentOrchestrationResultDetails) ProtoReflect() protoreflect.Message

func (x *AssessmentOrchestrationResultDetails) Reset()

func (x *AssessmentOrchestrationResultDetails) String() string

type AssessmentTaskDetails struct {

	// Required. The Cloud Storage path for assessment input files.
	InputPath string `protobuf:"bytes,1,opt,name=input_path,json=inputPath,proto3" json:"input_path,omitempty"`
	// Required. The BigQuery dataset for output.
	OutputDataset string `protobuf:"bytes,2,opt,name=output_dataset,json=outputDataset,proto3" json:"output_dataset,omitempty"`
	// Optional. An optional Cloud Storage path to write the query logs (which is
	// then used as an input path on the translation task)
	QuerylogsPath string `protobuf:"bytes,3,opt,name=querylogs_path,json=querylogsPath,proto3" json:"querylogs_path,omitempty"`
	// Required. The data source or data warehouse type (eg: TERADATA/REDSHIFT)
	// from which the input data is extracted.
	DataSource string `protobuf:"bytes,4,opt,name=data_source,json=dataSource,proto3" json:"data_source,omitempty"`
	// contains filtered or unexported fields
}

func (*AssessmentTaskDetails) Descriptor() ([]byte, []int)

func (x *AssessmentTaskDetails) GetDataSource() string

func (x *AssessmentTaskDetails) GetInputPath() string

func (x *AssessmentTaskDetails) GetOutputDataset() string

func (x *AssessmentTaskDetails) GetQuerylogsPath() string

func (*AssessmentTaskDetails) ProtoMessage()

func (x *AssessmentTaskDetails) ProtoReflect() protoreflect.Message

func (x *AssessmentTaskDetails) Reset()

func (x *AssessmentTaskDetails) String() string

type BteqOptions struct {
	ProjectDataset *DatasetReference `protobuf:"bytes,1,opt,name=project_dataset,json=projectDataset,proto3" json:"project_dataset,omitempty"`

	DefaultPathUri string `protobuf:"bytes,2,opt,name=default_path_uri,json=defaultPathUri,proto3" json:"default_path_uri,omitempty"`

	FileReplacementMap map[string]string "" /* 205 byte string literal not displayed */

}

func (*BteqOptions) Descriptor() ([]byte, []int)

func (x *BteqOptions) GetDefaultPathUri() string

func (x *BteqOptions) GetFileReplacementMap() map[string]string

func (x *BteqOptions) GetProjectDataset() *DatasetReference

func (*BteqOptions) ProtoMessage()

func (x *BteqOptions) ProtoReflect() protoreflect.Message

func (x *BteqOptions) Reset()

func (x *BteqOptions) String() string

type CreateMigrationWorkflowRequest struct {

	// Required. The name of the project to which this migration workflow belongs.
	// Example: `projects/foo/locations/bar`
	Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
	// Required. The migration workflow to create.
	MigrationWorkflow *MigrationWorkflow `protobuf:"bytes,2,opt,name=migration_workflow,json=migrationWorkflow,proto3" json:"migration_workflow,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateMigrationWorkflowRequest) Descriptor() ([]byte, []int)

func (x *CreateMigrationWorkflowRequest) GetMigrationWorkflow() *MigrationWorkflow

func (x *CreateMigrationWorkflowRequest) GetParent() string

func (*CreateMigrationWorkflowRequest) ProtoMessage()

func (x *CreateMigrationWorkflowRequest) ProtoReflect() protoreflect.Message

func (x *CreateMigrationWorkflowRequest) Reset()

func (x *CreateMigrationWorkflowRequest) String() string

type DatasetReference struct {

	// A unique ID for this dataset, without the project name. The ID
	// must contain only letters (a-z, A-Z), numbers (0-9), or underscores (_).
	// The maximum length is 1,024 characters.
	DatasetId string `protobuf:"bytes,1,opt,name=dataset_id,json=datasetId,proto3" json:"dataset_id,omitempty"`
	// The ID of the project containing this dataset.
	ProjectId string `protobuf:"bytes,2,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	// contains filtered or unexported fields
}

func (*DatasetReference) Descriptor() ([]byte, []int)

func (x *DatasetReference) GetDatasetId() string

func (x *DatasetReference) GetProjectId() string

func (*DatasetReference) ProtoMessage()

func (x *DatasetReference) ProtoReflect() protoreflect.Message

func (x *DatasetReference) Reset()

func (x *DatasetReference) String() string

type DeleteMigrationWorkflowRequest struct {

	// Required. The unique identifier for the migration workflow.
	// Example: `projects/123/locations/us/workflows/1234`
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteMigrationWorkflowRequest) Descriptor() ([]byte, []int)

func (x *DeleteMigrationWorkflowRequest) GetName() string

func (*DeleteMigrationWorkflowRequest) ProtoMessage()

func (x *DeleteMigrationWorkflowRequest) ProtoReflect() protoreflect.Message

func (x *DeleteMigrationWorkflowRequest) Reset()

func (x *DeleteMigrationWorkflowRequest) String() string

type ErrorDetail struct {

	// Optional. The exact location within the resource (if applicable).
	Location *ErrorLocation `protobuf:"bytes,1,opt,name=location,proto3" json:"location,omitempty"`
	// Required. Describes the cause of the error with structured detail.
	ErrorInfo *errdetails.ErrorInfo `protobuf:"bytes,2,opt,name=error_info,json=errorInfo,proto3" json:"error_info,omitempty"`
	// contains filtered or unexported fields
}

func (*ErrorDetail) Descriptor() ([]byte, []int)

func (x *ErrorDetail) GetErrorInfo() *errdetails.ErrorInfo

func (x *ErrorDetail) GetLocation() *ErrorLocation

func (*ErrorDetail) ProtoMessage()

func (x *ErrorDetail) ProtoReflect() protoreflect.Message

func (x *ErrorDetail) Reset()

func (x *ErrorDetail) String() string

type ErrorLocation struct {

	// Optional. If applicable, denotes the line where the error occurred. A zero value
	// means that there is no line information.
	Line int32 `protobuf:"varint,1,opt,name=line,proto3" json:"line,omitempty"`
	// Optional. If applicable, denotes the column where the error occurred. A zero value
	// means that there is no columns information.
	Column int32 `protobuf:"varint,2,opt,name=column,proto3" json:"column,omitempty"`
	// contains filtered or unexported fields
}

func (*ErrorLocation) Descriptor() ([]byte, []int)

func (x *ErrorLocation) GetColumn() int32

func (x *ErrorLocation) GetLine() int32

func (*ErrorLocation) ProtoMessage()

func (x *ErrorLocation) ProtoReflect() protoreflect.Message

func (x *ErrorLocation) Reset()

func (x *ErrorLocation) String() string

type Filter struct {
	InputFileExclusionPrefixes []string "" /* 143 byte string literal not displayed */

}

func (*Filter) Descriptor() ([]byte, []int)

func (x *Filter) GetInputFileExclusionPrefixes() []string

func (*Filter) ProtoMessage()

func (x *Filter) ProtoReflect() protoreflect.Message

func (x *Filter) Reset()

func (x *Filter) String() string

type GetMigrationSubtaskRequest struct {

	// Required. The unique identifier for the migration subtask.
	// Example: `projects/123/locations/us/workflows/1234/subtasks/543`
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Optional. The list of fields to be retrieved.
	ReadMask *fieldmaskpb.FieldMask `protobuf:"bytes,2,opt,name=read_mask,json=readMask,proto3" json:"read_mask,omitempty"`
	// contains filtered or unexported fields
}

func (*GetMigrationSubtaskRequest) Descriptor() ([]byte, []int)

func (x *GetMigrationSubtaskRequest) GetName() string

func (x *GetMigrationSubtaskRequest) GetReadMask() *fieldmaskpb.FieldMask

func (*GetMigrationSubtaskRequest) ProtoMessage()

func (x *GetMigrationSubtaskRequest) ProtoReflect() protoreflect.Message

func (x *GetMigrationSubtaskRequest) Reset()

func (x *GetMigrationSubtaskRequest) String() string

type GetMigrationWorkflowRequest struct {

	// Required. The unique identifier for the migration workflow.
	// Example: `projects/123/locations/us/workflows/1234`
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// The list of fields to be retrieved.
	ReadMask *fieldmaskpb.FieldMask `protobuf:"bytes,2,opt,name=read_mask,json=readMask,proto3" json:"read_mask,omitempty"`
	// contains filtered or unexported fields
}

func (*GetMigrationWorkflowRequest) Descriptor() ([]byte, []int)

func (x *GetMigrationWorkflowRequest) GetName() string

func (x *GetMigrationWorkflowRequest) GetReadMask() *fieldmaskpb.FieldMask

func (*GetMigrationWorkflowRequest) ProtoMessage()

func (x *GetMigrationWorkflowRequest) ProtoReflect() protoreflect.Message

func (x *GetMigrationWorkflowRequest) Reset()

func (x *GetMigrationWorkflowRequest) String() string

type IdentifierSettings struct {
	OutputIdentifierCase IdentifierSettings_IdentifierCase "" /* 203 byte string literal not displayed */

	IdentifierRewriteMode IdentifierSettings_IdentifierRewriteMode "" /* 213 byte string literal not displayed */

}

func (*IdentifierSettings) Descriptor() ([]byte, []int)

func (x *IdentifierSettings) GetIdentifierRewriteMode() IdentifierSettings_IdentifierRewriteMode

func (x *IdentifierSettings) GetOutputIdentifierCase() IdentifierSettings_IdentifierCase

func (*IdentifierSettings) ProtoMessage()

func (x *IdentifierSettings) ProtoReflect() protoreflect.Message

func (x *IdentifierSettings) Reset()

func (x *IdentifierSettings) String() string

type IdentifierSettings_IdentifierCase int32

const (
	// The identifier case is not specified.
	IdentifierSettings_IDENTIFIER_CASE_UNSPECIFIED IdentifierSettings_IdentifierCase = 0
	// Identifiers' cases will be kept as the original cases.
	IdentifierSettings_ORIGINAL IdentifierSettings_IdentifierCase = 1
	// Identifiers will be in upper cases.
	IdentifierSettings_UPPER IdentifierSettings_IdentifierCase = 2
	// Identifiers will be in lower cases.
	IdentifierSettings_LOWER IdentifierSettings_IdentifierCase = 3
)

func (IdentifierSettings_IdentifierCase) Descriptor() protoreflect.EnumDescriptor

func (x IdentifierSettings_IdentifierCase) Enum() *IdentifierSettings_IdentifierCase

func (IdentifierSettings_IdentifierCase) EnumDescriptor() ([]byte, []int)

func (x IdentifierSettings_IdentifierCase) Number() protoreflect.EnumNumber

func (x IdentifierSettings_IdentifierCase) String() string

func (IdentifierSettings_IdentifierCase) Type() protoreflect.EnumType

type IdentifierSettings_IdentifierRewriteMode int32

const (
	// SQL Identifier rewrite mode is unspecified.
	IdentifierSettings_IDENTIFIER_REWRITE_MODE_UNSPECIFIED IdentifierSettings_IdentifierRewriteMode = 0
	// SQL identifiers won't be rewrite.
	IdentifierSettings_NONE IdentifierSettings_IdentifierRewriteMode = 1
	// All SQL identifiers will be rewrite.
	IdentifierSettings_REWRITE_ALL IdentifierSettings_IdentifierRewriteMode = 2
)

func (IdentifierSettings_IdentifierRewriteMode) Descriptor() protoreflect.EnumDescriptor

func (x IdentifierSettings_IdentifierRewriteMode) Enum() *IdentifierSettings_IdentifierRewriteMode

func (IdentifierSettings_IdentifierRewriteMode) EnumDescriptor() ([]byte, []int)

func (x IdentifierSettings_IdentifierRewriteMode) Number() protoreflect.EnumNumber

func (x IdentifierSettings_IdentifierRewriteMode) String() string

func (IdentifierSettings_IdentifierRewriteMode) Type() protoreflect.EnumType

type ListMigrationSubtasksRequest struct {

	// Required. The migration task of the subtasks to list.
	// Example: `projects/123/locations/us/workflows/1234`
	Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
	// Optional. The list of fields to be retrieved.
	ReadMask *fieldmaskpb.FieldMask `protobuf:"bytes,2,opt,name=read_mask,json=readMask,proto3" json:"read_mask,omitempty"`
	// Optional. The maximum number of migration tasks to return. The service may return
	// fewer than this number.
	PageSize int32 `protobuf:"varint,3,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// Optional. A page token, received from previous `ListMigrationSubtasks` call.
	// Provide this to retrieve the subsequent page.
	//
	// When paginating, all other parameters provided to `ListMigrationSubtasks`
	// must match the call that provided the page token.
	PageToken string `protobuf:"bytes,4,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	// Optional. The filter to apply. This can be used to get the subtasks of a specific
	// tasks in a workflow, e.g. `migration_task = "ab012"` where `"ab012"` is the
	// task ID (not the name in the named map).
	Filter string `protobuf:"bytes,5,opt,name=filter,proto3" json:"filter,omitempty"`
	// contains filtered or unexported fields
}

func (*ListMigrationSubtasksRequest) Descriptor() ([]byte, []int)

func (x *ListMigrationSubtasksRequest) GetFilter() string

func (x *ListMigrationSubtasksRequest) GetPageSize() int32

func (x *ListMigrationSubtasksRequest) GetPageToken() string

func (x *ListMigrationSubtasksRequest) GetParent() string

func (x *ListMigrationSubtasksRequest) GetReadMask() *fieldmaskpb.FieldMask

func (*ListMigrationSubtasksRequest) ProtoMessage()

func (x *ListMigrationSubtasksRequest) ProtoReflect() protoreflect.Message

func (x *ListMigrationSubtasksRequest) Reset()

func (x *ListMigrationSubtasksRequest) String() string

type ListMigrationSubtasksResponse struct {

	// The migration subtasks for the specified task.
	MigrationSubtasks []*MigrationSubtask `protobuf:"bytes,1,rep,name=migration_subtasks,json=migrationSubtasks,proto3" json:"migration_subtasks,omitempty"`
	// A token, which can be sent as `page_token` to retrieve the next page.
	// If this field is omitted, there are no subsequent pages.
	NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// contains filtered or unexported fields
}

func (*ListMigrationSubtasksResponse) Descriptor() ([]byte, []int)

func (x *ListMigrationSubtasksResponse) GetMigrationSubtasks() []*MigrationSubtask

func (x *ListMigrationSubtasksResponse) GetNextPageToken() string

func (*ListMigrationSubtasksResponse) ProtoMessage()

func (x *ListMigrationSubtasksResponse) ProtoReflect() protoreflect.Message

func (x *ListMigrationSubtasksResponse) Reset()

func (x *ListMigrationSubtasksResponse) String() string

type ListMigrationWorkflowsRequest struct {

	// Required. The project and location of the migration workflows to list.
	// Example: `projects/123/locations/us`
	Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
	// The list of fields to be retrieved.
	ReadMask *fieldmaskpb.FieldMask `protobuf:"bytes,2,opt,name=read_mask,json=readMask,proto3" json:"read_mask,omitempty"`
	// The maximum number of migration workflows to return. The service may return
	// fewer than this number.
	PageSize int32 `protobuf:"varint,3,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// A page token, received from previous `ListMigrationWorkflows` call.
	// Provide this to retrieve the subsequent page.
	//
	// When paginating, all other parameters provided to `ListMigrationWorkflows`
	// must match the call that provided the page token.
	PageToken string `protobuf:"bytes,4,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	// contains filtered or unexported fields
}

func (*ListMigrationWorkflowsRequest) Descriptor() ([]byte, []int)

func (x *ListMigrationWorkflowsRequest) GetPageSize() int32

func (x *ListMigrationWorkflowsRequest) GetPageToken() string

func (x *ListMigrationWorkflowsRequest) GetParent() string

func (x *ListMigrationWorkflowsRequest) GetReadMask() *fieldmaskpb.FieldMask

func (*ListMigrationWorkflowsRequest) ProtoMessage()

func (x *ListMigrationWorkflowsRequest) ProtoReflect() protoreflect.Message

func (x *ListMigrationWorkflowsRequest) Reset()

func (x *ListMigrationWorkflowsRequest) String() string

type ListMigrationWorkflowsResponse struct {

	// The migration workflows for the specified project / location.
	MigrationWorkflows []*MigrationWorkflow `protobuf:"bytes,1,rep,name=migration_workflows,json=migrationWorkflows,proto3" json:"migration_workflows,omitempty"`
	// A token, which can be sent as `page_token` to retrieve the next page.
	// If this field is omitted, there are no subsequent pages.
	NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// contains filtered or unexported fields
}

func (*ListMigrationWorkflowsResponse) Descriptor() ([]byte, []int)

func (x *ListMigrationWorkflowsResponse) GetMigrationWorkflows() []*MigrationWorkflow

func (x *ListMigrationWorkflowsResponse) GetNextPageToken() string

func (*ListMigrationWorkflowsResponse) ProtoMessage()

func (x *ListMigrationWorkflowsResponse) ProtoReflect() protoreflect.Message

func (x *ListMigrationWorkflowsResponse) Reset()

func (x *ListMigrationWorkflowsResponse) String() string

type MigrationServiceClient interface {
	// Creates a migration workflow.
	CreateMigrationWorkflow(ctx context.Context, in *CreateMigrationWorkflowRequest, opts ...grpc.CallOption) (*MigrationWorkflow, error)
	// Gets a previously created migration workflow.
	GetMigrationWorkflow(ctx context.Context, in *GetMigrationWorkflowRequest, opts ...grpc.CallOption) (*MigrationWorkflow, error)
	// Lists previously created migration workflow.
	ListMigrationWorkflows(ctx context.Context, in *ListMigrationWorkflowsRequest, opts ...grpc.CallOption) (*ListMigrationWorkflowsResponse, error)
	// Deletes a migration workflow by name.
	DeleteMigrationWorkflow(ctx context.Context, in *DeleteMigrationWorkflowRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// Starts a previously created migration workflow. I.e., the state transitions
	// from DRAFT to RUNNING. This is a no-op if the state is already RUNNING.
	// An error will be signaled if the state is anything other than DRAFT or
	// RUNNING.
	StartMigrationWorkflow(ctx context.Context, in *StartMigrationWorkflowRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// Gets a previously created migration subtask.
	GetMigrationSubtask(ctx context.Context, in *GetMigrationSubtaskRequest, opts ...grpc.CallOption) (*MigrationSubtask, error)
	// Lists previously created migration subtasks.
	ListMigrationSubtasks(ctx context.Context, in *ListMigrationSubtasksRequest, opts ...grpc.CallOption) (*ListMigrationSubtasksResponse, error)
}

func NewMigrationServiceClient(cc grpc.ClientConnInterface) MigrationServiceClient

type MigrationServiceServer interface {
	// Creates a migration workflow.
	CreateMigrationWorkflow(context.Context, *CreateMigrationWorkflowRequest) (*MigrationWorkflow, error)
	// Gets a previously created migration workflow.
	GetMigrationWorkflow(context.Context, *GetMigrationWorkflowRequest) (*MigrationWorkflow, error)
	// Lists previously created migration workflow.
	ListMigrationWorkflows(context.Context, *ListMigrationWorkflowsRequest) (*ListMigrationWorkflowsResponse, error)
	// Deletes a migration workflow by name.
	DeleteMigrationWorkflow(context.Context, *DeleteMigrationWorkflowRequest) (*emptypb.Empty, error)
	// Starts a previously created migration workflow. I.e., the state transitions
	// from DRAFT to RUNNING. This is a no-op if the state is already RUNNING.
	// An error will be signaled if the state is anything other than DRAFT or
	// RUNNING.
	StartMigrationWorkflow(context.Context, *StartMigrationWorkflowRequest) (*emptypb.Empty, error)
	// Gets a previously created migration subtask.
	GetMigrationSubtask(context.Context, *GetMigrationSubtaskRequest) (*MigrationSubtask, error)
	// Lists previously created migration subtasks.
	ListMigrationSubtasks(context.Context, *ListMigrationSubtasksRequest) (*ListMigrationSubtasksResponse, error)
}

type MigrationSubtask struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`

	TaskId string `protobuf:"bytes,2,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`

	Type string `protobuf:"bytes,3,opt,name=type,proto3" json:"type,omitempty"`

	State MigrationSubtask_State "" /* 132 byte string literal not displayed */

	ProcessingError *errdetails.ErrorInfo `protobuf:"bytes,6,opt,name=processing_error,json=processingError,proto3" json:"processing_error,omitempty"`

	ResourceErrorDetails []*ResourceErrorDetail `protobuf:"bytes,12,rep,name=resource_error_details,json=resourceErrorDetails,proto3" json:"resource_error_details,omitempty"`

	ResourceErrorCount int32 `protobuf:"varint,13,opt,name=resource_error_count,json=resourceErrorCount,proto3" json:"resource_error_count,omitempty"`

	CreateTime *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`

	LastUpdateTime *timestamppb.Timestamp `protobuf:"bytes,8,opt,name=last_update_time,json=lastUpdateTime,proto3" json:"last_update_time,omitempty"`

	Metrics []*TimeSeries `protobuf:"bytes,11,rep,name=metrics,proto3" json:"metrics,omitempty"`

}

func (*MigrationSubtask) Descriptor() ([]byte, []int)

func (x *MigrationSubtask) GetCreateTime() *timestamppb.Timestamp

func (x *MigrationSubtask) GetLastUpdateTime() *timestamppb.Timestamp

func (x *MigrationSubtask) GetMetrics() []*TimeSeries

func (x *MigrationSubtask) GetName() string

func (x *MigrationSubtask) GetProcessingError() *errdetails.ErrorInfo

func (x *MigrationSubtask) GetResourceErrorCount() int32

func (x *MigrationSubtask) GetResourceErrorDetails() []*ResourceErrorDetail

func (x *MigrationSubtask) GetState() MigrationSubtask_State

func (x *MigrationSubtask) GetTaskId() string

func (x *MigrationSubtask) GetType() string

func (*MigrationSubtask) ProtoMessage()

func (x *MigrationSubtask) ProtoReflect() protoreflect.Message

func (x *MigrationSubtask) Reset()

func (x *MigrationSubtask) String() string

type MigrationSubtask_State int32

const (
	// The state is unspecified.
	MigrationSubtask_STATE_UNSPECIFIED MigrationSubtask_State = 0
	// The subtask is ready, i.e. it is ready for execution.
	MigrationSubtask_ACTIVE MigrationSubtask_State = 1
	// The subtask is running, i.e. it is assigned to a worker for execution.
	MigrationSubtask_RUNNING MigrationSubtask_State = 2
	// The subtask finished successfully.
	MigrationSubtask_SUCCEEDED MigrationSubtask_State = 3
	// The subtask finished unsuccessfully.
	MigrationSubtask_FAILED MigrationSubtask_State = 4
	// The subtask is paused, i.e., it will not be scheduled. If it was already
	// assigned,it might still finish but no new lease renewals will be granted.
	MigrationSubtask_PAUSED MigrationSubtask_State = 5
)

func (MigrationSubtask_State) Descriptor() protoreflect.EnumDescriptor

func (x MigrationSubtask_State) Enum() *MigrationSubtask_State

func (MigrationSubtask_State) EnumDescriptor() ([]byte, []int)

func (x MigrationSubtask_State) Number() protoreflect.EnumNumber

func (x MigrationSubtask_State) String() string

func (MigrationSubtask_State) Type() protoreflect.EnumType

type MigrationTask struct {
	TaskDetails isMigrationTask_TaskDetails `protobuf_oneof:"task_details"`

	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`

	Type string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`

	Details *anypb.Any `protobuf:"bytes,3,opt,name=details,proto3" json:"details,omitempty"`

	State MigrationTask_State "" /* 129 byte string literal not displayed */

	ProcessingError *errdetails.ErrorInfo `protobuf:"bytes,5,opt,name=processing_error,json=processingError,proto3" json:"processing_error,omitempty"`

	CreateTime *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`

	LastUpdateTime *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=last_update_time,json=lastUpdateTime,proto3" json:"last_update_time,omitempty"`

	OrchestrationResult *MigrationTaskOrchestrationResult `protobuf:"bytes,10,opt,name=orchestration_result,json=orchestrationResult,proto3" json:"orchestration_result,omitempty"`

}

func (*MigrationTask) Descriptor() ([]byte, []int)

func (x *MigrationTask) GetAssessmentTaskDetails() *AssessmentTaskDetails

func (x *MigrationTask) GetCreateTime() *timestamppb.Timestamp

func (x *MigrationTask) GetDetails() *anypb.Any

func (x *MigrationTask) GetId() string

func (x *MigrationTask) GetLastUpdateTime() *timestamppb.Timestamp

func (x *MigrationTask) GetOrchestrationResult() *MigrationTaskOrchestrationResult

func (x *MigrationTask) GetProcessingError() *errdetails.ErrorInfo

func (x *MigrationTask) GetState() MigrationTask_State

func (m *MigrationTask) GetTaskDetails() isMigrationTask_TaskDetails

func (x *MigrationTask) GetTranslationTaskDetails() *TranslationTaskDetails

func (x *MigrationTask) GetType() string

func (*MigrationTask) ProtoMessage()

func (x *MigrationTask) ProtoReflect() protoreflect.Message

func (x *MigrationTask) Reset()

func (x *MigrationTask) String() string

type MigrationTaskOrchestrationResult struct {

	// Details specific to the task type.
	//
	// Types that are assignable to Details:
	//
	//	*MigrationTaskOrchestrationResult_AssessmentDetails
	Details isMigrationTaskOrchestrationResult_Details `protobuf_oneof:"details"`
	// contains filtered or unexported fields
}

func (*MigrationTaskOrchestrationResult) Descriptor() ([]byte, []int)

func (x *MigrationTaskOrchestrationResult) GetAssessmentDetails() *AssessmentOrchestrationResultDetails

func (m *MigrationTaskOrchestrationResult) GetDetails() isMigrationTaskOrchestrationResult_Details

func (*MigrationTaskOrchestrationResult) ProtoMessage()

func (x *MigrationTaskOrchestrationResult) ProtoReflect() protoreflect.Message

func (x *MigrationTaskOrchestrationResult) Reset()

func (x *MigrationTaskOrchestrationResult) String() string

type MigrationTaskOrchestrationResult_AssessmentDetails struct {
	// Details specific to assessment task types.
	AssessmentDetails *AssessmentOrchestrationResultDetails `protobuf:"bytes,1,opt,name=assessment_details,json=assessmentDetails,proto3,oneof"`
}

type MigrationTask_AssessmentTaskDetails struct {
	// Task configuration for Assessment.
	AssessmentTaskDetails *AssessmentTaskDetails `protobuf:"bytes,12,opt,name=assessment_task_details,json=assessmentTaskDetails,proto3,oneof"`
}

type MigrationTask_State int32

const (
	// The state is unspecified.
	MigrationTask_STATE_UNSPECIFIED MigrationTask_State = 0
	// The task is waiting for orchestration.
	MigrationTask_PENDING MigrationTask_State = 1
	// The task is assigned to an orchestrator.
	MigrationTask_ORCHESTRATING MigrationTask_State = 2
	// The task is running, i.e. its subtasks are ready for execution.
	MigrationTask_RUNNING MigrationTask_State = 3
	// Tha task is paused. Assigned subtasks can continue, but no new subtasks
	// will be scheduled.
	MigrationTask_PAUSED MigrationTask_State = 4
	// The task finished successfully.
	MigrationTask_SUCCEEDED MigrationTask_State = 5
	// The task finished unsuccessfully.
	MigrationTask_FAILED MigrationTask_State = 6
)

func (MigrationTask_State) Descriptor() protoreflect.EnumDescriptor

func (x MigrationTask_State) Enum() *MigrationTask_State

func (MigrationTask_State) EnumDescriptor() ([]byte, []int)

func (x MigrationTask_State) Number() protoreflect.EnumNumber

func (x MigrationTask_State) String() string

func (MigrationTask_State) Type() protoreflect.EnumType

type MigrationTask_TranslationTaskDetails struct {
	// Task configuration for Batch/Offline SQL Translation.
	TranslationTaskDetails *TranslationTaskDetails `protobuf:"bytes,13,opt,name=translation_task_details,json=translationTaskDetails,proto3,oneof"`
}

type MigrationWorkflow struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`

	DisplayName string `protobuf:"bytes,6,opt,name=display_name,json=displayName,proto3" json:"display_name,omitempty"`

	Tasks map[string]*MigrationTask "" /* 151 byte string literal not displayed */

	State MigrationWorkflow_State "" /* 133 byte string literal not displayed */

	CreateTime *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`

	LastUpdateTime *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=last_update_time,json=lastUpdateTime,proto3" json:"last_update_time,omitempty"`

}

func (*MigrationWorkflow) Descriptor() ([]byte, []int)

func (x *MigrationWorkflow) GetCreateTime() *timestamppb.Timestamp

func (x *MigrationWorkflow) GetDisplayName() string

func (x *MigrationWorkflow) GetLastUpdateTime() *timestamppb.Timestamp

func (x *MigrationWorkflow) GetName() string

func (x *MigrationWorkflow) GetState() MigrationWorkflow_State

func (x *MigrationWorkflow) GetTasks() map[string]*MigrationTask

func (*MigrationWorkflow) ProtoMessage()

func (x *MigrationWorkflow) ProtoReflect() protoreflect.Message

func (x *MigrationWorkflow) Reset()

func (x *MigrationWorkflow) String() string

type MigrationWorkflow_State int32

const (
	// Workflow state is unspecified.
	MigrationWorkflow_STATE_UNSPECIFIED MigrationWorkflow_State = 0
	// Workflow is in draft status, i.e. tasks are not yet eligible for
	// execution.
	MigrationWorkflow_DRAFT MigrationWorkflow_State = 1
	// Workflow is running (i.e. tasks are eligible for execution).
	MigrationWorkflow_RUNNING MigrationWorkflow_State = 2
	// Workflow is paused. Tasks currently in progress may continue, but no
	// further tasks will be scheduled.
	MigrationWorkflow_PAUSED MigrationWorkflow_State = 3
	// Workflow is complete. There should not be any task in a non-terminal
	// state, but if they are (e.g. forced termination), they will not be
	// scheduled.
	MigrationWorkflow_COMPLETED MigrationWorkflow_State = 4
)

func (MigrationWorkflow_State) Descriptor() protoreflect.EnumDescriptor

func (x MigrationWorkflow_State) Enum() *MigrationWorkflow_State

func (MigrationWorkflow_State) EnumDescriptor() ([]byte, []int)

func (x MigrationWorkflow_State) Number() protoreflect.EnumNumber

func (x MigrationWorkflow_State) String() string

func (MigrationWorkflow_State) Type() protoreflect.EnumType

type Point struct {

	// The time interval to which the data point applies.  For `GAUGE` metrics,
	// the start time does not need to be supplied, but if it is supplied, it must
	// equal the end time.  For `DELTA` metrics, the start and end time should
	// specify a non-zero interval, with subsequent points specifying contiguous
	// and non-overlapping intervals.  For `CUMULATIVE` metrics, the start and end
	// time should specify a non-zero interval, with subsequent points specifying
	// the same start time and increasing end times, until an event resets the
	// cumulative value to zero and sets a new start time for the following
	// points.
	Interval *TimeInterval `protobuf:"bytes,1,opt,name=interval,proto3" json:"interval,omitempty"`
	// The value of the data point.
	Value *TypedValue `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*Point) Descriptor() ([]byte, []int)