![]() |
Workspace 6.21.5
|
#include <Workspace/Application/Server/schedulerclient.h>
Inherits QObject.
Public Slots | |
void | disconnect (bool abort=false) |
Signals | |
void | connected () |
void | disconnected () |
void | error (QAbstractSocket::SocketError socketError) |
void | handshake () |
void | handshakeTimedout () |
void | notifyFailure (SchedulerRequest &, const CSIRO::DataExecution::AbortReason &abortReason, const QString &text="") |
void | notifyList (const QList< WorkspaceBrief > &, bool isQueuedList) |
void | notifyLog (const QString &uuid, const QString &log, int startBytes) |
void | notifyOperationUpdateEventList (const ExecutionTimekeeper::EventList &eventList) |
void | notifyProgress (SchedulerRequest &, int percentComplete) |
void | notifyStarted (SchedulerRequest &) |
void | notifySuccess (SchedulerRequest &) |
void | stateChanged (QAbstractSocket::SocketState) |
Public Member Functions | |
SchedulerClient () | |
~SchedulerClient () override | |
QFuture< void > | changeRequestPriority (const QString &uuid, SchedulerController::TypeOfPriorityChange type) |
QFuture< void > | clearHistory () |
void | connect () |
QString | errorString () const |
const QString & | getAuthenticationCredentials () const |
Get credentials for the authentication provider. | |
const QString & | getAuthenticationProvider () const |
Get authentication provider. | |
const QString & | getAuthenticationProviderVersion () const |
Get authentication provider version. | |
int | getCurrentScheduledJob () const |
QString | getHostName () const |
Get host name. | |
QFuture< void > | getListAllWorkspace () |
QFuture< void > | getListQueueWorkspace () |
const QMap< QString, int > & | getOccupiedFeatures () const |
quint16 | getPort () const |
Get port. | |
int | getServerTimeDiffWarningTimeInMs () const |
Get server time difference thresold (in ms), will warn if server time is having a bigger diff from the client than this. | |
int | getTotalJob () const |
bool | getUseSecureConnection () const |
Get flag if using secure connection. | |
double | getWorkload (int maxConcurrentJob) const |
QFuture< void > | getWorkspaceDetail (const QString &uuid, const QString &sessionId, int logStartBytes) |
bool | isConnected () const |
bool | isConnecting () const |
bool | isPauseDelayed () const |
bool | isReady () const |
QString | localAddr () const |
void | pauseDelayed (bool pause) |
void | scheduleRequest (SchedulerRequest &) |
QString | serverId () const |
QString | sessionId () const |
void | setAuthenticationCredentials (const QString &credentials) |
Set credentials for the authentication provider. | |
void | setAuthenticationProvider (const QString &method) |
Set authentication provider. | |
void | setAuthenticationProviderVersion (const QString &version) |
Set authentication provider version. | |
void | setHostName (QString host) |
Set host name. | |
void | setPort (quint16 port) |
Set port. | |
void | setServerTimeDiffWarningTimeInMs (int diffTime) |
Set server time difference thresold (in ms) for warning. | |
void | setUseSecureConnection (bool secure) |
Set if secure connection should be used. | |
void | stopRequest (SchedulerRequest &) |
qint64 | timeOffset () const |
Static Public Member Functions | |
template<typename Func > | |
static void | ensureConnectAndCall (QSharedPointer< SchedulerClient > client, Func f) |
static SchedulerFeature | featureAnyHost () |
static SchedulerFeature | featureHost (QString name) |
SchedulerClient | ( | ) |
|
override |
Destructs the SchedulerClient.
QFuture< void > changeRequestPriority | ( | const QString & | uuid, |
SchedulerController::TypeOfPriorityChange | type | ||
) |
QFuture< void > clearHistory | ( | ) |
void connect | ( | ) |
Establishes a connection to the SchedulerClient.
|
signal |
|
slot |
Disconnects the SchedulerClient.
|
signal |
|
inlinestatic |
|
signal |
QString errorString | ( | ) | const |
|
static |
Name for the feature for host-any.
|
static |
Name for the feature for a specific host.
const QString & getAuthenticationCredentials | ( | ) | const |
const QString & getAuthenticationProvider | ( | ) | const |
const QString & getAuthenticationProviderVersion | ( | ) | const |
|
inline |
QString getHostName | ( | ) | const |
QFuture< void > getListAllWorkspace | ( | ) |
Request everything non-queued, the returned message contains a list of workflows but the order of it doesn't matter.
QFuture< void > getListQueueWorkspace | ( | ) |
Request queued workflows, the returned message contains a list of workflows ordered by the queue.
|
inline |
quint16 getPort | ( | ) | const |
int getServerTimeDiffWarningTimeInMs | ( | ) | const |
|
inline |
bool getUseSecureConnection | ( | ) | const |
double getWorkload | ( | int | maxConcurrentJob | ) | const |
maxConcurrentJob | Specify the max concurrent job to calculate the workload. With the same amount of jobs, providing a bigger max concurrent job end up with lower workload. |
Normalized workload. 0 is free, 1 is busy.
QFuture< void > getWorkspaceDetail | ( | const QString & | uuid, |
const QString & | sessionId, | ||
int | logStartBytes | ||
) |
Request everything non-queued, the returned message contains a list of workflows but the order of it doesn't matter.
|
signal |
|
signal |
bool isConnected | ( | ) | const |
Returns true if the SchedulerClient is connected, false if not.
bool isConnecting | ( | ) | const |
Returns true if the SchedulerClient is connecting, false if not.
bool isPauseDelayed | ( | ) | const |
bool isReady | ( | ) | const |
QString localAddr | ( | ) | const |
|
signal |
|
signal |
|
signal |
|
signal |
|
signal |
|
signal |
|
signal |
void pauseDelayed | ( | bool | pause | ) |
Request scheduler to pause or resume delayed workflows.
void scheduleRequest | ( | SchedulerRequest & | request | ) |
QString serverId | ( | ) | const |
QString sessionId | ( | ) | const |
void setAuthenticationCredentials | ( | const QString & | credentials | ) |
void setAuthenticationProvider | ( | const QString & | method | ) |
void setAuthenticationProviderVersion | ( | const QString & | version | ) |
void setHostName | ( | QString | host | ) |
void setPort | ( | quint16 | port | ) |
void setServerTimeDiffWarningTimeInMs | ( | int | diffTime | ) |
void setUseSecureConnection | ( | bool | secure | ) |
|
signal |
void stopRequest | ( | SchedulerRequest & | request | ) |
qint64 timeOffset | ( | ) | const |