streaming

type Connector interface {
	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.MeterValue, *models.WindowSize, error)
}

type QueryParams struct {
	From        *time.Time
	To          *time.Time
	Subject     *string
	GroupBy     *[]string
	Aggregation *models.MeterAggregation
	WindowSize  *models.WindowSize
}