Module: Dag::Client::Storage
- Included in:
- Dag::Client
- Defined in:
- lib/dag/client/storage.rb
Instance Method Summary collapse
- #buckets ⇒ Object
- #create_bucket(bucket) ⇒ Object
- #delete_bucket(bucket) ⇒ Object
- #delete_object(bucket, object) ⇒ Object
-
#import(db_name, table, file_path, options = {}) ⇒ Object
options == *
label
- label *jobs
- count of executing pararell. - #objects(bucket) ⇒ Object
Instance Method Details
#buckets ⇒ Object
4 5 6 |
# File 'lib/dag/client/storage.rb', line 4 def buckets Dag::BucketCollection.new(@api) end |
#create_bucket(bucket) ⇒ Object
12 13 14 15 16 |
# File 'lib/dag/client/storage.rb', line 12 def create_bucket(bucket) @api.create_bucket(bucket) Dag::Bucket.new(@api, bucket) end |
#delete_bucket(bucket) ⇒ Object
18 19 20 21 22 |
# File 'lib/dag/client/storage.rb', line 18 def delete_bucket(bucket) @api.delete_bucket(bucket) nil end |
#delete_object(bucket, object) ⇒ Object
24 25 26 27 28 |
# File 'lib/dag/client/storage.rb', line 24 def delete_object(bucket, object) @api.delete_object(bucket, object) nil end |
#import(db_name, table, file_path, options = {}) ⇒ Object
options ==
-
label
- label -
jobs
- count of executing pararell
34 35 36 37 38 |
# File 'lib/dag/client/storage.rb', line 34 def import(db_name, table, file_path, = {}) @api.import(db_name, table, file_path, ) nil end |
#objects(bucket) ⇒ Object
8 9 10 |
# File 'lib/dag/client/storage.rb', line 8 def objects(bucket) Dag::ObjectCollection.new(@api, bucket) end |