Upstream/harbor
1
0
Fork 0
mirror of https://github.com/goharbor/harbor.git synced 2024-12-24 01:27:49 +01:00
Code Issues Projects Releases Wiki Activity

Get the number of execution status every 10s and refresh the task list

Browse Source 
Signed-off-by: FangyuanCheng <fangyuanc@vmware.com>
This commit is contained in:
FangyuanCheng 2019-04-25 18:09:01 +08:00
parent 3296e2acae
commit 4768ad33ed
2 changed files with 23 additions and 20 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
src/portal/lib/src/replication/replication-tasks/replication-tasks.component.html
View File

@ -30,6 +30,7 @@
<div> <div>
<button class="btn btn-primary btn-sm" (click)="stopJob()" <button class="btn btn-primary btn-sm" (click)="stopJob()"
[disabled]="stopOnGoing">{{'REPLICATION.STOPJOB' | translate}}</button> [disabled]="stopOnGoing">{{'REPLICATION.STOPJOB' | translate}}</button>
<span class="spinner spinner-inline" [hidden]="inProgress === false"></span>
</div> </div>
</div> </div>
</div> </div>

42
src/portal/lib/src/replication/replication-tasks/replication-tasks.component.ts
View File

@ -20,6 +20,7 @@ const taskStatus: any = {
}) })
export class ReplicationTasksComponent implements OnInit, OnDestroy { export class ReplicationTasksComponent implements OnInit, OnDestroy {
isOpenFilterTag: boolean; isOpenFilterTag: boolean;
inProgress: boolean = false;
currentPage: number = 1; currentPage: number = 1;
selectedRow: []; selectedRow: [];
pageSize: number = DEFAULT_PAGE_SIZE; pageSize: number = DEFAULT_PAGE_SIZE;
@ -54,10 +55,13 @@ export class ReplicationTasksComponent implements OnInit, OnDestroy {
} }
getExecutionDetail(): void { getExecutionDetail(): void {
this.inProgress = true;
if (this.executionId) { if (this.executionId) {
this.replicationService.getExecutionById(this.executionId) this.replicationService.getExecutionById(this.executionId)
.pipe(finalize(() => (this.inProgress = false)))
.subscribe(res => { .subscribe(res => {
this.executions = res.data; this.executions = res.data;
this.clrLoadPage();
}, },
error => { error => {
this.errorHandler.error(error); this.errorHandler.error(error);
@ -65,6 +69,24 @@ export class ReplicationTasksComponent implements OnInit, OnDestroy {
} }
} }
clrLoadPage(): void {
if (!this.timerDelay) {
this.timerDelay = timer(10000, 10000).subscribe(() => {
let count: number = 0;
if (this.executions['in_progress'] > 0) {
count++;
}
if (count > 0) {
this.getExecutionDetail();
this.clrLoadTasks();
} else {
this.timerDelay.unsubscribe();
this.timerDelay = null;
}
});
}
}
public get trigger(): string { public get trigger(): string {
return this.executions && this.executions['trigger'] return this.executions && this.executions['trigger']
? this.executions['trigger'] ? this.executions['trigger']
@ -128,26 +150,6 @@ export class ReplicationTasksComponent implements OnInit, OnDestroy {
.pipe(finalize(() => (this.loading = false))) .pipe(finalize(() => (this.loading = false)))
.subscribe(res => { .subscribe(res => {
this.tasks = res; // Keep the data this.tasks = res; // Keep the data
if (!this.timerDelay) {
this.timerDelay = timer(10000, 10000).subscribe(() => {
let count: number = 0;
this.tasks.forEach(tasks => {
if (
tasks.status.toLowerCase() === taskStatus.PENDING ||
tasks.status.toLowerCase() === taskStatus.RUNNING ||
tasks.status.toLowerCase() === taskStatus.SCHEDULED
) {
count++;
}
});
if (count > 0) {
this.clrLoadTasks();
} else {
this.timerDelay.unsubscribe();
this.timerDelay = null;
}
});
}
}, },
error => { error => {
this.errorHandler.error(error); this.errorHandler.error(error);