class PulsarSdk::Client::Connection::Status
Constants
- STATUS
Attributes
last_ping_at[R]
last_received_at[R]
Public Class Methods
new()
click to toggle source
# File lib/pulsar_sdk/client/connection.rb, line 300 def initialize @state = 'init' @lock = Mutex.new @signal = ConditionVariable.new @last_received_at = 0 @last_ping_at = 0 end
Public Instance Methods
ping!()
click to toggle source
# File lib/pulsar_sdk/client/connection.rb, line 320 def ping! @lock.synchronize do @last_ping_at = Process.clock_gettime(Process::CLOCK_MONOTONIC) end end
received!()
click to toggle source
# File lib/pulsar_sdk/client/connection.rb, line 314 def received! @lock.synchronize do @last_received_at = Process.clock_gettime(Process::CLOCK_MONOTONIC) end end
wait()
click to toggle source
# File lib/pulsar_sdk/client/connection.rb, line 308 def wait @lock.synchronize do @signal.wait(@lock) end end