storage

Dec 14, 2020

Changes in this version

type InProcessWatcher

+ func (w *InProcessWatcher) EmitAdd(device *Device)

+ func (w *InProcessWatcher) EmitDelete(device *Device)

type PgWatcher

+ func (w *PgWatcher) EmitAdd(device *Device)

+ func (w *PgWatcher) EmitDelete(device *Device)

type Watcher

+ EmitAdd func(device *Device)

+ EmitDelete func(device *Device)

Nov 29, 2020

Changes in this version

type InMemoryStorage

+ func (s *InMemoryStorage) GetByPublicKey(publicKey string) (*Device, error)

type SQLStorage

+ func (s *SQLStorage) GetByPublicKey(publicKey string) (*Device, error)

type Storage

+ GetByPublicKey func(publicKey string) (*Device, error)

Nov 29, 2020

Changes in this version

+ type Callback func(device *Device)

+ type InProcessWatcher struct

+ func NewInProcessWatcher() *InProcessWatcher

+ func (w *InProcessWatcher) OnAdd(cb Callback)

+ func (w *InProcessWatcher) OnDelete(cb Callback)

+ func (w *InProcessWatcher) OnReconnect(cb func())

+ type PgWatcher struct

+ func NewPgWatcher(connectionString string, table string) (*PgWatcher, error)

+ func (w *PgWatcher) OnAdd(cb Callback)

+ func (w *PgWatcher) OnDelete(cb Callback)

+ func (w *PgWatcher) OnReconnect(cb func())

+ type Watcher interface

+ OnAdd func(cb Callback)

+ OnDelete func(cb Callback)

+ OnReconnect func(func())

Oct 18, 2020

Changes in this version

type Device

+ OwnerEmail string

+ OwnerName string

+ OwnerProvider string

+ type FileStorage struct

+ func NewFileStorage(directory string) *FileStorage

+ func (s *FileStorage) Close() error

+ func (s *FileStorage) Delete(device *Device) error

+ func (s *FileStorage) Get(owner string, name string) (*Device, error)

+ func (s *FileStorage) List(username string) ([]*Device, error)

+ func (s *FileStorage) Open() error

+ func (s *FileStorage) Save(device *Device) error

+ type GormLogger struct

+ func (*GormLogger) Print(v ...interface{})

type InMemoryStorage

+ func (s *InMemoryStorage) Close() error

+ func (s *InMemoryStorage) Open() error

+ type SQLStorage struct

+ func NewSqlStorage(u *url.URL) *SQLStorage

+ func (s *SQLStorage) Close() error

+ func (s *SQLStorage) Delete(device *Device) error

+ func (s *SQLStorage) Get(owner string, name string) (*Device, error)

+ func (s *SQLStorage) List(username string) ([]*Device, error)

+ func (s *SQLStorage) Open() error

+ func (s *SQLStorage) Save(device *Device) error

type Storage

+ func NewStorage(uri string) (Storage, error)

+ Close func() error

+ Open func() error

Mar 21, 2020

Changes in this version

+ type Device struct

+ Address string

+ CreatedAt time.Time

+ Endpoint string

+ LastHandshakeTime *time.Time

+ Name string

+ Owner string

+ PublicKey string

+ ReceiveBytes int64

+ TransmitBytes int64

+ type DiskStorage struct

+ func NewDiskStorage(directory string) *DiskStorage

+ func (s *DiskStorage) Delete(key string) error

+ func (s *DiskStorage) Get(key string) (*Device, error)

+ func (s *DiskStorage) List(prefix string) ([]*Device, error)

+ func (s *DiskStorage) Save(key string, device *Device) error

+ type InMemoryStorage struct

+ func NewMemoryStorage() *InMemoryStorage

+ func (s *InMemoryStorage) Delete(key string) error

+ func (s *InMemoryStorage) Get(key string) (*Device, error)

+ func (s *InMemoryStorage) List(prefix string) ([]*Device, error)

+ func (s *InMemoryStorage) Save(key string, device *Device) error

+ type Storage interface

+ Delete func(key string) error

+ Get func(key string) (*Device, error)

+ List func(prefix string) ([]*Device, error)

+ Save func(key string, device *Device) error