streaming

type Connector interface {
	CountEvents(ctx context.Context, namespace string, params CountEventsParams) ([]CountEventRow, error)
	ListEvents(ctx context.Context, namespace string, params ListEventsParams) ([]api.IngestedEvent, error)
	CreateMeter(ctx context.Context, namespace string, meter *models.Meter) error
	DeleteMeter(ctx context.Context, namespace string, meterSlug string) error
	QueryMeter(ctx context.Context, namespace string, meterSlug string, params *QueryParams) ([]models.MeterQueryRow, error)
	ListMeterSubjects(ctx context.Context, namespace string, meterSlug string, from *time.Time, to *time.Time) ([]string, error)
}

type CountEventRow struct {
	Count   uint64
	Subject string
	IsError bool
}

type CountEventsParams struct {
	From time.Time
}

type ListEventsParams struct {
	From  *time.Time
	To    *time.Time
	Limit int
}

type QueryParams struct {
	From           *time.Time
	To             *time.Time
	FilterSubject  []string
	FilterGroupBy  map[string][]string
	GroupBy        []string
	Aggregation    models.MeterAggregation
	WindowSize     *models.WindowSize
	WindowTimeZone *time.Location
}