hive peer suggester, saturation tracker

pkg/hive/hive.go

@@ -22,6 +22,8 @@ const (
 type Service struct {
 	streamer          p2p.Streamer
 	logger            logging.Logger
+	peerSuggester     PeerSuggester
+	saturationTracker SaturationTracker
 
 	tickInterval time.Duration
 	done         chan struct{}
@@ -31,6 +33,8 @@ type Service struct {
 type Options struct {
 	Streamer          p2p.Streamer
 	Logger            logging.Logger
+	PeerSuggester     PeerSuggester
+	SaturationTracker SaturationTracker
 	TickInterval      time.Duration
 }
 
@@ -49,6 +53,8 @@ func New(o Options) *Service {
 		streamer:          o.Streamer,
 		logger:            o.Logger,
 		tickInterval:      o.TickInterval,
+		peerSuggester:     o.PeerSuggester,
+		saturationTracker: o.SaturationTracker,
 		done:              make(chan struct{}),
 	}
 }