Module: VolumeSweeper::Comparer

Defined in:
lib/volume_sweeper/comparer.rb

Constant Summary collapse

LIST_SEP = 
"\n     "

Class Method Summary collapse

Class Method Details

.process(block_volumes, persistent_volumes) ⇒ Object

Compare unattached block volumes against kubernetes persistent volumes in order to avoid any block volume that as volumeHandler reference, even if not bound to instance.

Docs:

The algorithm goes as follows: “‘

FOR each_cluster IN oci:
  A] Fetch PVs (name, ocid)
  B] Fetch BLOCK VOL where attachment = nil
  C] Compare A ^ B to Extract Bx NOT IN Ax
     THEN:
    DEL [C] result
End

“‘



25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
 
# File 'lib/volume_sweeper/comparer.rb', line 25

def self.process  block_volumes, persistent_volumes
  unused_volumes = []
  active_volumes = []
  counters = { active: 0, unused: 0 }

  return {} if block_volumes.blank? || persistent_volumes.blank?

  block_volumes.each do |vol|
    if persistent_volumes.any? { |p| p[:volumeHandle]&.strip == vol&.strip  }
      counters[:active] += 1
      active_volumes << vol
    else
      counters[:unused] += 1
      unused_volumes << vol
    end
  end

  seperator = -> (str) { str.join(LIST_SEP).prepend LIST_SEP }

  active_list = active_volumes.any? ? seperator.call(active_volumes) : 'None'
  unused_list = unused_volumes.any? ? seperator.call(unused_volumes) : 'None'

  Utils::Log.instance.msg "=> Found #{counters[:active]} still in use."
  Utils::Log.instance.msg "=> Found #{counters[:unused]} unused and should be terminated."
  Utils::Log.instance.msg "=> Details:"
  Utils::Log.instance.msg "===> Active: ", active_list
  Utils::Log.instance.msg "===> Unused: ", unused_list

  { active_ids: active_volumes, unused_ids: unused_volumes }
end