Class: TrainPlugins::TrainKubernetes::Connection

Inherits:
Train::Plugins::Transport::BaseConnection
  • Object
show all
Includes:
Platform
Defined in:
lib/train-kubernetes/connection.rb

Instance Attribute Summary collapse

Instance Method Summary collapse

Methods included from Platform

#platform

Constructor Details

#initialize(options) ⇒ Connection

Returns a new instance of Connection.



10
11
12
13
14
15
 
# File 'lib/train-kubernetes/connection.rb', line 10

def initialize(options)
  super(options)

  parse_kubeconfig
  connect
end

Instance Attribute Details

#client ⇒ Object

Returns the value of attribute client.



17
18
19
 
# File 'lib/train-kubernetes/connection.rb', line 17

def client
  @client
end

Instance Method Details

#connect ⇒ Object 



19
20
21
22
23
24
 
# File 'lib/train-kubernetes/connection.rb', line 19

def connect
  @client.apis(prefetch_resources: true)
rescue Excon::Error::Socket => e
  logger.error e.message
  exit
end

#parse_kubeconfig ⇒ Object 



34
35
36
37
 
# File 'lib/train-kubernetes/connection.rb', line 34

def parse_kubeconfig
  kubeconfig_file = @options[:kubeconfig] if @options[:kubeconfig]
  @client = K8s::Client.config(K8s::Config.load_file(File.expand_path(kubeconfig_file)))
end

#unique_identifier ⇒ Object 



30
31
32
 
# File 'lib/train-kubernetes/connection.rb', line 30

def unique_identifier
  @client.transport.server.gsub(%r{(http|https)\:\/\/}, '') || 'default'
end

#uri ⇒ Object 



26
27
28
 
# File 'lib/train-kubernetes/connection.rb', line 26

def uri
  "kubernetes://#{unique_identifier}"
end