diff --git a/cmd/podsync/main.go b/cmd/podsync/main.go index 333d5a6..acb2e76 100644 --- a/cmd/podsync/main.go +++ b/cmd/podsync/main.go @@ -155,6 +155,10 @@ func main() { return } + // Queue of feeds to update + updates := make(chan *feed.Config, 16) + defer close(updates) + group, ctx := errgroup.WithContext(ctx) defer func() { if err := group.Wait(); err != nil && (err != context.Canceled && err != http.ErrServerClosed) { @@ -163,10 +167,6 @@ func main() { log.Info("gracefully stopped") }() - // Queue of feeds to update - updates := make(chan *feed.Config, 16) - defer close(updates) - // Create Cron c := cron.New(cron.WithChain(cron.SkipIfStillRunning(cron.DiscardLogger))) m := make(map[string]cron.EntryID) diff --git a/pkg/fs/local.go b/pkg/fs/local.go index 687ba54..8fef710 100644 --- a/pkg/fs/local.go +++ b/pkg/fs/local.go @@ -13,7 +13,7 @@ import ( // LocalConfig is the storage configuration for local file system type LocalConfig struct { - DataDir string `yaml:"data_dir"` + DataDir string `toml:"data_dir"` } // Local implements local file storage