Method _reportLoad

lib/load.js:78–94

()

    }

    _reportLoad() {
        debug(`LoadEstimator._reportLoad(): jobType = ${this.jobType}`);
        this._warnOldJobs();
        var params = {
            instance_id: config.instanceId,
            group_name: config.groupName,
            job_type: this.jobType,
            average_jobs: this._getAndResetLoadEstimate(),
            max_jobs: this.maxJobCount,
        };
        sqldb.query(sql.insert_load, params, (err) => {
            if (err) logger.error('Error reporting load', {err});
            if (!this.active) return;
            debug(`LoadEstimator._reportLoad(): jobType = ${this.jobType}, scheduling next call for ${config.reportIntervalSec * 1000} ms`);
            this.timeoutID = setTimeout(this._reportLoad.bind(this), config.reportIntervalSec * 1000);
        });
    }

    _warnOldJobs() {
        debug(`LoadEstimator._warnOldJobs(): jobType = ${this.jobType}`);