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:



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

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 



256
257
258
 
# File 'lib/httpimagestore/configuration/s3.rb', line 256

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

#private_url ⇒ Object 



240
241
242
243
244
245
246
 
# File 'lib/httpimagestore/configuration/s3.rb', line 240

def private_url
	url = @cache_file.header['private_url'] and return Addressable::URI.parse(url)
	dirty! :private_url
	url = super
	@cache_file.header['private_url'] = url.to_s
	Addressable::URI.parse(url)
end

#public_url ⇒ Object 



248
249
250
251
252
253
254
 
# File 'lib/httpimagestore/configuration/s3.rb', line 248

def public_url
	url = @cache_file.header['public_url'] and return Addressable::URI.parse(url)
	dirty! :public_url
	url = super
	@cache_file.header['public_url'] = url.to_s
	Addressable::URI.parse(url)
end

#read(max_bytes = nil) ⇒ Object 



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

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 



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

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