|
| HTCondorCentralManagerService (const std::string &hostname, std::set< ComputeService *> compute_resources, std::map< std::string, std::string > property_list={}, std::map< std::string, std::string > messagepayload_list={}) |
| Constructor. More...
|
|
void | submitPilotJob (PilotJob *job, std::map< std::string, std::string > &service_specific_arguments) override |
| Asynchronously submit a pilot job to the cloud service. More...
|
|
void | submitStandardJob (StandardJob *job, std::map< std::string, std::string > &service_specific_arguments) override |
| Submit a standard job to the HTCondor service. More...
|
|
std::map< std::string, double > | getCoreFlopRate () |
| Get the per-core flop rate of the compute service's hosts. More...
|
|
double | getFreeScratchSpaceSize () |
| Get the free space on the compute service's scratch storage space. More...
|
|
std::map< std::string, double > | getMemoryCapacity () |
| Get the RAM capacities for each of the compute service's hosts. More...
|
|
std::map< std::string, unsigned long > | getNumCores () |
| Get core counts for each of the compute service's host. More...
|
|
unsigned long | getNumHosts () |
| Get the number of hosts that the compute service manages. More...
|
|
std::map< std::string, unsigned long > | getNumIdleCores () |
| Get idle core counts for each of the compute service's host. More...
|
|
StorageService * | getScratch () |
| Get the compute service's scratch storage space. More...
|
|
std::shared_ptr< StorageService > | getScratchSharedPtr () |
| Get a shared pointer to the compute service's scratch storage space. More...
|
|
unsigned long | getTotalNumCores () |
| Get the total core counts for all hosts of the compute service. More...
|
|
unsigned long | getTotalNumIdleCores () |
| Get the total idle core counts for all hosts of the compute service. More...
|
|
double | getTotalScratchSpaceSize () |
| Get the total capacity of the compute service's scratch storage space. More...
|
|
double | getTTL () |
| Get the time-to-live of the compute service. More...
|
|
bool | hasScratch () |
| Checks if the compute service has a scratch space. More...
|
|
void | stop () override |
| Stop the compute service - must be called by the stop() method of derived classes.
|
|
void | submitJob (WorkflowJob *job, std::map< std::string, std::string >={}) |
| Submit a job to the compute service. More...
|
|
bool | supportsPilotJobs () |
| Get whether the compute service supports pilot jobs or not. More...
|
|
bool | supportsStandardJobs () |
| Get whether the compute service supports standard jobs or not. More...
|
|
void | terminateJob (WorkflowJob *job) |
| Terminate a previously-submitted job (which may or may not be running yet) More...
|
|
std::string | getHostname () |
| Get the name of the host on which the service is / will be running. More...
|
|
double | getNetworkTimeoutValue () |
| Returns the service's network timeout value. More...
|
|
bool | getPropertyValueAsBoolean (std::string) |
| Get a property of the Service as a boolean. More...
|
|
double | getPropertyValueAsDouble (std::string) |
| Get a property of the Service as a double. More...
|
|
std::string | getPropertyValueAsString (std::string) |
| Get a property of the Service as a string. More...
|
|
bool | isUp () |
| Returns true if the service is UP, false otherwise. More...
|
|
void | setNetworkTimeoutValue (double value) |
| Sets the service's network timeout value. More...
|
|
void | start (std::shared_ptr< Service > this_service, bool daemonize, bool auto_restart) |
| Start the service. More...
|
|