Versions in this module Expand all Collapse all v6 v6.0.0 Dec 23, 2020 Changes in this version + const ALL_CHANNEL_MEMBERS_FOR_USER_CACHE_DURATION + const ALL_CHANNEL_MEMBERS_FOR_USER_CACHE_SIZE + const ALL_CHANNEL_MEMBERS_NOTIFY_PROPS_FOR_CHANNEL_CACHE_DURATION + const ALL_CHANNEL_MEMBERS_NOTIFY_PROPS_FOR_CHANNEL_CACHE_SIZE + const CHANNEL_CACHE_DURATION + const CURRENT_SCHEMA_VERSION + const DB_PING_ATTEMPTS + const DB_PING_TIMEOUT_SECS + const EXIT_ALTER_COLUMN + const EXIT_ALTER_PRIMARY_KEY + const EXIT_COLUMN_EXISTS + const EXIT_CREATE_COLUMN_MISSING + const EXIT_CREATE_COLUMN_MYSQL + const EXIT_CREATE_COLUMN_POSTGRES + const EXIT_CREATE_INDEX_FULL_MYSQL + const EXIT_CREATE_INDEX_MISSING + const EXIT_CREATE_INDEX_MYSQL + const EXIT_CREATE_INDEX_POSTGRES + const EXIT_CREATE_INDEX_SQLITE + const EXIT_CREATE_TABLE + const EXIT_DB_OPEN + const EXIT_DOES_COLUMN_EXISTS_MISSING + const EXIT_DOES_COLUMN_EXISTS_MYSQL + const EXIT_DOES_COLUMN_EXISTS_POSTGRES + const EXIT_DOES_COLUMN_EXISTS_SQLITE + const EXIT_GENERIC_FAILURE + const EXIT_MAX_COLUMN + const EXIT_NO_DRIVER + const EXIT_PING + const EXIT_REMOVE_COLUMN + const EXIT_REMOVE_INDEX_MISSING + const EXIT_REMOVE_INDEX_MYSQL + const EXIT_REMOVE_INDEX_POSTGRES + const EXIT_REMOVE_INDEX_SQLITE + const EXIT_REMOVE_TABLE + const EXIT_RENAME_COLUMN + const EXIT_TABLE_EXISTS + const EXIT_TABLE_EXISTS_MYSQL + const EXIT_TABLE_EXISTS_SQLITE + const EXIT_TEAM_INVITEID_MIGRATION_FAILED + const EXIT_THEME_MIGRATION + const EXIT_VERSION_SAVE + const INDEX_TYPE_DEFAULT + const INDEX_TYPE_FULL_TEXT + const MAX_GROUP_CHANNELS_FOR_PROFILES + const MYSQL_DUP_TABLE_ERROR_CODE + const OLDEST_SUPPORTED_VERSION + const PG_DUP_TABLE_ERROR_CODE + const SESSIONS_CLEANUP_DELAY_MILLISECONDS + const TEAM_MEMBER_EXISTS_ERROR + const UPDATE_POST_HAS_REACTIONS_ON_DELETE_QUERY + const VERSION_3_0_0 + const VERSION_3_10_0 + const VERSION_3_1_0 + const VERSION_3_2_0 + const VERSION_3_3_0 + const VERSION_3_4_0 + const VERSION_3_5_0 + const VERSION_3_6_0 + const VERSION_3_7_0 + const VERSION_3_8_0 + const VERSION_3_9_0 + const VERSION_4_0_0 + const VERSION_4_10_0 + const VERSION_4_1_0 + const VERSION_4_2_0 + const VERSION_4_3_0 + const VERSION_4_4_0 + const VERSION_4_5_0 + const VERSION_4_6_0 + const VERSION_4_7_0 + const VERSION_4_7_1 + const VERSION_4_7_2 + const VERSION_4_8_0 + const VERSION_4_8_1 + const VERSION_4_9_0 + const VERSION_5_0_0 + const VERSION_5_10_0 + const VERSION_5_11_0 + const VERSION_5_12_0 + const VERSION_5_13_0 + const VERSION_5_14_0 + const VERSION_5_15_0 + const VERSION_5_16_0 + const VERSION_5_17_0 + const VERSION_5_18_0 + const VERSION_5_19_0 + const VERSION_5_1_0 + const VERSION_5_20_0 + const VERSION_5_21_0 + const VERSION_5_22_0 + const VERSION_5_23_0 + const VERSION_5_24_0 + const VERSION_5_25_0 + const VERSION_5_26_0 + const VERSION_5_27_0 + const VERSION_5_28_0 + const VERSION_5_28_1 + const VERSION_5_29_0 + const VERSION_5_2_0 + const VERSION_5_30_0 + const VERSION_5_31_0 + const VERSION_5_32_0 + const VERSION_5_3_0 + const VERSION_5_4_0 + const VERSION_5_5_0 + const VERSION_5_6_0 + const VERSION_5_7_0 + const VERSION_5_8_0 + const VERSION_5_9_0 + var CHANNEL_MEMBERS_WITH_SCHEME_SELECT_QUERY = ... + var USER_SEARCH_TYPE_ALL = []string + var USER_SEARCH_TYPE_ALL_NO_FULL_NAME = []string + var USER_SEARCH_TYPE_NAMES = []string + var USER_SEARCH_TYPE_NAMES_NO_FULL_NAME = []string + func CheckRelationalIntegrity(ss *SqlStore, results chan<- model.IntegrityCheckResult) + func IsDuplicate(err error) bool + func IsUniqueConstraintError(err error, indexName []string) bool + func MapStringsToQueryParams(list []string, paramPrefix string) (string, map[string]interface{}) + func NewChannelMemberFromModel(cm *model.ChannelMember) *channelMember + func NewTeamMemberFromModel(tm *model.TeamMember) *teamMember + type JSONSerializable interface + ToJson func() string + type Role struct + BuiltIn bool + CreateAt int64 + DeleteAt int64 + Description string + DisplayName string + Id string + Name string + Permissions string + SchemeManaged bool + UpdateAt int64 + func NewRoleFromModel(role *model.Role) *Role + func (role Role) ToModel() *model.Role + type SqlAuditStore struct + func (s SqlAuditStore) Get(userId string, offset int, limit int) (model.Audits, error) + func (s SqlAuditStore) PermanentDeleteByUser(userId string) error + func (s SqlAuditStore) Save(audit *model.Audit) error + type SqlBotStore struct + func (us SqlBotStore) Get(botUserId string, includeDeleted bool) (*model.Bot, error) + func (us SqlBotStore) GetAll(options *model.BotGetOptions) ([]*model.Bot, error) + func (us SqlBotStore) PermanentDelete(botUserId string) error + func (us SqlBotStore) Save(bot *model.Bot) (*model.Bot, error) + func (us SqlBotStore) Update(bot *model.Bot) (*model.Bot, error) + type SqlChannelMemberHistoryStore struct + func (s SqlChannelMemberHistoryStore) GetUsersInChannelDuring(startTime int64, endTime int64, channelId string) ([]*model.ChannelMemberHistoryResult, error) + func (s SqlChannelMemberHistoryStore) LogJoinEvent(userId string, channelId string, joinTime int64) error + func (s SqlChannelMemberHistoryStore) LogLeaveEvent(userId string, channelId string, leaveTime int64) error + func (s SqlChannelMemberHistoryStore) PermanentDeleteBatch(endTime int64, limit int64) (int64, error) + type SqlChannelStore struct + func (s SqlChannelStore) AnalyticsDeletedTypeCount(teamId string, channelType string) (int64, error) + func (s SqlChannelStore) AnalyticsTypeCount(teamId string, channelType string) (int64, error) + func (s SqlChannelStore) AutocompleteInTeam(teamId string, term string, includeDeleted bool) (*model.ChannelList, error) + func (s SqlChannelStore) AutocompleteInTeamForSearch(teamId string, userId string, term string, includeDeleted bool) (*model.ChannelList, error) + func (s SqlChannelStore) ClearAllCustomRoleAssignments() error + func (s SqlChannelStore) ClearCaches() + func (s SqlChannelStore) ClearSidebarOnTeamLeave(userId, teamId string) error + func (s SqlChannelStore) CountPostsAfter(channelId string, timestamp int64, userId string) (int, error) + func (s SqlChannelStore) CreateDirectChannel(user *model.User, otherUser *model.User) (*model.Channel, error) + func (s SqlChannelStore) CreateInitialSidebarCategories(userId, teamId string) error + func (s SqlChannelStore) CreateSidebarCategory(userId, teamId string, newCategory *model.SidebarCategoryWithChannels) (*model.SidebarCategoryWithChannels, error) + func (s SqlChannelStore) Delete(channelId string, time int64) error + func (s SqlChannelStore) DeleteSidebarCategory(categoryId string) error + func (s SqlChannelStore) DeleteSidebarChannelsByPreferences(preferences *model.Preferences) error + func (s SqlChannelStore) Get(id string, allowFromCache bool) (*model.Channel, error) + func (s SqlChannelStore) GetAll(teamId string) ([]*model.Channel, error) + func (s SqlChannelStore) GetAllChannelMembersForUser(userId string, allowFromCache bool, includeDeleted bool) (map[string]string, error) + func (s SqlChannelStore) GetAllChannelMembersNotifyPropsForChannel(channelId string, allowFromCache bool) (map[string]model.StringMap, error) + func (s SqlChannelStore) GetAllChannels(offset, limit int, opts store.ChannelSearchOpts) (*model.ChannelListWithTeamData, error) + func (s SqlChannelStore) GetAllChannelsCount(opts store.ChannelSearchOpts) (int64, error) + func (s SqlChannelStore) GetAllChannelsForExportAfter(limit int, afterId string) ([]*model.ChannelForExport, error) + func (s SqlChannelStore) GetAllDirectChannelsForExportAfter(limit int, afterId string) ([]*model.DirectChannelForExport, error) + func (s SqlChannelStore) GetByName(teamId string, name string, allowFromCache bool) (*model.Channel, error) + func (s SqlChannelStore) GetByNameIncludeDeleted(teamId string, name string, allowFromCache bool) (*model.Channel, error) + func (s SqlChannelStore) GetByNames(teamId string, names []string, allowFromCache bool) ([]*model.Channel, error) + func (s SqlChannelStore) GetChannelCounts(teamId string, userId string) (*model.ChannelCounts, error) + func (s SqlChannelStore) GetChannelMembersForExport(userId string, teamId string) ([]*model.ChannelMemberForExport, error) + func (s SqlChannelStore) GetChannelMembersTimezones(channelId string) ([]model.StringMap, error) + func (s SqlChannelStore) GetChannelUnread(channelId, userId string) (*model.ChannelUnread, error) + func (s SqlChannelStore) GetChannels(teamId string, userId string, includeDeleted bool, lastDeleteAt int) (*model.ChannelList, error) + func (s SqlChannelStore) GetChannelsBatchForIndexing(startTime, endTime int64, limit int) ([]*model.Channel, error) + func (s SqlChannelStore) GetChannelsByIds(channelIds []string, includeDeleted bool) ([]*model.Channel, error) + func (s SqlChannelStore) GetChannelsByScheme(schemeId string, offset int, limit int) (model.ChannelList, error) + func (s SqlChannelStore) GetDeleted(teamId string, offset int, limit int, userId string) (*model.ChannelList, error) + func (s SqlChannelStore) GetDeletedByName(teamId string, name string) (*model.Channel, error) + func (s SqlChannelStore) GetForPost(postId string) (*model.Channel, error) + func (s SqlChannelStore) GetFromMaster(id string) (*model.Channel, error) + func (s SqlChannelStore) GetGuestCount(channelId string, allowFromCache bool) (int64, error) + func (s SqlChannelStore) GetMember(channelId string, userId string) (*model.ChannelMember, error) + func (s SqlChannelStore) GetMemberCount(channelId string, allowFromCache bool) (int64, error) + func (s SqlChannelStore) GetMemberCountFromCache(channelId string) int64 + func (s SqlChannelStore) GetMemberCountsByGroup(channelID string, includeTimezones bool) ([]*model.ChannelMemberCountByGroup, error) + func (s SqlChannelStore) GetMemberForPost(postId string, userId string) (*model.ChannelMember, error) + func (s SqlChannelStore) GetMembers(channelId string, offset, limit int) (*model.ChannelMembers, error) + func (s SqlChannelStore) GetMembersByChannelIds(channelIds []string, userId string) (*model.ChannelMembers, error) + func (s SqlChannelStore) GetMembersByIds(channelId string, userIds []string) (*model.ChannelMembers, error) + func (s SqlChannelStore) GetMembersForUser(teamId string, userId string) (*model.ChannelMembers, error) + func (s SqlChannelStore) GetMembersForUserWithPagination(teamId, userId string, page, perPage int) (*model.ChannelMembers, error) + func (s SqlChannelStore) GetMoreChannels(teamId string, userId string, offset int, limit int) (*model.ChannelList, error) + func (s SqlChannelStore) GetPinnedPostCount(channelId string, allowFromCache bool) (int64, error) + func (s SqlChannelStore) GetPinnedPosts(channelId string) (*model.PostList, error) + func (s SqlChannelStore) GetPrivateChannelsForTeam(teamId string, offset int, limit int) (*model.ChannelList, error) + func (s SqlChannelStore) GetPublicChannelsByIdsForTeam(teamId string, channelIds []string) (*model.ChannelList, error) + func (s SqlChannelStore) GetPublicChannelsForTeam(teamId string, offset int, limit int) (*model.ChannelList, error) + func (s SqlChannelStore) GetSidebarCategories(userId, teamId string) (*model.OrderedSidebarCategories, error) + func (s SqlChannelStore) GetSidebarCategory(categoryId string) (*model.SidebarCategoryWithChannels, error) + func (s SqlChannelStore) GetSidebarCategoryOrder(userId, teamId string) ([]string, error) + func (s SqlChannelStore) GetTeamChannels(teamId string) (*model.ChannelList, error) + func (s SqlChannelStore) GroupSyncedChannelCount() (int64, error) + func (s SqlChannelStore) IncrementMentionCount(channelId string, userId string, updateThreads bool) error + 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, error) + func (s SqlChannelStore) MigrateFavoritesToSidebarChannels(lastUserId string, runningOrder int64) (map[string]interface{}, error) + func (s SqlChannelStore) MigratePublicChannels() error + func (s SqlChannelStore) PermanentDelete(channelId string) error + func (s SqlChannelStore) PermanentDeleteByTeam(teamId string) error + func (s SqlChannelStore) PermanentDeleteMembersByChannel(channelId string) error + func (s SqlChannelStore) PermanentDeleteMembersByUser(userId string) error + func (s SqlChannelStore) RemoveAllDeactivatedMembers(channelId string) error + func (s SqlChannelStore) RemoveMember(channelId string, userId string) error + func (s SqlChannelStore) RemoveMembers(channelId string, userIds []string) error + func (s SqlChannelStore) ResetAllChannelSchemes() error + func (s SqlChannelStore) Restore(channelId string, time int64) error + func (s SqlChannelStore) Save(channel *model.Channel, maxChannelsPerTeam int64) (*model.Channel, error) + func (s SqlChannelStore) SaveDirectChannel(directchannel *model.Channel, member1 *model.ChannelMember, ...) (*model.Channel, error) + func (s SqlChannelStore) SaveMember(member *model.ChannelMember) (*model.ChannelMember, error) + func (s SqlChannelStore) SaveMultipleMembers(members []*model.ChannelMember) ([]*model.ChannelMember, error) + func (s SqlChannelStore) SearchAllChannels(term string, opts store.ChannelSearchOpts) (*model.ChannelListWithTeamData, int64, error) + func (s SqlChannelStore) SearchArchivedInTeam(teamId string, term string, userId string) (*model.ChannelList, error) + func (s SqlChannelStore) SearchForUserInTeam(userId string, teamId string, term string, includeDeleted bool) (*model.ChannelList, error) + func (s SqlChannelStore) SearchGroupChannels(userId, term string) (*model.ChannelList, error) + func (s SqlChannelStore) SearchInTeam(teamId string, term string, includeDeleted bool) (*model.ChannelList, error) + func (s SqlChannelStore) SearchMore(userId string, teamId string, term string) (*model.ChannelList, error) + func (s SqlChannelStore) SetDeleteAt(channelId string, deleteAt, updateAt int64) error + func (s SqlChannelStore) Update(channel *model.Channel) (*model.Channel, error) + func (s SqlChannelStore) UpdateLastViewedAt(channelIds []string, userId string, updateThreads bool) (map[string]int64, error) + func (s SqlChannelStore) UpdateLastViewedAtPost(unreadPost *model.Post, userID string, mentionCount int, updateThreads bool) (*model.ChannelUnreadAt, error) + func (s SqlChannelStore) UpdateMember(member *model.ChannelMember) (*model.ChannelMember, error) + func (s SqlChannelStore) UpdateMembersRole(channelID string, userIDs []string) error + func (s SqlChannelStore) UpdateMultipleMembers(members []*model.ChannelMember) ([]*model.ChannelMember, error) + func (s SqlChannelStore) UpdateSidebarCategories(userId, teamId string, categories []*model.SidebarCategoryWithChannels) ([]*model.SidebarCategoryWithChannels, []*model.SidebarCategoryWithChannels, ...) + func (s SqlChannelStore) UpdateSidebarCategoryOrder(userId, teamId string, categoryOrder []string) error + func (s SqlChannelStore) UpdateSidebarChannelCategoryOnMove(channel *model.Channel, newTeamId string) error + func (s SqlChannelStore) UpdateSidebarChannelsByPreferences(preferences *model.Preferences) error + func (s SqlChannelStore) UserBelongsToChannels(userId string, channelIds []string) (bool, error) + type SqlCommandStore struct + func (s SqlCommandStore) AnalyticsCommandCount(teamId string) (int64, error) + func (s SqlCommandStore) Delete(commandId string, time int64) error + func (s SqlCommandStore) Get(id string) (*model.Command, error) + func (s SqlCommandStore) GetByTeam(teamId string) ([]*model.Command, error) + func (s SqlCommandStore) GetByTrigger(teamId string, trigger string) (*model.Command, error) + func (s SqlCommandStore) PermanentDeleteByTeam(teamId string) error + func (s SqlCommandStore) PermanentDeleteByUser(userId string) error + func (s SqlCommandStore) Save(command *model.Command) (*model.Command, error) + func (s SqlCommandStore) Update(cmd *model.Command) (*model.Command, error) + type SqlCommandWebhookStore struct + func (s SqlCommandWebhookStore) Cleanup() + func (s SqlCommandWebhookStore) Get(id string) (*model.CommandWebhook, error) + func (s SqlCommandWebhookStore) Save(webhook *model.CommandWebhook) (*model.CommandWebhook, error) + func (s SqlCommandWebhookStore) TryUse(id string, limit int) error + type SqlComplianceStore struct + func (s SqlComplianceStore) ComplianceExport(job *model.Compliance) ([]*model.CompliancePost, error) + func (s SqlComplianceStore) Get(id string) (*model.Compliance, error) + func (s SqlComplianceStore) GetAll(offset, limit int) (model.Compliances, error) + func (s SqlComplianceStore) MessageExport(after int64, limit int) ([]*model.MessageExport, error) + func (s SqlComplianceStore) Save(compliance *model.Compliance) (*model.Compliance, error) + func (s SqlComplianceStore) Update(compliance *model.Compliance) (*model.Compliance, error) + type SqlEmojiStore struct + func (es SqlEmojiStore) Delete(emoji *model.Emoji, time int64) error + func (es SqlEmojiStore) Get(id string, allowFromCache bool) (*model.Emoji, error) + func (es SqlEmojiStore) GetByName(name string, allowFromCache bool) (*model.Emoji, error) + func (es SqlEmojiStore) GetList(offset, limit int, sort string) ([]*model.Emoji, error) + func (es SqlEmojiStore) GetMultipleByName(names []string) ([]*model.Emoji, error) + func (es SqlEmojiStore) Save(emoji *model.Emoji) (*model.Emoji, error) + func (es SqlEmojiStore) Search(name string, prefixOnly bool, limit int) ([]*model.Emoji, error) + type SqlFileInfoStore struct + func (fs SqlFileInfoStore) AttachToPost(fileId, postId, creatorId string) error + func (fs SqlFileInfoStore) ClearCaches() + func (fs SqlFileInfoStore) DeleteForPost(postId string) (string, error) + func (fs SqlFileInfoStore) Get(id string) (*model.FileInfo, error) + func (fs SqlFileInfoStore) GetByPath(path string) (*model.FileInfo, error) + func (fs SqlFileInfoStore) GetForPost(postId string, readFromMaster, includeDeleted, allowFromCache bool) ([]*model.FileInfo, error) + func (fs SqlFileInfoStore) GetForUser(userId string) ([]*model.FileInfo, error) + func (fs SqlFileInfoStore) GetWithOptions(page, perPage int, opt *model.GetFileInfosOptions) ([]*model.FileInfo, error) + func (fs SqlFileInfoStore) InvalidateFileInfosForPostCache(postId string, deleted bool) + func (fs SqlFileInfoStore) PermanentDelete(fileId string) error + func (fs SqlFileInfoStore) PermanentDeleteBatch(endTime int64, limit int64) (int64, error) + func (fs SqlFileInfoStore) PermanentDeleteByUser(userId string) (int64, error) + func (fs SqlFileInfoStore) Save(info *model.FileInfo) (*model.FileInfo, error) + func (fs SqlFileInfoStore) SetContent(fileId, content string) error + func (fs SqlFileInfoStore) Upsert(info *model.FileInfo) (*model.FileInfo, error) + type SqlGroupStore struct + func (s *SqlGroupStore) AdminRoleGroupsForSyncableMember(userID, syncableID string, syncableType model.GroupSyncableType) ([]string, error) + func (s *SqlGroupStore) ChannelMembersMinusGroupMembers(channelID string, groupIDs []string, page, perPage int) ([]*model.UserWithGroups, error) + func (s *SqlGroupStore) ChannelMembersToAdd(since int64, channelID *string) ([]*model.UserChannelIDPair, error) + func (s *SqlGroupStore) ChannelMembersToRemove(channelID *string) ([]*model.ChannelMember, error) + func (s *SqlGroupStore) CountChannelMembersMinusGroupMembers(channelID string, groupIDs []string) (int64, error) + func (s *SqlGroupStore) CountGroupsByChannel(channelId string, opts model.GroupSearchOpts) (int64, error) + func (s *SqlGroupStore) CountGroupsByTeam(teamId string, opts model.GroupSearchOpts) (int64, error) + func (s *SqlGroupStore) CountTeamMembersMinusGroupMembers(teamID string, groupIDs []string) (int64, error) + func (s *SqlGroupStore) Create(group *model.Group) (*model.Group, error) + func (s *SqlGroupStore) CreateGroupSyncable(groupSyncable *model.GroupSyncable) (*model.GroupSyncable, error) + func (s *SqlGroupStore) Delete(groupID string) (*model.Group, error) + func (s *SqlGroupStore) DeleteGroupSyncable(groupID string, syncableID string, syncableType model.GroupSyncableType) (*model.GroupSyncable, error) + func (s *SqlGroupStore) DeleteMember(groupID string, userID string) (*model.GroupMember, error) + func (s *SqlGroupStore) DistinctGroupMemberCount() (int64, error) + func (s *SqlGroupStore) Get(groupId string) (*model.Group, error) + func (s *SqlGroupStore) GetAllBySource(groupSource model.GroupSource) ([]*model.Group, error) + func (s *SqlGroupStore) GetAllGroupSyncablesByGroupId(groupID string, syncableType model.GroupSyncableType) ([]*model.GroupSyncable, error) + func (s *SqlGroupStore) GetByIDs(groupIDs []string) ([]*model.Group, error) + func (s *SqlGroupStore) GetByName(name string, opts model.GroupSearchOpts) (*model.Group, error) + func (s *SqlGroupStore) GetByRemoteID(remoteID string, groupSource model.GroupSource) (*model.Group, error) + func (s *SqlGroupStore) GetByUser(userId string) ([]*model.Group, error) + func (s *SqlGroupStore) GetGroupSyncable(groupID string, syncableID string, syncableType model.GroupSyncableType) (*model.GroupSyncable, error) + func (s *SqlGroupStore) GetGroups(page, perPage int, opts model.GroupSearchOpts) ([]*model.Group, error) + func (s *SqlGroupStore) GetGroupsAssociatedToChannelsByTeam(teamId string, opts model.GroupSearchOpts) (map[string][]*model.GroupWithSchemeAdmin, error) + func (s *SqlGroupStore) GetGroupsByChannel(channelId string, opts model.GroupSearchOpts) ([]*model.GroupWithSchemeAdmin, error) + func (s *SqlGroupStore) GetGroupsByTeam(teamId string, opts model.GroupSearchOpts) ([]*model.GroupWithSchemeAdmin, error) + func (s *SqlGroupStore) GetMemberCount(groupID string) (int64, error) + func (s *SqlGroupStore) GetMemberUsers(groupID string) ([]*model.User, error) + func (s *SqlGroupStore) GetMemberUsersInTeam(groupID string, teamID string) ([]*model.User, error) + func (s *SqlGroupStore) GetMemberUsersNotInChannel(groupID string, channelID string) ([]*model.User, error) + func (s *SqlGroupStore) GetMemberUsersPage(groupID string, page int, perPage int) ([]*model.User, error) + func (s *SqlGroupStore) GroupChannelCount() (int64, error) + func (s *SqlGroupStore) GroupCount() (int64, error) + func (s *SqlGroupStore) GroupCountWithAllowReference() (int64, error) + func (s *SqlGroupStore) GroupMemberCount() (int64, error) + func (s *SqlGroupStore) GroupTeamCount() (int64, error) + func (s *SqlGroupStore) PermanentDeleteMembersByUser(userId string) error + func (s *SqlGroupStore) PermittedSyncableAdmins(syncableID string, syncableType model.GroupSyncableType) ([]string, error) + func (s *SqlGroupStore) TeamMembersMinusGroupMembers(teamID string, groupIDs []string, page, perPage int) ([]*model.UserWithGroups, error) + func (s *SqlGroupStore) TeamMembersToAdd(since int64, teamID *string) ([]*model.UserTeamIDPair, error) + func (s *SqlGroupStore) TeamMembersToRemove(teamID *string) ([]*model.TeamMember, error) + func (s *SqlGroupStore) Update(group *model.Group) (*model.Group, error) + func (s *SqlGroupStore) UpdateGroupSyncable(groupSyncable *model.GroupSyncable) (*model.GroupSyncable, error) + func (s *SqlGroupStore) UpsertMember(groupID string, userID string) (*model.GroupMember, error) + type SqlJobStore struct + func (jss SqlJobStore) Delete(id string) (string, error) + func (jss SqlJobStore) Get(id string) (*model.Job, error) + func (jss SqlJobStore) GetAllByStatus(status string) ([]*model.Job, error) + func (jss SqlJobStore) GetAllByType(jobType string) ([]*model.Job, error) + func (jss SqlJobStore) GetAllByTypePage(jobType string, offset int, limit int) ([]*model.Job, error) + func (jss SqlJobStore) GetAllPage(offset int, limit int) ([]*model.Job, error) + func (jss SqlJobStore) GetCountByStatusAndType(status string, jobType string) (int64, error) + func (jss SqlJobStore) GetNewestJobByStatusAndType(status string, jobType string) (*model.Job, error) + func (jss SqlJobStore) GetNewestJobByStatusesAndType(status []string, jobType string) (*model.Job, error) + func (jss SqlJobStore) Save(job *model.Job) (*model.Job, error) + func (jss SqlJobStore) UpdateOptimistically(job *model.Job, currentStatus string) (bool, error) + func (jss SqlJobStore) UpdateStatus(id string, status string) (*model.Job, error) + func (jss SqlJobStore) UpdateStatusOptimistically(id string, currentStatus string, newStatus string) (bool, error) + type SqlLicenseStore struct + func (ls SqlLicenseStore) Get(id string) (*model.LicenseRecord, error) + func (ls SqlLicenseStore) Save(license *model.LicenseRecord) (*model.LicenseRecord, error) + type SqlLinkMetadataStore struct + func (s SqlLinkMetadataStore) Get(url string, timestamp int64) (*model.LinkMetadata, error) + func (s SqlLinkMetadataStore) Save(metadata *model.LinkMetadata) (*model.LinkMetadata, error) + type SqlOAuthStore struct + func (as SqlOAuthStore) DeleteApp(id string) error + func (as SqlOAuthStore) GetAccessData(token string) (*model.AccessData, error) + func (as SqlOAuthStore) GetAccessDataByRefreshToken(token string) (*model.AccessData, error) + func (as SqlOAuthStore) GetAccessDataByUserForApp(userId, clientId string) ([]*model.AccessData, error) + func (as SqlOAuthStore) GetApp(id string) (*model.OAuthApp, error) + func (as SqlOAuthStore) GetAppByUser(userId string, offset, limit int) ([]*model.OAuthApp, error) + func (as SqlOAuthStore) GetApps(offset, limit int) ([]*model.OAuthApp, error) + func (as SqlOAuthStore) GetAuthData(code string) (*model.AuthData, error) + func (as SqlOAuthStore) GetAuthorizedApps(userId string, offset, limit int) ([]*model.OAuthApp, error) + func (as SqlOAuthStore) GetPreviousAccessData(userId, clientId string) (*model.AccessData, error) + func (as SqlOAuthStore) PermanentDeleteAuthDataByUser(userId string) error + func (as SqlOAuthStore) RemoveAccessData(token string) error + func (as SqlOAuthStore) RemoveAllAccessData() error + func (as SqlOAuthStore) RemoveAuthData(code string) error + func (as SqlOAuthStore) SaveAccessData(accessData *model.AccessData) (*model.AccessData, error) + func (as SqlOAuthStore) SaveApp(app *model.OAuthApp) (*model.OAuthApp, error) + func (as SqlOAuthStore) SaveAuthData(authData *model.AuthData) (*model.AuthData, error) + func (as SqlOAuthStore) UpdateAccessData(accessData *model.AccessData) (*model.AccessData, error) + func (as SqlOAuthStore) UpdateApp(app *model.OAuthApp) (*model.OAuthApp, error) + type SqlPluginStore struct + func (ps SqlPluginStore) CompareAndDelete(kv *model.PluginKeyValue, oldValue []byte) (bool, error) + func (ps SqlPluginStore) CompareAndSet(kv *model.PluginKeyValue, oldValue []byte) (bool, error) + func (ps SqlPluginStore) Delete(pluginId, key string) error + func (ps SqlPluginStore) DeleteAllExpired() error + func (ps SqlPluginStore) DeleteAllForPlugin(pluginId string) error + func (ps SqlPluginStore) Get(pluginId, key string) (*model.PluginKeyValue, error) + func (ps SqlPluginStore) List(pluginId string, offset int, limit int) ([]string, error) + func (ps SqlPluginStore) SaveOrUpdate(kv *model.PluginKeyValue) (*model.PluginKeyValue, error) + func (ps SqlPluginStore) SetWithOptions(pluginId string, key string, value []byte, opt model.PluginKVSetOptions) (bool, error) + type SqlPostStore struct + func (s *SqlPostStore) AnalyticsPostCount(teamId string, mustHaveFile bool, mustHaveHashtag bool) (int64, error) + func (s *SqlPostStore) AnalyticsPostCountsByDay(options *model.AnalyticsPostCountsOptions) (model.AnalyticsRows, error) + func (s *SqlPostStore) AnalyticsUserCountsWithPostsByDay(teamId string) (model.AnalyticsRows, error) + func (s *SqlPostStore) ClearCaches() + func (s *SqlPostStore) Delete(postId string, time int64, deleteByID string) error + func (s *SqlPostStore) Get(id string, skipFetchThreads bool) (*model.PostList, error) + func (s *SqlPostStore) GetDirectPostParentsForExportAfter(limit int, afterId string) ([]*model.DirectPostForExport, error) + func (s *SqlPostStore) GetEtag(channelId string, allowFromCache bool) string + func (s *SqlPostStore) GetFlaggedPosts(userId string, offset int, limit int) (*model.PostList, error) + func (s *SqlPostStore) GetFlaggedPostsForChannel(userId, channelId string, offset int, limit int) (*model.PostList, error) + func (s *SqlPostStore) GetFlaggedPostsForTeam(userId, teamId string, offset int, limit int) (*model.PostList, error) + func (s *SqlPostStore) GetMaxPostSize() int + func (s *SqlPostStore) GetOldest() (*model.Post, error) + func (s *SqlPostStore) GetOldestEntityCreationTime() (int64, error) + func (s *SqlPostStore) GetParentsForExportAfter(limit int, afterId string) ([]*model.PostForExport, error) + func (s *SqlPostStore) GetPostAfterTime(channelId string, time int64) (*model.Post, error) + func (s *SqlPostStore) GetPostIdAfterTime(channelId string, time int64) (string, error) + func (s *SqlPostStore) GetPostIdBeforeTime(channelId string, time int64) (string, error) + func (s *SqlPostStore) GetPosts(options model.GetPostsOptions, _ bool) (*model.PostList, error) + func (s *SqlPostStore) GetPostsAfter(options model.GetPostsOptions) (*model.PostList, error) + func (s *SqlPostStore) GetPostsBatchForIndexing(startTime int64, endTime int64, limit int) ([]*model.PostForIndexing, error) + func (s *SqlPostStore) GetPostsBefore(options model.GetPostsOptions) (*model.PostList, error) + func (s *SqlPostStore) GetPostsByIds(postIds []string) ([]*model.Post, error) + func (s *SqlPostStore) GetPostsCreatedAt(channelId string, time int64) ([]*model.Post, error) + func (s *SqlPostStore) GetPostsSince(options model.GetPostsSinceOptions, allowFromCache bool) (*model.PostList, error) + func (s *SqlPostStore) GetRepliesForExport(rootId string) ([]*model.ReplyForExport, error) + func (s *SqlPostStore) GetSingle(id string) (*model.Post, error) + func (s *SqlPostStore) InvalidateLastPostTimeCache(channelId string) + func (s *SqlPostStore) Overwrite(post *model.Post) (*model.Post, error) + func (s *SqlPostStore) OverwriteMultiple(posts []*model.Post) ([]*model.Post, int, error) + func (s *SqlPostStore) PermanentDeleteBatch(endTime int64, limit int64) (int64, error) + func (s *SqlPostStore) PermanentDeleteByChannel(channelId string) error + func (s *SqlPostStore) PermanentDeleteByUser(userId string) error + func (s *SqlPostStore) Save(post *model.Post) (*model.Post, error) + func (s *SqlPostStore) SaveMultiple(posts []*model.Post) ([]*model.Post, int, error) + func (s *SqlPostStore) Search(teamId string, userId string, params *model.SearchParams) (*model.PostList, error) + func (s *SqlPostStore) SearchPostsInTeamForUser(paramsList []*model.SearchParams, userId, teamId string, page, perPage int) (*model.PostSearchResults, error) + func (s *SqlPostStore) Update(newPost *model.Post, oldPost *model.Post) (*model.Post, error) + type SqlPreferenceStore struct + func (s SqlPreferenceStore) CleanupFlagsBatch(limit int64) (int64, error) + func (s SqlPreferenceStore) Delete(userId, category, name string) error + func (s SqlPreferenceStore) DeleteCategory(userId string, category string) error + func (s SqlPreferenceStore) DeleteCategoryAndName(category string, name string) error + func (s SqlPreferenceStore) Get(userId string, category string, name string) (*model.Preference, error) + func (s SqlPreferenceStore) GetAll(userId string) (model.Preferences, error) + func (s SqlPreferenceStore) GetCategory(userId string, category string) (model.Preferences, error) + func (s SqlPreferenceStore) PermanentDeleteByUser(userId string) error + func (s SqlPreferenceStore) Save(preferences *model.Preferences) error + type SqlProductNoticesStore struct + func (s SqlProductNoticesStore) Clear(notices []string) error + func (s SqlProductNoticesStore) ClearOldNotices(currentNotices *model.ProductNotices) error + func (s SqlProductNoticesStore) GetViews(userId string) ([]model.ProductNoticeViewState, error) + func (s SqlProductNoticesStore) View(userId string, notices []string) error + type SqlReactionStore struct + func (s *SqlReactionStore) BulkGetForPosts(postIds []string) ([]*model.Reaction, error) + func (s *SqlReactionStore) Delete(reaction *model.Reaction) (*model.Reaction, error) + func (s *SqlReactionStore) DeleteAllWithEmojiName(emojiName string) error + func (s *SqlReactionStore) GetForPost(postId string, allowFromCache bool) ([]*model.Reaction, error) + func (s *SqlReactionStore) PermanentDeleteBatch(endTime int64, limit int64) (int64, error) + func (s *SqlReactionStore) Save(reaction *model.Reaction) (*model.Reaction, error) + type SqlRoleStore struct + func (s *SqlRoleStore) AllChannelSchemeRoles() ([]*model.Role, error) + func (s *SqlRoleStore) ChannelHigherScopedPermissions(roleNames []string) (map[string]*model.RolePermissions, error) + func (s *SqlRoleStore) ChannelRolesUnderTeamRole(roleName string) ([]*model.Role, error) + func (s *SqlRoleStore) Delete(roleId string) (*model.Role, error) + func (s *SqlRoleStore) Get(roleId string) (*model.Role, error) + func (s *SqlRoleStore) GetAll() ([]*model.Role, error) + func (s *SqlRoleStore) GetByName(name string) (*model.Role, error) + func (s *SqlRoleStore) GetByNames(names []string) ([]*model.Role, error) + func (s *SqlRoleStore) PermanentDeleteAll() error + func (s *SqlRoleStore) Save(role *model.Role) (*model.Role, error) + type SqlSchemeStore struct + func (s *SqlSchemeStore) CountByScope(scope string) (int64, error) + func (s *SqlSchemeStore) CountWithoutPermission(schemeScope, permissionID string, roleScope model.RoleScope, ...) (int64, error) + func (s *SqlSchemeStore) Delete(schemeId string) (*model.Scheme, error) + func (s *SqlSchemeStore) Get(schemeId string) (*model.Scheme, error) + func (s *SqlSchemeStore) GetAllPage(scope string, offset int, limit int) ([]*model.Scheme, error) + func (s *SqlSchemeStore) GetByName(schemeName string) (*model.Scheme, error) + func (s *SqlSchemeStore) PermanentDeleteAll() error + func (s *SqlSchemeStore) Save(scheme *model.Scheme) (*model.Scheme, error) + type SqlSessionStore struct + func (me SqlSessionStore) AnalyticsSessionCount() (int64, error) + func (me SqlSessionStore) Cleanup(expiryTime int64, batchSize int64) + func (me SqlSessionStore) Get(sessionIdOrToken string) (*model.Session, error) + func (me SqlSessionStore) GetSessions(userId string) ([]*model.Session, error) + func (me SqlSessionStore) GetSessionsExpired(thresholdMillis int64, mobileOnly bool, unnotifiedOnly bool) ([]*model.Session, error) + func (me SqlSessionStore) GetSessionsWithActiveDeviceIds(userId string) ([]*model.Session, error) + func (me SqlSessionStore) PermanentDeleteSessionsByUser(userId string) error + func (me SqlSessionStore) Remove(sessionIdOrToken string) error + func (me SqlSessionStore) RemoveAllSessions() error + func (me SqlSessionStore) Save(session *model.Session) (*model.Session, error) + func (me SqlSessionStore) UpdateDeviceId(id string, deviceId string, expiresAt int64) (string, error) + func (me SqlSessionStore) UpdateExpiredNotify(sessionId string, notified bool) error + func (me SqlSessionStore) UpdateExpiresAt(sessionId string, time int64) error + func (me SqlSessionStore) UpdateLastActivityAt(sessionId string, time int64) error + func (me SqlSessionStore) UpdateProps(session *model.Session) error + func (me SqlSessionStore) UpdateRoles(userId, roles string) (string, error) + type SqlStatusStore struct + func (s SqlStatusStore) Get(userId string) (*model.Status, error) + func (s SqlStatusStore) GetByIds(userIds []string) ([]*model.Status, error) + func (s SqlStatusStore) GetTotalActiveUsersCount() (int64, error) + func (s SqlStatusStore) ResetAll() error + func (s SqlStatusStore) SaveOrUpdate(status *model.Status) error + func (s SqlStatusStore) UpdateLastActivityAt(userId string, lastActivityAt int64) error + type SqlStore struct + func New(settings model.SqlSettings, metrics einterfaces.MetricsInterface) *SqlStore + func (ss *SqlStore) AlterColumnDefaultIfExists(tableName string, columnName string, mySqlColDefault *string, ...) bool + func (ss *SqlStore) AlterColumnTypeIfExists(tableName string, columnName string, mySqlColType string, ...) bool + func (ss *SqlStore) AlterPrimaryKey(tableName string, columnNames []string) bool + func (ss *SqlStore) Audit() store.AuditStore + func (ss *SqlStore) Bot() store.BotStore + func (ss *SqlStore) Channel() store.ChannelStore + func (ss *SqlStore) ChannelMemberHistory() store.ChannelMemberHistoryStore + func (ss *SqlStore) CheckIntegrity() <-chan model.IntegrityCheckResult + func (ss *SqlStore) Close() + func (ss *SqlStore) ClusterDiscovery() store.ClusterDiscoveryStore + func (ss *SqlStore) Command() store.CommandStore + func (ss *SqlStore) CommandWebhook() store.CommandWebhookStore + func (ss *SqlStore) Compliance() store.ComplianceStore + func (ss *SqlStore) Context() context.Context + func (ss *SqlStore) CreateColumnIfNotExists(tableName string, columnName string, mySqlColType string, ...) bool + func (ss *SqlStore) CreateColumnIfNotExistsNoDefault(tableName string, columnName string, mySqlColType string, ...) bool + func (ss *SqlStore) CreateCompositeIndexIfNotExists(indexName string, tableName string, columnNames []string) bool + func (ss *SqlStore) CreateFullTextIndexIfNotExists(indexName string, tableName string, columnName string) bool + func (ss *SqlStore) CreateIndexIfNotExists(indexName string, tableName string, columnName string) bool + func (ss *SqlStore) CreateUniqueCompositeIndexIfNotExists(indexName string, tableName string, columnNames []string) bool + func (ss *SqlStore) CreateUniqueIndexIfNotExists(indexName string, tableName string, columnName string) bool + func (ss *SqlStore) DoesColumnExist(tableName string, columnName string) bool + func (ss *SqlStore) DoesTableExist(tableName string) bool + func (ss *SqlStore) DoesTriggerExist(triggerName string) bool + func (ss *SqlStore) DriverName() string + func (ss *SqlStore) DropAllTables() + func (ss *SqlStore) Emoji() store.EmojiStore + func (ss *SqlStore) FileInfo() store.FileInfoStore + func (ss *SqlStore) GetAllConns() []*gorp.DbMap + func (ss *SqlStore) GetCurrentSchemaVersion() string + func (ss *SqlStore) GetDbVersion() (string, error) + func (ss *SqlStore) GetMaster() *gorp.DbMap + func (ss *SqlStore) GetMaxLengthOfColumnIfExists(tableName string, columnName string) string + func (ss *SqlStore) GetReplica() *gorp.DbMap + func (ss *SqlStore) GetSearchReplica() *gorp.DbMap + func (ss *SqlStore) Group() store.GroupStore + func (ss *SqlStore) Job() store.JobStore + func (ss *SqlStore) License() store.LicenseStore + func (ss *SqlStore) LinkMetadata() store.LinkMetadataStore + func (ss *SqlStore) LockToMaster() + func (ss *SqlStore) MarkSystemRanUnitTests() + func (ss *SqlStore) OAuth() store.OAuthStore + func (ss *SqlStore) Plugin() store.PluginStore + func (ss *SqlStore) Post() store.PostStore + func (ss *SqlStore) Preference() store.PreferenceStore + func (ss *SqlStore) ProductNotices() store.ProductNoticesStore + func (ss *SqlStore) Reaction() store.ReactionStore + func (ss *SqlStore) RecycleDBConnections(d time.Duration) + func (ss *SqlStore) RemoveColumnIfExists(tableName string, columnName string) bool + func (ss *SqlStore) RemoveIndexIfExists(indexName string, tableName string) bool + func (ss *SqlStore) RemoveTableIfExists(tableName string) bool + func (ss *SqlStore) RenameColumnIfExists(tableName string, oldColumnName string, newColumnName string, colType string) bool + func (ss *SqlStore) Role() store.RoleStore + func (ss *SqlStore) Scheme() store.SchemeStore + func (ss *SqlStore) Session() store.SessionStore + func (ss *SqlStore) SetContext(context context.Context) + func (ss *SqlStore) Status() store.StatusStore + func (ss *SqlStore) System() store.SystemStore + func (ss *SqlStore) Team() store.TeamStore + func (ss *SqlStore) TermsOfService() store.TermsOfServiceStore + func (ss *SqlStore) Thread() store.ThreadStore + func (ss *SqlStore) Token() store.TokenStore + func (ss *SqlStore) TotalMasterDbConnections() int + func (ss *SqlStore) TotalReadDbConnections() int + func (ss *SqlStore) TotalSearchDbConnections() int + func (ss *SqlStore) UnlockFromMaster() + func (ss *SqlStore) UpdateLicense(license *model.License) + func (ss *SqlStore) UploadSession() store.UploadSessionStore + func (ss *SqlStore) User() store.UserStore + func (ss *SqlStore) UserAccessToken() store.UserAccessTokenStore + func (ss *SqlStore) UserTermsOfService() store.UserTermsOfServiceStore + func (ss *SqlStore) Webhook() store.WebhookStore + type SqlStoreStores struct + TermsOfService store.TermsOfServiceStore + UserTermsOfService store.UserTermsOfServiceStore + type SqlSystemStore struct + func (s SqlSystemStore) Get() (model.StringMap, error) + func (s SqlSystemStore) GetByName(name string) (*model.System, error) + func (s SqlSystemStore) InsertIfExists(system *model.System) (*model.System, error) + func (s SqlSystemStore) PermanentDeleteByName(name string) (*model.System, error) + func (s SqlSystemStore) Save(system *model.System) error + func (s SqlSystemStore) SaveOrUpdate(system *model.System) error + func (s SqlSystemStore) SaveOrUpdateWithWarnMetricHandling(system *model.System) error + func (s SqlSystemStore) Update(system *model.System) error + type SqlTeamStore struct + func (s SqlTeamStore) AnalyticsGetTeamCountForScheme(schemeId string) (int64, error) + func (s SqlTeamStore) AnalyticsPrivateTeamCount() (int64, error) + func (s SqlTeamStore) AnalyticsPublicTeamCount() (int64, error) + func (s SqlTeamStore) AnalyticsTeamCount(includeDeleted bool) (int64, error) + func (s SqlTeamStore) ClearAllCustomRoleAssignments() error + func (s SqlTeamStore) ClearCaches() + func (s SqlTeamStore) Get(id string) (*model.Team, error) + func (s SqlTeamStore) GetActiveMemberCount(teamId string, restrictions *model.ViewUsersRestrictions) (int64, error) + func (s SqlTeamStore) GetAll() ([]*model.Team, error) + func (s SqlTeamStore) GetAllForExportAfter(limit int, afterId string) ([]*model.TeamForExport, error) + func (s SqlTeamStore) GetAllPage(offset int, limit int) ([]*model.Team, error) + func (s SqlTeamStore) GetAllPrivateTeamListing() ([]*model.Team, error) + func (s SqlTeamStore) GetAllPrivateTeamPageListing(offset int, limit int) ([]*model.Team, error) + func (s SqlTeamStore) GetAllPublicTeamPageListing(offset int, limit int) ([]*model.Team, error) + func (s SqlTeamStore) GetAllTeamListing() ([]*model.Team, error) + func (s SqlTeamStore) GetAllTeamPageListing(offset int, limit int) ([]*model.Team, error) + func (s SqlTeamStore) GetByInviteId(inviteId string) (*model.Team, error) + func (s SqlTeamStore) GetByName(name string) (*model.Team, error) + func (s SqlTeamStore) GetByNames(names []string) ([]*model.Team, error) + func (s SqlTeamStore) GetChannelUnreadsForAllTeams(excludeTeamId, userId string) ([]*model.ChannelUnread, error) + func (s SqlTeamStore) GetChannelUnreadsForTeam(teamId, userId string) ([]*model.ChannelUnread, error) + func (s SqlTeamStore) GetMember(teamId string, userId string) (*model.TeamMember, error) + func (s SqlTeamStore) GetMembers(teamId string, offset int, limit int, ...) ([]*model.TeamMember, error) + func (s SqlTeamStore) GetMembersByIds(teamId string, userIds []string, restrictions *model.ViewUsersRestrictions) ([]*model.TeamMember, error) + func (s SqlTeamStore) GetTeamMembersForExport(userId string) ([]*model.TeamMemberForExport, error) + func (s SqlTeamStore) GetTeamsByScheme(schemeId string, offset int, limit int) ([]*model.Team, error) + func (s SqlTeamStore) GetTeamsByUserId(userId string) ([]*model.Team, error) + func (s SqlTeamStore) GetTeamsForUser(ctx context.Context, userId string) ([]*model.TeamMember, error) + func (s SqlTeamStore) GetTeamsForUserWithPagination(userId string, page, perPage int) ([]*model.TeamMember, error) + func (s SqlTeamStore) GetTotalMemberCount(teamId string, restrictions *model.ViewUsersRestrictions) (int64, error) + func (s SqlTeamStore) GetUserTeamIds(userId string, allowFromCache bool) ([]string, error) + func (s SqlTeamStore) GroupSyncedTeamCount() (int64, error) + func (s SqlTeamStore) InvalidateAllTeamIdsForUser(userId string) + func (s SqlTeamStore) MigrateTeamMembers(fromTeamId string, fromUserId string) (map[string]string, error) + func (s SqlTeamStore) PermanentDelete(teamId string) error + func (s SqlTeamStore) RemoveAllMembersByTeam(teamId string) error + func (s SqlTeamStore) RemoveAllMembersByUser(userId string) error + func (s SqlTeamStore) RemoveMember(teamId string, userId string) error + func (s SqlTeamStore) RemoveMembers(teamId string, userIds []string) error + func (s SqlTeamStore) ResetAllTeamSchemes() error + func (s SqlTeamStore) Save(team *model.Team) (*model.Team, error) + func (s SqlTeamStore) SaveMember(member *model.TeamMember, maxUsersPerTeam int) (*model.TeamMember, error) + func (s SqlTeamStore) SaveMultipleMembers(members []*model.TeamMember, maxUsersPerTeam int) ([]*model.TeamMember, error) + func (s SqlTeamStore) SearchAll(term string, opts *model.TeamSearch) ([]*model.Team, error) + func (s SqlTeamStore) SearchAllPaged(term string, opts *model.TeamSearch) ([]*model.Team, int64, error) + func (s SqlTeamStore) SearchOpen(term string) ([]*model.Team, error) + func (s SqlTeamStore) SearchPrivate(term string) ([]*model.Team, error) + func (s SqlTeamStore) Update(team *model.Team) (*model.Team, error) + func (s SqlTeamStore) UpdateLastTeamIconUpdate(teamId string, curTime int64) error + func (s SqlTeamStore) UpdateMember(member *model.TeamMember) (*model.TeamMember, error) + func (s SqlTeamStore) UpdateMembersRole(teamID string, userIDs []string) error + func (s SqlTeamStore) UpdateMultipleMembers(members []*model.TeamMember) ([]*model.TeamMember, error) + func (s SqlTeamStore) UserBelongsToTeams(userId string, teamIds []string) (bool, error) + type SqlTermsOfServiceStore struct + func (s SqlTermsOfServiceStore) Get(id string, allowFromCache bool) (*model.TermsOfService, error) + func (s SqlTermsOfServiceStore) GetLatest(allowFromCache bool) (*model.TermsOfService, error) + func (s SqlTermsOfServiceStore) Save(termsOfService *model.TermsOfService) (*model.TermsOfService, error) + type SqlThreadStore struct + func (s *SqlThreadStore) ClearCaches() + func (s *SqlThreadStore) CollectThreadsWithNewerReplies(userId string, channelIds []string, timestamp int64) ([]string, error) + func (s *SqlThreadStore) CreateMembershipIfNeeded(userId, postId string, following, incrementMentions, updateFollowing bool) error + func (s *SqlThreadStore) Delete(threadId string) error + func (s *SqlThreadStore) DeleteMembershipForUser(userId string, postId string) error + func (s *SqlThreadStore) Get(id string) (*model.Thread, error) + func (s *SqlThreadStore) GetMembershipForUser(userId, postId string) (*model.ThreadMembership, error) + func (s *SqlThreadStore) GetMembershipsForUser(userId, teamId string) ([]*model.ThreadMembership, error) + func (s *SqlThreadStore) GetPosts(threadId string, since int64) ([]*model.Post, error) + func (s *SqlThreadStore) GetThreadsForUser(userId, teamId string, opts model.GetUserThreadsOpts) (*model.Threads, error) + func (s *SqlThreadStore) MarkAllAsRead(userId, teamId string) error + func (s *SqlThreadStore) MarkAsRead(userId, threadId string, timestamp int64) error + func (s *SqlThreadStore) Save(thread *model.Thread) (*model.Thread, error) + func (s *SqlThreadStore) SaveMembership(membership *model.ThreadMembership) (*model.ThreadMembership, error) + func (s *SqlThreadStore) SaveMultiple(threads []*model.Thread) ([]*model.Thread, int, error) + func (s *SqlThreadStore) Update(thread *model.Thread) (*model.Thread, error) + func (s *SqlThreadStore) UpdateMembership(membership *model.ThreadMembership) (*model.ThreadMembership, error) + func (s *SqlThreadStore) UpdateUnreadsByChannel(userId string, changedThreads []string, timestamp int64, ...) error + type SqlTokenStore struct + func (s SqlTokenStore) Cleanup() + func (s SqlTokenStore) Delete(token string) error + func (s SqlTokenStore) GetByToken(tokenString string) (*model.Token, error) + func (s SqlTokenStore) RemoveAllTokensByType(tokenType string) error + func (s SqlTokenStore) Save(token *model.Token) error + type SqlUploadSessionStore struct + func (us SqlUploadSessionStore) Delete(id string) error + func (us SqlUploadSessionStore) Get(id string) (*model.UploadSession, error) + func (us SqlUploadSessionStore) GetForUser(userId string) ([]*model.UploadSession, error) + func (us SqlUploadSessionStore) Save(session *model.UploadSession) (*model.UploadSession, error) + func (us SqlUploadSessionStore) Update(session *model.UploadSession) error + type SqlUserAccessTokenStore struct + func (s SqlUserAccessTokenStore) Delete(tokenId string) error + func (s SqlUserAccessTokenStore) DeleteAllForUser(userId string) error + func (s SqlUserAccessTokenStore) Get(tokenId string) (*model.UserAccessToken, error) + func (s SqlUserAccessTokenStore) GetAll(offset, limit int) ([]*model.UserAccessToken, error) + func (s SqlUserAccessTokenStore) GetByToken(tokenString string) (*model.UserAccessToken, error) + func (s SqlUserAccessTokenStore) GetByUser(userId string, offset, limit int) ([]*model.UserAccessToken, error) + func (s SqlUserAccessTokenStore) Save(token *model.UserAccessToken) (*model.UserAccessToken, error) + func (s SqlUserAccessTokenStore) Search(term string) ([]*model.UserAccessToken, error) + func (s SqlUserAccessTokenStore) UpdateTokenDisable(tokenId string) error + func (s SqlUserAccessTokenStore) UpdateTokenEnable(tokenId string) error + type SqlUserStore struct + func (us SqlUserStore) AnalyticsActiveCount(timePeriod int64, options model.UserCountOptions) (int64, error) + func (us SqlUserStore) AnalyticsActiveCountForPeriod(startTime int64, endTime int64, options model.UserCountOptions) (int64, error) + func (us SqlUserStore) AnalyticsGetExternalUsers(hostDomain string) (bool, error) + func (us SqlUserStore) AnalyticsGetGuestCount() (int64, error) + func (us SqlUserStore) AnalyticsGetInactiveUsersCount() (int64, error) + func (us SqlUserStore) AnalyticsGetSystemAdminCount() (int64, error) + func (us SqlUserStore) AutocompleteUsersInChannel(teamId, channelId, term string, options *model.UserSearchOptions) (*model.UserAutocompleteInChannel, error) + func (us SqlUserStore) ClearAllCustomRoleAssignments() error + func (us SqlUserStore) ClearCaches() + func (us SqlUserStore) Count(options model.UserCountOptions) (int64, error) + func (us SqlUserStore) DeactivateGuests() ([]string, error) + func (us SqlUserStore) DemoteUserToGuest(userId string) error + func (us SqlUserStore) Get(id string) (*model.User, error) + func (us SqlUserStore) GetAll() ([]*model.User, error) + func (us SqlUserStore) GetAllAfter(limit int, afterId string) ([]*model.User, error) + func (us SqlUserStore) GetAllNotInAuthService(authServices []string) ([]*model.User, error) + func (us SqlUserStore) GetAllProfiles(options *model.UserGetOptions) ([]*model.User, error) + func (us SqlUserStore) GetAllProfilesInChannel(channelId string, allowFromCache bool) (map[string]*model.User, error) + func (us SqlUserStore) GetAllUsingAuthService(authService string) ([]*model.User, error) + func (us SqlUserStore) GetAnyUnreadPostCountForChannel(userId string, channelId string) (int64, error) + func (us SqlUserStore) GetByAuth(authData *string, authService string) (*model.User, error) + func (us SqlUserStore) GetByEmail(email string) (*model.User, error) + func (us SqlUserStore) GetByUsername(username string) (*model.User, error) + func (us SqlUserStore) GetChannelGroupUsers(channelID string) ([]*model.User, error) + 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, error) + func (us SqlUserStore) GetKnownUsers(userId string) ([]string, error) + func (us SqlUserStore) GetNewUsersForTeam(teamId string, offset, limit int, ...) ([]*model.User, error) + func (us SqlUserStore) GetProfileByGroupChannelIdsForUser(userId string, channelIds []string) (map[string][]*model.User, error) + func (us SqlUserStore) GetProfileByIds(userIds []string, options *store.UserGetByIdsOpts, allowFromCache bool) ([]*model.User, error) + func (us SqlUserStore) GetProfiles(options *model.UserGetOptions) ([]*model.User, error) + func (us SqlUserStore) GetProfilesByUsernames(usernames []string, viewRestrictions *model.ViewUsersRestrictions) ([]*model.User, error) + func (us SqlUserStore) GetProfilesInChannel(options *model.UserGetOptions) ([]*model.User, error) + func (us SqlUserStore) GetProfilesInChannelByStatus(options *model.UserGetOptions) ([]*model.User, error) + func (us SqlUserStore) GetProfilesNotInChannel(teamId string, channelId string, groupConstrained bool, offset int, limit int, ...) ([]*model.User, error) + func (us SqlUserStore) GetProfilesNotInTeam(teamId string, groupConstrained bool, offset int, limit int, ...) ([]*model.User, error) + func (us SqlUserStore) GetProfilesWithoutTeam(options *model.UserGetOptions) ([]*model.User, error) + func (us SqlUserStore) GetRecentlyActiveUsersForTeam(teamId string, offset, limit int, ...) ([]*model.User, error) + func (us SqlUserStore) GetSystemAdminProfiles() (map[string]*model.User, error) + func (us SqlUserStore) GetTeamGroupUsers(teamID string) ([]*model.User, error) + func (us SqlUserStore) GetUnreadCount(userId string) (int64, error) + func (us SqlUserStore) GetUnreadCountForChannel(userId string, channelId string) (int64, error) + func (us SqlUserStore) GetUsersBatchForIndexing(startTime, endTime int64, limit int) ([]*model.UserForIndexing, error) + func (us SqlUserStore) InferSystemInstallDate() (int64, error) + func (us SqlUserStore) InvalidateProfileCacheForUser(userId string) + func (us SqlUserStore) InvalidateProfilesInChannelCache(channelId string) + func (us SqlUserStore) InvalidateProfilesInChannelCacheByUser(userId string) + func (us SqlUserStore) PermanentDelete(userId string) error + func (us SqlUserStore) PromoteGuestToUser(userId string) error + func (us SqlUserStore) ResetLastPictureUpdate(userId string) error + func (us SqlUserStore) Save(user *model.User) (*model.User, error) + func (us SqlUserStore) Search(teamId string, term string, options *model.UserSearchOptions) ([]*model.User, error) + func (us SqlUserStore) SearchInChannel(channelId string, term string, options *model.UserSearchOptions) ([]*model.User, error) + func (us SqlUserStore) SearchInGroup(groupID string, term string, options *model.UserSearchOptions) ([]*model.User, error) + func (us SqlUserStore) SearchNotInChannel(teamId string, channelId string, term string, options *model.UserSearchOptions) ([]*model.User, error) + func (us SqlUserStore) SearchNotInTeam(notInTeamId string, term string, options *model.UserSearchOptions) ([]*model.User, error) + func (us SqlUserStore) SearchWithoutTeam(term string, options *model.UserSearchOptions) ([]*model.User, error) + func (us SqlUserStore) Update(user *model.User, trustedUpdateData bool) (*model.UserUpdate, error) + func (us SqlUserStore) UpdateAuthData(userId string, service string, authData *string, email string, resetMfa bool) (string, error) + func (us SqlUserStore) UpdateFailedPasswordAttempts(userId string, attempts int) error + func (us SqlUserStore) UpdateLastPictureUpdate(userId string) error + func (us SqlUserStore) UpdateMfaActive(userId string, active bool) error + func (us SqlUserStore) UpdateMfaSecret(userId, secret string) error + func (us SqlUserStore) UpdatePassword(userId, hashedPassword string) error + func (us SqlUserStore) UpdateUpdateAt(userId string) (int64, error) + func (us SqlUserStore) VerifyEmail(userId, email string) (string, error) + type SqlUserTermsOfServiceStore struct + func (s SqlUserTermsOfServiceStore) Delete(userId, termsOfServiceId string) error + func (s SqlUserTermsOfServiceStore) GetByUser(userId string) (*model.UserTermsOfService, error) + func (s SqlUserTermsOfServiceStore) Save(userTermsOfService *model.UserTermsOfService) (*model.UserTermsOfService, error) + type SqlWebhookStore struct + func (s SqlWebhookStore) AnalyticsIncomingCount(teamId string) (int64, error) + func (s SqlWebhookStore) AnalyticsOutgoingCount(teamId string) (int64, error) + func (s SqlWebhookStore) ClearCaches() + func (s SqlWebhookStore) DeleteIncoming(webhookId string, time int64) error + func (s SqlWebhookStore) DeleteOutgoing(webhookId string, time int64) error + func (s SqlWebhookStore) GetIncoming(id string, allowFromCache bool) (*model.IncomingWebhook, error) + func (s SqlWebhookStore) GetIncomingByChannel(channelId string) ([]*model.IncomingWebhook, error) + func (s SqlWebhookStore) GetIncomingByTeam(teamId string, offset, limit int) ([]*model.IncomingWebhook, error) + func (s SqlWebhookStore) GetIncomingByTeamByUser(teamId string, userId string, offset, limit int) ([]*model.IncomingWebhook, error) + func (s SqlWebhookStore) GetIncomingList(offset, limit int) ([]*model.IncomingWebhook, error) + func (s SqlWebhookStore) GetIncomingListByUser(userId string, offset, limit int) ([]*model.IncomingWebhook, error) + func (s SqlWebhookStore) GetOutgoing(id string) (*model.OutgoingWebhook, error) + func (s SqlWebhookStore) GetOutgoingByChannel(channelId string, offset, limit int) ([]*model.OutgoingWebhook, error) + func (s SqlWebhookStore) GetOutgoingByChannelByUser(channelId string, userId string, offset, limit int) ([]*model.OutgoingWebhook, error) + func (s SqlWebhookStore) GetOutgoingByTeam(teamId string, offset, limit int) ([]*model.OutgoingWebhook, error) + func (s SqlWebhookStore) GetOutgoingByTeamByUser(teamId string, userId string, offset, limit int) ([]*model.OutgoingWebhook, error) + func (s SqlWebhookStore) GetOutgoingList(offset, limit int) ([]*model.OutgoingWebhook, error) + func (s SqlWebhookStore) GetOutgoingListByUser(userId string, offset, limit int) ([]*model.OutgoingWebhook, error) + func (s SqlWebhookStore) InvalidateWebhookCache(webhookId string) + func (s SqlWebhookStore) PermanentDeleteIncomingByChannel(channelId string) error + func (s SqlWebhookStore) PermanentDeleteIncomingByUser(userId string) error + func (s SqlWebhookStore) PermanentDeleteOutgoingByChannel(channelId string) error + func (s SqlWebhookStore) PermanentDeleteOutgoingByUser(userId string) error + func (s SqlWebhookStore) SaveIncoming(webhook *model.IncomingWebhook) (*model.IncomingWebhook, error) + func (s SqlWebhookStore) SaveOutgoing(webhook *model.OutgoingWebhook) (*model.OutgoingWebhook, error) + func (s SqlWebhookStore) UpdateIncoming(hook *model.IncomingWebhook) (*model.IncomingWebhook, error) + func (s SqlWebhookStore) UpdateOutgoing(hook *model.OutgoingWebhook) (*model.OutgoingWebhook, error) + type TraceOnAdapter struct + func (t *TraceOnAdapter) Printf(format string, v ...interface{}) + type UserWithChannel struct + ChannelId string + type UserWithLastActivityAt struct + LastActivityAt int64 Other modules containing this package github.com/adacta-ru/mattermost-server github.com/adacta-ru/mattermost-server/v5
Go to main page