86058

pending completion

Build # 86058

Build Type

Pull #21589

travis-ci-com

Committed by

web-flow

Commit Message

<a href="https://github.com/ManageIQ/manageiq/commit/<a class=hub.com/ManageIQ/manageiq/commit/eb776b07c2b7b7a6b480f6770b63159ef47cc859">eb776b07c<a href="https://github.com/ManageIQ/manageiq/commit/eb776b07c2b7b7a6b480f6770b63159ef47cc859">">Merge </a><a class="double-link" href="https://github.com/ManageIQ/manageiq/commit/<a class="double-link" href="https://github.com/ManageIQ/manageiq/commit/01d4f91ee3cf1815fc034ec54df7586062f0e463">01d4f91ee</a>">01d4f91ee</a><a href="https://github.com/ManageIQ/manageiq/commit/eb776b07c2b7b7a6b480f6770b63159ef47cc859"> into fbd6274c7">fbd6274c7</a>

Pull Request Pull Request #21589: Move ovirt_metrics gem declaration out of core

Run Details

13119 of 59365 relevant lines covered (22.1%)

21.38 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

43.33

/lib/container_orchestrator.rb

autoload(:Kubeclient, 'kubeclient')
autoload(:KubeException, 'kubeclient')

class ContainerOrchestrator
  include Vmdb::Logging
  include_concern 'ObjectDefinition'

  TOKEN_FILE   = "/run/secrets/kubernetes.io/serviceaccount/token".freeze
  CA_CERT_FILE = "/run/secrets/kubernetes.io/serviceaccount/ca.crt".freeze

  def self.available?
    File.exist?(TOKEN_FILE) && File.exist?(CA_CERT_FILE)
  end

  def scale(deployment_name, replicas)
    patch_deployment(deployment_name, {:spec => {:replicas => replicas}})
  end

  def patch_deployment(deployment_name, data)
    _log.info("deployment_name: #{deployment_name}, data: #{data.inspect}")
    kube_apps_connection.patch_deployment(deployment_name, data, my_namespace)
  end

  def create_deployment(name)
    definition = deployment_definition(name)
    yield(definition) if block_given?
    kube_apps_connection.create_deployment(definition)
  rescue KubeException => e
    raise unless e.message =~ /already exists/
  end

  def create_service(name, selector, port)
    definition = service_definition(name, selector, port)
    yield(definition) if block_given?
    kube_connection.create_service(definition)
  rescue KubeException => e
    raise unless e.message =~ /already exists/
  end

  def create_secret(name, data)
    definition = secret_definition(name, data)
    yield(definition) if block_given?
    kube_connection.create_secret(definition)
  rescue KubeException => e
    raise unless e.message =~ /already exists/
  end

  def delete_deployment(name)
    _log.info("Deleting [#{name}] in namespace: #{my_namespace}")
    scale(name, 0)
    kube_apps_connection.delete_deployment(name, my_namespace)
  rescue KubeException => e
    raise unless e.message =~ /not found/
  end

  def delete_service(name)
    kube_connection.delete_service(name, my_namespace)
  rescue KubeException => e
    raise unless e.message =~ /not found/
  end

  def delete_secret(name)
    kube_connection.delete_secret(name, my_namespace)
  rescue KubeException => e
    raise unless e.message =~ /not found/
  end

  def get_deployments
    kube_apps_connection.get_deployments(default_get_options)
  end

  def watch_deployments(resource_version = nil)
    kube_apps_connection.watch_deployments(default_get_options.merge(:resource_version => resource_version))
  end

  def get_pods
    kube_connection.get_pods(default_get_options)
  end

  def watch_pods(resource_version = nil)
    kube_connection.watch_pods(default_get_options.merge(:resource_version => resource_version))
  end

  private
  def default_get_options
    {:namespace => my_namespace, :label_selector => [app_name_selector, orchestrated_by_selector].join(",")}
  end

  def kube_connection
    @kube_connection ||= raw_connect(manager_uri("/api"))
  end

  def kube_apps_connection
    @kube_apps_connection ||= raw_connect(manager_uri("/apis/apps"))
  end

  def raw_connect(uri)
    ssl_options = {
      :verify_ssl => OpenSSL::SSL::VERIFY_PEER,
      :ca_file    => CA_CERT_FILE
    }

    Kubeclient::Client.new(
      uri,
      :auth_options => { :bearer_token_file => TOKEN_FILE },
      :ssl_options  => ssl_options
    )
  end

  def manager_uri(path)
    URI::HTTPS.build(
      :host => ENV["KUBERNETES_SERVICE_HOST"],
      :port => ENV["KUBERNETES_SERVICE_PORT"],
      :path => path
    )
  end
