diff options
author | Herbert Eiselt <herbert.eiselt@highstreet-technologies.com> | 2019-02-07 17:50:41 +0100 |
---|---|---|
committer | Herbert Eiselt <herbert.eiselt@highstreet-technologies.com> | 2019-02-07 17:51:11 +0100 |
commit | 12a8c669f52c0e84d580c078cee849b25133b585 (patch) | |
tree | 1a0ddb6cc13f225e8a58833b8975f98b453a8d52 /sdnr/wt/devicemanager/provider/src/main/resources/elasticsearch/plugins/head/src/app/ui/clusterOverview/clusterOverview.js | |
parent | bd2aa3c75e0073ff07fb46b14b8b51926915d5c8 (diff) |
Add sdnr wt devicemanager
Add complete sdnr wireless transport app devicemanager
Change-Id: I433014ee579a3c8833b3b8f84c4087c5f776704f
Issue-ID: SDNC-575
Signed-off-by: Herbert Eiselt <herbert.eiselt@highstreet-technologies.com>
Diffstat (limited to 'sdnr/wt/devicemanager/provider/src/main/resources/elasticsearch/plugins/head/src/app/ui/clusterOverview/clusterOverview.js')
-rw-r--r-- | sdnr/wt/devicemanager/provider/src/main/resources/elasticsearch/plugins/head/src/app/ui/clusterOverview/clusterOverview.js | 302 |
1 files changed, 302 insertions, 0 deletions
diff --git a/sdnr/wt/devicemanager/provider/src/main/resources/elasticsearch/plugins/head/src/app/ui/clusterOverview/clusterOverview.js b/sdnr/wt/devicemanager/provider/src/main/resources/elasticsearch/plugins/head/src/app/ui/clusterOverview/clusterOverview.js new file mode 100644 index 000000000..745ab42e3 --- /dev/null +++ b/sdnr/wt/devicemanager/provider/src/main/resources/elasticsearch/plugins/head/src/app/ui/clusterOverview/clusterOverview.js @@ -0,0 +1,302 @@ +(function( $, app, i18n ) { + + var ui = app.ns("ui"); + var services = app.ns("services"); + + // ( master ) master = true, data = true + // ( coordinator ) master = true, data = false + // ( worker ) master = false, data = true; + // ( client ) master = false, data = false; + // http enabled ? + + function nodeSort_name(a, b) { + if (!(a.cluster && b.cluster)) { + return 0; + } + return a.cluster.name.toString().localeCompare( b.cluster.name.toString() ); + } + + function nodeSort_addr( a, b ) { + if (!(a.cluster && b.cluster)) { + return 0; + } + return a.cluster.transport_address.toString().localeCompare( b.cluster.transport_address.toString() ); + } + + function nodeSort_type( a, b ) { + if (!(a.cluster && b.cluster)) { + return 0; + } + if( a.master_node ) { + return -1; + } else if( b.master_node ) { + return 1; + } else if( a.data_node && !b.data_node ) { + return -1; + } else if( b.data_node && !a.data_node ) { + return 1; + } else { + return a.cluster.name.toString().localeCompare( b.cluster.name.toString() ); + } + } + + var NODE_SORT_TYPES = { + "Sort.ByName": nodeSort_name, + "Sort.ByAddress": nodeSort_addr, + "Sort.ByType": nodeSort_type + }; + + function nodeFilter_none( a ) { + return true; + } + + function nodeFilter_clients( a ) { + return (a.master_node || a.data_node ); + } + + + ui.ClusterOverview = ui.Page.extend({ + defaults: { + cluster: null // (reqired) an instanceof app.services.Cluster + }, + init: function() { + this._super(); + this.cluster = this.config.cluster; + this.prefs = services.Preferences.instance(); + this._clusterState = this.config.clusterState; + this._clusterState.on("data", this.draw_handler ); + this._refreshButton = new ui.RefreshButton({ + onRefresh: this.refresh.bind(this), + onChange: function( btn ) { + if( btn.value === -1 ) { + this.draw_handler(); + } + }.bind( this ) + }); + var nodeSortPref = this.prefs.get("clusterOverview-nodeSort") || Object.keys(NODE_SORT_TYPES)[0]; + this._nodeSort = NODE_SORT_TYPES[ nodeSortPref ]; + this._nodeSortMenu = new ui.MenuButton({ + label: i18n.text( "Preference.SortCluster" ), + menu: new ui.SelectMenuPanel({ + value: nodeSortPref, + items: Object.keys( NODE_SORT_TYPES ).map( function( k ) { + return { text: i18n.text( k ), value: k }; + }), + onSelect: function( panel, event ) { + this._nodeSort = NODE_SORT_TYPES[ event.value ]; + this.prefs.set("clusterOverview-nodeSort", event.value ); + this.draw_handler(); + }.bind(this) + }) + }); + this._indicesSort = this.prefs.get( "clusterOverview-indicesSort") || "desc"; + this._indicesSortMenu = new ui.MenuButton({ + label: i18n.text( "Preference.SortIndices" ), + menu: new ui.SelectMenuPanel({ + value: this._indicesSort, + items: [ + { value: "desc", text: i18n.text( "SortIndices.Descending" ) }, + { value: "asc", text: i18n.text( "SortIndices.Ascending" ) } ], + onSelect: function( panel, event ) { + this._indicesSort = event.value; + this.prefs.set( "clusterOverview-indicesSort", this._indicesSort ); + this.draw_handler(); + }.bind(this) + }) + }); + this._aliasRenderer = this.prefs.get( "clusterOverview-aliasRender" ) || "full"; + this._aliasMenu = new ui.MenuButton({ + label: i18n.text( "Preference.ViewAliases" ), + menu: new ui.SelectMenuPanel({ + value: this._aliasRenderer, + items: [ + { value: "full", text: i18n.text( "ViewAliases.Grouped" ) }, + { value: "list", text: i18n.text( "ViewAliases.List" ) }, + { value: "none", text: i18n.text( "ViewAliases.None" ) } ], + onSelect: function( panel, event ) { + this._aliasRenderer = event.value; + this.prefs.set( "clusterOverview-aliasRender", this._aliasRenderer ); + this.draw_handler(); + }.bind(this) + }) + }); + this._indexFilter = new ui.TextField({ + value: this.prefs.get("clusterOverview-indexFilter"), + placeholder: i18n.text( "Overview.IndexFilter" ), + onchange: function( indexFilter ) { + this.prefs.set("clusterOverview-indexFilter", indexFilter.val() ); + this.draw_handler(); + }.bind(this) + }); + this.el = $(this._main_template()); + this.tablEl = this.el.find(".uiClusterOverview-table"); + this.refresh(); + }, + remove: function() { + this._clusterState.removeObserver( "data", this.draw_handler ); + }, + refresh: function() { + this._refreshButton.disable(); + this._clusterState.refresh(); + }, + draw_handler: function() { + var data = this._clusterState; + var indexFilter; + try { + var indexFilterRe = new RegExp( this._indexFilter.val() ); + indexFilter = function(s) { return indexFilterRe.test(s); }; + } catch(e) { + indexFilter = function() { return true; }; + } + var clusterState = data.clusterState; + var status = data.status; + var nodeStats = data.nodeStats; + var clusterNodes = data.clusterNodes; + var nodes = []; + var indices = []; + var cluster = {}; + var nodeIndices = {}; + var indexIndices = {}, indexIndicesIndex = 0; + function newNode(n) { + return { + name: n, + routings: [], + master_node: clusterState.master_node === n + }; + } + function newIndex(i) { + return { + name: i, + replicas: [] + }; + } + function getIndexForNode(n) { + return nodeIndices[n] = (n in nodeIndices) ? nodeIndices[n] : nodes.push(newNode(n)) - 1; + } + function getIndexForIndex(routings, i) { + var index = indexIndices[i] = (i in indexIndices) ? + (routings[indexIndices[i]] = routings[indexIndices[i]] || newIndex(i)) && indexIndices[i] + : ( ( routings[indexIndicesIndex] = newIndex(i) ) && indexIndicesIndex++ ); + indices[index] = i; + return index; + } + $.each(clusterNodes.nodes, function(name, node) { + getIndexForNode(name); + }); + + var indexNames = []; + $.each(clusterState.routing_table.indices, function(name, index){ + indexNames.push(name); + }); + indexNames.sort(); + if (this._indicesSort === "desc") indexNames.reverse(); + indexNames.filter( indexFilter ).forEach(function(name) { + var indexObject = clusterState.routing_table.indices[name]; + $.each(indexObject.shards, function(name, shard) { + shard.forEach(function(replica){ + var node = replica.node; + if(node === null) { node = "Unassigned"; } + var index = replica.index; + var shard = replica.shard; + var routings = nodes[getIndexForNode(node)].routings; + var indexIndex = getIndexForIndex(routings, index); + var replicas = routings[indexIndex].replicas; + if(node === "Unassigned" || !indexObject.shards[shard]) { + replicas.push({ replica: replica }); + } else { + replicas[shard] = { + replica: replica, + status: indexObject.shards[shard].filter(function(replica) { + return replica.node === node; + })[0] + }; + } + }); + }); + }); + indices = indices.map(function(index){ + return { + name: index, + state: "open", + metadata: clusterState.metadata.indices[index], + status: status.indices[index] + }; + }, this); + $.each(clusterState.metadata.indices, function(name, index) { + if(index.state === "close" && indexFilter( name )) { + indices.push({ + name: name, + state: "close", + metadata: index, + status: null + }); + } + }); + nodes.forEach(function(node) { + node.stats = nodeStats.nodes[node.name]; + var cluster = clusterNodes.nodes[node.name]; + node.cluster = cluster || { name: "<unknown>" }; + node.data_node = !( cluster && cluster.attributes && cluster.attributes.data === "false" ); + for(var i = 0; i < indices.length; i++) { + node.routings[i] = node.routings[i] || { name: indices[i].name, replicas: [] }; + node.routings[i].max_number_of_shards = indices[i].metadata.settings["index.number_of_shards"]; + node.routings[i].open = indices[i].state === "open"; + } + }); + var aliasesIndex = {}; + var aliases = []; + var indexClone = indices.map(function() { return false; }); + $.each(clusterState.metadata.indices, function(name, index) { + index.aliases.forEach(function(alias) { + var aliasIndex = aliasesIndex[alias] = (alias in aliasesIndex) ? aliasesIndex[alias] : aliases.push( { name: alias, max: -1, min: 999, indices: [].concat(indexClone) }) - 1; + var indexIndex = indexIndices[name]; + var aliasRow = aliases[aliasIndex]; + aliasRow.min = Math.min(aliasRow.min, indexIndex); + aliasRow.max = Math.max(aliasRow.max, indexIndex); + aliasRow.indices[indexIndex] = indices[indexIndex]; + }); + }); + cluster.aliases = aliases; + cluster.nodes = nodes + .filter( nodeFilter_none ) + .sort( this._nodeSort ); + indices.unshift({ name: null }); + this._drawNodesView( cluster, indices ); + this._refreshButton.enable(); + }, + _drawNodesView: function( cluster, indices ) { + this._nodesView && this._nodesView.remove(); + this._nodesView = new ui.NodesView({ + onRedraw: function() { + this.refresh(); + }.bind(this), + interactive: ( this._refreshButton.value === -1 ), + aliasRenderer: this._aliasRenderer, + cluster: this.cluster, + data: { + cluster: cluster, + indices: indices + } + }); + this._nodesView.attach( this.tablEl ); + }, + _main_template: function() { + return { tag: "DIV", id: this.id(), cls: "uiClusterOverview", children: [ + new ui.Toolbar({ + label: i18n.text("Overview.PageTitle"), + left: [ + this._nodeSortMenu, + this._indicesSortMenu, + this._aliasMenu, + this._indexFilter + ], + right: [ + this._refreshButton + ] + }), + { tag: "DIV", cls: "uiClusterOverview-table" } + ] }; + } + }); + +})( this.jQuery, this.app, this.i18n ); |