split

Documentation

Index

• type Procedure
  • func NewProcedure(id uint64, dispatch eventdispatch.Dispatch, storage procedure.Storage, ...) *Procedure
  • func (p *Procedure) Cancel(_ context.Context) error
  • func (p *Procedure) ID() uint64
  • func (p *Procedure) Start(ctx context.Context) error
  • func (p *Procedure) State() procedure.State
  • func (p *Procedure) Typ() procedure.Typ

Types

type Procedure

type Procedure struct {
	// contains filtered or unexported fields
}

Procedure fsm: Update ShardTable Metadata -> OpenNewShard -> CloseTable

func NewProcedure

func NewProcedure(id uint64, dispatch eventdispatch.Dispatch, storage procedure.Storage, c *cluster.Cluster, schemaName string, shardID storage.ShardID, newShardID storage.ShardID, tableNames []string, targetNodeName string) *Procedure

func (*Procedure) Cancel

func (p *Procedure) Cancel(_ context.Context) error

func (*Procedure) ID

func (p *Procedure) ID() uint64

func (*Procedure) Start

func (p *Procedure) Start(ctx context.Context) error

func (*Procedure) State

func (p *Procedure) State() procedure.State

func (*Procedure) Typ

func (p *Procedure) Typ() procedure.Typ