stats

Documentation

Index

• func CompareRecordSizeStats(withCompression map[string]*RecordSizeStats, ...)
• type ProducerStats
  • func NewProducerStats() *ProducerStats
  • func (s *ProducerStats) GetAndReset() ProducerStats
  • func (s *ProducerStats) RecordSizeStats() map[string]*RecordSizeStats
  • func (s *ProducerStats) Reset()
  • func (s *ProducerStats) Show(indent string)
• type RecordBuilderStats
  • func (s *RecordBuilderStats) RecordSizeStats() map[string]*RecordSizeStats
  • func (s *RecordBuilderStats) Reset()
  • func (s *RecordBuilderStats) Show(indent string)
• type RecordSizeStats

Functions

func CompareRecordSizeStats

func CompareRecordSizeStats(withCompression map[string]*RecordSizeStats, withNoCompression map[string]*RecordSizeStats)

CompareRecordSizeStats compares the record size stats with and without compression and prints the results to the console.

Types

type ProducerStats

type ProducerStats struct {
	MetricsBatchesProduced uint64
	LogsBatchesProduced    uint64
	TracesBatchesProduced  uint64
	StreamProducersCreated uint64
	StreamProducersClosed  uint64
	RecordBuilderStats     RecordBuilderStats

	// SchemaStats is a flag that indicates whether to display schema stats.
	SchemaStats bool
	// SchemaUpdates is a flag that indicates whether to display schema updates.
	SchemaUpdates bool
	// RecordStats is a flag that indicates whether to display record stats.
	RecordStats bool
	// ProducerStats is a flag that indicates whether to display producer stats.
	ProducerStats bool
	// CompressionRatioStats is a flag that indicates whether to display compression ratio stats.
	CompressionRatioStats bool
	// DumpRecordRows specifies the number of rows to dump for each record.
	// If not defined or set to 0, no rows are dumped.
	DumpRecordRows map[string]int
}

ProducerStats is a struct that contains stats about the OTLP Arrow Producer.

func NewProducerStats

func NewProducerStats() *ProducerStats

NewProducerStats creates a new ProducerStats struct.

func (*ProducerStats) GetAndReset

func (s *ProducerStats) GetAndReset() ProducerStats

GetAndReset returns the current stats and resets them to zero.

func (*ProducerStats) RecordSizeStats

func (s *ProducerStats) RecordSizeStats() map[string]*RecordSizeStats

RecordSizeStats returns statistics per record payload type.

func (*ProducerStats) Reset

func (s *ProducerStats) Reset()

Reset sets all stats to zero.

func (*ProducerStats) Show

func (s *ProducerStats) Show(indent string)

Show prints the stats to the console.

type RecordBuilderStats

type RecordBuilderStats struct {
	SchemaUpdatesPerformed     uint64
	DictionaryIndexTypeChanged uint64
	DictionaryOverflowDetected uint64
	RecordSizeDistribution     map[string]*RecordSizeStats
}

func (*RecordBuilderStats) RecordSizeStats

func (s *RecordBuilderStats) RecordSizeStats() map[string]*RecordSizeStats

RecordSizeStats returns statistics per record payload type.

func (*RecordBuilderStats) Reset

func (s *RecordBuilderStats) Reset()

Reset sets all stats to zero.

func (*RecordBuilderStats) Show

func (s *RecordBuilderStats) Show(indent string)

Show prints the RecordBuilder stats to the console.

type RecordSizeStats

type RecordSizeStats struct {
	TotalSize int64
	Dist      *hdrhistogram.Histogram
}