Package cloud.google.com/go/bigquery/datatransfer/apiv1/datatransferpb (v1.53.0)

var (
	DataSourceParameter_Type_name = map[int32]string{
		0: "TYPE_UNSPECIFIED",
		1: "STRING",
		2: "INTEGER",
		3: "DOUBLE",
		4: "BOOLEAN",
		5: "RECORD",
		6: "PLUS_PAGE",
	}
	DataSourceParameter_Type_value = map[string]int32{
		"TYPE_UNSPECIFIED": 0,
		"STRING":           1,
		"INTEGER":          2,
		"DOUBLE":           3,
		"BOOLEAN":          4,
		"RECORD":           5,
		"PLUS_PAGE":        6,
	}
)

var (
	DataSource_AuthorizationType_name = map[int32]string{
		0: "AUTHORIZATION_TYPE_UNSPECIFIED",
		1: "AUTHORIZATION_CODE",
		2: "GOOGLE_PLUS_AUTHORIZATION_CODE",
		3: "FIRST_PARTY_OAUTH",
	}
	DataSource_AuthorizationType_value = map[string]int32{
		"AUTHORIZATION_TYPE_UNSPECIFIED": 0,
		"AUTHORIZATION_CODE":             1,
		"GOOGLE_PLUS_AUTHORIZATION_CODE": 2,
		"FIRST_PARTY_OAUTH":              3,
	}
)

var (
	DataSource_DataRefreshType_name = map[int32]string{
		0: "DATA_REFRESH_TYPE_UNSPECIFIED",
		1: "SLIDING_WINDOW",
		2: "CUSTOM_SLIDING_WINDOW",
	}
	DataSource_DataRefreshType_value = map[string]int32{
		"DATA_REFRESH_TYPE_UNSPECIFIED": 0,
		"SLIDING_WINDOW":                1,
		"CUSTOM_SLIDING_WINDOW":         2,
	}
)

var (
	ListTransferRunsRequest_RunAttempt_name = map[int32]string{
		0: "RUN_ATTEMPT_UNSPECIFIED",
		1: "LATEST",
	}
	ListTransferRunsRequest_RunAttempt_value = map[string]int32{
		"RUN_ATTEMPT_UNSPECIFIED": 0,
		"LATEST":                  1,
	}
)

var (
	TransferType_name = map[int32]string{
		0: "TRANSFER_TYPE_UNSPECIFIED",
		1: "BATCH",
		2: "STREAMING",
	}
	TransferType_value = map[string]int32{
		"TRANSFER_TYPE_UNSPECIFIED": 0,
		"BATCH":                     1,
		"STREAMING":                 2,
	}
)

var (
	TransferState_name = map[int32]string{
		0: "TRANSFER_STATE_UNSPECIFIED",
		2: "PENDING",
		3: "RUNNING",
		4: "SUCCEEDED",
		5: "FAILED",
		6: "CANCELLED",
	}
	TransferState_value = map[string]int32{
		"TRANSFER_STATE_UNSPECIFIED": 0,
		"PENDING":                    2,
		"RUNNING":                    3,
		"SUCCEEDED":                  4,
		"FAILED":                     5,
		"CANCELLED":                  6,
	}
)

var (
	TransferMessage_MessageSeverity_name = map[int32]string{
		0: "MESSAGE_SEVERITY_UNSPECIFIED",
		1: "INFO",
		2: "WARNING",
		3: "ERROR",
	}
	TransferMessage_MessageSeverity_value = map[string]int32{
		"MESSAGE_SEVERITY_UNSPECIFIED": 0,
		"INFO":                         1,
		"WARNING":                      2,
		"ERROR":                        3,
	}
)

var File_google_cloud_bigquery_datatransfer_v1_datatransfer_proto protoreflect.FileDescriptor

var File_google_cloud_bigquery_datatransfer_v1_transfer_proto protoreflect.FileDescriptor

func RegisterDataTransferServiceServer(s *grpc.Server, srv DataTransferServiceServer)

