meta

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

type MetadataManager interface {
	GetStore(addr string) (*store.Store, error)
	AddStore(addr string) error
	RemoveStore(addr string) error
	GetAllStores() []*store.Store
}

type NodeStatus struct {
	ID            string
	Address       string
	Alive         bool
	LastHeartbeat time.Time
	Capacity      int
	Availability  bool
}

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

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

type SchedulerConfig struct {
	MaxLoad              int
	MinLoad              int
	ReplicationFactor    int
	DataShardingStrategy string
	PriorityStrategy     string
	SchedulingAlgorithm  string
}

type SchedulingStrategy interface {
	SelectNode(nodes []*NodeStatus, key []byte) (*NodeStatus, error)
}