Sha256: bc4ed22aaf94b951d39501ea85c0256442b6ee38de9006bd9e810ed9713667a7

Contents?: true

Size: 1.97 KB

Versions: 3

Compression:

Stored size: 1.97 KB

Contents

module KubeAutoAnalyzer

  #This is somewhat awkward placement.  Deployment mechanism sits more with the agent checks
  #But from a "what it's looking for" perspective, its more with the vuln. checks as there's not a CIS check for it.
  def self.check_amicontained
    require 'json'
    @log.debug("Doing Am I contained check")
    target = @options.target_server
    @results[target]['vulns']['amicontained'] = Hash.new

    nodes = Array.new
    @client.get_nodes.each do |node|
      nodes << node
    end
    
    nodes.each do |nod|
      node_hostname = nod.metadata.labels['kubernetes.io/hostname']
      node_ip = nod['status']['addresses'][0]['address']
      container_name = "kaa" + node_hostname
      pod = Kubeclient::Resource.new
      pod.metadata = {}
      pod.metadata.name = container_name
      pod.metadata.namespace = "default"
      pod.spec = {}
      pod.spec.restartPolicy = "Never"
      pod.spec.containers = {}
      pod.spec.containers = [{name: "kubeautoanalyzerkubelettest", image: "raesene/kaa-agent:latest"}]
      pod.spec.containers[0].args = ["/amicontained.rb"]

      #Try the Toleration for Master
      pod.spec.tolerations = {}
      pod.spec.tolerations = [{ key:"key", operator:"Equal", value:"value",effect:"NoSchedule"}]
      
      pod.spec.nodeselector = {}
      pod.spec.nodeselector['kubernetes.io/hostname'] = node_hostname
      begin
        @log.debug("About to start amicontained pod")
        @client.create_pod(pod)
        @log.debug("Executed the create pod")
        begin
          sleep(5) until @client.get_pod(container_name,"default")['status']['containerStatuses'][0]['state']['terminated']['reason'] == "Completed"
        rescue
          retry
        end
        @log.debug ("started amicontained pod")
        results = JSON.parse(@client.get_pod_log(container_name,"default"))
        @results[target]['vulns']['amicontained'][node_ip] = results
      ensure
        @client.delete_pod(container_name,"default")
      end
    end
  end
end

Version data entries

3 entries across 3 versions & 1 rubygems

Version Path
kube_auto_analyzer-0.0.9 lib/kube_auto_analyzer/vuln_checks/amicontained.rb
kube_auto_analyzer-0.0.8 lib/kube_auto_analyzer/vuln_checks/amicontained.rb
kube_auto_analyzer-0.0.7 lib/kube_auto_analyzer/vuln_checks/amicontained.rb