Package ch.so.agi.gretl.control.server.web

Class WorkerController

java.lang.Object
ch.so.agi.gretl.control.server.web.WorkerController
@RestController public class WorkerController extends Object

  • Constructor Summary

    Constructors
    Constructor
    Description
    WorkerController(WorkerAuthentication authentication, WorkerService workerService, RunService runService)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    appendLog(String runId, ch.so.agi.gretl.control.api.RunLogAppendRequest request, jakarta.servlet.http.HttpServletRequest servletRequest)
     
    Map<String,Boolean>
    cancelRequested(String runId, jakarta.servlet.http.HttpServletRequest servletRequest)
     
    ch.so.agi.gretl.control.api.RunClaimResponse
    claim(ch.so.agi.gretl.control.api.RunClaimRequest request, jakarta.servlet.http.HttpServletRequest servletRequest)
     
    void
    heartbeat(ch.so.agi.gretl.control.api.WorkerHeartbeatRequest request, jakarta.servlet.http.HttpServletRequest servletRequest)
     
    ch.so.agi.gretl.control.api.WorkerRegistrationResponse
    register(ch.so.agi.gretl.control.api.WorkerRegistrationRequest request, jakarta.servlet.http.HttpServletRequest servletRequest)
     
    void
    updateRunStatus(String runId, ch.so.agi.gretl.control.api.RunStatusUpdateRequest request, jakarta.servlet.http.HttpServletRequest servletRequest)
     
    List<WorkerRecord>
    workers()
     

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

  • Constructor Details

  • Method Details

    • workers

      @GetMapping("/api/workers") public List<WorkerRecord> workers()

    • register

      @PostMapping("/api/worker/register") public ch.so.agi.gretl.control.api.WorkerRegistrationResponse register(@RequestBody ch.so.agi.gretl.control.api.WorkerRegistrationRequest request, jakarta.servlet.http.HttpServletRequest servletRequest)

    • heartbeat

      @PostMapping("/api/worker/heartbeat") public void heartbeat(@RequestBody ch.so.agi.gretl.control.api.WorkerHeartbeatRequest request, jakarta.servlet.http.HttpServletRequest servletRequest)

    • claim

      @PostMapping("/api/worker/claim") public ch.so.agi.gretl.control.api.RunClaimResponse claim(@RequestBody ch.so.agi.gretl.control.api.RunClaimRequest request, jakarta.servlet.http.HttpServletRequest servletRequest)

    • updateRunStatus

      @PostMapping("/api/worker/runs/{runId}/status") public void updateRunStatus(@PathVariable String runId, @RequestBody ch.so.agi.gretl.control.api.RunStatusUpdateRequest request, jakarta.servlet.http.HttpServletRequest servletRequest)

    • appendLog

      @PostMapping("/api/worker/runs/{runId}/logs") public void appendLog(@PathVariable String runId, @RequestBody ch.so.agi.gretl.control.api.RunLogAppendRequest request, jakarta.servlet.http.HttpServletRequest servletRequest)

    • cancelRequested

      @GetMapping("/api/worker/runs/{runId}/cancel-requested") public Map<String,Boolean> cancelRequested(@PathVariable String runId, jakarta.servlet.http.HttpServletRequest servletRequest)