genproto: google.golang.org/genproto/googleapis/cloud/bigquery/datatransfer/v1 Index | Files

package datatransfer

import "google.golang.org/genproto/googleapis/cloud/bigquery/datatransfer/v1"

Index

Package Files

datasource.pb.go datatransfer.pb.go transfer.pb.go

Variables

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

Enum value maps for DataSourceParameter_Type.

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

Enum value maps for DataSource_AuthorizationType.

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

Enum value maps for DataSource_DataRefreshType.

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

Enum value maps for ListTransferRunsRequest_RunAttempt.

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

Enum value maps for TransferType.

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

Enum value maps for TransferState.

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

Enum value maps for TransferMessage_MessageSeverity.

var File_google_cloud_bigquery_datatransfer_v1_datatransfer_proto protoreflect.FileDescriptor
var File_google_cloud_bigquery_datatransfer_v1_transfer_proto protoreflect.FileDescriptor
var ImportedDataInfo_Encoding_name = map[int32]string{
    0:  "ENCODING_UNSPECIFIED",
    1:  "ISO_8859_1",
    2:  "UTF8",
}
var ImportedDataInfo_Encoding_value = map[string]int32{
    "ENCODING_UNSPECIFIED": 0,
    "ISO_8859_1":           1,
    "UTF8":                 2,
}
var ImportedDataInfo_FieldSchema_Type_name = map[int32]string{
    0:  "TYPE_UNSPECIFIED",
    1:  "STRING",
    2:  "INTEGER",
    3:  "FLOAT",
    4:  "RECORD",
    5:  "BYTES",
    6:  "BOOLEAN",
    7:  "TIMESTAMP",
    8:  "DATE",
    9:  "TIME",
    10: "DATETIME",
    11: "NUMERIC",
    12: "GEOGRAPHY",
}
var ImportedDataInfo_FieldSchema_Type_value = map[string]int32{
    "TYPE_UNSPECIFIED": 0,
    "STRING":           1,
    "INTEGER":          2,
    "FLOAT":            3,
    "RECORD":           4,
    "BYTES":            5,
    "BOOLEAN":          6,
    "TIMESTAMP":        7,
    "DATE":             8,
    "TIME":             9,
    "DATETIME":         10,
    "NUMERIC":          11,
    "GEOGRAPHY":        12,
}
var ImportedDataInfo_Format_name = map[int32]string{
    0:  "FORMAT_UNSPECIFIED",
    1:  "CSV",
    2:  "JSON",
    3:  "AVRO",
    4:  "RECORDIO",
    5:  "COLUMNIO",
    6:  "CAPACITOR",
    7:  "PARQUET",
    8:  "ORC",
}
var ImportedDataInfo_Format_value = map[string]int32{
    "FORMAT_UNSPECIFIED": 0,
    "CSV":                1,
    "JSON":               2,
    "AVRO":               3,
    "RECORDIO":           4,
    "COLUMNIO":           5,
    "CAPACITOR":          6,
    "PARQUET":            7,
    "ORC":                8,
}
var WriteDisposition_name = map[int32]string{
    0:  "WRITE_DISPOSITION_UNSPECIFIED",
    1:  "WRITE_TRUNCATE",
    2:  "WRITE_APPEND",
}
var WriteDisposition_value = map[string]int32{
    "WRITE_DISPOSITION_UNSPECIFIED": 0,
    "WRITE_TRUNCATE":                1,
    "WRITE_APPEND":                  2,
}

func RegisterDataSourceServiceServer Uses

func RegisterDataSourceServiceServer(s *grpc.Server, srv DataSourceServiceServer)

func RegisterDataTransferServiceServer Uses

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

type CheckValidCredsRequest Uses

