Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Nodes & Namespaces improvements #9

Open
wants to merge 2 commits into
base: master
Choose a base branch
from
Open

Nodes & Namespaces improvements #9

Changes from all commits
Commits
Show all changes
2 commits
Select commit Hold shift + click to select a range
751e7f4
Improve output and display true status for nodes
Dec 24, 2018
911d150
Adding support for querying namespaces
Dec 24, 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
33 changes: 30 additions & 3 deletions ksql.js
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -129,8 +129,9 @@ var mybase = new alasql.Database('mybase');

var create_tables = function(db) {
db.exec('CREATE TABLE pods (uid TEXT, node TEXT, metadata Object, spec Object, status Object)');
db.exec('CREATE TABLE nodes (name TEXT, uid TEXT, metadata Object, spec Object, status Object)');
db.exec('CREATE TABLE nodes (name TEXT, uid TEXT, metadata Object, spec Object, status TXT)');
db.exec('CREATE TABLE services (name TEXT, uid TEXT, metadata Object, spec Object, status Object)');
db.exec('CREATE TABLE namespaces (name TEXT, uid TEXT)');
db.exec('CREATE TABLE containers (image TEXT, uid TEXT, restarts INT)');
};

Expand Down Expand Up @@ -242,15 +243,41 @@ var load_services = function(client) {
return generic_load(client.services.get, alasql.databases.mybase.tables.services);
};

var load_namespaces = function (client) {
return generic_load(client.namespaces.get, alasql.databases.mybase.tables.namespaces);
}

var load_nodes = function(client) {
return generic_load(client.nodes.get, alasql.databases.mybase.tables.nodes);
var defer = q.defer();
client.nodes.get(function (err, nodes) {
if (err != null) {
defer.reject(err);
return;
}
for (var i = 0; i < nodes[0].items.length; i++) {
var node = nodes[0].items[i];
node.uid = node.metadata.uid;
node.name = node.metadata.name;
for (var j = 0; j < node.status.conditions.length; j++) {
if (node.status.conditions[j].status == "True") {
node.status = node.status.conditions[j].type
break;
}
}
}
alasql.databases.mybase.tables.nodes.data = nodes[0].items;
defer.resolve();
});

return defer.promise;
};

var load = function (client) {
return q.all([
load_pods(client),
load_nodes(client),
load_services(client)
load_services(client),
load_namespaces(client)
])
};

Expand Down