registry

package

Go to main page

Versions in this module

v0

v0.6.1

Feb 12, 2019

Changes in this version

+ const LEVELDB

+ const MEMORY

+ func SupportedBackends(name string) bool

+ type API struct

+ func NewAPI(storage Storage) *API

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

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

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

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

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

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

+ type EventListener interface

+ CreateHandler func(new DataSource) error

+ DeleteHandler func(old DataSource) error

+ UpdateHandler func(old DataSource, new DataSource) error

type LevelDBStorage

+ func (s *LevelDBStorage) Add(ds DataSource) (DataSource, error)

+ func (s *LevelDBStorage) Delete(id string) error

+ func (s *LevelDBStorage) Filter(path, op, value string, page, perPage int) ([]DataSource, int, error)

+ func (s *LevelDBStorage) FilterOne(path, op, value string) (*DataSource, error)

+ func (s *LevelDBStorage) Get(id string) (DataSource, error)

+ func (s *LevelDBStorage) GetMany(page, perPage int) ([]DataSource, int, error)

+ func (s *LevelDBStorage) Update(id string, ds DataSource) (DataSource, error)

type MemoryStorage

+ func (ms *MemoryStorage) Add(ds DataSource) (DataSource, error)

+ func (ms *MemoryStorage) Delete(id string) error

+ func (ms *MemoryStorage) Filter(path, op, value string, page, perPage int) ([]DataSource, int, error)

+ func (ms *MemoryStorage) FilterOne(path, op, value string) (*DataSource, error)

+ func (ms *MemoryStorage) Get(id string) (DataSource, error)

+ func (ms *MemoryStorage) GetMany(page, perPage int) ([]DataSource, int, error)

+ func (ms *MemoryStorage) Update(id string, ds DataSource) (DataSource, error)

type RemoteClient

+ func (c *RemoteClient) Filter(path, op, value string) ([]DataSource, error)

+ func (c *RemoteClient) GetMany(page int, perPage int) (*Registry, error)

type Storage

+ Add func(ds DataSource) (DataSource, error)

+ Delete func(id string) error

+ Filter func(path, op, value string, page, perPage int) ([]DataSource, int, error)

+ FilterOne func(path, op, value string) (*DataSource, error)

+ Get func(id string) (DataSource, error)

+ GetMany func(page, perPage int) ([]DataSource, int, error)

+ Update func(id string, ds DataSource) (DataSource, error)

v0.6.0

Nov 14, 2018

v0.5.3

Nov 1, 2018

v0.5.2

Aug 9, 2018

v0.5.1

Jun 20, 2018

v0.5.0

Jun 11, 2018

Changes in this version

type DataSource

+ func (ds DataSource) MarshalJSON() ([]byte, error)

+ func (ds DataSource) MarshalSensitiveJSON() ([]byte, error)

v0.4.3

May 5, 2018

v0.4.2

Mar 29, 2018

Changes in this version

+ const FTypeMany

+ const FTypeOne

+ const MaxPerPage

+ var ErrConflict = errors.New("Conflict")

+ var ErrNotFound = errors.New("Datasource Not Found")

+ func ErrType(err, e error) bool

+ type Aggregation struct

+ Aggregates []string

+ Data string

+ ID string

+ Interval string

+ Retention string

+ func (a *Aggregation) Make(dsID string)

+ type Client interface

+ Add func(d DataSource) (DataSource, error)

+ Delete func(id string) error

+ FindDataSource func(path, op, value string) (*DataSource, error)

+ FindDataSources func(path, op, value string, page, perPage int) ([]DataSource, int, error)

+ Get func(id string) (DataSource, error)

+ GetDataSources func(page, perPage int) ([]DataSource, int, error)

+ Update func(id string, d DataSource) (DataSource, error)

+ func NewLocalClient(storage Storage) Client

+ type Connector struct

+ MQTT *MQTTConf

+ type DataSource struct

+ Aggregation []Aggregation

+ Connector Connector

+ Data string

+ Format string

+ ID string

+ Meta map[string]interface{}

+ Resource string

+ Retention string

+ Type string

+ URL string

+ func (ds *DataSource) ParsedResource() *url.URL

+ type DummyRegistryStorage struct

+ type HTTPAPI struct

+ func NewHTTPAPI(storage Storage) *HTTPAPI

+ func (regAPI *HTTPAPI) Create(w http.ResponseWriter, r *http.Request)

+ func (regAPI *HTTPAPI) Delete(w http.ResponseWriter, r *http.Request)

+ func (regAPI *HTTPAPI) Filter(w http.ResponseWriter, r *http.Request)

+ func (regAPI *HTTPAPI) Index(w http.ResponseWriter, r *http.Request)

+ func (regAPI *HTTPAPI) Retrieve(w http.ResponseWriter, r *http.Request)

+ func (regAPI *HTTPAPI) Update(w http.ResponseWriter, r *http.Request)

+ type LevelDBStorage struct

+ type LocalClient struct

+ func (c *LocalClient) Add(r DataSource) (DataSource, error)

+ func (c *LocalClient) Delete(id string) error

+ func (c *LocalClient) FindDataSource(path, op, value string) (*DataSource, error)

+ func (c *LocalClient) FindDataSources(path, op, value string, page, perPage int) ([]DataSource, int, error)

+ func (c *LocalClient) Get(id string) (DataSource, error)

+ func (c *LocalClient) GetDataSources(page int, perPage int) ([]DataSource, int, error)

+ func (c *LocalClient) Update(id string, r DataSource) (DataSource, error)

+ type MQTTConf struct

+ CaFile string

+ CertFile string

+ KeyFile string

+ Password string

+ QoS byte

+ Topic string

+ URL string

+ Username string

+ func (c MQTTConf) MarshalJSON() ([]byte, error)

+ type MemoryStorage struct

+ type Registry struct

+ Entries []DataSource

+ Page int

+ PerPage int

+ Total int

+ URL string

+ type RemoteClient struct

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

+ func (c *RemoteClient) Add(d *DataSource) (string, error)

+ func (c *RemoteClient) Delete(id string) error

+ func (c *RemoteClient) FilterMany(path, op, value string) ([]DataSource, error)

+ func (c *RemoteClient) FilterOne(path, op, value string) (*DataSource, error)

+ func (c *RemoteClient) Get(id string) (*DataSource, error)

+ func (c *RemoteClient) Index(page int, perPage int) (*Registry, error)

+ func (c *RemoteClient) Update(id string, d *DataSource) error

+ type Storage interface

+ func NewLevelDBStorage(dsn string, opts *opt.Options) (Storage, *chan common.Notification, func() error, error)

+ func NewMemoryStorage() (Storage, *chan common.Notification)

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