Add logs and interrupt handler. Persister should call when finished.

services/eventdb/main/main.go

@@ -2,6 +2,10 @@ package main
 
 import (
 	"flag"
+	"fmt"
+	"os"
+	"os/signal"
+	"syscall"
 
 	"github.com/m3db/m3cluster/shard"
 	m3config "github.com/m3db/m3x/config"
@@ -23,12 +27,14 @@ func main() {
 	// Parse command line args.
 	flag.Parse()
 
+	logger.Info("loading config...")
 	var cfg config.Config
 	if err := m3config.LoadFile(&cfg, configFilePath); err != nil {
 		logger.Fatalf("logstore load config error: %v", err)
 	}
 
 	// Instantiate DB.
+	logger.Info("instantiating database...")
 	shardIDs := make([]uint32, 0, cfg.Database.NumShards)
 	for i := 0; i < cfg.Database.NumShards; i++ {
 		shardIDs = append(shardIDs, uint32(i))
@@ -46,14 +52,22 @@ func main() {
 	defer db.Close()
 
 	// Instantiate service and run server.
+	logger.Info("instantiating and running server...")
 	svc := handlers.NewService(db, nil)
 	server := http.NewServer(cfg.Server.Address, svc, cfg.Server.NewServerOptions())
 	if err := server.ListenAndServe(); err != nil {
 		logger.Fatalf("error serving: %v", err)
 	}
 	defer server.Close()
+	logger.Infof("server is running @ %s", cfg.Server.Address)
 
-	select {}
+	logger.Warnf("interrupt: %v", interrupt())
+}
+
+func interrupt() error {
+	c := make(chan os.Signal, 1)
+	signal.Notify(c, syscall.SIGINT, syscall.SIGTERM)
+	return fmt.Errorf("%s", <-c)
 }
 
 func init() {

storage/flush.go

@@ -66,6 +66,7 @@ func (m *flushManager) Flush() error {
 	if err != nil {
 		return err
 	}
+	defer persister.Done()
 
 	namespaces, err := m.database.GetOwnedNamespaces()
 	if err != nil {