coordinator

Documentation

Index

• Variables
• type BatchRequest
• 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) CreateBatchTransferLeaderProcedure(ctx context.Context, request BatchRequest) (procedure.Procedure, error)
  • func (f *Factory) CreateDropTableProcedure(ctx context.Context, request DropTableRequest) (procedure.Procedure, bool, 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 ShardPicker
  • func NewLeastTableShardPicker() 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 BatchRequest

type BatchRequest struct {
	Batch     []procedure.Procedure
	BatchType procedure.Typ
}

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) CreateBatchTransferLeaderProcedure

func (f *Factory) CreateBatchTransferLeaderProcedure(ctx context.Context, request BatchRequest) (procedure.Procedure, error)

func (*Factory) CreateDropTableProcedure

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

CreateDropTableProcedure creates a procedure to do drop table.

And if no error is thrown, the returned boolean value is used to tell whether the procedure is created. In some cases, e.g. the table doesn't exist, it should not be an error and false will be returned.

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 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 NewLeastTableShardPicker

func NewLeastTableShardPicker() 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
}