Versions in this module Expand all Collapse all v0 v0.20.5 Dec 19, 2022 v0.20.4 Dec 19, 2022 Changes in this version + type MockDevicePersistenceInterface struct + func NewMockDevicePersistenceInterface(ctrl *gomock.Controller) *MockDevicePersistenceInterface + func (m *MockDevicePersistenceInterface) Delete(uid types.Uid, deviceID string) error + func (m *MockDevicePersistenceInterface) EXPECT() *MockDevicePersistenceInterfaceMockRecorder + func (m *MockDevicePersistenceInterface) GetAll(uid ...types.Uid) (map[types.Uid][]types.DeviceDef, int, error) + func (m *MockDevicePersistenceInterface) Update(uid types.Uid, oldDeviceID string, dev *types.DeviceDef) error + type MockDevicePersistenceInterfaceMockRecorder struct + func (mr *MockDevicePersistenceInterfaceMockRecorder) Delete(uid, deviceID interface{}) *gomock.Call + func (mr *MockDevicePersistenceInterfaceMockRecorder) GetAll(uid ...interface{}) *gomock.Call + func (mr *MockDevicePersistenceInterfaceMockRecorder) Update(uid, oldDeviceID, dev interface{}) *gomock.Call + type MockFilePersistenceInterface struct + func NewMockFilePersistenceInterface(ctrl *gomock.Controller) *MockFilePersistenceInterface + func (m *MockFilePersistenceInterface) DeleteUnused(olderThan time.Time, limit int) error + func (m *MockFilePersistenceInterface) EXPECT() *MockFilePersistenceInterfaceMockRecorder + func (m *MockFilePersistenceInterface) FinishUpload(fd *types.FileDef, success bool, size int64) (*types.FileDef, error) + func (m *MockFilePersistenceInterface) Get(fid string) (*types.FileDef, error) + func (m *MockFilePersistenceInterface) LinkAttachments(topic string, msgId types.Uid, attachments []string) error + func (m *MockFilePersistenceInterface) StartUpload(fd *types.FileDef) error + type MockFilePersistenceInterfaceMockRecorder struct + func (mr *MockFilePersistenceInterfaceMockRecorder) DeleteUnused(olderThan, limit interface{}) *gomock.Call + func (mr *MockFilePersistenceInterfaceMockRecorder) FinishUpload(fd, success, size interface{}) *gomock.Call + func (mr *MockFilePersistenceInterfaceMockRecorder) Get(fid interface{}) *gomock.Call + func (mr *MockFilePersistenceInterfaceMockRecorder) LinkAttachments(topic, msgId, attachments interface{}) *gomock.Call + func (mr *MockFilePersistenceInterfaceMockRecorder) StartUpload(fd interface{}) *gomock.Call + type MockMessagesPersistenceInterface struct + func NewMockMessagesPersistenceInterface(ctrl *gomock.Controller) *MockMessagesPersistenceInterface + func (m *MockMessagesPersistenceInterface) DeleteList(topic string, delID int, forUser types.Uid, ranges []types.Range) error + func (m *MockMessagesPersistenceInterface) EXPECT() *MockMessagesPersistenceInterfaceMockRecorder + func (m *MockMessagesPersistenceInterface) GetAll(topic string, forUser types.Uid, opt *types.QueryOpt) ([]types.Message, error) + func (m *MockMessagesPersistenceInterface) GetDeleted(topic string, forUser types.Uid, opt *types.QueryOpt) ([]types.Range, int, error) + func (m *MockMessagesPersistenceInterface) Save(msg *types.Message, attachmentURLs []string, readBySender bool) error + type MockMessagesPersistenceInterfaceMockRecorder struct + func (mr *MockMessagesPersistenceInterfaceMockRecorder) DeleteList(topic, delID, forUser, ranges interface{}) *gomock.Call + func (mr *MockMessagesPersistenceInterfaceMockRecorder) GetAll(topic, forUser, opt interface{}) *gomock.Call + func (mr *MockMessagesPersistenceInterfaceMockRecorder) GetDeleted(topic, forUser, opt interface{}) *gomock.Call + func (mr *MockMessagesPersistenceInterfaceMockRecorder) Save(msg, attachmentURLs, readBySender interface{}) *gomock.Call + type MockPersistentStorageInterface struct + func NewMockPersistentStorageInterface(ctrl *gomock.Controller) *MockPersistentStorageInterface + func (m *MockPersistentStorageInterface) Close() error + func (m *MockPersistentStorageInterface) DbStats() func() interface{} + func (m *MockPersistentStorageInterface) EXPECT() *MockPersistentStorageInterfaceMockRecorder + func (m *MockPersistentStorageInterface) GetAdapter() adapter.Adapter + func (m *MockPersistentStorageInterface) GetAdapterName() string + func (m *MockPersistentStorageInterface) GetAdapterVersion() int + func (m *MockPersistentStorageInterface) GetAuthHandler(name string) auth.AuthHandler + func (m *MockPersistentStorageInterface) GetAuthNames() []string + func (m *MockPersistentStorageInterface) GetDbVersion() int + func (m *MockPersistentStorageInterface) GetLogicalAuthHandler(name string) auth.AuthHandler + func (m *MockPersistentStorageInterface) GetMediaHandler() media.Handler + func (m *MockPersistentStorageInterface) GetUid() types.Uid + func (m *MockPersistentStorageInterface) GetUidString() string + func (m *MockPersistentStorageInterface) GetValidator(name string) validate.Validator + func (m *MockPersistentStorageInterface) InitDb(jsonconf json.RawMessage, reset bool) error + func (m *MockPersistentStorageInterface) IsOpen() bool + func (m *MockPersistentStorageInterface) Open(workerId int, jsonconf json.RawMessage) error + func (m *MockPersistentStorageInterface) UpgradeDb(jsonconf json.RawMessage) error + func (m *MockPersistentStorageInterface) UseMediaHandler(name, config string) error + type MockPersistentStorageInterfaceMockRecorder struct + func (mr *MockPersistentStorageInterfaceMockRecorder) Close() *gomock.Call + func (mr *MockPersistentStorageInterfaceMockRecorder) DbStats() *gomock.Call + func (mr *MockPersistentStorageInterfaceMockRecorder) GetAdapter() *gomock.Call + func (mr *MockPersistentStorageInterfaceMockRecorder) GetAdapterName() *gomock.Call + func (mr *MockPersistentStorageInterfaceMockRecorder) GetAdapterVersion() *gomock.Call + func (mr *MockPersistentStorageInterfaceMockRecorder) GetAuthHandler(name interface{}) *gomock.Call + func (mr *MockPersistentStorageInterfaceMockRecorder) GetAuthNames() *gomock.Call + func (mr *MockPersistentStorageInterfaceMockRecorder) GetDbVersion() *gomock.Call + func (mr *MockPersistentStorageInterfaceMockRecorder) GetLogicalAuthHandler(name interface{}) *gomock.Call + func (mr *MockPersistentStorageInterfaceMockRecorder) GetMediaHandler() *gomock.Call + func (mr *MockPersistentStorageInterfaceMockRecorder) GetUid() *gomock.Call + func (mr *MockPersistentStorageInterfaceMockRecorder) GetUidString() *gomock.Call + func (mr *MockPersistentStorageInterfaceMockRecorder) GetValidator(name interface{}) *gomock.Call + func (mr *MockPersistentStorageInterfaceMockRecorder) InitDb(jsonconf, reset interface{}) *gomock.Call + func (mr *MockPersistentStorageInterfaceMockRecorder) IsOpen() *gomock.Call + func (mr *MockPersistentStorageInterfaceMockRecorder) Open(workerId, jsonconf interface{}) *gomock.Call + func (mr *MockPersistentStorageInterfaceMockRecorder) UpgradeDb(jsonconf interface{}) *gomock.Call + func (mr *MockPersistentStorageInterfaceMockRecorder) UseMediaHandler(name, config interface{}) *gomock.Call + type MockSubsPersistenceInterface struct + func NewMockSubsPersistenceInterface(ctrl *gomock.Controller) *MockSubsPersistenceInterface + func (m *MockSubsPersistenceInterface) Create(subs ...*types.Subscription) error + func (m *MockSubsPersistenceInterface) Delete(topic string, user types.Uid) error + func (m *MockSubsPersistenceInterface) EXPECT() *MockSubsPersistenceInterfaceMockRecorder + func (m *MockSubsPersistenceInterface) Get(topic string, user types.Uid, keepDeleted bool) (*types.Subscription, error) + func (m *MockSubsPersistenceInterface) Update(topic string, user types.Uid, update map[string]interface{}) error + type MockSubsPersistenceInterfaceMockRecorder struct + func (mr *MockSubsPersistenceInterfaceMockRecorder) Create(subs ...interface{}) *gomock.Call + func (mr *MockSubsPersistenceInterfaceMockRecorder) Delete(topic, user interface{}) *gomock.Call + func (mr *MockSubsPersistenceInterfaceMockRecorder) Get(topic, user, keepDeleted interface{}) *gomock.Call + func (mr *MockSubsPersistenceInterfaceMockRecorder) Update(topic, user, update interface{}) *gomock.Call + type MockTopicsPersistenceInterface struct + func NewMockTopicsPersistenceInterface(ctrl *gomock.Controller) *MockTopicsPersistenceInterface + func (m *MockTopicsPersistenceInterface) Create(topic *types.Topic, owner types.Uid, private interface{}) error + func (m *MockTopicsPersistenceInterface) CreateP2P(initiator, invited *types.Subscription) error + func (m *MockTopicsPersistenceInterface) Delete(topic string, isChan, hard bool) error + func (m *MockTopicsPersistenceInterface) EXPECT() *MockTopicsPersistenceInterfaceMockRecorder + func (m *MockTopicsPersistenceInterface) Get(topic string) (*types.Topic, error) + func (m *MockTopicsPersistenceInterface) GetSubs(topic string, opts *types.QueryOpt) ([]types.Subscription, error) + func (m *MockTopicsPersistenceInterface) GetSubsAny(topic string, opts *types.QueryOpt) ([]types.Subscription, error) + func (m *MockTopicsPersistenceInterface) GetUsers(topic string, opts *types.QueryOpt) ([]types.Subscription, error) + func (m *MockTopicsPersistenceInterface) GetUsersAny(topic string, opts *types.QueryOpt) ([]types.Subscription, error) + func (m *MockTopicsPersistenceInterface) OwnerChange(topic string, newOwner types.Uid) error + func (m *MockTopicsPersistenceInterface) Update(topic string, update map[string]interface{}) error + type MockTopicsPersistenceInterfaceMockRecorder struct + func (mr *MockTopicsPersistenceInterfaceMockRecorder) Create(topic, owner, private interface{}) *gomock.Call + func (mr *MockTopicsPersistenceInterfaceMockRecorder) CreateP2P(initiator, invited interface{}) *gomock.Call + func (mr *MockTopicsPersistenceInterfaceMockRecorder) Delete(topic, isChan, hard interface{}) *gomock.Call + func (mr *MockTopicsPersistenceInterfaceMockRecorder) Get(topic interface{}) *gomock.Call + func (mr *MockTopicsPersistenceInterfaceMockRecorder) GetSubs(topic, opts interface{}) *gomock.Call + func (mr *MockTopicsPersistenceInterfaceMockRecorder) GetSubsAny(topic, opts interface{}) *gomock.Call + func (mr *MockTopicsPersistenceInterfaceMockRecorder) GetUsers(topic, opts interface{}) *gomock.Call + func (mr *MockTopicsPersistenceInterfaceMockRecorder) GetUsersAny(topic, opts interface{}) *gomock.Call + func (mr *MockTopicsPersistenceInterfaceMockRecorder) OwnerChange(topic, newOwner interface{}) *gomock.Call + func (mr *MockTopicsPersistenceInterfaceMockRecorder) Update(topic, update interface{}) *gomock.Call + type MockUsersPersistenceInterface struct + func NewMockUsersPersistenceInterface(ctrl *gomock.Controller) *MockUsersPersistenceInterface + func (m *MockUsersPersistenceInterface) AddAuthRecord(uid types.Uid, authLvl auth.Level, scheme, unique string, secret []byte, ...) error + func (m *MockUsersPersistenceInterface) ConfirmCred(id types.Uid, method string) error + func (m *MockUsersPersistenceInterface) Create(user *types.User, private interface{}) (*types.User, error) + func (m *MockUsersPersistenceInterface) DelAuthRecords(uid types.Uid, scheme string) error + func (m *MockUsersPersistenceInterface) DelCred(id types.Uid, method, value string) error + func (m *MockUsersPersistenceInterface) Delete(id types.Uid, hard bool) error + func (m *MockUsersPersistenceInterface) EXPECT() *MockUsersPersistenceInterfaceMockRecorder + func (m *MockUsersPersistenceInterface) FailCred(id types.Uid, method string) error + func (m *MockUsersPersistenceInterface) FindSubs(id types.Uid, required [][]string, optional []string) ([]types.Subscription, error) + func (m *MockUsersPersistenceInterface) Get(uid types.Uid) (*types.User, error) + func (m *MockUsersPersistenceInterface) GetActiveCred(id types.Uid, method string) (*types.Credential, error) + func (m *MockUsersPersistenceInterface) GetAll(uid ...types.Uid) ([]types.User, error) + func (m *MockUsersPersistenceInterface) GetAllCreds(id types.Uid, method string, validatedOnly bool) ([]types.Credential, error) + func (m *MockUsersPersistenceInterface) GetAuthRecord(user types.Uid, scheme string) (string, auth.Level, []byte, time.Time, error) + func (m *MockUsersPersistenceInterface) GetAuthUniqueRecord(scheme, unique string) (types.Uid, auth.Level, []byte, time.Time, error) + func (m *MockUsersPersistenceInterface) GetByCred(method, value string) (types.Uid, error) + func (m *MockUsersPersistenceInterface) GetChannels(id types.Uid) ([]string, error) + func (m *MockUsersPersistenceInterface) GetOwnTopics(id types.Uid) ([]string, error) + func (m *MockUsersPersistenceInterface) GetSubs(id types.Uid) ([]types.Subscription, error) + func (m *MockUsersPersistenceInterface) GetTopics(id types.Uid, opts *types.QueryOpt) ([]types.Subscription, error) + func (m *MockUsersPersistenceInterface) GetTopicsAny(id types.Uid, opts *types.QueryOpt) ([]types.Subscription, error) + func (m *MockUsersPersistenceInterface) GetUnreadCount(ids ...types.Uid) (map[types.Uid]int, error) + func (m *MockUsersPersistenceInterface) Update(uid types.Uid, update map[string]interface{}) error + func (m *MockUsersPersistenceInterface) UpdateAuthRecord(uid types.Uid, authLvl auth.Level, scheme, unique string, secret []byte, ...) error + func (m *MockUsersPersistenceInterface) UpdateLastSeen(uid types.Uid, userAgent string, when time.Time) error + func (m *MockUsersPersistenceInterface) UpdateState(uid types.Uid, state types.ObjState) error + func (m *MockUsersPersistenceInterface) UpdateTags(uid types.Uid, add, remove, reset []string) ([]string, error) + func (m *MockUsersPersistenceInterface) UpsertCred(cred *types.Credential) (bool, error) + type MockUsersPersistenceInterfaceMockRecorder struct + func (mr *MockUsersPersistenceInterfaceMockRecorder) AddAuthRecord(uid, authLvl, scheme, unique, secret, expires interface{}) *gomock.Call + func (mr *MockUsersPersistenceInterfaceMockRecorder) ConfirmCred(id, method interface{}) *gomock.Call + func (mr *MockUsersPersistenceInterfaceMockRecorder) Create(user, private interface{}) *gomock.Call + func (mr *MockUsersPersistenceInterfaceMockRecorder) DelAuthRecords(uid, scheme interface{}) *gomock.Call + func (mr *MockUsersPersistenceInterfaceMockRecorder) DelCred(id, method, value interface{}) *gomock.Call + func (mr *MockUsersPersistenceInterfaceMockRecorder) Delete(id, hard interface{}) *gomock.Call + func (mr *MockUsersPersistenceInterfaceMockRecorder) FailCred(id, method interface{}) *gomock.Call + func (mr *MockUsersPersistenceInterfaceMockRecorder) FindSubs(id, required, optional interface{}) *gomock.Call + func (mr *MockUsersPersistenceInterfaceMockRecorder) Get(uid interface{}) *gomock.Call + func (mr *MockUsersPersistenceInterfaceMockRecorder) GetActiveCred(id, method interface{}) *gomock.Call + func (mr *MockUsersPersistenceInterfaceMockRecorder) GetAll(uid ...interface{}) *gomock.Call + func (mr *MockUsersPersistenceInterfaceMockRecorder) GetAllCreds(id, method, validatedOnly interface{}) *gomock.Call + func (mr *MockUsersPersistenceInterfaceMockRecorder) GetAuthRecord(user, scheme interface{}) *gomock.Call + func (mr *MockUsersPersistenceInterfaceMockRecorder) GetAuthUniqueRecord(scheme, unique interface{}) *gomock.Call + func (mr *MockUsersPersistenceInterfaceMockRecorder) GetByCred(method, value interface{}) *gomock.Call + func (mr *MockUsersPersistenceInterfaceMockRecorder) GetChannels(id interface{}) *gomock.Call + func (mr *MockUsersPersistenceInterfaceMockRecorder) GetOwnTopics(id interface{}) *gomock.Call + func (mr *MockUsersPersistenceInterfaceMockRecorder) GetSubs(id interface{}) *gomock.Call + func (mr *MockUsersPersistenceInterfaceMockRecorder) GetTopics(id, opts interface{}) *gomock.Call + func (mr *MockUsersPersistenceInterfaceMockRecorder) GetTopicsAny(id, opts interface{}) *gomock.Call + func (mr *MockUsersPersistenceInterfaceMockRecorder) GetUnreadCount(ids ...interface{}) *gomock.Call + func (mr *MockUsersPersistenceInterfaceMockRecorder) Update(uid, update interface{}) *gomock.Call + func (mr *MockUsersPersistenceInterfaceMockRecorder) UpdateAuthRecord(uid, authLvl, scheme, unique, secret, expires interface{}) *gomock.Call + func (mr *MockUsersPersistenceInterfaceMockRecorder) UpdateLastSeen(uid, userAgent, when interface{}) *gomock.Call + func (mr *MockUsersPersistenceInterfaceMockRecorder) UpdateState(uid, state interface{}) *gomock.Call + func (mr *MockUsersPersistenceInterfaceMockRecorder) UpdateTags(uid, add, remove, reset interface{}) *gomock.Call + func (mr *MockUsersPersistenceInterfaceMockRecorder) UpsertCred(cred interface{}) *gomock.Call
Go to main page