edu.iu.dsc.tws.master.dashclient

Class DashboardClient

java.lang.Object

edu.iu.dsc.tws.master.dashclient.DashboardClient

public class DashboardClient
extends java.lang.Object

This client is used to send messages to Dashboard by JobMaster

Constructor Summary

Constructors

Constructor and Description
DashboardClient(java.lang.String dashHost, java.lang.String jobID, int numberOfConnections)

Method Summary

Modifier and Type	Method and Description
void	close()
boolean	jobStateChange(JobAPI.JobState state) send JobStateChange message to Dashboard
boolean	registerJob(JobAPI.Job job, JobMasterAPI.NodeInfo jobMasterNodeInfo) send registerJob message to Dashboard when a job master starts, it sends this message to Dashboard
boolean	registerWorker(JobMasterAPI.WorkerInfo workerInfo, JobMasterAPI.WorkerState initialState) send RegisterWorker message to Dashboard initialState must be either STARTED or RESTARTED
boolean	scaledWorkers(int change, int numberOfWorkers, java.util.List<java.lang.Integer> killedWorkers) send ScaleComputeResource message to Dashboard instances shows the updated value of the instances for this compute resource instances may be smaller or higher than the original value if it is smaller, it means some instances of that resource removed if it is higher, it means some instances of that resource added
boolean	workerStateChange(int workerID, JobMasterAPI.WorkerState state) send WorkerStateChange message to Dashboard

Methods inherited from class java.lang.Object

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

Constructor Detail

DashboardClient

public DashboardClient(java.lang.String dashHost,
                       java.lang.String jobID,
                       int numberOfConnections)

Method Detail

registerJob

public boolean registerJob(JobAPI.Job job,
                           JobMasterAPI.NodeInfo jobMasterNodeInfo)

send registerJob message to Dashboard when a job master starts, it sends this message to Dashboard

jobStateChange

public boolean jobStateChange(JobAPI.JobState state)

send JobStateChange message to Dashboard

scaledWorkers

public boolean scaledWorkers(int change,
                             int numberOfWorkers,
                             java.util.List<java.lang.Integer> killedWorkers)

send ScaleComputeResource message to Dashboard instances shows the updated value of the instances for this compute resource instances may be smaller or higher than the original value if it is smaller, it means some instances of that resource removed if it is higher, it means some instances of that resource added

registerWorker

public boolean registerWorker(JobMasterAPI.WorkerInfo workerInfo,
                              JobMasterAPI.WorkerState initialState)

send RegisterWorker message to Dashboard initialState must be either STARTED or RESTARTED

workerStateChange

public boolean workerStateChange(int workerID,
                                 JobMasterAPI.WorkerState state)

send WorkerStateChange message to Dashboard

close

public void close()