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 



843
844
845
846
 
# File 'lib/wurk/client/buffered.rb', line 843

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

#push_bulk(items) ⇒ Object 



848
849
850
851
 
# File 'lib/wurk/client/buffered.rb', line 848

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

#push_prepared(payloads) ⇒ Object 



853
854
855
856
 
# File 'lib/wurk/client/buffered.rb', line 853

def push_prepared(payloads)
  Buffered.drain!(self) unless Buffered.unbuffered?
  super
end