class UploadService::BlockList
@api private
Public Class Methods
new(blocks = [])
click to toggle source
# File lib/fluent/plugin/upload_service.rb, line 112 def initialize(blocks = []) @blocks = blocks @mutex = Mutex.new end
Public Instance Methods
clear!()
click to toggle source
# File lib/fluent/plugin/upload_service.rb, line 125 def clear! @mutex.synchronize { @blocks.clear } end
push(block)
click to toggle source
# File lib/fluent/plugin/upload_service.rb, line 117 def push(block) @mutex.synchronize { @blocks.push(block) } end
shift()
click to toggle source
# File lib/fluent/plugin/upload_service.rb, line 121 def shift @mutex.synchronize { @blocks.shift } end
to_a()
click to toggle source
# File lib/fluent/plugin/upload_service.rb, line 129 def to_a @mutex.synchronize { @blocks.dup } end