class LogStash::Outputs::DatadogLogs::DatadogTCPClient
Public Class Methods
new(logger, use_ssl, no_ssl_validation, host, port)
click to toggle source
# File lib/logstash/outputs/datadog_logs.rb, line 241 def initialize(logger, use_ssl, no_ssl_validation, host, port) @logger = logger @use_ssl = use_ssl @no_ssl_validation = no_ssl_validation @host = host @port = port end
Public Instance Methods
close()
click to toggle source
# File lib/logstash/outputs/datadog_logs.rb, line 277 def close @socket.close rescue nil end
connect()
click to toggle source
# File lib/logstash/outputs/datadog_logs.rb, line 249 def connect if @use_ssl @logger.info("Starting SSL connection #{@host} #{@port}") socket = TCPSocket.new @host, @port ssl_context = OpenSSL::SSL::SSLContext.new if @no_ssl_validation ssl_context.set_params({:verify_mode => OpenSSL::SSL::VERIFY_NONE}) end ssl_context = OpenSSL::SSL::SSLSocket.new socket, ssl_context ssl_context.connect ssl_context else @logger.info("Starting plaintext connection #{@host} #{@port}") TCPSocket.new @host, @port end end
send(payload)
click to toggle source
# File lib/logstash/outputs/datadog_logs.rb, line 266 def send(payload) begin @socket ||= connect @socket.puts(payload) rescue => e @socket.close rescue nil @socket = nil raise RetryableError.new "Unable to send payload: #{e.message}." end end