mongo

func (this *Mongo) DeleteFcmToken(token model.FcmToken) (err error, errCode int)

func (this *Mongo) Disconnect()

func (this *Mongo) GetFcmTokens(userId string) (tokens []model.FcmToken, err error)

func (this *Mongo) HandlerBrokerMongoVaultConsistency(cleanupVaultKeys bool) (err error)

func (this *Mongo) ListBrokers(userId string, o persistence.ListOptions) (result []model.Broker, total int64, err error, errCode int)

func (this *Mongo) ListEnabledBrokers(userId string) (result []model.Broker, err error)

func (this *Mongo) ListNotifications(userId string, o persistence.ListOptions, topics []model.Topic) (result []model.Notification, total int64, err error, errCode int)

func (this *Mongo) MigrateSecretsToVault() (err error)

func (this *Mongo) ReadBroker(userId string, id string) (result model.Broker, err error, errCode int)

func (this *Mongo) ReadNotification(userId string, id string) (result model.Notification, err error, errCode int)

func (this *Mongo) ReadNotificationByHash(userId string, hash [32]byte, notOlderThan time.Time) (result model.Notification, err error, errCode int)

func (this *Mongo) ReadPlatformBroker(userId string) (result model.PlatformBroker, err error, errCode int)

func (this *Mongo) ReadSettings(userId string) (result model.Settings, err error, errCode int)

func (this *Mongo) RemoveBrokers(userId string, ids []string) (error, int)

func (this *Mongo) RemoveNotifications(userId string, ids []string) (error, int)

func (this *Mongo) RemovePlatformBroker(userId string) (error, int)

func (this *Mongo) SetBroker(broker model.Broker) (error, int)

func (this *Mongo) SetNotification(notification model.Notification) (error, int)

func (this *Mongo) SetPlatformBroker(broker model.PlatformBroker) (error, int)

func (this *Mongo) SetSettings(settings model.Settings) (error, int)

func (this *Mongo) UpsertFcmToken(token model.FcmToken) (err error, errCode int)