kafkaperf

Documentation

Index

• Constants
• type CSVEncodedData
  • func NewCSVEncodedData(rawMetricsData RawMetricsData) CSVEncodedData
• type Encoder
  • func NewEncoder(source io.Reader, encoderConfig EncoderConfig) Encoder
• type EncoderConfig
• type LatencyMetrics
• type Metrics
• type MetricsCalculator
  • func NewMetricsCalculator() MetricsCalculator
• type Monitor
  • func NewMonitor(destination io.Writer, appConfig MonitorConfig) (Monitor, error)
• type MonitorConfig
• type MonitorMetrics
• type RawMetricsData
  • func (rawMetricsData RawMetricsData) Latency() time.Duration
• type Reporter
  • func NewReporter(reportConfig ReporterConfig, encoder Encoder, ...) Reporter
• type ReporterConfig
• type ReporterStats

Constants

const (
	TLS_MODE_NONE = "NONE"
	TLS_MODE_TLS  = "TLS"
	TLS_MODE_MTLS = "MTLS"
)

const (
	DefaultChannelBufferSize = 10000
)

Types

type CSVEncodedData

type CSVEncodedData struct {
	MessageSentTime      time.Time     `csv:"MessageSentTime"`
	MessageReceivedTime  time.Time     `csv:"MessageReceivedTime"`
	Latency              time.Duration `csv:"Latency"`
	LatencyInNanoSeconds int           `csv:"LatencyInNanoSeconds"`
	Partition            int           `csv:"Partition"`
}

func NewCSVEncodedData

func NewCSVEncodedData(rawMetricsData RawMetricsData) CSVEncodedData

type Encoder

type Encoder interface {
	EncodeAsStruct(result chan<- RawMetricsData) error
	Encode(destination io.Writer) error
}

func NewEncoder

func NewEncoder(source io.Reader, encoderConfig EncoderConfig) Encoder

type EncoderConfig

type EncoderConfig struct {
	Type           string
	TimeStampField string
}

type LatencyMetrics

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

type Metrics

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

type MetricsCalculator

type MetricsCalculator interface {
	AddRawMetric(rawMetricsData RawMetricsData)
	GetMetrics() Metrics
}

func NewMetricsCalculator

func NewMetricsCalculator() MetricsCalculator

type Monitor

type Monitor interface {
	Start() error
	Stats() MonitorMetrics
}

func NewMonitor

func NewMonitor(destination io.Writer, appConfig MonitorConfig) (Monitor, error)

type MonitorConfig

type MonitorConfig struct {
	Topic            string
	BootstrapServers []string
	TlsMode          string
	CertLocation     string
	KeyLocation      string
	CACertLocation   string
}

type MonitorMetrics

type MonitorMetrics struct {
	EventsReceived  int64
	EventsRead      int64
	Lag             int64
	EventsInProcess int64
	EventsProcessed int64
}

type RawMetricsData

type RawMetricsData struct {
	MessageSentTime     time.Time
	MessageReceivedTime time.Time
	Partition           int
}

func (RawMetricsData) Latency

func (rawMetricsData RawMetricsData) Latency() time.Duration

type Reporter

type Reporter interface {
	GenerateReport(writer io.Writer) error
	Stats() ReporterStats
}

func NewReporter

func NewReporter(reportConfig ReporterConfig, encoder Encoder, metricsCalculator MetricsCalculator) Reporter

type ReporterConfig

type ReporterConfig struct {
	Type           string
	TimeStampField string
}

type ReporterStats

type ReporterStats struct {
	RecordsProcessed int64
}