generated from rollkit/template-da-repo
-
Notifications
You must be signed in to change notification settings - Fork 2
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Merge branch 'main' into latest-fixes
- Loading branch information
Showing
7 changed files
with
169 additions
and
15 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,99 @@ | ||
| package sequencing | ||
|
|
||
| import ( | ||
| "errors" | ||
|
|
||
| "github.com/go-kit/kit/metrics" | ||
| "github.com/go-kit/kit/metrics/discard" | ||
| "github.com/go-kit/kit/metrics/prometheus" | ||
| stdprometheus "github.com/prometheus/client_golang/prometheus" | ||
| ) | ||
|
|
||
| const ( | ||
| // MetricsSubsystem is a subsystem shared by all metrics exposed by this | ||
| // package. | ||
| MetricsSubsystem = "sequencer" | ||
| ) | ||
|
|
||
| // MetricsProvider returns sequencing Metrics. | ||
| type MetricsProvider func(chainID string) (*Metrics, error) | ||
|
|
||
| // DefaultMetricsProvider returns Metrics build using Prometheus client library | ||
| // if Prometheus is enabled. Otherwise, it returns no-op Metrics. | ||
| func DefaultMetricsProvider(enabled bool) MetricsProvider { | ||
| return func(chainID string) (*Metrics, error) { | ||
| if enabled { | ||
| return PrometheusMetrics("chain_id", chainID) | ||
| } | ||
| return NopMetrics() | ||
| } | ||
| } | ||
|
|
||
| // Metrics contains metrics exposed by this package. | ||
| type Metrics struct { | ||
| // GasPrice | ||
| GasPrice metrics.Gauge | ||
| // Last submitted blob size | ||
| LastBlobSize metrics.Gauge | ||
| // cost / byte | ||
| // CostPerByte metrics.Gauge | ||
| // Wallet Balance | ||
| // WalletBalance metrics.Gauge | ||
| // Transaction Status | ||
| TransactionStatus metrics.Counter | ||
| // Number of pending blocks. | ||
| NumPendingBlocks metrics.Gauge | ||
| // Last included block height | ||
| IncludedBlockHeight metrics.Gauge | ||
| } | ||
|
|
||
| // PrometheusMetrics returns Metrics build using Prometheus client library. | ||
| // Optionally, labels can be provided along with their values ("foo", | ||
| // "fooValue"). | ||
| func PrometheusMetrics(labelsAndValues ...string) (*Metrics, error) { | ||
| if len(labelsAndValues)%2 != 0 { | ||
| return nil, errors.New("uneven number of labels and values; labels and values should be provided in pairs") | ||
| } | ||
| labels := []string{} | ||
| for i := 0; i < len(labelsAndValues); i += 2 { | ||
| labels = append(labels, labelsAndValues[i]) | ||
| } | ||
| return &Metrics{ | ||
| GasPrice: prometheus.NewGaugeFrom(stdprometheus.GaugeOpts{ | ||
| Subsystem: MetricsSubsystem, | ||
| Name: "gas_price", | ||
| Help: "The gas price of DA.", | ||
| }, labels).With(labelsAndValues...), | ||
| LastBlobSize: prometheus.NewGaugeFrom(stdprometheus.GaugeOpts{ | ||
| Subsystem: MetricsSubsystem, | ||
| Name: "last_blob_size", | ||
| Help: "The size in bytes of the last DA blob.", | ||
| }, labels).With(labelsAndValues...), | ||
| TransactionStatus: prometheus.NewCounterFrom(stdprometheus.CounterOpts{ | ||
| Subsystem: MetricsSubsystem, | ||
| Name: "transaction_status", | ||
| Help: "Count of transaction statuses for DA submissions", | ||
| }, labels).With(labelsAndValues...), | ||
| NumPendingBlocks: prometheus.NewGaugeFrom(stdprometheus.GaugeOpts{ | ||
| Subsystem: MetricsSubsystem, | ||
| Name: "num_pending_blocks", | ||
| Help: "The number of pending blocks for DA submission.", | ||
| }, labels).With(labelsAndValues...), | ||
| IncludedBlockHeight: prometheus.NewGaugeFrom(stdprometheus.GaugeOpts{ | ||
| Subsystem: MetricsSubsystem, | ||
| Name: "included_block_height", | ||
| Help: "The last DA included block height.", | ||
| }, labels).With(labelsAndValues...), | ||
| }, nil | ||
| } | ||
|
|
||
| // NopMetrics returns no-op Metrics. | ||
| func NopMetrics() (*Metrics, error) { | ||
| return &Metrics{ | ||
| GasPrice: discard.NewGauge(), | ||
| LastBlobSize: discard.NewGauge(), | ||
| TransactionStatus: discard.NewCounter(), | ||
| NumPendingBlocks: discard.NewGauge(), | ||
| IncludedBlockHeight: discard.NewGauge(), | ||
| }, nil | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters