Nucypher
/
nucypher
mirror of https://github.com/nucypher/nucypher.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

Update outdated event names and function parameter

pull/2069/head
derekpierre 2020-06-03 13:46:11 -04:00
parent 89911a87ab
commit 4281761ffc
2 changed files with 6 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
nucypher/cli/commands/ursula.py
View File

@ -377,7 +377,8 @@ def run(general_config, character_options, config_file, interactive, dry_run, me
prometheus_config = None prometheus_config = None
if prometheus: if prometheus:
prometheus_config = PrometheusMetricsConfig(port=metrics_port, metrics_prefix=metrics_prefix, prometheus_config = PrometheusMetricsConfig(port=metrics_port,
metrics_prefix=metrics_prefix,
listen_address=metrics_listen_address) listen_address=metrics_listen_address)
return URSULA.run(emitter=emitter, return URSULA.run(emitter=emitter,

8
nucypher/utilities/prometheus.py
View File

@ -238,7 +238,7 @@ def collect_prometheus_metrics(ursula,
node_metrics["current_period_gauge"].set(staking_agent.get_current_period()) node_metrics["current_period_gauge"].set(staking_agent.get_current_period())
missing_commitments = staking_agent.get_missing_commitments(staker_address=ursula.checksum_address) # TODO: lol missing_commitments = staking_agent.get_missing_commitments(checksum_address=ursula.checksum_address) # TODO: lol
node_metrics["missing_commitments_gauge"].set(missing_commitments) node_metrics["missing_commitments_gauge"].set(missing_commitments)
decentralized_payload = {'provider': str(ursula.provider_uri), decentralized_payload = {'provider': str(ursula.provider_uri),
@ -260,7 +260,7 @@ def get_staking_event_collectors_config(ursula, metrics_prefix: str) -> Tuple:
"collector": BaseEventMetricsCollector, "collector": BaseEventMetricsCollector,
"name": "activity_confirmed", "name": "activity_confirmed",
"contract_agent": staking_agent, "contract_agent": staking_agent,
"event": "ActivityConfirmed", "event": "CommitmentMade",
"argument_filters": {"staker": ursula.checksum_address}, "argument_filters": {"staker": ursula.checksum_address},
"metrics": {"value": Gauge(f'{metrics_prefix}_activity_confirmed_value', "metrics": {"value": Gauge(f'{metrics_prefix}_activity_confirmed_value',
'Activity confirmed with value of locked tokens'), 'Activity confirmed with value of locked tokens'),
@ -271,7 +271,7 @@ def get_staking_event_collectors_config(ursula, metrics_prefix: str) -> Tuple:
"collector": BaseEventMetricsCollector, "collector": BaseEventMetricsCollector,
"name": "mined", "name": "mined",
"contract_agent": staking_agent, "contract_agent": staking_agent,
"event": "Mined", "event": "Minted",
"argument_filters": {"staker": ursula.checksum_address}, "argument_filters": {"staker": ursula.checksum_address},
"metrics": {"value": Gauge(f'{metrics_prefix}_mined_value', 'Mined value'), "metrics": {"value": Gauge(f'{metrics_prefix}_mined_value', 'Mined value'),
"period": Gauge(f'{metrics_prefix}_mined_period', 'Mined period'), "period": Gauge(f'{metrics_prefix}_mined_period', 'Mined period'),
@ -307,7 +307,7 @@ def get_staking_event_collectors_config(ursula, metrics_prefix: str) -> Tuple:
"collector": WorkerSetEventMetricsCollector, "collector": WorkerSetEventMetricsCollector,
"name": "worker_set", "name": "worker_set",
"contract_agent": staking_agent, "contract_agent": staking_agent,
"event": "WorkerSet", "event": "WorkerBonded",
"argument_filters": {"staker": ursula.checksum_address}, "argument_filters": {"staker": ursula.checksum_address},
"metrics": {"startPeriod": Gauge(f'{metrics_prefix}_worker_set_start_period', 'New worker was set'), "metrics": {"startPeriod": Gauge(f'{metrics_prefix}_worker_set_start_period', 'New worker was set'),
"block_number": Gauge(f'{metrics_prefix}_worker_set_block_number', 'WorkerSet block number')} "block_number": Gauge(f'{metrics_prefix}_worker_set_block_number', 'WorkerSet block number')}