Emcee

1
import Foundation
2
import EmceeLogging
3
import QueueModels
4

5
public struct StuckBucket: Equatable {
6
    public enum Reason: Equatable, CustomStringConvertible {
7
        case workerIsSilent
8
        case bucketLost
9
        
10
        public var description: String {
11
            switch self {
12
            case .workerIsSilent:
13
                return "worker is silent"
14
            case .bucketLost:
15
                return "worker has been processing bucket but then switched to another bucket"
16
            }
17
        }
18
    }
19
    
20
    public let reason: Reason
21
    public let bucket: Bucket
22
    public let workerId: WorkerId
23
    
24
    public init(reason: Reason, bucket: Bucket, workerId: WorkerId) {
25
        self.reason = reason
26
        self.bucket = bucket
27
        self.workerId = workerId
28
    }
29
}
30