OpenCloud
/
MatrixSynapse
mirror of https://github.com/matrix-org/synapse
1
0
Fork 0
Code Issues Releases Wiki Activity

Merge pull request #841 from matrix-org/erikj/event_counter 

Add metric counter for number of persisted events
pull/839/merge
Erik Johnston 2016-06-06 14:17:40 +01:00
parent 778c1fea8b 7aa778fba9
commit e4134c5e13
1 changed files with 9 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
synapse/storage/events.py
View File

@ -27,6 +27,9 @@ from synapse.api.constants import EventTypes
from canonicaljson import encode_canonical_json from canonicaljson import encode_canonical_json
from collections import deque, namedtuple from collections import deque, namedtuple
import synapse
import synapse.metrics
import logging import logging
import math import math
@ -35,6 +38,10 @@ import ujson as json
logger = logging.getLogger(__name__) logger = logging.getLogger(__name__)
metrics = synapse.metrics.get_metrics_for(__name__)
persist_event_counter = metrics.register_counter("persisted_events")
def encode_json(json_object): def encode_json(json_object):
if USE_FROZEN_DICTS: if USE_FROZEN_DICTS:
# ujson doesn't like frozen_dicts # ujson doesn't like frozen_dicts
@ -261,6 +268,7 @@ class EventsStore(SQLBaseStore):
events_and_contexts=chunk, events_and_contexts=chunk,
backfilled=backfilled, backfilled=backfilled,
) )
persist_event_counter.inc_by(len(chunk))
@defer.inlineCallbacks @defer.inlineCallbacks
@log_function @log_function
@ -278,6 +286,7 @@ class EventsStore(SQLBaseStore):
current_state=current_state, current_state=current_state,
backfilled=backfilled, backfilled=backfilled,
) )
persist_event_counter.inc()
except _RollbackButIsFineException: except _RollbackButIsFineException:
pass pass