Class: Ruote::CompositeStorage

Inherits:

Object

• Object
• Ruote::CompositeStorage

show all

Includes:

StorageBase

Defined in:

lib/ruote/storage/composite_storage.rb

Overview

opts = {}

engine =
  Ruote::Engine.new(
    Ruote::Worker.new(
      Ruote::CompositeStorage.new(
        Ruote::FsStorage.new('ruote_work', opts),
        'msgs' => Ruote::HashStorage.new(opts))))

Constant Summary

Instance Method Summary (collapse)

• - (Object) delete(doc)
• - (Object) get(type, key)
• - (Object) get_many(type, key = nil, opts = {})
• - (Object) ids(type)
• - (CompositeStorage) initialize(default_storage, storages) constructor

  A new instance of CompositeStorage.

• - (Object) purge!
• - (Object) purge_type!(type)
• - (Object) put(doc, opts = {})

Methods included from StorageBase

#clear, #context, #context=, #copy_to, #delete_schedule, #empty?, #expression_wfids, #find_root_expression, #get_configuration, #get_engine_variable, #get_msgs, #get_schedules, #get_trackers, #put_engine_variable, #put_msg, #put_schedule, #reserve

50
51
52
53
54
55
56

# File 'lib/ruote/storage/composite_storage.rb', line 50

def initialize(default_storage, storages)

  @default_storage = default_storage
  @storages = storages

  prepare_base_methods
end

68
69
70
71

# File 'lib/ruote/storage/composite_storage.rb', line 68

def delete(doc)

  storage(doc['type']).delete(doc)
end

63
64
65
66

# File 'lib/ruote/storage/composite_storage.rb', line 63

def get(type, key)

  storage(type).get(type, key)
end

73
74
75
76

# File 'lib/ruote/storage/composite_storage.rb', line 73

def get_many(type, key=nil, opts={})

  storage(type).get_many(type, key, opts)
end

78
79
80
81

# File 'lib/ruote/storage/composite_storage.rb', line 78

def ids(type)

  storage(type).ids(type)
end

83
84
85
86

# File 'lib/ruote/storage/composite_storage.rb', line 83

def purge!

  TYPES.collect { |t| storage(t) }.uniq.each { |s| s.purge! }
end

88
89
90
91

# File 'lib/ruote/storage/composite_storage.rb', line 88

def purge_type!(type)

  storage(type).purge_type!(type)
end

58
59
60
61

# File 'lib/ruote/storage/composite_storage.rb', line 58

def put(doc, opts={})

  storage(doc['type']).put(doc, opts)
end