Merge "Add rpc_response_timeout option"
This commit is contained in:
commit
fb0eae41e7
@ -160,8 +160,9 @@ class trove::api(
|
||||
}
|
||||
|
||||
oslo::messaging::default { 'trove_config':
|
||||
transport_url => $::trove::default_transport_url,
|
||||
control_exchange => $::trove::control_exchange
|
||||
transport_url => $::trove::default_transport_url,
|
||||
control_exchange => $::trove::control_exchange,
|
||||
rpc_response_timeout => $::trove::rpc_response_timeout,
|
||||
}
|
||||
|
||||
if $auth_strategy == 'keystone' {
|
||||
|
@ -109,8 +109,9 @@ class trove::conductor(
|
||||
}
|
||||
|
||||
oslo::messaging::default { 'trove_conductor_config':
|
||||
transport_url => $::trove::default_transport_url,
|
||||
control_exchange => $::trove::control_exchange,
|
||||
transport_url => $::trove::default_transport_url,
|
||||
control_exchange => $::trove::control_exchange,
|
||||
rpc_response_timeout => $::trove::rpc_response_timeout,
|
||||
}
|
||||
|
||||
oslo::messaging::notifications { 'trove_conductor_config':
|
||||
|
@ -143,6 +143,11 @@ and trove::guestagent::rabbit_port are deprecated. Please use \
|
||||
trove::guestagent::default_transport_url instead.")
|
||||
}
|
||||
|
||||
if $control_exchange {
|
||||
warning("control_exchange parameter is deprecated. Please use \
|
||||
trove::control_exchange instead.")
|
||||
}
|
||||
|
||||
# basic service config
|
||||
trove_guestagent_config {
|
||||
'DEFAULT/trove_auth_url': value => $auth_url;
|
||||
@ -155,8 +160,9 @@ trove::guestagent::default_transport_url instead.")
|
||||
}
|
||||
|
||||
oslo::messaging::default { 'trove_guestagent_config':
|
||||
transport_url => $default_transport_url,
|
||||
control_exchange => $::trove::control_exchange
|
||||
transport_url => $default_transport_url,
|
||||
control_exchange => $::trove::control_exchange,
|
||||
rpc_response_timeout => $::trove::rpc_response_timeout,
|
||||
}
|
||||
|
||||
# region name
|
||||
|
@ -196,6 +196,10 @@
|
||||
# (optional) Admin tenant name used to connect to nova.
|
||||
# Defaults to 'admin'
|
||||
#
|
||||
# [*rpc_response_timeout*]
|
||||
# (Optional) Seconds to wait for a response from a call.
|
||||
# Defaults to $::os_service_default
|
||||
#
|
||||
# [*control_exchange*]
|
||||
# (optional) Control exchange.
|
||||
# Defaults to 'trove'.
|
||||
@ -321,6 +325,7 @@ class trove(
|
||||
$nova_compute_url = false,
|
||||
$nova_proxy_admin_user = 'admin',
|
||||
$nova_proxy_admin_tenant_name = 'admin',
|
||||
$rpc_response_timeout = $::os_service_default,
|
||||
$control_exchange = 'trove',
|
||||
$cinder_url = false,
|
||||
$swift_url = false,
|
||||
|
@ -161,8 +161,9 @@ class trove::taskmanager(
|
||||
}
|
||||
|
||||
oslo::messaging::default { 'trove_taskmanager_config':
|
||||
transport_url => $::trove::default_transport_url,
|
||||
control_exchange => $::trove::control_exchange
|
||||
transport_url => $::trove::default_transport_url,
|
||||
control_exchange => $::trove::control_exchange,
|
||||
rpc_response_timeout => $::trove::rpc_response_timeout,
|
||||
}
|
||||
|
||||
oslo::messaging::notifications { 'trove_taskmanager_config':
|
||||
|
@ -0,0 +1,4 @@
|
||||
---
|
||||
features:
|
||||
- Add new parameter "rpc_response_timeout", seconds to wait for a
|
||||
response from a call
|
@ -79,6 +79,8 @@ describe 'trove::api' do
|
||||
is_expected.to contain_trove_config('DEFAULT/http_delete_rate').with_value('200')
|
||||
is_expected.to contain_trove_config('DEFAULT/http_mgmt_post_rate').with_value('200')
|
||||
is_expected.to contain_trove_config('DEFAULT/transport_url').with_value('<SERVICE DEFAULT>')
|
||||
is_expected.to contain_trove_config('DEFAULT/rpc_response_timeout').with_value('<SERVICE DEFAULT>')
|
||||
is_expected.to contain_trove_config('DEFAULT/control_exchange').with_value('trove')
|
||||
is_expected.to contain_trove_config('oslo_messaging_notifications/transport_url').with_value('<SERVICE DEFAULT>')
|
||||
is_expected.to contain_trove_config('oslo_messaging_notifications/driver').with_value('<SERVICE DEFAULT>')
|
||||
is_expected.to contain_trove_config('oslo_messaging_notifications/topics').with_value('<SERVICE DEFAULT>')
|
||||
@ -226,7 +228,7 @@ describe 'trove::api' do
|
||||
let :pre_condition do
|
||||
"class { 'trove':
|
||||
nova_proxy_admin_pass => 'verysecrete',
|
||||
rabbit_use_ssl => false}
|
||||
rabbit_use_ssl => false}
|
||||
class { '::trove::keystone::authtoken':
|
||||
password => 'a_big_secret',
|
||||
}"
|
||||
@ -244,8 +246,10 @@ describe 'trove::api' do
|
||||
context 'with transport_url entries' do
|
||||
let :pre_condition do
|
||||
"class { 'trove':
|
||||
nova_proxy_admin_pass => 'verysecrete',
|
||||
default_transport_url => 'rabbit://rabbit_user:password@localhost:5673',
|
||||
nova_proxy_admin_pass => 'verysecrete',
|
||||
default_transport_url => 'rabbit://rabbit_user:password@localhost:5673',
|
||||
rpc_response_timeout => '120',
|
||||
control_exchange => 'openstack',
|
||||
notification_transport_url => 'rabbit://rabbit_user:password@localhost:5673' }
|
||||
class { '::trove::keystone::authtoken':
|
||||
password => 'a_big_secret',
|
||||
@ -254,6 +258,8 @@ describe 'trove::api' do
|
||||
|
||||
it do
|
||||
is_expected.to contain_trove_config('DEFAULT/transport_url').with_value('rabbit://rabbit_user:password@localhost:5673')
|
||||
is_expected.to contain_trove_config('DEFAULT/rpc_response_timeout').with_value('120')
|
||||
is_expected.to contain_trove_config('DEFAULT/control_exchange').with_value('openstack')
|
||||
is_expected.to contain_trove_config('oslo_messaging_notifications/transport_url').with_value('rabbit://rabbit_user:password@localhost:5673')
|
||||
end
|
||||
end
|
||||
|
@ -35,6 +35,8 @@ describe 'trove::conductor' do
|
||||
is_expected.to contain_trove_conductor_config('DEFAULT/nova_proxy_admin_pass').with_value('verysecrete')
|
||||
is_expected.to contain_trove_conductor_config('DEFAULT/nova_proxy_admin_tenant_name').with_value('admin')
|
||||
is_expected.to contain_trove_conductor_config('DEFAULT/transport_url').with_value('<SERVICE DEFAULT>')
|
||||
is_expected.to contain_trove_conductor_config('DEFAULT/rpc_response_timeout').with_value('<SERVICE DEFAULT>')
|
||||
is_expected.to contain_trove_conductor_config('DEFAULT/control_exchange').with_value('trove')
|
||||
is_expected.to contain_trove_conductor_config('oslo_messaging_notifications/transport_url').with_value('<SERVICE DEFAULT>')
|
||||
is_expected.to contain_trove_conductor_config('oslo_messaging_rabbit/rabbit_userid').with_value('<SERVICE DEFAULT>')
|
||||
is_expected.to contain_trove_conductor_config('oslo_messaging_rabbit/rabbit_password').with_value('<SERVICE DEFAULT>')
|
||||
@ -122,7 +124,7 @@ describe 'trove::conductor' do
|
||||
let :pre_condition do
|
||||
"class { 'trove':
|
||||
nova_proxy_admin_pass => 'verysecrete',
|
||||
rabbit_use_ssl => true}"
|
||||
rabbit_use_ssl => true}"
|
||||
end
|
||||
|
||||
it do
|
||||
@ -138,7 +140,7 @@ describe 'trove::conductor' do
|
||||
let :pre_condition do
|
||||
"class { 'trove':
|
||||
nova_proxy_admin_pass => 'verysecrete',
|
||||
rabbit_use_ssl => false}"
|
||||
rabbit_use_ssl => false}"
|
||||
end
|
||||
|
||||
it do
|
||||
@ -153,13 +155,17 @@ describe 'trove::conductor' do
|
||||
context 'with transport_url entries' do
|
||||
let :pre_condition do
|
||||
"class { 'trove':
|
||||
nova_proxy_admin_pass => 'verysecrete',
|
||||
default_transport_url => 'rabbit://rabbit_user:password@localhost:5673',
|
||||
nova_proxy_admin_pass => 'verysecrete',
|
||||
default_transport_url => 'rabbit://rabbit_user:password@localhost:5673',
|
||||
rpc_response_timeout => '120',
|
||||
control_exchange => 'openstack',
|
||||
notification_transport_url => 'rabbit://rabbit_user:password@localhost:5673' }"
|
||||
end
|
||||
|
||||
it do
|
||||
is_expected.to contain_trove_conductor_config('DEFAULT/transport_url').with_value('rabbit://rabbit_user:password@localhost:5673')
|
||||
is_expected.to contain_trove_conductor_config('DEFAULT/rpc_response_timeout').with_value('120')
|
||||
is_expected.to contain_trove_conductor_config('DEFAULT/control_exchange').with_value('openstack')
|
||||
is_expected.to contain_trove_conductor_config('oslo_messaging_notifications/transport_url').with_value('rabbit://rabbit_user:password@localhost:5673')
|
||||
end
|
||||
end
|
||||
@ -168,7 +174,7 @@ describe 'trove::conductor' do
|
||||
let :pre_condition do
|
||||
"class { 'trove' :
|
||||
nova_proxy_admin_pass => 'verysecrete',
|
||||
rpc_backend => 'amqp' }"
|
||||
rpc_backend => 'amqp' }"
|
||||
end
|
||||
|
||||
it do
|
||||
|
@ -35,6 +35,8 @@ describe 'trove::guestagent' do
|
||||
is_expected.to contain_trove_guestagent_config('DEFAULT/os_region_name').with_value('RegionOne')
|
||||
is_expected.to contain_trove_guestagent_config('DEFAULT/control_exchange').with_value('trove')
|
||||
is_expected.to contain_trove_guestagent_config('DEFAULT/transport_url').with_value('<SERVICE DEFAULT>')
|
||||
is_expected.to contain_trove_guestagent_config('DEFAULT/rpc_response_timeout').with_value('<SERVICE DEFAULT>')
|
||||
is_expected.to contain_trove_guestagent_config('DEFAULT/control_exchange').with_value('trove')
|
||||
is_expected.to contain_trove_guestagent_config('oslo_messaging_notifications/transport_url').with_value('<SERVICE DEFAULT>')
|
||||
is_expected.to contain_trove_guestagent_config('oslo_messaging_notifications/driver').with_value('<SERVICE DEFAULT>')
|
||||
is_expected.to contain_trove_guestagent_config('oslo_messaging_notifications/topics').with_value('<SERVICE DEFAULT>')
|
||||
@ -99,10 +101,14 @@ describe 'trove::guestagent' do
|
||||
let :pre_condition do
|
||||
"class { 'trove':
|
||||
nova_proxy_admin_pass => 'verysecrete',
|
||||
default_transport_url => 'rabbit://user:pass@host:1234/virt',}"
|
||||
default_transport_url => 'rabbit://user:pass@host:1234/virt',
|
||||
rpc_response_timeout => '120',
|
||||
control_exchange => 'openstack',}"
|
||||
end
|
||||
it 'configures trove-guestagent with DEFAULT/transport_url' do
|
||||
is_expected.to contain_trove_guestagent_config('DEFAULT/transport_url').with_value('rabbit://user:pass@host:1234/virt')
|
||||
is_expected.to contain_trove_guestagent_config('DEFAULT/rpc_response_timeout').with_value('120')
|
||||
is_expected.to contain_trove_guestagent_config('DEFAULT/control_exchange').with_value('openstack')
|
||||
end
|
||||
end
|
||||
|
||||
@ -115,12 +121,12 @@ describe 'trove::guestagent' do
|
||||
end
|
||||
|
||||
let :params do
|
||||
{ :auth_url => "http://10.0.0.1:5000/v2.0",
|
||||
:swift_url => "http://10.0.0.1:8080/v1/AUTH_",
|
||||
{ :auth_url => "http://10.0.0.1:5000/v2.0",
|
||||
:swift_url => "http://10.0.0.1:8080/v1/AUTH_",
|
||||
:swift_service_type => 'object-store',
|
||||
:rabbit_host => '10.1.0.1',
|
||||
:rabbit_port => '5673',
|
||||
:rabbit_use_ssl => 'true'
|
||||
:rabbit_host => '10.1.0.1',
|
||||
:rabbit_port => '5673',
|
||||
:rabbit_use_ssl => 'true'
|
||||
}
|
||||
end
|
||||
it 'configures trove-guestagent with custom parameters' do
|
||||
@ -157,7 +163,7 @@ describe 'trove::guestagent' do
|
||||
let :pre_condition do
|
||||
"class { 'trove':
|
||||
nova_proxy_admin_pass => 'verysecrete',
|
||||
rabbit_use_ssl => true}"
|
||||
rabbit_use_ssl => true}"
|
||||
end
|
||||
|
||||
it do
|
||||
@ -173,7 +179,7 @@ describe 'trove::guestagent' do
|
||||
let :pre_condition do
|
||||
"class { 'trove':
|
||||
nova_proxy_admin_pass => 'verysecrete',
|
||||
rabbit_use_ssl => false}"
|
||||
rabbit_use_ssl => false}"
|
||||
end
|
||||
|
||||
it do
|
||||
@ -188,13 +194,17 @@ describe 'trove::guestagent' do
|
||||
context 'with transport_url entries' do
|
||||
let :pre_condition do
|
||||
"class { 'trove':
|
||||
nova_proxy_admin_pass => 'verysecrete',
|
||||
default_transport_url => 'rabbit://rabbit_user:password@localhost:5673',
|
||||
nova_proxy_admin_pass => 'verysecrete',
|
||||
default_transport_url => 'rabbit://rabbit_user:password@localhost:5673',
|
||||
rpc_response_timeout => '60',
|
||||
control_exchange => 'exchange',
|
||||
notification_transport_url => 'rabbit://rabbit_user:password@localhost:5673' }"
|
||||
end
|
||||
|
||||
it do
|
||||
is_expected.to contain_trove_guestagent_config('DEFAULT/transport_url').with_value('rabbit://rabbit_user:password@localhost:5673')
|
||||
is_expected.to contain_trove_guestagent_config('DEFAULT/rpc_response_timeout').with_value('60')
|
||||
is_expected.to contain_trove_guestagent_config('DEFAULT/control_exchange').with_value('exchange')
|
||||
is_expected.to contain_trove_guestagent_config('oslo_messaging_notifications/transport_url').with_value('rabbit://rabbit_user:password@localhost:5673')
|
||||
end
|
||||
end
|
||||
|
@ -71,6 +71,8 @@ describe 'trove::taskmanager' do
|
||||
is_expected.to contain_trove_taskmanager_config('DEFAULT/taskmanager_manager').with_value('trove.taskmanager.manager.Manager')
|
||||
is_expected.to contain_file('/etc/trove/trove-guestagent.conf')
|
||||
is_expected.to contain_trove_taskmanager_config('DEFAULT/transport_url').with_value('<SERVICE DEFAULT>')
|
||||
is_expected.to contain_trove_taskmanager_config('DEFAULT/rpc_response_timeout').with_value('<SERVICE DEFAULT>')
|
||||
is_expected.to contain_trove_taskmanager_config('DEFAULT/control_exchange').with_value('trove')
|
||||
is_expected.to contain_trove_taskmanager_config('oslo_messaging_notifications/transport_url').with_value('<SERVICE DEFAULT>')
|
||||
is_expected.to contain_trove_taskmanager_config('oslo_messaging_notifications/driver').with_value('<SERVICE DEFAULT>')
|
||||
is_expected.to contain_trove_taskmanager_config('oslo_messaging_notifications/topics').with_value('<SERVICE DEFAULT>')
|
||||
@ -232,7 +234,7 @@ describe 'trove::taskmanager' do
|
||||
let :pre_condition do
|
||||
"class { 'trove':
|
||||
nova_proxy_admin_pass => 'verysecrete',
|
||||
rabbit_use_ssl => true}"
|
||||
rabbit_use_ssl => true}"
|
||||
end
|
||||
|
||||
it do
|
||||
@ -248,7 +250,7 @@ describe 'trove::taskmanager' do
|
||||
let :pre_condition do
|
||||
"class { 'trove':
|
||||
nova_proxy_admin_pass => 'verysecrete',
|
||||
rabbit_use_ssl => false}"
|
||||
rabbit_use_ssl => false}"
|
||||
end
|
||||
|
||||
it do
|
||||
@ -263,13 +265,17 @@ describe 'trove::taskmanager' do
|
||||
context 'with transport_url entries' do
|
||||
let :pre_condition do
|
||||
"class { 'trove':
|
||||
nova_proxy_admin_pass => 'verysecrete',
|
||||
default_transport_url => 'rabbit://rabbit_user:password@localhost:5673',
|
||||
nova_proxy_admin_pass => 'verysecrete',
|
||||
default_transport_url => 'rabbit://rabbit_user:password@localhost:5673',
|
||||
rpc_response_timeout => '120',
|
||||
control_exchange => 'openstack',
|
||||
notification_transport_url => 'rabbit://rabbit_user:password@localhost:5673' }"
|
||||
end
|
||||
|
||||
it do
|
||||
is_expected.to contain_trove_taskmanager_config('DEFAULT/transport_url').with_value('rabbit://rabbit_user:password@localhost:5673')
|
||||
is_expected.to contain_trove_taskmanager_config('DEFAULT/rpc_response_timeout').with_value('120')
|
||||
is_expected.to contain_trove_taskmanager_config('DEFAULT/control_exchange').with_value('openstack')
|
||||
is_expected.to contain_trove_taskmanager_config('oslo_messaging_notifications/transport_url').with_value('rabbit://rabbit_user:password@localhost:5673')
|
||||
end
|
||||
end
|
||||
@ -278,7 +284,7 @@ describe 'trove::taskmanager' do
|
||||
let :pre_condition do
|
||||
"class { 'trove' :
|
||||
nova_proxy_admin_pass => 'verysecrete',
|
||||
rpc_backend => 'amqp' }"
|
||||
rpc_backend => 'amqp' }"
|
||||
end
|
||||
|
||||
it do
|
||||
|
Loading…
Reference in New Issue
Block a user