101c4480b3
When Kubernetes clusters were originally built they could only exist at the project level, and so there was logic included that assumed there would only ever be a single Kubernetes namespace per cluster. We now support clusters at the group and instance level, which allows multiple namespaces. This change consolidates various project-specific fallbacks to generate namespaces, and hands all responsibility to the Clusters::KubernetesNamespace model. There is now no concept of a single namespace for a Clusters::Platforms::Kubernetes; to retrieve a namespace a project must now be supplied in all cases. This simplifies upcoming work to use a separate Kubernetes namespace per project environment (instead of a namespace per project).
86 lines
2.6 KiB
Ruby
86 lines
2.6 KiB
Ruby
# frozen_string_literal: true
|
|
|
|
module Projects
|
|
module Serverless
|
|
class FunctionsFinder
|
|
attr_reader :project
|
|
|
|
def initialize(project)
|
|
@clusters = project.clusters
|
|
@project = project
|
|
end
|
|
|
|
def execute
|
|
knative_services.flatten.compact
|
|
end
|
|
|
|
def installed?
|
|
clusters_with_knative_installed.exists?
|
|
end
|
|
|
|
def service(environment_scope, name)
|
|
knative_service(environment_scope, name)&.first
|
|
end
|
|
|
|
def invocation_metrics(environment_scope, name)
|
|
return unless prometheus_adapter&.can_query?
|
|
|
|
cluster = clusters_with_knative_installed.preload_knative.find do |c|
|
|
environment_scope == c.environment_scope
|
|
end
|
|
|
|
func = ::Serverless::Function.new(project, name, cluster.kubernetes_namespace_for(project))
|
|
prometheus_adapter.query(:knative_invocation, func)
|
|
end
|
|
|
|
def has_prometheus?(environment_scope)
|
|
clusters_with_knative_installed.preload_knative.to_a.any? do |cluster|
|
|
environment_scope == cluster.environment_scope && cluster.application_prometheus_available?
|
|
end
|
|
end
|
|
|
|
private
|
|
|
|
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.kubernetes_namespace_for(project))
|
|
.select { |svc| svc["metadata"]["name"] == name }
|
|
|
|
add_metadata(cluster, services).first unless services.nil?
|
|
end
|
|
end
|
|
|
|
def knative_services
|
|
clusters_with_knative_installed.preload_knative.map do |cluster|
|
|
services = cluster.application_knative.services_for(ns: cluster.kubernetes_namespace_for(project))
|
|
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.kubernetes_namespace_for(project),
|
|
s["metadata"]["name"]).length
|
|
end
|
|
end
|
|
end
|
|
|
|
def clusters_with_knative_installed
|
|
@clusters.with_knative_installed
|
|
end
|
|
|
|
# rubocop: disable CodeReuse/ServiceClass
|
|
def prometheus_adapter
|
|
@prometheus_adapter ||= ::Prometheus::AdapterService.new(project).prometheus_adapter
|
|
end
|
|
# rubocop: enable CodeReuse/ServiceClass
|
|
end
|
|
end
|
|
end
|