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
-
#connection ⇒ Object
Returns the value of attribute connection.
Instance Method Summary collapse
- #address ⇒ Object
- #connect ⇒ Object
-
#initialize(address, port) ⇒ TlsEndpoint
constructor
A new instance of TlsEndpoint.
- #resolve_address ⇒ Object
- #unbind ⇒ Object
- #write(value) ⇒ Object
Constructor Details
#initialize(address, port) ⇒ TlsEndpoint
Returns a new instance of TlsEndpoint.
21 22 23 24 25 26 27 28 29 30 31 32 33 34 |
# File 'lib/remote_syslog/tls_endpoint.rb', line 21 def initialize(address, port) @address = address @port = port.to_i # 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
#connection ⇒ Object
Returns the value of attribute connection.
19 20 21 |
# File 'lib/remote_syslog/tls_endpoint.rb', line 19 def connection @connection end |
Instance Method Details
#address ⇒ Object
43 44 45 |
# File 'lib/remote_syslog/tls_endpoint.rb', line 43 def address @cached_ip || @address end |
#connect ⇒ Object
47 48 49 |
# File 'lib/remote_syslog/tls_endpoint.rb', line 47 def connect EventMachine.connect(address, @port, TlsEndpoint::Handler, self) end |
#resolve_address ⇒ Object
36 37 38 39 40 41 |
# File 'lib/remote_syslog/tls_endpoint.rb', line 36 def resolve_address request = EventMachine::DnsResolver.resolve(@address) request.callback do |addrs| @cached_ip = addrs.first end end |
#unbind ⇒ Object
51 52 53 54 |
# File 'lib/remote_syslog/tls_endpoint.rb', line 51 def unbind @connection = nil connect end |
#write(value) ⇒ Object
56 57 58 59 60 61 62 63 64 65 66 |
# File 'lib/remote_syslog/tls_endpoint.rb', line 56 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 end end |