coordinator

Documentation

Index

• Variables
• type ConsistentHashNodePicker
  • func (p *ConsistentHashNodePicker) PickNode(_ context.Context, shardID storage.ShardID, ...) (metadata.RegisteredNode, error)
• 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) 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 NodePicker
  • func NewConsistentHashNodePicker(logger *zap.Logger, hashReplicas int) NodePicker
• type RandomBalancedShardPicker
  • func (p *RandomBalancedShardPicker) PickShards(_ context.Context, snapshot metadata.Snapshot, expectShardNum int) ([]storage.ShardNode, error)
• type ShardPicker
  • func NewRandomBalancedShardPicker() ShardPicker
• type SplitRequest
• type TransferLeaderRequest

Variables

var (
	ErrNodeNumberNotEnough = coderr.NewCodeError(coderr.Internal, "node number not enough")
	ErrPickNode            = coderr.NewCodeError(coderr.Internal, "no node is picked")
)

Types

type ConsistentHashNodePicker

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

func (*ConsistentHashNodePicker) PickNode

func (p *ConsistentHashNodePicker) PickNode(_ context.Context, shardID storage.ShardID, registerNodes []metadata.RegisteredNode) (metadata.RegisteredNode, error)

type CreatePartitionTableRequest

type CreatePartitionTableRequest struct {
	ClusterMetadata *metadata.ClusterMetadata
	SourceReq       *metaservicepb.CreateTableRequest

	PartitionTableRatioOfNodes float32

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

type CreateTableRequest

type CreateTableRequest struct {
	ClusterMetadata *metadata.ClusterMetadata
	SourceReq       *metaservicepb.CreateTableRequest

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

type DropTableRequest

type DropTableRequest struct {
	ClusterMetadata *metadata.ClusterMetadata
	ClusterSnapshot metadata.Snapshot
	SourceReq       *metaservicepb.DropTableRequest

	OnSucceeded func(metadata.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) *Factory

func (*Factory) CreateDropTableProcedure

func (f *Factory) CreateDropTableProcedure(ctx context.Context, request DropTableRequest) (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 NodePicker

type NodePicker interface {
	PickNode(ctx context.Context, shardID storage.ShardID, registerNodes []metadata.RegisteredNode) (metadata.RegisteredNode, error)
}

func NewConsistentHashNodePicker

func NewConsistentHashNodePicker(logger *zap.Logger, hashReplicas int) NodePicker

type RandomBalancedShardPicker

type RandomBalancedShardPicker struct{}

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

func (*RandomBalancedShardPicker) PickShards

func (p *RandomBalancedShardPicker) PickShards(_ context.Context, snapshot metadata.Snapshot, expectShardNum int) ([]storage.ShardNode, error)

PickShards will pick a specified number of shards as expectShardNum.

type ShardPicker

type ShardPicker interface {
	PickShards(ctx context.Context, snapshot metadata.Snapshot, expectShardNum int) ([]storage.ShardNode, 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: TODO: Consider refactor this interface, abstracts the parameters of PickShards as PickStrategy.

func NewRandomBalancedShardPicker

func NewRandomBalancedShardPicker() ShardPicker

type SplitRequest

type SplitRequest struct {
	ClusterMetadata *metadata.ClusterMetadata
	SchemaName      string
	TableNames      []string
	Snapshot        metadata.Snapshot
	ShardID         storage.ShardID
	NewShardID      storage.ShardID
	TargetNodeName  string
}

type TransferLeaderRequest

type TransferLeaderRequest struct {
	Snapshot          metadata.Snapshot
	ShardID           storage.ShardID
	OldLeaderNodeName string
	NewLeaderNodeName string
}