import { parallel } from 'async'
import {
- BaseRequestScheduler,
+ AbstractRequestScheduler,
getRequestScheduler,
getRequestVideoQaduScheduler,
getRequestVideoEventScheduler
// ---------------------------------------------------------------------------
-function buildRequestSchedulerFunction (requestScheduler: BaseRequestScheduler) {
+function buildRequestSchedulerFunction (requestScheduler: AbstractRequestScheduler) {
return function (callback) {
requestScheduler.remainingRequestsCount(function (err, count) {
if (err) return callback(err)
REQUESTS_INTERVAL
} from '../../initializers'
-abstract class BaseRequestScheduler {
+abstract class AbstractRequestScheduler {
requestInterval: number
limitPods: number
limitPerPod: number
// ---------------------------------------------------------------------------
export {
- BaseRequestScheduler
+ AbstractRequestScheduler
}
-export * from './base-request-scheduler'
+export * from './abstract-request-scheduler'
export * from './request-scheduler'
export * from './request-video-event-scheduler'
export * from './request-video-qadu-scheduler'
import * as Sequelize from 'sequelize'
import { database as db } from '../../initializers/database'
-import { BaseRequestScheduler } from './base-request-scheduler'
+import { AbstractRequestScheduler } from './abstract-request-scheduler'
import { logger } from '../../helpers'
import {
REQUESTS_LIMIT_PODS,
transaction: Sequelize.Transaction
}
-class RequestScheduler extends BaseRequestScheduler {
+class RequestScheduler extends AbstractRequestScheduler {
constructor () {
super()
import * as Sequelize from 'sequelize'
import { database as db } from '../../initializers/database'
-import { BaseRequestScheduler } from './base-request-scheduler'
+import { AbstractRequestScheduler } from './abstract-request-scheduler'
import {
REQUESTS_VIDEO_EVENT_LIMIT_PODS,
REQUESTS_VIDEO_EVENT_LIMIT_PER_POD,
transaction?: Sequelize.Transaction
}
-class RequestVideoEventScheduler extends BaseRequestScheduler {
+class RequestVideoEventScheduler extends AbstractRequestScheduler {
constructor () {
super()
import * as Sequelize from 'sequelize'
import { database as db } from '../../initializers/database'
-import { BaseRequestScheduler } from './base-request-scheduler'
+import { AbstractRequestScheduler } from './abstract-request-scheduler'
import { logger } from '../../helpers'
import {
REQUESTS_VIDEO_QADU_LIMIT_PODS,
transaction?: Sequelize.Transaction
}
-class RequestVideoQaduScheduler extends BaseRequestScheduler {
+class RequestVideoQaduScheduler extends AbstractRequestScheduler {
constructor () {
super()