debian-mirror-gitlab/app/finders/projects/serverless/functions_finder.rb

61 lines
1.7 KiB
Ruby
Raw Normal View History

2019-02-15 15:39:39 +05:30
# frozen_string_literal: true
module Projects
module Serverless
class FunctionsFinder
def initialize(clusters)
@clusters = clusters
end
def execute
knative_services.flatten.compact
end
def installed?
clusters_with_knative_installed.exists?
end
2019-03-02 22:35:43 +05:30
def service(environment_scope, name)
knative_service(environment_scope, name)&.first
end
2019-02-15 15:39:39 +05:30
private
2019-03-02 22:35:43 +05:30
def knative_service(environment_scope, name)
clusters_with_knative_installed.preload_knative.map do |cluster|
next if environment_scope != cluster.environment_scope
services = cluster.application_knative.services_for(ns: cluster.platform_kubernetes&.actual_namespace)
.select { |svc| svc["metadata"]["name"] == name }
add_metadata(cluster, services).first unless services.nil?
end
end
2019-02-15 15:39:39 +05:30
def knative_services
clusters_with_knative_installed.preload_knative.map do |cluster|
2019-03-02 22:35:43 +05:30
services = cluster.application_knative.services_for(ns: cluster.platform_kubernetes&.actual_namespace)
add_metadata(cluster, services) unless services.nil?
end
end
def add_metadata(cluster, services)
services.each do |s|
s["environment_scope"] = cluster.environment_scope
s["cluster_id"] = cluster.id
if services.length == 1
s["podcount"] = cluster.application_knative.service_pod_details(
cluster.platform_kubernetes&.actual_namespace,
s["metadata"]["name"]).length
end
2019-02-15 15:39:39 +05:30
end
end
def clusters_with_knative_installed
@clusters.with_knative_installed
end
end
end
end