Method initProcesses

common/runtime/manager/manager.go:612–790

(ctx context.Context, bootstrap config.Store, base string)

}

func (m *manager) initProcesses(ctx context.Context, bootstrap config.Store, base string) error {
	cmds := make(map[string]*fork.Process)

	var baseWatch []string
	if base != "#" {
		baseWatch = append(baseWatch, strings.Split(strings.TrimLeft(base, "#/"), "/")...)
	}

	w, err := bootstrap.Watch(watch.WithPath(append(baseWatch, "processes", "*")...), watch.WithChangesOnly())
	if err != nil {
		return err
	}

	for {
		diff, err := w.Next()
		if err != nil {
			return err
		}
		baseRead := append(baseWatch, "processes")
		create := diff.(kv.Values).Val(append([]string{"create"}, baseRead...)...)
		update := diff.(kv.Values).Val(append([]string{"update"}, baseRead...)...)
		deletes := diff.(kv.Values).Val(append([]string{"delete"}, baseRead...)...)

		var processesToStart, processesToStop []string

		for name := range create.Map() {
			processesToStart = append(processesToStart, name)
		}
		for name := range update.Map() {
			processesToStop = append(processesToStop, name)
			processesToStart = append(processesToStart, name)
		}
		for name := range deletes.Map() {
			processesToStop = append(processesToStop, name)
		}

		for _, name := range processesToStop {
			if cmd, ok := cmds[name]; ok {
				cmd.Stop()
			}
		}

		processes := bootstrap.Val(base + "/processes")

		for _, name := range processesToStart {
			process := processes.Val(name)

			childBinary := os.Args[0]
			var childArgs []string
			var childEnv []string

			connections := process.Val("connections")
			// TODO
			//binary := process.Val("binary")
			//args := process.Val("args")
			env := process.Val("env")
			servers := process.Val("servers")
			tags := process.Val("tags")