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