diff options
author | Frédéric Guillot <fred@miniflux.net> | 2018-11-11 15:32:48 -0800 |
---|---|---|
committer | Frédéric Guillot <fred@miniflux.net> | 2018-11-11 15:32:48 -0800 |
commit | 487852f07eb191ef56967b7b7d7f01537a55eabd (patch) | |
tree | 0c5194c4371392128917a0860ac7a6b00f7784a2 /daemon/daemon.go | |
parent | ca45765c46de3b00c3b22936c885b57c37186e3d (diff) |
Replace daemon and scheduler package with service package
Diffstat (limited to 'daemon/daemon.go')
-rw-r--r-- | daemon/daemon.go | 61 |
1 files changed, 0 insertions, 61 deletions
diff --git a/daemon/daemon.go b/daemon/daemon.go deleted file mode 100644 index a1fbf8e..0000000 --- a/daemon/daemon.go +++ /dev/null @@ -1,61 +0,0 @@ -// Copyright 2018 Frédéric Guillot. All rights reserved. -// Use of this source code is governed by the Apache 2.0 -// license that can be found in the LICENSE file. - -package daemon // import "miniflux.app/daemon" - -import ( - "context" - "os" - "os/signal" - "runtime" - "syscall" - "time" - - "miniflux.app/config" - "miniflux.app/logger" - "miniflux.app/reader/feed" - "miniflux.app/scheduler" - "miniflux.app/storage" -) - -// Run starts the daemon. -func Run(cfg *config.Config, store *storage.Storage) { - logger.Info("Starting Miniflux...") - - stop := make(chan os.Signal, 1) - signal.Notify(stop, os.Interrupt) - signal.Notify(stop, syscall.SIGTERM) - - go func() { - for { - var m runtime.MemStats - runtime.ReadMemStats(&m) - logger.Debug("Sys=%vK, InUse=%vK, HeapInUse=%vK, StackSys=%vK, StackInUse=%vK, GoRoutines=%d, NumCPU=%d", - m.Sys/1024, (m.Sys-m.HeapReleased)/1024, m.HeapInuse/1024, m.StackSys/1024, m.StackInuse/1024, - runtime.NumGoroutine(), runtime.NumCPU()) - time.Sleep(30 * time.Second) - } - }() - - feedHandler := feed.NewFeedHandler(store) - pool := scheduler.NewWorkerPool(feedHandler, cfg.WorkerPoolSize()) - server := newServer(cfg, store, pool, feedHandler) - - scheduler.NewFeedScheduler( - store, - pool, - cfg.PollingFrequency(), - cfg.BatchSize(), - ) - - scheduler.NewCleanupScheduler(store, cfg.CleanupFrequency()) - - <-stop - logger.Info("Shutting down the server...") - ctx, cancel := context.WithTimeout(context.Background(), 5*time.Second) - defer cancel() - - server.Shutdown(ctx) - logger.Info("Server gracefully stopped") -} |