aboutsummaryrefslogtreecommitdiffstats
path: root/src/orchestrator/pkg/module/instantiation.go
diff options
context:
space:
mode:
Diffstat (limited to 'src/orchestrator/pkg/module/instantiation.go')
-rw-r--r--src/orchestrator/pkg/module/instantiation.go21
1 files changed, 21 insertions, 0 deletions
diff --git a/src/orchestrator/pkg/module/instantiation.go b/src/orchestrator/pkg/module/instantiation.go
index 27990cee..76be2a2d 100644
--- a/src/orchestrator/pkg/module/instantiation.go
+++ b/src/orchestrator/pkg/module/instantiation.go
@@ -276,11 +276,32 @@ func (c InstantiationClient) Instantiate(p string, ca string, v string, di strin
// BEGIN: scheduler code
pl, mapOfControllers, err := getPrioritizedControllerList(p, ca, v, di)
+ if err != nil {
+ return err
+ }
log.Info("Priority Based List ", log.Fields{"PlacementControllers::": pl.pPlaCont,
"ActionControllers::": pl.pActCont, "mapOfControllers::": mapOfControllers})
+ err = callGrpcForControllerList(pl.pPlaCont, mapOfControllers, ctxval)
+ if err != nil {
+ return err
+ }
+
+ err = deleteExtraClusters(allApps, context)
+ if err != nil {
+ return err
+ }
+
+ err = callGrpcForControllerList(pl.pActCont, mapOfControllers, ctxval)
+ if err != nil {
+ return err
+ }
+
// END: Scheduler code
+ // BEGIN : Rsync code
+ // END : Rsyc code
+
log.Info(":: Done with instantiation... ::", log.Fields{"CompositeAppName": ca})
return err
}