metrics

Documentation

Index

• func EmitCurrentBlock(contractAddress string, block int)
• func EmitGetLogsDuration(contractAddress string, duration time.Duration)
• func EmitNumLogsFound(contractAddress string, numLogs int)
• func MeasureGetLogs[Return any](contractAddress string, fn func() (Return, error)) (Return, error)
• type Server
  • func NewMetricsServer(ctx context.Context, address string, port int, log *zap.Logger, ...) (*Server, error)
  • func (s *Server) Close() error

Functions

func EmitCurrentBlock

func EmitCurrentBlock(contractAddress string, block int)

func EmitGetLogsDuration

func EmitGetLogsDuration(contractAddress string, duration time.Duration)

func EmitNumLogsFound

func EmitNumLogsFound(contractAddress string, numLogs int)

func MeasureGetLogs

func MeasureGetLogs[Return any](contractAddress string, fn func() (Return, error)) (Return, error)

Types

type Server

type Server struct {
	// contains filtered or unexported fields
}

func NewMetricsServer

func NewMetricsServer(
	ctx context.Context,
	address string,
	port int,
	log *zap.Logger,
	reg *prometheus.Registry,
) (*Server, error)

func (*Server) Close

func (s *Server) Close() error