public ISink getSink()

in src/main/java/software/amazon/cloudwatchlogs/emf/environment/AgentBasedEnvironment.java [56:81]

26 lines of code
3 McCabe index (conditional complexity)


    public ISink getSink() {
        if (sink == null) {
            Endpoint endpoint;
            if (!config.getAgentEndpoint().isPresent()) {
                log.info(
                        "Endpoint is not defined. Using default: {}",
                        Endpoint.DEFAULT_TCP_ENDPOINT);
                endpoint = Endpoint.DEFAULT_TCP_ENDPOINT;
            } else {
                endpoint = Endpoint.fromURL(config.getAgentEndpoint().get());
            }
            sink =
                    new AgentSink(
                            getLogGroupName(),
                            getLogStreamName(),
                            endpoint,
                            new SocketClientFactory(),
                            config.getAsyncBufferSize(),
                            () ->
                                    new FibonacciRetryStrategy(
                                            Constants.MIN_BACKOFF_MILLIS,
                                            Constants.MAX_BACKOFF_MILLIS,
                                            Constants.MAX_BACKOFF_JITTER));
        }
        return sink;
    }