logos-storage/logos-storage-network-crawler
1
0
Fork 0
mirror of https://github.com/logos-storage/logos-storage-network-crawler.git synced 2026-01-07 16:03:08 +00:00
Code Issues Packages Projects Releases Wiki Activity

Turns on chainmetrics components. Tested with local node. it works!

Browse Source
This commit is contained in:
thatben 2025-03-18 18:22:31 +01:00
parent 6a8a6c252f
commit eaeddb5a28
No known key found for this signature in database
GPG Key ID: 62C543548433D43E
2 changed files with 4 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
codexcrawler/components/chainmetrics.nim
View File

@ -9,7 +9,7 @@ import ../services/marketplace
import ../component import ../component
logScope: logScope:
topics = "ChainMetrics" topics = "chainmetrics"
type ChainMetrics* = ref object of Component type ChainMetrics* = ref object of Component
state: State state: State

3
codexcrawler/installer.nim
View File

@ -14,6 +14,7 @@ import ./components/timetracker
import ./components/nodestore import ./components/nodestore
import ./components/dhtmetrics import ./components/dhtmetrics
import ./components/todolist import ./components/todolist
import ./components/chainmetrics
proc createComponents*(state: State): Future[?!seq[Component]] {.async.} = proc createComponents*(state: State): Future[?!seq[Component]] {.async.} =
var components: seq[Component] = newSeq[Component]() var components: seq[Component] = newSeq[Component]()
@ -29,6 +30,7 @@ proc createComponents*(state: State): Future[?!seq[Component]] {.async.} =
metrics = createMetrics(state.config.metricsAddress, state.config.metricsPort) metrics = createMetrics(state.config.metricsAddress, state.config.metricsPort)
todoList = createTodoList(state, metrics) todoList = createTodoList(state, metrics)
marketplace = createMarketplace(state) marketplace = createMarketplace(state)
chainMetrics = ChainMetrics.new(state, metrics, marketplace)
without dhtMetrics =? createDhtMetrics(state, metrics), err: without dhtMetrics =? createDhtMetrics(state, metrics), err:
return failure(err) return failure(err)
@ -40,5 +42,6 @@ proc createComponents*(state: State): Future[?!seq[Component]] {.async.} =
components.add(TimeTracker.new(state, nodeStore, dht, clock)) components.add(TimeTracker.new(state, nodeStore, dht, clock))
components.add(dhtMetrics) components.add(dhtMetrics)
components.add(marketplace) components.add(marketplace)
components.add(chainMetrics)
return success(components) return success(components)