Package ch.so.agi.gretl.control.worker.client

Class ControlPlaneClient

java.lang.Object
ch.so.agi.gretl.control.worker.client.ControlPlaneClient
@Component public class ControlPlaneClient extends Object

  • Constructor Summary

    Constructors
    Constructor
    Description
    ControlPlaneClient(org.springframework.web.client.RestClient.Builder builder, WorkerProperties properties)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    appendLog(String runId, ch.so.agi.gretl.control.api.RunLogAppendRequest request)
     
    boolean
    cancelRequested(String runId)
     
    ch.so.agi.gretl.control.api.RunClaimResponse
    claim(ch.so.agi.gretl.control.api.RunClaimRequest request)
     
    void
    heartbeat(ch.so.agi.gretl.control.api.WorkerHeartbeatRequest request)
     
    ch.so.agi.gretl.control.api.WorkerRegistrationResponse
    register(ch.so.agi.gretl.control.api.WorkerRegistrationRequest request)
     
    void
    updateStatus(String runId, ch.so.agi.gretl.control.api.RunStatusUpdateRequest request)
     

    Methods inherited from class java.lang.Object

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

  • Constructor Details

    • ControlPlaneClient

      public ControlPlaneClient(org.springframework.web.client.RestClient.Builder builder, WorkerProperties properties)

  • Method Details

    • register

      public ch.so.agi.gretl.control.api.WorkerRegistrationResponse register(ch.so.agi.gretl.control.api.WorkerRegistrationRequest request)

    • heartbeat

      public void heartbeat(ch.so.agi.gretl.control.api.WorkerHeartbeatRequest request)

    • claim

      public ch.so.agi.gretl.control.api.RunClaimResponse claim(ch.so.agi.gretl.control.api.RunClaimRequest request)

    • updateStatus

      public void updateStatus(String runId, ch.so.agi.gretl.control.api.RunStatusUpdateRequest request)

    • appendLog

      public void appendLog(String runId, ch.so.agi.gretl.control.api.RunLogAppendRequest request)

    • cancelRequested

      public boolean cancelRequested(String runId)