Class: K8s::Resource

Inherits:
RecursiveOpenStruct
  • Object
show all
Extended by:
Forwardable
Includes:
Comparable
Defined in:
lib/k8s/resource.rb

Overview

generic untyped resource

Class Method Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(hash, options = {}, **kwargs) ⇒ Resource 



45
46
47
48
 
# File 'lib/k8s/resource.rb', line 45

def initialize(hash, options = {}, **kwargs)
  options_with_defaults = { recurse_over_arrays: true }.merge(options).merge(kwargs)
  super(hash, options_with_defaults)
end

Class Method Details

.from_file(filename) ⇒ K8s::Resource 



25
26
27
 
# File 'lib/k8s/resource.rb', line 25

def self.from_file(filename)
  new(YAML.safe_load(File.read(filename), [], [], true, filename))
end

.from_files(path) ⇒ Array<K8s::Resource> 



31
32
33
34
35
36
37
38
39
40
 
# File 'lib/k8s/resource.rb', line 31

def self.from_files(path)
  stat = File.stat(path)

  if stat.directory?
    # recurse
    Dir.glob("#{path}/*.{yml,yaml}").sort.map { |dir| from_files(dir) }.flatten
  else
    YAML.safe_load_stream(File.read(path), path).map{ |doc| new(doc) }
  end
end

.from_json(data) ⇒ self 



19
20
21
 
# File 'lib/k8s/resource.rb', line 19

def self.from_json(data)
  new(Yajl::Parser.parse(data))
end

Instance Method Details

#<=>(other) ⇒ Boolean 



58
59
60
 
# File 'lib/k8s/resource.rb', line 58

def <=>(other)
  to_hash <=> other.to_hash
end

#can_patch?(config_annotation) ⇒ Boolean 



105
106
107
 
# File 'lib/k8s/resource.rb', line 105

def can_patch?(config_annotation)
  !!metadata.annotations&.dig(config_annotation)
end

#checksum ⇒ String 



77
78
79
 
# File 'lib/k8s/resource.rb', line 77

def checksum
  @checksum ||= Digest::MD5.hexdigest(Marshal.dump(to_hash))
end

#current_config(config_annotation) ⇒ Hash

Gets the existing resources (on kube api) configuration, an empty hash if not present



92
93
94
95
96
97
98
99
100
101
 
# File 'lib/k8s/resource.rb', line 92

def current_config(config_annotation)
  current_cfg = metadata.annotations&.dig(config_annotation)
  return {} unless current_cfg

  current_hash = Yajl::Parser.parse(current_cfg)
  # kubectl adds empty metadata.namespace, let's fix it
  current_hash['metadata'].delete('namespace') if current_hash.dig('metadata', 'namespace').to_s.empty?

  current_hash
end

#merge(attrs) ⇒ K8s::Resource

merge in fields



66
67
68
69
70
71
72
73
74
 
# File 'lib/k8s/resource.rb', line 66

def merge(attrs)
  # deep clone of attrs
  h = to_hash

  # merge in-place
  h.deep_merge!(attrs.to_hash, overwrite_arrays: true, merge_nil_values: true)

  self.class.new(h)
end

#merge_patch_ops(attrs, config_annotation) ⇒ Hash 



84
85
86
 
# File 'lib/k8s/resource.rb', line 84

def merge_patch_ops(attrs, config_annotation)
  Util.json_patch(current_config(config_annotation), stringify_hash(attrs))
end

#stringify_hash(hash) ⇒ Hash 



111
112
113
 
# File 'lib/k8s/resource.rb', line 111

def stringify_hash(hash)
  Yajl::Parser.parse(JSON.dump(hash))
end

#to_json(**options) ⇒ String 



52
53
54
 
# File 'lib/k8s/resource.rb', line 52

def to_json(**options)
  to_hash.to_json(**options)
end