cmd,config: add config

cmd/fsd/main.go

@@ -38,6 +38,10 @@ var (
 			BusAddress:    "http://localhost:9980/api/bus",
 			Bucket:        "ipfs",
 		},
+		BlockStore: config.BlockStore{
+			CacheSize:     10000,
+			MaxConcurrent: 1000,
+		},
 		IPFS: config.IPFS{
 			Gateway: config.HTTPGateway{
 				ListenAddress: ":8080",
@@ -150,11 +154,11 @@ func main() {
 	workerClient := worker.NewClient(cfg.Renterd.WorkerAddress, cfg.Renterd.WorkerPassword)
 	busClient := bus.NewClient(cfg.Renterd.BusAddress, cfg.Renterd.BusPassword)
 
-	bd, err := downloader.NewBlockDownloader(cfg.Renterd.Bucket, 4096, workerClient, log.Named("downloader"))
+	bd, err := downloader.NewBlockDownloader(cfg.Renterd.Bucket, cfg.BlockStore.CacheSize, workerClient, log.Named("downloader"))
 	if err != nil {
 		log.Fatal("failed to create block downloader", zap.Error(err))
 	}
-	bd.StartWorkers(ctx, 1000)
+	bd.StartWorkers(ctx, cfg.BlockStore.MaxConcurrent)
 
 	bs, err := renterd.NewBlockStore(
 		renterd.WithBucket(cfg.Renterd.Bucket),

config/config.go

@@ -15,6 +15,13 @@ type (
 		Bucket         string `yaml:"bucket"`
 	}
 
+	BlockStore struct {
+		// MaxConcurrent is the maximum number of concurrent block fetches.
+		MaxConcurrent int `yaml:"maxConcurrent"`
+		// CacheSize is the maximum number of blocks to cache in memory.
+		CacheSize int `yaml:"cacheSize"`
+	}
+
 	// RemoteFetch contains settings for enabling/disabling remote IPFS block
 	// fetching.
 	RemoteFetch struct {
@@ -61,9 +68,10 @@ type (
 
 	// Config contains the configuration for fsd
 	Config struct {
-		Renterd Renterd `yaml:"renterd"`
-		IPFS    IPFS    `yaml:"ipfs"`
-		API     API     `yaml:"api"`
-		Log     Log     `yaml:"log"`
+		Renterd    Renterd    `yaml:"renterd"`
+		BlockStore BlockStore `yaml:"blockstore"`
+		IPFS       IPFS       `yaml:"ipfs"`
+		API        API        `yaml:"api"`
+		Log        Log        `yaml:"log"`
 	}
 )