Skip to content
This repository was archived by the owner on Sep 26, 2025. It is now read-only.

Addon 20535 update metrics test #11

Merged
merged 6 commits into from
Dec 17, 2018
Merged

Addon 20535 update metrics test #11

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
6 commits
Select commit Hold shift + click to select a range
49324ec
Adding support for stats
Dec 6, 2018
cac4114
rename cadvisor mock file, add tests
Dec 11, 2018
e4841bc
Fixed cadvisor errors
Dec 11, 2018
1295f53
ADDON-20535: update metrics test
inthemuse Dec 12, 2018
59628c5
merged in develop, modified test helper to remove errors
Dec 17, 2018
0c61b13
fixed typo
Dec 17, 2018
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion Rakefile
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -13,7 +13,7 @@ Rake::TestTask.new(:test) do |t|
t.libs.push("lib", "test")
t.test_files = FileList["test/**/test_*.rb"]
t.verbose = true
t.warning = true
t.warning = false
end

task default: [:test]
Expand Down
22 changes: 19 additions & 3 deletions test/helper.rb
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -34,8 +34,9 @@ def stub_k8s_requests
stub_kubelet_summary_api
stub_k8s_proxy_summary_api
stub_metrics_cadvisor
stub_metrics_stats
stub_k8s_proxy_cadvisor_api
stub_metrics_stats
stub_metrics_proxy_stats
end

def stub_k8s_proxy_summary_api
Expand Down Expand Up @@ -78,7 +79,7 @@ def stub_k8s_proxy_cadvisor_api
stub_request(:get, "#{k8s_url}/v1/nodes/generics-aws-node-name:10255/proxy/metrics/cadvisor")
.to_return(body: f.read)
}.close
end
end

def stub_metrics_stats
open(File.expand_path('../stats.json', __FILE__)).tap { |f|
Expand All @@ -87,11 +88,26 @@ def stub_metrics_stats
}.close
end

def get_parsed_string
def stub_metrics_proxy_stats
open(File.expand_path('../stats.json', __FILE__)).tap { |f|
stub_request(:get, "#{k8s_url}/v1/nodes/generics-aws-node-name:10255/proxy/stats/")
.to_return(body: f.read)
}.close
end

def get_unit_parsed_string
parsed_string = nil
open(File.expand_path('../unit.json', __FILE__)).tap { |f|
parsed_string = f.read()
}.close
parsed_string
end

def get_stats_parsed_string
get_stats_parsed_string = nil
open(File.expand_path('../stats.json', __FILE__)).tap { |f|
get_stats_parsed_string = f.read()
}.close
get_stats_parsed_string
end
end
71 changes: 46 additions & 25 deletions test/plugin/test_in_kubernetes_metrics.rb
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -30,7 +30,8 @@ class KubernetesMetricsInputTest < Test::Unit::TestCase
setup do
Fluent::Test.setup

@@parsed_string = JSON.parse(get_parsed_string)
@@parsed_unit_string = JSON.parse(get_unit_parsed_string)
@@parsed_string2 = JSON.parse(get_stats_parsed_string)

stub_k8s_requests

Expand Down Expand Up @@ -67,96 +68,96 @@ def create_driver(conf = CONFIG)
puts 'Test: test_emit_cpu_metrics'

assert_not_nil @@hash_map_test.find('kube.node.cpu.usage')
assert_equal @@parsed_string['node']['cpu']['usageNanoCores'], @@hash_map_test['kube.node.cpu.usage'][2]["value"]
assert_equal @@parsed_unit_string['node']['cpu']['usageNanoCores'], @@hash_map_test['kube.node.cpu.usage'][2]["value"]

assert_not_nil @@hash_map_test.find('kube.node.cpu.usage_rate')
assert_equal @@parsed_string['node']['cpu']['usageNanoCores']/ 1_000_000, @@hash_map_test['kube.node.cpu.usage_rate'][2]["value"]
assert_equal @@parsed_unit_string['node']['cpu']['usageNanoCores']/ 1_000_000, @@hash_map_test['kube.node.cpu.usage_rate'][2]["value"]

end

test 'test_emit_memory_metrics' do
puts 'Test: test_emit_memory_metrics'

assert_not_nil @@hash_map_test.find('kube.node.memory.available_bytes')
assert_equal @@parsed_string['node']['memory']['availableBytes'], @@hash_map_test['kube.node.memory.available_bytes'][2]["value"]
assert_equal @@parsed_unit_string['node']['memory']['availableBytes'], @@hash_map_test['kube.node.memory.available_bytes'][2]["value"]

