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