Method: OpenC3::TargetModel.get_telemetry_counts

Defined in:

lib/openc3/models/target_model.rb

.get_telemetry_counts(target_packets, scope:) ⇒ Object

# File 'lib/openc3/models/target_model.rb', line 1302

def self.get_telemetry_counts(target_packets, scope:)
  result = []
  if $openc3_redis_cluster
    # No pipelining for cluster mode
    # because it requires using the same shard for all keys
    target_packets.each do |target_name, packet_name|
      target_name = target_name.upcase
      packet_name = packet_name.upcase
      result << Store.hget("#{scope}__TELEMETRYCNTS__{#{target_name}}", packet_name)
    end
  else
    result = Store.redis_pool.pipelined do
      target_packets.each do |target_name, packet_name|
        target_name = target_name.upcase
        packet_name = packet_name.upcase
        Store.hget("#{scope}__TELEMETRYCNTS__{#{target_name}}", packet_name)
      end
    end
  end
  counts = []
  result.each do |count|
    if count
      counts << count.to_i
    else
      counts << 0
    end
  end
  return counts
end