diff --git a/NEW/src/JdeScoping.DataSync/Contracts/IEtlPipelineFactory.cs b/NEW/src/JdeScoping.DataSync/Contracts/IEtlPipelineFactory.cs new file mode 100644 index 0000000..2dff781 --- /dev/null +++ b/NEW/src/JdeScoping.DataSync/Contracts/IEtlPipelineFactory.cs @@ -0,0 +1,15 @@ +using JdeScoping.DataSync.Etl.Pipeline; + +namespace JdeScoping.DataSync.Contracts; + +public interface IEtlPipelineFactory +{ + IEtlPipelineBuilder ForTable(string tableName); +} + +public interface IEtlPipelineBuilder +{ + IEtlPipelineBuilder WithMode(SyncMode mode); + IEtlPipelineBuilder WithMinimumDate(DateTime? minDt); + EtlPipeline Build(); +} diff --git a/NEW/src/JdeScoping.DataSync/Contracts/SyncMode.cs b/NEW/src/JdeScoping.DataSync/Contracts/SyncMode.cs new file mode 100644 index 0000000..f497f07 --- /dev/null +++ b/NEW/src/JdeScoping.DataSync/Contracts/SyncMode.cs @@ -0,0 +1,7 @@ +namespace JdeScoping.DataSync.Contracts; + +public enum SyncMode +{ + Mass, + Incremental +}