Versions in this module Expand all Collapse all v0 v0.16.3 Nov 29, 2024 Changes in this version + func AddMissingTaskID(tc []*automationpb.TaskContainer, taskIDGenerator *IDGenerator) + func AddTask(t *automationpb.TaskContainer, taskName string, parameters map[string]string) + func ExecuteVtctl(ctx context.Context, server string, args []string) (string, error) + func ExecuteVtworker(ctx context.Context, server string, args []string) (string, error) + func MarkTaskFailed(t *automationpb.Task, output string, err error) + func MarkTaskSucceeded(t *automationpb.Task, output string) + func NewTask(taskName string, parameters map[string]string) *automationpb.Task + func NewTaskContainer() *automationpb.TaskContainer + func NewTaskContainerWithSingleTask(taskName string, parameters map[string]string) *automationpb.TaskContainer + type ClusterOperationInstance struct + func NewClusterOperationInstance(clusterOpID string, initialTask *automationpb.TaskContainer, ...) ClusterOperationInstance + func (c *ClusterOperationInstance) InsertTaskContainers(newTaskContainers []*automationpb.TaskContainer, pos int) + func (c ClusterOperationInstance) Clone() ClusterOperationInstance + type CopySchemaShardTask struct + func (t *CopySchemaShardTask) OptionalParameters() []string + func (t *CopySchemaShardTask) RequiredParameters() []string + func (t *CopySchemaShardTask) Run(parameters map[string]string) ([]*automationpb.TaskContainer, string, error) + type HorizontalReshardingTask struct + func (t *HorizontalReshardingTask) OptionalParameters() []string + func (t *HorizontalReshardingTask) RequiredParameters() []string + func (t *HorizontalReshardingTask) Run(parameters map[string]string) ([]*automationpb.TaskContainer, string, error) + type IDGenerator struct + func (ig *IDGenerator) GetNextID() string + type MigrateServedFromTask struct + func (t *MigrateServedFromTask) OptionalParameters() []string + func (t *MigrateServedFromTask) RequiredParameters() []string + func (t *MigrateServedFromTask) Run(parameters map[string]string) ([]*automationpb.TaskContainer, string, error) + type MigrateServedTypesTask struct + func (t *MigrateServedTypesTask) OptionalParameters() []string + func (t *MigrateServedTypesTask) RequiredParameters() []string + func (t *MigrateServedTypesTask) Run(parameters map[string]string) ([]*automationpb.TaskContainer, string, error) + type RebuildKeyspaceGraphTask struct + func (t *RebuildKeyspaceGraphTask) OptionalParameters() []string + func (t *RebuildKeyspaceGraphTask) RequiredParameters() []string + func (t *RebuildKeyspaceGraphTask) Run(parameters map[string]string) ([]*automationpb.TaskContainer, string, error) + type Scheduler struct + func NewScheduler() (*Scheduler, error) + func (s *Scheduler) Checkpoint(clusterOp ClusterOperationInstance) + func (s *Scheduler) EnqueueClusterOperation(ctx context.Context, req *automationpb.EnqueueClusterOperationRequest) (*automationpb.EnqueueClusterOperationResponse, error) + func (s *Scheduler) GetClusterOperationDetails(ctx context.Context, req *automationpb.GetClusterOperationDetailsRequest) (*automationpb.GetClusterOperationDetailsResponse, error) + func (s *Scheduler) Run() + func (s *Scheduler) ShutdownAndWait() + type SplitCloneTask struct + func (t *SplitCloneTask) OptionalParameters() []string + func (t *SplitCloneTask) RequiredParameters() []string + func (t *SplitCloneTask) Run(parameters map[string]string) ([]*automationpb.TaskContainer, string, error) + type SplitDiffTask struct + func (t *SplitDiffTask) OptionalParameters() []string + func (t *SplitDiffTask) RequiredParameters() []string + func (t *SplitDiffTask) Run(parameters map[string]string) ([]*automationpb.TaskContainer, string, error) + type Task interface + OptionalParameters func() []string + RequiredParameters func() []string + Run func(parameters map[string]string) (newTaskContainers []*automationpb.TaskContainer, output string, err error) + type VerticalSplitCloneTask struct + func (t *VerticalSplitCloneTask) OptionalParameters() []string + func (t *VerticalSplitCloneTask) RequiredParameters() []string + func (t *VerticalSplitCloneTask) Run(parameters map[string]string) ([]*automationpb.TaskContainer, string, error) + type VerticalSplitDiffTask struct + func (t *VerticalSplitDiffTask) OptionalParameters() []string + func (t *VerticalSplitDiffTask) RequiredParameters() []string + func (t *VerticalSplitDiffTask) Run(parameters map[string]string) ([]*automationpb.TaskContainer, string, error) + type VerticalSplitTask struct + func (t *VerticalSplitTask) OptionalParameters() []string + func (t *VerticalSplitTask) RequiredParameters() []string + func (t *VerticalSplitTask) Run(parameters map[string]string) ([]*automationpb.TaskContainer, string, error) + type WaitForFilteredReplicationTask struct + func (t *WaitForFilteredReplicationTask) OptionalParameters() []string + func (t *WaitForFilteredReplicationTask) RequiredParameters() []string + func (t *WaitForFilteredReplicationTask) Run(parameters map[string]string) ([]*automationpb.TaskContainer, string, error)
Go to main page