Upr::Monitor

Keeps track of the status of all currently processing uploads This uses any Moneta store to monitor upload progress.

Usage (in config.ru with Moneta::Memory store):

  require 'upr'
  require 'moneta/memory'
  use Upr, :backend => Upr::Monitor.new(Moneta::Memory.new)
  run YourApplication.new

Constants

OPT

Public Class Methods

new(moneta_store = nil) click to toggle source

    # File lib/upr/monitor.rb, line 17
17:     def initialize(moneta_store = nil)
18:       super
19:       if moneta_store.nil?
20:         require 'moneta/memory' # moneta does not autoload :<
21:         self.moneta = Moneta::Memory.new
22:       end
23:     end

Public Instance Methods

error!(upid) click to toggle source

    # File lib/upr/monitor.rb, line 46
46:     def error!(upid)
47:       status = moneta[upid] or return
48:       status.seen = 1
49:       moneta.store(upid, status, OPT)
50:     end

finish(upid) click to toggle source

    # File lib/upr/monitor.rb, line 39
39:     def finish(upid)
40:       status = moneta[upid] or return
41:       status.length ||= status.seen
42:       status.seen = status.length
43:       moneta.store(upid, status, OPT)
44:     end

incr(upid, nr) click to toggle source

    # File lib/upr/monitor.rb, line 33
33:     def incr(upid, nr)
34:       status = moneta[upid] or return
35:       status.seen += nr if status.seen >= 0
36:       moneta.store(upid, status, OPT)
37:     end

read(upid) click to toggle source

    # File lib/upr/monitor.rb, line 29
29:     def read(upid)
30:       moneta[upid]
31:     end

start(upid, length) click to toggle source

    # File lib/upr/monitor.rb, line 25
25:     def start(upid, length)
26:       moneta.store(upid, Status.new(0, length), OPT)
27:     end

Home Classes Methods

In Files

Parent

Methods

Files

Class Index

Upr::Monitor

Constants

Public Class Methods

Public Instance Methods