Class: RetryAWS::SimpleDB

Inherits:
Object
  • Object
show all
Defined in:
lib/RetryAWS/SimpleDB.rb

Instance Method Summary collapse

Constructor Details

#initialize(access_key, secret_key) ⇒ SimpleDB

Returns a new instance of SimpleDB.



7
8
9
10
 
# File 'lib/RetryAWS/SimpleDB.rb', line 7

def initialize(access_key, secret_key)
  @simple_db = AWS::SimpleDB.new(access_key, secret_key)
  @@log = STDOUT
end

Instance Method Details

#create_domain(domain_name) ⇒ Object 



46
47
48
49
50
51
52
53
54
55
56
 
# File 'lib/RetryAWS/SimpleDB.rb', line 46

def create_domain(domain_name)
  retry_time = 1
  begin
    @simple_db.create_domain(domain_name)
  rescue AWS::ServiceError => err
    retry if retry_time = retry?(err, retry_time)
    report_error false
  rescue
    report_error false
  end
end

#delete_attributes(domain_name, item_name, attributes = {}) ⇒ Object 



82
83
84
85
86
87
88
89
90
91
92
 
# File 'lib/RetryAWS/SimpleDB.rb', line 82

def delete_attributes(domain_name, item_name, attributes = {})
  retry_time = 1
  begin
    @simple_db.delete_attributes(domain_name, item_name, attributes)
  rescue AWS::ServiceError => err
    retry if retry_time = retry?(err, retry_time)
    report_error false
  rescue
    report_error false
  end
end

#delete_domain(domain_name) ⇒ Object 



58
59
60
61
62
63
64
65
66
67
68
 
# File 'lib/RetryAWS/SimpleDB.rb', line 58

def delete_domain(domain_name)
  retry_time = 1
  begin
    @simple_db.delete_domain(domain_name)
  rescue AWS::ServiceError => err
    retry if retry_time = retry?(err, retry_time)
    report_error false
  rescue
    report_error false
  end
end

#get_attributes(domain_name, item_name, attribute_name = nil) ⇒ Object 



94
95
96
97
98
99
100
101
102
103
104
 
# File 'lib/RetryAWS/SimpleDB.rb', line 94

def get_attributes(domain_name, item_name, attribute_name = nil)
  retry_time = 1
  begin
    @simple_db.get_attributes(domain_name, item_name, attribute_name)
  rescue AWS::ServiceError => err
    retry if retry_time = retry?(err, retry_time)
    report_error {}
  rescue
    report_error {}
  end
end

#list_domains(max_domains = 100) ⇒ Object 



34
35
36
37
38
39
40
41
42
43
44
 
# File 'lib/RetryAWS/SimpleDB.rb', line 34

def list_domains(max_domains = 100)
  retry_time = 1
  begin
    @simple_db.list_domains(max_domains)
  rescue AWS::ServiceError => err
    retry if retry_time = retry?(err, retry_time)
    report_error []
  rescue
    report_error []
  end
end

#logger=(logger) ⇒ Object 



12
13
14
 
# File 'lib/RetryAWS/SimpleDB.rb', line 12

def logger=(logger)
  @@log = logger
end

#put_attributes(domain_name, item_name, attributes, replace = false) ⇒ Object 



70
71
72
73
74
75
76
77
78
79
80
 
# File 'lib/RetryAWS/SimpleDB.rb', line 70

def put_attributes(domain_name, item_name, attributes, replace=false)
  retry_time = 1
  begin
    @simple_db.put_attributes(domain_name, item_name, attributes, replace)
  rescue AWS::ServiceError => err
    retry if retry_time = retry?(err, retry_time)
    report_error false
  rescue
    report_error false
  end
end

#query(domain_name, query_expression = nil, options = {:fetch_all=>true}) ⇒ Object 



106
107
108
109
110
111
112
113
114
115
116
 
# File 'lib/RetryAWS/SimpleDB.rb', line 106

def query(domain_name, query_expression=nil, options={:fetch_all=>true})
  retry_time = 1
  begin
    @simple_db.query(domain_name, query_expression, options)
  rescue AWS::ServiceError => err
    retry if retry_time = retry?(err, retry_time)
    report_error {}
  rescue
    report_error {}
  end
end