Renamespace the fedmsg module.
This commit is contained in:
parent
cd9ecb0e8b
commit
edbc9b21cf
56 changed files with 40 additions and 40 deletions
136
roles/fedmsg/base/templates/endpoints.py.j2
Normal file
136
roles/fedmsg/base/templates/endpoints.py.j2
Normal file
|
@ -0,0 +1,136 @@
|
|||
{% if env == 'staging' %}
|
||||
suffix = 'stg.phx2.fedoraproject.org'
|
||||
non_phx_suffix = 'stg.fedoraproject.org'
|
||||
{% else %}
|
||||
suffix = 'phx2.fedoraproject.org'
|
||||
non_phx_suffix = 'fedoraproject.org'
|
||||
vpn_suffix = 'vpn.fedoraproject.org'
|
||||
{% endif %}
|
||||
|
||||
|
||||
config = dict(
|
||||
# This is a dict of possible addresses from which fedmsg can send
|
||||
# messages. fedmsg.init(...) requires that a 'name' argument be passed
|
||||
# to it which corresponds with one of the keys in this dict.
|
||||
endpoints = {
|
||||
# For message producers, fedmsg will try to guess the
|
||||
# name of it's calling module to determine which endpoint definition
|
||||
# to use. This can be overridden by explicitly providing the name in
|
||||
# the initial call to fedmsg.init(...).
|
||||
"bodhi.app01": [
|
||||
"tcp://app01.%s:300%i" % (suffix, i)
|
||||
for i in range(8)
|
||||
],
|
||||
"bodhi.app02": [
|
||||
"tcp://app02.%s:300%i" % (suffix, i)
|
||||
for i in range(8)
|
||||
],
|
||||
"bodhi.releng01": [
|
||||
"tcp://releng01.%s:3000" % suffix,
|
||||
"tcp://releng01.%s:3001" % suffix,
|
||||
],
|
||||
"bodhi.releng02": [
|
||||
"tcp://releng02.%s:3000" % suffix,
|
||||
"tcp://releng02.%s:3001" % suffix,
|
||||
],
|
||||
"bodhi.bodhi01": [
|
||||
"tcp://bodhi01.%s:300%i" % (suffix, i)
|
||||
for i in range(8)
|
||||
],
|
||||
"bodhi.bodhi02": [
|
||||
"tcp://bodhi02.%s:300%i" % (suffix, i)
|
||||
for i in range(8)
|
||||
],
|
||||
{% if not env == 'staging' %}
|
||||
"bodhi.app03": [
|
||||
"tcp://app03.%s:300%i" % (suffix, i)
|
||||
for i in range(8)
|
||||
],
|
||||
"bodhi.app04": [
|
||||
"tcp://app04.%s:300%i" % (suffix, i)
|
||||
for i in range(8)
|
||||
],
|
||||
"bodhi.app05": [
|
||||
"tcp://app05.%s:300%i" % (non_phx_suffix, i)
|
||||
for i in range(8)
|
||||
],
|
||||
"bodhi.app07": [
|
||||
"tcp://app07.%s:300%i" % (suffix, i)
|
||||
for i in range(8)
|
||||
],
|
||||
"bodhi.app08": [
|
||||
"tcp://app08.%s:300%i" % (non_phx_suffix, i)
|
||||
for i in range(8)
|
||||
],
|
||||
"bodhi.releng04": [
|
||||
"tcp://releng04.%s:3000" % suffix,
|
||||
"tcp://releng04.%s:3001" % suffix,
|
||||
],
|
||||
"bodhi.relepel01": [
|
||||
"tcp://relepel01.%s:3000" % suffix,
|
||||
"tcp://relepel01.%s:3001" % suffix,
|
||||
],
|
||||
{% endif %}
|
||||
# FAS is a little out of the ordinary. It has 40 endpoints instead of
|
||||
# the usual 8 since there are so many mod_wsgi processes for it.
|
||||
"fas.fas01": [
|
||||
"tcp://fas01.%s:30%02i" % (suffix, i)
|
||||
for i in range(40)
|
||||
],
|
||||
{% if env != 'staging' %}
|
||||
"fas.fas02": [
|
||||
"tcp://fas02.%s:30%02i" % (suffix, i)
|
||||
for i in range(40)
|
||||
],
|
||||
"fas.fas03": [
|
||||
"tcp://fas03.%s:30%02i" % (suffix, i)
|
||||
for i in range(40)
|
||||
],
|
||||
{% endif %}
|
||||
# TODO -- these are the old tagger endpoints that should eventually be
|
||||
# removed.
|
||||
"fedoratagger.packages01": [
|
||||
"tcp://packages01.%s:30%02i" % (suffix, i)
|
||||
for i in range(32)
|
||||
],
|
||||
{% if env != 'staging' %}
|
||||
"fedoratagger.packages02": [
|
||||
"tcp://packages02.%s:30%02i" % (suffix, i)
|
||||
for i in range(32)
|
||||
],
|
||||
{% endif %}
|
||||
# These are the new endpoints, on the new tagger01,2 nodes.
|
||||
# fedoratagger needs 32 endpoints too, just like FAS.
|
||||
"fedoratagger.tagger01": [
|
||||
"tcp://tagger01.%s:30%02i" % (suffix, i)
|
||||
for i in range(32)
|
||||
],
|
||||
{% if env != 'staging' %}
|
||||
"fedoratagger.tagger02": [
|
||||
"tcp://tagger02.%s:30%02i" % (suffix, i)
|
||||
for i in range(32)
|
||||
],
|
||||
{% endif %}
|
||||
"busmon_consumers.busgateway01": [
|
||||
"tcp://busgateway01.%s:3000" % suffix,
|
||||
],
|
||||
{% if env != 'staging' %}
|
||||
"supybot.value03": [
|
||||
"tcp://value03.%s:3000" % suffix,
|
||||
],
|
||||
{% endif %}
|
||||
# Askbot runs as 6 processes with 1 thread each.
|
||||
"askbot.ask01": [
|
||||
"tcp://ask01.%s:30%02i" % (suffix, i)
|
||||
for i in range(6)
|
||||
],
|
||||
|
||||
# Askbot runs as 6 processes with 1 thread each.
|
||||
"askbot.ask02": [
|
||||
"tcp://ask02.%s:30%02i" % (suffix, i)
|
||||
for i in range(6)
|
||||
],
|
||||
|
||||
# koji is not listed here since it publishes to the fedmsg-relay
|
||||
},
|
||||
)
|
Loading…
Add table
Add a link
Reference in a new issue