Method RenderEventStreamStats

internal/display/event_streams.go:453–508

(stats *management.EventStreamStats)

}

func (r *Renderer) RenderEventStreamStats(stats *management.EventStreamStats) {
	if r.Format == OutputFormatJSON {
		r.JSONResult(stats)
		return
	}

	v := &eventStreamStatsView{
		ID:       stats.GetID(),
		Name:     stats.GetName(),
		From:     stats.Window.GetDateFrom().Format(time.RFC3339),
		To:       stats.Window.GetDateTo().Format(time.RFC3339),
		Interval: fmt.Sprintf("%ds", stats.Window.BucketInterval.GetScaleFactor()),
		raw:      stats,
	}

	r.Newline()
	fmt.Println(ansi.Bold(ansi.Cyan("Event Stream Stats")))
	r.Result(v)

	// Metric buckets.
	metricMap := extractMetricMap(stats.Metrics)

	success := metricMap[MetricSuccessfulDeliveries]
	fail := metricMap[MetricFailedDeliveries]

	var rows []View
	for i, bucket := range stats.Buckets {
		timestamp := bucket.Format("2006-01-02 15:04")
		row := &eventStreamStatsRowView{
			Timestamp: timestamp,
			Success:   safeMetric(success, i),
			Failure:   safeMetric(fail, i),
			raw:       nil,
		}
		rows = append(rows, row)
	}

	r.Newline()
	fmt.Println(ansi.Bold(ansi.Cyan("Delivery Metrics")))
	r.Results(rows)

	// Metric Totals + Types.
	r.Newline()
	if success != nil {
		s := findMetric(stats.Metrics, MetricSuccessfulDeliveries)
		if s != nil {
			fmt.Printf("  Successful Deliveries: Total = %d, Type = %s\n", s.GetWindowTotal(), s.GetType())
		}
	}
	if fail != nil {
		f := findMetric(stats.Metrics, MetricFailedDeliveries)
		if f != nil {
			fmt.Printf("  Failed Deliveries:     Total = %d, Type = %s\n", f.GetWindowTotal(), f.GetType())
		}
	}
}

func findMetric(metrics []*management.StatsMetric, name string) *management.StatsMetric {