procedure

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 ScatterCallbackRequest struct {
	// contains filtered or unexported fields
}

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

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

type State string

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

type Typ uint

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