add starting delay when proc start

.gitignore

@@ -1,3 +1,6 @@
 /goreman
 /goxz
 *.exe
+.idea
+.git
+.cover

log.go

@@ -20,12 +20,14 @@ type clogger struct {
 }
 
 var colors = []int{
+	//30, // break
+	31, // red
 	32, // green
-	36, // cyan
-	35, // magenta
 	33, // yellow
 	34, // blue
-	31, // red
+	35, // magenta
+	36, // cyan
+	37, // write txt, break ground
 }
 var mutex = new(sync.Mutex)
 

main.go

@@ -98,6 +98,12 @@ var exitOnStop = flag.Bool("exit-on-stop", true, "Exit goreman if all subprocess
 // show timestamp in log
 var logTime = flag.Bool("logtime", true, "show timestamp in log")
 
+// start proc interval (sec)
+var interval = flag.Uint("interval", 0, "show timestamp in log")
+
+// reverse procs sort when stop
+var reverseOnStop = flag.Bool("reverse-on-stop", false, "reverse procs sort when stop")
+
 var maxProcNameLength = 0
 
 var re = regexp.MustCompile(`\$([a-zA-Z]+[a-zA-Z0-9_]+)`)
@@ -180,7 +186,10 @@ func defaultServer(serverPort uint) string {
 	if s, ok := os.LookupEnv("GOREMAN_RPC_SERVER"); ok {
 		return s
 	}
-	return fmt.Sprintf("127.0.0.1:%d", defaultPort())
+	if serverPort == 0 {
+		serverPort = defaultPort()
+	}
+	return fmt.Sprintf("127.0.0.1:%d", serverPort)
 }
 
 func defaultAddr() string {

proc.go

@@ -126,11 +126,23 @@ func restartProc(name string) error {
 // opportunity to stop.
 func stopProcs(sig os.Signal) error {
 	var err error
+	// reverse procs sort when stop
+	if *reverseOnStop {
+		tmp := make([]*procInfo, len(procs))
+		for i := 0; i < len(procs); i++ {
+			tmp[i] = procs[(len(procs)-1)-i]
+		}
+		procs = tmp
+	}
+
 	for _, proc := range procs {
 		stopErr := stopProc(proc.name, sig)
 		if stopErr != nil {
 			err = stopErr
 		}
+		if *interval > 0 {
+			time.Sleep(time.Second * time.Duration(*interval))
+		}
 	}
 	return err
 }
@@ -142,6 +154,11 @@ func startProcs(sc <-chan os.Signal, rpcCh <-chan *rpcMessage, exitOnError bool)
 
 	for _, proc := range procs {
 		startProc(proc.name, &wg, errCh)
+		// sleep N sec. because sometimes, dependencies checking between stateful services (procs)
+		//  will let it starting fail .
+		if *interval > 0 {
+			time.Sleep(time.Second * time.Duration(*interval))
+		}
 	}
 
 	allProcsDone := make(chan struct{}, 1)