aggregation

Feb 12, 2019

Changes in this version

type InfluxAggr

+ func (a *InfluxAggr) CreateHandler(ds registry.DataSource) error

+ func (a *InfluxAggr) DeleteHandler(ds registry.DataSource) error

+ func (a *InfluxAggr) UpdateHandler(oldDS registry.DataSource, newDS registry.DataSource) error

Mar 29, 2018

Changes in this version

+ const MaxPerPage

+ var ErrNotImplemented = errors.New("API not implemented")

+ func NtfListener(s Storage, ntChan <-chan common.Notification)

+ type API struct

+ func NewAPI(registryClient registry.Client, storage Storage) *API

+ func (api *API) Aggregations() (map[string]Aggregation, error)

+ func (api *API) Filter(w http.ResponseWriter, r *http.Request)

+ func (api *API) Index(w http.ResponseWriter, r *http.Request)

+ func (api *API) Query(w http.ResponseWriter, r *http.Request)

+ type Aggregation struct

+ Aggregates []string

+ ID string

+ Interval string

+ Retention string

+ Sources []string

+ type DataEntry struct

+ Aggregates map[string]float64

+ Name string

+ TimeEnd int64

+ TimeStart int64

+ func NewDataEntry() DataEntry

+ func (e *DataEntry) MarshalJSON() ([]byte, error)

+ type DataSet struct

+ BaseName string

+ BaseTimeEnd int64

+ BaseTimeStart int64

+ Entries []DataEntry

+ type Index struct

+ Aggrs []Aggregation

+ type InfluxAggr struct

+ func (a *InfluxAggr) NtfCreated(ds registry.DataSource, callback chan error)

+ func (a *InfluxAggr) NtfDeleted(ds registry.DataSource, callback chan error)

+ func (a *InfluxAggr) NtfUpdated(oldDS registry.DataSource, newDS registry.DataSource, callback chan error)

+ func (a *InfluxAggr) Query(aggr registry.Aggregation, q data.Query, page, perPage int, ...) (DataSet, int, error)

+ type MongoAggr struct

+ func (a *MongoAggr) NtfCreated(ds registry.DataSource, callback chan error)

+ func (a *MongoAggr) NtfDeleted(ds registry.DataSource, callback chan error)

+ func (a *MongoAggr) NtfUpdated(oldDS registry.DataSource, newDS registry.DataSource, callback chan error)

+ func (a *MongoAggr) Query(aggr registry.Aggregation, q data.Query, page, perPage int, ...) (DataSet, int, error)

+ type RecordSet struct

+ Data DataSet

+ Page int

+ PerPage int

+ Time float64

+ Total int

+ URL string

+ type Storage interface

+ NtfCreated func(ds registry.DataSource, callback chan error)

+ NtfDeleted func(ds registry.DataSource, callback chan error)

+ NtfUpdated func(old registry.DataSource, new registry.DataSource, callback chan error)

+ Query func(aggr registry.Aggregation, q data.Query, page, perPage int, ...) (DataSet, int, error)

+ func NewInfluxAggr(influxStorage *data.InfluxStorage) (Storage, chan<- common.Notification, error)

+ func NewMongoAggr(mongoStorage *data.MongoStorage) (Storage, chan<- common.Notification, error)