class Capistrano::Karafka

Karafka Capistrano integration

Constants

CAP_FILES

Names of files that store capistrano procedures

Public Instance Methods

register_hooks() click to toggle source

Deploy hooks registration

# File lib/capistrano/karafka.rb, line 30
def register_hooks
  after 'deploy:finished', 'karafka:restart'
end
set_defaults() click to toggle source

Default values for Karafka settings

# File lib/capistrano/karafka.rb, line 20
def set_defaults
  set_if_empty :karafka_role, :karafka
  set_if_empty :karafka_processes, 1
  set_if_empty :karafka_consumer_groups, []
  set_if_empty :karafka_default_hooks, -> { true }
  set_if_empty :karafka_env, -> { fetch(:karafka_env, fetch(:environment)) }
  set_if_empty :karafka_pid, -> { File.join(shared_path, 'tmp', 'pids', 'karafka.pid') }
end