SetJobInput(
const string&
input);
82 voidSetJobAffinity(
const string& affinity);
84 voidPrepareNextJob();
88 voidSubmit(
const string& job_group =
kEmptyStr);
93 constvector<CNetScheduleJob>&
GetBatch()
const{
returnm_Jobs; }
98 voidCheckIfBatchAlreadySubmitted();
99 voidCheckIfBatchSubmittedAndPrepareNextJob();
121eAutomaticCleanup = 0,
144EProgressMsg progress_msg);
160EProgressMsg progress_msg);
171 const string& GetJobOutput();
174 const string& GetJobInput();
183 const string& GetErrorMessage();
201 stringGetProgressMessage();
210 voidSetJobInput(
const string&
input);
228 stringSubmit(
const string& affinity =
kEmptyStr);
246 voidSetJobKey(
const string& job_key);
253 voidCancelJob(
const string& job_key);
257 returnm_NetScheduleSubmitter;
261 size_tGetMaxServerInputSize();
264 voidRemoveDataBlob(
const string&);
275 voidx_ProlongBlobLifetime(
const string& blob_key,
unsignedttl);
276 boolx_ProlongJobFieldLifetime(
const string& job_field,
unsignedttl);
277 voidx_RenewAllJobBlobs(
unsignedttl);
280 voidx_GetJobDetails();
282 size_tm_BlobSize = 0;
285 boolm_JobDetailsRead =
false;
ncbi::TMaskedQueryRegions mask
Grid Client (the submitter).
Grid Job Batch Submitter.
Client API for NetCache server.
Smart pointer to the job submission part of the NetSchedule API.
static void cleanup(void)
TErrCode GetErrCode(void) const
Get error code.
virtual const char * GetErrCodeString(void) const
Get error code interpreted as text.
CNetCacheAPI m_NetCacheAPI
CGridJobBatchSubmitter & operator=(CGridJobBatchSubmitter &)
EJobStatus
Job status codes.
CGridClient & m_GridClient
CGridJobBatchSubmitter(const CGridJobBatchSubmitter &)
The copy constructor and the assignment operator are prohibited.
CGridClient(const CGridClient &)
The copy constructor and the assignment operator are prohibited.
CNetScheduleSubmitter GetNetScheduleSubmitter()
void SetJobAffinity(const string &affinity)
NCBI_EXCEPTION_DEFAULT(CGridClientException, CException)
CNetScheduleJob & GetJob()
CNetCacheAPI & GetNetCacheAPI()
void SetJobMask(CNetScheduleAPI::TJobMask mask)
virtual const char * GetErrCodeString(void) const override
Get error code interpreted as text.
vector< CNetScheduleJob > m_Jobs
CNetScheduleSubmitter m_NetScheduleSubmitter
CGridJobBatchSubmitter m_JobBatchSubmitter
CGridClient & operator=(const CGridClient &)
size_t GetBlobSize() const
Get the size of an input stream.
const vector< CNetScheduleJob > & GetBatch() const
void SetJobGroup(const string &group)
#define END_NCBI_SCOPE
End previously defined NCBI scope.
#define BEGIN_NCBI_SCOPE
Define ncbi namespace.
IO_PREFIX::ostream CNcbiOstream
Portable alias for ostream.
IO_PREFIX::istream CNcbiIstream
Portable alias for istream.
#define NCBI_XCONNECT_EXPORT
NCBI C++ stream class wrappers for triggering between "new" and "old" C++ stream libraries.
NetSchedule client specs.
unique_ptr< CObjectIStream > GetIStream(string path, ESerialDataFormat serial_format)
RetroSearch is an open source project built by @garambo | Open a GitHub Issue
Search and Browse the WWW like it's 1997 | Search results from DuckDuckGo
HTML:
3.2
| Encoding:
UTF-8
| Version:
0.7.4