Class: RemoteSyslog::TlsEndpoint
- Inherits:
-
Object
- Object
- RemoteSyslog::TlsEndpoint
- Defined in:
- lib/remote_syslog/tls_endpoint.rb
Defined Under Namespace
Classes: Handler
Instance Attribute Summary collapse
-
#client_cert_chain ⇒ Object
readonly
Returns the value of attribute client_cert_chain.
-
#client_private_key ⇒ Object
readonly
Returns the value of attribute client_private_key.
-
#connection ⇒ Object
Returns the value of attribute connection.
-
#logger ⇒ Object
readonly
Returns the value of attribute logger.
-
#server_cert ⇒ Object
readonly
Returns the value of attribute server_cert.
Instance Method Summary collapse
- #address ⇒ Object
- #connect ⇒ Object
-
#initialize(address, port, options = {}) ⇒ TlsEndpoint
constructor
A new instance of TlsEndpoint.
- #resolve_address ⇒ Object
- #unbind ⇒ Object
- #write(value) ⇒ Object
Constructor Details
#initialize(address, port, options = {}) ⇒ TlsEndpoint
Returns a new instance of TlsEndpoint.
36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 |
# File 'lib/remote_syslog/tls_endpoint.rb', line 36 def initialize(address, port, = {}) @address = address @port = port.to_i @client_cert_chain = [:client_cert_chain] @client_private_key = [:client_private_key] @queue_limit = [:queue_limit] || 10_000 @logger = [:logger] || Logger.new(STDERR) if [:server_cert] @server_cert = OpenSSL::X509::Certificate.new(File.read([:server_cert])) end # Try to resolve the address resolve_address # Every 60 seconds we'll see if the address has changed EventMachine.add_periodic_timer(60) do resolve_address end connect end |
Instance Attribute Details
#client_cert_chain ⇒ Object (readonly)
Returns the value of attribute client_cert_chain.
32 33 34 |
# File 'lib/remote_syslog/tls_endpoint.rb', line 32 def client_cert_chain @client_cert_chain end |
#client_private_key ⇒ Object (readonly)
Returns the value of attribute client_private_key.
32 33 34 |
# File 'lib/remote_syslog/tls_endpoint.rb', line 32 def client_private_key @client_private_key end |
#connection ⇒ Object
Returns the value of attribute connection.
31 32 33 |
# File 'lib/remote_syslog/tls_endpoint.rb', line 31 def connection @connection end |
#logger ⇒ Object (readonly)
Returns the value of attribute logger.
34 35 36 |
# File 'lib/remote_syslog/tls_endpoint.rb', line 34 def logger @logger end |
#server_cert ⇒ Object (readonly)
Returns the value of attribute server_cert.
32 33 34 |
# File 'lib/remote_syslog/tls_endpoint.rb', line 32 def server_cert @server_cert end |
Instance Method Details
#address ⇒ Object
72 73 74 |
# File 'lib/remote_syslog/tls_endpoint.rb', line 72 def address @cached_ip || @address end |
#connect ⇒ Object
76 77 78 79 |
# File 'lib/remote_syslog/tls_endpoint.rb', line 76 def connect logger.debug "Connecting to #{address}:#{@port}" EventMachine.connect(address, @port, TlsEndpoint::Handler, self) end |
#resolve_address ⇒ Object
65 66 67 68 69 70 |
# File 'lib/remote_syslog/tls_endpoint.rb', line 65 def resolve_address request = EventMachine::DnsResolver.resolve(@address) request.callback do |addrs| @cached_ip = addrs.first end end |
#unbind ⇒ Object
81 82 83 84 85 86 87 |
# File 'lib/remote_syslog/tls_endpoint.rb', line 81 def unbind @connection = nil EventMachine.add_timer(1) do connect end end |
#write(value) ⇒ Object
89 90 91 92 93 94 95 96 97 98 99 100 101 102 |
# File 'lib/remote_syslog/tls_endpoint.rb', line 89 def write(value) if @connection if @queue @connection.send_data(@queue.join("\n") + "\n") @queue = nil end @connection.send_data(value + "\n") else (@queue ||= []) << value # Make sure our queue does not get to be too big @queue.shift if @queue.length > @queue_limit end end |