reporter

Documentation

Index

• func BrokersStats(stats, tags []string, statJSON, statsType string)
• func ConsumptionDelay(t time.Duration)
• func GenerateReport()
• func GetStats(stats, tags []string, statsJSON, level, statType string)
• func GetValueFromJq(parseStr, statJSON string) ([]byte, error)
• func Setup(sr storeReporter, maxNLatency int, cfg config.Reporter, ...)
• func TopLevelStats(stats, tags []string, statJSON, statsType 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(tags LibrdTags) LibrdKafkaStatsHandler
  • func (stats LibrdKafkaStatsHandler) HandleStats(statJSON string)
• type LibrdTags
• type Messages
• type Report
  • func (r *Report) String() string
• type Time

Functions

func BrokersStats

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

func ConsumptionDelay

func ConsumptionDelay(t time.Duration)

func GenerateReport

func GenerateReport()

func GetStats

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

func GetValueFromJq

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

func Setup

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

func TopLevelStats

func TopLevelStats(stats, tags []string, statJSON, statsType 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(tags LibrdTags) LibrdKafkaStatsHandler

func (LibrdKafkaStatsHandler) HandleStats

func (stats LibrdKafkaStatsHandler) HandleStats(statJSON string)

type LibrdTags

type LibrdTags struct {
	ClusterName string
	Ack         string
	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
}