/*
 * Code generated by Speakeasy (https://speakeasy.com). DO NOT EDIT.
 */

import { computeJobsCreateJob } from "../funcs/computeJobsCreateJob.js";
import { computeJobsGetJob } from "../funcs/computeJobsGetJob.js";
import { computeJobsListJobEvents } from "../funcs/computeJobsListJobEvents.js";
import { computeJobsListJobInstances } from "../funcs/computeJobsListJobInstances.js";
import { computeJobsListJobLogs } from "../funcs/computeJobsListJobLogs.js";
import { computeJobsListJobs } from "../funcs/computeJobsListJobs.js";
import { computeJobsTerminateJob } from "../funcs/computeJobsTerminateJob.js";
import { ClientSDK, RequestOptions } from "../lib/sdks.js";
import * as operations from "../models/operations/index.js";
import { unwrapAsync } from "../types/fp.js";

export class ComputeJobs extends ClientSDK {
  /**
   * List jobs
   */
  async listJobs(
    request: operations.ListJobsRequest,
    options?: RequestOptions,
  ): Promise<operations.ListJobsResponse> {
    return unwrapAsync(computeJobsListJobs(
      this,
      request,
      options,
    ));
  }

  /**
   * Create a job
   */
  async createJob(
    request: operations.CreateJobRequest,
    options?: RequestOptions,
  ): Promise<operations.CreateJobResponse> {
    return unwrapAsync(computeJobsCreateJob(
      this,
      request,
      options,
    ));
  }

  /**
   * Get a job
   */
  async getJob(
    request: operations.GetJobRequest,
    options?: RequestOptions,
  ): Promise<operations.GetJobResponse> {
    return unwrapAsync(computeJobsGetJob(
      this,
      request,
      options,
    ));
  }

  /**
   * List job events
   */
  async listJobEvents(
    request: operations.ListJobEventsRequest,
    options?: RequestOptions,
  ): Promise<operations.ListJobEventsResponse> {
    return unwrapAsync(computeJobsListJobEvents(
      this,
      request,
      options,
    ));
  }

  /**
   * List observed job instances
   */
  async listJobInstances(
    request: operations.ListJobInstancesRequest,
    options?: RequestOptions,
  ): Promise<operations.ListJobInstancesResponse> {
    return unwrapAsync(computeJobsListJobInstances(
      this,
      request,
      options,
    ));
  }

  /**
   * List job logs
   */
  async listJobLogs(
    request: operations.ListJobLogsRequest,
    options?: RequestOptions,
  ): Promise<operations.ListJobLogsResponse> {
    return unwrapAsync(computeJobsListJobLogs(
      this,
      request,
      options,
    ));
  }

  /**
   * Terminate a job
   */
  async terminateJob(
    request: operations.TerminateJobRequest,
    options?: RequestOptions,
  ): Promise<operations.TerminateJobResponse> {
    return unwrapAsync(computeJobsTerminateJob(
      this,
      request,
      options,
    ));
  }
}