Package io.armadaproject
Class ArmadaClient
- java.lang.Object
-
- io.armadaproject.ArmadaClient
-
- All Implemented Interfaces:
AutoCloseable
public class ArmadaClient extends Object implements AutoCloseable
-
-
Constructor Summary
Constructors Constructor Description ArmadaClient(String host, int port)ArmadaClient(String host, int port, String bearerToken)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description SubmitOuterClass.CancellationResultcancelJob(SubmitOuterClass.JobCancelRequest jobCancelRequest)Health.HealthCheckResponse.ServingStatuscheckHealth()voidclose()Iterator<EventOuterClass.EventStreamMessage>getEvents(EventOuterClass.JobSetRequest jobSetRequest)Job.JobStatusResponsegetJobStatus(Job.JobStatusRequest jobStatusRequest)SubmitOuterClass.QueuegetQueue(SubmitOuterClass.QueueGetRequest queueGetRequest)Iterator<SubmitOuterClass.StreamingQueueMessage>getQueueInfo(SubmitOuterClass.StreamingQueueGetRequest streamingQueueGetRequest)SubmitOuterClass.JobSubmitResponsesubmitJob(SubmitOuterClass.JobSubmitRequest jobSubmitRequest)
-
-
-
Method Detail
-
checkHealth
public Health.HealthCheckResponse.ServingStatus checkHealth()
-
submitJob
public SubmitOuterClass.JobSubmitResponse submitJob(SubmitOuterClass.JobSubmitRequest jobSubmitRequest)
-
cancelJob
public SubmitOuterClass.CancellationResult cancelJob(SubmitOuterClass.JobCancelRequest jobCancelRequest)
-
getEvents
public Iterator<EventOuterClass.EventStreamMessage> getEvents(EventOuterClass.JobSetRequest jobSetRequest)
-
getQueue
public SubmitOuterClass.Queue getQueue(SubmitOuterClass.QueueGetRequest queueGetRequest)
-
getQueueInfo
public Iterator<SubmitOuterClass.StreamingQueueMessage> getQueueInfo(SubmitOuterClass.StreamingQueueGetRequest streamingQueueGetRequest)
-
getJobStatus
public Job.JobStatusResponse getJobStatus(Job.JobStatusRequest jobStatusRequest)
-
close
public void close() throws Exception- Specified by:
closein interfaceAutoCloseable- Throws:
Exception
-
-