Documentation ¶
Overview ¶
Package bigquerydatatransfer provides access to the BigQuery Data Transfer API.
For product documentation, see: https://cloud.google.com/bigquery-transfer/
Library status ¶
These client libraries are officially supported by Google. However, this library is considered complete and is in maintenance mode. This means that we will address critical bugs and security issues but will not add any new features.
When possible, we recommend using our newer [Cloud Client Libraries for Go](https://pkg.go.dev/cloud.google.com/go) that are still actively being worked and iterated on.
Creating a client ¶
Usage example:
import "google.golang.org/api/bigquerydatatransfer/v1" ... ctx := context.Background() bigquerydatatransferService, err := bigquerydatatransfer.NewService(ctx)
In this example, Google Application Default Credentials are used for authentication. For information on how to create and obtain Application Default Credentials, see https://developers.google.com/identity/protocols/application-default-credentials.
Other authentication options ¶
By default, all available scopes (see "Constants") are used to authenticate. To restrict scopes, use google.golang.org/api/option.WithScopes:
bigquerydatatransferService, err := bigquerydatatransfer.NewService(ctx, option.WithScopes(bigquerydatatransfer.CloudPlatformReadOnlyScope))
To use an API key for authentication (note: some APIs do not support API keys), use google.golang.org/api/option.WithAPIKey:
bigquerydatatransferService, err := bigquerydatatransfer.NewService(ctx, option.WithAPIKey("AIza..."))
To use an OAuth token (e.g., a user token obtained via a three-legged OAuth flow, use google.golang.org/api/option.WithTokenSource:
config := &oauth2.Config{...} // ... token, err := config.Exchange(ctx, ...) bigquerydatatransferService, err := bigquerydatatransfer.NewService(ctx, option.WithTokenSource(config.TokenSource(ctx, token)))
See google.golang.org/api/option.ClientOption for details on options.
Index ¶
- Constants
- type CheckValidCredsRequest
- type CheckValidCredsResponse
- type DataSource
- type DataSourceParameter
- type EmailPreferences
- type Empty
- type EncryptionConfiguration
- type EnrollDataSourcesRequest
- type ListDataSourcesResponse
- type ListLocationsResponse
- type ListTransferConfigsResponse
- type ListTransferLogsResponse
- type ListTransferRunsResponse
- type Location
- type ProjectsDataSourcesCheckValidCredsCall
- func (c *ProjectsDataSourcesCheckValidCredsCall) Context(ctx context.Context) *ProjectsDataSourcesCheckValidCredsCall
- func (c *ProjectsDataSourcesCheckValidCredsCall) Do(opts ...googleapi.CallOption) (*CheckValidCredsResponse, error)
- func (c *ProjectsDataSourcesCheckValidCredsCall) Fields(s ...googleapi.Field) *ProjectsDataSourcesCheckValidCredsCall
- func (c *ProjectsDataSourcesCheckValidCredsCall) Header() http.Header
- type ProjectsDataSourcesGetCall
- func (c *ProjectsDataSourcesGetCall) Context(ctx context.Context) *ProjectsDataSourcesGetCall
- func (c *ProjectsDataSourcesGetCall) Do(opts ...googleapi.CallOption) (*DataSource, error)
- func (c *ProjectsDataSourcesGetCall) Fields(s ...googleapi.Field) *ProjectsDataSourcesGetCall
- func (c *ProjectsDataSourcesGetCall) Header() http.Header
- func (c *ProjectsDataSourcesGetCall) IfNoneMatch(entityTag string) *ProjectsDataSourcesGetCall
- type ProjectsDataSourcesListCall
- func (c *ProjectsDataSourcesListCall) Context(ctx context.Context) *ProjectsDataSourcesListCall
- func (c *ProjectsDataSourcesListCall) Do(opts ...googleapi.CallOption) (*ListDataSourcesResponse, error)
- func (c *ProjectsDataSourcesListCall) Fields(s ...googleapi.Field) *ProjectsDataSourcesListCall
- func (c *ProjectsDataSourcesListCall) Header() http.Header
- func (c *ProjectsDataSourcesListCall) IfNoneMatch(entityTag string) *ProjectsDataSourcesListCall
- func (c *ProjectsDataSourcesListCall) PageSize(pageSize int64) *ProjectsDataSourcesListCall
- func (c *ProjectsDataSourcesListCall) PageToken(pageToken string) *ProjectsDataSourcesListCall
- func (c *ProjectsDataSourcesListCall) Pages(ctx context.Context, f func(*ListDataSourcesResponse) error) error
- type ProjectsDataSourcesService
- func (r *ProjectsDataSourcesService) CheckValidCreds(name string, checkvalidcredsrequest *CheckValidCredsRequest) *ProjectsDataSourcesCheckValidCredsCall
- func (r *ProjectsDataSourcesService) Get(name string) *ProjectsDataSourcesGetCall
- func (r *ProjectsDataSourcesService) List(parent string) *ProjectsDataSourcesListCall
- type ProjectsEnrollDataSourcesCall
- func (c *ProjectsEnrollDataSourcesCall) Context(ctx context.Context) *ProjectsEnrollDataSourcesCall
- func (c *ProjectsEnrollDataSourcesCall) Do(opts ...googleapi.CallOption) (*Empty, error)
- func (c *ProjectsEnrollDataSourcesCall) Fields(s ...googleapi.Field) *ProjectsEnrollDataSourcesCall
- func (c *ProjectsEnrollDataSourcesCall) Header() http.Header
- type ProjectsLocationsDataSourcesCheckValidCredsCall
- func (c *ProjectsLocationsDataSourcesCheckValidCredsCall) Context(ctx context.Context) *ProjectsLocationsDataSourcesCheckValidCredsCall
- func (c *ProjectsLocationsDataSourcesCheckValidCredsCall) Do(opts ...googleapi.CallOption) (*CheckValidCredsResponse, error)
- func (c *ProjectsLocationsDataSourcesCheckValidCredsCall) Fields(s ...googleapi.Field) *ProjectsLocationsDataSourcesCheckValidCredsCall
- func (c *ProjectsLocationsDataSourcesCheckValidCredsCall) Header() http.Header
- type ProjectsLocationsDataSourcesGetCall
- func (c *ProjectsLocationsDataSourcesGetCall) Context(ctx context.Context) *ProjectsLocationsDataSourcesGetCall
- func (c *ProjectsLocationsDataSourcesGetCall) Do(opts ...googleapi.CallOption) (*DataSource, error)
- func (c *ProjectsLocationsDataSourcesGetCall) Fields(s ...googleapi.Field) *ProjectsLocationsDataSourcesGetCall
- func (c *ProjectsLocationsDataSourcesGetCall) Header() http.Header
- func (c *ProjectsLocationsDataSourcesGetCall) IfNoneMatch(entityTag string) *ProjectsLocationsDataSourcesGetCall
- type ProjectsLocationsDataSourcesListCall
- func (c *ProjectsLocationsDataSourcesListCall) Context(ctx context.Context) *ProjectsLocationsDataSourcesListCall
- func (c *ProjectsLocationsDataSourcesListCall) Do(opts ...googleapi.CallOption) (*ListDataSourcesResponse, error)
- func (c *ProjectsLocationsDataSourcesListCall) Fields(s ...googleapi.Field) *ProjectsLocationsDataSourcesListCall
- func (c *ProjectsLocationsDataSourcesListCall) Header() http.Header
- func (c *ProjectsLocationsDataSourcesListCall) IfNoneMatch(entityTag string) *ProjectsLocationsDataSourcesListCall
- func (c *ProjectsLocationsDataSourcesListCall) PageSize(pageSize int64) *ProjectsLocationsDataSourcesListCall
- func (c *ProjectsLocationsDataSourcesListCall) PageToken(pageToken string) *ProjectsLocationsDataSourcesListCall
- func (c *ProjectsLocationsDataSourcesListCall) Pages(ctx context.Context, f func(*ListDataSourcesResponse) error) error
- type ProjectsLocationsDataSourcesService
- func (r *ProjectsLocationsDataSourcesService) CheckValidCreds(name string, checkvalidcredsrequest *CheckValidCredsRequest) *ProjectsLocationsDataSourcesCheckValidCredsCall
- func (r *ProjectsLocationsDataSourcesService) Get(name string) *ProjectsLocationsDataSourcesGetCall
- func (r *ProjectsLocationsDataSourcesService) List(parent string) *ProjectsLocationsDataSourcesListCall
- type ProjectsLocationsEnrollDataSourcesCall
- func (c *ProjectsLocationsEnrollDataSourcesCall) Context(ctx context.Context) *ProjectsLocationsEnrollDataSourcesCall
- func (c *ProjectsLocationsEnrollDataSourcesCall) Do(opts ...googleapi.CallOption) (*Empty, error)
- func (c *ProjectsLocationsEnrollDataSourcesCall) Fields(s ...googleapi.Field) *ProjectsLocationsEnrollDataSourcesCall
- func (c *ProjectsLocationsEnrollDataSourcesCall) Header() http.Header
- type ProjectsLocationsGetCall
- func (c *ProjectsLocationsGetCall) Context(ctx context.Context) *ProjectsLocationsGetCall
- func (c *ProjectsLocationsGetCall) Do(opts ...googleapi.CallOption) (*Location, error)
- func (c *ProjectsLocationsGetCall) Fields(s ...googleapi.Field) *ProjectsLocationsGetCall
- func (c *ProjectsLocationsGetCall) Header() http.Header
- func (c *ProjectsLocationsGetCall) IfNoneMatch(entityTag string) *ProjectsLocationsGetCall
- type ProjectsLocationsListCall
- func (c *ProjectsLocationsListCall) Context(ctx context.Context) *ProjectsLocationsListCall
- func (c *ProjectsLocationsListCall) Do(opts ...googleapi.CallOption) (*ListLocationsResponse, error)
- func (c *ProjectsLocationsListCall) Fields(s ...googleapi.Field) *ProjectsLocationsListCall
- func (c *ProjectsLocationsListCall) Filter(filter string) *ProjectsLocationsListCall
- func (c *ProjectsLocationsListCall) Header() http.Header
- func (c *ProjectsLocationsListCall) IfNoneMatch(entityTag string) *ProjectsLocationsListCall
- func (c *ProjectsLocationsListCall) PageSize(pageSize int64) *ProjectsLocationsListCall
- func (c *ProjectsLocationsListCall) PageToken(pageToken string) *ProjectsLocationsListCall
- func (c *ProjectsLocationsListCall) Pages(ctx context.Context, f func(*ListLocationsResponse) error) error
- type ProjectsLocationsService
- func (r *ProjectsLocationsService) EnrollDataSources(name string, enrolldatasourcesrequest *EnrollDataSourcesRequest) *ProjectsLocationsEnrollDataSourcesCall
- func (r *ProjectsLocationsService) Get(name string) *ProjectsLocationsGetCall
- func (r *ProjectsLocationsService) List(name string) *ProjectsLocationsListCall
- type ProjectsLocationsTransferConfigsCreateCall
- func (c *ProjectsLocationsTransferConfigsCreateCall) AuthorizationCode(authorizationCode string) *ProjectsLocationsTransferConfigsCreateCall
- func (c *ProjectsLocationsTransferConfigsCreateCall) Context(ctx context.Context) *ProjectsLocationsTransferConfigsCreateCall
- func (c *ProjectsLocationsTransferConfigsCreateCall) Do(opts ...googleapi.CallOption) (*TransferConfig, error)
- func (c *ProjectsLocationsTransferConfigsCreateCall) Fields(s ...googleapi.Field) *ProjectsLocationsTransferConfigsCreateCall
- func (c *ProjectsLocationsTransferConfigsCreateCall) Header() http.Header
- func (c *ProjectsLocationsTransferConfigsCreateCall) ServiceAccountName(serviceAccountName string) *ProjectsLocationsTransferConfigsCreateCall
- func (c *ProjectsLocationsTransferConfigsCreateCall) VersionInfo(versionInfo string) *ProjectsLocationsTransferConfigsCreateCall
- type ProjectsLocationsTransferConfigsDeleteCall
- func (c *ProjectsLocationsTransferConfigsDeleteCall) Context(ctx context.Context) *ProjectsLocationsTransferConfigsDeleteCall
- func (c *ProjectsLocationsTransferConfigsDeleteCall) Do(opts ...googleapi.CallOption) (*Empty, error)
- func (c *ProjectsLocationsTransferConfigsDeleteCall) Fields(s ...googleapi.Field) *ProjectsLocationsTransferConfigsDeleteCall
- func (c *ProjectsLocationsTransferConfigsDeleteCall) Header() http.Header
- type ProjectsLocationsTransferConfigsGetCall
- func (c *ProjectsLocationsTransferConfigsGetCall) Context(ctx context.Context) *ProjectsLocationsTransferConfigsGetCall
- func (c *ProjectsLocationsTransferConfigsGetCall) Do(opts ...googleapi.CallOption) (*TransferConfig, error)
- func (c *ProjectsLocationsTransferConfigsGetCall) Fields(s ...googleapi.Field) *ProjectsLocationsTransferConfigsGetCall
- func (c *ProjectsLocationsTransferConfigsGetCall) Header() http.Header
- func (c *ProjectsLocationsTransferConfigsGetCall) IfNoneMatch(entityTag string) *ProjectsLocationsTransferConfigsGetCall
- type ProjectsLocationsTransferConfigsListCall
- func (c *ProjectsLocationsTransferConfigsListCall) Context(ctx context.Context) *ProjectsLocationsTransferConfigsListCall
- func (c *ProjectsLocationsTransferConfigsListCall) DataSourceIds(dataSourceIds ...string) *ProjectsLocationsTransferConfigsListCall
- func (c *ProjectsLocationsTransferConfigsListCall) Do(opts ...googleapi.CallOption) (*ListTransferConfigsResponse, error)
- func (c *ProjectsLocationsTransferConfigsListCall) Fields(s ...googleapi.Field) *ProjectsLocationsTransferConfigsListCall
- func (c *ProjectsLocationsTransferConfigsListCall) Header() http.Header
- func (c *ProjectsLocationsTransferConfigsListCall) IfNoneMatch(entityTag string) *ProjectsLocationsTransferConfigsListCall
- func (c *ProjectsLocationsTransferConfigsListCall) PageSize(pageSize int64) *ProjectsLocationsTransferConfigsListCall
- func (c *ProjectsLocationsTransferConfigsListCall) PageToken(pageToken string) *ProjectsLocationsTransferConfigsListCall
- func (c *ProjectsLocationsTransferConfigsListCall) Pages(ctx context.Context, f func(*ListTransferConfigsResponse) error) error
- type ProjectsLocationsTransferConfigsPatchCall
- func (c *ProjectsLocationsTransferConfigsPatchCall) AuthorizationCode(authorizationCode string) *ProjectsLocationsTransferConfigsPatchCall
- func (c *ProjectsLocationsTransferConfigsPatchCall) Context(ctx context.Context) *ProjectsLocationsTransferConfigsPatchCall
- func (c *ProjectsLocationsTransferConfigsPatchCall) Do(opts ...googleapi.CallOption) (*TransferConfig, error)
- func (c *ProjectsLocationsTransferConfigsPatchCall) Fields(s ...googleapi.Field) *ProjectsLocationsTransferConfigsPatchCall
- func (c *ProjectsLocationsTransferConfigsPatchCall) Header() http.Header
- func (c *ProjectsLocationsTransferConfigsPatchCall) ServiceAccountName(serviceAccountName string) *ProjectsLocationsTransferConfigsPatchCall
- func (c *ProjectsLocationsTransferConfigsPatchCall) UpdateMask(updateMask string) *ProjectsLocationsTransferConfigsPatchCall
- func (c *ProjectsLocationsTransferConfigsPatchCall) VersionInfo(versionInfo string) *ProjectsLocationsTransferConfigsPatchCall
- type ProjectsLocationsTransferConfigsRunsDeleteCall
- func (c *ProjectsLocationsTransferConfigsRunsDeleteCall) Context(ctx context.Context) *ProjectsLocationsTransferConfigsRunsDeleteCall
- func (c *ProjectsLocationsTransferConfigsRunsDeleteCall) Do(opts ...googleapi.CallOption) (*Empty, error)
- func (c *ProjectsLocationsTransferConfigsRunsDeleteCall) Fields(s ...googleapi.Field) *ProjectsLocationsTransferConfigsRunsDeleteCall
- func (c *ProjectsLocationsTransferConfigsRunsDeleteCall) Header() http.Header
- type ProjectsLocationsTransferConfigsRunsGetCall
- func (c *ProjectsLocationsTransferConfigsRunsGetCall) Context(ctx context.Context) *ProjectsLocationsTransferConfigsRunsGetCall
- func (c *ProjectsLocationsTransferConfigsRunsGetCall) Do(opts ...googleapi.CallOption) (*TransferRun, error)
- func (c *ProjectsLocationsTransferConfigsRunsGetCall) Fields(s ...googleapi.Field) *ProjectsLocationsTransferConfigsRunsGetCall
- func (c *ProjectsLocationsTransferConfigsRunsGetCall) Header() http.Header
- func (c *ProjectsLocationsTransferConfigsRunsGetCall) IfNoneMatch(entityTag string) *ProjectsLocationsTransferConfigsRunsGetCall
- type ProjectsLocationsTransferConfigsRunsListCall
- func (c *ProjectsLocationsTransferConfigsRunsListCall) Context(ctx context.Context) *ProjectsLocationsTransferConfigsRunsListCall
- func (c *ProjectsLocationsTransferConfigsRunsListCall) Do(opts ...googleapi.CallOption) (*ListTransferRunsResponse, error)
- func (c *ProjectsLocationsTransferConfigsRunsListCall) Fields(s ...googleapi.Field) *ProjectsLocationsTransferConfigsRunsListCall
- func (c *ProjectsLocationsTransferConfigsRunsListCall) Header() http.Header
- func (c *ProjectsLocationsTransferConfigsRunsListCall) IfNoneMatch(entityTag string) *ProjectsLocationsTransferConfigsRunsListCall
- func (c *ProjectsLocationsTransferConfigsRunsListCall) PageSize(pageSize int64) *ProjectsLocationsTransferConfigsRunsListCall
- func (c *ProjectsLocationsTransferConfigsRunsListCall) PageToken(pageToken string) *ProjectsLocationsTransferConfigsRunsListCall
- func (c *ProjectsLocationsTransferConfigsRunsListCall) Pages(ctx context.Context, f func(*ListTransferRunsResponse) error) error
- func (c *ProjectsLocationsTransferConfigsRunsListCall) RunAttempt(runAttempt string) *ProjectsLocationsTransferConfigsRunsListCall
- func (c *ProjectsLocationsTransferConfigsRunsListCall) States(states ...string) *ProjectsLocationsTransferConfigsRunsListCall
- type ProjectsLocationsTransferConfigsRunsService
- func (r *ProjectsLocationsTransferConfigsRunsService) Delete(name string) *ProjectsLocationsTransferConfigsRunsDeleteCall
- func (r *ProjectsLocationsTransferConfigsRunsService) Get(name string) *ProjectsLocationsTransferConfigsRunsGetCall
- func (r *ProjectsLocationsTransferConfigsRunsService) List(parent string) *ProjectsLocationsTransferConfigsRunsListCall
- type ProjectsLocationsTransferConfigsRunsTransferLogsListCall
- func (c *ProjectsLocationsTransferConfigsRunsTransferLogsListCall) Context(ctx context.Context) *ProjectsLocationsTransferConfigsRunsTransferLogsListCall
- func (c *ProjectsLocationsTransferConfigsRunsTransferLogsListCall) Do(opts ...googleapi.CallOption) (*ListTransferLogsResponse, error)
- func (c *ProjectsLocationsTransferConfigsRunsTransferLogsListCall) Fields(s ...googleapi.Field) *ProjectsLocationsTransferConfigsRunsTransferLogsListCall
- func (c *ProjectsLocationsTransferConfigsRunsTransferLogsListCall) Header() http.Header
- func (c *ProjectsLocationsTransferConfigsRunsTransferLogsListCall) IfNoneMatch(entityTag string) *ProjectsLocationsTransferConfigsRunsTransferLogsListCall
- func (c *ProjectsLocationsTransferConfigsRunsTransferLogsListCall) MessageTypes(messageTypes ...string) *ProjectsLocationsTransferConfigsRunsTransferLogsListCall
- func (c *ProjectsLocationsTransferConfigsRunsTransferLogsListCall) PageSize(pageSize int64) *ProjectsLocationsTransferConfigsRunsTransferLogsListCall
- func (c *ProjectsLocationsTransferConfigsRunsTransferLogsListCall) PageToken(pageToken string) *ProjectsLocationsTransferConfigsRunsTransferLogsListCall
- func (c *ProjectsLocationsTransferConfigsRunsTransferLogsListCall) Pages(ctx context.Context, f func(*ListTransferLogsResponse) error) error
- type ProjectsLocationsTransferConfigsRunsTransferLogsService
- type ProjectsLocationsTransferConfigsScheduleRunsCall
- func (c *ProjectsLocationsTransferConfigsScheduleRunsCall) Context(ctx context.Context) *ProjectsLocationsTransferConfigsScheduleRunsCall
- func (c *ProjectsLocationsTransferConfigsScheduleRunsCall) Do(opts ...googleapi.CallOption) (*ScheduleTransferRunsResponse, error)
- func (c *ProjectsLocationsTransferConfigsScheduleRunsCall) Fields(s ...googleapi.Field) *ProjectsLocationsTransferConfigsScheduleRunsCall
- func (c *ProjectsLocationsTransferConfigsScheduleRunsCall) Header() http.Header
- type ProjectsLocationsTransferConfigsService
- func (r *ProjectsLocationsTransferConfigsService) Create(parent string, transferconfig *TransferConfig) *ProjectsLocationsTransferConfigsCreateCall
- func (r *ProjectsLocationsTransferConfigsService) Delete(name string) *ProjectsLocationsTransferConfigsDeleteCall
- func (r *ProjectsLocationsTransferConfigsService) Get(name string) *ProjectsLocationsTransferConfigsGetCall
- func (r *ProjectsLocationsTransferConfigsService) List(parent string) *ProjectsLocationsTransferConfigsListCall
- func (r *ProjectsLocationsTransferConfigsService) Patch(name string, transferconfig *TransferConfig) *ProjectsLocationsTransferConfigsPatchCall
- func (r *ProjectsLocationsTransferConfigsService) ScheduleRuns(parent string, scheduletransferrunsrequest *ScheduleTransferRunsRequest) *ProjectsLocationsTransferConfigsScheduleRunsCall
- func (r *ProjectsLocationsTransferConfigsService) StartManualRuns(parent string, startmanualtransferrunsrequest *StartManualTransferRunsRequest) *ProjectsLocationsTransferConfigsStartManualRunsCall
- type ProjectsLocationsTransferConfigsStartManualRunsCall
- func (c *ProjectsLocationsTransferConfigsStartManualRunsCall) Context(ctx context.Context) *ProjectsLocationsTransferConfigsStartManualRunsCall
- func (c *ProjectsLocationsTransferConfigsStartManualRunsCall) Do(opts ...googleapi.CallOption) (*StartManualTransferRunsResponse, error)
- func (c *ProjectsLocationsTransferConfigsStartManualRunsCall) Fields(s ...googleapi.Field) *ProjectsLocationsTransferConfigsStartManualRunsCall
- func (c *ProjectsLocationsTransferConfigsStartManualRunsCall) Header() http.Header
- type ProjectsService
- type ProjectsTransferConfigsCreateCall
- func (c *ProjectsTransferConfigsCreateCall) AuthorizationCode(authorizationCode string) *ProjectsTransferConfigsCreateCall
- func (c *ProjectsTransferConfigsCreateCall) Context(ctx context.Context) *ProjectsTransferConfigsCreateCall
- func (c *ProjectsTransferConfigsCreateCall) Do(opts ...googleapi.CallOption) (*TransferConfig, error)
- func (c *ProjectsTransferConfigsCreateCall) Fields(s ...googleapi.Field) *ProjectsTransferConfigsCreateCall
- func (c *ProjectsTransferConfigsCreateCall) Header() http.Header
- func (c *ProjectsTransferConfigsCreateCall) ServiceAccountName(serviceAccountName string) *ProjectsTransferConfigsCreateCall
- func (c *ProjectsTransferConfigsCreateCall) VersionInfo(versionInfo string) *ProjectsTransferConfigsCreateCall
- type ProjectsTransferConfigsDeleteCall
- func (c *ProjectsTransferConfigsDeleteCall) Context(ctx context.Context) *ProjectsTransferConfigsDeleteCall
- func (c *ProjectsTransferConfigsDeleteCall) Do(opts ...googleapi.CallOption) (*Empty, error)
- func (c *ProjectsTransferConfigsDeleteCall) Fields(s ...googleapi.Field) *ProjectsTransferConfigsDeleteCall
- func (c *ProjectsTransferConfigsDeleteCall) Header() http.Header
- type ProjectsTransferConfigsGetCall
- func (c *ProjectsTransferConfigsGetCall) Context(ctx context.Context) *ProjectsTransferConfigsGetCall
- func (c *ProjectsTransferConfigsGetCall) Do(opts ...googleapi.CallOption) (*TransferConfig, error)
- func (c *ProjectsTransferConfigsGetCall) Fields(s ...googleapi.Field) *ProjectsTransferConfigsGetCall
- func (c *ProjectsTransferConfigsGetCall) Header() http.Header
- func (c *ProjectsTransferConfigsGetCall) IfNoneMatch(entityTag string) *ProjectsTransferConfigsGetCall
- type ProjectsTransferConfigsListCall
- func (c *ProjectsTransferConfigsListCall) Context(ctx context.Context) *ProjectsTransferConfigsListCall
- func (c *ProjectsTransferConfigsListCall) DataSourceIds(dataSourceIds ...string) *ProjectsTransferConfigsListCall
- func (c *ProjectsTransferConfigsListCall) Do(opts ...googleapi.CallOption) (*ListTransferConfigsResponse, error)
- func (c *ProjectsTransferConfigsListCall) Fields(s ...googleapi.Field) *ProjectsTransferConfigsListCall
- func (c *ProjectsTransferConfigsListCall) Header() http.Header
- func (c *ProjectsTransferConfigsListCall) IfNoneMatch(entityTag string) *ProjectsTransferConfigsListCall
- func (c *ProjectsTransferConfigsListCall) PageSize(pageSize int64) *ProjectsTransferConfigsListCall
- func (c *ProjectsTransferConfigsListCall) PageToken(pageToken string) *ProjectsTransferConfigsListCall
- func (c *ProjectsTransferConfigsListCall) Pages(ctx context.Context, f func(*ListTransferConfigsResponse) error) error
- type ProjectsTransferConfigsPatchCall
- func (c *ProjectsTransferConfigsPatchCall) AuthorizationCode(authorizationCode string) *ProjectsTransferConfigsPatchCall
- func (c *ProjectsTransferConfigsPatchCall) Context(ctx context.Context) *ProjectsTransferConfigsPatchCall
- func (c *ProjectsTransferConfigsPatchCall) Do(opts ...googleapi.CallOption) (*TransferConfig, error)
- func (c *ProjectsTransferConfigsPatchCall) Fields(s ...googleapi.Field) *ProjectsTransferConfigsPatchCall
- func (c *ProjectsTransferConfigsPatchCall) Header() http.Header
- func (c *ProjectsTransferConfigsPatchCall) ServiceAccountName(serviceAccountName string) *ProjectsTransferConfigsPatchCall
- func (c *ProjectsTransferConfigsPatchCall) UpdateMask(updateMask string) *ProjectsTransferConfigsPatchCall
- func (c *ProjectsTransferConfigsPatchCall) VersionInfo(versionInfo string) *ProjectsTransferConfigsPatchCall
- type ProjectsTransferConfigsRunsDeleteCall
- func (c *ProjectsTransferConfigsRunsDeleteCall) Context(ctx context.Context) *ProjectsTransferConfigsRunsDeleteCall
- func (c *ProjectsTransferConfigsRunsDeleteCall) Do(opts ...googleapi.CallOption) (*Empty, error)
- func (c *ProjectsTransferConfigsRunsDeleteCall) Fields(s ...googleapi.Field) *ProjectsTransferConfigsRunsDeleteCall
- func (c *ProjectsTransferConfigsRunsDeleteCall) Header() http.Header
- type ProjectsTransferConfigsRunsGetCall
- func (c *ProjectsTransferConfigsRunsGetCall) Context(ctx context.Context) *ProjectsTransferConfigsRunsGetCall
- func (c *ProjectsTransferConfigsRunsGetCall) Do(opts ...googleapi.CallOption) (*TransferRun, error)
- func (c *ProjectsTransferConfigsRunsGetCall) Fields(s ...googleapi.Field) *ProjectsTransferConfigsRunsGetCall
- func (c *ProjectsTransferConfigsRunsGetCall) Header() http.Header
- func (c *ProjectsTransferConfigsRunsGetCall) IfNoneMatch(entityTag string) *ProjectsTransferConfigsRunsGetCall
- type ProjectsTransferConfigsRunsListCall
- func (c *ProjectsTransferConfigsRunsListCall) Context(ctx context.Context) *ProjectsTransferConfigsRunsListCall
- func (c *ProjectsTransferConfigsRunsListCall) Do(opts ...googleapi.CallOption) (*ListTransferRunsResponse, error)
- func (c *ProjectsTransferConfigsRunsListCall) Fields(s ...googleapi.Field) *ProjectsTransferConfigsRunsListCall
- func (c *ProjectsTransferConfigsRunsListCall) Header() http.Header
- func (c *ProjectsTransferConfigsRunsListCall) IfNoneMatch(entityTag string) *ProjectsTransferConfigsRunsListCall
- func (c *ProjectsTransferConfigsRunsListCall) PageSize(pageSize int64) *ProjectsTransferConfigsRunsListCall
- func (c *ProjectsTransferConfigsRunsListCall) PageToken(pageToken string) *ProjectsTransferConfigsRunsListCall
- func (c *ProjectsTransferConfigsRunsListCall) Pages(ctx context.Context, f func(*ListTransferRunsResponse) error) error
- func (c *ProjectsTransferConfigsRunsListCall) RunAttempt(runAttempt string) *ProjectsTransferConfigsRunsListCall
- func (c *ProjectsTransferConfigsRunsListCall) States(states ...string) *ProjectsTransferConfigsRunsListCall
- type ProjectsTransferConfigsRunsService
- func (r *ProjectsTransferConfigsRunsService) Delete(name string) *ProjectsTransferConfigsRunsDeleteCall
- func (r *ProjectsTransferConfigsRunsService) Get(name string) *ProjectsTransferConfigsRunsGetCall
- func (r *ProjectsTransferConfigsRunsService) List(parent string) *ProjectsTransferConfigsRunsListCall
- type ProjectsTransferConfigsRunsTransferLogsListCall
- func (c *ProjectsTransferConfigsRunsTransferLogsListCall) Context(ctx context.Context) *ProjectsTransferConfigsRunsTransferLogsListCall
- func (c *ProjectsTransferConfigsRunsTransferLogsListCall) Do(opts ...googleapi.CallOption) (*ListTransferLogsResponse, error)
- func (c *ProjectsTransferConfigsRunsTransferLogsListCall) Fields(s ...googleapi.Field) *ProjectsTransferConfigsRunsTransferLogsListCall
- func (c *ProjectsTransferConfigsRunsTransferLogsListCall) Header() http.Header
- func (c *ProjectsTransferConfigsRunsTransferLogsListCall) IfNoneMatch(entityTag string) *ProjectsTransferConfigsRunsTransferLogsListCall
- func (c *ProjectsTransferConfigsRunsTransferLogsListCall) MessageTypes(messageTypes ...string) *ProjectsTransferConfigsRunsTransferLogsListCall
- func (c *ProjectsTransferConfigsRunsTransferLogsListCall) PageSize(pageSize int64) *ProjectsTransferConfigsRunsTransferLogsListCall
- func (c *ProjectsTransferConfigsRunsTransferLogsListCall) PageToken(pageToken string) *ProjectsTransferConfigsRunsTransferLogsListCall
- func (c *ProjectsTransferConfigsRunsTransferLogsListCall) Pages(ctx context.Context, f func(*ListTransferLogsResponse) error) error
- type ProjectsTransferConfigsRunsTransferLogsService
- type ProjectsTransferConfigsScheduleRunsCall
- func (c *ProjectsTransferConfigsScheduleRunsCall) Context(ctx context.Context) *ProjectsTransferConfigsScheduleRunsCall
- func (c *ProjectsTransferConfigsScheduleRunsCall) Do(opts ...googleapi.CallOption) (*ScheduleTransferRunsResponse, error)
- func (c *ProjectsTransferConfigsScheduleRunsCall) Fields(s ...googleapi.Field) *ProjectsTransferConfigsScheduleRunsCall
- func (c *ProjectsTransferConfigsScheduleRunsCall) Header() http.Header
- type ProjectsTransferConfigsService
- func (r *ProjectsTransferConfigsService) Create(parent string, transferconfig *TransferConfig) *ProjectsTransferConfigsCreateCall
- func (r *ProjectsTransferConfigsService) Delete(name string) *ProjectsTransferConfigsDeleteCall
- func (r *ProjectsTransferConfigsService) Get(name string) *ProjectsTransferConfigsGetCall
- func (r *ProjectsTransferConfigsService) List(parent string) *ProjectsTransferConfigsListCall
- func (r *ProjectsTransferConfigsService) Patch(name string, transferconfig *TransferConfig) *ProjectsTransferConfigsPatchCall
- func (r *ProjectsTransferConfigsService) ScheduleRuns(parent string, scheduletransferrunsrequest *ScheduleTransferRunsRequest) *ProjectsTransferConfigsScheduleRunsCall
- func (r *ProjectsTransferConfigsService) StartManualRuns(parent string, startmanualtransferrunsrequest *StartManualTransferRunsRequest) *ProjectsTransferConfigsStartManualRunsCall
- type ProjectsTransferConfigsStartManualRunsCall
- func (c *ProjectsTransferConfigsStartManualRunsCall) Context(ctx context.Context) *ProjectsTransferConfigsStartManualRunsCall
- func (c *ProjectsTransferConfigsStartManualRunsCall) Do(opts ...googleapi.CallOption) (*StartManualTransferRunsResponse, error)
- func (c *ProjectsTransferConfigsStartManualRunsCall) Fields(s ...googleapi.Field) *ProjectsTransferConfigsStartManualRunsCall
- func (c *ProjectsTransferConfigsStartManualRunsCall) Header() http.Header
- type ScheduleOptions
- type ScheduleTransferRunsRequest
- type ScheduleTransferRunsResponse
- type Service
- type StartManualTransferRunsRequest
- type StartManualTransferRunsResponse
- type Status
- type TimeRange
- type TransferConfig
- type TransferMessage
- type TransferRun
- type UserInfo
Constants ¶
const ( // View and manage your data in Google BigQuery and see the email // address for your Google Account BigqueryScope = "https://www.googleapis.com/auth/bigquery" // See, edit, configure, and delete your Google Cloud data and see the // email address for your Google Account. CloudPlatformScope = "https://www.googleapis.com/auth/cloud-platform" // View your data across Google Cloud services and see the email address // of your Google Account CloudPlatformReadOnlyScope = "https://www.googleapis.com/auth/cloud-platform.read-only" )
OAuth2 scopes used by this API.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type CheckValidCredsRequest ¶
type CheckValidCredsRequest struct { }
CheckValidCredsRequest: A request to determine whether the user has valid credentials. This method is used to limit the number of OAuth popups in the user interface. The user id is inferred from the API call context. If the data source has the Google+ authorization type, this method returns false, as it cannot be determined whether the credentials are already valid merely based on the user id.
type CheckValidCredsResponse ¶
type CheckValidCredsResponse struct { // HasValidCreds: If set to `true`, the credentials exist and are valid. HasValidCreds bool `json:"hasValidCreds,omitempty"` // ServerResponse contains the HTTP response code and headers from the // server. googleapi.ServerResponse `json:"-"` // ForceSendFields is a list of field names (e.g. "HasValidCreds") to // unconditionally include in API requests. By default, fields with // empty or default values are omitted from API requests. However, any // non-pointer, non-interface field appearing in ForceSendFields will be // sent to the server regardless of whether the field is empty or not. // This may be used to include empty fields in Patch requests. ForceSendFields []string `json:"-"` // NullFields is a list of field names (e.g. "HasValidCreds") to include // in API requests with the JSON null value. By default, fields with // empty values are omitted from API requests. However, any field with // an empty value appearing in NullFields will be sent to the server as // null. It is an error if a field in this list has a non-empty value. // This may be used to include null fields in Patch requests. NullFields []string `json:"-"` }
CheckValidCredsResponse: A response indicating whether the credentials exist and are valid.
func (*CheckValidCredsResponse) MarshalJSON ¶
func (s *CheckValidCredsResponse) MarshalJSON() ([]byte, error)
type DataSource ¶
type DataSource struct { // AuthorizationType: Indicates the type of authorization. // // Possible values: // "AUTHORIZATION_TYPE_UNSPECIFIED" - Type unspecified. // "AUTHORIZATION_CODE" - Use OAuth 2 authorization codes that can be // exchanged for a refresh token on the backend. // "GOOGLE_PLUS_AUTHORIZATION_CODE" - Return an authorization code for // a given Google+ page that can then be exchanged for a refresh token // on the backend. // "FIRST_PARTY_OAUTH" - Use First Party OAuth. AuthorizationType string `json:"authorizationType,omitempty"` // ClientId: Data source client id which should be used to receive // refresh token. ClientId string `json:"clientId,omitempty"` // DataRefreshType: Specifies whether the data source supports automatic // data refresh for the past few days, and how it's supported. For some // data sources, data might not be complete until a few days later, so // it's useful to refresh data automatically. // // Possible values: // "DATA_REFRESH_TYPE_UNSPECIFIED" - The data source won't support // data auto refresh, which is default value. // "SLIDING_WINDOW" - 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. // "CUSTOM_SLIDING_WINDOW" - 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. DataRefreshType string `json:"dataRefreshType,omitempty"` // DataSourceId: Data source id. DataSourceId string `json:"dataSourceId,omitempty"` // DefaultDataRefreshWindowDays: Default data refresh window on days. // Only meaningful when `data_refresh_type` = `SLIDING_WINDOW`. DefaultDataRefreshWindowDays int64 `json:"defaultDataRefreshWindowDays,omitempty"` // DefaultSchedule: Default data transfer schedule. Examples of valid // schedules include: `1st,3rd monday of month 15:30`, `every wed,fri of // jan,jun 13:15`, and `first sunday of quarter 00:00`. DefaultSchedule string `json:"defaultSchedule,omitempty"` // Description: User friendly data source description string. Description string `json:"description,omitempty"` // DisplayName: User friendly data source name. DisplayName string `json:"displayName,omitempty"` // HelpUrl: Url for the help document for this data source. HelpUrl string `json:"helpUrl,omitempty"` // ManualRunsDisabled: Disables backfilling and manual run scheduling // for the data source. ManualRunsDisabled bool `json:"manualRunsDisabled,omitempty"` // MinimumScheduleInterval: The minimum interval for scheduler to // schedule runs. MinimumScheduleInterval string `json:"minimumScheduleInterval,omitempty"` // Name: Output only. Data source resource name. Name string `json:"name,omitempty"` // Parameters: Data source parameters. Parameters []*DataSourceParameter `json:"parameters,omitempty"` // Scopes: Api auth scopes for which refresh token needs to be obtained. // These are scopes needed by a data source to prepare data and ingest // them into BigQuery, e.g., https://www.googleapis.com/auth/bigquery Scopes []string `json:"scopes,omitempty"` // SupportsCustomSchedule: Specifies whether the data source supports a // user defined schedule, or operates on the default schedule. When set // to `true`, user can override default schedule. SupportsCustomSchedule bool `json:"supportsCustomSchedule,omitempty"` // SupportsMultipleTransfers: Deprecated. This field has no effect. SupportsMultipleTransfers bool `json:"supportsMultipleTransfers,omitempty"` // TransferType: Deprecated. This field has no effect. // // Possible values: // "TRANSFER_TYPE_UNSPECIFIED" - Invalid or Unknown transfer type // placeholder. // "BATCH" - Batch data transfer. // "STREAMING" - Streaming data transfer. Streaming data source // currently doesn't support multiple transfer configs per project. TransferType string `json:"transferType,omitempty"` // UpdateDeadlineSeconds: The number of seconds to wait for an update // from the data source before the Data Transfer Service marks the // transfer as FAILED. UpdateDeadlineSeconds int64 `json:"updateDeadlineSeconds,omitempty"` // ServerResponse contains the HTTP response code and headers from the // server. googleapi.ServerResponse `json:"-"` // ForceSendFields is a list of field names (e.g. "AuthorizationType") // to unconditionally include in API requests. By default, fields with // empty or default values are omitted from API requests. However, any // non-pointer, non-interface field appearing in ForceSendFields will be // sent to the server regardless of whether the field is empty or not. // This may be used to include empty fields in Patch requests. ForceSendFields []string `json:"-"` // NullFields is a list of field names (e.g. "AuthorizationType") to // include in API requests with the JSON null value. By default, fields // with empty values are omitted from API requests. However, any field // with an empty value appearing in NullFields will be sent to the // server as null. It is an error if a field in this list has a // non-empty value. This may be used to include null fields in Patch // requests. NullFields []string `json:"-"` }
DataSource: Defines the properties and custom parameters for a data source.
func (*DataSource) MarshalJSON ¶
func (s *DataSource) MarshalJSON() ([]byte, error)
type DataSourceParameter ¶
type DataSourceParameter struct { // AllowedValues: All possible values for the parameter. AllowedValues []string `json:"allowedValues,omitempty"` // Deprecated -- If true, it should not be used in new transfers, and it // should not be visible to users. Deprecated bool `json:"deprecated,omitempty"` // Description: Parameter description. Description string `json:"description,omitempty"` // DisplayName: Parameter display name in the user interface. DisplayName string `json:"displayName,omitempty"` // Fields: Deprecated. This field has no effect. Fields []*DataSourceParameter `json:"fields,omitempty"` // Immutable: Cannot be changed after initial creation. Immutable bool `json:"immutable,omitempty"` // MaxValue: For integer and double values specifies maximum allowed // value. MaxValue float64 `json:"maxValue,omitempty"` // MinValue: For integer and double values specifies minimum allowed // value. MinValue float64 `json:"minValue,omitempty"` // ParamId: Parameter identifier. ParamId string `json:"paramId,omitempty"` // Recurse: Deprecated. This field has no effect. Recurse bool `json:"recurse,omitempty"` // Repeated: Deprecated. This field has no effect. Repeated bool `json:"repeated,omitempty"` // Required: Is parameter required. Required bool `json:"required,omitempty"` // Type: Parameter type. // // Possible values: // "TYPE_UNSPECIFIED" - Type unspecified. // "STRING" - String parameter. // "INTEGER" - Integer parameter (64-bits). Will be serialized to json // as string. // "DOUBLE" - Double precision floating point parameter. // "BOOLEAN" - Boolean parameter. // "RECORD" - Deprecated. This field has no effect. // "PLUS_PAGE" - Page ID for a Google+ Page. // "LIST" - List of strings parameter. Type string `json:"type,omitempty"` // ValidationDescription: Description of the requirements for this // field, in case the user input does not fulfill the regex pattern or // min/max values. ValidationDescription string `json:"validationDescription,omitempty"` // ValidationHelpUrl: URL to a help document to further explain the // naming requirements. ValidationHelpUrl string `json:"validationHelpUrl,omitempty"` // ValidationRegex: Regular expression which can be used for parameter // validation. ValidationRegex string `json:"validationRegex,omitempty"` // ForceSendFields is a list of field names (e.g. "AllowedValues") to // unconditionally include in API requests. By default, fields with // empty or default values are omitted from API requests. However, any // non-pointer, non-interface field appearing in ForceSendFields will be // sent to the server regardless of whether the field is empty or not. // This may be used to include empty fields in Patch requests. ForceSendFields []string `json:"-"` // NullFields is a list of field names (e.g. "AllowedValues") to include // in API requests with the JSON null value. By default, fields with // empty values are omitted from API requests. However, any field with // an empty value appearing in NullFields will be sent to the server as // null. It is an error if a field in this list has a non-empty value. // This may be used to include null fields in Patch requests. NullFields []string `json:"-"` }
DataSourceParameter: A parameter used to define custom fields in a data source definition.
func (*DataSourceParameter) MarshalJSON ¶
func (s *DataSourceParameter) MarshalJSON() ([]byte, error)
func (*DataSourceParameter) UnmarshalJSON ¶
func (s *DataSourceParameter) UnmarshalJSON(data []byte) error
type EmailPreferences ¶ added in v0.18.0
type EmailPreferences struct { // EnableFailureEmail: If true, email notifications will be sent on // transfer run failures. EnableFailureEmail bool `json:"enableFailureEmail,omitempty"` // ForceSendFields is a list of field names (e.g. "EnableFailureEmail") // to unconditionally include in API requests. By default, fields with // empty or default values are omitted from API requests. However, any // non-pointer, non-interface field appearing in ForceSendFields will be // sent to the server regardless of whether the field is empty or not. // This may be used to include empty fields in Patch requests. ForceSendFields []string `json:"-"` // NullFields is a list of field names (e.g. "EnableFailureEmail") to // include in API requests with the JSON null value. By default, fields // with empty values are omitted from API requests. However, any field // with an empty value appearing in NullFields will be sent to the // server as null. It is an error if a field in this list has a // non-empty value. This may be used to include null fields in Patch // requests. NullFields []string `json:"-"` }
EmailPreferences: Represents preferences for sending email notifications for transfer run events.
func (*EmailPreferences) MarshalJSON ¶ added in v0.18.0
func (s *EmailPreferences) MarshalJSON() ([]byte, error)
type Empty ¶
type Empty struct { // ServerResponse contains the HTTP response code and headers from the // server. googleapi.ServerResponse `json:"-"` }
Empty: A generic empty message that you can re-use to avoid defining duplicated empty messages in your APIs. A typical example is to use it as the request or the response type of an API method. For instance: service Foo { rpc Bar(google.protobuf.Empty) returns (google.protobuf.Empty); }
type EncryptionConfiguration ¶ added in v0.135.0
type EncryptionConfiguration struct { // KmsKeyName: The name of the KMS key used for encrypting BigQuery // data. KmsKeyName string `json:"kmsKeyName,omitempty"` // ForceSendFields is a list of field names (e.g. "KmsKeyName") to // unconditionally include in API requests. By default, fields with // empty or default values are omitted from API requests. However, any // non-pointer, non-interface field appearing in ForceSendFields will be // sent to the server regardless of whether the field is empty or not. // This may be used to include empty fields in Patch requests. ForceSendFields []string `json:"-"` // NullFields is a list of field names (e.g. "KmsKeyName") to include in // API requests with the JSON null value. By default, fields with empty // values are omitted from API requests. However, any field with an // empty value appearing in NullFields will be sent to the server as // null. It is an error if a field in this list has a non-empty value. // This may be used to include null fields in Patch requests. NullFields []string `json:"-"` }
EncryptionConfiguration: Represents the encryption configuration for a transfer.
func (*EncryptionConfiguration) MarshalJSON ¶ added in v0.135.0
func (s *EncryptionConfiguration) MarshalJSON() ([]byte, error)
type EnrollDataSourcesRequest ¶ added in v0.55.0
type EnrollDataSourcesRequest struct { // DataSourceIds: Data sources that are enrolled. It is required to // provide at least one data source id. DataSourceIds []string `json:"dataSourceIds,omitempty"` // ForceSendFields is a list of field names (e.g. "DataSourceIds") to // unconditionally include in API requests. By default, fields with // empty or default values are omitted from API requests. However, any // non-pointer, non-interface field appearing in ForceSendFields will be // sent to the server regardless of whether the field is empty or not. // This may be used to include empty fields in Patch requests. ForceSendFields []string `json:"-"` // NullFields is a list of field names (e.g. "DataSourceIds") to include // in API requests with the JSON null value. By default, fields with // empty values are omitted from API requests. However, any field with // an empty value appearing in NullFields will be sent to the server as // null. It is an error if a field in this list has a non-empty value. // This may be used to include null fields in Patch requests. NullFields []string `json:"-"` }
EnrollDataSourcesRequest: A request to enroll a set of data sources so they are visible in the BigQuery UI's `Transfer` tab.
func (*EnrollDataSourcesRequest) MarshalJSON ¶ added in v0.55.0
func (s *EnrollDataSourcesRequest) MarshalJSON() ([]byte, error)
type ListDataSourcesResponse ¶
type ListDataSourcesResponse struct { // DataSources: List of supported data sources and their transfer // settings. DataSources []*DataSource `json:"dataSources,omitempty"` // NextPageToken: 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 `json:"nextPageToken,omitempty"` // ServerResponse contains the HTTP response code and headers from the // server. googleapi.ServerResponse `json:"-"` // ForceSendFields is a list of field names (e.g. "DataSources") to // unconditionally include in API requests. By default, fields with // empty or default values are omitted from API requests. However, any // non-pointer, non-interface field appearing in ForceSendFields will be // sent to the server regardless of whether the field is empty or not. // This may be used to include empty fields in Patch requests. ForceSendFields []string `json:"-"` // NullFields is a list of field names (e.g. "DataSources") to include // in API requests with the JSON null value. By default, fields with // empty values are omitted from API requests. However, any field with // an empty value appearing in NullFields will be sent to the server as // null. It is an error if a field in this list has a non-empty value. // This may be used to include null fields in Patch requests. NullFields []string `json:"-"` }
ListDataSourcesResponse: Returns list of supported data sources and their metadata.
func (*ListDataSourcesResponse) MarshalJSON ¶
func (s *ListDataSourcesResponse) MarshalJSON() ([]byte, error)
type ListLocationsResponse ¶
type ListLocationsResponse struct { // Locations: A list of locations that matches the specified filter in // the request. Locations []*Location `json:"locations,omitempty"` // NextPageToken: The standard List next-page token. NextPageToken string `json:"nextPageToken,omitempty"` // ServerResponse contains the HTTP response code and headers from the // server. googleapi.ServerResponse `json:"-"` // ForceSendFields is a list of field names (e.g. "Locations") to // unconditionally include in API requests. By default, fields with // empty or default values are omitted from API requests. However, any // non-pointer, non-interface field appearing in ForceSendFields will be // sent to the server regardless of whether the field is empty or not. // This may be used to include empty fields in Patch requests. ForceSendFields []string `json:"-"` // NullFields is a list of field names (e.g. "Locations") to include in // API requests with the JSON null value. By default, fields with empty // values are omitted from API requests. However, any field with an // empty value appearing in NullFields will be sent to the server as // null. It is an error if a field in this list has a non-empty value. // This may be used to include null fields in Patch requests. NullFields []string `json:"-"` }
ListLocationsResponse: The response message for Locations.ListLocations.
func (*ListLocationsResponse) MarshalJSON ¶
func (s *ListLocationsResponse) MarshalJSON() ([]byte, error)
type ListTransferConfigsResponse ¶
type ListTransferConfigsResponse struct { // NextPageToken: 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 `json:"nextPageToken,omitempty"` // TransferConfigs: Output only. The stored pipeline transfer // configurations. TransferConfigs []*TransferConfig `json:"transferConfigs,omitempty"` // ServerResponse contains the HTTP response code and headers from the // server. googleapi.ServerResponse `json:"-"` // ForceSendFields is a list of field names (e.g. "NextPageToken") to // unconditionally include in API requests. By default, fields with // empty or default values are omitted from API requests. However, any // non-pointer, non-interface field appearing in ForceSendFields will be // sent to the server regardless of whether the field is empty or not. // This may be used to include empty fields in Patch requests. ForceSendFields []string `json:"-"` // NullFields is a list of field names (e.g. "NextPageToken") to include // in API requests with the JSON null value. By default, fields with // empty values are omitted from API requests. However, any field with // an empty value appearing in NullFields will be sent to the server as // null. It is an error if a field in this list has a non-empty value. // This may be used to include null fields in Patch requests. NullFields []string `json:"-"` }
ListTransferConfigsResponse: The returned list of pipelines in the project.
func (*ListTransferConfigsResponse) MarshalJSON ¶
func (s *ListTransferConfigsResponse) MarshalJSON() ([]byte, error)
type ListTransferLogsResponse ¶
type ListTransferLogsResponse struct { // NextPageToken: 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 `json:"nextPageToken,omitempty"` // TransferMessages: Output only. The stored pipeline transfer messages. TransferMessages []*TransferMessage `json:"transferMessages,omitempty"` // ServerResponse contains the HTTP response code and headers from the // server. googleapi.ServerResponse `json:"-"` // ForceSendFields is a list of field names (e.g. "NextPageToken") to // unconditionally include in API requests. By default, fields with // empty or default values are omitted from API requests. However, any // non-pointer, non-interface field appearing in ForceSendFields will be // sent to the server regardless of whether the field is empty or not. // This may be used to include empty fields in Patch requests. ForceSendFields []string `json:"-"` // NullFields is a list of field names (e.g. "NextPageToken") to include // in API requests with the JSON null value. By default, fields with // empty values are omitted from API requests. However, any field with // an empty value appearing in NullFields will be sent to the server as // null. It is an error if a field in this list has a non-empty value. // This may be used to include null fields in Patch requests. NullFields []string `json:"-"` }
ListTransferLogsResponse: The returned list transfer run messages.
func (*ListTransferLogsResponse) MarshalJSON ¶
func (s *ListTransferLogsResponse) MarshalJSON() ([]byte, error)
type ListTransferRunsResponse ¶
type ListTransferRunsResponse struct { // NextPageToken: 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 `json:"nextPageToken,omitempty"` // TransferRuns: Output only. The stored pipeline transfer runs. TransferRuns []*TransferRun `json:"transferRuns,omitempty"` // ServerResponse contains the HTTP response code and headers from the // server. googleapi.ServerResponse `json:"-"` // ForceSendFields is a list of field names (e.g. "NextPageToken") to // unconditionally include in API requests. By default, fields with // empty or default values are omitted from API requests. However, any // non-pointer, non-interface field appearing in ForceSendFields will be // sent to the server regardless of whether the field is empty or not. // This may be used to include empty fields in Patch requests. ForceSendFields []string `json:"-"` // NullFields is a list of field names (e.g. "NextPageToken") to include // in API requests with the JSON null value. By default, fields with // empty values are omitted from API requests. However, any field with // an empty value appearing in NullFields will be sent to the server as // null. It is an error if a field in this list has a non-empty value. // This may be used to include null fields in Patch requests. NullFields []string `json:"-"` }
ListTransferRunsResponse: The returned list of pipelines in the project.
func (*ListTransferRunsResponse) MarshalJSON ¶
func (s *ListTransferRunsResponse) MarshalJSON() ([]byte, error)
type Location ¶
type Location struct { // DisplayName: The friendly name for this location, typically a nearby // city name. For example, "Tokyo". DisplayName string `json:"displayName,omitempty"` // Labels: Cross-service attributes for the location. For example // {"cloud.googleapis.com/region": "us-east1"} Labels map[string]string `json:"labels,omitempty"` // LocationId: The canonical id for this location. For example: // "us-east1". LocationId string `json:"locationId,omitempty"` // Metadata: Service-specific metadata. For example the available // capacity at the given location. Metadata googleapi.RawMessage `json:"metadata,omitempty"` // Name: Resource name for the location, which may vary between // implementations. For example: // "projects/example-project/locations/us-east1" Name string `json:"name,omitempty"` // ServerResponse contains the HTTP response code and headers from the // server. googleapi.ServerResponse `json:"-"` // ForceSendFields is a list of field names (e.g. "DisplayName") to // unconditionally include in API requests. By default, fields with // empty or default values are omitted from API requests. However, any // non-pointer, non-interface field appearing in ForceSendFields will be // sent to the server regardless of whether the field is empty or not. // This may be used to include empty fields in Patch requests. ForceSendFields []string `json:"-"` // NullFields is a list of field names (e.g. "DisplayName") to include // in API requests with the JSON null value. By default, fields with // empty values are omitted from API requests. However, any field with // an empty value appearing in NullFields will be sent to the server as // null. It is an error if a field in this list has a non-empty value. // This may be used to include null fields in Patch requests. NullFields []string `json:"-"` }
Location: A resource that represents a Google Cloud location.
func (*Location) MarshalJSON ¶
type ProjectsDataSourcesCheckValidCredsCall ¶
type ProjectsDataSourcesCheckValidCredsCall struct {
// contains filtered or unexported fields
}
func (*ProjectsDataSourcesCheckValidCredsCall) Context ¶
func (c *ProjectsDataSourcesCheckValidCredsCall) Context(ctx context.Context) *ProjectsDataSourcesCheckValidCredsCall
Context sets the context to be used in this call's Do method. Any pending HTTP request will be aborted if the provided context is canceled.
func (*ProjectsDataSourcesCheckValidCredsCall) Do ¶
func (c *ProjectsDataSourcesCheckValidCredsCall) Do(opts ...googleapi.CallOption) (*CheckValidCredsResponse, error)
Do executes the "bigquerydatatransfer.projects.dataSources.checkValidCreds" call. Exactly one of *CheckValidCredsResponse or error will be non-nil. Any non-2xx status code is an error. Response headers are in either *CheckValidCredsResponse.ServerResponse.Header or (if a response was returned at all) in error.(*googleapi.Error).Header. Use googleapi.IsNotModified to check whether the returned error was because http.StatusNotModified was returned.
func (*ProjectsDataSourcesCheckValidCredsCall) Fields ¶
func (c *ProjectsDataSourcesCheckValidCredsCall) Fields(s ...googleapi.Field) *ProjectsDataSourcesCheckValidCredsCall
Fields allows partial responses to be retrieved. See https://developers.google.com/gdata/docs/2.0/basics#PartialResponse for more information.
func (*ProjectsDataSourcesCheckValidCredsCall) Header ¶
func (c *ProjectsDataSourcesCheckValidCredsCall) Header() http.Header
Header returns an http.Header that can be modified by the caller to add HTTP headers to the request.
type ProjectsDataSourcesGetCall ¶
type ProjectsDataSourcesGetCall struct {
// contains filtered or unexported fields
}
func (*ProjectsDataSourcesGetCall) Context ¶
func (c *ProjectsDataSourcesGetCall) Context(ctx context.Context) *ProjectsDataSourcesGetCall
Context sets the context to be used in this call's Do method. Any pending HTTP request will be aborted if the provided context is canceled.
func (*ProjectsDataSourcesGetCall) Do ¶
func (c *ProjectsDataSourcesGetCall) Do(opts ...googleapi.CallOption) (*DataSource, error)
Do executes the "bigquerydatatransfer.projects.dataSources.get" call. Exactly one of *DataSource or error will be non-nil. Any non-2xx status code is an error. Response headers are in either *DataSource.ServerResponse.Header or (if a response was returned at all) in error.(*googleapi.Error).Header. Use googleapi.IsNotModified to check whether the returned error was because http.StatusNotModified was returned.
func (*ProjectsDataSourcesGetCall) Fields ¶
func (c *ProjectsDataSourcesGetCall) Fields(s ...googleapi.Field) *ProjectsDataSourcesGetCall
Fields allows partial responses to be retrieved. See https://developers.google.com/gdata/docs/2.0/basics#PartialResponse for more information.
func (*ProjectsDataSourcesGetCall) Header ¶
func (c *ProjectsDataSourcesGetCall) Header() http.Header
Header returns an http.Header that can be modified by the caller to add HTTP headers to the request.
func (*ProjectsDataSourcesGetCall) IfNoneMatch ¶
func (c *ProjectsDataSourcesGetCall) IfNoneMatch(entityTag string) *ProjectsDataSourcesGetCall
IfNoneMatch sets the optional parameter which makes the operation fail if the object's ETag matches the given value. This is useful for getting updates only after the object has changed since the last request. Use googleapi.IsNotModified to check whether the response error from Do is the result of In-None-Match.
type ProjectsDataSourcesListCall ¶
type ProjectsDataSourcesListCall struct {
// contains filtered or unexported fields
}
func (*ProjectsDataSourcesListCall) Context ¶
func (c *ProjectsDataSourcesListCall) Context(ctx context.Context) *ProjectsDataSourcesListCall
Context sets the context to be used in this call's Do method. Any pending HTTP request will be aborted if the provided context is canceled.
func (*ProjectsDataSourcesListCall) Do ¶
func (c *ProjectsDataSourcesListCall) Do(opts ...googleapi.CallOption) (*ListDataSourcesResponse, error)
Do executes the "bigquerydatatransfer.projects.dataSources.list" call. Exactly one of *ListDataSourcesResponse or error will be non-nil. Any non-2xx status code is an error. Response headers are in either *ListDataSourcesResponse.ServerResponse.Header or (if a response was returned at all) in error.(*googleapi.Error).Header. Use googleapi.IsNotModified to check whether the returned error was because http.StatusNotModified was returned.
func (*ProjectsDataSourcesListCall) Fields ¶
func (c *ProjectsDataSourcesListCall) Fields(s ...googleapi.Field) *ProjectsDataSourcesListCall
Fields allows partial responses to be retrieved. See https://developers.google.com/gdata/docs/2.0/basics#PartialResponse for more information.
func (*ProjectsDataSourcesListCall) Header ¶
func (c *ProjectsDataSourcesListCall) Header() http.Header
Header returns an http.Header that can be modified by the caller to add HTTP headers to the request.
func (*ProjectsDataSourcesListCall) IfNoneMatch ¶
func (c *ProjectsDataSourcesListCall) IfNoneMatch(entityTag string) *ProjectsDataSourcesListCall
IfNoneMatch sets the optional parameter which makes the operation fail if the object's ETag matches the given value. This is useful for getting updates only after the object has changed since the last request. Use googleapi.IsNotModified to check whether the response error from Do is the result of In-None-Match.
func (*ProjectsDataSourcesListCall) PageSize ¶
func (c *ProjectsDataSourcesListCall) PageSize(pageSize int64) *ProjectsDataSourcesListCall
PageSize sets the optional parameter "pageSize": Page size. The default page size is the maximum value of 1000 results.
func (*ProjectsDataSourcesListCall) PageToken ¶
func (c *ProjectsDataSourcesListCall) PageToken(pageToken string) *ProjectsDataSourcesListCall
PageToken sets the optional parameter "pageToken": 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.
func (*ProjectsDataSourcesListCall) Pages ¶
func (c *ProjectsDataSourcesListCall) Pages(ctx context.Context, f func(*ListDataSourcesResponse) error) error
Pages invokes f for each page of results. A non-nil error returned from f will halt the iteration. The provided context supersedes any context provided to the Context method.
type ProjectsDataSourcesService ¶
type ProjectsDataSourcesService struct {
// contains filtered or unexported fields
}
func NewProjectsDataSourcesService ¶
func NewProjectsDataSourcesService(s *Service) *ProjectsDataSourcesService
func (*ProjectsDataSourcesService) CheckValidCreds ¶
func (r *ProjectsDataSourcesService) CheckValidCreds(name string, checkvalidcredsrequest *CheckValidCredsRequest) *ProjectsDataSourcesCheckValidCredsCall
CheckValidCreds: Returns true if valid credentials exist for the given data source and requesting user.
- name: The data source in the form: `projects/{project_id}/dataSources/{data_source_id}` or `projects/{project_id}/locations/{location_id}/dataSources/{data_sou rce_id}`.
func (*ProjectsDataSourcesService) Get ¶
func (r *ProjectsDataSourcesService) Get(name string) *ProjectsDataSourcesGetCall
Get: Retrieves a supported data source and returns its settings.
- name: 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_sou rce_id}`.
func (*ProjectsDataSourcesService) List ¶
func (r *ProjectsDataSourcesService) List(parent string) *ProjectsDataSourcesListCall
List: Lists supported data sources and returns their settings.
- parent: 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}`.
type ProjectsEnrollDataSourcesCall ¶ added in v0.55.0
type ProjectsEnrollDataSourcesCall struct {
// contains filtered or unexported fields
}
func (*ProjectsEnrollDataSourcesCall) Context ¶ added in v0.55.0
func (c *ProjectsEnrollDataSourcesCall) Context(ctx context.Context) *ProjectsEnrollDataSourcesCall
Context sets the context to be used in this call's Do method. Any pending HTTP request will be aborted if the provided context is canceled.
func (*ProjectsEnrollDataSourcesCall) Do ¶ added in v0.55.0
func (c *ProjectsEnrollDataSourcesCall) Do(opts ...googleapi.CallOption) (*Empty, error)
Do executes the "bigquerydatatransfer.projects.enrollDataSources" call. Exactly one of *Empty or error will be non-nil. Any non-2xx status code is an error. Response headers are in either *Empty.ServerResponse.Header or (if a response was returned at all) in error.(*googleapi.Error).Header. Use googleapi.IsNotModified to check whether the returned error was because http.StatusNotModified was returned.
func (*ProjectsEnrollDataSourcesCall) Fields ¶ added in v0.55.0
func (c *ProjectsEnrollDataSourcesCall) Fields(s ...googleapi.Field) *ProjectsEnrollDataSourcesCall
Fields allows partial responses to be retrieved. See https://developers.google.com/gdata/docs/2.0/basics#PartialResponse for more information.
func (*ProjectsEnrollDataSourcesCall) Header ¶ added in v0.55.0
func (c *ProjectsEnrollDataSourcesCall) Header() http.Header
Header returns an http.Header that can be modified by the caller to add HTTP headers to the request.
type ProjectsLocationsDataSourcesCheckValidCredsCall ¶
type ProjectsLocationsDataSourcesCheckValidCredsCall struct {
// contains filtered or unexported fields
}
func (*ProjectsLocationsDataSourcesCheckValidCredsCall) Context ¶
func (c *ProjectsLocationsDataSourcesCheckValidCredsCall) Context(ctx context.Context) *ProjectsLocationsDataSourcesCheckValidCredsCall
Context sets the context to be used in this call's Do method. Any pending HTTP request will be aborted if the provided context is canceled.
func (*ProjectsLocationsDataSourcesCheckValidCredsCall) Do ¶
func (c *ProjectsLocationsDataSourcesCheckValidCredsCall) Do(opts ...googleapi.CallOption) (*CheckValidCredsResponse, error)
Do executes the "bigquerydatatransfer.projects.locations.dataSources.checkValidCreds" call. Exactly one of *CheckValidCredsResponse or error will be non-nil. Any non-2xx status code is an error. Response headers are in either *CheckValidCredsResponse.ServerResponse.Header or (if a response was returned at all) in error.(*googleapi.Error).Header. Use googleapi.IsNotModified to check whether the returned error was because http.StatusNotModified was returned.
func (*ProjectsLocationsDataSourcesCheckValidCredsCall) Fields ¶
func (c *ProjectsLocationsDataSourcesCheckValidCredsCall) Fields(s ...googleapi.Field) *ProjectsLocationsDataSourcesCheckValidCredsCall
Fields allows partial responses to be retrieved. See https://developers.google.com/gdata/docs/2.0/basics#PartialResponse for more information.
func (*ProjectsLocationsDataSourcesCheckValidCredsCall) Header ¶
func (c *ProjectsLocationsDataSourcesCheckValidCredsCall) Header() http.Header
Header returns an http.Header that can be modified by the caller to add HTTP headers to the request.
type ProjectsLocationsDataSourcesGetCall ¶
type ProjectsLocationsDataSourcesGetCall struct {
// contains filtered or unexported fields
}
func (*ProjectsLocationsDataSourcesGetCall) Context ¶
func (c *ProjectsLocationsDataSourcesGetCall) Context(ctx context.Context) *ProjectsLocationsDataSourcesGetCall
Context sets the context to be used in this call's Do method. Any pending HTTP request will be aborted if the provided context is canceled.
func (*ProjectsLocationsDataSourcesGetCall) Do ¶
func (c *ProjectsLocationsDataSourcesGetCall) Do(opts ...googleapi.CallOption) (*DataSource, error)
Do executes the "bigquerydatatransfer.projects.locations.dataSources.get" call. Exactly one of *DataSource or error will be non-nil. Any non-2xx status code is an error. Response headers are in either *DataSource.ServerResponse.Header or (if a response was returned at all) in error.(*googleapi.Error).Header. Use googleapi.IsNotModified to check whether the returned error was because http.StatusNotModified was returned.
func (*ProjectsLocationsDataSourcesGetCall) Fields ¶
func (c *ProjectsLocationsDataSourcesGetCall) Fields(s ...googleapi.Field) *ProjectsLocationsDataSourcesGetCall
Fields allows partial responses to be retrieved. See https://developers.google.com/gdata/docs/2.0/basics#PartialResponse for more information.
func (*ProjectsLocationsDataSourcesGetCall) Header ¶
func (c *ProjectsLocationsDataSourcesGetCall) Header() http.Header
Header returns an http.Header that can be modified by the caller to add HTTP headers to the request.
func (*ProjectsLocationsDataSourcesGetCall) IfNoneMatch ¶
func (c *ProjectsLocationsDataSourcesGetCall) IfNoneMatch(entityTag string) *ProjectsLocationsDataSourcesGetCall
IfNoneMatch sets the optional parameter which makes the operation fail if the object's ETag matches the given value. This is useful for getting updates only after the object has changed since the last request. Use googleapi.IsNotModified to check whether the response error from Do is the result of In-None-Match.
type ProjectsLocationsDataSourcesListCall ¶
type ProjectsLocationsDataSourcesListCall struct {
// contains filtered or unexported fields
}
func (*ProjectsLocationsDataSourcesListCall) Context ¶
func (c *ProjectsLocationsDataSourcesListCall) Context(ctx context.Context) *ProjectsLocationsDataSourcesListCall
Context sets the context to be used in this call's Do method. Any pending HTTP request will be aborted if the provided context is canceled.
func (*ProjectsLocationsDataSourcesListCall) Do ¶
func (c *ProjectsLocationsDataSourcesListCall) Do(opts ...googleapi.CallOption) (*ListDataSourcesResponse, error)
Do executes the "bigquerydatatransfer.projects.locations.dataSources.list" call. Exactly one of *ListDataSourcesResponse or error will be non-nil. Any non-2xx status code is an error. Response headers are in either *ListDataSourcesResponse.ServerResponse.Header or (if a response was returned at all) in error.(*googleapi.Error).Header. Use googleapi.IsNotModified to check whether the returned error was because http.StatusNotModified was returned.
func (*ProjectsLocationsDataSourcesListCall) Fields ¶
func (c *ProjectsLocationsDataSourcesListCall) Fields(s ...googleapi.Field) *ProjectsLocationsDataSourcesListCall
Fields allows partial responses to be retrieved. See https://developers.google.com/gdata/docs/2.0/basics#PartialResponse for more information.
func (*ProjectsLocationsDataSourcesListCall) Header ¶
func (c *ProjectsLocationsDataSourcesListCall) Header() http.Header
Header returns an http.Header that can be modified by the caller to add HTTP headers to the request.
func (*ProjectsLocationsDataSourcesListCall) IfNoneMatch ¶
func (c *ProjectsLocationsDataSourcesListCall) IfNoneMatch(entityTag string) *ProjectsLocationsDataSourcesListCall
IfNoneMatch sets the optional parameter which makes the operation fail if the object's ETag matches the given value. This is useful for getting updates only after the object has changed since the last request. Use googleapi.IsNotModified to check whether the response error from Do is the result of In-None-Match.
func (*ProjectsLocationsDataSourcesListCall) PageSize ¶
func (c *ProjectsLocationsDataSourcesListCall) PageSize(pageSize int64) *ProjectsLocationsDataSourcesListCall
PageSize sets the optional parameter "pageSize": Page size. The default page size is the maximum value of 1000 results.
func (*ProjectsLocationsDataSourcesListCall) PageToken ¶
func (c *ProjectsLocationsDataSourcesListCall) PageToken(pageToken string) *ProjectsLocationsDataSourcesListCall
PageToken sets the optional parameter "pageToken": 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.
func (*ProjectsLocationsDataSourcesListCall) Pages ¶
func (c *ProjectsLocationsDataSourcesListCall) Pages(ctx context.Context, f func(*ListDataSourcesResponse) error) error
Pages invokes f for each page of results. A non-nil error returned from f will halt the iteration. The provided context supersedes any context provided to the Context method.
type ProjectsLocationsDataSourcesService ¶
type ProjectsLocationsDataSourcesService struct {
// contains filtered or unexported fields
}
func NewProjectsLocationsDataSourcesService ¶
func NewProjectsLocationsDataSourcesService(s *Service) *ProjectsLocationsDataSourcesService
func (*ProjectsLocationsDataSourcesService) CheckValidCreds ¶
func (r *ProjectsLocationsDataSourcesService) CheckValidCreds(name string, checkvalidcredsrequest *CheckValidCredsRequest) *ProjectsLocationsDataSourcesCheckValidCredsCall
CheckValidCreds: Returns true if valid credentials exist for the given data source and requesting user.
- name: The data source in the form: `projects/{project_id}/dataSources/{data_source_id}` or `projects/{project_id}/locations/{location_id}/dataSources/{data_sou rce_id}`.
func (*ProjectsLocationsDataSourcesService) Get ¶
func (r *ProjectsLocationsDataSourcesService) Get(name string) *ProjectsLocationsDataSourcesGetCall
Get: Retrieves a supported data source and returns its settings.
- name: 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_sou rce_id}`.
func (*ProjectsLocationsDataSourcesService) List ¶
func (r *ProjectsLocationsDataSourcesService) List(parent string) *ProjectsLocationsDataSourcesListCall
List: Lists supported data sources and returns their settings.
- parent: 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}`.
type ProjectsLocationsEnrollDataSourcesCall ¶ added in v0.55.0
type ProjectsLocationsEnrollDataSourcesCall struct {
// contains filtered or unexported fields
}
func (*ProjectsLocationsEnrollDataSourcesCall) Context ¶ added in v0.55.0
func (c *ProjectsLocationsEnrollDataSourcesCall) Context(ctx context.Context) *ProjectsLocationsEnrollDataSourcesCall
Context sets the context to be used in this call's Do method. Any pending HTTP request will be aborted if the provided context is canceled.
func (*ProjectsLocationsEnrollDataSourcesCall) Do ¶ added in v0.55.0
func (c *ProjectsLocationsEnrollDataSourcesCall) Do(opts ...googleapi.CallOption) (*Empty, error)
Do executes the "bigquerydatatransfer.projects.locations.enrollDataSources" call. Exactly one of *Empty or error will be non-nil. Any non-2xx status code is an error. Response headers are in either *Empty.ServerResponse.Header or (if a response was returned at all) in error.(*googleapi.Error).Header. Use googleapi.IsNotModified to check whether the returned error was because http.StatusNotModified was returned.
func (*ProjectsLocationsEnrollDataSourcesCall) Fields ¶ added in v0.55.0
func (c *ProjectsLocationsEnrollDataSourcesCall) Fields(s ...googleapi.Field) *ProjectsLocationsEnrollDataSourcesCall
Fields allows partial responses to be retrieved. See https://developers.google.com/gdata/docs/2.0/basics#PartialResponse for more information.
func (*ProjectsLocationsEnrollDataSourcesCall) Header ¶ added in v0.55.0
func (c *ProjectsLocationsEnrollDataSourcesCall) Header() http.Header
Header returns an http.Header that can be modified by the caller to add HTTP headers to the request.
type ProjectsLocationsGetCall ¶
type ProjectsLocationsGetCall struct {
// contains filtered or unexported fields
}
func (*ProjectsLocationsGetCall) Context ¶
func (c *ProjectsLocationsGetCall) Context(ctx context.Context) *ProjectsLocationsGetCall
Context sets the context to be used in this call's Do method. Any pending HTTP request will be aborted if the provided context is canceled.
func (*ProjectsLocationsGetCall) Do ¶
func (c *ProjectsLocationsGetCall) Do(opts ...googleapi.CallOption) (*Location, error)
Do executes the "bigquerydatatransfer.projects.locations.get" call. Exactly one of *Location or error will be non-nil. Any non-2xx status code is an error. Response headers are in either *Location.ServerResponse.Header or (if a response was returned at all) in error.(*googleapi.Error).Header. Use googleapi.IsNotModified to check whether the returned error was because http.StatusNotModified was returned.
func (*ProjectsLocationsGetCall) Fields ¶
func (c *ProjectsLocationsGetCall) Fields(s ...googleapi.Field) *ProjectsLocationsGetCall
Fields allows partial responses to be retrieved. See https://developers.google.com/gdata/docs/2.0/basics#PartialResponse for more information.
func (*ProjectsLocationsGetCall) Header ¶
func (c *ProjectsLocationsGetCall) Header() http.Header
Header returns an http.Header that can be modified by the caller to add HTTP headers to the request.
func (*ProjectsLocationsGetCall) IfNoneMatch ¶
func (c *ProjectsLocationsGetCall) IfNoneMatch(entityTag string) *ProjectsLocationsGetCall
IfNoneMatch sets the optional parameter which makes the operation fail if the object's ETag matches the given value. This is useful for getting updates only after the object has changed since the last request. Use googleapi.IsNotModified to check whether the response error from Do is the result of In-None-Match.
type ProjectsLocationsListCall ¶
type ProjectsLocationsListCall struct {
// contains filtered or unexported fields
}
func (*ProjectsLocationsListCall) Context ¶
func (c *ProjectsLocationsListCall) Context(ctx context.Context) *ProjectsLocationsListCall
Context sets the context to be used in this call's Do method. Any pending HTTP request will be aborted if the provided context is canceled.
func (*ProjectsLocationsListCall) Do ¶
func (c *ProjectsLocationsListCall) Do(opts ...googleapi.CallOption) (*ListLocationsResponse, error)
Do executes the "bigquerydatatransfer.projects.locations.list" call. Exactly one of *ListLocationsResponse or error will be non-nil. Any non-2xx status code is an error. Response headers are in either *ListLocationsResponse.ServerResponse.Header or (if a response was returned at all) in error.(*googleapi.Error).Header. Use googleapi.IsNotModified to check whether the returned error was because http.StatusNotModified was returned.
func (*ProjectsLocationsListCall) Fields ¶
func (c *ProjectsLocationsListCall) Fields(s ...googleapi.Field) *ProjectsLocationsListCall
Fields allows partial responses to be retrieved. See https://developers.google.com/gdata/docs/2.0/basics#PartialResponse for more information.
func (*ProjectsLocationsListCall) Filter ¶
func (c *ProjectsLocationsListCall) Filter(filter string) *ProjectsLocationsListCall
Filter sets the optional parameter "filter": A filter to narrow down results to a preferred subset. The filtering language accepts strings like "displayName=tokyo", and is documented in more detail in AIP-160 (https://google.aip.dev/160).
func (*ProjectsLocationsListCall) Header ¶
func (c *ProjectsLocationsListCall) Header() http.Header
Header returns an http.Header that can be modified by the caller to add HTTP headers to the request.
func (*ProjectsLocationsListCall) IfNoneMatch ¶
func (c *ProjectsLocationsListCall) IfNoneMatch(entityTag string) *ProjectsLocationsListCall
IfNoneMatch sets the optional parameter which makes the operation fail if the object's ETag matches the given value. This is useful for getting updates only after the object has changed since the last request. Use googleapi.IsNotModified to check whether the response error from Do is the result of In-None-Match.
func (*ProjectsLocationsListCall) PageSize ¶
func (c *ProjectsLocationsListCall) PageSize(pageSize int64) *ProjectsLocationsListCall
PageSize sets the optional parameter "pageSize": The maximum number of results to return. If not set, the service selects a default.
func (*ProjectsLocationsListCall) PageToken ¶
func (c *ProjectsLocationsListCall) PageToken(pageToken string) *ProjectsLocationsListCall
PageToken sets the optional parameter "pageToken": A page token received from the `next_page_token` field in the response. Send that page token to receive the subsequent page.
func (*ProjectsLocationsListCall) Pages ¶
func (c *ProjectsLocationsListCall) Pages(ctx context.Context, f func(*ListLocationsResponse) error) error
Pages invokes f for each page of results. A non-nil error returned from f will halt the iteration. The provided context supersedes any context provided to the Context method.
type ProjectsLocationsService ¶
type ProjectsLocationsService struct { DataSources *ProjectsLocationsDataSourcesService TransferConfigs *ProjectsLocationsTransferConfigsService // contains filtered or unexported fields }
func NewProjectsLocationsService ¶
func NewProjectsLocationsService(s *Service) *ProjectsLocationsService
func (*ProjectsLocationsService) EnrollDataSources ¶ added in v0.55.0
func (r *ProjectsLocationsService) EnrollDataSources(name string, enrolldatasourcesrequest *EnrollDataSourcesRequest) *ProjectsLocationsEnrollDataSourcesCall
EnrollDataSources: 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).
- name: The name of the project resource in the form: `projects/{project_id}`.
func (*ProjectsLocationsService) Get ¶
func (r *ProjectsLocationsService) Get(name string) *ProjectsLocationsGetCall
Get: Gets information about a location.
- name: Resource name for the location.
func (*ProjectsLocationsService) List ¶
func (r *ProjectsLocationsService) List(name string) *ProjectsLocationsListCall
List: Lists information about the supported locations for this service.
- name: The resource that owns the locations collection, if applicable.
type ProjectsLocationsTransferConfigsCreateCall ¶
type ProjectsLocationsTransferConfigsCreateCall struct {
// contains filtered or unexported fields
}
func (*ProjectsLocationsTransferConfigsCreateCall) AuthorizationCode ¶
func (c *ProjectsLocationsTransferConfigsCreateCall) AuthorizationCode(authorizationCode string) *ProjectsLocationsTransferConfigsCreateCall
AuthorizationCode sets the optional parameter "authorizationCode": 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.
func (*ProjectsLocationsTransferConfigsCreateCall) Context ¶
func (c *ProjectsLocationsTransferConfigsCreateCall) Context(ctx context.Context) *ProjectsLocationsTransferConfigsCreateCall
Context sets the context to be used in this call's Do method. Any pending HTTP request will be aborted if the provided context is canceled.
func (*ProjectsLocationsTransferConfigsCreateCall) Do ¶
func (c *ProjectsLocationsTransferConfigsCreateCall) Do(opts ...googleapi.CallOption) (*TransferConfig, error)
Do executes the "bigquerydatatransfer.projects.locations.transferConfigs.create" call. Exactly one of *TransferConfig or error will be non-nil. Any non-2xx status code is an error. Response headers are in either *TransferConfig.ServerResponse.Header or (if a response was returned at all) in error.(*googleapi.Error).Header. Use googleapi.IsNotModified to check whether the returned error was because http.StatusNotModified was returned.
func (*ProjectsLocationsTransferConfigsCreateCall) Fields ¶
func (c *ProjectsLocationsTransferConfigsCreateCall) Fields(s ...googleapi.Field) *ProjectsLocationsTransferConfigsCreateCall
Fields allows partial responses to be retrieved. See https://developers.google.com/gdata/docs/2.0/basics#PartialResponse for more information.
func (*ProjectsLocationsTransferConfigsCreateCall) Header ¶
func (c *ProjectsLocationsTransferConfigsCreateCall) Header() http.Header
Header returns an http.Header that can be modified by the caller to add HTTP headers to the request.
func (*ProjectsLocationsTransferConfigsCreateCall) ServiceAccountName ¶ added in v0.14.0
func (c *ProjectsLocationsTransferConfigsCreateCall) ServiceAccountName(serviceAccountName string) *ProjectsLocationsTransferConfigsCreateCall
ServiceAccountName sets the optional parameter "serviceAccountName": 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).
func (*ProjectsLocationsTransferConfigsCreateCall) VersionInfo ¶ added in v0.2.0
func (c *ProjectsLocationsTransferConfigsCreateCall) VersionInfo(versionInfo string) *ProjectsLocationsTransferConfigsCreateCall
VersionInfo sets the optional parameter "versionInfo": 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.
type ProjectsLocationsTransferConfigsDeleteCall ¶
type ProjectsLocationsTransferConfigsDeleteCall struct {
// contains filtered or unexported fields
}
func (*ProjectsLocationsTransferConfigsDeleteCall) Context ¶
func (c *ProjectsLocationsTransferConfigsDeleteCall) Context(ctx context.Context) *ProjectsLocationsTransferConfigsDeleteCall
Context sets the context to be used in this call's Do method. Any pending HTTP request will be aborted if the provided context is canceled.
func (*ProjectsLocationsTransferConfigsDeleteCall) Do ¶
func (c *ProjectsLocationsTransferConfigsDeleteCall) Do(opts ...googleapi.CallOption) (*Empty, error)
Do executes the "bigquerydatatransfer.projects.locations.transferConfigs.delete" call. Exactly one of *Empty or error will be non-nil. Any non-2xx status code is an error. Response headers are in either *Empty.ServerResponse.Header or (if a response was returned at all) in error.(*googleapi.Error).Header. Use googleapi.IsNotModified to check whether the returned error was because http.StatusNotModified was returned.
func (*ProjectsLocationsTransferConfigsDeleteCall) Fields ¶
func (c *ProjectsLocationsTransferConfigsDeleteCall) Fields(s ...googleapi.Field) *ProjectsLocationsTransferConfigsDeleteCall
Fields allows partial responses to be retrieved. See https://developers.google.com/gdata/docs/2.0/basics#PartialResponse for more information.
func (*ProjectsLocationsTransferConfigsDeleteCall) Header ¶
func (c *ProjectsLocationsTransferConfigsDeleteCall) Header() http.Header
Header returns an http.Header that can be modified by the caller to add HTTP headers to the request.
type ProjectsLocationsTransferConfigsGetCall ¶
type ProjectsLocationsTransferConfigsGetCall struct {
// contains filtered or unexported fields
}
func (*ProjectsLocationsTransferConfigsGetCall) Context ¶
func (c *ProjectsLocationsTransferConfigsGetCall) Context(ctx context.Context) *ProjectsLocationsTransferConfigsGetCall
Context sets the context to be used in this call's Do method. Any pending HTTP request will be aborted if the provided context is canceled.
func (*ProjectsLocationsTransferConfigsGetCall) Do ¶
func (c *ProjectsLocationsTransferConfigsGetCall) Do(opts ...googleapi.CallOption) (*TransferConfig, error)
Do executes the "bigquerydatatransfer.projects.locations.transferConfigs.get" call. Exactly one of *TransferConfig or error will be non-nil. Any non-2xx status code is an error. Response headers are in either *TransferConfig.ServerResponse.Header or (if a response was returned at all) in error.(*googleapi.Error).Header. Use googleapi.IsNotModified to check whether the returned error was because http.StatusNotModified was returned.
func (*ProjectsLocationsTransferConfigsGetCall) Fields ¶
func (c *ProjectsLocationsTransferConfigsGetCall) Fields(s ...googleapi.Field) *ProjectsLocationsTransferConfigsGetCall
Fields allows partial responses to be retrieved. See https://developers.google.com/gdata/docs/2.0/basics#PartialResponse for more information.
func (*ProjectsLocationsTransferConfigsGetCall) Header ¶
func (c *ProjectsLocationsTransferConfigsGetCall) Header() http.Header
Header returns an http.Header that can be modified by the caller to add HTTP headers to the request.
func (*ProjectsLocationsTransferConfigsGetCall) IfNoneMatch ¶
func (c *ProjectsLocationsTransferConfigsGetCall) IfNoneMatch(entityTag string) *ProjectsLocationsTransferConfigsGetCall
IfNoneMatch sets the optional parameter which makes the operation fail if the object's ETag matches the given value. This is useful for getting updates only after the object has changed since the last request. Use googleapi.IsNotModified to check whether the response error from Do is the result of In-None-Match.
type ProjectsLocationsTransferConfigsListCall ¶
type ProjectsLocationsTransferConfigsListCall struct {
// contains filtered or unexported fields
}
func (*ProjectsLocationsTransferConfigsListCall) Context ¶
func (c *ProjectsLocationsTransferConfigsListCall) Context(ctx context.Context) *ProjectsLocationsTransferConfigsListCall
Context sets the context to be used in this call's Do method. Any pending HTTP request will be aborted if the provided context is canceled.
func (*ProjectsLocationsTransferConfigsListCall) DataSourceIds ¶
func (c *ProjectsLocationsTransferConfigsListCall) DataSourceIds(dataSourceIds ...string) *ProjectsLocationsTransferConfigsListCall
DataSourceIds sets the optional parameter "dataSourceIds": When specified, only configurations of requested data sources are returned.
func (*ProjectsLocationsTransferConfigsListCall) Do ¶
func (c *ProjectsLocationsTransferConfigsListCall) Do(opts ...googleapi.CallOption) (*ListTransferConfigsResponse, error)
Do executes the "bigquerydatatransfer.projects.locations.transferConfigs.list" call. Exactly one of *ListTransferConfigsResponse or error will be non-nil. Any non-2xx status code is an error. Response headers are in either *ListTransferConfigsResponse.ServerResponse.Header or (if a response was returned at all) in error.(*googleapi.Error).Header. Use googleapi.IsNotModified to check whether the returned error was because http.StatusNotModified was returned.
func (*ProjectsLocationsTransferConfigsListCall) Fields ¶
func (c *ProjectsLocationsTransferConfigsListCall) Fields(s ...googleapi.Field) *ProjectsLocationsTransferConfigsListCall
Fields allows partial responses to be retrieved. See https://developers.google.com/gdata/docs/2.0/basics#PartialResponse for more information.
func (*ProjectsLocationsTransferConfigsListCall) Header ¶
func (c *ProjectsLocationsTransferConfigsListCall) Header() http.Header
Header returns an http.Header that can be modified by the caller to add HTTP headers to the request.
func (*ProjectsLocationsTransferConfigsListCall) IfNoneMatch ¶
func (c *ProjectsLocationsTransferConfigsListCall) IfNoneMatch(entityTag string) *ProjectsLocationsTransferConfigsListCall
IfNoneMatch sets the optional parameter which makes the operation fail if the object's ETag matches the given value. This is useful for getting updates only after the object has changed since the last request. Use googleapi.IsNotModified to check whether the response error from Do is the result of In-None-Match.
func (*ProjectsLocationsTransferConfigsListCall) PageSize ¶
func (c *ProjectsLocationsTransferConfigsListCall) PageSize(pageSize int64) *ProjectsLocationsTransferConfigsListCall
PageSize sets the optional parameter "pageSize": Page size. The default page size is the maximum value of 1000 results.
func (*ProjectsLocationsTransferConfigsListCall) PageToken ¶
func (c *ProjectsLocationsTransferConfigsListCall) PageToken(pageToken string) *ProjectsLocationsTransferConfigsListCall
PageToken sets the optional parameter "pageToken": 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.
func (*ProjectsLocationsTransferConfigsListCall) Pages ¶
func (c *ProjectsLocationsTransferConfigsListCall) Pages(ctx context.Context, f func(*ListTransferConfigsResponse) error) error
Pages invokes f for each page of results. A non-nil error returned from f will halt the iteration. The provided context supersedes any context provided to the Context method.
type ProjectsLocationsTransferConfigsPatchCall ¶
type ProjectsLocationsTransferConfigsPatchCall struct {
// contains filtered or unexported fields
}
func (*ProjectsLocationsTransferConfigsPatchCall) AuthorizationCode ¶
func (c *ProjectsLocationsTransferConfigsPatchCall) AuthorizationCode(authorizationCode string) *ProjectsLocationsTransferConfigsPatchCall
AuthorizationCode sets the optional parameter "authorizationCode": 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 update the transfer config.
func (*ProjectsLocationsTransferConfigsPatchCall) Context ¶
func (c *ProjectsLocationsTransferConfigsPatchCall) Context(ctx context.Context) *ProjectsLocationsTransferConfigsPatchCall
Context sets the context to be used in this call's Do method. Any pending HTTP request will be aborted if the provided context is canceled.
func (*ProjectsLocationsTransferConfigsPatchCall) Do ¶
func (c *ProjectsLocationsTransferConfigsPatchCall) Do(opts ...googleapi.CallOption) (*TransferConfig, error)
Do executes the "bigquerydatatransfer.projects.locations.transferConfigs.patch" call. Exactly one of *TransferConfig or error will be non-nil. Any non-2xx status code is an error. Response headers are in either *TransferConfig.ServerResponse.Header or (if a response was returned at all) in error.(*googleapi.Error).Header. Use googleapi.IsNotModified to check whether the returned error was because http.StatusNotModified was returned.
func (*ProjectsLocationsTransferConfigsPatchCall) Fields ¶
func (c *ProjectsLocationsTransferConfigsPatchCall) Fields(s ...googleapi.Field) *ProjectsLocationsTransferConfigsPatchCall
Fields allows partial responses to be retrieved. See https://developers.google.com/gdata/docs/2.0/basics#PartialResponse for more information.
func (*ProjectsLocationsTransferConfigsPatchCall) Header ¶
func (c *ProjectsLocationsTransferConfigsPatchCall) Header() http.Header
Header returns an http.Header that can be modified by the caller to add HTTP headers to the request.
func (*ProjectsLocationsTransferConfigsPatchCall) ServiceAccountName ¶ added in v0.14.0
func (c *ProjectsLocationsTransferConfigsPatchCall) ServiceAccountName(serviceAccountName string) *ProjectsLocationsTransferConfigsPatchCall
ServiceAccountName sets the optional parameter "serviceAccountName": 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).
func (*ProjectsLocationsTransferConfigsPatchCall) UpdateMask ¶
func (c *ProjectsLocationsTransferConfigsPatchCall) UpdateMask(updateMask string) *ProjectsLocationsTransferConfigsPatchCall
UpdateMask sets the optional parameter "updateMask": Required. Required list of fields to be updated in this request.
func (*ProjectsLocationsTransferConfigsPatchCall) VersionInfo ¶ added in v0.2.0
func (c *ProjectsLocationsTransferConfigsPatchCall) VersionInfo(versionInfo string) *ProjectsLocationsTransferConfigsPatchCall
VersionInfo sets the optional parameter "versionInfo": 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 update the transfer config.
type ProjectsLocationsTransferConfigsRunsDeleteCall ¶
type ProjectsLocationsTransferConfigsRunsDeleteCall struct {
// contains filtered or unexported fields
}
func (*ProjectsLocationsTransferConfigsRunsDeleteCall) Context ¶
func (c *ProjectsLocationsTransferConfigsRunsDeleteCall) Context(ctx context.Context) *ProjectsLocationsTransferConfigsRunsDeleteCall
Context sets the context to be used in this call's Do method. Any pending HTTP request will be aborted if the provided context is canceled.
func (*ProjectsLocationsTransferConfigsRunsDeleteCall) Do ¶
func (c *ProjectsLocationsTransferConfigsRunsDeleteCall) Do(opts ...googleapi.CallOption) (*Empty, error)
Do executes the "bigquerydatatransfer.projects.locations.transferConfigs.runs.delete" call. Exactly one of *Empty or error will be non-nil. Any non-2xx status code is an error. Response headers are in either *Empty.ServerResponse.Header or (if a response was returned at all) in error.(*googleapi.Error).Header. Use googleapi.IsNotModified to check whether the returned error was because http.StatusNotModified was returned.
func (*ProjectsLocationsTransferConfigsRunsDeleteCall) Fields ¶
func (c *ProjectsLocationsTransferConfigsRunsDeleteCall) Fields(s ...googleapi.Field) *ProjectsLocationsTransferConfigsRunsDeleteCall
Fields allows partial responses to be retrieved. See https://developers.google.com/gdata/docs/2.0/basics#PartialResponse for more information.
func (*ProjectsLocationsTransferConfigsRunsDeleteCall) Header ¶
func (c *ProjectsLocationsTransferConfigsRunsDeleteCall) Header() http.Header
Header returns an http.Header that can be modified by the caller to add HTTP headers to the request.
type ProjectsLocationsTransferConfigsRunsGetCall ¶
type ProjectsLocationsTransferConfigsRunsGetCall struct {
// contains filtered or unexported fields
}
func (*ProjectsLocationsTransferConfigsRunsGetCall) Context ¶
func (c *ProjectsLocationsTransferConfigsRunsGetCall) Context(ctx context.Context) *ProjectsLocationsTransferConfigsRunsGetCall
Context sets the context to be used in this call's Do method. Any pending HTTP request will be aborted if the provided context is canceled.
func (*ProjectsLocationsTransferConfigsRunsGetCall) Do ¶
func (c *ProjectsLocationsTransferConfigsRunsGetCall) Do(opts ...googleapi.CallOption) (*TransferRun, error)
Do executes the "bigquerydatatransfer.projects.locations.transferConfigs.runs.get" call. Exactly one of *TransferRun or error will be non-nil. Any non-2xx status code is an error. Response headers are in either *TransferRun.ServerResponse.Header or (if a response was returned at all) in error.(*googleapi.Error).Header. Use googleapi.IsNotModified to check whether the returned error was because http.StatusNotModified was returned.
func (*ProjectsLocationsTransferConfigsRunsGetCall) Fields ¶
func (c *ProjectsLocationsTransferConfigsRunsGetCall) Fields(s ...googleapi.Field) *ProjectsLocationsTransferConfigsRunsGetCall
Fields allows partial responses to be retrieved. See https://developers.google.com/gdata/docs/2.0/basics#PartialResponse for more information.
func (*ProjectsLocationsTransferConfigsRunsGetCall) Header ¶
func (c *ProjectsLocationsTransferConfigsRunsGetCall) Header() http.Header
Header returns an http.Header that can be modified by the caller to add HTTP headers to the request.
func (*ProjectsLocationsTransferConfigsRunsGetCall) IfNoneMatch ¶
func (c *ProjectsLocationsTransferConfigsRunsGetCall) IfNoneMatch(entityTag string) *ProjectsLocationsTransferConfigsRunsGetCall
IfNoneMatch sets the optional parameter which makes the operation fail if the object's ETag matches the given value. This is useful for getting updates only after the object has changed since the last request. Use googleapi.IsNotModified to check whether the response error from Do is the result of In-None-Match.
type ProjectsLocationsTransferConfigsRunsListCall ¶
type ProjectsLocationsTransferConfigsRunsListCall struct {
// contains filtered or unexported fields
}
func (*ProjectsLocationsTransferConfigsRunsListCall) Context ¶
func (c *ProjectsLocationsTransferConfigsRunsListCall) Context(ctx context.Context) *ProjectsLocationsTransferConfigsRunsListCall
Context sets the context to be used in this call's Do method. Any pending HTTP request will be aborted if the provided context is canceled.
func (*ProjectsLocationsTransferConfigsRunsListCall) Do ¶
func (c *ProjectsLocationsTransferConfigsRunsListCall) Do(opts ...googleapi.CallOption) (*ListTransferRunsResponse, error)
Do executes the "bigquerydatatransfer.projects.locations.transferConfigs.runs.list" call. Exactly one of *ListTransferRunsResponse or error will be non-nil. Any non-2xx status code is an error. Response headers are in either *ListTransferRunsResponse.ServerResponse.Header or (if a response was returned at all) in error.(*googleapi.Error).Header. Use googleapi.IsNotModified to check whether the returned error was because http.StatusNotModified was returned.
func (*ProjectsLocationsTransferConfigsRunsListCall) Fields ¶
func (c *ProjectsLocationsTransferConfigsRunsListCall) Fields(s ...googleapi.Field) *ProjectsLocationsTransferConfigsRunsListCall
Fields allows partial responses to be retrieved. See https://developers.google.com/gdata/docs/2.0/basics#PartialResponse for more information.
func (*ProjectsLocationsTransferConfigsRunsListCall) Header ¶
func (c *ProjectsLocationsTransferConfigsRunsListCall) Header() http.Header
Header returns an http.Header that can be modified by the caller to add HTTP headers to the request.
func (*ProjectsLocationsTransferConfigsRunsListCall) IfNoneMatch ¶
func (c *ProjectsLocationsTransferConfigsRunsListCall) IfNoneMatch(entityTag string) *ProjectsLocationsTransferConfigsRunsListCall
IfNoneMatch sets the optional parameter which makes the operation fail if the object's ETag matches the given value. This is useful for getting updates only after the object has changed since the last request. Use googleapi.IsNotModified to check whether the response error from Do is the result of In-None-Match.
func (*ProjectsLocationsTransferConfigsRunsListCall) PageSize ¶
func (c *ProjectsLocationsTransferConfigsRunsListCall) PageSize(pageSize int64) *ProjectsLocationsTransferConfigsRunsListCall
PageSize sets the optional parameter "pageSize": Page size. The default page size is the maximum value of 1000 results.
func (*ProjectsLocationsTransferConfigsRunsListCall) PageToken ¶
func (c *ProjectsLocationsTransferConfigsRunsListCall) PageToken(pageToken string) *ProjectsLocationsTransferConfigsRunsListCall
PageToken sets the optional parameter "pageToken": Pagination token, which can be used to request a specific page of `ListTransferRunsRequest` list results. For multiple-page results, `ListTransferRunsResponse` outputs a `next_page` token, which can be used as the `page_token` value to request the next page of list results.
func (*ProjectsLocationsTransferConfigsRunsListCall) Pages ¶
func (c *ProjectsLocationsTransferConfigsRunsListCall) Pages(ctx context.Context, f func(*ListTransferRunsResponse) error) error
Pages invokes f for each page of results. A non-nil error returned from f will halt the iteration. The provided context supersedes any context provided to the Context method.
func (*ProjectsLocationsTransferConfigsRunsListCall) RunAttempt ¶
func (c *ProjectsLocationsTransferConfigsRunsListCall) RunAttempt(runAttempt string) *ProjectsLocationsTransferConfigsRunsListCall
RunAttempt sets the optional parameter "runAttempt": Indicates how run attempts are to be pulled.
Possible values:
"RUN_ATTEMPT_UNSPECIFIED" - All runs should be returned. "LATEST" - Only latest run per day should be returned.
func (*ProjectsLocationsTransferConfigsRunsListCall) States ¶
func (c *ProjectsLocationsTransferConfigsRunsListCall) States(states ...string) *ProjectsLocationsTransferConfigsRunsListCall
States sets the optional parameter "states": When specified, only transfer runs with requested states are returned.
Possible values:
"TRANSFER_STATE_UNSPECIFIED" - State placeholder (0). "PENDING" - Data transfer is scheduled and is waiting to be picked
up by data transfer backend (2).
"RUNNING" - Data transfer is in progress (3). "SUCCEEDED" - Data transfer completed successfully (4). "FAILED" - Data transfer failed (5). "CANCELLED" - Data transfer is cancelled (6).
type ProjectsLocationsTransferConfigsRunsService ¶
type ProjectsLocationsTransferConfigsRunsService struct { TransferLogs *ProjectsLocationsTransferConfigsRunsTransferLogsService // contains filtered or unexported fields }
func NewProjectsLocationsTransferConfigsRunsService ¶
func NewProjectsLocationsTransferConfigsRunsService(s *Service) *ProjectsLocationsTransferConfigsRunsService
func (*ProjectsLocationsTransferConfigsRunsService) Delete ¶
func (r *ProjectsLocationsTransferConfigsRunsService) Delete(name string) *ProjectsLocationsTransferConfigsRunsDeleteCall
Delete: Deletes the specified transfer run.
- name: 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/{conf ig_id}/runs/{run_id}`.
func (*ProjectsLocationsTransferConfigsRunsService) Get ¶
func (r *ProjectsLocationsTransferConfigsRunsService) Get(name string) *ProjectsLocationsTransferConfigsRunsGetCall
Get: Returns information about the particular transfer run.
- name: 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/{conf ig_id}/runs/{run_id}`.
func (*ProjectsLocationsTransferConfigsRunsService) List ¶
func (r *ProjectsLocationsTransferConfigsRunsService) List(parent string) *ProjectsLocationsTransferConfigsRunsListCall
List: Returns information about running and completed transfer runs.
- parent: Name of transfer configuration for which transfer runs should be retrieved. Format of transfer configuration resource name is: `projects/{project_id}/transferConfigs/{config_id}` or `projects/{project_id}/locations/{location_id}/transferConfigs/{conf ig_id}`.
type ProjectsLocationsTransferConfigsRunsTransferLogsListCall ¶
type ProjectsLocationsTransferConfigsRunsTransferLogsListCall struct {
// contains filtered or unexported fields
}
func (*ProjectsLocationsTransferConfigsRunsTransferLogsListCall) Context ¶
func (c *ProjectsLocationsTransferConfigsRunsTransferLogsListCall) Context(ctx context.Context) *ProjectsLocationsTransferConfigsRunsTransferLogsListCall
Context sets the context to be used in this call's Do method. Any pending HTTP request will be aborted if the provided context is canceled.
func (*ProjectsLocationsTransferConfigsRunsTransferLogsListCall) Do ¶
func (c *ProjectsLocationsTransferConfigsRunsTransferLogsListCall) Do(opts ...googleapi.CallOption) (*ListTransferLogsResponse, error)
Do executes the "bigquerydatatransfer.projects.locations.transferConfigs.runs.transferLogs.list" call. Exactly one of *ListTransferLogsResponse or error will be non-nil. Any non-2xx status code is an error. Response headers are in either *ListTransferLogsResponse.ServerResponse.Header or (if a response was returned at all) in error.(*googleapi.Error).Header. Use googleapi.IsNotModified to check whether the returned error was because http.StatusNotModified was returned.
func (*ProjectsLocationsTransferConfigsRunsTransferLogsListCall) Fields ¶
func (c *ProjectsLocationsTransferConfigsRunsTransferLogsListCall) Fields(s ...googleapi.Field) *ProjectsLocationsTransferConfigsRunsTransferLogsListCall
Fields allows partial responses to be retrieved. See https://developers.google.com/gdata/docs/2.0/basics#PartialResponse for more information.
func (*ProjectsLocationsTransferConfigsRunsTransferLogsListCall) Header ¶
func (c *ProjectsLocationsTransferConfigsRunsTransferLogsListCall) Header() http.Header
Header returns an http.Header that can be modified by the caller to add HTTP headers to the request.
func (*ProjectsLocationsTransferConfigsRunsTransferLogsListCall) IfNoneMatch ¶
func (c *ProjectsLocationsTransferConfigsRunsTransferLogsListCall) IfNoneMatch(entityTag string) *ProjectsLocationsTransferConfigsRunsTransferLogsListCall
IfNoneMatch sets the optional parameter which makes the operation fail if the object's ETag matches the given value. This is useful for getting updates only after the object has changed since the last request. Use googleapi.IsNotModified to check whether the response error from Do is the result of In-None-Match.
func (*ProjectsLocationsTransferConfigsRunsTransferLogsListCall) MessageTypes ¶
func (c *ProjectsLocationsTransferConfigsRunsTransferLogsListCall) MessageTypes(messageTypes ...string) *ProjectsLocationsTransferConfigsRunsTransferLogsListCall
MessageTypes sets the optional parameter "messageTypes": Message types to return. If not populated - INFO, WARNING and ERROR messages are returned.
Possible values:
"MESSAGE_SEVERITY_UNSPECIFIED" - No severity specified. "INFO" - Informational message. "WARNING" - Warning message. "ERROR" - Error message.
func (*ProjectsLocationsTransferConfigsRunsTransferLogsListCall) PageSize ¶
func (c *ProjectsLocationsTransferConfigsRunsTransferLogsListCall) PageSize(pageSize int64) *ProjectsLocationsTransferConfigsRunsTransferLogsListCall
PageSize sets the optional parameter "pageSize": Page size. The default page size is the maximum value of 1000 results.
func (*ProjectsLocationsTransferConfigsRunsTransferLogsListCall) PageToken ¶
func (c *ProjectsLocationsTransferConfigsRunsTransferLogsListCall) PageToken(pageToken string) *ProjectsLocationsTransferConfigsRunsTransferLogsListCall
PageToken sets the optional parameter "pageToken": Pagination token, which can be used to request a specific page of `ListTransferLogsRequest` list results. For multiple-page results, `ListTransferLogsResponse` outputs a `next_page` token, which can be used as the `page_token` value to request the next page of list results.
func (*ProjectsLocationsTransferConfigsRunsTransferLogsListCall) Pages ¶
func (c *ProjectsLocationsTransferConfigsRunsTransferLogsListCall) Pages(ctx context.Context, f func(*ListTransferLogsResponse) error) error
Pages invokes f for each page of results. A non-nil error returned from f will halt the iteration. The provided context supersedes any context provided to the Context method.
type ProjectsLocationsTransferConfigsRunsTransferLogsService ¶
type ProjectsLocationsTransferConfigsRunsTransferLogsService struct {
// contains filtered or unexported fields
}
func NewProjectsLocationsTransferConfigsRunsTransferLogsService ¶
func NewProjectsLocationsTransferConfigsRunsTransferLogsService(s *Service) *ProjectsLocationsTransferConfigsRunsTransferLogsService
func (*ProjectsLocationsTransferConfigsRunsTransferLogsService) List ¶
func (r *ProjectsLocationsTransferConfigsRunsTransferLogsService) List(parent string) *ProjectsLocationsTransferConfigsRunsTransferLogsListCall
List: Returns log messages for the transfer run.
- parent: Transfer run name in the form: `projects/{project_id}/transferConfigs/{config_id}/runs/{run_id}` or `projects/{project_id}/locations/{location_id}/transferConfigs/{conf ig_id}/runs/{run_id}`.
type ProjectsLocationsTransferConfigsScheduleRunsCall ¶
type ProjectsLocationsTransferConfigsScheduleRunsCall struct {
// contains filtered or unexported fields
}
func (*ProjectsLocationsTransferConfigsScheduleRunsCall) Context ¶
func (c *ProjectsLocationsTransferConfigsScheduleRunsCall) Context(ctx context.Context) *ProjectsLocationsTransferConfigsScheduleRunsCall
Context sets the context to be used in this call's Do method. Any pending HTTP request will be aborted if the provided context is canceled.
func (*ProjectsLocationsTransferConfigsScheduleRunsCall) Do ¶
func (c *ProjectsLocationsTransferConfigsScheduleRunsCall) Do(opts ...googleapi.CallOption) (*ScheduleTransferRunsResponse, error)
Do executes the "bigquerydatatransfer.projects.locations.transferConfigs.scheduleRuns" call. Exactly one of *ScheduleTransferRunsResponse or error will be non-nil. Any non-2xx status code is an error. Response headers are in either *ScheduleTransferRunsResponse.ServerResponse.Header or (if a response was returned at all) in error.(*googleapi.Error).Header. Use googleapi.IsNotModified to check whether the returned error was because http.StatusNotModified was returned.
func (*ProjectsLocationsTransferConfigsScheduleRunsCall) Fields ¶
func (c *ProjectsLocationsTransferConfigsScheduleRunsCall) Fields(s ...googleapi.Field) *ProjectsLocationsTransferConfigsScheduleRunsCall
Fields allows partial responses to be retrieved. See https://developers.google.com/gdata/docs/2.0/basics#PartialResponse for more information.
func (*ProjectsLocationsTransferConfigsScheduleRunsCall) Header ¶
func (c *ProjectsLocationsTransferConfigsScheduleRunsCall) Header() http.Header
Header returns an http.Header that can be modified by the caller to add HTTP headers to the request.
type ProjectsLocationsTransferConfigsService ¶
type ProjectsLocationsTransferConfigsService struct { Runs *ProjectsLocationsTransferConfigsRunsService // contains filtered or unexported fields }
func NewProjectsLocationsTransferConfigsService ¶
func NewProjectsLocationsTransferConfigsService(s *Service) *ProjectsLocationsTransferConfigsService
func (*ProjectsLocationsTransferConfigsService) Create ¶
func (r *ProjectsLocationsTransferConfigsService) Create(parent string, transferconfig *TransferConfig) *ProjectsLocationsTransferConfigsCreateCall
Create: Creates a new data transfer configuration.
- parent: 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.
func (*ProjectsLocationsTransferConfigsService) Delete ¶
func (r *ProjectsLocationsTransferConfigsService) Delete(name string) *ProjectsLocationsTransferConfigsDeleteCall
Delete: Deletes a data transfer configuration, including any associated transfer runs and logs.
- name: 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/{conf ig_id}`.
func (*ProjectsLocationsTransferConfigsService) Get ¶
func (r *ProjectsLocationsTransferConfigsService) Get(name string) *ProjectsLocationsTransferConfigsGetCall
Get: Returns information about a data transfer config.
- name: 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/{conf ig_id}`.
func (*ProjectsLocationsTransferConfigsService) List ¶
func (r *ProjectsLocationsTransferConfigsService) List(parent string) *ProjectsLocationsTransferConfigsListCall
List: Returns information about all transfer configs owned by a project in the specified location.
- parent: The BigQuery project id for which transfer configs should be returned: `projects/{project_id}` or `projects/{project_id}/locations/{location_id}`.
func (*ProjectsLocationsTransferConfigsService) Patch ¶
func (r *ProjectsLocationsTransferConfigsService) Patch(name string, transferconfig *TransferConfig) *ProjectsLocationsTransferConfigsPatchCall
Patch: Updates a data transfer configuration. All fields must be set, even if they are not updated.
- name: The resource name of the transfer config. Transfer config names have the form either `projects/{project_id}/locations/{region}/transferConfigs/{config_id }` or `projects/{project_id}/transferConfigs/{config_id}`, where `config_id` is usually a UUID, even though it is not guaranteed or required. The name is ignored when creating a transfer config.
func (*ProjectsLocationsTransferConfigsService) ScheduleRuns ¶
func (r *ProjectsLocationsTransferConfigsService) ScheduleRuns(parent string, scheduletransferrunsrequest *ScheduleTransferRunsRequest) *ProjectsLocationsTransferConfigsScheduleRunsCall
ScheduleRuns: 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.
- parent: Transfer configuration name in the form: `projects/{project_id}/transferConfigs/{config_id}` or `projects/{project_id}/locations/{location_id}/transferConfigs/{conf ig_id}`.
func (*ProjectsLocationsTransferConfigsService) StartManualRuns ¶ added in v0.3.1
func (r *ProjectsLocationsTransferConfigsService) StartManualRuns(parent string, startmanualtransferrunsrequest *StartManualTransferRunsRequest) *ProjectsLocationsTransferConfigsStartManualRunsCall
StartManualRuns: 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.
- parent: Transfer configuration name in the form: `projects/{project_id}/transferConfigs/{config_id}` or `projects/{project_id}/locations/{location_id}/transferConfigs/{conf ig_id}`.
type ProjectsLocationsTransferConfigsStartManualRunsCall ¶ added in v0.3.1
type ProjectsLocationsTransferConfigsStartManualRunsCall struct {
// contains filtered or unexported fields
}
func (*ProjectsLocationsTransferConfigsStartManualRunsCall) Context ¶ added in v0.3.1
func (c *ProjectsLocationsTransferConfigsStartManualRunsCall) Context(ctx context.Context) *ProjectsLocationsTransferConfigsStartManualRunsCall
Context sets the context to be used in this call's Do method. Any pending HTTP request will be aborted if the provided context is canceled.
func (*ProjectsLocationsTransferConfigsStartManualRunsCall) Do ¶ added in v0.3.1
func (c *ProjectsLocationsTransferConfigsStartManualRunsCall) Do(opts ...googleapi.CallOption) (*StartManualTransferRunsResponse, error)
Do executes the "bigquerydatatransfer.projects.locations.transferConfigs.startManualRuns" call. Exactly one of *StartManualTransferRunsResponse or error will be non-nil. Any non-2xx status code is an error. Response headers are in either *StartManualTransferRunsResponse.ServerResponse.Header or (if a response was returned at all) in error.(*googleapi.Error).Header. Use googleapi.IsNotModified to check whether the returned error was because http.StatusNotModified was returned.
func (*ProjectsLocationsTransferConfigsStartManualRunsCall) Fields ¶ added in v0.3.1
func (c *ProjectsLocationsTransferConfigsStartManualRunsCall) Fields(s ...googleapi.Field) *ProjectsLocationsTransferConfigsStartManualRunsCall
Fields allows partial responses to be retrieved. See https://developers.google.com/gdata/docs/2.0/basics#PartialResponse for more information.
func (*ProjectsLocationsTransferConfigsStartManualRunsCall) Header ¶ added in v0.3.1
func (c *ProjectsLocationsTransferConfigsStartManualRunsCall) Header() http.Header
Header returns an http.Header that can be modified by the caller to add HTTP headers to the request.
type ProjectsService ¶
type ProjectsService struct { DataSources *ProjectsDataSourcesService Locations *ProjectsLocationsService TransferConfigs *ProjectsTransferConfigsService // contains filtered or unexported fields }
func NewProjectsService ¶
func NewProjectsService(s *Service) *ProjectsService
func (*ProjectsService) EnrollDataSources ¶ added in v0.55.0
func (r *ProjectsService) EnrollDataSources(name string, enrolldatasourcesrequest *EnrollDataSourcesRequest) *ProjectsEnrollDataSourcesCall
EnrollDataSources: 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).
- name: The name of the project resource in the form: `projects/{project_id}`.
type ProjectsTransferConfigsCreateCall ¶
type ProjectsTransferConfigsCreateCall struct {
// contains filtered or unexported fields
}
func (*ProjectsTransferConfigsCreateCall) AuthorizationCode ¶
func (c *ProjectsTransferConfigsCreateCall) AuthorizationCode(authorizationCode string) *ProjectsTransferConfigsCreateCall
AuthorizationCode sets the optional parameter "authorizationCode": 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.
func (*ProjectsTransferConfigsCreateCall) Context ¶
func (c *ProjectsTransferConfigsCreateCall) Context(ctx context.Context) *ProjectsTransferConfigsCreateCall
Context sets the context to be used in this call's Do method. Any pending HTTP request will be aborted if the provided context is canceled.
func (*ProjectsTransferConfigsCreateCall) Do ¶
func (c *ProjectsTransferConfigsCreateCall) Do(opts ...googleapi.CallOption) (*TransferConfig, error)
Do executes the "bigquerydatatransfer.projects.transferConfigs.create" call. Exactly one of *TransferConfig or error will be non-nil. Any non-2xx status code is an error. Response headers are in either *TransferConfig.ServerResponse.Header or (if a response was returned at all) in error.(*googleapi.Error).Header. Use googleapi.IsNotModified to check whether the returned error was because http.StatusNotModified was returned.
func (*ProjectsTransferConfigsCreateCall) Fields ¶
func (c *ProjectsTransferConfigsCreateCall) Fields(s ...googleapi.Field) *ProjectsTransferConfigsCreateCall
Fields allows partial responses to be retrieved. See https://developers.google.com/gdata/docs/2.0/basics#PartialResponse for more information.
func (*ProjectsTransferConfigsCreateCall) Header ¶
func (c *ProjectsTransferConfigsCreateCall) Header() http.Header
Header returns an http.Header that can be modified by the caller to add HTTP headers to the request.
func (*ProjectsTransferConfigsCreateCall) ServiceAccountName ¶ added in v0.14.0
func (c *ProjectsTransferConfigsCreateCall) ServiceAccountName(serviceAccountName string) *ProjectsTransferConfigsCreateCall
ServiceAccountName sets the optional parameter "serviceAccountName": 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).
func (*ProjectsTransferConfigsCreateCall) VersionInfo ¶ added in v0.2.0
func (c *ProjectsTransferConfigsCreateCall) VersionInfo(versionInfo string) *ProjectsTransferConfigsCreateCall
VersionInfo sets the optional parameter "versionInfo": 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.
type ProjectsTransferConfigsDeleteCall ¶
type ProjectsTransferConfigsDeleteCall struct {
// contains filtered or unexported fields
}
func (*ProjectsTransferConfigsDeleteCall) Context ¶
func (c *ProjectsTransferConfigsDeleteCall) Context(ctx context.Context) *ProjectsTransferConfigsDeleteCall
Context sets the context to be used in this call's Do method. Any pending HTTP request will be aborted if the provided context is canceled.
func (*ProjectsTransferConfigsDeleteCall) Do ¶
func (c *ProjectsTransferConfigsDeleteCall) Do(opts ...googleapi.CallOption) (*Empty, error)
Do executes the "bigquerydatatransfer.projects.transferConfigs.delete" call. Exactly one of *Empty or error will be non-nil. Any non-2xx status code is an error. Response headers are in either *Empty.ServerResponse.Header or (if a response was returned at all) in error.(*googleapi.Error).Header. Use googleapi.IsNotModified to check whether the returned error was because http.StatusNotModified was returned.
func (*ProjectsTransferConfigsDeleteCall) Fields ¶
func (c *ProjectsTransferConfigsDeleteCall) Fields(s ...googleapi.Field) *ProjectsTransferConfigsDeleteCall
Fields allows partial responses to be retrieved. See https://developers.google.com/gdata/docs/2.0/basics#PartialResponse for more information.
func (*ProjectsTransferConfigsDeleteCall) Header ¶
func (c *ProjectsTransferConfigsDeleteCall) Header() http.Header
Header returns an http.Header that can be modified by the caller to add HTTP headers to the request.
type ProjectsTransferConfigsGetCall ¶
type ProjectsTransferConfigsGetCall struct {
// contains filtered or unexported fields
}
func (*ProjectsTransferConfigsGetCall) Context ¶
func (c *ProjectsTransferConfigsGetCall) Context(ctx context.Context) *ProjectsTransferConfigsGetCall
Context sets the context to be used in this call's Do method. Any pending HTTP request will be aborted if the provided context is canceled.
func (*ProjectsTransferConfigsGetCall) Do ¶
func (c *ProjectsTransferConfigsGetCall) Do(opts ...googleapi.CallOption) (*TransferConfig, error)
Do executes the "bigquerydatatransfer.projects.transferConfigs.get" call. Exactly one of *TransferConfig or error will be non-nil. Any non-2xx status code is an error. Response headers are in either *TransferConfig.ServerResponse.Header or (if a response was returned at all) in error.(*googleapi.Error).Header. Use googleapi.IsNotModified to check whether the returned error was because http.StatusNotModified was returned.
func (*ProjectsTransferConfigsGetCall) Fields ¶
func (c *ProjectsTransferConfigsGetCall) Fields(s ...googleapi.Field) *ProjectsTransferConfigsGetCall
Fields allows partial responses to be retrieved. See https://developers.google.com/gdata/docs/2.0/basics#PartialResponse for more information.
func (*ProjectsTransferConfigsGetCall) Header ¶
func (c *ProjectsTransferConfigsGetCall) Header() http.Header
Header returns an http.Header that can be modified by the caller to add HTTP headers to the request.
func (*ProjectsTransferConfigsGetCall) IfNoneMatch ¶
func (c *ProjectsTransferConfigsGetCall) IfNoneMatch(entityTag string) *ProjectsTransferConfigsGetCall
IfNoneMatch sets the optional parameter which makes the operation fail if the object's ETag matches the given value. This is useful for getting updates only after the object has changed since the last request. Use googleapi.IsNotModified to check whether the response error from Do is the result of In-None-Match.
type ProjectsTransferConfigsListCall ¶
type ProjectsTransferConfigsListCall struct {
// contains filtered or unexported fields
}
func (*ProjectsTransferConfigsListCall) Context ¶
func (c *ProjectsTransferConfigsListCall) Context(ctx context.Context) *ProjectsTransferConfigsListCall
Context sets the context to be used in this call's Do method. Any pending HTTP request will be aborted if the provided context is canceled.
func (*ProjectsTransferConfigsListCall) DataSourceIds ¶
func (c *ProjectsTransferConfigsListCall) DataSourceIds(dataSourceIds ...string) *ProjectsTransferConfigsListCall
DataSourceIds sets the optional parameter "dataSourceIds": When specified, only configurations of requested data sources are returned.
func (*ProjectsTransferConfigsListCall) Do ¶
func (c *ProjectsTransferConfigsListCall) Do(opts ...googleapi.CallOption) (*ListTransferConfigsResponse, error)
Do executes the "bigquerydatatransfer.projects.transferConfigs.list" call. Exactly one of *ListTransferConfigsResponse or error will be non-nil. Any non-2xx status code is an error. Response headers are in either *ListTransferConfigsResponse.ServerResponse.Header or (if a response was returned at all) in error.(*googleapi.Error).Header. Use googleapi.IsNotModified to check whether the returned error was because http.StatusNotModified was returned.
func (*ProjectsTransferConfigsListCall) Fields ¶
func (c *ProjectsTransferConfigsListCall) Fields(s ...googleapi.Field) *ProjectsTransferConfigsListCall
Fields allows partial responses to be retrieved. See https://developers.google.com/gdata/docs/2.0/basics#PartialResponse for more information.
func (*ProjectsTransferConfigsListCall) Header ¶
func (c *ProjectsTransferConfigsListCall) Header() http.Header
Header returns an http.Header that can be modified by the caller to add HTTP headers to the request.
func (*ProjectsTransferConfigsListCall) IfNoneMatch ¶
func (c *ProjectsTransferConfigsListCall) IfNoneMatch(entityTag string) *ProjectsTransferConfigsListCall
IfNoneMatch sets the optional parameter which makes the operation fail if the object's ETag matches the given value. This is useful for getting updates only after the object has changed since the last request. Use googleapi.IsNotModified to check whether the response error from Do is the result of In-None-Match.
func (*ProjectsTransferConfigsListCall) PageSize ¶
func (c *ProjectsTransferConfigsListCall) PageSize(pageSize int64) *ProjectsTransferConfigsListCall
PageSize sets the optional parameter "pageSize": Page size. The default page size is the maximum value of 1000 results.
func (*ProjectsTransferConfigsListCall) PageToken ¶
func (c *ProjectsTransferConfigsListCall) PageToken(pageToken string) *ProjectsTransferConfigsListCall
PageToken sets the optional parameter "pageToken": 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.
func (*ProjectsTransferConfigsListCall) Pages ¶
func (c *ProjectsTransferConfigsListCall) Pages(ctx context.Context, f func(*ListTransferConfigsResponse) error) error
Pages invokes f for each page of results. A non-nil error returned from f will halt the iteration. The provided context supersedes any context provided to the Context method.
type ProjectsTransferConfigsPatchCall ¶
type ProjectsTransferConfigsPatchCall struct {
// contains filtered or unexported fields
}
func (*ProjectsTransferConfigsPatchCall) AuthorizationCode ¶
func (c *ProjectsTransferConfigsPatchCall) AuthorizationCode(authorizationCode string) *ProjectsTransferConfigsPatchCall
AuthorizationCode sets the optional parameter "authorizationCode": 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 update the transfer config.
func (*ProjectsTransferConfigsPatchCall) Context ¶
func (c *ProjectsTransferConfigsPatchCall) Context(ctx context.Context) *ProjectsTransferConfigsPatchCall
Context sets the context to be used in this call's Do method. Any pending HTTP request will be aborted if the provided context is canceled.
func (*ProjectsTransferConfigsPatchCall) Do ¶
func (c *ProjectsTransferConfigsPatchCall) Do(opts ...googleapi.CallOption) (*TransferConfig, error)
Do executes the "bigquerydatatransfer.projects.transferConfigs.patch" call. Exactly one of *TransferConfig or error will be non-nil. Any non-2xx status code is an error. Response headers are in either *TransferConfig.ServerResponse.Header or (if a response was returned at all) in error.(*googleapi.Error).Header. Use googleapi.IsNotModified to check whether the returned error was because http.StatusNotModified was returned.
func (*ProjectsTransferConfigsPatchCall) Fields ¶
func (c *ProjectsTransferConfigsPatchCall) Fields(s ...googleapi.Field) *ProjectsTransferConfigsPatchCall
Fields allows partial responses to be retrieved. See https://developers.google.com/gdata/docs/2.0/basics#PartialResponse for more information.
func (*ProjectsTransferConfigsPatchCall) Header ¶
func (c *ProjectsTransferConfigsPatchCall) Header() http.Header
Header returns an http.Header that can be modified by the caller to add HTTP headers to the request.
func (*ProjectsTransferConfigsPatchCall) ServiceAccountName ¶ added in v0.14.0
func (c *ProjectsTransferConfigsPatchCall) ServiceAccountName(serviceAccountName string) *ProjectsTransferConfigsPatchCall
ServiceAccountName sets the optional parameter "serviceAccountName": 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).
func (*ProjectsTransferConfigsPatchCall) UpdateMask ¶
func (c *ProjectsTransferConfigsPatchCall) UpdateMask(updateMask string) *ProjectsTransferConfigsPatchCall
UpdateMask sets the optional parameter "updateMask": Required. Required list of fields to be updated in this request.
func (*ProjectsTransferConfigsPatchCall) VersionInfo ¶ added in v0.2.0
func (c *ProjectsTransferConfigsPatchCall) VersionInfo(versionInfo string) *ProjectsTransferConfigsPatchCall
VersionInfo sets the optional parameter "versionInfo": 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 update the transfer config.
type ProjectsTransferConfigsRunsDeleteCall ¶
type ProjectsTransferConfigsRunsDeleteCall struct {
// contains filtered or unexported fields
}
func (*ProjectsTransferConfigsRunsDeleteCall) Context ¶
func (c *ProjectsTransferConfigsRunsDeleteCall) Context(ctx context.Context) *ProjectsTransferConfigsRunsDeleteCall
Context sets the context to be used in this call's Do method. Any pending HTTP request will be aborted if the provided context is canceled.
func (*ProjectsTransferConfigsRunsDeleteCall) Do ¶
func (c *ProjectsTransferConfigsRunsDeleteCall) Do(opts ...googleapi.CallOption) (*Empty, error)
Do executes the "bigquerydatatransfer.projects.transferConfigs.runs.delete" call. Exactly one of *Empty or error will be non-nil. Any non-2xx status code is an error. Response headers are in either *Empty.ServerResponse.Header or (if a response was returned at all) in error.(*googleapi.Error).Header. Use googleapi.IsNotModified to check whether the returned error was because http.StatusNotModified was returned.
func (*ProjectsTransferConfigsRunsDeleteCall) Fields ¶
func (c *ProjectsTransferConfigsRunsDeleteCall) Fields(s ...googleapi.Field) *ProjectsTransferConfigsRunsDeleteCall
Fields allows partial responses to be retrieved. See https://developers.google.com/gdata/docs/2.0/basics#PartialResponse for more information.
func (*ProjectsTransferConfigsRunsDeleteCall) Header ¶
func (c *ProjectsTransferConfigsRunsDeleteCall) Header() http.Header
Header returns an http.Header that can be modified by the caller to add HTTP headers to the request.
type ProjectsTransferConfigsRunsGetCall ¶
type ProjectsTransferConfigsRunsGetCall struct {
// contains filtered or unexported fields
}
func (*ProjectsTransferConfigsRunsGetCall) Context ¶
func (c *ProjectsTransferConfigsRunsGetCall) Context(ctx context.Context) *ProjectsTransferConfigsRunsGetCall
Context sets the context to be used in this call's Do method. Any pending HTTP request will be aborted if the provided context is canceled.
func (*ProjectsTransferConfigsRunsGetCall) Do ¶
func (c *ProjectsTransferConfigsRunsGetCall) Do(opts ...googleapi.CallOption) (*TransferRun, error)
Do executes the "bigquerydatatransfer.projects.transferConfigs.runs.get" call. Exactly one of *TransferRun or error will be non-nil. Any non-2xx status code is an error. Response headers are in either *TransferRun.ServerResponse.Header or (if a response was returned at all) in error.(*googleapi.Error).Header. Use googleapi.IsNotModified to check whether the returned error was because http.StatusNotModified was returned.
func (*ProjectsTransferConfigsRunsGetCall) Fields ¶
func (c *ProjectsTransferConfigsRunsGetCall) Fields(s ...googleapi.Field) *ProjectsTransferConfigsRunsGetCall
Fields allows partial responses to be retrieved. See https://developers.google.com/gdata/docs/2.0/basics#PartialResponse for more information.
func (*ProjectsTransferConfigsRunsGetCall) Header ¶
func (c *ProjectsTransferConfigsRunsGetCall) Header() http.Header
Header returns an http.Header that can be modified by the caller to add HTTP headers to the request.
func (*ProjectsTransferConfigsRunsGetCall) IfNoneMatch ¶
func (c *ProjectsTransferConfigsRunsGetCall) IfNoneMatch(entityTag string) *ProjectsTransferConfigsRunsGetCall
IfNoneMatch sets the optional parameter which makes the operation fail if the object's ETag matches the given value. This is useful for getting updates only after the object has changed since the last request. Use googleapi.IsNotModified to check whether the response error from Do is the result of In-None-Match.
type ProjectsTransferConfigsRunsListCall ¶
type ProjectsTransferConfigsRunsListCall struct {
// contains filtered or unexported fields
}
func (*ProjectsTransferConfigsRunsListCall) Context ¶
func (c *ProjectsTransferConfigsRunsListCall) Context(ctx context.Context) *ProjectsTransferConfigsRunsListCall
Context sets the context to be used in this call's Do method. Any pending HTTP request will be aborted if the provided context is canceled.
func (*ProjectsTransferConfigsRunsListCall) Do ¶
func (c *ProjectsTransferConfigsRunsListCall) Do(opts ...googleapi.CallOption) (*ListTransferRunsResponse, error)
Do executes the "bigquerydatatransfer.projects.transferConfigs.runs.list" call. Exactly one of *ListTransferRunsResponse or error will be non-nil. Any non-2xx status code is an error. Response headers are in either *ListTransferRunsResponse.ServerResponse.Header or (if a response was returned at all) in error.(*googleapi.Error).Header. Use googleapi.IsNotModified to check whether the returned error was because http.StatusNotModified was returned.
func (*ProjectsTransferConfigsRunsListCall) Fields ¶
func (c *ProjectsTransferConfigsRunsListCall) Fields(s ...googleapi.Field) *ProjectsTransferConfigsRunsListCall
Fields allows partial responses to be retrieved. See https://developers.google.com/gdata/docs/2.0/basics#PartialResponse for more information.
func (*ProjectsTransferConfigsRunsListCall) Header ¶
func (c *ProjectsTransferConfigsRunsListCall) Header() http.Header
Header returns an http.Header that can be modified by the caller to add HTTP headers to the request.
func (*ProjectsTransferConfigsRunsListCall) IfNoneMatch ¶
func (c *ProjectsTransferConfigsRunsListCall) IfNoneMatch(entityTag string) *ProjectsTransferConfigsRunsListCall
IfNoneMatch sets the optional parameter which makes the operation fail if the object's ETag matches the given value. This is useful for getting updates only after the object has changed since the last request. Use googleapi.IsNotModified to check whether the response error from Do is the result of In-None-Match.
func (*ProjectsTransferConfigsRunsListCall) PageSize ¶
func (c *ProjectsTransferConfigsRunsListCall) PageSize(pageSize int64) *ProjectsTransferConfigsRunsListCall
PageSize sets the optional parameter "pageSize": Page size. The default page size is the maximum value of 1000 results.
func (*ProjectsTransferConfigsRunsListCall) PageToken ¶
func (c *ProjectsTransferConfigsRunsListCall) PageToken(pageToken string) *ProjectsTransferConfigsRunsListCall
PageToken sets the optional parameter "pageToken": Pagination token, which can be used to request a specific page of `ListTransferRunsRequest` list results. For multiple-page results, `ListTransferRunsResponse` outputs a `next_page` token, which can be used as the `page_token` value to request the next page of list results.
func (*ProjectsTransferConfigsRunsListCall) Pages ¶
func (c *ProjectsTransferConfigsRunsListCall) Pages(ctx context.Context, f func(*ListTransferRunsResponse) error) error
Pages invokes f for each page of results. A non-nil error returned from f will halt the iteration. The provided context supersedes any context provided to the Context method.
func (*ProjectsTransferConfigsRunsListCall) RunAttempt ¶
func (c *ProjectsTransferConfigsRunsListCall) RunAttempt(runAttempt string) *ProjectsTransferConfigsRunsListCall
RunAttempt sets the optional parameter "runAttempt": Indicates how run attempts are to be pulled.
Possible values:
"RUN_ATTEMPT_UNSPECIFIED" - All runs should be returned. "LATEST" - Only latest run per day should be returned.
func (*ProjectsTransferConfigsRunsListCall) States ¶
func (c *ProjectsTransferConfigsRunsListCall) States(states ...string) *ProjectsTransferConfigsRunsListCall
States sets the optional parameter "states": When specified, only transfer runs with requested states are returned.
Possible values:
"TRANSFER_STATE_UNSPECIFIED" - State placeholder (0). "PENDING" - Data transfer is scheduled and is waiting to be picked
up by data transfer backend (2).
"RUNNING" - Data transfer is in progress (3). "SUCCEEDED" - Data transfer completed successfully (4). "FAILED" - Data transfer failed (5). "CANCELLED" - Data transfer is cancelled (6).
type ProjectsTransferConfigsRunsService ¶
type ProjectsTransferConfigsRunsService struct { TransferLogs *ProjectsTransferConfigsRunsTransferLogsService // contains filtered or unexported fields }
func NewProjectsTransferConfigsRunsService ¶
func NewProjectsTransferConfigsRunsService(s *Service) *ProjectsTransferConfigsRunsService
func (*ProjectsTransferConfigsRunsService) Delete ¶
func (r *ProjectsTransferConfigsRunsService) Delete(name string) *ProjectsTransferConfigsRunsDeleteCall
Delete: Deletes the specified transfer run.
- name: 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/{conf ig_id}/runs/{run_id}`.
func (*ProjectsTransferConfigsRunsService) Get ¶
func (r *ProjectsTransferConfigsRunsService) Get(name string) *ProjectsTransferConfigsRunsGetCall
Get: Returns information about the particular transfer run.
- name: 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/{conf ig_id}/runs/{run_id}`.
func (*ProjectsTransferConfigsRunsService) List ¶
func (r *ProjectsTransferConfigsRunsService) List(parent string) *ProjectsTransferConfigsRunsListCall
List: Returns information about running and completed transfer runs.
- parent: Name of transfer configuration for which transfer runs should be retrieved. Format of transfer configuration resource name is: `projects/{project_id}/transferConfigs/{config_id}` or `projects/{project_id}/locations/{location_id}/transferConfigs/{conf ig_id}`.
type ProjectsTransferConfigsRunsTransferLogsListCall ¶
type ProjectsTransferConfigsRunsTransferLogsListCall struct {
// contains filtered or unexported fields
}
func (*ProjectsTransferConfigsRunsTransferLogsListCall) Context ¶
func (c *ProjectsTransferConfigsRunsTransferLogsListCall) Context(ctx context.Context) *ProjectsTransferConfigsRunsTransferLogsListCall
Context sets the context to be used in this call's Do method. Any pending HTTP request will be aborted if the provided context is canceled.
func (*ProjectsTransferConfigsRunsTransferLogsListCall) Do ¶
func (c *ProjectsTransferConfigsRunsTransferLogsListCall) Do(opts ...googleapi.CallOption) (*ListTransferLogsResponse, error)
Do executes the "bigquerydatatransfer.projects.transferConfigs.runs.transferLogs.list" call. Exactly one of *ListTransferLogsResponse or error will be non-nil. Any non-2xx status code is an error. Response headers are in either *ListTransferLogsResponse.ServerResponse.Header or (if a response was returned at all) in error.(*googleapi.Error).Header. Use googleapi.IsNotModified to check whether the returned error was because http.StatusNotModified was returned.
func (*ProjectsTransferConfigsRunsTransferLogsListCall) Fields ¶
func (c *ProjectsTransferConfigsRunsTransferLogsListCall) Fields(s ...googleapi.Field) *ProjectsTransferConfigsRunsTransferLogsListCall
Fields allows partial responses to be retrieved. See https://developers.google.com/gdata/docs/2.0/basics#PartialResponse for more information.
func (*ProjectsTransferConfigsRunsTransferLogsListCall) Header ¶
func (c *ProjectsTransferConfigsRunsTransferLogsListCall) Header() http.Header
Header returns an http.Header that can be modified by the caller to add HTTP headers to the request.
func (*ProjectsTransferConfigsRunsTransferLogsListCall) IfNoneMatch ¶
func (c *ProjectsTransferConfigsRunsTransferLogsListCall) IfNoneMatch(entityTag string) *ProjectsTransferConfigsRunsTransferLogsListCall
IfNoneMatch sets the optional parameter which makes the operation fail if the object's ETag matches the given value. This is useful for getting updates only after the object has changed since the last request. Use googleapi.IsNotModified to check whether the response error from Do is the result of In-None-Match.
func (*ProjectsTransferConfigsRunsTransferLogsListCall) MessageTypes ¶
func (c *ProjectsTransferConfigsRunsTransferLogsListCall) MessageTypes(messageTypes ...string) *ProjectsTransferConfigsRunsTransferLogsListCall
MessageTypes sets the optional parameter "messageTypes": Message types to return. If not populated - INFO, WARNING and ERROR messages are returned.
Possible values:
"MESSAGE_SEVERITY_UNSPECIFIED" - No severity specified. "INFO" - Informational message. "WARNING" - Warning message. "ERROR" - Error message.
func (*ProjectsTransferConfigsRunsTransferLogsListCall) PageSize ¶
func (c *ProjectsTransferConfigsRunsTransferLogsListCall) PageSize(pageSize int64) *ProjectsTransferConfigsRunsTransferLogsListCall
PageSize sets the optional parameter "pageSize": Page size. The default page size is the maximum value of 1000 results.
func (*ProjectsTransferConfigsRunsTransferLogsListCall) PageToken ¶
func (c *ProjectsTransferConfigsRunsTransferLogsListCall) PageToken(pageToken string) *ProjectsTransferConfigsRunsTransferLogsListCall
PageToken sets the optional parameter "pageToken": Pagination token, which can be used to request a specific page of `ListTransferLogsRequest` list results. For multiple-page results, `ListTransferLogsResponse` outputs a `next_page` token, which can be used as the `page_token` value to request the next page of list results.
func (*ProjectsTransferConfigsRunsTransferLogsListCall) Pages ¶
func (c *ProjectsTransferConfigsRunsTransferLogsListCall) Pages(ctx context.Context, f func(*ListTransferLogsResponse) error) error
Pages invokes f for each page of results. A non-nil error returned from f will halt the iteration. The provided context supersedes any context provided to the Context method.
type ProjectsTransferConfigsRunsTransferLogsService ¶
type ProjectsTransferConfigsRunsTransferLogsService struct {
// contains filtered or unexported fields
}
func NewProjectsTransferConfigsRunsTransferLogsService ¶
func NewProjectsTransferConfigsRunsTransferLogsService(s *Service) *ProjectsTransferConfigsRunsTransferLogsService
func (*ProjectsTransferConfigsRunsTransferLogsService) List ¶
func (r *ProjectsTransferConfigsRunsTransferLogsService) List(parent string) *ProjectsTransferConfigsRunsTransferLogsListCall
List: Returns log messages for the transfer run.
- parent: Transfer run name in the form: `projects/{project_id}/transferConfigs/{config_id}/runs/{run_id}` or `projects/{project_id}/locations/{location_id}/transferConfigs/{conf ig_id}/runs/{run_id}`.
type ProjectsTransferConfigsScheduleRunsCall ¶
type ProjectsTransferConfigsScheduleRunsCall struct {
// contains filtered or unexported fields
}
func (*ProjectsTransferConfigsScheduleRunsCall) Context ¶
func (c *ProjectsTransferConfigsScheduleRunsCall) Context(ctx context.Context) *ProjectsTransferConfigsScheduleRunsCall
Context sets the context to be used in this call's Do method. Any pending HTTP request will be aborted if the provided context is canceled.
func (*ProjectsTransferConfigsScheduleRunsCall) Do ¶
func (c *ProjectsTransferConfigsScheduleRunsCall) Do(opts ...googleapi.CallOption) (*ScheduleTransferRunsResponse, error)
Do executes the "bigquerydatatransfer.projects.transferConfigs.scheduleRuns" call. Exactly one of *ScheduleTransferRunsResponse or error will be non-nil. Any non-2xx status code is an error. Response headers are in either *ScheduleTransferRunsResponse.ServerResponse.Header or (if a response was returned at all) in error.(*googleapi.Error).Header. Use googleapi.IsNotModified to check whether the returned error was because http.StatusNotModified was returned.
func (*ProjectsTransferConfigsScheduleRunsCall) Fields ¶
func (c *ProjectsTransferConfigsScheduleRunsCall) Fields(s ...googleapi.Field) *ProjectsTransferConfigsScheduleRunsCall
Fields allows partial responses to be retrieved. See https://developers.google.com/gdata/docs/2.0/basics#PartialResponse for more information.
func (*ProjectsTransferConfigsScheduleRunsCall) Header ¶
func (c *ProjectsTransferConfigsScheduleRunsCall) Header() http.Header
Header returns an http.Header that can be modified by the caller to add HTTP headers to the request.
type ProjectsTransferConfigsService ¶
type ProjectsTransferConfigsService struct { Runs *ProjectsTransferConfigsRunsService // contains filtered or unexported fields }
func NewProjectsTransferConfigsService ¶
func NewProjectsTransferConfigsService(s *Service) *ProjectsTransferConfigsService
func (*ProjectsTransferConfigsService) Create ¶
func (r *ProjectsTransferConfigsService) Create(parent string, transferconfig *TransferConfig) *ProjectsTransferConfigsCreateCall
Create: Creates a new data transfer configuration.
- parent: 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.
func (*ProjectsTransferConfigsService) Delete ¶
func (r *ProjectsTransferConfigsService) Delete(name string) *ProjectsTransferConfigsDeleteCall
Delete: Deletes a data transfer configuration, including any associated transfer runs and logs.
- name: 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/{conf ig_id}`.
func (*ProjectsTransferConfigsService) Get ¶
func (r *ProjectsTransferConfigsService) Get(name string) *ProjectsTransferConfigsGetCall
Get: Returns information about a data transfer config.
- name: 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/{conf ig_id}`.
func (*ProjectsTransferConfigsService) List ¶
func (r *ProjectsTransferConfigsService) List(parent string) *ProjectsTransferConfigsListCall
List: Returns information about all transfer configs owned by a project in the specified location.
- parent: The BigQuery project id for which transfer configs should be returned: `projects/{project_id}` or `projects/{project_id}/locations/{location_id}`.
func (*ProjectsTransferConfigsService) Patch ¶
func (r *ProjectsTransferConfigsService) Patch(name string, transferconfig *TransferConfig) *ProjectsTransferConfigsPatchCall
Patch: Updates a data transfer configuration. All fields must be set, even if they are not updated.
- name: The resource name of the transfer config. Transfer config names have the form either `projects/{project_id}/locations/{region}/transferConfigs/{config_id }` or `projects/{project_id}/transferConfigs/{config_id}`, where `config_id` is usually a UUID, even though it is not guaranteed or required. The name is ignored when creating a transfer config.
func (*ProjectsTransferConfigsService) ScheduleRuns ¶
func (r *ProjectsTransferConfigsService) ScheduleRuns(parent string, scheduletransferrunsrequest *ScheduleTransferRunsRequest) *ProjectsTransferConfigsScheduleRunsCall
ScheduleRuns: 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.
- parent: Transfer configuration name in the form: `projects/{project_id}/transferConfigs/{config_id}` or `projects/{project_id}/locations/{location_id}/transferConfigs/{conf ig_id}`.
func (*ProjectsTransferConfigsService) StartManualRuns ¶ added in v0.3.1
func (r *ProjectsTransferConfigsService) StartManualRuns(parent string, startmanualtransferrunsrequest *StartManualTransferRunsRequest) *ProjectsTransferConfigsStartManualRunsCall
StartManualRuns: 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.
- parent: Transfer configuration name in the form: `projects/{project_id}/transferConfigs/{config_id}` or `projects/{project_id}/locations/{location_id}/transferConfigs/{conf ig_id}`.
type ProjectsTransferConfigsStartManualRunsCall ¶ added in v0.3.1
type ProjectsTransferConfigsStartManualRunsCall struct {
// contains filtered or unexported fields
}
func (*ProjectsTransferConfigsStartManualRunsCall) Context ¶ added in v0.3.1
func (c *ProjectsTransferConfigsStartManualRunsCall) Context(ctx context.Context) *ProjectsTransferConfigsStartManualRunsCall
Context sets the context to be used in this call's Do method. Any pending HTTP request will be aborted if the provided context is canceled.
func (*ProjectsTransferConfigsStartManualRunsCall) Do ¶ added in v0.3.1
func (c *ProjectsTransferConfigsStartManualRunsCall) Do(opts ...googleapi.CallOption) (*StartManualTransferRunsResponse, error)
Do executes the "bigquerydatatransfer.projects.transferConfigs.startManualRuns" call. Exactly one of *StartManualTransferRunsResponse or error will be non-nil. Any non-2xx status code is an error. Response headers are in either *StartManualTransferRunsResponse.ServerResponse.Header or (if a response was returned at all) in error.(*googleapi.Error).Header. Use googleapi.IsNotModified to check whether the returned error was because http.StatusNotModified was returned.
func (*ProjectsTransferConfigsStartManualRunsCall) Fields ¶ added in v0.3.1
func (c *ProjectsTransferConfigsStartManualRunsCall) Fields(s ...googleapi.Field) *ProjectsTransferConfigsStartManualRunsCall
Fields allows partial responses to be retrieved. See https://developers.google.com/gdata/docs/2.0/basics#PartialResponse for more information.
func (*ProjectsTransferConfigsStartManualRunsCall) Header ¶ added in v0.3.1
func (c *ProjectsTransferConfigsStartManualRunsCall) Header() http.Header
Header returns an http.Header that can be modified by the caller to add HTTP headers to the request.
type ScheduleOptions ¶ added in v0.2.0
type ScheduleOptions struct { // DisableAutoScheduling: If true, automatic scheduling of data transfer // runs for this configuration will be disabled. The runs can be started // on ad-hoc basis using StartManualTransferRuns API. When automatic // scheduling is disabled, the TransferConfig.schedule field will be // ignored. DisableAutoScheduling bool `json:"disableAutoScheduling,omitempty"` // EndTime: Defines time to stop scheduling transfer runs. A transfer // run cannot be scheduled at or after the end time. The end time can be // changed at any moment. The time when a data transfer can be trigerred // manually is not limited by this option. EndTime string `json:"endTime,omitempty"` // StartTime: Specifies time to start scheduling transfer runs. The // first run will be scheduled at or after the start time according to a // recurrence pattern defined in the schedule string. The start time can // be changed at any moment. The time when a data transfer can be // trigerred manually is not limited by this option. StartTime string `json:"startTime,omitempty"` // ForceSendFields is a list of field names (e.g. // "DisableAutoScheduling") to unconditionally include in API requests. // By default, fields with empty or default values are omitted from API // requests. However, any non-pointer, non-interface field appearing in // ForceSendFields will be sent to the server regardless of whether the // field is empty or not. This may be used to include empty fields in // Patch requests. ForceSendFields []string `json:"-"` // NullFields is a list of field names (e.g. "DisableAutoScheduling") to // include in API requests with the JSON null value. By default, fields // with empty values are omitted from API requests. However, any field // with an empty value appearing in NullFields will be sent to the // server as null. It is an error if a field in this list has a // non-empty value. This may be used to include null fields in Patch // requests. NullFields []string `json:"-"` }
ScheduleOptions: Options customizing the data transfer schedule.
func (*ScheduleOptions) MarshalJSON ¶ added in v0.2.0
func (s *ScheduleOptions) MarshalJSON() ([]byte, error)
type ScheduleTransferRunsRequest ¶
type ScheduleTransferRunsRequest struct { // EndTime: Required. End time of the range of transfer runs. For // example, "2017-05-30T00:00:00+00:00". EndTime string `json:"endTime,omitempty"` // StartTime: Required. Start time of the range of transfer runs. For // example, "2017-05-25T00:00:00+00:00". StartTime string `json:"startTime,omitempty"` // ForceSendFields is a list of field names (e.g. "EndTime") to // unconditionally include in API requests. By default, fields with // empty or default values are omitted from API requests. However, any // non-pointer, non-interface field appearing in ForceSendFields will be // sent to the server regardless of whether the field is empty or not. // This may be used to include empty fields in Patch requests. ForceSendFields []string `json:"-"` // NullFields is a list of field names (e.g. "EndTime") to include in // API requests with the JSON null value. By default, fields with empty // values are omitted from API requests. However, any field with an // empty value appearing in NullFields will be sent to the server as // null. It is an error if a field in this list has a non-empty value. // This may be used to include null fields in Patch requests. NullFields []string `json:"-"` }
ScheduleTransferRunsRequest: A request to schedule transfer runs for a time range.
func (*ScheduleTransferRunsRequest) MarshalJSON ¶
func (s *ScheduleTransferRunsRequest) MarshalJSON() ([]byte, error)
type ScheduleTransferRunsResponse ¶
type ScheduleTransferRunsResponse struct { // Runs: The transfer runs that were scheduled. Runs []*TransferRun `json:"runs,omitempty"` // ServerResponse contains the HTTP response code and headers from the // server. googleapi.ServerResponse `json:"-"` // ForceSendFields is a list of field names (e.g. "Runs") to // unconditionally include in API requests. By default, fields with // empty or default values are omitted from API requests. However, any // non-pointer, non-interface field appearing in ForceSendFields will be // sent to the server regardless of whether the field is empty or not. // This may be used to include empty fields in Patch requests. ForceSendFields []string `json:"-"` // NullFields is a list of field names (e.g. "Runs") to include in API // requests with the JSON null value. By default, fields with empty // values are omitted from API requests. However, any field with an // empty value appearing in NullFields will be sent to the server as // null. It is an error if a field in this list has a non-empty value. // This may be used to include null fields in Patch requests. NullFields []string `json:"-"` }
ScheduleTransferRunsResponse: A response to schedule transfer runs for a time range.
func (*ScheduleTransferRunsResponse) MarshalJSON ¶
func (s *ScheduleTransferRunsResponse) MarshalJSON() ([]byte, error)
type Service ¶
type Service struct { BasePath string // API endpoint base URL UserAgent string // optional additional User-Agent fragment Projects *ProjectsService // contains filtered or unexported fields }
func New
deprecated
New creates a new Service. It uses the provided http.Client for requests.
Deprecated: please use NewService instead. To provide a custom HTTP client, use option.WithHTTPClient. If you are using google.golang.org/api/googleapis/transport.APIKey, use option.WithAPIKey with NewService instead.
func NewService ¶ added in v0.3.0
NewService creates a new Service.
type StartManualTransferRunsRequest ¶ added in v0.3.1
type StartManualTransferRunsRequest struct { // RequestedRunTime: A run_time timestamp for historical data files or // reports that are scheduled to be transferred by the scheduled // transfer run. requested_run_time must be a past time and cannot // include future time values. RequestedRunTime string `json:"requestedRunTime,omitempty"` // RequestedTimeRange: A time_range start and end timestamp for // historical data files or reports that are scheduled to be transferred // by the scheduled transfer run. requested_time_range must be a past // time and cannot include future time values. RequestedTimeRange *TimeRange `json:"requestedTimeRange,omitempty"` // ForceSendFields is a list of field names (e.g. "RequestedRunTime") to // unconditionally include in API requests. By default, fields with // empty or default values are omitted from API requests. However, any // non-pointer, non-interface field appearing in ForceSendFields will be // sent to the server regardless of whether the field is empty or not. // This may be used to include empty fields in Patch requests. ForceSendFields []string `json:"-"` // NullFields is a list of field names (e.g. "RequestedRunTime") to // include in API requests with the JSON null value. By default, fields // with empty values are omitted from API requests. However, any field // with an empty value appearing in NullFields will be sent to the // server as null. It is an error if a field in this list has a // non-empty value. This may be used to include null fields in Patch // requests. NullFields []string `json:"-"` }
StartManualTransferRunsRequest: A request to start manual transfer runs.
func (*StartManualTransferRunsRequest) MarshalJSON ¶ added in v0.3.1
func (s *StartManualTransferRunsRequest) MarshalJSON() ([]byte, error)
type StartManualTransferRunsResponse ¶ added in v0.3.1
type StartManualTransferRunsResponse struct { // Runs: The transfer runs that were created. Runs []*TransferRun `json:"runs,omitempty"` // ServerResponse contains the HTTP response code and headers from the // server. googleapi.ServerResponse `json:"-"` // ForceSendFields is a list of field names (e.g. "Runs") to // unconditionally include in API requests. By default, fields with // empty or default values are omitted from API requests. However, any // non-pointer, non-interface field appearing in ForceSendFields will be // sent to the server regardless of whether the field is empty or not. // This may be used to include empty fields in Patch requests. ForceSendFields []string `json:"-"` // NullFields is a list of field names (e.g. "Runs") to include in API // requests with the JSON null value. By default, fields with empty // values are omitted from API requests. However, any field with an // empty value appearing in NullFields will be sent to the server as // null. It is an error if a field in this list has a non-empty value. // This may be used to include null fields in Patch requests. NullFields []string `json:"-"` }
StartManualTransferRunsResponse: A response to start manual transfer runs.
func (*StartManualTransferRunsResponse) MarshalJSON ¶ added in v0.3.1
func (s *StartManualTransferRunsResponse) MarshalJSON() ([]byte, error)
type Status ¶
type Status struct { // Code: The status code, which should be an enum value of // google.rpc.Code. Code int64 `json:"code,omitempty"` // Details: A list of messages that carry the error details. There is a // common set of message types for APIs to use. Details []googleapi.RawMessage `json:"details,omitempty"` // Message: A developer-facing error message, which should be in // English. Any user-facing error message should be localized and sent // in the google.rpc.Status.details field, or localized by the client. Message string `json:"message,omitempty"` // ForceSendFields is a list of field names (e.g. "Code") to // unconditionally include in API requests. By default, fields with // empty or default values are omitted from API requests. However, any // non-pointer, non-interface field appearing in ForceSendFields will be // sent to the server regardless of whether the field is empty or not. // This may be used to include empty fields in Patch requests. ForceSendFields []string `json:"-"` // NullFields is a list of field names (e.g. "Code") to include in API // requests with the JSON null value. By default, fields with empty // values are omitted from API requests. However, any field with an // empty value appearing in NullFields will be sent to the server as // null. It is an error if a field in this list has a non-empty value. // This may be used to include null fields in Patch requests. NullFields []string `json:"-"` }
Status: The `Status` type defines a logical error model that is suitable for different programming environments, including REST APIs and RPC APIs. It is used by gRPC (https://github.com/grpc). Each `Status` message contains three pieces of data: error code, error message, and error details. You can find out more about this error model and how to work with it in the API Design Guide (https://cloud.google.com/apis/design/errors).
func (*Status) MarshalJSON ¶
type TimeRange ¶ added in v0.3.1
type TimeRange struct { // EndTime: End time of the range of transfer runs. For example, // "2017-05-30T00:00:00+00:00". The end_time must not be in the // future. Creates transfer runs where run_time is in the range between // start_time (inclusive) and end_time (exclusive). EndTime string `json:"endTime,omitempty"` // StartTime: Start time of the range of transfer runs. For example, // "2017-05-25T00:00:00+00:00". The start_time must be strictly less // than the end_time. Creates transfer runs where run_time is in the // range between start_time (inclusive) and end_time (exclusive). StartTime string `json:"startTime,omitempty"` // ForceSendFields is a list of field names (e.g. "EndTime") to // unconditionally include in API requests. By default, fields with // empty or default values are omitted from API requests. However, any // non-pointer, non-interface field appearing in ForceSendFields will be // sent to the server regardless of whether the field is empty or not. // This may be used to include empty fields in Patch requests. ForceSendFields []string `json:"-"` // NullFields is a list of field names (e.g. "EndTime") to include in // API requests with the JSON null value. By default, fields with empty // values are omitted from API requests. However, any field with an // empty value appearing in NullFields will be sent to the server as // null. It is an error if a field in this list has a non-empty value. // This may be used to include null fields in Patch requests. NullFields []string `json:"-"` }
TimeRange: A specification for a time range, this will request transfer runs with run_time between start_time (inclusive) and end_time (exclusive).
func (*TimeRange) MarshalJSON ¶ added in v0.3.1
type TransferConfig ¶
type TransferConfig struct { // DataRefreshWindowDays: The number of days to look back to // automatically refresh the data. For example, if // `data_refresh_window_days = 10`, then every day BigQuery reingests // data for [today-10, today-1], rather than ingesting data for just // [today-1]. Only valid if the data source supports the feature. Set // the value to 0 to use the default value. DataRefreshWindowDays int64 `json:"dataRefreshWindowDays,omitempty"` // DataSourceId: Data source ID. This cannot be changed once data // transfer is created. The full list of available data source IDs can // be returned through an API call: // https://cloud.google.com/bigquery-transfer/docs/reference/datatransfer/rest/v1/projects.locations.dataSources/list DataSourceId string `json:"dataSourceId,omitempty"` // DatasetRegion: Output only. Region in which BigQuery dataset is // located. DatasetRegion string `json:"datasetRegion,omitempty"` // DestinationDatasetId: The BigQuery target dataset id. DestinationDatasetId string `json:"destinationDatasetId,omitempty"` // Disabled: Is this config disabled. When set to true, no runs are // scheduled for a given transfer. Disabled bool `json:"disabled,omitempty"` // DisplayName: User specified display name for the data transfer. DisplayName string `json:"displayName,omitempty"` // EmailPreferences: Email notifications will be sent according to these // preferences to the email address of the user who owns this transfer // config. EmailPreferences *EmailPreferences `json:"emailPreferences,omitempty"` // EncryptionConfiguration: The encryption configuration part. // Currently, it is only used for the optional KMS key name. The // BigQuery service account of your project must be granted permissions // to use the key. Read methods will return the key name applied in // effect. Write methods will apply the key if it is present, or // otherwise try to apply project default keys if it is absent. EncryptionConfiguration *EncryptionConfiguration `json:"encryptionConfiguration,omitempty"` // Name: The resource name of the transfer config. Transfer config names // have the form either // `projects/{project_id}/locations/{region}/transferConfigs/{config_id}` // or `projects/{project_id}/transferConfigs/{config_id}`, where // `config_id` is usually a UUID, even though it is not guaranteed or // required. The name is ignored when creating a transfer config. Name string `json:"name,omitempty"` // NextRunTime: Output only. Next time when data transfer will run. NextRunTime string `json:"nextRunTime,omitempty"` // NotificationPubsubTopic: Pub/Sub topic where notifications will be // sent after transfer runs associated with this transfer config finish. // The format for specifying a pubsub topic is: // `projects/{project}/topics/{topic}` NotificationPubsubTopic string `json:"notificationPubsubTopic,omitempty"` // OwnerInfo: Output only. Information about the user whose credentials // are used to transfer data. Populated only for `transferConfigs.get` // requests. In case the user information is not available, this field // will not be populated. OwnerInfo *UserInfo `json:"ownerInfo,omitempty"` // Params: Parameters specific to each data source. For more information // see the bq tab in the 'Setting up a data transfer' section for each // data source. For example the parameters for Cloud Storage transfers // are listed here: // https://cloud.google.com/bigquery-transfer/docs/cloud-storage-transfer#bq Params googleapi.RawMessage `json:"params,omitempty"` // Schedule: Data transfer schedule. If the data source does not support // a custom schedule, this should be empty. If it is empty, the default // value for the data source will be used. The specified times are in // UTC. Examples of valid format: `1st,3rd monday of month 15:30`, // `every wed,fri of jan,jun 13:15`, and `first sunday of quarter // 00:00`. See more explanation about the format here: // https://cloud.google.com/appengine/docs/flexible/python/scheduling-jobs-with-cron-yaml#the_schedule_format // NOTE: The minimum interval time between recurring transfers depends // on the data source; refer to the documentation for your data source. Schedule string `json:"schedule,omitempty"` // ScheduleOptions: Options customizing the data transfer schedule. ScheduleOptions *ScheduleOptions `json:"scheduleOptions,omitempty"` // State: Output only. State of the most recently updated transfer run. // // Possible values: // "TRANSFER_STATE_UNSPECIFIED" - State placeholder (0). // "PENDING" - Data transfer is scheduled and is waiting to be picked // up by data transfer backend (2). // "RUNNING" - Data transfer is in progress (3). // "SUCCEEDED" - Data transfer completed successfully (4). // "FAILED" - Data transfer failed (5). // "CANCELLED" - Data transfer is cancelled (6). State string `json:"state,omitempty"` // UpdateTime: Output only. Data transfer modification time. Ignored by // server on input. UpdateTime string `json:"updateTime,omitempty"` // UserId: Deprecated. Unique ID of the user on whose behalf transfer is // done. UserId int64 `json:"userId,omitempty,string"` // ServerResponse contains the HTTP response code and headers from the // server. googleapi.ServerResponse `json:"-"` // ForceSendFields is a list of field names (e.g. // "DataRefreshWindowDays") to unconditionally include in API requests. // By default, fields with empty or default values are omitted from API // requests. However, any non-pointer, non-interface field appearing in // ForceSendFields will be sent to the server regardless of whether the // field is empty or not. This may be used to include empty fields in // Patch requests. ForceSendFields []string `json:"-"` // NullFields is a list of field names (e.g. "DataRefreshWindowDays") to // include in API requests with the JSON null value. By default, fields // with empty values are omitted from API requests. However, any field // with an empty value appearing in NullFields will be sent to the // server as null. It is an error if a field in this list has a // non-empty value. This may be used to include null fields in Patch // requests. NullFields []string `json:"-"` }
TransferConfig: Represents a data transfer configuration. A transfer configuration contains all metadata needed to perform a data transfer. For example, `destination_dataset_id` specifies where data should be stored. When a new transfer configuration is created, the specified `destination_dataset_id` is created when needed and shared with the appropriate data source service account.
func (*TransferConfig) MarshalJSON ¶
func (s *TransferConfig) MarshalJSON() ([]byte, error)
type TransferMessage ¶
type TransferMessage struct { // MessageText: Message text. MessageText string `json:"messageText,omitempty"` // MessageTime: Time when message was logged. MessageTime string `json:"messageTime,omitempty"` // Severity: Message severity. // // Possible values: // "MESSAGE_SEVERITY_UNSPECIFIED" - No severity specified. // "INFO" - Informational message. // "WARNING" - Warning message. // "ERROR" - Error message. Severity string `json:"severity,omitempty"` // ForceSendFields is a list of field names (e.g. "MessageText") to // unconditionally include in API requests. By default, fields with // empty or default values are omitted from API requests. However, any // non-pointer, non-interface field appearing in ForceSendFields will be // sent to the server regardless of whether the field is empty or not. // This may be used to include empty fields in Patch requests. ForceSendFields []string `json:"-"` // NullFields is a list of field names (e.g. "MessageText") to include // in API requests with the JSON null value. By default, fields with // empty values are omitted from API requests. However, any field with // an empty value appearing in NullFields will be sent to the server as // null. It is an error if a field in this list has a non-empty value. // This may be used to include null fields in Patch requests. NullFields []string `json:"-"` }
TransferMessage: Represents a user facing message for a particular data transfer run.
func (*TransferMessage) MarshalJSON ¶
func (s *TransferMessage) MarshalJSON() ([]byte, error)
type TransferRun ¶
type TransferRun struct { // DataSourceId: Output only. Data source id. DataSourceId string `json:"dataSourceId,omitempty"` // DestinationDatasetId: Output only. The BigQuery target dataset id. DestinationDatasetId string `json:"destinationDatasetId,omitempty"` // EmailPreferences: Output only. Email notifications will be sent // according to these preferences to the email address of the user who // owns the transfer config this run was derived from. EmailPreferences *EmailPreferences `json:"emailPreferences,omitempty"` // EndTime: Output only. Time when transfer run ended. Parameter ignored // by server for input requests. EndTime string `json:"endTime,omitempty"` // ErrorStatus: Status of the transfer run. ErrorStatus *Status `json:"errorStatus,omitempty"` // Name: The resource name of the transfer run. Transfer run names have // the form // `projects/{project_id}/locations/{location}/transferConfigs/{config_id // }/runs/{run_id}`. The name is ignored when creating a transfer run. Name string `json:"name,omitempty"` // NotificationPubsubTopic: Output only. Pub/Sub topic where a // notification will be sent after this transfer run finishes. The // format for specifying a pubsub topic is: // `projects/{project}/topics/{topic}` NotificationPubsubTopic string `json:"notificationPubsubTopic,omitempty"` // Params: Output only. Parameters specific to each data source. For // more information see the bq tab in the 'Setting up a data transfer' // section for each data source. For example the parameters for Cloud // Storage transfers are listed here: // https://cloud.google.com/bigquery-transfer/docs/cloud-storage-transfer#bq Params googleapi.RawMessage `json:"params,omitempty"` // RunTime: For batch transfer runs, specifies the date and time of the // data should be ingested. RunTime string `json:"runTime,omitempty"` // Schedule: Output only. Describes the schedule of this transfer run if // it was created as part of a regular schedule. For batch transfer runs // that are scheduled manually, this is empty. NOTE: the system might // choose to delay the schedule depending on the current load, so // `schedule_time` doesn't always match this. Schedule string `json:"schedule,omitempty"` // ScheduleTime: Minimum time after which a transfer run can be started. ScheduleTime string `json:"scheduleTime,omitempty"` // StartTime: Output only. Time when transfer run was started. Parameter // ignored by server for input requests. StartTime string `json:"startTime,omitempty"` // State: Data transfer run state. Ignored for input requests. // // Possible values: // "TRANSFER_STATE_UNSPECIFIED" - State placeholder (0). // "PENDING" - Data transfer is scheduled and is waiting to be picked // up by data transfer backend (2). // "RUNNING" - Data transfer is in progress (3). // "SUCCEEDED" - Data transfer completed successfully (4). // "FAILED" - Data transfer failed (5). // "CANCELLED" - Data transfer is cancelled (6). State string `json:"state,omitempty"` // UpdateTime: Output only. Last time the data transfer run state was // updated. UpdateTime string `json:"updateTime,omitempty"` // UserId: Deprecated. Unique ID of the user on whose behalf transfer is // done. UserId int64 `json:"userId,omitempty,string"` // ServerResponse contains the HTTP response code and headers from the // server. googleapi.ServerResponse `json:"-"` // ForceSendFields is a list of field names (e.g. "DataSourceId") to // unconditionally include in API requests. By default, fields with // empty or default values are omitted from API requests. However, any // non-pointer, non-interface field appearing in ForceSendFields will be // sent to the server regardless of whether the field is empty or not. // This may be used to include empty fields in Patch requests. ForceSendFields []string `json:"-"` // NullFields is a list of field names (e.g. "DataSourceId") to include // in API requests with the JSON null value. By default, fields with // empty values are omitted from API requests. However, any field with // an empty value appearing in NullFields will be sent to the server as // null. It is an error if a field in this list has a non-empty value. // This may be used to include null fields in Patch requests. NullFields []string `json:"-"` }
TransferRun: Represents a data transfer run.
func (*TransferRun) MarshalJSON ¶
func (s *TransferRun) MarshalJSON() ([]byte, error)
type UserInfo ¶ added in v0.55.0
type UserInfo struct { // Email: E-mail address of the user. Email string `json:"email,omitempty"` // ForceSendFields is a list of field names (e.g. "Email") to // unconditionally include in API requests. By default, fields with // empty or default values are omitted from API requests. However, any // non-pointer, non-interface field appearing in ForceSendFields will be // sent to the server regardless of whether the field is empty or not. // This may be used to include empty fields in Patch requests. ForceSendFields []string `json:"-"` // NullFields is a list of field names (e.g. "Email") to include in API // requests with the JSON null value. By default, fields with empty // values are omitted from API requests. However, any field with an // empty value appearing in NullFields will be sent to the server as // null. It is an error if a field in this list has a non-empty value. // This may be used to include null fields in Patch requests. NullFields []string `json:"-"` }
UserInfo: Information about a user.