datatransfer

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

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 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 CreateEndpointMetadata struct {
	EndpointId string `protobuf:"bytes,1,opt,name=endpoint_id,json=endpointId,proto3" json:"endpoint_id,omitempty"`
	// contains filtered or unexported fields
}

type CreateEndpointRequest struct {
	FolderId    string            `protobuf:"bytes,1,opt,name=folder_id,json=folderId,proto3" json:"folder_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 CreateTransferMetadata struct {
	TransferId string `protobuf:"bytes,1,opt,name=transfer_id,json=transferId,proto3" json:"transfer_id,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"`
	FolderId       string            `protobuf:"bytes,4,opt,name=folder_id,json=folderId,proto3" json:"folder_id,omitempty"`
	Runtime        *Runtime          `protobuf:"bytes,5,opt,name=runtime,proto3" json:"runtime,omitempty"`
	Type           TransferType      `protobuf:"varint,6,opt,name=type,proto3,enum=yandex.cloud.datatransfer.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 */
	Transformation *Transformation   `protobuf:"bytes,10,opt,name=transformation,proto3" json:"transformation,omitempty"`
	// contains filtered or unexported fields
}

type DeactivateTransferMetadata struct {
	TransferId string `protobuf:"bytes,1,opt,name=transfer_id,json=transferId,proto3" json:"transfer_id,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 DeleteEndpointMetadata struct {
	EndpointId string `protobuf:"bytes,1,opt,name=endpoint_id,json=endpointId,proto3" json:"endpoint_id,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 DeleteTransferMetadata struct {
	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"`
	FolderId    string            `protobuf:"bytes,2,opt,name=folder_id,json=folderId,proto3" json:"folder_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) (*operation.Operation, error)
	Update(ctx context.Context, in *UpdateEndpointRequest, opts ...grpc.CallOption) (*operation.Operation, error)
	Delete(ctx context.Context, in *DeleteEndpointRequest, opts ...grpc.CallOption) (*operation.Operation, error)
}

type EndpointServiceServer interface {
	Get(context.Context, *GetEndpointRequest) (*Endpoint, error)
	List(context.Context, *ListEndpointsRequest) (*ListEndpointsResponse, error)
	Create(context.Context, *CreateEndpointRequest) (*operation.Operation, error)
	Update(context.Context, *UpdateEndpointRequest) (*operation.Operation, error)
	Delete(context.Context, *DeleteEndpointRequest) (*operation.Operation, error)
}

type EndpointSettings struct {

	// Types that are assignable to Settings:
	//
	//	*EndpointSettings_MysqlSource
	//	*EndpointSettings_PostgresSource
	//	*EndpointSettings_YdbSource
	//	*EndpointSettings_YdsSource
	//	*EndpointSettings_KafkaSource
	//	*EndpointSettings_MongoSource
	//	*EndpointSettings_ClickhouseSource
	//	*EndpointSettings_MysqlTarget
	//	*EndpointSettings_PostgresTarget
	//	*EndpointSettings_ClickhouseTarget
	//	*EndpointSettings_YdbTarget
	//	*EndpointSettings_KafkaTarget
	//	*EndpointSettings_MongoTarget
	//	*EndpointSettings_MetrikaSource
	//	*EndpointSettings_YdsTarget
	Settings isEndpointSettings_Settings `protobuf_oneof:"settings"`
	// contains filtered or unexported fields
}

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_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_MetrikaSource struct {
	MetrikaSource *endpoint.MetrikaSource `protobuf:"bytes,146,opt,name=metrika_source,json=metrikaSource,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_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_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_Settings = isEndpointSettings_Settings

type EndpointSettings_YdbSource struct {
	YdbSource *endpoint.YdbSource `protobuf:"bytes,3,opt,name=ydb_source,json=ydbSource,proto3,oneof"`
}

type EndpointSettings_YdbTarget struct {
	YdbTarget *endpoint.YdbTarget `protobuf:"bytes,105,opt,name=ydb_target,json=ydbTarget,proto3,oneof"`
}

type EndpointSettings_YdsSource struct {
	YdsSource *endpoint.YDSSource `protobuf:"bytes,7,opt,name=yds_source,json=ydsSource,proto3,oneof"`
}

type EndpointSettings_YdsTarget struct {
	YdsTarget *endpoint.YDSTarget `protobuf:"bytes,150,opt,name=yds_target,json=ydsTarget,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 GetEndpointRequest struct {
	EndpointId string `protobuf:"bytes,1,opt,name=endpoint_id,json=endpointId,proto3" json:"endpoint_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 ListEndpointsRequest struct {

	// Identifier of the folder containing the endpoints to be listed.
	FolderId string `protobuf:"bytes,1,opt,name=folder_id,json=folderId,proto3" json:"folder_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`.
	PageSize int64 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// Opaque value identifying the endpoints page to be fetched. Should be empty in
	// the first `ListEndpointsRequest`. Subsequent requests should have this field
	// filled
	// with the `next_page_token` from the previous `ListEndpointsResponse`.
	PageToken string `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,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.
	NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// contains filtered or unexported fields
}

type ListTransfersRequest struct {

	// Identifier of the folder containing the transfers to be listed.
	FolderId string `protobuf:"bytes,2,opt,name=folder_id,json=folderId,proto3" json:"folder_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`.
	PageSize int64 `protobuf:"varint,3,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// Opaque value identifying the transfers page to be fetched. Should be empty in
	// the first `ListTransfersRequest`. Subsequent requests should have this field
	// filled
	// with the `next_page_token` from the previous `ListTransfersResponse`.
	PageToken string `protobuf:"bytes,4,opt,name=page_token,json=pageToken,proto3" json:"page_token,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 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_MaskFunction = isMaskFunction_MaskFunction

type MaskFunction_MaskFunctionHash struct {
	// Hash mask function
	MaskFunctionHash *MaskFunctionHash `protobuf:"bytes,1,opt,name=mask_function_hash,json=maskFunctionHash,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_YcRuntime
	Runtime isRuntime_Runtime `protobuf_oneof:"runtime"`
	// contains filtered or unexported fields
}

type Runtime_Runtime = isRuntime_Runtime

type Runtime_YcRuntime struct {
	YcRuntime *YcRuntime `protobuf:"bytes,4,opt,name=yc_runtime,json=ycRuntime,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 ShardingUploadParams struct {
	JobCount     int64 `protobuf:"varint,1,opt,name=job_count,json=jobCount,proto3" json:"job_count,omitempty"`
	ProcessCount int64 `protobuf:"varint,2,opt,name=process_count,json=processCount,proto3" json:"process_count,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"`
	FolderId       string            `protobuf:"bytes,2,opt,name=folder_id,json=folderId,proto3" json:"folder_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=yandex.cloud.datatransfer.v1.TransferStatus" json:"status,omitempty"`
	Type           TransferType      `protobuf:"varint,12,opt,name=type,proto3,enum=yandex.cloud.datatransfer.v1.TransferType" json:"type,omitempty"`
	Warning        string            `protobuf:"bytes,15,opt,name=warning,proto3" json:"warning,omitempty"`
	Transformation *Transformation   `protobuf:"bytes,17,opt,name=transformation,proto3" json:"transformation,omitempty"`
	Prestable      bool              `protobuf:"varint,22,opt,name=prestable,proto3" json:"prestable,omitempty"`
	// contains filtered or unexported fields
}

type TransferServiceClient interface {
	Create(ctx context.Context, in *CreateTransferRequest, opts ...grpc.CallOption) (*operation.Operation, error)
	Update(ctx context.Context, in *UpdateTransferRequest, opts ...grpc.CallOption) (*operation.Operation, error)
	Delete(ctx context.Context, in *DeleteTransferRequest, opts ...grpc.CallOption) (*operation.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) (*operation.Operation, error)
	Activate(ctx context.Context, in *ActivateTransferRequest, opts ...grpc.CallOption) (*operation.Operation, error)
}

type TransferServiceServer interface {
	Create(context.Context, *CreateTransferRequest) (*operation.Operation, error)
	Update(context.Context, *UpdateTransferRequest) (*operation.Operation, error)
	Delete(context.Context, *DeleteTransferRequest) (*operation.Operation, error)
	List(context.Context, *ListTransfersRequest) (*ListTransfersResponse, error)
	Get(context.Context, *GetTransferRequest) (*Transfer, error)
	Deactivate(context.Context, *DeactivateTransferRequest) (*operation.Operation, error)
	Activate(context.Context, *ActivateTransferRequest) (*operation.Operation, error)
}

type TransferStatus int32

type TransferType int32

type Transformation struct {

	// Transformers are set as a list.
	// When activating a transfer, a transformation plan is made for the tables that
	// match the specified criteria.
	// Transformers are applied to the tables in the sequence specified in the list.
	Transformers []*Transformer `protobuf:"bytes,1,rep,name=transformers,proto3" json:"transformers,omitempty"`
	// contains filtered or unexported fields
}

type Transformer struct {

	// Types that are assignable to Transformer:
	//
	//	*Transformer_MaskField
	//	*Transformer_FilterColumns
	//	*Transformer_RenameTables
	//	*Transformer_ReplacePrimaryKey
	//	*Transformer_ConvertToString
	//	*Transformer_SharderTransformer
	//	*Transformer_TableSplitterTransformer
	//	*Transformer_FilterRows
	Transformer isTransformer_Transformer `protobuf_oneof:"transformer"`
	// contains filtered or unexported fields
}

type Transformer_ConvertToString struct {
	ConvertToString *ToStringTransformer `protobuf:"bytes,7,opt,name=convert_to_string,json=convertToString,proto3,oneof"`
}

type Transformer_FilterColumns struct {
	FilterColumns *FilterColumnsTransformer `protobuf:"bytes,2,opt,name=filter_columns,json=filterColumns,proto3,oneof"`
}

type Transformer_FilterRows struct {
	FilterRows *FilterRowsTransformer `protobuf:"bytes,14,opt,name=filter_rows,json=filterRows,proto3,oneof"`
}

type Transformer_MaskField struct {
	MaskField *MaskFieldTransformer `protobuf:"bytes,1,opt,name=mask_field,json=maskField,proto3,oneof"`
}

type Transformer_RenameTables struct {
	RenameTables *RenameTablesTransformer `protobuf:"bytes,4,opt,name=rename_tables,json=renameTables,proto3,oneof"`
}

type Transformer_ReplacePrimaryKey struct {
	ReplacePrimaryKey *ReplacePrimaryKeyTransformer `protobuf:"bytes,6,opt,name=replace_primary_key,json=replacePrimaryKey,proto3,oneof"`
}

type Transformer_SharderTransformer struct {
	SharderTransformer *SharderTransformer `protobuf:"bytes,9,opt,name=sharder_transformer,json=sharderTransformer,proto3,oneof"`
}

type Transformer_TableSplitterTransformer struct {
	TableSplitterTransformer *TableSplitterTransformer `protobuf:"bytes,13,opt,name=table_splitter_transformer,json=tableSplitterTransformer,proto3,oneof"`
}

type Transformer_Transformer = isTransformer_Transformer

type UnimplementedEndpointServiceServer struct {
}

type UnimplementedTransferServiceServer struct {
}

type UnsafeEndpointServiceServer interface {
	// contains filtered or unexported methods
}

type UnsafeTransferServiceServer interface {
	// contains filtered or unexported methods
}

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

type UpdateEndpointRequest struct {

	// Identifier of the endpoint to be updated.
	EndpointId string `protobuf:"bytes,10,opt,name=endpoint_id,json=endpointId,proto3" json:"endpoint_id,omitempty"`
	// The new endpoint name. Must be unique within the folder.
	Name string `protobuf:"bytes,11,opt,name=name,proto3" json:"name,omitempty"`
	// The new description for the endpoint.
	Description string            `protobuf:"bytes,12,opt,name=description,proto3" json:"description,omitempty"`
	Labels      map[string]string `` /* 154-byte string literal not displayed */
	// The new endpoint name. Must be unique within the folder.
	Settings *EndpointSettings `protobuf:"bytes,52,opt,name=settings,proto3" json:"settings,omitempty"`
	// Field mask specifying endpoint fields to be updated. Semantics for this field is
	// described here:
	// <https://pkg.go.dev/google.golang.org/protobuf/types/known/fieldmaskpb#FieldMask>
	// The only exception: if the repeated field is specified in the mask, then
	// the new value replaces the old one instead of being appended to the old one.
	UpdateMask *fieldmaskpb.FieldMask `protobuf:"bytes,60,opt,name=update_mask,json=updateMask,proto3" json:"update_mask,omitempty"`
	// contains filtered or unexported fields
}

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

type UpdateTransferRequest struct {

	// Identifier of the transfer to be updated.
	TransferId string `protobuf:"bytes,1,opt,name=transfer_id,json=transferId,proto3" json:"transfer_id,omitempty"`
	// The new description for the transfer.
	Description string   `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
	Runtime     *Runtime `protobuf:"bytes,3,opt,name=runtime,proto3" json:"runtime,omitempty"`
	// The new transfer name. Must be unique within the folder.
	Name string `protobuf:"bytes,4,opt,name=name,proto3" json:"name,omitempty"`
	// Field mask specifying transfer fields to be updated. Semantics for this field is
	// described here:
	// <https://pkg.go.dev/google.golang.org/protobuf/types/known/fieldmaskpb#FieldMask>
	// The only exception: if the repeated field is specified in the mask, then
	// the new value replaces the old one instead of being appended to the old one.
	UpdateMask     *fieldmaskpb.FieldMask `protobuf:"bytes,5,opt,name=update_mask,json=updateMask,proto3" json:"update_mask,omitempty"`
	Labels         map[string]string      `` /* 153-byte string literal not displayed */
	Transformation *Transformation        `protobuf:"bytes,8,opt,name=transformation,proto3" json:"transformation,omitempty"`
	// contains filtered or unexported fields
}