Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func Register ¶
func Register()
Register registers the HorizontalReshardingWorkflowFactory as a factory in the workflow framework.
func WorkflowPhases ¶
func WorkflowPhases() []string
WorkflowPhases returns phases for resharding workflow
Types ¶
type Factory ¶
type Factory struct{}
Factory is the factory to create a horizontal resharding workflow.
type ReshardingWrangler ¶
type ReshardingWrangler interface {
CopySchemaShardFromShard(ctx context.Context, tables, excludeTables []string, includeViews bool, sourceKeyspace, sourceShard, destKeyspace, destShard string, waitSlaveTimeout time.Duration) error
WaitForFilteredReplication(ctx context.Context, keyspace, shard string, maxDelay time.Duration) error
MigrateServedTypes(ctx context.Context, keyspace, shard string, cells []string, servedType topodatapb.TabletType, reverse, skipReFreshState bool, filteredReplicationWaitTime time.Duration, reverseReplication bool) error
}
ReshardingWrangler is the interface to be used in creating mock interface for wrangler, which is used for unit test. It includes a subset of the methods in go/vt/Wrangler.
Source Files
Click to show internal directories.
Click to hide internal directories.