public LogShipper()

in src/Serilog.Sinks.AzureDataExplorer/Durable/LogShipper.cs [82:105]

• 24 lines of code
• 1 McCabe index (conditional complexity)

        public LogShipper(
            AzureDataExplorerSinkOptions options,
            TimeSpan period,
            IPayloadReader<TPayload> payloadReader,
            IKustoQueuedIngestClient ingestClient,
            IngestionMapping ingestionMapping)
        {
            m_options = options;
            m_batchPostingLimit = options.BatchPostingLimit;
            m_eventBodyLimitBytes = options.SingleEventSizePostingLimit;
            m_payloadReader = payloadReader;
            m_controlledSwitch = new ControlledLevelSwitch(options.BufferFileLoggingLevelSwitch);
            m_connectionSchedule = new ExponentialBackoffConnectionSchedule(period);
            m_bufferSizeLimitBytes = options.BufferFileSizeLimitBytes;
            m_fileSet = new FileSet(options.BufferBaseFileName, options.BufferFileRollingInterval);
            m_timer = new PortableTimer(c => OnTick());
            m_ingestClient = ingestClient;
            m_formatProvider = options.FormatProvider;
            m_databaseName = options.DatabaseName;
            m_tableName = options.TableName;
            m_ingestionMapping = ingestionMapping;
            m_flushImmediately = options.FlushImmediately;
            SetTimer();
        }