type CheckValidCredsRequest struct {

	// Required. The data source in the form:
	// `projects/{project_id}/dataSources/{data_source_id}` or
	// `projects/{project_id}/locations/{location_id}/dataSources/{data_source_id}`.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

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

func (x *CheckValidCredsRequest) GetName() string

func (*CheckValidCredsRequest) ProtoMessage()

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

func (x *CheckValidCredsRequest) Reset()

func (x *CheckValidCredsRequest) String() string

type CheckValidCredsResponse struct {

	// If set to `true`, the credentials exist and are valid.
	HasValidCreds bool `protobuf:"varint,1,opt,name=has_valid_creds,json=hasValidCreds,proto3" json:"has_valid_creds,omitempty"`
	// contains filtered or unexported fields
}

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

func (x *CheckValidCredsResponse) GetHasValidCreds() bool

func (*CheckValidCredsResponse) ProtoMessage()

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

func (x *CheckValidCredsResponse) Reset()

func (x *CheckValidCredsResponse) String() string

type CreateTransferConfigRequest struct {

	// Required. The BigQuery project id where the transfer configuration should
	// be created. Must be in the format
	// projects/{project_id}/locations/{location_id} or projects/{project_id}. If
	// specified location and location of the destination bigquery dataset do not
	// match - the request will fail.
	Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
	// Required. Data transfer configuration to create.
	TransferConfig *TransferConfig `protobuf:"bytes,2,opt,name=transfer_config,json=transferConfig,proto3" json:"transfer_config,omitempty"`
	// Optional OAuth2 authorization code to use with this transfer configuration.
	// This is required only if `transferConfig.dataSourceId` is 'youtube_channel'
	// and new credentials are needed, as indicated by `CheckValidCreds`. In order
	// to obtain authorization_code, make a request to the following URL:
	// 
	// https://www.gstatic.com/bigquerydatatransfer/oauthz/auth?redirect_uri=urn:ietf:wg:oauth:2.0:oob&response_type=authorization_code&client_id=client_id&scope=data_source_scopes
	// 
	// * The client_id is the OAuth client_id of the a data source as
	// returned by ListDataSources method.
	// * data_source_scopes are the scopes returned by ListDataSources
	// method.
	//
	// Note that this should not be set when `service_account_name` is used to
	// create the transfer config.
	AuthorizationCode string `protobuf:"bytes,3,opt,name=authorization_code,json=authorizationCode,proto3" json:"authorization_code,omitempty"`
	// Optional version info. This is required only if
	// `transferConfig.dataSourceId` is not 'youtube_channel' and new credentials
	// are needed, as indicated by `CheckValidCreds`. In order to obtain version
	// info, make a request to the following URL:
	// 
	// https://www.gstatic.com/bigquerydatatransfer/oauthz/auth?redirect_uri=urn:ietf:wg:oauth:2.0:oob&response_type=version_info&client_id=client_id&scope=data_source_scopes
	// 
	// * The client_id is the OAuth client_id of the a data source as
	// returned by ListDataSources method.
	// * data_source_scopes are the scopes returned by ListDataSources
	// method.
	//
	// Note that this should not be set when `service_account_name` is used to
	// create the transfer config.
	VersionInfo string `protobuf:"bytes,5,opt,name=version_info,json=versionInfo,proto3" json:"version_info,omitempty"`
	// Optional service account email. If this field is set, the transfer config
	// will be created with this service account's credentials. It requires that
	// the requesting user calling this API has permissions to act as this service
	// account.
	//
	// Note that not all data sources support service account credentials when
	// creating a transfer config. For the latest list of data sources, read about
	// [using service
	// accounts](https://cloud.google.com/bigquery-transfer/docs/use-service-accounts).
	ServiceAccountName string `protobuf:"bytes,6,opt,name=service_account_name,json=serviceAccountName,proto3" json:"service_account_name,omitempty"`
	// contains filtered or unexported fields
}

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

func (x *CreateTransferConfigRequest) GetAuthorizationCode() string

func (x *CreateTransferConfigRequest) GetParent() string

func (x *CreateTransferConfigRequest) GetServiceAccountName() string

func (x *CreateTransferConfigRequest) GetTransferConfig() *TransferConfig

func (x *CreateTransferConfigRequest) GetVersionInfo() string

func (*CreateTransferConfigRequest) ProtoMessage()

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

func (x *CreateTransferConfigRequest) Reset()

func (x *CreateTransferConfigRequest) String() string

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

	DataSourceId string `protobuf:"bytes,2,opt,name=data_source_id,json=dataSourceId,proto3" json:"data_source_id,omitempty"`

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

	Description string `protobuf:"bytes,4,opt,name=description,proto3" json:"description,omitempty"`

	ClientId string `protobuf:"bytes,5,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"`

	Scopes []string `protobuf:"bytes,6,rep,name=scopes,proto3" json:"scopes,omitempty"`

	TransferType TransferType "" /* 154 byte string literal not displayed */

	SupportsMultipleTransfers bool "" /* 139 byte string literal not displayed */

	UpdateDeadlineSeconds int32 "" /* 127 byte string literal not displayed */

	DefaultSchedule string `protobuf:"bytes,10,opt,name=default_schedule,json=defaultSchedule,proto3" json:"default_schedule,omitempty"`

	SupportsCustomSchedule bool "" /* 131 byte string literal not displayed */

	Parameters []*DataSourceParameter `protobuf:"bytes,12,rep,name=parameters,proto3" json:"parameters,omitempty"`

	HelpUrl string `protobuf:"bytes,13,opt,name=help_url,json=helpUrl,proto3" json:"help_url,omitempty"`

	AuthorizationType DataSource_AuthorizationType "" /* 186 byte string literal not displayed */

	DataRefreshType DataSource_DataRefreshType "" /* 180 byte string literal not displayed */

	DefaultDataRefreshWindowDays int32 "" /* 153 byte string literal not displayed */

	ManualRunsDisabled bool `protobuf:"varint,17,opt,name=manual_runs_disabled,json=manualRunsDisabled,proto3" json:"manual_runs_disabled,omitempty"`

	MinimumScheduleInterval *durationpb.Duration "" /* 133 byte string literal not displayed */

}

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

