meta

type MetadataManager interface {
	// GetStore gets a store by address.
	GetStore(addr string) (*store.Store, error)
	// AddStore adds a new store to the cluster.
	AddStore(addr string) error
	// RemoveStore removes a store from the cluster.
	RemoveStore(addr string) error
	// GetAllStores gets all stores in the cluster.
	GetAllStores() []*store.Store
	// GetRegionByID gets a region by id.
	GetRegionByID(id uint64) (*region.Region, error)
	// GetStoreByID gets a store by id.
	GetStoreByID(id uint64) (*store.Store, error)
	// ApplyConfig applies a new config to the cluster.
	ApplyConfig(config *config.Config) error
}

type NodeStatus struct {
	ID            string    // node id
	Address       string    // node address
	Alive         bool      // whether the node is alive
	LastHeartbeat time.Time // last heartbeat time
	Capacity      int       // node capacity
	Availability  bool      // whether the node is available
}

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

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

type SchedulerConfig struct {
	MaxLoad              int    // max load of a node
	MinLoad              int    // min load of a node
	ReplicationFactor    int    // replication factor
	DataShardingStrategy string // data sharding strategy
	PriorityStrategy     string // priority strategy
	SchedulingAlgorithm  string // scheduling algorithm
}

type SchedulingStrategy interface {
	// SelectNode selects num node to schedule the key.
	SelectNode(nodes []*NodeStatus, key []byte, num int) (*NodeStatus, error)
}