datatransfer

Jul 1, 2019

Changes in this version

type CallOptions

+ StartManualTransferRuns []gax.CallOption

type Client

+ func (c *Client) StartManualTransferRuns(ctx context.Context, req *datatransferpb.StartManualTransferRunsRequest, ...) (*datatransferpb.StartManualTransferRunsResponse, error)

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