func (x *DataSource) GetAuthorizationType() DataSource_AuthorizationType

func (x *DataSource) GetClientId() string

func (x *DataSource) GetDataRefreshType() DataSource_DataRefreshType

func (x *DataSource) GetDataSourceId() string

func (x *DataSource) GetDefaultDataRefreshWindowDays() int32

func (x *DataSource) GetDefaultSchedule() string

func (x *DataSource) GetDescription() string

func (x *DataSource) GetDisplayName() string

func (x *DataSource) GetHelpUrl() string

func (x *DataSource) GetManualRunsDisabled() bool

func (x *DataSource) GetMinimumScheduleInterval() *durationpb.Duration

func (x *DataSource) GetName() string

func (x *DataSource) GetParameters() []*DataSourceParameter

func (x *DataSource) GetScopes() []string

func (x *DataSource) GetSupportsCustomSchedule() bool

func (x *DataSource) GetSupportsMultipleTransfers() bool

func (x *DataSource) GetTransferType() TransferType

func (x *DataSource) GetUpdateDeadlineSeconds() int32

func (*DataSource) ProtoMessage()

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

func (x *DataSource) Reset()

func (x *DataSource) String() string

type DataSourceParameter struct {
	ParamId string `protobuf:"bytes,1,opt,name=param_id,json=paramId,proto3" json:"param_id,omitempty"`

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

	Description string `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`

	Type DataSourceParameter_Type "" /* 130 byte string literal not displayed */

	Required bool `protobuf:"varint,5,opt,name=required,proto3" json:"required,omitempty"`

	Repeated bool `protobuf:"varint,6,opt,name=repeated,proto3" json:"repeated,omitempty"`

	ValidationRegex string `protobuf:"bytes,7,opt,name=validation_regex,json=validationRegex,proto3" json:"validation_regex,omitempty"`

	AllowedValues []string `protobuf:"bytes,8,rep,name=allowed_values,json=allowedValues,proto3" json:"allowed_values,omitempty"`

	MinValue *wrapperspb.DoubleValue `protobuf:"bytes,9,opt,name=min_value,json=minValue,proto3" json:"min_value,omitempty"`

	MaxValue *wrapperspb.DoubleValue `protobuf:"bytes,10,opt,name=max_value,json=maxValue,proto3" json:"max_value,omitempty"`

	Fields []*DataSourceParameter `protobuf:"bytes,11,rep,name=fields,proto3" json:"fields,omitempty"`

	ValidationDescription string `protobuf:"bytes,12,opt,name=validation_description,json=validationDescription,proto3" json:"validation_description,omitempty"`

	ValidationHelpUrl string `protobuf:"bytes,13,opt,name=validation_help_url,json=validationHelpUrl,proto3" json:"validation_help_url,omitempty"`

	Immutable bool `protobuf:"varint,14,opt,name=immutable,proto3" json:"immutable,omitempty"`

	Recurse bool `protobuf:"varint,15,opt,name=recurse,proto3" json:"recurse,omitempty"`

	Deprecated bool `protobuf:"varint,20,opt,name=deprecated,proto3" json:"deprecated,omitempty"`

}

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

func (x *DataSourceParameter) GetAllowedValues() []string

func (x *DataSourceParameter) GetDeprecated() bool

func (x *DataSourceParameter) GetDescription() string

func (x *DataSourceParameter) GetDisplayName() string

func (x *DataSourceParameter) GetFields() []*DataSourceParameter

func (x *DataSourceParameter) GetImmutable() bool

func (x *DataSourceParameter) GetMaxValue() *wrapperspb.DoubleValue

func (x *DataSourceParameter) GetMinValue() *wrapperspb.DoubleValue

