External Logging link for container nodes

app/models/container_node.rb

@@ -4,6 +4,9 @@ class ContainerNode < ApplicationRecord
   include MiqPolicyMixin
   include NewWithTypeStiMixin
   include TenantIdentityMixin
+  include SupportsFeatureMixin
+
+  EXTERNAL_LOGGING_PATH = "/#/discover?_g=()&_a=(columns:!(hostname,level,kubernetes.pod_name,message),filters:!((meta:(disabled:!f,index:'%{index}',key:hostname,negate:!f),%{query})),index:'%{index}',interval:auto,query:(query_string:(analyze_wildcard:!t,query:'*')),sort:!(time,desc))".freeze
 
   # :name, :uid, :creation_timestamp, :resource_version
   belongs_to :ext_management_system, :foreign_key => "ems_id"
@@ -72,17 +75,36 @@ def perf_rollup_parents(interval_name = nil)
     [ext_management_system] unless interval_name == 'realtime'
   end
 
-  def ipaddress
+  def kubernetes_hostname
     labels.find_by(:name => "kubernetes.io/hostname").try(:value)
   end
 
   def cockpit_url
-    URI::HTTP.build(:host => ipaddress, :port => 9090)
+    URI::HTTP.build(:host => kubernetes_hostname, :port => 9090)
   end
 
   def evaluate_alert(_alert_id, _event)
     # currently only EmsEvents from hawkular are tested for node alerts,
     # and these should automaticaly be translated to alerts.
     true
   end
+
+  supports :external_logging_support do
+    unless ext_management_system.respond_to?(:external_logging_route_name)
+      unsupported_reason_add(:external_logging_support, _('This provider type does not support External Logging'))
+    end
+  end
+
+  def external_logging_query
+    nil # {}.to_query # TODO
+  end
+
+  def external_logging_path
+    node_hostnames = [kubernetes_hostname || name] # node name cannot be empty, it's an ID
+    node_hostnames.push(node_hostnames.first.split('.').first).compact!
+    node_hostnames_query = node_hostnames.uniq.map { |x| "(term:(hostname:'#{x}'))" }.join(",")
+    query = "bool:(filter:(or:!(#{node_hostnames_query})))"
+    index = ".operations.*"
+    EXTERNAL_LOGGING_PATH % {:index => index, :query => query}
+  end
 end

spec/models/manageiq/providers/kubernetes/container_manager/container_node_spec.rb

@@ -32,4 +32,37 @@
     )
     expect(node.container_images.count).to eq(1)
   end
+
+  describe "#external_logging_path" do
+    def get_query(path)
+      index = ".operations.*"
+      prefix_len = (ContainerNode::EXTERNAL_LOGGING_PATH % {:index => index, :query => 'MARKER'}).index('MARKER')
+      path[prefix_len..(prefix_len + path[prefix_len..-1].index("index:'.operations.*'") - 4)]
+    end
+
+    it "will query for nothing when no name/fqdn is available" do
+      node = FactoryGirl.create(:container_node, :name => "")
+      query = get_query(node.external_logging_path)
+      expect(query).to eq("bool:(filter:(or:!((term:(hostname:'')))))")
+    end
+
+    it "queries both fqdn and hostname when both are avaialble only from kubernetes lables" do
+      node = FactoryGirl.create(:container_node, :name => "other_name")
+      node.labels.create(:name => "kubernetes.io/hostname", :value => "hello.world.com")
+      query = get_query(node.external_logging_path)
+      expect(query).to eq("bool:(filter:(or:!((term:(hostname:'hello.world.com')),(term:(hostname:'hello')))))")
+    end
+
+    it "queries both fqdn and hostname when both are avaialble" do
+      node = FactoryGirl.create(:container_node, :name => "hello.world.com")
+      query = get_query(node.external_logging_path)
+      expect(query).to eq("bool:(filter:(or:!((term:(hostname:'hello.world.com')),(term:(hostname:'hello')))))")
+    end
+
+    it "queries only for the name/fqdn when hostname can't be parsed" do
+      node = FactoryGirl.create(:container_node, :name => "hello")
+      query = get_query(node.external_logging_path)
+      expect(query).to eq("bool:(filter:(or:!((term:(hostname:'hello')))))")
+    end
+  end
 end