assert_not_nil @@hash_map_test.find('kube.node.memory.usage_bytes')
assert_equal @@parsed_string['node']['memory']['usageBytes'], @@hash_map_test['kube.node.memory.usage_bytes'][2]["value"]
assert_equal @@parsed_unit_string['node']['memory']['usageBytes'], @@hash_map_test['kube.node.memory.usage_bytes'][2]["value"]

assert_not_nil @@hash_map_test.find('kube.node.memory.working_set_bytes')
assert_equal @@parsed_string['node']['memory']['workingSetBytes'], @@hash_map_test['kube.node.memory.working_set_bytes'][2]["value"]
assert_equal @@parsed_unit_string['node']['memory']['workingSetBytes'], @@hash_map_test['kube.node.memory.working_set_bytes'][2]["value"]

assert_not_nil @@hash_map_test.find('kube.node.memory.rss_bytes')
assert_equal @@parsed_string['node']['memory']['rssBytes'], @@hash_map_test['kube.node.memory.rss_bytes'][2]["value"]
assert_equal @@parsed_unit_string['node']['memory']['rssBytes'], @@hash_map_test['kube.node.memory.rss_bytes'][2]["value"]

assert_not_nil @@hash_map_test.find('kube.node.memory.page_faults')
assert_equal @@parsed_string['node']['memory']['pageFaults'], @@hash_map_test['kube.node.memory.page_faults'][2]["value"]
assert_equal @@parsed_unit_string['node']['memory']['pageFaults'], @@hash_map_test['kube.node.memory.page_faults'][2]["value"]

assert_not_nil @@hash_map_test.find('kube.node.memory.major_page_faults')
assert_equal @@parsed_string['node']['memory']['majorPageFaults'], @@hash_map_test['kube.node.memory.major_page_faults'][2]["value"]
assert_equal @@parsed_unit_string['node']['memory']['majorPageFaults'], @@hash_map_test['kube.node.memory.major_page_faults'][2]["value"]

end

test 'test_emit_network_metrics' do
puts 'Test: test_emit_network_metrics'

assert_not_nil @@hash_map_test.find('kube.node.network.rx_bytes')
assert_equal @@parsed_string['node']['network']['rxBytes'], @@hash_map_test['kube.node.network.rx_bytes'][2]["value"]
assert_equal @@parsed_unit_string['node']['network']['rxBytes'], @@hash_map_test['kube.node.network.rx_bytes'][2]["value"]

assert_not_nil @@hash_map_test.find('kube.node.network.rx_errors')
assert_equal @@parsed_string['node']['network']['rxErrors'], @@hash_map_test['kube.node.network.rx_errors'][2]["value"]
assert_equal @@parsed_unit_string['node']['network']['rxErrors'], @@hash_map_test['kube.node.network.rx_errors'][2]["value"]

assert_not_nil @@hash_map_test.find('kube.node.network.tx_bytes')
assert_equal @@parsed_string['node']['network']['txBytes'], @@hash_map_test['kube.node.network.tx_bytes'][2]["value"]
assert_equal @@parsed_unit_string['node']['network']['txBytes'], @@hash_map_test['kube.node.network.tx_bytes'][2]["value"]

assert_not_nil @@hash_map_test.find('kube.node.network.tx_errors')
assert_equal @@parsed_string['node']['network']['txErrors'], @@hash_map_test['kube.node.network.tx_errors'][2]["value"]
assert_equal @@parsed_unit_string['node']['network']['txErrors'], @@hash_map_test['kube.node.network.tx_errors'][2]["value"]

end

test 'test_emit_fs_metrics' do
puts 'Test: test_emit_fs_metrics'

assert_not_nil @@hash_map_test.find('kube.node.fs.available_bytes')
assert_equal @@parsed_string['node']['fs']['availableBytes'], @@hash_map_test['kube.node.fs.available_bytes'][2]["value"]
assert_equal @@parsed_unit_string['node']['fs']['availableBytes'], @@hash_map_test['kube.node.fs.available_bytes'][2]["value"]

assert_not_nil @@hash_map_test.find('kube.node.fs.capacity_bytes')
assert_equal @@parsed_string['node']['fs']['capacityBytes'], @@hash_map_test['kube.node.fs.capacity_bytes'][2]["value"]
assert_equal @@parsed_unit_string['node']['fs']['capacityBytes'], @@hash_map_test['kube.node.fs.capacity_bytes'][2]["value"]

assert_not_nil @@hash_map_test.find('kube.node.fs.used_bytes')
assert_equal @@parsed_string['node']['fs']['usedBytes'], @@hash_map_test['kube.node.fs.used_bytes'][2]["value"]
assert_equal @@parsed_unit_string['node']['fs']['usedBytes'], @@hash_map_test['kube.node.fs.used_bytes'][2]["value"]