func (x *DataSourceParameter) GetParamId() string

func (x *DataSourceParameter) GetRecurse() bool

func (x *DataSourceParameter) GetRepeated() bool

func (x *DataSourceParameter) GetRequired() bool

func (x *DataSourceParameter) GetType() DataSourceParameter_Type

func (x *DataSourceParameter) GetValidationDescription() string

func (x *DataSourceParameter) GetValidationHelpUrl() string

func (x *DataSourceParameter) GetValidationRegex() string

func (*DataSourceParameter) ProtoMessage()

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

func (x *DataSourceParameter) Reset()

func (x *DataSourceParameter) String() string

type DataSourceParameter_Type int32

const (
	// Type unspecified.
	DataSourceParameter_TYPE_UNSPECIFIED DataSourceParameter_Type = 0
	// String parameter.
	DataSourceParameter_STRING DataSourceParameter_Type = 1
	// Integer parameter (64-bits).
	// Will be serialized to json as string.
	DataSourceParameter_INTEGER DataSourceParameter_Type = 2
	// Double precision floating point parameter.
	DataSourceParameter_DOUBLE DataSourceParameter_Type = 3
	// Boolean parameter.
	DataSourceParameter_BOOLEAN DataSourceParameter_Type = 4
	// Deprecated. This field has no effect.
	DataSourceParameter_RECORD DataSourceParameter_Type = 5
	// Page ID for a Google+ Page.
	DataSourceParameter_PLUS_PAGE DataSourceParameter_Type = 6
)

func (DataSourceParameter_Type) Descriptor() protoreflect.EnumDescriptor

func (x DataSourceParameter_Type) Enum() *DataSourceParameter_Type

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

func (x DataSourceParameter_Type) Number() protoreflect.EnumNumber

func (x DataSourceParameter_Type) String() string

func (DataSourceParameter_Type) Type() protoreflect.EnumType

type DataSource_AuthorizationType int32

const (
	// Type unspecified.
	DataSource_AUTHORIZATION_TYPE_UNSPECIFIED DataSource_AuthorizationType = 0
	// Use OAuth 2 authorization codes that can be exchanged
	// for a refresh token on the backend.
	DataSource_AUTHORIZATION_CODE DataSource_AuthorizationType = 1
	// Return an authorization code for a given Google+ page that can then be
	// exchanged for a refresh token on the backend.
	DataSource_GOOGLE_PLUS_AUTHORIZATION_CODE DataSource_AuthorizationType = 2
	// Use First Party OAuth.
	DataSource_FIRST_PARTY_OAUTH DataSource_AuthorizationType = 3
)

func (DataSource_AuthorizationType) Descriptor() protoreflect.EnumDescriptor

func (x DataSource_AuthorizationType) Enum() *DataSource_AuthorizationType

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

func (x DataSource_AuthorizationType) Number() protoreflect.EnumNumber

func (x DataSource_AuthorizationType) String() string

func (DataSource_AuthorizationType) Type() protoreflect.EnumType

type DataSource_DataRefreshType int32

const (
	// The data source won't support data auto refresh, which is default value.
	DataSource_DATA_REFRESH_TYPE_UNSPECIFIED DataSource_DataRefreshType = 0
	// The data source supports data auto refresh, and runs will be scheduled
	// for the past few days. Does not allow custom values to be set for each
	// transfer config.
	DataSource_SLIDING_WINDOW DataSource_DataRefreshType = 1
	// The data source supports data auto refresh, and runs will be scheduled
	// for the past few days. Allows custom values to be set for each transfer
	// config.
	DataSource_CUSTOM_SLIDING_WINDOW DataSource_DataRefreshType = 2
)

func (DataSource_DataRefreshType) Descriptor() protoreflect.EnumDescriptor

func (x DataSource_DataRefreshType) Enum() *DataSource_DataRefreshType

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

func (x DataSource_DataRefreshType) Number() protoreflect.EnumNumber

func (x DataSource_DataRefreshType) String() string

func (DataSource_DataRefreshType) Type() protoreflect.EnumType

