Class: Configuration::S3SourceStoreBase::CacheObject

Inherits:
S3Object
  • Object
show all
Extended by:
Stats
Includes:
ClassLogging
Defined in:
lib/httpimagestore/configuration/s3.rb

Instance Method Summary collapse

Methods inherited from S3Object

#s3_object

Constructor Details

#initialize(cache_file, client, bucket, key) {|_self| ... } ⇒ CacheObject

Returns a new instance of CacheObject.

Yields:

  • (_self)

Yield Parameters:



202
203
204
205
206
207
208
209
210
211
212
 
# File 'lib/httpimagestore/configuration/s3.rb', line 202

def initialize(cache_file, client, bucket, key)
	super(client, bucket, key)

	@cache_file = cache_file
	@dirty = false

	yield self

	# save object if new data was read/written to/from S3 and no error happened
	write_cache if dirty?
end

Instance Method Details

#content_type ⇒ Object 



247
248
249
 
# File 'lib/httpimagestore/configuration/s3.rb', line 247

def content_type
	@cache_file.header['content_type'] ||= (dirty! :content_type; super)
end

#private_url ⇒ Object 



239
240
241
 
# File 'lib/httpimagestore/configuration/s3.rb', line 239

def private_url
	@cache_file.header['private_url'] ||= (dirty! :private_url; super)
end

#public_url ⇒ Object 



243
244
245
 
# File 'lib/httpimagestore/configuration/s3.rb', line 243

def public_url
	@cache_file.header['public_url'] ||= (dirty! :public_url; super)
end

#read(max_bytes = nil) ⇒ Object 



214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
 
# File 'lib/httpimagestore/configuration/s3.rb', line 214

def read(max_bytes = nil)
	begin
		@data = @cache_file.read(max_bytes)
		CacheObject.stats.incr_total_s3_cache_hits
		log.debug{"S3 object cache hit for bucket: '#{@bucket}' key: '#{@key}' [#{@cache_file}]: header: #{@cache_file.header}"}
		return @data
	rescue Errno::ENOENT
		CacheObject.stats.incr_total_s3_cache_misses
		log.debug{"S3 object cache miss for bucket: '#{@bucket}' key: '#{@key}' [#{@cache_file}]"}
	rescue => error
		CacheObject.stats.incr_total_s3_cache_errors
		log.warn "cannot use cached S3 object for bucket: '#{@bucket}' key: '#{@key}' [#{@cache_file}]", error
	end
	@data = super
	dirty! :read
	return @data
end

#write(data, options = {}) ⇒ Object 



232
233
234
235
236
237
 
# File 'lib/httpimagestore/configuration/s3.rb', line 232

def write(data, options = {})
	super
	@data = data
	@cache_file.header['content_type'] = options[:content_type] if options[:content_type]
	dirty! :write
end