statistics

Documentation

Index

• type Statistics
  • func NewStatistics(log logr.Logger) (*Statistics, error)
  • func (s *Statistics) AddDatabaseMetrics(bundle bundle.Bundle, duration time.Duration, err error)
  • func (s *Statistics) IncrementNumberOfConflations(bundle bundle.Bundle)
  • func (s *Statistics) IncrementNumberOfReceivedBundles(bundle bundle.Bundle)
  • func (s *Statistics) SetConflationReadyQueueSize(size int)
  • func (s *Statistics) SetNumberOfAvailableDBWorkers(numOf int)
  • func (s *Statistics) Start(ctx context.Context) error
  • func (s *Statistics) StartConflationUnitMetrics(bundle bundle.Bundle)
  • func (s *Statistics) StopConflationUnitMetrics(bundle bundle.Bundle)

Types

type Statistics

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

Statistics aggregates different statistics.

func NewStatistics

func NewStatistics(log logr.Logger) (*Statistics, error)

NewStatistics creates a new instance of Statistics.

func (*Statistics) AddDatabaseMetrics

func (s *Statistics) AddDatabaseMetrics(bundle bundle.Bundle, duration time.Duration, err error)

AddDatabaseMetrics adds database metrics of the specific bundle type.

func (*Statistics) IncrementNumberOfConflations

func (s *Statistics) IncrementNumberOfConflations(bundle bundle.Bundle)

IncrementNumberOfConflations increments number of conflations of the specific bundle type.

func (*Statistics) IncrementNumberOfReceivedBundles

func (s *Statistics) IncrementNumberOfReceivedBundles(bundle bundle.Bundle)

IncrementNumberOfReceivedBundles increments total number of received bundles of the specific type via transport.

func (*Statistics) SetConflationReadyQueueSize

func (s *Statistics) SetConflationReadyQueueSize(size int)

SetConflationReadyQueueSize sets conflation ready queue size.

func (*Statistics) SetNumberOfAvailableDBWorkers

func (s *Statistics) SetNumberOfAvailableDBWorkers(numOf int)

SetNumberOfAvailableDBWorkers sets number of available db workers.

func (*Statistics) Start

func (s *Statistics) Start(ctx context.Context) error

Start starts the statistics.

func (*Statistics) StartConflationUnitMetrics

func (s *Statistics) StartConflationUnitMetrics(bundle bundle.Bundle)

StartConflationUnitMetrics starts conflation unit metrics of the specific bundle type.

func (*Statistics) StopConflationUnitMetrics

func (s *Statistics) StopConflationUnitMetrics(bundle bundle.Bundle)

StopConflationUnitMetrics stops conflation unit metrics of the specific bundle type.