streaming

type Connector interface {
	Init(meter *models.Meter) error
	GetValues(meter *models.Meter, params *GetValuesParams) ([]*models.MeterValue, error)
}

type GetValuesParams struct {
	From       *time.Time
	To         *time.Time
	Subject    *string
	WindowSize *models.WindowSize
}