store

package

Go to main page

Versions in this module

v0

v0.14.2

Feb 27, 2018

Changes in this version

+ func DecodeUid(uid types.Uid) int64

+ func EncodeUid(id int64) types.Uid

+ func RegisterAdapter(name string, a adapter.Adapter)

type MessagesObjMapper

+ func (MessagesObjMapper) GetDeleted(topic string, forUser types.Uid, opt *types.BrowseOpt) ([]types.Range, int, error)

type TopicsObjMapper

+ func (u TopicsObjMapper) UpdateTags(topic string, unique, tags []string) error

type UsersObjMapper

+ func (u UsersObjMapper) UpdateTags(id types.Uid, unique, newTags []string) error

v0.13.1

Nov 28, 2017

Changes in this version

+ const MAX_USERS_FOR_TOPIC

+ func Close() error

+ func GetAuthHandler(name string) auth.AuthHandler

+ func GetUid() types.Uid

+ func GetUidString() string

+ func InitDb(reset bool) error

+ func IsOpen() bool

+ func Open(jsonconf string) error

+ func Register(name string, adapter adapter.Adapter)

+ func RegisterAuthScheme(name string, handler auth.AuthHandler)

+ type DeviceMapper struct

+ var Devices DeviceMapper

+ func (DeviceMapper) Delete(uid types.Uid, deviceId string) error

+ func (DeviceMapper) GetAll(uid ...types.Uid) (map[types.Uid][]types.DeviceDef, int, error)

+ func (DeviceMapper) Update(uid types.Uid, dev *types.DeviceDef) error

+ type MessagesObjMapper struct

+ var Messages MessagesObjMapper

+ func (MessagesObjMapper) Delete(topic string, forUser types.Uid, hard bool, cleared int) (err error)

+ func (MessagesObjMapper) DeleteList(topic string, forUser types.Uid, hard bool, list []int) (err error)

+ func (MessagesObjMapper) GetAll(topic string, forUser types.Uid, opt *types.BrowseOpt) ([]types.Message, error)

+ func (MessagesObjMapper) Save(msg *types.Message) error

+ type SubsObjMapper struct

+ var Subs SubsObjMapper

+ func (SubsObjMapper) Create(subs ...*types.Subscription) error

+ func (SubsObjMapper) Delete(topic string, user types.Uid) error

+ func (SubsObjMapper) Get(topic string, user types.Uid) (*types.Subscription, error)

+ func (SubsObjMapper) Update(topic string, user types.Uid, update map[string]interface{}) error

+ type TopicsObjMapper struct

+ var Topics TopicsObjMapper

+ func (TopicsObjMapper) Create(topic *types.Topic, owner types.Uid, private interface{}) error

+ func (TopicsObjMapper) CreateP2P(initiator, invited *types.Subscription) error

+ func (TopicsObjMapper) Delete(topic string) error

+ func (TopicsObjMapper) Get(topic string) (*types.Topic, error)

+ func (TopicsObjMapper) GetSubs(topic string) ([]types.Subscription, error)

+ func (TopicsObjMapper) GetUsers(topic string) ([]types.Subscription, error)

+ func (TopicsObjMapper) GetUsersAny(topic string) ([]types.Subscription, error)

+ func (TopicsObjMapper) Update(topic string, update map[string]interface{}) error

+ type UsersObjMapper struct

+ var Users UsersObjMapper

+ func (UsersObjMapper) AddAuthRecord(uid types.Uid, authLvl int, scheme, unique string, secret []byte, ...) (error, bool)

+ func (UsersObjMapper) Delete(id types.Uid, soft bool) error

+ func (UsersObjMapper) Get(uid types.Uid) (*types.User, error)

+ func (UsersObjMapper) GetAll(uid ...types.Uid) ([]types.User, error)

+ func (UsersObjMapper) GetAuthRecord(scheme, unique string) (types.Uid, int, []byte, time.Time, error)

+ func (UsersObjMapper) Update(uid types.Uid, update map[string]interface{}) error

+ func (UsersObjMapper) UpdateAuthRecord(uid types.Uid, authLvl int, scheme, unique string, secret []byte, ...) (int, error)

+ func (UsersObjMapper) UpdateLastSeen(uid types.Uid, userAgent string, when time.Time) error

+ func (UsersObjMapper) UpdateStatus(id types.Uid, status interface{}) error

+ func (u UsersObjMapper) Create(user *types.User, private interface{}) (*types.User, error)

+ func (u UsersObjMapper) FindSubs(id types.Uid, query []interface{}) ([]types.Subscription, error)

+ func (u UsersObjMapper) GetSubs(id types.Uid) ([]types.Subscription, error)

+ func (u UsersObjMapper) GetTopics(id types.Uid) ([]types.Subscription, error)

+ func (u UsersObjMapper) GetTopicsAny(id types.Uid) ([]types.Subscription, error)

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