Documentation
¶
Index ¶
- Constants
- Variables
- func CheckRelationalIntegrity(ss *SqlSupplier, results chan<- store.IntegrityCheckResult)
- func IsUniqueConstraintError(err error, indexName []string) bool
- func MapStringsToQueryParams(list []string, paramPrefix string) (string, map[string]interface{})
- func NewChannelMemberFromModel(cm *model.ChannelMember) *channelMember
- func NewSqlAuditStore(sqlStore SqlStore) store.AuditStore
- func NewSqlBotStore(sqlStore SqlStore, metrics einterfaces.MetricsInterface) store.BotStore
- func NewSqlChannelMemberHistoryStore(sqlStore SqlStore) store.ChannelMemberHistoryStore
- func NewSqlChannelStore(sqlStore SqlStore, metrics einterfaces.MetricsInterface) store.ChannelStore
- func NewSqlClusterDiscoveryStore(sqlStore SqlStore) store.ClusterDiscoveryStore
- func NewSqlCommandStore(sqlStore SqlStore) store.CommandStore
- func NewSqlCommandWebhookStore(sqlStore SqlStore) store.CommandWebhookStore
- func NewSqlComplianceStore(sqlStore SqlStore) store.ComplianceStore
- func NewSqlEmojiStore(sqlStore SqlStore, metrics einterfaces.MetricsInterface) store.EmojiStore
- func NewSqlFileInfoStore(sqlStore SqlStore, metrics einterfaces.MetricsInterface) store.FileInfoStore
- func NewSqlGroupStore(sqlStore SqlStore) store.GroupStore
- func NewSqlJobStore(sqlStore SqlStore) store.JobStore
- func NewSqlLicenseStore(sqlStore SqlStore) store.LicenseStore
- func NewSqlLinkMetadataStore(sqlStore SqlStore) store.LinkMetadataStore
- func NewSqlOAuthStore(sqlStore SqlStore) store.OAuthStore
- func NewSqlPluginStore(sqlStore SqlStore) store.PluginStore
- func NewSqlPostStore(sqlStore SqlStore, metrics einterfaces.MetricsInterface) store.PostStore
- func NewSqlPreferenceStore(sqlStore SqlStore) store.PreferenceStore
- func NewSqlReactionStore(sqlStore SqlStore) store.ReactionStore
- func NewSqlRoleStore(sqlStore SqlStore) store.RoleStore
- func NewSqlSchemeStore(sqlStore SqlStore) store.SchemeStore
- func NewSqlSessionStore(sqlStore SqlStore) store.SessionStore
- func NewSqlStatusStore(sqlStore SqlStore) store.StatusStore
- func NewSqlSystemStore(sqlStore SqlStore) store.SystemStore
- func NewSqlTeamStore(sqlStore SqlStore) store.TeamStore
- func NewSqlTermsOfServiceStore(sqlStore SqlStore, metrics einterfaces.MetricsInterface) store.TermsOfServiceStore
- func NewSqlTokenStore(sqlStore SqlStore) store.TokenStore
- func NewSqlUserAccessTokenStore(sqlStore SqlStore) store.UserAccessTokenStore
- func NewSqlUserStore(sqlStore SqlStore, metrics einterfaces.MetricsInterface) store.UserStore
- func NewSqlUserTermsOfServiceStore(sqlStore SqlStore) store.UserTermsOfServiceStore
- func NewSqlWebhookStore(sqlStore SqlStore, metrics einterfaces.MetricsInterface) store.WebhookStore
- func NewTeamMemberFromModel(tm *model.TeamMember) *teamMember
- type JSONSerializable
- type Role
- type SqlAuditStore
- type SqlBotStore
- func (us SqlBotStore) CreateIndexesIfNotExists()
- func (us SqlBotStore) Get(botUserId string, includeDeleted bool) (*model.Bot, *model.AppError)
- func (us SqlBotStore) GetAll(options *model.BotGetOptions) ([]*model.Bot, *model.AppError)
- func (us SqlBotStore) PermanentDelete(botUserId string) *model.AppError
- func (us SqlBotStore) Save(bot *model.Bot) (*model.Bot, *model.AppError)
- func (us SqlBotStore) Update(bot *model.Bot) (*model.Bot, *model.AppError)
- type SqlChannelMemberHistoryStore
- func (s SqlChannelMemberHistoryStore) GetUsersInChannelDuring(startTime int64, endTime int64, channelId string) ([]*model.ChannelMemberHistoryResult, *model.AppError)
- func (s SqlChannelMemberHistoryStore) LogJoinEvent(userId string, channelId string, joinTime int64) *model.AppError
- func (s SqlChannelMemberHistoryStore) LogLeaveEvent(userId string, channelId string, leaveTime int64) *model.AppError
- func (s SqlChannelMemberHistoryStore) PermanentDeleteBatch(endTime int64, limit int64) (int64, *model.AppError)
- type SqlChannelStore
- func (s SqlChannelStore) AnalyticsDeletedTypeCount(teamId string, channelType string) (int64, *model.AppError)
- func (s SqlChannelStore) AnalyticsTypeCount(teamId string, channelType string) (int64, *model.AppError)
- func (s SqlChannelStore) AutocompleteInTeam(teamId string, term string, includeDeleted bool) (*model.ChannelList, *model.AppError)
- func (s SqlChannelStore) AutocompleteInTeamForSearch(teamId string, userId string, term string, includeDeleted bool) (*model.ChannelList, *model.AppError)
- func (s SqlChannelStore) ClearAllCustomRoleAssignments() *model.AppError
- func (s SqlChannelStore) ClearCaches()
- func (s SqlChannelStore) CountPostsAfter(channelId string, timestamp int64, userId string) (int, *model.AppError)
- func (s SqlChannelStore) CreateDirectChannel(user *model.User, otherUser *model.User) (*model.Channel, *model.AppError)
- func (s SqlChannelStore) CreateIndexesIfNotExists()
- func (s SqlChannelStore) Delete(channelId string, time int64) *model.AppError
- func (s SqlChannelStore) Get(id string, allowFromCache bool) (*model.Channel, *model.AppError)
- func (s SqlChannelStore) GetAll(teamId string) ([]*model.Channel, *model.AppError)
- func (s SqlChannelStore) GetAllChannelMembersForUser(userId string, allowFromCache bool, includeDeleted bool) (map[string]string, *model.AppError)
- func (s SqlChannelStore) GetAllChannelMembersNotifyPropsForChannel(channelId string, allowFromCache bool) (map[string]model.StringMap, *model.AppError)
- func (s SqlChannelStore) GetAllChannels(offset, limit int, opts store.ChannelSearchOpts) (*model.ChannelListWithTeamData, *model.AppError)
- func (s SqlChannelStore) GetAllChannelsCount(opts store.ChannelSearchOpts) (int64, *model.AppError)
- func (s SqlChannelStore) GetAllChannelsForExportAfter(limit int, afterId string) ([]*model.ChannelForExport, *model.AppError)
- func (s SqlChannelStore) GetAllDirectChannelsForExportAfter(limit int, afterId string) ([]*model.DirectChannelForExport, *model.AppError)
- func (s SqlChannelStore) GetByName(teamId string, name string, allowFromCache bool) (*model.Channel, *model.AppError)
- func (s SqlChannelStore) GetByNameIncludeDeleted(teamId string, name string, allowFromCache bool) (*model.Channel, *model.AppError)
- func (s SqlChannelStore) GetByNames(teamId string, names []string, allowFromCache bool) ([]*model.Channel, *model.AppError)
- func (s SqlChannelStore) GetChannelCounts(teamId string, userId string) (*model.ChannelCounts, *model.AppError)
- func (s SqlChannelStore) GetChannelMembersForExport(userId string, teamId string) ([]*model.ChannelMemberForExport, *model.AppError)
- func (s SqlChannelStore) GetChannelMembersTimezones(channelId string) ([]model.StringMap, *model.AppError)
- func (s SqlChannelStore) GetChannelUnread(channelId, userId string) (*model.ChannelUnread, *model.AppError)
- func (s SqlChannelStore) GetChannels(teamId string, userId string, includeDeleted bool) (*model.ChannelList, *model.AppError)
- func (s SqlChannelStore) GetChannelsBatchForIndexing(startTime, endTime int64, limit int) ([]*model.Channel, *model.AppError)
- func (s SqlChannelStore) GetChannelsByIds(channelIds []string) ([]*model.Channel, *model.AppError)
- func (s SqlChannelStore) GetChannelsByScheme(schemeId string, offset int, limit int) (model.ChannelList, *model.AppError)
- func (s SqlChannelStore) GetDeleted(teamId string, offset int, limit int, userId string) (*model.ChannelList, *model.AppError)
- func (s SqlChannelStore) GetDeletedByName(teamId string, name string) (*model.Channel, *model.AppError)
- func (s SqlChannelStore) GetForPost(postId string) (*model.Channel, *model.AppError)
- func (s SqlChannelStore) GetFromMaster(id string) (*model.Channel, *model.AppError)
- func (s SqlChannelStore) GetGuestCount(channelId string, allowFromCache bool) (int64, *model.AppError)
- func (s SqlChannelStore) GetMember(channelId string, userId string) (*model.ChannelMember, *model.AppError)
- func (s SqlChannelStore) GetMemberCount(channelId string, allowFromCache bool) (int64, *model.AppError)
- func (s SqlChannelStore) GetMemberCountFromCache(channelId string) int64
- func (s SqlChannelStore) GetMemberForPost(postId string, userId string) (*model.ChannelMember, *model.AppError)
- func (s SqlChannelStore) GetMembers(channelId string, offset, limit int) (*model.ChannelMembers, *model.AppError)
- func (s SqlChannelStore) GetMembersByIds(channelId string, userIds []string) (*model.ChannelMembers, *model.AppError)
- func (s SqlChannelStore) GetMembersForUser(teamId string, userId string) (*model.ChannelMembers, *model.AppError)
- func (s SqlChannelStore) GetMembersForUserWithPagination(teamId, userId string, page, perPage int) (*model.ChannelMembers, *model.AppError)
- func (s SqlChannelStore) GetMoreChannels(teamId string, userId string, offset int, limit int) (*model.ChannelList, *model.AppError)
- func (s SqlChannelStore) GetPinnedPostCount(channelId string, allowFromCache bool) (int64, *model.AppError)
- func (s SqlChannelStore) GetPinnedPosts(channelId string) (*model.PostList, *model.AppError)
- func (s SqlChannelStore) GetPublicChannelsByIdsForTeam(teamId string, channelIds []string) (*model.ChannelList, *model.AppError)
- func (s SqlChannelStore) GetPublicChannelsForTeam(teamId string, offset int, limit int) (*model.ChannelList, *model.AppError)
- func (s SqlChannelStore) GetTeamChannels(teamId string) (*model.ChannelList, *model.AppError)
- func (s SqlChannelStore) IncrementMentionCount(channelId string, userId string) *model.AppError
- func (s SqlChannelStore) InvalidateAllChannelMembersForUser(userId string)
- func (s SqlChannelStore) InvalidateCacheForChannelMembersNotifyProps(channelId string)
- func (s SqlChannelStore) InvalidateChannel(id string)
- func (s SqlChannelStore) InvalidateChannelByName(teamId, name string)
- func (s SqlChannelStore) InvalidateGuestCount(channelId string)
- func (s SqlChannelStore) InvalidateMemberCount(channelId string)
- func (s SqlChannelStore) InvalidatePinnedPostCount(channelId string)
- func (s SqlChannelStore) IsUserInChannelUseCache(userId string, channelId string) bool
- func (s SqlChannelStore) MigrateChannelMembers(fromChannelId string, fromUserId string) (map[string]string, *model.AppError)
- func (s SqlChannelStore) MigratePublicChannels() error
- func (s SqlChannelStore) PermanentDelete(channelId string) *model.AppError
- func (s SqlChannelStore) PermanentDeleteByTeam(teamId string) *model.AppError
- func (s SqlChannelStore) PermanentDeleteMembersByChannel(channelId string) *model.AppError
- func (s SqlChannelStore) PermanentDeleteMembersByUser(userId string) *model.AppError
- func (s SqlChannelStore) RemoveAllDeactivatedMembers(channelId string) *model.AppError
- func (s SqlChannelStore) RemoveMember(channelId string, userId string) *model.AppError
- func (s SqlChannelStore) ResetAllChannelSchemes() *model.AppError
- func (s SqlChannelStore) Restore(channelId string, time int64) *model.AppError
- func (s SqlChannelStore) Save(channel *model.Channel, maxChannelsPerTeam int64) (*model.Channel, *model.AppError)
- func (s SqlChannelStore) SaveDirectChannel(directchannel *model.Channel, member1 *model.ChannelMember, ...) (*model.Channel, *model.AppError)
- func (s SqlChannelStore) SaveMember(member *model.ChannelMember) (*model.ChannelMember, *model.AppError)
- func (s SqlChannelStore) SearchAllChannels(term string, opts store.ChannelSearchOpts) (*model.ChannelListWithTeamData, int64, *model.AppError)
- func (s SqlChannelStore) SearchArchivedInTeam(teamId string, term string, userId string) (*model.ChannelList, *model.AppError)
- func (s SqlChannelStore) SearchForUserInTeam(userId string, teamId string, term string, includeDeleted bool) (*model.ChannelList, *model.AppError)
- func (s SqlChannelStore) SearchGroupChannels(userId, term string) (*model.ChannelList, *model.AppError)
- func (s SqlChannelStore) SearchInTeam(teamId string, term string, includeDeleted bool) (*model.ChannelList, *model.AppError)
- func (s SqlChannelStore) SearchMore(userId string, teamId string, term string) (*model.ChannelList, *model.AppError)
- func (s SqlChannelStore) SetDeleteAt(channelId string, deleteAt, updateAt int64) *model.AppError
- func (s SqlChannelStore) Update(channel *model.Channel) (*model.Channel, *model.AppError)
- func (s SqlChannelStore) UpdateLastViewedAt(channelIds []string, userId string) (map[string]int64, *model.AppError)
- func (s SqlChannelStore) UpdateLastViewedAtPost(unreadPost *model.Post, userID string, mentionCount int) (*model.ChannelUnreadAt, *model.AppError)
- func (s SqlChannelStore) UpdateMember(member *model.ChannelMember) (*model.ChannelMember, *model.AppError)
- func (s SqlChannelStore) UpdateMembersRole(channelID string, userIDs []string) *model.AppError
- func (s SqlChannelStore) UserBelongsToChannels(userId string, channelIds []string) (bool, *model.AppError)
- type SqlCommandStore
- func (s SqlCommandStore) AnalyticsCommandCount(teamId string) (int64, *model.AppError)
- func (s SqlCommandStore) CreateIndexesIfNotExists()
- func (s SqlCommandStore) Delete(commandId string, time int64) *model.AppError
- func (s SqlCommandStore) Get(id string) (*model.Command, *model.AppError)
- func (s SqlCommandStore) GetByTeam(teamId string) ([]*model.Command, *model.AppError)
- func (s SqlCommandStore) GetByTrigger(teamId string, trigger string) (*model.Command, *model.AppError)
- func (s SqlCommandStore) PermanentDeleteByTeam(teamId string) *model.AppError
- func (s SqlCommandStore) PermanentDeleteByUser(userId string) *model.AppError
- func (s SqlCommandStore) Save(command *model.Command) (*model.Command, *model.AppError)
- func (s SqlCommandStore) Update(cmd *model.Command) (*model.Command, *model.AppError)
- type SqlCommandWebhookStore
- func (s SqlCommandWebhookStore) Cleanup()
- func (s SqlCommandWebhookStore) CreateIndexesIfNotExists()
- func (s SqlCommandWebhookStore) Get(id string) (*model.CommandWebhook, *model.AppError)
- func (s SqlCommandWebhookStore) Save(webhook *model.CommandWebhook) (*model.CommandWebhook, *model.AppError)
- func (s SqlCommandWebhookStore) TryUse(id string, limit int) *model.AppError
- type SqlComplianceStore
- func (s SqlComplianceStore) ComplianceExport(job *model.Compliance) ([]*model.CompliancePost, *model.AppError)
- func (s SqlComplianceStore) CreateIndexesIfNotExists()
- func (s SqlComplianceStore) Get(id string) (*model.Compliance, *model.AppError)
- func (s SqlComplianceStore) GetAll(offset, limit int) (model.Compliances, *model.AppError)
- func (s SqlComplianceStore) MessageExport(after int64, limit int) ([]*model.MessageExport, *model.AppError)
- func (s SqlComplianceStore) Save(compliance *model.Compliance) (*model.Compliance, *model.AppError)
- func (s SqlComplianceStore) Update(compliance *model.Compliance) (*model.Compliance, *model.AppError)
- type SqlEmojiStore
- func (es SqlEmojiStore) CreateIndexesIfNotExists()
- func (es SqlEmojiStore) Delete(emoji *model.Emoji, time int64) *model.AppError
- func (es SqlEmojiStore) Get(id string, allowFromCache bool) (*model.Emoji, *model.AppError)
- func (es SqlEmojiStore) GetByName(name string, allowFromCache bool) (*model.Emoji, *model.AppError)
- func (es SqlEmojiStore) GetList(offset, limit int, sort string) ([]*model.Emoji, *model.AppError)
- func (es SqlEmojiStore) GetMultipleByName(names []string) ([]*model.Emoji, *model.AppError)
- func (es SqlEmojiStore) Save(emoji *model.Emoji) (*model.Emoji, *model.AppError)
- func (es SqlEmojiStore) Search(name string, prefixOnly bool, limit int) ([]*model.Emoji, *model.AppError)
- type SqlFileInfoStore
- func (fs SqlFileInfoStore) AttachToPost(fileId, postId, creatorId string) *model.AppError
- func (fs SqlFileInfoStore) ClearCaches()
- func (fs SqlFileInfoStore) CreateIndexesIfNotExists()
- func (fs SqlFileInfoStore) DeleteForPost(postId string) (string, *model.AppError)
- func (fs SqlFileInfoStore) Get(id string) (*model.FileInfo, *model.AppError)
- func (fs SqlFileInfoStore) GetByPath(path string) (*model.FileInfo, *model.AppError)
- func (fs SqlFileInfoStore) GetForPost(postId string, readFromMaster, includeDeleted, allowFromCache bool) ([]*model.FileInfo, *model.AppError)
- func (fs SqlFileInfoStore) GetForUser(userId string) ([]*model.FileInfo, *model.AppError)
- func (fs SqlFileInfoStore) InvalidateFileInfosForPostCache(postId string)
- func (fs SqlFileInfoStore) PermanentDelete(fileId string) *model.AppError
- func (fs SqlFileInfoStore) PermanentDeleteBatch(endTime int64, limit int64) (int64, *model.AppError)
- func (fs SqlFileInfoStore) PermanentDeleteByUser(userId string) (int64, *model.AppError)
- func (fs SqlFileInfoStore) Save(info *model.FileInfo) (*model.FileInfo, *model.AppError)
- type SqlGroupStore
- func (s *SqlGroupStore) AdminRoleGroupsForSyncableMember(userID, syncableID string, syncableType model.GroupSyncableType) ([]string, *model.AppError)
- func (s *SqlGroupStore) ChannelMembersMinusGroupMembers(channelID string, groupIDs []string, page, perPage int) ([]*model.UserWithGroups, *model.AppError)
- func (s *SqlGroupStore) ChannelMembersToAdd(since int64, channelID *string) ([]*model.UserChannelIDPair, *model.AppError)
- func (s *SqlGroupStore) ChannelMembersToRemove(channelID *string) ([]*model.ChannelMember, *model.AppError)
- func (s *SqlGroupStore) CountChannelMembersMinusGroupMembers(channelID string, groupIDs []string) (int64, *model.AppError)
- func (s *SqlGroupStore) CountGroupsByChannel(channelId string, opts model.GroupSearchOpts) (int64, *model.AppError)
- func (s *SqlGroupStore) CountGroupsByTeam(teamId string, opts model.GroupSearchOpts) (int64, *model.AppError)
- func (s *SqlGroupStore) CountTeamMembersMinusGroupMembers(teamID string, groupIDs []string) (int64, *model.AppError)
- func (s *SqlGroupStore) Create(group *model.Group) (*model.Group, *model.AppError)
- func (s *SqlGroupStore) CreateGroupSyncable(groupSyncable *model.GroupSyncable) (*model.GroupSyncable, *model.AppError)
- func (s *SqlGroupStore) CreateIndexesIfNotExists()
- func (s *SqlGroupStore) Delete(groupID string) (*model.Group, *model.AppError)
- func (s *SqlGroupStore) DeleteGroupSyncable(groupID string, syncableID string, syncableType model.GroupSyncableType) (*model.GroupSyncable, *model.AppError)
- func (s *SqlGroupStore) DeleteMember(groupID string, userID string) (*model.GroupMember, *model.AppError)
- func (s *SqlGroupStore) Get(groupId string) (*model.Group, *model.AppError)
- func (s *SqlGroupStore) GetAllBySource(groupSource model.GroupSource) ([]*model.Group, *model.AppError)
- func (s *SqlGroupStore) GetAllGroupSyncablesByGroupId(groupID string, syncableType model.GroupSyncableType) ([]*model.GroupSyncable, *model.AppError)
- func (s *SqlGroupStore) GetByIDs(groupIDs []string) ([]*model.Group, *model.AppError)
- func (s *SqlGroupStore) GetByName(name string) (*model.Group, *model.AppError)
- func (s *SqlGroupStore) GetByRemoteID(remoteID string, groupSource model.GroupSource) (*model.Group, *model.AppError)
- func (s *SqlGroupStore) GetByUser(userId string) ([]*model.Group, *model.AppError)
- func (s *SqlGroupStore) GetGroupSyncable(groupID string, syncableID string, syncableType model.GroupSyncableType) (*model.GroupSyncable, *model.AppError)
- func (s *SqlGroupStore) GetGroups(page, perPage int, opts model.GroupSearchOpts) ([]*model.Group, *model.AppError)
- func (s *SqlGroupStore) GetGroupsByChannel(channelId string, opts model.GroupSearchOpts) ([]*model.GroupWithSchemeAdmin, *model.AppError)
- func (s *SqlGroupStore) GetGroupsByTeam(teamId string, opts model.GroupSearchOpts) ([]*model.GroupWithSchemeAdmin, *model.AppError)
- func (s *SqlGroupStore) GetMemberCount(groupID string) (int64, *model.AppError)
- func (s *SqlGroupStore) GetMemberUsers(groupID string) ([]*model.User, *model.AppError)
- func (s *SqlGroupStore) GetMemberUsersPage(groupID string, page int, perPage int) ([]*model.User, *model.AppError)
- func (s *SqlGroupStore) PermanentDeleteMembersByUser(userId string) *model.AppError
- func (s *SqlGroupStore) PermittedSyncableAdmins(syncableID string, syncableType model.GroupSyncableType) ([]string, *model.AppError)
- func (s *SqlGroupStore) TeamMembersMinusGroupMembers(teamID string, groupIDs []string, page, perPage int) ([]*model.UserWithGroups, *model.AppError)
- func (s *SqlGroupStore) TeamMembersToAdd(since int64, teamID *string) ([]*model.UserTeamIDPair, *model.AppError)
- func (s *SqlGroupStore) TeamMembersToRemove(teamID *string) ([]*model.TeamMember, *model.AppError)
- func (s *SqlGroupStore) Update(group *model.Group) (*model.Group, *model.AppError)
- func (s *SqlGroupStore) UpdateGroupSyncable(groupSyncable *model.GroupSyncable) (*model.GroupSyncable, *model.AppError)
- func (s *SqlGroupStore) UpsertMember(groupID string, userID string) (*model.GroupMember, *model.AppError)
- type SqlJobStore
- func (jss SqlJobStore) CreateIndexesIfNotExists()
- func (jss SqlJobStore) Delete(id string) (string, *model.AppError)
- func (jss SqlJobStore) Get(id string) (*model.Job, *model.AppError)
- func (jss SqlJobStore) GetAllByStatus(status string) ([]*model.Job, *model.AppError)
- func (jss SqlJobStore) GetAllByType(jobType string) ([]*model.Job, *model.AppError)
- func (jss SqlJobStore) GetAllByTypePage(jobType string, offset int, limit int) ([]*model.Job, *model.AppError)
- func (jss SqlJobStore) GetAllPage(offset int, limit int) ([]*model.Job, *model.AppError)
- func (jss SqlJobStore) GetCountByStatusAndType(status string, jobType string) (int64, *model.AppError)
- func (jss SqlJobStore) GetNewestJobByStatusAndType(status string, jobType string) (*model.Job, *model.AppError)
- func (jss SqlJobStore) Save(job *model.Job) (*model.Job, *model.AppError)
- func (jss SqlJobStore) UpdateOptimistically(job *model.Job, currentStatus string) (bool, *model.AppError)
- func (jss SqlJobStore) UpdateStatus(id string, status string) (*model.Job, *model.AppError)
- func (jss SqlJobStore) UpdateStatusOptimistically(id string, currentStatus string, newStatus string) (bool, *model.AppError)
- type SqlLicenseStore
- type SqlLinkMetadataStore
- type SqlOAuthStore
- func (as SqlOAuthStore) CreateIndexesIfNotExists()
- func (as SqlOAuthStore) DeleteApp(id string) *model.AppError
- func (as SqlOAuthStore) GetAccessData(token string) (*model.AccessData, *model.AppError)
- func (as SqlOAuthStore) GetAccessDataByRefreshToken(token string) (*model.AccessData, *model.AppError)
- func (as SqlOAuthStore) GetAccessDataByUserForApp(userId, clientId string) ([]*model.AccessData, *model.AppError)
- func (as SqlOAuthStore) GetApp(id string) (*model.OAuthApp, *model.AppError)
- func (as SqlOAuthStore) GetAppByUser(userId string, offset, limit int) ([]*model.OAuthApp, *model.AppError)
- func (as SqlOAuthStore) GetApps(offset, limit int) ([]*model.OAuthApp, *model.AppError)
- func (as SqlOAuthStore) GetAuthData(code string) (*model.AuthData, *model.AppError)
- func (as SqlOAuthStore) GetAuthorizedApps(userId string, offset, limit int) ([]*model.OAuthApp, *model.AppError)
- func (as SqlOAuthStore) GetPreviousAccessData(userId, clientId string) (*model.AccessData, *model.AppError)
- func (as SqlOAuthStore) PermanentDeleteAuthDataByUser(userId string) *model.AppError
- func (as SqlOAuthStore) RemoveAccessData(token string) *model.AppError
- func (as SqlOAuthStore) RemoveAllAccessData() *model.AppError
- func (as SqlOAuthStore) RemoveAuthData(code string) *model.AppError
- func (as SqlOAuthStore) SaveAccessData(accessData *model.AccessData) (*model.AccessData, *model.AppError)
- func (as SqlOAuthStore) SaveApp(app *model.OAuthApp) (*model.OAuthApp, *model.AppError)
- func (as SqlOAuthStore) SaveAuthData(authData *model.AuthData) (*model.AuthData, *model.AppError)
- func (as SqlOAuthStore) UpdateAccessData(accessData *model.AccessData) (*model.AccessData, *model.AppError)
- func (as SqlOAuthStore) UpdateApp(app *model.OAuthApp) (*model.OAuthApp, *model.AppError)
- type SqlPluginStore
- func (ps SqlPluginStore) CompareAndDelete(kv *model.PluginKeyValue, oldValue []byte) (bool, *model.AppError)
- func (ps SqlPluginStore) CompareAndSet(kv *model.PluginKeyValue, oldValue []byte) (bool, *model.AppError)
- func (ps SqlPluginStore) CreateIndexesIfNotExists()
- func (ps SqlPluginStore) Delete(pluginId, key string) *model.AppError
- func (ps SqlPluginStore) DeleteAllExpired() *model.AppError
- func (ps SqlPluginStore) DeleteAllForPlugin(pluginId string) *model.AppError
- func (ps SqlPluginStore) Get(pluginId, key string) (*model.PluginKeyValue, *model.AppError)
- func (ps SqlPluginStore) List(pluginId string, offset int, limit int) ([]string, *model.AppError)
- func (ps SqlPluginStore) SaveOrUpdate(kv *model.PluginKeyValue) (*model.PluginKeyValue, *model.AppError)
- func (ps SqlPluginStore) SetWithOptions(pluginId string, key string, value []byte, opt model.PluginKVSetOptions) (bool, *model.AppError)
- type SqlPostStore
- func (s *SqlPostStore) AnalyticsPostCount(teamId string, mustHaveFile bool, mustHaveHashtag bool) (int64, *model.AppError)
- func (s *SqlPostStore) AnalyticsPostCountsByDay(options *model.AnalyticsPostCountsOptions) (model.AnalyticsRows, *model.AppError)
- func (s *SqlPostStore) AnalyticsUserCountsWithPostsByDay(teamId string) (model.AnalyticsRows, *model.AppError)
- func (s *SqlPostStore) ClearCaches()
- func (s *SqlPostStore) CreateIndexesIfNotExists()
- func (s *SqlPostStore) Delete(postId string, time int64, deleteByID string) *model.AppError
- func (s *SqlPostStore) Get(id string) (*model.PostList, *model.AppError)
- func (s *SqlPostStore) GetDirectPostParentsForExportAfter(limit int, afterId string) ([]*model.DirectPostForExport, *model.AppError)
- func (s *SqlPostStore) GetEtag(channelId string, allowFromCache bool) string
- func (s *SqlPostStore) GetFlaggedPosts(userId string, offset int, limit int) (*model.PostList, *model.AppError)
- func (s *SqlPostStore) GetFlaggedPostsForChannel(userId, channelId string, offset int, limit int) (*model.PostList, *model.AppError)
- func (s *SqlPostStore) GetFlaggedPostsForTeam(userId, teamId string, offset int, limit int) (*model.PostList, *model.AppError)
- func (s *SqlPostStore) GetMaxPostSize() int
- func (s *SqlPostStore) GetOldest() (*model.Post, *model.AppError)
- func (s *SqlPostStore) GetParentsForExportAfter(limit int, afterId string) ([]*model.PostForExport, *model.AppError)
- func (s *SqlPostStore) GetPostAfterTime(channelId string, time int64) (*model.Post, *model.AppError)
- func (s *SqlPostStore) GetPostIdAfterTime(channelId string, time int64) (string, *model.AppError)
- func (s *SqlPostStore) GetPostIdBeforeTime(channelId string, time int64) (string, *model.AppError)
- func (s *SqlPostStore) GetPosts(channelId string, offset int, limit int, allowFromCache bool) (*model.PostList, *model.AppError)
- func (s *SqlPostStore) GetPostsAfter(channelId string, postId string, limit int, offset int) (*model.PostList, *model.AppError)
- func (s *SqlPostStore) GetPostsBatchForIndexing(startTime int64, endTime int64, limit int) ([]*model.PostForIndexing, *model.AppError)
- func (s *SqlPostStore) GetPostsBefore(channelId string, postId string, limit int, offset int) (*model.PostList, *model.AppError)
- func (s *SqlPostStore) GetPostsByIds(postIds []string) ([]*model.Post, *model.AppError)
- func (s *SqlPostStore) GetPostsCreatedAt(channelId string, time int64) ([]*model.Post, *model.AppError)
- func (s *SqlPostStore) GetPostsSince(channelId string, time int64, allowFromCache bool) (*model.PostList, *model.AppError)
- func (s *SqlPostStore) GetRepliesForExport(rootId string) ([]*model.ReplyForExport, *model.AppError)
- func (s *SqlPostStore) GetSingle(id string) (*model.Post, *model.AppError)
- func (s *SqlPostStore) InvalidateLastPostTimeCache(channelId string)
- func (s *SqlPostStore) Overwrite(post *model.Post) (*model.Post, *model.AppError)
- func (s *SqlPostStore) PermanentDeleteBatch(endTime int64, limit int64) (int64, *model.AppError)
- func (s *SqlPostStore) PermanentDeleteByChannel(channelId string) *model.AppError
- func (s *SqlPostStore) PermanentDeleteByUser(userId string) *model.AppError
- func (s *SqlPostStore) Save(post *model.Post) (*model.Post, *model.AppError)
- func (s *SqlPostStore) Search(teamId string, userId string, params *model.SearchParams) (*model.PostList, *model.AppError)
- func (s *SqlPostStore) Update(newPost *model.Post, oldPost *model.Post) (*model.Post, *model.AppError)
- type SqlPreferenceStore
- func (s SqlPreferenceStore) CleanupFlagsBatch(limit int64) (int64, *model.AppError)
- func (s SqlPreferenceStore) CreateIndexesIfNotExists()
- func (s SqlPreferenceStore) Delete(userId, category, name string) *model.AppError
- func (s SqlPreferenceStore) DeleteCategory(userId string, category string) *model.AppError
- func (s SqlPreferenceStore) DeleteCategoryAndName(category string, name string) *model.AppError
- func (s SqlPreferenceStore) DeleteUnusedFeatures()
- func (s SqlPreferenceStore) Get(userId string, category string, name string) (*model.Preference, *model.AppError)
- func (s SqlPreferenceStore) GetAll(userId string) (model.Preferences, *model.AppError)
- func (s SqlPreferenceStore) GetCategory(userId string, category string) (model.Preferences, *model.AppError)
- func (s SqlPreferenceStore) PermanentDeleteByUser(userId string) *model.AppError
- func (s SqlPreferenceStore) Save(preferences *model.Preferences) *model.AppError
- type SqlReactionStore
- func (s *SqlReactionStore) BulkGetForPosts(postIds []string) ([]*model.Reaction, *model.AppError)
- func (s SqlReactionStore) CreateIndexesIfNotExists()
- func (s *SqlReactionStore) Delete(reaction *model.Reaction) (*model.Reaction, *model.AppError)
- func (s *SqlReactionStore) DeleteAllWithEmojiName(emojiName string) *model.AppError
- func (s *SqlReactionStore) GetForPost(postId string, allowFromCache bool) ([]*model.Reaction, *model.AppError)
- func (s *SqlReactionStore) PermanentDeleteBatch(endTime int64, limit int64) (int64, *model.AppError)
- func (s *SqlReactionStore) Save(reaction *model.Reaction) (*model.Reaction, *model.AppError)
- type SqlRoleStore
- func (s SqlRoleStore) CreateIndexesIfNotExists()
- func (s *SqlRoleStore) Delete(roleId string) (*model.Role, *model.AppError)
- func (s *SqlRoleStore) Get(roleId string) (*model.Role, *model.AppError)
- func (s *SqlRoleStore) GetAll() ([]*model.Role, *model.AppError)
- func (s *SqlRoleStore) GetByName(name string) (*model.Role, *model.AppError)
- func (s *SqlRoleStore) GetByNames(names []string) ([]*model.Role, *model.AppError)
- func (s *SqlRoleStore) PermanentDeleteAll() *model.AppError
- func (s *SqlRoleStore) Save(role *model.Role) (*model.Role, *model.AppError)
- type SqlSchemeStore
- func (s SqlSchemeStore) CreateIndexesIfNotExists()
- func (s *SqlSchemeStore) Delete(schemeId string) (*model.Scheme, *model.AppError)
- func (s *SqlSchemeStore) Get(schemeId string) (*model.Scheme, *model.AppError)
- func (s *SqlSchemeStore) GetAllPage(scope string, offset int, limit int) ([]*model.Scheme, *model.AppError)
- func (s *SqlSchemeStore) GetByName(schemeName string) (*model.Scheme, *model.AppError)
- func (s *SqlSchemeStore) PermanentDeleteAll() *model.AppError
- func (s *SqlSchemeStore) Save(scheme *model.Scheme) (*model.Scheme, *model.AppError)
- type SqlSessionStore
- func (me SqlSessionStore) AnalyticsSessionCount() (int64, *model.AppError)
- func (me SqlSessionStore) Cleanup(expiryTime int64, batchSize int64)
- func (me SqlSessionStore) CreateIndexesIfNotExists()
- func (me SqlSessionStore) Get(sessionIdOrToken string) (*model.Session, *model.AppError)
- func (me SqlSessionStore) GetSessions(userId string) ([]*model.Session, *model.AppError)
- func (me SqlSessionStore) GetSessionsWithActiveDeviceIds(userId string) ([]*model.Session, *model.AppError)
- func (me SqlSessionStore) PermanentDeleteSessionsByUser(userId string) *model.AppError
- func (me SqlSessionStore) Remove(sessionIdOrToken string) *model.AppError
- func (me SqlSessionStore) RemoveAllSessions() *model.AppError
- func (me SqlSessionStore) Save(session *model.Session) (*model.Session, *model.AppError)
- func (me SqlSessionStore) UpdateDeviceId(id string, deviceId string, expiresAt int64) (string, *model.AppError)
- func (me SqlSessionStore) UpdateLastActivityAt(sessionId string, time int64) *model.AppError
- func (me SqlSessionStore) UpdateProps(session *model.Session) *model.AppError
- func (me SqlSessionStore) UpdateRoles(userId, roles string) (string, *model.AppError)
- type SqlStatusStore
- func (s SqlStatusStore) CreateIndexesIfNotExists()
- func (s SqlStatusStore) Get(userId string) (*model.Status, *model.AppError)
- func (s SqlStatusStore) GetByIds(userIds []string) ([]*model.Status, *model.AppError)
- func (s SqlStatusStore) GetTotalActiveUsersCount() (int64, *model.AppError)
- func (s SqlStatusStore) ResetAll() *model.AppError
- func (s SqlStatusStore) SaveOrUpdate(status *model.Status) *model.AppError
- func (s SqlStatusStore) UpdateLastActivityAt(userId string, lastActivityAt int64) *model.AppError
- type SqlStore
- type SqlSupplier
- func (ss *SqlSupplier) AlterColumnDefaultIfExists(tableName string, columnName string, mySqlColDefault *string, ...) bool
- func (ss *SqlSupplier) AlterColumnTypeIfExists(tableName string, columnName string, mySqlColType string, ...) bool
- func (ss *SqlSupplier) Audit() store.AuditStore
- func (ss *SqlSupplier) Bot() store.BotStore
- func (ss *SqlSupplier) Channel() store.ChannelStore
- func (ss *SqlSupplier) ChannelMemberHistory() store.ChannelMemberHistoryStore
- func (ss *SqlSupplier) CheckIntegrity() <-chan store.IntegrityCheckResult
- func (ss *SqlSupplier) Close()
- func (ss *SqlSupplier) ClusterDiscovery() store.ClusterDiscoveryStore
- func (ss *SqlSupplier) Command() store.CommandStore
- func (ss *SqlSupplier) CommandWebhook() store.CommandWebhookStore
- func (ss *SqlSupplier) Compliance() store.ComplianceStore
- func (ss *SqlSupplier) CreateColumnIfNotExists(tableName string, columnName string, mySqlColType string, ...) bool
- func (ss *SqlSupplier) CreateColumnIfNotExistsNoDefault(tableName string, columnName string, mySqlColType string, ...) bool
- func (ss *SqlSupplier) CreateCompositeIndexIfNotExists(indexName string, tableName string, columnNames []string) bool
- func (ss *SqlSupplier) CreateFullTextIndexIfNotExists(indexName string, tableName string, columnName string) bool
- func (ss *SqlSupplier) CreateIndexIfNotExists(indexName string, tableName string, columnName string) bool
- func (ss *SqlSupplier) CreateUniqueIndexIfNotExists(indexName string, tableName string, columnName string) bool
- func (ss *SqlSupplier) DoesColumnExist(tableName string, columnName string) bool
- func (ss *SqlSupplier) DoesTableExist(tableName string) bool
- func (ss *SqlSupplier) DoesTriggerExist(triggerName string) bool
- func (ss *SqlSupplier) DriverName() string
- func (ss *SqlSupplier) DropAllTables()
- func (ss *SqlSupplier) Emoji() store.EmojiStore
- func (ss *SqlSupplier) FileInfo() store.FileInfoStore
- func (ss *SqlSupplier) GetAllConns() []*gorp.DbMap
- func (ss *SqlSupplier) GetCurrentSchemaVersion() string
- func (ss *SqlSupplier) GetMaster() *gorp.DbMap
- func (ss *SqlSupplier) GetMaxLengthOfColumnIfExists(tableName string, columnName string) string
- func (ss *SqlSupplier) GetReplica() *gorp.DbMap
- func (ss *SqlSupplier) GetSearchReplica() *gorp.DbMap
- func (ss *SqlSupplier) Group() store.GroupStore
- func (ss *SqlSupplier) Job() store.JobStore
- func (ss *SqlSupplier) License() store.LicenseStore
- func (ss *SqlSupplier) LinkMetadata() store.LinkMetadataStore
- func (ss *SqlSupplier) LockToMaster()
- func (ss *SqlSupplier) MarkSystemRanUnitTests()
- func (ss *SqlSupplier) OAuth() store.OAuthStore
- func (ss *SqlSupplier) Plugin() store.PluginStore
- func (ss *SqlSupplier) Post() store.PostStore
- func (ss *SqlSupplier) Preference() store.PreferenceStore
- func (ss *SqlSupplier) Reaction() store.ReactionStore
- func (ss *SqlSupplier) RemoveColumnIfExists(tableName string, columnName string) bool
- func (ss *SqlSupplier) RemoveIndexIfExists(indexName string, tableName string) bool
- func (ss *SqlSupplier) RemoveTableIfExists(tableName string) bool
- func (ss *SqlSupplier) RenameColumnIfExists(tableName string, oldColumnName string, newColumnName string, colType string) bool
- func (ss *SqlSupplier) Role() store.RoleStore
- func (ss *SqlSupplier) Scheme() store.SchemeStore
- func (ss *SqlSupplier) Session() store.SessionStore
- func (ss *SqlSupplier) Status() store.StatusStore
- func (ss *SqlSupplier) System() store.SystemStore
- func (ss *SqlSupplier) Team() store.TeamStore
- func (ss *SqlSupplier) TermsOfService() store.TermsOfServiceStore
- func (ss *SqlSupplier) Token() store.TokenStore
- func (ss *SqlSupplier) TotalMasterDbConnections() int
- func (ss *SqlSupplier) TotalReadDbConnections() int
- func (ss *SqlSupplier) TotalSearchDbConnections() int
- func (ss *SqlSupplier) UnlockFromMaster()
- func (ss *SqlSupplier) User() store.UserStore
- func (ss *SqlSupplier) UserAccessToken() store.UserAccessTokenStore
- func (ss *SqlSupplier) UserTermsOfService() store.UserTermsOfServiceStore
- func (ss *SqlSupplier) Webhook() store.WebhookStore
- type SqlSupplierStores
- type SqlSystemStore
- func (s SqlSystemStore) CreateIndexesIfNotExists()
- func (s SqlSystemStore) Get() (model.StringMap, *model.AppError)
- func (s SqlSystemStore) GetByName(name string) (*model.System, *model.AppError)
- func (s SqlSystemStore) PermanentDeleteByName(name string) (*model.System, *model.AppError)
- func (s SqlSystemStore) Save(system *model.System) *model.AppError
- func (s SqlSystemStore) SaveOrUpdate(system *model.System) *model.AppError
- func (s SqlSystemStore) Update(system *model.System) *model.AppError
- type SqlTeamStore
- func (s SqlTeamStore) AnalyticsGetTeamCountForScheme(schemeId string) (int64, *model.AppError)
- func (s SqlTeamStore) AnalyticsPrivateTeamCount() (int64, *model.AppError)
- func (s SqlTeamStore) AnalyticsPublicTeamCount() (int64, *model.AppError)
- func (s SqlTeamStore) AnalyticsTeamCount(includeDeleted bool) (int64, *model.AppError)
- func (s SqlTeamStore) ClearAllCustomRoleAssignments() *model.AppError
- func (s SqlTeamStore) ClearCaches()
- func (s SqlTeamStore) CreateIndexesIfNotExists()
- func (s SqlTeamStore) Get(id string) (*model.Team, *model.AppError)
- func (s SqlTeamStore) GetActiveMemberCount(teamId string, restrictions *model.ViewUsersRestrictions) (int64, *model.AppError)
- func (s SqlTeamStore) GetAll() ([]*model.Team, *model.AppError)
- func (s SqlTeamStore) GetAllForExportAfter(limit int, afterId string) ([]*model.TeamForExport, *model.AppError)
- func (s SqlTeamStore) GetAllPage(offset int, limit int) ([]*model.Team, *model.AppError)
- func (s SqlTeamStore) GetAllPrivateTeamListing() ([]*model.Team, *model.AppError)
- func (s SqlTeamStore) GetAllPrivateTeamPageListing(offset int, limit int) ([]*model.Team, *model.AppError)
- func (s SqlTeamStore) GetAllPublicTeamPageListing(offset int, limit int) ([]*model.Team, *model.AppError)
- func (s SqlTeamStore) GetAllTeamListing() ([]*model.Team, *model.AppError)
- func (s SqlTeamStore) GetAllTeamPageListing(offset int, limit int) ([]*model.Team, *model.AppError)
- func (s SqlTeamStore) GetByInviteId(inviteId string) (*model.Team, *model.AppError)
- func (s SqlTeamStore) GetByName(name string) (*model.Team, *model.AppError)
- func (s SqlTeamStore) GetChannelUnreadsForAllTeams(excludeTeamId, userId string) ([]*model.ChannelUnread, *model.AppError)
- func (s SqlTeamStore) GetChannelUnreadsForTeam(teamId, userId string) ([]*model.ChannelUnread, *model.AppError)
- func (s SqlTeamStore) GetMember(teamId string, userId string) (*model.TeamMember, *model.AppError)
- func (s SqlTeamStore) GetMembers(teamId string, offset int, limit int, ...) ([]*model.TeamMember, *model.AppError)
- func (s SqlTeamStore) GetMembersByIds(teamId string, userIds []string, restrictions *model.ViewUsersRestrictions) ([]*model.TeamMember, *model.AppError)
- func (s SqlTeamStore) GetTeamMembersForExport(userId string) ([]*model.TeamMemberForExport, *model.AppError)
- func (s SqlTeamStore) GetTeamsByScheme(schemeId string, offset int, limit int) ([]*model.Team, *model.AppError)
- func (s SqlTeamStore) GetTeamsByUserId(userId string) ([]*model.Team, *model.AppError)
- func (s SqlTeamStore) GetTeamsForUser(userId string) ([]*model.TeamMember, *model.AppError)
- func (s SqlTeamStore) GetTeamsForUserWithPagination(userId string, page, perPage int) ([]*model.TeamMember, *model.AppError)
- func (s SqlTeamStore) GetTotalMemberCount(teamId string, restrictions *model.ViewUsersRestrictions) (int64, *model.AppError)
- func (s SqlTeamStore) GetUserTeamIds(userID string, allowFromCache bool) ([]string, *model.AppError)
- func (s SqlTeamStore) InvalidateAllTeamIdsForUser(userId string)
- func (s SqlTeamStore) MigrateTeamMembers(fromTeamId string, fromUserId string) (map[string]string, *model.AppError)
- func (s SqlTeamStore) PermanentDelete(teamId string) *model.AppError
- func (s SqlTeamStore) RemoveAllMembersByTeam(teamId string) *model.AppError
- func (s SqlTeamStore) RemoveAllMembersByUser(userId string) *model.AppError
- func (s SqlTeamStore) RemoveMember(teamId string, userId string) *model.AppError
- func (s SqlTeamStore) ResetAllTeamSchemes() *model.AppError
- func (s SqlTeamStore) Save(team *model.Team) (*model.Team, *model.AppError)
- func (s SqlTeamStore) SaveMember(member *model.TeamMember, maxUsersPerTeam int) (*model.TeamMember, *model.AppError)
- func (s SqlTeamStore) SearchAll(term string) ([]*model.Team, *model.AppError)
- func (s SqlTeamStore) SearchAllPaged(term string, page int, perPage int) ([]*model.Team, int64, *model.AppError)
- func (s SqlTeamStore) SearchOpen(term string) ([]*model.Team, *model.AppError)
- func (s SqlTeamStore) SearchPrivate(term string) ([]*model.Team, *model.AppError)
- func (s SqlTeamStore) Update(team *model.Team) (*model.Team, *model.AppError)
- func (s SqlTeamStore) UpdateLastTeamIconUpdate(teamId string, curTime int64) *model.AppError
- func (s SqlTeamStore) UpdateMember(member *model.TeamMember) (*model.TeamMember, *model.AppError)
- func (s SqlTeamStore) UpdateMembersRole(teamID string, userIDs []string) *model.AppError
- func (s SqlTeamStore) UserBelongsToTeams(userId string, teamIds []string) (bool, *model.AppError)
- type SqlTermsOfServiceStore
- func (s SqlTermsOfServiceStore) CreateIndexesIfNotExists()
- func (s SqlTermsOfServiceStore) Get(id string, allowFromCache bool) (*model.TermsOfService, *model.AppError)
- func (s SqlTermsOfServiceStore) GetLatest(allowFromCache bool) (*model.TermsOfService, *model.AppError)
- func (s SqlTermsOfServiceStore) Save(termsOfService *model.TermsOfService) (*model.TermsOfService, *model.AppError)
- type SqlTokenStore
- func (s SqlTokenStore) Cleanup()
- func (s SqlTokenStore) CreateIndexesIfNotExists()
- func (s SqlTokenStore) Delete(token string) *model.AppError
- func (s SqlTokenStore) GetByToken(tokenString string) (*model.Token, *model.AppError)
- func (s SqlTokenStore) RemoveAllTokensByType(tokenType string) *model.AppError
- func (s SqlTokenStore) Save(token *model.Token) *model.AppError
- type SqlUserAccessTokenStore
- func (s SqlUserAccessTokenStore) CreateIndexesIfNotExists()
- func (s SqlUserAccessTokenStore) Delete(tokenId string) *model.AppError
- func (s SqlUserAccessTokenStore) DeleteAllForUser(userId string) *model.AppError
- func (s SqlUserAccessTokenStore) Get(tokenId string) (*model.UserAccessToken, *model.AppError)
- func (s SqlUserAccessTokenStore) GetAll(offset, limit int) ([]*model.UserAccessToken, *model.AppError)
- func (s SqlUserAccessTokenStore) GetByToken(tokenString string) (*model.UserAccessToken, *model.AppError)
- func (s SqlUserAccessTokenStore) GetByUser(userId string, offset, limit int) ([]*model.UserAccessToken, *model.AppError)
- func (s SqlUserAccessTokenStore) Save(token *model.UserAccessToken) (*model.UserAccessToken, *model.AppError)
- func (s SqlUserAccessTokenStore) Search(term string) ([]*model.UserAccessToken, *model.AppError)
- func (s SqlUserAccessTokenStore) UpdateTokenDisable(tokenId string) *model.AppError
- func (s SqlUserAccessTokenStore) UpdateTokenEnable(tokenId string) *model.AppError
- type SqlUserStore
- func (us SqlUserStore) AnalyticsActiveCount(timePeriod int64, options model.UserCountOptions) (int64, *model.AppError)
- func (us SqlUserStore) AnalyticsGetInactiveUsersCount() (int64, *model.AppError)
- func (us SqlUserStore) AnalyticsGetSystemAdminCount() (int64, *model.AppError)
- func (us SqlUserStore) ClearAllCustomRoleAssignments() *model.AppError
- func (us SqlUserStore) ClearCaches()
- func (us SqlUserStore) Count(options model.UserCountOptions) (int64, *model.AppError)
- func (us SqlUserStore) CreateIndexesIfNotExists()
- func (us SqlUserStore) DeactivateGuests() ([]string, *model.AppError)
- func (us SqlUserStore) DemoteUserToGuest(userId string) *model.AppError
- func (us SqlUserStore) Get(id string) (*model.User, *model.AppError)
- func (us SqlUserStore) GetAll() ([]*model.User, *model.AppError)
- func (us SqlUserStore) GetAllAfter(limit int, afterId string) ([]*model.User, *model.AppError)
- func (us SqlUserStore) GetAllProfiles(options *model.UserGetOptions) ([]*model.User, *model.AppError)
- func (us SqlUserStore) GetAllProfilesInChannel(channelId string, allowFromCache bool) (map[string]*model.User, *model.AppError)
- func (us SqlUserStore) GetAllUsingAuthService(authService string) ([]*model.User, *model.AppError)
- func (us SqlUserStore) GetAnyUnreadPostCountForChannel(userId string, channelId string) (int64, *model.AppError)
- func (us SqlUserStore) GetByAuth(authData *string, authService string) (*model.User, *model.AppError)
- func (us SqlUserStore) GetByEmail(email string) (*model.User, *model.AppError)
- func (us SqlUserStore) GetByUsername(username string) (*model.User, *model.AppError)
- func (us SqlUserStore) GetChannelGroupUsers(channelID string) ([]*model.User, *model.AppError)
- func (us SqlUserStore) GetEtagForAllProfiles() string
- func (us SqlUserStore) GetEtagForProfiles(teamId string) string
- func (us SqlUserStore) GetEtagForProfilesNotInTeam(teamId string) string
- func (us SqlUserStore) GetForLogin(loginId string, allowSignInWithUsername, allowSignInWithEmail bool) (*model.User, *model.AppError)
- func (us SqlUserStore) GetNewUsersForTeam(teamId string, offset, limit int, ...) ([]*model.User, *model.AppError)
- func (us SqlUserStore) GetProfileByGroupChannelIdsForUser(userId string, channelIds []string) (map[string][]*model.User, *model.AppError)
- func (us SqlUserStore) GetProfileByIds(userIds []string, options *store.UserGetByIdsOpts, _ bool) ([]*model.User, *model.AppError)
- func (us SqlUserStore) GetProfiles(options *model.UserGetOptions) ([]*model.User, *model.AppError)
- func (us SqlUserStore) GetProfilesByUsernames(usernames []string, viewRestrictions *model.ViewUsersRestrictions) ([]*model.User, *model.AppError)
- func (us SqlUserStore) GetProfilesInChannel(channelId string, offset int, limit int) ([]*model.User, *model.AppError)
- func (us SqlUserStore) GetProfilesInChannelByStatus(channelId string, offset int, limit int) ([]*model.User, *model.AppError)
- func (us SqlUserStore) GetProfilesNotInChannel(teamId string, channelId string, groupConstrained bool, offset int, limit int, ...) ([]*model.User, *model.AppError)
- func (us SqlUserStore) GetProfilesNotInTeam(teamId string, groupConstrained bool, offset int, limit int, ...) ([]*model.User, *model.AppError)
- func (us SqlUserStore) GetProfilesWithoutTeam(options *model.UserGetOptions) ([]*model.User, *model.AppError)
- func (us SqlUserStore) GetRecentlyActiveUsersForTeam(teamId string, offset, limit int, ...) ([]*model.User, *model.AppError)
- func (us SqlUserStore) GetSystemAdminProfiles() (map[string]*model.User, *model.AppError)
- func (us SqlUserStore) GetTeamGroupUsers(teamID string) ([]*model.User, *model.AppError)
- func (us SqlUserStore) GetUnreadCount(userId string) (int64, *model.AppError)
- func (us SqlUserStore) GetUnreadCountForChannel(userId string, channelId string) (int64, *model.AppError)
- func (us SqlUserStore) GetUsersBatchForIndexing(startTime, endTime int64, limit int) ([]*model.UserForIndexing, *model.AppError)
- func (us SqlUserStore) InferSystemInstallDate() (int64, *model.AppError)
- func (us SqlUserStore) InvalidateProfileCacheForUser(userId string)
- func (us SqlUserStore) InvalidateProfilesInChannelCache(channelId string)
- func (us SqlUserStore) InvalidateProfilesInChannelCacheByUser(userId string)
- func (us SqlUserStore) PermanentDelete(userId string) *model.AppError
- func (us SqlUserStore) PromoteGuestToUser(userId string) *model.AppError
- func (us SqlUserStore) ResetLastPictureUpdate(userId string) *model.AppError
- func (us SqlUserStore) Save(user *model.User) (*model.User, *model.AppError)
- func (us SqlUserStore) Search(teamId string, term string, options *model.UserSearchOptions) ([]*model.User, *model.AppError)
- func (us SqlUserStore) SearchInChannel(channelId string, term string, options *model.UserSearchOptions) ([]*model.User, *model.AppError)
- func (us SqlUserStore) SearchNotInChannel(teamId string, channelId string, term string, options *model.UserSearchOptions) ([]*model.User, *model.AppError)
- func (us SqlUserStore) SearchNotInTeam(notInTeamId string, term string, options *model.UserSearchOptions) ([]*model.User, *model.AppError)
- func (us SqlUserStore) SearchWithoutTeam(term string, options *model.UserSearchOptions) ([]*model.User, *model.AppError)
- func (us SqlUserStore) Update(user *model.User, trustedUpdateData bool) (*model.UserUpdate, *model.AppError)
- func (us SqlUserStore) UpdateAuthData(userId string, service string, authData *string, email string, resetMfa bool) (string, *model.AppError)
- func (us SqlUserStore) UpdateFailedPasswordAttempts(userId string, attempts int) *model.AppError
- func (us SqlUserStore) UpdateLastPictureUpdate(userId string) *model.AppError
- func (us SqlUserStore) UpdateMfaActive(userId string, active bool) *model.AppError
- func (us SqlUserStore) UpdateMfaSecret(userId, secret string) *model.AppError
- func (us SqlUserStore) UpdatePassword(userId, hashedPassword string) *model.AppError
- func (us SqlUserStore) UpdateUpdateAt(userId string) (int64, *model.AppError)
- func (us SqlUserStore) VerifyEmail(userId, email string) (string, *model.AppError)
- type SqlUserTermsOfServiceStore
- func (s SqlUserTermsOfServiceStore) CreateIndexesIfNotExists()
- func (s SqlUserTermsOfServiceStore) Delete(userId, termsOfServiceId string) *model.AppError
- func (s SqlUserTermsOfServiceStore) GetByUser(userId string) (*model.UserTermsOfService, *model.AppError)
- func (s SqlUserTermsOfServiceStore) Save(userTermsOfService *model.UserTermsOfService) (*model.UserTermsOfService, *model.AppError)
- type SqlWebhookStore
- func (s SqlWebhookStore) AnalyticsIncomingCount(teamId string) (int64, *model.AppError)
- func (s SqlWebhookStore) AnalyticsOutgoingCount(teamId string) (int64, *model.AppError)
- func (s SqlWebhookStore) ClearCaches()
- func (s SqlWebhookStore) CreateIndexesIfNotExists()
- func (s SqlWebhookStore) DeleteIncoming(webhookId string, time int64) *model.AppError
- func (s SqlWebhookStore) DeleteOutgoing(webhookId string, time int64) *model.AppError
- func (s SqlWebhookStore) GetIncoming(id string, allowFromCache bool) (*model.IncomingWebhook, *model.AppError)
- func (s SqlWebhookStore) GetIncomingByChannel(channelId string) ([]*model.IncomingWebhook, *model.AppError)
- func (s SqlWebhookStore) GetIncomingByTeam(teamId string, offset, limit int) ([]*model.IncomingWebhook, *model.AppError)
- func (s SqlWebhookStore) GetIncomingByTeamByUser(teamId string, userId string, offset, limit int) ([]*model.IncomingWebhook, *model.AppError)
- func (s SqlWebhookStore) GetIncomingList(offset, limit int) ([]*model.IncomingWebhook, *model.AppError)
- func (s SqlWebhookStore) GetIncomingListByUser(userId string, offset, limit int) ([]*model.IncomingWebhook, *model.AppError)
- func (s SqlWebhookStore) GetOutgoing(id string) (*model.OutgoingWebhook, *model.AppError)
- func (s SqlWebhookStore) GetOutgoingByChannel(channelId string, offset, limit int) ([]*model.OutgoingWebhook, *model.AppError)
- func (s SqlWebhookStore) GetOutgoingByChannelByUser(channelId string, userId string, offset, limit int) ([]*model.OutgoingWebhook, *model.AppError)
- func (s SqlWebhookStore) GetOutgoingByTeam(teamId string, offset, limit int) ([]*model.OutgoingWebhook, *model.AppError)
- func (s SqlWebhookStore) GetOutgoingByTeamByUser(teamId string, userId string, offset, limit int) ([]*model.OutgoingWebhook, *model.AppError)
- func (s SqlWebhookStore) GetOutgoingList(offset, limit int) ([]*model.OutgoingWebhook, *model.AppError)
- func (s SqlWebhookStore) GetOutgoingListByUser(userId string, offset, limit int) ([]*model.OutgoingWebhook, *model.AppError)
- func (s SqlWebhookStore) InvalidateWebhookCache(webhookId string)
- func (s SqlWebhookStore) PermanentDeleteIncomingByChannel(channelId string) *model.AppError
- func (s SqlWebhookStore) PermanentDeleteIncomingByUser(userId string) *model.AppError
- func (s SqlWebhookStore) PermanentDeleteOutgoingByChannel(channelId string) *model.AppError
- func (s SqlWebhookStore) PermanentDeleteOutgoingByUser(userId string) *model.AppError
- func (s SqlWebhookStore) SaveIncoming(webhook *model.IncomingWebhook) (*model.IncomingWebhook, *model.AppError)
- func (s SqlWebhookStore) SaveOutgoing(webhook *model.OutgoingWebhook) (*model.OutgoingWebhook, *model.AppError)
- func (s SqlWebhookStore) UpdateIncoming(hook *model.IncomingWebhook) (*model.IncomingWebhook, *model.AppError)
- func (s SqlWebhookStore) UpdateOutgoing(hook *model.OutgoingWebhook) (*model.OutgoingWebhook, *model.AppError)
- type TraceOnAdapter
- type UserWithChannel
- type UserWithLastActivityAt
Constants ¶
const ( ALL_CHANNEL_MEMBERS_FOR_USER_CACHE_SIZE = model.SESSION_CACHE_SIZE ALL_CHANNEL_MEMBERS_FOR_USER_CACHE_SEC = 900 // 15 mins ALL_CHANNEL_MEMBERS_NOTIFY_PROPS_FOR_CHANNEL_CACHE_SIZE = model.SESSION_CACHE_SIZE ALL_CHANNEL_MEMBERS_NOTIFY_PROPS_FOR_CHANNEL_CACHE_SEC = 1800 // 30 mins CHANNEL_CACHE_SEC = 900 // 15 mins )
const ( FILE_INFO_CACHE_SIZE = 25000 FILE_INFO_CACHE_SEC = 1800 // 30 minutes )
const ( INDEX_TYPE_FULL_TEXT = "full_text" INDEX_TYPE_DEFAULT = "default" DB_PING_ATTEMPTS = 18 DB_PING_TIMEOUT_SECS = 10 )
const ( EXIT_GENERIC_FAILURE = 1 EXIT_CREATE_TABLE = 100 EXIT_DB_OPEN = 101 EXIT_PING = 102 EXIT_NO_DRIVER = 103 EXIT_TABLE_EXISTS = 104 EXIT_TABLE_EXISTS_MYSQL = 105 EXIT_COLUMN_EXISTS = 106 EXIT_DOES_COLUMN_EXISTS_POSTGRES = 107 EXIT_DOES_COLUMN_EXISTS_MYSQL = 108 EXIT_DOES_COLUMN_EXISTS_MISSING = 109 EXIT_CREATE_COLUMN_POSTGRES = 110 EXIT_CREATE_COLUMN_MYSQL = 111 EXIT_CREATE_COLUMN_MISSING = 112 EXIT_REMOVE_COLUMN = 113 EXIT_RENAME_COLUMN = 114 EXIT_MAX_COLUMN = 115 EXIT_ALTER_COLUMN = 116 EXIT_CREATE_INDEX_POSTGRES = 117 EXIT_CREATE_INDEX_MYSQL = 118 EXIT_CREATE_INDEX_FULL_MYSQL = 119 EXIT_CREATE_INDEX_MISSING = 120 EXIT_REMOVE_INDEX_POSTGRES = 121 EXIT_REMOVE_INDEX_MYSQL = 122 EXIT_REMOVE_INDEX_MISSING = 123 EXIT_REMOVE_TABLE = 134 EXIT_CREATE_INDEX_SQLITE = 135 EXIT_REMOVE_INDEX_SQLITE = 136 EXIT_TABLE_EXISTS_SQLITE = 137 EXIT_DOES_COLUMN_EXISTS_SQLITE = 138 )
const ( CURRENT_SCHEMA_VERSION = VERSION_5_21_0 VERSION_5_21_0 = "5.21.0" VERSION_5_20_0 = "5.20.0" VERSION_5_19_0 = "5.19.0" VERSION_5_18_0 = "5.18.0" VERSION_5_17_0 = "5.17.0" VERSION_5_16_0 = "5.16.0" VERSION_5_15_0 = "5.15.0" VERSION_5_14_0 = "5.14.0" VERSION_5_13_0 = "5.13.0" VERSION_5_12_0 = "5.12.0" VERSION_5_11_0 = "5.11.0" VERSION_5_10_0 = "5.10.0" VERSION_5_9_0 = "5.9.0" VERSION_5_8_0 = "5.8.0" VERSION_5_7_0 = "5.7.0" VERSION_5_6_0 = "5.6.0" VERSION_5_5_0 = "5.5.0" VERSION_5_4_0 = "5.4.0" VERSION_5_3_0 = "5.3.0" VERSION_5_2_0 = "5.2.0" VERSION_5_1_0 = "5.1.0" VERSION_5_0_0 = "5.0.0" VERSION_4_10_0 = "4.10.0" VERSION_4_9_0 = "4.9.0" VERSION_4_8_1 = "4.8.1" VERSION_4_8_0 = "4.8.0" VERSION_4_7_2 = "4.7.2" VERSION_4_7_1 = "4.7.1" VERSION_4_7_0 = "4.7.0" VERSION_4_6_0 = "4.6.0" VERSION_4_5_0 = "4.5.0" VERSION_4_4_0 = "4.4.0" VERSION_4_3_0 = "4.3.0" VERSION_4_2_0 = "4.2.0" VERSION_4_1_0 = "4.1.0" VERSION_4_0_0 = "4.0.0" VERSION_3_10_0 = "3.10.0" VERSION_3_9_0 = "3.9.0" VERSION_3_8_0 = "3.8.0" VERSION_3_7_0 = "3.7.0" VERSION_3_6_0 = "3.6.0" VERSION_3_5_0 = "3.5.0" VERSION_3_4_0 = "3.4.0" VERSION_3_3_0 = "3.3.0" VERSION_3_2_0 = "3.2.0" VERSION_3_1_0 = "3.1.0" VERSION_3_0_0 = "3.0.0" OLDEST_SUPPORTED_VERSION = VERSION_3_0_0 )
const ( EXIT_VERSION_SAVE = 1003 EXIT_THEME_MIGRATION = 1004 EXIT_TEAM_INVITEID_MIGRATION_FAILED = 1006 )
const (
MAX_GROUP_CHANNELS_FOR_PROFILES = 50
)
const (
MISSING_STATUS_ERROR = "store.sql_status.get.missing.app_error"
)
const (
SESSIONS_CLEANUP_DELAY_MILLISECONDS = 100
)
const (
TEAM_MEMBER_EXISTS_ERROR = "store.sql_team.save_member.exists.app_error"
)
const (
UPDATE_POST_HAS_REACTIONS_ON_DELETE_QUERY = `` /* 148-byte string literal not displayed */
)
Variables ¶
var ( USER_SEARCH_TYPE_NAMES_NO_FULL_NAME = []string{"Username", "Nickname"} USER_SEARCH_TYPE_NAMES = []string{"Username", "FirstName", "LastName", "Nickname"} USER_SEARCH_TYPE_ALL_NO_FULL_NAME = []string{"Username", "Nickname", "Email"} USER_SEARCH_TYPE_ALL = []string{"Username", "FirstName", "LastName", "Nickname", "Email"} )
var CHANNEL_MEMBERS_WITH_SCHEME_SELECT_QUERY = `` /* 710-byte string literal not displayed */
Functions ¶
func CheckRelationalIntegrity ¶
func CheckRelationalIntegrity(ss *SqlSupplier, results chan<- store.IntegrityCheckResult)
func IsUniqueConstraintError ¶
func MapStringsToQueryParams ¶
Converts a list of strings into a list of query parameters and a named parameter map that can be used as part of a SQL query.
func NewChannelMemberFromModel ¶
func NewChannelMemberFromModel(cm *model.ChannelMember) *channelMember
func NewSqlAuditStore ¶
func NewSqlAuditStore(sqlStore SqlStore) store.AuditStore
func NewSqlBotStore ¶
func NewSqlBotStore(sqlStore SqlStore, metrics einterfaces.MetricsInterface) store.BotStore
NewSqlBotStore creates an instance of SqlBotStore, registering the table schema in question.
func NewSqlChannelMemberHistoryStore ¶
func NewSqlChannelMemberHistoryStore(sqlStore SqlStore) store.ChannelMemberHistoryStore
func NewSqlChannelStore ¶
func NewSqlChannelStore(sqlStore SqlStore, metrics einterfaces.MetricsInterface) store.ChannelStore
func NewSqlClusterDiscoveryStore ¶
func NewSqlClusterDiscoveryStore(sqlStore SqlStore) store.ClusterDiscoveryStore
func NewSqlCommandStore ¶
func NewSqlCommandStore(sqlStore SqlStore) store.CommandStore
func NewSqlCommandWebhookStore ¶
func NewSqlCommandWebhookStore(sqlStore SqlStore) store.CommandWebhookStore
func NewSqlComplianceStore ¶
func NewSqlComplianceStore(sqlStore SqlStore) store.ComplianceStore
func NewSqlEmojiStore ¶
func NewSqlEmojiStore(sqlStore SqlStore, metrics einterfaces.MetricsInterface) store.EmojiStore
func NewSqlFileInfoStore ¶
func NewSqlFileInfoStore(sqlStore SqlStore, metrics einterfaces.MetricsInterface) store.FileInfoStore
func NewSqlGroupStore ¶
func NewSqlGroupStore(sqlStore SqlStore) store.GroupStore
func NewSqlJobStore ¶
func NewSqlLicenseStore ¶
func NewSqlLicenseStore(sqlStore SqlStore) store.LicenseStore
func NewSqlLinkMetadataStore ¶
func NewSqlLinkMetadataStore(sqlStore SqlStore) store.LinkMetadataStore
func NewSqlOAuthStore ¶
func NewSqlOAuthStore(sqlStore SqlStore) store.OAuthStore
func NewSqlPluginStore ¶
func NewSqlPluginStore(sqlStore SqlStore) store.PluginStore
func NewSqlPostStore ¶
func NewSqlPostStore(sqlStore SqlStore, metrics einterfaces.MetricsInterface) store.PostStore
func NewSqlPreferenceStore ¶
func NewSqlPreferenceStore(sqlStore SqlStore) store.PreferenceStore
func NewSqlReactionStore ¶
func NewSqlReactionStore(sqlStore SqlStore) store.ReactionStore
func NewSqlRoleStore ¶
func NewSqlSchemeStore ¶
func NewSqlSchemeStore(sqlStore SqlStore) store.SchemeStore
func NewSqlSessionStore ¶
func NewSqlSessionStore(sqlStore SqlStore) store.SessionStore
func NewSqlStatusStore ¶
func NewSqlStatusStore(sqlStore SqlStore) store.StatusStore
func NewSqlSystemStore ¶
func NewSqlSystemStore(sqlStore SqlStore) store.SystemStore
func NewSqlTeamStore ¶
func NewSqlTermsOfServiceStore ¶
func NewSqlTermsOfServiceStore(sqlStore SqlStore, metrics einterfaces.MetricsInterface) store.TermsOfServiceStore
func NewSqlTokenStore ¶
func NewSqlTokenStore(sqlStore SqlStore) store.TokenStore
func NewSqlUserAccessTokenStore ¶
func NewSqlUserAccessTokenStore(sqlStore SqlStore) store.UserAccessTokenStore
func NewSqlUserStore ¶
func NewSqlUserStore(sqlStore SqlStore, metrics einterfaces.MetricsInterface) store.UserStore
func NewSqlUserTermsOfServiceStore ¶
func NewSqlUserTermsOfServiceStore(sqlStore SqlStore) store.UserTermsOfServiceStore
func NewSqlWebhookStore ¶
func NewSqlWebhookStore(sqlStore SqlStore, metrics einterfaces.MetricsInterface) store.WebhookStore
func NewTeamMemberFromModel ¶
func NewTeamMemberFromModel(tm *model.TeamMember) *teamMember
Types ¶
type JSONSerializable ¶
type JSONSerializable interface {
ToJson() string
}
type Role ¶
type Role struct { Id string Name string DisplayName string Description string CreateAt int64 UpdateAt int64 DeleteAt int64 Permissions string SchemeManaged bool BuiltIn bool }
func NewRoleFromModel ¶
type SqlAuditStore ¶
type SqlAuditStore struct {
SqlStore
}
func (SqlAuditStore) CreateIndexesIfNotExists ¶
func (s SqlAuditStore) CreateIndexesIfNotExists()
func (SqlAuditStore) PermanentDeleteByUser ¶
func (s SqlAuditStore) PermanentDeleteByUser(userId string) *model.AppError
type SqlBotStore ¶
type SqlBotStore struct { SqlStore // contains filtered or unexported fields }
SqlBotStore is a store for managing bots in the database. Bots are otherwise normal users with extra metadata record in the Bots table. The primary key for a bot matches the primary key value for corresponding User record.
func (SqlBotStore) CreateIndexesIfNotExists ¶
func (us SqlBotStore) CreateIndexesIfNotExists()
func (SqlBotStore) GetAll ¶
func (us SqlBotStore) GetAll(options *model.BotGetOptions) ([]*model.Bot, *model.AppError)
GetAll fetches from all bots in the database.
func (SqlBotStore) PermanentDelete ¶
func (us SqlBotStore) PermanentDelete(botUserId string) *model.AppError
PermanentDelete removes the bot from the database altogether. If the corresponding user is to be deleted, it must be done via the user store.
type SqlChannelMemberHistoryStore ¶
type SqlChannelMemberHistoryStore struct {
SqlStore
}
func (SqlChannelMemberHistoryStore) GetUsersInChannelDuring ¶
func (s SqlChannelMemberHistoryStore) GetUsersInChannelDuring(startTime int64, endTime int64, channelId string) ([]*model.ChannelMemberHistoryResult, *model.AppError)
func (SqlChannelMemberHistoryStore) LogJoinEvent ¶
func (SqlChannelMemberHistoryStore) LogLeaveEvent ¶
func (SqlChannelMemberHistoryStore) PermanentDeleteBatch ¶
type SqlChannelStore ¶
type SqlChannelStore struct { SqlStore // contains filtered or unexported fields }
func (SqlChannelStore) AnalyticsDeletedTypeCount ¶
func (SqlChannelStore) AnalyticsTypeCount ¶
func (SqlChannelStore) AutocompleteInTeam ¶
func (s SqlChannelStore) AutocompleteInTeam(teamId string, term string, includeDeleted bool) (*model.ChannelList, *model.AppError)
func (SqlChannelStore) AutocompleteInTeamForSearch ¶
func (s SqlChannelStore) AutocompleteInTeamForSearch(teamId string, userId string, term string, includeDeleted bool) (*model.ChannelList, *model.AppError)
func (SqlChannelStore) ClearAllCustomRoleAssignments ¶
func (s SqlChannelStore) ClearAllCustomRoleAssignments() *model.AppError
func (SqlChannelStore) ClearCaches ¶
func (s SqlChannelStore) ClearCaches()
func (SqlChannelStore) CountPostsAfter ¶
func (s SqlChannelStore) CountPostsAfter(channelId string, timestamp int64, userId string) (int, *model.AppError)
CountPostsAfter returns the number of posts in the given channel created after but not including the given timestamp. If given a non-empty user ID, only counts posts made by that user.
func (SqlChannelStore) CreateDirectChannel ¶
func (SqlChannelStore) CreateIndexesIfNotExists ¶
func (s SqlChannelStore) CreateIndexesIfNotExists()
func (SqlChannelStore) Delete ¶
func (s SqlChannelStore) Delete(channelId string, time int64) *model.AppError
Delete records the given deleted timestamp to the channel in question.
func (SqlChannelStore) GetAllChannelMembersForUser ¶
func (SqlChannelStore) GetAllChannelMembersNotifyPropsForChannel ¶
func (SqlChannelStore) GetAllChannels ¶
func (s SqlChannelStore) GetAllChannels(offset, limit int, opts store.ChannelSearchOpts) (*model.ChannelListWithTeamData, *model.AppError)
func (SqlChannelStore) GetAllChannelsCount ¶
func (s SqlChannelStore) GetAllChannelsCount(opts store.ChannelSearchOpts) (int64, *model.AppError)
func (SqlChannelStore) GetAllChannelsForExportAfter ¶
func (s SqlChannelStore) GetAllChannelsForExportAfter(limit int, afterId string) ([]*model.ChannelForExport, *model.AppError)
func (SqlChannelStore) GetAllDirectChannelsForExportAfter ¶
func (s SqlChannelStore) GetAllDirectChannelsForExportAfter(limit int, afterId string) ([]*model.DirectChannelForExport, *model.AppError)
func (SqlChannelStore) GetByNameIncludeDeleted ¶
func (SqlChannelStore) GetByNames ¶
func (SqlChannelStore) GetChannelCounts ¶
func (s SqlChannelStore) GetChannelCounts(teamId string, userId string) (*model.ChannelCounts, *model.AppError)
func (SqlChannelStore) GetChannelMembersForExport ¶
func (s SqlChannelStore) GetChannelMembersForExport(userId string, teamId string) ([]*model.ChannelMemberForExport, *model.AppError)
func (SqlChannelStore) GetChannelMembersTimezones ¶
func (SqlChannelStore) GetChannelUnread ¶
func (s SqlChannelStore) GetChannelUnread(channelId, userId string) (*model.ChannelUnread, *model.AppError)
func (SqlChannelStore) GetChannels ¶
func (s SqlChannelStore) GetChannels(teamId string, userId string, includeDeleted bool) (*model.ChannelList, *model.AppError)
func (SqlChannelStore) GetChannelsBatchForIndexing ¶
func (SqlChannelStore) GetChannelsByIds ¶
func (SqlChannelStore) GetChannelsByScheme ¶
func (s SqlChannelStore) GetChannelsByScheme(schemeId string, offset int, limit int) (model.ChannelList, *model.AppError)
func (SqlChannelStore) GetDeleted ¶
func (s SqlChannelStore) GetDeleted(teamId string, offset int, limit int, userId string) (*model.ChannelList, *model.AppError)
func (SqlChannelStore) GetDeletedByName ¶
func (SqlChannelStore) GetForPost ¶
func (SqlChannelStore) GetFromMaster ¶
func (SqlChannelStore) GetGuestCount ¶
func (SqlChannelStore) GetMember ¶
func (s SqlChannelStore) GetMember(channelId string, userId string) (*model.ChannelMember, *model.AppError)
func (SqlChannelStore) GetMemberCount ¶
func (SqlChannelStore) GetMemberCountFromCache ¶
func (s SqlChannelStore) GetMemberCountFromCache(channelId string) int64
func (SqlChannelStore) GetMemberForPost ¶
func (s SqlChannelStore) GetMemberForPost(postId string, userId string) (*model.ChannelMember, *model.AppError)
func (SqlChannelStore) GetMembers ¶
func (s SqlChannelStore) GetMembers(channelId string, offset, limit int) (*model.ChannelMembers, *model.AppError)
func (SqlChannelStore) GetMembersByIds ¶
func (s SqlChannelStore) GetMembersByIds(channelId string, userIds []string) (*model.ChannelMembers, *model.AppError)
func (SqlChannelStore) GetMembersForUser ¶
func (s SqlChannelStore) GetMembersForUser(teamId string, userId string) (*model.ChannelMembers, *model.AppError)
func (SqlChannelStore) GetMembersForUserWithPagination ¶
func (s SqlChannelStore) GetMembersForUserWithPagination(teamId, userId string, page, perPage int) (*model.ChannelMembers, *model.AppError)
func (SqlChannelStore) GetMoreChannels ¶
func (s SqlChannelStore) GetMoreChannels(teamId string, userId string, offset int, limit int) (*model.ChannelList, *model.AppError)
func (SqlChannelStore) GetPinnedPostCount ¶
func (SqlChannelStore) GetPinnedPosts ¶
func (SqlChannelStore) GetPublicChannelsByIdsForTeam ¶
func (s SqlChannelStore) GetPublicChannelsByIdsForTeam(teamId string, channelIds []string) (*model.ChannelList, *model.AppError)
func (SqlChannelStore) GetPublicChannelsForTeam ¶
func (s SqlChannelStore) GetPublicChannelsForTeam(teamId string, offset int, limit int) (*model.ChannelList, *model.AppError)
func (SqlChannelStore) GetTeamChannels ¶
func (s SqlChannelStore) GetTeamChannels(teamId string) (*model.ChannelList, *model.AppError)
func (SqlChannelStore) IncrementMentionCount ¶
func (s SqlChannelStore) IncrementMentionCount(channelId string, userId string) *model.AppError
func (SqlChannelStore) InvalidateAllChannelMembersForUser ¶
func (s SqlChannelStore) InvalidateAllChannelMembersForUser(userId string)
func (SqlChannelStore) InvalidateCacheForChannelMembersNotifyProps ¶
func (s SqlChannelStore) InvalidateCacheForChannelMembersNotifyProps(channelId string)
func (SqlChannelStore) InvalidateChannel ¶
func (s SqlChannelStore) InvalidateChannel(id string)
func (SqlChannelStore) InvalidateChannelByName ¶
func (s SqlChannelStore) InvalidateChannelByName(teamId, name string)
func (SqlChannelStore) InvalidateGuestCount ¶
func (s SqlChannelStore) InvalidateGuestCount(channelId string)
func (SqlChannelStore) InvalidateMemberCount ¶
func (s SqlChannelStore) InvalidateMemberCount(channelId string)
func (SqlChannelStore) InvalidatePinnedPostCount ¶
func (s SqlChannelStore) InvalidatePinnedPostCount(channelId string)
func (SqlChannelStore) IsUserInChannelUseCache ¶
func (s SqlChannelStore) IsUserInChannelUseCache(userId string, channelId string) bool
func (SqlChannelStore) MigrateChannelMembers ¶
func (s SqlChannelStore) MigrateChannelMembers(fromChannelId string, fromUserId string) (map[string]string, *model.AppError)
This function does the Advanced Permissions Phase 2 migration for ChannelMember objects. It performs the migration in batches as a single transaction per batch to ensure consistency but to also minimise execution time to avoid causing unnecessary table locks. **THIS FUNCTION SHOULD NOT BE USED FOR ANY OTHER PURPOSE.** Executing this function *after* the new Schemes functionality has been used on an installation will have unintended consequences.
func (SqlChannelStore) MigratePublicChannels ¶
func (s SqlChannelStore) MigratePublicChannels() error
MigratePublicChannels initializes the PublicChannels table with data created before this version of the Mattermost server kept it up-to-date.
func (SqlChannelStore) PermanentDelete ¶
func (s SqlChannelStore) PermanentDelete(channelId string) *model.AppError
PermanentDelete removes the given channel from the database.
func (SqlChannelStore) PermanentDeleteByTeam ¶
func (s SqlChannelStore) PermanentDeleteByTeam(teamId string) *model.AppError
PermanentDeleteByTeam removes all channels for the given team from the database.
func (SqlChannelStore) PermanentDeleteMembersByChannel ¶
func (s SqlChannelStore) PermanentDeleteMembersByChannel(channelId string) *model.AppError
func (SqlChannelStore) PermanentDeleteMembersByUser ¶
func (s SqlChannelStore) PermanentDeleteMembersByUser(userId string) *model.AppError
func (SqlChannelStore) RemoveAllDeactivatedMembers ¶
func (s SqlChannelStore) RemoveAllDeactivatedMembers(channelId string) *model.AppError
func (SqlChannelStore) RemoveMember ¶
func (s SqlChannelStore) RemoveMember(channelId string, userId string) *model.AppError
func (SqlChannelStore) ResetAllChannelSchemes ¶
func (s SqlChannelStore) ResetAllChannelSchemes() *model.AppError
func (SqlChannelStore) Restore ¶
func (s SqlChannelStore) Restore(channelId string, time int64) *model.AppError
Restore reverts a previous deleted timestamp from the channel in question.
func (SqlChannelStore) Save ¶
func (s SqlChannelStore) Save(channel *model.Channel, maxChannelsPerTeam int64) (*model.Channel, *model.AppError)
Save writes the (non-direct) channel channel to the database.
func (SqlChannelStore) SaveDirectChannel ¶
func (s SqlChannelStore) SaveDirectChannel(directchannel *model.Channel, member1 *model.ChannelMember, member2 *model.ChannelMember) (*model.Channel, *model.AppError)
func (SqlChannelStore) SaveMember ¶
func (s SqlChannelStore) SaveMember(member *model.ChannelMember) (*model.ChannelMember, *model.AppError)
func (SqlChannelStore) SearchAllChannels ¶
func (s SqlChannelStore) SearchAllChannels(term string, opts store.ChannelSearchOpts) (*model.ChannelListWithTeamData, int64, *model.AppError)
func (SqlChannelStore) SearchArchivedInTeam ¶
func (s SqlChannelStore) SearchArchivedInTeam(teamId string, term string, userId string) (*model.ChannelList, *model.AppError)
func (SqlChannelStore) SearchForUserInTeam ¶
func (s SqlChannelStore) SearchForUserInTeam(userId string, teamId string, term string, includeDeleted bool) (*model.ChannelList, *model.AppError)
func (SqlChannelStore) SearchGroupChannels ¶
func (s SqlChannelStore) SearchGroupChannels(userId, term string) (*model.ChannelList, *model.AppError)
func (SqlChannelStore) SearchInTeam ¶
func (s SqlChannelStore) SearchInTeam(teamId string, term string, includeDeleted bool) (*model.ChannelList, *model.AppError)
func (SqlChannelStore) SearchMore ¶
func (s SqlChannelStore) SearchMore(userId string, teamId string, term string) (*model.ChannelList, *model.AppError)
func (SqlChannelStore) SetDeleteAt ¶
func (s SqlChannelStore) SetDeleteAt(channelId string, deleteAt, updateAt int64) *model.AppError
SetDeleteAt records the given deleted and updated timestamp to the channel in question.
func (SqlChannelStore) UpdateLastViewedAt ¶
func (SqlChannelStore) UpdateLastViewedAtPost ¶
func (s SqlChannelStore) UpdateLastViewedAtPost(unreadPost *model.Post, userID string, mentionCount int) (*model.ChannelUnreadAt, *model.AppError)
UpdateLastViewedAtPost updates a ChannelMember as if the user last read the channel at the time of the given post. If the provided mentionCount is -1, the given post and all posts after it are considered to be mentions. Returns an updated model.ChannelUnreadAt that can be returned to the client.
func (SqlChannelStore) UpdateMember ¶
func (s SqlChannelStore) UpdateMember(member *model.ChannelMember) (*model.ChannelMember, *model.AppError)
func (SqlChannelStore) UpdateMembersRole ¶ added in v5.20.0
func (s SqlChannelStore) UpdateMembersRole(channelID string, userIDs []string) *model.AppError
func (SqlChannelStore) UserBelongsToChannels ¶
type SqlCommandStore ¶
type SqlCommandStore struct {
SqlStore
}
func (SqlCommandStore) AnalyticsCommandCount ¶
func (s SqlCommandStore) AnalyticsCommandCount(teamId string) (int64, *model.AppError)
func (SqlCommandStore) CreateIndexesIfNotExists ¶
func (s SqlCommandStore) CreateIndexesIfNotExists()
func (SqlCommandStore) Delete ¶
func (s SqlCommandStore) Delete(commandId string, time int64) *model.AppError
func (SqlCommandStore) GetByTrigger ¶
func (SqlCommandStore) PermanentDeleteByTeam ¶
func (s SqlCommandStore) PermanentDeleteByTeam(teamId string) *model.AppError
func (SqlCommandStore) PermanentDeleteByUser ¶
func (s SqlCommandStore) PermanentDeleteByUser(userId string) *model.AppError
type SqlCommandWebhookStore ¶
type SqlCommandWebhookStore struct {
SqlStore
}
func (SqlCommandWebhookStore) Cleanup ¶
func (s SqlCommandWebhookStore) Cleanup()
func (SqlCommandWebhookStore) CreateIndexesIfNotExists ¶
func (s SqlCommandWebhookStore) CreateIndexesIfNotExists()
func (SqlCommandWebhookStore) Get ¶
func (s SqlCommandWebhookStore) Get(id string) (*model.CommandWebhook, *model.AppError)
func (SqlCommandWebhookStore) Save ¶
func (s SqlCommandWebhookStore) Save(webhook *model.CommandWebhook) (*model.CommandWebhook, *model.AppError)
type SqlComplianceStore ¶
type SqlComplianceStore struct {
SqlStore
}
func (SqlComplianceStore) ComplianceExport ¶
func (s SqlComplianceStore) ComplianceExport(job *model.Compliance) ([]*model.CompliancePost, *model.AppError)
func (SqlComplianceStore) CreateIndexesIfNotExists ¶
func (s SqlComplianceStore) CreateIndexesIfNotExists()
func (SqlComplianceStore) Get ¶
func (s SqlComplianceStore) Get(id string) (*model.Compliance, *model.AppError)
func (SqlComplianceStore) GetAll ¶
func (s SqlComplianceStore) GetAll(offset, limit int) (model.Compliances, *model.AppError)
func (SqlComplianceStore) MessageExport ¶
func (s SqlComplianceStore) MessageExport(after int64, limit int) ([]*model.MessageExport, *model.AppError)
func (SqlComplianceStore) Save ¶
func (s SqlComplianceStore) Save(compliance *model.Compliance) (*model.Compliance, *model.AppError)
func (SqlComplianceStore) Update ¶
func (s SqlComplianceStore) Update(compliance *model.Compliance) (*model.Compliance, *model.AppError)
type SqlEmojiStore ¶
type SqlEmojiStore struct { SqlStore // contains filtered or unexported fields }
func (SqlEmojiStore) CreateIndexesIfNotExists ¶
func (es SqlEmojiStore) CreateIndexesIfNotExists()
func (SqlEmojiStore) GetMultipleByName ¶
type SqlFileInfoStore ¶
type SqlFileInfoStore struct { SqlStore // contains filtered or unexported fields }
func (SqlFileInfoStore) AttachToPost ¶
func (fs SqlFileInfoStore) AttachToPost(fileId, postId, creatorId string) *model.AppError
func (SqlFileInfoStore) ClearCaches ¶
func (fs SqlFileInfoStore) ClearCaches()
func (SqlFileInfoStore) CreateIndexesIfNotExists ¶
func (fs SqlFileInfoStore) CreateIndexesIfNotExists()
func (SqlFileInfoStore) DeleteForPost ¶
func (fs SqlFileInfoStore) DeleteForPost(postId string) (string, *model.AppError)
func (SqlFileInfoStore) GetForPost ¶
func (SqlFileInfoStore) GetForUser ¶
func (SqlFileInfoStore) InvalidateFileInfosForPostCache ¶
func (fs SqlFileInfoStore) InvalidateFileInfosForPostCache(postId string)
func (SqlFileInfoStore) PermanentDelete ¶
func (fs SqlFileInfoStore) PermanentDelete(fileId string) *model.AppError
func (SqlFileInfoStore) PermanentDeleteBatch ¶
func (SqlFileInfoStore) PermanentDeleteByUser ¶
func (fs SqlFileInfoStore) PermanentDeleteByUser(userId string) (int64, *model.AppError)
type SqlGroupStore ¶
type SqlGroupStore struct {
SqlStore
}
func (*SqlGroupStore) AdminRoleGroupsForSyncableMember ¶ added in v5.20.0
func (s *SqlGroupStore) AdminRoleGroupsForSyncableMember(userID, syncableID string, syncableType model.GroupSyncableType) ([]string, *model.AppError)
func (*SqlGroupStore) ChannelMembersMinusGroupMembers ¶
func (s *SqlGroupStore) ChannelMembersMinusGroupMembers(channelID string, groupIDs []string, page, perPage int) ([]*model.UserWithGroups, *model.AppError)
ChannelMembersMinusGroupMembers returns the set of users in the given channel minus the set of users in the given groups.
func (*SqlGroupStore) ChannelMembersToAdd ¶
func (s *SqlGroupStore) ChannelMembersToAdd(since int64, channelID *string) ([]*model.UserChannelIDPair, *model.AppError)
func (*SqlGroupStore) ChannelMembersToRemove ¶
func (s *SqlGroupStore) ChannelMembersToRemove(channelID *string) ([]*model.ChannelMember, *model.AppError)
func (*SqlGroupStore) CountChannelMembersMinusGroupMembers ¶
func (s *SqlGroupStore) CountChannelMembersMinusGroupMembers(channelID string, groupIDs []string) (int64, *model.AppError)
CountChannelMembersMinusGroupMembers returns the count of the set of users in the given channel minus the set of users in the given groups.
func (*SqlGroupStore) CountGroupsByChannel ¶
func (s *SqlGroupStore) CountGroupsByChannel(channelId string, opts model.GroupSearchOpts) (int64, *model.AppError)
func (*SqlGroupStore) CountGroupsByTeam ¶
func (s *SqlGroupStore) CountGroupsByTeam(teamId string, opts model.GroupSearchOpts) (int64, *model.AppError)
func (*SqlGroupStore) CountTeamMembersMinusGroupMembers ¶
func (s *SqlGroupStore) CountTeamMembersMinusGroupMembers(teamID string, groupIDs []string) (int64, *model.AppError)
CountTeamMembersMinusGroupMembers returns the count of the set of users on the given team minus the set of users in the given groups.
func (*SqlGroupStore) CreateGroupSyncable ¶
func (s *SqlGroupStore) CreateGroupSyncable(groupSyncable *model.GroupSyncable) (*model.GroupSyncable, *model.AppError)
func (*SqlGroupStore) CreateIndexesIfNotExists ¶
func (s *SqlGroupStore) CreateIndexesIfNotExists()
func (*SqlGroupStore) DeleteGroupSyncable ¶
func (s *SqlGroupStore) DeleteGroupSyncable(groupID string, syncableID string, syncableType model.GroupSyncableType) (*model.GroupSyncable, *model.AppError)
func (*SqlGroupStore) DeleteMember ¶
func (s *SqlGroupStore) DeleteMember(groupID string, userID string) (*model.GroupMember, *model.AppError)
func (*SqlGroupStore) GetAllBySource ¶
func (s *SqlGroupStore) GetAllBySource(groupSource model.GroupSource) ([]*model.Group, *model.AppError)
func (*SqlGroupStore) GetAllGroupSyncablesByGroupId ¶
func (s *SqlGroupStore) GetAllGroupSyncablesByGroupId(groupID string, syncableType model.GroupSyncableType) ([]*model.GroupSyncable, *model.AppError)
func (*SqlGroupStore) GetByRemoteID ¶
func (s *SqlGroupStore) GetByRemoteID(remoteID string, groupSource model.GroupSource) (*model.Group, *model.AppError)
func (*SqlGroupStore) GetGroupSyncable ¶
func (s *SqlGroupStore) GetGroupSyncable(groupID string, syncableID string, syncableType model.GroupSyncableType) (*model.GroupSyncable, *model.AppError)
func (*SqlGroupStore) GetGroups ¶
func (s *SqlGroupStore) GetGroups(page, perPage int, opts model.GroupSearchOpts) ([]*model.Group, *model.AppError)
func (*SqlGroupStore) GetGroupsByChannel ¶
func (s *SqlGroupStore) GetGroupsByChannel(channelId string, opts model.GroupSearchOpts) ([]*model.GroupWithSchemeAdmin, *model.AppError)
func (*SqlGroupStore) GetGroupsByTeam ¶
func (s *SqlGroupStore) GetGroupsByTeam(teamId string, opts model.GroupSearchOpts) ([]*model.GroupWithSchemeAdmin, *model.AppError)
func (*SqlGroupStore) GetMemberCount ¶
func (s *SqlGroupStore) GetMemberCount(groupID string) (int64, *model.AppError)
func (*SqlGroupStore) GetMemberUsers ¶
func (*SqlGroupStore) GetMemberUsersPage ¶
func (*SqlGroupStore) PermanentDeleteMembersByUser ¶
func (s *SqlGroupStore) PermanentDeleteMembersByUser(userId string) *model.AppError
func (*SqlGroupStore) PermittedSyncableAdmins ¶ added in v5.20.0
func (s *SqlGroupStore) PermittedSyncableAdmins(syncableID string, syncableType model.GroupSyncableType) ([]string, *model.AppError)
func (*SqlGroupStore) TeamMembersMinusGroupMembers ¶
func (s *SqlGroupStore) TeamMembersMinusGroupMembers(teamID string, groupIDs []string, page, perPage int) ([]*model.UserWithGroups, *model.AppError)
TeamMembersMinusGroupMembers returns the set of users on the given team minus the set of users in the given groups.
func (*SqlGroupStore) TeamMembersToAdd ¶
func (s *SqlGroupStore) TeamMembersToAdd(since int64, teamID *string) ([]*model.UserTeamIDPair, *model.AppError)
func (*SqlGroupStore) TeamMembersToRemove ¶
func (s *SqlGroupStore) TeamMembersToRemove(teamID *string) ([]*model.TeamMember, *model.AppError)
func (*SqlGroupStore) UpdateGroupSyncable ¶
func (s *SqlGroupStore) UpdateGroupSyncable(groupSyncable *model.GroupSyncable) (*model.GroupSyncable, *model.AppError)
func (*SqlGroupStore) UpsertMember ¶
func (s *SqlGroupStore) UpsertMember(groupID string, userID string) (*model.GroupMember, *model.AppError)
type SqlJobStore ¶
type SqlJobStore struct {
SqlStore
}
func (SqlJobStore) CreateIndexesIfNotExists ¶
func (jss SqlJobStore) CreateIndexesIfNotExists()
func (SqlJobStore) GetAllByStatus ¶
func (SqlJobStore) GetAllByType ¶
func (SqlJobStore) GetAllByTypePage ¶
func (SqlJobStore) GetAllPage ¶
func (SqlJobStore) GetCountByStatusAndType ¶
func (SqlJobStore) GetNewestJobByStatusAndType ¶
func (SqlJobStore) UpdateOptimistically ¶
func (SqlJobStore) UpdateStatus ¶
func (SqlJobStore) UpdateStatusOptimistically ¶
type SqlLicenseStore ¶
type SqlLicenseStore struct {
SqlStore
}
func (SqlLicenseStore) CreateIndexesIfNotExists ¶
func (ls SqlLicenseStore) CreateIndexesIfNotExists()
func (SqlLicenseStore) Get ¶
func (ls SqlLicenseStore) Get(id string) (*model.LicenseRecord, *model.AppError)
func (SqlLicenseStore) Save ¶
func (ls SqlLicenseStore) Save(license *model.LicenseRecord) (*model.LicenseRecord, *model.AppError)
type SqlLinkMetadataStore ¶
type SqlLinkMetadataStore struct {
SqlStore
}
func (SqlLinkMetadataStore) CreateIndexesIfNotExists ¶
func (s SqlLinkMetadataStore) CreateIndexesIfNotExists()
func (SqlLinkMetadataStore) Get ¶
func (s SqlLinkMetadataStore) Get(url string, timestamp int64) (*model.LinkMetadata, *model.AppError)
func (SqlLinkMetadataStore) Save ¶
func (s SqlLinkMetadataStore) Save(metadata *model.LinkMetadata) (*model.LinkMetadata, *model.AppError)
type SqlOAuthStore ¶
type SqlOAuthStore struct {
SqlStore
}
func (SqlOAuthStore) CreateIndexesIfNotExists ¶
func (as SqlOAuthStore) CreateIndexesIfNotExists()
func (SqlOAuthStore) GetAccessData ¶
func (as SqlOAuthStore) GetAccessData(token string) (*model.AccessData, *model.AppError)
func (SqlOAuthStore) GetAccessDataByRefreshToken ¶
func (as SqlOAuthStore) GetAccessDataByRefreshToken(token string) (*model.AccessData, *model.AppError)
func (SqlOAuthStore) GetAccessDataByUserForApp ¶
func (as SqlOAuthStore) GetAccessDataByUserForApp(userId, clientId string) ([]*model.AccessData, *model.AppError)
func (SqlOAuthStore) GetAppByUser ¶
func (SqlOAuthStore) GetAuthData ¶
func (SqlOAuthStore) GetAuthorizedApps ¶
func (SqlOAuthStore) GetPreviousAccessData ¶
func (as SqlOAuthStore) GetPreviousAccessData(userId, clientId string) (*model.AccessData, *model.AppError)
func (SqlOAuthStore) PermanentDeleteAuthDataByUser ¶
func (as SqlOAuthStore) PermanentDeleteAuthDataByUser(userId string) *model.AppError
func (SqlOAuthStore) RemoveAccessData ¶
func (as SqlOAuthStore) RemoveAccessData(token string) *model.AppError
func (SqlOAuthStore) RemoveAllAccessData ¶
func (as SqlOAuthStore) RemoveAllAccessData() *model.AppError
func (SqlOAuthStore) RemoveAuthData ¶
func (as SqlOAuthStore) RemoveAuthData(code string) *model.AppError
func (SqlOAuthStore) SaveAccessData ¶
func (as SqlOAuthStore) SaveAccessData(accessData *model.AccessData) (*model.AccessData, *model.AppError)
func (SqlOAuthStore) SaveAuthData ¶
func (SqlOAuthStore) UpdateAccessData ¶
func (as SqlOAuthStore) UpdateAccessData(accessData *model.AccessData) (*model.AccessData, *model.AppError)
type SqlPluginStore ¶
type SqlPluginStore struct {
SqlStore
}
func (SqlPluginStore) CompareAndDelete ¶
func (ps SqlPluginStore) CompareAndDelete(kv *model.PluginKeyValue, oldValue []byte) (bool, *model.AppError)
func (SqlPluginStore) CompareAndSet ¶
func (ps SqlPluginStore) CompareAndSet(kv *model.PluginKeyValue, oldValue []byte) (bool, *model.AppError)
func (SqlPluginStore) CreateIndexesIfNotExists ¶
func (ps SqlPluginStore) CreateIndexesIfNotExists()
func (SqlPluginStore) Delete ¶
func (ps SqlPluginStore) Delete(pluginId, key string) *model.AppError
func (SqlPluginStore) DeleteAllExpired ¶
func (ps SqlPluginStore) DeleteAllExpired() *model.AppError
func (SqlPluginStore) DeleteAllForPlugin ¶
func (ps SqlPluginStore) DeleteAllForPlugin(pluginId string) *model.AppError
func (SqlPluginStore) Get ¶
func (ps SqlPluginStore) Get(pluginId, key string) (*model.PluginKeyValue, *model.AppError)
func (SqlPluginStore) SaveOrUpdate ¶
func (ps SqlPluginStore) SaveOrUpdate(kv *model.PluginKeyValue) (*model.PluginKeyValue, *model.AppError)
func (SqlPluginStore) SetWithOptions ¶
func (ps SqlPluginStore) SetWithOptions(pluginId string, key string, value []byte, opt model.PluginKVSetOptions) (bool, *model.AppError)
type SqlPostStore ¶
type SqlPostStore struct { SqlStore // contains filtered or unexported fields }
func (*SqlPostStore) AnalyticsPostCount ¶
func (*SqlPostStore) AnalyticsPostCountsByDay ¶
func (s *SqlPostStore) AnalyticsPostCountsByDay(options *model.AnalyticsPostCountsOptions) (model.AnalyticsRows, *model.AppError)
func (*SqlPostStore) AnalyticsUserCountsWithPostsByDay ¶
func (s *SqlPostStore) AnalyticsUserCountsWithPostsByDay(teamId string) (model.AnalyticsRows, *model.AppError)
func (*SqlPostStore) ClearCaches ¶
func (s *SqlPostStore) ClearCaches()
func (*SqlPostStore) CreateIndexesIfNotExists ¶
func (s *SqlPostStore) CreateIndexesIfNotExists()
func (*SqlPostStore) GetDirectPostParentsForExportAfter ¶
func (s *SqlPostStore) GetDirectPostParentsForExportAfter(limit int, afterId string) ([]*model.DirectPostForExport, *model.AppError)
func (*SqlPostStore) GetEtag ¶
func (s *SqlPostStore) GetEtag(channelId string, allowFromCache bool) string
func (*SqlPostStore) GetFlaggedPosts ¶
func (*SqlPostStore) GetFlaggedPostsForChannel ¶
func (*SqlPostStore) GetFlaggedPostsForTeam ¶
func (*SqlPostStore) GetMaxPostSize ¶
func (s *SqlPostStore) GetMaxPostSize() int
GetMaxPostSize returns the maximum number of runes that may be stored in a post.
func (*SqlPostStore) GetParentsForExportAfter ¶
func (s *SqlPostStore) GetParentsForExportAfter(limit int, afterId string) ([]*model.PostForExport, *model.AppError)
func (*SqlPostStore) GetPostAfterTime ¶
func (*SqlPostStore) GetPostIdAfterTime ¶
func (*SqlPostStore) GetPostIdBeforeTime ¶
func (*SqlPostStore) GetPostsAfter ¶
func (*SqlPostStore) GetPostsBatchForIndexing ¶
func (s *SqlPostStore) GetPostsBatchForIndexing(startTime int64, endTime int64, limit int) ([]*model.PostForIndexing, *model.AppError)
func (*SqlPostStore) GetPostsBefore ¶
func (*SqlPostStore) GetPostsByIds ¶
func (*SqlPostStore) GetPostsCreatedAt ¶
func (*SqlPostStore) GetPostsSince ¶
func (*SqlPostStore) GetRepliesForExport ¶
func (s *SqlPostStore) GetRepliesForExport(rootId string) ([]*model.ReplyForExport, *model.AppError)
func (*SqlPostStore) InvalidateLastPostTimeCache ¶
func (s *SqlPostStore) InvalidateLastPostTimeCache(channelId string)
func (*SqlPostStore) PermanentDeleteBatch ¶
func (*SqlPostStore) PermanentDeleteByChannel ¶
func (s *SqlPostStore) PermanentDeleteByChannel(channelId string) *model.AppError
func (*SqlPostStore) PermanentDeleteByUser ¶
func (s *SqlPostStore) PermanentDeleteByUser(userId string) *model.AppError
type SqlPreferenceStore ¶
type SqlPreferenceStore struct {
SqlStore
}
func (SqlPreferenceStore) CleanupFlagsBatch ¶
func (s SqlPreferenceStore) CleanupFlagsBatch(limit int64) (int64, *model.AppError)
func (SqlPreferenceStore) CreateIndexesIfNotExists ¶
func (s SqlPreferenceStore) CreateIndexesIfNotExists()
func (SqlPreferenceStore) Delete ¶
func (s SqlPreferenceStore) Delete(userId, category, name string) *model.AppError
func (SqlPreferenceStore) DeleteCategory ¶
func (s SqlPreferenceStore) DeleteCategory(userId string, category string) *model.AppError
func (SqlPreferenceStore) DeleteCategoryAndName ¶
func (s SqlPreferenceStore) DeleteCategoryAndName(category string, name string) *model.AppError
func (SqlPreferenceStore) DeleteUnusedFeatures ¶
func (s SqlPreferenceStore) DeleteUnusedFeatures()
func (SqlPreferenceStore) Get ¶
func (s SqlPreferenceStore) Get(userId string, category string, name string) (*model.Preference, *model.AppError)
func (SqlPreferenceStore) GetAll ¶
func (s SqlPreferenceStore) GetAll(userId string) (model.Preferences, *model.AppError)
func (SqlPreferenceStore) GetCategory ¶
func (s SqlPreferenceStore) GetCategory(userId string, category string) (model.Preferences, *model.AppError)
func (SqlPreferenceStore) PermanentDeleteByUser ¶
func (s SqlPreferenceStore) PermanentDeleteByUser(userId string) *model.AppError
func (SqlPreferenceStore) Save ¶
func (s SqlPreferenceStore) Save(preferences *model.Preferences) *model.AppError
type SqlReactionStore ¶
type SqlReactionStore struct {
SqlStore
}
func (*SqlReactionStore) BulkGetForPosts ¶
func (SqlReactionStore) CreateIndexesIfNotExists ¶
func (s SqlReactionStore) CreateIndexesIfNotExists()
func (*SqlReactionStore) DeleteAllWithEmojiName ¶
func (s *SqlReactionStore) DeleteAllWithEmojiName(emojiName string) *model.AppError
func (*SqlReactionStore) GetForPost ¶
func (*SqlReactionStore) PermanentDeleteBatch ¶
type SqlRoleStore ¶
type SqlRoleStore struct {
SqlStore
}
func (SqlRoleStore) CreateIndexesIfNotExists ¶
func (s SqlRoleStore) CreateIndexesIfNotExists()
func (*SqlRoleStore) GetByNames ¶
func (*SqlRoleStore) PermanentDeleteAll ¶
func (s *SqlRoleStore) PermanentDeleteAll() *model.AppError
type SqlSchemeStore ¶
type SqlSchemeStore struct {
SqlStore
}
func (SqlSchemeStore) CreateIndexesIfNotExists ¶
func (s SqlSchemeStore) CreateIndexesIfNotExists()
func (*SqlSchemeStore) GetAllPage ¶
func (*SqlSchemeStore) PermanentDeleteAll ¶
func (s *SqlSchemeStore) PermanentDeleteAll() *model.AppError
type SqlSessionStore ¶
type SqlSessionStore struct {
SqlStore
}
func (SqlSessionStore) AnalyticsSessionCount ¶
func (me SqlSessionStore) AnalyticsSessionCount() (int64, *model.AppError)
func (SqlSessionStore) Cleanup ¶
func (me SqlSessionStore) Cleanup(expiryTime int64, batchSize int64)
func (SqlSessionStore) CreateIndexesIfNotExists ¶
func (me SqlSessionStore) CreateIndexesIfNotExists()
func (SqlSessionStore) GetSessions ¶
func (SqlSessionStore) GetSessionsWithActiveDeviceIds ¶
func (SqlSessionStore) PermanentDeleteSessionsByUser ¶
func (me SqlSessionStore) PermanentDeleteSessionsByUser(userId string) *model.AppError
func (SqlSessionStore) Remove ¶
func (me SqlSessionStore) Remove(sessionIdOrToken string) *model.AppError
func (SqlSessionStore) RemoveAllSessions ¶
func (me SqlSessionStore) RemoveAllSessions() *model.AppError
func (SqlSessionStore) UpdateDeviceId ¶
func (SqlSessionStore) UpdateLastActivityAt ¶
func (me SqlSessionStore) UpdateLastActivityAt(sessionId string, time int64) *model.AppError
func (SqlSessionStore) UpdateProps ¶
func (me SqlSessionStore) UpdateProps(session *model.Session) *model.AppError
func (SqlSessionStore) UpdateRoles ¶
func (me SqlSessionStore) UpdateRoles(userId, roles string) (string, *model.AppError)
type SqlStatusStore ¶
type SqlStatusStore struct {
SqlStore
}
func (SqlStatusStore) CreateIndexesIfNotExists ¶
func (s SqlStatusStore) CreateIndexesIfNotExists()
func (SqlStatusStore) GetTotalActiveUsersCount ¶
func (s SqlStatusStore) GetTotalActiveUsersCount() (int64, *model.AppError)
func (SqlStatusStore) ResetAll ¶
func (s SqlStatusStore) ResetAll() *model.AppError
func (SqlStatusStore) SaveOrUpdate ¶
func (s SqlStatusStore) SaveOrUpdate(status *model.Status) *model.AppError
func (SqlStatusStore) UpdateLastActivityAt ¶
func (s SqlStatusStore) UpdateLastActivityAt(userId string, lastActivityAt int64) *model.AppError
type SqlStore ¶
type SqlStore interface { DriverName() string GetCurrentSchemaVersion() string GetMaster() *gorp.DbMap GetSearchReplica() *gorp.DbMap GetReplica() *gorp.DbMap TotalMasterDbConnections() int TotalReadDbConnections() int TotalSearchDbConnections() int MarkSystemRanUnitTests() DoesTableExist(tablename string) bool DoesColumnExist(tableName string, columName string) bool DoesTriggerExist(triggerName string) bool CreateColumnIfNotExists(tableName string, columnName string, mySqlColType string, postgresColType string, defaultValue string) bool CreateColumnIfNotExistsNoDefault(tableName string, columnName string, mySqlColType string, postgresColType string) bool RemoveColumnIfExists(tableName string, columnName string) bool RemoveTableIfExists(tableName string) bool RenameColumnIfExists(tableName string, oldColumnName string, newColumnName string, colType string) bool GetMaxLengthOfColumnIfExists(tableName string, columnName string) string AlterColumnTypeIfExists(tableName string, columnName string, mySqlColType string, postgresColType string) bool AlterColumnDefaultIfExists(tableName string, columnName string, mySqlColDefault *string, postgresColDefault *string) bool CreateUniqueIndexIfNotExists(indexName string, tableName string, columnName string) bool CreateIndexIfNotExists(indexName string, tableName string, columnName string) bool CreateCompositeIndexIfNotExists(indexName string, tableName string, columnNames []string) bool CreateFullTextIndexIfNotExists(indexName string, tableName string, columnName string) bool RemoveIndexIfExists(indexName string, tableName string) bool GetAllConns() []*gorp.DbMap Close() LockToMaster() UnlockFromMaster() Team() store.TeamStore Channel() store.ChannelStore Post() store.PostStore User() store.UserStore Bot() store.BotStore Audit() store.AuditStore ClusterDiscovery() store.ClusterDiscoveryStore Compliance() store.ComplianceStore Session() store.SessionStore OAuth() store.OAuthStore System() store.SystemStore Webhook() store.WebhookStore Command() store.CommandStore CommandWebhook() store.CommandWebhookStore Preference() store.PreferenceStore License() store.LicenseStore Token() store.TokenStore Emoji() store.EmojiStore Status() store.StatusStore FileInfo() store.FileInfoStore Reaction() store.ReactionStore Job() store.JobStore Plugin() store.PluginStore UserAccessToken() store.UserAccessTokenStore Role() store.RoleStore Scheme() store.SchemeStore TermsOfService() store.TermsOfServiceStore UserTermsOfService() store.UserTermsOfServiceStore LinkMetadata() store.LinkMetadataStore // contains filtered or unexported methods }
type SqlSupplier ¶
type SqlSupplier struct {
// contains filtered or unexported fields
}
func NewSqlSupplier ¶
func NewSqlSupplier(settings model.SqlSettings, metrics einterfaces.MetricsInterface) *SqlSupplier
func (*SqlSupplier) AlterColumnDefaultIfExists ¶
func (*SqlSupplier) AlterColumnTypeIfExists ¶
func (*SqlSupplier) Audit ¶
func (ss *SqlSupplier) Audit() store.AuditStore
func (*SqlSupplier) Bot ¶
func (ss *SqlSupplier) Bot() store.BotStore
func (*SqlSupplier) Channel ¶
func (ss *SqlSupplier) Channel() store.ChannelStore
func (*SqlSupplier) ChannelMemberHistory ¶
func (ss *SqlSupplier) ChannelMemberHistory() store.ChannelMemberHistoryStore
func (*SqlSupplier) CheckIntegrity ¶
func (ss *SqlSupplier) CheckIntegrity() <-chan store.IntegrityCheckResult
func (*SqlSupplier) Close ¶
func (ss *SqlSupplier) Close()
func (*SqlSupplier) ClusterDiscovery ¶
func (ss *SqlSupplier) ClusterDiscovery() store.ClusterDiscoveryStore
func (*SqlSupplier) Command ¶
func (ss *SqlSupplier) Command() store.CommandStore
func (*SqlSupplier) CommandWebhook ¶
func (ss *SqlSupplier) CommandWebhook() store.CommandWebhookStore
func (*SqlSupplier) Compliance ¶
func (ss *SqlSupplier) Compliance() store.ComplianceStore
func (*SqlSupplier) CreateColumnIfNotExists ¶
func (*SqlSupplier) CreateColumnIfNotExistsNoDefault ¶
func (*SqlSupplier) CreateCompositeIndexIfNotExists ¶
func (ss *SqlSupplier) CreateCompositeIndexIfNotExists(indexName string, tableName string, columnNames []string) bool
func (*SqlSupplier) CreateFullTextIndexIfNotExists ¶
func (ss *SqlSupplier) CreateFullTextIndexIfNotExists(indexName string, tableName string, columnName string) bool
func (*SqlSupplier) CreateIndexIfNotExists ¶
func (ss *SqlSupplier) CreateIndexIfNotExists(indexName string, tableName string, columnName string) bool
func (*SqlSupplier) CreateUniqueIndexIfNotExists ¶
func (ss *SqlSupplier) CreateUniqueIndexIfNotExists(indexName string, tableName string, columnName string) bool
func (*SqlSupplier) DoesColumnExist ¶
func (ss *SqlSupplier) DoesColumnExist(tableName string, columnName string) bool
func (*SqlSupplier) DoesTableExist ¶
func (ss *SqlSupplier) DoesTableExist(tableName string) bool
func (*SqlSupplier) DoesTriggerExist ¶
func (ss *SqlSupplier) DoesTriggerExist(triggerName string) bool
func (*SqlSupplier) DriverName ¶
func (ss *SqlSupplier) DriverName() string
func (*SqlSupplier) DropAllTables ¶
func (ss *SqlSupplier) DropAllTables()
func (*SqlSupplier) Emoji ¶
func (ss *SqlSupplier) Emoji() store.EmojiStore
func (*SqlSupplier) FileInfo ¶
func (ss *SqlSupplier) FileInfo() store.FileInfoStore
func (*SqlSupplier) GetAllConns ¶
func (ss *SqlSupplier) GetAllConns() []*gorp.DbMap
func (*SqlSupplier) GetCurrentSchemaVersion ¶
func (ss *SqlSupplier) GetCurrentSchemaVersion() string
func (*SqlSupplier) GetMaster ¶
func (ss *SqlSupplier) GetMaster() *gorp.DbMap
func (*SqlSupplier) GetMaxLengthOfColumnIfExists ¶
func (ss *SqlSupplier) GetMaxLengthOfColumnIfExists(tableName string, columnName string) string
func (*SqlSupplier) GetReplica ¶
func (ss *SqlSupplier) GetReplica() *gorp.DbMap
func (*SqlSupplier) GetSearchReplica ¶
func (ss *SqlSupplier) GetSearchReplica() *gorp.DbMap
func (*SqlSupplier) Group ¶
func (ss *SqlSupplier) Group() store.GroupStore
func (*SqlSupplier) Job ¶
func (ss *SqlSupplier) Job() store.JobStore
func (*SqlSupplier) License ¶
func (ss *SqlSupplier) License() store.LicenseStore
func (*SqlSupplier) LinkMetadata ¶
func (ss *SqlSupplier) LinkMetadata() store.LinkMetadataStore
func (*SqlSupplier) LockToMaster ¶
func (ss *SqlSupplier) LockToMaster()
func (*SqlSupplier) MarkSystemRanUnitTests ¶
func (ss *SqlSupplier) MarkSystemRanUnitTests()
func (*SqlSupplier) OAuth ¶
func (ss *SqlSupplier) OAuth() store.OAuthStore
func (*SqlSupplier) Plugin ¶
func (ss *SqlSupplier) Plugin() store.PluginStore
func (*SqlSupplier) Post ¶
func (ss *SqlSupplier) Post() store.PostStore
func (*SqlSupplier) Preference ¶
func (ss *SqlSupplier) Preference() store.PreferenceStore
func (*SqlSupplier) Reaction ¶
func (ss *SqlSupplier) Reaction() store.ReactionStore
func (*SqlSupplier) RemoveColumnIfExists ¶
func (ss *SqlSupplier) RemoveColumnIfExists(tableName string, columnName string) bool
func (*SqlSupplier) RemoveIndexIfExists ¶
func (ss *SqlSupplier) RemoveIndexIfExists(indexName string, tableName string) bool
func (*SqlSupplier) RemoveTableIfExists ¶
func (ss *SqlSupplier) RemoveTableIfExists(tableName string) bool
func (*SqlSupplier) RenameColumnIfExists ¶
func (*SqlSupplier) Role ¶
func (ss *SqlSupplier) Role() store.RoleStore
func (*SqlSupplier) Scheme ¶
func (ss *SqlSupplier) Scheme() store.SchemeStore
func (*SqlSupplier) Session ¶
func (ss *SqlSupplier) Session() store.SessionStore
func (*SqlSupplier) Status ¶
func (ss *SqlSupplier) Status() store.StatusStore
func (*SqlSupplier) System ¶
func (ss *SqlSupplier) System() store.SystemStore
func (*SqlSupplier) Team ¶
func (ss *SqlSupplier) Team() store.TeamStore
func (*SqlSupplier) TermsOfService ¶
func (ss *SqlSupplier) TermsOfService() store.TermsOfServiceStore
func (*SqlSupplier) Token ¶
func (ss *SqlSupplier) Token() store.TokenStore
func (*SqlSupplier) TotalMasterDbConnections ¶
func (ss *SqlSupplier) TotalMasterDbConnections() int
func (*SqlSupplier) TotalReadDbConnections ¶
func (ss *SqlSupplier) TotalReadDbConnections() int
func (*SqlSupplier) TotalSearchDbConnections ¶
func (ss *SqlSupplier) TotalSearchDbConnections() int
func (*SqlSupplier) UnlockFromMaster ¶
func (ss *SqlSupplier) UnlockFromMaster()
func (*SqlSupplier) User ¶
func (ss *SqlSupplier) User() store.UserStore
func (*SqlSupplier) UserAccessToken ¶
func (ss *SqlSupplier) UserAccessToken() store.UserAccessTokenStore
func (*SqlSupplier) UserTermsOfService ¶
func (ss *SqlSupplier) UserTermsOfService() store.UserTermsOfServiceStore
func (*SqlSupplier) Webhook ¶
func (ss *SqlSupplier) Webhook() store.WebhookStore
type SqlSupplierStores ¶
type SqlSupplierStores struct { TermsOfService store.TermsOfServiceStore UserTermsOfService store.UserTermsOfServiceStore // contains filtered or unexported fields }
type SqlSystemStore ¶
type SqlSystemStore struct {
SqlStore
}
func (SqlSystemStore) CreateIndexesIfNotExists ¶
func (s SqlSystemStore) CreateIndexesIfNotExists()
func (SqlSystemStore) PermanentDeleteByName ¶
func (SqlSystemStore) SaveOrUpdate ¶
func (s SqlSystemStore) SaveOrUpdate(system *model.System) *model.AppError
type SqlTeamStore ¶
type SqlTeamStore struct {
SqlStore
}
func (SqlTeamStore) AnalyticsGetTeamCountForScheme ¶
func (s SqlTeamStore) AnalyticsGetTeamCountForScheme(schemeId string) (int64, *model.AppError)
func (SqlTeamStore) AnalyticsPrivateTeamCount ¶
func (s SqlTeamStore) AnalyticsPrivateTeamCount() (int64, *model.AppError)
func (SqlTeamStore) AnalyticsPublicTeamCount ¶
func (s SqlTeamStore) AnalyticsPublicTeamCount() (int64, *model.AppError)
func (SqlTeamStore) AnalyticsTeamCount ¶
func (s SqlTeamStore) AnalyticsTeamCount(includeDeleted bool) (int64, *model.AppError)
func (SqlTeamStore) ClearAllCustomRoleAssignments ¶
func (s SqlTeamStore) ClearAllCustomRoleAssignments() *model.AppError
func (SqlTeamStore) ClearCaches ¶
func (s SqlTeamStore) ClearCaches()
func (SqlTeamStore) CreateIndexesIfNotExists ¶
func (s SqlTeamStore) CreateIndexesIfNotExists()
func (SqlTeamStore) GetActiveMemberCount ¶
func (s SqlTeamStore) GetActiveMemberCount(teamId string, restrictions *model.ViewUsersRestrictions) (int64, *model.AppError)
func (SqlTeamStore) GetAllForExportAfter ¶
func (s SqlTeamStore) GetAllForExportAfter(limit int, afterId string) ([]*model.TeamForExport, *model.AppError)
func (SqlTeamStore) GetAllPage ¶
func (SqlTeamStore) GetAllPrivateTeamListing ¶
func (s SqlTeamStore) GetAllPrivateTeamListing() ([]*model.Team, *model.AppError)
func (SqlTeamStore) GetAllPrivateTeamPageListing ¶
func (SqlTeamStore) GetAllPublicTeamPageListing ¶
func (SqlTeamStore) GetAllTeamListing ¶
func (s SqlTeamStore) GetAllTeamListing() ([]*model.Team, *model.AppError)
func (SqlTeamStore) GetAllTeamPageListing ¶
func (SqlTeamStore) GetByInviteId ¶
func (SqlTeamStore) GetChannelUnreadsForAllTeams ¶
func (s SqlTeamStore) GetChannelUnreadsForAllTeams(excludeTeamId, userId string) ([]*model.ChannelUnread, *model.AppError)
func (SqlTeamStore) GetChannelUnreadsForTeam ¶
func (s SqlTeamStore) GetChannelUnreadsForTeam(teamId, userId string) ([]*model.ChannelUnread, *model.AppError)
func (SqlTeamStore) GetMember ¶
func (s SqlTeamStore) GetMember(teamId string, userId string) (*model.TeamMember, *model.AppError)
func (SqlTeamStore) GetMembers ¶
func (s SqlTeamStore) GetMembers(teamId string, offset int, limit int, restrictions *model.ViewUsersRestrictions) ([]*model.TeamMember, *model.AppError)
func (SqlTeamStore) GetMembersByIds ¶
func (s SqlTeamStore) GetMembersByIds(teamId string, userIds []string, restrictions *model.ViewUsersRestrictions) ([]*model.TeamMember, *model.AppError)
func (SqlTeamStore) GetTeamMembersForExport ¶
func (s SqlTeamStore) GetTeamMembersForExport(userId string) ([]*model.TeamMemberForExport, *model.AppError)
func (SqlTeamStore) GetTeamsByScheme ¶
func (SqlTeamStore) GetTeamsByUserId ¶
func (SqlTeamStore) GetTeamsForUser ¶
func (s SqlTeamStore) GetTeamsForUser(userId string) ([]*model.TeamMember, *model.AppError)
func (SqlTeamStore) GetTeamsForUserWithPagination ¶
func (s SqlTeamStore) GetTeamsForUserWithPagination(userId string, page, perPage int) ([]*model.TeamMember, *model.AppError)
func (SqlTeamStore) GetTotalMemberCount ¶
func (s SqlTeamStore) GetTotalMemberCount(teamId string, restrictions *model.ViewUsersRestrictions) (int64, *model.AppError)
func (SqlTeamStore) GetUserTeamIds ¶
func (s SqlTeamStore) GetUserTeamIds(userID string, allowFromCache bool) ([]string, *model.AppError)
GetUserTeamIds get the team ids to which the user belongs to. allowFromCache parameter does not have any effect in this Store
func (SqlTeamStore) InvalidateAllTeamIdsForUser ¶
func (s SqlTeamStore) InvalidateAllTeamIdsForUser(userId string)
func (SqlTeamStore) MigrateTeamMembers ¶
func (s SqlTeamStore) MigrateTeamMembers(fromTeamId string, fromUserId string) (map[string]string, *model.AppError)
This function does the Advanced Permissions Phase 2 migration for TeamMember objects. It performs the migration in batches as a single transaction per batch to ensure consistency but to also minimise execution time to avoid causing unnecessary table locks. **THIS FUNCTION SHOULD NOT BE USED FOR ANY OTHER PURPOSE.** Executing this function *after* the new Schemes functionality has been used on an installation will have unintended consequences.
func (SqlTeamStore) PermanentDelete ¶
func (s SqlTeamStore) PermanentDelete(teamId string) *model.AppError
func (SqlTeamStore) RemoveAllMembersByTeam ¶
func (s SqlTeamStore) RemoveAllMembersByTeam(teamId string) *model.AppError
func (SqlTeamStore) RemoveAllMembersByUser ¶
func (s SqlTeamStore) RemoveAllMembersByUser(userId string) *model.AppError
func (SqlTeamStore) RemoveMember ¶
func (s SqlTeamStore) RemoveMember(teamId string, userId string) *model.AppError
func (SqlTeamStore) ResetAllTeamSchemes ¶
func (s SqlTeamStore) ResetAllTeamSchemes() *model.AppError
func (SqlTeamStore) SaveMember ¶
func (s SqlTeamStore) SaveMember(member *model.TeamMember, maxUsersPerTeam int) (*model.TeamMember, *model.AppError)
func (SqlTeamStore) SearchAllPaged ¶
func (s SqlTeamStore) SearchAllPaged(term string, page int, perPage int) ([]*model.Team, int64, *model.AppError)
SearchAllPaged returns a teams list and the total count of teams that matched the search.
func (SqlTeamStore) SearchOpen ¶
func (SqlTeamStore) SearchPrivate ¶
func (SqlTeamStore) UpdateLastTeamIconUpdate ¶
func (s SqlTeamStore) UpdateLastTeamIconUpdate(teamId string, curTime int64) *model.AppError
func (SqlTeamStore) UpdateMember ¶
func (s SqlTeamStore) UpdateMember(member *model.TeamMember) (*model.TeamMember, *model.AppError)
func (SqlTeamStore) UpdateMembersRole ¶ added in v5.20.0
func (s SqlTeamStore) UpdateMembersRole(teamID string, userIDs []string) *model.AppError
func (SqlTeamStore) UserBelongsToTeams ¶
type SqlTermsOfServiceStore ¶
type SqlTermsOfServiceStore struct { SqlStore // contains filtered or unexported fields }
func (SqlTermsOfServiceStore) CreateIndexesIfNotExists ¶
func (s SqlTermsOfServiceStore) CreateIndexesIfNotExists()
func (SqlTermsOfServiceStore) Get ¶
func (s SqlTermsOfServiceStore) Get(id string, allowFromCache bool) (*model.TermsOfService, *model.AppError)
func (SqlTermsOfServiceStore) GetLatest ¶
func (s SqlTermsOfServiceStore) GetLatest(allowFromCache bool) (*model.TermsOfService, *model.AppError)
func (SqlTermsOfServiceStore) Save ¶
func (s SqlTermsOfServiceStore) Save(termsOfService *model.TermsOfService) (*model.TermsOfService, *model.AppError)
type SqlTokenStore ¶
type SqlTokenStore struct {
SqlStore
}
func (SqlTokenStore) Cleanup ¶
func (s SqlTokenStore) Cleanup()
func (SqlTokenStore) CreateIndexesIfNotExists ¶
func (s SqlTokenStore) CreateIndexesIfNotExists()
func (SqlTokenStore) GetByToken ¶
func (SqlTokenStore) RemoveAllTokensByType ¶
func (s SqlTokenStore) RemoveAllTokensByType(tokenType string) *model.AppError
type SqlUserAccessTokenStore ¶
type SqlUserAccessTokenStore struct {
SqlStore
}
func (SqlUserAccessTokenStore) CreateIndexesIfNotExists ¶
func (s SqlUserAccessTokenStore) CreateIndexesIfNotExists()
func (SqlUserAccessTokenStore) Delete ¶
func (s SqlUserAccessTokenStore) Delete(tokenId string) *model.AppError
func (SqlUserAccessTokenStore) DeleteAllForUser ¶
func (s SqlUserAccessTokenStore) DeleteAllForUser(userId string) *model.AppError
func (SqlUserAccessTokenStore) Get ¶
func (s SqlUserAccessTokenStore) Get(tokenId string) (*model.UserAccessToken, *model.AppError)
func (SqlUserAccessTokenStore) GetAll ¶
func (s SqlUserAccessTokenStore) GetAll(offset, limit int) ([]*model.UserAccessToken, *model.AppError)
func (SqlUserAccessTokenStore) GetByToken ¶
func (s SqlUserAccessTokenStore) GetByToken(tokenString string) (*model.UserAccessToken, *model.AppError)
func (SqlUserAccessTokenStore) GetByUser ¶
func (s SqlUserAccessTokenStore) GetByUser(userId string, offset, limit int) ([]*model.UserAccessToken, *model.AppError)
func (SqlUserAccessTokenStore) Save ¶
func (s SqlUserAccessTokenStore) Save(token *model.UserAccessToken) (*model.UserAccessToken, *model.AppError)
func (SqlUserAccessTokenStore) Search ¶
func (s SqlUserAccessTokenStore) Search(term string) ([]*model.UserAccessToken, *model.AppError)
func (SqlUserAccessTokenStore) UpdateTokenDisable ¶
func (s SqlUserAccessTokenStore) UpdateTokenDisable(tokenId string) *model.AppError
func (SqlUserAccessTokenStore) UpdateTokenEnable ¶
func (s SqlUserAccessTokenStore) UpdateTokenEnable(tokenId string) *model.AppError
type SqlUserStore ¶
type SqlUserStore struct { SqlStore // contains filtered or unexported fields }
func (SqlUserStore) AnalyticsActiveCount ¶
func (us SqlUserStore) AnalyticsActiveCount(timePeriod int64, options model.UserCountOptions) (int64, *model.AppError)
func (SqlUserStore) AnalyticsGetInactiveUsersCount ¶
func (us SqlUserStore) AnalyticsGetInactiveUsersCount() (int64, *model.AppError)
func (SqlUserStore) AnalyticsGetSystemAdminCount ¶
func (us SqlUserStore) AnalyticsGetSystemAdminCount() (int64, *model.AppError)
func (SqlUserStore) ClearAllCustomRoleAssignments ¶
func (us SqlUserStore) ClearAllCustomRoleAssignments() *model.AppError
func (SqlUserStore) ClearCaches ¶
func (us SqlUserStore) ClearCaches()
func (SqlUserStore) Count ¶
func (us SqlUserStore) Count(options model.UserCountOptions) (int64, *model.AppError)
func (SqlUserStore) CreateIndexesIfNotExists ¶
func (us SqlUserStore) CreateIndexesIfNotExists()
func (SqlUserStore) DeactivateGuests ¶
func (us SqlUserStore) DeactivateGuests() ([]string, *model.AppError)
func (SqlUserStore) DemoteUserToGuest ¶
func (us SqlUserStore) DemoteUserToGuest(userId string) *model.AppError
func (SqlUserStore) GetAllAfter ¶
func (SqlUserStore) GetAllProfiles ¶
func (us SqlUserStore) GetAllProfiles(options *model.UserGetOptions) ([]*model.User, *model.AppError)
func (SqlUserStore) GetAllProfilesInChannel ¶
func (SqlUserStore) GetAllUsingAuthService ¶
func (SqlUserStore) GetAnyUnreadPostCountForChannel ¶
func (SqlUserStore) GetByEmail ¶
func (SqlUserStore) GetByUsername ¶
func (SqlUserStore) GetChannelGroupUsers ¶
func (SqlUserStore) GetEtagForAllProfiles ¶
func (us SqlUserStore) GetEtagForAllProfiles() string
func (SqlUserStore) GetEtagForProfiles ¶
func (us SqlUserStore) GetEtagForProfiles(teamId string) string
func (SqlUserStore) GetEtagForProfilesNotInTeam ¶
func (us SqlUserStore) GetEtagForProfilesNotInTeam(teamId string) string
func (SqlUserStore) GetForLogin ¶
func (SqlUserStore) GetNewUsersForTeam ¶
func (us SqlUserStore) GetNewUsersForTeam(teamId string, offset, limit int, viewRestrictions *model.ViewUsersRestrictions) ([]*model.User, *model.AppError)
func (SqlUserStore) GetProfileByGroupChannelIdsForUser ¶
func (SqlUserStore) GetProfileByIds ¶
func (us SqlUserStore) GetProfileByIds(userIds []string, options *store.UserGetByIdsOpts, _ bool) ([]*model.User, *model.AppError)
func (SqlUserStore) GetProfiles ¶
func (us SqlUserStore) GetProfiles(options *model.UserGetOptions) ([]*model.User, *model.AppError)
func (SqlUserStore) GetProfilesByUsernames ¶
func (us SqlUserStore) GetProfilesByUsernames(usernames []string, viewRestrictions *model.ViewUsersRestrictions) ([]*model.User, *model.AppError)
func (SqlUserStore) GetProfilesInChannel ¶
func (SqlUserStore) GetProfilesInChannelByStatus ¶
func (SqlUserStore) GetProfilesNotInChannel ¶
func (SqlUserStore) GetProfilesNotInTeam ¶
func (SqlUserStore) GetProfilesWithoutTeam ¶
func (us SqlUserStore) GetProfilesWithoutTeam(options *model.UserGetOptions) ([]*model.User, *model.AppError)
func (SqlUserStore) GetRecentlyActiveUsersForTeam ¶
func (us SqlUserStore) GetRecentlyActiveUsersForTeam(teamId string, offset, limit int, viewRestrictions *model.ViewUsersRestrictions) ([]*model.User, *model.AppError)
func (SqlUserStore) GetSystemAdminProfiles ¶
func (SqlUserStore) GetTeamGroupUsers ¶
func (SqlUserStore) GetUnreadCount ¶
func (us SqlUserStore) GetUnreadCount(userId string) (int64, *model.AppError)
func (SqlUserStore) GetUnreadCountForChannel ¶
func (SqlUserStore) GetUsersBatchForIndexing ¶
func (us SqlUserStore) GetUsersBatchForIndexing(startTime, endTime int64, limit int) ([]*model.UserForIndexing, *model.AppError)
func (SqlUserStore) InferSystemInstallDate ¶
func (us SqlUserStore) InferSystemInstallDate() (int64, *model.AppError)
func (SqlUserStore) InvalidateProfileCacheForUser ¶ added in v5.20.0
func (us SqlUserStore) InvalidateProfileCacheForUser(userId string)
func (SqlUserStore) InvalidateProfilesInChannelCache ¶
func (us SqlUserStore) InvalidateProfilesInChannelCache(channelId string)
func (SqlUserStore) InvalidateProfilesInChannelCacheByUser ¶
func (us SqlUserStore) InvalidateProfilesInChannelCacheByUser(userId string)
func (SqlUserStore) PermanentDelete ¶
func (us SqlUserStore) PermanentDelete(userId string) *model.AppError
func (SqlUserStore) PromoteGuestToUser ¶
func (us SqlUserStore) PromoteGuestToUser(userId string) *model.AppError
func (SqlUserStore) ResetLastPictureUpdate ¶
func (us SqlUserStore) ResetLastPictureUpdate(userId string) *model.AppError
func (SqlUserStore) Search ¶
func (us SqlUserStore) Search(teamId string, term string, options *model.UserSearchOptions) ([]*model.User, *model.AppError)
func (SqlUserStore) SearchInChannel ¶
func (us SqlUserStore) SearchInChannel(channelId string, term string, options *model.UserSearchOptions) ([]*model.User, *model.AppError)
func (SqlUserStore) SearchNotInChannel ¶
func (us SqlUserStore) SearchNotInChannel(teamId string, channelId string, term string, options *model.UserSearchOptions) ([]*model.User, *model.AppError)
func (SqlUserStore) SearchNotInTeam ¶
func (us SqlUserStore) SearchNotInTeam(notInTeamId string, term string, options *model.UserSearchOptions) ([]*model.User, *model.AppError)
func (SqlUserStore) SearchWithoutTeam ¶
func (us SqlUserStore) SearchWithoutTeam(term string, options *model.UserSearchOptions) ([]*model.User, *model.AppError)
func (SqlUserStore) Update ¶
func (us SqlUserStore) Update(user *model.User, trustedUpdateData bool) (*model.UserUpdate, *model.AppError)
func (SqlUserStore) UpdateAuthData ¶
func (SqlUserStore) UpdateFailedPasswordAttempts ¶
func (us SqlUserStore) UpdateFailedPasswordAttempts(userId string, attempts int) *model.AppError
func (SqlUserStore) UpdateLastPictureUpdate ¶
func (us SqlUserStore) UpdateLastPictureUpdate(userId string) *model.AppError
func (SqlUserStore) UpdateMfaActive ¶
func (us SqlUserStore) UpdateMfaActive(userId string, active bool) *model.AppError
func (SqlUserStore) UpdateMfaSecret ¶
func (us SqlUserStore) UpdateMfaSecret(userId, secret string) *model.AppError
func (SqlUserStore) UpdatePassword ¶
func (us SqlUserStore) UpdatePassword(userId, hashedPassword string) *model.AppError
func (SqlUserStore) UpdateUpdateAt ¶
func (us SqlUserStore) UpdateUpdateAt(userId string) (int64, *model.AppError)
func (SqlUserStore) VerifyEmail ¶
func (us SqlUserStore) VerifyEmail(userId, email string) (string, *model.AppError)
type SqlUserTermsOfServiceStore ¶
type SqlUserTermsOfServiceStore struct {
SqlStore
}
func (SqlUserTermsOfServiceStore) CreateIndexesIfNotExists ¶
func (s SqlUserTermsOfServiceStore) CreateIndexesIfNotExists()
func (SqlUserTermsOfServiceStore) Delete ¶
func (s SqlUserTermsOfServiceStore) Delete(userId, termsOfServiceId string) *model.AppError
func (SqlUserTermsOfServiceStore) GetByUser ¶
func (s SqlUserTermsOfServiceStore) GetByUser(userId string) (*model.UserTermsOfService, *model.AppError)
func (SqlUserTermsOfServiceStore) Save ¶
func (s SqlUserTermsOfServiceStore) Save(userTermsOfService *model.UserTermsOfService) (*model.UserTermsOfService, *model.AppError)
type SqlWebhookStore ¶
type SqlWebhookStore struct { SqlStore // contains filtered or unexported fields }
func (SqlWebhookStore) AnalyticsIncomingCount ¶
func (s SqlWebhookStore) AnalyticsIncomingCount(teamId string) (int64, *model.AppError)
func (SqlWebhookStore) AnalyticsOutgoingCount ¶
func (s SqlWebhookStore) AnalyticsOutgoingCount(teamId string) (int64, *model.AppError)
func (SqlWebhookStore) ClearCaches ¶
func (s SqlWebhookStore) ClearCaches()
func (SqlWebhookStore) CreateIndexesIfNotExists ¶
func (s SqlWebhookStore) CreateIndexesIfNotExists()
func (SqlWebhookStore) DeleteIncoming ¶
func (s SqlWebhookStore) DeleteIncoming(webhookId string, time int64) *model.AppError
func (SqlWebhookStore) DeleteOutgoing ¶
func (s SqlWebhookStore) DeleteOutgoing(webhookId string, time int64) *model.AppError
func (SqlWebhookStore) GetIncoming ¶
func (s SqlWebhookStore) GetIncoming(id string, allowFromCache bool) (*model.IncomingWebhook, *model.AppError)
func (SqlWebhookStore) GetIncomingByChannel ¶
func (s SqlWebhookStore) GetIncomingByChannel(channelId string) ([]*model.IncomingWebhook, *model.AppError)
func (SqlWebhookStore) GetIncomingByTeam ¶
func (s SqlWebhookStore) GetIncomingByTeam(teamId string, offset, limit int) ([]*model.IncomingWebhook, *model.AppError)
func (SqlWebhookStore) GetIncomingByTeamByUser ¶
func (s SqlWebhookStore) GetIncomingByTeamByUser(teamId string, userId string, offset, limit int) ([]*model.IncomingWebhook, *model.AppError)
func (SqlWebhookStore) GetIncomingList ¶
func (s SqlWebhookStore) GetIncomingList(offset, limit int) ([]*model.IncomingWebhook, *model.AppError)
func (SqlWebhookStore) GetIncomingListByUser ¶
func (s SqlWebhookStore) GetIncomingListByUser(userId string, offset, limit int) ([]*model.IncomingWebhook, *model.AppError)
func (SqlWebhookStore) GetOutgoing ¶
func (s SqlWebhookStore) GetOutgoing(id string) (*model.OutgoingWebhook, *model.AppError)
func (SqlWebhookStore) GetOutgoingByChannel ¶
func (s SqlWebhookStore) GetOutgoingByChannel(channelId string, offset, limit int) ([]*model.OutgoingWebhook, *model.AppError)
func (SqlWebhookStore) GetOutgoingByChannelByUser ¶
func (s SqlWebhookStore) GetOutgoingByChannelByUser(channelId string, userId string, offset, limit int) ([]*model.OutgoingWebhook, *model.AppError)
func (SqlWebhookStore) GetOutgoingByTeam ¶
func (s SqlWebhookStore) GetOutgoingByTeam(teamId string, offset, limit int) ([]*model.OutgoingWebhook, *model.AppError)
func (SqlWebhookStore) GetOutgoingByTeamByUser ¶
func (s SqlWebhookStore) GetOutgoingByTeamByUser(teamId string, userId string, offset, limit int) ([]*model.OutgoingWebhook, *model.AppError)
func (SqlWebhookStore) GetOutgoingList ¶
func (s SqlWebhookStore) GetOutgoingList(offset, limit int) ([]*model.OutgoingWebhook, *model.AppError)
func (SqlWebhookStore) GetOutgoingListByUser ¶
func (s SqlWebhookStore) GetOutgoingListByUser(userId string, offset, limit int) ([]*model.OutgoingWebhook, *model.AppError)
func (SqlWebhookStore) InvalidateWebhookCache ¶
func (s SqlWebhookStore) InvalidateWebhookCache(webhookId string)
func (SqlWebhookStore) PermanentDeleteIncomingByChannel ¶
func (s SqlWebhookStore) PermanentDeleteIncomingByChannel(channelId string) *model.AppError
func (SqlWebhookStore) PermanentDeleteIncomingByUser ¶
func (s SqlWebhookStore) PermanentDeleteIncomingByUser(userId string) *model.AppError
func (SqlWebhookStore) PermanentDeleteOutgoingByChannel ¶
func (s SqlWebhookStore) PermanentDeleteOutgoingByChannel(channelId string) *model.AppError
func (SqlWebhookStore) PermanentDeleteOutgoingByUser ¶
func (s SqlWebhookStore) PermanentDeleteOutgoingByUser(userId string) *model.AppError
func (SqlWebhookStore) SaveIncoming ¶
func (s SqlWebhookStore) SaveIncoming(webhook *model.IncomingWebhook) (*model.IncomingWebhook, *model.AppError)
func (SqlWebhookStore) SaveOutgoing ¶
func (s SqlWebhookStore) SaveOutgoing(webhook *model.OutgoingWebhook) (*model.OutgoingWebhook, *model.AppError)
func (SqlWebhookStore) UpdateIncoming ¶
func (s SqlWebhookStore) UpdateIncoming(hook *model.IncomingWebhook) (*model.IncomingWebhook, *model.AppError)
func (SqlWebhookStore) UpdateOutgoing ¶
func (s SqlWebhookStore) UpdateOutgoing(hook *model.OutgoingWebhook) (*model.OutgoingWebhook, *model.AppError)
type TraceOnAdapter ¶ added in v5.20.0
type TraceOnAdapter struct{}
func (*TraceOnAdapter) Printf ¶ added in v5.20.0
func (t *TraceOnAdapter) Printf(format string, v ...interface{})
type UserWithChannel ¶
type UserWithLastActivityAt ¶
Source Files
¶
- audit_store.go
- bot_store.go
- channel_member_history_store.go
- channel_store.go
- cluster_discovery_store.go
- command_store.go
- command_webhook_store.go
- compliance_store.go
- emoji_store.go
- file_info_store.go
- group_store.go
- integrity.go
- job_store.go
- license_store.go
- link_metadata_store.go
- oauth_store.go
- plugin_store.go
- post_store.go
- preference_store.go
- role_supplier.go
- scheme_supplier.go
- session_store.go
- status_store.go
- store.go
- supplier.go
- supplier_reactions.go
- system_store.go
- team_store.go
- terms_of_service_store.go
- tokens_store.go
- upgrade.go
- user_access_token_store.go
- user_store.go
- user_terms_of_service.go
- utils.go
- webhook_store.go