Module: Sidekiq::Status
- Extended by:
- Storage
- Defined in:
- lib/sidekiq-status/web.rb,
lib/sidekiq-status/version.rb,
lib/sidekiq-status/testing/inline.rb,
lib/sidekiq-status/client_middleware.rb,
lib/sidekiq-status/server_middleware.rb,
lib/sidekiq-status.rb
Overview
Defined Under Namespace
Modules: Storage, Web, Worker
Classes: ClientMiddleware, RedisAdapter, RedisClientAdapter, ServerMiddleware
Constant Summary
collapse
- VERSION =
'3.0.3'
- DEFAULT_EXPIRY =
60 * 30
- STATUS =
[ :queued, :working, :retrying, :complete, :stopped, :failed, :interrupted ].freeze
Constants included
from Storage
Storage::BATCH_LIMIT, Storage::RESERVED_FIELDS
Class Method Summary
collapse
Class Method Details
.at(job_id) ⇒ Object
Methods for retrieving job completion
54
55
56
|
# File 'lib/sidekiq-status.rb', line 54
def at(job_id)
get(job_id, :at).to_i
end
|
.cancel(job_id, job_unix_time = nil) ⇒ Object
Also known as:
unschedule
37
38
39
|
# File 'lib/sidekiq-status.rb', line 37
def cancel(job_id, job_unix_time = nil)
delete_and_unschedule(job_id, job_unix_time)
end
|
Helper method to easily configure sidekiq-status client middleware whatever the Sidekiq version is.
63
64
65
66
67
|
# File 'lib/sidekiq-status/client_middleware.rb', line 63
def self.configure_client_middleware(sidekiq_config, client_middleware_options = {})
sidekiq_config.client_middleware do |chain|
chain.add Sidekiq::Status::ClientMiddleware, client_middleware_options
end
end
|
Helper method to easily configure sidekiq-status server middleware whatever the Sidekiq version is.
94
95
96
97
98
99
100
101
102
103
104
|
# File 'lib/sidekiq-status/server_middleware.rb', line 94
def self.configure_server_middleware(sidekiq_config, server_middleware_options = {})
sidekiq_config.server_middleware do |chain|
if Sidekiq.major_version < 5
chain.insert_after Sidekiq::Middleware::Server::Logging,
Sidekiq::Status::ServerMiddleware, server_middleware_options
else
chain.add Sidekiq::Status::ServerMiddleware, server_middleware_options
end
end
end
|
.delete(job_id) ⇒ Object
41
42
43
|
# File 'lib/sidekiq-status.rb', line 41
def delete(job_id)
delete_status(job_id)
end
|
.eta(job_id) ⇒ Object
74
75
76
77
78
79
|
# File 'lib/sidekiq-status.rb', line 74
def eta(job_id)
at = at(job_id)
return nil if at.zero?
(Time.now.to_i - working_at(job_id)).to_f / at * (total(job_id) - at)
end
|
.get(job_id, field) ⇒ String
21
22
23
|
# File 'lib/sidekiq-status.rb', line 21
def get(job_id, field)
read_field_for_id(job_id, field)
end
|
.get_all(job_id) ⇒ Hash
Get all status fields for a job
28
29
30
|
# File 'lib/sidekiq-status.rb', line 28
def get_all(job_id)
read_hash_for_id(job_id)
end
|
.message(job_id) ⇒ Object
81
82
83
|
# File 'lib/sidekiq-status.rb', line 81
def message(job_id)
get(job_id, :message)
end
|
.pct_complete(job_id) ⇒ Object
62
63
64
|
# File 'lib/sidekiq-status.rb', line 62
def pct_complete(job_id)
get(job_id, :pct_complete).to_i
end
|
.redis_adapter ⇒ Object
93
94
95
|
# File 'lib/sidekiq-status.rb', line 93
def redis_adapter
Sidekiq.redis { |conn| yield wrap_redis_connection(conn) }
end
|
.status(job_id) ⇒ Object
4
5
6
|
# File 'lib/sidekiq-status/testing/inline.rb', line 4
def status(jid)
:complete
end
|
.total(job_id) ⇒ Object
58
59
60
|
# File 'lib/sidekiq-status.rb', line 58
def total(job_id)
get(job_id, :total).to_i
end
|
.update_time(job_id) ⇒ Object
70
71
72
|
# File 'lib/sidekiq-status.rb', line 70
def update_time(job_id)
(get(job_id, :update_time) || Time.now).to_i
end
|
.working_at(job_id) ⇒ Object
66
67
68
|
# File 'lib/sidekiq-status.rb', line 66
def working_at(job_id)
(get(job_id, :working_at) || Time.now).to_i
end
|
.wrap_redis_connection(conn) ⇒ Object