using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace MarketDataWriterService.Configuration
{
    public class MarketDataWriterServiceConfig
    {
        public string DatabaseConnectionString { get; set; }
        public string KafkaBrokers { get; set; }
        public string TradesAllTopic { get; set; }
        public string HaltsAllTopic { get; set; }
        public string OrderImbalancesAllTopic { get; set; }

        //NOT SUPPORTED YET
        public string CryptoTradesAllTopic { get; set; }

        //The Number of MarketDataWriterWorkers to start 
        public int Workers { get; set; }

        //The Max size the memory queue can reach before no further message inserts are permitted
        //When the max is reached insertion is paused until the workers can catch up.
        public int MaxQueueSize { get; set; }

        //The Delay between the Monitoring Loop Iterations
        public int MonitorDelaySeconds { get; set; }

        //The amount of TradeQuote records sent as one batch to the database for insertion
        public int BatchSize { get; set; }

        //The amount of time to wait before sending an batch insert when the batch size has not yet been reached. 
        public int BatchTimeoutMilliseconds { get; set; }

    }
}