support capacities in stream sync

harmony-one · Oct 29, 2024 · a316f67 · a316f67
1 parent ab1f686
commit a316f67
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/api/service/stagedstreamsync/adapter.go b/api/service/stagedstreamsync/adapter.go
@@ -29,9 +29,10 @@ type syncProtocol interface {
 	RemoveStream(stID sttypes.StreamID) // If a stream delivers invalid data, remove the stream
 	StreamFailed(stID sttypes.StreamID, reason string)
 	SubscribeAddStreamEvent(ch chan<- streammanager.EvtStreamAdded) event.Subscription
+	Streams() []sttypes.Stream
 	NumStreams() int
+	AvailableCapacity() int
 }
-
 type blockChain interface {
 	engine.ChainReader
 	Engine() engine.Engine