You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ambari.apache.org by rl...@apache.org on 2017/10/23 15:20:10 UTC
[02/50] [abbrv] ambari git commit: AMBARI-21955. Update React version
to 15.6.2 to get MIT license. (Sanket Shah via yusaku)
http://git-wip-us.apache.org/repos/asf/ambari/blob/0c188aea/contrib/views/storm/src/main/resources/ui/app/scripts/containers/TopologyDetailView.jsx
----------------------------------------------------------------------
diff --git a/contrib/views/storm/src/main/resources/ui/app/scripts/containers/TopologyDetailView.jsx b/contrib/views/storm/src/main/resources/ui/app/scripts/containers/TopologyDetailView.jsx
new file mode 100644
index 0000000..847ae7d
--- /dev/null
+++ b/contrib/views/storm/src/main/resources/ui/app/scripts/containers/TopologyDetailView.jsx
@@ -0,0 +1,862 @@
+/**
+ Licensed to the Apache Software Foundation (ASF) under one
+ or more contributor license agreements. See the NOTICE file
+ distributed with this work for additional information
+ regarding copyright ownership. The ASF licenses this file
+ to you under the Apache License, Version 2.0 (the
+ "License"); you may not use this file except in compliance
+ with the License. You may obtain a copy of the License at
+*
+ http://www.apache.org/licenses/LICENSE-2.0
+*
+ Unless required by applicable law or agreed to in writing, software
+ distributed under the License is distributed on an "AS IS" BASIS,
+ WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ See the License for the specific language governing permissions and
+ limitations under the License.
+**/
+
+import React, {Component} from 'react';
+import ReactDOM from 'react-dom';
+import BaseContainer from './BaseContainer';
+import SearchLogs from '../components/SearchLogs';
+import TopologyREST from '../rest/TopologyREST';
+import {Accordion, Panel,OverlayTrigger, Tooltip} from 'react-bootstrap';
+import TopologyGraph from '../components/TopologyGraph';
+import {
+ Table,
+ Thead,
+ Th,
+ Tr,
+ Td,
+ unsafe
+} from 'reactable';
+import CommonPagination from '../components/CommonPagination';
+import {Link} from 'react-router';
+import {toastOpt,pageSize} from '../utils/Constants';
+import Utils from '../utils/Utils';
+import FSReactToastr from '../components/FSReactToastr';
+import CommonNotification from '../components/CommonNotification';
+import Breadcrumbs from '../components/Breadcrumbs';
+import Modal from '../components/FSModel';
+import CommonWindowPanel from '../components/CommonWindowPanel';
+import RebalanceTopology from '../components/RebalanceTopology';
+import LogLevelComponent from '../components/LogLevelComponent';
+import CommonSwitchComponent from '../components/CommonSwitchComponent';
+import BarChart from '../components/BarChart';
+import CommonExpanded from '../components/CommonExpanded';
+
+export default class TopologyDetailView extends Component {
+ constructor(props){
+ super(props);
+ this.state = {
+ details: {},
+ spotActivePage : 1,
+ boltsActivePage : 1,
+ topologyActivePage : 1,
+ spotFilterValue : '',
+ blotFilterValue : '',
+ topologyFilterValue : '',
+ selectedWindowKey : {label : 'All time' , value : ':all-time'},
+ windowOptions : [],
+ systemFlag : false,
+ killWaitTime : 30,
+ showLogLevel : false,
+ topologyLagFlag : true,
+ topologyLagPage : 1,
+ toggleGraphAndTable: true,
+ expandGraph : true,
+ expandSpout : true,
+ expandBolt : true,
+ expandConfig : false,
+ topologyLag : [],
+ debugFlag : false
+ };
+ this.fetchDetails();
+ }
+ fetchDetails(){
+ const {selectedWindowKey,systemFlag} = this.state;
+ let promiseArr=[
+ TopologyREST.getTopologyDetails(this.props.params.id,selectedWindowKey.value,systemFlag),
+ TopologyREST.getTopologyGraphData(this.props.params.id,selectedWindowKey.value),
+ TopologyREST.getTopologyLag(this.props.params.id)
+ ];
+
+ Promise.all(promiseArr).then((results) => {
+ _.map(results, (result) => {
+ if(result.errorMessage !== undefined){
+ FSReactToastr.error(
+ <CommonNotification flag="error" content={result.errorMessage}/>, '', toastOpt);
+ }
+ });
+
+ let stateObj = {};
+ stateObj.details = results[0];
+ stateObj.windowOptions = Utils.populateWindowsOptions(stateObj.details.topologyStats);
+ if(stateObj.windowOptions.length === 0){
+ stateObj.windowOptions = [{label : 'All time', value : ':all-time'}];
+ }
+ stateObj.debugSimplePCT = stateObj.details.samplingPct;
+ stateObj.selectedWindowKey = {label : stateObj.details.windowHint || 'All time', value : stateObj.details.window || ':all-time'};
+ stateObj.graphData = results[1];
+ stateObj.topologyLag = _.isEmpty(results[2]) ? [] : this.generateTopologyLagData(results[2]);
+ stateObj.debugFlag = stateObj.details.debug;
+ this.setState(stateObj);
+ });
+ }
+
+ generateTopologyLagData = (lagObj) => {
+ const objKey = _.keys(lagObj);
+ let arr = [];
+ _.map(objKey, (o) => {
+ let data = lagObj[o];
+ const topicKeys = _.keys(data.spoutLagResult);
+ _.map(topicKeys, (t) => {
+ const topicName = t;
+ const partitionData = data.spoutLagResult[t];
+ const partitionKey = _.keys(partitionData);
+ _.map(partitionKey, (pk) => {
+ let obj = partitionData[pk];
+ obj['spoutId'] = data.spoutId;
+ obj['spoutType'] = data.spoutType;
+ obj['partition'] = pk;
+ obj['topic'] = topicName;
+ arr.push(obj);
+ });
+ });
+ });
+ return arr;
+ }
+
+ componentDidUpdate(){
+ if(this.refs.barChart){
+ ReactDOM.findDOMNode(document.getElementById('lag-graph')).appendChild(this.refs.barChart.legendsEl);
+ }
+ }
+
+ handleWindowChange = (obj) => {
+ if(!_.isEmpty(obj)){
+ this.setState({selectedWindowKey : obj}, () => {
+ this.fetchDetails();
+ });
+ }
+ }
+
+ getWorkerData = () => {
+ const {details} = this.state;
+ let data='';
+ _.map(details.workers,(worker,i) => {
+ data += worker.host+':'+worker.port;
+ if(i !== details.workers.length - 1){
+ data += ', \n';
+ }
+ });
+ return data;
+ }
+
+ getDateFormat = (d) => {
+ let obj = new Date(d * 1000);
+ return <span>{obj.toLocaleDateString() + ' ' + obj.toLocaleTimeString()}</span>;
+ }
+
+ handleFilter = (section,e) => {
+ switch(section){
+ case 'spout' : this.setState({spotFilterValue : e.target.value.trim()});
+ break;
+ case 'bolt' : this.setState({blotFilterValue : e.target.value.trim()});
+ break;
+ case 'topologyConfig' : this.setState({topologyFilterValue : e.target.value.trim()});
+ break;
+ default :
+ break;
+ };
+ }
+
+ callBackFunction = (eventKey,tableName) => {
+ switch(tableName){
+ case 'spout' : this.setState({spotActivePage : eventKey});
+ break;
+ case 'bolt' : this.setState({boltsActivePage : eventKey});
+ break;
+ case 'topologyConfig' : this.setState({topologyActivePage : eventKey});
+ break;
+ case 'topologyLag' : this.setState({topologyLagPage : eventKey});
+ break;
+ default :
+ break;
+ };
+ }
+
+ getLinks(){
+ const {details} = this.state;
+ var links = [
+ {link: '#/', title: 'Dashboard'},
+ {link: '#/topology', title: 'Topology Listing'},
+ {link: 'javascript:void(0);', title: details.name? details.name : ""}
+ ];
+ return links;
+ }
+
+ toggleSystem = (toggleStatus) => {
+ let stateObj = _.cloneDeep(this.state);
+ stateObj[toggleStatus] = !stateObj[toggleStatus];
+ this.setState(stateObj,() => {
+ if(toggleStatus === 'debugFlag'){
+ !stateObj.debugFlag ? this.debugEnableConfirmBox(stateObj.debugFlag,'debugModelRef') : this.refs.debugModelRef.show();
+ } else {
+ this.fetchDetails();
+ }
+ });
+ }
+
+ handleModelAction = (modalType,action) => {
+ if(action === 'save'){
+ switch(modalType){
+ case 'debugModelRef' : this.handleDebugSave(modalType,'enable');;
+ break;
+ case 'rebalanceModelRef' : this.handleRebalanceModalSave(modalType);
+ break;
+ case 'killModelRef' : this.handleTopologyKilled(modalType);
+ break;
+ default :
+ break;
+ }
+ } else{
+ switch(modalType){
+ case 'debugModelRef' : Utils.hideFSModal.call(this,modalType,'callBack').then((res) => {
+ this.setState({debugFlag : !this.state.debugFlag});
+ });
+ break;
+ default : Utils.hideFSModal.call(this,modalType);
+ break;
+ }
+ }
+ }
+
+ inputTextChange = (type,e) => {
+ let stateObj = _.cloneDeep(this.state);
+ stateObj[type] = e.target.value;
+ this.setState(stateObj);
+ }
+
+ debugEnableConfirmBox = (confirm,modalType) => {
+ if(!confirm){
+ this.refs.BaseContainer.refs.Confirm.show({title: 'Do you really want to stop debugging this topology ?"'}).then((confirmBox) => {
+ this.setState({debugSimplePCT : 0}, () => {
+ this.handleDebugSave(modalType,'disable');
+ confirmBox.cancel();
+ });
+ }, () => {
+ this.setState({debugFlag : true});
+ });
+ }
+ }
+
+ handleDebugSave = (modal,toEnableFlag) => {
+ const {debugSimplePCT,details} = this.state;
+ Utils.hideFSModal.call(this,modal);
+ TopologyREST.postDebugTopology(details.id,toEnableFlag,debugSimplePCT).then((result) => {
+ if(result.errorMessage !== undefined){
+ this.setState({debugSimplePCT : details.samplingPct});
+ FSReactToastr.error(
+ <CommonNotification flag="error" content={result.errorMessage}/>, '', toastOpt);
+ } else {
+ FSReactToastr.success(<strong>Debugging enabled successfully.</strong>);
+ }
+ });
+ }
+
+ handleRebalanceModalSave = (modalType) => {
+ if(this.refs.rebalanceModal.validateData()){
+ Utils.hideFSModal.call(this,modalType);
+ this.refs.rebalanceModal.handleSave().then((result) => {
+ if(result.errorMessage !== undefined){
+ FSReactToastr.error(
+ <CommonNotification flag="error" content={result.errorMessage}/>, '', toastOpt);
+ } else {
+ this.fetchDetails();
+ clearTimeout(this.clearTimeOut);
+ this.clearTimeOut = setTimeout(function () {
+ FSReactToastr.success(<strong>Topology rebalanced successfully.</strong>);
+ },300);
+ }
+ });
+ }
+ }
+
+ handleTopologyAction = (action) => {
+ if(action === 'activate' || action === 'deactivate'){
+ this.handleTopologyActiveAndDeactive(action);
+ } else if(action === 'rebalance'){
+ this.refs.rebalanceModelRef.show();
+ } else if (action === "kill"){
+ this.refs.killModelRef.show();
+ }
+ }
+
+ handleTopologyKilled = (modalType) => {
+ const {killWaitTime,details} = this.state;
+ Utils.hideFSModal.call(this,modalType);
+ TopologyREST.postActionOnTopology(details.id,'kill',killWaitTime).then((result) => {
+ if(result.errorMessage !== undefined){
+ FSReactToastr.error(
+ <CommonNotification flag="error" content={result.errorMessage}/>, '', toastOpt);
+ } else {
+ clearTimeout(this.clearTimeOutKill);
+ this.clearTimeOutKill = setTimeout(function () {
+ FSReactToastr.success(<strong>"Topology killed successfully."</strong>);
+ },300);
+ }
+ });
+ }
+
+ handleTopologyActiveAndDeactive = (action) => {
+ this.refs.BaseContainer.refs.Confirm.show({title: "Do you really want to "+action+" this topology ?"}).then((confirmBox) => {
+ const {details} = this.state;
+ TopologyREST.postActionOnTopology(details.id,action).then((result) => {
+ if(result.errorMessage !== undefined){
+ FSReactToastr.error(
+ <CommonNotification flag="error" content={result.errorMessage}/>, '', toastOpt);
+ } else {
+ FSReactToastr.success(<strong>{"Topology "+action+"d successfully."}</strong>);
+ }
+ });
+ confirmBox.cancel();
+ }, () => {});
+ }
+
+ handleLogLevel = () => {
+ this.setState({showLogLevel : !this.state.showLogLevel});
+ }
+
+ toggleKafkaLag = (action,event) => {
+ event.stopPropagation();
+ this.setState({toggleGraphAndTable : !this.state.toggleGraphAndTable});
+ }
+
+ lagAccodianClick = () => {
+ this.setState({topologyLagFlag : !this.state.topologyLagFlag});
+ }
+
+ commonOnSelectFunction = (type) => {
+ let tempState = _.cloneDeep(this.state);
+ tempState[type] = !tempState[type];
+ this.setState(tempState);
+ }
+
+ populateLagGraphData = (data) => {
+ let graphArr=[];
+ _.map(data, (t) => {
+ graphArr.push({
+ 'Latest Offset': t.logHeadOffset,
+ 'Spout Committed Offset': t.consumerCommittedOffset,
+ 'spoutId-partition': t.spoutId+'-'+t.partition
+ });
+ });
+ return graphArr;
+ }
+
+ render() {
+ const {details,spotActivePage,boltsActivePage,topologyActivePage,spotFilterValue,blotFilterValue,topologyFilterValue,
+ graphData,selectedWindowKey,windowOptions,systemFlag,debugFlag,debugSimplePCT,killWaitTime,showLogLevel,
+ topologyLagFlag,topologyLagPage,topologyLag,toggleGraphAndTable,expandGraph,expandSpout,expandBolt,expandConfig,onEntervalue} = this.state;
+ const spoutfilteredEntities = Utils.filterByKey(details.spouts || [], spotFilterValue,'spoutId');
+ const blotfilteredEntities = Utils.filterByKey(details.bolts || [], blotFilterValue,'boltId');
+ const topologyfilteredEntities = Utils.filterByKey(_.keys(details.configuration) || [], topologyFilterValue);
+ const spotPaginationObj = {
+ activePage :spotActivePage,
+ pageSize,
+ filteredEntities : spoutfilteredEntities
+ };
+ const boltPaginationObj = {
+ activePage :boltsActivePage,
+ pageSize,
+ filteredEntities : blotfilteredEntities
+ };
+ const topologyPaginationObj = {
+ activePage :topologyActivePage,
+ pageSize,
+ filteredEntities : topologyfilteredEntities
+ };
+ const graphDataObj = _.isEmpty(graphData) && graphData === undefined ? {} : graphData;
+ const topologyStatus = details !== undefined ? details.status : '';
+ const lagPanelHeader = <h4>
+ Kafka Spout Lag
+ <CommonSwitchComponent KYC="kafka" checked={toggleGraphAndTable} textON="Table" textOFF="Graph" switchCallBack={this.toggleKafkaLag.bind(this,'kafkaSpoutLag')} />
+ </h4>;
+
+ const graphPanelHead = <h4> {details.name}
+ <CommonExpanded expandFlag={expandGraph}/></h4>;
+
+ const spoutPanelHead = <h4> Spouts
+ <CommonExpanded expandFlag={expandSpout}/></h4>;
+
+ const boltPanelHead = <h4> Bolts
+ <CommonExpanded expandFlag={expandBolt}/></h4>;
+
+ const configPanelHead = <h4> Topology Configuration
+ <CommonExpanded expandFlag={expandConfig}/></h4>;
+
+ return (
+ <BaseContainer ref="BaseContainer">
+ <Breadcrumbs links={this.getLinks()} />
+ <SearchLogs
+ id={this.props.params.id}
+ />
+ <div className="row">
+ <div className="col-sm-12">
+ <div className="box filter">
+ <div className="box-body form-horizontal">
+ <CommonWindowPanel KYC="detailView" selectedWindowKey={selectedWindowKey} windowOptions={windowOptions} status={topologyStatus} systemFlag={systemFlag} debugFlag={debugFlag} handleWindowChange={this.handleWindowChange.bind(this)} toggleSystem={this.toggleSystem.bind(this)} handleTopologyAction={this.handleTopologyAction.bind(this)} handleLogLevel={this.handleLogLevel.bind(this)} topologyStatus={topologyStatus}/>
+ {
+ showLogLevel
+ ? <LogLevelComponent topologyId={details.id}/>
+ : ''
+ }
+ </div>
+ </div>
+ </div>
+ </div>
+ <div className="row">
+ <div className="col-sm-5">
+ <div className="summary-tile">
+ <div className="summary-title">Topology Summary</div>
+ <div className="summary-body form-horizontal">
+ <div className="form-group">
+ <label className="col-sm-4 control-label">ID:</label>
+ <div className="col-sm-8">
+ <p className="form-control-static">{details.id}</p>
+ </div>
+ </div>
+ <div className="form-group">
+ <label className="col-sm-4 control-label">Owner:</label>
+ <div className="col-sm-8">
+ <p className="form-control-static">{details.owner}</p>
+ </div>
+ </div>
+ <div className="form-group">
+ <label className="col-sm-4 control-label">Status:</label>
+ <div className="col-sm-8">
+ <p className="form-control-static">{details.status}</p>
+ </div>
+ </div>
+ <div className="form-group">
+ <label className="col-sm-4 control-label">Uptime:</label>
+ <div className="col-sm-8">
+ <p className="form-control-static">{details.uptime}</p>
+ </div>
+ </div>
+ <div className="form-group">
+ <label className="col-sm-4 control-label">Workers:</label>
+ <div className="col-sm-8">
+ <p className="form-control-static">{details.workersTotal}</p>
+ </div>
+ </div>
+ <div className="form-group">
+ <label className="col-sm-4 control-label">Executors:</label>
+ <div className="col-sm-8">
+ <p className="form-control-static">{details.executorsTotal}</p>
+ </div>
+ </div>
+ <div className="form-group">
+ <label className="col-sm-4 control-label">Tasks:</label>
+ <div className="col-sm-8">
+ <p className="form-control-static">{details.tasksTotal}</p>
+ </div>
+ </div>
+ <div className="form-group">
+ <label className="col-sm-4 control-label">Memory:</label>
+ <div className="col-sm-8">
+ <p className="form-control-static">{details.assignedTotalMem}</p>
+ </div>
+ </div>
+ <div className="form-group">
+ <label className="col-sm-4 control-label">Worker-Host:Port:</label>
+ <div className="col-sm-8">
+ <p className="form-control-static preformatted">{this.getWorkerData()}</p>
+ </div>
+ </div>
+
+ </div>
+ </div>
+ </div>
+ <div className="col-sm-7">
+ <div className="stats-tile">
+ <div className="stats-title">Topology Stats</div>
+ <div className="stats-body">
+ <Table className="table table-enlarge" noDataText="No records found." currentPage={0} >
+ <Thead>
+ <Th column="windowPretty">
+ <OverlayTrigger placement="top" overlay={<Tooltip id="tooltip1">The past period of time for which the statistics apply.</Tooltip>}>
+ <span>Window</span>
+ </OverlayTrigger>
+ </Th>
+ <Th column="emitted">
+ <OverlayTrigger placement="top" overlay={<Tooltip id="tooltip1">The number of Tuples emitted.</Tooltip>}>
+ <span>Emitted</span>
+ </OverlayTrigger>
+ </Th>
+ <Th column="transferred">
+ <OverlayTrigger placement="top" overlay={<Tooltip id="tooltip1">The number of Tuples emitted that sent to one or more bolts.</Tooltip>}>
+ <span>Transferred</span>
+ </OverlayTrigger>
+ </Th>
+ <Th column="completeLatency">
+ <OverlayTrigger placement="top" overlay={<Tooltip id="tooltip1">The average time a Tuple tree takes to be completely processed by the Topology. A value of 0 is expected if no acking is done.</Tooltip>}>
+ <span>Complete Latency (ms)</span>
+ </OverlayTrigger>
+ </Th>
+ <Th column="acked">
+ <OverlayTrigger placement="top" overlay={<Tooltip id="tooltip1">The number of Tuple trees successfully processed. A value of 0 is expected if no acking is done.</Tooltip>}>
+ <span>Acked</span>
+ </OverlayTrigger>
+ </Th>
+ <Th column="failed">
+ <OverlayTrigger placement="top" overlay={<Tooltip id="tooltip1">The number of Tuple trees that were explicitly failed or timed out before acking was completed. A value of 0 is expected if no acking is done.</Tooltip>}>
+ <span>Failed</span>
+ </OverlayTrigger>
+ </Th>
+ </Thead>
+ {
+ _.map(details.topologyStats,(s,i) => {
+ return(
+ <Tr key={i}>
+ <Td column="windowPretty">{s.windowPretty}</Td>
+ <Td column="emitted">{s.emitted}</Td>
+ <Td column="transferred">{s.transferred}</Td>
+ <Td column="completeLatency">{s.completeLatency}</Td>
+ <Td column="acked">{s.acked}</Td>
+ <Td column="failed">{s.failed}</Td>
+ </Tr>
+ );
+ })
+ }
+ </Table>
+ </div>
+ </div>
+ </div>
+ </div>
+ <Panel expanded={expandGraph} collapsible header={graphPanelHead} eventKey="1" onSelect={this.commonOnSelectFunction.bind(this,'expandGraph')}>
+ <div className="graph-bg">
+ <TopologyGraph
+ data={graphDataObj}
+ />
+ </div>
+ </Panel>
+ {
+ topologyLag.length
+ ? <Panel expanded={true} collapsible header={lagPanelHeader} eventKey="2" onSelect={this.lagAccodianClick.bind(this)}>
+ {
+ toggleGraphAndTable
+ ? <Table className="table table-striped table-bordered" noDataText="No data found !" currentPage={topologyLagPage-1} itemsPerPage={pageSize}>
+ <Thead>
+ <Th column="spoutId">
+ <OverlayTrigger placement="bottom" overlay={<Tooltip id="tooltip1">Id</Tooltip>}>
+ <span>Id</span>
+ </OverlayTrigger>
+ </Th>
+ <Th column="topic">
+ <OverlayTrigger placement="bottom" overlay={<Tooltip id="tooltip1">Topic</Tooltip>}>
+ <span>Topic</span>
+ </OverlayTrigger>
+ </Th>
+ <Th column="partition">
+ <OverlayTrigger placement="bottom" overlay={<Tooltip id="tooltip1">Partition</Tooltip>}>
+ <span>Partition</span>
+ </OverlayTrigger>
+ </Th>
+ <Th column="logHeadOffset">
+ <OverlayTrigger placement="bottom" overlay={<Tooltip id="tooltip1">Latest Offset</Tooltip>}>
+ <span>Latest Offset</span>
+ </OverlayTrigger>
+ </Th>
+ <Th column="consumerCommittedOffset">
+ <OverlayTrigger placement="bottom" overlay={<Tooltip id="tooltip1">Spout Committed Offset</Tooltip>}>
+ <span>Spout Committed Offset</span>
+ </OverlayTrigger>
+ </Th>
+ <Th column="lag">
+ <OverlayTrigger placement="bottom" overlay={<Tooltip id="tooltip1">Lag</Tooltip>}>
+ <span>Lag</span>
+ </OverlayTrigger>
+ </Th>
+ </Thead>
+ {
+ _.map(topologyLag , (l, i) => {
+ return <Tr key={i}>
+ <Td column="spoutId">{l.spoutId}</Td>
+ <Td column="topic">{l.topic}</Td>
+ <Td column="partition">{l.partition}</Td>
+ <Td column="logHeadOffset">{l.logHeadOffset}</Td>
+ <Td column="consumerCommittedOffset">{l.consumerCommittedOffset}</Td>
+ <Td column="lag">{l.lag}</Td>
+ </Tr>;
+ })
+ }
+ </Table>
+ : <div id="lag-graph">
+ <BarChart
+ ref="barChart"
+ width={window != window.parent ? 1100 : 1300}
+ height={400}
+ xAttr="spoutId-partition"
+ yAttr="count"
+ data={this.populateLagGraphData(topologyLag)}
+ />
+ </div>
+ }
+
+
+ </Panel>
+ : null
+ }
+ <Panel expanded={expandSpout} collapsible header={spoutPanelHead} eventKey="3" onSelect={this.commonOnSelectFunction.bind(this,'expandSpout')}>
+ <div className="input-group col-sm-4">
+ <input type="text" onKeyUp={this.handleFilter.bind(this,'spout')} className="form-control" placeholder="Search By Id" />
+ <span className="input-group-btn">
+ <button className="btn btn-primary" type="button"><i className="fa fa-search"></i></button>
+ </span>
+ </div>
+ <div className="table-responsive">
+ <Table className="table no-margin" noDataText="No spouts found !" currentPage={spotActivePage-1} itemsPerPage={pageSize}>
+ <Thead>
+ <Th column="spoutId">
+ <OverlayTrigger placement="bottom" overlay={<Tooltip id="tooltip1">The ID assigned to a the Component by the Topology. Click on the name to view the Component's page.</Tooltip>}>
+ <span>Id</span>
+ </OverlayTrigger>
+ </Th>
+ <Th column="executors">
+ <OverlayTrigger placement="bottom" overlay={<Tooltip id="tooltip1">Executors are threads in a Worker process.</Tooltip>}>
+ <span>Executors</span>
+ </OverlayTrigger>
+ </Th>
+ <Th column="tasks">
+ <OverlayTrigger placement="bottom" overlay={<Tooltip id="tooltip1">A Task is an instance of a Bolt or Spout. The number of Tasks is almost always equal to the number of Executors.</Tooltip>}>
+ <span>Tasks</span>
+ </OverlayTrigger>
+ </Th>
+ <Th column="emitted">
+ <OverlayTrigger placement="bottom" overlay={<Tooltip id="tooltip1">The number of Tuples emitted.</Tooltip>}>
+ <span>Emitted</span>
+ </OverlayTrigger>
+ </Th>
+ <Th column="transferred">
+ <OverlayTrigger placement="bottom" overlay={<Tooltip id="tooltip1">The number of Tuples emitted that sent to one or more bolts.</Tooltip>}>
+ <span>Transferred</span>
+ </OverlayTrigger>
+ </Th>
+ <Th column="completeLatency">
+ <OverlayTrigger placement="bottom" overlay={<Tooltip id="tooltip1">The average time a Tuple tree takes to be completely processed by the Topology. A value of 0 is expected if no acking is done.</Tooltip>}>
+ <span>Complete Latency (ms)</span>
+ </OverlayTrigger>
+ </Th>
+ <Th column="acked" title="">
+ <OverlayTrigger placement="bottom" overlay={<Tooltip id="tooltip1">The number of Tuple trees successfully processed. A value of 0 is expected if no acking is done.</Tooltip>}>
+ <span>Acked</span>
+ </OverlayTrigger>
+ </Th>
+ <Th column="failed">
+ <OverlayTrigger placement="bottom" overlay={<Tooltip id="tooltip1">The number of Tuple trees that were explicitly failed or timed out before acking was completed. A value of 0 is expected if no acking is done.</Tooltip>}>
+ <span>Failed</span>
+ </OverlayTrigger>
+ </Th>
+ <Th column="errorHost">
+ <OverlayTrigger placement="bottom" overlay={<Tooltip id="tooltip1">Error Host:Port</Tooltip>}>
+ <span>Error Host:Port</span>
+ </OverlayTrigger>
+ </Th>
+ <Th column="lastError">
+ <OverlayTrigger placement="bottom" overlay={<Tooltip id="tooltip1">Last Error</Tooltip>}>
+ <span>Last Error</span>
+ </OverlayTrigger>
+ </Th>
+ <Th column="errorTime">
+ <OverlayTrigger placement="bottom" overlay={<Tooltip id="tooltip1">Error Time</Tooltip>}>
+ <span>Error Time</span>
+ </OverlayTrigger>
+ </Th>
+ </Thead>
+ {
+ _.map(spoutfilteredEntities, (s,i) => {
+ return(
+ <Tr key={i}>
+ <Td column="spoutId"><Link to={`/topology/${details.id}/component/${s.spoutId}`}>{s.spoutId}</Link></Td>
+ <Td column="executors">{s.executors}</Td>
+ <Td column="tasks">{s.tasks}</Td>
+ <Td column="emitted">{s.emitted}</Td>
+ <Td column="transferred">{s.transferred}</Td>
+ <Td column="completeLatency">{s.completeLatency}</Td>
+ <Td column="acked">{s.acked}</Td>
+ <Td column="failed">{s.failed}</Td>
+ <Td column="errorHost">{s.errorHost !== '' ? s.errorHost+s.errorPort : '' }</Td>
+ <Td column="lastError">{s.lastError}</Td>
+ <Td column="errorTime">{s.errorTime !== null && s.errorTime !== 0 ? this.getDateFormat(s.errorTime) : '' }</Td>
+ </Tr>
+ );
+ })
+ }
+ </Table>
+ </div>
+ {
+ spoutfilteredEntities.length !== 0
+ ? <CommonPagination {...spotPaginationObj} callBackFunction={this.callBackFunction.bind(this)} tableName="spout"/>
+ : ''
+ }
+ </Panel>
+ <Panel expanded={expandBolt} collapsible header={boltPanelHead} eventKey="4" onSelect={this.commonOnSelectFunction.bind(this,'expandBolt')}>
+ <div className="input-group col-sm-4">
+ <input type="text" onKeyUp={this.handleFilter.bind(this,'bolt')} className="form-control" placeholder="Search By Id" />
+ <span className="input-group-btn">
+ <button className="btn btn-primary" type="button"><i className="fa fa-search"></i></button>
+ </span>
+ </div>
+ <div className="table-responsive">
+ <Table className="table no-margin" noDataText="No bolts found !" currentPage={boltsActivePage-1} itemsPerPage={pageSize}>
+ <Thead>
+ <Th column="boltId">
+ <OverlayTrigger placement="bottom" overlay={<Tooltip id="tooltip1">The ID assigned to a the Component by the Topology. Click on the name to view the Component's page.</Tooltip>}>
+ <span>Id</span>
+ </OverlayTrigger>
+ </Th>
+ <Th column="executors">
+ <OverlayTrigger placement="bottom" overlay={<Tooltip id="tooltip1">Executors are threads in a Worker process.</Tooltip>}>
+ <span>Executors</span>
+ </OverlayTrigger>
+ </Th>
+ <Th column="tasks">
+ <OverlayTrigger placement="bottom" overlay={<Tooltip id="tooltip1">A Task is an instance of a Bolt or Spout. The number of Tasks is almost always equal to the number of Executors.</Tooltip>}>
+ <span>Tasks</span>
+ </OverlayTrigger>
+ </Th>
+ <Th column="emitted">
+ <OverlayTrigger placement="bottom" overlay={<Tooltip id="tooltip1">The number of Tuples emitted.</Tooltip>}>
+ <span>Emitted</span>
+ </OverlayTrigger>
+ </Th>
+ <Th column="transferred">
+ <OverlayTrigger placement="bottom" overlay={<Tooltip id="tooltip1">The number of Tuples emitted that sent to one or more bolts.</Tooltip>}>
+ <span>Transferred</span>
+ </OverlayTrigger>
+ </Th>
+ <Th column="capacity">
+ <OverlayTrigger placement="bottom" overlay={<Tooltip id="tooltip1">If this is around 1.0, the corresponding Bolt is running as fast as it can, so you may want to increase the Bolt's parallelism. This is (number executed * average execute latency) / measurement time.</Tooltip>}>
+ <span>Capacity (last 10m)</span>
+ </OverlayTrigger>
+ </Th>
+ <Th column="executeLatency">
+ <OverlayTrigger placement="bottom" overlay={<Tooltip id="tooltip1">The average time a Tuple spends in the execute method. The execute method may complete without sending an Ack for the tuple.</Tooltip>}>
+ <span>Execute Latency (ms)</span>
+ </OverlayTrigger>
+ </Th>
+ <Th column="executed">
+ <OverlayTrigger placement="bottom" overlay={<Tooltip id="tooltip1">The number of incoming Tuples processed.</Tooltip>}>
+ <span>Executed</span>
+ </OverlayTrigger>
+ </Th>
+ <Th column="processLatency">
+ <OverlayTrigger placement="bottom" overlay={<Tooltip id="tooltip1">The average time it takes to Ack a Tuple after it is first received. Bolts that join, aggregate or batch may not Ack a tuple until a number of other Tuples have been received.</Tooltip>}>
+ <span>Process Latency (ms)</span>
+ </OverlayTrigger>
+ </Th>
+ <Th column="acked">
+ <OverlayTrigger placement="bottom" overlay={<Tooltip id="tooltip1">The number of Tuples acknowledged by this Bolt.</Tooltip>}>
+ <span>Acked</span>
+ </OverlayTrigger>
+ </Th>
+ <Th column="failed">
+ <OverlayTrigger placement="bottom" overlay={<Tooltip id="tooltip1">The number of tuples Failed by this Bolt.</Tooltip>}>
+ <span>Failed</span>
+ </OverlayTrigger>
+ </Th>
+ <Th column="errorHost">
+ <OverlayTrigger placement="bottom" overlay={<Tooltip id="tooltip1">Error Host:Port</Tooltip>}>
+ <span>Error Host:Port</span>
+ </OverlayTrigger>
+ </Th>
+ <Th column="lastError">
+ <OverlayTrigger placement="bottom" overlay={<Tooltip id="tooltip1">Last Error</Tooltip>}>
+ <span>Last Error</span>
+ </OverlayTrigger>
+ </Th>
+ <Th column="errorTime">
+ <OverlayTrigger placement="bottom" overlay={<Tooltip id="tooltip1">Error Time</Tooltip>}>
+ <span>Error Time</span>
+ </OverlayTrigger>
+ </Th>
+ </Thead>
+ {
+ _.map(blotfilteredEntities, (b,k) => {
+ return(
+ <Tr key={k}>
+ <Td column="boltId"><Link to={`/topology/${details.id}/component/${b.boltId}`}>{b.boltId}</Link></Td>
+ <Td column="executors">{b.executors}</Td>
+ <Td column="tasks">{b.tasks}</Td>
+ <Td column="emitted">{b.emitted}</Td>
+ <Td column="transferred">{b.transferred}</Td>
+ <Td column="capacity">{b.capacity}</Td>
+ <Td column="executeLatency">{b.executeLatency}</Td>
+ <Td column="executed">{b.executed}</Td>
+ <Td column="processLatency">{b.processLatency}</Td>
+ <Td column="acked">{b.acked}</Td>
+ <Td column="failed">{b.failed}</Td>
+ <Td column="errorHost">{b.errorHost !== '' ? b.errorHost+b.errorPort : '' }</Td>
+ <Td column="lastError">{b.lastError}</Td>
+ <Td column="errorTime">{b.errorTime !== null && b.errorTime !== 0 ? this.getDateFormat(b.errorTime) : '' }</Td>
+ </Tr>
+ );
+ })
+ }
+ </Table>
+ </div>
+ {
+ blotfilteredEntities.length !== 0
+ ? <CommonPagination {...boltPaginationObj} callBackFunction={this.callBackFunction.bind(this)} tableName="bolt"/>
+ : ''
+ }
+ </Panel>
+ <Panel expanded={expandConfig} collapsible header={configPanelHead} eventKey="5" onSelect={this.commonOnSelectFunction.bind(this,'expandConfig')}>
+ <div className="input-group col-sm-4">
+ <input type="text" onKeyUp={this.handleFilter.bind(this,'topologyConfig')} className="form-control" placeholder="Search By Key" />
+ <span className="input-group-btn">
+ <button className="btn btn-primary" type="button"><i className="fa fa-search"></i></button>
+ </span>
+ </div>
+ <Table className="table no-margin" noDataText="No topology configuration found !" currentPage={topologyActivePage-1} itemsPerPage={pageSize}>
+ <Thead>
+ <Th column="Key">Key</Th>
+ <Th column="value">Value</Th>
+ </Thead>
+ {
+ _.map(topologyfilteredEntities, (k,t) => {
+ return(
+ <Tr key={t}>
+ <Td column="Key">{k}</Td>
+ <Td column="value">{details.configuration[k]}</Td>
+ </Tr>
+ );
+ })
+ }
+ </Table>
+ {
+ topologyfilteredEntities.length !== 0
+ ? <CommonPagination {...topologyPaginationObj} callBackFunction={this.callBackFunction.bind(this)} tableName="topologyConfig"/>
+ : ''
+ }
+ </Panel>
+
+ {/*Model start here*/}
+ <Modal ref={"debugModelRef"} data-title="Do you really want to debug this topology ? If yes, please, specify sampling percentage." data-resolve={this.handleModelAction.bind(this,'debugModelRef','save')} data-reject={this.handleModelAction.bind(this,'debugModelRef','hide')}>
+ <input className="form-control" type="number" min={0} max={Number.MAX_SAFE_INTEGER} value={debugSimplePCT} onChange={this.inputTextChange.bind(this,'debugSimplePCT')}/>
+ </Modal>
+
+ <Modal ref={"killModelRef"} data-title="Are you sure you want to kill this topology ? If yes, please, specify wait time in seconds." data-resolve={this.handleModelAction.bind(this,'killModelRef','save')} data-reject={this.handleModelAction.bind(this,'killModelRef','hide')}>
+ <input className="form-control" type="number" min={0} max={Number.MAX_SAFE_INTEGER} value={killWaitTime} onChange={this.inputTextChange.bind(this,'killWaitTime')}/>
+ </Modal>
+
+ <Modal ref={"rebalanceModelRef"} data-title="Rebalance Topology" data-resolve={this.handleModelAction.bind(this,'rebalanceModelRef','save')} data-reject={this.handleModelAction.bind(this,'rebalanceModelRef','hide')}>
+ <RebalanceTopology ref={"rebalanceModal"} topologyId={details.id} spoutArr={details.spouts} boltArr={details.bolts} topologyExecutors={details.workersTotal}/>
+ </Modal>
+
+ </BaseContainer>);
+ }
+}
http://git-wip-us.apache.org/repos/asf/ambari/blob/0c188aea/contrib/views/storm/src/main/resources/ui/app/scripts/containers/TopologyListing.jsx
----------------------------------------------------------------------
diff --git a/contrib/views/storm/src/main/resources/ui/app/scripts/containers/TopologyListing.jsx b/contrib/views/storm/src/main/resources/ui/app/scripts/containers/TopologyListing.jsx
new file mode 100644
index 0000000..104a253
--- /dev/null
+++ b/contrib/views/storm/src/main/resources/ui/app/scripts/containers/TopologyListing.jsx
@@ -0,0 +1,222 @@
+/**
+ Licensed to the Apache Software Foundation (ASF) under one
+ or more contributor license agreements. See the NOTICE file
+ distributed with this work for additional information
+ regarding copyright ownership. The ASF licenses this file
+ to you under the Apache License, Version 2.0 (the
+ "License"); you may not use this file except in compliance
+ with the License. You may obtain a copy of the License at
+*
+ http://www.apache.org/licenses/LICENSE-2.0
+*
+ Unless required by applicable law or agreed to in writing, software
+ distributed under the License is distributed on an "AS IS" BASIS,
+ WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ See the License for the specific language governing permissions and
+ limitations under the License.
+**/
+
+import React, {Component} from 'react';
+import _ from 'lodash';
+import {
+ Table,
+ Thead,
+ Th,
+ Tr,
+ Td,
+ unsafe
+} from 'reactable';
+import FSReactToastr from '../components/FSReactToastr';
+import {toastOpt} from '../utils/Constants';
+import TopologyREST from '../rest/TopologyREST';
+import CommonNotification from '../components/CommonNotification';
+import {Link} from 'react-router';
+import {OverlayTrigger, Tooltip} from 'react-bootstrap';
+import Breadcrumbs from '../components/Breadcrumbs';
+import CommonPagination from '../components/CommonPagination';
+import {pageSize} from '../utils/Constants';
+import Utils from '../utils/Utils';
+import Footer from '../components/Footer';
+
+export default class TopologyListing extends Component{
+ constructor(props){
+ super(props);
+ this.fetchData();
+ this.state = {
+ entities : [],
+ filterValue: '',
+ activePage: 1
+ };
+ }
+
+ fetchData = () => {
+ TopologyREST.getSummary('topology').then((results) => {
+ if(results.errorMessage !== undefined){
+ FSReactToastr.error(
+ <CommonNotification flag="error" content={results.errorMessage}/>, '', toastOpt);
+ } else {
+ let stateObj={};
+ stateObj.entities = results.topologies;
+ if(!this.props.fromDashboard){
+ var additionalColumns = [
+ {name: 'assignedTotalMem', title: 'Memory Assigned (MB)'},
+ {name: 'workersTotal', title: 'Workers'},
+ {name: 'executorsTotal', title: 'Executors'},
+ {name: 'tasksTotal', title: 'Tasks'},
+ {name: 'owner', title: 'Owner'}
+ ];
+ Array.prototype.push.apply(stateObj.entities, additionalColumns);
+ }
+ this.setState({entities : stateObj.entities});
+ }
+ });
+ }
+
+ getLinks(){
+ var links = [
+ {link: '#/', title: 'Dashboard'},
+ {link: '#/topology', title: 'Topology Listing'}
+ ];
+ return links;
+ }
+
+ activeClass = (status) => {
+ let classname="label ";
+ switch(status){
+ case 'ACTIVE':
+ classname += "label-success";
+ break;
+ case 'INACTIVE':
+ classname += "label-default";
+ break;
+ case 'REBALANCING':
+ classname += "label-warning";
+ break;
+ case 'KILLED':
+ classname += "label-danger";
+ break;
+ default:
+ classname += "label-primary";
+ break;
+ }
+ return classname;
+ }
+
+ handleFilter = (e) => {
+ this.setState({filterValue: e.target.value.trim()});
+ }
+
+ callBackFunction = (eventKey) => {
+ this.setState({activePage : eventKey});
+ }
+
+ render(){
+ const {entities, filterValue, activePage} = this.state;
+ const {fromDashboard} = this.props;
+ const topologies = _.filter(entities, (e)=>{return e.id !== undefined;});
+ const filteredEntities = Utils.filterByKey(topologies, filterValue, 'name');
+ const paginationObj = {
+ activePage,
+ pageSize,
+ filteredEntities
+ };
+ return(
+ <div className={fromDashboard ? "" : "container-fluid"}>
+ {!fromDashboard ? <Breadcrumbs links={this.getLinks()} /> : ''}
+ <div className="box">
+ <div className="box-header">
+ <h4>Topology Listing</h4>
+ {fromDashboard ?
+ <div className="box-control">
+ <a className="primary" href="#/topology"><i className="fa fa-external-link"></i></a>
+ </div>
+ : ''}
+ </div>
+ <div className={fromDashboard ? "box-body paddless" : "box-body"}>
+ {!fromDashboard ?
+ <div className="input-group col-sm-4">
+ <input type="text" onKeyUp={this.handleFilter} className="form-control" placeholder="Search By Topology Name" />
+ <span className="input-group-btn">
+ <button className="btn btn-primary" type="button"><i className="fa fa-search"></i></button>
+ </span>
+ </div>
+ : ''}
+ <Table className="table topology-table" noDataText="No topology found." currentPage={0} >
+ <Thead>
+ <Th column="topologyName"><OverlayTrigger placement="bottom" overlay={<Tooltip id="tooltip1">The name given to the topology by when it was submitted. Click the name to view the Topology's information.</Tooltip>}><span>Topology Name</span></OverlayTrigger></Th>
+ <Th column="status"><OverlayTrigger placement="bottom" overlay={<Tooltip id="tooltip1">The status can be one of ACTIVE, INACTIVE, KILLED, or REBALANCING.</Tooltip>}><span>Status</span></OverlayTrigger></Th>
+ {
+ !fromDashboard
+ ? [
+ <Th key={3} column="assignedTotalMem">
+ <OverlayTrigger placement="bottom" overlay={<Tooltip id="tooltip1">Assigned Total Memory by Scheduler.</Tooltip>}>
+ <span>Memory Assigned (MB)</span>
+ </OverlayTrigger></Th>,
+ <Th key={4} column="workersTotal">
+ <OverlayTrigger placement="bottom" overlay={<Tooltip id="tooltip1">The number of Workers (processes).</Tooltip>}>
+ <span>Workers</span>
+ </OverlayTrigger>
+ </Th>,
+ <Th key={5} column="executorsTotal">
+ <OverlayTrigger placement="bottom" overlay={<Tooltip id="tooltip1">Executors are threads in a Worker process.</Tooltip>}>
+ <span>Executors</span>
+ </OverlayTrigger>
+ </Th>,
+ <Th key={6} column="tasksTotal">
+ <OverlayTrigger placement="bottom" overlay={<Tooltip id="tooltip1">A Task is an instance of a Bolt or Spout. The number of Tasks is almost always equal to the number of Executors.</Tooltip>}>
+ <span>Tasks</span>
+ </OverlayTrigger>
+ </Th>,
+ <Th key={7} column="owner" title="">
+ <OverlayTrigger placement="bottom" overlay={<Tooltip id="tooltip1">The user that submitted the Topology, if authentication is enabled.</Tooltip>}>
+ <span>Owner</span>
+ </OverlayTrigger>
+ </Th>,
+ <Th key={8} column="uptime">
+ <OverlayTrigger placement="bottom" overlay={<Tooltip id="tooltip1">The time since the Topology was submitted.</Tooltip>}>
+ <span>Uptime</span>
+ </OverlayTrigger>
+ </Th>
+ ]
+ : <Th column="uptime"><OverlayTrigger placement="bottom" overlay={<Tooltip id="tooltip1">The time since the Topology was submitted.</Tooltip>}><span>Uptime</span></OverlayTrigger></Th>
+ }
+ </Thead>
+ {
+ _.map(filteredEntities, (entity, i) => {
+ return (
+ <Tr key={i}>
+ <Td column="topologyName"><Link to={"topology/"+entity.id}>{entity.name}</Link></Td>
+ <Td column="status"><span className={this.activeClass(entity.status)}>{entity.status}</span></Td>
+ {
+ !fromDashboard
+ ? [
+ <Td key={i+'assignedTotalMem'} column="assignedTotalMem">{entity.assignedTotalMem}</Td>,
+ <Td key={i+'workersTotal'} column="workersTotal">{entity.workersTotal}</Td>,
+ <Td key={i+'executorsTotal'} column="executorsTotal">{entity.executorsTotal}</Td>,
+ <Td key={i+'tasksTotal'} column="tasksTotal">{entity.tasksTotal}</Td>,
+ <Td key={i+'owner'} column="owner">{entity.owner}</Td>
+ ]
+ : ''
+ }
+ <Td column="uptime"><small>{entity.uptime}</small></Td>
+ </Tr>
+ );
+ })
+ }
+ </Table>
+ {
+ !fromDashboard && filteredEntities.length !== 0
+ ? <CommonPagination {...paginationObj} callBackFunction={this.callBackFunction.bind(this)}/>
+ : ''
+ }
+ </div>
+ </div>
+ {
+ !fromDashboard
+ ? <Footer />
+ : null
+ }
+ </div>
+ );
+ }
+}
http://git-wip-us.apache.org/repos/asf/ambari/blob/0c188aea/contrib/views/storm/src/main/resources/ui/app/scripts/rest/TopologyREST.js
----------------------------------------------------------------------
diff --git a/contrib/views/storm/src/main/resources/ui/app/scripts/rest/TopologyREST.js b/contrib/views/storm/src/main/resources/ui/app/scripts/rest/TopologyREST.js
new file mode 100644
index 0000000..d4627cf
--- /dev/null
+++ b/contrib/views/storm/src/main/resources/ui/app/scripts/rest/TopologyREST.js
@@ -0,0 +1,118 @@
+/**
+ Licensed to the Apache Software Foundation (ASF) under one
+ or more contributor license agreements. See the NOTICE file
+ distributed with this work for additional information
+ regarding copyright ownership. The ASF licenses this file
+ to you under the Apache License, Version 2.0 (the
+ "License"); you may not use this file except in compliance
+ with the License. You may obtain a copy of the License at
+*
+ http://www.apache.org/licenses/LICENSE-2.0
+*
+ Unless required by applicable law or agreed to in writing, software
+ distributed under the License is distributed on an "AS IS" BASIS,
+ WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ See the License for the specific language governing permissions and
+ limitations under the License.
+**/
+
+import fetch from 'isomorphic-fetch';
+import {baseUrl} from '../utils/Constants';
+
+const topology = 'topology';
+const cluster = 'cluster';
+
+const TopologyREST = {
+ getSummary(entity,options) {
+ options = options || {};
+ options.method = options.method || 'GET';
+ return this.requestCall(baseUrl+entity+'/summary', options);
+ },
+ getClusterConfig(options) {
+ options = options || {};
+ options.method = options.method || 'GET';
+ return this.requestCall(baseUrl+'cluster/configuration', options);
+ },
+ getTopologyGraphData(id,windowSize,options) {
+ options = options || {};
+ options.method = options.method || 'GET';
+ return this.requestCall(baseUrl+'topology/'+id+'/visualization?window='+windowSize, options);
+ },
+ getTopologyDetails(id,windowSize,systemFlag, options){
+ options = options || {};
+ options.method = options.method || 'GET';
+ let url = baseUrl+'topology/'+id+'?window='+windowSize;
+ if(systemFlag !== '' && systemFlag !== undefined){
+ url += '&sys='+systemFlag;
+ }
+ return this.requestCall(url, options);
+ },
+ getTopologyComponentDetail(TopId, CompName,windowSize,systemFlag, options){
+ options = options || {};
+ options.method = options.method || 'GET';
+ let url = baseUrl+'topology/'+TopId+'/component/'+CompName+'?window='+windowSize;
+ if(systemFlag !== '' && systemFlag !== undefined){
+ url += '&sys='+systemFlag;
+ }
+ return this.requestCall(url, options);
+ },
+ getLogConfig(id,options) {
+ options = options || {};
+ options.method = options.method || 'GET';
+ return this.requestCall(baseUrl+'topology/'+id+'/logconfig', options);
+ },
+ postLogConfig(id,options){
+ options = options || {};
+ options.method = options.method || 'POST';
+ options.headers = options.headers || {
+ 'Content-Type': 'application/json',
+ 'Accept': 'application/json'
+ };
+ return this.requestCall(baseUrl+'topology/'+id+'/logconfig', options);
+ },
+ postDebugTopology(id,type,percent,options){
+ options = options || {};
+ options.method = options.method || 'POST';
+ options.headers = options.headers || {
+ 'Content-Type': 'application/json',
+ 'Accept': 'application/json'
+ };
+ return this.requestCall(baseUrl+'topology/'+id+'/debug/'+type+'/'+percent,options);
+ },
+ postActionOnTopology(id,type,waitTime,options){
+ options = options || {};
+ options.method = options.method || 'POST';
+ options.headers = options.headers || {
+ 'Content-Type': 'application/json',
+ 'Accept': 'application/json'
+ };
+ let url = baseUrl+'topology/'+id+'/'+type;
+ if(!!waitTime){
+ url += '/'+waitTime;
+ }
+ return this.requestCall(url,options);
+ },
+ getTopologyLag(id,options) {
+ options = options || {};
+ options.method = options.method || 'GET';
+ return this.requestCall(baseUrl+'topology/'+id+'/lag', options);
+ },
+ getProfiling(id,type,hostPort,options) {
+ options = options || {};
+ options.method = options.method || 'GET';
+ return this.requestCall(baseUrl+'topology/'+id+'/profiling/'+type+'/'+hostPort, options);
+ },
+ requestCall(url, options){
+ let urlPart = url.split('url=')[0];
+ let stormUrlPart = url.split('url=')[1];
+ urlPart += 'url=' + encodeURIComponent(stormUrlPart);
+ url = urlPart;
+ options.credentials = 'same-origin';
+ return fetch(url, options)
+ .then((response) => {
+ return response.json();
+ });
+ }
+};
+
+export default TopologyREST;
http://git-wip-us.apache.org/repos/asf/ambari/blob/0c188aea/contrib/views/storm/src/main/resources/ui/app/scripts/routers/routes.jsx
----------------------------------------------------------------------
diff --git a/contrib/views/storm/src/main/resources/ui/app/scripts/routers/routes.jsx b/contrib/views/storm/src/main/resources/ui/app/scripts/routers/routes.jsx
new file mode 100644
index 0000000..a5d1958
--- /dev/null
+++ b/contrib/views/storm/src/main/resources/ui/app/scripts/routers/routes.jsx
@@ -0,0 +1,68 @@
+/**
+ Licensed to the Apache Software Foundation (ASF) under one
+ or more contributor license agreements. See the NOTICE file
+ distributed with this work for additional information
+ regarding copyright ownership. The ASF licenses this file
+ to you under the Apache License, Version 2.0 (the
+ "License"); you may not use this file except in compliance
+ with the License. You may obtain a copy of the License at
+*
+ http://www.apache.org/licenses/LICENSE-2.0
+*
+ Unless required by applicable law or agreed to in writing, software
+ distributed under the License is distributed on an "AS IS" BASIS,
+ WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ See the License for the specific language governing permissions and
+ limitations under the License.
+**/
+
+import React, {Component} from 'react';
+import {Router, Route, hashHistory, browserHistory, IndexRoute} from 'react-router';
+import Dashboard from '../containers/Dashboard';
+import TopologyListing from '../containers/TopologyListing';
+import SupervisorSummary from '../containers/SupervisorSummary';
+import NimbusSummary from '../containers/NimbusSummary';
+import TopologyDetailView from '../containers/TopologyDetailView';
+import ComponentDetailView from '../containers/ComponentDetailView';
+
+const onEnter = (nextState, replace, callback) => {
+ callback();
+ shareUrl();
+};
+
+const shareUrl = () => {
+ if(window != window.parent){
+ var parentWindow = window.parent;
+ var parentHash = parentWindow.location.hash.split("?")[0];
+ var newurl = parentWindow.location.protocol + "//" + parentWindow.location.host + parentHash + '?viewpath='+encodeURIComponent(location.hash);
+ parentWindow.history.replaceState({path:newurl},'',newurl);
+ }
+};
+
+const getParameterByName = (name) => {
+ name = name.replace(/[\[]/, "\\[").replace(/[\]]/, "\\]");
+ var regex = new RegExp("[\\?&]" + name + "=([^&#]*)"),
+ results = regex.exec(location.search);
+ return results === null ? "" : decodeURIComponent(results[1].replace(/\+/g, " "));
+};
+
+function getInitialRoute(){
+ if(window != window.parent){
+ var viewPath = getParameterByName("viewpath");
+ location.hash = viewPath ? viewPath : '';
+ }
+}
+getInitialRoute();
+
+export default(
+ <Route path="/" component={null} name="Home" onEnter={onEnter}>
+ <IndexRoute name="" component={Dashboard} onEnter={onEnter}/>
+ <Route path="topology" name="TopologyListing" component={null} onEnter={onEnter}>
+ <IndexRoute name="TopologyListing" component={TopologyListing} onEnter={onEnter}/>
+ <Route path=":id" name="TopologyDetailView" component={TopologyDetailView} onEnter={onEnter}/>
+ <Route path=":id/component/:name" name="TopologyDetailView" component={ComponentDetailView} onEnter={onEnter}/>
+ </Route>
+ <Route path="supervisor" name="SupervisorSummary" component={SupervisorSummary} onEnter={onEnter}/>
+ <Route path="nimbus" name="NimbusSummary" component={NimbusSummary} onEnter={onEnter}/>
+ </Route>
+);
http://git-wip-us.apache.org/repos/asf/ambari/blob/0c188aea/contrib/views/storm/src/main/resources/ui/app/scripts/utils/Utils.js
----------------------------------------------------------------------
diff --git a/contrib/views/storm/src/main/resources/ui/app/scripts/utils/Utils.js b/contrib/views/storm/src/main/resources/ui/app/scripts/utils/Utils.js
new file mode 100644
index 0000000..5a823f6
--- /dev/null
+++ b/contrib/views/storm/src/main/resources/ui/app/scripts/utils/Utils.js
@@ -0,0 +1,51 @@
+/**
+ Licensed to the Apache Software Foundation (ASF) under one
+ or more contributor license agreements. See the NOTICE file
+ distributed with this work for additional information
+ regarding copyright ownership. The ASF licenses this file
+ to you under the Apache License, Version 2.0 (the
+ "License"); you may not use this file except in compliance
+ with the License. You may obtain a copy of the License at
+*
+ http://www.apache.org/licenses/LICENSE-2.0
+*
+ Unless required by applicable law or agreed to in writing, software
+ distributed under the License is distributed on an "AS IS" BASIS,
+ WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ See the License for the specific language governing permissions and
+ limitations under the License.
+**/
+
+import React from 'react';
+import _ from 'lodash';
+
+const filterByKey = function(entities, filterValue,entity) {
+ let matchFilter = new RegExp(filterValue, 'i');
+ return entities.filter(filteredList => !filterValue || _.isEmpty(entity) ? matchFilter.test(filteredList) : matchFilter.test(filteredList[entity]));
+};
+
+const hideFSModal = function(modal,callback){
+ this.refs[modal].hide();
+ if(!!callback){
+ return new Promise((resolve,reject) => {
+ return resolve(callback);
+ });
+ }
+};
+
+const populateWindowsOptions = function(optionsArr){
+ let options=[];
+ _.map(optionsArr, (opt) => {
+ options.push({
+ label : opt.windowPretty,
+ value : opt.window
+ });
+ });
+ return options;
+};
+
+export default{
+ filterByKey,
+ hideFSModal,
+ populateWindowsOptions
+};
http://git-wip-us.apache.org/repos/asf/ambari/blob/0c188aea/contrib/views/storm/src/main/resources/ui/app/styles/css/font-awesome.min.css
----------------------------------------------------------------------
diff --git a/contrib/views/storm/src/main/resources/ui/app/styles/css/font-awesome.min.css b/contrib/views/storm/src/main/resources/ui/app/styles/css/font-awesome.min.css
new file mode 100644
index 0000000..9b27f8e
--- /dev/null
+++ b/contrib/views/storm/src/main/resources/ui/app/styles/css/font-awesome.min.css
@@ -0,0 +1,4 @@
+/*!
+ * Font Awesome 4.6.3 by @davegandy - http://fontawesome.io - @fontawesome
+ * License - http://fontawesome.io/license (Font: SIL OFL 1.1, CSS: MIT License)
+ */@font-face{font-family:'FontAwesome';src:url('../fonts/fontawesome-webfont.eot?v=4.6.3');src:url('../fonts/fontawesome-webfont.eot?#iefix&v=4.6.3') format('embedded-opentype'),url('../fonts/fontawesome-webfont.woff2?v=4.6.3') format('woff2'),url('../fonts/fontawesome-webfont.woff?v=4.6.3') format('woff'),url('../fonts/fontawesome-webfont.ttf?v=4.6.3') format('truetype'),url('../fonts/fontawesome-webfont.svg?v=4.6.3#fontawesomeregular') format('svg');font-weight:normal;font-style:normal}.fa{display:inline-block;font:normal normal normal 14px/1 FontAwesome;font-size:inherit;text-rendering:auto;-webkit-font-smoothing:antialiased;-moz-osx-font-smoothing:grayscale}.fa-lg{font-size:1.33333333em;line-height:.75em;vertical-align:-15%}.fa-2x{font-size:2em}.fa-3x{font-size:3em}.fa-4x{font-size:4em}.fa-5x{font-size:5em}.fa-fw{width:1.28571429em;text-align:center}.fa-ul{padding-left:0;margin-left:2.14285714em;list-style-type:none}.fa-ul>li{position:relative}.fa-li{position:absolute;left:-2.1
4285714em;width:2.14285714em;top:.14285714em;text-align:center}.fa-li.fa-lg{left:-1.85714286em}.fa-border{padding:.2em .25em .15em;border:solid .08em #eee;border-radius:.1em}.fa-pull-left{float:left}.fa-pull-right{float:right}.fa.fa-pull-left{margin-right:.3em}.fa.fa-pull-right{margin-left:.3em}.pull-right{float:right}.pull-left{float:left}.fa.pull-left{margin-right:.3em}.fa.pull-right{margin-left:.3em}.fa-spin{-webkit-animation:fa-spin 2s infinite linear;animation:fa-spin 2s infinite linear}.fa-pulse{-webkit-animation:fa-spin 1s infinite steps(8);animation:fa-spin 1s infinite steps(8)}@-webkit-keyframes fa-spin{0%{-webkit-transform:rotate(0deg);transform:rotate(0deg)}100%{-webkit-transform:rotate(359deg);transform:rotate(359deg)}}@keyframes fa-spin{0%{-webkit-transform:rotate(0deg);transform:rotate(0deg)}100%{-webkit-transform:rotate(359deg);transform:rotate(359deg)}}.fa-rotate-90{-ms-filter:"progid:DXImageTransform.Microsoft.BasicImage(rotation=1)";-webkit-transform:rotate(90deg);
-ms-transform:rotate(90deg);transform:rotate(90deg)}.fa-rotate-180{-ms-filter:"progid:DXImageTransform.Microsoft.BasicImage(rotation=2)";-webkit-transform:rotate(180deg);-ms-transform:rotate(180deg);transform:rotate(180deg)}.fa-rotate-270{-ms-filter:"progid:DXImageTransform.Microsoft.BasicImage(rotation=3)";-webkit-transform:rotate(270deg);-ms-transform:rotate(270deg);transform:rotate(270deg)}.fa-flip-horizontal{-ms-filter:"progid:DXImageTransform.Microsoft.BasicImage(rotation=0, mirror=1)";-webkit-transform:scale(-1, 1);-ms-transform:scale(-1, 1);transform:scale(-1, 1)}.fa-flip-vertical{-ms-filter:"progid:DXImageTransform.Microsoft.BasicImage(rotation=2, mirror=1)";-webkit-transform:scale(1, -1);-ms-transform:scale(1, -1);transform:scale(1, -1)}:root .fa-rotate-90,:root .fa-rotate-180,:root .fa-rotate-270,:root .fa-flip-horizontal,:root .fa-flip-vertical{filter:none}.fa-stack{position:relative;display:inline-block;width:2em;height:2em;line-height:2em;vertical-align:middle}.fa-stack
-1x,.fa-stack-2x{position:absolute;left:0;width:100%;text-align:center}.fa-stack-1x{line-height:inherit}.fa-stack-2x{font-size:2em}.fa-inverse{color:#fff}.fa-glass:before{content:"\f000"}.fa-music:before{content:"\f001"}.fa-search:before{content:"\f002"}.fa-envelope-o:before{content:"\f003"}.fa-heart:before{content:"\f004"}.fa-star:before{content:"\f005"}.fa-star-o:before{content:"\f006"}.fa-user:before{content:"\f007"}.fa-film:before{content:"\f008"}.fa-th-large:before{content:"\f009"}.fa-th:before{content:"\f00a"}.fa-th-list:before{content:"\f00b"}.fa-check:before{content:"\f00c"}.fa-remove:before,.fa-close:before,.fa-times:before{content:"\f00d"}.fa-search-plus:before{content:"\f00e"}.fa-search-minus:before{content:"\f010"}.fa-power-off:before{content:"\f011"}.fa-signal:before{content:"\f012"}.fa-gear:before,.fa-cog:before{content:"\f013"}.fa-trash-o:before{content:"\f014"}.fa-home:before{content:"\f015"}.fa-file-o:before{content:"\f016"}.fa-clock-o:before{content:"\f017"}.fa-roa
d:before{content:"\f018"}.fa-download:before{content:"\f019"}.fa-arrow-circle-o-down:before{content:"\f01a"}.fa-arrow-circle-o-up:before{content:"\f01b"}.fa-inbox:before{content:"\f01c"}.fa-play-circle-o:before{content:"\f01d"}.fa-rotate-right:before,.fa-repeat:before{content:"\f01e"}.fa-refresh:before{content:"\f021"}.fa-list-alt:before{content:"\f022"}.fa-lock:before{content:"\f023"}.fa-flag:before{content:"\f024"}.fa-headphones:before{content:"\f025"}.fa-volume-off:before{content:"\f026"}.fa-volume-down:before{content:"\f027"}.fa-volume-up:before{content:"\f028"}.fa-qrcode:before{content:"\f029"}.fa-barcode:before{content:"\f02a"}.fa-tag:before{content:"\f02b"}.fa-tags:before{content:"\f02c"}.fa-book:before{content:"\f02d"}.fa-bookmark:before{content:"\f02e"}.fa-print:before{content:"\f02f"}.fa-camera:before{content:"\f030"}.fa-font:before{content:"\f031"}.fa-bold:before{content:"\f032"}.fa-italic:before{content:"\f033"}.fa-text-height:before{content:"\f034"}.fa-text-width:before
{content:"\f035"}.fa-align-left:before{content:"\f036"}.fa-align-center:before{content:"\f037"}.fa-align-right:before{content:"\f038"}.fa-align-justify:before{content:"\f039"}.fa-list:before{content:"\f03a"}.fa-dedent:before,.fa-outdent:before{content:"\f03b"}.fa-indent:before{content:"\f03c"}.fa-video-camera:before{content:"\f03d"}.fa-photo:before,.fa-image:before,.fa-picture-o:before{content:"\f03e"}.fa-pencil:before{content:"\f040"}.fa-map-marker:before{content:"\f041"}.fa-adjust:before{content:"\f042"}.fa-tint:before{content:"\f043"}.fa-edit:before,.fa-pencil-square-o:before{content:"\f044"}.fa-share-square-o:before{content:"\f045"}.fa-check-square-o:before{content:"\f046"}.fa-arrows:before{content:"\f047"}.fa-step-backward:before{content:"\f048"}.fa-fast-backward:before{content:"\f049"}.fa-backward:before{content:"\f04a"}.fa-play:before{content:"\f04b"}.fa-pause:before{content:"\f04c"}.fa-stop:before{content:"\f04d"}.fa-forward:before{content:"\f04e"}.fa-fast-forward:before{con
tent:"\f050"}.fa-step-forward:before{content:"\f051"}.fa-eject:before{content:"\f052"}.fa-chevron-left:before{content:"\f053"}.fa-chevron-right:before{content:"\f054"}.fa-plus-circle:before{content:"\f055"}.fa-minus-circle:before{content:"\f056"}.fa-times-circle:before{content:"\f057"}.fa-check-circle:before{content:"\f058"}.fa-question-circle:before{content:"\f059"}.fa-info-circle:before{content:"\f05a"}.fa-crosshairs:before{content:"\f05b"}.fa-times-circle-o:before{content:"\f05c"}.fa-check-circle-o:before{content:"\f05d"}.fa-ban:before{content:"\f05e"}.fa-arrow-left:before{content:"\f060"}.fa-arrow-right:before{content:"\f061"}.fa-arrow-up:before{content:"\f062"}.fa-arrow-down:before{content:"\f063"}.fa-mail-forward:before,.fa-share:before{content:"\f064"}.fa-expand:before{content:"\f065"}.fa-compress:before{content:"\f066"}.fa-plus:before{content:"\f067"}.fa-minus:before{content:"\f068"}.fa-asterisk:before{content:"\f069"}.fa-exclamation-circle:before{content:"\f06a"}.fa-gift:be
fore{content:"\f06b"}.fa-leaf:before{content:"\f06c"}.fa-fire:before{content:"\f06d"}.fa-eye:before{content:"\f06e"}.fa-eye-slash:before{content:"\f070"}.fa-warning:before,.fa-exclamation-triangle:before{content:"\f071"}.fa-plane:before{content:"\f072"}.fa-calendar:before{content:"\f073"}.fa-random:before{content:"\f074"}.fa-comment:before{content:"\f075"}.fa-magnet:before{content:"\f076"}.fa-chevron-up:before{content:"\f077"}.fa-chevron-down:before{content:"\f078"}.fa-retweet:before{content:"\f079"}.fa-shopping-cart:before{content:"\f07a"}.fa-folder:before{content:"\f07b"}.fa-folder-open:before{content:"\f07c"}.fa-arrows-v:before{content:"\f07d"}.fa-arrows-h:before{content:"\f07e"}.fa-bar-chart-o:before,.fa-bar-chart:before{content:"\f080"}.fa-twitter-square:before{content:"\f081"}.fa-facebook-square:before{content:"\f082"}.fa-camera-retro:before{content:"\f083"}.fa-key:before{content:"\f084"}.fa-gears:before,.fa-cogs:before{content:"\f085"}.fa-comments:before{content:"\f086"}.fa-t
humbs-o-up:before{content:"\f087"}.fa-thumbs-o-down:before{content:"\f088"}.fa-star-half:before{content:"\f089"}.fa-heart-o:before{content:"\f08a"}.fa-sign-out:before{content:"\f08b"}.fa-linkedin-square:before{content:"\f08c"}.fa-thumb-tack:before{content:"\f08d"}.fa-external-link:before{content:"\f08e"}.fa-sign-in:before{content:"\f090"}.fa-trophy:before{content:"\f091"}.fa-github-square:before{content:"\f092"}.fa-upload:before{content:"\f093"}.fa-lemon-o:before{content:"\f094"}.fa-phone:before{content:"\f095"}.fa-square-o:before{content:"\f096"}.fa-bookmark-o:before{content:"\f097"}.fa-phone-square:before{content:"\f098"}.fa-twitter:before{content:"\f099"}.fa-facebook-f:before,.fa-facebook:before{content:"\f09a"}.fa-github:before{content:"\f09b"}.fa-unlock:before{content:"\f09c"}.fa-credit-card:before{content:"\f09d"}.fa-feed:before,.fa-rss:before{content:"\f09e"}.fa-hdd-o:before{content:"\f0a0"}.fa-bullhorn:before{content:"\f0a1"}.fa-bell:before{content:"\f0f3"}.fa-certificate:be
fore{content:"\f0a3"}.fa-hand-o-right:before{content:"\f0a4"}.fa-hand-o-left:before{content:"\f0a5"}.fa-hand-o-up:before{content:"\f0a6"}.fa-hand-o-down:before{content:"\f0a7"}.fa-arrow-circle-left:before{content:"\f0a8"}.fa-arrow-circle-right:before{content:"\f0a9"}.fa-arrow-circle-up:before{content:"\f0aa"}.fa-arrow-circle-down:before{content:"\f0ab"}.fa-globe:before{content:"\f0ac"}.fa-wrench:before{content:"\f0ad"}.fa-tasks:before{content:"\f0ae"}.fa-filter:before{content:"\f0b0"}.fa-briefcase:before{content:"\f0b1"}.fa-arrows-alt:before{content:"\f0b2"}.fa-group:before,.fa-users:before{content:"\f0c0"}.fa-chain:before,.fa-link:before{content:"\f0c1"}.fa-cloud:before{content:"\f0c2"}.fa-flask:before{content:"\f0c3"}.fa-cut:before,.fa-scissors:before{content:"\f0c4"}.fa-copy:before,.fa-files-o:before{content:"\f0c5"}.fa-paperclip:before{content:"\f0c6"}.fa-save:before,.fa-floppy-o:before{content:"\f0c7"}.fa-square:before{content:"\f0c8"}.fa-navicon:before,.fa-reorder:before,.fa-b
ars:before{content:"\f0c9"}.fa-list-ul:before{content:"\f0ca"}.fa-list-ol:before{content:"\f0cb"}.fa-strikethrough:before{content:"\f0cc"}.fa-underline:before{content:"\f0cd"}.fa-table:before{content:"\f0ce"}.fa-magic:before{content:"\f0d0"}.fa-truck:before{content:"\f0d1"}.fa-pinterest:before{content:"\f0d2"}.fa-pinterest-square:before{content:"\f0d3"}.fa-google-plus-square:before{content:"\f0d4"}.fa-google-plus:before{content:"\f0d5"}.fa-money:before{content:"\f0d6"}.fa-caret-down:before{content:"\f0d7"}.fa-caret-up:before{content:"\f0d8"}.fa-caret-left:before{content:"\f0d9"}.fa-caret-right:before{content:"\f0da"}.fa-columns:before{content:"\f0db"}.fa-unsorted:before,.fa-sort:before{content:"\f0dc"}.fa-sort-down:before,.fa-sort-desc:before{content:"\f0dd"}.fa-sort-up:before,.fa-sort-asc:before{content:"\f0de"}.fa-envelope:before{content:"\f0e0"}.fa-linkedin:before{content:"\f0e1"}.fa-rotate-left:before,.fa-undo:before{content:"\f0e2"}.fa-legal:before,.fa-gavel:before{content:"\f0
e3"}.fa-dashboard:before,.fa-tachometer:before{content:"\f0e4"}.fa-comment-o:before{content:"\f0e5"}.fa-comments-o:before{content:"\f0e6"}.fa-flash:before,.fa-bolt:before{content:"\f0e7"}.fa-sitemap:before{content:"\f0e8"}.fa-umbrella:before{content:"\f0e9"}.fa-paste:before,.fa-clipboard:before{content:"\f0ea"}.fa-lightbulb-o:before{content:"\f0eb"}.fa-exchange:before{content:"\f0ec"}.fa-cloud-download:before{content:"\f0ed"}.fa-cloud-upload:before{content:"\f0ee"}.fa-user-md:before{content:"\f0f0"}.fa-stethoscope:before{content:"\f0f1"}.fa-suitcase:before{content:"\f0f2"}.fa-bell-o:before{content:"\f0a2"}.fa-coffee:before{content:"\f0f4"}.fa-cutlery:before{content:"\f0f5"}.fa-file-text-o:before{content:"\f0f6"}.fa-building-o:before{content:"\f0f7"}.fa-hospital-o:before{content:"\f0f8"}.fa-ambulance:before{content:"\f0f9"}.fa-medkit:before{content:"\f0fa"}.fa-fighter-jet:before{content:"\f0fb"}.fa-beer:before{content:"\f0fc"}.fa-h-square:before{content:"\f0fd"}.fa-plus-square:before
{content:"\f0fe"}.fa-angle-double-left:before{content:"\f100"}.fa-angle-double-right:before{content:"\f101"}.fa-angle-double-up:before{content:"\f102"}.fa-angle-double-down:before{content:"\f103"}.fa-angle-left:before{content:"\f104"}.fa-angle-right:before{content:"\f105"}.fa-angle-up:before{content:"\f106"}.fa-angle-down:before{content:"\f107"}.fa-desktop:before{content:"\f108"}.fa-laptop:before{content:"\f109"}.fa-tablet:before{content:"\f10a"}.fa-mobile-phone:before,.fa-mobile:before{content:"\f10b"}.fa-circle-o:before{content:"\f10c"}.fa-quote-left:before{content:"\f10d"}.fa-quote-right:before{content:"\f10e"}.fa-spinner:before{content:"\f110"}.fa-circle:before{content:"\f111"}.fa-mail-reply:before,.fa-reply:before{content:"\f112"}.fa-github-alt:before{content:"\f113"}.fa-folder-o:before{content:"\f114"}.fa-folder-open-o:before{content:"\f115"}.fa-smile-o:before{content:"\f118"}.fa-frown-o:before{content:"\f119"}.fa-meh-o:before{content:"\f11a"}.fa-gamepad:before{content:"\f11b"
}.fa-keyboard-o:before{content:"\f11c"}.fa-flag-o:before{content:"\f11d"}.fa-flag-checkered:before{content:"\f11e"}.fa-terminal:before{content:"\f120"}.fa-code:before{content:"\f121"}.fa-mail-reply-all:before,.fa-reply-all:before{content:"\f122"}.fa-star-half-empty:before,.fa-star-half-full:before,.fa-star-half-o:before{content:"\f123"}.fa-location-arrow:before{content:"\f124"}.fa-crop:before{content:"\f125"}.fa-code-fork:before{content:"\f126"}.fa-unlink:before,.fa-chain-broken:before{content:"\f127"}.fa-question:before{content:"\f128"}.fa-info:before{content:"\f129"}.fa-exclamation:before{content:"\f12a"}.fa-superscript:before{content:"\f12b"}.fa-subscript:before{content:"\f12c"}.fa-eraser:before{content:"\f12d"}.fa-puzzle-piece:before{content:"\f12e"}.fa-microphone:before{content:"\f130"}.fa-microphone-slash:before{content:"\f131"}.fa-shield:before{content:"\f132"}.fa-calendar-o:before{content:"\f133"}.fa-fire-extinguisher:before{content:"\f134"}.fa-rocket:before{content:"\f135"}
.fa-maxcdn:before{content:"\f136"}.fa-chevron-circle-left:before{content:"\f137"}.fa-chevron-circle-right:before{content:"\f138"}.fa-chevron-circle-up:before{content:"\f139"}.fa-chevron-circle-down:before{content:"\f13a"}.fa-html5:before{content:"\f13b"}.fa-css3:before{content:"\f13c"}.fa-anchor:before{content:"\f13d"}.fa-unlock-alt:before{content:"\f13e"}.fa-bullseye:before{content:"\f140"}.fa-ellipsis-h:before{content:"\f141"}.fa-ellipsis-v:before{content:"\f142"}.fa-rss-square:before{content:"\f143"}.fa-play-circle:before{content:"\f144"}.fa-ticket:before{content:"\f145"}.fa-minus-square:before{content:"\f146"}.fa-minus-square-o:before{content:"\f147"}.fa-level-up:before{content:"\f148"}.fa-level-down:before{content:"\f149"}.fa-check-square:before{content:"\f14a"}.fa-pencil-square:before{content:"\f14b"}.fa-external-link-square:before{content:"\f14c"}.fa-share-square:before{content:"\f14d"}.fa-compass:before{content:"\f14e"}.fa-toggle-down:before,.fa-caret-square-o-down:before{co
ntent:"\f150"}.fa-toggle-up:before,.fa-caret-square-o-up:before{content:"\f151"}.fa-toggle-right:before,.fa-caret-square-o-right:before{content:"\f152"}.fa-euro:before,.fa-eur:before{content:"\f153"}.fa-gbp:before{content:"\f154"}.fa-dollar:before,.fa-usd:before{content:"\f155"}.fa-rupee:before,.fa-inr:before{content:"\f156"}.fa-cny:before,.fa-rmb:before,.fa-yen:before,.fa-jpy:before{content:"\f157"}.fa-ruble:before,.fa-rouble:before,.fa-rub:before{content:"\f158"}.fa-won:before,.fa-krw:before{content:"\f159"}.fa-bitcoin:before,.fa-btc:before{content:"\f15a"}.fa-file:before{content:"\f15b"}.fa-file-text:before{content:"\f15c"}.fa-sort-alpha-asc:before{content:"\f15d"}.fa-sort-alpha-desc:before{content:"\f15e"}.fa-sort-amount-asc:before{content:"\f160"}.fa-sort-amount-desc:before{content:"\f161"}.fa-sort-numeric-asc:before{content:"\f162"}.fa-sort-numeric-desc:before{content:"\f163"}.fa-thumbs-up:before{content:"\f164"}.fa-thumbs-down:before{content:"\f165"}.fa-youtube-square:before{
content:"\f166"}.fa-youtube:before{content:"\f167"}.fa-xing:before{content:"\f168"}.fa-xing-square:before{content:"\f169"}.fa-youtube-play:before{content:"\f16a"}.fa-dropbox:before{content:"\f16b"}.fa-stack-overflow:before{content:"\f16c"}.fa-instagram:before{content:"\f16d"}.fa-flickr:before{content:"\f16e"}.fa-adn:before{content:"\f170"}.fa-bitbucket:before{content:"\f171"}.fa-bitbucket-square:before{content:"\f172"}.fa-tumblr:before{content:"\f173"}.fa-tumblr-square:before{content:"\f174"}.fa-long-arrow-down:before{content:"\f175"}.fa-long-arrow-up:before{content:"\f176"}.fa-long-arrow-left:before{content:"\f177"}.fa-long-arrow-right:before{content:"\f178"}.fa-apple:before{content:"\f179"}.fa-windows:before{content:"\f17a"}.fa-android:before{content:"\f17b"}.fa-linux:before{content:"\f17c"}.fa-dribbble:before{content:"\f17d"}.fa-skype:before{content:"\f17e"}.fa-foursquare:before{content:"\f180"}.fa-trello:before{content:"\f181"}.fa-female:before{content:"\f182"}.fa-male:before{co
ntent:"\f183"}.fa-gittip:before,.fa-gratipay:before{content:"\f184"}.fa-sun-o:before{content:"\f185"}.fa-moon-o:before{content:"\f186"}.fa-archive:before{content:"\f187"}.fa-bug:before{content:"\f188"}.fa-vk:before{content:"\f189"}.fa-weibo:before{content:"\f18a"}.fa-renren:before{content:"\f18b"}.fa-pagelines:before{content:"\f18c"}.fa-stack-exchange:before{content:"\f18d"}.fa-arrow-circle-o-right:before{content:"\f18e"}.fa-arrow-circle-o-left:before{content:"\f190"}.fa-toggle-left:before,.fa-caret-square-o-left:before{content:"\f191"}.fa-dot-circle-o:before{content:"\f192"}.fa-wheelchair:before{content:"\f193"}.fa-vimeo-square:before{content:"\f194"}.fa-turkish-lira:before,.fa-try:before{content:"\f195"}.fa-plus-square-o:before{content:"\f196"}.fa-space-shuttle:before{content:"\f197"}.fa-slack:before{content:"\f198"}.fa-envelope-square:before{content:"\f199"}.fa-wordpress:before{content:"\f19a"}.fa-openid:before{content:"\f19b"}.fa-institution:before,.fa-bank:before,.fa-university
:before{content:"\f19c"}.fa-mortar-board:before,.fa-graduation-cap:before{content:"\f19d"}.fa-yahoo:before{content:"\f19e"}.fa-google:before{content:"\f1a0"}.fa-reddit:before{content:"\f1a1"}.fa-reddit-square:before{content:"\f1a2"}.fa-stumbleupon-circle:before{content:"\f1a3"}.fa-stumbleupon:before{content:"\f1a4"}.fa-delicious:before{content:"\f1a5"}.fa-digg:before{content:"\f1a6"}.fa-pied-piper-pp:before{content:"\f1a7"}.fa-pied-piper-alt:before{content:"\f1a8"}.fa-drupal:before{content:"\f1a9"}.fa-joomla:before{content:"\f1aa"}.fa-language:before{content:"\f1ab"}.fa-fax:before{content:"\f1ac"}.fa-building:before{content:"\f1ad"}.fa-child:before{content:"\f1ae"}.fa-paw:before{content:"\f1b0"}.fa-spoon:before{content:"\f1b1"}.fa-cube:before{content:"\f1b2"}.fa-cubes:before{content:"\f1b3"}.fa-behance:before{content:"\f1b4"}.fa-behance-square:before{content:"\f1b5"}.fa-steam:before{content:"\f1b6"}.fa-steam-square:before{content:"\f1b7"}.fa-recycle:before{content:"\f1b8"}.fa-automo
bile:before,.fa-car:before{content:"\f1b9"}.fa-cab:before,.fa-taxi:before{content:"\f1ba"}.fa-tree:before{content:"\f1bb"}.fa-spotify:before{content:"\f1bc"}.fa-deviantart:before{content:"\f1bd"}.fa-soundcloud:before{content:"\f1be"}.fa-database:before{content:"\f1c0"}.fa-file-pdf-o:before{content:"\f1c1"}.fa-file-word-o:before{content:"\f1c2"}.fa-file-excel-o:before{content:"\f1c3"}.fa-file-powerpoint-o:before{content:"\f1c4"}.fa-file-photo-o:before,.fa-file-picture-o:before,.fa-file-image-o:before{content:"\f1c5"}.fa-file-zip-o:before,.fa-file-archive-o:before{content:"\f1c6"}.fa-file-sound-o:before,.fa-file-audio-o:before{content:"\f1c7"}.fa-file-movie-o:before,.fa-file-video-o:before{content:"\f1c8"}.fa-file-code-o:before{content:"\f1c9"}.fa-vine:before{content:"\f1ca"}.fa-codepen:before{content:"\f1cb"}.fa-jsfiddle:before{content:"\f1cc"}.fa-life-bouy:before,.fa-life-buoy:before,.fa-life-saver:before,.fa-support:before,.fa-life-ring:before{content:"\f1cd"}.fa-circle-o-notch:bef
ore{content:"\f1ce"}.fa-ra:before,.fa-resistance:before,.fa-rebel:before{content:"\f1d0"}.fa-ge:before,.fa-empire:before{content:"\f1d1"}.fa-git-square:before{content:"\f1d2"}.fa-git:before{content:"\f1d3"}.fa-y-combinator-square:before,.fa-yc-square:before,.fa-hacker-news:before{content:"\f1d4"}.fa-tencent-weibo:before{content:"\f1d5"}.fa-qq:before{content:"\f1d6"}.fa-wechat:before,.fa-weixin:before{content:"\f1d7"}.fa-send:before,.fa-paper-plane:before{content:"\f1d8"}.fa-send-o:before,.fa-paper-plane-o:before{content:"\f1d9"}.fa-history:before{content:"\f1da"}.fa-circle-thin:before{content:"\f1db"}.fa-header:before{content:"\f1dc"}.fa-paragraph:before{content:"\f1dd"}.fa-sliders:before{content:"\f1de"}.fa-share-alt:before{content:"\f1e0"}.fa-share-alt-square:before{content:"\f1e1"}.fa-bomb:before{content:"\f1e2"}.fa-soccer-ball-o:before,.fa-futbol-o:before{content:"\f1e3"}.fa-tty:before{content:"\f1e4"}.fa-binoculars:before{content:"\f1e5"}.fa-plug:before{content:"\f1e6"}.fa-slid
eshare:before{content:"\f1e7"}.fa-twitch:before{content:"\f1e8"}.fa-yelp:before{content:"\f1e9"}.fa-newspaper-o:before{content:"\f1ea"}.fa-wifi:before{content:"\f1eb"}.fa-calculator:before{content:"\f1ec"}.fa-paypal:before{content:"\f1ed"}.fa-google-wallet:before{content:"\f1ee"}.fa-cc-visa:before{content:"\f1f0"}.fa-cc-mastercard:before{content:"\f1f1"}.fa-cc-discover:before{content:"\f1f2"}.fa-cc-amex:before{content:"\f1f3"}.fa-cc-paypal:before{content:"\f1f4"}.fa-cc-stripe:before{content:"\f1f5"}.fa-bell-slash:before{content:"\f1f6"}.fa-bell-slash-o:before{content:"\f1f7"}.fa-trash:before{content:"\f1f8"}.fa-copyright:before{content:"\f1f9"}.fa-at:before{content:"\f1fa"}.fa-eyedropper:before{content:"\f1fb"}.fa-paint-brush:before{content:"\f1fc"}.fa-birthday-cake:before{content:"\f1fd"}.fa-area-chart:before{content:"\f1fe"}.fa-pie-chart:before{content:"\f200"}.fa-line-chart:before{content:"\f201"}.fa-lastfm:before{content:"\f202"}.fa-lastfm-square:before{content:"\f203"}.fa-toggl
e-off:before{content:"\f204"}.fa-toggle-on:before{content:"\f205"}.fa-bicycle:before{content:"\f206"}.fa-bus:before{content:"\f207"}.fa-ioxhost:before{content:"\f208"}.fa-angellist:before{content:"\f209"}.fa-cc:before{content:"\f20a"}.fa-shekel:before,.fa-sheqel:before,.fa-ils:before{content:"\f20b"}.fa-meanpath:before{content:"\f20c"}.fa-buysellads:before{content:"\f20d"}.fa-connectdevelop:before{content:"\f20e"}.fa-dashcube:before{content:"\f210"}.fa-forumbee:before{content:"\f211"}.fa-leanpub:before{content:"\f212"}.fa-sellsy:before{content:"\f213"}.fa-shirtsinbulk:before{content:"\f214"}.fa-simplybuilt:before{content:"\f215"}.fa-skyatlas:before{content:"\f216"}.fa-cart-plus:before{content:"\f217"}.fa-cart-arrow-down:before{content:"\f218"}.fa-diamond:before{content:"\f219"}.fa-ship:before{content:"\f21a"}.fa-user-secret:before{content:"\f21b"}.fa-motorcycle:before{content:"\f21c"}.fa-street-view:before{content:"\f21d"}.fa-heartbeat:before{content:"\f21e"}.fa-venus:before{content
:"\f221"}.fa-mars:before{content:"\f222"}.fa-mercury:before{content:"\f223"}.fa-intersex:before,.fa-transgender:before{content:"\f224"}.fa-transgender-alt:before{content:"\f225"}.fa-venus-double:before{content:"\f226"}.fa-mars-double:before{content:"\f227"}.fa-venus-mars:before{content:"\f228"}.fa-mars-stroke:before{content:"\f229"}.fa-mars-stroke-v:before{content:"\f22a"}.fa-mars-stroke-h:before{content:"\f22b"}.fa-neuter:before{content:"\f22c"}.fa-genderless:before{content:"\f22d"}.fa-facebook-official:before{content:"\f230"}.fa-pinterest-p:before{content:"\f231"}.fa-whatsapp:before{content:"\f232"}.fa-server:before{content:"\f233"}.fa-user-plus:before{content:"\f234"}.fa-user-times:before{content:"\f235"}.fa-hotel:before,.fa-bed:before{content:"\f236"}.fa-viacoin:before{content:"\f237"}.fa-train:before{content:"\f238"}.fa-subway:before{content:"\f239"}.fa-medium:before{content:"\f23a"}.fa-yc:before,.fa-y-combinator:before{content:"\f23b"}.fa-optin-monster:before{content:"\f23c"}.
fa-opencart:before{content:"\f23d"}.fa-expeditedssl:before{content:"\f23e"}.fa-battery-4:before,.fa-battery-full:before{content:"\f240"}.fa-battery-3:before,.fa-battery-three-quarters:before{content:"\f241"}.fa-battery-2:before,.fa-battery-half:before{content:"\f242"}.fa-battery-1:before,.fa-battery-quarter:before{content:"\f243"}.fa-battery-0:before,.fa-battery-empty:before{content:"\f244"}.fa-mouse-pointer:before{content:"\f245"}.fa-i-cursor:before{content:"\f246"}.fa-object-group:before{content:"\f247"}.fa-object-ungroup:before{content:"\f248"}.fa-sticky-note:before{content:"\f249"}.fa-sticky-note-o:before{content:"\f24a"}.fa-cc-jcb:before{content:"\f24b"}.fa-cc-diners-club:before{content:"\f24c"}.fa-clone:before{content:"\f24d"}.fa-balance-scale:before{content:"\f24e"}.fa-hourglass-o:before{content:"\f250"}.fa-hourglass-1:before,.fa-hourglass-start:before{content:"\f251"}.fa-hourglass-2:before,.fa-hourglass-half:before{content:"\f252"}.fa-hourglass-3:before,.fa-hourglass-end:bef
ore{content:"\f253"}.fa-hourglass:before{content:"\f254"}.fa-hand-grab-o:before,.fa-hand-rock-o:before{content:"\f255"}.fa-hand-stop-o:before,.fa-hand-paper-o:before{content:"\f256"}.fa-hand-scissors-o:before{content:"\f257"}.fa-hand-lizard-o:before{content:"\f258"}.fa-hand-spock-o:before{content:"\f259"}.fa-hand-pointer-o:before{content:"\f25a"}.fa-hand-peace-o:before{content:"\f25b"}.fa-trademark:before{content:"\f25c"}.fa-registered:before{content:"\f25d"}.fa-creative-commons:before{content:"\f25e"}.fa-gg:before{content:"\f260"}.fa-gg-circle:before{content:"\f261"}.fa-tripadvisor:before{content:"\f262"}.fa-odnoklassniki:before{content:"\f263"}.fa-odnoklassniki-square:before{content:"\f264"}.fa-get-pocket:before{content:"\f265"}.fa-wikipedia-w:before{content:"\f266"}.fa-safari:before{content:"\f267"}.fa-chrome:before{content:"\f268"}.fa-firefox:before{content:"\f269"}.fa-opera:before{content:"\f26a"}.fa-internet-explorer:before{content:"\f26b"}.fa-tv:before,.fa-television:before{c
ontent:"\f26c"}.fa-contao:before{content:"\f26d"}.fa-500px:before{content:"\f26e"}.fa-amazon:before{content:"\f270"}.fa-calendar-plus-o:before{content:"\f271"}.fa-calendar-minus-o:before{content:"\f272"}.fa-calendar-times-o:before{content:"\f273"}.fa-calendar-check-o:before{content:"\f274"}.fa-industry:before{content:"\f275"}.fa-map-pin:before{content:"\f276"}.fa-map-signs:before{content:"\f277"}.fa-map-o:before{content:"\f278"}.fa-map:before{content:"\f279"}.fa-commenting:before{content:"\f27a"}.fa-commenting-o:before{content:"\f27b"}.fa-houzz:before{content:"\f27c"}.fa-vimeo:before{content:"\f27d"}.fa-black-tie:before{content:"\f27e"}.fa-fonticons:before{content:"\f280"}.fa-reddit-alien:before{content:"\f281"}.fa-edge:before{content:"\f282"}.fa-credit-card-alt:before{content:"\f283"}.fa-codiepie:before{content:"\f284"}.fa-modx:before{content:"\f285"}.fa-fort-awesome:before{content:"\f286"}.fa-usb:before{content:"\f287"}.fa-product-hunt:before{content:"\f288"}.fa-mixcloud:before{co
ntent:"\f289"}.fa-scribd:before{content:"\f28a"}.fa-pause-circle:before{content:"\f28b"}.fa-pause-circle-o:before{content:"\f28c"}.fa-stop-circle:before{content:"\f28d"}.fa-stop-circle-o:before{content:"\f28e"}.fa-shopping-bag:before{content:"\f290"}.fa-shopping-basket:before{content:"\f291"}.fa-hashtag:before{content:"\f292"}.fa-bluetooth:before{content:"\f293"}.fa-bluetooth-b:before{content:"\f294"}.fa-percent:before{content:"\f295"}.fa-gitlab:before{content:"\f296"}.fa-wpbeginner:before{content:"\f297"}.fa-wpforms:before{content:"\f298"}.fa-envira:before{content:"\f299"}.fa-universal-access:before{content:"\f29a"}.fa-wheelchair-alt:before{content:"\f29b"}.fa-question-circle-o:before{content:"\f29c"}.fa-blind:before{content:"\f29d"}.fa-audio-description:before{content:"\f29e"}.fa-volume-control-phone:before{content:"\f2a0"}.fa-braille:before{content:"\f2a1"}.fa-assistive-listening-systems:before{content:"\f2a2"}.fa-asl-interpreting:before,.fa-american-sign-language-interpreting:be
fore{content:"\f2a3"}.fa-deafness:before,.fa-hard-of-hearing:before,.fa-deaf:before{content:"\f2a4"}.fa-glide:before{content:"\f2a5"}.fa-glide-g:before{content:"\f2a6"}.fa-signing:before,.fa-sign-language:before{content:"\f2a7"}.fa-low-vision:before{content:"\f2a8"}.fa-viadeo:before{content:"\f2a9"}.fa-viadeo-square:before{content:"\f2aa"}.fa-snapchat:before{content:"\f2ab"}.fa-snapchat-ghost:before{content:"\f2ac"}.fa-snapchat-square:before{content:"\f2ad"}.fa-pied-piper:before{content:"\f2ae"}.fa-first-order:before{content:"\f2b0"}.fa-yoast:before{content:"\f2b1"}.fa-themeisle:before{content:"\f2b2"}.fa-google-plus-circle:before,.fa-google-plus-official:before{content:"\f2b3"}.fa-fa:before,.fa-font-awesome:before{content:"\f2b4"}.sr-only{position:absolute;width:1px;height:1px;padding:0;margin:-1px;overflow:hidden;clip:rect(0, 0, 0, 0);border:0}.sr-only-focusable:active,.sr-only-focusable:focus{position:static;width:auto;height:auto;margin:0;overflow:visible;clip:auto}