feature: implement an empty scheduler and update the interface

Signed-off-by: Starnop <starnop@163.com>

supernode/daemon/mgr/scheduler/manager.go

@@ -0,0 +1,26 @@
+package scheduler
+
+import (
+	"context"
+
+	"github.com/dragonflyoss/Dragonfly/supernode/daemon/mgr"
+)
+
+var _ mgr.SchedulerMgr = &Manager{}
+
+// Manager is an implement of the interface of SchedulerMgr.
+type Manager struct {
+	progressMgr mgr.ProgressMgr
+}
+
+// NewManager returns a new Manager.
+func NewManager(progressMgr mgr.ProgressMgr) *Manager {
+	return &Manager{
+		progressMgr: progressMgr,
+	}
+}
+
+// Schedule gets scheduler result with specified taskID, clientID and peerID through some rules.
+func (sm *Manager) Schedule(ctx context.Context, taskID, clientID, peerID string) ([]*mgr.PieceResult, error) {
+	return nil, nil
+}

supernode/daemon/mgr/scheduler_mgr.go

@@ -2,12 +2,18 @@ package mgr
 
 import (
 	"context"
-
-	"github.com/dragonflyoss/Dragonfly/apis/types"
 )
 
+// PieceResult contains the information about which piece to download from which node.
+type PieceResult struct {
+	TaskID    string
+	PieceNum  int
+	PieceSize int32
+	DstPID    string
+}
+
 // SchedulerMgr is responsible for calculating scheduling results according to certain rules.
 type SchedulerMgr interface {
-	// Schedule get scheduler result with specified taskID, clientID through some rules.
-	Schedule(ctx context.Context, taskID, clientID string) ([]*types.PieceInfo, error)
+	// Schedule gets scheduler result with specified taskID, clientID and peerID through some rules.
+	Schedule(ctx context.Context, taskID, clientID, peerID string) ([]*PieceResult, error)
 }