class KalturaBatchService in Kaltura 6.2
Hierarchy
- class \KalturaServiceBase
- class \KalturaBatchService
Expanded class hierarchy of KalturaBatchService
File
- kaltura_client/
KalturaClient.php, line 4772
View source
class KalturaBatchService extends KalturaServiceBase {
function __construct(KalturaClient $client) {
parent::__construct($client);
}
function addImportJob(KalturaBatchJob $importJob) {
$kparams = array();
$this->client
->addParam($kparams, "importJob", $importJob
->toParams());
$this->client
->queueServiceActionCall("batch", "addImportJob", $kparams);
if ($this->client
->isMultiRequest()) {
return null;
}
$resultObject = $this->client
->doQueue();
$this->client
->throwExceptionIfError($resultObject);
$this->client
->validateObjectType($resultObject, "KalturaBatchJob");
return $resultObject;
}
function getExclusiveImportJobs($processorLocation, $pocessorName, $maxExecutionTime, $numberOfJobs, $partnerGroups) {
$kparams = array();
$this->client
->addParam($kparams, "processorLocation", $processorLocation);
$this->client
->addParam($kparams, "pocessorName", $pocessorName);
$this->client
->addParam($kparams, "maxExecutionTime", $maxExecutionTime);
$this->client
->addParam($kparams, "numberOfJobs", $numberOfJobs);
$this->client
->addParam($kparams, "partnerGroups", $partnerGroups);
$this->client
->queueServiceActionCall("batch", "getExclusiveImportJobs", $kparams);
if ($this->client
->isMultiRequest()) {
return null;
}
$resultObject = $this->client
->doQueue();
$this->client
->throwExceptionIfError($resultObject);
$this->client
->validateObjectType($resultObject, "array");
return $resultObject;
}
function updateExclusiveImportJob($id, $processorLocation, $pocessorName, KalturaBatchJob $importJob, $entryStatus = null) {
$kparams = array();
$this->client
->addParam($kparams, "id", $id);
$this->client
->addParam($kparams, "processorLocation", $processorLocation);
$this->client
->addParam($kparams, "pocessorName", $pocessorName);
$this->client
->addParam($kparams, "importJob", $importJob
->toParams());
$this->client
->addParam($kparams, "entryStatus", $entryStatus);
$this->client
->queueServiceActionCall("batch", "updateExclusiveImportJob", $kparams);
if ($this->client
->isMultiRequest()) {
return null;
}
$resultObject = $this->client
->doQueue();
$this->client
->throwExceptionIfError($resultObject);
$this->client
->validateObjectType($resultObject, "KalturaBatchJob");
return $resultObject;
}
function freeExclusiveImportJob($id, $processorLocation, $pocessorName) {
$kparams = array();
$this->client
->addParam($kparams, "id", $id);
$this->client
->addParam($kparams, "processorLocation", $processorLocation);
$this->client
->addParam($kparams, "pocessorName", $pocessorName);
$this->client
->queueServiceActionCall("batch", "freeExclusiveImportJob", $kparams);
if ($this->client
->isMultiRequest()) {
return null;
}
$resultObject = $this->client
->doQueue();
$this->client
->throwExceptionIfError($resultObject);
$this->client
->validateObjectType($resultObject, "KalturaBatchJob");
return $resultObject;
}
function addPreConvertJob(KalturaBatchJob $preConvertJob) {
$kparams = array();
$this->client
->addParam($kparams, "preConvertJob", $preConvertJob
->toParams());
$this->client
->queueServiceActionCall("batch", "addPreConvertJob", $kparams);
if ($this->client
->isMultiRequest()) {
return null;
}
$resultObject = $this->client
->doQueue();
$this->client
->throwExceptionIfError($resultObject);
$this->client
->validateObjectType($resultObject, "KalturaBatchJob");
return $resultObject;
}
function getExclusivePreConvertJobs($processorLocation, $pocessorName, $maxExecutionTime, $numberOfJobs, $partnerGroups) {
$kparams = array();
$this->client
->addParam($kparams, "processorLocation", $processorLocation);
$this->client
->addParam($kparams, "pocessorName", $pocessorName);
$this->client
->addParam($kparams, "maxExecutionTime", $maxExecutionTime);
$this->client
->addParam($kparams, "numberOfJobs", $numberOfJobs);
$this->client
->addParam($kparams, "partnerGroups", $partnerGroups);
$this->client
->queueServiceActionCall("batch", "getExclusivePreConvertJobs", $kparams);
if ($this->client
->isMultiRequest()) {
return null;
}
$resultObject = $this->client
->doQueue();
$this->client
->throwExceptionIfError($resultObject);
$this->client
->validateObjectType($resultObject, "array");
return $resultObject;
}
function updateExclusivePreConvertJob($id, $processorLocation, $pocessorName, KalturaBatchJob $preConvertJob, $entryStatus = null) {
$kparams = array();
$this->client
->addParam($kparams, "id", $id);
$this->client
->addParam($kparams, "processorLocation", $processorLocation);
$this->client
->addParam($kparams, "pocessorName", $pocessorName);
$this->client
->addParam($kparams, "preConvertJob", $preConvertJob
->toParams());
$this->client
->addParam($kparams, "entryStatus", $entryStatus);
$this->client
->queueServiceActionCall("batch", "updateExclusivePreConvertJob", $kparams);
if ($this->client
->isMultiRequest()) {
return null;
}
$resultObject = $this->client
->doQueue();
$this->client
->throwExceptionIfError($resultObject);
$this->client
->validateObjectType($resultObject, "KalturaBatchJob");
return $resultObject;
}
function freeExclusivePreConvertJob($id, $processorLocation, $pocessorName) {
$kparams = array();
$this->client
->addParam($kparams, "id", $id);
$this->client
->addParam($kparams, "processorLocation", $processorLocation);
$this->client
->addParam($kparams, "pocessorName", $pocessorName);
$this->client
->queueServiceActionCall("batch", "freeExclusivePreConvertJob", $kparams);
if ($this->client
->isMultiRequest()) {
return null;
}
$resultObject = $this->client
->doQueue();
$this->client
->throwExceptionIfError($resultObject);
$this->client
->validateObjectType($resultObject, "KalturaBatchJob");
return $resultObject;
}
function createNotification(KalturaNotification $notificationJob) {
$kparams = array();
$this->client
->addParam($kparams, "notificationJob", $notificationJob
->toParams());
$this->client
->queueServiceActionCall("batch", "createNotification", $kparams);
if ($this->client
->isMultiRequest()) {
return null;
}
$resultObject = $this->client
->doQueue();
$this->client
->throwExceptionIfError($resultObject);
$this->client
->validateObjectType($resultObject, "null");
return $resultObject;
}
function getExclusiveNotificationJobs($processorLocation, $pocessorName, $maxExecutionTime, $numberOfJobs, $partnerGroups) {
$kparams = array();
$this->client
->addParam($kparams, "processorLocation", $processorLocation);
$this->client
->addParam($kparams, "pocessorName", $pocessorName);
$this->client
->addParam($kparams, "maxExecutionTime", $maxExecutionTime);
$this->client
->addParam($kparams, "numberOfJobs", $numberOfJobs);
$this->client
->addParam($kparams, "partnerGroups", $partnerGroups);
$this->client
->queueServiceActionCall("batch", "getExclusiveNotificationJobs", $kparams);
if ($this->client
->isMultiRequest()) {
return null;
}
$resultObject = $this->client
->doQueue();
$this->client
->throwExceptionIfError($resultObject);
$this->client
->validateObjectType($resultObject, "KalturaBatchGetExclusiveNotificationJobsResponse");
return $resultObject;
}
function updateExclusiveNotificationJob($id, $processorLocation, $pocessorName, KalturaNotification $notificationJob) {
$kparams = array();
$this->client
->addParam($kparams, "id", $id);
$this->client
->addParam($kparams, "processorLocation", $processorLocation);
$this->client
->addParam($kparams, "pocessorName", $pocessorName);
$this->client
->addParam($kparams, "notificationJob", $notificationJob
->toParams());
$this->client
->queueServiceActionCall("batch", "updateExclusiveNotificationJob", $kparams);
if ($this->client
->isMultiRequest()) {
return null;
}
$resultObject = $this->client
->doQueue();
$this->client
->throwExceptionIfError($resultObject);
$this->client
->validateObjectType($resultObject, "KalturaNotification");
return $resultObject;
}
function freeExclusiveNotificationJob($id, $processorLocation, $pocessorName, KalturaNotification $notificationJob = null) {
$kparams = array();
$this->client
->addParam($kparams, "id", $id);
$this->client
->addParam($kparams, "processorLocation", $processorLocation);
$this->client
->addParam($kparams, "pocessorName", $pocessorName);
if ($notificationJob !== null) {
$this->client
->addParam($kparams, "notificationJob", $notificationJob
->toParams());
}
$this->client
->queueServiceActionCall("batch", "freeExclusiveNotificationJob", $kparams);
if ($this->client
->isMultiRequest()) {
return null;
}
$resultObject = $this->client
->doQueue();
$this->client
->throwExceptionIfError($resultObject);
$this->client
->validateObjectType($resultObject, "KalturaBatchJob");
return $resultObject;
}
function addMailJob(KalturaMailJob $mailJob) {
$kparams = array();
$this->client
->addParam($kparams, "mailJob", $mailJob
->toParams());
$this->client
->queueServiceActionCall("batch", "addMailJob", $kparams);
if ($this->client
->isMultiRequest()) {
return null;
}
$resultObject = $this->client
->doQueue();
$this->client
->throwExceptionIfError($resultObject);
$this->client
->validateObjectType($resultObject, "null");
return $resultObject;
}
function getExclusiveMailJobs($processorLocation, $pocessorName, $maxExecutionTime, $numberOfJobs, $partnerGroups) {
$kparams = array();
$this->client
->addParam($kparams, "processorLocation", $processorLocation);
$this->client
->addParam($kparams, "pocessorName", $pocessorName);
$this->client
->addParam($kparams, "maxExecutionTime", $maxExecutionTime);
$this->client
->addParam($kparams, "numberOfJobs", $numberOfJobs);
$this->client
->addParam($kparams, "partnerGroups", $partnerGroups);
$this->client
->queueServiceActionCall("batch", "getExclusiveMailJobs", $kparams);
if ($this->client
->isMultiRequest()) {
return null;
}
$resultObject = $this->client
->doQueue();
$this->client
->throwExceptionIfError($resultObject);
$this->client
->validateObjectType($resultObject, "array");
return $resultObject;
}
function updateExclusiveMailJob($id, $processorLocation, $pocessorName, KalturaMailJob $mailJob) {
$kparams = array();
$this->client
->addParam($kparams, "id", $id);
$this->client
->addParam($kparams, "processorLocation", $processorLocation);
$this->client
->addParam($kparams, "pocessorName", $pocessorName);
$this->client
->addParam($kparams, "mailJob", $mailJob
->toParams());
$this->client
->queueServiceActionCall("batch", "updateExclusiveMailJob", $kparams);
if ($this->client
->isMultiRequest()) {
return null;
}
$resultObject = $this->client
->doQueue();
$this->client
->throwExceptionIfError($resultObject);
$this->client
->validateObjectType($resultObject, "KalturaMailJob");
return $resultObject;
}
function freeExclusiveMailJob($id, $processorLocation, $pocessorName) {
$kparams = array();
$this->client
->addParam($kparams, "id", $id);
$this->client
->addParam($kparams, "processorLocation", $processorLocation);
$this->client
->addParam($kparams, "pocessorName", $pocessorName);
$this->client
->queueServiceActionCall("batch", "freeExclusiveMailJob", $kparams);
if ($this->client
->isMultiRequest()) {
return null;
}
$resultObject = $this->client
->doQueue();
$this->client
->throwExceptionIfError($resultObject);
$this->client
->validateObjectType($resultObject, "KalturaMailJob");
return $resultObject;
}
}