Class: Turnpike::Base

Inherits:
Object
  • Object
show all
Extended by:
Forwardable
Defined in:
lib/turnpike/base.rb

Direct Known Subclasses

Queue, UniqueQueue

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(name, redis: Redis.current) ⇒ Base

Returns a new instance of Base.



13
14
15
16
 
# File 'lib/turnpike/base.rb', line 13

def initialize(name, redis: Redis.current)
  @name = "#{Turnpike.namespace}:#{name}"
  @redis = redis
end

Instance Attribute Details

#name ⇒ Object (readonly)

Returns the value of attribute name.



11
12
13
 
# File 'lib/turnpike/base.rb', line 11

def name
  @name
end

Instance Method Details

#bpop ⇒ Object

Raises:

  • (NotImplementedError) 


27
 
# File 'lib/turnpike/base.rb', line 27

def bpop(*); raise NotImplementedError; end

#clear ⇒ Object 



18
19
20
 
# File 'lib/turnpike/base.rb', line 18

def clear
  redis.del(name)
end

#empty? ⇒ Boolean

Returns:

  • (Boolean) 


22
23
24
 
# File 'lib/turnpike/base.rb', line 22

def empty?
  size == 0
end

#pop ⇒ Object

Raises:

  • (NotImplementedError) 


26
 
# File 'lib/turnpike/base.rb', line 26

def pop(*); raise NotImplementedError; end

#push ⇒ Object

Raises:

  • (NotImplementedError) 


28
 
# File 'lib/turnpike/base.rb', line 28

def push(*); raise NotImplementedError; end

#size ⇒ Object

Raises:

  • (NotImplementedError) 


29
 
# File 'lib/turnpike/base.rb', line 29

def size; raise NotImplementedError; end

#unshift ⇒ Object

Raises:

  • (NotImplementedError) 


30
 
# File 'lib/turnpike/base.rb', line 30

def unshift(*); raise NotImplementedError; end