procedure

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

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

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

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

type CreatePartitionTableRawData struct {
	ID       uint64
	FsmState string
	State    State

	CreateTableResult    cluster.CreateTableResult
	PartitionTableShards []cluster.ShardNodeWithVersion
	DataTablesShards     []cluster.ShardNodeWithVersion
}

type CreatePartitionTableRequest struct {
	ClusterName string
	SourceReq   *metaservicepb.CreateTableRequest

	PartitionTableRatioOfNodes float32

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

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

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

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

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

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

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

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

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

type Info struct {
	ID    uint64
	Typ   Typ
	State State
}

type Manager interface {
	// Start must be called before manager is used.
	Start(ctx context.Context) error
	// Stop must be called before manager is dropped.
	Stop(ctx context.Context) error

	// Submit procedure to be executed asynchronously.
	// TODO: change result type, add channel to get whether the procedure executed successfully
	Submit(ctx context.Context, procedure Procedure) error
	// Cancel procedure that has been submitted.
	Cancel(ctx context.Context, procedureID uint64) error
	ListRunningProcedure(ctx context.Context) ([]*Info, error)
}

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

type Meta struct {
	ID      uint64
	Typ     Typ
	State   State
	RawData []byte
}

type Procedure interface {
	// ID of the procedure.
	ID() uint64

	// Typ of the procedure.
	Typ() Typ

	// Start the procedure.
	Start(ctx context.Context) error

	// Cancel the procedure.
	Cancel(ctx context.Context) error

	// State of the procedure. Retrieve the state of this procedure.
	State() State
}

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

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

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

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

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

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

type SplitProcedurePersistRawData struct {
	SchemaName     string
	TableNames     []string
	ShardID        uint32
	NewShardID     uint32
	TargetNodeName string
}

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

type State string

type Storage interface {
	Write
	List(ctx context.Context, batchSize int) ([]*Meta, error)
	MarkDeleted(ctx context.Context, id uint64) error
}

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

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

type TransferLeaderProcedurePersistRawData struct {
	ID       uint64
	FsmState string
	State    State

	ShardID           storage.ShardID
	OldLeaderNodeName string
	NewLeaderNodeName string
}

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

type Typ uint

type Write interface {
	CreateOrUpdate(ctx context.Context, meta Meta) error
}