compute

Nov 20, 2024

Changes in this version

+ func Range(re encoding.Resolution, start, end time.Time) iter.Seq2[int64, int64]

Oct 30, 2024

Changes in this version

+ func Minute(ts time.Time) time.Time

Oct 3, 2024

Changes in this version

+ func ByDate(start, end time.Time, f func(time.Time) error) error

+ func ByHour(start, end time.Time, f func(time.Time) error) error

+ func ByMinute(start, end time.Time, f func(time.Time) error) error

+ func ByMonth(start, end time.Time, f func(time.Time) error) error

+ func ByWeek(start, end time.Time, f func(time.Time) error) error

+ func Date(ts time.Time) time.Time

+ func Hour(ts time.Time) time.Time

+ func Month(ts time.Time) time.Time

+ func Week(ts time.Time) time.Time

Mar 3, 2024

Changes in this version

+ func Aggregate(ctx context.Context, scan db.Scanner, req *v1.Aggregate_Request) (*v1.Aggregate_Response, error)

+ func Breakdown(ctx context.Context, scan db.Scanner, req *v1.BreakDown_Request) (*v1.BreakDown_Response, error)

+ func CalVisits(a *array.Boolean) int

+ func CalcBounce(a *array.Boolean) int

+ func HashProp(a arrow.Array) map[string]*roaring.Bitmap

+ func MetricsToProjection(f *v1.Filters, me []v1.Metric, props ...v1.Property) []string

+ func Realtime(ctx context.Context, scan db.Scanner, req *v1.Realtime_Request) (*v1.Realtime_Response, error)

+ func Take(ctx context.Context, a arrow.Array, idx *array.Uint32) (arrow.Array, error)

+ func Timeseries(ctx context.Context, scan db.Scanner, req *v1.Timeseries_Request) (*v1.Timeseries_Response, error)

+ func ValidByPeriod(period *v1.TimePeriod, i v1.Interval) bool

+ type Compute struct

+ Mapping map[string]arrow.Array

+ func NewCompute(r arrow.Record) *Compute

+ func (c *Compute) Bounce() float64

+ func (c *Compute) BounceRate() float64

+ func (c *Compute) Duration() float64

+ func (c *Compute) Events() float64

+ func (c *Compute) Metric(ctx context.Context, m v1.Metric) (float64, error)

+ func (c *Compute) PageView() float64

+ func (c *Compute) Release()

+ func (c *Compute) Reset(r arrow.Record)

+ func (c *Compute) ViewsPerVisits() float64

+ func (c *Compute) VisitDuration() float64

+ func (c *Compute) Visitors(ctx context.Context) (float64, error)

+ func (c *Compute) Visits() float64