Method: ConcurrentPipeline::Store#create

Defined in:
lib/concurrent_pipeline/store.rb

#create(record_name, **attrs) ⇒ Object 



34
35
36
37
38
39
40
41
42
43
 
# File 'lib/concurrent_pipeline/store.rb', line 34

def create(record_name, **attrs)
  ensure_writable

  storage.create(
    name: record_name,
    attrs: { id: SecureRandom.uuid }.merge(attrs)
  )

  nil
end