transfer

type ActivateTransferRequest struct {
	TransferId string `protobuf:"bytes,1,opt,name=transfer_id,json=transferId,proto3" json:"transfer_id,omitempty"`
	// contains filtered or unexported fields
}

type AutoSettings struct {
	// contains filtered or unexported fields
}

type ColumnsFilter struct {

	// List of columns that will be included to transfer
	IncludeColumns []string `protobuf:"bytes,1,rep,name=include_columns,json=includeColumns,proto3" json:"include_columns,omitempty"`
	// List of columns that will be excluded to transfer
	ExcludeColumns []string `protobuf:"bytes,2,rep,name=exclude_columns,json=excludeColumns,proto3" json:"exclude_columns,omitempty"`
	// contains filtered or unexported fields
}

type CreateEndpointRequest struct {
	ProjectId   string            `protobuf:"bytes,1,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	Name        string            `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Description string            `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	Labels      map[string]string `` /* 153-byte string literal not displayed */
	Settings    *EndpointSettings `protobuf:"bytes,52,opt,name=settings,proto3" json:"settings,omitempty"`
	// contains filtered or unexported fields
}

type CreateTransferRequest struct {
	SourceId        string            `protobuf:"bytes,1,opt,name=source_id,json=sourceId,proto3" json:"source_id,omitempty"`
	TargetId        string            `protobuf:"bytes,2,opt,name=target_id,json=targetId,proto3" json:"target_id,omitempty"`
	Description     string            `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	ProjectId       string            `protobuf:"bytes,4,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	Runtime         *Runtime          `protobuf:"bytes,5,opt,name=runtime,proto3" json:"runtime,omitempty"`
	Type            TransferType      `protobuf:"varint,6,opt,name=type,proto3,enum=doublecloud.transfer.v1.TransferType" json:"type,omitempty"`
	Name            string            `protobuf:"bytes,7,opt,name=name,proto3" json:"name,omitempty"`
	Labels          map[string]string `` /* 153-byte string literal not displayed */
	RegularSnapshot *RegularSnapshot  `protobuf:"bytes,9,opt,name=regular_snapshot,json=regularSnapshot,proto3" json:"regular_snapshot,omitempty"`
	Transformation  *Transformation   `protobuf:"bytes,10,opt,name=transformation,proto3" json:"transformation,omitempty"`
	DataObjects     *DataObjects      `protobuf:"bytes,12,opt,name=data_objects,json=dataObjects,proto3" json:"data_objects,omitempty"`
	// contains filtered or unexported fields
}

type DBTTransformer struct {
	GitRepositoryLink string                   `protobuf:"bytes,1,opt,name=git_repository_link,json=gitRepositoryLink,proto3" json:"git_repository_link,omitempty"`
	GitBranch         string                   `protobuf:"bytes,2,opt,name=git_branch,json=gitBranch,proto3" json:"git_branch,omitempty"`
	ProfileName       string                   `protobuf:"bytes,3,opt,name=profile_name,json=profileName,proto3" json:"profile_name,omitempty"`
	Operation         DBTTransformer_Operation `` /* 126-byte string literal not displayed */
	// contains filtered or unexported fields
}

type DBTTransformer_Operation int32

type DataObjects struct {
	IncludeObjects []string `protobuf:"bytes,1,rep,name=include_objects,json=includeObjects,proto3" json:"include_objects,omitempty"`
	// contains filtered or unexported fields
}

type DeactivateTransferRequest struct {
	TransferId string `protobuf:"bytes,1,opt,name=transfer_id,json=transferId,proto3" json:"transfer_id,omitempty"`
	// contains filtered or unexported fields
}

type DedicatedRuntime struct {
	Flavor   Flavor    `protobuf:"varint,2,opt,name=flavor,proto3,enum=doublecloud.transfer.v1.Flavor" json:"flavor,omitempty"`
	Settings *Settings `protobuf:"bytes,8,opt,name=settings,proto3" json:"settings,omitempty"`
	// contains filtered or unexported fields
}

type DeleteEndpointRequest struct {
	EndpointId string `protobuf:"bytes,1,opt,name=endpoint_id,json=endpointId,proto3" json:"endpoint_id,omitempty"`
	// contains filtered or unexported fields
}

type DeleteExporterConnectionInfoMetadata struct {

	// The ID of the Transfer
	TransferId string `protobuf:"bytes,1,opt,name=transfer_id,json=transferId,proto3" json:"transfer_id,omitempty"`
	// contains filtered or unexported fields
}

type DeleteExporterConnectionInfoRequest struct {

	// The ID of the Transfer
	TransferId string `protobuf:"bytes,1,opt,name=transfer_id,json=transferId,proto3" json:"transfer_id,omitempty"`
	// contains filtered or unexported fields
}

type DeleteTransferRequest struct {
	TransferId string `protobuf:"bytes,1,opt,name=transfer_id,json=transferId,proto3" json:"transfer_id,omitempty"`
	// contains filtered or unexported fields
}

type Endpoint struct {
	Id          string            `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	ProjectId   string            `protobuf:"bytes,2,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	Name        string            `protobuf:"bytes,4,opt,name=name,proto3" json:"name,omitempty"`
	Description string            `protobuf:"bytes,5,opt,name=description,proto3" json:"description,omitempty"`
	Labels      map[string]string `` /* 153-byte string literal not displayed */
	Settings    *EndpointSettings `protobuf:"bytes,52,opt,name=settings,proto3" json:"settings,omitempty"`
	// contains filtered or unexported fields
}

type EndpointServiceClient interface {
	Get(ctx context.Context, in *GetEndpointRequest, opts ...grpc.CallOption) (*Endpoint, error)
	List(ctx context.Context, in *ListEndpointsRequest, opts ...grpc.CallOption) (*ListEndpointsResponse, error)
	Create(ctx context.Context, in *CreateEndpointRequest, opts ...grpc.CallOption) (*v1.Operation, error)
	Update(ctx context.Context, in *UpdateEndpointRequest, opts ...grpc.CallOption) (*v1.Operation, error)
	Delete(ctx context.Context, in *DeleteEndpointRequest, opts ...grpc.CallOption) (*v1.Operation, error)
}

type EndpointServiceServer interface {
	Get(context.Context, *GetEndpointRequest) (*Endpoint, error)
	List(context.Context, *ListEndpointsRequest) (*ListEndpointsResponse, error)
	Create(context.Context, *CreateEndpointRequest) (*v1.Operation, error)
	Update(context.Context, *UpdateEndpointRequest) (*v1.Operation, error)
	Delete(context.Context, *DeleteEndpointRequest) (*v1.Operation, error)
	// contains filtered or unexported methods
}

type EndpointSettings struct {

	// Types that are assignable to Settings:
	//
	//	*EndpointSettings_MysqlSource
	//	*EndpointSettings_PostgresSource
	//	*EndpointSettings_KafkaSource
	//	*EndpointSettings_MongoSource
	//	*EndpointSettings_ClickhouseSource
	//	*EndpointSettings_MysqlTarget
	//	*EndpointSettings_PostgresTarget
	//	*EndpointSettings_ClickhouseTarget
	//	*EndpointSettings_ObjectStorageTarget
	//	*EndpointSettings_KafkaTarget
	//	*EndpointSettings_MongoTarget
	//	*EndpointSettings_S3Source
	//	*EndpointSettings_AwsCloudtrailSource
	//	*EndpointSettings_BigQuerySource
	//	*EndpointSettings_FacebookMarketingSource
	//	*EndpointSettings_GoogleAdsSource
	//	*EndpointSettings_AmazonAdsSource
	//	*EndpointSettings_InstagramSource
	//	*EndpointSettings_LinkedinAdsSource
	//	*EndpointSettings_MssqlSource
	//	*EndpointSettings_RedshiftSource
	//	*EndpointSettings_SnowflakeSource
	//	*EndpointSettings_ObjectStorageSource
	//	*EndpointSettings_DatadogTarget
	//	*EndpointSettings_JiraSource
	//	*EndpointSettings_HubspotSource
	//	*EndpointSettings_CoralogixTarget
	//	*EndpointSettings_BigqueryTarget
	Settings isEndpointSettings_Settings `protobuf_oneof:"settings"`
	// contains filtered or unexported fields
}

type EndpointSettings_AmazonAdsSource struct {
	AmazonAdsSource *airbyte.AmazonAdsSource `protobuf:"bytes,134,opt,name=amazon_ads_source,json=amazonAdsSource,proto3,oneof"`
}

type EndpointSettings_AwsCloudtrailSource struct {
	AwsCloudtrailSource *airbyte.AWSCloudTrailSource `protobuf:"bytes,127,opt,name=aws_cloudtrail_source,json=awsCloudtrailSource,proto3,oneof"`
}

type EndpointSettings_BigQuerySource struct {
	BigQuerySource *airbyte.BigQuerySource `protobuf:"bytes,128,opt,name=big_query_source,json=bigQuerySource,proto3,oneof"`
}

type EndpointSettings_BigqueryTarget struct {
	BigqueryTarget *endpoint.BigQueryTarget `protobuf:"bytes,158,opt,name=bigquery_target,json=bigqueryTarget,proto3,oneof"`
}

type EndpointSettings_ClickhouseSource struct {
	ClickhouseSource *endpoint.ClickhouseSource `protobuf:"bytes,16,opt,name=clickhouse_source,json=clickhouseSource,proto3,oneof"`
}

type EndpointSettings_ClickhouseTarget struct {
	ClickhouseTarget *endpoint.ClickhouseTarget `protobuf:"bytes,104,opt,name=clickhouse_target,json=clickhouseTarget,proto3,oneof"`
}

type EndpointSettings_CoralogixTarget struct {
	CoralogixTarget *endpoint.CoralogixTarget `protobuf:"bytes,157,opt,name=coralogix_target,json=coralogixTarget,proto3,oneof"`
}

type EndpointSettings_DatadogTarget struct {
	DatadogTarget *endpoint.DatadogTarget `protobuf:"bytes,154,opt,name=datadog_target,json=datadogTarget,proto3,oneof"`
}

type EndpointSettings_FacebookMarketingSource struct {
	FacebookMarketingSource *airbyte.FacebookMarketingSource `protobuf:"bytes,130,opt,name=facebook_marketing_source,json=facebookMarketingSource,proto3,oneof"`
}

type EndpointSettings_GoogleAdsSource struct {
	GoogleAdsSource *airbyte.GoogleAdsSource `protobuf:"bytes,132,opt,name=google_ads_source,json=googleAdsSource,proto3,oneof"`
}

type EndpointSettings_HubspotSource struct {
	HubspotSource *airbyte.HubspotSource `protobuf:"bytes,156,opt,name=hubspot_source,json=hubspotSource,proto3,oneof"`
}

type EndpointSettings_InstagramSource struct {
	InstagramSource *airbyte.InstagramSource `protobuf:"bytes,136,opt,name=instagram_source,json=instagramSource,proto3,oneof"`
}

type EndpointSettings_JiraSource struct {
	JiraSource *airbyte.JiraSource `protobuf:"bytes,155,opt,name=jira_source,json=jiraSource,proto3,oneof"`
}

type EndpointSettings_KafkaSource struct {
	KafkaSource *endpoint.KafkaSource `protobuf:"bytes,8,opt,name=kafka_source,json=kafkaSource,proto3,oneof"`
}

type EndpointSettings_KafkaTarget struct {
	KafkaTarget *endpoint.KafkaTarget `protobuf:"bytes,110,opt,name=kafka_target,json=kafkaTarget,proto3,oneof"`
}

type EndpointSettings_LinkedinAdsSource struct {
	LinkedinAdsSource *airbyte.LinkedinAdsSource `protobuf:"bytes,137,opt,name=linkedin_ads_source,json=linkedinAdsSource,proto3,oneof"`
}

type EndpointSettings_MongoSource struct {
	MongoSource *endpoint.MongoSource `protobuf:"bytes,9,opt,name=mongo_source,json=mongoSource,proto3,oneof"`
}

type EndpointSettings_MongoTarget struct {
	MongoTarget *endpoint.MongoTarget `protobuf:"bytes,111,opt,name=mongo_target,json=mongoTarget,proto3,oneof"`
}

type EndpointSettings_MssqlSource struct {
	MssqlSource *airbyte.MSSQLSource `protobuf:"bytes,138,opt,name=mssql_source,json=mssqlSource,proto3,oneof"`
}

type EndpointSettings_MysqlSource struct {
	MysqlSource *endpoint.MysqlSource `protobuf:"bytes,1,opt,name=mysql_source,json=mysqlSource,proto3,oneof"`
}

type EndpointSettings_MysqlTarget struct {
	MysqlTarget *endpoint.MysqlTarget `protobuf:"bytes,101,opt,name=mysql_target,json=mysqlTarget,proto3,oneof"`
}

type EndpointSettings_ObjectStorageSource struct {
	ObjectStorageSource *endpoint.ObjectStorageSource `protobuf:"bytes,153,opt,name=object_storage_source,json=objectStorageSource,proto3,oneof"`
}

type EndpointSettings_ObjectStorageTarget struct {
	ObjectStorageTarget *endpoint.ObjectStorageTarget `protobuf:"bytes,109,opt,name=object_storage_target,json=objectStorageTarget,proto3,oneof"`
}

type EndpointSettings_PostgresSource struct {
	PostgresSource *endpoint.PostgresSource `protobuf:"bytes,2,opt,name=postgres_source,json=postgresSource,proto3,oneof"`
}

type EndpointSettings_PostgresTarget struct {
	PostgresTarget *endpoint.PostgresTarget `protobuf:"bytes,102,opt,name=postgres_target,json=postgresTarget,proto3,oneof"`
}

type EndpointSettings_RedshiftSource struct {
	RedshiftSource *airbyte.RedshiftSource `protobuf:"bytes,139,opt,name=redshift_source,json=redshiftSource,proto3,oneof"`
}

type EndpointSettings_S3Source struct {
	S3Source *airbyte.S3Source `protobuf:"bytes,124,opt,name=s3_source,json=s3Source,proto3,oneof"`
}

type EndpointSettings_SnowflakeSource struct {
	SnowflakeSource *airbyte.SnowflakeSource `protobuf:"bytes,148,opt,name=snowflake_source,json=snowflakeSource,proto3,oneof"`
}

type FilterColumnsTransformer struct {

	// List of the tables to filter using lists of included and excluded tables.
	Tables *TablesFilter `protobuf:"bytes,1,opt,name=tables,proto3" json:"tables,omitempty"`
	// List of the columns to transfer to the target tables using lists of included and
	// excluded columns.
	Columns *ColumnsFilter `protobuf:"bytes,2,opt,name=columns,proto3" json:"columns,omitempty"`
	// contains filtered or unexported fields
}

type FilterRowsTransformer struct {

	// List of included and excluded tables
	Tables *TablesFilter `protobuf:"bytes,1,opt,name=tables,proto3" json:"tables,omitempty"`
	// Filtering criterion. This can be comparison operators for numeric, string, and
	// Boolean values,
	// comparison to NULL, and checking whether a substring is part of a string.
	// Details here:
	// https://cloud.yandex.com/en/docs/data-transfer/concepts/data-transformation#append-only-sources
	Filter string `protobuf:"bytes,2,opt,name=filter,proto3" json:"filter,omitempty"`
	// contains filtered or unexported fields
}

type Flavor int32

type GetEndpointRequest struct {
	EndpointId string `protobuf:"bytes,1,opt,name=endpoint_id,json=endpointId,proto3" json:"endpoint_id,omitempty"`
	// contains filtered or unexported fields
}

type GetMetricsRequest struct {

	// The ID of Transfer
	TransferId string `protobuf:"bytes,1,opt,name=transfer_id,json=transferId,proto3" json:"transfer_id,omitempty"`
	// contains filtered or unexported fields
}

type GetOperationRequest struct {
	OperationId string `protobuf:"bytes,1,opt,name=operation_id,json=operationId,proto3" json:"operation_id,omitempty"`
	// contains filtered or unexported fields
}

type GetTransferRequest struct {
	TransferId string `protobuf:"bytes,1,opt,name=transfer_id,json=transferId,proto3" json:"transfer_id,omitempty"`
	// contains filtered or unexported fields
}

type IncrementalTable struct {
	TableNamespace string `protobuf:"bytes,1,opt,name=table_namespace,json=tableNamespace,proto3" json:"table_namespace,omitempty"`
	TableName      string `protobuf:"bytes,2,opt,name=table_name,json=tableName,proto3" json:"table_name,omitempty"`
	CursorColumn   string `protobuf:"bytes,3,opt,name=cursor_column,json=cursorColumn,proto3" json:"cursor_column,omitempty"`
	InitialState   string `protobuf:"bytes,4,opt,name=initial_state,json=initialState,proto3" json:"initial_state,omitempty"`
	// contains filtered or unexported fields
}

type ListEndpointsRequest struct {

	// Identifier of the folder containing the endpoints to be listed.
	ProjectId string `protobuf:"bytes,1,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	// The maximum number of endpoints to be sent in the response message. If the
	// folder contains more endpoints than `page_size`, `next_page_token` will be
	// included
	// in the response message. Include it into the subsequent `ListEndpointRequest` to
	// fetch the next page. Defaults to `100` if not specified. The maximum allowed
	// value
	// for this field is `500`.
	Page *v1.Paging `protobuf:"bytes,2,opt,name=page,proto3" json:"page,omitempty"`
	// contains filtered or unexported fields
}

