Page MenuHomeSoftware Heritage
Differential D2417

docker/compose: add rabbitmq_exporter service
ClosedPublic
Actions

Authored by douardda on Dec 9 2019, 4:26 PM.

Details

Reviewers
anlambert
Group Reviewers
Reviewers
Commits
rDENV22cb6ffb25c4: docker/compose: add rabbitmq_exporter service
Summary

to report rabbitmq stats in prometheus.

Depends on D2416.

Diff Detail

Repository
rDENV Development environment
Branch
master
Lint
Lint Skipped
Unit
Unit Tests Skipped
Build Status
Buildable 9619
Build 14163: arc lint + arc unit

Revision Contents
Changeset List

PathSize
docker/
conf/
5 lines
8 lines

Diff 8535

View Options

docker/conf/prometheus.yml

Show All 32 Linesclass KafkaJournalWriter:
def send(self, topic, key, value): def send(self, topic, key, value):
self.producer.produce( self.producer.produce(
topic=topic, topic=topic,
key=key_to_kafka(key), key=key_to_kafka(key),
value=value_to_kafka(value), value=value_to_kafka(value),
) )
def flush(self):
self.producer.flush()
# Need to service the callbacks regularly by calling poll # Need to service the callbacks regularly by calling poll
self.producer.poll(0) self.producer.poll(0)
def flush(self):
self.producer.flush()
def _get_key(self, object_type, object_): def _get_key(self, object_type, object_):
if object_type in ('revision', 'release', 'directory', 'snapshot'): if object_type in ('revision', 'release', 'directory', 'snapshot'):
return object_['id'] return object_['id']
elif object_type == 'content': elif object_type == 'content':
return object_['sha1'] # TODO: use a dict of hashes return object_['sha1'] # TODO: use a dict of hashes
elif object_type == 'skipped_content': elif object_type == 'skipped_content':
return { return {
hash: object_[hash] hash: object_[hash]
▲ Show 20 Lines • Show All 44 Lines • Show Last 20 Lines
View Options

docker/docker-compose.yml

Show All 32 Linesclass KafkaJournalWriter:
def send(self, topic, key, value): def send(self, topic, key, value):
self.producer.produce( self.producer.produce(
topic=topic, topic=topic,
key=key_to_kafka(key), key=key_to_kafka(key),
value=value_to_kafka(value), value=value_to_kafka(value),
) )
def flush(self):
self.producer.flush()
# Need to service the callbacks regularly by calling poll # Need to service the callbacks regularly by calling poll
self.producer.poll(0) self.producer.poll(0)
def flush(self):
self.producer.flush()
def _get_key(self, object_type, object_): def _get_key(self, object_type, object_):
if object_type in ('revision', 'release', 'directory', 'snapshot'): if object_type in ('revision', 'release', 'directory', 'snapshot'):
return object_['id'] return object_['id']
elif object_type == 'content': elif object_type == 'content':
return object_['sha1'] # TODO: use a dict of hashes return object_['sha1'] # TODO: use a dict of hashes
elif object_type == 'skipped_content': elif object_type == 'skipped_content':
return { return {
hash: object_[hash] hash: object_[hash]
▲ Show 20 Lines • Show All 44 Lines • Show Last 20 Lines
About · Developer information · Legal