Skip to content

Commit d862a43

Browse files
Add database primary replica configuration for sidekiqs
1 parent c3c2b99 commit d862a43

File tree

2 files changed

+10
-2
lines changed

2 files changed

+10
-2
lines changed

libraries/drivers_worker_sidekiq.rb

Lines changed: 7 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -133,6 +133,11 @@ def add_replica_config
133133
Chef::Log.info('Rewrite Sidekiq database.yml for read-replica')
134134

135135
deploy = node['deploy'][app['shortname']]
136+
database = deploy['database']
137+
replica_database = deploy['sidekiq_on_replica']&.dup
138+
replica_database = database.dup if replica_database.nil?
139+
replica_database[:replica] = true
140+
136141
Chef::Log.info(deploy.inspect)
137142
context.template "#{deploy_dir(app)}/shared/config/database.yml" do
138143
source 'sidekiq_database.yml.erb'
@@ -141,9 +146,9 @@ def add_replica_config
141146
group node['deployer']['group']
142147
owner node['deployer']['user']
143148
variables(
144-
database: deploy['database'],
149+
database: database,
145150
environment: deploy['global']['environment'],
146-
sidekiq_on_replica: deploy['sidekiq_on_replica']
151+
sidekiq_on_replica: replica_database,
147152
)
148153
end
149154
end

sidekiq_custom/templates/default/sidekiq_database.yml.erb

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -24,5 +24,8 @@
2424
<%- if @sidekiq_on_replica[:port] -%>
2525
port: <%= @sidekiq_on_replica[:port].to_i.inspect %>
2626
<%- end -%>
27+
<%- if @sidekiq_on_replica[:replica] -%>
28+
replica: true
29+
<%- end -%>
2730
<% end -%>
2831
<%- end -%>

0 commit comments

Comments
 (0)