storagetransfer

Sep 12, 2024

Changes in this version

type AgentPoolIterator

+ func (it *AgentPoolIterator) All() iter.Seq2[*storagetransferpb.AgentPool, error]

type OperationIterator

+ func (it *OperationIterator) All() iter.Seq2[*longrunningpb.Operation, error]

type TransferJobIterator

+ func (it *TransferJobIterator) All() iter.Seq2[*storagetransferpb.TransferJob, error]

Jan 5, 2023

Changes in this version

type Client

+ func NewRESTClient(ctx context.Context, opts ...option.ClientOption) (*Client, error)

Sep 15, 2022

Changes in this version

type CallOptions

+ CancelOperation []gax.CallOption

+ DeleteTransferJob []gax.CallOption

+ GetOperation []gax.CallOption

+ ListOperations []gax.CallOption

type Client

+ func (c *Client) CancelOperation(ctx context.Context, req *longrunningpb.CancelOperationRequest, ...) error

+ func (c *Client) DeleteTransferJob(ctx context.Context, req *storagetransferpb.DeleteTransferJobRequest, ...) error

+ func (c *Client) GetOperation(ctx context.Context, req *longrunningpb.GetOperationRequest, ...) (*longrunningpb.Operation, error)

+ func (c *Client) ListOperations(ctx context.Context, req *longrunningpb.ListOperationsRequest, ...) *OperationIterator

+ type OperationIterator struct

+ InternalFetch func(pageSize int, pageToken string) (results []*longrunningpb.Operation, nextPageToken string, err error)

+ Response interface{}

+ func (it *OperationIterator) Next() (*longrunningpb.Operation, error)

+ func (it *OperationIterator) PageInfo() *iterator.PageInfo

Apr 6, 2022

Changes in this version

+ type AgentPoolIterator struct

+ InternalFetch func(pageSize int, pageToken string) (results []*storagetransferpb.AgentPool, nextPageToken string, err error)

+ Response interface{}

+ func (it *AgentPoolIterator) Next() (*storagetransferpb.AgentPool, error)

+ func (it *AgentPoolIterator) PageInfo() *iterator.PageInfo

type CallOptions

+ CreateAgentPool []gax.CallOption

+ DeleteAgentPool []gax.CallOption

+ GetAgentPool []gax.CallOption

+ ListAgentPools []gax.CallOption

+ UpdateAgentPool []gax.CallOption

type Client

+ func (c *Client) CreateAgentPool(ctx context.Context, req *storagetransferpb.CreateAgentPoolRequest, ...) (*storagetransferpb.AgentPool, error)

+ func (c *Client) DeleteAgentPool(ctx context.Context, req *storagetransferpb.DeleteAgentPoolRequest, ...) error

+ func (c *Client) GetAgentPool(ctx context.Context, req *storagetransferpb.GetAgentPoolRequest, ...) (*storagetransferpb.AgentPool, error)

+ func (c *Client) ListAgentPools(ctx context.Context, req *storagetransferpb.ListAgentPoolsRequest, ...) *AgentPoolIterator

+ func (c *Client) UpdateAgentPool(ctx context.Context, req *storagetransferpb.UpdateAgentPoolRequest, ...) (*storagetransferpb.AgentPool, error)

Aug 11, 2021

Changes in this version

+ func DefaultAuthScopes() []string

+ type CallOptions struct

+ CreateTransferJob []gax.CallOption

+ GetGoogleServiceAccount []gax.CallOption

+ GetTransferJob []gax.CallOption

+ ListTransferJobs []gax.CallOption

+ PauseTransferOperation []gax.CallOption

+ ResumeTransferOperation []gax.CallOption

+ RunTransferJob []gax.CallOption

+ UpdateTransferJob []gax.CallOption

+ type Client struct

+ CallOptions *CallOptions

+ LROClient *lroauto.OperationsClient

+ func NewClient(ctx context.Context, opts ...option.ClientOption) (*Client, error)

+ func (c *Client) Close() error

+ func (c *Client) Connection() *grpc.ClientConn

+ func (c *Client) CreateTransferJob(ctx context.Context, req *storagetransferpb.CreateTransferJobRequest, ...) (*storagetransferpb.TransferJob, error)

+ func (c *Client) GetGoogleServiceAccount(ctx context.Context, req *storagetransferpb.GetGoogleServiceAccountRequest, ...) (*storagetransferpb.GoogleServiceAccount, error)

+ func (c *Client) GetTransferJob(ctx context.Context, req *storagetransferpb.GetTransferJobRequest, ...) (*storagetransferpb.TransferJob, error)

+ func (c *Client) ListTransferJobs(ctx context.Context, req *storagetransferpb.ListTransferJobsRequest, ...) *TransferJobIterator

+ func (c *Client) PauseTransferOperation(ctx context.Context, req *storagetransferpb.PauseTransferOperationRequest, ...) error

+ func (c *Client) ResumeTransferOperation(ctx context.Context, req *storagetransferpb.ResumeTransferOperationRequest, ...) error

+ func (c *Client) RunTransferJob(ctx context.Context, req *storagetransferpb.RunTransferJobRequest, ...) (*RunTransferJobOperation, error)

+ func (c *Client) RunTransferJobOperation(name string) *RunTransferJobOperation

+ func (c *Client) UpdateTransferJob(ctx context.Context, req *storagetransferpb.UpdateTransferJobRequest, ...) (*storagetransferpb.TransferJob, error)

+ type RunTransferJobOperation struct

+ func (op *RunTransferJobOperation) Done() bool

+ func (op *RunTransferJobOperation) Metadata() (*storagetransferpb.TransferOperation, error)

+ func (op *RunTransferJobOperation) Name() string

+ func (op *RunTransferJobOperation) Poll(ctx context.Context, opts ...gax.CallOption) error

+ func (op *RunTransferJobOperation) Wait(ctx context.Context, opts ...gax.CallOption) error

+ type TransferJobIterator struct

+ InternalFetch func(pageSize int, pageToken string) (results []*storagetransferpb.TransferJob, nextPageToken string, err error)

+ Response interface{}

+ func (it *TransferJobIterator) Next() (*storagetransferpb.TransferJob, error)

+ func (it *TransferJobIterator) PageInfo() *iterator.PageInfo