Simple Collector

gistfile1.txt

using System;
using System.Collections.Generic;
using System.Threading.Tasks;
using CentralStation.Actors.Services;
using CentralStation.Core;
using CentralStation.Core.Actors.Collectors;
using CentralStation.Core.Messages.Collectors;
using CentralStation.Core.PatternMatching;
using Syncromatics.Instrumentation.InfluxDb;

namespace CentralStation.Actors.Collectors
{
    public class InfluxStatsCollectorActor : IInfluxStatsCollectorActor
    {
        private readonly IStatPointsWriter _influxDbClient;
        public event MetricDelegate MetricUpdates;
        public event UnHandledMessageDelegate UnHandledMessage;

        private readonly List<InfluxDbPoint> _points = new List<InfluxDbPoint>();

        public InfluxStatsCollectorActor(IStatPointsWriter influxDbClient)
        {
            _influxDbClient = influxDbClient;
        }

        public Task TellAsync(object message)
        {
            return message.TaskMatch()
                .With<InfluxDbPoint>(point => CollectPoint(point))
                .With<Collect>(async _ => await CollectPoints())
                .Execute();
        }

        public void Tell(object message)
        {
            TellAsync(message).Wait();
        }

        private void CollectPoint(InfluxDbPoint point)
        {
            _points.Add(point);
        }

        private async Task CollectPoints()
        {
            await _influxDbClient.WriteAsync(_points);
            _points.Clear();
        }

        public void Dispose()
        {
            
        }
    }
}