if dev_obj.Status.DelegatedHub == hub_obj.Metadata.Name {
dev_obj.Status.DelegatedHub = ""
+ dev_manager.UpdateObject(m, dev_obj)
+
for i, item := range hub_obj.Status.DelegateDevices {
if item == dev_obj.Metadata.Name {
hub_obj.Status.DelegateDevices = append(hub_obj.Status.DelegateDevices[:i], hub_obj.Status.DelegateDevices[i+1:]...)
break
}
}
+ hub_manager.UpdateObject(m, hub_obj)
}
conn, err := conn_manager.GetObject(overlay_name,
\r
"github.com/akraino-edge-stack/icn-sdwan/central-controller/src/scc/pkg/module"\r
"github.com/open-ness/EMCO/src/orchestrator/pkg/infra/db"\r
+ pkgerrors "github.com/pkg/errors"\r
)\r
\r
type ResourceObjectKey struct {\r
}\r
\r
func (c *ResourceObjectManager) GetStoreKey(m map[string]string, t module.ControllerObject, isCollection bool) (db.Key, error) {\r
+ // Currently no collections fetching supported\r
return ResourceObjectKey{\r
Cluster: m[OverlayResource] + "-" + m[DeviceResource],\r
Type: m["Type"],\r
}\r
\r
func (c *ResourceObjectManager) GetObjects(m map[string]string) ([]module.ControllerObject, error) {\r
- // DB Operation\r
- t, err := GetDBUtils().GetObjects(c, m)\r
- return t, err\r
+ return []module.ControllerObject{}, pkgerrors.New("Not implemented")\r
}\r
\r
func (c *ResourceObjectManager) UpdateObject(m map[string]string, t module.ControllerObject) (module.ControllerObject, error) {\r
resource.Status = 2
errMessage = errMessage + " " + resource.Resource.GetName()
} else {
- // reset rewource status
+ // reset resource status
resource.Status = 1
resobj.Specification.Ref = 0
res_manager.DeleteObject(m)