Add define oslo::messaging_rabbit

Code Issues Proposed changes

This patch aims to add a new define to manage parameters in
[oslo_messaging_rabbit] which belongs to oslo.messaging.

This commit is contained in:

Xingchao Yu

2016年01月22日 01:19:43 +08:00

parent 11c109f092

commit b86091eb6f

1 changed files with 171 additions and 0 deletions

Show all changes Ignore whitespace when comparing lines Ignore changes in amount of whitespace Ignore changes in whitespace at EOL

Download Patch File Download Diff File Expand all files Collapse all files

171
manifests/messaging_rabbit.pp Normal file

View File

@@ -0,0 +1,171 @@

#==Define:oslo::messaging_rabbit

#

#Configureoslo_messaging_rabbitoptions

#

#ThisresourceconfiguresOslomessagingresourcesforanOpenStackservice.

#Itwillmanagethe[oslo_messaging_rabbit]sectioninthegivenconfigresource.

#

#===Parameters:

#

#[*kombu_ssl_version*]

#(Optional)SSLversiontouse(validonlyifSSLenabled).'

#ValidvaluesareTLSv1andSSLv23.

#SSLv2,SSLv3,TLSv1_1,andTLSv1_2maybeavailableonsomedistributions.

#Defaultstoundef.

#

#[*kombu_ssl_keyfile*]

#(Optional)SSLkeyfile(validonlyifSSLenabled)

#Defaultstoundef.

#

#[*kombu_ssl_certfile*]

#(Optional)SSLcertfile(validonlyifSSLenabled)

#Defaultstoundef.

#

#[*kombu_ssl_ca_certs*]

#(Optional)SSLcertificationauthorityfile(validonlyifSSLenabled)

#Defaultstoundef.

#

#[*kombu_reconnect_delay*]

#(Optional)HowlongtowaitbeforereconnectinginresponsetoanAMQPconsumercancelnotification.

#Defaultsto'1'.

#

#[*kombu_missing_consumer_retry_timeout*]

#(Optional)Howlongtowaitamissingclientbeforceabandoningto

#sendititsreplies.Thisvalueshouldnotbelongerthanrpc_response_timeout.

#Defaultsto'60'.

#

#[*kombu_failover_strategy*]

#(Optional)DetermineshowthenextRabbitMQnodeischosenincase

#theonewearecurrentlyconnectedtobecomesunavailable.

#TakeseffectonlyifmorethanoneRabbitMQnodeisprovidedinconfig.

#Defaultsto'round-robin'.

#

#[*rabbit_host*]

#(Optional)TheRabbitMQbrokeraddresswhereasinglenodeisused.

#Defaultsto'localhost'.

#

#[*rabbit_port*]

#(Optional)TheRabbitMQbrokerportwhereasinglenodeisused.

#Defaultsto'5672'.

#

#[*rabbit_hosts*]

#(Optional)RabbitMQHAclusterhost:portpairs.

#Defaultsto['localhost:5672'].

#

#[*rabbit_use_ssl*]

#(Optional)ConnectoverSSLforRabbitMQ.

#Defaultstofalse.

#

#[*rabbit_userid*]

#(Optional)TheRabbitMQuserid.

#Defaultsto'guest'.

#

#[*rabbit_password*]

#(Optional)TheRabbitMQpassword.

#Defaultstoundef.

#

#[*rabbit_login_method*]

#(Optional)TheRabbitMQloginmethod.

#Defaultsto'AMQPLAIN'.

#

#[*rabbit_virtual_host*]

#(Optional)TheRabbitMQvirtualhost.

#Defaultsto'/'.

#

#[*rabbit_retry_interval*]

#(Optional)HowfrequentlytoretryconnectingwithRabbitMQ.

#Defaultsto1.

#

#[*rabbit_retry_backoff*]

#(Optional)HowlongtobackoffforbetweenretrieswhenconnectingtoRabbitMQ.

#Defaultsto2.

#

#[*rabbit_interval_max*]

#(Optional)MaximumintervalofRabbitMQconnectionretries.

#Defaultsto30.

#

#[*rabbit_max_retries*]

#(Optional)MaximumnumberofRabbitMQconnectionretries.

#Defaultsto0.

#

#[*rabbit_ha_queues*]

#(Optional)UseHAqueuesinRabbitMQ(x-ha-policy:all).

#Ifyouchangethisoption,youmustwipetheRabbitMQdatabase.

#Defaultstofalse.

#

#[*rabbit_transient_queues_ttl*]

#(Optional)Positiveintegerrepresentingdurationinsecondsfor

#queueTTL(x-expires).Queueswhichareunusedfortheduration

#oftheTTLareautomaticallydeleted.

#Theparameteraffectsonlyreplyandfanoutqueues.

#Minto1

#Defaultsto600.

#

#[*heartbeat_timeout_threshold*]