end

1	autoload(:Kubeclient, 'kubeclient')	3✔
2	autoload(:KubeException, 'kubeclient')	3✔
3
4	class ContainerOrchestrator	3✔
5	include Vmdb::Logging	3✔
6	include_concern 'ObjectDefinition'	3✔
7
8	TOKEN_FILE = "/run/secrets/kubernetes.io/serviceaccount/token".freeze	3✔
9	CA_CERT_FILE = "/run/secrets/kubernetes.io/serviceaccount/ca.crt".freeze	3✔
10
11	def self.available?	3✔
12	File.exist?(TOKEN_FILE) && File.exist?(CA_CERT_FILE)	×
13	end
14
15	def scale(deployment_name, replicas)	3✔
16	patch_deployment(deployment_name, {:spec => {:replicas => replicas}})	×
17	end
18
19	def patch_deployment(deployment_name, data)	3✔
20	_log.info("deployment_name: #{deployment_name}, data: #{data.inspect}")	×
21	kube_apps_connection.patch_deployment(deployment_name, data, my_namespace)	×
22	end
23
24	def create_deployment(name)	3✔
25	definition = deployment_definition(name)	×
26	yield(definition) if block_given?	×
27	kube_apps_connection.create_deployment(definition)	×
28	rescue KubeException => e
29	raise unless e.message =~ /already exists/	×
30	end
31
32	def create_service(name, selector, port)	3✔
33	definition = service_definition(name, selector, port)	×
34	yield(definition) if block_given?	×
35	kube_connection.create_service(definition)	×
36	rescue KubeException => e
37	raise unless e.message =~ /already exists/	×
38	end
39
40	def create_secret(name, data)	3✔
41	definition = secret_definition(name, data)	×
42	yield(definition) if block_given?	×
43	kube_connection.create_secret(definition)	×
44	rescue KubeException => e
45	raise unless e.message =~ /already exists/	×
46	end
47
48	def delete_deployment(name)	3✔
49	_log.info("Deleting [#{name}] in namespace: #{my_namespace}")	×
50	scale(name, 0)	×
51	kube_apps_connection.delete_deployment(name, my_namespace)	×
52	rescue KubeException => e
53	raise unless e.message =~ /not found/	×
54	end
55
56	def delete_service(name)	3✔
57	kube_connection.delete_service(name, my_namespace)	×
58	rescue KubeException => e
59	raise unless e.message =~ /not found/	×
60	end
61
62	def delete_secret(name)	3✔
63	kube_connection.delete_secret(name, my_namespace)	×
64	rescue KubeException => e
65	raise unless e.message =~ /not found/	×
66	end
67
68	def get_deployments	3✔
69	kube_apps_connection.get_deployments(default_get_options)	×
70	end
71
72	def watch_deployments(resource_version = nil)	3✔
73	kube_apps_connection.watch_deployments(default_get_options.merge(:resource_version => resource_version))	×
74	end
75
76	def get_pods	3✔
77	kube_connection.get_pods(default_get_options)	×
78	end
79
80	def watch_pods(resource_version = nil)	3✔
81	kube_connection.watch_pods(default_get_options.merge(:resource_version => resource_version))	×
82	end
83
84	private	3✔
85	def default_get_options	3✔
86	{:namespace => my_namespace, :label_selector => [app_name_selector, orchestrated_by_selector].join(",")}	×
87	end
88
89	def kube_connection	3✔
90	@kube_connection \|\|= raw_connect(manager_uri("/api"))	×
91	end
92
93	def kube_apps_connection	3✔
94	@kube_apps_connection \|\|= raw_connect(manager_uri("/apis/apps"))	×
95	end
96
97	def raw_connect(uri)	3✔
98	ssl_options = {
99	:verify_ssl => OpenSSL::SSL::VERIFY_PEER,	×
100	:ca_file => CA_CERT_FILE
101	}
102
103	Kubeclient::Client.new(	×
104	uri,
105	:auth_options => { :bearer_token_file => TOKEN_FILE },
106	:ssl_options => ssl_options
107	)
108	end
109
110	def manager_uri(path)	3✔
111	URI::HTTPS.build(	×
112	:host => ENV["KUBERNETES_SERVICE_HOST"],
113	:port => ENV["KUBERNETES_SERVICE_PORT"],
114	:path => path
115	)
116	end
117	end

ManageIQ / manageiq / 86058

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous