Skip to content

Commit

Permalink
Remove Pausable Queues functionality (#9)
Browse files Browse the repository at this point in the history
  • Loading branch information
holstvoogd authored Jul 19, 2022
1 parent f82d980 commit 4294acd
Show file tree
Hide file tree
Showing 19 changed files with 1 addition and 1,365 deletions.
34 changes: 0 additions & 34 deletions README.md
Original file line number Diff line number Diff line change
Expand Up @@ -205,40 +205,6 @@ lock TTL to fit your needs:
sidekiq_throttle(:concurrency => { :limit => 20, :ttl => 1.hour.to_i })
```


## Enhanced Queues list

This gem provides ability to pause/resume queues from processing by workers.
So you may simply pause particular queue without need to stop and reconfigure
workers by simply pushing a button on sidekiq web UI.

By default we add *Enhanced Queues* tab with this functionality. But if you
want you can override default *Queues* tab completely (notice that page will
still be available using it's URL, but tab will be pointing enhanced version).
To do so, just call `Sidekiq::Throttled::Web.enhance_queues_tab!` somewhere
in your initializer/bootstrap code. If you are using rails, you might want to
add it right into your `config/routes.rb` file:

``` ruby
# file config/routes.rb

require "sidekiq/web"
require "sidekiq/throttled/web"

Rails.application.routes.draw do
# ...

# Replace Sidekiq Queues with enhanced version!
Sidekiq::Throttled::Web.enhance_queues_tab!

# Mount Sidekiq Web UI to `/sidekiq` endpoint
mount Sidekiq::Web => "/sidekiq"

# ...
end
```


## Supported Ruby Versions

This library aims to support and is [tested against][ci] the following Ruby
Expand Down
5 changes: 0 additions & 5 deletions lib/sidekiq/throttled.rb
Original file line number Diff line number Diff line change
Expand Up @@ -5,9 +5,7 @@

# internal
require "sidekiq/throttled/version"
require "sidekiq/throttled/communicator"
require "sidekiq/throttled/configuration"
require "sidekiq/throttled/queues_pauser"
require "sidekiq/throttled/registry"
require "sidekiq/throttled/job"
require "sidekiq/throttled/worker"
Expand Down Expand Up @@ -58,9 +56,6 @@ def configuration
#
# @return [void]
def setup!
Communicator.instance.setup!
QueuesPauser.instance.setup!

Sidekiq.configure_server do |config|
setup_strategy!(config)

Expand Down
116 changes: 0 additions & 116 deletions lib/sidekiq/throttled/communicator.rb

This file was deleted.

72 changes: 0 additions & 72 deletions lib/sidekiq/throttled/communicator/callbacks.rb

This file was deleted.

25 changes: 0 additions & 25 deletions lib/sidekiq/throttled/communicator/exception_handler.rb

This file was deleted.

109 changes: 0 additions & 109 deletions lib/sidekiq/throttled/communicator/listener.rb

This file was deleted.

Loading

0 comments on commit 4294acd

Please sign in to comment.