fedmsg config changes for tagger on new nodes.

This commit is contained in:
Ralph Bean 2014-03-07 21:38:41 +00:00
parent 2cc6cb4bc4
commit d853ff6f60
3 changed files with 33 additions and 1 deletions

View file

@ -86,7 +86,8 @@ config = dict(
for i in range(40)
],
{% endif %}
# Well, fedoratagger needs 32 endpoints too, just like FAS.
# 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)
@ -96,6 +97,18 @@ config = dict(
"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,

View file

@ -172,6 +172,17 @@ config = dict(
],
# Tagger messages
topic_prefix + "fedoratagger.tag.update": [
"fedoratagger-tagger0%i.%s" % (i, suffix) for i in range(1, 3)
],
topic_prefix + "fedoratagger.tag.create": [
"fedoratagger-tagger0%i.%s" % (i, suffix) for i in range(1, 3)
],
topic_prefix + "fedoratagger.user.rank.update": [
"fedoratagger-tagger0%i.%s" % (i, suffix) for i in range(1, 3)
],
# TODO -- delete these once we retired tagger off of packages01,2
topic_prefix + "fedoratagger.tag.update": [
"fedoratagger-packages0%i.%s" % (i, suffix) for i in range(1, 3)
],

View file

@ -54,8 +54,16 @@ config = dict(
("shell.packages0%i" % i, "shell-packages0%i.%s" % (i, suffix))
for i in range(1, 3)
] + [
# TODO -- this one can be delete eventually once we retired tagger off
# of packages01,2
("fedoratagger.packages0%i" % i, "fedoratagger-packages0%i.%s" % (i, suffix))
for i in range(1, 3)
] + [
("fedoratagger.tagger0%i" % i, "fedoratagger-tagger0%i.%s" % (i, suffix))
for i in range(1, 3)
] + [
("shell.tagger0%i" % i, "shell-tagger0%i.%s" % (i, suffix))
for i in range(1, 3)
] + [
("shell.pkgs0%i" % i, "shell-pkgs0%i.%s" % (i, suffix))
for i in range(1, 2)