type CheckValidCredsRequest struct {

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

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.

func (*CheckValidCredsRequest) Descriptor Uses

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

Deprecated: Use CheckValidCredsRequest.ProtoReflect.Descriptor instead.

func (*CheckValidCredsRequest) GetName Uses

func (x *CheckValidCredsRequest) GetName() string

func (*CheckValidCredsRequest) ProtoMessage Uses

func (*CheckValidCredsRequest) ProtoMessage()

func (*CheckValidCredsRequest) ProtoReflect Uses

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

func (*CheckValidCredsRequest) Reset Uses

func (x *CheckValidCredsRequest) Reset()

func (*CheckValidCredsRequest) String Uses

func (x *CheckValidCredsRequest) String() string

type CheckValidCredsResponse Uses

type CheckValidCredsResponse struct {

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

A response indicating whether the credentials exist and are valid.

func (*CheckValidCredsResponse) Descriptor Uses

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

Deprecated: Use CheckValidCredsResponse.ProtoReflect.Descriptor instead.

func (*CheckValidCredsResponse) GetHasValidCreds Uses

func (x *CheckValidCredsResponse) GetHasValidCreds() bool

func (*CheckValidCredsResponse) ProtoMessage Uses

func (*CheckValidCredsResponse) ProtoMessage()

func (*CheckValidCredsResponse) ProtoReflect Uses

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

func (*CheckValidCredsResponse) Reset Uses

func (x *CheckValidCredsResponse) Reset()

func (*CheckValidCredsResponse) String Uses

func (x *CheckValidCredsResponse) String() string

type CreateDataSourceDefinitionRequest Uses

type CreateDataSourceDefinitionRequest struct {
    // The BigQuery project id for which data source definition is associated.
    // Must be in the form: `projects/{project_id}/locations/{location_id}`
    Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
    // Data source definition.
    DataSourceDefinition *DataSourceDefinition `protobuf:"bytes,2,opt,name=data_source_definition,json=dataSourceDefinition,proto3" json:"data_source_definition,omitempty"`
    XXX_NoUnkeyedLiteral struct{}              `json:"-"`
    XXX_unrecognized     []byte                `json:"-"`
    XXX_sizecache        int32                 `json:"-"`
}

Represents the request of the CreateDataSourceDefinition method.

func (*CreateDataSourceDefinitionRequest) Descriptor Uses

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

func (*CreateDataSourceDefinitionRequest) GetDataSourceDefinition Uses

func (m *CreateDataSourceDefinitionRequest) GetDataSourceDefinition() *DataSourceDefinition

func (*CreateDataSourceDefinitionRequest) GetParent Uses

func (m *CreateDataSourceDefinitionRequest) GetParent() string

func (*CreateDataSourceDefinitionRequest) ProtoMessage Uses

func (*CreateDataSourceDefinitionRequest) ProtoMessage()

func (*CreateDataSourceDefinitionRequest) Reset Uses

func (m *CreateDataSourceDefinitionRequest) Reset()

func (*CreateDataSourceDefinitionRequest) String Uses

func (m *CreateDataSourceDefinitionRequest) String() string

func (*CreateDataSourceDefinitionRequest) XXX_DiscardUnknown Uses

func (m *CreateDataSourceDefinitionRequest) XXX_DiscardUnknown()

func (*CreateDataSourceDefinitionRequest) XXX_Marshal Uses

func (m *CreateDataSourceDefinitionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CreateDataSourceDefinitionRequest) XXX_Merge Uses

func (m *CreateDataSourceDefinitionRequest) XXX_Merge(src proto.Message)

func (*CreateDataSourceDefinitionRequest) XXX_Size Uses

func (m *CreateDataSourceDefinitionRequest) XXX_Size() int

func (*CreateDataSourceDefinitionRequest) XXX_Unmarshal Uses

func (m *CreateDataSourceDefinitionRequest) XXX_Unmarshal(b []byte) error

type CreateTransferConfigRequest Uses

type CreateTransferConfigRequest struct {

    // Required. The BigQuery project id where the transfer configuration should be created.
    // Must be in the format projects/{project_id}/locations/{location_id} or
    // projects/{project_id}. If specified location and location of the
    // destination bigquery dataset do not match - the request will fail.
    Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
    // Required. Data transfer configuration to create.
    TransferConfig *TransferConfig `protobuf:"bytes,2,opt,name=transfer_config,json=transferConfig,proto3" json:"transfer_config,omitempty"`
    // Optional OAuth2 authorization code to use with this transfer configuration.
    // This is required if new credentials are needed, as indicated by
    // `CheckValidCreds`.
    // In order to obtain authorization_code, please make a
    // request to
    // https://www.gstatic.com/bigquerydatatransfer/oauthz/auth?client_id=<datatransferapiclientid>&scope=<data_source_scopes>&redirect_uri=<redirect_uri>
    //
    // * client_id should be OAuth client_id of BigQuery DTS API for the given
    //   data source returned by ListDataSources method.
    // * data_source_scopes are the scopes returned by ListDataSources method.
    // * redirect_uri is an optional parameter. If not specified, then
    //   authorization code is posted to the opener of authorization flow window.
    //   Otherwise it will be sent to the redirect uri. A special value of
    //   urn:ietf:wg:oauth:2.0:oob means that authorization code should be
    //   returned in the title bar of the browser, with the page text prompting
    //   the user to copy the code and paste it in the application.
    AuthorizationCode string `protobuf:"bytes,3,opt,name=authorization_code,json=authorizationCode,proto3" json:"authorization_code,omitempty"`
    // Optional version info. If users want to find a very recent access token,
    // that is, immediately after approving access, users have to set the
    // version_info claim in the token request. To obtain the version_info, users
    // must use the "none+gsession" response type. which be return a
    // version_info back in the authorization response which be be put in a JWT
    // claim in the token request.
    VersionInfo string `protobuf:"bytes,5,opt,name=version_info,json=versionInfo,proto3" json:"version_info,omitempty"`
    // Optional service account name. If this field is set, transfer config will
    // be created with this service account credentials. It requires that
    // requesting user calling this API has permissions to act as this service
    // account.
    ServiceAccountName string `protobuf:"bytes,6,opt,name=service_account_name,json=serviceAccountName,proto3" json:"service_account_name,omitempty"`
    // contains filtered or unexported fields
}

A request to create a data transfer configuration. If new credentials are needed for this transfer configuration, an authorization code must be provided. If an authorization code is provided, the transfer configuration will be associated with the user id corresponding to the authorization code. Otherwise, the transfer configuration will be associated with the calling user.

func (*CreateTransferConfigRequest) Descriptor Uses

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

Deprecated: Use CreateTransferConfigRequest.ProtoReflect.Descriptor instead.

func (*CreateTransferConfigRequest) GetAuthorizationCode Uses

func (x *CreateTransferConfigRequest) GetAuthorizationCode() string

func (*CreateTransferConfigRequest) GetParent Uses

func (x *CreateTransferConfigRequest) GetParent() string

func (*CreateTransferConfigRequest) GetServiceAccountName Uses

func (x *CreateTransferConfigRequest) GetServiceAccountName() string

func (*CreateTransferConfigRequest) GetTransferConfig Uses

func (x *CreateTransferConfigRequest) GetTransferConfig() *TransferConfig

func (*CreateTransferConfigRequest) GetVersionInfo Uses

func (x *CreateTransferConfigRequest) GetVersionInfo() string

func (*CreateTransferConfigRequest) ProtoMessage Uses

func (*CreateTransferConfigRequest) ProtoMessage()

func (*CreateTransferConfigRequest) ProtoReflect Uses

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

func (*CreateTransferConfigRequest) Reset Uses

func (x *CreateTransferConfigRequest) Reset()

func (*CreateTransferConfigRequest) String Uses

func (x *CreateTransferConfigRequest) String() string

type DataSource Uses

type DataSource struct {

    // Output only. Data source resource name.
    Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
    // Data source id.
    DataSourceId string `protobuf:"bytes,2,opt,name=data_source_id,json=dataSourceId,proto3" json:"data_source_id,omitempty"`
    // User friendly data source name.
    DisplayName string `protobuf:"bytes,3,opt,name=display_name,json=displayName,proto3" json:"display_name,omitempty"`
    // User friendly data source description string.
    Description string `protobuf:"bytes,4,opt,name=description,proto3" json:"description,omitempty"`
    // Data source client id which should be used to receive refresh token.
    ClientId string `protobuf:"bytes,5,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"`
    // 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 `protobuf:"bytes,6,rep,name=scopes,proto3" json:"scopes,omitempty"`
    // Deprecated. This field has no effect.
    //
    // Deprecated: Do not use.
    TransferType TransferType `protobuf:"varint,7,opt,name=transfer_type,json=transferType,proto3,enum=google.cloud.bigquery.datatransfer.v1.TransferType" json:"transfer_type,omitempty"`
    // Deprecated. This field has no effect.
    //
    // Deprecated: Do not use.
    SupportsMultipleTransfers bool `protobuf:"varint,8,opt,name=supports_multiple_transfers,json=supportsMultipleTransfers,proto3" json:"supports_multiple_transfers,omitempty"`
    // The number of seconds to wait for an update from the data source
    // before the Data Transfer Service marks the transfer as FAILED.
    UpdateDeadlineSeconds int32 `protobuf:"varint,9,opt,name=update_deadline_seconds,json=updateDeadlineSeconds,proto3" json:"update_deadline_seconds,omitempty"`
    // 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 `protobuf:"bytes,10,opt,name=default_schedule,json=defaultSchedule,proto3" json:"default_schedule,omitempty"`
    // 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 `protobuf:"varint,11,opt,name=supports_custom_schedule,json=supportsCustomSchedule,proto3" json:"supports_custom_schedule,omitempty"`
    // Data source parameters.
    Parameters []*DataSourceParameter `protobuf:"bytes,12,rep,name=parameters,proto3" json:"parameters,omitempty"`
    // Url for the help document for this data source.
    HelpUrl string `protobuf:"bytes,13,opt,name=help_url,json=helpUrl,proto3" json:"help_url,omitempty"`
    // Indicates the type of authorization.
    AuthorizationType DataSource_AuthorizationType `protobuf:"varint,14,opt,name=authorization_type,json=authorizationType,proto3,enum=google.cloud.bigquery.datatransfer.v1.DataSource_AuthorizationType" json:"authorization_type,omitempty"`
    // 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.
    DataRefreshType DataSource_DataRefreshType `protobuf:"varint,15,opt,name=data_refresh_type,json=dataRefreshType,proto3,enum=google.cloud.bigquery.datatransfer.v1.DataSource_DataRefreshType" json:"data_refresh_type,omitempty"`
    // Default data refresh window on days.
    // Only meaningful when `data_refresh_type` = `SLIDING_WINDOW`.
    DefaultDataRefreshWindowDays int32 `protobuf:"varint,16,opt,name=default_data_refresh_window_days,json=defaultDataRefreshWindowDays,proto3" json:"default_data_refresh_window_days,omitempty"`
    // Disables backfilling and manual run scheduling
    // for the data source.
    ManualRunsDisabled bool `protobuf:"varint,17,opt,name=manual_runs_disabled,json=manualRunsDisabled,proto3" json:"manual_runs_disabled,omitempty"`
    // The minimum interval for scheduler to schedule runs.
    MinimumScheduleInterval *duration.Duration `protobuf:"bytes,18,opt,name=minimum_schedule_interval,json=minimumScheduleInterval,proto3" json:"minimum_schedule_interval,omitempty"`
    // contains filtered or unexported fields
}

Represents data source metadata. Metadata is sufficient to render UI and request proper OAuth tokens.

func (*DataSource) Descriptor Uses

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

Deprecated: Use DataSource.ProtoReflect.Descriptor instead.

func (*DataSource) GetAuthorizationType Uses

func (x *DataSource) GetAuthorizationType() DataSource_AuthorizationType

func (*DataSource) GetClientId Uses

func (x *DataSource) GetClientId() string

func (*DataSource) GetDataRefreshType Uses

func (x *DataSource) GetDataRefreshType() DataSource_DataRefreshType

func (*DataSource) GetDataSourceId Uses

func (x *DataSource) GetDataSourceId() string

func (*DataSource) GetDefaultDataRefreshWindowDays Uses

func (x *DataSource) GetDefaultDataRefreshWindowDays() int32

func (*DataSource) GetDefaultSchedule Uses

func (x *DataSource) GetDefaultSchedule() string

func (*DataSource) GetDescription Uses

func (x *DataSource) GetDescription() string

func (*DataSource) GetDisplayName Uses

func (x *DataSource) GetDisplayName() string

func (*DataSource) GetHelpUrl Uses

func (x *DataSource) GetHelpUrl() string

func (*DataSource) GetManualRunsDisabled Uses

func (x *DataSource) GetManualRunsDisabled() bool

func (*DataSource) GetMinimumScheduleInterval Uses

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

func (*DataSource) GetName Uses

func (x *DataSource) GetName() string

func (*DataSource) GetParameters Uses

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

func (*DataSource) GetScopes Uses

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

func (*DataSource) GetSupportsCustomSchedule Uses

func (x *DataSource) GetSupportsCustomSchedule() bool

func (*DataSource) GetSupportsMultipleTransfers Uses

func (x *DataSource) GetSupportsMultipleTransfers() bool

Deprecated: Do not use.

func (*DataSource) GetTransferType Uses

func (x *DataSource) GetTransferType() TransferType

Deprecated: Do not use.

func (*DataSource) GetUpdateDeadlineSeconds Uses

func (x *DataSource) GetUpdateDeadlineSeconds() int32

func (*DataSource) ProtoMessage Uses

func (*DataSource) ProtoMessage()

func (*DataSource) ProtoReflect Uses

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

func (*DataSource) Reset Uses

func (x *DataSource) Reset()

func (*DataSource) String Uses

func (x *DataSource) String() string

type DataSourceDefinition Uses

type DataSourceDefinition struct {
    // The resource name of the data source definition.
    // Data source definition names have the form
    // `projects/{project_id}/locations/{location}/dataSourceDefinitions/{data_source_id}`.
    Name string `protobuf:"bytes,21,opt,name=name,proto3" json:"name,omitempty"`
    // Data source metadata.
    DataSource *DataSource `protobuf:"bytes,1,opt,name=data_source,json=dataSource,proto3" json:"data_source,omitempty"`
    // The Pub/Sub topic to be used for broadcasting a message when a transfer run
    // is created. Both this topic and transfer_config_pubsub_topic can be
    // set to a custom topic. By default, both topics are auto-generated if none
    // of them is provided when creating the definition. However, if one topic is
    // manually set, the other topic has to be manually set as well. The only
    // difference is that transfer_run_pubsub_topic must be a non-empty Pub/Sub
    // topic, but transfer_config_pubsub_topic can be set to empty. The comments
    // about "{location}" for transfer_config_pubsub_topic apply here too.
    TransferRunPubsubTopic string `protobuf:"bytes,13,opt,name=transfer_run_pubsub_topic,json=transferRunPubsubTopic,proto3" json:"transfer_run_pubsub_topic,omitempty"`
    // Duration which should be added to schedule_time to calculate
    // run_time when job is scheduled. Only applicable for automatically
    // scheduled transfer runs. Used to start a run early on a data source that
    // supports continuous data refresh to compensate for unknown timezone
    // offsets. Use a negative number to start a run late for data sources not
    // supporting continuous data refresh.
    RunTimeOffset *duration.Duration `protobuf:"bytes,16,opt,name=run_time_offset,json=runTimeOffset,proto3" json:"run_time_offset,omitempty"`
    // Support e-mail address of the OAuth client's Brand, which contains the
    // consent screen data.
    SupportEmail string `protobuf:"bytes,22,opt,name=support_email,json=supportEmail,proto3" json:"support_email,omitempty"`
    // When service account is specified, BigQuery will share created dataset
    // with the given service account. Also, this service account will be
    // eligible to perform status updates and message logging for data transfer
    // runs for the corresponding data_source_id.
    ServiceAccount string `protobuf:"bytes,2,opt,name=service_account,json=serviceAccount,proto3" json:"service_account,omitempty"`
    // Is data source disabled? If true, data_source is not visible.
    // API will also stop returning any data transfer configs and/or runs
    // associated with the data source. This setting has higher priority
    // than whitelisted_project_ids.
    Disabled bool `protobuf:"varint,5,opt,name=disabled,proto3" json:"disabled,omitempty"`
    // The Pub/Sub topic to use for broadcasting a message for transfer config. If
    // empty, a message will not be broadcasted. Both this topic and
    // transfer_run_pubsub_topic are auto-generated if none of them is provided
    // when creating the definition. It is recommended to provide
    // transfer_config_pubsub_topic if a user-owned transfer_run_pubsub_topic is
    // provided. Otherwise, it will be set to empty. If "{location}" is found in
    // the value, then that means, data source wants to handle message separately
    // for datasets in different regions. We will replace {location} with the
    // actual dataset location, as the actual topic name. For example,
    // projects/connector/topics/scheduler-{location} could become
    // projects/connector/topics/scheduler-us. If "{location}" is not found, then
    // we will use the input value as topic name.
    TransferConfigPubsubTopic string `protobuf:"bytes,12,opt,name=transfer_config_pubsub_topic,json=transferConfigPubsubTopic,proto3" json:"transfer_config_pubsub_topic,omitempty"`
    // Supported location_ids used for deciding in which locations Pub/Sub topics
    // need to be created. If custom Pub/Sub topics are used and they contains
    // '{location}', the location_ids will be used for validating the topics by
    // replacing the '{location}' with the individual location in the list. The
    // valid values are the "location_id" field of the response of `GET
    // https://bigquerydatatransfer.googleapis.com/v1/{name=projects/*}/locations`
    // In addition, if the data source needs to support all available regions,
    // supported_location_ids can be set to "global" (a single string element).
    // When "global" is specified:
    // 1) the data source implementation is supposed to stage the data in proper
    // region of the destination dataset;
    // 2) Data source developer should be aware of the implications (e.g., network
    // traffic latency, potential charge associated with cross-region traffic,
    // etc.) of supporting the "global" region;
    SupportedLocationIds []string `protobuf:"bytes,23,rep,name=supported_location_ids,json=supportedLocationIds,proto3" json:"supported_location_ids,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

Represents the data source definition.

func (*DataSourceDefinition) Descriptor Uses

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

func (*DataSourceDefinition) GetDataSource Uses

func (m *DataSourceDefinition) GetDataSource() *DataSource

func (*DataSourceDefinition) GetDisabled Uses

func (m *DataSourceDefinition) GetDisabled() bool

func (*DataSourceDefinition) GetName Uses

func (m *DataSourceDefinition) GetName() string

func (*DataSourceDefinition) GetRunTimeOffset Uses

func (m *DataSourceDefinition) GetRunTimeOffset() *duration.Duration

func (*DataSourceDefinition) GetServiceAccount Uses

func (m *DataSourceDefinition) GetServiceAccount() string

func (*DataSourceDefinition) GetSupportEmail Uses

func (m *DataSourceDefinition) GetSupportEmail() string

func (*DataSourceDefinition) GetSupportedLocationIds Uses

func (m *DataSourceDefinition) GetSupportedLocationIds() []string

func (*DataSourceDefinition) GetTransferConfigPubsubTopic Uses

func (m *DataSourceDefinition) GetTransferConfigPubsubTopic() string

func (*DataSourceDefinition) GetTransferRunPubsubTopic Uses

func (m *DataSourceDefinition) GetTransferRunPubsubTopic() string

func (*DataSourceDefinition) ProtoMessage Uses

func (*DataSourceDefinition) ProtoMessage()

func (*DataSourceDefinition) Reset Uses

func (m *DataSourceDefinition) Reset()

func (*DataSourceDefinition) String Uses

func (m *DataSourceDefinition) String() string

func (*DataSourceDefinition) XXX_DiscardUnknown Uses

func (m *DataSourceDefinition) XXX_DiscardUnknown()

func (*DataSourceDefinition) XXX_Marshal Uses

func (m *DataSourceDefinition) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DataSourceDefinition) XXX_Merge Uses

func (m *DataSourceDefinition) XXX_Merge(src proto.Message)

func (*DataSourceDefinition) XXX_Size Uses

func (m *DataSourceDefinition) XXX_Size() int

func (*DataSourceDefinition) XXX_Unmarshal Uses

func (m *DataSourceDefinition) XXX_Unmarshal(b []byte) error

type DataSourceParameter Uses

type DataSourceParameter struct {

    // Parameter identifier.
    ParamId string `protobuf:"bytes,1,opt,name=param_id,json=paramId,proto3" json:"param_id,omitempty"`
    // Parameter display name in the user interface.
    DisplayName string `protobuf:"bytes,2,opt,name=display_name,json=displayName,proto3" json:"display_name,omitempty"`
    // Parameter description.
    Description string `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
    // Parameter type.
    Type DataSourceParameter_Type `protobuf:"varint,4,opt,name=type,proto3,enum=google.cloud.bigquery.datatransfer.v1.DataSourceParameter_Type" json:"type,omitempty"`
    // Is parameter required.
    Required bool `protobuf:"varint,5,opt,name=required,proto3" json:"required,omitempty"`
    // Deprecated. This field has no effect.
    Repeated bool `protobuf:"varint,6,opt,name=repeated,proto3" json:"repeated,omitempty"`
    // Regular expression which can be used for parameter validation.
    ValidationRegex string `protobuf:"bytes,7,opt,name=validation_regex,json=validationRegex,proto3" json:"validation_regex,omitempty"`
    // All possible values for the parameter.
    AllowedValues []string `protobuf:"bytes,8,rep,name=allowed_values,json=allowedValues,proto3" json:"allowed_values,omitempty"`
    // For integer and double values specifies minimum allowed value.
    MinValue *wrappers.DoubleValue `protobuf:"bytes,9,opt,name=min_value,json=minValue,proto3" json:"min_value,omitempty"`
    // For integer and double values specifies maxminum allowed value.
    MaxValue *wrappers.DoubleValue `protobuf:"bytes,10,opt,name=max_value,json=maxValue,proto3" json:"max_value,omitempty"`
    // Deprecated. This field has no effect.
    Fields []*DataSourceParameter `protobuf:"bytes,11,rep,name=fields,proto3" json:"fields,omitempty"`
    // Description of the requirements for this field, in case the user input does
    // not fulfill the regex pattern or min/max values.
    ValidationDescription string `protobuf:"bytes,12,opt,name=validation_description,json=validationDescription,proto3" json:"validation_description,omitempty"`
    // URL to a help document to further explain the naming requirements.
    ValidationHelpUrl string `protobuf:"bytes,13,opt,name=validation_help_url,json=validationHelpUrl,proto3" json:"validation_help_url,omitempty"`
    // Cannot be changed after initial creation.
    Immutable bool `protobuf:"varint,14,opt,name=immutable,proto3" json:"immutable,omitempty"`
    // Deprecated. This field has no effect.
    Recurse bool `protobuf:"varint,15,opt,name=recurse,proto3" json:"recurse,omitempty"`
    // If true, it should not be used in new transfers, and it should not be
    // visible to users.
    Deprecated bool `protobuf:"varint,20,opt,name=deprecated,proto3" json:"deprecated,omitempty"`
    // contains filtered or unexported fields
}

Represents a data source parameter with validation rules, so that parameters can be rendered in the UI. These parameters are given to us by supported data sources, and include all needed information for rendering and validation. Thus, whoever uses this api can decide to generate either generic ui, or custom data source specific forms.

func (*DataSourceParameter) Descriptor Uses

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

Deprecated: Use DataSourceParameter.ProtoReflect.Descriptor instead.

func (*DataSourceParameter) GetAllowedValues Uses

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

func (*DataSourceParameter) GetDeprecated Uses

func (x *DataSourceParameter) GetDeprecated() bool

func (*DataSourceParameter) GetDescription Uses

func (x *DataSourceParameter) GetDescription() string

func (*DataSourceParameter) GetDisplayName Uses

func (x *DataSourceParameter) GetDisplayName() string

func (*DataSourceParameter) GetFields Uses

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

func (*DataSourceParameter) GetImmutable Uses

func (x *DataSourceParameter) GetImmutable() bool

func (*DataSourceParameter) GetMaxValue Uses

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

func (*DataSourceParameter) GetMinValue Uses

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

func (*DataSourceParameter) GetParamId Uses

func (x *DataSourceParameter) GetParamId() string

func (*DataSourceParameter) GetRecurse Uses

func (x *DataSourceParameter) GetRecurse() bool

func (*DataSourceParameter) GetRepeated Uses

func (x *DataSourceParameter) GetRepeated() bool

func (*DataSourceParameter) GetRequired Uses

func (x *DataSourceParameter) GetRequired() bool

func (*DataSourceParameter) GetType Uses

func (x *DataSourceParameter) GetType() DataSourceParameter_Type

func (*DataSourceParameter) GetValidationDescription Uses

func (x *DataSourceParameter) GetValidationDescription() string

func (*DataSourceParameter) GetValidationHelpUrl Uses

func (x *DataSourceParameter) GetValidationHelpUrl() string

func (*DataSourceParameter) GetValidationRegex Uses

func (x *DataSourceParameter) GetValidationRegex() string

func (*DataSourceParameter) ProtoMessage Uses

func (*DataSourceParameter) ProtoMessage()

func (*DataSourceParameter) ProtoReflect Uses

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

func (*DataSourceParameter) Reset Uses

func (x *DataSourceParameter) Reset()

func (*DataSourceParameter) String Uses

func (x *DataSourceParameter) String() string

type DataSourceParameter_Type Uses

type DataSourceParameter_Type int32

Parameter type.

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

func (DataSourceParameter_Type) Descriptor Uses

func (DataSourceParameter_Type) Descriptor() protoreflect.EnumDescriptor

func (DataSourceParameter_Type) Enum Uses

func (x DataSourceParameter_Type) Enum() *DataSourceParameter_Type

func (DataSourceParameter_Type) EnumDescriptor Uses

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

Deprecated: Use DataSourceParameter_Type.Descriptor instead.

func (DataSourceParameter_Type) Number Uses

func (x DataSourceParameter_Type) Number() protoreflect.EnumNumber

func (DataSourceParameter_Type) String Uses

func (x DataSourceParameter_Type) String() string

func (DataSourceParameter_Type) Type Uses

func (DataSourceParameter_Type) Type() protoreflect.EnumType

type DataSourceServiceClient Uses

type DataSourceServiceClient interface {
    // Update a transfer run. If successful, resets
    // data_source.update_deadline_seconds timer.
    UpdateTransferRun(ctx context.Context, in *UpdateTransferRunRequest, opts ...grpc.CallOption) (*TransferRun, error)
    // Log messages for a transfer run. If successful (at least 1 message), resets
    // data_source.update_deadline_seconds timer.
    LogTransferRunMessages(ctx context.Context, in *LogTransferRunMessagesRequest, opts ...grpc.CallOption) (*empty.Empty, error)
    // Notify the Data Transfer Service that data is ready for loading.
    // The Data Transfer Service will start and monitor multiple BigQuery Load
    // jobs for a transfer run. Monitored jobs will be automatically retried
    // and produce log messages when starting and finishing a job.
    // Can be called multiple times for the same transfer run.
    StartBigQueryJobs(ctx context.Context, in *StartBigQueryJobsRequest, opts ...grpc.CallOption) (*empty.Empty, error)
    // Notify the Data Transfer Service that the data source is done processing
    // the run. No more status updates or requests to start/monitor jobs will be
    // accepted. The run will be finalized by the Data Transfer Service when all
    // monitored jobs are completed.
    // Does not need to be called if the run is set to FAILED.
    FinishRun(ctx context.Context, in *FinishRunRequest, opts ...grpc.CallOption) (*empty.Empty, error)
    // Creates a data source definition.  Calling this method will automatically
    // use your credentials to create the following Google Cloud resources in
    // YOUR Google Cloud project.
    // 1. OAuth client
    // 2. Pub/Sub Topics and Subscriptions in each supported_location_ids. e.g.,
    // projects/{project_id}/{topics|subscriptions}/bigquerydatatransfer.{data_source_id}.{location_id}.run
    // The field data_source.client_id should be left empty in the input request,
    // as the API will create a new OAuth client on behalf of the caller. On the
    // other hand data_source.scopes usually need to be set when there are OAuth
    // scopes that need to be granted by end users.
    // 3. We need a longer deadline due to the 60 seconds SLO from Pub/Sub admin
    // Operations. This also applies to update and delete data source definition.
    CreateDataSourceDefinition(ctx context.Context, in *CreateDataSourceDefinitionRequest, opts ...grpc.CallOption) (*DataSourceDefinition, error)
    // Updates an existing data source definition. If changing
    // supported_location_ids, triggers same effects as mentioned in "Create a
    // data source definition."
    UpdateDataSourceDefinition(ctx context.Context, in *UpdateDataSourceDefinitionRequest, opts ...grpc.CallOption) (*DataSourceDefinition, error)
    // Deletes a data source definition, all of the transfer configs associated
    // with this data source definition (if any) must be deleted first by the user
    // in ALL regions, in order to delete the data source definition.
    // This method is primarily meant for deleting data sources created during
    // testing stage.
    // If the data source is referenced by transfer configs in the region
    // specified in the request URL, the method will fail immediately. If in the
    // current region (e.g., US) it's not used by any transfer configs, but in
    // another region (e.g., EU) it is, then although the method will succeed in
    // region US, but it will fail when the deletion operation is replicated to
    // region EU. And eventually, the system will replicate the data source
    // definition back from EU to US, in order to bring all regions to
    // consistency. The final effect is that the data source appears to be
    // 'undeleted' in the US region.
    DeleteDataSourceDefinition(ctx context.Context, in *DeleteDataSourceDefinitionRequest, opts ...grpc.CallOption) (*empty.Empty, error)
    // Retrieves an existing data source definition.
    GetDataSourceDefinition(ctx context.Context, in *GetDataSourceDefinitionRequest, opts ...grpc.CallOption) (*DataSourceDefinition, error)
    // Lists supported data source definitions.
    ListDataSourceDefinitions(ctx context.Context, in *ListDataSourceDefinitionsRequest, opts ...grpc.CallOption) (*ListDataSourceDefinitionsResponse, error)
}

DataSourceServiceClient is the client API for DataSourceService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewDataSourceServiceClient Uses

func NewDataSourceServiceClient(cc grpc.ClientConnInterface) DataSourceServiceClient

type DataSourceServiceServer Uses

type DataSourceServiceServer interface {
    // Update a transfer run. If successful, resets
    // data_source.update_deadline_seconds timer.
    UpdateTransferRun(context.Context, *UpdateTransferRunRequest) (*TransferRun, error)
    // Log messages for a transfer run. If successful (at least 1 message), resets
    // data_source.update_deadline_seconds timer.
    LogTransferRunMessages(context.Context, *LogTransferRunMessagesRequest) (*empty.Empty, error)
    // Notify the Data Transfer Service that data is ready for loading.
    // The Data Transfer Service will start and monitor multiple BigQuery Load
    // jobs for a transfer run. Monitored jobs will be automatically retried
    // and produce log messages when starting and finishing a job.
    // Can be called multiple times for the same transfer run.
    StartBigQueryJobs(context.Context, *StartBigQueryJobsRequest) (*empty.Empty, error)
    // Notify the Data Transfer Service that the data source is done processing
    // the run. No more status updates or requests to start/monitor jobs will be
    // accepted. The run will be finalized by the Data Transfer Service when all
    // monitored jobs are completed.
    // Does not need to be called if the run is set to FAILED.
    FinishRun(context.Context, *FinishRunRequest) (*empty.Empty, error)
    // Creates a data source definition.  Calling this method will automatically
    // use your credentials to create the following Google Cloud resources in
    // YOUR Google Cloud project.
    // 1. OAuth client
    // 2. Pub/Sub Topics and Subscriptions in each supported_location_ids. e.g.,
    // projects/{project_id}/{topics|subscriptions}/bigquerydatatransfer.{data_source_id}.{location_id}.run
    // The field data_source.client_id should be left empty in the input request,
    // as the API will create a new OAuth client on behalf of the caller. On the
    // other hand data_source.scopes usually need to be set when there are OAuth
    // scopes that need to be granted by end users.
    // 3. We need a longer deadline due to the 60 seconds SLO from Pub/Sub admin
    // Operations. This also applies to update and delete data source definition.
    CreateDataSourceDefinition(context.Context, *CreateDataSourceDefinitionRequest) (*DataSourceDefinition, error)
    // Updates an existing data source definition. If changing
    // supported_location_ids, triggers same effects as mentioned in "Create a
    // data source definition."
    UpdateDataSourceDefinition(context.Context, *UpdateDataSourceDefinitionRequest) (*DataSourceDefinition, error)
    // Deletes a data source definition, all of the transfer configs associated
    // with this data source definition (if any) must be deleted first by the user
    // in ALL regions, in order to delete the data source definition.
    // This method is primarily meant for deleting data sources created during
    // testing stage.
    // If the data source is referenced by transfer configs in the region
    // specified in the request URL, the method will fail immediately. If in the
    // current region (e.g., US) it's not used by any transfer configs, but in
    // another region (e.g., EU) it is, then although the method will succeed in
    // region US, but it will fail when the deletion operation is replicated to
    // region EU. And eventually, the system will replicate the data source
    // definition back from EU to US, in order to bring all regions to
    // consistency. The final effect is that the data source appears to be
    // 'undeleted' in the US region.
    DeleteDataSourceDefinition(context.Context, *DeleteDataSourceDefinitionRequest) (*empty.Empty, error)
    // Retrieves an existing data source definition.
    GetDataSourceDefinition(context.Context, *GetDataSourceDefinitionRequest) (*DataSourceDefinition, error)
    // Lists supported data source definitions.
    ListDataSourceDefinitions(context.Context, *ListDataSourceDefinitionsRequest) (*ListDataSourceDefinitionsResponse, error)
}

DataSourceServiceServer is the server API for DataSourceService service.

type DataSource_AuthorizationType Uses

type DataSource_AuthorizationType int32

The type of authorization needed for this data source.

const (
    // Type unspecified.
    DataSource_AUTHORIZATION_TYPE_UNSPECIFIED DataSource_AuthorizationType = 0
    // Use OAuth 2 authorization codes that can be exchanged
    // for a refresh token on the backend.
    DataSource_AUTHORIZATION_CODE DataSource_AuthorizationType = 1
    // Return an authorization code for a given Google+ page that can then be
    // exchanged for a refresh token on the backend.
    DataSource_GOOGLE_PLUS_AUTHORIZATION_CODE DataSource_AuthorizationType = 2
    // Use First Party Client OAuth. First Party Client OAuth doesn't require a
    // refresh token to get an offline access token. Instead, it uses a
    // client-signed JWT assertion to retrieve an access token.
    DataSource_FIRST_PARTY_OAUTH DataSource_AuthorizationType = 3
)

func (DataSource_AuthorizationType) Descriptor Uses

func (DataSource_AuthorizationType) Descriptor() protoreflect.EnumDescriptor

func (DataSource_AuthorizationType) Enum Uses

func (x DataSource_AuthorizationType) Enum() *DataSource_AuthorizationType

func (DataSource_AuthorizationType) EnumDescriptor Uses

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

Deprecated: Use DataSource_AuthorizationType.Descriptor instead.

func (DataSource_AuthorizationType) Number Uses

func (x DataSource_AuthorizationType) Number() protoreflect.EnumNumber

func (DataSource_AuthorizationType) String Uses

func (x DataSource_AuthorizationType) String() string

func (DataSource_AuthorizationType) Type Uses

func (DataSource_AuthorizationType) Type() protoreflect.EnumType

type DataSource_DataRefreshType Uses

type DataSource_DataRefreshType int32

Represents how the data source supports data auto refresh.

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

func (DataSource_DataRefreshType) Descriptor Uses

func (DataSource_DataRefreshType) Descriptor() protoreflect.EnumDescriptor

func (DataSource_DataRefreshType) Enum Uses

func (x DataSource_DataRefreshType) Enum() *DataSource_DataRefreshType

func (DataSource_DataRefreshType) EnumDescriptor Uses

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

Deprecated: Use DataSource_DataRefreshType.Descriptor instead.

func (DataSource_DataRefreshType) Number Uses

func (x DataSource_DataRefreshType) Number() protoreflect.EnumNumber

func (DataSource_DataRefreshType) String Uses

func (x DataSource_DataRefreshType) String() string

func (DataSource_DataRefreshType) Type Uses

func (DataSource_DataRefreshType) Type() protoreflect.EnumType

type DataTransferServiceClient Uses

type DataTransferServiceClient interface {
    // Retrieves a supported data source and returns its settings,
    // which can be used for UI rendering.
    GetDataSource(ctx context.Context, in *GetDataSourceRequest, opts ...grpc.CallOption) (*DataSource, error)
    // Lists supported data sources and returns their settings,
    // which can be used for UI rendering.
    ListDataSources(ctx context.Context, in *ListDataSourcesRequest, opts ...grpc.CallOption) (*ListDataSourcesResponse, error)
    // Creates a new data transfer configuration.
    CreateTransferConfig(ctx context.Context, in *CreateTransferConfigRequest, opts ...grpc.CallOption) (*TransferConfig, error)
    // Updates a data transfer configuration.
    // All fields must be set, even if they are not updated.
    UpdateTransferConfig(ctx context.Context, in *UpdateTransferConfigRequest, opts ...grpc.CallOption) (*TransferConfig, error)
    // Deletes a data transfer configuration,
    // including any associated transfer runs and logs.
    DeleteTransferConfig(ctx context.Context, in *DeleteTransferConfigRequest, opts ...grpc.CallOption) (*empty.Empty, error)
    // Returns information about a data transfer config.
    GetTransferConfig(ctx context.Context, in *GetTransferConfigRequest, opts ...grpc.CallOption) (*TransferConfig, error)
    // Returns information about all data transfers in the project.
    ListTransferConfigs(ctx context.Context, in *ListTransferConfigsRequest, opts ...grpc.CallOption) (*ListTransferConfigsResponse, error)
    // Deprecated: Do not use.
    // Creates transfer runs for a time range [start_time, end_time].
    // For each date - or whatever granularity the data source supports - in the
    // range, one transfer run is created.
    // Note that runs are created per UTC time in the time range.
    // DEPRECATED: use StartManualTransferRuns instead.
    ScheduleTransferRuns(ctx context.Context, in *ScheduleTransferRunsRequest, opts ...grpc.CallOption) (*ScheduleTransferRunsResponse, error)
    // Start manual transfer runs to be executed now with schedule_time equal to
    // current time. The transfer runs can be created for a time range where the
    // run_time is between start_time (inclusive) and end_time (exclusive), or for
    // a specific run_time.
    StartManualTransferRuns(ctx context.Context, in *StartManualTransferRunsRequest, opts ...grpc.CallOption) (*StartManualTransferRunsResponse, error)
    // Returns information about the particular transfer run.
    GetTransferRun(ctx context.Context, in *GetTransferRunRequest, opts ...grpc.CallOption) (*TransferRun, error)
    // Deletes the specified transfer run.
    DeleteTransferRun(ctx context.Context, in *DeleteTransferRunRequest, opts ...grpc.CallOption) (*empty.Empty, error)
    // Returns information about running and completed jobs.
    ListTransferRuns(ctx context.Context, in *ListTransferRunsRequest, opts ...grpc.CallOption) (*ListTransferRunsResponse, error)
    // Returns user facing log messages for the data transfer run.
    ListTransferLogs(ctx context.Context, in *ListTransferLogsRequest, opts ...grpc.CallOption) (*ListTransferLogsResponse, error)
    // Returns true if valid credentials exist for the given data source and
    // requesting user.
    // Some data sources doesn't support service account, so we need to talk to
    // them on behalf of the end user. This API just checks whether we have OAuth
    // token for the particular user, which is a pre-requisite before user can
    // create a transfer config.
    CheckValidCreds(ctx context.Context, in *CheckValidCredsRequest, opts ...grpc.CallOption) (*CheckValidCredsResponse, error)
}

DataTransferServiceClient is the client API for DataTransferService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewDataTransferServiceClient Uses

func NewDataTransferServiceClient(cc grpc.ClientConnInterface) DataTransferServiceClient

type DataTransferServiceServer Uses

type DataTransferServiceServer interface {
    // Retrieves a supported data source and returns its settings,
    // which can be used for UI rendering.
    GetDataSource(context.Context, *GetDataSourceRequest) (*DataSource, error)
    // Lists supported data sources and returns their settings,
    // which can be used for UI rendering.
    ListDataSources(context.Context, *ListDataSourcesRequest) (*ListDataSourcesResponse, error)
    // Creates a new data transfer configuration.
    CreateTransferConfig(context.Context, *CreateTransferConfigRequest) (*TransferConfig, error)
    // Updates a data transfer configuration.
    // All fields must be set, even if they are not updated.
    UpdateTransferConfig(context.Context, *UpdateTransferConfigRequest) (*TransferConfig, error)
    // Deletes a data transfer configuration,
    // including any associated transfer runs and logs.
    DeleteTransferConfig(context.Context, *DeleteTransferConfigRequest) (*empty.Empty, error)
    // Returns information about a data transfer config.
    GetTransferConfig(context.Context, *GetTransferConfigRequest) (*TransferConfig, error)
    // Returns information about all data transfers in the project.
    ListTransferConfigs(context.Context, *ListTransferConfigsRequest) (*ListTransferConfigsResponse, error)
    // Deprecated: Do not use.
    // Creates transfer runs for a time range [start_time, end_time].
    // For each date - or whatever granularity the data source supports - in the
    // range, one transfer run is created.
    // Note that runs are created per UTC time in the time range.
    // DEPRECATED: use StartManualTransferRuns instead.
    ScheduleTransferRuns(context.Context, *ScheduleTransferRunsRequest) (*ScheduleTransferRunsResponse, error)
    // Start manual transfer runs to be executed now with schedule_time equal to
    // current time. The transfer runs can be created for a time range where the
    // run_time is between start_time (inclusive) and end_time (exclusive), or for
    // a specific run_time.
    StartManualTransferRuns(context.Context, *StartManualTransferRunsRequest) (*StartManualTransferRunsResponse, error)
    // Returns information about the particular transfer run.
    GetTransferRun(context.Context, *GetTransferRunRequest) (*TransferRun, error)
    // Deletes the specified transfer run.
    DeleteTransferRun(context.Context, *DeleteTransferRunRequest) (*empty.Empty, error)
    // Returns information about running and completed jobs.
    ListTransferRuns(context.Context, *ListTransferRunsRequest) (*ListTransferRunsResponse, error)
    // Returns user facing log messages for the data transfer run.
    ListTransferLogs(context.Context, *ListTransferLogsRequest) (*ListTransferLogsResponse, error)
    // Returns true if valid credentials exist for the given data source and
    // requesting user.
    // Some data sources doesn't support service account, so we need to talk to
    // them on behalf of the end user. This API just checks whether we have OAuth
    // token for the particular user, which is a pre-requisite before user can
    // create a transfer config.
    CheckValidCreds(context.Context, *CheckValidCredsRequest) (*CheckValidCredsResponse, error)
}

DataTransferServiceServer is the server API for DataTransferService service.

type DeleteDataSourceDefinitionRequest Uses

type DeleteDataSourceDefinitionRequest struct {
    // The field will contain name of the resource requested, for example:
    // `projects/{project_id}/locations/{location_id}/dataSourceDefinitions/{data_source_id}`
    Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

Represents the request of the DeleteDataSourceDefinition method. All transfer configs associated with the data source must be deleted first, before the data source can be deleted.

func (*DeleteDataSourceDefinitionRequest) Descriptor Uses

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

func (*DeleteDataSourceDefinitionRequest) GetName Uses

func (m *DeleteDataSourceDefinitionRequest) GetName() string

func (*DeleteDataSourceDefinitionRequest) ProtoMessage Uses

func (*DeleteDataSourceDefinitionRequest) ProtoMessage()

func (*DeleteDataSourceDefinitionRequest) Reset Uses

func (m *DeleteDataSourceDefinitionRequest) Reset()

func (*DeleteDataSourceDefinitionRequest) String Uses

func (m *DeleteDataSourceDefinitionRequest) String() string

func (*DeleteDataSourceDefinitionRequest) XXX_DiscardUnknown Uses

func (m *DeleteDataSourceDefinitionRequest) XXX_DiscardUnknown()

func (*DeleteDataSourceDefinitionRequest) XXX_Marshal Uses

func (m *DeleteDataSourceDefinitionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DeleteDataSourceDefinitionRequest) XXX_Merge Uses

func (m *DeleteDataSourceDefinitionRequest) XXX_Merge(src proto.Message)

func (*DeleteDataSourceDefinitionRequest) XXX_Size Uses

func (m *DeleteDataSourceDefinitionRequest) XXX_Size() int

func (*DeleteDataSourceDefinitionRequest) XXX_Unmarshal Uses

func (m *DeleteDataSourceDefinitionRequest) XXX_Unmarshal(b []byte) error

type DeleteTransferConfigRequest Uses

type DeleteTransferConfigRequest struct {

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

A request to delete data transfer information. All associated transfer runs and log messages will be deleted as well.

func (*DeleteTransferConfigRequest) Descriptor Uses

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

Deprecated: Use DeleteTransferConfigRequest.ProtoReflect.Descriptor instead.

func (*DeleteTransferConfigRequest) GetName Uses

func (x *DeleteTransferConfigRequest) GetName() string

func (*DeleteTransferConfigRequest) ProtoMessage Uses

func (*DeleteTransferConfigRequest) ProtoMessage()

func (*DeleteTransferConfigRequest) ProtoReflect Uses

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

func (*DeleteTransferConfigRequest) Reset Uses

func (x *DeleteTransferConfigRequest) Reset()

func (*DeleteTransferConfigRequest) String Uses

func (x *DeleteTransferConfigRequest) String() string

type DeleteTransferRunRequest Uses

type DeleteTransferRunRequest struct {

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

A request to delete data transfer run information.

func (*DeleteTransferRunRequest) Descriptor Uses

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

Deprecated: Use DeleteTransferRunRequest.ProtoReflect.Descriptor instead.

func (*DeleteTransferRunRequest) GetName Uses

func (x *DeleteTransferRunRequest) GetName() string

func (*DeleteTransferRunRequest) ProtoMessage Uses

func (*DeleteTransferRunRequest) ProtoMessage()

func (*DeleteTransferRunRequest) ProtoReflect Uses

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

func (*DeleteTransferRunRequest) Reset Uses

func (x *DeleteTransferRunRequest) Reset()

func (*DeleteTransferRunRequest) String Uses

func (x *DeleteTransferRunRequest) String() string

type EmailPreferences Uses

type EmailPreferences struct {

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

Represents preferences for sending email notifications for transfer run events.

func (*EmailPreferences) Descriptor Uses

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

Deprecated: Use EmailPreferences.ProtoReflect.Descriptor instead.

func (*EmailPreferences) GetEnableFailureEmail Uses

func (x *EmailPreferences) GetEnableFailureEmail() bool

func (*EmailPreferences) ProtoMessage Uses

func (*EmailPreferences) ProtoMessage()

func (*EmailPreferences) ProtoReflect Uses

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

func (*EmailPreferences) Reset Uses

func (x *EmailPreferences) Reset()

func (*EmailPreferences) String Uses

func (x *EmailPreferences) String() string

type FinishRunRequest Uses

type FinishRunRequest struct {
    // Name of the resource in the form:
    // "projects/{project_id}/locations/{location_id}/transferConfigs/{config_id}/runs/{run_id}"
    Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

A request to finish a run.

func (*FinishRunRequest) Descriptor Uses

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

func (*FinishRunRequest) GetName Uses

func (m *FinishRunRequest) GetName() string

func (*FinishRunRequest) ProtoMessage Uses

func (*FinishRunRequest) ProtoMessage()

func (*FinishRunRequest) Reset Uses

func (m *FinishRunRequest) Reset()

func (*FinishRunRequest) String Uses

func (m *FinishRunRequest) String() string

func (*FinishRunRequest) XXX_DiscardUnknown Uses

func (m *FinishRunRequest) XXX_DiscardUnknown()

func (*FinishRunRequest) XXX_Marshal Uses

func (m *FinishRunRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FinishRunRequest) XXX_Merge Uses

func (m *FinishRunRequest) XXX_Merge(src proto.Message)

func (*FinishRunRequest) XXX_Size Uses

func (m *FinishRunRequest) XXX_Size() int

func (*FinishRunRequest) XXX_Unmarshal Uses

func (m *FinishRunRequest) XXX_Unmarshal(b []byte) error

type GetDataSourceDefinitionRequest Uses

type GetDataSourceDefinitionRequest struct {
    // The field will contain name of the resource requested.
    Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

Represents the request of the GetDataSourceDefinition method.

func (*GetDataSourceDefinitionRequest) Descriptor Uses

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

func (*GetDataSourceDefinitionRequest) GetName Uses

func (m *GetDataSourceDefinitionRequest) GetName() string

func (*GetDataSourceDefinitionRequest) ProtoMessage Uses

func (*GetDataSourceDefinitionRequest) ProtoMessage()

func (*GetDataSourceDefinitionRequest) Reset Uses

func (m *GetDataSourceDefinitionRequest) Reset()

func (*GetDataSourceDefinitionRequest) String Uses

func (m *GetDataSourceDefinitionRequest) String() string

func (*GetDataSourceDefinitionRequest) XXX_DiscardUnknown Uses

func (m *GetDataSourceDefinitionRequest) XXX_DiscardUnknown()

func (*GetDataSourceDefinitionRequest) XXX_Marshal Uses

func (m *GetDataSourceDefinitionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetDataSourceDefinitionRequest) XXX_Merge Uses

func (m *GetDataSourceDefinitionRequest) XXX_Merge(src proto.Message)

func (*GetDataSourceDefinitionRequest) XXX_Size Uses

func (m *GetDataSourceDefinitionRequest) XXX_Size() int

func (*GetDataSourceDefinitionRequest) XXX_Unmarshal Uses

func (m *GetDataSourceDefinitionRequest) XXX_Unmarshal(b []byte) error

type GetDataSourceRequest Uses

type GetDataSourceRequest struct {

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

A request to get data source info.

func (*GetDataSourceRequest) Descriptor Uses

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

Deprecated: Use GetDataSourceRequest.ProtoReflect.Descriptor instead.

func (*GetDataSourceRequest) GetName Uses

func (x *GetDataSourceRequest) GetName() string

func (*GetDataSourceRequest) ProtoMessage Uses

func (*GetDataSourceRequest) ProtoMessage()

func (*GetDataSourceRequest) ProtoReflect Uses

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

func (*GetDataSourceRequest) Reset Uses

func (x *GetDataSourceRequest) Reset()

func (*GetDataSourceRequest) String Uses

func (x *GetDataSourceRequest) String() string

type GetTransferConfigRequest Uses

type GetTransferConfigRequest struct {

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

A request to get data transfer information.

func (*GetTransferConfigRequest) Descriptor Uses

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

Deprecated: Use GetTransferConfigRequest.ProtoReflect.Descriptor instead.

func (*GetTransferConfigRequest) GetName Uses

func (x *GetTransferConfigRequest) GetName() string

func (*GetTransferConfigRequest) ProtoMessage Uses

func (*GetTransferConfigRequest) ProtoMessage()

func (*GetTransferConfigRequest) ProtoReflect Uses

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

func (*GetTransferConfigRequest) Reset Uses

func (x *GetTransferConfigRequest) Reset()

func (*GetTransferConfigRequest) String Uses

func (x *GetTransferConfigRequest) String() string

type GetTransferRunRequest Uses

type GetTransferRunRequest struct {

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

A request to get data transfer run information.

func (*GetTransferRunRequest) Descriptor Uses

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

Deprecated: Use GetTransferRunRequest.ProtoReflect.Descriptor instead.

func (*GetTransferRunRequest) GetName Uses

func (x *GetTransferRunRequest) GetName() string

func (*GetTransferRunRequest) ProtoMessage Uses

func (*GetTransferRunRequest) ProtoMessage()

func (*GetTransferRunRequest) ProtoReflect Uses

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

func (*GetTransferRunRequest) Reset Uses

func (x *GetTransferRunRequest) Reset()

func (*GetTransferRunRequest) String Uses

func (x *GetTransferRunRequest) String() string

type ImportedDataInfo Uses

type ImportedDataInfo struct {
    // SQL query to run. When empty, API checks that there is only one
    // table_def specified and loads this table. Only Standard SQL queries
    // are accepted. Legacy SQL is not allowed.
    Sql string `protobuf:"bytes,1,opt,name=sql,proto3" json:"sql,omitempty"`
    // Table where results should be written.
    DestinationTableId string `protobuf:"bytes,2,opt,name=destination_table_id,json=destinationTableId,proto3" json:"destination_table_id,omitempty"`
    // The description of a destination table. This can be several sentences
    // or paragraphs describing the table contents in detail.
    DestinationTableDescription string `protobuf:"bytes,10,opt,name=destination_table_description,json=destinationTableDescription,proto3" json:"destination_table_description,omitempty"`
    // When used WITHOUT the "sql" parameter, describes the schema of the
    // destination table.
    // When used WITH the "sql" parameter, describes tables with data stored
    // outside of BigQuery.
    TableDefs []*ImportedDataInfo_TableDefinition `protobuf:"bytes,3,rep,name=table_defs,json=tableDefs,proto3" json:"table_defs,omitempty"`
    // Inline code for User-defined function resources.
    // Ignored when "sql" parameter is empty.
    UserDefinedFunctions []string `protobuf:"bytes,4,rep,name=user_defined_functions,json=userDefinedFunctions,proto3" json:"user_defined_functions,omitempty"`
    // Specifies the action if the destination table already exists.
    WriteDisposition     WriteDisposition `protobuf:"varint,6,opt,name=write_disposition,json=writeDisposition,proto3,enum=google.cloud.bigquery.datatransfer.v1.WriteDisposition" json:"write_disposition,omitempty"`
    XXX_NoUnkeyedLiteral struct{}         `json:"-"`
    XXX_unrecognized     []byte           `json:"-"`
    XXX_sizecache        int32            `json:"-"`
}

Describes data which should be imported.

func (*ImportedDataInfo) Descriptor Uses

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

func (*ImportedDataInfo) GetDestinationTableDescription Uses

func (m *ImportedDataInfo) GetDestinationTableDescription() string

func (*ImportedDataInfo) GetDestinationTableId Uses

func (m *ImportedDataInfo) GetDestinationTableId() string

func (*ImportedDataInfo) GetSql Uses

func (m *ImportedDataInfo) GetSql() string

func (*ImportedDataInfo) GetTableDefs Uses

func (m *ImportedDataInfo) GetTableDefs() []*ImportedDataInfo_TableDefinition

func (*ImportedDataInfo) GetUserDefinedFunctions Uses

func (m *ImportedDataInfo) GetUserDefinedFunctions() []string

func (*ImportedDataInfo) GetWriteDisposition Uses

func (m *ImportedDataInfo) GetWriteDisposition() WriteDisposition

func (*ImportedDataInfo) ProtoMessage Uses

func (*ImportedDataInfo) ProtoMessage()

func (*ImportedDataInfo) Reset Uses

func (m *ImportedDataInfo) Reset()

func (*ImportedDataInfo) String Uses

func (m *ImportedDataInfo) String() string

func (*ImportedDataInfo) XXX_DiscardUnknown Uses

func (m *ImportedDataInfo) XXX_DiscardUnknown()

func (*ImportedDataInfo) XXX_Marshal Uses

func (m *ImportedDataInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ImportedDataInfo) XXX_Merge Uses

func (m *ImportedDataInfo) XXX_Merge(src proto.Message)

func (*ImportedDataInfo) XXX_Size Uses

func (m *ImportedDataInfo) XXX_Size() int

func (*ImportedDataInfo) XXX_Unmarshal Uses

func (m *ImportedDataInfo) XXX_Unmarshal(b []byte) error

type ImportedDataInfo_Encoding Uses

type ImportedDataInfo_Encoding int32

Encoding of input data in CSV/JSON format.

const (
    // Default encoding (UTF8).
    ImportedDataInfo_ENCODING_UNSPECIFIED ImportedDataInfo_Encoding = 0
    // ISO_8859_1 encoding.
    ImportedDataInfo_ISO_8859_1 ImportedDataInfo_Encoding = 1
    // UTF8 encoding.
    ImportedDataInfo_UTF8 ImportedDataInfo_Encoding = 2
)

func (ImportedDataInfo_Encoding) EnumDescriptor Uses

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

func (ImportedDataInfo_Encoding) String Uses

func (x ImportedDataInfo_Encoding) String() string

type ImportedDataInfo_FieldSchema Uses

type ImportedDataInfo_FieldSchema struct {
    // Field name. Matches: [A-Za-z_][A-Za-z_0-9]{0,127}
    FieldName string `protobuf:"bytes,1,opt,name=field_name,json=fieldName,proto3" json:"field_name,omitempty"`
    // Field type
    Type ImportedDataInfo_FieldSchema_Type `protobuf:"varint,2,opt,name=type,proto3,enum=google.cloud.bigquery.datatransfer.v1.ImportedDataInfo_FieldSchema_Type" json:"type,omitempty"`
    // Is field repeated.
    IsRepeated bool `protobuf:"varint,3,opt,name=is_repeated,json=isRepeated,proto3" json:"is_repeated,omitempty"`
    // Description for this field.
    Description string `protobuf:"bytes,4,opt,name=description,proto3" json:"description,omitempty"`
    // Present iff type == RECORD.
    Schema               *ImportedDataInfo_RecordSchema `protobuf:"bytes,5,opt,name=schema,proto3" json:"schema,omitempty"`
    XXX_NoUnkeyedLiteral struct{}                       `json:"-"`
    XXX_unrecognized     []byte                         `json:"-"`
    XXX_sizecache        int32                          `json:"-"`
}

Defines schema of a field in the imported data.

func (*ImportedDataInfo_FieldSchema) Descriptor Uses

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

func (*ImportedDataInfo_FieldSchema) GetDescription Uses

func (m *ImportedDataInfo_FieldSchema) GetDescription() string

func (*ImportedDataInfo_FieldSchema) GetFieldName Uses

func (m *ImportedDataInfo_FieldSchema) GetFieldName() string

func (*ImportedDataInfo_FieldSchema) GetIsRepeated Uses

func (m *ImportedDataInfo_FieldSchema) GetIsRepeated() bool

func (*ImportedDataInfo_FieldSchema) GetSchema Uses

func (m *ImportedDataInfo_FieldSchema) GetSchema() *ImportedDataInfo_RecordSchema

func (*ImportedDataInfo_FieldSchema) GetType Uses

func (m *ImportedDataInfo_FieldSchema) GetType() ImportedDataInfo_FieldSchema_Type

func (*ImportedDataInfo_FieldSchema) ProtoMessage Uses

func (*ImportedDataInfo_FieldSchema) ProtoMessage()

func (*ImportedDataInfo_FieldSchema) Reset Uses

func (m *ImportedDataInfo_FieldSchema) Reset()

func (*ImportedDataInfo_FieldSchema) String Uses

func (m *ImportedDataInfo_FieldSchema) String() string

func (*ImportedDataInfo_FieldSchema) XXX_DiscardUnknown Uses

func (m *ImportedDataInfo_FieldSchema) XXX_DiscardUnknown()

func (*ImportedDataInfo_FieldSchema) XXX_Marshal Uses

func (m *ImportedDataInfo_FieldSchema) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ImportedDataInfo_FieldSchema) XXX_Merge Uses

func (m *ImportedDataInfo_FieldSchema) XXX_Merge(src proto.Message)

func (*ImportedDataInfo_FieldSchema) XXX_Size Uses

func (m *ImportedDataInfo_FieldSchema) XXX_Size() int

func (*ImportedDataInfo_FieldSchema) XXX_Unmarshal Uses

func (m *ImportedDataInfo_FieldSchema) XXX_Unmarshal(b []byte) error

type ImportedDataInfo_FieldSchema_Type Uses

type ImportedDataInfo_FieldSchema_Type int32

LINT.IfChange Field type.

const (
    // Illegal value.
    ImportedDataInfo_FieldSchema_TYPE_UNSPECIFIED ImportedDataInfo_FieldSchema_Type = 0
    // 64K, UTF8.
    ImportedDataInfo_FieldSchema_STRING ImportedDataInfo_FieldSchema_Type = 1
    // 64-bit signed.
    ImportedDataInfo_FieldSchema_INTEGER ImportedDataInfo_FieldSchema_Type = 2
    // 64-bit IEEE floating point.
    ImportedDataInfo_FieldSchema_FLOAT ImportedDataInfo_FieldSchema_Type = 3
    // Aggregate type.
    ImportedDataInfo_FieldSchema_RECORD ImportedDataInfo_FieldSchema_Type = 4
    // 64K, Binary.
    ImportedDataInfo_FieldSchema_BYTES ImportedDataInfo_FieldSchema_Type = 5
    // 2-valued.
    ImportedDataInfo_FieldSchema_BOOLEAN ImportedDataInfo_FieldSchema_Type = 6
    // 64-bit signed usec since UTC epoch.
    ImportedDataInfo_FieldSchema_TIMESTAMP ImportedDataInfo_FieldSchema_Type = 7
    // Civil date - Year, Month, Day.
    ImportedDataInfo_FieldSchema_DATE ImportedDataInfo_FieldSchema_Type = 8
    // Civil time - Hour, Minute, Second, Microseconds.
    ImportedDataInfo_FieldSchema_TIME ImportedDataInfo_FieldSchema_Type = 9
    // Combination of civil date and civil time.
    ImportedDataInfo_FieldSchema_DATETIME ImportedDataInfo_FieldSchema_Type = 10
    // Numeric type with 38 decimal digits of precision and 9 decimal digits
    // of scale.
    ImportedDataInfo_FieldSchema_NUMERIC ImportedDataInfo_FieldSchema_Type = 11
    // Geography object (go/googlesql_geography).
    ImportedDataInfo_FieldSchema_GEOGRAPHY ImportedDataInfo_FieldSchema_Type = 12
)

func (ImportedDataInfo_FieldSchema_Type) EnumDescriptor Uses

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

func (ImportedDataInfo_FieldSchema_Type) String Uses

func (x ImportedDataInfo_FieldSchema_Type) String() string

type ImportedDataInfo_Format Uses

type ImportedDataInfo_Format int32

Data format.

const (
    // Unspecified format. In this case, we have to infer the format from the
    // data source.
    ImportedDataInfo_FORMAT_UNSPECIFIED ImportedDataInfo_Format = 0
    // CSV format.
    ImportedDataInfo_CSV ImportedDataInfo_Format = 1
    // Newline-delimited JSON.
    ImportedDataInfo_JSON ImportedDataInfo_Format = 2
    // Avro format. See http://avro.apache.org .
    ImportedDataInfo_AVRO ImportedDataInfo_Format = 3
    // RecordIO.
    ImportedDataInfo_RECORDIO ImportedDataInfo_Format = 4
    // ColumnIO.
    ImportedDataInfo_COLUMNIO ImportedDataInfo_Format = 5
    // Capacitor.
    ImportedDataInfo_CAPACITOR ImportedDataInfo_Format = 6
    // Parquet format. See https://parquet.apache.org .
    ImportedDataInfo_PARQUET ImportedDataInfo_Format = 7
    // ORC format. See https://orc.apache.org .
    ImportedDataInfo_ORC ImportedDataInfo_Format = 8
)

func (ImportedDataInfo_Format) EnumDescriptor Uses

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

func (ImportedDataInfo_Format) String Uses

func (x ImportedDataInfo_Format) String() string

type ImportedDataInfo_RecordSchema Uses

type ImportedDataInfo_RecordSchema struct {
    // One field per column in the record.
    Fields               []*ImportedDataInfo_FieldSchema `protobuf:"bytes,1,rep,name=fields,proto3" json:"fields,omitempty"`
    XXX_NoUnkeyedLiteral struct{}                        `json:"-"`
    XXX_unrecognized     []byte                          `json:"-"`
    XXX_sizecache        int32                           `json:"-"`
}

Describes schema of the data to be ingested.

func (*ImportedDataInfo_RecordSchema) Descriptor Uses

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

func (*ImportedDataInfo_RecordSchema) GetFields Uses

func (m *ImportedDataInfo_RecordSchema) GetFields() []*ImportedDataInfo_FieldSchema

func (*ImportedDataInfo_RecordSchema) ProtoMessage Uses

func (*ImportedDataInfo_RecordSchema) ProtoMessage()

func (*ImportedDataInfo_RecordSchema) Reset Uses

func (m *ImportedDataInfo_RecordSchema) Reset()

func (*ImportedDataInfo_RecordSchema) String Uses

func (m *ImportedDataInfo_RecordSchema) String() string

func (*ImportedDataInfo_RecordSchema) XXX_DiscardUnknown Uses

func (m *ImportedDataInfo_RecordSchema) XXX_DiscardUnknown()

func (*ImportedDataInfo_RecordSchema) XXX_Marshal Uses

func (m *ImportedDataInfo_RecordSchema) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ImportedDataInfo_RecordSchema) XXX_Merge Uses

func (m *ImportedDataInfo_RecordSchema) XXX_Merge(src proto.Message)

func (*ImportedDataInfo_RecordSchema) XXX_Size Uses

func (m *ImportedDataInfo_RecordSchema) XXX_Size() int

func (*ImportedDataInfo_RecordSchema) XXX_Unmarshal Uses

func (m *ImportedDataInfo_RecordSchema) XXX_Unmarshal(b []byte) error

type ImportedDataInfo_TableDefinition Uses

type ImportedDataInfo_TableDefinition struct {
    // BigQuery table_id (required). This will be used to reference this
    // table in the query.
    TableId string `protobuf:"bytes,1,opt,name=table_id,json=tableId,proto3" json:"table_id,omitempty"`
    // URIs for the data to be imported. All URIs must be from the same storage
    // system.
    SourceUris []string `protobuf:"bytes,2,rep,name=source_uris,json=sourceUris,proto3" json:"source_uris,omitempty"`
    // Describes the format of the data in source_uri.
    Format ImportedDataInfo_Format `protobuf:"varint,3,opt,name=format,proto3,enum=google.cloud.bigquery.datatransfer.v1.ImportedDataInfo_Format" json:"format,omitempty"`
    // Specify the maximum number of bad records that can be ignored.
    // If bad records exceed this threshold the query is aborted.
    MaxBadRecords int32 `protobuf:"varint,4,opt,name=max_bad_records,json=maxBadRecords,proto3" json:"max_bad_records,omitempty"`
    // Character encoding of the input when applicable (CSV, JSON).
    // Defaults to UTF8.
    Encoding ImportedDataInfo_Encoding `protobuf:"varint,5,opt,name=encoding,proto3,enum=google.cloud.bigquery.datatransfer.v1.ImportedDataInfo_Encoding" json:"encoding,omitempty"`
    // CSV specific options.
    CsvOptions *ImportedDataInfo_TableDefinition_CsvOptions `protobuf:"bytes,6,opt,name=csv_options,json=csvOptions,proto3" json:"csv_options,omitempty"`
    // Optional schema for the data. When not specified for JSON and CSV formats
    // we will try to detect it automatically.
    Schema *ImportedDataInfo_RecordSchema `protobuf:"bytes,7,opt,name=schema,proto3" json:"schema,omitempty"`
    // Indicates if extra values that are not represented in the table schema is
    // allowed.
    IgnoreUnknownValues  *wrappers.BoolValue `protobuf:"bytes,10,opt,name=ignore_unknown_values,json=ignoreUnknownValues,proto3" json:"ignore_unknown_values,omitempty"`
    XXX_NoUnkeyedLiteral struct{}            `json:"-"`
    XXX_unrecognized     []byte              `json:"-"`
    XXX_sizecache        int32               `json:"-"`
}

External table definition. These tables can be referenced with 'name' in the query and can be read just like any other table.

func (*ImportedDataInfo_TableDefinition) Descriptor Uses

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

func (*ImportedDataInfo_TableDefinition) GetCsvOptions Uses

func (m *ImportedDataInfo_TableDefinition) GetCsvOptions() *ImportedDataInfo_TableDefinition_CsvOptions

func (*ImportedDataInfo_TableDefinition) GetEncoding Uses

func (m *ImportedDataInfo_TableDefinition) GetEncoding() ImportedDataInfo_Encoding

func (*ImportedDataInfo_TableDefinition) GetFormat Uses

func (m *ImportedDataInfo_TableDefinition) GetFormat() ImportedDataInfo_Format

func (*ImportedDataInfo_TableDefinition) GetIgnoreUnknownValues Uses

func (m *ImportedDataInfo_TableDefinition) GetIgnoreUnknownValues() *wrappers.BoolValue

func (*ImportedDataInfo_TableDefinition) GetMaxBadRecords Uses

func (m *ImportedDataInfo_TableDefinition) GetMaxBadRecords() int32

func (*ImportedDataInfo_TableDefinition) GetSchema Uses

func (m *ImportedDataInfo_TableDefinition) GetSchema() *ImportedDataInfo_RecordSchema

func (*ImportedDataInfo_TableDefinition) GetSourceUris Uses

func (m *ImportedDataInfo_TableDefinition) GetSourceUris() []string

func (*ImportedDataInfo_TableDefinition) GetTableId Uses

func (m *ImportedDataInfo_TableDefinition) GetTableId() string

func (*ImportedDataInfo_TableDefinition) ProtoMessage Uses

func (*ImportedDataInfo_TableDefinition) ProtoMessage()

func (*ImportedDataInfo_TableDefinition) Reset Uses

func (m *ImportedDataInfo_TableDefinition) Reset()

func (*ImportedDataInfo_TableDefinition) String Uses

func (m *ImportedDataInfo_TableDefinition) String() string

func (*ImportedDataInfo_TableDefinition) XXX_DiscardUnknown Uses

func (m *ImportedDataInfo_TableDefinition) XXX_DiscardUnknown()

func (*ImportedDataInfo_TableDefinition) XXX_Marshal Uses

func (m *ImportedDataInfo_TableDefinition) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ImportedDataInfo_TableDefinition) XXX_Merge Uses

func (m *ImportedDataInfo_TableDefinition) XXX_Merge(src proto.Message)

func (*ImportedDataInfo_TableDefinition) XXX_Size Uses

func (m *ImportedDataInfo_TableDefinition) XXX_Size() int

func (*ImportedDataInfo_TableDefinition) XXX_Unmarshal Uses

func (m *ImportedDataInfo_TableDefinition) XXX_Unmarshal(b []byte) error

type ImportedDataInfo_TableDefinition_CsvOptions Uses

type ImportedDataInfo_TableDefinition_CsvOptions struct {
    // The delimiter.  We currently restrict this to U+0001 to U+00FF and
    // apply additional constraints during validation.
    FieldDelimiter *wrappers.StringValue `protobuf:"bytes,1,opt,name=field_delimiter,json=fieldDelimiter,proto3" json:"field_delimiter,omitempty"`
    // Whether CSV files are allowed to have quoted newlines. If quoted
    // newlines are allowed, we can't split CSV files.
    AllowQuotedNewlines *wrappers.BoolValue `protobuf:"bytes,2,opt,name=allow_quoted_newlines,json=allowQuotedNewlines,proto3" json:"allow_quoted_newlines,omitempty"`
    // The quote character.  We currently restrict this to U+0000 to U+00FF
    // and apply additional constraints during validation. Set to '\0' to
    // indicate no quote is used.
    QuoteChar *wrappers.StringValue `protobuf:"bytes,3,opt,name=quote_char,json=quoteChar,proto3" json:"quote_char,omitempty"`
    // Number of leading rows to skip.
    SkipLeadingRows *wrappers.Int64Value `protobuf:"bytes,4,opt,name=skip_leading_rows,json=skipLeadingRows,proto3" json:"skip_leading_rows,omitempty"`
    // Accept rows that are missing trailing optional columns.
    AllowJaggedRows      *wrappers.BoolValue `protobuf:"bytes,5,opt,name=allow_jagged_rows,json=allowJaggedRows,proto3" json:"allow_jagged_rows,omitempty"`
    XXX_NoUnkeyedLiteral struct{}            `json:"-"`
    XXX_unrecognized     []byte              `json:"-"`
    XXX_sizecache        int32               `json:"-"`
}

CSV specific options.

func (*ImportedDataInfo_TableDefinition_CsvOptions) Descriptor Uses

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

func (*ImportedDataInfo_TableDefinition_CsvOptions) GetAllowJaggedRows Uses

func (m *ImportedDataInfo_TableDefinition_CsvOptions) GetAllowJaggedRows() *wrappers.BoolValue

func (*ImportedDataInfo_TableDefinition_CsvOptions) GetAllowQuotedNewlines Uses

func (m *ImportedDataInfo_TableDefinition_CsvOptions) GetAllowQuotedNewlines() *wrappers.BoolValue

func (*ImportedDataInfo_TableDefinition_CsvOptions) GetFieldDelimiter Uses

func (m *ImportedDataInfo_TableDefinition_CsvOptions) GetFieldDelimiter() *wrappers.StringValue

func (*ImportedDataInfo_TableDefinition_CsvOptions) GetQuoteChar Uses

func (m *ImportedDataInfo_TableDefinition_CsvOptions) GetQuoteChar() *wrappers.StringValue

func (*ImportedDataInfo_TableDefinition_CsvOptions) GetSkipLeadingRows Uses

func (m *ImportedDataInfo_TableDefinition_CsvOptions) GetSkipLeadingRows() *wrappers.Int64Value

func (*ImportedDataInfo_TableDefinition_CsvOptions) ProtoMessage Uses

func (*ImportedDataInfo_TableDefinition_CsvOptions) ProtoMessage()

func (*ImportedDataInfo_TableDefinition_CsvOptions) Reset Uses

func (m *ImportedDataInfo_TableDefinition_CsvOptions) Reset()

func (*ImportedDataInfo_TableDefinition_CsvOptions) String Uses

func (m *ImportedDataInfo_TableDefinition_CsvOptions) String() string

func (*ImportedDataInfo_TableDefinition_CsvOptions) XXX_DiscardUnknown Uses

func (m *ImportedDataInfo_TableDefinition_CsvOptions) XXX_DiscardUnknown()

func (*ImportedDataInfo_TableDefinition_CsvOptions) XXX_Marshal Uses

func (m *ImportedDataInfo_TableDefinition_CsvOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ImportedDataInfo_TableDefinition_CsvOptions) XXX_Merge Uses

func (m *ImportedDataInfo_TableDefinition_CsvOptions) XXX_Merge(src proto.Message)

func (*ImportedDataInfo_TableDefinition_CsvOptions) XXX_Size Uses

func (m *ImportedDataInfo_TableDefinition_CsvOptions) XXX_Size() int

func (*ImportedDataInfo_TableDefinition_CsvOptions) XXX_Unmarshal Uses

func (m *ImportedDataInfo_TableDefinition_CsvOptions) XXX_Unmarshal(b []byte) error

type ListDataSourceDefinitionsRequest Uses

type ListDataSourceDefinitionsRequest struct {
    // The BigQuery project id for which data sources should be returned.
    // Must be in the form: `projects/{project_id}/locations/{location_id}`
    Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
    // Pagination token, which can be used to request a specific page
    // of `ListDataSourceDefinitionsRequest` list results. For multiple-page
    // results, `ListDataSourceDefinitionsResponse` outputs a `next_page` token,
    // which can be used as the `page_token` value to request the next page of
    // the list results.
    PageToken string `protobuf:"bytes,2,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
    // Page size. The default page size is the maximum value of 1000 results.
    PageSize             int32    `protobuf:"varint,3,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

Represents the request of the ListDataSourceDefinitions method.

func (*ListDataSourceDefinitionsRequest) Descriptor Uses

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

func (*ListDataSourceDefinitionsRequest) GetPageSize Uses

func (m *ListDataSourceDefinitionsRequest) GetPageSize() int32

func (*ListDataSourceDefinitionsRequest) GetPageToken Uses

func (m *ListDataSourceDefinitionsRequest) GetPageToken() string

func (*ListDataSourceDefinitionsRequest) GetParent Uses

func (m *ListDataSourceDefinitionsRequest) GetParent() string

func (*ListDataSourceDefinitionsRequest) ProtoMessage Uses

func (*ListDataSourceDefinitionsRequest) ProtoMessage()

func (*ListDataSourceDefinitionsRequest) Reset Uses

func (m *ListDataSourceDefinitionsRequest) Reset()

func (*ListDataSourceDefinitionsRequest) String Uses

func (m *ListDataSourceDefinitionsRequest) String() string

func (*ListDataSourceDefinitionsRequest) XXX_DiscardUnknown Uses

func (m *ListDataSourceDefinitionsRequest) XXX_DiscardUnknown()

func (*ListDataSourceDefinitionsRequest) XXX_Marshal Uses

func (m *ListDataSourceDefinitionsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListDataSourceDefinitionsRequest) XXX_Merge Uses

func (m *ListDataSourceDefinitionsRequest) XXX_Merge(src proto.Message)

func (*ListDataSourceDefinitionsRequest) XXX_Size Uses

func (m *ListDataSourceDefinitionsRequest) XXX_Size() int

func (*ListDataSourceDefinitionsRequest) XXX_Unmarshal Uses

func (m *ListDataSourceDefinitionsRequest) XXX_Unmarshal(b []byte) error

type ListDataSourceDefinitionsResponse Uses

type ListDataSourceDefinitionsResponse struct {
    // List of supported data source definitions.
    DataSourceDefinitions []*DataSourceDefinition `protobuf:"bytes,1,rep,name=data_source_definitions,json=dataSourceDefinitions,proto3" json:"data_source_definitions,omitempty"`
    // Output only. The next-pagination token. For multiple-page list results,
    // this token can be used as the
    // `ListDataSourceDefinitionsRequest.page_token`
    // to request the next page of the list results.
    NextPageToken        string   `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

Returns a list of supported data source definitions.

func (*ListDataSourceDefinitionsResponse) Descriptor Uses

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

func (*ListDataSourceDefinitionsResponse) GetDataSourceDefinitions Uses

func (m *ListDataSourceDefinitionsResponse) GetDataSourceDefinitions() []*DataSourceDefinition

func (*ListDataSourceDefinitionsResponse) GetNextPageToken Uses

func (m *ListDataSourceDefinitionsResponse) GetNextPageToken() string

func (*ListDataSourceDefinitionsResponse) ProtoMessage Uses

func (*ListDataSourceDefinitionsResponse) ProtoMessage()

func (*ListDataSourceDefinitionsResponse) Reset Uses

func (m *ListDataSourceDefinitionsResponse) Reset()

func (*ListDataSourceDefinitionsResponse) String Uses

func (m *ListDataSourceDefinitionsResponse) String() string

func (*ListDataSourceDefinitionsResponse) XXX_DiscardUnknown Uses

func (m *ListDataSourceDefinitionsResponse) XXX_DiscardUnknown()

func (*ListDataSourceDefinitionsResponse) XXX_Marshal Uses

func (m *ListDataSourceDefinitionsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListDataSourceDefinitionsResponse) XXX_Merge Uses

func (m *ListDataSourceDefinitionsResponse) XXX_Merge(src proto.Message)

func (*ListDataSourceDefinitionsResponse) XXX_Size Uses

func (m *ListDataSourceDefinitionsResponse) XXX_Size() int

func (*ListDataSourceDefinitionsResponse) XXX_Unmarshal Uses

func (m *ListDataSourceDefinitionsResponse) XXX_Unmarshal(b []byte) error

type ListDataSourcesRequest Uses

type ListDataSourcesRequest struct {

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

Request to list supported data sources and their data transfer settings.

func (*ListDataSourcesRequest) Descriptor Uses

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

Deprecated: Use ListDataSourcesRequest.ProtoReflect.Descriptor instead.

func (*ListDataSourcesRequest) GetPageSize Uses

func (x *ListDataSourcesRequest) GetPageSize() int32

func (*ListDataSourcesRequest) GetPageToken Uses

func (x *ListDataSourcesRequest) GetPageToken() string

func (*ListDataSourcesRequest) GetParent Uses

func (x *ListDataSourcesRequest) GetParent() string

func (*ListDataSourcesRequest) ProtoMessage Uses

func (*ListDataSourcesRequest) ProtoMessage()

func (*ListDataSourcesRequest) ProtoReflect Uses

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

func (*ListDataSourcesRequest) Reset Uses

func (x *ListDataSourcesRequest) Reset()

func (*ListDataSourcesRequest) String Uses

func (x *ListDataSourcesRequest) String() string

type ListDataSourcesResponse Uses

type ListDataSourcesResponse struct {

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

Returns list of supported data sources and their metadata.

func (*ListDataSourcesResponse) Descriptor Uses

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

Deprecated: Use ListDataSourcesResponse.ProtoReflect.Descriptor instead.

func (*ListDataSourcesResponse) GetDataSources Uses

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

func (*ListDataSourcesResponse) GetNextPageToken Uses

func (x *ListDataSourcesResponse) GetNextPageToken() string

func (*ListDataSourcesResponse) ProtoMessage Uses

func (*ListDataSourcesResponse) ProtoMessage()

func (*ListDataSourcesResponse) ProtoReflect Uses

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

func (*ListDataSourcesResponse) Reset Uses

func (x *ListDataSourcesResponse) Reset()

func (*ListDataSourcesResponse) String Uses

func (x *ListDataSourcesResponse) String() string

type ListTransferConfigsRequest Uses

type ListTransferConfigsRequest struct {

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

A request to list data transfers configured for a BigQuery project.

func (*ListTransferConfigsRequest) Descriptor Uses

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

Deprecated: Use ListTransferConfigsRequest.ProtoReflect.Descriptor instead.

func (*ListTransferConfigsRequest) GetDataSourceIds Uses

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

func (*ListTransferConfigsRequest) GetPageSize Uses

func (x *ListTransferConfigsRequest) GetPageSize() int32

func (*ListTransferConfigsRequest) GetPageToken Uses

func (x *ListTransferConfigsRequest) GetPageToken() string

func (*ListTransferConfigsRequest) GetParent Uses

func (x *ListTransferConfigsRequest) GetParent() string

func (*ListTransferConfigsRequest) ProtoMessage Uses

func (*ListTransferConfigsRequest) ProtoMessage()

func (*ListTransferConfigsRequest) ProtoReflect Uses

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

func (*ListTransferConfigsRequest) Reset Uses

func (x *ListTransferConfigsRequest) Reset()

func (*ListTransferConfigsRequest) String Uses

func (x *ListTransferConfigsRequest) String() string

type ListTransferConfigsResponse Uses

type ListTransferConfigsResponse struct {

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

The returned list of pipelines in the project.

func (*ListTransferConfigsResponse) Descriptor Uses

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

Deprecated: Use ListTransferConfigsResponse.ProtoReflect.Descriptor instead.

func (*ListTransferConfigsResponse) GetNextPageToken Uses

func (x *ListTransferConfigsResponse) GetNextPageToken() string

func (*ListTransferConfigsResponse) GetTransferConfigs Uses

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

func (*ListTransferConfigsResponse) ProtoMessage Uses

func (*ListTransferConfigsResponse) ProtoMessage()

func (*ListTransferConfigsResponse) ProtoReflect Uses

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

func (*ListTransferConfigsResponse) Reset Uses

func (x *ListTransferConfigsResponse) Reset()

func (*ListTransferConfigsResponse) String Uses

func (x *ListTransferConfigsResponse) String() string

type ListTransferLogsRequest Uses

type ListTransferLogsRequest struct {

    // Required. Transfer run name in the form:
    // `projects/{project_id}/transferConfigs/{config_id}/runs/{run_id}` or
    // `projects/{project_id}/locations/{location_id}/transferConfigs/{config_id}/runs/{run_id}`
    Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
    // Pagination token, which can be used to request a specific page
    // of `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.
    PageToken string `protobuf:"bytes,4,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
    // Page size. The default page size is the maximum value of 1000 results.
    PageSize int32 `protobuf:"varint,5,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
    // Message types to return. If not populated - INFO, WARNING and ERROR
    // messages are returned.
    MessageTypes []TransferMessage_MessageSeverity `protobuf:"varint,6,rep,packed,name=message_types,json=messageTypes,proto3,enum=google.cloud.bigquery.datatransfer.v1.TransferMessage_MessageSeverity" json:"message_types,omitempty"`
    // contains filtered or unexported fields
}

A request to get user facing log messages associated with data transfer run.

func (*ListTransferLogsRequest) Descriptor Uses

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

Deprecated: Use ListTransferLogsRequest.ProtoReflect.Descriptor instead.

func (*ListTransferLogsRequest) GetMessageTypes Uses

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

func (*ListTransferLogsRequest) GetPageSize Uses

func (x *ListTransferLogsRequest) GetPageSize() int32

func (*ListTransferLogsRequest) GetPageToken Uses

func (x *ListTransferLogsRequest) GetPageToken() string

func (*ListTransferLogsRequest) GetParent Uses

func (x *ListTransferLogsRequest) GetParent() string

func (*ListTransferLogsRequest) ProtoMessage Uses

func (*ListTransferLogsRequest) ProtoMessage()

func (*ListTransferLogsRequest) ProtoReflect Uses

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

func (*ListTransferLogsRequest) Reset Uses

func (x *ListTransferLogsRequest) Reset()

func (*ListTransferLogsRequest) String Uses

func (x *ListTransferLogsRequest) String() string

type ListTransferLogsResponse Uses

type ListTransferLogsResponse struct {

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

The returned list transfer run messages.

func (*ListTransferLogsResponse) Descriptor Uses

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

Deprecated: Use ListTransferLogsResponse.ProtoReflect.Descriptor instead.

func (*ListTransferLogsResponse) GetNextPageToken Uses

func (x *ListTransferLogsResponse) GetNextPageToken() string

func (*ListTransferLogsResponse) GetTransferMessages Uses

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

func (*ListTransferLogsResponse) ProtoMessage Uses

func (*ListTransferLogsResponse) ProtoMessage()

func (*ListTransferLogsResponse) ProtoReflect Uses

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

func (*ListTransferLogsResponse) Reset Uses

func (x *ListTransferLogsResponse) Reset()

func (*ListTransferLogsResponse) String Uses

func (x *ListTransferLogsResponse) String() string

type ListTransferRunsRequest Uses

type ListTransferRunsRequest struct {

    // Required. 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/{config_id}`.
    Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
    // When specified, only transfer runs with requested states are returned.
    States []TransferState `protobuf:"varint,2,rep,packed,name=states,proto3,enum=google.cloud.bigquery.datatransfer.v1.TransferState" json:"states,omitempty"`
    // 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.
    PageToken string `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
    // Page size. The default page size is the maximum value of 1000 results.
    PageSize int32 `protobuf:"varint,4,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
    // Indicates how run attempts are to be pulled.
    RunAttempt ListTransferRunsRequest_RunAttempt `protobuf:"varint,5,opt,name=run_attempt,json=runAttempt,proto3,enum=google.cloud.bigquery.datatransfer.v1.ListTransferRunsRequest_RunAttempt" json:"run_attempt,omitempty"`
    // contains filtered or unexported fields
}

A request to list data transfer runs. UI can use this method to show/filter specific data transfer runs. The data source can use this method to request all scheduled transfer runs.

func (*ListTransferRunsRequest) Descriptor Uses

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

Deprecated: Use ListTransferRunsRequest.ProtoReflect.Descriptor instead.

func (*ListTransferRunsRequest) GetPageSize Uses

func (x *ListTransferRunsRequest) GetPageSize() int32

func (*ListTransferRunsRequest) GetPageToken Uses

func (x *ListTransferRunsRequest) GetPageToken() string

func (*ListTransferRunsRequest) GetParent Uses

func (x *ListTransferRunsRequest) GetParent() string

func (*ListTransferRunsRequest) GetRunAttempt Uses

func (x *ListTransferRunsRequest) GetRunAttempt() ListTransferRunsRequest_RunAttempt

func (*ListTransferRunsRequest) GetStates Uses

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

func (*ListTransferRunsRequest) ProtoMessage Uses

func (*ListTransferRunsRequest) ProtoMessage()

func (*ListTransferRunsRequest) ProtoReflect Uses

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

func (*ListTransferRunsRequest) Reset Uses

func (x *ListTransferRunsRequest) Reset()

func (*ListTransferRunsRequest) String Uses

func (x *ListTransferRunsRequest) String() string

type ListTransferRunsRequest_RunAttempt Uses

type ListTransferRunsRequest_RunAttempt int32

Represents which runs should be pulled.

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

func (ListTransferRunsRequest_RunAttempt) Descriptor Uses

func (ListTransferRunsRequest_RunAttempt) Descriptor() protoreflect.EnumDescriptor

func (ListTransferRunsRequest_RunAttempt) Enum Uses

func (x ListTransferRunsRequest_RunAttempt) Enum() *ListTransferRunsRequest_RunAttempt

func (ListTransferRunsRequest_RunAttempt) EnumDescriptor Uses

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

Deprecated: Use ListTransferRunsRequest_RunAttempt.Descriptor instead.

func (ListTransferRunsRequest_RunAttempt) Number Uses

func (x ListTransferRunsRequest_RunAttempt) Number() protoreflect.EnumNumber

func (ListTransferRunsRequest_RunAttempt) String Uses

func (x ListTransferRunsRequest_RunAttempt) String() string

func (ListTransferRunsRequest_RunAttempt) Type Uses

func (ListTransferRunsRequest_RunAttempt) Type() protoreflect.EnumType

type ListTransferRunsResponse Uses

type ListTransferRunsResponse struct {

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

The returned list of pipelines in the project.

func (*ListTransferRunsResponse) Descriptor Uses

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

Deprecated: Use ListTransferRunsResponse.ProtoReflect.Descriptor instead.

func (*ListTransferRunsResponse) GetNextPageToken Uses

func (x *ListTransferRunsResponse) GetNextPageToken() string

func (*ListTransferRunsResponse) GetTransferRuns Uses

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

func (*ListTransferRunsResponse) ProtoMessage Uses

func (*ListTransferRunsResponse) ProtoMessage()

func (*ListTransferRunsResponse) ProtoReflect Uses

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

func (*ListTransferRunsResponse) Reset Uses

func (x *ListTransferRunsResponse) Reset()

func (*ListTransferRunsResponse) String Uses

func (x *ListTransferRunsResponse) String() string

type LogTransferRunMessagesRequest Uses

type LogTransferRunMessagesRequest struct {
    // Name of the resource in the form:
    // "projects/{project_id}/locations/{location_id}/transferConfigs/{config_id}/runs/{run_id}"
    Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
    // Messages to append.
    TransferMessages     []*TransferMessage `protobuf:"bytes,2,rep,name=transfer_messages,json=transferMessages,proto3" json:"transfer_messages,omitempty"`
    XXX_NoUnkeyedLiteral struct{}           `json:"-"`
    XXX_unrecognized     []byte             `json:"-"`
    XXX_sizecache        int32              `json:"-"`
}

A request to add transfer status messages to the run.

func (*LogTransferRunMessagesRequest) Descriptor Uses

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

func (*LogTransferRunMessagesRequest) GetName Uses

func (m *LogTransferRunMessagesRequest) GetName() string

func (*LogTransferRunMessagesRequest) GetTransferMessages Uses

func (m *LogTransferRunMessagesRequest) GetTransferMessages() []*TransferMessage

func (*LogTransferRunMessagesRequest) ProtoMessage Uses

func (*LogTransferRunMessagesRequest) ProtoMessage()

func (*LogTransferRunMessagesRequest) Reset Uses

func (m *LogTransferRunMessagesRequest) Reset()

func (*LogTransferRunMessagesRequest) String Uses

func (m *LogTransferRunMessagesRequest) String() string

func (*LogTransferRunMessagesRequest) XXX_DiscardUnknown Uses

func (m *LogTransferRunMessagesRequest) XXX_DiscardUnknown()

func (*LogTransferRunMessagesRequest) XXX_Marshal Uses

func (m *LogTransferRunMessagesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LogTransferRunMessagesRequest) XXX_Merge Uses

func (m *LogTransferRunMessagesRequest) XXX_Merge(src proto.Message)

func (*LogTransferRunMessagesRequest) XXX_Size Uses

func (m *LogTransferRunMessagesRequest) XXX_Size() int

func (*LogTransferRunMessagesRequest) XXX_Unmarshal Uses

func (m *LogTransferRunMessagesRequest) XXX_Unmarshal(b []byte) error

type ScheduleOptions Uses

type ScheduleOptions struct {

    // 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 `protobuf:"varint,3,opt,name=disable_auto_scheduling,json=disableAutoScheduling,proto3" json:"disable_auto_scheduling,omitempty"`
    // 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 *timestamp.Timestamp `protobuf:"bytes,1,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
    // 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 *timestamp.Timestamp `protobuf:"bytes,2,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"`
    // contains filtered or unexported fields
}

Options customizing the data transfer schedule.

func (*ScheduleOptions) Descriptor Uses

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

Deprecated: Use ScheduleOptions.ProtoReflect.Descriptor instead.

func (*ScheduleOptions) GetDisableAutoScheduling Uses

func (x *ScheduleOptions) GetDisableAutoScheduling() bool

func (*ScheduleOptions) GetEndTime Uses

func (x *ScheduleOptions) GetEndTime() *timestamp.Timestamp

func (*ScheduleOptions) GetStartTime Uses

func (x *ScheduleOptions) GetStartTime() *timestamp.Timestamp

func (*ScheduleOptions) ProtoMessage Uses

func (*ScheduleOptions) ProtoMessage()

func (*ScheduleOptions) ProtoReflect Uses

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

func (*ScheduleOptions) Reset Uses

func (x *ScheduleOptions) Reset()

func (*ScheduleOptions) String Uses

func (x *ScheduleOptions) String() string

type ScheduleTransferRunsRequest Uses

type ScheduleTransferRunsRequest struct {

    // Required. Transfer configuration name in the form:
    // `projects/{project_id}/transferConfigs/{config_id}` or
    // `projects/{project_id}/locations/{location_id}/transferConfigs/{config_id}`.
    Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
    // Required. Start time of the range of transfer runs. For example,
    // `"2017-05-25T00:00:00+00:00"`.
    StartTime *timestamp.Timestamp `protobuf:"bytes,2,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
    // Required. End time of the range of transfer runs. For example,
    // `"2017-05-30T00:00:00+00:00"`.
    EndTime *timestamp.Timestamp `protobuf:"bytes,3,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"`
    // contains filtered or unexported fields
}

A request to schedule transfer runs for a time range.

func (*ScheduleTransferRunsRequest) Descriptor Uses

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

Deprecated: Use ScheduleTransferRunsRequest.ProtoReflect.Descriptor instead.

func (*ScheduleTransferRunsRequest) GetEndTime Uses

func (x *ScheduleTransferRunsRequest) GetEndTime() *timestamp.Timestamp

func (*ScheduleTransferRunsRequest) GetParent Uses

func (x *ScheduleTransferRunsRequest) GetParent() string

func (*ScheduleTransferRunsRequest) GetStartTime Uses

func (x *ScheduleTransferRunsRequest) GetStartTime() *timestamp.Timestamp

func (*ScheduleTransferRunsRequest) ProtoMessage Uses

func (*ScheduleTransferRunsRequest) ProtoMessage()

func (*ScheduleTransferRunsRequest) ProtoReflect Uses

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

func (*ScheduleTransferRunsRequest) Reset Uses

func (x *ScheduleTransferRunsRequest) Reset()

func (*ScheduleTransferRunsRequest) String Uses

func (x *ScheduleTransferRunsRequest) String() string

type ScheduleTransferRunsResponse Uses

type ScheduleTransferRunsResponse struct {

    // The transfer runs that were scheduled.
    Runs []*TransferRun `protobuf:"bytes,1,rep,name=runs,proto3" json:"runs,omitempty"`
    // contains filtered or unexported fields
}

A response to schedule transfer runs for a time range.

func (*ScheduleTransferRunsResponse) Descriptor Uses

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

Deprecated: Use ScheduleTransferRunsResponse.ProtoReflect.Descriptor instead.

func (*ScheduleTransferRunsResponse) GetRuns Uses

func (x *ScheduleTransferRunsResponse) GetRuns() []*TransferRun

func (*ScheduleTransferRunsResponse) ProtoMessage Uses

func (*ScheduleTransferRunsResponse) ProtoMessage()

func (*ScheduleTransferRunsResponse) ProtoReflect Uses

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

func (*ScheduleTransferRunsResponse) Reset Uses

func (x *ScheduleTransferRunsResponse) Reset()

func (*ScheduleTransferRunsResponse) String Uses

func (x *ScheduleTransferRunsResponse) String() string

type StartBigQueryJobsRequest Uses

type StartBigQueryJobsRequest struct {
    // Name of the resource in the form:
    // "projects/{project_id}/locations/{location_id}/transferConfigs/{config_id}/runs/{run_id}"
    Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
    // Import jobs which should be started and monitored.
    ImportedData []*ImportedDataInfo `protobuf:"bytes,2,rep,name=imported_data,json=importedData,proto3" json:"imported_data,omitempty"`
    // User credentials which should be used to start/monitor
    // BigQuery jobs. If not specified, then jobs
    // are started using data source service account credentials.
    // This may be OAuth token or JWT token.
    UserCredentials []byte `protobuf:"bytes,3,opt,name=user_credentials,json=userCredentials,proto3" json:"user_credentials,omitempty"`
    // The number of BQ Jobs that can run in parallel.
    MaxParallelism       int32    `protobuf:"varint,8,opt,name=max_parallelism,json=maxParallelism,proto3" json:"max_parallelism,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

A request to start and monitor a BigQuery load job.

func (*StartBigQueryJobsRequest) Descriptor Uses

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

func (*StartBigQueryJobsRequest) GetImportedData Uses

func (m *StartBigQueryJobsRequest) GetImportedData() []*ImportedDataInfo

func (*StartBigQueryJobsRequest) GetMaxParallelism Uses

func (m *StartBigQueryJobsRequest) GetMaxParallelism() int32

func (*StartBigQueryJobsRequest) GetName Uses

func (m *StartBigQueryJobsRequest) GetName() string

func (*StartBigQueryJobsRequest) GetUserCredentials Uses

func (m *StartBigQueryJobsRequest) GetUserCredentials() []byte

func (*StartBigQueryJobsRequest) ProtoMessage Uses

func (*StartBigQueryJobsRequest) ProtoMessage()

func (*StartBigQueryJobsRequest) Reset Uses

func (m *StartBigQueryJobsRequest) Reset()

func (*StartBigQueryJobsRequest) String Uses

func (m *StartBigQueryJobsRequest) String() string

func (*StartBigQueryJobsRequest) XXX_DiscardUnknown Uses

func (m *StartBigQueryJobsRequest) XXX_DiscardUnknown()

func (*StartBigQueryJobsRequest) XXX_Marshal Uses

func (m *StartBigQueryJobsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StartBigQueryJobsRequest) XXX_Merge Uses

func (m *StartBigQueryJobsRequest) XXX_Merge(src proto.Message)

func (*StartBigQueryJobsRequest) XXX_Size Uses

func (m *StartBigQueryJobsRequest) XXX_Size() int

func (*StartBigQueryJobsRequest) XXX_Unmarshal Uses

func (m *StartBigQueryJobsRequest) XXX_Unmarshal(b []byte) error

type StartManualTransferRunsRequest Uses

type StartManualTransferRunsRequest struct {

    // Transfer configuration name in the form:
    // `projects/{project_id}/transferConfigs/{config_id}` or
    // `projects/{project_id}/locations/{location_id}/transferConfigs/{config_id}`.
    Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
    // The requested time specification - this can be a time range or a specific
    // run_time.
    //
    // Types that are assignable to Time:
    //	*StartManualTransferRunsRequest_RequestedTimeRange
    //	*StartManualTransferRunsRequest_RequestedRunTime
    Time isStartManualTransferRunsRequest_Time `protobuf_oneof:"time"`
    // contains filtered or unexported fields
}

A request to start manual transfer runs.

func (*StartManualTransferRunsRequest) Descriptor Uses

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

Deprecated: Use StartManualTransferRunsRequest.ProtoReflect.Descriptor instead.

func (*StartManualTransferRunsRequest) GetParent Uses

func (x *StartManualTransferRunsRequest) GetParent() string

func (*StartManualTransferRunsRequest) GetRequestedRunTime Uses

func (x *StartManualTransferRunsRequest) GetRequestedRunTime() *timestamp.Timestamp

func (*StartManualTransferRunsRequest) GetRequestedTimeRange Uses

func (x *StartManualTransferRunsRequest) GetRequestedTimeRange() *StartManualTransferRunsRequest_TimeRange

func (*StartManualTransferRunsRequest) GetTime Uses

func (m *StartManualTransferRunsRequest) GetTime() isStartManualTransferRunsRequest_Time

func (*StartManualTransferRunsRequest) ProtoMessage Uses

func (*StartManualTransferRunsRequest) ProtoMessage()

func (*StartManualTransferRunsRequest) ProtoReflect Uses

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

func (*StartManualTransferRunsRequest) Reset Uses

func (x *StartManualTransferRunsRequest) Reset()

func (*StartManualTransferRunsRequest) String Uses

func (x *StartManualTransferRunsRequest) String() string

type StartManualTransferRunsRequest_RequestedRunTime Uses

type StartManualTransferRunsRequest_RequestedRunTime struct {
    // Specific run_time for a transfer run to be started. The
    // requested_run_time must not be in the future.
    RequestedRunTime *timestamp.Timestamp `protobuf:"bytes,4,opt,name=requested_run_time,json=requestedRunTime,proto3,oneof"`
}

type StartManualTransferRunsRequest_RequestedTimeRange Uses

type StartManualTransferRunsRequest_RequestedTimeRange struct {
    // Time range for the transfer runs that should be started.
    RequestedTimeRange *StartManualTransferRunsRequest_TimeRange `protobuf:"bytes,3,opt,name=requested_time_range,json=requestedTimeRange,proto3,oneof"`
}

type StartManualTransferRunsRequest_TimeRange Uses

type StartManualTransferRunsRequest_TimeRange struct {

    // 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 betwen
    // start_time (inclusive) and end_time (exlusive).
    StartTime *timestamp.Timestamp `protobuf:"bytes,1,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
    // 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 betwen start_time
    // (inclusive) and end_time (exlusive).
    EndTime *timestamp.Timestamp `protobuf:"bytes,2,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"`
    // contains filtered or unexported fields
}

A specification for a time range, this will request transfer runs with run_time between start_time (inclusive) and end_time (exclusive).

func (*StartManualTransferRunsRequest_TimeRange) Descriptor Uses

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

Deprecated: Use StartManualTransferRunsRequest_TimeRange.ProtoReflect.Descriptor instead.

func (*StartManualTransferRunsRequest_TimeRange) GetEndTime Uses

func (x *StartManualTransferRunsRequest_TimeRange) GetEndTime() *timestamp.Timestamp

func (*StartManualTransferRunsRequest_TimeRange) GetStartTime Uses

func (x *StartManualTransferRunsRequest_TimeRange) GetStartTime() *timestamp.Timestamp

func (*StartManualTransferRunsRequest_TimeRange) ProtoMessage Uses

func (*StartManualTransferRunsRequest_TimeRange) ProtoMessage()

func (*StartManualTransferRunsRequest_TimeRange) ProtoReflect Uses

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

func (*StartManualTransferRunsRequest_TimeRange) Reset Uses

func (x *StartManualTransferRunsRequest_TimeRange) Reset()

func (*StartManualTransferRunsRequest_TimeRange) String Uses

func (x *StartManualTransferRunsRequest_TimeRange) String() string

type StartManualTransferRunsResponse Uses

type StartManualTransferRunsResponse struct {

    // The transfer runs that were created.
    Runs []*TransferRun `protobuf:"bytes,1,rep,name=runs,proto3" json:"runs,omitempty"`
    // contains filtered or unexported fields
}

A response to start manual transfer runs.

func (*StartManualTransferRunsResponse) Descriptor Uses

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

Deprecated: Use StartManualTransferRunsResponse.ProtoReflect.Descriptor instead.

func (*StartManualTransferRunsResponse) GetRuns Uses

func (x *StartManualTransferRunsResponse) GetRuns() []*TransferRun

func (*StartManualTransferRunsResponse) ProtoMessage Uses

func (*StartManualTransferRunsResponse) ProtoMessage()

func (*StartManualTransferRunsResponse) ProtoReflect Uses

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

func (*StartManualTransferRunsResponse) Reset Uses

func (x *StartManualTransferRunsResponse) Reset()

func (*StartManualTransferRunsResponse) String Uses

func (x *StartManualTransferRunsResponse) String() string

type TransferConfig Uses

type TransferConfig struct {

    // The resource name of the transfer config.
    // Transfer config names have the form of
    // `projects/{project_id}/locations/{region}/transferConfigs/{config_id}`.
    // The name is automatically generated based on the config_id specified in
    // CreateTransferConfigRequest along with project_id and region. If config_id
    // is not provided, usually a uuid, even though it is not guaranteed or
    // required, will be generated for config_id.
    Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
    // The desination of the transfer config.
    //
    // Types that are assignable to Destination:
    //	*TransferConfig_DestinationDatasetId
    Destination isTransferConfig_Destination `protobuf_oneof:"destination"`
    // User specified display name for the data transfer.
    DisplayName string `protobuf:"bytes,3,opt,name=display_name,json=displayName,proto3" json:"display_name,omitempty"`
    // Data source id. Cannot be changed once data transfer is created.
    DataSourceId string `protobuf:"bytes,5,opt,name=data_source_id,json=dataSourceId,proto3" json:"data_source_id,omitempty"`
    // Data transfer specific parameters.
    Params *_struct.Struct `protobuf:"bytes,9,opt,name=params,proto3" json:"params,omitempty"`
    // 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 granularity should be at least 8 hours, or less frequent.
    Schedule string `protobuf:"bytes,7,opt,name=schedule,proto3" json:"schedule,omitempty"`
    // Options customizing the data transfer schedule.
    ScheduleOptions *ScheduleOptions `protobuf:"bytes,24,opt,name=schedule_options,json=scheduleOptions,proto3" json:"schedule_options,omitempty"`
    // 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 int32 `protobuf:"varint,12,opt,name=data_refresh_window_days,json=dataRefreshWindowDays,proto3" json:"data_refresh_window_days,omitempty"`
    // Is this config disabled. When set to true, no runs are scheduled
    // for a given transfer.
    Disabled bool `protobuf:"varint,13,opt,name=disabled,proto3" json:"disabled,omitempty"`
    // Output only. Data transfer modification time. Ignored by server on input.
    UpdateTime *timestamp.Timestamp `protobuf:"bytes,4,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"`
    // Output only. Next time when data transfer will run.
    NextRunTime *timestamp.Timestamp `protobuf:"bytes,8,opt,name=next_run_time,json=nextRunTime,proto3" json:"next_run_time,omitempty"`
    // Output only. State of the most recently updated transfer run.
    State TransferState `protobuf:"varint,10,opt,name=state,proto3,enum=google.cloud.bigquery.datatransfer.v1.TransferState" json:"state,omitempty"`
    // Deprecated. Unique ID of the user on whose behalf transfer is done.
    UserId int64 `protobuf:"varint,11,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
    // Output only. Region in which BigQuery dataset is located.
    DatasetRegion string `protobuf:"bytes,14,opt,name=dataset_region,json=datasetRegion,proto3" json:"dataset_region,omitempty"`
    // Pub/Sub topic where notifications will be sent after transfer runs
    // associated with this transfer config finish.
    NotificationPubsubTopic string `protobuf:"bytes,15,opt,name=notification_pubsub_topic,json=notificationPubsubTopic,proto3" json:"notification_pubsub_topic,omitempty"`
    // Email notifications will be sent according to these preferences
    // to the email address of the user who owns this transfer config.
    EmailPreferences *EmailPreferences `protobuf:"bytes,18,opt,name=email_preferences,json=emailPreferences,proto3" json:"email_preferences,omitempty"`
    // contains filtered or unexported fields
}

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) Descriptor Uses

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

Deprecated: Use TransferConfig.ProtoReflect.Descriptor instead.

func (*TransferConfig) GetDataRefreshWindowDays Uses

func (x *TransferConfig) GetDataRefreshWindowDays() int32

func (*TransferConfig) GetDataSourceId Uses

func (x *TransferConfig) GetDataSourceId() string

func (*TransferConfig) GetDatasetRegion Uses

func (x *TransferConfig) GetDatasetRegion() string

func (*TransferConfig) GetDestination Uses

func (m *TransferConfig) GetDestination() isTransferConfig_Destination

func (*TransferConfig) GetDestinationDatasetId Uses

func (x *TransferConfig) GetDestinationDatasetId() string

func (*TransferConfig) GetDisabled Uses

func (x *TransferConfig) GetDisabled() bool

func (*TransferConfig) GetDisplayName Uses

func (x *TransferConfig) GetDisplayName() string

func (*TransferConfig) GetEmailPreferences Uses

func (x *TransferConfig) GetEmailPreferences() *EmailPreferences

func (*TransferConfig) GetName Uses

func (x *TransferConfig) GetName() string

func (*TransferConfig) GetNextRunTime Uses

func (x *TransferConfig) GetNextRunTime() *timestamp.Timestamp

func (*TransferConfig) GetNotificationPubsubTopic Uses

func (x *TransferConfig) GetNotificationPubsubTopic() string

func (*TransferConfig) GetParams Uses

func (x *TransferConfig) GetParams() *_struct.Struct

func (*TransferConfig) GetSchedule Uses

func (x *TransferConfig) GetSchedule() string

func (*TransferConfig) GetScheduleOptions Uses

func (x *TransferConfig) GetScheduleOptions() *ScheduleOptions

func (*TransferConfig) GetState Uses

func (x *TransferConfig) GetState() TransferState

func (*TransferConfig) GetUpdateTime Uses

func (x *TransferConfig) GetUpdateTime() *timestamp.Timestamp

func (*TransferConfig) GetUserId Uses

func (x *TransferConfig) GetUserId() int64

func (*TransferConfig) ProtoMessage Uses

func (*TransferConfig) ProtoMessage()

func (*TransferConfig) ProtoReflect Uses

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

func (*TransferConfig) Reset Uses

func (x *TransferConfig) Reset()

func (*TransferConfig) String Uses

func (x *TransferConfig) String() string

type TransferConfig_DestinationDatasetId Uses

type TransferConfig_DestinationDatasetId struct {
    // The BigQuery target dataset id.
    DestinationDatasetId string `protobuf:"bytes,2,opt,name=destination_dataset_id,json=destinationDatasetId,proto3,oneof"`
}

type TransferMessage Uses

type TransferMessage struct {

    // Time when message was logged.
    MessageTime *timestamp.Timestamp `protobuf:"bytes,1,opt,name=message_time,json=messageTime,proto3" json:"message_time,omitempty"`
    // Message severity.
    Severity TransferMessage_MessageSeverity `protobuf:"varint,2,opt,name=severity,proto3,enum=google.cloud.bigquery.datatransfer.v1.TransferMessage_MessageSeverity" json:"severity,omitempty"`
    // Message text.
    MessageText string `protobuf:"bytes,3,opt,name=message_text,json=messageText,proto3" json:"message_text,omitempty"`
    // contains filtered or unexported fields
}

Represents a user facing message for a particular data transfer run.

func (*TransferMessage) Descriptor Uses

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

Deprecated: Use TransferMessage.ProtoReflect.Descriptor instead.

func (*TransferMessage) GetMessageText Uses

func (x *TransferMessage) GetMessageText() string

func (*TransferMessage) GetMessageTime Uses

func (x *TransferMessage) GetMessageTime() *timestamp.Timestamp

func (*TransferMessage) GetSeverity Uses

func (x *TransferMessage) GetSeverity() TransferMessage_MessageSeverity

func (*TransferMessage) ProtoMessage Uses

func (*TransferMessage) ProtoMessage()

func (*TransferMessage) ProtoReflect Uses

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

func (*TransferMessage) Reset Uses

func (x *TransferMessage) Reset()

func (*TransferMessage) String Uses

func (x *TransferMessage) String() string

type TransferMessage_MessageSeverity Uses

type TransferMessage_MessageSeverity int32

Represents data transfer user facing message severity.

const (
    // No severity specified.
    TransferMessage_MESSAGE_SEVERITY_UNSPECIFIED TransferMessage_MessageSeverity = 0
    // Informational message.
    TransferMessage_INFO TransferMessage_MessageSeverity = 1
    // Warning message.
    TransferMessage_WARNING TransferMessage_MessageSeverity = 2
    // Error message.
    TransferMessage_ERROR TransferMessage_MessageSeverity = 3
)

func (TransferMessage_MessageSeverity) Descriptor Uses

func (TransferMessage_MessageSeverity) Descriptor() protoreflect.EnumDescriptor

func (TransferMessage_MessageSeverity) Enum Uses

func (x TransferMessage_MessageSeverity) Enum() *TransferMessage_MessageSeverity

func (TransferMessage_MessageSeverity) EnumDescriptor Uses

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

Deprecated: Use TransferMessage_MessageSeverity.Descriptor instead.

func (TransferMessage_MessageSeverity) Number Uses

func (x TransferMessage_MessageSeverity) Number() protoreflect.EnumNumber

func (TransferMessage_MessageSeverity) String Uses

func (x TransferMessage_MessageSeverity) String() string

func (TransferMessage_MessageSeverity) Type Uses

func (TransferMessage_MessageSeverity) Type() protoreflect.EnumType

type TransferRun Uses

type TransferRun struct {

    // 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 `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
    // Minimum time after which a transfer run can be started.
    ScheduleTime *timestamp.Timestamp `protobuf:"bytes,3,opt,name=schedule_time,json=scheduleTime,proto3" json:"schedule_time,omitempty"`
    // For batch transfer runs, specifies the date and time of the data should be
    // ingested.
    RunTime *timestamp.Timestamp `protobuf:"bytes,10,opt,name=run_time,json=runTime,proto3" json:"run_time,omitempty"`
    // Status of the transfer run.
    ErrorStatus *status.Status `protobuf:"bytes,21,opt,name=error_status,json=errorStatus,proto3" json:"error_status,omitempty"`
    // Output only. Time when transfer run was started.
    // Parameter ignored by server for input requests.
    StartTime *timestamp.Timestamp `protobuf:"bytes,4,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
    // Output only. Time when transfer run ended.
    // Parameter ignored by server for input requests.
    EndTime *timestamp.Timestamp `protobuf:"bytes,5,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"`
    // Output only. Last time the data transfer run state was updated.
    UpdateTime *timestamp.Timestamp `protobuf:"bytes,6,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"`
    // Output only. Data transfer specific parameters.
    Params *_struct.Struct `protobuf:"bytes,9,opt,name=params,proto3" json:"params,omitempty"`
    // Data transfer destination.
    //
    // Types that are assignable to Destination:
    //	*TransferRun_DestinationDatasetId
    Destination isTransferRun_Destination `protobuf_oneof:"destination"`
    // Output only. Data source id.
    DataSourceId string `protobuf:"bytes,7,opt,name=data_source_id,json=dataSourceId,proto3" json:"data_source_id,omitempty"`
    // Data transfer run state. Ignored for input requests.
    State TransferState `protobuf:"varint,8,opt,name=state,proto3,enum=google.cloud.bigquery.datatransfer.v1.TransferState" json:"state,omitempty"`
    // Deprecated. Unique ID of the user on whose behalf transfer is done.
    UserId int64 `protobuf:"varint,11,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
    // 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 `protobuf:"bytes,12,opt,name=schedule,proto3" json:"schedule,omitempty"`
    // Output only. Pub/Sub topic where a notification will be sent after this
    // transfer run finishes
    NotificationPubsubTopic string `protobuf:"bytes,23,opt,name=notification_pubsub_topic,json=notificationPubsubTopic,proto3" json:"notification_pubsub_topic,omitempty"`
    // 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 `protobuf:"bytes,25,opt,name=email_preferences,json=emailPreferences,proto3" json:"email_preferences,omitempty"`
    // contains filtered or unexported fields
}

Represents a data transfer run.

func (*TransferRun) Descriptor Uses

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

Deprecated: Use TransferRun.ProtoReflect.Descriptor instead.

func (*TransferRun) GetDataSourceId Uses

func (x *TransferRun) GetDataSourceId() string

func (*TransferRun) GetDestination Uses

func (m *TransferRun) GetDestination() isTransferRun_Destination

func (*TransferRun) GetDestinationDatasetId Uses

func (x *TransferRun) GetDestinationDatasetId() string

func (*TransferRun) GetEmailPreferences Uses

func (x *TransferRun) GetEmailPreferences() *EmailPreferences

func (*TransferRun) GetEndTime Uses

func (x *TransferRun) GetEndTime() *timestamp.Timestamp

func (*TransferRun) GetErrorStatus Uses

func (x *TransferRun) GetErrorStatus() *status.Status

func (*TransferRun) GetName Uses

func (x *TransferRun) GetName() string

func (*TransferRun) GetNotificationPubsubTopic Uses

func (x *TransferRun) GetNotificationPubsubTopic() string

func (*TransferRun) GetParams Uses

func (x *TransferRun) GetParams() *_struct.Struct

func (*TransferRun) GetRunTime Uses

func (x *TransferRun) GetRunTime() *timestamp.Timestamp

func (*TransferRun) GetSchedule Uses

func (x *TransferRun) GetSchedule() string

func (*TransferRun) GetScheduleTime Uses

func (x *TransferRun) GetScheduleTime() *timestamp.Timestamp

func (*TransferRun) GetStartTime Uses

func (x *TransferRun) GetStartTime() *timestamp.Timestamp

func (*TransferRun) GetState Uses

func (x *TransferRun) GetState() TransferState

func (*TransferRun) GetUpdateTime Uses

func (x *TransferRun) GetUpdateTime() *timestamp.Timestamp

func (*TransferRun) GetUserId Uses

func (x *TransferRun) GetUserId() int64

func (*TransferRun) ProtoMessage Uses

func (*TransferRun) ProtoMessage()

func (*TransferRun) ProtoReflect Uses

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

func (*TransferRun) Reset Uses

func (x *TransferRun) Reset()

func (*TransferRun) String Uses

func (x *TransferRun) String() string

type TransferRun_DestinationDatasetId Uses

type TransferRun_DestinationDatasetId struct {
    // Output only. The BigQuery target dataset id.
    DestinationDatasetId string `protobuf:"bytes,2,opt,name=destination_dataset_id,json=destinationDatasetId,proto3,oneof"`
}

type TransferState Uses

type TransferState int32

Represents data transfer run state.

const (
    // State placeholder.
    TransferState_TRANSFER_STATE_UNSPECIFIED TransferState = 0
    // Data transfer is scheduled and is waiting to be picked up by
    // data transfer backend.
    TransferState_PENDING TransferState = 2
    // Data transfer is in progress.
    TransferState_RUNNING TransferState = 3
    // Data transfer completed successfully.
    TransferState_SUCCEEDED TransferState = 4
    // Data transfer failed.
    TransferState_FAILED TransferState = 5
    // Data transfer is cancelled.
    TransferState_CANCELLED TransferState = 6
)

func (TransferState) Descriptor Uses

func (TransferState) Descriptor() protoreflect.EnumDescriptor

func (TransferState) Enum Uses

func (x TransferState) Enum() *TransferState

func (TransferState) EnumDescriptor Uses

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

Deprecated: Use TransferState.Descriptor instead.

func (TransferState) Number Uses

func (x TransferState) Number() protoreflect.EnumNumber

func (TransferState) String Uses

func (x TransferState) String() string

func (TransferState) Type Uses

func (TransferState) Type() protoreflect.EnumType

type TransferType Uses

type TransferType int32

DEPRECATED. Represents data transfer type.

Deprecated: Do not use.

const (
    // Invalid or Unknown transfer type placeholder.
    TransferType_TRANSFER_TYPE_UNSPECIFIED TransferType = 0
    // Batch data transfer.
    TransferType_BATCH TransferType = 1
    // Streaming data transfer. Streaming data source currently doesn't
    // support multiple transfer configs per project.
    TransferType_STREAMING TransferType = 2
)

func (TransferType) Descriptor Uses

func (TransferType) Descriptor() protoreflect.EnumDescriptor

func (TransferType) Enum Uses

func (x TransferType) Enum() *TransferType

func (TransferType) EnumDescriptor Uses

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

Deprecated: Use TransferType.Descriptor instead.

func (TransferType) Number Uses

func (x TransferType) Number() protoreflect.EnumNumber

func (TransferType) String Uses

func (x TransferType) String() string

func (TransferType) Type Uses

func (TransferType) Type() protoreflect.EnumType

type UnimplementedDataSourceServiceServer Uses

type UnimplementedDataSourceServiceServer struct {
}

UnimplementedDataSourceServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedDataSourceServiceServer) CreateDataSourceDefinition Uses

func (*UnimplementedDataSourceServiceServer) CreateDataSourceDefinition(ctx context.Context, req *CreateDataSourceDefinitionRequest) (*DataSourceDefinition, error)

func (*UnimplementedDataSourceServiceServer) DeleteDataSourceDefinition Uses

func (*UnimplementedDataSourceServiceServer) DeleteDataSourceDefinition(ctx context.Context, req *DeleteDataSourceDefinitionRequest) (*empty.Empty, error)

func (*UnimplementedDataSourceServiceServer) FinishRun Uses

func (*UnimplementedDataSourceServiceServer) FinishRun(ctx context.Context, req *FinishRunRequest) (*empty.Empty, error)

func (*UnimplementedDataSourceServiceServer) GetDataSourceDefinition Uses

func (*UnimplementedDataSourceServiceServer) GetDataSourceDefinition(ctx context.Context, req *GetDataSourceDefinitionRequest) (*DataSourceDefinition, error)

func (*UnimplementedDataSourceServiceServer) ListDataSourceDefinitions Uses

func (*UnimplementedDataSourceServiceServer) ListDataSourceDefinitions(ctx context.Context, req *ListDataSourceDefinitionsRequest) (*ListDataSourceDefinitionsResponse, error)

func (*UnimplementedDataSourceServiceServer) LogTransferRunMessages Uses

func (*UnimplementedDataSourceServiceServer) LogTransferRunMessages(ctx context.Context, req *LogTransferRunMessagesRequest) (*empty.Empty, error)

func (*UnimplementedDataSourceServiceServer) StartBigQueryJobs Uses

func (*UnimplementedDataSourceServiceServer) StartBigQueryJobs(ctx context.Context, req *StartBigQueryJobsRequest) (*empty.Empty, error)

func (*UnimplementedDataSourceServiceServer) UpdateDataSourceDefinition Uses

func (*UnimplementedDataSourceServiceServer) UpdateDataSourceDefinition(ctx context.Context, req *UpdateDataSourceDefinitionRequest) (*DataSourceDefinition, error)

func (*UnimplementedDataSourceServiceServer) UpdateTransferRun Uses

func (*UnimplementedDataSourceServiceServer) UpdateTransferRun(ctx context.Context, req *UpdateTransferRunRequest) (*TransferRun, error)

type UnimplementedDataTransferServiceServer Uses

type UnimplementedDataTransferServiceServer struct {
}

UnimplementedDataTransferServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedDataTransferServiceServer) CheckValidCreds Uses

func (*UnimplementedDataTransferServiceServer) CheckValidCreds(context.Context, *CheckValidCredsRequest) (*CheckValidCredsResponse, error)

func (*UnimplementedDataTransferServiceServer) CreateTransferConfig Uses

func (*UnimplementedDataTransferServiceServer) CreateTransferConfig(context.Context, *CreateTransferConfigRequest) (*TransferConfig, error)

func (*UnimplementedDataTransferServiceServer) DeleteTransferConfig Uses

func (*UnimplementedDataTransferServiceServer) DeleteTransferConfig(context.Context, *DeleteTransferConfigRequest) (*empty.Empty, error)

func (*UnimplementedDataTransferServiceServer) DeleteTransferRun Uses

func (*UnimplementedDataTransferServiceServer) DeleteTransferRun(context.Context, *DeleteTransferRunRequest) (*empty.Empty, error)

func (*UnimplementedDataTransferServiceServer) GetDataSource Uses

func (*UnimplementedDataTransferServiceServer) GetDataSource(context.Context, *GetDataSourceRequest) (*DataSource, error)

func (*UnimplementedDataTransferServiceServer) GetTransferConfig Uses

func (*UnimplementedDataTransferServiceServer) GetTransferConfig(context.Context, *GetTransferConfigRequest) (*TransferConfig, error)

func (*UnimplementedDataTransferServiceServer) GetTransferRun Uses

func (*UnimplementedDataTransferServiceServer) GetTransferRun(context.Context, *GetTransferRunRequest) (*TransferRun, error)

func (*UnimplementedDataTransferServiceServer) ListDataSources Uses

func (*UnimplementedDataTransferServiceServer) ListDataSources(context.Context, *ListDataSourcesRequest) (*ListDataSourcesResponse, error)

func (*UnimplementedDataTransferServiceServer) ListTransferConfigs Uses

func (*UnimplementedDataTransferServiceServer) ListTransferConfigs(context.Context, *ListTransferConfigsRequest) (*ListTransferConfigsResponse, error)

func (*UnimplementedDataTransferServiceServer) ListTransferLogs Uses

func (*UnimplementedDataTransferServiceServer) ListTransferLogs(context.Context, *ListTransferLogsRequest) (*ListTransferLogsResponse, error)

func (*UnimplementedDataTransferServiceServer) ListTransferRuns Uses

func (*UnimplementedDataTransferServiceServer) ListTransferRuns(context.Context, *ListTransferRunsRequest) (*ListTransferRunsResponse, error)

func (*UnimplementedDataTransferServiceServer) ScheduleTransferRuns Uses

func (*UnimplementedDataTransferServiceServer) ScheduleTransferRuns(context.Context, *ScheduleTransferRunsRequest) (*ScheduleTransferRunsResponse, error)

func (*UnimplementedDataTransferServiceServer) StartManualTransferRuns Uses

func (*UnimplementedDataTransferServiceServer) StartManualTransferRuns(context.Context, *StartManualTransferRunsRequest) (*StartManualTransferRunsResponse, error)

func (*UnimplementedDataTransferServiceServer) UpdateTransferConfig Uses

func (*UnimplementedDataTransferServiceServer) UpdateTransferConfig(context.Context, *UpdateTransferConfigRequest) (*TransferConfig, error)

type UpdateDataSourceDefinitionRequest Uses

type UpdateDataSourceDefinitionRequest struct {
    // Data source definition.
    DataSourceDefinition *DataSourceDefinition `protobuf:"bytes,1,opt,name=data_source_definition,json=dataSourceDefinition,proto3" json:"data_source_definition,omitempty"`
    // Update field mask.
    UpdateMask           *field_mask.FieldMask `protobuf:"bytes,2,opt,name=update_mask,json=updateMask,proto3" json:"update_mask,omitempty"`
    XXX_NoUnkeyedLiteral struct{}              `json:"-"`
    XXX_unrecognized     []byte                `json:"-"`
    XXX_sizecache        int32                 `json:"-"`
}

Represents the request of the UpdateDataSourceDefinition method.

func (*UpdateDataSourceDefinitionRequest) Descriptor Uses

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

func (*UpdateDataSourceDefinitionRequest) GetDataSourceDefinition Uses

func (m *UpdateDataSourceDefinitionRequest) GetDataSourceDefinition() *DataSourceDefinition

func (*UpdateDataSourceDefinitionRequest) GetUpdateMask Uses

func (m *UpdateDataSourceDefinitionRequest) GetUpdateMask() *field_mask.FieldMask

func (*UpdateDataSourceDefinitionRequest) ProtoMessage Uses

func (*UpdateDataSourceDefinitionRequest) ProtoMessage()

func (*UpdateDataSourceDefinitionRequest) Reset Uses

func (m *UpdateDataSourceDefinitionRequest) Reset()

func (*UpdateDataSourceDefinitionRequest) String Uses

func (m *UpdateDataSourceDefinitionRequest) String() string

func (*UpdateDataSourceDefinitionRequest) XXX_DiscardUnknown Uses

func (m *UpdateDataSourceDefinitionRequest) XXX_DiscardUnknown()

func (*UpdateDataSourceDefinitionRequest) XXX_Marshal Uses

func (m *UpdateDataSourceDefinitionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UpdateDataSourceDefinitionRequest) XXX_Merge Uses

func (m *UpdateDataSourceDefinitionRequest) XXX_Merge(src proto.Message)

func (*UpdateDataSourceDefinitionRequest) XXX_Size Uses

func (m *UpdateDataSourceDefinitionRequest) XXX_Size() int

func (*UpdateDataSourceDefinitionRequest) XXX_Unmarshal Uses

func (m *UpdateDataSourceDefinitionRequest) XXX_Unmarshal(b []byte) error

type UpdateTransferConfigRequest Uses

type UpdateTransferConfigRequest struct {

    // Required. Data transfer configuration to create.
    TransferConfig *TransferConfig `protobuf:"bytes,1,opt,name=transfer_config,json=transferConfig,proto3" json:"transfer_config,omitempty"`
    // Optional OAuth2 authorization code to use with this transfer configuration.
    // If it is provided, the transfer configuration will be associated with the
    // authorizing user.
    // In order to obtain authorization_code, please make a
    // request to
    // https://www.gstatic.com/bigquerydatatransfer/oauthz/auth?client_id=<datatransferapiclientid>&scope=<data_source_scopes>&redirect_uri=<redirect_uri>
    //
    // * client_id should be OAuth client_id of BigQuery DTS API for the given
    //   data source returned by ListDataSources method.
    // * data_source_scopes are the scopes returned by ListDataSources method.
    // * redirect_uri is an optional parameter. If not specified, then
    //   authorization code is posted to the opener of authorization flow window.
    //   Otherwise it will be sent to the redirect uri. A special value of
    //   urn:ietf:wg:oauth:2.0:oob means that authorization code should be
    //   returned in the title bar of the browser, with the page text prompting
    //   the user to copy the code and paste it in the application.
    AuthorizationCode string `protobuf:"bytes,3,opt,name=authorization_code,json=authorizationCode,proto3" json:"authorization_code,omitempty"`
    // Required. Required list of fields to be updated in this request.
    UpdateMask *field_mask.FieldMask `protobuf:"bytes,4,opt,name=update_mask,json=updateMask,proto3" json:"update_mask,omitempty"`
    // Optional version info. If users want to find a very recent access token,
    // that is, immediately after approving access, users have to set the
    // version_info claim in the token request. To obtain the version_info, users
    // must use the "none+gsession" response type. which be return a
    // version_info back in the authorization response which be be put in a JWT
    // claim in the token request.
    VersionInfo string `protobuf:"bytes,5,opt,name=version_info,json=versionInfo,proto3" json:"version_info,omitempty"`
    // Optional service account name. If this field is set and
    // "service_account_name" is set in update_mask, transfer config will be
    // updated to use this service account credentials. It requires that
    // requesting user calling this API has permissions to act as this service
    // account.
    ServiceAccountName string `protobuf:"bytes,6,opt,name=service_account_name,json=serviceAccountName,proto3" json:"service_account_name,omitempty"`
    // contains filtered or unexported fields
}

A request to update a transfer configuration. To update the user id of the transfer configuration, an authorization code needs to be provided.

func (*UpdateTransferConfigRequest) Descriptor Uses

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

Deprecated: Use UpdateTransferConfigRequest.ProtoReflect.Descriptor instead.

func (*UpdateTransferConfigRequest) GetAuthorizationCode Uses

func (x *UpdateTransferConfigRequest) GetAuthorizationCode() string

func (*UpdateTransferConfigRequest) GetServiceAccountName Uses

func (x *UpdateTransferConfigRequest) GetServiceAccountName() string

func (*UpdateTransferConfigRequest) GetTransferConfig Uses

func (x *UpdateTransferConfigRequest) GetTransferConfig() *TransferConfig

func (*UpdateTransferConfigRequest) GetUpdateMask Uses

func (x *UpdateTransferConfigRequest) GetUpdateMask() *field_mask.FieldMask

func (*UpdateTransferConfigRequest) GetVersionInfo Uses

func (x *UpdateTransferConfigRequest) GetVersionInfo() string

func (*UpdateTransferConfigRequest) ProtoMessage Uses

func (*UpdateTransferConfigRequest) ProtoMessage()

func (*UpdateTransferConfigRequest) ProtoReflect Uses

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

func (*UpdateTransferConfigRequest) Reset Uses

func (x *UpdateTransferConfigRequest) Reset()

func (*UpdateTransferConfigRequest) String Uses

func (x *UpdateTransferConfigRequest) String() string

type UpdateTransferRunRequest Uses

type UpdateTransferRunRequest struct {
    // Run name must be set and correspond to an already existing run. Only
    // state, error_status, and data_version fields will be updated. All other
    // fields will be ignored.
    TransferRun *TransferRun `protobuf:"bytes,1,opt,name=transfer_run,json=transferRun,proto3" json:"transfer_run,omitempty"`
    // Required list of fields to be updated in this request.
    UpdateMask           *field_mask.FieldMask `protobuf:"bytes,2,opt,name=update_mask,json=updateMask,proto3" json:"update_mask,omitempty"`
    XXX_NoUnkeyedLiteral struct{}              `json:"-"`
    XXX_unrecognized     []byte                `json:"-"`
    XXX_sizecache        int32                 `json:"-"`
}

A request to update a transfer run.

func (*UpdateTransferRunRequest) Descriptor Uses

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

func (*UpdateTransferRunRequest) GetTransferRun Uses

func (m *UpdateTransferRunRequest) GetTransferRun() *TransferRun

func (*UpdateTransferRunRequest) GetUpdateMask Uses

func (m *UpdateTransferRunRequest) GetUpdateMask() *field_mask.FieldMask

func (*UpdateTransferRunRequest) ProtoMessage Uses

func (*UpdateTransferRunRequest) ProtoMessage()

func (*UpdateTransferRunRequest) Reset Uses

func (m *UpdateTransferRunRequest) Reset()

func (*UpdateTransferRunRequest) String Uses

func (m *UpdateTransferRunRequest) String() string

func (*UpdateTransferRunRequest) XXX_DiscardUnknown Uses

func (m *UpdateTransferRunRequest) XXX_DiscardUnknown()

func (*UpdateTransferRunRequest) XXX_Marshal Uses

func (m *UpdateTransferRunRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UpdateTransferRunRequest) XXX_Merge Uses

func (m *UpdateTransferRunRequest) XXX_Merge(src proto.Message)

func (*UpdateTransferRunRequest) XXX_Size Uses

func (m *UpdateTransferRunRequest) XXX_Size() int

func (*UpdateTransferRunRequest) XXX_Unmarshal Uses

func (m *UpdateTransferRunRequest) XXX_Unmarshal(b []byte) error

type WriteDisposition Uses

type WriteDisposition int32

Options for writing to the table. The WRITE_EMPTY option is intentionally excluded from the enum and is not supported by the data transfer service.

const (
    // The default writeDispostion
    WriteDisposition_WRITE_DISPOSITION_UNSPECIFIED WriteDisposition = 0
    // overwrites the table data.
    WriteDisposition_WRITE_TRUNCATE WriteDisposition = 1
    // the data is appended to the table.
    // Note duplication might happen if this mode is used.
    WriteDisposition_WRITE_APPEND WriteDisposition = 2
)

func (WriteDisposition) EnumDescriptor Uses

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

func (WriteDisposition) String Uses

func (x WriteDisposition) String() string

Package datatransfer imports 19 packages (graph) and is imported by 3 packages. Updated 2020-05-31. Refresh now. Tools for package owners.