mirror of https://github.com/portainer/portainer
98 lines
2.6 KiB
JavaScript
98 lines
2.6 KiB
JavaScript
import angular from 'angular';
|
|
import PortainerError from 'Portainer/error';
|
|
|
|
import { KubernetesCommonParams } from 'Kubernetes/models/common/params';
|
|
|
|
class KubernetesPodService {
|
|
/* @ngInject */
|
|
constructor($async, KubernetesPods) {
|
|
this.$async = $async;
|
|
this.KubernetesPods = KubernetesPods;
|
|
|
|
this.getAsync = this.getAsync.bind(this);
|
|
this.getAllAsync = this.getAllAsync.bind(this);
|
|
this.logsAsync = this.logsAsync.bind(this);
|
|
this.deleteAsync = this.deleteAsync.bind(this);
|
|
}
|
|
|
|
async getAsync(namespace, name) {
|
|
try {
|
|
const params = new KubernetesCommonParams();
|
|
params.id = name;
|
|
const [raw, yaml] = await Promise.all([this.KubernetesPods(namespace).get(params).$promise, this.KubernetesPods(namespace).getYaml(params).$promise]);
|
|
const res = {
|
|
Raw: raw,
|
|
Yaml: yaml.data,
|
|
};
|
|
return res;
|
|
} catch (err) {
|
|
throw new PortainerError('Unable to retrieve pod', err);
|
|
}
|
|
}
|
|
|
|
/**
|
|
* GET ALL
|
|
*/
|
|
async getAllAsync(namespace) {
|
|
try {
|
|
const data = await this.KubernetesPods(namespace).get().$promise;
|
|
return data.items;
|
|
} catch (err) {
|
|
throw new PortainerError('Unable to retrieve pods', err);
|
|
}
|
|
}
|
|
|
|
get(namespace, name) {
|
|
if (name) {
|
|
return this.$async(this.getAsync, namespace, name);
|
|
}
|
|
return this.$async(this.getAllAsync, namespace);
|
|
}
|
|
|
|
/**
|
|
* Logs
|
|
*
|
|
* @param {string} namespace
|
|
* @param {string} podName
|
|
* @param {string} containerName
|
|
*/
|
|
async logsAsync(namespace, podName, containerName) {
|
|
try {
|
|
const params = new KubernetesCommonParams();
|
|
params.id = podName;
|
|
if (containerName) {
|
|
params.container = containerName;
|
|
}
|
|
const data = await this.KubernetesPods(namespace).logs(params).$promise;
|
|
return data.logs.length === 0 ? [] : data.logs.split('\n');
|
|
} catch (err) {
|
|
throw new PortainerError('Unable to retrieve pod logs', err);
|
|
}
|
|
}
|
|
|
|
logs(namespace, podName, containerName) {
|
|
return this.$async(this.logsAsync, namespace, podName, containerName);
|
|
}
|
|
|
|
/**
|
|
* DELETE
|
|
*/
|
|
async deleteAsync(pod) {
|
|
try {
|
|
const params = new KubernetesCommonParams();
|
|
params.id = pod.Name;
|
|
const namespace = pod.Namespace;
|
|
await this.KubernetesPods(namespace).delete(params).$promise;
|
|
} catch (err) {
|
|
throw new PortainerError('Unable to remove pod', err);
|
|
}
|
|
}
|
|
|
|
delete(pod) {
|
|
return this.$async(this.deleteAsync, pod);
|
|
}
|
|
}
|
|
|
|
export default KubernetesPodService;
|
|
angular.module('portainer.kubernetes').service('KubernetesPodService', KubernetesPodService);
|