Versions in this module Expand all Collapse all v0 v0.18.0 Jan 19, 2018 v0.17.0 Dec 11, 2017 Changes in this version + func DataSourcePath(project, dataSource string) string + func DefaultAuthScopes() []string + func LocationDataSourcePath(project, location, dataSource string) string + func LocationPath(project, location string) string + func LocationRunPath(project, location, transferConfig, run string) string + func LocationTransferConfigPath(project, location, transferConfig string) string + func ProjectPath(project string) string + func RunPath(project, transferConfig, run string) string + func TransferConfigPath(project, transferConfig string) string + type CallOptions struct + CheckValidCreds []gax.CallOption + CreateTransferConfig []gax.CallOption + DeleteTransferConfig []gax.CallOption + DeleteTransferRun []gax.CallOption + GetDataSource []gax.CallOption + GetTransferConfig []gax.CallOption + GetTransferRun []gax.CallOption + ListDataSources []gax.CallOption + ListTransferConfigs []gax.CallOption + ListTransferLogs []gax.CallOption + ListTransferRuns []gax.CallOption + ScheduleTransferRuns []gax.CallOption + UpdateTransferConfig []gax.CallOption + type Client struct + CallOptions *CallOptions + func NewClient(ctx context.Context, opts ...option.ClientOption) (*Client, error) + func (c *Client) CheckValidCreds(ctx context.Context, req *datatransferpb.CheckValidCredsRequest, ...) (*datatransferpb.CheckValidCredsResponse, error) + func (c *Client) Close() error + func (c *Client) Connection() *grpc.ClientConn + func (c *Client) CreateTransferConfig(ctx context.Context, req *datatransferpb.CreateTransferConfigRequest, ...) (*datatransferpb.TransferConfig, error) + func (c *Client) DeleteTransferConfig(ctx context.Context, req *datatransferpb.DeleteTransferConfigRequest, ...) error + func (c *Client) DeleteTransferRun(ctx context.Context, req *datatransferpb.DeleteTransferRunRequest, ...) error + func (c *Client) GetDataSource(ctx context.Context, req *datatransferpb.GetDataSourceRequest, ...) (*datatransferpb.DataSource, error) + func (c *Client) GetTransferConfig(ctx context.Context, req *datatransferpb.GetTransferConfigRequest, ...) (*datatransferpb.TransferConfig, error) + func (c *Client) GetTransferRun(ctx context.Context, req *datatransferpb.GetTransferRunRequest, ...) (*datatransferpb.TransferRun, error) + func (c *Client) ListDataSources(ctx context.Context, req *datatransferpb.ListDataSourcesRequest, ...) *DataSourceIterator + func (c *Client) ListTransferConfigs(ctx context.Context, req *datatransferpb.ListTransferConfigsRequest, ...) *TransferConfigIterator + func (c *Client) ListTransferLogs(ctx context.Context, req *datatransferpb.ListTransferLogsRequest, ...) *TransferMessageIterator + func (c *Client) ListTransferRuns(ctx context.Context, req *datatransferpb.ListTransferRunsRequest, ...) *TransferRunIterator + func (c *Client) ScheduleTransferRuns(ctx context.Context, req *datatransferpb.ScheduleTransferRunsRequest, ...) (*datatransferpb.ScheduleTransferRunsResponse, error) + func (c *Client) UpdateTransferConfig(ctx context.Context, req *datatransferpb.UpdateTransferConfigRequest, ...) (*datatransferpb.TransferConfig, error) + type DataSourceIterator struct + InternalFetch func(pageSize int, pageToken string) (results []*datatransferpb.DataSource, nextPageToken string, err error) + func (it *DataSourceIterator) Next() (*datatransferpb.DataSource, error) + func (it *DataSourceIterator) PageInfo() *iterator.PageInfo + type TransferConfigIterator struct + InternalFetch func(pageSize int, pageToken string) (results []*datatransferpb.TransferConfig, nextPageToken string, err error) + func (it *TransferConfigIterator) Next() (*datatransferpb.TransferConfig, error) + func (it *TransferConfigIterator) PageInfo() *iterator.PageInfo + type TransferMessageIterator struct + InternalFetch func(pageSize int, pageToken string) (results []*datatransferpb.TransferMessage, nextPageToken string, err error) + func (it *TransferMessageIterator) Next() (*datatransferpb.TransferMessage, error) + func (it *TransferMessageIterator) PageInfo() *iterator.PageInfo + type TransferRunIterator struct + InternalFetch func(pageSize int, pageToken string) (results []*datatransferpb.TransferRun, nextPageToken string, err error) + func (it *TransferRunIterator) Next() (*datatransferpb.TransferRun, error) + func (it *TransferRunIterator) PageInfo() *iterator.PageInfo
Go to main page