in pkg/cloudmap/resource_manager.go [140:172]
func (m *defaultResourceManager) Cleanup(ctx context.Context, vn *appmesh.VirtualNode) error {
ms, err := m.findMeshDependency(ctx, vn)
if err != nil {
return err
}
cloudMapConfig := vn.Spec.ServiceDiscovery.AWSCloudMap
nsSummary, err := m.findCloudMapNamespace(ctx, cloudMapConfig.NamespaceName)
if err != nil {
if !m.isCloudMapServiceCreated(ctx, vn) {
return nil
}
return err
}
if nsSummary == nil {
return nil
}
svcSummary, err := m.findCloudMapService(ctx, nsSummary, cloudMapConfig.ServiceName)
if err != nil {
return err
}
if svcSummary == nil {
return nil
}
if err := m.instancesReconciler.Reconcile(ctx, ms, vn, *svcSummary, nil, nil, nil); err != nil {
return err
}
if err := m.deleteCloudMapService(ctx, vn, nsSummary, svcSummary); err != nil {
return err
}
return nil
}