blob: ad33498667fcf69203ee6b3ff9cbe4182c06b4b9 (
plain) (
tree)
|
|
import { JobScheduler, JobHandler } from '../job-scheduler'
import * as httpRequestBroadcastHandler from './http-request-broadcast-handler'
import * as httpRequestUnicastHandler from './http-request-unicast-handler'
import { JobCategory } from '../../../../shared'
type HTTPRequestPayload = {
uris: string[]
body: any
}
const jobHandlers: { [ handlerName: string ]: JobHandler<HTTPRequestPayload, void> } = {
httpRequestBroadcastHandler,
httpRequestUnicastHandler
}
const jobCategory: JobCategory = 'http-request'
const httpRequestJobScheduler = new JobScheduler(jobCategory, jobHandlers)
export {
HTTPRequestPayload,
httpRequestJobScheduler
}
|