blob: 0602a15e862d0ecbaae7eb4f49be1b90ab6b7676 [file] [log] [blame]
import { Injectable } from '@angular/core';
import { Workflow } from './workflow.model';
import { HelixService } from '../../core/helix.service';
@Injectable()
export class WorkflowService extends HelixService {
public getAll(clusterName: string) {
return this
.request(`/clusters/${ clusterName }/workflows`)
.map(data => data.Workflows.sort());
}
public get(clusterName: string, workflowName: string) {
return this
.request(`/clusters/${ clusterName }/workflows/${ workflowName }`)
.map(data => new Workflow(data, clusterName));
}
public stop(clusterName: string, workflowName: string) {
return this
.post(`/clusters/${ clusterName }/workflows/${ workflowName }?command=stop`, null);
}
public resume(clusterName: string, workflowName: string) {
return this
.post(`/clusters/${ clusterName }/workflows/${ workflowName }?command=resume`, null);
}
}