Documentation ¶
Index ¶
- type SqlDB
- func (db *SqlDB) Add(subscription storage.Subscription) error
- func (db *SqlDB) Close() error
- func (db *SqlDB) Delete(id int64) error
- func (db *SqlDB) Get(clientId int64) ([]storage.Subscription, error)
- func (db *SqlDB) GetAllActive() ([]storage.Subscription, error)
- func (db *SqlDB) Update(subscription storage.Subscription) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type SqlDB ¶
type SqlDB struct {
// contains filtered or unexported fields
}
SqlDB implements Storage interface
func (*SqlDB) Add ¶
func (db *SqlDB) Add(subscription storage.Subscription) error
Add inserts new subscription
func (*SqlDB) Get ¶
func (db *SqlDB) Get(clientId int64) ([]storage.Subscription, error)
Get gets all client subscriptions
func (*SqlDB) GetAllActive ¶
func (db *SqlDB) GetAllActive() ([]storage.Subscription, error)
GetAllActive gets all active subscriptions for all clients
Click to show internal directories.
Click to hide internal directories.