reporter

Documentation

Index

• func BrokersStats(stats []string, statJSON, statsType, topic string)
• func ConsumptionDelay(t time.Duration)
• func GenerateReport()
• func GetStats(stats []string, statsJSON, level, statType, topic string)
• func GetValueFromJq(parseStr, statJSON string) ([]byte, error)
• func Setup(sr storeReporter, maxNLatency int, cfg config.Reporter)
• func TopLevelStats(stats []string, statJSON, statsType, topic string)
• type Latency
  • func NewLatencyReporter(topN int) *Latency
  • func (l *Latency) Len() int
  • func (l *Latency) Less(i, j int) bool
  • func (l *Latency) Max() uint32
  • func (l *Latency) Min() uint32
  • func (l *Latency) Pop() uint32
  • func (l *Latency) Push(lt uint32)
  • func (l *Latency) Swap(i, j int)
• type LibrdKafkaStatsHandler
  • func NewlibrdKafkaStat() LibrdKafkaStatsHandler
  • func (stats LibrdKafkaStatsHandler) HandleStats(statJSON, topic string)
• type Messages
• type Report
  • func (r *Report) String() string
• type Time

Functions

func BrokersStats

func BrokersStats(stats []string, statJSON, statsType, topic string)

func ConsumptionDelay

func ConsumptionDelay(t time.Duration)

func GenerateReport

func GenerateReport()

func GetStats

func GetStats(stats []string, statsJSON, level, statType, topic string)

func GetValueFromJq

func GetValueFromJq(parseStr, statJSON string) ([]byte, error)

func Setup

func Setup(sr storeReporter, maxNLatency int, cfg config.Reporter)

func TopLevelStats

func TopLevelStats(stats []string, statJSON, statsType, topic string)

Types

type Latency

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

func NewLatencyReporter

func NewLatencyReporter(topN int) *Latency

func (*Latency) Len

func (l *Latency) Len() int

func (*Latency) Less

func (l *Latency) Less(i, j int) bool

func (*Latency) Max

func (l *Latency) Max() uint32

func (*Latency) Min

func (l *Latency) Min() uint32

func (*Latency) Pop

func (l *Latency) Pop() uint32

func (*Latency) Push

func (l *Latency) Push(lt uint32)

func (*Latency) Swap

func (l *Latency) Swap(i, j int)

type LibrdKafkaStatsHandler

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

func NewlibrdKafkaStat

func NewlibrdKafkaStat() LibrdKafkaStatsHandler

func (LibrdKafkaStatsHandler) HandleStats

func (stats LibrdKafkaStatsHandler) HandleStats(statJSON, topic string)

type Messages

type Messages struct {
	Lost     int64
	Sent     int64
	Received int64
}

type Report

type Report struct {
	Messages
	Time
}

func (*Report) String

func (r *Report) String() string

type Time

type Time struct {
	MinConsumption uint32
	MaxConsumption uint32
	AppRun         time.Duration
}