kafkaperf

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"`
}

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

type EncoderConfig struct {
	Type           string
	TimeStampField string
}

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

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

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

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

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

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

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

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

type ReporterConfig struct {
	Type           string
	TimeStampField string
}

type ReporterStats struct {
	RecordsProcessed int64
}