Emcee

1
import BalancingBucketQueue
2
import BucketQueue
3
import BucketQueueTestHelpers
4
import MetricsExtensions
5
import Foundation
6
import QueueModels
7

8
func createJob(
9
    creationTime: Date = Date(timeIntervalSince1970: 100),
10
    jobId: JobId = "jobId",
11
    priority: Priority = .medium
12
) -> Job {
13
    Job(
14
        creationTime: creationTime,
15
        jobId: jobId,
16
        priority: priority
17
    )
18
}
19

20
func createJobGroup(
21
    creationTime: Date = Date(timeIntervalSince1970: 100),
22
    jobGroupId: JobGroupId = "jobGroupId",
23
    priority: Priority = .medium
24
) -> JobGroup {
25
    JobGroup(
26
        creationTime: creationTime,
27
        jobGroupId: jobGroupId,
28
        priority: priority
29
    )
30
}
31

32
func createJobQueue(
33
    bucketQueueHolder: BucketQueueHolder = BucketQueueHolder(),
34
    job: Job = createJob(),
35
    jobGroup: JobGroup = createJobGroup(),
36
    resultsCollector: ResultsCollector = ResultsCollector()
37
) -> JobQueue {
38
    JobQueue(
39
        analyticsConfiguration: AnalyticsConfiguration(),
40
        bucketQueueHolder: bucketQueueHolder,
41
        job: job,
42
        jobGroup: jobGroup,
43
        resultsCollector: resultsCollector
44
    )
45
}
46