store

Mar 13, 2020

Changes in this version

type UsersObjMapper

+ func (UsersObjMapper) UpdateState(uid types.Uid, state types.ObjState) error

Aug 14, 2019

Changes in this version

+ func GetAdapterVersion() int

+ func GetDbVersion() int

+ func UpgradeDb(jsonconf string) error

type UsersObjMapper

+ func (UsersObjMapper) GetActiveCred(id types.Uid, method string) (*types.Credential, error)

+ func (UsersObjMapper) GetAllCreds(id types.Uid, method string, validatedOnly bool) ([]types.Credential, error)

+ func (UsersObjMapper) GetUnreadCount(id types.Uid) (int, error)

+ func (UsersObjMapper) UpsertCred(cred *types.Credential) (bool, error)

Jan 6, 2019

Changes in this version

+ func GetAuthNames() []string

type TopicsObjMapper

+ func (TopicsObjMapper) GetSubsAny(topic string, opts *types.QueryOpt) ([]types.Subscription, error)

+ func (TopicsObjMapper) OwnerChange(topic string, newOwner, oldOwner types.Uid) error

type UsersObjMapper

+ func (UsersObjMapper) DelCred(id types.Uid, method string) error

+ func (UsersObjMapper) GetDisabled(since time.Time) ([]types.Uid, error)

+ func (UsersObjMapper) GetOwnTopics(id types.Uid, opts *types.QueryOpt) ([]string, error)

Oct 15, 2018

Changes in this version

+ func GetLogicalAuthHandler(name string) auth.AuthHandler

+ func InitAuthLogicalNames(config json.RawMessage) error

type UsersObjMapper

+ func (UsersObjMapper) GetByCred(method, value string) (types.Uid, error)

Jul 7, 2018

Changes in this version

+ func GetMediaHandler() media.Handler

+ func RegisterMediaHandler(name string, mh media.Handler)

+ func UseMediaHandler(name, config string) error

+ type FileMapper struct

+ var Files FileMapper

+ func (FileMapper) DeleteUnused(olderThan time.Time, limit int) error

+ func (FileMapper) FinishUpload(fid string, success bool, size int64) (*types.FileDef, error)

+ func (FileMapper) Get(fid string) (*types.FileDef, error)

+ func (FileMapper) StartUpload(fd *types.FileDef) error

Apr 27, 2018

Changes in this version

+ func GetAdapterName() string

type UsersObjMapper

+ func (UsersObjMapper) GetAuthUniqueRecord(scheme, unique string) (types.Uid, auth.Level, []byte, time.Time, error)

Apr 16, 2018

Changes in this version

+ func GetValidator(name string) validate.Validator

+ func RegisterValidator(name string, v validate.Validator)

type UsersObjMapper

+ func (UsersObjMapper) ConfirmCred(id types.Uid, method string) error

+ func (UsersObjMapper) DelAuthRecords(uid types.Uid, scheme string) error

+ func (UsersObjMapper) FailCred(id types.Uid, method string) error

+ func (UsersObjMapper) GetAllCred(id types.Uid, method string) ([]*types.Credential, error)

+ func (UsersObjMapper) GetCred(id types.Uid, method string) (*types.Credential, error)

+ func (UsersObjMapper) SaveCred(cred *types.Credential) error

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

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)