prometheus

Documentation

Index

• type Parameter
  • func WithAddress(address string) Parameter
  • func WithLogLevel(logLevel zerolog.Level) Parameter
• type Service
  • func New(ctx context.Context, params ...Parameter) (*Service, error)
  • func (s *Service) Accounts(state string, count uint64)
  • func (s *Service) AttestationAggregationCompleted(started time.Time, result string)
  • func (s *Service) AttestationAggregationCoverage(frac float64)
  • func (s *Service) AttestationCompleted(started time.Time, result string)
  • func (s *Service) BeaconBlockProposalCompleted(started time.Time, result string)
  • func (s *Service) BeaconCommitteeAggregators(aggregators int)
  • func (s *Service) BeaconCommitteeSubscribers(subscribers int)
  • func (s *Service) BeaconCommitteeSubscriptionCompleted(started time.Time, result string)
  • func (s *Service) BlockDelay(delay time.Duration)
  • func (s *Service) ClientOperation(provider string, operation string, succeeded bool, duration time.Duration)
  • func (s *Service) JobCancelled()
  • func (s *Service) JobScheduled()
  • func (s *Service) JobStartedOnSignal()
  • func (s *Service) JobStartedOnTimer()
  • func (s *Service) NewEpoch()

Types

type Parameter

type Parameter interface {
	// contains filtered or unexported methods
}

Parameter is the interface for service parameters.

func WithAddress

func WithAddress(address string) Parameter

WithAddress sets the address.

func WithLogLevel

func WithLogLevel(logLevel zerolog.Level) Parameter

WithLogLevel sets the log level for the module.

type Service

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

Service is a metrics service exposing metrics via prometheus.

func New

func New(ctx context.Context, params ...Parameter) (*Service, error)

New creates a new prometheus metrics service.

func (*Service) Accounts

func (s *Service) Accounts(state string, count uint64)

Accounts sets the number of accounts in a given state.

func (*Service) AttestationAggregationCompleted

func (s *Service) AttestationAggregationCompleted(started time.Time, result string)

AttestationAggregationCompleted is called when an attestation aggregationprocess has completed.

func (*Service) AttestationAggregationCoverage

func (s *Service) AttestationAggregationCoverage(frac float64)

AttestationAggregationCoverage measures the attestation ratio of the attestation aggregation.

func (*Service) AttestationCompleted

func (s *Service) AttestationCompleted(started time.Time, result string)

AttestationCompleted is called when a block attestation process has completed.

func (*Service) BeaconBlockProposalCompleted

func (s *Service) BeaconBlockProposalCompleted(started time.Time, result string)

BeaconBlockProposalCompleted is called when a block proposal process has completed.

func (*Service) BeaconCommitteeAggregators

func (s *Service) BeaconCommitteeAggregators(aggregators int)

BeaconCommitteeAggregators sets the number of beacon committees for which our validators are aggregating.

func (*Service) BeaconCommitteeSubscribers

func (s *Service) BeaconCommitteeSubscribers(subscribers int)

BeaconCommitteeSubscribers sets the number of beacon committees to which our validators are subscribed.

func (*Service) BeaconCommitteeSubscriptionCompleted

func (s *Service) BeaconCommitteeSubscriptionCompleted(started time.Time, result string)

BeaconCommitteeSubscriptionCompleted is called when an beacon committee subscription process has completed.

func (*Service) BlockDelay

func (s *Service) BlockDelay(delay time.Duration)

BlockDelay provides the delay between the start of a slot and vouch receiving its block.

func (*Service) ClientOperation

func (s *Service) ClientOperation(provider string, operation string, succeeded bool, duration time.Duration)

ClientOperation registers an operation.

func (*Service) JobCancelled

func (s *Service) JobCancelled()

JobCancelled is called when a scheduled job is cancelled.

func (*Service) JobScheduled

func (s *Service) JobScheduled()

JobScheduled is called when a job is scheduled.

func (*Service) JobStartedOnSignal

func (s *Service) JobStartedOnSignal()

JobStartedOnSignal is called when a scheduled job is started due to being manually signalled.

func (*Service) JobStartedOnTimer

func (s *Service) JobStartedOnTimer()

JobStartedOnTimer is called when a scheduled job is started due to meeting its time.

func (*Service) NewEpoch

func (s *Service) NewEpoch()

NewEpoch is called when vouch starts processing a new epoch.