type ListEndpointsResponse struct {

	// The list of endpoints. If there are more endpoints in the folder, then
	// `next_page_token` is a non-empty string to be included into the subsequent
	// `ListEndpointsRequest` to fetch the next endpoints page.
	Endpoints []*Endpoint `protobuf:"bytes,1,rep,name=endpoints,proto3" json:"endpoints,omitempty"`
	// Opaque value identifying the next endpoints page. This field is empty if there
	// are no more endpoints in the folder. Otherwise, it is non-empty and should be
	// included in the subsequent `ListEndpointsRequest` to fetch the next endpoints
	// page.
	NextPage *v1.NextPage `protobuf:"bytes,2,opt,name=next_page,json=nextPage,proto3" json:"next_page,omitempty"`
	// contains filtered or unexported fields
}

type ListTransfersRequest struct {

	// Identifier of the folder containing the transfers to be listed.
	ProjectId string `protobuf:"bytes,2,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	// The maximum number of transfers to be sent in the response message. If the
	// folder contains more transfers than `page_size`, `next_page_token` will be
	// included
	// in the response message. Include it into the subsequent `ListTransfersRequest`
	// to
	// fetch the next page. Defaults to `100` if not specified. The maximum allowed
	// value
	// for this field is `500`.
	Page *v1.Paging `protobuf:"bytes,3,opt,name=page,proto3" json:"page,omitempty"`
	// contains filtered or unexported fields
}

type ListTransfersResponse struct {

	// The list of transfers. If there are more transfers in the folder, then
	// `next_page_token` is a non-empty string to be included into the subsequent
	// `ListTransfersRequest` to fetch the next transfers page.
	Transfers []*Transfer `protobuf:"bytes,1,rep,name=transfers,proto3" json:"transfers,omitempty"`
	// Opaque value identifying the next transfers page. This field is empty if there
	// are no more transfers in the folder. Otherwise it is non-empty and should be
	// included in the subsequent `ListTransfersRequest` to fetch the next transfers
	// page.
	NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// contains filtered or unexported fields
}

type ManualSettings struct {
	NetworkId string `protobuf:"bytes,4,opt,name=network_id,json=networkId,proto3" json:"network_id,omitempty"`
	// contains filtered or unexported fields
}

type MaskFieldTransformer struct {

	// List of included and excluded tables
	Tables *TablesFilter `protobuf:"bytes,1,opt,name=tables,proto3" json:"tables,omitempty"`
	// Specify the name of the column for data masking (a regular expression).
	Columns []string `protobuf:"bytes,2,rep,name=columns,proto3" json:"columns,omitempty"`
	// Mask function
	Function *MaskFunction `protobuf:"bytes,3,opt,name=function,proto3" json:"function,omitempty"`
	// contains filtered or unexported fields
}

type MaskFunction struct {

	// Types that are assignable to MaskFunction:
	//
	//	*MaskFunction_MaskFunctionHash
	MaskFunction isMaskFunction_MaskFunction `protobuf_oneof:"mask_function"`
	// contains filtered or unexported fields
}

type MaskFunctionHash struct {

	// This string will be used in the HMAC(sha256, salt) function applied to the
	// column data.
	UserDefinedSalt string `protobuf:"bytes,1,opt,name=user_defined_salt,json=userDefinedSalt,proto3" json:"user_defined_salt,omitempty"`
	// contains filtered or unexported fields
}

type MaskFunction_MaskFunctionHash struct {
	// Hash mask function
	MaskFunctionHash *MaskFunctionHash `protobuf:"bytes,1,opt,name=mask_function_hash,json=maskFunctionHash,proto3,oneof"`
}

type MetricExporterConnectionInfoMetadata struct {

	// String to use in clients. i.e. url for config
	ConnectionString string `protobuf:"bytes,1,opt,name=connection_string,json=connectionString,proto3" json:"connection_string,omitempty"`
	// User for HTTP basic auth.
	User string `protobuf:"bytes,2,opt,name=user,proto3" json:"user,omitempty"`
	// Password for HTTP basic auth.
	Password string `protobuf:"bytes,3,opt,name=password,proto3" json:"password,omitempty"`
	// contains filtered or unexported fields
}

type MetricExporterConnectionInfoRequest struct {

	// The ID of the Transfer
	TransferId string `protobuf:"bytes,1,opt,name=transfer_id,json=transferId,proto3" json:"transfer_id,omitempty"`
	// contains filtered or unexported fields
}

type NumberToFloatTransformer struct {
	Tables *TablesFilter `protobuf:"bytes,1,opt,name=tables,proto3" json:"tables,omitempty"`
	// contains filtered or unexported fields
}

type OperationServiceClient interface {
	Get(ctx context.Context, in *GetOperationRequest, opts ...grpc.CallOption) (*v1.Operation, error)
}

type OperationServiceServer interface {
	Get(context.Context, *GetOperationRequest) (*v1.Operation, error)
	// contains filtered or unexported methods
}

type RawCdcDocGroupTransformer struct {
	Keys   []string `protobuf:"bytes,2,rep,name=keys,proto3" json:"keys,omitempty"`
	Fields []string `protobuf:"bytes,3,rep,name=fields,proto3" json:"fields,omitempty"`
	// contains filtered or unexported fields
}

type RawDocGroupTransformer struct {
	Tables *TablesFilter `protobuf:"bytes,1,opt,name=tables,proto3" json:"tables,omitempty"`
	Keys   []string      `protobuf:"bytes,2,rep,name=keys,proto3" json:"keys,omitempty"`
	Fields []string      `protobuf:"bytes,3,rep,name=fields,proto3" json:"fields,omitempty"`
	// contains filtered or unexported fields
}

type RegularSnapshot struct {

	// Types that are assignable to Mode:
	//
	//	*RegularSnapshot_Settings
	//	*RegularSnapshot_Disabled
	Mode isRegularSnapshot_Mode `protobuf_oneof:"mode"`
	// contains filtered or unexported fields
}

type RegularSnapshotDisabled struct {
	// contains filtered or unexported fields
}

type RegularSnapshotScheduleInterval int32

type RegularSnapshotSettings struct {
	Schedule       RegularSnapshotScheduleInterval `` /* 131-byte string literal not displayed */
	Tables         []*IncrementalTable             `protobuf:"bytes,2,rep,name=tables,proto3" json:"tables,omitempty"`
	CronExpression string                          `protobuf:"bytes,3,opt,name=cron_expression,json=cronExpression,proto3" json:"cron_expression,omitempty"`
	// contains filtered or unexported fields
}

type RegularSnapshot_Disabled struct {
	Disabled *RegularSnapshotDisabled `protobuf:"bytes,4,opt,name=disabled,proto3,oneof"`
}

type RegularSnapshot_Settings struct {
	Settings *RegularSnapshotSettings `protobuf:"bytes,3,opt,name=settings,proto3,oneof"`
}

type RenameTable struct {

	// Specify the current names of the table in the source
	OriginalName *Table `protobuf:"bytes,1,opt,name=original_name,json=originalName,proto3" json:"original_name,omitempty"`
	// Specify the new names for this table in the target
	NewName *Table `protobuf:"bytes,2,opt,name=new_name,json=newName,proto3" json:"new_name,omitempty"`
	// contains filtered or unexported fields
}

type RenameTablesTransformer struct {

	// List of renaming rules
	RenameTables []*RenameTable `protobuf:"bytes,1,rep,name=rename_tables,json=renameTables,proto3" json:"rename_tables,omitempty"`
	// contains filtered or unexported fields
}

type ReplacePrimaryKeyTransformer struct {

	// List of included and excluded tables
	Tables *TablesFilter `protobuf:"bytes,1,opt,name=tables,proto3" json:"tables,omitempty"`
	// List of columns to be used as primary keys
	Keys []string `protobuf:"bytes,2,rep,name=keys,proto3" json:"keys,omitempty"`
	// contains filtered or unexported fields
}

type Runtime struct {

	// Types that are assignable to Runtime:
	//
	//	*Runtime_ServerlessRuntime
	//	*Runtime_DedicatedRuntime
	Runtime isRuntime_Runtime `protobuf_oneof:"runtime"`
	// contains filtered or unexported fields
}

type Runtime_DedicatedRuntime struct {
	DedicatedRuntime *DedicatedRuntime `protobuf:"bytes,6,opt,name=dedicated_runtime,json=dedicatedRuntime,proto3,oneof"`
}

type Runtime_ServerlessRuntime struct {
	ServerlessRuntime *ServerlessRuntime `protobuf:"bytes,5,opt,name=serverless_runtime,json=serverlessRuntime,proto3,oneof"`
}

type SQLTransformer struct {
	Tables *TablesFilter `protobuf:"bytes,1,opt,name=tables,proto3" json:"tables,omitempty"`
	Query  string        `protobuf:"bytes,2,opt,name=query,proto3" json:"query,omitempty"`
	// contains filtered or unexported fields
}

type ServerlessRuntime struct {
	JobCount int64 `protobuf:"varint,2,opt,name=job_count,json=jobCount,proto3" json:"job_count,omitempty"`
	// contains filtered or unexported fields
}

type Settings struct {

	// Types that are assignable to Settings:
	//
	//	*Settings_AutoSettings
	//	*Settings_ManualSettings
	Settings isSettings_Settings `protobuf_oneof:"settings"`
	// contains filtered or unexported fields
}

type Settings_AutoSettings struct {
	AutoSettings *AutoSettings `protobuf:"bytes,1,opt,name=auto_settings,json=autoSettings,proto3,oneof"`
}

type Settings_ManualSettings struct {
	ManualSettings *ManualSettings `protobuf:"bytes,2,opt,name=manual_settings,json=manualSettings,proto3,oneof"`
}

type SharderTransformer struct {

	// List of included and excluded tables
	Tables *TablesFilter `protobuf:"bytes,1,opt,name=tables,proto3" json:"tables,omitempty"`
	// List of included and excluded columns
	Columns *ColumnsFilter `protobuf:"bytes,2,opt,name=columns,proto3" json:"columns,omitempty"`
	// Number of shards
	ShardsCount int64 `protobuf:"varint,3,opt,name=shards_count,json=shardsCount,proto3" json:"shards_count,omitempty"`
	// contains filtered or unexported fields
}

type SkipEventsTransformer struct {
	Tables *TablesFilter `protobuf:"bytes,1,opt,name=tables,proto3" json:"tables,omitempty"`
	// contains filtered or unexported fields
}

type Table struct {
	NameSpace string `protobuf:"bytes,1,opt,name=name_space,json=nameSpace,proto3" json:"name_space,omitempty"`
	Name      string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

type TableSplitterTransformer struct {

	// List of included and excluded tables
	Tables *TablesFilter `protobuf:"bytes,1,opt,name=tables,proto3" json:"tables,omitempty"`
	// Specify the columns in the tables to be partitioned.
	Columns []string `protobuf:"bytes,2,rep,name=columns,proto3" json:"columns,omitempty"`
	// Specify the split string to be used for merging components in a new table name.
	Splitter string `protobuf:"bytes,3,opt,name=splitter,proto3" json:"splitter,omitempty"`
	// contains filtered or unexported fields
}

type TablesFilter struct {

	// List of tables that will be included to transfer
	IncludeTables []string `protobuf:"bytes,1,rep,name=include_tables,json=includeTables,proto3" json:"include_tables,omitempty"`
	// List of tables that will be excluded to transfer
	ExcludeTables []string `protobuf:"bytes,2,rep,name=exclude_tables,json=excludeTables,proto3" json:"exclude_tables,omitempty"`
	// contains filtered or unexported fields
}

type ToStringTransformer struct {

	// List of included and excluded tables
	Tables *TablesFilter `protobuf:"bytes,1,opt,name=tables,proto3" json:"tables,omitempty"`
	// List of included and excluded columns
	Columns *ColumnsFilter `protobuf:"bytes,2,opt,name=columns,proto3" json:"columns,omitempty"`
	// contains filtered or unexported fields
}

type Transfer struct {
	Id              string            `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	ProjectId       string            `protobuf:"bytes,2,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	Name            string            `protobuf:"bytes,4,opt,name=name,proto3" json:"name,omitempty"`
	Description     string            `protobuf:"bytes,5,opt,name=description,proto3" json:"description,omitempty"`
	Labels          map[string]string `` /* 153-byte string literal not displayed */
	Source          *Endpoint         `protobuf:"bytes,7,opt,name=source,proto3" json:"source,omitempty"`
	Target          *Endpoint         `protobuf:"bytes,8,opt,name=target,proto3" json:"target,omitempty"`
	Runtime         *Runtime          `protobuf:"bytes,9,opt,name=runtime,proto3" json:"runtime,omitempty"`
	Status          TransferStatus    `protobuf:"varint,10,opt,name=status,proto3,enum=doublecloud.transfer.v1.TransferStatus" json:"status,omitempty"`
	Type            TransferType      `protobuf:"varint,12,opt,name=type,proto3,enum=doublecloud.transfer.v1.TransferType" json:"type,omitempty"`
	Warning         string            `protobuf:"bytes,15,opt,name=warning,proto3" json:"warning,omitempty"`
	RegularSnapshot *RegularSnapshot  `protobuf:"bytes,16,opt,name=regular_snapshot,json=regularSnapshot,proto3" json:"regular_snapshot,omitempty"`
	Transformation  *Transformation   `protobuf:"bytes,17,opt,name=transformation,proto3" json:"transformation,omitempty"`
	DataObjects     *DataObjects      `protobuf:"bytes,19,opt,name=data_objects,json=dataObjects,proto3" json:"data_objects,omitempty"`
	// contains filtered or unexported fields
}

type TransferMetrics struct {

	// The list of the transfer metrics
	Metrics []*TransferMetrics_Metric `protobuf:"bytes,1,rep,name=metrics,proto3" json:"metrics,omitempty"`
	// contains filtered or unexported fields
}

type TransferMetrics_Metric struct {
	Help  string `protobuf:"bytes,1,opt,name=help,proto3" json:"help,omitempty"`
	Type  string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	Value string `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

type TransferServiceClient interface {
	Create(ctx context.Context, in *CreateTransferRequest, opts ...grpc.CallOption) (*v1.Operation, error)
	Update(ctx context.Context, in *UpdateTransferRequest, opts ...grpc.CallOption) (*v1.Operation, error)
	Delete(ctx context.Context, in *DeleteTransferRequest, opts ...grpc.CallOption) (*v1.Operation, error)
	List(ctx context.Context, in *ListTransfersRequest, opts ...grpc.CallOption) (*ListTransfersResponse, error)
	Get(ctx context.Context, in *GetTransferRequest, opts ...grpc.CallOption) (*Transfer, error)
	Deactivate(ctx context.Context, in *DeactivateTransferRequest, opts ...grpc.CallOption) (*v1.Operation, error)
	Activate(ctx context.Context, in *ActivateTransferRequest, opts ...grpc.CallOption) (*v1.Operation, error)
	// Allows scraping of metrics by a prometheus scraper
	GetMetrics(ctx context.Context, in *GetMetricsRequest, opts ...grpc.CallOption) (*TransferMetrics, error)
	GetMetricExporterConnectionInfo(ctx context.Context, in *MetricExporterConnectionInfoRequest, opts ...grpc.CallOption) (*MetricExporterConnectionInfoMetadata, error)
	DeleteMetricExporterConnectionInfo(ctx context.Context, in *DeleteExporterConnectionInfoRequest, opts ...grpc.CallOption) (*v1.Operation, error)
}