1
0
mirror of https://github.com/lensapp/lens.git synced 2025-05-20 05:10:56 +00:00

Adding getStatus() tests for each store

Signed-off-by: Alex Andreev <alex.andreev.email@gmail.com>
This commit is contained in:
Alex Andreev 2021-07-22 16:55:06 +03:00
parent 000b5a0edd
commit b1bd1c36d9
9 changed files with 1313 additions and 1 deletions

View File

@ -48,6 +48,7 @@ export interface KubeJsonApiMetadata {
annotations?: {
[annotation: string]: string;
};
[key: string]: any;
}
export interface KubeJsonApiData extends JsonApiData {

View File

@ -46,7 +46,7 @@ export class JobStore extends KubeObjectStore<Job> {
}
getStatuses(jobs?: Job[]) {
const status = { running: 0, succeeded: 0, failed: 0, pending: 0 };
const status = { succeeded: 0, running: 0, failed: 0, pending: 0 };
jobs.forEach(job => {
const pods = this.getChildPods(job);

View File

@ -0,0 +1,115 @@
/**
* Copyright (c) 2021 OpenLens Authors
*
* Permission is hereby granted, free of charge, to any person obtaining a copy of
* this software and associated documentation files (the "Software"), to deal in
* the Software without restriction, including without limitation the rights to
* use, copy, modify, merge, publish, distribute, sublicense, and/or sell copies of
* the Software, and to permit persons to whom the Software is furnished to do so,
* subject to the following conditions:
*
* The above copyright notice and this permission notice shall be included in all
* copies or substantial portions of the Software.
*
* THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
* IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS
* FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR
* COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER
* IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN
* CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
*/
import { cronJobStore } from "../+workloads-cronjobs/cronjob.store";
import { CronJob } from "../../api/endpoints";
const spec = {
schedule: "test",
concurrencyPolicy: "test",
suspend: true,
jobTemplate: {
metadata: {},
spec: {
template: {
metadata: {},
spec: {
containers: [] as any,
restartPolicy: "restart",
terminationGracePeriodSeconds: 1,
dnsPolicy: "no",
hostPID: true,
schedulerName: "string"
}
}
}
},
successfulJobsHistoryLimit: 1,
failedJobsHistoryLimit: 1
};
const scheduledCronJob = new CronJob({
apiVersion: "foo",
kind: "CronJob",
metadata: {
name: "scheduledCronJob",
resourceVersion: "scheduledCronJob",
uid: "scheduledCronJob",
namespace: "default",
},
});
const suspendedCronJob = new CronJob({
apiVersion: "foo",
kind: "CronJob",
metadata: {
name: "suspendedCronJob",
resourceVersion: "suspendedCronJob",
uid: "suspendedCronJob",
namespace: "default",
}
});
const otherSuspendedCronJob = new CronJob({
apiVersion: "foo",
kind: "CronJob",
metadata: {
name: "otherSuspendedCronJob",
resourceVersion: "otherSuspendedCronJob",
uid: "otherSuspendedCronJob",
namespace: "default",
},
});
scheduledCronJob.spec = { ...spec };
suspendedCronJob.spec = { ...spec };
otherSuspendedCronJob.spec = { ...spec };
scheduledCronJob.spec.suspend = false;
describe("CronJob Store tests", () => {
it("gets CronJob statuses in proper sorting order", () => {
const statuses = Object.entries(cronJobStore.getStatuses([
suspendedCronJob,
otherSuspendedCronJob,
scheduledCronJob
]));
expect(statuses).toEqual([
["scheduled", 1],
["suspended", 2],
]);
});
it("returns 0 for other statuses", () => {
let statuses = Object.entries(cronJobStore.getStatuses([scheduledCronJob]));
expect(statuses).toEqual([
["scheduled", 1],
["suspended", 0],
]);
statuses = Object.entries(cronJobStore.getStatuses([suspendedCronJob]));
expect(statuses).toEqual([
["scheduled", 0],
["suspended", 1],
]);
});
});

View File

@ -0,0 +1,181 @@
/**
* Copyright (c) 2021 OpenLens Authors
*
* Permission is hereby granted, free of charge, to any person obtaining a copy of
* this software and associated documentation files (the "Software"), to deal in
* the Software without restriction, including without limitation the rights to
* use, copy, modify, merge, publish, distribute, sublicense, and/or sell copies of
* the Software, and to permit persons to whom the Software is furnished to do so,
* subject to the following conditions:
*
* The above copyright notice and this permission notice shall be included in all
* copies or substantial portions of the Software.
*
* THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
* IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS
* FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR
* COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER
* IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN
* CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
*/
import { observable } from "mobx";
import { daemonSetStore } from "../+workloads-daemonsets/daemonsets.store";
import { podsStore } from "../+workloads-pods/pods.store";
import { DaemonSet, Pod } from "../../api/endpoints";
const runningDaemonSet = new DaemonSet({
apiVersion: "foo",
kind: "DaemonSet",
metadata: {
name: "runningDaemonSet",
resourceVersion: "runningDaemonSet",
uid: "runningDaemonSet",
namespace: "default",
},
});
const failedDaemonSet = new DaemonSet({
apiVersion: "foo",
kind: "DaemonSet",
metadata: {
name: "failedDaemonSet",
resourceVersion: "failedDaemonSet",
uid: "failedDaemonSet",
namespace: "default",
},
});
const pendingDaemonSet = new DaemonSet({
apiVersion: "foo",
kind: "DaemonSet",
metadata: {
name: "pendingDaemonSet",
resourceVersion: "pendingDaemonSet",
uid: "pendingDaemonSet",
namespace: "default",
},
});
const runningPod = new Pod({
apiVersion: "foo",
kind: "Pod",
metadata: {
name: "foobar",
resourceVersion: "foobar",
uid: "foobar",
ownerReferences: [{
uid: "runningDaemonSet",
}],
namespace: "default"
},
});
runningPod.status = {
phase: "Running",
conditions: [
{
type: "Initialized",
status: "True",
lastProbeTime: 1,
lastTransitionTime: "1",
},
{
type: "Ready",
status: "True",
lastProbeTime: 1,
lastTransitionTime: "1",
}
],
hostIP: "10.0.0.1",
podIP: "10.0.0.1",
startTime: "now",
containerStatuses: [],
initContainerStatuses: [],
};
const pendingPod = new Pod({
apiVersion: "foo",
kind: "Pod",
metadata: {
name: "foobar-pending",
resourceVersion: "foobar",
uid: "foobar-pending",
ownerReferences: [{
uid: "pendingDaemonSet",
}],
namespace: "default"
},
});
const failedPod = new Pod({
apiVersion: "foo",
kind: "Pod",
metadata: {
name: "foobar-failed",
resourceVersion: "foobar",
uid: "foobar-failed",
ownerReferences: [{
uid: "failedDaemonSet",
}],
namespace: "default"
},
});
failedPod.status = {
phase: "Failed",
conditions: [],
hostIP: "10.0.0.1",
podIP: "10.0.0.1",
startTime: "now",
};
describe("DaemonSet Store tests", () => {
beforeAll(() => {
podsStore.items = observable.array([
runningPod,
failedPod,
pendingPod
]);
});
it("gets DaemonSet statuses in proper sorting order", () => {
const statuses = Object.entries(daemonSetStore.getStatuses([
failedDaemonSet,
runningDaemonSet,
pendingDaemonSet
]));
expect(statuses).toEqual([
["running", 1],
["failed", 1],
["pending", 1],
]);
});
it("returns 0 for other statuses", () => {
let statuses = Object.entries(daemonSetStore.getStatuses([runningDaemonSet]));
expect(statuses).toEqual([
["running", 1],
["failed", 0],
["pending", 0],
]);
statuses = Object.entries(daemonSetStore.getStatuses([failedDaemonSet]));
expect(statuses).toEqual([
["running", 0],
["failed", 1],
["pending", 0],
]);
statuses = Object.entries(daemonSetStore.getStatuses([pendingDaemonSet]));
expect(statuses).toEqual([
["running", 0],
["failed", 0],
["pending", 1],
]);
});
});

View File

@ -0,0 +1,265 @@
/**
* Copyright (c) 2021 OpenLens Authors
*
* Permission is hereby granted, free of charge, to any person obtaining a copy of
* this software and associated documentation files (the "Software"), to deal in
* the Software without restriction, including without limitation the rights to
* use, copy, modify, merge, publish, distribute, sublicense, and/or sell copies of
* the Software, and to permit persons to whom the Software is furnished to do so,
* subject to the following conditions:
*
* The above copyright notice and this permission notice shall be included in all
* copies or substantial portions of the Software.
*
* THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
* IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS
* FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR
* COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER
* IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN
* CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
*/
import { observable } from "mobx";
import { deploymentStore } from "../+workloads-deployments/deployments.store";
import { podsStore } from "../+workloads-pods/pods.store";
import { Deployment, Pod } from "../../api/endpoints";
const spec = {
containers: [{
name: "some",
image: "someimage",
resources: {
requests: {
cpu: "2",
memory: "2Gi"
},
},
terminationMessagePath: "test",
terminationMessagePolicy: "test",
imagePullPolicy: "test",
}],
restartPolicy: "restart",
terminationGracePeriodSeconds: 1200,
dnsPolicy: "dns",
serviceAccountName: "test",
serviceAccount: "test",
securityContext: {},
schedulerName: "test"
};
const runningDeployment = new Deployment({
apiVersion: "foo",
kind: "Deployment",
metadata: {
name: "foobar",
resourceVersion: "foobar",
uid: "foobar",
namespace: "default",
},
});
runningDeployment.spec = {
replicas: 1,
selector: { matchLabels: {} },
strategy: {
type: "test",
rollingUpdate: {
maxSurge: 1,
maxUnavailable: 1
}
},
template: {
metadata: {
labels: {
"name": "kube-state-metrics"
}
},
spec
}
};
const failedDeployment = new Deployment({
apiVersion: "foo",
kind: "Deployment",
metadata: {
name: "failedDeployment",
resourceVersion: "failedDeployment",
uid: "failedDeployment",
namespace: "default",
},
});
failedDeployment.spec = {
replicas: 1,
selector: { matchLabels: {} },
strategy: {
type: "test",
rollingUpdate: {
maxSurge: 1,
maxUnavailable: 1
}
},
template: {
metadata: {
labels: {
"name": "failedpods"
}
},
spec
}
};
const pendingDeployment = new Deployment({
apiVersion: "foo",
kind: "Deployment",
metadata: {
name: "pendingDeployment",
resourceVersion: "pendingDeployment",
uid: "pendingDeployment",
namespace: "default",
},
});
pendingDeployment.spec = {
replicas: 1,
selector: { matchLabels: {} },
strategy: {
type: "test",
rollingUpdate: {
maxSurge: 1,
maxUnavailable: 1
}
},
template: {
metadata: {
labels: {
"mydeployment": "true"
}
},
spec
}
};
const runningPod = new Pod({
apiVersion: "foo",
kind: "Pod",
metadata: {
name: "foobar",
resourceVersion: "foobar",
uid: "foobar",
labels: {
"name": "kube-state-metrics"
},
namespace: "default"
},
});
runningPod.status = {
phase: "Running",
conditions: [
{
type: "Initialized",
status: "True",
lastProbeTime: 1,
lastTransitionTime: "1",
},
{
type: "Ready",
status: "True",
lastProbeTime: 1,
lastTransitionTime: "1",
}
],
hostIP: "10.0.0.1",
podIP: "10.0.0.1",
startTime: "now",
containerStatuses: [],
initContainerStatuses: [],
};
const pendingPod = new Pod({
apiVersion: "foo",
kind: "Pod",
metadata: {
name: "foobar-pending",
resourceVersion: "foobar",
uid: "foobar-pending",
labels: {
"mydeployment": "true"
},
namespace: "default"
},
});
const failedPod = new Pod({
apiVersion: "foo",
kind: "Pod",
metadata: {
name: "foobar-failed",
resourceVersion: "foobar",
uid: "foobar-failed",
labels: {
"name": "failedpods"
},
namespace: "default"
},
});
failedPod.status = {
phase: "Failed",
conditions: [],
hostIP: "10.0.0.1",
podIP: "10.0.0.1",
startTime: "now",
};
describe("Deployment Store tests", () => {
beforeAll(() => {
// Add pods to pod store
podsStore.items = observable.array([
runningPod,
failedPod,
pendingPod
]);
});
it("gets Deployment statuses in proper sorting order", () => {
const statuses = Object.entries(deploymentStore.getStatuses([
failedDeployment,
runningDeployment,
pendingDeployment
]));
expect(statuses).toEqual([
["running", 1],
["failed", 1],
["pending", 1],
]);
});
it("returns 0 for other statuses", () => {
let statuses = Object.entries(deploymentStore.getStatuses([runningDeployment]));
expect(statuses).toEqual([
["running", 1],
["failed", 0],
["pending", 0],
]);
statuses = Object.entries(deploymentStore.getStatuses([failedDeployment]));
expect(statuses).toEqual([
["running", 0],
["failed", 1],
["pending", 0],
]);
statuses = Object.entries(deploymentStore.getStatuses([pendingDeployment]));
expect(statuses).toEqual([
["running", 0],
["failed", 0],
["pending", 1],
]);
});
});

View File

@ -0,0 +1,228 @@
/**
* Copyright (c) 2021 OpenLens Authors
*
* Permission is hereby granted, free of charge, to any person obtaining a copy of
* this software and associated documentation files (the "Software"), to deal in
* the Software without restriction, including without limitation the rights to
* use, copy, modify, merge, publish, distribute, sublicense, and/or sell copies of
* the Software, and to permit persons to whom the Software is furnished to do so,
* subject to the following conditions:
*
* The above copyright notice and this permission notice shall be included in all
* copies or substantial portions of the Software.
*
* THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
* IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS
* FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR
* COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER
* IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN
* CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
*/
import { observable } from "mobx";
import { jobStore } from "../+workloads-jobs/job.store";
import { podsStore } from "../+workloads-pods/pods.store";
import { Job, Pod } from "../../api/endpoints";
const runningJob = new Job({
apiVersion: "foo",
kind: "Job",
metadata: {
name: "runningJob",
resourceVersion: "runningJob",
uid: "runningJob",
namespace: "default",
},
});
const failedJob = new Job({
apiVersion: "foo",
kind: "Job",
metadata: {
name: "failedJob",
resourceVersion: "failedJob",
uid: "failedJob",
namespace: "default",
},
});
const pendingJob = new Job({
apiVersion: "foo",
kind: "Job",
metadata: {
name: "pendingJob",
resourceVersion: "pendingJob",
uid: "pendingJob",
namespace: "default",
},
});
const succeededJob = new Job({
apiVersion: "foo",
kind: "Job",
metadata: {
name: "succeededJob",
resourceVersion: "succeededJob",
uid: "succeededJob",
namespace: "default",
},
});
const runningPod = new Pod({
apiVersion: "foo",
kind: "Pod",
metadata: {
name: "foobar",
resourceVersion: "foobar",
uid: "foobar",
ownerReferences: [{
uid: "runningJob",
}],
namespace: "default"
},
});
runningPod.status = {
phase: "Running",
conditions: [
{
type: "Initialized",
status: "True",
lastProbeTime: 1,
lastTransitionTime: "1",
},
{
type: "Ready",
status: "True",
lastProbeTime: 1,
lastTransitionTime: "1",
}
],
hostIP: "10.0.0.1",
podIP: "10.0.0.1",
startTime: "now",
containerStatuses: [],
initContainerStatuses: [],
};
const pendingPod = new Pod({
apiVersion: "foo",
kind: "Pod",
metadata: {
name: "foobar-pending",
resourceVersion: "foobar",
uid: "foobar-pending",
ownerReferences: [{
uid: "pendingJob",
}],
namespace: "default"
},
});
const failedPod = new Pod({
apiVersion: "foo",
kind: "Pod",
metadata: {
name: "foobar-failed",
resourceVersion: "foobar",
uid: "foobar-failed",
ownerReferences: [{
uid: "failedJob",
}],
namespace: "default"
},
});
failedPod.status = {
phase: "Failed",
conditions: [],
hostIP: "10.0.0.1",
podIP: "10.0.0.1",
startTime: "now",
};
const succeededPod = new Pod({
apiVersion: "foo",
kind: "Pod",
metadata: {
name: "foobar-succeeded",
resourceVersion: "foobar",
uid: "foobar-succeeded",
ownerReferences: [{
uid: "succeededJob",
}],
},
});
succeededPod.status = {
phase: "Succeeded",
conditions: [],
hostIP: "10.0.0.1",
podIP: "10.0.0.1",
startTime: "now",
};
describe("Job Store tests", () => {
beforeAll(() => {
podsStore.items = observable.array([
runningPod,
failedPod,
pendingPod,
succeededPod
]);
});
it("gets Job statuses in proper sorting order", () => {
const statuses = Object.entries(jobStore.getStatuses([
failedJob,
succeededJob,
runningJob,
pendingJob
]));
expect(statuses).toEqual([
["succeeded", 1],
["running", 1],
["failed", 1],
["pending", 1],
]);
});
it("returns 0 for other statuses", () => {
let statuses = Object.entries(jobStore.getStatuses([succeededJob]));
expect(statuses).toEqual([
["succeeded", 1],
["running", 0],
["failed", 0],
["pending", 0],
]);
statuses = Object.entries(jobStore.getStatuses([runningJob]));
expect(statuses).toEqual([
["succeeded", 0],
["running", 1],
["failed", 0],
["pending", 0],
]);
statuses = Object.entries(jobStore.getStatuses([failedJob]));
expect(statuses).toEqual([
["succeeded", 0],
["running", 0],
["failed", 1],
["pending", 0],
]);
statuses = Object.entries(jobStore.getStatuses([pendingJob]));
expect(statuses).toEqual([
["succeeded", 0],
["running", 0],
["failed", 0],
["pending", 1],
]);
});
});

View File

@ -0,0 +1,159 @@
/**
* Copyright (c) 2021 OpenLens Authors
*
* Permission is hereby granted, free of charge, to any person obtaining a copy of
* this software and associated documentation files (the "Software"), to deal in
* the Software without restriction, including without limitation the rights to
* use, copy, modify, merge, publish, distribute, sublicense, and/or sell copies of
* the Software, and to permit persons to whom the Software is furnished to do so,
* subject to the following conditions:
*
* The above copyright notice and this permission notice shall be included in all
* copies or substantial portions of the Software.
*
* THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
* IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS
* FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR
* COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER
* IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN
* CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
*/
import { Pod } from "../../api/endpoints";
import { podsStore } from "../+workloads-pods/pods.store";
const runningPod = new Pod({
apiVersion: "foo",
kind: "Pod",
metadata: {
name: "foobar",
resourceVersion: "foobar",
uid: "foobar",
},
});
runningPod.status = {
phase: "Running",
conditions: [
{
type: "Initialized",
status: "True",
lastProbeTime: 1,
lastTransitionTime: "1",
},
{
type: "Ready",
status: "True",
lastProbeTime: 1,
lastTransitionTime: "1",
}
],
hostIP: "10.0.0.1",
podIP: "10.0.0.1",
startTime: "now",
containerStatuses: [],
initContainerStatuses: [],
};
const pendingPod = new Pod({
apiVersion: "foo",
kind: "Pod",
metadata: {
name: "foobar-pending",
resourceVersion: "foobar",
uid: "foobar-pending",
},
});
const failedPod = new Pod({
apiVersion: "foo",
kind: "Pod",
metadata: {
name: "foobar-failed",
resourceVersion: "foobar",
uid: "foobar-failed",
},
});
failedPod.status = {
phase: "Failed",
conditions: [],
hostIP: "10.0.0.1",
podIP: "10.0.0.1",
startTime: "now",
};
const evictedPod = new Pod({
apiVersion: "foo",
kind: "Pod",
metadata: {
name: "foobar-evicted",
resourceVersion: "foobar",
uid: "foobar-evicted",
},
});
evictedPod.status = {
phase: "Failed",
reason: "Evicted",
conditions: [],
hostIP: "10.0.0.1",
podIP: "10.0.0.1",
startTime: "now",
};
const succeededPod = new Pod({
apiVersion: "foo",
kind: "Pod",
metadata: {
name: "foobar-succeeded",
resourceVersion: "foobar",
uid: "foobar-succeeded",
},
});
succeededPod.status = {
phase: "Succeeded",
conditions: [],
hostIP: "10.0.0.1",
podIP: "10.0.0.1",
startTime: "now",
};
describe("Pod Store tests", () => {
it("gets Pod statuses in proper sorting order", () => {
const statuses = Object.entries(podsStore.getStatuses([
pendingPod,
runningPod,
succeededPod,
failedPod,
evictedPod,
evictedPod
]));
expect(statuses).toEqual([
["Succeeded", 1],
["Running", 1],
["Pending", 1],
["Failed", 1],
["Evicted", 2],
]);
});
it("counts statuses properly", () => {
const statuses = Object.entries(podsStore.getStatuses([
pendingPod,
pendingPod,
pendingPod,
runningPod,
failedPod,
failedPod,
]));
expect(statuses).toEqual([
["Running", 1],
["Pending", 3],
["Failed", 2],
]);
});
});

View File

@ -0,0 +1,181 @@
/**
* Copyright (c) 2021 OpenLens Authors
*
* Permission is hereby granted, free of charge, to any person obtaining a copy of
* this software and associated documentation files (the "Software"), to deal in
* the Software without restriction, including without limitation the rights to
* use, copy, modify, merge, publish, distribute, sublicense, and/or sell copies of
* the Software, and to permit persons to whom the Software is furnished to do so,
* subject to the following conditions:
*
* The above copyright notice and this permission notice shall be included in all
* copies or substantial portions of the Software.
*
* THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
* IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS
* FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR
* COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER
* IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN
* CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
*/
import { observable } from "mobx";
import { podsStore } from "../+workloads-pods/pods.store";
import { replicaSetStore } from "../+workloads-replicasets/replicasets.store";
import { ReplicaSet, Pod } from "../../api/endpoints";
const runningReplicaSet = new ReplicaSet({
apiVersion: "foo",
kind: "ReplicaSet",
metadata: {
name: "runningReplicaSet",
resourceVersion: "runningReplicaSet",
uid: "runningReplicaSet",
namespace: "default",
},
});
const failedReplicaSet = new ReplicaSet({
apiVersion: "foo",
kind: "ReplicaSet",
metadata: {
name: "failedReplicaSet",
resourceVersion: "failedReplicaSet",
uid: "failedReplicaSet",
namespace: "default",
},
});
const pendingReplicaSet = new ReplicaSet({
apiVersion: "foo",
kind: "ReplicaSet",
metadata: {
name: "pendingReplicaSet",
resourceVersion: "pendingReplicaSet",
uid: "pendingReplicaSet",
namespace: "default",
},
});
const runningPod = new Pod({
apiVersion: "foo",
kind: "Pod",
metadata: {
name: "foobar",
resourceVersion: "foobar",
uid: "foobar",
ownerReferences: [{
uid: "runningReplicaSet",
}],
namespace: "default"
},
});
runningPod.status = {
phase: "Running",
conditions: [
{
type: "Initialized",
status: "True",
lastProbeTime: 1,
lastTransitionTime: "1",
},
{
type: "Ready",
status: "True",
lastProbeTime: 1,
lastTransitionTime: "1",
}
],
hostIP: "10.0.0.1",
podIP: "10.0.0.1",
startTime: "now",
containerStatuses: [],
initContainerStatuses: [],
};
const pendingPod = new Pod({
apiVersion: "foo",
kind: "Pod",
metadata: {
name: "foobar-pending",
resourceVersion: "foobar",
uid: "foobar-pending",
ownerReferences: [{
uid: "pendingReplicaSet",
}],
namespace: "default"
},
});
const failedPod = new Pod({
apiVersion: "foo",
kind: "Pod",
metadata: {
name: "foobar-failed",
resourceVersion: "foobar",
uid: "foobar-failed",
ownerReferences: [{
uid: "failedReplicaSet",
}],
namespace: "default"
},
});
failedPod.status = {
phase: "Failed",
conditions: [],
hostIP: "10.0.0.1",
podIP: "10.0.0.1",
startTime: "now",
};
describe("ReplicaSet Store tests", () => {
beforeAll(() => {
podsStore.items = observable.array([
runningPod,
failedPod,
pendingPod
]);
});
it("gets ReplicaSet statuses in proper sorting order", () => {
const statuses = Object.entries(replicaSetStore.getStatuses([
failedReplicaSet,
runningReplicaSet,
pendingReplicaSet
]));
expect(statuses).toEqual([
["running", 1],
["failed", 1],
["pending", 1],
]);
});
it("returns 0 for other statuses", () => {
let statuses = Object.entries(replicaSetStore.getStatuses([runningReplicaSet]));
expect(statuses).toEqual([
["running", 1],
["failed", 0],
["pending", 0],
]);
statuses = Object.entries(replicaSetStore.getStatuses([failedReplicaSet]));
expect(statuses).toEqual([
["running", 0],
["failed", 1],
["pending", 0],
]);
statuses = Object.entries(replicaSetStore.getStatuses([pendingReplicaSet]));
expect(statuses).toEqual([
["running", 0],
["failed", 0],
["pending", 1],
]);
});
});

View File

@ -0,0 +1,182 @@
/**
* Copyright (c) 2021 OpenLens Authors
*
* Permission is hereby granted, free of charge, to any person obtaining a copy of
* this software and associated documentation files (the "Software"), to deal in
* the Software without restriction, including without limitation the rights to
* use, copy, modify, merge, publish, distribute, sublicense, and/or sell copies of
* the Software, and to permit persons to whom the Software is furnished to do so,
* subject to the following conditions:
*
* The above copyright notice and this permission notice shall be included in all
* copies or substantial portions of the Software.
*
* THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
* IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS
* FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR
* COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER
* IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN
* CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
*/
import { observable } from "mobx";
import { podsStore } from "../+workloads-pods/pods.store";
import { statefulSetStore } from "../+workloads-statefulsets/statefulset.store";
import { StatefulSet, Pod } from "../../api/endpoints";
const runningStatefulSet = new StatefulSet({
apiVersion: "foo",
kind: "StatefulSet",
metadata: {
name: "runningStatefulSet",
resourceVersion: "runningStatefulSet",
uid: "runningStatefulSet",
namespace: "default",
},
});
const failedStatefulSet = new StatefulSet({
apiVersion: "foo",
kind: "StatefulSet",
metadata: {
name: "failedStatefulSet",
resourceVersion: "failedStatefulSet",
uid: "failedStatefulSet",
namespace: "default",
},
});
const pendingStatefulSet = new StatefulSet({
apiVersion: "foo",
kind: "StatefulSet",
metadata: {
name: "pendingStatefulSet",
resourceVersion: "pendingStatefulSet",
uid: "pendingStatefulSet",
namespace: "default",
},
});
const runningPod = new Pod({
apiVersion: "foo",
kind: "Pod",
metadata: {
name: "foobar",
resourceVersion: "foobar",
uid: "foobar",
ownerReferences: [{
uid: "runningStatefulSet",
}],
namespace: "default"
},
});
runningPod.status = {
phase: "Running",
conditions: [
{
type: "Initialized",
status: "True",
lastProbeTime: 1,
lastTransitionTime: "1",
},
{
type: "Ready",
status: "True",
lastProbeTime: 1,
lastTransitionTime: "1",
}
],
hostIP: "10.0.0.1",
podIP: "10.0.0.1",
startTime: "now",
containerStatuses: [],
initContainerStatuses: [],
};
const pendingPod = new Pod({
apiVersion: "foo",
kind: "Pod",
metadata: {
name: "foobar-pending",
resourceVersion: "foobar",
uid: "foobar-pending",
ownerReferences: [{
uid: "pendingStatefulSet",
}],
namespace: "default"
},
});
const failedPod = new Pod({
apiVersion: "foo",
kind: "Pod",
metadata: {
name: "foobar-failed",
resourceVersion: "foobar",
uid: "foobar-failed",
ownerReferences: [{
uid: "failedStatefulSet",
}],
namespace: "default"
},
});
failedPod.status = {
phase: "Failed",
conditions: [],
hostIP: "10.0.0.1",
podIP: "10.0.0.1",
startTime: "now",
};
describe("StatefulSet Store tests", () => {
beforeAll(() => {
// Add pods to pod store
podsStore.items = observable.array([
runningPod,
failedPod,
pendingPod
]);
});
it("gets StatefulSet statuses in proper sorting order", () => {
const statuses = Object.entries(statefulSetStore.getStatuses([
failedStatefulSet,
runningStatefulSet,
pendingStatefulSet
]));
expect(statuses).toEqual([
["running", 1],
["failed", 1],
["pending", 1],
]);
});
it("returns 0 for other statuses", () => {
let statuses = Object.entries(statefulSetStore.getStatuses([runningStatefulSet]));
expect(statuses).toEqual([
["running", 1],
["failed", 0],
["pending", 0],
]);
statuses = Object.entries(statefulSetStore.getStatuses([failedStatefulSet]));
expect(statuses).toEqual([
["running", 0],
["failed", 1],
["pending", 0],
]);
statuses = Object.entries(statefulSetStore.getStatuses([pendingStatefulSet]));
expect(statuses).toEqual([
["running", 0],
["failed", 0],
["pending", 1],
]);
});
});