public AgentSink()

in src/Amazon.CloudWatch.EMF/Sink/AgentSink.cs [27:42]

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

        public AgentSink(
             string logGroupName,
             string logStreamName,
             Endpoint endpoint,
             ISocketClientFactory clientFactory,
             IConfiguration config,
             ILoggerFactory loggerFactory)
        {
            _logGroupName = logGroupName;
            _logStreamName = logStreamName;
            _socketClient = clientFactory.GetClient(endpoint);
            _queue = new BlockingCollection<string>(config.AgentBufferSize);
            _logger = loggerFactory.CreateLogger<AgentSink>();
            _cancellationTokenSource = new CancellationTokenSource();
            _sender = RunSenderThread(loggerFactory);
        }