coordinator

Documentation

Index

• type CreatePartitionTableRequest
• type CreateTableRequest
• type DropTableRequest
  • func (d DropTableRequest) IsPartitionTable() bool
• type Factory
  • func NewFactory(allocator id.Allocator, dispatch eventdispatch.Dispatch, ...) *Factory
  • func (f *Factory) CreateDropTableProcedure(ctx context.Context, request DropTableRequest) (procedure.Procedure, error)
  • func (f *Factory) CreateScatterProcedure(ctx context.Context, request ScatterRequest) (procedure.Procedure, error)
  • func (f *Factory) CreateSplitProcedure(ctx context.Context, request SplitRequest) (procedure.Procedure, error)
  • func (f *Factory) CreateTransferLeaderProcedure(ctx context.Context, request TransferLeaderRequest) (procedure.Procedure, error)
  • func (f *Factory) MakeCreateTableProcedure(ctx context.Context, request CreateTableRequest) (procedure.Procedure, error)
• type RandomBalancedShardPicker
  • func (p *RandomBalancedShardPicker) PickShards(ctx context.Context, clusterName string, expectShardNum int, ...) ([]cluster.ShardNodeWithVersion, error)
• type ScatterRequest
• type Scheduler
  • func NewScheduler(clusterManager cluster.Manager, procedureManager procedure.Manager, ...) *Scheduler
  • func (s *Scheduler) ProcessHeartbeat(_ context.Context, _ *metaservicepb.NodeInfo)
  • func (s *Scheduler) Start(ctx context.Context) error
  • func (s *Scheduler) Stop(_ context.Context) error
• type ShardPicker
  • func NewRandomBalancedShardPicker(manager cluster.Manager) ShardPicker
• type SplitRequest
• type TransferLeaderRequest

Types

type CreatePartitionTableRequest

type CreatePartitionTableRequest struct {
	Cluster   *cluster.Cluster
	SourceReq *metaservicepb.CreateTableRequest

	PartitionTableRatioOfNodes float32

	OnSucceeded func(cluster.CreateTableResult) error
	OnFailed    func(error) error
}

type CreateTableRequest

type CreateTableRequest struct {
	Cluster   *cluster.Cluster
	SourceReq *metaservicepb.CreateTableRequest

	OnSucceeded func(cluster.CreateTableResult) error
	OnFailed    func(error) error
}

type DropTableRequest

type DropTableRequest struct {
	Cluster   *cluster.Cluster
	SourceReq *metaservicepb.DropTableRequest

	OnSucceeded func(cluster.TableInfo) error
	OnFailed    func(error) error
}

func (DropTableRequest) IsPartitionTable

func (d DropTableRequest) IsPartitionTable() bool

type Factory

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

func NewFactory

func NewFactory(allocator id.Allocator, dispatch eventdispatch.Dispatch, storage procedure.Storage, manager cluster.Manager, partitionTableProportionOfNodes float32) *Factory

func (*Factory) CreateDropTableProcedure

func (f *Factory) CreateDropTableProcedure(ctx context.Context, request DropTableRequest) (procedure.Procedure, error)

func (*Factory) CreateScatterProcedure

func (f *Factory) CreateScatterProcedure(ctx context.Context, request ScatterRequest) (procedure.Procedure, error)

func (*Factory) CreateSplitProcedure

func (f *Factory) CreateSplitProcedure(ctx context.Context, request SplitRequest) (procedure.Procedure, error)

func (*Factory) CreateTransferLeaderProcedure

func (f *Factory) CreateTransferLeaderProcedure(ctx context.Context, request TransferLeaderRequest) (procedure.Procedure, error)

func (*Factory) MakeCreateTableProcedure

func (f *Factory) MakeCreateTableProcedure(ctx context.Context, request CreateTableRequest) (procedure.Procedure, error)

type RandomBalancedShardPicker

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

RandomBalancedShardPicker randomly pick up shards that are not on the same node in the current cluster.

func (*RandomBalancedShardPicker) PickShards

func (p *RandomBalancedShardPicker) PickShards(ctx context.Context, clusterName string, expectShardNum int, enableDuplicateNode bool) ([]cluster.ShardNodeWithVersion, error)

PickShards will pick a specified number of shards as expectShardNum.

type ScatterRequest

type ScatterRequest struct {
	Cluster  *cluster.Cluster
	ShardIDs []storage.ShardID
}

type Scheduler

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

func NewScheduler

func NewScheduler(clusterManager cluster.Manager, procedureManager procedure.Manager, procedureFactory *Factory, dispatch eventdispatch.Dispatch) *Scheduler

func (*Scheduler) ProcessHeartbeat

func (s *Scheduler) ProcessHeartbeat(_ context.Context, _ *metaservicepb.NodeInfo)

func (*Scheduler) Start

func (s *Scheduler) Start(ctx context.Context) error

func (*Scheduler) Stop

func (s *Scheduler) Stop(_ context.Context) error

type ShardPicker

type ShardPicker interface {
	PickShards(ctx context.Context, clusterName string, expectShardNum int, enableDuplicateNode bool) ([]cluster.ShardNodeWithVersion, error)
}

ShardPicker is used to pick up the shards suitable for scheduling in the cluster. If expectShardNum bigger than cluster node number, the result depends on enableDuplicateNode: If enableDuplicateNode is false, pick shards will be failed and return error. If enableDuplicateNode is true, pick shard will return shards on the same node. TODO: Consider refactor this interface, abstracts the parameters of PickShards as PickStrategy.

func NewRandomBalancedShardPicker

func NewRandomBalancedShardPicker(manager cluster.Manager) ShardPicker

type SplitRequest

type SplitRequest struct {
	ClusterName    string
	SchemaName     string
	TableNames     []string
	ShardID        storage.ShardID
	NewShardID     storage.ShardID
	TargetNodeName string
	ClusterVersion uint64
}

type TransferLeaderRequest

type TransferLeaderRequest struct {
	ClusterName       string
	ShardID           storage.ShardID
	OldLeaderNodeName string
	NewLeaderNodeName string
	ClusterVersion    uint64
}