diff --git a/src/RethinkDb.Azure.WebJobs.Extensions/Trigger/RethinkDbScaleMonitor.cs b/src/RethinkDb.Azure.WebJobs.Extensions/Trigger/RethinkDbScaleMonitor.cs index c8ced1a..d503884 100644 --- a/src/RethinkDb.Azure.WebJobs.Extensions/Trigger/RethinkDbScaleMonitor.cs +++ b/src/RethinkDb.Azure.WebJobs.Extensions/Trigger/RethinkDbScaleMonitor.cs @@ -1,8 +1,6 @@ -using System; -using System.Linq; +using System.Linq; using System.Threading.Tasks; using Microsoft.Azure.WebJobs.Host.Scale; -using Microsoft.Extensions.Logging; namespace RethinkDb.Azure.WebJobs.Extensions.Trigger { diff --git a/src/RethinkDb.Azure.WebJobs.Extensions/Trigger/RethinkDbTargetScaler.cs b/src/RethinkDb.Azure.WebJobs.Extensions/Trigger/RethinkDbTargetScaler.cs index 04cacdf..8b614f0 100644 --- a/src/RethinkDb.Azure.WebJobs.Extensions/Trigger/RethinkDbTargetScaler.cs +++ b/src/RethinkDb.Azure.WebJobs.Extensions/Trigger/RethinkDbTargetScaler.cs @@ -1,16 +1,35 @@ -using System; -using System.Threading.Tasks; +using System.Threading.Tasks; using Microsoft.Azure.WebJobs.Host.Scale; namespace RethinkDb.Azure.WebJobs.Extensions.Trigger { internal class RethinkDbTargetScaler : ITargetScaler { - public TargetScalerDescriptor TargetScalerDescriptor => throw new NotImplementedException(); + #region Fields + private readonly string _functionId; + #endregion + #region Properties + public TargetScalerDescriptor TargetScalerDescriptor { get; } + #endregion + + #region Constructor + public RethinkDbTargetScaler(string functionId) + { + _functionId = functionId; + + TargetScalerDescriptor = new TargetScalerDescriptor(_functionId); + } + #endregion + + #region Methods public Task GetScaleResultAsync(TargetScalerContext context) { - throw new NotImplementedException(); + return Task.FromResult(new TargetScalerResult + { + TargetWorkerCount = 1 + }); } + #endregion } } diff --git a/src/RethinkDb.Azure.WebJobs.Extensions/Trigger/RethinkDbTriggerListener.cs b/src/RethinkDb.Azure.WebJobs.Extensions/Trigger/RethinkDbTriggerListener.cs index e4186f8..5c42ce9 100644 --- a/src/RethinkDb.Azure.WebJobs.Extensions/Trigger/RethinkDbTriggerListener.cs +++ b/src/RethinkDb.Azure.WebJobs.Extensions/Trigger/RethinkDbTriggerListener.cs @@ -43,7 +43,7 @@ public RethinkDbTriggerListener(string functionId, ITriggeredFunctionExecutor ex _rethinkDbMetricsProvider = new RethinkDbMetricsProvider(); _rethinkDbScaleMonitor = new RethinkDbScaleMonitor(_functionId, _rethinkDbMetricsProvider); - _rethinkDbTargetScaler = new RethinkDbTargetScaler(); + _rethinkDbTargetScaler = new RethinkDbTargetScaler(_functionId); } #endregion