Move Retention policy inside PostgresJobQueue

Author: adam-fowler

Sources/JobsPostgres/PostgresJobsQueue+cleanup.swift

@@ -58,7 +58,7 @@ extension PostgresJobQueue {
     /// Use this with the ``JobSchedule`` to schedule a cleanup of
     /// failed, cancelled or completed jobs
     public var cleanupJob: JobName<JobCleanupParameters> {
-        .init("_JobCleanup_\(self.configuration.queueName)")
+        .init("_Jobs_PostgresCleanup_\(self.configuration.queueName)")
     }
 
     /// register clean up job on queue

Sources/JobsPostgres/RetentionPolicy.swift

@@ -14,36 +14,38 @@
 
 import Foundation
 
-/// Data rentension policy
-public struct RetentionPolicy: Sendable {
-    /// Data retention policy
-    public struct RetainData: Equatable, Sendable {
-        enum Policy {
-            case retain
-            case doNotRetain
-        }
+extension PostgresJobQueue {
+    /// Data rentension policy
+    public struct RetentionPolicy: Sendable {
+        /// Data retention policy
+        public struct RetainData: Equatable, Sendable {
+            enum Policy {
+                case retain
+                case doNotRetain
+            }
 
-        let rawValue: Policy
-        /// Retain task
-        public static var retain: RetainData { RetainData(rawValue: .retain) }
-        /// Never retain any data
-        public static var doNotRetain: RetainData { RetainData(rawValue: .doNotRetain) }
-    }
+            let rawValue: Policy
+            /// Retain task
+            public static var retain: RetainData { RetainData(rawValue: .retain) }
+            /// Never retain any data
+            public static var doNotRetain: RetainData { RetainData(rawValue: .doNotRetain) }
+        }
 
-    /// Jobs with status cancelled
-    public var cancelled: RetainData
-    /// Jobs with status completed
-    public var completed: RetainData
-    /// Jobs with status failed
-    public var failed: RetainData
+        /// Jobs with status cancelled
+        public var cancelled: RetainData
+        /// Jobs with status completed
+        public var completed: RetainData
+        /// Jobs with status failed
+        public var failed: RetainData
 
-    public init(
-        cancelled: RetainData = .doNotRetain,
-        completed: RetainData = .doNotRetain,
-        failed: RetainData = .retain
-    ) {
-        self.cancelled = cancelled
-        self.completed = completed
-        self.failed = failed
+        public init(
+            cancelled: RetainData = .doNotRetain,
+            completed: RetainData = .doNotRetain,
+            failed: RetainData = .retain
+        ) {
+            self.cancelled = cancelled
+            self.completed = completed
+            self.failed = failed
+        }
     }
 }