#(Optional)NumberofsecondsafterwhichtheRabbitbrokeris

#considereddownifheartbeat'skeep-alivefails

#(0disabletheheartbeat).EXPERIMENTAL")

#Defaultsto60.

#

#[*heartbeat_rate*]

#(Optional)Howoftentimesduringtheheartbeat_timeout_threshold

#wechecktheheartbeat.

#Defaultsto2.

#

#DEPRECATED:

#[*fake_rabbit*]

defineoslo::messaging_rabbit(

$kombu_ssl_version=undef,

$kombu_ssl_keyfile=undef,

$kombu_ssl_certfile=undef,

$kombu_ssl_ca_certs=undef,

$kombu_reconnect_delay='1',

$kombu_missing_consumer_retry_timeout='60',

$kombu_failover_strategy='round-robin',

$rabbit_host='localhost',

$rabbit_port='5672',

$rabbit_hosts='localhost:5672',

$rabbit_use_ssl=false,

$rabbit_userid='guest',

$rabbit_password=undef,

$rabbit_login_method='AMQPLAIN',

$rabbit_virtual_host='/',

$rabbit_retry_interval='1',

$rabbit_retry_backoff='2',

$rabbit_interval_max='30',

$rabbit_max_retries='0',

$rabbit_ha_queues=false,

$rabbit_transient_queues_ttl='600',

$heartbeat_timeout_threshold='60',

$heartbeat_rate='2',

$fake_rabbit=undef,

){

create_resources($name, {'oslo_messaging_rabbit/kombu_ssl_version' => { value => $kombu_ssl_version }})

create_resources($name,{'oslo_messaging_rabbit/kombu_ssl_keyfile' => { value => $kombu_ssl_keyfile }})

create_resources($name,{'oslo_messaging_rabbit/kombu_ssl_certfile' => { value => $kombu_ssl_certfile }})

create_resources($name,{'oslo_messaging_rabbit/kombu_ssl_ca_certs' => { value => $kombu_ssl_ca_certs }})

create_resources($name,{'oslo_messaging_rabbit/kombu_reconnect_delay' => { value => $kombu_reconnect_delay }})

create_resources($name,{'oslo_messaging_rabbit/kombu_missing_consumer_retry_timeout' => { value => $kombu_missing_consumer_retry_timeout }})

create_resources($name,{'oslo_messaging_rabbit/kombu_failover_strategy' => { value => $kombu_failover_strategy }})

create_resources($name,{'oslo_messaging_rabbit/rabbit_host' => { value => $rabbit_host }})

create_resources($name,{'oslo_messaging_rabbit/rabbit_port' => { value => $rabbit_port }})

create_resources($name,{'oslo_messaging_rabbit/rabbit_hosts' => { value => $rabbit_hosts }})

create_resources($name,{'oslo_messaging_rabbit/rabbit_use_ssl' => { value => $rabbit_use_ssl }})

create_resources($name,{'oslo_messaging_rabbit/rabbit_userid' => { value => $rabbit_userid }})

create_resources($name,{'oslo_messaging_rabbit/rabbit_password' => { value => $rabbit_password }})

create_resources($name,{'oslo_messaging_rabbit/rabbit_login_method' => { value => $rabbit_login_method }})

create_resources($name,{'oslo_messaging_rabbit/rabbit_virtual_host' => { value => $rabbit_virtual_host }})

create_resources($name,{'oslo_messaging_rabbit/rabbit_retry_interval' => { value => $rabbit_retry_interval }})

create_resources($name,{'oslo_messaging_rabbit/rabbit_retry_backoff' => { value => $rabbit_retry_backoff }})

create_resources($name,{'oslo_messaging_rabbit/rabbit_interval_max' => { value => $rabbit_interval_max }})

create_resources($name,{'oslo_messaging_rabbit/rabbit_max_retries' => { value => $rabbit_max_retries }})

create_resources($name,{'oslo_messaging_rabbit/rabbit_ha_queues' => { value => $rabbit_ha_queues }})

create_resources($name,{'oslo_messaging_rabbit/rabbit_transient_queues_ttl' => { value => $rabbit_transient_queues_ttl }})

create_resources($name,{'oslo_messaging_rabbit/heartbeat_timeout_threshold' => { value => $heartbeat_timeout_threshold }})

create_resources($name,{'oslo_messaging_rabbit/heartbeat_rate' => { value => $heartbeat_rate }})

if$fake_rabbit{

warning('fake_rabbit is depracted, please use use rpc_backend=kombu+memory or rpc_backend=fake')

create_resources($name, {'oslo_messaging_rabbit/fake_rabbit' => { value => $fake_rabbit }})

}

Add define oslo::messaging_rabbit

171 manifests/messaging_rabbit.pp Normal file Unescape Escape View File

171
manifests/messaging_rabbit.pp Normal file

View File