telemetry

Documentation

Index

• func PrometheusMetrics(ctx context.Context, logger tmlog.Logger, registerer prometheus.Registerer, ...) (func() error, error)
• func Start(ctx context.Context, logger tmlog.Logger, serviceName string, ...) (*prometheus.Registry, func() error, error)
• type Config
• type OrchestratorMeters
  • func InitOrchestratorMeters() (*OrchestratorMeters, error)
• type RelayerMeters
  • func InitRelayerMeters() (*RelayerMeters, error)

Functions

func PrometheusMetrics

func PrometheusMetrics(ctx context.Context, logger tmlog.Logger, registerer prometheus.Registerer, listenAddress string) (func() error, error)

PrometheusMetrics sets up native libp2p metrics up

func Start

func Start(
	ctx context.Context,
	logger tmlog.Logger,
	serviceName string,
	instanceID string,
	opts []otlpmetrichttp.Option,
) (*prometheus.Registry, func() error, error)

Types

type Config

type Config struct {
	Metrics     bool   `mapstructure:"metrics" json:"metrics"`
	Endpoint    string `mapstructure:"endpoint" json:"endpoint"`
	TLS         bool   `mapstructure:"tls" json:"tls"`
	P2PEndpoint string `mapstructure:"p2p-endpoint" json:"p2p-endpoint"`
}

Config defines the configuration options for blobstream telemetry.

type OrchestratorMeters

type OrchestratorMeters struct {
	ProcessedNonces   metric.Int64Counter
	FailedNonces      metric.Int64Counter
	ReprocessedNonces metric.Int64Counter
	ProcessingTime    metric.Float64Histogram
}

func InitOrchestratorMeters

func InitOrchestratorMeters() (*OrchestratorMeters, error)

type RelayerMeters

type RelayerMeters struct {
	ProcessedNonces metric.Int64Counter
	Failures        metric.Int64Counter
	ProcessingTime  metric.Float64Histogram
}

func InitRelayerMeters

func InitRelayerMeters() (*RelayerMeters, error)