Module: Wurk::Client::Buffered::InstanceMethods

Defined in:
lib/wurk/client/buffered.rb

Overview

Wraps Wurk::Client. push / push_bulk drain the buffer first; raw_push catches transient failures — RedisClient::ConnectionError past RedisPool's own retries, or a starved checkout (ConnectionPool::TimeoutError) — and buffers non-batched payloads.

Instance Method Summary collapse

Instance Method Details

#push(item) ⇒ Object 



317
318
319
320
 
# File 'lib/wurk/client/buffered.rb', line 317

def push(item)
  Buffered.drain!(self)
  super
end

#push_bulk(items) ⇒ Object 



322
323
324
325
 
# File 'lib/wurk/client/buffered.rb', line 322

def push_bulk(items)
  Buffered.drain!(self)
  super
end