main.go

package main

import (
	"os"
	"os/signal"

	"github.com/gluster/glusterd2/commands"
	"github.com/gluster/glusterd2/context"
	"github.com/gluster/glusterd2/etcdmgmt"
	"github.com/gluster/glusterd2/rpc/server"

	log "github.com/Sirupsen/logrus"
)

func main() {
	log.Info("GlusterD starting")

	// Starting etcd daemon upon starting of GlusterD
	etcdCtx, err := etcdmgmt.StartETCD()
	if err != nil {
		log.WithField("Error", err).Fatal("Could not able to start etcd")
	}

	context.Init()
	context.EtcdProcessCtx = etcdCtx

	for _, c := range commands.Commands {
		context.Rest.SetRoutes(c.Routes())
	}

	err = server.StartListener()
	if err != nil {
		log.Fatal("Could not register the listener. Aborting")
	} else {
		log.Debug("Registered RPC listener")
	}

	sigCh := make(chan os.Signal)
	signal.Notify(sigCh)
	go func() {
		for s := range sigCh {
			log.WithField("signal", s).Debug("Signal recieved")
			switch s {
			case os.Interrupt:
				log.WithField("signal", s).Info("Recieved SIGTERM. Stopping GlusterD.")
				context.Rest.Stop()
				log.Info("Termintaing GlusterD.")
				os.Exit(0)

			default:
				continue
			}
		}
	}()

	err = context.Rest.Listen()
	if err != nil {
		log.Fatal("Could not start GlusterD Rest Server. Aborting.")
	}

}