migration

Apr 13, 2022

Changes in this version

+ func DefaultAuthScopes() []string

+ type CallOptions struct

+ CreateMigrationWorkflow []gax.CallOption

+ DeleteMigrationWorkflow []gax.CallOption

+ GetMigrationSubtask []gax.CallOption

+ GetMigrationWorkflow []gax.CallOption

+ ListMigrationSubtasks []gax.CallOption

+ ListMigrationWorkflows []gax.CallOption

+ StartMigrationWorkflow []gax.CallOption

+ type Client struct

+ CallOptions *CallOptions

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

+ func (c *Client) Close() error

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

+ func (c *Client) CreateMigrationWorkflow(ctx context.Context, req *migrationpb.CreateMigrationWorkflowRequest, ...) (*migrationpb.MigrationWorkflow, error)

+ func (c *Client) DeleteMigrationWorkflow(ctx context.Context, req *migrationpb.DeleteMigrationWorkflowRequest, ...) error

+ func (c *Client) GetMigrationSubtask(ctx context.Context, req *migrationpb.GetMigrationSubtaskRequest, ...) (*migrationpb.MigrationSubtask, error)

+ func (c *Client) GetMigrationWorkflow(ctx context.Context, req *migrationpb.GetMigrationWorkflowRequest, ...) (*migrationpb.MigrationWorkflow, error)

+ func (c *Client) ListMigrationSubtasks(ctx context.Context, req *migrationpb.ListMigrationSubtasksRequest, ...) *MigrationSubtaskIterator

+ func (c *Client) ListMigrationWorkflows(ctx context.Context, req *migrationpb.ListMigrationWorkflowsRequest, ...) *MigrationWorkflowIterator

+ func (c *Client) StartMigrationWorkflow(ctx context.Context, req *migrationpb.StartMigrationWorkflowRequest, ...) error

+ type MigrationSubtaskIterator struct

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

+ Response interface{}

+ func (it *MigrationSubtaskIterator) Next() (*migrationpb.MigrationSubtask, error)

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

+ type MigrationWorkflowIterator struct

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

+ Response interface{}

+ func (it *MigrationWorkflowIterator) Next() (*migrationpb.MigrationWorkflow, error)

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