data

package

Go to main page

Versions in this module

v0

v0.6.1

Feb 12, 2019

Changes in this version

+ const INFLUXDB

+ const MONGODB

+ func SupportedBackends(name string) bool

+ type API struct

+ func NewAPI(registry registry.Storage, storage Storage, autoRegistration bool) *API

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

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

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

type InfluxStorage

+ func (s *InfluxStorage) CreateHandler(ds registry.DataSource) error

+ func (s *InfluxStorage) DeleteHandler(ds registry.DataSource) error

+ func (s *InfluxStorage) UpdateHandler(oldDS registry.DataSource, newDS registry.DataSource) error

type MQTTConnector

+ func (c *MQTTConnector) CreateHandler(ds registry.DataSource) error

+ func (c *MQTTConnector) DeleteHandler(oldDS registry.DataSource) error

+ func (c *MQTTConnector) Start(registry registry.Storage) error

+ func (c *MQTTConnector) UpdateHandler(oldDS registry.DataSource, newDS registry.DataSource) error

v0.6.0

Nov 14, 2018

v0.5.3

Nov 1, 2018

v0.5.2

Aug 9, 2018

Changes in this version

type InfluxStorage

+ func (s *InfluxStorage) ChangeRetentionPolicy(measurement, countField, oldRP, newRP string) error

+ func (s *InfluxStorage) ParseDuration(durationStr string) (time.Duration, error)

v0.5.1

Jun 20, 2018

v0.5.0

Jun 11, 2018

Changes in this version

type InfluxStorage

+ func (s *InfluxStorage) MeasurementName(ds *registry.DataSource) string

+ func (s *InfluxStorage) MeasurementNameFQ(ds *registry.DataSource) string

+ func (s *InfluxStorage) RetentionPolicyName(period string) string

v0.4.3

May 5, 2018

v0.4.2

Mar 29, 2018

Changes in this version

+ const MaxPerPage

+ var SupportedContentTypes = map[string]bool

+ func NewMQTTConnector(registryClient registry.Client, storage Storage) (chan<- common.Notification, error)

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

+ func NtfListenerMQTT(c *MQTTConnector, ntChan <-chan common.Notification)

+ type DataPoint struct

+ func NewDataPoint() DataPoint

+ func (p *DataPoint) FromEntry(e senml.Entry) DataPoint

+ type DataSet struct

+ Entries []DataPoint

+ func NewDataSet() DataSet

+ func (s *DataSet) FromMessage(m senml.Message) DataSet

+ type Entry struct

+ BooleanValue *bool

+ Name string

+ StringValue *string

+ Sum *float64

+ Time int64

+ Units string

+ UpdateTime int64

+ Value *float64

+ type HTTPAPI struct

+ func NewHTTPAPI(registryClient registry.Client, storage Storage, autoRegistration bool) *HTTPAPI

+ func (d *HTTPAPI) Query(w http.ResponseWriter, r *http.Request)

+ func (d *HTTPAPI) Submit(w http.ResponseWriter, r *http.Request)

+ func (d *HTTPAPI) SubmitWithoutID(w http.ResponseWriter, r *http.Request)

+ type InfluxStorage struct

+ func NewInfluxStorage(DSN string) (*InfluxStorage, chan<- common.Notification, error)

+ func (s *InfluxStorage) CountSprintf(format string, a ...interface{}) (int64, error)

+ func (s *InfluxStorage) Database() string

+ func (s *InfluxStorage) FQMsrmt(ds *registry.DataSource) string

+ func (s *InfluxStorage) FieldForType(t string) string

+ func (s *InfluxStorage) Msrmt(ds *registry.DataSource) string

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

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

+ func (s *InfluxStorage) NtfUpdated(oldDS registry.DataSource, newDS registry.DataSource, callback chan error)

+ func (s *InfluxStorage) Query(q Query, page, perPage int, sources ...*registry.DataSource) (DataSet, int, error)

+ func (s *InfluxStorage) QuerySprintf(format string, a ...interface{}) (res []influx.Result, err error)

+ func (s *InfluxStorage) Replication() int

+ func (s *InfluxStorage) Retention(ds *registry.DataSource) string

+ func (s *InfluxStorage) Submit(data map[string][]DataPoint, sources map[string]*registry.DataSource) error

+ type InfluxStorageConfig struct

+ DSN string

+ Database string

+ Password string

+ Replication int

+ Username string

+ type MQTTConnector struct

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

+ func (c *MQTTConnector) NtfDeleted(oldDS registry.DataSource, callback chan error)

+ func (c *MQTTConnector) NtfUpdated(oldDS registry.DataSource, newDS registry.DataSource, callback chan error)

+ type Manager struct

+ type MongoStorage struct

+ func NewMongoStorage(DSN string) (*MongoStorage, chan<- common.Notification, error)

+ func (s *MongoStorage) Database() string

+ func (s *MongoStorage) FQMsrmt(ds *registry.DataSource) string

+ func (s *MongoStorage) FieldForType(t string) string

+ func (s *MongoStorage) Msrmt(ds *registry.DataSource) string

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

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

+ func (s *MongoStorage) NtfUpdated(oldDS registry.DataSource, newDS registry.DataSource, callback chan error)

+ func (s *MongoStorage) Query(q Query, page, perPage int, sources ...*registry.DataSource) (DataSet, int, error)

+ func (s *MongoStorage) Retention(ds *registry.DataSource) string

+ func (s *MongoStorage) Submit(data map[string][]DataPoint, sources map[string]*registry.DataSource) error

+ type Query struct

+ End time.Time

+ Limit int

+ Sort string

+ Start time.Time

+ func ParseQueryParameters(form url.Values) (Query, error)

+ type RecordSet struct

+ Data DataSet

+ Page int

+ PerPage int

+ Time float64

+ Total int

+ URL string

+ type RemoteClient struct

+ func NewRemoteClient(serverEndpoint string, ticket *obtainer.Client) (*RemoteClient, error)

+ func (c *RemoteClient) Query(q Query, page, perPage int, id ...string) (*RecordSet, error)

+ func (c *RemoteClient) Submit(data []byte, contentType string, id ...string) error

+ 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(q Query, page, perPage int, sources ...*registry.DataSource) (DataSet, int, error)

+ Submit func(data map[string][]DataPoint, sources map[string]*registry.DataSource) error

+ type Subscription struct

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL