Make everything sendable (#60)

Author: winsmith

Sources/DataTransferObjects/Chart Configuration/ChartAggregationConfiguration.swift

@@ -5,7 +5,7 @@ import Foundation
 /// Maps to "seriesConfiguration" internally in the charting library.
 ///
 /// Subset of https://echarts.apache.org/en/option.html#series-line
-public struct ChartAggregationConfiguration: Codable, Equatable {
+public struct ChartAggregationConfiguration: Codable, Equatable, Sendable {
     public var startAngle: Int?
     public var endAngle: Int?
     public var radius: [String]?

Sources/DataTransferObjects/Chart Configuration/ChartConfiguration.swift

@@ -3,7 +3,7 @@ import Foundation
 /// Display configuration for charts. Overrides various default display options.
 ///
 /// Not hashable, because we don't want to include these values in the cache, as cached calculation results won't change based on these values.
-public struct ChartConfiguration: Codable, Equatable {
+public struct ChartConfiguration: Codable, Equatable, Sendable {
     /// The display mode for the chart.
     public var displayMode: ChartDisplayMode?
 
@@ -33,7 +33,7 @@ public struct ChartConfiguration: Codable, Equatable {
     }
 }
 
-public enum ChartDisplayMode: String, Codable {
+public enum ChartDisplayMode: String, Codable, Sendable {
     case raw
     case barChart
     case lineChart

Sources/DataTransferObjects/Chart Configuration/ChartConfigurationOptions.swift

@@ -3,7 +3,7 @@ import Foundation
 /// Options for configuring a chart in our charting library
 ///
 /// Subset of echart's options https://echarts.apache.org/en/option.html
-public struct ChartConfigurationOptions: Codable, Equatable {
+public struct ChartConfigurationOptions: Codable, Equatable, Sendable {
     /// Whether to enable animation.
     public var animation: Bool?
 
@@ -40,15 +40,15 @@ public struct ChartConfigurationOptions: Codable, Equatable {
     }
 }
 
-public struct ToolTipConfiguration: Codable, Equatable {
+public struct ToolTipConfiguration: Codable, Equatable, Sendable {
     public var show: Bool?
 
     public init(show: Bool? = nil) {
         self.show = show
     }
 }
 
-public struct GridConfiguration: Codable, Equatable {
+public struct GridConfiguration: Codable, Equatable, Sendable {
     public var top: Int?
     public var bottom: Int?
     public var left: Int?
@@ -70,7 +70,7 @@ public struct GridConfiguration: Codable, Equatable {
     }
 }
 
-public enum EasingFunction: String, Codable {
+public enum EasingFunction: String, Codable, Sendable {
     case linear
     case quadraticIn
     case quadraticOut
@@ -104,7 +104,7 @@ public enum EasingFunction: String, Codable {
     case bounceInOut
 }
 
-public struct AxisOptions: Codable, Equatable {
+public struct AxisOptions: Codable, Equatable, Sendable {
     /// Set this to false to prevent the axis from showing.
     public var show: Bool?
     public var position: Position?
@@ -127,12 +127,12 @@ public struct AxisOptions: Codable, Equatable {
         self.inverse = inverse
     }
 
-    public enum Position: String, Codable, Equatable {
+    public enum Position: String, Codable, Equatable, Sendable {
         case top
         case bottom
     }
 
-    public enum AxisType: String, Codable, Equatable {
+    public enum AxisType: String, Codable, Equatable, Sendable {
         /// Numerical axis, suitable for continuous data.
         case value
 

Sources/DataTransferObjects/Druid/configuration/AutomaticCompactionConfig/AutoCompactionDynamicConfiguration.swift

@@ -1,5 +1,5 @@
 /// Defines Automatic Compaction settings for a data source
-public struct AutoCompactionDynamicConfig: Codable, Hashable, Equatable {
+public struct AutoCompactionDynamicConfig: Codable, Hashable, Equatable, Sendable {
     public init(
         dataSource: String,
         taskPriority: Int?,

Sources/DataTransferObjects/Druid/configuration/TuningConfig/IndexParallelTuningConfig.swift

@@ -1,4 +1,4 @@
-public struct IndexParallelTuningConfig: Codable, Hashable, Equatable {
+public struct IndexParallelTuningConfig: Codable, Hashable, Equatable, Sendable {
     public init(
         maxRowsInMemory: Int? = nil,
         maxBytesInMemory: Int? = nil,

Sources/DataTransferObjects/Druid/configuration/TuningConfig/KinesisTuningConfig.swift

@@ -1,6 +1,6 @@
 /// https://druid.apache.org/docs/latest/ingestion/supervisor/#tuning-configuration
 /// https://druid.apache.org/docs/latest/ingestion/kinesis-ingestion#tuning-configuration
-public struct KinesisTuningConfig: Codable, Hashable, Equatable {
+public struct KinesisTuningConfig: Codable, Hashable, Equatable, Sendable {
     public init(
         skipSequenceNumberAvailabilityCheck: Bool? = nil,
         recordBufferSizeBytes: Int? = nil,
@@ -165,7 +165,7 @@ public struct KinesisTuningConfig: Codable, Hashable, Equatable {
     public let appendableIndexSpec: AppendableIndexSpec?
 }
 
-public struct AppendableIndexSpec: Codable, Hashable, Equatable {
+public struct AppendableIndexSpec: Codable, Hashable, Equatable, Sendable {
     public init(type: String, preserveExistingMetrics: Bool? = nil) {
         self.type = type
         self.preserveExistingMetrics = preserveExistingMetrics

Sources/DataTransferObjects/Druid/configuration/TuningConfig/TuningConfig.swift

@@ -1,4 +1,4 @@
-public indirect enum TuningConfig: Codable, Hashable, Equatable {
+public indirect enum TuningConfig: Codable, Hashable, Equatable, Sendable {
     case kinesis(KinesisTuningConfig)
     case indexParallel(IndexParallelTuningConfig)
     // case kafka not implemented

Sources/DataTransferObjects/Druid/data/input/InputFormat.swift

@@ -1,13 +1,13 @@
 /// https://druid.apache.org/docs/latest/ingestion/data-formats/#input-format
 ///
 /// https://github.com/apache/druid/blob/master/processing/src/main/java/org/apache/druid/data/input/InputFormat.java
-public struct InputFormat: Codable, Hashable, Equatable {
+public struct InputFormat: Codable, Hashable, Equatable, Sendable {
     public init(type: InputFormat.InputFormatType, keepNullColumns: Bool? = nil) {
         self.type = type
         self.keepNullColumns = keepNullColumns
     }
 
-    public enum InputFormatType: String, Codable, CaseIterable {
+    public enum InputFormatType: String, Codable, CaseIterable, Sendable {
         case json
     }
 

Sources/DataTransferObjects/Druid/data/input/InputSource.swift

@@ -1,5 +1,5 @@
 /// https://github.com/apache/druid/blob/master/processing/src/main/java/org/apache/druid/data/input/InputSource.java#L61
-public indirect enum InputSource: Codable, Hashable, Equatable {
+public indirect enum InputSource: Codable, Hashable, Equatable, Sendable {
     case druid(DruidInputSource)
 
     enum CodingKeys: String, CodingKey {

Sources/DataTransferObjects/Druid/data/input/impl/DimensionsSpec.swift

@@ -1,6 +1,6 @@
 /// https://druid.apache.org/docs/latest/ingestion/ingestion-spec/#dimensionsspec
 /// https://github.com/apache/druid/blob/master/processing/src/main/java/org/apache/druid/data/input/impl/DimensionsSpec.java
-public struct DimensionsSpec: Codable, Hashable, Equatable {
+public struct DimensionsSpec: Codable, Hashable, Equatable, Sendable {
     public init(
         dimensions: [IngestionDimensionSpecDimension]? = nil,
         dimensionExclusions: [String]? = nil,
@@ -60,7 +60,7 @@ public struct DimensionsSpec: Codable, Hashable, Equatable {
     public let forceSegmentSortByTime: Bool?
 }
 
-public struct IngestionDimensionSpecDimension: Codable, Hashable, Equatable {
+public struct IngestionDimensionSpecDimension: Codable, Hashable, Equatable, Sendable {
     public init(
         type: IngestionDimensionSpecDimension.DimensionType? = nil,
         name: String,
@@ -73,7 +73,7 @@ public struct IngestionDimensionSpecDimension: Codable, Hashable, Equatable {
         self.multiValueHandling = multiValueHandling
     }
 
-    public enum DimensionType: String, Codable, Hashable, Equatable {
+    public enum DimensionType: String, Codable, Hashable, Equatable, Sendable {
         case auto
         case string
         case long
@@ -82,7 +82,7 @@ public struct IngestionDimensionSpecDimension: Codable, Hashable, Equatable {
         case json
     }
 
-    public enum MultiValueHandlingOption: String, Codable, Hashable, Equatable {
+    public enum MultiValueHandlingOption: String, Codable, Hashable, Equatable, Sendable {
         case array
         case sorted_array
         case sorted_set
@@ -108,7 +108,7 @@ public struct IngestionDimensionSpecDimension: Codable, Hashable, Equatable {
     public let multiValueHandling: MultiValueHandlingOption?
 }
 
-public struct IngestionDimensionSpecSpatialDimension: Codable, Hashable, Equatable {
+public struct IngestionDimensionSpecSpatialDimension: Codable, Hashable, Equatable, Sendable {
     public init(dimName: String, dims: [String]? = nil) {
         self.dimName = dimName
         self.dims = dims