' + build.displayName + '
' + - 'duration: ' + y + ' seconds
'; - if (date) { - tooltip += 'started: ' + date + '
'; - } - if (result) { - tooltip += 'result: ' + result + '
'; - } - if (x) { - var data = buildsSucceeded; - var key = successBuildKey; - if (!successBuildKey && (!result || !result.startsWith("SUCC"))) { - data = buildsFailed; - key = failedBuildKey; - } - data.push({ - tooltip: tooltip, - color: color, - x: x, y: y }); - } - }); - $scope.data = []; - if (buildsSucceeded.length) { - $scope.data.push({ - key: successBuildKey, - values: buildsSucceeded - }); - } - if (buildsFailed.length) { - $scope.data.push({ - key: failedBuildKey, - values: buildsFailed - }); - } - $scope.api.updateWithData($scope.data); - $timeout(function () { - $scope.api.update(); - }, 50); - } - function updateData() { - var metricsPath = $scope.jobId ? UrlHelpers.join("job", $scope.jobId, "fabric8/metrics") : "fabric8/metrics"; - var url = Kubernetes.kubernetesProxyUrlForServiceCurrentNamespace(Developer.jenkinsServiceNameAndPort, metricsPath); - Developer.log.info(""); - if (url && (!$scope.jenkins || Kubernetes.keepPollingModel)) { - $http.get(url, Developer.jenkinsHttpConfig). - success(function (data, status, headers, config) { - if (data) { - if (Developer.hasObjectChanged(data, $scope.entityChangedCache)) { - Developer.log.info("entity has changed!"); - $scope.metrics = data; - updateChartData(); - } - } - $scope.model.fetched = true; - Core.$apply($scope); - }). - error(function (data, status, headers, config) { - Developer.log.warn("Failed to load " + url + " " + data + " " + status); - }); - } - } - }]); -})(Developer || (Developer = {})); - -///\n {
+ return this.filterReplicationcontrollers;
+ }
+
+ public set filterReplicationcontrollers(filterReplicationcontrollers:Array) {
+ this.filterReplicationcontrollers = filterReplicationcontrollers;
+ }*/
+ get: function () {
+ return this.replicationcontrollers;
+ },
+ set: function (replicationControllers) {
+ this.replicationcontrollers = replicationControllers;
+ },
+ enumerable: true,
+ configurable: true
+ });
+ Object.defineProperty(KubernetesModelService.prototype, "namespaces", {
+ get: function () {
+ return this.kubernetes.namespaces;
+ },
+ enumerable: true,
+ configurable: true
+ });
+ Object.defineProperty(KubernetesModelService.prototype, "showRunButton", {
+ get: function () {
+ if (Kubernetes.isOpenShift) {
+ return true;
+ }
+ return _.any(this.services, function (service) {
+ var name = Kubernetes.getName(service);
+ if (name === "templates") {
+ var podCounters = service.$podCounters;
+ return podCounters && (podCounters.valid || podCounters.ready);
+ }
+ else {
+ return false;
+ }
+ });
+ },
+ enumerable: true,
+ configurable: true
+ });
+ Object.defineProperty(KubernetesModelService.prototype, "serviceApps", {
+ get: function () {
+ return _.filter(this.services, function (s) {
+ return s.$host && s.$serviceUrl && s.$podCount;
+ });
+ },
+ enumerable: true,
+ configurable: true
+ });
+ KubernetesModelService.prototype.$keepPolling = function () {
+ return Kubernetes.keepPollingModel;
+ };
+ KubernetesModelService.prototype.orRedraw = function (flag) {
+ this.redraw = this.redraw || flag;
+ };
+ KubernetesModelService.prototype.getService = function (namespace, id) {
+ return this.servicesByKey[createKey(namespace, id, 'service')];
+ };
+ KubernetesModelService.prototype.getReplicationController = function (namespace, id) {
+ return this.replicationControllersByKey[createKey(namespace, id, 'replicationController')];
+ };
+ KubernetesModelService.prototype.getPod = function (namespace, id) {
+ return this.podsByKey[createKey(namespace, id, 'pod')];
+ };
+ KubernetesModelService.prototype.podsForNamespace = function (namespace) {
+ if (namespace === void 0) { namespace = this.currentNamespace(); }
+ return _.filter(this.pods, { namespace: namespace });
+ };
+ KubernetesModelService.prototype.getBuildConfig = function (name) {
+ return _.find(this.buildconfigs, { $name: name });
+ };
+ KubernetesModelService.prototype.getProject = function (name, ns) {
+ if (ns === void 0) { ns = this.currentNamespace(); }
+ var buildConfig = this.project;
+ if (!buildConfig) {
+ var text = localStorage[Kubernetes.FABRIC8_PROJECT_JSON];
+ if (text) {
+ try {
+ buildConfig = angular.fromJson(text);
+ }
+ catch (e) {
+ Kubernetes.log.warn("Could not parse json for " + Kubernetes.FABRIC8_PROJECT_JSON + ". Was: " + text + ". " + e, e);
+ }
+ }
+ }
+ if (buildConfig && ns != Kubernetes.getNamespace(buildConfig) && name != buildConfig.$name) {
+ buildConfig = this.getBuildConfig(name);
+ }
+ return buildConfig;
+ };
+ KubernetesModelService.prototype.setProject = function (buildConfig) {
+ this.project = buildConfig;
+ if (buildConfig) {
+ // lets store in local storage
+ var localStorage = Kubernetes.inject("localStorage");
+ if (localStorage) {
+ localStorage[Kubernetes.FABRIC8_PROJECT_JSON] = angular.toJson(buildConfig);
+ }
+ }
+ };
+ /**
+ * Returns the current selected namespace or the default namespace
+ */
+ KubernetesModelService.prototype.currentNamespace = function () {
+ var answer = null;
+ if (this.kubernetes) {
+ answer = this.kubernetes.selectedNamespace;
+ }
+ return answer || Kubernetes.defaultNamespace;
+ };
+ KubernetesModelService.prototype.updateIconUrlAndAppInfo = function (entity, nameField) {
+ var answer = null;
+ var id = Kubernetes.getName(entity);
+ entity.$iconUrl = Core.pathGet(entity, ['metadata', 'annotations', 'fabric8.' + id + '/iconUrl']);
+ entity.$info = Core.pathGet(entity, ['metadata', 'annotations', 'fabric8.' + id + '/summary']);
+ if (entity.$iconUrl) {
+ return;
+ }
+ if (id && nameField) {
+ (this.templates || []).forEach(function (template) {
+ var metadata = template.metadata;
+ if (metadata) {
+ var annotations = metadata.annotations || {};
+ var iconUrl = annotations["fabric8." + id + "/iconUrl"] || annotations["fabric8/iconUrl"];
+ if (iconUrl) {
+ (template.objects || []).forEach(function (item) {
+ var entityName = Kubernetes.getName(item);
+ if (id === entityName) {
+ entity.$iconUrl = iconUrl;
+ }
+ });
+ }
+ }
+ });
+ (this.appInfos || []).forEach(function (appInfo) {
+ var iconPath = appInfo.iconPath;
+ if (iconPath && !answer && iconPath !== "null") {
+ var iconUrl = Kubernetes.gitPathToUrl(iconPath);
+ var ids = Core.pathGet(appInfo, ["names", nameField]);
+ angular.forEach(ids, function (appId) {
+ if (appId === id) {
+ entity.$iconUrl = iconUrl;
+ entity.appPath = appInfo.appPath;
+ entity.$info = appInfo;
+ }
+ });
+ }
+ });
+ }
+ if (!entity.$iconUrl) {
+ entity.$iconUrl = Kubernetes.defaultIconUrl;
+ }
+ };
+ KubernetesModelService.prototype.maybeInit = function () {
+ var _this = this;
+ this.fetched = true;
+ this.servicesByKey = {};
+ this.podsByKey = {};
+ this.replicationControllersByKey = {};
+ this.pods.forEach(function (pod) {
+ if (!pod.kind)
+ pod.kind = "Pod";
+ _this.podsByKey[pod._key] = pod;
+ var host = Kubernetes.getHost(pod);
+ pod.$labelsText = Kubernetes.labelsToString(Kubernetes.getLabels(pod));
+ if (host) {
+ pod.$labelsText += Kubernetes.labelFilterTextSeparator + "host=" + host;
+ }
+ pod.$iconUrl = Kubernetes.defaultIconUrl;
+ _this.discoverPodConnections(pod);
+ pod.$containerPorts = [];
+ var podStatus = pod.status || {};
+ var startTime = podStatus.startTime;
+ pod.$startTime = null;
+ if (startTime) {
+ pod.$startTime = new Date(startTime);
+ }
+ var createdTime = Kubernetes.getCreationTimestamp(pod);
+ pod.$createdTime = null;
+ pod.$age = null;
+ if (createdTime) {
+ pod.$createdTime = new Date(createdTime);
+ pod.$age = humandate.relativeTime(pod.$createdTime);
+ }
+ var ready = Kubernetes.isReady(pod);
+ pod.$ready = ready;
+ pod.$statusCss = Kubernetes.statusTextToCssClass(podStatus.phase, ready);
+ var maxRestartCount = 0;
+ angular.forEach(Core.pathGet(pod, ["status", "containerStatuses"]), function (status) {
+ var restartCount = status.restartCount;
+ if (restartCount) {
+ if (restartCount > maxRestartCount) {
+ maxRestartCount = restartCount;
+ }
+ }
+ });
+ if (maxRestartCount) {
+ pod.$restartCount = maxRestartCount;
+ }
+ var imageNames = "";
+ angular.forEach(Core.pathGet(pod, ["spec", "containers"]), function (container) {
+ var image = container.image;
+ if (image) {
+ if (!imageNames) {
+ imageNames = image;
+ }
+ else {
+ imageNames = imageNames + " " + image;
+ }
+ var idx = image.lastIndexOf(":");
+ if (idx > 0) {
+ image = image.substring(0, idx);
+ }
+ var paths = image.split("/", 3);
+ if (paths.length) {
+ var answer = null;
+ if (paths.length == 3) {
+ answer = paths[1] + "/" + paths[2];
+ }
+ else if (paths.length == 2) {
+ answer = paths[0] + "/" + paths[1];
+ }
+ else {
+ answer = paths[0] + "/" + paths[1];
+ }
+ container.$imageLink = UrlHelpers.join("https://registry.hub.docker.com/u/", answer);
+ }
+ }
+ angular.forEach(container.ports, function (port) {
+ var containerPort = port.containerPort;
+ if (containerPort) {
+ pod.$containerPorts.push(containerPort);
+ }
+ });
+ });
+ pod.$imageNames = imageNames;
+ var podStatus = podStatus;
+ var podSpec = (pod.spec || {});
+ pod.$podIP = podStatus.podIP;
+ pod.$host = podSpec.host || podSpec.nodeName || podStatus.hostIP;
+ });
+ this.services.forEach(function (service) {
+ if (!service.kind)
+ service.kind = "Service";
+ _this.servicesByKey[service._key] = service;
+ var selector = Kubernetes.getSelector(service);
+ service.$pods = [];
+ if (!service.$podCounters) {
+ service.$podCounters = {};
+ }
+ var podLinkUrl = UrlHelpers.join("/kubernetes/namespace", service.metadata.namespace, "pods");
+ _.assign(service.$podCounters, selector ? Kubernetes.createPodCounters(selector, _this.pods, service.$pods, Kubernetes.labelsToString(selector, ","), podLinkUrl) : {});
+ service.$podCount = service.$pods.length;
+ var selectedPods = service.$pods;
+ service.connectTo = selectedPods.map(function (pod) {
+ return pod._key;
+ }).join(',');
+ service.$labelsText = Kubernetes.labelsToString(Kubernetes.getLabels(service));
+ _this.updateIconUrlAndAppInfo(service, "serviceNames");
+ var spec = service.spec || {};
+ service.$portalIP = spec.portalIP;
+ service.$selectorText = Kubernetes.labelsToString(spec.selector);
+ var ports = _.map(spec.ports || [], "port");
+ service.$ports = ports;
+ service.$portsText = ports.join(", ");
+ var iconUrl = service.$iconUrl;
+ if (iconUrl && selectedPods) {
+ selectedPods.forEach(function (pod) {
+ pod.$iconUrl = iconUrl;
+ });
+ }
+ service.$serviceUrl = Kubernetes.serviceLinkUrl(service);
+ });
+ this.replicationControllers.forEach(function (replicationController) {
+ if (!replicationController.kind)
+ replicationController.kind = "ReplicationController";
+ _this.replicationControllersByKey[replicationController._key] = replicationController;
+ var selector = Kubernetes.getSelector(replicationController);
+ replicationController.$pods = [];
+ if (Kubernetes.isFilterRC(replicationController) && !Kubernetes.isInclude(_this.filterReplicationcontrollers, replicationController))
+ _this.filterReplicationcontrollers.push(replicationController);
+ replicationController.$podCounters = selector ? Kubernetes.createPodCounters(selector, _this.pods, replicationController.$pods) : null;
+ replicationController.$podCount = replicationController.$pods.length;
+ replicationController.$replicas = (replicationController.spec || {}).replicas;
+ replicationController.$oracleName = Kubernetes.getOracleName(replicationController);
+ //console.log(getName(replicationController));
+ replicationController.$oracleStatus = Kubernetes.getOracleStatus(Kubernetes.getLabels(replicationController));
+ replicationController.$extractStatus = Kubernetes.getExtractStatus(Kubernetes.getLabels(replicationController));
+ //
+ var annotation = Kubernetes.getAnnotations(replicationController);
+ var label = Kubernetes.getLabels(replicationController);
+ replicationController.$alias = annotation.cityName + "_" + annotation.districtName + "_" + annotation.systemName + "_" + annotation.year + "_" + label.version;
+ var selectedPods = replicationController.$pods;
+ replicationController.connectTo = selectedPods.map(function (pod) {
+ return pod._key;
+ }).join(',');
+ //console.log(getLabels(replicationController));
+ replicationController.$labelsText = Kubernetes.labelsToString(Kubernetes.getLabels(replicationController));
+ replicationController.metadata.labels = Kubernetes.labelsFormat(replicationController);
+ _this.updateIconUrlAndAppInfo(replicationController, "replicationControllerNames");
+ var iconUrl = replicationController.$iconUrl;
+ if (iconUrl && selectedPods) {
+ selectedPods.forEach(function (pod) {
+ pod.$iconUrl = iconUrl;
+ });
+ }
+ });
+ // services may not map to an icon but their pods may do via the RC
+ // so lets default it...
+ this.services.forEach(function (service) {
+ var iconUrl = service.$iconUrl;
+ var selectedPods = service.$pods;
+ if (selectedPods) {
+ if (!iconUrl || iconUrl === Kubernetes.defaultIconUrl) {
+ iconUrl = null;
+ selectedPods.forEach(function (pod) {
+ if (!iconUrl) {
+ iconUrl = pod.$iconUrl;
+ if (iconUrl) {
+ service.$iconUrl = iconUrl;
+ }
+ }
+ });
+ }
+ }
+ });
+ this.updateApps();
+ var podsByHost = {};
+ this.pods.forEach(function (pod) {
+ var host = Kubernetes.getHost(pod);
+ var podsForHost = podsByHost[host];
+ if (!podsForHost) {
+ podsForHost = [];
+ podsByHost[host] = podsForHost;
+ }
+ podsForHost.push(pod);
+ });
+ this.podsByHost = podsByHost;
+ var tmpHosts = [];
+ for (var hostKey in podsByHost) {
+ var hostPods = [];
+ var podCounters = Kubernetes.createPodCounters(function (pod) { return Kubernetes.getHost(pod) === hostKey; }, this.pods, hostPods, "host=" + hostKey);
+ var hostIP = null;
+ if (hostPods.length) {
+ var pod = hostPods[0];
+ var currentState = pod.status;
+ if (currentState) {
+ hostIP = currentState.hostIP;
+ }
+ }
+ var hostDetails = {
+ name: hostKey,
+ id: hostKey,
+ elementId: hostKey.replace(/\./g, '_'),
+ hostIP: hostIP,
+ pods: hostPods,
+ kind: "Host",
+ $podCounters: podCounters,
+ $iconUrl: Kubernetes.hostIconUrl
+ };
+ tmpHosts.push(hostDetails);
+ }
+ this.hosts = tmpHosts;
+ Kubernetes.enrichBuildConfigs(this.buildconfigs);
+ Kubernetes.enrichEvents(this.events, this);
+ };
+ KubernetesModelService.prototype.updateApps = function () {
+ var _this = this;
+ try {
+ // lets create the app views by trying to join controllers / services / pods that are related
+ var appViews = [];
+ this.replicationControllers.forEach(function (replicationController) {
+ var name = Kubernetes.getName(replicationController);
+ var $iconUrl = replicationController.$iconUrl;
+ appViews.push({
+ appPath: "/dummyPath/" + name,
+ $name: name,
+ $info: {
+ $iconUrl: $iconUrl
+ },
+ $iconUrl: $iconUrl,
+ replicationControllers: [replicationController],
+ pods: replicationController.$pods || [],
+ services: []
+ });
+ });
+ var noMatches = [];
+ this.services.forEach(function (service) {
+ // now lets see if we can find an app with an RC of the same selector
+ var matchesApp = null;
+ appViews.forEach(function (appView) {
+ appView.replicationControllers.forEach(function (replicationController) {
+ var repSelector = Kubernetes.getSelector(replicationController);
+ if (repSelector &&
+ Kubernetes.selectorMatches(repSelector, Kubernetes.getSelector(service)) &&
+ Kubernetes.getNamespace(service) === Kubernetes.getNamespace(replicationController)) {
+ matchesApp = appView;
+ }
+ });
+ });
+ if (matchesApp) {
+ matchesApp.services.push(service);
+ }
+ else {
+ noMatches.push(service);
+ }
+ });
+ Kubernetes.log.debug("no matches: ", noMatches);
+ noMatches.forEach(function (service) {
+ var appView = _.find(appViews, function (appView) {
+ return _.any(appView.replicationControllers, function (rc) {
+ return _.startsWith(Kubernetes.getName(rc), Kubernetes.getName(service));
+ });
+ });
+ if (appView) {
+ appView.services.push(service);
+ }
+ else {
+ var $iconUrl = service.$iconUrl;
+ appViews.push({
+ appPath: "/dummyPath/" + name,
+ $name: name,
+ $info: {
+ $iconUrl: $iconUrl
+ },
+ $iconUrl: $iconUrl,
+ replicationControllers: [],
+ pods: service.$pods || [],
+ services: [service]
+ });
+ }
+ });
+ angular.forEach(this.routes, function (route) {
+ var metadata = route.metadata || {};
+ var spec = route.spec || {};
+ var serviceName = Core.pathGet(spec, ["to", "name"]);
+ var host = spec.host;
+ var namespace = Kubernetes.getNamespace(route);
+ if (serviceName && host) {
+ var service = _this.getService(namespace, serviceName);
+ if (service) {
+ service.$host = host;
+ // TODO we could use some annotations / metadata to deduce what URL we should use to open this
+ // service in the console. For now just assume its http:
+ if (host) {
+ var hostUrl = host;
+ if (hostUrl.indexOf("://") < 0) {
+ hostUrl = "http://" + host;
+ }
+ service.$connectUrl = UrlHelpers.join(hostUrl, "/");
+ }
+ // TODO definitely need that annotation, temp hack for apiman link
+ if (Kubernetes.getName(service) === 'apiman' && host) {
+ service.$connectUrl = new URI().host(service.$host)
+ .path('apimanui/index.html')
+ .query({})
+ .hash(URI.encode(angular.toJson({
+ backTo: new URI().toString(),
+ token: HawtioOAuth.getOAuthToken()
+ }))).toString();
+ }
+ }
+ else {
+ Kubernetes.log.debug("Could not find service " + serviceName + " namespace " + namespace + " for route: " + metadata.name);
+ }
+ }
+ });
+ appViews = _.sortBy(populateKeys(appViews), function (appView) { return appView._key; });
+ ArrayHelpers.sync(this.appViews, appViews, '$name');
+ if (this.appInfos && this.appViews) {
+ var folderMap = {};
+ var folders = [];
+ var appMap = {};
+ angular.forEach(this.appInfos, function (appInfo) {
+ if (!appInfo.$iconUrl && appInfo.iconPath && appInfo.iconPath !== "null") {
+ appInfo.$iconUrl = Kubernetes.gitPathToUrl(appInfo.iconPath);
+ }
+ var appPath = appInfo.appPath;
+ if (appPath) {
+ appMap[appPath] = appInfo;
+ var idx = appPath.lastIndexOf("/");
+ var folderPath = "";
+ if (idx >= 0) {
+ folderPath = appPath.substring(0, idx);
+ }
+ folderPath = Core.trimLeading(folderPath, "/");
+ var folder = folderMap[folderPath];
+ if (!folder) {
+ folder = {
+ path: folderPath,
+ expanded: true,
+ apps: []
+ };
+ folders.push(folder);
+ folderMap[folderPath] = folder;
+ }
+ folder.apps.push(appInfo);
+ }
+ });
+ this.appFolders = _.sortBy(folders, "path");
+ var apps = [];
+ var defaultInfo = {
+ $iconUrl: Kubernetes.defaultIconUrl
+ };
+ angular.forEach(this.appViews, function (appView) {
+ try {
+ var appPath = appView.appPath;
+ /*
+ TODO
+ appView.$select = () => {
+ Kubernetes.setJson($scope, appView.id, $scope.model.apps);
+ };
+ */
+ var appInfo = angular.copy(defaultInfo);
+ if (appPath) {
+ appInfo = appMap[appPath] || appInfo;
+ }
+ if (!appView.$info) {
+ appView.$info = defaultInfo;
+ appView.$info = appInfo;
+ }
+ appView.id = appPath;
+ if (!appView.$name) {
+ appView.$name = appInfo.name || appView.$name;
+ }
+ if (!appView.$iconUrl) {
+ appView.$iconUrl = appInfo.$iconUrl;
+ }
+ apps.push(appView);
+ appView.$podCounters = Kubernetes.createAppViewPodCounters(appView);
+ appView.$podCount = (appView.pods || []).length;
+ appView.$replicationControllersText = (appView.replicationControllers || []).map(function (i) { return i["_key"]; }).join(" ");
+ appView.$servicesText = (appView.services || []).map(function (i) { return i["_key"]; }).join(" ");
+ appView.$serviceViews = Kubernetes.createAppViewServiceViews(appView);
+ }
+ catch (e) {
+ Kubernetes.log.warn("Failed to update appViews: " + e);
+ }
+ });
+ //this.apps = apps;
+ this.apps = this.appViews;
+ }
+ }
+ catch (e) {
+ Kubernetes.log.warn("Caught error: " + e);
+ }
+ };
+ KubernetesModelService.prototype.discoverPodConnections = function (entity) {
+ var info = Core.pathGet(entity, ["status", "info"]);
+ var hostPort = null;
+ var currentState = entity.status || {};
+ var desiredState = entity.spec || {};
+ var podId = Kubernetes.getName(entity);
+ var host = currentState["hostIP"];
+ var podIP = currentState["podIP"];
+ var hasDocker = false;
+ var foundContainerPort = null;
+ if (desiredState) {
+ var containers = desiredState.containers;
+ angular.forEach(containers, function (container) {
+ if (!hostPort) {
+ var ports = container.ports;
+ angular.forEach(ports, function (port) {
+ if (!hostPort) {
+ var containerPort = port.containerPort;
+ var portName = port.name;
+ var containerHostPort = port.hostPort;
+ if (containerPort === 8778 || "jolokia" === portName) {
+ if (containerPort) {
+ if (podIP) {
+ foundContainerPort = containerPort;
+ }
+ if (containerHostPort) {
+ hostPort = containerHostPort;
+ }
+ }
+ }
+ }
+ });
+ }
+ });
+ }
+ if (foundContainerPort && podId && Kubernetes.isRunning(currentState)) {
+ if (!Kubernetes.isOpenShift) {
+ // TODO temp workaround for k8s on GKE https://github.com/kubernetes/kubernetes/issues/17172
+ entity.$jolokiaUrl = UrlHelpers.join(Kubernetes.masterApiUrl(), "api", Kubernetes.defaultApiVersion, "proxy", "namespaces", entity.metadata.namespace, "pods",
+ //"https:" + podId + ":" + foundContainerPort,
+ podId + ":" + foundContainerPort, "jolokia/");
+ }
+ else {
+ entity.$jolokiaUrl = UrlHelpers.join(Kubernetes.masterApiUrl(), "api", Kubernetes.defaultApiVersion, "namespaces", entity.metadata.namespace, "pods", "https:" + podId + ":" + foundContainerPort, "proxy/jolokia/");
+ }
+ }
+ };
+ return KubernetesModelService;
+ }());
+ Kubernetes.KubernetesModelService = KubernetesModelService;
+ function getTemplateService(model) {
+ var key = createKey('default', 'templates', 'service');
+ var answer = model.servicesByKey[key];
+ Kubernetes.log.debug("found template service: ", answer);
+ return answer;
+ }
+ /**
+ * Creates a model service which keeps track of all the pods, replication controllers and services along
+ * with their associations and status
+ */
+ Kubernetes._module.factory('KubernetesModel', ['$rootScope', '$http', 'KubernetesApiURL', 'KubernetesState', 'WatcherService', '$location', '$resource', function ($rootScope, $http, AppLibraryURL, KubernetesState, watcher, $location, $resource) {
+ var $scope = new KubernetesModelService();
+ $scope.kubernetes = KubernetesState;
+ // create all of our resource classes
+ var typeNames = watcher.getTypes();
+ _.forEach(typeNames, function (type) {
+ var urlTemplate = Kubernetes.uriTemplateForKubernetesKind(type);
+ $scope[type + 'Resource'] = Kubernetes.createResource(type, urlTemplate, $resource, $scope);
+ });
+ if (!Kubernetes.isOpenShift) {
+ // register custom URL factories for templates/projects
+ watcher.registerCustomUrlFunction(KubernetesAPI.WatchTypes.BUILD_CONFIGS, function (options) {
+ var templateService = getTemplateService($scope);
+ if (templateService) {
+ return UrlHelpers.join(templateService.proxyUrl, '/oapi/v1/namespaces/default/buildconfigs/');
+ }
+ return null;
+ });
+ // register custom URL factories for templates/projects
+ watcher.registerCustomUrlFunction(KubernetesAPI.WatchTypes.TEMPLATES, function (options) {
+ var templateService = getTemplateService($scope);
+ if (templateService) {
+ return UrlHelpers.join(templateService.proxyUrl, '/oapi/v1/namespaces/default/templates/');
+ }
+ return null;
+ });
+ }
+ // register for all updates on objects
+ watcher.registerListener(function (objects) {
+ var types = watcher.getTypes();
+ _.forEach(types, function (type) {
+ switch (type) {
+ case Kubernetes.WatchTypes.SERVICES:
+ var items = populateKeys(objects[type]);
+ angular.forEach(items, function (item) {
+ item.proxyUrl = Kubernetes.kubernetesProxyUrlForService(Kubernetes.kubernetesApiUrl(), item);
+ });
+ $scope[type] = items;
+ break;
+ case Kubernetes.WatchTypes.TEMPLATES:
+ case Kubernetes.WatchTypes.ROUTES:
+ case Kubernetes.WatchTypes.BUILDS:
+ case Kubernetes.WatchTypes.BUILD_CONFIGS:
+ case Kubernetes.WatchTypes.IMAGE_STREAMS:
+ // don't put a break here :-)
+ default:
+ $scope[type] = populateKeys(objects[type]);
+ }
+ Kubernetes.log.debug("Type: ", type, " object: ", $scope[type]);
+ });
+ $scope.maybeInit();
+ $rootScope.$broadcast('kubernetesModelUpdated', $scope);
+ Core.$apply($rootScope);
+ });
+ // set the selected namespace if set in the location bar
+ // otherwise use whatever previously selected namespace is
+ // available
+ var search = $location.search();
+ if ('namespace' in search) {
+ watcher.setNamespace(search['namespace']);
+ }
+ function selectPods(pods, namespace, labels) {
+ return pods.filter(function (pod) {
+ return Kubernetes.getNamespace(pod) === namespace && Kubernetes.selectorMatches(labels, Kubernetes.getLabels(pod));
+ });
+ }
+ return $scope;
+ }]);
+})(Kubernetes || (Kubernetes = {}));
+
///
\n
\n ",
- link: function (scope, element, attrs) {
- if (!initialized) {
- try {
- }
- catch (err) {
- }
- initialized = true;
- }
- scope.HawtioSubTabs = HawtioSubTabs;
- var collapsed = false;
- scope.getClass = function () {
- //log.debug("My class: ", element.attr('class'));
- if (!scope.subTabConfig || !scope.subTabConfig.length) {
- return 'hidden';
- }
- if (collapsed) {
- return 'collapsed';
- }
- return '';
- };
- scope.$on('hawtioCollapseNav', function () {
- collapsed = !collapsed;
- });
- scope.$watch('HawtioSubTabs.get()', function (subTabConfig) {
- scope.subTabConfig = subTabConfig;
- });
- }
- };
- }]);
- Navigation._module.directive('hawtioBreadcrumbsOutlet', ['HawtioBreadcrumbs', 'HawtioSubTabs', function (HawtioBreadcrumbs, HawtioSubTabs) {
- return {
- restrict: 'E',
- scope: {},
- template: "\n \n \n \n ![]()
\n {{subTab.label}}\n \n \n
\n \n \n \n
\n ",
- link: function (scope, element, attrs) {
- scope.breadcrumbs = HawtioBreadcrumbs;
- scope.tabs = HawtioSubTabs;
- scope.$watchCollection('breadcrumbs.get()', function (breadcrumbConfig) {
- scope.breadcrumbConfig = breadcrumbConfig;
- });
- scope.$watchCollection('tabs.get()', function (tabs) {
- var active = _.find(tabs, function (tab) { return tab.active; });
- if (active) {
- scope.pageTitle = active.label;
- }
- else {
- scope.pageTitle = undefined;
- }
- });
- }
- };
- }]);
- Navigation._module.directive('platformSubTabsOutlet', ['HawtioSubTabs', function (HawtioSubTabs) {
- var initialized = false;
- return {
- restrict: 'AE',
- replace: true,
- template: "\n \n \n
\n ",
- link: function (scope, element, attrs) {
- if (!initialized) {
- try {
- }
- catch (err) {
- }
- initialized = true;
- }
- scope.HawtioSubTabs = HawtioSubTabs;
- var collapsed = false;
- scope.getClass = function () {
- //log.debug("My class: ", element.attr('class'));
- if (!scope.subTabConfig || !scope.subTabConfig.length) {
- return 'hidden';
- }
- if (collapsed) {
- return 'collapsed';
- }
- return '';
- };
- scope.$on('hawtioCollapseNav', function () {
- collapsed = !collapsed;
- });
- scope.$watch('HawtioSubTabs.get()', function (subTabConfig) {
- scope.subTabConfig = subTabConfig;
- });
- }
- };
- }]);
- //hawtioPluginLoader.addModule('patternfly');
- hawtioPluginLoader.addModule(Navigation.pluginName);
-})(Navigation || (Navigation = {}));
-
/// \n
\r\n");
$templateCache.put("plugins/developer/html/tools.html","\n
\n ",
+ link: function (scope, element, attrs) {
+ if (!initialized) {
+ try {
+ }
+ catch (err) {
+ }
+ initialized = true;
+ }
+ scope.HawtioSubTabs = HawtioSubTabs;
+ var collapsed = false;
+ scope.getClass = function () {
+ //log.debug("My class: ", element.attr('class'));
+ if (!scope.subTabConfig || !scope.subTabConfig.length) {
+ return 'hidden';
+ }
+ if (collapsed) {
+ return 'collapsed';
+ }
+ return '';
+ };
+ scope.$on('hawtioCollapseNav', function () {
+ collapsed = !collapsed;
+ });
+ scope.$watch('HawtioSubTabs.get()', function (subTabConfig) {
+ scope.subTabConfig = subTabConfig;
+ });
+ }
+ };
+ }]);
+ Navigation._module.directive('hawtioBreadcrumbsOutlet', ['HawtioBreadcrumbs', 'HawtioSubTabs', function (HawtioBreadcrumbs, HawtioSubTabs) {
+ return {
+ restrict: 'E',
+ scope: {},
+ template: "\n \n \n \n ![]()
\n {{subTab.label}}\n \n \n
\n \n \n \n
\n ",
+ link: function (scope, element, attrs) {
+ scope.breadcrumbs = HawtioBreadcrumbs;
+ scope.tabs = HawtioSubTabs;
+ scope.$watchCollection('breadcrumbs.get()', function (breadcrumbConfig) {
+ scope.breadcrumbConfig = breadcrumbConfig;
+ });
+ scope.$watchCollection('tabs.get()', function (tabs) {
+ var active = _.find(tabs, function (tab) { return tab.active; });
+ if (active) {
+ scope.pageTitle = active.label;
+ }
+ else {
+ scope.pageTitle = undefined;
+ }
+ });
+ }
+ };
+ }]);
+ Navigation._module.directive('platformSubTabsOutlet', ['HawtioSubTabs', function (HawtioSubTabs) {
+ var initialized = false;
+ return {
+ restrict: 'AE',
+ replace: true,
+ template: "\n \n \n
\n ",
+ link: function (scope, element, attrs) {
+ if (!initialized) {
+ try {
+ }
+ catch (err) {
+ }
+ initialized = true;
+ }
+ scope.HawtioSubTabs = HawtioSubTabs;
+ var collapsed = false;
+ scope.getClass = function () {
+ //log.debug("My class: ", element.attr('class'));
+ if (!scope.subTabConfig || !scope.subTabConfig.length) {
+ return 'hidden';
+ }
+ if (collapsed) {
+ return 'collapsed';
+ }
+ return '';
+ };
+ scope.$on('hawtioCollapseNav', function () {
+ collapsed = !collapsed;
+ });
+ scope.$watch('HawtioSubTabs.get()', function (subTabConfig) {
+ scope.subTabConfig = subTabConfig;
+ });
+ }
+ };
+ }]);
+ //hawtioPluginLoader.addModule('patternfly');
+ hawtioPluginLoader.addModule(Navigation.pluginName);
+})(Navigation || (Navigation = {}));
+
/// ' + build.displayName + '
' + + 'duration: ' + y + ' seconds
'; + if (date) { + tooltip += 'started: ' + date + '
'; + } + if (result) { + tooltip += 'result: ' + result + '
'; + } + if (x) { + var data = buildsSucceeded; + var key = successBuildKey; + if (!successBuildKey && (!result || !result.startsWith("SUCC"))) { + data = buildsFailed; + key = failedBuildKey; + } + data.push({ + tooltip: tooltip, + color: color, + x: x, y: y }); + } + }); + $scope.data = []; + if (buildsSucceeded.length) { + $scope.data.push({ + key: successBuildKey, + values: buildsSucceeded + }); + } + if (buildsFailed.length) { + $scope.data.push({ + key: failedBuildKey, + values: buildsFailed + }); + } + $scope.api.updateWithData($scope.data); + $timeout(function () { + $scope.api.update(); + }, 50); + } + function updateData() { + var metricsPath = $scope.jobId ? UrlHelpers.join("job", $scope.jobId, "fabric8/metrics") : "fabric8/metrics"; + var url = Kubernetes.kubernetesProxyUrlForServiceCurrentNamespace(Developer.jenkinsServiceNameAndPort, metricsPath); + Developer.log.info(""); + if (url && (!$scope.jenkins || Kubernetes.keepPollingModel)) { + $http.get(url, Developer.jenkinsHttpConfig). + success(function (data, status, headers, config) { + if (data) { + if (Developer.hasObjectChanged(data, $scope.entityChangedCache)) { + Developer.log.info("entity has changed!"); + $scope.metrics = data; + updateChartData(); + } + } + $scope.model.fetched = true; + Core.$apply($scope); + }). + error(function (data, status, headers, config) { + Developer.log.warn("Failed to load " + url + " " + data + " " + status); + }); + } + } + }]); +})(Developer || (Developer = {})); + +///- \r\n
- \r\n {{item.label}}\r\n \r\n
\r\n
\r\n");
@@ -21340,7 +21341,7 @@ $templateCache.put("plugins/developer/html/projectSelector.html","\r\n \r\n
\r\n \r\n \r\n
\r\n \r\n \r\n
\r\n \r\n
\r\n \r\n \r\n
\r\n \r\n \r\n \r\n
\r\n
\r\n | 已启用 | \r\n已停止 | \r\n\r\n {{volume.name}}\r\n | \r\n\r\n 云路径：{{volume.path}}\r\n | \r\n\r\n \r\n | \r\n\r\n 已用 {{volume.formatUsedSize}} / 共 {{volume.formatTotalSize}}\r\n | \r\n\r\n \r\n \r\n | \r\n
|---|---|---|---|---|---|---|
| \r\n \r\n \r\n | \r\n\r\n 服务器{{$index+1}}\r\n | \r\n\r\n {{row.ip}}\r\n | \r\n\r\n 存储路径:{{row.path}}\r\n | \r\n\r\n 已用 {{row.formatUsedSize}} / 共 {{row.formatAllSize}}\r\n | \r\n\r\n |
\r\n
\r\n\r\n
\r\n \r\n 是否删除：{{showDeleteVolume.item.name}} 云盘?\r\n
\r\n- \r\n \r\n \r\n \r\n \r\n \r\n \r\n\r\n
\r\n \r\n
\r\n\r\n \r\n \r\n
\r\n \r\n
\r\n\r\n
\r\n \r\n
\r\n \r\n \r\n
\r\n \r\n
\r\n \r\n
\r\n There are no projects in this workspace.
\r\n\r\n
\r\n
\r\n \r\n
\r\n");
$templateCache.put("plugins/developer/html/workspace.html","\r\n \r\n
\r\n\r\n \r\n \r\n
\r\n\r\n \r\n
\r\n \r\n \r\n
\r\n \r\n
\r\n\r\n
\r\n \r\n
\r\n \r\n \r\n
\r\n \r\n
\r\n \r\n
\r\n There are no tools currently available.
\r\n\r\n
\r\n \r\n
\r\n There are no tools currently available.
\r\n\r\n
\r\n \r\n
\r\n \r\n \r\n
\r\n \r\n \r\n {{env.label}}\r\n
\r\n \r\n\r\n
\r\n");
-$templateCache.put("plugins/developer/html/workspaces.html","\r\n \r\n
\r\n\r\n \r\n \r\n
\r\n\r\n \r\n \r\n
\r\n \r\n
\r\n\r\n
\r\n \r\n
\r\n \r\n \r\n
\r\n \r\n \r\n
\r\n \r\n \r\n \r\n
\r\n");
+$templateCache.put("plugins/developer/html/workspaces.html","\r\n
\r\n \r\n
\r\n \r\n
\r\n - \r\n
- {{item.label}} \r\n
\r\n
\r\n 当前没有可以查看的数据.
\r\n\r\n
\r\n
\r\n \r\n
\r\n \r\n \r\n \r\n \r\n \r\n \r\n \r\n \r\n
\r\n - \r\n
- 当前显示1~{{model.data.length}}行，共{{model.data.length}}行。 \r\n
- 每页显示\r\n 行\r\n \r\n
- 当前页码 \r\n
- \r\n \r\n \r\n\r\n\r\n \r\n \r\n \r\n \r\n\r\n \r\n
\r\n \r\n
\r\n \r\n\r\n \r\n \r\n
\r\n");
$templateCache.put("plugins/kubernetes/html/appDeployedTemplate.html","\r\n
\r\n \r\n
\r\n \r\n
\r\n - \r\n
- {{item.label}} \r\n
\r\n
\r\n 当前没有可以查看的数据.
\r\n\r\n
\r\n
\r\n \r\n
\r\n \r\n \r\n \r\n \r\n \r\n \r\n \r\n \r\n
\r\n - \r\n
- 当前显示{{(options.currentPageNum-1)*20 + 1}}~{{(options.currentPageNum-1)*20 + model.data.length}}行，共{{model.paramOptions.totalSize}}行, \r\n \r\n
- 当前页码 \r\n
- \r\n \r\n \r\n\r\n\r\n \r\n \r\n \r\n \r\n\r\n \r\n
\r\n \r\n
\r\n \r\n\r\n {{row.entity.$creationDate ? (row.entity.$creationDate | relativeTime) : \'\'}}\r\n
\r\n");
$templateCache.put("plugins/kubernetes/html/appDetailTemplate.html","\r\n
\r\n");
$templateCache.put("plugins/kubernetes/html/appIconTemplate.html","\r\n
\r\n\r\n \r\n \r\n \r\n ![]()
\r\n \r\n \r\n \r\n \r\n {{view.appName}}\r\n \r\n \r\n
\r\n \r\n \r\n \r\n {{view.service.$host}}\r\n \r\n {{view.service.$host}}\r\n \r\n
\r\n \r\n \r\n
\r\n\r\n
\r\n\r\n \r\n
\r\n \r\n deployed:\r\n {{view.createdDate | relativeTime}}\r\n
\r\n \r\n not deployed\r\n
\r\n \r\n
\r\n \r\n pod template:\r\n {{view.controllerId}} \r\n
\r\n \r\n no pod template\r\n
\r\n \r\n \r\n pods:\r\n \r\n {{view.podCount}}\r\n \r\n \r\n {{view.podCount}}\r\n \r\n \r\n
\r\n \r\n
\r\n \r\n
\r\n \r\n \r\n\r\n
\r\n \r\n \r\n
\r\n
\r\n | \r\n \r\n | \r\n\r\n \r\n \r\n \r\n | \r\n\r\n \r\n Pod {{pod.idAbbrev}}\r\n \r\n \r\n IP:\r\n {{pod.status.podIP}}\r\n \r\n | \r\n \r\n \r\n | \r\n
\r\n \r\n ![]()
\r\n \r\n \r\n \r\n {{row.entity.$info.name}}\r\n \r\n \r\n
\r\n");
diff --git a/plugins/developer/html/workspaces.html b/plugins/developer/html/workspaces.html
index f0f397a..7146d13 100644
--- a/plugins/developer/html/workspaces.html
+++ b/plugins/developer/html/workspaces.html
@@ -35,10 +35,10 @@
-
-
- 当前显示1~{{model.data.length}}行，共{{model.data.length}}行。 -
- 每页显示 +
- 当前显示{{(options.currentPageNum-1)*20 + 1}}~{{(options.currentPageNum-1)*20 + model.data.length}}行，共{{model.paramOptions.totalSize}}行, +
- 当前页码
-
diff --git a/plugins/developer/ts/workspaces.ts b/plugins/developer/ts/workspaces.ts index 27f8145..d31e6a4 100644 --- a/plugins/developer/ts/workspaces.ts +++ b/plugins/developer/ts/workspaces.ts @@ -326,6 +326,7 @@ module Developer { function init($scope,$location,$routeParams){ //$scope.model.updateModel(); $scope.keyQuery = ""; + $scope.model.initParamOptions(); $scope.model.updateParamOption("keyQuery", $scope.keyQuery); if(ConfigsModel.cluster!=null) $scope.volumes = ConfigsModel.cluster;