assert_not_nil @@hash_map_test.find('kube.node.fs.inodes_free')
assert_equal @@parsed_string['node']['fs']['inodesFree'], @@hash_map_test['kube.node.fs.inodes_free'][2]["value"]
assert_equal @@parsed_unit_string['node']['fs']['inodesFree'], @@hash_map_test['kube.node.fs.inodes_free'][2]["value"]

assert_not_nil @@hash_map_test.find('kube.node.fs.inodes')
assert_equal @@parsed_string['node']['fs']['inodes'], @@hash_map_test['kube.node.fs.inodes'][2]["value"]
assert_equal @@parsed_unit_string['node']['fs']['inodes'], @@hash_map_test['kube.node.fs.inodes'][2]["value"]

assert_not_nil @@hash_map_test.find('kube.node.fs.inodes_used')
assert_equal @@parsed_string['node']['fs']['inodesUsed'], @@hash_map_test['kube.node.fs.inodes_used'][2]["value"]
assert_equal @@parsed_unit_string['node']['fs']['inodesUsed'], @@hash_map_test['kube.node.fs.inodes_used'][2]["value"]

end

test 'test_emit_fs_imagefs_metrics' do
puts 'Test: test_emit_fs_imagefs_metrics'

assert_not_nil @@hash_map_test.find('kube.node.fs.available_bytes')
assert_equal @@parsed_string['node']['runtime']['imageFs']['availableBytes'], @@hash_map_test['kube.node.imagefs.available_bytes'][2]["value"]
assert_equal @@parsed_unit_string['node']['runtime']['imageFs']['availableBytes'], @@hash_map_test['kube.node.imagefs.available_bytes'][2]["value"]

assert_not_nil @@hash_map_test.find('kube.node.fs.capacity_bytes')
assert_equal @@parsed_string['node']['runtime']['imageFs']['capacityBytes'], @@hash_map_test['kube.node.imagefs.capacity_bytes'][2]["value"]
assert_equal @@parsed_unit_string['node']['runtime']['imageFs']['capacityBytes'], @@hash_map_test['kube.node.imagefs.capacity_bytes'][2]["value"]

assert_not_nil @@hash_map_test.find('kube.node.fs.used_bytes')
assert_equal @@parsed_string['node']['runtime']['imageFs']['usedBytes'], @@hash_map_test['kube.node.imagefs.used_bytes'][2]["value"]
assert_equal @@parsed_unit_string['node']['runtime']['imageFs']['usedBytes'], @@hash_map_test['kube.node.imagefs.used_bytes'][2]["value"]

assert_not_nil @@hash_map_test.find('kube.node.fs.inodes_free')
assert_equal @@parsed_string['node']['runtime']['imageFs']['inodesFree'], @@hash_map_test['kube.node.imagefs.inodes_free'][2]["value"]
assert_equal @@parsed_unit_string['node']['runtime']['imageFs']['inodesFree'], @@hash_map_test['kube.node.imagefs.inodes_free'][2]["value"]

assert_not_nil @@hash_map_test.find('kube.node.fs.inodes')
assert_equal @@parsed_string['node']['runtime']['imageFs']['inodes'], @@hash_map_test['kube.node.imagefs.inodes'][2]["value"]
assert_equal @@parsed_unit_string['node']['runtime']['imageFs']['inodes'], @@hash_map_test['kube.node.imagefs.inodes'][2]["value"]

assert_not_nil @@hash_map_test.find('kube.node.fs.inodes_used')
assert_equal @@parsed_string['node']['runtime']['imageFs']['inodesUsed'], @@hash_map_test['kube.node.imagefs.inodes_used'][2]["value"]
assert_equal @@parsed_unit_string['node']['runtime']['imageFs']['inodesUsed'], @@hash_map_test['kube.node.imagefs.inodes_used'][2]["value"]

end

Expand All @@ -167,5 +168,25 @@ def create_driver(conf = CONFIG)
events = d.events
assert_not_nil events
end

end

sub_test_case "node_stats_tests" do

test 'test_stats_cpu_usage' do
puts 'Test: test_stats_cpu_usage'

# assert_not_nil @@hash_map_test.find('kube.container.cpu.usage')
# assert_equal @@parsed_string2["stats"][0]["cpu"]["usage"]["total"], @@hash_map_test['kube.container.cpu.usage'][2]["value"]

puts @@parsed_string2["stats"][0]["cpu"]["usage"]["total"].inspect

# puts @@hash_map_test['kube.container.cpu.usage'][2]["value"].inspect

end

end

# end

end