aggregates

Documentation

Index

• func Reduce(metrics []string) func(*Stats, map[string]any)
• func StatToValue(metric string) func(s *Stats) float64
• type Stats
  • func Aggregates(ctx context.Context, ts *timeseries.Timeseries, domain string, ...) (*Stats, error)
  • func NewStats(fs fieldset.Set) *Stats
  • func (s *Stats) Compute()
  • func (d *Stats) Read(ctx context.Context, ts *timeseries.Timeseries, shard, view uint64, ...) error

Functions

func Reduce

func Reduce(metrics []string) func(*Stats, map[string]any)

func StatToValue

func StatToValue(metric string) func(s *Stats) float64

Types

type Stats

type Stats struct {
	Visitors       float64
	Visits         float64
	PageViews      float64
	ViewsPerVisits float64
	BounceRate     float64
	VisitDuration  float64
	Events         float64
	// contains filtered or unexported fields
}

func Aggregates

func Aggregates(ctx context.Context, ts *timeseries.Timeseries, domain string, start, end time.Time, interval query.Interval, filters query.Filters, metrics []string) (*Stats, error)

func NewStats

func NewStats(fs fieldset.Set) *Stats

func (*Stats) Compute

func (s *Stats) Compute()

func (*Stats) Read

func (d *Stats) Read(ctx context.Context, ts *timeseries.Timeseries, shard, view uint64, match *roaring.Bitmap, fields fieldset.Set) error