type DataTransferServiceClient interface {
	// Retrieves a supported data source and returns its settings.
	GetDataSource(ctx context.Context, in *GetDataSourceRequest, opts ...grpc.CallOption) (*DataSource, error)
	// Lists supported data sources and returns their settings.
	ListDataSources(ctx context.Context, in *ListDataSourcesRequest, opts ...grpc.CallOption) (*ListDataSourcesResponse, error)
	// Creates a new data transfer configuration.
	CreateTransferConfig(ctx context.Context, in *CreateTransferConfigRequest, opts ...grpc.CallOption) (*TransferConfig, error)
	// Updates a data transfer configuration.
	// All fields must be set, even if they are not updated.
	UpdateTransferConfig(ctx context.Context, in *UpdateTransferConfigRequest, opts ...grpc.CallOption) (*TransferConfig, error)
	// Deletes a data transfer configuration, including any associated transfer
	// runs and logs.
	DeleteTransferConfig(ctx context.Context, in *DeleteTransferConfigRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// Returns information about a data transfer config.
	GetTransferConfig(ctx context.Context, in *GetTransferConfigRequest, opts ...grpc.CallOption) (*TransferConfig, error)
	// Returns information about all transfer configs owned by a project in the
	// specified location.
	ListTransferConfigs(ctx context.Context, in *ListTransferConfigsRequest, opts ...grpc.CallOption) (*ListTransferConfigsResponse, error)
	// Deprecated: Do not use.
	// Creates transfer runs for a time range [start_time, end_time].
	// For each date - or whatever granularity the data source supports - in the
	// range, one transfer run is created.
	// Note that runs are created per UTC time in the time range.
	// DEPRECATED: use StartManualTransferRuns instead.
	ScheduleTransferRuns(ctx context.Context, in *ScheduleTransferRunsRequest, opts ...grpc.CallOption) (*ScheduleTransferRunsResponse, error)
	// Start manual transfer runs to be executed now with schedule_time equal to
	// current time. The transfer runs can be created for a time range where the
	// run_time is between start_time (inclusive) and end_time (exclusive), or for
	// a specific run_time.
	StartManualTransferRuns(ctx context.Context, in *StartManualTransferRunsRequest, opts ...grpc.CallOption) (*StartManualTransferRunsResponse, error)
	// Returns information about the particular transfer run.
	GetTransferRun(ctx context.Context, in *GetTransferRunRequest, opts ...grpc.CallOption) (*TransferRun, error)
	// Deletes the specified transfer run.
	DeleteTransferRun(ctx context.Context, in *DeleteTransferRunRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// Returns information about running and completed transfer runs.
	ListTransferRuns(ctx context.Context, in *ListTransferRunsRequest, opts ...grpc.CallOption) (*ListTransferRunsResponse, error)
	// Returns log messages for the transfer run.
	ListTransferLogs(ctx context.Context, in *ListTransferLogsRequest, opts ...grpc.CallOption) (*ListTransferLogsResponse, error)
	// Returns true if valid credentials exist for the given data source and
	// requesting user.
	CheckValidCreds(ctx context.Context, in *CheckValidCredsRequest, opts ...grpc.CallOption) (*CheckValidCredsResponse, error)
	// Enroll data sources in a user project. This allows users to create transfer
	// configurations for these data sources. They will also appear in the
	// ListDataSources RPC and as such, will appear in the
	// [BigQuery UI](https://console.cloud.google.com/bigquery), and the documents
	// can be found in the public guide for
	// [BigQuery Web UI](https://cloud.google.com/bigquery/bigquery-web-ui) and
	// [Data Transfer
	// Service](https://cloud.google.com/bigquery/docs/working-with-transfers).
	EnrollDataSources(ctx context.Context, in *EnrollDataSourcesRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
}

func NewDataTransferServiceClient(cc grpc.ClientConnInterface) DataTransferServiceClient

type DataTransferServiceServer interface {
	// Retrieves a supported data source and returns its settings.
	GetDataSource(context.Context, *GetDataSourceRequest) (*DataSource, error)
	// Lists supported data sources and returns their settings.
	ListDataSources(context.Context, *ListDataSourcesRequest) (*ListDataSourcesResponse, error)
	// Creates a new data transfer configuration.
	CreateTransferConfig(context.Context, *CreateTransferConfigRequest) (*TransferConfig, error)
	// Updates a data transfer configuration.
	// All fields must be set, even if they are not updated.
	UpdateTransferConfig(context.Context, *UpdateTransferConfigRequest) (*TransferConfig, error)
	// Deletes a data transfer configuration, including any associated transfer
	// runs and logs.
	DeleteTransferConfig(context.Context, *DeleteTransferConfigRequest) (*emptypb.Empty, error)
	// Returns information about a data transfer config.
	GetTransferConfig(context.Context, *GetTransferConfigRequest) (*TransferConfig, error)
	// Returns information about all transfer configs owned by a project in the
	// specified location.
	ListTransferConfigs(context.Context, *ListTransferConfigsRequest) (*ListTransferConfigsResponse, error)
	// Deprecated: Do not use.
	// Creates transfer runs for a time range [start_time, end_time].
	// For each date - or whatever granularity the data source supports - in the
	// range, one transfer run is created.
	// Note that runs are created per UTC time in the time range.
	// DEPRECATED: use StartManualTransferRuns instead.
	ScheduleTransferRuns(context.Context, *ScheduleTransferRunsRequest) (*ScheduleTransferRunsResponse, error)
	// Start manual transfer runs to be executed now with schedule_time equal to
	// current time. The transfer runs can be created for a time range where the
	// run_time is between start_time (inclusive) and end_time (exclusive), or for
	// a specific run_time.
	StartManualTransferRuns(context.Context, *StartManualTransferRunsRequest) (*StartManualTransferRunsResponse, error)
	// Returns information about the particular transfer run.
	GetTransferRun(context.Context, *GetTransferRunRequest) (*TransferRun, error)
	// Deletes the specified transfer run.
	DeleteTransferRun(context.Context, *DeleteTransferRunRequest) (*emptypb.Empty, error)
	// Returns information about running and completed transfer runs.
	ListTransferRuns(context.Context, *ListTransferRunsRequest) (*ListTransferRunsResponse, error)
	// Returns log messages for the transfer run.
	ListTransferLogs(context.Context, *ListTransferLogsRequest) (*ListTransferLogsResponse, error)
	// Returns true if valid credentials exist for the given data source and
	// requesting user.
	CheckValidCreds(context.Context, *CheckValidCredsRequest) (*CheckValidCredsResponse, error)
	// Enroll data sources in a user project. This allows users to create transfer
	// configurations for these data sources. They will also appear in the
	// ListDataSources RPC and as such, will appear in the
	// [BigQuery UI](https://console.cloud.google.com/bigquery), and the documents
	// can be found in the public guide for
	// [BigQuery Web UI](https://cloud.google.com/bigquery/bigquery-web-ui) and
	// [Data Transfer
	// Service](https://cloud.google.com/bigquery/docs/working-with-transfers).
	EnrollDataSources(context.Context, *EnrollDataSourcesRequest) (*emptypb.Empty, error)
}

type DeleteTransferConfigRequest struct {

	// Required. The field will contain name of the resource requested, for
	// example: `projects/{project_id}/transferConfigs/{config_id}` or
	// `projects/{project_id}/locations/{location_id}/transferConfigs/{config_id}`
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

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

func (x *DeleteTransferConfigRequest) GetName() string

func (*DeleteTransferConfigRequest) ProtoMessage()

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

func (x *DeleteTransferConfigRequest) Reset()

func (x *DeleteTransferConfigRequest) String() string

type DeleteTransferRunRequest struct {

	// Required. The field will contain name of the resource requested, for
	// example: `projects/{project_id}/transferConfigs/{config_id}/runs/{run_id}`
	// or
	// `projects/{project_id}/locations/{location_id}/transferConfigs/{config_id}/runs/{run_id}`
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

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

func (x *DeleteTransferRunRequest) GetName() string

func (*DeleteTransferRunRequest) ProtoMessage()

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

func (x *DeleteTransferRunRequest) Reset()

func (x *DeleteTransferRunRequest) String() string

type EmailPreferences struct {

	// If true, email notifications will be sent on transfer run failures.
	EnableFailureEmail bool `protobuf:"varint,1,opt,name=enable_failure_email,json=enableFailureEmail,proto3" json:"enable_failure_email,omitempty"`
	// contains filtered or unexported fields
}

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

func (x *EmailPreferences) GetEnableFailureEmail() bool

func (*EmailPreferences) ProtoMessage()

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

func (x *EmailPreferences) Reset()

func (x *EmailPreferences) String() string

type EnrollDataSourcesRequest struct {

	// The name of the project resource in the form: `projects/{project_id}`
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Data sources that are enrolled. It is required to provide at least one
	// data source id.
	DataSourceIds []string `protobuf:"bytes,2,rep,name=data_source_ids,json=dataSourceIds,proto3" json:"data_source_ids,omitempty"`
	// contains filtered or unexported fields
}

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

func (x *EnrollDataSourcesRequest) GetDataSourceIds() []string

func (x *EnrollDataSourcesRequest) GetName() string

func (*EnrollDataSourcesRequest) ProtoMessage()

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

func (x *EnrollDataSourcesRequest) Reset()

func (x *EnrollDataSourcesRequest) String() string

type GetDataSourceRequest struct {

	// Required. The field will contain name of the resource requested, for
	// example: `projects/{project_id}/dataSources/{data_source_id}` or
	// `projects/{project_id}/locations/{location_id}/dataSources/{data_source_id}`
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

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

func (x *GetDataSourceRequest) GetName() string

func (*GetDataSourceRequest) ProtoMessage()

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

func (x *GetDataSourceRequest) Reset()

func (x *GetDataSourceRequest) String() string

type GetTransferConfigRequest struct {

	// Required. The field will contain name of the resource requested, for
	// example: `projects/{project_id}/transferConfigs/{config_id}` or
	// `projects/{project_id}/locations/{location_id}/transferConfigs/{config_id}`
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

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

func (x *GetTransferConfigRequest) GetName() string

func (*GetTransferConfigRequest) ProtoMessage()

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

func (x *GetTransferConfigRequest) Reset()

func (x *GetTransferConfigRequest) String() string

type GetTransferRunRequest struct {

	// Required. The field will contain name of the resource requested, for
	// example: `projects/{project_id}/transferConfigs/{config_id}/runs/{run_id}`
	// or
	// `projects/{project_id}/locations/{location_id}/transferConfigs/{config_id}/runs/{run_id}`
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

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

func (x *GetTransferRunRequest) GetName() string

func (*GetTransferRunRequest) ProtoMessage()

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

func (x *GetTransferRunRequest) Reset()

func (x *GetTransferRunRequest) String() string

type ListDataSourcesRequest struct {

	// Required. The BigQuery project id for which data sources should be
	// returned. Must be in the form: `projects/{project_id}` or
	// `projects/{project_id}/locations/{location_id}`
	Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
	// Pagination token, which can be used to request a specific page
	// of `ListDataSourcesRequest` list results. For multiple-page
	// results, `ListDataSourcesResponse` outputs
	// a `next_page` token, which can be used as the
	// `page_token` value to request the next page of list results.
	PageToken string `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	// Page size. The default page size is the maximum value of 1000 results.
	PageSize int32 `protobuf:"varint,4,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// contains filtered or unexported fields
}

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

func (x *ListDataSourcesRequest) GetPageSize() int32

func (x *ListDataSourcesRequest) GetPageToken() string

func (x *ListDataSourcesRequest) GetParent() string

func (*ListDataSourcesRequest) ProtoMessage()

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

func (x *ListDataSourcesRequest) Reset()

func (x *ListDataSourcesRequest) String() string

type ListDataSourcesResponse struct {

	// List of supported data sources and their transfer settings.
	DataSources []*DataSource `protobuf:"bytes,1,rep,name=data_sources,json=dataSources,proto3" json:"data_sources,omitempty"`
	// Output only. The next-pagination token. For multiple-page list results,
	// this token can be used as the
	// `ListDataSourcesRequest.page_token`
	// to request the next page of list results.
	NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// contains filtered or unexported fields
}

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

func (x *ListDataSourcesResponse) GetDataSources() []*DataSource

func (x *ListDataSourcesResponse) GetNextPageToken() string

func (*ListDataSourcesResponse) ProtoMessage()

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

func (x *ListDataSourcesResponse) Reset()

func (x *ListDataSourcesResponse) String() string

type ListTransferConfigsRequest struct {

	// Required. The BigQuery project id for which transfer configs
	// should be returned: `projects/{project_id}` or
	// `projects/{project_id}/locations/{location_id}`
	Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
	// When specified, only configurations of requested data sources are returned.
	DataSourceIds []string `protobuf:"bytes,2,rep,name=data_source_ids,json=dataSourceIds,proto3" json:"data_source_ids,omitempty"`
	// Pagination token, which can be used to request a specific page
	// of `ListTransfersRequest` list results. For multiple-page
	// results, `ListTransfersResponse` outputs
	// a `next_page` token, which can be used as the
	// `page_token` value to request the next page of list results.
	PageToken string `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	// Page size. The default page size is the maximum value of 1000 results.
	PageSize int32 `protobuf:"varint,4,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// contains filtered or unexported fields
}

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

func (x *ListTransferConfigsRequest) GetDataSourceIds() []string

func (x *ListTransferConfigsRequest) GetPageSize() int32

func (x *ListTransferConfigsRequest) GetPageToken() string

func (x *ListTransferConfigsRequest) GetParent() string

func (*ListTransferConfigsRequest) ProtoMessage()

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

func (x *ListTransferConfigsRequest) Reset()

func (x *ListTransferConfigsRequest) String() string

type ListTransferConfigsResponse struct {

	// Output only. The stored pipeline transfer configurations.
	TransferConfigs []*TransferConfig `protobuf:"bytes,1,rep,name=transfer_configs,json=transferConfigs,proto3" json:"transfer_configs,omitempty"`
	// Output only. The next-pagination token. For multiple-page list results,
	// this token can be used as the
	// `ListTransferConfigsRequest.page_token`
	// to request the next page of list results.
	NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// contains filtered or unexported fields
}

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

func (x *ListTransferConfigsResponse) GetNextPageToken() string

func (x *ListTransferConfigsResponse) GetTransferConfigs() []*TransferConfig

func (*ListTransferConfigsResponse) ProtoMessage()

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

func (x *ListTransferConfigsResponse) Reset()

func (x *ListTransferConfigsResponse) String() string

type ListTransferLogsRequest struct {
	Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`

	PageToken string `protobuf:"bytes,4,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`

	PageSize int32 `protobuf:"varint,5,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`

	MessageTypes []TransferMessage_MessageSeverity "" /* 180 byte string literal not displayed */

}

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

func (x *ListTransferLogsRequest) GetMessageTypes() []TransferMessage_MessageSeverity

func (x *ListTransferLogsRequest) GetPageSize() int32

func (x *ListTransferLogsRequest) GetPageToken() string

func (x *ListTransferLogsRequest) GetParent() string

func (*ListTransferLogsRequest) ProtoMessage()

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

func (x *ListTransferLogsRequest) Reset()

func (x *ListTransferLogsRequest) String() string

type ListTransferLogsResponse struct {

	// Output only. The stored pipeline transfer messages.
	TransferMessages []*TransferMessage `protobuf:"bytes,1,rep,name=transfer_messages,json=transferMessages,proto3" json:"transfer_messages,omitempty"`
	// Output only. The next-pagination token. For multiple-page list results,
	// this token can be used as the
	// `GetTransferRunLogRequest.page_token`
	// to request the next page of list results.
	NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// contains filtered or unexported fields
}

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

func (x *ListTransferLogsResponse) GetNextPageToken() string

func (x *ListTransferLogsResponse) GetTransferMessages() []*TransferMessage

func (*ListTransferLogsResponse) ProtoMessage()

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

func (x *ListTransferLogsResponse) Reset()

func (x *ListTransferLogsResponse) String() string

type ListTransferRunsRequest struct {
	Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`

	States []TransferState "" /* 130 byte string literal not displayed */

	PageToken string `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`

	PageSize int32 `protobuf:"varint,4,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`

	RunAttempt ListTransferRunsRequest_RunAttempt "" /* 170 byte string literal not displayed */

}

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

func (x *ListTransferRunsRequest) GetPageSize() int32

func (x *ListTransferRunsRequest) GetPageToken() string

func (x *ListTransferRunsRequest) GetParent() string

func (x *ListTransferRunsRequest) GetRunAttempt() ListTransferRunsRequest_RunAttempt

func (x *ListTransferRunsRequest) GetStates() []TransferState

func (*ListTransferRunsRequest) ProtoMessage()

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

func (x *ListTransferRunsRequest) Reset()

func (x *ListTransferRunsRequest) String() string

type ListTransferRunsRequest_RunAttempt int32

const (
	// All runs should be returned.
	ListTransferRunsRequest_RUN_ATTEMPT_UNSPECIFIED ListTransferRunsRequest_RunAttempt = 0
	// Only latest run per day should be returned.
	ListTransferRunsRequest_LATEST ListTransferRunsRequest_RunAttempt = 1
)

func (ListTransferRunsRequest_RunAttempt) Descriptor() protoreflect.EnumDescriptor

func (x ListTransferRunsRequest_RunAttempt) Enum() *ListTransferRunsRequest_RunAttempt

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

func (x ListTransferRunsRequest_RunAttempt) Number() protoreflect.EnumNumber

func (x ListTransferRunsRequest_RunAttempt) String() string

func (ListTransferRunsRequest_RunAttempt) Type() protoreflect.EnumType

type ListTransferRunsResponse struct {

	// Output only. The stored pipeline transfer runs.
	TransferRuns []*TransferRun `protobuf:"bytes,1,rep,name=transfer_runs,json=transferRuns,proto3" json:"transfer_runs,omitempty"`
	// Output only. The next-pagination token. For multiple-page list results,
	// this token can be used as the
	// `ListTransferRunsRequest.page_token`
	// to request the next page of list results.
	NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// contains filtered or unexported fields
}

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

func (x *ListTransferRunsResponse) GetNextPageToken() string

func (x *ListTransferRunsResponse) GetTransferRuns() []*TransferRun

func (*ListTransferRunsResponse) ProtoMessage()

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

func (x *ListTransferRunsResponse) Reset()

func (x *ListTransferRunsResponse) String() string

type ScheduleOptions struct {
	DisableAutoScheduling bool "" /* 127 byte string literal not displayed */

	StartTime *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`

	EndTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"`

}