sinker

var BlockCount = metrics.NewCounter("substreams_sink_kv_block_count", "The number of blocks received")

var DataMessageCount = metrics.NewCounterVec("substreams_sink_kv_data_message", []string{"module"}, "The number of data message received")

var FlushCount = metrics.NewCounter("substreams_sink_kv_store_flush_count", "The amount of flush that happened so far")

var FlushDuration = metrics.NewCounter("substreams_sink_kv_store_flush_duration", "The amount of time spent flushing cache to db")

var FlushedEntriesCount = metrics.NewCounter("substreams_sink_kv_flushed_entries_count", "The number of flushed entries")

var ProgressMessageCount = metrics.NewCounterVec("substreams_sink_kv_progress_message", []string{"module"}, "The number of progress message received")

var SubstreamsErrorCount = metrics.NewCounter("substreams_sink_kv_error", "The error count we encountered when interacting with Substreams for which we had to restart the connection loop")