in pkg/mesh/members_finalizer.go [45:73]
func (m *pendingMembersFinalizer) Finalize(ctx context.Context, ms *appmesh.Mesh) error {
vsMembers, err := m.findVirtualServiceMembers(ctx, ms)
if err != nil {
return err
}
vrMembers, err := m.findVirtualRouterMembers(ctx, ms)
if err != nil {
return err
}
vnMembers, err := m.findVirtualNodeMembers(ctx, ms)
if err != nil {
return err
}
vgMembers, err := m.findVirtualGatewayMembers(ctx, ms)
if err != nil {
return err
}
grMembers, err := m.findGatewayRouteMembers(ctx, ms)
if err != nil {
return err
}
if len(vsMembers) == 0 && len(vrMembers) == 0 && len(vnMembers) == 0 && len(vgMembers) == 0 && len(grMembers) == 0 {
return nil
}
message := m.buildPendingMembersEventMessage(ctx, vsMembers, vrMembers, vnMembers, vgMembers, grMembers)
m.eventRecorder.Eventf(ms, corev1.EventTypeWarning, "PendingMembersDeletion", message)
return runtime.NewRequeueAfterError(errors.New("pending members deletion"), m.evaluateInterval)
}