diff --git a/engine/graph/engine.go b/engine/graph/engine.go index 8bfd87e1..91b29992 100644 --- a/engine/graph/engine.go +++ b/engine/graph/engine.go @@ -45,15 +45,15 @@ type Engine struct { Program string Version string Hostname string - World engine.World + + Converger *converger.Coordinator + World engine.World // Prefix is a unique directory prefix which can be used. It should be // created if needed. - Prefix string - Converger *converger.Coordinator - - Debug bool - Logf func(format string, v ...interface{}) + Prefix string + Debug bool + Logf func(format string, v ...interface{}) graph *pgraph.Graph nextGraph *pgraph.Graph @@ -223,9 +223,9 @@ func (obj *Engine) Commit() error { Version: obj.Version, Hostname: obj.Hostname, + //Converger: obj.Converger, World: obj.World, Prefix: statePrefix, - //Converger: obj.Converger, Debug: obj.Debug, Logf: func(format string, v ...interface{}) { diff --git a/engine/graph/state.go b/engine/graph/state.go index a8b73588..cd23c67e 100644 --- a/engine/graph/state.go +++ b/engine/graph/state.go @@ -43,14 +43,15 @@ type State struct { Program string Version string Hostname string - World engine.World + + //Converger *converger.Coordinator + + World engine.World // Prefix is a unique directory prefix which can be used. It should be // created if needed. Prefix string - //Converger *converger.Coordinator - // Debug turns on additional output and behaviours. Debug bool diff --git a/lang/interfaces/func.go b/lang/interfaces/func.go index 62acda0a..63b3662f 100644 --- a/lang/interfaces/func.go +++ b/lang/interfaces/func.go @@ -62,6 +62,7 @@ type Init struct { // TODO: should we pass in a *Scope here for functions like template() ? World engine.World + Debug bool Logf func(format string, v ...interface{}) } diff --git a/lang/interpret_test.go b/lang/interpret_test.go index 107916b0..020faad7 100644 --- a/lang/interpret_test.go +++ b/lang/interpret_test.go @@ -2001,9 +2001,9 @@ func TestAstFunc3(t *testing.T) { Program: "testing", // TODO: name it mgmt? //Version: obj.Version, Hostname: "localhost", + Converger: converger, World: world, Prefix: fmt.Sprintf("%s/", filepath.Join(tmpdir, "engine")), - Converger: converger, Debug: testing.Verbose(), Logf: func(format string, v ...interface{}) { logf("engine: "+format, v...) diff --git a/lib/main.go b/lib/main.go index 5bc51d43..6bb39f44 100644 --- a/lib/main.go +++ b/lib/main.go @@ -492,9 +492,9 @@ func (obj *Main) Run() error { Program: obj.Program, Version: obj.Version, Hostname: hostname, + Converger: converger, World: world, Prefix: fmt.Sprintf("%s/", path.Join(prefix, "engine")), - Converger: converger, //Prometheus: prom, // TODO: implement this via a general Status API Debug: obj.Flags.Debug, Logf: func(format string, v ...interface{}) {