metrics

Documentation

Index

• Constants
• type Metricer
• type Metrics
  • func NewMetrics() *Metrics
  • func (m *Metrics) DecActiveExecutors()
  • func (m *Metrics) DecIdleExecutors()
  • func (m *Metrics) Document() []opmetrics.DocumentedMetric
  • func (m *Metrics) IncActiveExecutors()
  • func (m *Metrics) IncIdleExecutors()
  • func (m *Metrics) RecordCannonExecutionTime(t float64)
  • func (m *Metrics) RecordGameMove()
  • func (m *Metrics) RecordGameStep()
  • func (m *Metrics) RecordGameUpdateCompleted()
  • func (m *Metrics) RecordGameUpdateScheduled()
  • func (m *Metrics) RecordGamesStatus(inProgress, defenderWon, challengerWon int)
  • func (m *Metrics) RecordInfo(version string)
  • func (m *Metrics) RecordUp()
  • func (m *Metrics) Start(host string, port int) (*httputil.HTTPServer, error)
  • func (m *Metrics) StartBalanceMetrics(ctx context.Context, l log.Logger, client *ethclient.Client, ...)
• type NoopMetricsImpl
  • func (*NoopMetricsImpl) DecActiveExecutors()
  • func (*NoopMetricsImpl) DecIdleExecutors()
  • func (*NoopMetricsImpl) IncActiveExecutors()
  • func (*NoopMetricsImpl) IncIdleExecutors()
  • func (*NoopMetricsImpl) RecordCannonExecutionTime(t float64)
  • func (*NoopMetricsImpl) RecordGameMove()
  • func (*NoopMetricsImpl) RecordGameStep()
  • func (*NoopMetricsImpl) RecordGameUpdateCompleted()
  • func (*NoopMetricsImpl) RecordGameUpdateScheduled()
  • func (*NoopMetricsImpl) RecordGamesStatus(inProgress, defenderWon, challengerWon int)
  • func (*NoopMetricsImpl) RecordInfo(version string)
  • func (*NoopMetricsImpl) RecordUp()

Constants

const Namespace = "op_challenger"

Types

type Metricer

type Metricer interface {
	RecordInfo(version string)
	RecordUp()

	// Record Tx metrics
	txmetrics.TxMetricer

	RecordGameStep()
	RecordGameMove()
	RecordCannonExecutionTime(t float64)

	RecordGamesStatus(inProgress, defenderWon, challengerWon int)

	RecordGameUpdateScheduled()
	RecordGameUpdateCompleted()

	IncActiveExecutors()
	DecActiveExecutors()
	IncIdleExecutors()
	DecIdleExecutors()
}

var NoopMetrics Metricer = new(NoopMetricsImpl)

type Metrics

type Metrics struct {
	txmetrics.TxMetrics
	// contains filtered or unexported fields
}

func NewMetrics

func NewMetrics() *Metrics

func (*Metrics) DecActiveExecutors

func (m *Metrics) DecActiveExecutors()

func (*Metrics) DecIdleExecutors

func (m *Metrics) DecIdleExecutors()

func (*Metrics) Document

func (m *Metrics) Document() []opmetrics.DocumentedMetric

func (*Metrics) IncActiveExecutors

func (m *Metrics) IncActiveExecutors()

func (*Metrics) IncIdleExecutors

func (m *Metrics) IncIdleExecutors()

func (*Metrics) RecordCannonExecutionTime

func (m *Metrics) RecordCannonExecutionTime(t float64)

func (*Metrics) RecordGameMove

func (m *Metrics) RecordGameMove()

func (*Metrics) RecordGameStep

func (m *Metrics) RecordGameStep()

func (*Metrics) RecordGameUpdateCompleted

func (m *Metrics) RecordGameUpdateCompleted()

func (*Metrics) RecordGameUpdateScheduled

func (m *Metrics) RecordGameUpdateScheduled()

func (*Metrics) RecordGamesStatus

func (m *Metrics) RecordGamesStatus(inProgress, defenderWon, challengerWon int)

func (*Metrics) RecordInfo

func (m *Metrics) RecordInfo(version string)

RecordInfo sets a pseudo-metric that contains versioning and config info for the bl-proposer.

func (*Metrics) RecordUp

func (m *Metrics) RecordUp()

RecordUp sets the up metric to 1.

func (*Metrics) Start

func (m *Metrics) Start(host string, port int) (*httputil.HTTPServer, error)

func (*Metrics) StartBalanceMetrics

func (m *Metrics) StartBalanceMetrics(
	ctx context.Context,
	l log.Logger,
	client *ethclient.Client,
	account common.Address,
)

type NoopMetricsImpl

type NoopMetricsImpl struct {
	txmetrics.NoopTxMetrics
}

func (*NoopMetricsImpl) DecActiveExecutors

func (*NoopMetricsImpl) DecActiveExecutors()

func (*NoopMetricsImpl) DecIdleExecutors

func (*NoopMetricsImpl) DecIdleExecutors()

func (*NoopMetricsImpl) IncActiveExecutors

func (*NoopMetricsImpl) IncActiveExecutors()

func (*NoopMetricsImpl) IncIdleExecutors

func (*NoopMetricsImpl) IncIdleExecutors()

func (*NoopMetricsImpl) RecordCannonExecutionTime

func (*NoopMetricsImpl) RecordCannonExecutionTime(t float64)

func (*NoopMetricsImpl) RecordGameMove

func (*NoopMetricsImpl) RecordGameMove()

func (*NoopMetricsImpl) RecordGameStep

func (*NoopMetricsImpl) RecordGameStep()

func (*NoopMetricsImpl) RecordGameUpdateCompleted

func (*NoopMetricsImpl) RecordGameUpdateCompleted()

func (*NoopMetricsImpl) RecordGameUpdateScheduled

func (*NoopMetricsImpl) RecordGameUpdateScheduled()

func (*NoopMetricsImpl) RecordGamesStatus

func (*NoopMetricsImpl) RecordGamesStatus(inProgress, defenderWon, challengerWon int)

func (*NoopMetricsImpl) RecordInfo

func (*NoopMetricsImpl) RecordInfo(version string)

func (*NoopMetricsImpl) RecordUp

func (*NoopMetricsImpl) RecordUp()