Class: Fractor::QueuePersister::Base Abstract

Inherits:
Object
  • Object
show all
Defined in:
lib/fractor/queue_persister.rb

Overview

This class is abstract.

Subclasses must implement #save and #load

Base class for queue persisters.

Direct Known Subclasses

JSONPersister, MarshalPersister, YAMLPersister

Instance Method Summary collapse

Instance Method Details

#clear ⇒ Boolean

This method is abstract.

Clear persisted data.

Returns:

  • (Boolean) —

    true if cleared successfully

Raises:

  • (NotImplementedError) 


35
36
37
 
# File 'lib/fractor/queue_persister.rb', line 35

def clear
  raise NotImplementedError, "Subclasses must implement #clear"
end

#load ⇒ Array<Hash>?

This method is abstract.

Load work items from persistent storage.

Returns:

  • (Array<Hash>, nil) —

    Serialized work items, or nil if no data

Raises:

  • (NotImplementedError) 


27
28
29
 
# File 'lib/fractor/queue_persister.rb', line 27

def load
  raise NotImplementedError, "Subclasses must implement #load"
end

#save(_items) ⇒ Boolean

This method is abstract.

Save work items to persistent storage.

Parameters:

Returns:

  • (Boolean) —

    true if saved successfully

Raises:

  • (NotImplementedError) 


19
20
21
 
# File 'lib/fractor/queue_persister.rb', line 19

def save(_items)
  raise NotImplementedError, "Subclasses must implement #save"
end