Affected by GO-2022-0540 and 46 other vulnerabilities

GO-2022-0540: Mattermost users could access some sensitive information via API call in github.com/mattermost/mattermost-server

GO-2024-2444: Mattermost allows demoted guests to change group names in github.com/mattermost/mattermost-server

GO-2024-2446: Mattermost Cross-site Scripting vulnerability in github.com/mattermost/mattermost-server

GO-2024-2448: Mattermost notified all users in the channel when using WebSockets to respond individually in github.com/mattermost/mattermost-server

GO-2024-2450: Mattermost viewing archived public channels permissions vulnerability in github.com/mattermost/mattermost-server

GO-2024-2541: Mattermost vulnerable to denial of service via large number of emoji reactions in github.com/mattermost/mattermost-server

GO-2024-2566: Mattermost fails to check the required permissions in github.com/mattermost/mattermost-server

GO-2024-2588: Mattermost race condition in github.com/mattermost/mattermost-server

GO-2024-2589: Mattermost denial of service through long emoji value in github.com/mattermost/mattermost-server

GO-2024-2590: Mattermost leaks details of AD/LDAP groups of a teams in github.com/mattermost/mattermost-server

GO-2024-2591: Mattermost post fetching without auditing in compliance export in github.com/mattermost/mattermost-server

GO-2024-2592: Mattermost allows attackers access to posts in channels they are not a member of in github.com/mattermost/mattermost-server

GO-2024-2593: Mattermost fails to check the "invite_guest" permission in github.com/mattermost/mattermost-server

GO-2024-2594: Mattermost fails to limit the number of role names in github.com/mattermost/mattermost-server

GO-2024-2595: Mattermost fails to properly restrict the access of files attached to posts in github.com/mattermost/mattermost-server

GO-2024-2635: Mattermost incorrectly allows access individual posts in github.com/mattermost/mattermost-server

GO-2024-2695: Mattermost Server doesn't limit the number of user preferences in github.com/mattermost/mattermost-server

GO-2024-2696: Mattermost fails to authenticate the source of certain types of post actions in github.com/mattermost/mattermost-server

GO-2024-2706: Mattermost Server Improper Access Control in github.com/mattermost/mattermost-server

GO-2024-2707: Mattermost Server Improper Access Control in github.com/mattermost/mattermost-server

GO-2024-3020: Mattermost allows a remote actor to permanently delete local data by abusing dangerous error handling in github.com/mattermost/mattermost-server

GO-2024-3022: Mattermost allows remote actor to set arbitrary RemoteId values for synced users in github.com/mattermost/mattermost-server

GO-2024-3023: Mattermost allows remote actor to create/update/delete posts in arbitrary channels in github.com/mattermost/mattermost-server

GO-2024-3024: Mattermost allows a user on a remote to set their remote username prop to an arbitrary string in github.com/mattermost/mattermost-server

GO-2024-3025: Mattermost failed to disallow the modification of local users when syncing users in shared channels in github.com/mattermost/mattermost-server

GO-2024-3028: Mattermost failed to properly validate that the channel that comes from the sync message is a shared channel in github.com/mattermost/mattermost-server

GO-2024-3030: Mattermost failed to properly validate synced reactions in github.com/mattermost/mattermost-server

GO-2024-3031: Mattermost allows a remote actor to make an arbitrary local channel read-only in github.com/mattermost/mattermost-server

GO-2024-3032: Mattermost did not properly restrict channel creation in github.com/mattermost/mattermost-server

GO-2024-3089: Mattermost allows guest user with read access to upload files to a channel in github.com/mattermost/mattermost-server

GO-2024-3090: Mattermost allows team admin user without "Add Team Members" permission to disable invite URL in github.com/mattermost/mattermost-server

GO-2024-3091: Mattermost allows user with systems manager role with read-only access to teams to perform write operations on teams in github.com/mattermost/mattermost-server

GO-2024-3092: Mattermost allows unsolicited invites to expose access to local channels in github.com/mattermost/mattermost-server

GO-2024-3093: Mattermost doesn't redact remote users' original email addresses in github.com/mattermost/mattermost-server

GO-2024-3094: Mattermost doesn't restrict which roles can promote a user as system admin in github.com/mattermost/mattermost-server

GO-2024-3096: Mattermost allows remote/synthetic users to create sessions, reset passwords in github.com/mattermost/mattermost-server

GO-2024-3097: Mattermost Cross-Site Request Forgery vulnerability in github.com/mattermost/mattermost-server

GO-2024-3164: Mattermost fails to strip `embeds` from `metadata` when broadcasting `posted` events in github.com/mattermost/mattermost-server

GO-2024-3227: Mattermost incorrectly issues two sessions when using desktop SSO in github.com/mattermost/mattermost-server

GO-2024-3232: Mattermost Server allows user to get private channel names in github.com/mattermost/mattermost-server

GO-2024-3233: Mattermost Server Path Traversal vulnerability that leads to Cross-Site Request Forgery in github.com/mattermost/mattermost-server

GO-2024-3234: Mattermost Server vulnerable to application crash from attacker-generated large response in github.com/mattermost/mattermost-server

GO-2024-3235: Mattermost server allows authenticated user to delete arbitrary post in github.com/mattermost/mattermost-server

GO-2024-3334: Mattermost Server Resource Exhaustion in github.com/mattermost/mattermost-server

GO-2024-3337: Mattermost Improper Validation of Specified Type of Input vulnerability in github.com/mattermost/mattermost-server

GO-2024-3338: Mattermost Race Condition vulnerability in github.com/mattermost/mattermost-server

GO-2024-3340: Mattermost Data Amplification vulnerability in github.com/mattermost/mattermost-server

retrylayer

package

v6.5.1 Latest Latest Go to latest Published: Apr 28, 2022 License: AGPL-3.0, Apache-2.0 Imports: 7 Imported by: 2

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/mattermost/mattermost-server

Links

Open Source Insights

Documentation ¶

Index ¶

type RetryLayer
- func New(childStore store.Store) *RetryLayer
- func (s *RetryLayer) Audit() store.AuditStore
- func (s *RetryLayer) Bot() store.BotStore
- func (s *RetryLayer) Channel() store.ChannelStore
- func (s *RetryLayer) ChannelMemberHistory() store.ChannelMemberHistoryStore
- func (s *RetryLayer) Close()
- func (s *RetryLayer) ClusterDiscovery() store.ClusterDiscoveryStore
- func (s *RetryLayer) Command() store.CommandStore
- func (s *RetryLayer) CommandWebhook() store.CommandWebhookStore
- func (s *RetryLayer) Compliance() store.ComplianceStore
- func (s *RetryLayer) DropAllTables()
- func (s *RetryLayer) Emoji() store.EmojiStore
- func (s *RetryLayer) FileInfo() store.FileInfoStore
- func (s *RetryLayer) GetCurrentSchemaVersion() string
- func (s *RetryLayer) Group() store.GroupStore
- func (s *RetryLayer) Job() store.JobStore
- func (s *RetryLayer) License() store.LicenseStore
- func (s *RetryLayer) LinkMetadata() store.LinkMetadataStore
- func (s *RetryLayer) LockToMaster()
- func (s *RetryLayer) MarkSystemRanUnitTests()
- func (s *RetryLayer) OAuth() store.OAuthStore
- func (s *RetryLayer) Plugin() store.PluginStore
- func (s *RetryLayer) Post() store.PostStore
- func (s *RetryLayer) Preference() store.PreferenceStore
- func (s *RetryLayer) ProductNotices() store.ProductNoticesStore
- func (s *RetryLayer) Reaction() store.ReactionStore
- func (s *RetryLayer) RemoteCluster() store.RemoteClusterStore
- func (s *RetryLayer) RetentionPolicy() store.RetentionPolicyStore
- func (s *RetryLayer) Role() store.RoleStore
- func (s *RetryLayer) Scheme() store.SchemeStore
- func (s *RetryLayer) Session() store.SessionStore
- func (s *RetryLayer) SetContext(context context.Context)
- func (s *RetryLayer) SharedChannel() store.SharedChannelStore
- func (s *RetryLayer) Status() store.StatusStore
- func (s *RetryLayer) System() store.SystemStore
- func (s *RetryLayer) Team() store.TeamStore
- func (s *RetryLayer) TermsOfService() store.TermsOfServiceStore
- func (s *RetryLayer) Thread() store.ThreadStore
- func (s *RetryLayer) Token() store.TokenStore
- func (s *RetryLayer) TotalMasterDbConnections() int
- func (s *RetryLayer) TotalReadDbConnections() int
- func (s *RetryLayer) TotalSearchDbConnections() int
- func (s *RetryLayer) UnlockFromMaster()
- func (s *RetryLayer) UploadSession() store.UploadSessionStore
- func (s *RetryLayer) User() store.UserStore
- func (s *RetryLayer) UserAccessToken() store.UserAccessTokenStore
- func (s *RetryLayer) UserTermsOfService() store.UserTermsOfServiceStore
- func (s *RetryLayer) Webhook() store.WebhookStore
type RetryLayerAuditStore
- func (s *RetryLayerAuditStore) Get(user_id string, offset int, limit int) (model.Audits, error)
- func (s *RetryLayerAuditStore) PermanentDeleteByUser(userID string) error
- func (s *RetryLayerAuditStore) Save(audit *model.Audit) error
type RetryLayerBotStore
- func (s *RetryLayerBotStore) Get(userID string, includeDeleted bool) (*model.Bot, error)
- func (s *RetryLayerBotStore) GetAll(options *model.BotGetOptions) ([]*model.Bot, error)
- func (s *RetryLayerBotStore) PermanentDelete(userID string) error
- func (s *RetryLayerBotStore) Save(bot *model.Bot) (*model.Bot, error)
- func (s *RetryLayerBotStore) Update(bot *model.Bot) (*model.Bot, error)
type RetryLayerChannelMemberHistoryStore
- func (s *RetryLayerChannelMemberHistoryStore) DeleteOrphanedRows(limit int) (int64, error)
- func (s *RetryLayerChannelMemberHistoryStore) GetChannelsLeftSince(userID string, since int64) ([]string, error)
- func (s *RetryLayerChannelMemberHistoryStore) GetUsersInChannelDuring(startTime int64, endTime int64, channelID string) ([]*model.ChannelMemberHistoryResult, error)
- func (s *RetryLayerChannelMemberHistoryStore) LogJoinEvent(userID string, channelID string, joinTime int64) error
- func (s *RetryLayerChannelMemberHistoryStore) LogLeaveEvent(userID string, channelID string, leaveTime int64) error
- func (s *RetryLayerChannelMemberHistoryStore) PermanentDeleteBatch(endTime int64, limit int64) (int64, error)
- func (s *RetryLayerChannelMemberHistoryStore) PermanentDeleteBatchForRetentionPolicies(now int64, globalPolicyEndTime int64, limit int64, ...) (int64, model.RetentionPolicyCursor, error)
type RetryLayerChannelStore
- func (s *RetryLayerChannelStore) AnalyticsDeletedTypeCount(teamID string, channelType model.ChannelType) (int64, error)
- func (s *RetryLayerChannelStore) AnalyticsTypeCount(teamID string, channelType model.ChannelType) (int64, error)
- func (s *RetryLayerChannelStore) Autocomplete(userID string, term string, includeDeleted bool) (model.ChannelListWithTeamData, error)
- func (s *RetryLayerChannelStore) AutocompleteInTeam(teamID string, userID string, term string, includeDeleted bool) (model.ChannelList, error)
- func (s *RetryLayerChannelStore) AutocompleteInTeamForSearch(teamID string, userID string, term string, includeDeleted bool) (model.ChannelList, error)
- func (s *RetryLayerChannelStore) ClearAllCustomRoleAssignments() error
- func (s *RetryLayerChannelStore) ClearCaches()
- func (s *RetryLayerChannelStore) ClearSidebarOnTeamLeave(userID string, teamID string) error
- func (s *RetryLayerChannelStore) CountPostsAfter(channelID string, timestamp int64, userID string) (int, int, error)
- func (s *RetryLayerChannelStore) CreateDirectChannel(userID *model.User, otherUserID *model.User, ...) (*model.Channel, error)
- func (s *RetryLayerChannelStore) CreateInitialSidebarCategories(userID string, teamID string) (*model.OrderedSidebarCategories, error)
- func (s *RetryLayerChannelStore) CreateSidebarCategory(userID string, teamID string, newCategory *model.SidebarCategoryWithChannels) (*model.SidebarCategoryWithChannels, error)
- func (s *RetryLayerChannelStore) Delete(channelID string, time int64) error
- func (s *RetryLayerChannelStore) DeleteSidebarCategory(categoryID string) error
- func (s *RetryLayerChannelStore) DeleteSidebarChannelsByPreferences(preferences model.Preferences) error
- func (s *RetryLayerChannelStore) Get(id string, allowFromCache bool) (*model.Channel, error)
- func (s *RetryLayerChannelStore) GetAll(teamID string) ([]*model.Channel, error)
- func (s *RetryLayerChannelStore) GetAllChannelMembersById(id string) ([]string, error)
- func (s *RetryLayerChannelStore) GetAllChannelMembersForUser(userID string, allowFromCache bool, includeDeleted bool) (map[string]string, error)
- func (s *RetryLayerChannelStore) GetAllChannelMembersNotifyPropsForChannel(channelID string, allowFromCache bool) (map[string]model.StringMap, error)
- func (s *RetryLayerChannelStore) GetAllChannels(page int, perPage int, opts store.ChannelSearchOpts) (model.ChannelListWithTeamData, error)
- func (s *RetryLayerChannelStore) GetAllChannelsCount(opts store.ChannelSearchOpts) (int64, error)
- func (s *RetryLayerChannelStore) GetAllChannelsForExportAfter(limit int, afterID string) ([]*model.ChannelForExport, error)
- func (s *RetryLayerChannelStore) GetAllDirectChannelsForExportAfter(limit int, afterID string) ([]*model.DirectChannelForExport, error)
- func (s *RetryLayerChannelStore) GetByName(team_id string, name string, allowFromCache bool) (*model.Channel, error)
- func (s *RetryLayerChannelStore) GetByNameIncludeDeleted(team_id string, name string, allowFromCache bool) (*model.Channel, error)
- func (s *RetryLayerChannelStore) GetByNames(team_id string, names []string, allowFromCache bool) ([]*model.Channel, error)
- func (s *RetryLayerChannelStore) GetChannelCounts(teamID string, userID string) (*model.ChannelCounts, error)
- func (s *RetryLayerChannelStore) GetChannelMembersForExport(userID string, teamID string) ([]*model.ChannelMemberForExport, error)
- func (s *RetryLayerChannelStore) GetChannelMembersTimezones(channelID string) ([]model.StringMap, error)
- func (s *RetryLayerChannelStore) GetChannelUnread(channelID string, userID string) (*model.ChannelUnread, error)
- func (s *RetryLayerChannelStore) GetChannels(teamID string, userID string, opts *model.ChannelSearchOpts) (model.ChannelList, error)
- func (s *RetryLayerChannelStore) GetChannelsBatchForIndexing(startTime int64, endTime int64, limit int) ([]*model.Channel, error)
- func (s *RetryLayerChannelStore) GetChannelsByIds(channelIds []string, includeDeleted bool) ([]*model.Channel, error)
- func (s *RetryLayerChannelStore) GetChannelsByScheme(schemeID string, offset int, limit int) (model.ChannelList, error)
- func (s *RetryLayerChannelStore) GetChannelsByUser(userID string, includeDeleted bool, lastDeleteAt int, pageSize int, ...) (model.ChannelList, error)
- func (s *RetryLayerChannelStore) GetChannelsWithCursor(teamId string, userId string, opts *model.ChannelSearchOpts, ...) (model.ChannelList, error)
- func (s *RetryLayerChannelStore) GetChannelsWithTeamDataByIds(channelIds []string, includeDeleted bool) ([]*model.ChannelWithTeamData, error)
- func (s *RetryLayerChannelStore) GetDeleted(team_id string, offset int, limit int, userID string) (model.ChannelList, error)
- func (s *RetryLayerChannelStore) GetDeletedByName(team_id string, name string) (*model.Channel, error)
- func (s *RetryLayerChannelStore) GetForPost(postID string) (*model.Channel, error)
- func (s *RetryLayerChannelStore) GetFromMaster(id string) (*model.Channel, error)
- func (s *RetryLayerChannelStore) GetGuestCount(channelID string, allowFromCache bool) (int64, error)
- func (s *RetryLayerChannelStore) GetMember(ctx context.Context, channelID string, userID string) (*model.ChannelMember, error)
- func (s *RetryLayerChannelStore) GetMemberCount(channelID string, allowFromCache bool) (int64, error)
- func (s *RetryLayerChannelStore) GetMemberCountFromCache(channelID string) int64
- func (s *RetryLayerChannelStore) GetMemberCountsByGroup(ctx context.Context, channelID string, includeTimezones bool) ([]*model.ChannelMemberCountByGroup, error)
- func (s *RetryLayerChannelStore) GetMemberForPost(postID string, userID string) (*model.ChannelMember, error)
- func (s *RetryLayerChannelStore) GetMembers(channelID string, offset int, limit int) (model.ChannelMembers, error)
- func (s *RetryLayerChannelStore) GetMembersByChannelIds(channelIds []string, userID string) (model.ChannelMembers, error)
- func (s *RetryLayerChannelStore) GetMembersByIds(channelID string, userIds []string) (model.ChannelMembers, error)
- func (s *RetryLayerChannelStore) GetMembersForUser(teamID string, userID string) (model.ChannelMembers, error)
- func (s *RetryLayerChannelStore) GetMembersForUserWithCursor(userID string, afterChannel string, afterUser string, limit int, ...) (model.ChannelMembers, error)
- func (s *RetryLayerChannelStore) GetMembersForUserWithPagination(userID string, page int, perPage int) (model.ChannelMembersWithTeamData, error)
- func (s *RetryLayerChannelStore) GetMembersInfoByChannelIds(channelIDs []string) (map[string][]*model.User, error)
- func (s *RetryLayerChannelStore) GetMoreChannels(teamID string, userID string, offset int, limit int) (model.ChannelList, error)
- func (s *RetryLayerChannelStore) GetPinnedPostCount(channelID string, allowFromCache bool) (int64, error)
- func (s *RetryLayerChannelStore) GetPinnedPosts(channelID string) (*model.PostList, error)
- func (s *RetryLayerChannelStore) GetPrivateChannelsForTeam(teamID string, offset int, limit int) (model.ChannelList, error)
- func (s *RetryLayerChannelStore) GetPublicChannelsByIdsForTeam(teamID string, channelIds []string) (model.ChannelList, error)
- func (s *RetryLayerChannelStore) GetPublicChannelsForTeam(teamID string, offset int, limit int) (model.ChannelList, error)
- func (s *RetryLayerChannelStore) GetSidebarCategories(userID string, teamID string) (*model.OrderedSidebarCategories, error)
- func (s *RetryLayerChannelStore) GetSidebarCategory(categoryID string) (*model.SidebarCategoryWithChannels, error)
- func (s *RetryLayerChannelStore) GetSidebarCategoryOrder(userID string, teamID string) ([]string, error)
- func (s *RetryLayerChannelStore) GetTeamChannels(teamID string) (model.ChannelList, error)
- func (s *RetryLayerChannelStore) GetTeamForChannel(channelID string) (*model.Team, error)
- func (s *RetryLayerChannelStore) GetTeamMembersForChannel(channelID string) ([]string, error)
- func (s *RetryLayerChannelStore) GroupSyncedChannelCount() (int64, error)
- func (s *RetryLayerChannelStore) IncrementMentionCount(channelID string, userID string, isRoot bool) error
- func (s *RetryLayerChannelStore) InvalidateAllChannelMembersForUser(userID string)
- func (s *RetryLayerChannelStore) InvalidateCacheForChannelMembersNotifyProps(channelID string)
- func (s *RetryLayerChannelStore) InvalidateChannel(id string)
- func (s *RetryLayerChannelStore) InvalidateChannelByName(teamID string, name string)
- func (s *RetryLayerChannelStore) InvalidateGuestCount(channelID string)
- func (s *RetryLayerChannelStore) InvalidateMemberCount(channelID string)
- func (s *RetryLayerChannelStore) InvalidatePinnedPostCount(channelID string)
- func (s *RetryLayerChannelStore) IsUserInChannelUseCache(userID string, channelID string) bool
- func (s *RetryLayerChannelStore) MigrateChannelMembers(fromChannelID string, fromUserID string) (map[string]string, error)
- func (s *RetryLayerChannelStore) PermanentDelete(channelID string) error
- func (s *RetryLayerChannelStore) PermanentDeleteByTeam(teamID string) error
- func (s *RetryLayerChannelStore) PermanentDeleteMembersByChannel(channelID string) error
- func (s *RetryLayerChannelStore) PermanentDeleteMembersByUser(userID string) error
- func (s *RetryLayerChannelStore) RemoveAllDeactivatedMembers(channelID string) error
- func (s *RetryLayerChannelStore) RemoveMember(channelID string, userID string) error
- func (s *RetryLayerChannelStore) RemoveMembers(channelID string, userIds []string) error
- func (s *RetryLayerChannelStore) ResetAllChannelSchemes() error
- func (s *RetryLayerChannelStore) Restore(channelID string, time int64) error
- func (s *RetryLayerChannelStore) Save(channel *model.Channel, maxChannelsPerTeam int64) (*model.Channel, error)
- func (s *RetryLayerChannelStore) SaveDirectChannel(channel *model.Channel, member1 *model.ChannelMember, ...) (*model.Channel, error)
- func (s *RetryLayerChannelStore) SaveMember(member *model.ChannelMember) (*model.ChannelMember, error)
- func (s *RetryLayerChannelStore) SaveMultipleMembers(members []*model.ChannelMember) ([]*model.ChannelMember, error)
- func (s *RetryLayerChannelStore) SearchAllChannels(term string, opts store.ChannelSearchOpts) (model.ChannelListWithTeamData, int64, error)
- func (s *RetryLayerChannelStore) SearchArchivedInTeam(teamID string, term string, userID string) (model.ChannelList, error)
- func (s *RetryLayerChannelStore) SearchForUserInTeam(userID string, teamID string, term string, includeDeleted bool) (model.ChannelList, error)
- func (s *RetryLayerChannelStore) SearchGroupChannels(userID string, term string) (model.ChannelList, error)
- func (s *RetryLayerChannelStore) SearchInTeam(teamID string, term string, includeDeleted bool) (model.ChannelList, error)
- func (s *RetryLayerChannelStore) SearchMore(userID string, teamID string, term string) (model.ChannelList, error)
- func (s *RetryLayerChannelStore) SetDeleteAt(channelID string, deleteAt int64, updateAt int64) error
- func (s *RetryLayerChannelStore) SetShared(channelId string, shared bool) error
- func (s *RetryLayerChannelStore) Update(channel *model.Channel) (*model.Channel, error)
- func (s *RetryLayerChannelStore) UpdateLastViewedAt(channelIds []string, userID string) (map[string]int64, error)
- func (s *RetryLayerChannelStore) UpdateLastViewedAtPost(unreadPost *model.Post, userID string, mentionCount int, mentionCountRoot int, ...) (*model.ChannelUnreadAt, error)
- func (s *RetryLayerChannelStore) UpdateMember(member *model.ChannelMember) (*model.ChannelMember, error)
- func (s *RetryLayerChannelStore) UpdateMemberNotifyProps(channelID string, userID string, props map[string]string) (*model.ChannelMember, error)
- func (s *RetryLayerChannelStore) UpdateMembersRole(channelID string, userIDs []string) error
- func (s *RetryLayerChannelStore) UpdateMultipleMembers(members []*model.ChannelMember) ([]*model.ChannelMember, error)
- func (s *RetryLayerChannelStore) UpdateSidebarCategories(userID string, teamID string, categories []*model.SidebarCategoryWithChannels) ([]*model.SidebarCategoryWithChannels, []*model.SidebarCategoryWithChannels, ...)
- func (s *RetryLayerChannelStore) UpdateSidebarCategoryOrder(userID string, teamID string, categoryOrder []string) error
- func (s *RetryLayerChannelStore) UpdateSidebarChannelCategoryOnMove(channel *model.Channel, newTeamID string) error
- func (s *RetryLayerChannelStore) UpdateSidebarChannelsByPreferences(preferences model.Preferences) error
- func (s *RetryLayerChannelStore) UserBelongsToChannels(userID string, channelIds []string) (bool, error)
type RetryLayerClusterDiscoveryStore
- func (s *RetryLayerClusterDiscoveryStore) Cleanup() error
- func (s *RetryLayerClusterDiscoveryStore) Delete(discovery *model.ClusterDiscovery) (bool, error)
- func (s *RetryLayerClusterDiscoveryStore) Exists(discovery *model.ClusterDiscovery) (bool, error)
- func (s *RetryLayerClusterDiscoveryStore) GetAll(discoveryType string, clusterName string) ([]*model.ClusterDiscovery, error)
- func (s *RetryLayerClusterDiscoveryStore) Save(discovery *model.ClusterDiscovery) error
- func (s *RetryLayerClusterDiscoveryStore) SetLastPingAt(discovery *model.ClusterDiscovery) error
type RetryLayerCommandStore
- func (s *RetryLayerCommandStore) AnalyticsCommandCount(teamID string) (int64, error)
- func (s *RetryLayerCommandStore) Delete(commandID string, time int64) error
- func (s *RetryLayerCommandStore) Get(id string) (*model.Command, error)
- func (s *RetryLayerCommandStore) GetByTeam(teamID string) ([]*model.Command, error)
- func (s *RetryLayerCommandStore) GetByTrigger(teamID string, trigger string) (*model.Command, error)
- func (s *RetryLayerCommandStore) PermanentDeleteByTeam(teamID string) error
- func (s *RetryLayerCommandStore) PermanentDeleteByUser(userID string) error
- func (s *RetryLayerCommandStore) Save(webhook *model.Command) (*model.Command, error)
- func (s *RetryLayerCommandStore) Update(hook *model.Command) (*model.Command, error)
type RetryLayerCommandWebhookStore
- func (s *RetryLayerCommandWebhookStore) Cleanup()
- func (s *RetryLayerCommandWebhookStore) Get(id string) (*model.CommandWebhook, error)
- func (s *RetryLayerCommandWebhookStore) Save(webhook *model.CommandWebhook) (*model.CommandWebhook, error)
- func (s *RetryLayerCommandWebhookStore) TryUse(id string, limit int) error
type RetryLayerComplianceStore
- func (s *RetryLayerComplianceStore) ComplianceExport(compliance *model.Compliance, cursor model.ComplianceExportCursor, limit int) ([]*model.CompliancePost, model.ComplianceExportCursor, error)
- func (s *RetryLayerComplianceStore) Get(id string) (*model.Compliance, error)
- func (s *RetryLayerComplianceStore) GetAll(offset int, limit int) (model.Compliances, error)
- func (s *RetryLayerComplianceStore) MessageExport(cursor model.MessageExportCursor, limit int) ([]*model.MessageExport, model.MessageExportCursor, error)
- func (s *RetryLayerComplianceStore) Save(compliance *model.Compliance) (*model.Compliance, error)
- func (s *RetryLayerComplianceStore) Update(compliance *model.Compliance) (*model.Compliance, error)
type RetryLayerEmojiStore
- func (s *RetryLayerEmojiStore) Delete(emoji *model.Emoji, time int64) error
- func (s *RetryLayerEmojiStore) Get(ctx context.Context, id string, allowFromCache bool) (*model.Emoji, error)
- func (s *RetryLayerEmojiStore) GetByName(ctx context.Context, name string, allowFromCache bool) (*model.Emoji, error)
- func (s *RetryLayerEmojiStore) GetList(offset int, limit int, sort string) ([]*model.Emoji, error)
- func (s *RetryLayerEmojiStore) GetMultipleByName(names []string) ([]*model.Emoji, error)
- func (s *RetryLayerEmojiStore) Save(emoji *model.Emoji) (*model.Emoji, error)
- func (s *RetryLayerEmojiStore) Search(name string, prefixOnly bool, limit int) ([]*model.Emoji, error)
type RetryLayerFileInfoStore
- func (s *RetryLayerFileInfoStore) AttachToPost(fileID string, postID string, creatorID string) error
- func (s *RetryLayerFileInfoStore) ClearCaches()
- func (s *RetryLayerFileInfoStore) CountAll() (int64, error)
- func (s *RetryLayerFileInfoStore) DeleteForPost(postID string) (string, error)
- func (s *RetryLayerFileInfoStore) Get(id string) (*model.FileInfo, error)
- func (s *RetryLayerFileInfoStore) GetByIds(ids []string) ([]*model.FileInfo, error)
- func (s *RetryLayerFileInfoStore) GetByPath(path string) (*model.FileInfo, error)
- func (s *RetryLayerFileInfoStore) GetFilesBatchForIndexing(startTime int64, endTime int64, limit int) ([]*model.FileForIndexing, error)
- func (s *RetryLayerFileInfoStore) GetForPost(postID string, readFromMaster bool, includeDeleted bool, allowFromCache bool) ([]*model.FileInfo, error)
- func (s *RetryLayerFileInfoStore) GetForUser(userID string) ([]*model.FileInfo, error)
- func (s *RetryLayerFileInfoStore) GetFromMaster(id string) (*model.FileInfo, error)
- func (s *RetryLayerFileInfoStore) GetWithOptions(page int, perPage int, opt *model.GetFileInfosOptions) ([]*model.FileInfo, error)
- func (s *RetryLayerFileInfoStore) InvalidateFileInfosForPostCache(postID string, deleted bool)
- func (s *RetryLayerFileInfoStore) PermanentDelete(fileID string) error
- func (s *RetryLayerFileInfoStore) PermanentDeleteBatch(endTime int64, limit int64) (int64, error)
- func (s *RetryLayerFileInfoStore) PermanentDeleteByUser(userID string) (int64, error)
- func (s *RetryLayerFileInfoStore) Save(info *model.FileInfo) (*model.FileInfo, error)
- func (s *RetryLayerFileInfoStore) Search(paramsList []*model.SearchParams, userID string, teamID string, page int, ...) (*model.FileInfoList, error)
- func (s *RetryLayerFileInfoStore) SetContent(fileID string, content string) error
- func (s *RetryLayerFileInfoStore) Upsert(info *model.FileInfo) (*model.FileInfo, error)
type RetryLayerGroupStore
- func (s *RetryLayerGroupStore) AdminRoleGroupsForSyncableMember(userID string, syncableID string, syncableType model.GroupSyncableType) ([]string, error)
- func (s *RetryLayerGroupStore) ChannelMembersMinusGroupMembers(channelID string, groupIDs []string, page int, perPage int) ([]*model.UserWithGroups, error)
- func (s *RetryLayerGroupStore) ChannelMembersToAdd(since int64, channelID *string, includeRemovedMembers bool) ([]*model.UserChannelIDPair, error)
- func (s *RetryLayerGroupStore) ChannelMembersToRemove(channelID *string) ([]*model.ChannelMember, error)
- func (s *RetryLayerGroupStore) CountChannelMembersMinusGroupMembers(channelID string, groupIDs []string) (int64, error)
- func (s *RetryLayerGroupStore) CountGroupsByChannel(channelID string, opts model.GroupSearchOpts) (int64, error)
- func (s *RetryLayerGroupStore) CountGroupsByTeam(teamID string, opts model.GroupSearchOpts) (int64, error)
- func (s *RetryLayerGroupStore) CountTeamMembersMinusGroupMembers(teamID string, groupIDs []string) (int64, error)
- func (s *RetryLayerGroupStore) Create(group *model.Group) (*model.Group, error)
- func (s *RetryLayerGroupStore) CreateGroupSyncable(groupSyncable *model.GroupSyncable) (*model.GroupSyncable, error)
- func (s *RetryLayerGroupStore) CreateWithUserIds(group *model.GroupWithUserIds) (*model.Group, error)
- func (s *RetryLayerGroupStore) Delete(groupID string) (*model.Group, error)
- func (s *RetryLayerGroupStore) DeleteGroupSyncable(groupID string, syncableID string, syncableType model.GroupSyncableType) (*model.GroupSyncable, error)
- func (s *RetryLayerGroupStore) DeleteMember(groupID string, userID string) (*model.GroupMember, error)
- func (s *RetryLayerGroupStore) DeleteMembers(groupID string, userIDs []string) ([]*model.GroupMember, error)
- func (s *RetryLayerGroupStore) DistinctGroupMemberCount() (int64, error)
- func (s *RetryLayerGroupStore) Get(groupID string) (*model.Group, error)
- func (s *RetryLayerGroupStore) GetAllBySource(groupSource model.GroupSource) ([]*model.Group, error)
- func (s *RetryLayerGroupStore) GetAllGroupSyncablesByGroupId(groupID string, syncableType model.GroupSyncableType) ([]*model.GroupSyncable, error)
- func (s *RetryLayerGroupStore) GetByIDs(groupIDs []string) ([]*model.Group, error)
- func (s *RetryLayerGroupStore) GetByName(name string, opts model.GroupSearchOpts) (*model.Group, error)
- func (s *RetryLayerGroupStore) GetByRemoteID(remoteID string, groupSource model.GroupSource) (*model.Group, error)
- func (s *RetryLayerGroupStore) GetByUser(userID string) ([]*model.Group, error)
- func (s *RetryLayerGroupStore) GetGroupSyncable(groupID string, syncableID string, syncableType model.GroupSyncableType) (*model.GroupSyncable, error)
- func (s *RetryLayerGroupStore) GetGroups(page int, perPage int, opts model.GroupSearchOpts) ([]*model.Group, error)
- func (s *RetryLayerGroupStore) GetGroupsAssociatedToChannelsByTeam(teamID string, opts model.GroupSearchOpts) (map[string][]*model.GroupWithSchemeAdmin, error)
- func (s *RetryLayerGroupStore) GetGroupsByChannel(channelID string, opts model.GroupSearchOpts) ([]*model.GroupWithSchemeAdmin, error)
- func (s *RetryLayerGroupStore) GetGroupsByTeam(teamID string, opts model.GroupSearchOpts) ([]*model.GroupWithSchemeAdmin, error)
- func (s *RetryLayerGroupStore) GetMember(groupID string, userID string) (*model.GroupMember, error)
- func (s *RetryLayerGroupStore) GetMemberCount(groupID string) (int64, error)
- func (s *RetryLayerGroupStore) GetMemberUsers(groupID string) ([]*model.User, error)
- func (s *RetryLayerGroupStore) GetMemberUsersInTeam(groupID string, teamID string) ([]*model.User, error)
- func (s *RetryLayerGroupStore) GetMemberUsersNotInChannel(groupID string, channelID string) ([]*model.User, error)
- func (s *RetryLayerGroupStore) GetMemberUsersPage(groupID string, page int, perPage int) ([]*model.User, error)
- func (s *RetryLayerGroupStore) GetNonMemberUsersPage(groupID string, page int, perPage int) ([]*model.User, error)
- func (s *RetryLayerGroupStore) GroupChannelCount() (int64, error)
- func (s *RetryLayerGroupStore) GroupCount() (int64, error)
- func (s *RetryLayerGroupStore) GroupCountWithAllowReference() (int64, error)
- func (s *RetryLayerGroupStore) GroupMemberCount() (int64, error)
- func (s *RetryLayerGroupStore) GroupTeamCount() (int64, error)
- func (s *RetryLayerGroupStore) PermanentDeleteMembersByUser(userID string) error
- func (s *RetryLayerGroupStore) PermittedSyncableAdmins(syncableID string, syncableType model.GroupSyncableType) ([]string, error)
- func (s *RetryLayerGroupStore) TeamMembersMinusGroupMembers(teamID string, groupIDs []string, page int, perPage int) ([]*model.UserWithGroups, error)
- func (s *RetryLayerGroupStore) TeamMembersToAdd(since int64, teamID *string, includeRemovedMembers bool) ([]*model.UserTeamIDPair, error)
- func (s *RetryLayerGroupStore) TeamMembersToRemove(teamID *string) ([]*model.TeamMember, error)
- func (s *RetryLayerGroupStore) Update(group *model.Group) (*model.Group, error)
- func (s *RetryLayerGroupStore) UpdateGroupSyncable(groupSyncable *model.GroupSyncable) (*model.GroupSyncable, error)
- func (s *RetryLayerGroupStore) UpsertMember(groupID string, userID string) (*model.GroupMember, error)
- func (s *RetryLayerGroupStore) UpsertMembers(groupID string, userIDs []string) ([]*model.GroupMember, error)
type RetryLayerJobStore
- func (s *RetryLayerJobStore) Cleanup(expiryTime int64, batchSize int) error
- func (s *RetryLayerJobStore) Delete(id string) (string, error)
- func (s *RetryLayerJobStore) Get(id string) (*model.Job, error)
- func (s *RetryLayerJobStore) GetAllByStatus(status string) ([]*model.Job, error)
- func (s *RetryLayerJobStore) GetAllByType(jobType string) ([]*model.Job, error)
- func (s *RetryLayerJobStore) GetAllByTypeAndStatus(jobType string, status string) ([]*model.Job, error)
- func (s *RetryLayerJobStore) GetAllByTypePage(jobType string, offset int, limit int) ([]*model.Job, error)
- func (s *RetryLayerJobStore) GetAllByTypesPage(jobTypes []string, offset int, limit int) ([]*model.Job, error)
- func (s *RetryLayerJobStore) GetAllPage(offset int, limit int) ([]*model.Job, error)
- func (s *RetryLayerJobStore) GetCountByStatusAndType(status string, jobType string) (int64, error)
- func (s *RetryLayerJobStore) GetNewestJobByStatusAndType(status string, jobType string) (*model.Job, error)
- func (s *RetryLayerJobStore) GetNewestJobByStatusesAndType(statuses []string, jobType string) (*model.Job, error)
- func (s *RetryLayerJobStore) Save(job *model.Job) (*model.Job, error)
- func (s *RetryLayerJobStore) UpdateOptimistically(job *model.Job, currentStatus string) (bool, error)
- func (s *RetryLayerJobStore) UpdateStatus(id string, status string) (*model.Job, error)
- func (s *RetryLayerJobStore) UpdateStatusOptimistically(id string, currentStatus string, newStatus string) (bool, error)
type RetryLayerLicenseStore
- func (s *RetryLayerLicenseStore) Get(id string) (*model.LicenseRecord, error)
- func (s *RetryLayerLicenseStore) GetAll() ([]*model.LicenseRecord, error)
- func (s *RetryLayerLicenseStore) Save(license *model.LicenseRecord) (*model.LicenseRecord, error)
type RetryLayerLinkMetadataStore
- func (s *RetryLayerLinkMetadataStore) Get(url string, timestamp int64) (*model.LinkMetadata, error)
- func (s *RetryLayerLinkMetadataStore) Save(linkMetadata *model.LinkMetadata) (*model.LinkMetadata, error)
type RetryLayerOAuthStore
- func (s *RetryLayerOAuthStore) DeleteApp(id string) error
- func (s *RetryLayerOAuthStore) GetAccessData(token string) (*model.AccessData, error)
- func (s *RetryLayerOAuthStore) GetAccessDataByRefreshToken(token string) (*model.AccessData, error)
- func (s *RetryLayerOAuthStore) GetAccessDataByUserForApp(userID string, clientId string) ([]*model.AccessData, error)
- func (s *RetryLayerOAuthStore) GetApp(id string) (*model.OAuthApp, error)
- func (s *RetryLayerOAuthStore) GetAppByUser(userID string, offset int, limit int) ([]*model.OAuthApp, error)
- func (s *RetryLayerOAuthStore) GetApps(offset int, limit int) ([]*model.OAuthApp, error)
- func (s *RetryLayerOAuthStore) GetAuthData(code string) (*model.AuthData, error)
- func (s *RetryLayerOAuthStore) GetAuthorizedApps(userID string, offset int, limit int) ([]*model.OAuthApp, error)
- func (s *RetryLayerOAuthStore) GetPreviousAccessData(userID string, clientId string) (*model.AccessData, error)
- func (s *RetryLayerOAuthStore) PermanentDeleteAuthDataByUser(userID string) error
- func (s *RetryLayerOAuthStore) RemoveAccessData(token string) error
- func (s *RetryLayerOAuthStore) RemoveAllAccessData() error
- func (s *RetryLayerOAuthStore) RemoveAuthData(code string) error
- func (s *RetryLayerOAuthStore) SaveAccessData(accessData *model.AccessData) (*model.AccessData, error)
- func (s *RetryLayerOAuthStore) SaveApp(app *model.OAuthApp) (*model.OAuthApp, error)
- func (s *RetryLayerOAuthStore) SaveAuthData(authData *model.AuthData) (*model.AuthData, error)
- func (s *RetryLayerOAuthStore) UpdateAccessData(accessData *model.AccessData) (*model.AccessData, error)
- func (s *RetryLayerOAuthStore) UpdateApp(app *model.OAuthApp) (*model.OAuthApp, error)
type RetryLayerPluginStore
- func (s *RetryLayerPluginStore) CompareAndDelete(keyVal *model.PluginKeyValue, oldValue []byte) (bool, error)
- func (s *RetryLayerPluginStore) CompareAndSet(keyVal *model.PluginKeyValue, oldValue []byte) (bool, error)
- func (s *RetryLayerPluginStore) Delete(pluginID string, key string) error
- func (s *RetryLayerPluginStore) DeleteAllExpired() error
- func (s *RetryLayerPluginStore) DeleteAllForPlugin(PluginID string) error
- func (s *RetryLayerPluginStore) Get(pluginID string, key string) (*model.PluginKeyValue, error)
- func (s *RetryLayerPluginStore) List(pluginID string, page int, perPage int) ([]string, error)
- func (s *RetryLayerPluginStore) SaveOrUpdate(keyVal *model.PluginKeyValue) (*model.PluginKeyValue, error)
- func (s *RetryLayerPluginStore) SetWithOptions(pluginID string, key string, value []byte, options model.PluginKVSetOptions) (bool, error)
type RetryLayerPostStore
- func (s *RetryLayerPostStore) AnalyticsPostCount(teamID string, mustHaveFile bool, mustHaveHashtag bool) (int64, error)
- func (s *RetryLayerPostStore) AnalyticsPostCountsByDay(options *model.AnalyticsPostCountsOptions) (model.AnalyticsRows, error)
- func (s *RetryLayerPostStore) AnalyticsUserCountsWithPostsByDay(teamID string) (model.AnalyticsRows, error)
- func (s *RetryLayerPostStore) ClearCaches()
- func (s *RetryLayerPostStore) Delete(postID string, time int64, deleteByID string) error
- func (s *RetryLayerPostStore) DeleteOrphanedRows(limit int) (int64, error)
- func (s *RetryLayerPostStore) Get(ctx context.Context, id string, skipFetchThreads bool, collapsedThreads bool, ...) (*model.PostList, error)
- func (s *RetryLayerPostStore) GetDirectPostParentsForExportAfter(limit int, afterID string) ([]*model.DirectPostForExport, error)
- func (s *RetryLayerPostStore) GetEtag(channelID string, allowFromCache bool, collapsedThreads bool) string
- func (s *RetryLayerPostStore) GetFlaggedPosts(userID string, offset int, limit int) (*model.PostList, error)
- func (s *RetryLayerPostStore) GetFlaggedPostsForChannel(userID string, channelID string, offset int, limit int) (*model.PostList, error)
- func (s *RetryLayerPostStore) GetFlaggedPostsForTeam(userID string, teamID string, offset int, limit int) (*model.PostList, error)
- func (s *RetryLayerPostStore) GetLastPostRowCreateAt() (int64, error)
- func (s *RetryLayerPostStore) GetMaxPostSize() int
- func (s *RetryLayerPostStore) GetOldest() (*model.Post, error)
- func (s *RetryLayerPostStore) GetOldestEntityCreationTime() (int64, error)
- func (s *RetryLayerPostStore) GetParentsForExportAfter(limit int, afterID string) ([]*model.PostForExport, error)
- func (s *RetryLayerPostStore) GetPostAfterTime(channelID string, time int64, collapsedThreads bool) (*model.Post, error)
- func (s *RetryLayerPostStore) GetPostIdAfterTime(channelID string, time int64, collapsedThreads bool) (string, error)
- func (s *RetryLayerPostStore) GetPostIdBeforeTime(channelID string, time int64, collapsedThreads bool) (string, error)
- func (s *RetryLayerPostStore) GetPosts(options model.GetPostsOptions, allowFromCache bool) (*model.PostList, error)
- func (s *RetryLayerPostStore) GetPostsAfter(options model.GetPostsOptions) (*model.PostList, error)
- func (s *RetryLayerPostStore) GetPostsBatchForIndexing(startTime int64, endTime int64, limit int) ([]*model.PostForIndexing, error)
- func (s *RetryLayerPostStore) GetPostsBefore(options model.GetPostsOptions) (*model.PostList, error)
- func (s *RetryLayerPostStore) GetPostsByIds(postIds []string) ([]*model.Post, error)
- func (s *RetryLayerPostStore) GetPostsCreatedAt(channelID string, time int64) ([]*model.Post, error)
- func (s *RetryLayerPostStore) GetPostsSince(options model.GetPostsSinceOptions, allowFromCache bool) (*model.PostList, error)
- func (s *RetryLayerPostStore) GetPostsSinceForSync(options model.GetPostsSinceForSyncOptions, ...) ([]*model.Post, model.GetPostsSinceForSyncCursor, error)
- func (s *RetryLayerPostStore) GetRepliesForExport(parentID string) ([]*model.ReplyForExport, error)
- func (s *RetryLayerPostStore) GetSingle(id string, inclDeleted bool) (*model.Post, error)
- func (s *RetryLayerPostStore) HasAutoResponsePostByUserSince(options model.GetPostsSinceOptions, userId string) (bool, error)
- func (s *RetryLayerPostStore) InvalidateLastPostTimeCache(channelID string)
- func (s *RetryLayerPostStore) Overwrite(post *model.Post) (*model.Post, error)
- func (s *RetryLayerPostStore) OverwriteMultiple(posts []*model.Post) ([]*model.Post, int, error)
- func (s *RetryLayerPostStore) PermanentDeleteBatch(endTime int64, limit int64) (int64, error)
- func (s *RetryLayerPostStore) PermanentDeleteBatchForRetentionPolicies(now int64, globalPolicyEndTime int64, limit int64, ...) (int64, model.RetentionPolicyCursor, error)
- func (s *RetryLayerPostStore) PermanentDeleteByChannel(channelID string) error
- func (s *RetryLayerPostStore) PermanentDeleteByUser(userID string) error
- func (s *RetryLayerPostStore) Save(post *model.Post) (*model.Post, error)
- func (s *RetryLayerPostStore) SaveMultiple(posts []*model.Post) ([]*model.Post, int, error)
- func (s *RetryLayerPostStore) Search(teamID string, userID string, params *model.SearchParams) (*model.PostList, error)
- func (s *RetryLayerPostStore) SearchPostsForUser(paramsList []*model.SearchParams, userID string, teamID string, page int, ...) (*model.PostSearchResults, error)
- func (s *RetryLayerPostStore) Update(newPost *model.Post, oldPost *model.Post) (*model.Post, error)
type RetryLayerPreferenceStore
- func (s *RetryLayerPreferenceStore) CleanupFlagsBatch(limit int64) (int64, error)
- func (s *RetryLayerPreferenceStore) Delete(userID string, category string, name string) error
- func (s *RetryLayerPreferenceStore) DeleteCategory(userID string, category string) error
- func (s *RetryLayerPreferenceStore) DeleteCategoryAndName(category string, name string) error
- func (s *RetryLayerPreferenceStore) DeleteOrphanedRows(limit int) (int64, error)
- func (s *RetryLayerPreferenceStore) Get(userID string, category string, name string) (*model.Preference, error)
- func (s *RetryLayerPreferenceStore) GetAll(userID string) (model.Preferences, error)
- func (s *RetryLayerPreferenceStore) GetCategory(userID string, category string) (model.Preferences, error)
- func (s *RetryLayerPreferenceStore) PermanentDeleteByUser(userID string) error
- func (s *RetryLayerPreferenceStore) Save(preferences model.Preferences) error
type RetryLayerProductNoticesStore
- func (s *RetryLayerProductNoticesStore) Clear(notices []string) error
- func (s *RetryLayerProductNoticesStore) ClearOldNotices(currentNotices model.ProductNotices) error
- func (s *RetryLayerProductNoticesStore) GetViews(userID string) ([]model.ProductNoticeViewState, error)
- func (s *RetryLayerProductNoticesStore) View(userID string, notices []string) error
type RetryLayerReactionStore
- func (s *RetryLayerReactionStore) BulkGetForPosts(postIds []string) ([]*model.Reaction, error)
- func (s *RetryLayerReactionStore) Delete(reaction *model.Reaction) (*model.Reaction, error)
- func (s *RetryLayerReactionStore) DeleteAllWithEmojiName(emojiName string) error
- func (s *RetryLayerReactionStore) DeleteOrphanedRows(limit int) (int64, error)
- func (s *RetryLayerReactionStore) GetForPost(postID string, allowFromCache bool) ([]*model.Reaction, error)
- func (s *RetryLayerReactionStore) GetForPostSince(postId string, since int64, excludeRemoteId string, inclDeleted bool) ([]*model.Reaction, error)
- func (s *RetryLayerReactionStore) PermanentDeleteBatch(endTime int64, limit int64) (int64, error)
- func (s *RetryLayerReactionStore) Save(reaction *model.Reaction) (*model.Reaction, error)
type RetryLayerRemoteClusterStore
- func (s *RetryLayerRemoteClusterStore) Delete(remoteClusterId string) (bool, error)
- func (s *RetryLayerRemoteClusterStore) Get(remoteClusterId string) (*model.RemoteCluster, error)
- func (s *RetryLayerRemoteClusterStore) GetAll(filter model.RemoteClusterQueryFilter) ([]*model.RemoteCluster, error)
- func (s *RetryLayerRemoteClusterStore) Save(rc *model.RemoteCluster) (*model.RemoteCluster, error)
- func (s *RetryLayerRemoteClusterStore) SetLastPingAt(remoteClusterId string) error
- func (s *RetryLayerRemoteClusterStore) Update(rc *model.RemoteCluster) (*model.RemoteCluster, error)
- func (s *RetryLayerRemoteClusterStore) UpdateTopics(remoteClusterId string, topics string) (*model.RemoteCluster, error)
type RetryLayerRetentionPolicyStore
- func (s *RetryLayerRetentionPolicyStore) AddChannels(policyId string, channelIds []string) error
- func (s *RetryLayerRetentionPolicyStore) AddTeams(policyId string, teamIds []string) error
- func (s *RetryLayerRetentionPolicyStore) Delete(id string) error
- func (s *RetryLayerRetentionPolicyStore) DeleteOrphanedRows(limit int) (int64, error)
- func (s *RetryLayerRetentionPolicyStore) Get(id string) (*model.RetentionPolicyWithTeamAndChannelCounts, error)
- func (s *RetryLayerRetentionPolicyStore) GetAll(offset int, limit int) ([]*model.RetentionPolicyWithTeamAndChannelCounts, error)
- func (s *RetryLayerRetentionPolicyStore) GetChannelPoliciesCountForUser(userID string) (int64, error)
- func (s *RetryLayerRetentionPolicyStore) GetChannelPoliciesForUser(userID string, offset int, limit int) ([]*model.RetentionPolicyForChannel, error)
- func (s *RetryLayerRetentionPolicyStore) GetChannels(policyId string, offset int, limit int) (model.ChannelListWithTeamData, error)
- func (s *RetryLayerRetentionPolicyStore) GetChannelsCount(policyId string) (int64, error)
- func (s *RetryLayerRetentionPolicyStore) GetCount() (int64, error)
- func (s *RetryLayerRetentionPolicyStore) GetTeamPoliciesCountForUser(userID string) (int64, error)
- func (s *RetryLayerRetentionPolicyStore) GetTeamPoliciesForUser(userID string, offset int, limit int) ([]*model.RetentionPolicyForTeam, error)
- func (s *RetryLayerRetentionPolicyStore) GetTeams(policyId string, offset int, limit int) ([]*model.Team, error)
- func (s *RetryLayerRetentionPolicyStore) GetTeamsCount(policyId string) (int64, error)
- func (s *RetryLayerRetentionPolicyStore) Patch(patch *model.RetentionPolicyWithTeamAndChannelIDs) (*model.RetentionPolicyWithTeamAndChannelCounts, error)
- func (s *RetryLayerRetentionPolicyStore) RemoveChannels(policyId string, channelIds []string) error
- func (s *RetryLayerRetentionPolicyStore) RemoveTeams(policyId string, teamIds []string) error
- func (s *RetryLayerRetentionPolicyStore) Save(policy *model.RetentionPolicyWithTeamAndChannelIDs) (*model.RetentionPolicyWithTeamAndChannelCounts, error)
type RetryLayerRoleStore
- func (s *RetryLayerRoleStore) AllChannelSchemeRoles() ([]*model.Role, error)
- func (s *RetryLayerRoleStore) ChannelHigherScopedPermissions(roleNames []string) (map[string]*model.RolePermissions, error)
- func (s *RetryLayerRoleStore) ChannelRolesUnderTeamRole(roleName string) ([]*model.Role, error)
- func (s *RetryLayerRoleStore) Delete(roleID string) (*model.Role, error)
- func (s *RetryLayerRoleStore) Get(roleID string) (*model.Role, error)
- func (s *RetryLayerRoleStore) GetAll() ([]*model.Role, error)
- func (s *RetryLayerRoleStore) GetByName(ctx context.Context, name string) (*model.Role, error)
- func (s *RetryLayerRoleStore) GetByNames(names []string) ([]*model.Role, error)
- func (s *RetryLayerRoleStore) PermanentDeleteAll() error
- func (s *RetryLayerRoleStore) Save(role *model.Role) (*model.Role, error)
type RetryLayerSchemeStore
- func (s *RetryLayerSchemeStore) CountByScope(scope string) (int64, error)
- func (s *RetryLayerSchemeStore) CountWithoutPermission(scope string, permissionID string, roleScope model.RoleScope, ...) (int64, error)
- func (s *RetryLayerSchemeStore) Delete(schemeID string) (*model.Scheme, error)
- func (s *RetryLayerSchemeStore) Get(schemeID string) (*model.Scheme, error)
- func (s *RetryLayerSchemeStore) GetAllPage(scope string, offset int, limit int) ([]*model.Scheme, error)
- func (s *RetryLayerSchemeStore) GetByName(schemeName string) (*model.Scheme, error)
- func (s *RetryLayerSchemeStore) PermanentDeleteAll() error
- func (s *RetryLayerSchemeStore) Save(scheme *model.Scheme) (*model.Scheme, error)
type RetryLayerSessionStore
- func (s *RetryLayerSessionStore) AnalyticsSessionCount() (int64, error)
- func (s *RetryLayerSessionStore) Cleanup(expiryTime int64, batchSize int64) error
- func (s *RetryLayerSessionStore) Get(ctx context.Context, sessionIDOrToken string) (*model.Session, error)
- func (s *RetryLayerSessionStore) GetLastSessionRowCreateAt() (int64, error)
- func (s *RetryLayerSessionStore) GetSessions(userID string) ([]*model.Session, error)
- func (s *RetryLayerSessionStore) GetSessionsExpired(thresholdMillis int64, mobileOnly bool, unnotifiedOnly bool) ([]*model.Session, error)
- func (s *RetryLayerSessionStore) GetSessionsWithActiveDeviceIds(userID string) ([]*model.Session, error)
- func (s *RetryLayerSessionStore) PermanentDeleteSessionsByUser(teamID string) error
- func (s *RetryLayerSessionStore) Remove(sessionIDOrToken string) error
- func (s *RetryLayerSessionStore) RemoveAllSessions() error
- func (s *RetryLayerSessionStore) Save(session *model.Session) (*model.Session, error)
- func (s *RetryLayerSessionStore) UpdateDeviceId(id string, deviceID string, expiresAt int64) (string, error)
- func (s *RetryLayerSessionStore) UpdateExpiredNotify(sessionid string, notified bool) error
- func (s *RetryLayerSessionStore) UpdateExpiresAt(sessionID string, time int64) error
- func (s *RetryLayerSessionStore) UpdateLastActivityAt(sessionID string, time int64) error
- func (s *RetryLayerSessionStore) UpdateProps(session *model.Session) error
- func (s *RetryLayerSessionStore) UpdateRoles(userID string, roles string) (string, error)
type RetryLayerSharedChannelStore
- func (s *RetryLayerSharedChannelStore) Delete(channelId string) (bool, error)
- func (s *RetryLayerSharedChannelStore) DeleteRemote(remoteId string) (bool, error)
- func (s *RetryLayerSharedChannelStore) Get(channelId string) (*model.SharedChannel, error)
- func (s *RetryLayerSharedChannelStore) GetAll(offset int, limit int, opts model.SharedChannelFilterOpts) ([]*model.SharedChannel, error)
- func (s *RetryLayerSharedChannelStore) GetAllCount(opts model.SharedChannelFilterOpts) (int64, error)
- func (s *RetryLayerSharedChannelStore) GetAttachment(fileId string, remoteId string) (*model.SharedChannelAttachment, error)
- func (s *RetryLayerSharedChannelStore) GetRemote(id string) (*model.SharedChannelRemote, error)
- func (s *RetryLayerSharedChannelStore) GetRemoteByIds(channelId string, remoteId string) (*model.SharedChannelRemote, error)
- func (s *RetryLayerSharedChannelStore) GetRemoteForUser(remoteId string, userId string) (*model.RemoteCluster, error)
- func (s *RetryLayerSharedChannelStore) GetRemotes(opts model.SharedChannelRemoteFilterOpts) ([]*model.SharedChannelRemote, error)
- func (s *RetryLayerSharedChannelStore) GetRemotesStatus(channelId string) ([]*model.SharedChannelRemoteStatus, error)
- func (s *RetryLayerSharedChannelStore) GetSingleUser(userID string, channelID string, remoteID string) (*model.SharedChannelUser, error)
- func (s *RetryLayerSharedChannelStore) GetUsersForSync(filter model.GetUsersForSyncFilter) ([]*model.User, error)
- func (s *RetryLayerSharedChannelStore) GetUsersForUser(userID string) ([]*model.SharedChannelUser, error)
- func (s *RetryLayerSharedChannelStore) HasChannel(channelID string) (bool, error)
- func (s *RetryLayerSharedChannelStore) HasRemote(channelID string, remoteId string) (bool, error)
- func (s *RetryLayerSharedChannelStore) Save(sc *model.SharedChannel) (*model.SharedChannel, error)
- func (s *RetryLayerSharedChannelStore) SaveAttachment(remote *model.SharedChannelAttachment) (*model.SharedChannelAttachment, error)
- func (s *RetryLayerSharedChannelStore) SaveRemote(remote *model.SharedChannelRemote) (*model.SharedChannelRemote, error)
- func (s *RetryLayerSharedChannelStore) SaveUser(remote *model.SharedChannelUser) (*model.SharedChannelUser, error)
- func (s *RetryLayerSharedChannelStore) Update(sc *model.SharedChannel) (*model.SharedChannel, error)
- func (s *RetryLayerSharedChannelStore) UpdateAttachmentLastSyncAt(id string, syncTime int64) error
- func (s *RetryLayerSharedChannelStore) UpdateRemote(remote *model.SharedChannelRemote) (*model.SharedChannelRemote, error)
- func (s *RetryLayerSharedChannelStore) UpdateRemoteCursor(id string, cursor model.GetPostsSinceForSyncCursor) error
- func (s *RetryLayerSharedChannelStore) UpdateUserLastSyncAt(userID string, channelID string, remoteID string) error
- func (s *RetryLayerSharedChannelStore) UpsertAttachment(remote *model.SharedChannelAttachment) (string, error)
type RetryLayerStatusStore
- func (s *RetryLayerStatusStore) Get(userID string) (*model.Status, error)
- func (s *RetryLayerStatusStore) GetByIds(userIds []string) ([]*model.Status, error)
- func (s *RetryLayerStatusStore) GetTotalActiveUsersCount() (int64, error)
- func (s *RetryLayerStatusStore) ResetAll() error
- func (s *RetryLayerStatusStore) SaveOrUpdate(status *model.Status) error
- func (s *RetryLayerStatusStore) UpdateExpiredDNDStatuses() ([]*model.Status, error)
- func (s *RetryLayerStatusStore) UpdateLastActivityAt(userID string, lastActivityAt int64) error
type RetryLayerSystemStore
- func (s *RetryLayerSystemStore) Get() (model.StringMap, error)
- func (s *RetryLayerSystemStore) GetByName(name string) (*model.System, error)
- func (s *RetryLayerSystemStore) InsertIfExists(system *model.System) (*model.System, error)
- func (s *RetryLayerSystemStore) PermanentDeleteByName(name string) (*model.System, error)
- func (s *RetryLayerSystemStore) Save(system *model.System) error
- func (s *RetryLayerSystemStore) SaveOrUpdate(system *model.System) error
- func (s *RetryLayerSystemStore) SaveOrUpdateWithWarnMetricHandling(system *model.System) error
- func (s *RetryLayerSystemStore) Update(system *model.System) error
type RetryLayerTeamStore
- func (s *RetryLayerTeamStore) AnalyticsGetTeamCountForScheme(schemeID string) (int64, error)
- func (s *RetryLayerTeamStore) AnalyticsTeamCount(opts *model.TeamSearch) (int64, error)
- func (s *RetryLayerTeamStore) ClearAllCustomRoleAssignments() error
- func (s *RetryLayerTeamStore) ClearCaches()
- func (s *RetryLayerTeamStore) Get(id string) (*model.Team, error)
- func (s *RetryLayerTeamStore) GetActiveMemberCount(teamID string, restrictions *model.ViewUsersRestrictions) (int64, error)
- func (s *RetryLayerTeamStore) GetAll() ([]*model.Team, error)
- func (s *RetryLayerTeamStore) GetAllForExportAfter(limit int, afterID string) ([]*model.TeamForExport, error)
- func (s *RetryLayerTeamStore) GetAllPage(offset int, limit int, opts *model.TeamSearch) ([]*model.Team, error)
- func (s *RetryLayerTeamStore) GetAllPrivateTeamListing() ([]*model.Team, error)
- func (s *RetryLayerTeamStore) GetAllTeamListing() ([]*model.Team, error)
- func (s *RetryLayerTeamStore) GetByInviteId(inviteID string) (*model.Team, error)
- func (s *RetryLayerTeamStore) GetByName(name string) (*model.Team, error)
- func (s *RetryLayerTeamStore) GetByNames(name []string) ([]*model.Team, error)
- func (s *RetryLayerTeamStore) GetChannelUnreadsForAllTeams(excludeTeamID string, userID string) ([]*model.ChannelUnread, error)
- func (s *RetryLayerTeamStore) GetChannelUnreadsForTeam(teamID string, userID string) ([]*model.ChannelUnread, error)
- func (s *RetryLayerTeamStore) GetCommonTeamIDsForTwoUsers(userID string, otherUserID string) ([]string, error)
- func (s *RetryLayerTeamStore) GetMember(ctx context.Context, teamID string, userID string) (*model.TeamMember, error)
- func (s *RetryLayerTeamStore) GetMembers(teamID string, offset int, limit int, ...) ([]*model.TeamMember, error)
- func (s *RetryLayerTeamStore) GetMembersByIds(teamID string, userIds []string, restrictions *model.ViewUsersRestrictions) ([]*model.TeamMember, error)
- func (s *RetryLayerTeamStore) GetTeamMembersForExport(userID string) ([]*model.TeamMemberForExport, error)
- func (s *RetryLayerTeamStore) GetTeamsByScheme(schemeID string, offset int, limit int) ([]*model.Team, error)
- func (s *RetryLayerTeamStore) GetTeamsByUserId(userID string) ([]*model.Team, error)
- func (s *RetryLayerTeamStore) GetTeamsForUser(ctx context.Context, userID string) ([]*model.TeamMember, error)
- func (s *RetryLayerTeamStore) GetTeamsForUserWithPagination(userID string, page int, perPage int) ([]*model.TeamMember, error)
- func (s *RetryLayerTeamStore) GetTotalMemberCount(teamID string, restrictions *model.ViewUsersRestrictions) (int64, error)
- func (s *RetryLayerTeamStore) GetUserTeamIds(userID string, allowFromCache bool) ([]string, error)
- func (s *RetryLayerTeamStore) GroupSyncedTeamCount() (int64, error)
- func (s *RetryLayerTeamStore) InvalidateAllTeamIdsForUser(userID string)
- func (s *RetryLayerTeamStore) MigrateTeamMembers(fromTeamID string, fromUserID string) (map[string]string, error)
- func (s *RetryLayerTeamStore) PermanentDelete(teamID string) error
- func (s *RetryLayerTeamStore) RemoveAllMembersByTeam(teamID string) error
- func (s *RetryLayerTeamStore) RemoveAllMembersByUser(userID string) error
- func (s *RetryLayerTeamStore) RemoveMember(teamID string, userID string) error
- func (s *RetryLayerTeamStore) RemoveMembers(teamID string, userIds []string) error
- func (s *RetryLayerTeamStore) ResetAllTeamSchemes() error
- func (s *RetryLayerTeamStore) Save(team *model.Team) (*model.Team, error)
- func (s *RetryLayerTeamStore) SaveMember(member *model.TeamMember, maxUsersPerTeam int) (*model.TeamMember, error)
- func (s *RetryLayerTeamStore) SaveMultipleMembers(members []*model.TeamMember, maxUsersPerTeam int) ([]*model.TeamMember, error)
- func (s *RetryLayerTeamStore) SearchAll(opts *model.TeamSearch) ([]*model.Team, error)
- func (s *RetryLayerTeamStore) SearchAllPaged(opts *model.TeamSearch) ([]*model.Team, int64, error)
- func (s *RetryLayerTeamStore) SearchOpen(opts *model.TeamSearch) ([]*model.Team, error)
- func (s *RetryLayerTeamStore) SearchPrivate(opts *model.TeamSearch) ([]*model.Team, error)
- func (s *RetryLayerTeamStore) Update(team *model.Team) (*model.Team, error)
- func (s *RetryLayerTeamStore) UpdateLastTeamIconUpdate(teamID string, curTime int64) error
- func (s *RetryLayerTeamStore) UpdateMember(member *model.TeamMember) (*model.TeamMember, error)
- func (s *RetryLayerTeamStore) UpdateMembersRole(teamID string, userIDs []string) error
- func (s *RetryLayerTeamStore) UpdateMultipleMembers(members []*model.TeamMember) ([]*model.TeamMember, error)
- func (s *RetryLayerTeamStore) UserBelongsToTeams(userID string, teamIds []string) (bool, error)
type RetryLayerTermsOfServiceStore
- func (s *RetryLayerTermsOfServiceStore) Get(id string, allowFromCache bool) (*model.TermsOfService, error)
- func (s *RetryLayerTermsOfServiceStore) GetLatest(allowFromCache bool) (*model.TermsOfService, error)
- func (s *RetryLayerTermsOfServiceStore) Save(termsOfService *model.TermsOfService) (*model.TermsOfService, error)
type RetryLayerThreadStore
- func (s *RetryLayerThreadStore) DeleteMembershipForUser(userId string, postID string) error
- func (s *RetryLayerThreadStore) DeleteOrphanedRows(limit int) (int64, error)
- func (s *RetryLayerThreadStore) Get(id string) (*model.Thread, error)
- func (s *RetryLayerThreadStore) GetMembershipForUser(userId string, postID string) (*model.ThreadMembership, error)
- func (s *RetryLayerThreadStore) GetMembershipsForUser(userId string, teamID string) ([]*model.ThreadMembership, error)
- func (s *RetryLayerThreadStore) GetPosts(threadID string, since int64) ([]*model.Post, error)
- func (s *RetryLayerThreadStore) GetTeamsUnreadForUser(userID string, teamIDs []string) (map[string]*model.TeamUnread, error)
- func (s *RetryLayerThreadStore) GetThreadFollowers(threadID string, fetchOnlyActive bool) ([]string, error)
- func (s *RetryLayerThreadStore) GetThreadForUser(teamID string, threadMembership *model.ThreadMembership, extended bool) (*model.ThreadResponse, error)
- func (s *RetryLayerThreadStore) GetThreadUnreadReplyCount(threadMembership *model.ThreadMembership) (int64, error)
- func (s *RetryLayerThreadStore) GetThreadsForUser(userId string, teamID string, opts model.GetUserThreadsOpts) (*model.Threads, error)
- func (s *RetryLayerThreadStore) MaintainMembership(userID string, postID string, opts store.ThreadMembershipOpts) (*model.ThreadMembership, error)
- func (s *RetryLayerThreadStore) MarkAllAsRead(userID string, threadIds []string) error
- func (s *RetryLayerThreadStore) MarkAllAsReadByChannels(userID string, channelIDs []string) error
- func (s *RetryLayerThreadStore) MarkAllAsReadByTeam(userID string, teamID string) error
- func (s *RetryLayerThreadStore) MarkAsRead(userID string, threadID string, timestamp int64) error
- func (s *RetryLayerThreadStore) PermanentDeleteBatchForRetentionPolicies(now int64, globalPolicyEndTime int64, limit int64, ...) (int64, model.RetentionPolicyCursor, error)
- func (s *RetryLayerThreadStore) PermanentDeleteBatchThreadMembershipsForRetentionPolicies(now int64, globalPolicyEndTime int64, limit int64, ...) (int64, model.RetentionPolicyCursor, error)
- func (s *RetryLayerThreadStore) UpdateMembership(membership *model.ThreadMembership) (*model.ThreadMembership, error)
type RetryLayerTokenStore
- func (s *RetryLayerTokenStore) Cleanup(expiryTime int64)
- func (s *RetryLayerTokenStore) Delete(token string) error
- func (s *RetryLayerTokenStore) GetAllTokensByType(tokenType string) ([]*model.Token, error)
- func (s *RetryLayerTokenStore) GetByToken(token string) (*model.Token, error)
- func (s *RetryLayerTokenStore) RemoveAllTokensByType(tokenType string) error
- func (s *RetryLayerTokenStore) Save(recovery *model.Token) error
type RetryLayerUploadSessionStore
- func (s *RetryLayerUploadSessionStore) Delete(id string) error
- func (s *RetryLayerUploadSessionStore) Get(id string) (*model.UploadSession, error)
- func (s *RetryLayerUploadSessionStore) GetForUser(userID string) ([]*model.UploadSession, error)
- func (s *RetryLayerUploadSessionStore) Save(session *model.UploadSession) (*model.UploadSession, error)
- func (s *RetryLayerUploadSessionStore) Update(session *model.UploadSession) error
type RetryLayerUserAccessTokenStore
- func (s *RetryLayerUserAccessTokenStore) Delete(tokenID string) error
- func (s *RetryLayerUserAccessTokenStore) DeleteAllForUser(userID string) error
- func (s *RetryLayerUserAccessTokenStore) Get(tokenID string) (*model.UserAccessToken, error)
- func (s *RetryLayerUserAccessTokenStore) GetAll(offset int, limit int) ([]*model.UserAccessToken, error)
- func (s *RetryLayerUserAccessTokenStore) GetByToken(tokenString string) (*model.UserAccessToken, error)
- func (s *RetryLayerUserAccessTokenStore) GetByUser(userID string, page int, perPage int) ([]*model.UserAccessToken, error)
- func (s *RetryLayerUserAccessTokenStore) Save(token *model.UserAccessToken) (*model.UserAccessToken, error)
- func (s *RetryLayerUserAccessTokenStore) Search(term string) ([]*model.UserAccessToken, error)
- func (s *RetryLayerUserAccessTokenStore) UpdateTokenDisable(tokenID string) error
- func (s *RetryLayerUserAccessTokenStore) UpdateTokenEnable(tokenID string) error
type RetryLayerUserStore
- func (s *RetryLayerUserStore) AnalyticsActiveCount(time int64, options model.UserCountOptions) (int64, error)
- func (s *RetryLayerUserStore) AnalyticsActiveCountForPeriod(startTime int64, endTime int64, options model.UserCountOptions) (int64, error)
- func (s *RetryLayerUserStore) AnalyticsGetExternalUsers(hostDomain string) (bool, error)
- func (s *RetryLayerUserStore) AnalyticsGetGuestCount() (int64, error)
- func (s *RetryLayerUserStore) AnalyticsGetInactiveUsersCount() (int64, error)
- func (s *RetryLayerUserStore) AnalyticsGetSystemAdminCount() (int64, error)
- func (s *RetryLayerUserStore) AutocompleteUsersInChannel(teamID string, channelID string, term string, options *model.UserSearchOptions) (*model.UserAutocompleteInChannel, error)
- func (s *RetryLayerUserStore) ClearAllCustomRoleAssignments() error
- func (s *RetryLayerUserStore) ClearCaches()
- func (s *RetryLayerUserStore) Count(options model.UserCountOptions) (int64, error)
- func (s *RetryLayerUserStore) DeactivateGuests() ([]string, error)
- func (s *RetryLayerUserStore) DemoteUserToGuest(userID string) (*model.User, error)
- func (s *RetryLayerUserStore) Get(ctx context.Context, id string) (*model.User, error)
- func (s *RetryLayerUserStore) GetAll() ([]*model.User, error)
- func (s *RetryLayerUserStore) GetAllAfter(limit int, afterID string) ([]*model.User, error)
- func (s *RetryLayerUserStore) GetAllNotInAuthService(authServices []string) ([]*model.User, error)
- func (s *RetryLayerUserStore) GetAllProfiles(options *model.UserGetOptions) ([]*model.User, error)
- func (s *RetryLayerUserStore) GetAllProfilesInChannel(ctx context.Context, channelID string, allowFromCache bool) (map[string]*model.User, error)
- func (s *RetryLayerUserStore) GetAllUsingAuthService(authService string) ([]*model.User, error)
- func (s *RetryLayerUserStore) GetAnyUnreadPostCountForChannel(userID string, channelID string) (int64, error)
- func (s *RetryLayerUserStore) GetByAuth(authData *string, authService string) (*model.User, error)
- func (s *RetryLayerUserStore) GetByEmail(email string) (*model.User, error)
- func (s *RetryLayerUserStore) GetByUsername(username string) (*model.User, error)
- func (s *RetryLayerUserStore) GetChannelGroupUsers(channelID string) ([]*model.User, error)
- func (s *RetryLayerUserStore) GetEtagForAllProfiles() string
- func (s *RetryLayerUserStore) GetEtagForProfiles(teamID string) string
- func (s *RetryLayerUserStore) GetEtagForProfilesNotInTeam(teamID string) string
- func (s *RetryLayerUserStore) GetForLogin(loginID string, allowSignInWithUsername bool, allowSignInWithEmail bool) (*model.User, error)
- func (s *RetryLayerUserStore) GetKnownUsers(userID string) ([]string, error)
- func (s *RetryLayerUserStore) GetMany(ctx context.Context, ids []string) ([]*model.User, error)
- func (s *RetryLayerUserStore) GetNewUsersForTeam(teamID string, offset int, limit int, ...) ([]*model.User, error)
- func (s *RetryLayerUserStore) GetProfileByGroupChannelIdsForUser(userID string, channelIds []string) (map[string][]*model.User, error)
- func (s *RetryLayerUserStore) GetProfileByIds(ctx context.Context, userIds []string, options *store.UserGetByIdsOpts, ...) ([]*model.User, error)
- func (s *RetryLayerUserStore) GetProfiles(options *model.UserGetOptions) ([]*model.User, error)
- func (s *RetryLayerUserStore) GetProfilesByUsernames(usernames []string, viewRestrictions *model.ViewUsersRestrictions) ([]*model.User, error)
- func (s *RetryLayerUserStore) GetProfilesInChannel(options *model.UserGetOptions) ([]*model.User, error)
- func (s *RetryLayerUserStore) GetProfilesInChannelByStatus(options *model.UserGetOptions) ([]*model.User, error)
- func (s *RetryLayerUserStore) GetProfilesNotInChannel(teamID string, channelId string, groupConstrained bool, offset int, limit int, ...) ([]*model.User, error)
- func (s *RetryLayerUserStore) GetProfilesNotInTeam(teamID string, groupConstrained bool, offset int, limit int, ...) ([]*model.User, error)
- func (s *RetryLayerUserStore) GetProfilesWithoutTeam(options *model.UserGetOptions) ([]*model.User, error)
- func (s *RetryLayerUserStore) GetRecentlyActiveUsersForTeam(teamID string, offset int, limit int, ...) ([]*model.User, error)
- func (s *RetryLayerUserStore) GetSystemAdminProfiles() (map[string]*model.User, error)
- func (s *RetryLayerUserStore) GetTeamGroupUsers(teamID string) ([]*model.User, error)
- func (s *RetryLayerUserStore) GetUnreadCount(userID string) (int64, error)
- func (s *RetryLayerUserStore) GetUnreadCountForChannel(userID string, channelID string) (int64, error)
- func (s *RetryLayerUserStore) GetUsersBatchForIndexing(startTime int64, endTime int64, limit int) ([]*model.UserForIndexing, error)
- func (s *RetryLayerUserStore) GetUsersWithInvalidEmails(page int, perPage int, restrictedDomains string) ([]*model.User, error)
- func (s *RetryLayerUserStore) InferSystemInstallDate() (int64, error)
- func (s *RetryLayerUserStore) InsertUsers(users []*model.User) error
- func (s *RetryLayerUserStore) InvalidateProfileCacheForUser(userID string)
- func (s *RetryLayerUserStore) InvalidateProfilesInChannelCache(channelID string)
- func (s *RetryLayerUserStore) InvalidateProfilesInChannelCacheByUser(userID string)
- func (s *RetryLayerUserStore) IsEmpty(excludeBots bool) (bool, error)
- func (s *RetryLayerUserStore) PermanentDelete(userID string) error
- func (s *RetryLayerUserStore) PromoteGuestToUser(userID string) error
- func (s *RetryLayerUserStore) ResetAuthDataToEmailForUsers(service string, userIDs []string, includeDeleted bool, dryRun bool) (int, error)
- func (s *RetryLayerUserStore) ResetLastPictureUpdate(userID string) error
- func (s *RetryLayerUserStore) Save(user *model.User) (*model.User, error)
- func (s *RetryLayerUserStore) Search(teamID string, term string, options *model.UserSearchOptions) ([]*model.User, error)
- func (s *RetryLayerUserStore) SearchInChannel(channelID string, term string, options *model.UserSearchOptions) ([]*model.User, error)
- func (s *RetryLayerUserStore) SearchInGroup(groupID string, term string, options *model.UserSearchOptions) ([]*model.User, error)
- func (s *RetryLayerUserStore) SearchNotInChannel(teamID string, channelID string, term string, options *model.UserSearchOptions) ([]*model.User, error)
- func (s *RetryLayerUserStore) SearchNotInGroup(groupID string, term string, options *model.UserSearchOptions) ([]*model.User, error)
- func (s *RetryLayerUserStore) SearchNotInTeam(notInTeamID string, term string, options *model.UserSearchOptions) ([]*model.User, error)
- func (s *RetryLayerUserStore) SearchWithoutTeam(term string, options *model.UserSearchOptions) ([]*model.User, error)
- func (s *RetryLayerUserStore) Update(user *model.User, allowRoleUpdate bool) (*model.UserUpdate, error)
- func (s *RetryLayerUserStore) UpdateAuthData(userID string, service string, authData *string, email string, resetMfa bool) (string, error)
- func (s *RetryLayerUserStore) UpdateFailedPasswordAttempts(userID string, attempts int) error
- func (s *RetryLayerUserStore) UpdateLastPictureUpdate(userID string) error
- func (s *RetryLayerUserStore) UpdateMfaActive(userID string, active bool) error
- func (s *RetryLayerUserStore) UpdateMfaSecret(userID string, secret string) error
- func (s *RetryLayerUserStore) UpdateNotifyProps(userID string, props map[string]string) error
- func (s *RetryLayerUserStore) UpdatePassword(userID string, newPassword string) error
- func (s *RetryLayerUserStore) UpdateUpdateAt(userID string) (int64, error)
- func (s *RetryLayerUserStore) VerifyEmail(userID string, email string) (string, error)
type RetryLayerUserTermsOfServiceStore
- func (s *RetryLayerUserTermsOfServiceStore) Delete(userID string, termsOfServiceId string) error
- func (s *RetryLayerUserTermsOfServiceStore) GetByUser(userID string) (*model.UserTermsOfService, error)
- func (s *RetryLayerUserTermsOfServiceStore) Save(userTermsOfService *model.UserTermsOfService) (*model.UserTermsOfService, error)
type RetryLayerWebhookStore
- func (s *RetryLayerWebhookStore) AnalyticsIncomingCount(teamID string) (int64, error)
- func (s *RetryLayerWebhookStore) AnalyticsOutgoingCount(teamID string) (int64, error)
- func (s *RetryLayerWebhookStore) ClearCaches()
- func (s *RetryLayerWebhookStore) DeleteIncoming(webhookID string, time int64) error
- func (s *RetryLayerWebhookStore) DeleteOutgoing(webhookID string, time int64) error
- func (s *RetryLayerWebhookStore) GetIncoming(id string, allowFromCache bool) (*model.IncomingWebhook, error)
- func (s *RetryLayerWebhookStore) GetIncomingByChannel(channelID string) ([]*model.IncomingWebhook, error)
- func (s *RetryLayerWebhookStore) GetIncomingByTeam(teamID string, offset int, limit int) ([]*model.IncomingWebhook, error)
- func (s *RetryLayerWebhookStore) GetIncomingByTeamByUser(teamID string, userID string, offset int, limit int) ([]*model.IncomingWebhook, error)
- func (s *RetryLayerWebhookStore) GetIncomingList(offset int, limit int) ([]*model.IncomingWebhook, error)
- func (s *RetryLayerWebhookStore) GetIncomingListByUser(userID string, offset int, limit int) ([]*model.IncomingWebhook, error)
- func (s *RetryLayerWebhookStore) GetOutgoing(id string) (*model.OutgoingWebhook, error)
- func (s *RetryLayerWebhookStore) GetOutgoingByChannel(channelID string, offset int, limit int) ([]*model.OutgoingWebhook, error)
- func (s *RetryLayerWebhookStore) GetOutgoingByChannelByUser(channelID string, userID string, offset int, limit int) ([]*model.OutgoingWebhook, error)
- func (s *RetryLayerWebhookStore) GetOutgoingByTeam(teamID string, offset int, limit int) ([]*model.OutgoingWebhook, error)
- func (s *RetryLayerWebhookStore) GetOutgoingByTeamByUser(teamID string, userID string, offset int, limit int) ([]*model.OutgoingWebhook, error)
- func (s *RetryLayerWebhookStore) GetOutgoingList(offset int, limit int) ([]*model.OutgoingWebhook, error)
- func (s *RetryLayerWebhookStore) GetOutgoingListByUser(userID string, offset int, limit int) ([]*model.OutgoingWebhook, error)
- func (s *RetryLayerWebhookStore) InvalidateWebhookCache(webhook string)
- func (s *RetryLayerWebhookStore) PermanentDeleteIncomingByChannel(channelID string) error
- func (s *RetryLayerWebhookStore) PermanentDeleteIncomingByUser(userID string) error
- func (s *RetryLayerWebhookStore) PermanentDeleteOutgoingByChannel(channelID string) error
- func (s *RetryLayerWebhookStore) PermanentDeleteOutgoingByUser(userID string) error
- func (s *RetryLayerWebhookStore) SaveIncoming(webhook *model.IncomingWebhook) (*model.IncomingWebhook, error)
- func (s *RetryLayerWebhookStore) SaveOutgoing(webhook *model.OutgoingWebhook) (*model.OutgoingWebhook, error)
- func (s *RetryLayerWebhookStore) UpdateIncoming(webhook *model.IncomingWebhook) (*model.IncomingWebhook, error)
- func (s *RetryLayerWebhookStore) UpdateOutgoing(hook *model.OutgoingWebhook) (*model.OutgoingWebhook, error)

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type RetryLayer ¶

type RetryLayer struct {
	store.Store
	AuditStore                store.AuditStore
	BotStore                  store.BotStore
	ChannelStore              store.ChannelStore
	ChannelMemberHistoryStore store.ChannelMemberHistoryStore
	ClusterDiscoveryStore     store.ClusterDiscoveryStore
	CommandStore              store.CommandStore
	CommandWebhookStore       store.CommandWebhookStore
	ComplianceStore           store.ComplianceStore
	EmojiStore                store.EmojiStore
	FileInfoStore             store.FileInfoStore
	GroupStore                store.GroupStore
	JobStore                  store.JobStore
	LicenseStore              store.LicenseStore
	LinkMetadataStore         store.LinkMetadataStore
	OAuthStore                store.OAuthStore
	PluginStore               store.PluginStore
	PostStore                 store.PostStore
	PreferenceStore           store.PreferenceStore
	ProductNoticesStore       store.ProductNoticesStore
	ReactionStore             store.ReactionStore
	RemoteClusterStore        store.RemoteClusterStore
	RetentionPolicyStore      store.RetentionPolicyStore
	RoleStore                 store.RoleStore
	SchemeStore               store.SchemeStore
	SessionStore              store.SessionStore
	SharedChannelStore        store.SharedChannelStore
	StatusStore               store.StatusStore
	SystemStore               store.SystemStore
	TeamStore                 store.TeamStore
	TermsOfServiceStore       store.TermsOfServiceStore
	ThreadStore               store.ThreadStore
	TokenStore                store.TokenStore
	UploadSessionStore        store.UploadSessionStore
	UserStore                 store.UserStore
	UserAccessTokenStore      store.UserAccessTokenStore
	UserTermsOfServiceStore   store.UserTermsOfServiceStore
	WebhookStore              store.WebhookStore
}

func New ¶

func New(childStore store.Store) *RetryLayer

func (*RetryLayer) Audit ¶

func (s *RetryLayer) Audit() store.AuditStore

func (*RetryLayer) Bot ¶

func (s *RetryLayer) Bot() store.BotStore

func (*RetryLayer) Channel ¶

func (s *RetryLayer) Channel() store.ChannelStore

func (*RetryLayer) ChannelMemberHistory ¶

func (s *RetryLayer) ChannelMemberHistory() store.ChannelMemberHistoryStore

func (*RetryLayer) Close ¶

func (s *RetryLayer) Close()

func (*RetryLayer) ClusterDiscovery ¶

func (s *RetryLayer) ClusterDiscovery() store.ClusterDiscoveryStore

func (*RetryLayer) Command ¶

func (s *RetryLayer) Command() store.CommandStore

func (*RetryLayer) CommandWebhook ¶

func (s *RetryLayer) CommandWebhook() store.CommandWebhookStore

func (*RetryLayer) Compliance ¶

func (s *RetryLayer) Compliance() store.ComplianceStore

func (*RetryLayer) DropAllTables ¶

func (s *RetryLayer) DropAllTables()

func (*RetryLayer) Emoji ¶

func (s *RetryLayer) Emoji() store.EmojiStore

func (*RetryLayer) FileInfo ¶

func (s *RetryLayer) FileInfo() store.FileInfoStore

func (*RetryLayer) GetCurrentSchemaVersion ¶

func (s *RetryLayer) GetCurrentSchemaVersion() string

func (*RetryLayer) Group ¶

func (s *RetryLayer) Group() store.GroupStore

func (*RetryLayer) Job ¶

func (s *RetryLayer) Job() store.JobStore

func (*RetryLayer) License ¶

func (s *RetryLayer) License() store.LicenseStore

func (*RetryLayer) LinkMetadata ¶

func (s *RetryLayer) LinkMetadata() store.LinkMetadataStore

func (*RetryLayer) LockToMaster ¶

func (s *RetryLayer) LockToMaster()

func (*RetryLayer) MarkSystemRanUnitTests ¶

func (s *RetryLayer) MarkSystemRanUnitTests()

func (*RetryLayer) OAuth ¶

func (s *RetryLayer) OAuth() store.OAuthStore

func (*RetryLayer) Plugin ¶

func (s *RetryLayer) Plugin() store.PluginStore

func (*RetryLayer) Post ¶

func (s *RetryLayer) Post() store.PostStore

func (*RetryLayer) Preference ¶

func (s *RetryLayer) Preference() store.PreferenceStore

func (*RetryLayer) ProductNotices ¶

func (s *RetryLayer) ProductNotices() store.ProductNoticesStore

func (*RetryLayer) Reaction ¶

func (s *RetryLayer) Reaction() store.ReactionStore

func (*RetryLayer) RemoteCluster ¶

func (s *RetryLayer) RemoteCluster() store.RemoteClusterStore

func (*RetryLayer) RetentionPolicy ¶

func (s *RetryLayer) RetentionPolicy() store.RetentionPolicyStore

func (*RetryLayer) Role ¶

func (s *RetryLayer) Role() store.RoleStore

func (*RetryLayer) Scheme ¶

func (s *RetryLayer) Scheme() store.SchemeStore

func (*RetryLayer) Session ¶

func (s *RetryLayer) Session() store.SessionStore

func (*RetryLayer) SetContext ¶

func (s *RetryLayer) SetContext(context context.Context)

func (*RetryLayer) SharedChannel ¶

func (s *RetryLayer) SharedChannel() store.SharedChannelStore

func (*RetryLayer) Status ¶

func (s *RetryLayer) Status() store.StatusStore

func (*RetryLayer) System ¶

func (s *RetryLayer) System() store.SystemStore

func (*RetryLayer) Team ¶

func (s *RetryLayer) Team() store.TeamStore

func (*RetryLayer) TermsOfService ¶

func (s *RetryLayer) TermsOfService() store.TermsOfServiceStore

func (*RetryLayer) Thread ¶

func (s *RetryLayer) Thread() store.ThreadStore

func (*RetryLayer) Token ¶

func (s *RetryLayer) Token() store.TokenStore

func (*RetryLayer) TotalMasterDbConnections ¶

func (s *RetryLayer) TotalMasterDbConnections() int

func (*RetryLayer) TotalReadDbConnections ¶

func (s *RetryLayer) TotalReadDbConnections() int

func (*RetryLayer) TotalSearchDbConnections ¶

func (s *RetryLayer) TotalSearchDbConnections() int

func (*RetryLayer) UnlockFromMaster ¶

func (s *RetryLayer) UnlockFromMaster()

func (*RetryLayer) UploadSession ¶

func (s *RetryLayer) UploadSession() store.UploadSessionStore

func (*RetryLayer) User ¶

func (s *RetryLayer) User() store.UserStore

func (*RetryLayer) UserAccessToken ¶

func (s *RetryLayer) UserAccessToken() store.UserAccessTokenStore

func (*RetryLayer) UserTermsOfService ¶

func (s *RetryLayer) UserTermsOfService() store.UserTermsOfServiceStore

func (*RetryLayer) Webhook ¶

func (s *RetryLayer) Webhook() store.WebhookStore

type RetryLayerAuditStore ¶

type RetryLayerAuditStore struct {
	store.AuditStore
	Root *RetryLayer
}

func (*RetryLayerAuditStore) Get ¶

func (s *RetryLayerAuditStore) Get(user_id string, offset int, limit int) (model.Audits, error)

func (*RetryLayerAuditStore) PermanentDeleteByUser ¶

func (s *RetryLayerAuditStore) PermanentDeleteByUser(userID string) error

func (*RetryLayerAuditStore) Save ¶

func (s *RetryLayerAuditStore) Save(audit *model.Audit) error

type RetryLayerBotStore ¶

type RetryLayerBotStore struct {
	store.BotStore
	Root *RetryLayer
}

func (*RetryLayerBotStore) Get ¶

func (s *RetryLayerBotStore) Get(userID string, includeDeleted bool) (*model.Bot, error)

func (*RetryLayerBotStore) GetAll ¶

func (s *RetryLayerBotStore) GetAll(options *model.BotGetOptions) ([]*model.Bot, error)

func (*RetryLayerBotStore) PermanentDelete ¶

func (s *RetryLayerBotStore) PermanentDelete(userID string) error

func (*RetryLayerBotStore) Save ¶

func (s *RetryLayerBotStore) Save(bot *model.Bot) (*model.Bot, error)

func (*RetryLayerBotStore) Update ¶

func (s *RetryLayerBotStore) Update(bot *model.Bot) (*model.Bot, error)

type RetryLayerChannelMemberHistoryStore ¶

type RetryLayerChannelMemberHistoryStore struct {
	store.ChannelMemberHistoryStore
	Root *RetryLayer
}

func (*RetryLayerChannelMemberHistoryStore) DeleteOrphanedRows ¶

func (s *RetryLayerChannelMemberHistoryStore) DeleteOrphanedRows(limit int) (int64, error)

func (*RetryLayerChannelMemberHistoryStore) GetChannelsLeftSince ¶ added in v6.5.0

func (s *RetryLayerChannelMemberHistoryStore) GetChannelsLeftSince(userID string, since int64) ([]string, error)

func (*RetryLayerChannelMemberHistoryStore) GetUsersInChannelDuring ¶

func (s *RetryLayerChannelMemberHistoryStore) GetUsersInChannelDuring(startTime int64, endTime int64, channelID string) ([]*model.ChannelMemberHistoryResult, error)

func (*RetryLayerChannelMemberHistoryStore) LogJoinEvent ¶

func (s *RetryLayerChannelMemberHistoryStore) LogJoinEvent(userID string, channelID string, joinTime int64) error

func (*RetryLayerChannelMemberHistoryStore) LogLeaveEvent ¶

func (s *RetryLayerChannelMemberHistoryStore) LogLeaveEvent(userID string, channelID string, leaveTime int64) error

func (*RetryLayerChannelMemberHistoryStore) PermanentDeleteBatch ¶

func (s *RetryLayerChannelMemberHistoryStore) PermanentDeleteBatch(endTime int64, limit int64) (int64, error)

func (*RetryLayerChannelMemberHistoryStore) PermanentDeleteBatchForRetentionPolicies ¶

func (s *RetryLayerChannelMemberHistoryStore) PermanentDeleteBatchForRetentionPolicies(now int64, globalPolicyEndTime int64, limit int64, cursor model.RetentionPolicyCursor) (int64, model.RetentionPolicyCursor, error)

type RetryLayerChannelStore ¶

type RetryLayerChannelStore struct {
	store.ChannelStore
	Root *RetryLayer
}

func (*RetryLayerChannelStore) AnalyticsDeletedTypeCount ¶

func (s *RetryLayerChannelStore) AnalyticsDeletedTypeCount(teamID string, channelType model.ChannelType) (int64, error)

func (*RetryLayerChannelStore) AnalyticsTypeCount ¶

func (s *RetryLayerChannelStore) AnalyticsTypeCount(teamID string, channelType model.ChannelType) (int64, error)

func (*RetryLayerChannelStore) Autocomplete ¶ added in v6.2.0

func (s *RetryLayerChannelStore) Autocomplete(userID string, term string, includeDeleted bool) (model.ChannelListWithTeamData, error)

func (*RetryLayerChannelStore) AutocompleteInTeam ¶

func (s *RetryLayerChannelStore) AutocompleteInTeam(teamID string, userID string, term string, includeDeleted bool) (model.ChannelList, error)

func (*RetryLayerChannelStore) AutocompleteInTeamForSearch ¶

func (s *RetryLayerChannelStore) AutocompleteInTeamForSearch(teamID string, userID string, term string, includeDeleted bool) (model.ChannelList, error)

func (*RetryLayerChannelStore) ClearAllCustomRoleAssignments ¶

func (s *RetryLayerChannelStore) ClearAllCustomRoleAssignments() error

func (*RetryLayerChannelStore) ClearCaches ¶

func (s *RetryLayerChannelStore) ClearCaches()

func (*RetryLayerChannelStore) ClearSidebarOnTeamLeave ¶

func (s *RetryLayerChannelStore) ClearSidebarOnTeamLeave(userID string, teamID string) error

func (*RetryLayerChannelStore) CountPostsAfter ¶

func (s *RetryLayerChannelStore) CountPostsAfter(channelID string, timestamp int64, userID string) (int, int, error)

func (*RetryLayerChannelStore) CreateDirectChannel ¶

func (s *RetryLayerChannelStore) CreateDirectChannel(userID *model.User, otherUserID *model.User, channelOptions ...model.ChannelOption) (*model.Channel, error)

func (*RetryLayerChannelStore) CreateInitialSidebarCategories ¶

func (s *RetryLayerChannelStore) CreateInitialSidebarCategories(userID string, teamID string) (*model.OrderedSidebarCategories, error)

func (*RetryLayerChannelStore) CreateSidebarCategory ¶

func (s *RetryLayerChannelStore) CreateSidebarCategory(userID string, teamID string, newCategory *model.SidebarCategoryWithChannels) (*model.SidebarCategoryWithChannels, error)

func (*RetryLayerChannelStore) Delete ¶

func (s *RetryLayerChannelStore) Delete(channelID string, time int64) error

func (*RetryLayerChannelStore) DeleteSidebarCategory ¶

func (s *RetryLayerChannelStore) DeleteSidebarCategory(categoryID string) error

func (*RetryLayerChannelStore) DeleteSidebarChannelsByPreferences ¶

func (s *RetryLayerChannelStore) DeleteSidebarChannelsByPreferences(preferences model.Preferences) error

func (*RetryLayerChannelStore) Get ¶

func (s *RetryLayerChannelStore) Get(id string, allowFromCache bool) (*model.Channel, error)

func (*RetryLayerChannelStore) GetAll ¶

func (s *RetryLayerChannelStore) GetAll(teamID string) ([]*model.Channel, error)

func (*RetryLayerChannelStore) GetAllChannelMembersById ¶ added in v6.2.0

func (s *RetryLayerChannelStore) GetAllChannelMembersById(id string) ([]string, error)

func (*RetryLayerChannelStore) GetAllChannelMembersForUser ¶

func (s *RetryLayerChannelStore) GetAllChannelMembersForUser(userID string, allowFromCache bool, includeDeleted bool) (map[string]string, error)

func (*RetryLayerChannelStore) GetAllChannelMembersNotifyPropsForChannel ¶

func (s *RetryLayerChannelStore) GetAllChannelMembersNotifyPropsForChannel(channelID string, allowFromCache bool) (map[string]model.StringMap, error)

func (*RetryLayerChannelStore) GetAllChannels ¶

func (s *RetryLayerChannelStore) GetAllChannels(page int, perPage int, opts store.ChannelSearchOpts) (model.ChannelListWithTeamData, error)

func (*RetryLayerChannelStore) GetAllChannelsCount ¶

func (s *RetryLayerChannelStore) GetAllChannelsCount(opts store.ChannelSearchOpts) (int64, error)

func (*RetryLayerChannelStore) GetAllChannelsForExportAfter ¶

func (s *RetryLayerChannelStore) GetAllChannelsForExportAfter(limit int, afterID string) ([]*model.ChannelForExport, error)

func (*RetryLayerChannelStore) GetAllDirectChannelsForExportAfter ¶

func (s *RetryLayerChannelStore) GetAllDirectChannelsForExportAfter(limit int, afterID string) ([]*model.DirectChannelForExport, error)

func (*RetryLayerChannelStore) GetByName ¶

func (s *RetryLayerChannelStore) GetByName(team_id string, name string, allowFromCache bool) (*model.Channel, error)

func (*RetryLayerChannelStore) GetByNameIncludeDeleted ¶

func (s *RetryLayerChannelStore) GetByNameIncludeDeleted(team_id string, name string, allowFromCache bool) (*model.Channel, error)

func (*RetryLayerChannelStore) GetByNames ¶

func (s *RetryLayerChannelStore) GetByNames(team_id string, names []string, allowFromCache bool) ([]*model.Channel, error)

func (*RetryLayerChannelStore) GetChannelCounts ¶

func (s *RetryLayerChannelStore) GetChannelCounts(teamID string, userID string) (*model.ChannelCounts, error)

func (*RetryLayerChannelStore) GetChannelMembersForExport ¶

func (s *RetryLayerChannelStore) GetChannelMembersForExport(userID string, teamID string) ([]*model.ChannelMemberForExport, error)

func (*RetryLayerChannelStore) GetChannelMembersTimezones ¶

func (s *RetryLayerChannelStore) GetChannelMembersTimezones(channelID string) ([]model.StringMap, error)

func (*RetryLayerChannelStore) GetChannelUnread ¶

func (s *RetryLayerChannelStore) GetChannelUnread(channelID string, userID string) (*model.ChannelUnread, error)

func (*RetryLayerChannelStore) GetChannels ¶

func (s *RetryLayerChannelStore) GetChannels(teamID string, userID string, opts *model.ChannelSearchOpts) (model.ChannelList, error)

func (*RetryLayerChannelStore) GetChannelsBatchForIndexing ¶

func (s *RetryLayerChannelStore) GetChannelsBatchForIndexing(startTime int64, endTime int64, limit int) ([]*model.Channel, error)

func (*RetryLayerChannelStore) GetChannelsByIds ¶

func (s *RetryLayerChannelStore) GetChannelsByIds(channelIds []string, includeDeleted bool) ([]*model.Channel, error)

func (*RetryLayerChannelStore) GetChannelsByScheme ¶

func (s *RetryLayerChannelStore) GetChannelsByScheme(schemeID string, offset int, limit int) (model.ChannelList, error)

func (*RetryLayerChannelStore) GetChannelsByUser ¶ added in v6.2.0

func (s *RetryLayerChannelStore) GetChannelsByUser(userID string, includeDeleted bool, lastDeleteAt int, pageSize int, fromChannelID string) (model.ChannelList, error)

func (*RetryLayerChannelStore) GetChannelsWithCursor ¶ added in v6.5.0

func (s *RetryLayerChannelStore) GetChannelsWithCursor(teamId string, userId string, opts *model.ChannelSearchOpts, afterChannelID string) (model.ChannelList, error)

func (*RetryLayerChannelStore) GetChannelsWithTeamDataByIds ¶ added in v6.2.0

func (s *RetryLayerChannelStore) GetChannelsWithTeamDataByIds(channelIds []string, includeDeleted bool) ([]*model.ChannelWithTeamData, error)

func (*RetryLayerChannelStore) GetDeleted ¶

func (s *RetryLayerChannelStore) GetDeleted(team_id string, offset int, limit int, userID string) (model.ChannelList, error)

func (*RetryLayerChannelStore) GetDeletedByName ¶

func (s *RetryLayerChannelStore) GetDeletedByName(team_id string, name string) (*model.Channel, error)

func (*RetryLayerChannelStore) GetForPost ¶

func (s *RetryLayerChannelStore) GetForPost(postID string) (*model.Channel, error)

func (*RetryLayerChannelStore) GetFromMaster ¶

func (s *RetryLayerChannelStore) GetFromMaster(id string) (*model.Channel, error)

func (*RetryLayerChannelStore) GetGuestCount ¶

func (s *RetryLayerChannelStore) GetGuestCount(channelID string, allowFromCache bool) (int64, error)

func (*RetryLayerChannelStore) GetMember ¶

func (s *RetryLayerChannelStore) GetMember(ctx context.Context, channelID string, userID string) (*model.ChannelMember, error)

func (*RetryLayerChannelStore) GetMemberCount ¶

func (s *RetryLayerChannelStore) GetMemberCount(channelID string, allowFromCache bool) (int64, error)

func (*RetryLayerChannelStore) GetMemberCountFromCache ¶

func (s *RetryLayerChannelStore) GetMemberCountFromCache(channelID string) int64

func (*RetryLayerChannelStore) GetMemberCountsByGroup ¶

func (s *RetryLayerChannelStore) GetMemberCountsByGroup(ctx context.Context, channelID string, includeTimezones bool) ([]*model.ChannelMemberCountByGroup, error)

func (*RetryLayerChannelStore) GetMemberForPost ¶

func (s *RetryLayerChannelStore) GetMemberForPost(postID string, userID string) (*model.ChannelMember, error)

func (*RetryLayerChannelStore) GetMembers ¶

func (s *RetryLayerChannelStore) GetMembers(channelID string, offset int, limit int) (model.ChannelMembers, error)

func (*RetryLayerChannelStore) GetMembersByChannelIds ¶

func (s *RetryLayerChannelStore) GetMembersByChannelIds(channelIds []string, userID string) (model.ChannelMembers, error)

func (*RetryLayerChannelStore) GetMembersByIds ¶

func (s *RetryLayerChannelStore) GetMembersByIds(channelID string, userIds []string) (model.ChannelMembers, error)

func (*RetryLayerChannelStore) GetMembersForUser ¶

func (s *RetryLayerChannelStore) GetMembersForUser(teamID string, userID string) (model.ChannelMembers, error)

func (*RetryLayerChannelStore) GetMembersForUserWithCursor ¶ added in v6.5.0

func (s *RetryLayerChannelStore) GetMembersForUserWithCursor(userID string, afterChannel string, afterUser string, limit int, lastUpdateAt int) (model.ChannelMembers, error)

func (*RetryLayerChannelStore) GetMembersForUserWithPagination ¶

func (s *RetryLayerChannelStore) GetMembersForUserWithPagination(userID string, page int, perPage int) (model.ChannelMembersWithTeamData, error)

func (*RetryLayerChannelStore) GetMembersInfoByChannelIds ¶ added in v6.5.0

func (s *RetryLayerChannelStore) GetMembersInfoByChannelIds(channelIDs []string) (map[string][]*model.User, error)

func (*RetryLayerChannelStore) GetMoreChannels ¶

func (s *RetryLayerChannelStore) GetMoreChannels(teamID string, userID string, offset int, limit int) (model.ChannelList, error)

func (*RetryLayerChannelStore) GetPinnedPostCount ¶

func (s *RetryLayerChannelStore) GetPinnedPostCount(channelID string, allowFromCache bool) (int64, error)

func (*RetryLayerChannelStore) GetPinnedPosts ¶

func (s *RetryLayerChannelStore) GetPinnedPosts(channelID string) (*model.PostList, error)

func (*RetryLayerChannelStore) GetPrivateChannelsForTeam ¶

func (s *RetryLayerChannelStore) GetPrivateChannelsForTeam(teamID string, offset int, limit int) (model.ChannelList, error)

func (*RetryLayerChannelStore) GetPublicChannelsByIdsForTeam ¶

func (s *RetryLayerChannelStore) GetPublicChannelsByIdsForTeam(teamID string, channelIds []string) (model.ChannelList, error)

func (*RetryLayerChannelStore) GetPublicChannelsForTeam ¶

func (s *RetryLayerChannelStore) GetPublicChannelsForTeam(teamID string, offset int, limit int) (model.ChannelList, error)

func (*RetryLayerChannelStore) GetSidebarCategories ¶

func (s *RetryLayerChannelStore) GetSidebarCategories(userID string, teamID string) (*model.OrderedSidebarCategories, error)

func (*RetryLayerChannelStore) GetSidebarCategory ¶

func (s *RetryLayerChannelStore) GetSidebarCategory(categoryID string) (*model.SidebarCategoryWithChannels, error)

func (*RetryLayerChannelStore) GetSidebarCategoryOrder ¶

func (s *RetryLayerChannelStore) GetSidebarCategoryOrder(userID string, teamID string) ([]string, error)

func (*RetryLayerChannelStore) GetTeamChannels ¶

func (s *RetryLayerChannelStore) GetTeamChannels(teamID string) (model.ChannelList, error)

func (*RetryLayerChannelStore) GetTeamForChannel ¶

func (s *RetryLayerChannelStore) GetTeamForChannel(channelID string) (*model.Team, error)

func (*RetryLayerChannelStore) GetTeamMembersForChannel ¶ added in v6.2.0

func (s *RetryLayerChannelStore) GetTeamMembersForChannel(channelID string) ([]string, error)

func (*RetryLayerChannelStore) GroupSyncedChannelCount ¶

func (s *RetryLayerChannelStore) GroupSyncedChannelCount() (int64, error)

func (*RetryLayerChannelStore) IncrementMentionCount ¶

func (s *RetryLayerChannelStore) IncrementMentionCount(channelID string, userID string, isRoot bool) error

func (*RetryLayerChannelStore) InvalidateAllChannelMembersForUser ¶

func (s *RetryLayerChannelStore) InvalidateAllChannelMembersForUser(userID string)

func (*RetryLayerChannelStore) InvalidateCacheForChannelMembersNotifyProps ¶

func (s *RetryLayerChannelStore) InvalidateCacheForChannelMembersNotifyProps(channelID string)

func (*RetryLayerChannelStore) InvalidateChannel ¶

func (s *RetryLayerChannelStore) InvalidateChannel(id string)

func (*RetryLayerChannelStore) InvalidateChannelByName ¶

func (s *RetryLayerChannelStore) InvalidateChannelByName(teamID string, name string)

func (*RetryLayerChannelStore) InvalidateGuestCount ¶

func (s *RetryLayerChannelStore) InvalidateGuestCount(channelID string)

func (*RetryLayerChannelStore) InvalidateMemberCount ¶

func (s *RetryLayerChannelStore) InvalidateMemberCount(channelID string)

func (*RetryLayerChannelStore) InvalidatePinnedPostCount ¶

func (s *RetryLayerChannelStore) InvalidatePinnedPostCount(channelID string)

func (*RetryLayerChannelStore) IsUserInChannelUseCache ¶

func (s *RetryLayerChannelStore) IsUserInChannelUseCache(userID string, channelID string) bool

func (*RetryLayerChannelStore) MigrateChannelMembers ¶

func (s *RetryLayerChannelStore) MigrateChannelMembers(fromChannelID string, fromUserID string) (map[string]string, error)

func (*RetryLayerChannelStore) PermanentDelete ¶

func (s *RetryLayerChannelStore) PermanentDelete(channelID string) error

func (*RetryLayerChannelStore) PermanentDeleteByTeam ¶

func (s *RetryLayerChannelStore) PermanentDeleteByTeam(teamID string) error

func (*RetryLayerChannelStore) PermanentDeleteMembersByChannel ¶

func (s *RetryLayerChannelStore) PermanentDeleteMembersByChannel(channelID string) error

func (*RetryLayerChannelStore) PermanentDeleteMembersByUser ¶

func (s *RetryLayerChannelStore) PermanentDeleteMembersByUser(userID string) error

func (*RetryLayerChannelStore) RemoveAllDeactivatedMembers ¶

func (s *RetryLayerChannelStore) RemoveAllDeactivatedMembers(channelID string) error

func (*RetryLayerChannelStore) RemoveMember ¶

func (s *RetryLayerChannelStore) RemoveMember(channelID string, userID string) error

func (*RetryLayerChannelStore) RemoveMembers ¶

func (s *RetryLayerChannelStore) RemoveMembers(channelID string, userIds []string) error

func (*RetryLayerChannelStore) ResetAllChannelSchemes ¶

func (s *RetryLayerChannelStore) ResetAllChannelSchemes() error

func (*RetryLayerChannelStore) Restore ¶

func (s *RetryLayerChannelStore) Restore(channelID string, time int64) error

func (*RetryLayerChannelStore) Save ¶

func (s *RetryLayerChannelStore) Save(channel *model.Channel, maxChannelsPerTeam int64) (*model.Channel, error)

func (*RetryLayerChannelStore) SaveDirectChannel ¶

func (s *RetryLayerChannelStore) SaveDirectChannel(channel *model.Channel, member1 *model.ChannelMember, member2 *model.ChannelMember) (*model.Channel, error)

func (*RetryLayerChannelStore) SaveMember ¶

func (s *RetryLayerChannelStore) SaveMember(member *model.ChannelMember) (*model.ChannelMember, error)

func (*RetryLayerChannelStore) SaveMultipleMembers ¶

func (s *RetryLayerChannelStore) SaveMultipleMembers(members []*model.ChannelMember) ([]*model.ChannelMember, error)

func (*RetryLayerChannelStore) SearchAllChannels ¶

func (s *RetryLayerChannelStore) SearchAllChannels(term string, opts store.ChannelSearchOpts) (model.ChannelListWithTeamData, int64, error)

func (*RetryLayerChannelStore) SearchArchivedInTeam ¶

func (s *RetryLayerChannelStore) SearchArchivedInTeam(teamID string, term string, userID string) (model.ChannelList, error)

func (*RetryLayerChannelStore) SearchForUserInTeam ¶

func (s *RetryLayerChannelStore) SearchForUserInTeam(userID string, teamID string, term string, includeDeleted bool) (model.ChannelList, error)

func (*RetryLayerChannelStore) SearchGroupChannels ¶

func (s *RetryLayerChannelStore) SearchGroupChannels(userID string, term string) (model.ChannelList, error)

func (*RetryLayerChannelStore) SearchInTeam ¶

func (s *RetryLayerChannelStore) SearchInTeam(teamID string, term string, includeDeleted bool) (model.ChannelList, error)

func (*RetryLayerChannelStore) SearchMore ¶

func (s *RetryLayerChannelStore) SearchMore(userID string, teamID string, term string) (model.ChannelList, error)

func (*RetryLayerChannelStore) SetDeleteAt ¶

func (s *RetryLayerChannelStore) SetDeleteAt(channelID string, deleteAt int64, updateAt int64) error

func (*RetryLayerChannelStore) SetShared ¶

func (s *RetryLayerChannelStore) SetShared(channelId string, shared bool) error

func (*RetryLayerChannelStore) Update ¶

func (s *RetryLayerChannelStore) Update(channel *model.Channel) (*model.Channel, error)

func (*RetryLayerChannelStore) UpdateLastViewedAt ¶

func (s *RetryLayerChannelStore) UpdateLastViewedAt(channelIds []string, userID string) (map[string]int64, error)

func (*RetryLayerChannelStore) UpdateLastViewedAtPost ¶

func (s *RetryLayerChannelStore) UpdateLastViewedAtPost(unreadPost *model.Post, userID string, mentionCount int, mentionCountRoot int, setUnreadCountRoot bool) (*model.ChannelUnreadAt, error)

func (*RetryLayerChannelStore) UpdateMember ¶

func (s *RetryLayerChannelStore) UpdateMember(member *model.ChannelMember) (*model.ChannelMember, error)

func (*RetryLayerChannelStore) UpdateMemberNotifyProps ¶ added in v6.1.0

func (s *RetryLayerChannelStore) UpdateMemberNotifyProps(channelID string, userID string, props map[string]string) (*model.ChannelMember, error)

func (*RetryLayerChannelStore) UpdateMembersRole ¶

func (s *RetryLayerChannelStore) UpdateMembersRole(channelID string, userIDs []string) error

func (*RetryLayerChannelStore) UpdateMultipleMembers ¶

func (s *RetryLayerChannelStore) UpdateMultipleMembers(members []*model.ChannelMember) ([]*model.ChannelMember, error)

func (*RetryLayerChannelStore) UpdateSidebarCategories ¶

func (s *RetryLayerChannelStore) UpdateSidebarCategories(userID string, teamID string, categories []*model.SidebarCategoryWithChannels) ([]*model.SidebarCategoryWithChannels, []*model.SidebarCategoryWithChannels, error)

func (*RetryLayerChannelStore) UpdateSidebarCategoryOrder ¶

func (s *RetryLayerChannelStore) UpdateSidebarCategoryOrder(userID string, teamID string, categoryOrder []string) error

func (*RetryLayerChannelStore) UpdateSidebarChannelCategoryOnMove ¶

func (s *RetryLayerChannelStore) UpdateSidebarChannelCategoryOnMove(channel *model.Channel, newTeamID string) error

func (*RetryLayerChannelStore) UpdateSidebarChannelsByPreferences ¶

func (s *RetryLayerChannelStore) UpdateSidebarChannelsByPreferences(preferences model.Preferences) error

func (*RetryLayerChannelStore) UserBelongsToChannels ¶

func (s *RetryLayerChannelStore) UserBelongsToChannels(userID string, channelIds []string) (bool, error)

type RetryLayerClusterDiscoveryStore ¶

type RetryLayerClusterDiscoveryStore struct {
	store.ClusterDiscoveryStore
	Root *RetryLayer
}

func (*RetryLayerClusterDiscoveryStore) Cleanup ¶

func (s *RetryLayerClusterDiscoveryStore) Cleanup() error

func (*RetryLayerClusterDiscoveryStore) Delete ¶

func (s *RetryLayerClusterDiscoveryStore) Delete(discovery *model.ClusterDiscovery) (bool, error)

func (*RetryLayerClusterDiscoveryStore) Exists ¶

func (s *RetryLayerClusterDiscoveryStore) Exists(discovery *model.ClusterDiscovery) (bool, error)

func (*RetryLayerClusterDiscoveryStore) GetAll ¶

func (s *RetryLayerClusterDiscoveryStore) GetAll(discoveryType string, clusterName string) ([]*model.ClusterDiscovery, error)

func (*RetryLayerClusterDiscoveryStore) Save ¶

func (s *RetryLayerClusterDiscoveryStore) Save(discovery *model.ClusterDiscovery) error

func (*RetryLayerClusterDiscoveryStore) SetLastPingAt ¶

func (s *RetryLayerClusterDiscoveryStore) SetLastPingAt(discovery *model.ClusterDiscovery) error

type RetryLayerCommandStore ¶

type RetryLayerCommandStore struct {
	store.CommandStore
	Root *RetryLayer
}

func (*RetryLayerCommandStore) AnalyticsCommandCount ¶

func (s *RetryLayerCommandStore) AnalyticsCommandCount(teamID string) (int64, error)

func (*RetryLayerCommandStore) Delete ¶

func (s *RetryLayerCommandStore) Delete(commandID string, time int64) error

func (*RetryLayerCommandStore) Get ¶

func (s *RetryLayerCommandStore) Get(id string) (*model.Command, error)

func (*RetryLayerCommandStore) GetByTeam ¶

func (s *RetryLayerCommandStore) GetByTeam(teamID string) ([]*model.Command, error)

func (*RetryLayerCommandStore) GetByTrigger ¶

func (s *RetryLayerCommandStore) GetByTrigger(teamID string, trigger string) (*model.Command, error)

func (*RetryLayerCommandStore) PermanentDeleteByTeam ¶

func (s *RetryLayerCommandStore) PermanentDeleteByTeam(teamID string) error

func (*RetryLayerCommandStore) PermanentDeleteByUser ¶

func (s *RetryLayerCommandStore) PermanentDeleteByUser(userID string) error

func (*RetryLayerCommandStore) Save ¶

func (s *RetryLayerCommandStore) Save(webhook *model.Command) (*model.Command, error)

func (*RetryLayerCommandStore) Update ¶

func (s *RetryLayerCommandStore) Update(hook *model.Command) (*model.Command, error)

type RetryLayerCommandWebhookStore ¶

type RetryLayerCommandWebhookStore struct {
	store.CommandWebhookStore
	Root *RetryLayer
}

func (*RetryLayerCommandWebhookStore) Cleanup ¶

func (s *RetryLayerCommandWebhookStore) Cleanup()

func (*RetryLayerCommandWebhookStore) Get ¶

func (s *RetryLayerCommandWebhookStore) Get(id string) (*model.CommandWebhook, error)

func (*RetryLayerCommandWebhookStore) Save ¶

func (s *RetryLayerCommandWebhookStore) Save(webhook *model.CommandWebhook) (*model.CommandWebhook, error)

func (*RetryLayerCommandWebhookStore) TryUse ¶

func (s *RetryLayerCommandWebhookStore) TryUse(id string, limit int) error

type RetryLayerComplianceStore ¶

type RetryLayerComplianceStore struct {
	store.ComplianceStore
	Root *RetryLayer
}

func (*RetryLayerComplianceStore) ComplianceExport ¶

func (s *RetryLayerComplianceStore) ComplianceExport(compliance *model.Compliance, cursor model.ComplianceExportCursor, limit int) ([]*model.CompliancePost, model.ComplianceExportCursor, error)

func (*RetryLayerComplianceStore) Get ¶

func (s *RetryLayerComplianceStore) Get(id string) (*model.Compliance, error)

func (*RetryLayerComplianceStore) GetAll ¶

func (s *RetryLayerComplianceStore) GetAll(offset int, limit int) (model.Compliances, error)

func (*RetryLayerComplianceStore) MessageExport ¶

func (s *RetryLayerComplianceStore) MessageExport(cursor model.MessageExportCursor, limit int) ([]*model.MessageExport, model.MessageExportCursor, error)

func (*RetryLayerComplianceStore) Save ¶

func (s *RetryLayerComplianceStore) Save(compliance *model.Compliance) (*model.Compliance, error)

func (*RetryLayerComplianceStore) Update ¶

func (s *RetryLayerComplianceStore) Update(compliance *model.Compliance) (*model.Compliance, error)

type RetryLayerEmojiStore ¶

type RetryLayerEmojiStore struct {
	store.EmojiStore
	Root *RetryLayer
}

func (*RetryLayerEmojiStore) Delete ¶

func (s *RetryLayerEmojiStore) Delete(emoji *model.Emoji, time int64) error

func (*RetryLayerEmojiStore) Get ¶

func (s *RetryLayerEmojiStore) Get(ctx context.Context, id string, allowFromCache bool) (*model.Emoji, error)

func (*RetryLayerEmojiStore) GetByName ¶

func (s *RetryLayerEmojiStore) GetByName(ctx context.Context, name string, allowFromCache bool) (*model.Emoji, error)

func (*RetryLayerEmojiStore) GetList ¶

func (s *RetryLayerEmojiStore) GetList(offset int, limit int, sort string) ([]*model.Emoji, error)

func (*RetryLayerEmojiStore) GetMultipleByName ¶

func (s *RetryLayerEmojiStore) GetMultipleByName(names []string) ([]*model.Emoji, error)

func (*RetryLayerEmojiStore) Save ¶

func (s *RetryLayerEmojiStore) Save(emoji *model.Emoji) (*model.Emoji, error)

func (*RetryLayerEmojiStore) Search ¶

func (s *RetryLayerEmojiStore) Search(name string, prefixOnly bool, limit int) ([]*model.Emoji, error)

type RetryLayerFileInfoStore ¶

type RetryLayerFileInfoStore struct {
	store.FileInfoStore
	Root *RetryLayer
}

func (*RetryLayerFileInfoStore) AttachToPost ¶

func (s *RetryLayerFileInfoStore) AttachToPost(fileID string, postID string, creatorID string) error

func (*RetryLayerFileInfoStore) ClearCaches ¶

func (s *RetryLayerFileInfoStore) ClearCaches()

func (*RetryLayerFileInfoStore) CountAll ¶

func (s *RetryLayerFileInfoStore) CountAll() (int64, error)

func (*RetryLayerFileInfoStore) DeleteForPost ¶

func (s *RetryLayerFileInfoStore) DeleteForPost(postID string) (string, error)

func (*RetryLayerFileInfoStore) Get ¶

func (s *RetryLayerFileInfoStore) Get(id string) (*model.FileInfo, error)

func (*RetryLayerFileInfoStore) GetByIds ¶

func (s *RetryLayerFileInfoStore) GetByIds(ids []string) ([]*model.FileInfo, error)

func (*RetryLayerFileInfoStore) GetByPath ¶

func (s *RetryLayerFileInfoStore) GetByPath(path string) (*model.FileInfo, error)

func (*RetryLayerFileInfoStore) GetFilesBatchForIndexing ¶

func (s *RetryLayerFileInfoStore) GetFilesBatchForIndexing(startTime int64, endTime int64, limit int) ([]*model.FileForIndexing, error)

func (*RetryLayerFileInfoStore) GetForPost ¶

func (s *RetryLayerFileInfoStore) GetForPost(postID string, readFromMaster bool, includeDeleted bool, allowFromCache bool) ([]*model.FileInfo, error)

func (*RetryLayerFileInfoStore) GetForUser ¶

func (s *RetryLayerFileInfoStore) GetForUser(userID string) ([]*model.FileInfo, error)

func (*RetryLayerFileInfoStore) GetFromMaster ¶

func (s *RetryLayerFileInfoStore) GetFromMaster(id string) (*model.FileInfo, error)

func (*RetryLayerFileInfoStore) GetWithOptions ¶

func (s *RetryLayerFileInfoStore) GetWithOptions(page int, perPage int, opt *model.GetFileInfosOptions) ([]*model.FileInfo, error)

func (*RetryLayerFileInfoStore) InvalidateFileInfosForPostCache ¶

func (s *RetryLayerFileInfoStore) InvalidateFileInfosForPostCache(postID string, deleted bool)

func (*RetryLayerFileInfoStore) PermanentDelete ¶

func (s *RetryLayerFileInfoStore) PermanentDelete(fileID string) error

func (*RetryLayerFileInfoStore) PermanentDeleteBatch ¶

func (s *RetryLayerFileInfoStore) PermanentDeleteBatch(endTime int64, limit int64) (int64, error)

func (*RetryLayerFileInfoStore) PermanentDeleteByUser ¶

func (s *RetryLayerFileInfoStore) PermanentDeleteByUser(userID string) (int64, error)

func (*RetryLayerFileInfoStore) Save ¶

func (s *RetryLayerFileInfoStore) Save(info *model.FileInfo) (*model.FileInfo, error)

func (*RetryLayerFileInfoStore) Search ¶

func (s *RetryLayerFileInfoStore) Search(paramsList []*model.SearchParams, userID string, teamID string, page int, perPage int) (*model.FileInfoList, error)

func (*RetryLayerFileInfoStore) SetContent ¶

func (s *RetryLayerFileInfoStore) SetContent(fileID string, content string) error

func (*RetryLayerFileInfoStore) Upsert ¶

func (s *RetryLayerFileInfoStore) Upsert(info *model.FileInfo) (*model.FileInfo, error)

type RetryLayerGroupStore ¶

type RetryLayerGroupStore struct {
	store.GroupStore
	Root *RetryLayer
}

func (*RetryLayerGroupStore) AdminRoleGroupsForSyncableMember ¶

func (s *RetryLayerGroupStore) AdminRoleGroupsForSyncableMember(userID string, syncableID string, syncableType model.GroupSyncableType) ([]string, error)

func (*RetryLayerGroupStore) ChannelMembersMinusGroupMembers ¶

func (s *RetryLayerGroupStore) ChannelMembersMinusGroupMembers(channelID string, groupIDs []string, page int, perPage int) ([]*model.UserWithGroups, error)

func (*RetryLayerGroupStore) ChannelMembersToAdd ¶

func (s *RetryLayerGroupStore) ChannelMembersToAdd(since int64, channelID *string, includeRemovedMembers bool) ([]*model.UserChannelIDPair, error)

func (*RetryLayerGroupStore) ChannelMembersToRemove ¶

func (s *RetryLayerGroupStore) ChannelMembersToRemove(channelID *string) ([]*model.ChannelMember, error)

func (*RetryLayerGroupStore) CountChannelMembersMinusGroupMembers ¶

func (s *RetryLayerGroupStore) CountChannelMembersMinusGroupMembers(channelID string, groupIDs []string) (int64, error)

func (*RetryLayerGroupStore) CountGroupsByChannel ¶

func (s *RetryLayerGroupStore) CountGroupsByChannel(channelID string, opts model.GroupSearchOpts) (int64, error)

func (*RetryLayerGroupStore) CountGroupsByTeam ¶

func (s *RetryLayerGroupStore) CountGroupsByTeam(teamID string, opts model.GroupSearchOpts) (int64, error)

func (*RetryLayerGroupStore) CountTeamMembersMinusGroupMembers ¶

func (s *RetryLayerGroupStore) CountTeamMembersMinusGroupMembers(teamID string, groupIDs []string) (int64, error)

func (*RetryLayerGroupStore) Create ¶

func (s *RetryLayerGroupStore) Create(group *model.Group) (*model.Group, error)

func (*RetryLayerGroupStore) CreateGroupSyncable ¶

func (s *RetryLayerGroupStore) CreateGroupSyncable(groupSyncable *model.GroupSyncable) (*model.GroupSyncable, error)

func (*RetryLayerGroupStore) CreateWithUserIds ¶ added in v6.5.0

func (s *RetryLayerGroupStore) CreateWithUserIds(group *model.GroupWithUserIds) (*model.Group, error)

func (*RetryLayerGroupStore) Delete ¶

func (s *RetryLayerGroupStore) Delete(groupID string) (*model.Group, error)

func (*RetryLayerGroupStore) DeleteGroupSyncable ¶

func (s *RetryLayerGroupStore) DeleteGroupSyncable(groupID string, syncableID string, syncableType model.GroupSyncableType) (*model.GroupSyncable, error)

func (*RetryLayerGroupStore) DeleteMember ¶

func (s *RetryLayerGroupStore) DeleteMember(groupID string, userID string) (*model.GroupMember, error)

func (*RetryLayerGroupStore) DeleteMembers ¶ added in v6.5.0

func (s *RetryLayerGroupStore) DeleteMembers(groupID string, userIDs []string) ([]*model.GroupMember, error)

func (*RetryLayerGroupStore) DistinctGroupMemberCount ¶

func (s *RetryLayerGroupStore) DistinctGroupMemberCount() (int64, error)

func (*RetryLayerGroupStore) Get ¶

func (s *RetryLayerGroupStore) Get(groupID string) (*model.Group, error)

func (*RetryLayerGroupStore) GetAllBySource ¶

func (s *RetryLayerGroupStore) GetAllBySource(groupSource model.GroupSource) ([]*model.Group, error)

func (*RetryLayerGroupStore) GetAllGroupSyncablesByGroupId ¶

func (s *RetryLayerGroupStore) GetAllGroupSyncablesByGroupId(groupID string, syncableType model.GroupSyncableType) ([]*model.GroupSyncable, error)

func (*RetryLayerGroupStore) GetByIDs ¶

func (s *RetryLayerGroupStore) GetByIDs(groupIDs []string) ([]*model.Group, error)

func (*RetryLayerGroupStore) GetByName ¶

func (s *RetryLayerGroupStore) GetByName(name string, opts model.GroupSearchOpts) (*model.Group, error)

func (*RetryLayerGroupStore) GetByRemoteID ¶

func (s *RetryLayerGroupStore) GetByRemoteID(remoteID string, groupSource model.GroupSource) (*model.Group, error)

func (*RetryLayerGroupStore) GetByUser ¶

func (s *RetryLayerGroupStore) GetByUser(userID string) ([]*model.Group, error)

func (*RetryLayerGroupStore) GetGroupSyncable ¶

func (s *RetryLayerGroupStore) GetGroupSyncable(groupID string, syncableID string, syncableType model.GroupSyncableType) (*model.GroupSyncable, error)

func (*RetryLayerGroupStore) GetGroups ¶

func (s *RetryLayerGroupStore) GetGroups(page int, perPage int, opts model.GroupSearchOpts) ([]*model.Group, error)

func (*RetryLayerGroupStore) GetGroupsAssociatedToChannelsByTeam ¶

func (s *RetryLayerGroupStore) GetGroupsAssociatedToChannelsByTeam(teamID string, opts model.GroupSearchOpts) (map[string][]*model.GroupWithSchemeAdmin, error)

func (*RetryLayerGroupStore) GetGroupsByChannel ¶

func (s *RetryLayerGroupStore) GetGroupsByChannel(channelID string, opts model.GroupSearchOpts) ([]*model.GroupWithSchemeAdmin, error)

func (*RetryLayerGroupStore) GetGroupsByTeam ¶

func (s *RetryLayerGroupStore) GetGroupsByTeam(teamID string, opts model.GroupSearchOpts) ([]*model.GroupWithSchemeAdmin, error)

func (*RetryLayerGroupStore) GetMember ¶ added in v6.5.0

func (s *RetryLayerGroupStore) GetMember(groupID string, userID string) (*model.GroupMember, error)

func (*RetryLayerGroupStore) GetMemberCount ¶

func (s *RetryLayerGroupStore) GetMemberCount(groupID string) (int64, error)

func (*RetryLayerGroupStore) GetMemberUsers ¶

func (s *RetryLayerGroupStore) GetMemberUsers(groupID string) ([]*model.User, error)

func (*RetryLayerGroupStore) GetMemberUsersInTeam ¶

func (s *RetryLayerGroupStore) GetMemberUsersInTeam(groupID string, teamID string) ([]*model.User, error)

func (*RetryLayerGroupStore) GetMemberUsersNotInChannel ¶

func (s *RetryLayerGroupStore) GetMemberUsersNotInChannel(groupID string, channelID string) ([]*model.User, error)

func (*RetryLayerGroupStore) GetMemberUsersPage ¶

func (s *RetryLayerGroupStore) GetMemberUsersPage(groupID string, page int, perPage int) ([]*model.User, error)

func (*RetryLayerGroupStore) GetNonMemberUsersPage ¶ added in v6.5.0

func (s *RetryLayerGroupStore) GetNonMemberUsersPage(groupID string, page int, perPage int) ([]*model.User, error)

func (*RetryLayerGroupStore) GroupChannelCount ¶

func (s *RetryLayerGroupStore) GroupChannelCount() (int64, error)

func (*RetryLayerGroupStore) GroupCount ¶

func (s *RetryLayerGroupStore) GroupCount() (int64, error)

func (*RetryLayerGroupStore) GroupCountWithAllowReference ¶

func (s *RetryLayerGroupStore) GroupCountWithAllowReference() (int64, error)

func (*RetryLayerGroupStore) GroupMemberCount ¶

func (s *RetryLayerGroupStore) GroupMemberCount() (int64, error)

func (*RetryLayerGroupStore) GroupTeamCount ¶

func (s *RetryLayerGroupStore) GroupTeamCount() (int64, error)

func (*RetryLayerGroupStore) PermanentDeleteMembersByUser ¶

func (s *RetryLayerGroupStore) PermanentDeleteMembersByUser(userID string) error

func (*RetryLayerGroupStore) PermittedSyncableAdmins ¶

func (s *RetryLayerGroupStore) PermittedSyncableAdmins(syncableID string, syncableType model.GroupSyncableType) ([]string, error)

func (*RetryLayerGroupStore) TeamMembersMinusGroupMembers ¶

func (s *RetryLayerGroupStore) TeamMembersMinusGroupMembers(teamID string, groupIDs []string, page int, perPage int) ([]*model.UserWithGroups, error)

func (*RetryLayerGroupStore) TeamMembersToAdd ¶

func (s *RetryLayerGroupStore) TeamMembersToAdd(since int64, teamID *string, includeRemovedMembers bool) ([]*model.UserTeamIDPair, error)

func (*RetryLayerGroupStore) TeamMembersToRemove ¶

func (s *RetryLayerGroupStore) TeamMembersToRemove(teamID *string) ([]*model.TeamMember, error)

func (*RetryLayerGroupStore) Update ¶

func (s *RetryLayerGroupStore) Update(group *model.Group) (*model.Group, error)

func (*RetryLayerGroupStore) UpdateGroupSyncable ¶

func (s *RetryLayerGroupStore) UpdateGroupSyncable(groupSyncable *model.GroupSyncable) (*model.GroupSyncable, error)

func (*RetryLayerGroupStore) UpsertMember ¶

func (s *RetryLayerGroupStore) UpsertMember(groupID string, userID string) (*model.GroupMember, error)

func (*RetryLayerGroupStore) UpsertMembers ¶ added in v6.5.0

func (s *RetryLayerGroupStore) UpsertMembers(groupID string, userIDs []string) ([]*model.GroupMember, error)

type RetryLayerJobStore ¶

type RetryLayerJobStore struct {
	store.JobStore
	Root *RetryLayer
}

func (*RetryLayerJobStore) Cleanup ¶ added in v6.1.0

func (s *RetryLayerJobStore) Cleanup(expiryTime int64, batchSize int) error

func (*RetryLayerJobStore) Delete ¶

func (s *RetryLayerJobStore) Delete(id string) (string, error)

func (*RetryLayerJobStore) Get ¶

func (s *RetryLayerJobStore) Get(id string) (*model.Job, error)

func (*RetryLayerJobStore) GetAllByStatus ¶

func (s *RetryLayerJobStore) GetAllByStatus(status string) ([]*model.Job, error)

func (*RetryLayerJobStore) GetAllByType ¶

func (s *RetryLayerJobStore) GetAllByType(jobType string) ([]*model.Job, error)

func (*RetryLayerJobStore) GetAllByTypeAndStatus ¶ added in v6.5.0

func (s *RetryLayerJobStore) GetAllByTypeAndStatus(jobType string, status string) ([]*model.Job, error)

func (*RetryLayerJobStore) GetAllByTypePage ¶

func (s *RetryLayerJobStore) GetAllByTypePage(jobType string, offset int, limit int) ([]*model.Job, error)

func (*RetryLayerJobStore) GetAllByTypesPage ¶

func (s *RetryLayerJobStore) GetAllByTypesPage(jobTypes []string, offset int, limit int) ([]*model.Job, error)

func (*RetryLayerJobStore) GetAllPage ¶

func (s *RetryLayerJobStore) GetAllPage(offset int, limit int) ([]*model.Job, error)

func (*RetryLayerJobStore) GetCountByStatusAndType ¶

func (s *RetryLayerJobStore) GetCountByStatusAndType(status string, jobType string) (int64, error)

func (*RetryLayerJobStore) GetNewestJobByStatusAndType ¶

func (s *RetryLayerJobStore) GetNewestJobByStatusAndType(status string, jobType string) (*model.Job, error)

func (*RetryLayerJobStore) GetNewestJobByStatusesAndType ¶

func (s *RetryLayerJobStore) GetNewestJobByStatusesAndType(statuses []string, jobType string) (*model.Job, error)

func (*RetryLayerJobStore) Save ¶

func (s *RetryLayerJobStore) Save(job *model.Job) (*model.Job, error)

func (*RetryLayerJobStore) UpdateOptimistically ¶

func (s *RetryLayerJobStore) UpdateOptimistically(job *model.Job, currentStatus string) (bool, error)

func (*RetryLayerJobStore) UpdateStatus ¶

func (s *RetryLayerJobStore) UpdateStatus(id string, status string) (*model.Job, error)

func (*RetryLayerJobStore) UpdateStatusOptimistically ¶

func (s *RetryLayerJobStore) UpdateStatusOptimistically(id string, currentStatus string, newStatus string) (bool, error)

type RetryLayerLicenseStore ¶

type RetryLayerLicenseStore struct {
	store.LicenseStore
	Root *RetryLayer
}

func (*RetryLayerLicenseStore) Get ¶

func (s *RetryLayerLicenseStore) Get(id string) (*model.LicenseRecord, error)

func (*RetryLayerLicenseStore) GetAll ¶

func (s *RetryLayerLicenseStore) GetAll() ([]*model.LicenseRecord, error)

func (*RetryLayerLicenseStore) Save ¶

func (s *RetryLayerLicenseStore) Save(license *model.LicenseRecord) (*model.LicenseRecord, error)

type RetryLayerLinkMetadataStore ¶

type RetryLayerLinkMetadataStore struct {
	store.LinkMetadataStore
	Root *RetryLayer
}

func (*RetryLayerLinkMetadataStore) Get ¶

func (s *RetryLayerLinkMetadataStore) Get(url string, timestamp int64) (*model.LinkMetadata, error)

func (*RetryLayerLinkMetadataStore) Save ¶

func (s *RetryLayerLinkMetadataStore) Save(linkMetadata *model.LinkMetadata) (*model.LinkMetadata, error)

type RetryLayerOAuthStore ¶

type RetryLayerOAuthStore struct {
	store.OAuthStore
	Root *RetryLayer
}

func (*RetryLayerOAuthStore) DeleteApp ¶

func (s *RetryLayerOAuthStore) DeleteApp(id string) error

func (*RetryLayerOAuthStore) GetAccessData ¶

func (s *RetryLayerOAuthStore) GetAccessData(token string) (*model.AccessData, error)

func (*RetryLayerOAuthStore) GetAccessDataByRefreshToken ¶

func (s *RetryLayerOAuthStore) GetAccessDataByRefreshToken(token string) (*model.AccessData, error)

func (*RetryLayerOAuthStore) GetAccessDataByUserForApp ¶

func (s *RetryLayerOAuthStore) GetAccessDataByUserForApp(userID string, clientId string) ([]*model.AccessData, error)

func (*RetryLayerOAuthStore) GetApp ¶

func (s *RetryLayerOAuthStore) GetApp(id string) (*model.OAuthApp, error)

func (*RetryLayerOAuthStore) GetAppByUser ¶

func (s *RetryLayerOAuthStore) GetAppByUser(userID string, offset int, limit int) ([]*model.OAuthApp, error)

func (*RetryLayerOAuthStore) GetApps ¶

func (s *RetryLayerOAuthStore) GetApps(offset int, limit int) ([]*model.OAuthApp, error)

func (*RetryLayerOAuthStore) GetAuthData ¶

func (s *RetryLayerOAuthStore) GetAuthData(code string) (*model.AuthData, error)

func (*RetryLayerOAuthStore) GetAuthorizedApps ¶

func (s *RetryLayerOAuthStore) GetAuthorizedApps(userID string, offset int, limit int) ([]*model.OAuthApp, error)

func (*RetryLayerOAuthStore) GetPreviousAccessData ¶

func (s *RetryLayerOAuthStore) GetPreviousAccessData(userID string, clientId string) (*model.AccessData, error)

func (*RetryLayerOAuthStore) PermanentDeleteAuthDataByUser ¶

func (s *RetryLayerOAuthStore) PermanentDeleteAuthDataByUser(userID string) error

func (*RetryLayerOAuthStore) RemoveAccessData ¶

func (s *RetryLayerOAuthStore) RemoveAccessData(token string) error

func (*RetryLayerOAuthStore) RemoveAllAccessData ¶

func (s *RetryLayerOAuthStore) RemoveAllAccessData() error

func (*RetryLayerOAuthStore) RemoveAuthData ¶

func (s *RetryLayerOAuthStore) RemoveAuthData(code string) error

func (*RetryLayerOAuthStore) SaveAccessData ¶

func (s *RetryLayerOAuthStore) SaveAccessData(accessData *model.AccessData) (*model.AccessData, error)

func (*RetryLayerOAuthStore) SaveApp ¶

func (s *RetryLayerOAuthStore) SaveApp(app *model.OAuthApp) (*model.OAuthApp, error)

func (*RetryLayerOAuthStore) SaveAuthData ¶

func (s *RetryLayerOAuthStore) SaveAuthData(authData *model.AuthData) (*model.AuthData, error)

func (*RetryLayerOAuthStore) UpdateAccessData ¶

func (s *RetryLayerOAuthStore) UpdateAccessData(accessData *model.AccessData) (*model.AccessData, error)

func (*RetryLayerOAuthStore) UpdateApp ¶

func (s *RetryLayerOAuthStore) UpdateApp(app *model.OAuthApp) (*model.OAuthApp, error)

type RetryLayerPluginStore ¶

type RetryLayerPluginStore struct {
	store.PluginStore
	Root *RetryLayer
}

func (*RetryLayerPluginStore) CompareAndDelete ¶

func (s *RetryLayerPluginStore) CompareAndDelete(keyVal *model.PluginKeyValue, oldValue []byte) (bool, error)

func (*RetryLayerPluginStore) CompareAndSet ¶

func (s *RetryLayerPluginStore) CompareAndSet(keyVal *model.PluginKeyValue, oldValue []byte) (bool, error)

func (*RetryLayerPluginStore) Delete ¶

func (s *RetryLayerPluginStore) Delete(pluginID string, key string) error

func (*RetryLayerPluginStore) DeleteAllExpired ¶

func (s *RetryLayerPluginStore) DeleteAllExpired() error

func (*RetryLayerPluginStore) DeleteAllForPlugin ¶

func (s *RetryLayerPluginStore) DeleteAllForPlugin(PluginID string) error

func (*RetryLayerPluginStore) Get ¶

func (s *RetryLayerPluginStore) Get(pluginID string, key string) (*model.PluginKeyValue, error)

func (*RetryLayerPluginStore) List ¶

func (s *RetryLayerPluginStore) List(pluginID string, page int, perPage int) ([]string, error)

func (*RetryLayerPluginStore) SaveOrUpdate ¶

func (s *RetryLayerPluginStore) SaveOrUpdate(keyVal *model.PluginKeyValue) (*model.PluginKeyValue, error)

func (*RetryLayerPluginStore) SetWithOptions ¶

func (s *RetryLayerPluginStore) SetWithOptions(pluginID string, key string, value []byte, options model.PluginKVSetOptions) (bool, error)

type RetryLayerPostStore ¶

type RetryLayerPostStore struct {
	store.PostStore
	Root *RetryLayer
}

func (*RetryLayerPostStore) AnalyticsPostCount ¶

func (s *RetryLayerPostStore) AnalyticsPostCount(teamID string, mustHaveFile bool, mustHaveHashtag bool) (int64, error)

func (*RetryLayerPostStore) AnalyticsPostCountsByDay ¶

func (s *RetryLayerPostStore) AnalyticsPostCountsByDay(options *model.AnalyticsPostCountsOptions) (model.AnalyticsRows, error)

func (*RetryLayerPostStore) AnalyticsUserCountsWithPostsByDay ¶

func (s *RetryLayerPostStore) AnalyticsUserCountsWithPostsByDay(teamID string) (model.AnalyticsRows, error)

func (*RetryLayerPostStore) ClearCaches ¶

func (s *RetryLayerPostStore) ClearCaches()

func (*RetryLayerPostStore) Delete ¶

func (s *RetryLayerPostStore) Delete(postID string, time int64, deleteByID string) error

func (*RetryLayerPostStore) DeleteOrphanedRows ¶

func (s *RetryLayerPostStore) DeleteOrphanedRows(limit int) (int64, error)

func (*RetryLayerPostStore) Get ¶

func (s *RetryLayerPostStore) Get(ctx context.Context, id string, skipFetchThreads bool, collapsedThreads bool, collapsedThreadsExtended bool, userID string) (*model.PostList, error)

func (*RetryLayerPostStore) GetDirectPostParentsForExportAfter ¶

func (s *RetryLayerPostStore) GetDirectPostParentsForExportAfter(limit int, afterID string) ([]*model.DirectPostForExport, error)

func (*RetryLayerPostStore) GetEtag ¶

func (s *RetryLayerPostStore) GetEtag(channelID string, allowFromCache bool, collapsedThreads bool) string

func (*RetryLayerPostStore) GetFlaggedPosts ¶

func (s *RetryLayerPostStore) GetFlaggedPosts(userID string, offset int, limit int) (*model.PostList, error)

func (*RetryLayerPostStore) GetFlaggedPostsForChannel ¶

func (s *RetryLayerPostStore) GetFlaggedPostsForChannel(userID string, channelID string, offset int, limit int) (*model.PostList, error)

func (*RetryLayerPostStore) GetFlaggedPostsForTeam ¶

func (s *RetryLayerPostStore) GetFlaggedPostsForTeam(userID string, teamID string, offset int, limit int) (*model.PostList, error)

func (*RetryLayerPostStore) GetLastPostRowCreateAt ¶ added in v6.5.0

func (s *RetryLayerPostStore) GetLastPostRowCreateAt() (int64, error)

func (*RetryLayerPostStore) GetMaxPostSize ¶

func (s *RetryLayerPostStore) GetMaxPostSize() int

func (*RetryLayerPostStore) GetOldest ¶

func (s *RetryLayerPostStore) GetOldest() (*model.Post, error)

func (*RetryLayerPostStore) GetOldestEntityCreationTime ¶

func (s *RetryLayerPostStore) GetOldestEntityCreationTime() (int64, error)

func (*RetryLayerPostStore) GetParentsForExportAfter ¶

func (s *RetryLayerPostStore) GetParentsForExportAfter(limit int, afterID string) ([]*model.PostForExport, error)

func (*RetryLayerPostStore) GetPostAfterTime ¶

func (s *RetryLayerPostStore) GetPostAfterTime(channelID string, time int64, collapsedThreads bool) (*model.Post, error)

func (*RetryLayerPostStore) GetPostIdAfterTime ¶

func (s *RetryLayerPostStore) GetPostIdAfterTime(channelID string, time int64, collapsedThreads bool) (string, error)

func (*RetryLayerPostStore) GetPostIdBeforeTime ¶

func (s *RetryLayerPostStore) GetPostIdBeforeTime(channelID string, time int64, collapsedThreads bool) (string, error)

func (*RetryLayerPostStore) GetPosts ¶

func (s *RetryLayerPostStore) GetPosts(options model.GetPostsOptions, allowFromCache bool) (*model.PostList, error)

func (*RetryLayerPostStore) GetPostsAfter ¶

func (s *RetryLayerPostStore) GetPostsAfter(options model.GetPostsOptions) (*model.PostList, error)

func (*RetryLayerPostStore) GetPostsBatchForIndexing ¶

func (s *RetryLayerPostStore) GetPostsBatchForIndexing(startTime int64, endTime int64, limit int) ([]*model.PostForIndexing, error)

func (*RetryLayerPostStore) GetPostsBefore ¶

func (s *RetryLayerPostStore) GetPostsBefore(options model.GetPostsOptions) (*model.PostList, error)

func (*RetryLayerPostStore) GetPostsByIds ¶

func (s *RetryLayerPostStore) GetPostsByIds(postIds []string) ([]*model.Post, error)

func (*RetryLayerPostStore) GetPostsCreatedAt ¶

func (s *RetryLayerPostStore) GetPostsCreatedAt(channelID string, time int64) ([]*model.Post, error)

func (*RetryLayerPostStore) GetPostsSince ¶

func (s *RetryLayerPostStore) GetPostsSince(options model.GetPostsSinceOptions, allowFromCache bool) (*model.PostList, error)

func (*RetryLayerPostStore) GetPostsSinceForSync ¶

func (s *RetryLayerPostStore) GetPostsSinceForSync(options model.GetPostsSinceForSyncOptions, cursor model.GetPostsSinceForSyncCursor, limit int) ([]*model.Post, model.GetPostsSinceForSyncCursor, error)

func (*RetryLayerPostStore) GetRepliesForExport ¶

func (s *RetryLayerPostStore) GetRepliesForExport(parentID string) ([]*model.ReplyForExport, error)

func (*RetryLayerPostStore) GetSingle ¶

func (s *RetryLayerPostStore) GetSingle(id string, inclDeleted bool) (*model.Post, error)

func (*RetryLayerPostStore) HasAutoResponsePostByUserSince ¶

func (s *RetryLayerPostStore) HasAutoResponsePostByUserSince(options model.GetPostsSinceOptions, userId string) (bool, error)

func (*RetryLayerPostStore) InvalidateLastPostTimeCache ¶

func (s *RetryLayerPostStore) InvalidateLastPostTimeCache(channelID string)

func (*RetryLayerPostStore) Overwrite ¶

func (s *RetryLayerPostStore) Overwrite(post *model.Post) (*model.Post, error)

func (*RetryLayerPostStore) OverwriteMultiple ¶

func (s *RetryLayerPostStore) OverwriteMultiple(posts []*model.Post) ([]*model.Post, int, error)

func (*RetryLayerPostStore) PermanentDeleteBatch ¶

func (s *RetryLayerPostStore) PermanentDeleteBatch(endTime int64, limit int64) (int64, error)

func (*RetryLayerPostStore) PermanentDeleteBatchForRetentionPolicies ¶

func (s *RetryLayerPostStore) PermanentDeleteBatchForRetentionPolicies(now int64, globalPolicyEndTime int64, limit int64, cursor model.RetentionPolicyCursor) (int64, model.RetentionPolicyCursor, error)

func (*RetryLayerPostStore) PermanentDeleteByChannel ¶

func (s *RetryLayerPostStore) PermanentDeleteByChannel(channelID string) error

func (*RetryLayerPostStore) PermanentDeleteByUser ¶

func (s *RetryLayerPostStore) PermanentDeleteByUser(userID string) error

func (*RetryLayerPostStore) Save ¶

func (s *RetryLayerPostStore) Save(post *model.Post) (*model.Post, error)

func (*RetryLayerPostStore) SaveMultiple ¶

func (s *RetryLayerPostStore) SaveMultiple(posts []*model.Post) ([]*model.Post, int, error)

func (*RetryLayerPostStore) Search ¶

func (s *RetryLayerPostStore) Search(teamID string, userID string, params *model.SearchParams) (*model.PostList, error)

func (*RetryLayerPostStore) SearchPostsForUser ¶ added in v6.1.0

func (s *RetryLayerPostStore) SearchPostsForUser(paramsList []*model.SearchParams, userID string, teamID string, page int, perPage int) (*model.PostSearchResults, error)

func (*RetryLayerPostStore) Update ¶

func (s *RetryLayerPostStore) Update(newPost *model.Post, oldPost *model.Post) (*model.Post, error)

type RetryLayerPreferenceStore ¶

type RetryLayerPreferenceStore struct {
	store.PreferenceStore
	Root *RetryLayer
}

func (*RetryLayerPreferenceStore) CleanupFlagsBatch ¶

func (s *RetryLayerPreferenceStore) CleanupFlagsBatch(limit int64) (int64, error)

func (*RetryLayerPreferenceStore) Delete ¶

func (s *RetryLayerPreferenceStore) Delete(userID string, category string, name string) error

func (*RetryLayerPreferenceStore) DeleteCategory ¶

func (s *RetryLayerPreferenceStore) DeleteCategory(userID string, category string) error

func (*RetryLayerPreferenceStore) DeleteCategoryAndName ¶

func (s *RetryLayerPreferenceStore) DeleteCategoryAndName(category string, name string) error

func (*RetryLayerPreferenceStore) DeleteOrphanedRows ¶

func (s *RetryLayerPreferenceStore) DeleteOrphanedRows(limit int) (int64, error)

func (*RetryLayerPreferenceStore) Get ¶

func (s *RetryLayerPreferenceStore) Get(userID string, category string, name string) (*model.Preference, error)

func (*RetryLayerPreferenceStore) GetAll ¶

func (s *RetryLayerPreferenceStore) GetAll(userID string) (model.Preferences, error)

func (*RetryLayerPreferenceStore) GetCategory ¶

func (s *RetryLayerPreferenceStore) GetCategory(userID string, category string) (model.Preferences, error)

func (*RetryLayerPreferenceStore) PermanentDeleteByUser ¶

func (s *RetryLayerPreferenceStore) PermanentDeleteByUser(userID string) error

func (*RetryLayerPreferenceStore) Save ¶

func (s *RetryLayerPreferenceStore) Save(preferences model.Preferences) error

type RetryLayerProductNoticesStore ¶

type RetryLayerProductNoticesStore struct {
	store.ProductNoticesStore
	Root *RetryLayer
}

func (*RetryLayerProductNoticesStore) Clear ¶

func (s *RetryLayerProductNoticesStore) Clear(notices []string) error

func (*RetryLayerProductNoticesStore) ClearOldNotices ¶

func (s *RetryLayerProductNoticesStore) ClearOldNotices(currentNotices model.ProductNotices) error

func (*RetryLayerProductNoticesStore) GetViews ¶

func (s *RetryLayerProductNoticesStore) GetViews(userID string) ([]model.ProductNoticeViewState, error)

func (*RetryLayerProductNoticesStore) View ¶

func (s *RetryLayerProductNoticesStore) View(userID string, notices []string) error

type RetryLayerReactionStore ¶

type RetryLayerReactionStore struct {
	store.ReactionStore
	Root *RetryLayer
}

func (*RetryLayerReactionStore) BulkGetForPosts ¶

func (s *RetryLayerReactionStore) BulkGetForPosts(postIds []string) ([]*model.Reaction, error)

func (*RetryLayerReactionStore) Delete ¶

func (s *RetryLayerReactionStore) Delete(reaction *model.Reaction) (*model.Reaction, error)

func (*RetryLayerReactionStore) DeleteAllWithEmojiName ¶

func (s *RetryLayerReactionStore) DeleteAllWithEmojiName(emojiName string) error

func (*RetryLayerReactionStore) DeleteOrphanedRows ¶

func (s *RetryLayerReactionStore) DeleteOrphanedRows(limit int) (int64, error)

func (*RetryLayerReactionStore) GetForPost ¶

func (s *RetryLayerReactionStore) GetForPost(postID string, allowFromCache bool) ([]*model.Reaction, error)

func (*RetryLayerReactionStore) GetForPostSince ¶

func (s *RetryLayerReactionStore) GetForPostSince(postId string, since int64, excludeRemoteId string, inclDeleted bool) ([]*model.Reaction, error)

func (*RetryLayerReactionStore) PermanentDeleteBatch ¶

func (s *RetryLayerReactionStore) PermanentDeleteBatch(endTime int64, limit int64) (int64, error)

func (*RetryLayerReactionStore) Save ¶

func (s *RetryLayerReactionStore) Save(reaction *model.Reaction) (*model.Reaction, error)

type RetryLayerRemoteClusterStore ¶

type RetryLayerRemoteClusterStore struct {
	store.RemoteClusterStore
	Root *RetryLayer
}

func (*RetryLayerRemoteClusterStore) Delete ¶

func (s *RetryLayerRemoteClusterStore) Delete(remoteClusterId string) (bool, error)

func (*RetryLayerRemoteClusterStore) Get ¶

func (s *RetryLayerRemoteClusterStore) Get(remoteClusterId string) (*model.RemoteCluster, error)

func (*RetryLayerRemoteClusterStore) GetAll ¶

func (s *RetryLayerRemoteClusterStore) GetAll(filter model.RemoteClusterQueryFilter) ([]*model.RemoteCluster, error)

func (*RetryLayerRemoteClusterStore) Save ¶

func (s *RetryLayerRemoteClusterStore) Save(rc *model.RemoteCluster) (*model.RemoteCluster, error)

func (*RetryLayerRemoteClusterStore) SetLastPingAt ¶

func (s *RetryLayerRemoteClusterStore) SetLastPingAt(remoteClusterId string) error

func (*RetryLayerRemoteClusterStore) Update ¶

func (s *RetryLayerRemoteClusterStore) Update(rc *model.RemoteCluster) (*model.RemoteCluster, error)

func (*RetryLayerRemoteClusterStore) UpdateTopics ¶

func (s *RetryLayerRemoteClusterStore) UpdateTopics(remoteClusterId string, topics string) (*model.RemoteCluster, error)

type RetryLayerRetentionPolicyStore ¶

type RetryLayerRetentionPolicyStore struct {
	store.RetentionPolicyStore
	Root *RetryLayer
}

func (*RetryLayerRetentionPolicyStore) AddChannels ¶

func (s *RetryLayerRetentionPolicyStore) AddChannels(policyId string, channelIds []string) error

func (*RetryLayerRetentionPolicyStore) AddTeams ¶

func (s *RetryLayerRetentionPolicyStore) AddTeams(policyId string, teamIds []string) error

func (*RetryLayerRetentionPolicyStore) Delete ¶

func (s *RetryLayerRetentionPolicyStore) Delete(id string) error

func (*RetryLayerRetentionPolicyStore) DeleteOrphanedRows ¶

func (s *RetryLayerRetentionPolicyStore) DeleteOrphanedRows(limit int) (int64, error)

func (*RetryLayerRetentionPolicyStore) Get ¶

func (s *RetryLayerRetentionPolicyStore) Get(id string) (*model.RetentionPolicyWithTeamAndChannelCounts, error)

func (*RetryLayerRetentionPolicyStore) GetAll ¶

func (s *RetryLayerRetentionPolicyStore) GetAll(offset int, limit int) ([]*model.RetentionPolicyWithTeamAndChannelCounts, error)

func (*RetryLayerRetentionPolicyStore) GetChannelPoliciesCountForUser ¶

func (s *RetryLayerRetentionPolicyStore) GetChannelPoliciesCountForUser(userID string) (int64, error)

func (*RetryLayerRetentionPolicyStore) GetChannelPoliciesForUser ¶

func (s *RetryLayerRetentionPolicyStore) GetChannelPoliciesForUser(userID string, offset int, limit int) ([]*model.RetentionPolicyForChannel, error)

func (*RetryLayerRetentionPolicyStore) GetChannels ¶

func (s *RetryLayerRetentionPolicyStore) GetChannels(policyId string, offset int, limit int) (model.ChannelListWithTeamData, error)

func (*RetryLayerRetentionPolicyStore) GetChannelsCount ¶

func (s *RetryLayerRetentionPolicyStore) GetChannelsCount(policyId string) (int64, error)

func (*RetryLayerRetentionPolicyStore) GetCount ¶

func (s *RetryLayerRetentionPolicyStore) GetCount() (int64, error)

func (*RetryLayerRetentionPolicyStore) GetTeamPoliciesCountForUser ¶

func (s *RetryLayerRetentionPolicyStore) GetTeamPoliciesCountForUser(userID string) (int64, error)

func (*RetryLayerRetentionPolicyStore) GetTeamPoliciesForUser ¶

func (s *RetryLayerRetentionPolicyStore) GetTeamPoliciesForUser(userID string, offset int, limit int) ([]*model.RetentionPolicyForTeam, error)

func (*RetryLayerRetentionPolicyStore) GetTeams ¶

func (s *RetryLayerRetentionPolicyStore) GetTeams(policyId string, offset int, limit int) ([]*model.Team, error)

func (*RetryLayerRetentionPolicyStore) GetTeamsCount ¶

func (s *RetryLayerRetentionPolicyStore) GetTeamsCount(policyId string) (int64, error)

func (*RetryLayerRetentionPolicyStore) Patch ¶

func (s *RetryLayerRetentionPolicyStore) Patch(patch *model.RetentionPolicyWithTeamAndChannelIDs) (*model.RetentionPolicyWithTeamAndChannelCounts, error)

func (*RetryLayerRetentionPolicyStore) RemoveChannels ¶

func (s *RetryLayerRetentionPolicyStore) RemoveChannels(policyId string, channelIds []string) error

func (*RetryLayerRetentionPolicyStore) RemoveTeams ¶

func (s *RetryLayerRetentionPolicyStore) RemoveTeams(policyId string, teamIds []string) error

func (*RetryLayerRetentionPolicyStore) Save ¶

func (s *RetryLayerRetentionPolicyStore) Save(policy *model.RetentionPolicyWithTeamAndChannelIDs) (*model.RetentionPolicyWithTeamAndChannelCounts, error)

type RetryLayerRoleStore ¶

type RetryLayerRoleStore struct {
	store.RoleStore
	Root *RetryLayer
}

func (*RetryLayerRoleStore) AllChannelSchemeRoles ¶

func (s *RetryLayerRoleStore) AllChannelSchemeRoles() ([]*model.Role, error)

func (*RetryLayerRoleStore) ChannelHigherScopedPermissions ¶

func (s *RetryLayerRoleStore) ChannelHigherScopedPermissions(roleNames []string) (map[string]*model.RolePermissions, error)

func (*RetryLayerRoleStore) ChannelRolesUnderTeamRole ¶

func (s *RetryLayerRoleStore) ChannelRolesUnderTeamRole(roleName string) ([]*model.Role, error)

func (*RetryLayerRoleStore) Delete ¶

func (s *RetryLayerRoleStore) Delete(roleID string) (*model.Role, error)

func (*RetryLayerRoleStore) Get ¶

func (s *RetryLayerRoleStore) Get(roleID string) (*model.Role, error)

func (*RetryLayerRoleStore) GetAll ¶

func (s *RetryLayerRoleStore) GetAll() ([]*model.Role, error)

func (*RetryLayerRoleStore) GetByName ¶

func (s *RetryLayerRoleStore) GetByName(ctx context.Context, name string) (*model.Role, error)

func (*RetryLayerRoleStore) GetByNames ¶

func (s *RetryLayerRoleStore) GetByNames(names []string) ([]*model.Role, error)

func (*RetryLayerRoleStore) PermanentDeleteAll ¶

func (s *RetryLayerRoleStore) PermanentDeleteAll() error

func (*RetryLayerRoleStore) Save ¶

func (s *RetryLayerRoleStore) Save(role *model.Role) (*model.Role, error)

type RetryLayerSchemeStore ¶

type RetryLayerSchemeStore struct {
	store.SchemeStore
	Root *RetryLayer
}

func (*RetryLayerSchemeStore) CountByScope ¶

func (s *RetryLayerSchemeStore) CountByScope(scope string) (int64, error)

func (*RetryLayerSchemeStore) CountWithoutPermission ¶

func (s *RetryLayerSchemeStore) CountWithoutPermission(scope string, permissionID string, roleScope model.RoleScope, roleType model.RoleType) (int64, error)

func (*RetryLayerSchemeStore) Delete ¶

func (s *RetryLayerSchemeStore) Delete(schemeID string) (*model.Scheme, error)

func (*RetryLayerSchemeStore) Get ¶

func (s *RetryLayerSchemeStore) Get(schemeID string) (*model.Scheme, error)

func (*RetryLayerSchemeStore) GetAllPage ¶

func (s *RetryLayerSchemeStore) GetAllPage(scope string, offset int, limit int) ([]*model.Scheme, error)

func (*RetryLayerSchemeStore) GetByName ¶

func (s *RetryLayerSchemeStore) GetByName(schemeName string) (*model.Scheme, error)

func (*RetryLayerSchemeStore) PermanentDeleteAll ¶

func (s *RetryLayerSchemeStore) PermanentDeleteAll() error

func (*RetryLayerSchemeStore) Save ¶

func (s *RetryLayerSchemeStore) Save(scheme *model.Scheme) (*model.Scheme, error)

type RetryLayerSessionStore ¶

type RetryLayerSessionStore struct {
	store.SessionStore
	Root *RetryLayer
}

func (*RetryLayerSessionStore) AnalyticsSessionCount ¶

func (s *RetryLayerSessionStore) AnalyticsSessionCount() (int64, error)

func (*RetryLayerSessionStore) Cleanup ¶

func (s *RetryLayerSessionStore) Cleanup(expiryTime int64, batchSize int64) error

func (*RetryLayerSessionStore) Get ¶

func (s *RetryLayerSessionStore) Get(ctx context.Context, sessionIDOrToken string) (*model.Session, error)

func (*RetryLayerSessionStore) GetLastSessionRowCreateAt ¶ added in v6.5.0

func (s *RetryLayerSessionStore) GetLastSessionRowCreateAt() (int64, error)

func (*RetryLayerSessionStore) GetSessions ¶

func (s *RetryLayerSessionStore) GetSessions(userID string) ([]*model.Session, error)

func (*RetryLayerSessionStore) GetSessionsExpired ¶

func (s *RetryLayerSessionStore) GetSessionsExpired(thresholdMillis int64, mobileOnly bool, unnotifiedOnly bool) ([]*model.Session, error)

func (*RetryLayerSessionStore) GetSessionsWithActiveDeviceIds ¶

func (s *RetryLayerSessionStore) GetSessionsWithActiveDeviceIds(userID string) ([]*model.Session, error)

func (*RetryLayerSessionStore) PermanentDeleteSessionsByUser ¶

func (s *RetryLayerSessionStore) PermanentDeleteSessionsByUser(teamID string) error

func (*RetryLayerSessionStore) Remove ¶

func (s *RetryLayerSessionStore) Remove(sessionIDOrToken string) error

func (*RetryLayerSessionStore) RemoveAllSessions ¶

func (s *RetryLayerSessionStore) RemoveAllSessions() error

func (*RetryLayerSessionStore) Save ¶

func (s *RetryLayerSessionStore) Save(session *model.Session) (*model.Session, error)

func (*RetryLayerSessionStore) UpdateDeviceId ¶

func (s *RetryLayerSessionStore) UpdateDeviceId(id string, deviceID string, expiresAt int64) (string, error)

func (*RetryLayerSessionStore) UpdateExpiredNotify ¶

func (s *RetryLayerSessionStore) UpdateExpiredNotify(sessionid string, notified bool) error

func (*RetryLayerSessionStore) UpdateExpiresAt ¶

func (s *RetryLayerSessionStore) UpdateExpiresAt(sessionID string, time int64) error

func (*RetryLayerSessionStore) UpdateLastActivityAt ¶

func (s *RetryLayerSessionStore) UpdateLastActivityAt(sessionID string, time int64) error

func (*RetryLayerSessionStore) UpdateProps ¶

func (s *RetryLayerSessionStore) UpdateProps(session *model.Session) error

func (*RetryLayerSessionStore) UpdateRoles ¶

func (s *RetryLayerSessionStore) UpdateRoles(userID string, roles string) (string, error)

type RetryLayerSharedChannelStore ¶

type RetryLayerSharedChannelStore struct {
	store.SharedChannelStore
	Root *RetryLayer
}

func (*RetryLayerSharedChannelStore) Delete ¶

func (s *RetryLayerSharedChannelStore) Delete(channelId string) (bool, error)

func (*RetryLayerSharedChannelStore) DeleteRemote ¶

func (s *RetryLayerSharedChannelStore) DeleteRemote(remoteId string) (bool, error)

func (*RetryLayerSharedChannelStore) Get ¶

func (s *RetryLayerSharedChannelStore) Get(channelId string) (*model.SharedChannel, error)

func (*RetryLayerSharedChannelStore) GetAll ¶

func (s *RetryLayerSharedChannelStore) GetAll(offset int, limit int, opts model.SharedChannelFilterOpts) ([]*model.SharedChannel, error)

func (*RetryLayerSharedChannelStore) GetAllCount ¶

func (s *RetryLayerSharedChannelStore) GetAllCount(opts model.SharedChannelFilterOpts) (int64, error)

func (*RetryLayerSharedChannelStore) GetAttachment ¶

func (s *RetryLayerSharedChannelStore) GetAttachment(fileId string, remoteId string) (*model.SharedChannelAttachment, error)

func (*RetryLayerSharedChannelStore) GetRemote ¶

func (s *RetryLayerSharedChannelStore) GetRemote(id string) (*model.SharedChannelRemote, error)

func (*RetryLayerSharedChannelStore) GetRemoteByIds ¶

func (s *RetryLayerSharedChannelStore) GetRemoteByIds(channelId string, remoteId string) (*model.SharedChannelRemote, error)

func (*RetryLayerSharedChannelStore) GetRemoteForUser ¶

func (s *RetryLayerSharedChannelStore) GetRemoteForUser(remoteId string, userId string) (*model.RemoteCluster, error)

func (*RetryLayerSharedChannelStore) GetRemotes ¶

func (s *RetryLayerSharedChannelStore) GetRemotes(opts model.SharedChannelRemoteFilterOpts) ([]*model.SharedChannelRemote, error)

func (*RetryLayerSharedChannelStore) GetRemotesStatus ¶

func (s *RetryLayerSharedChannelStore) GetRemotesStatus(channelId string) ([]*model.SharedChannelRemoteStatus, error)

func (*RetryLayerSharedChannelStore) GetSingleUser ¶

func (s *RetryLayerSharedChannelStore) GetSingleUser(userID string, channelID string, remoteID string) (*model.SharedChannelUser, error)

func (*RetryLayerSharedChannelStore) GetUsersForSync ¶

func (s *RetryLayerSharedChannelStore) GetUsersForSync(filter model.GetUsersForSyncFilter) ([]*model.User, error)

func (*RetryLayerSharedChannelStore) GetUsersForUser ¶

func (s *RetryLayerSharedChannelStore) GetUsersForUser(userID string) ([]*model.SharedChannelUser, error)

func (*RetryLayerSharedChannelStore) HasChannel ¶

func (s *RetryLayerSharedChannelStore) HasChannel(channelID string) (bool, error)

func (*RetryLayerSharedChannelStore) HasRemote ¶

func (s *RetryLayerSharedChannelStore) HasRemote(channelID string, remoteId string) (bool, error)

func (*RetryLayerSharedChannelStore) Save ¶

func (s *RetryLayerSharedChannelStore) Save(sc *model.SharedChannel) (*model.SharedChannel, error)

func (*RetryLayerSharedChannelStore) SaveAttachment ¶

func (s *RetryLayerSharedChannelStore) SaveAttachment(remote *model.SharedChannelAttachment) (*model.SharedChannelAttachment, error)

func (*RetryLayerSharedChannelStore) SaveRemote ¶

func (s *RetryLayerSharedChannelStore) SaveRemote(remote *model.SharedChannelRemote) (*model.SharedChannelRemote, error)

func (*RetryLayerSharedChannelStore) SaveUser ¶

func (s *RetryLayerSharedChannelStore) SaveUser(remote *model.SharedChannelUser) (*model.SharedChannelUser, error)

func (*RetryLayerSharedChannelStore) Update ¶

func (s *RetryLayerSharedChannelStore) Update(sc *model.SharedChannel) (*model.SharedChannel, error)

func (*RetryLayerSharedChannelStore) UpdateAttachmentLastSyncAt ¶

func (s *RetryLayerSharedChannelStore) UpdateAttachmentLastSyncAt(id string, syncTime int64) error

func (*RetryLayerSharedChannelStore) UpdateRemote ¶

func (s *RetryLayerSharedChannelStore) UpdateRemote(remote *model.SharedChannelRemote) (*model.SharedChannelRemote, error)

func (*RetryLayerSharedChannelStore) UpdateRemoteCursor ¶

func (s *RetryLayerSharedChannelStore) UpdateRemoteCursor(id string, cursor model.GetPostsSinceForSyncCursor) error

func (*RetryLayerSharedChannelStore) UpdateUserLastSyncAt ¶

func (s *RetryLayerSharedChannelStore) UpdateUserLastSyncAt(userID string, channelID string, remoteID string) error

func (*RetryLayerSharedChannelStore) UpsertAttachment ¶

func (s *RetryLayerSharedChannelStore) UpsertAttachment(remote *model.SharedChannelAttachment) (string, error)

type RetryLayerStatusStore ¶

type RetryLayerStatusStore struct {
	store.StatusStore
	Root *RetryLayer
}

func (*RetryLayerStatusStore) Get ¶

func (s *RetryLayerStatusStore) Get(userID string) (*model.Status, error)

func (*RetryLayerStatusStore) GetByIds ¶

func (s *RetryLayerStatusStore) GetByIds(userIds []string) ([]*model.Status, error)

func (*RetryLayerStatusStore) GetTotalActiveUsersCount ¶

func (s *RetryLayerStatusStore) GetTotalActiveUsersCount() (int64, error)

func (*RetryLayerStatusStore) ResetAll ¶

func (s *RetryLayerStatusStore) ResetAll() error

func (*RetryLayerStatusStore) SaveOrUpdate ¶

func (s *RetryLayerStatusStore) SaveOrUpdate(status *model.Status) error

func (*RetryLayerStatusStore) UpdateExpiredDNDStatuses ¶

func (s *RetryLayerStatusStore) UpdateExpiredDNDStatuses() ([]*model.Status, error)

func (*RetryLayerStatusStore) UpdateLastActivityAt ¶

func (s *RetryLayerStatusStore) UpdateLastActivityAt(userID string, lastActivityAt int64) error

type RetryLayerSystemStore ¶

type RetryLayerSystemStore struct {
	store.SystemStore
	Root *RetryLayer
}

func (*RetryLayerSystemStore) Get ¶

func (s *RetryLayerSystemStore) Get() (model.StringMap, error)

func (*RetryLayerSystemStore) GetByName ¶

func (s *RetryLayerSystemStore) GetByName(name string) (*model.System, error)

func (*RetryLayerSystemStore) InsertIfExists ¶

func (s *RetryLayerSystemStore) InsertIfExists(system *model.System) (*model.System, error)

func (*RetryLayerSystemStore) PermanentDeleteByName ¶

func (s *RetryLayerSystemStore) PermanentDeleteByName(name string) (*model.System, error)

func (*RetryLayerSystemStore) Save ¶

func (s *RetryLayerSystemStore) Save(system *model.System) error

func (*RetryLayerSystemStore) SaveOrUpdate ¶

func (s *RetryLayerSystemStore) SaveOrUpdate(system *model.System) error

func (*RetryLayerSystemStore) SaveOrUpdateWithWarnMetricHandling ¶

func (s *RetryLayerSystemStore) SaveOrUpdateWithWarnMetricHandling(system *model.System) error

func (*RetryLayerSystemStore) Update ¶

func (s *RetryLayerSystemStore) Update(system *model.System) error

type RetryLayerTeamStore ¶

type RetryLayerTeamStore struct {
	store.TeamStore
	Root *RetryLayer
}

func (*RetryLayerTeamStore) AnalyticsGetTeamCountForScheme ¶

func (s *RetryLayerTeamStore) AnalyticsGetTeamCountForScheme(schemeID string) (int64, error)

func (*RetryLayerTeamStore) AnalyticsTeamCount ¶

func (s *RetryLayerTeamStore) AnalyticsTeamCount(opts *model.TeamSearch) (int64, error)

func (*RetryLayerTeamStore) ClearAllCustomRoleAssignments ¶

func (s *RetryLayerTeamStore) ClearAllCustomRoleAssignments() error

func (*RetryLayerTeamStore) ClearCaches ¶

func (s *RetryLayerTeamStore) ClearCaches()

func (*RetryLayerTeamStore) Get ¶

func (s *RetryLayerTeamStore) Get(id string) (*model.Team, error)

func (*RetryLayerTeamStore) GetActiveMemberCount ¶

func (s *RetryLayerTeamStore) GetActiveMemberCount(teamID string, restrictions *model.ViewUsersRestrictions) (int64, error)

func (*RetryLayerTeamStore) GetAll ¶

func (s *RetryLayerTeamStore) GetAll() ([]*model.Team, error)

func (*RetryLayerTeamStore) GetAllForExportAfter ¶

func (s *RetryLayerTeamStore) GetAllForExportAfter(limit int, afterID string) ([]*model.TeamForExport, error)

func (*RetryLayerTeamStore) GetAllPage ¶

func (s *RetryLayerTeamStore) GetAllPage(offset int, limit int, opts *model.TeamSearch) ([]*model.Team, error)

func (*RetryLayerTeamStore) GetAllPrivateTeamListing ¶

func (s *RetryLayerTeamStore) GetAllPrivateTeamListing() ([]*model.Team, error)

func (*RetryLayerTeamStore) GetAllTeamListing ¶

func (s *RetryLayerTeamStore) GetAllTeamListing() ([]*model.Team, error)

func (*RetryLayerTeamStore) GetByInviteId ¶

func (s *RetryLayerTeamStore) GetByInviteId(inviteID string) (*model.Team, error)

func (*RetryLayerTeamStore) GetByName ¶

func (s *RetryLayerTeamStore) GetByName(name string) (*model.Team, error)

func (*RetryLayerTeamStore) GetByNames ¶

func (s *RetryLayerTeamStore) GetByNames(name []string) ([]*model.Team, error)

func (*RetryLayerTeamStore) GetChannelUnreadsForAllTeams ¶

func (s *RetryLayerTeamStore) GetChannelUnreadsForAllTeams(excludeTeamID string, userID string) ([]*model.ChannelUnread, error)

func (*RetryLayerTeamStore) GetChannelUnreadsForTeam ¶

func (s *RetryLayerTeamStore) GetChannelUnreadsForTeam(teamID string, userID string) ([]*model.ChannelUnread, error)

func (*RetryLayerTeamStore) GetCommonTeamIDsForTwoUsers ¶

func (s *RetryLayerTeamStore) GetCommonTeamIDsForTwoUsers(userID string, otherUserID string) ([]string, error)

func (*RetryLayerTeamStore) GetMember ¶

func (s *RetryLayerTeamStore) GetMember(ctx context.Context, teamID string, userID string) (*model.TeamMember, error)

func (*RetryLayerTeamStore) GetMembers ¶

func (s *RetryLayerTeamStore) GetMembers(teamID string, offset int, limit int, teamMembersGetOptions *model.TeamMembersGetOptions) ([]*model.TeamMember, error)

func (*RetryLayerTeamStore) GetMembersByIds ¶

func (s *RetryLayerTeamStore) GetMembersByIds(teamID string, userIds []string, restrictions *model.ViewUsersRestrictions) ([]*model.TeamMember, error)

func (*RetryLayerTeamStore) GetTeamMembersForExport ¶

func (s *RetryLayerTeamStore) GetTeamMembersForExport(userID string) ([]*model.TeamMemberForExport, error)

func (*RetryLayerTeamStore) GetTeamsByScheme ¶

func (s *RetryLayerTeamStore) GetTeamsByScheme(schemeID string, offset int, limit int) ([]*model.Team, error)

func (*RetryLayerTeamStore) GetTeamsByUserId ¶

func (s *RetryLayerTeamStore) GetTeamsByUserId(userID string) ([]*model.Team, error)

func (*RetryLayerTeamStore) GetTeamsForUser ¶

func (s *RetryLayerTeamStore) GetTeamsForUser(ctx context.Context, userID string) ([]*model.TeamMember, error)

func (*RetryLayerTeamStore) GetTeamsForUserWithPagination ¶

func (s *RetryLayerTeamStore) GetTeamsForUserWithPagination(userID string, page int, perPage int) ([]*model.TeamMember, error)

func (*RetryLayerTeamStore) GetTotalMemberCount ¶

func (s *RetryLayerTeamStore) GetTotalMemberCount(teamID string, restrictions *model.ViewUsersRestrictions) (int64, error)

func (*RetryLayerTeamStore) GetUserTeamIds ¶

func (s *RetryLayerTeamStore) GetUserTeamIds(userID string, allowFromCache bool) ([]string, error)

func (*RetryLayerTeamStore) GroupSyncedTeamCount ¶

func (s *RetryLayerTeamStore) GroupSyncedTeamCount() (int64, error)

func (*RetryLayerTeamStore) InvalidateAllTeamIdsForUser ¶

func (s *RetryLayerTeamStore) InvalidateAllTeamIdsForUser(userID string)

func (*RetryLayerTeamStore) MigrateTeamMembers ¶

func (s *RetryLayerTeamStore) MigrateTeamMembers(fromTeamID string, fromUserID string) (map[string]string, error)

func (*RetryLayerTeamStore) PermanentDelete ¶

func (s *RetryLayerTeamStore) PermanentDelete(teamID string) error

func (*RetryLayerTeamStore) RemoveAllMembersByTeam ¶

func (s *RetryLayerTeamStore) RemoveAllMembersByTeam(teamID string) error

func (*RetryLayerTeamStore) RemoveAllMembersByUser ¶

func (s *RetryLayerTeamStore) RemoveAllMembersByUser(userID string) error

func (*RetryLayerTeamStore) RemoveMember ¶

func (s *RetryLayerTeamStore) RemoveMember(teamID string, userID string) error

func (*RetryLayerTeamStore) RemoveMembers ¶

func (s *RetryLayerTeamStore) RemoveMembers(teamID string, userIds []string) error

func (*RetryLayerTeamStore) ResetAllTeamSchemes ¶

func (s *RetryLayerTeamStore) ResetAllTeamSchemes() error

func (*RetryLayerTeamStore) Save ¶

func (s *RetryLayerTeamStore) Save(team *model.Team) (*model.Team, error)

func (*RetryLayerTeamStore) SaveMember ¶

func (s *RetryLayerTeamStore) SaveMember(member *model.TeamMember, maxUsersPerTeam int) (*model.TeamMember, error)

func (*RetryLayerTeamStore) SaveMultipleMembers ¶

func (s *RetryLayerTeamStore) SaveMultipleMembers(members []*model.TeamMember, maxUsersPerTeam int) ([]*model.TeamMember, error)

func (*RetryLayerTeamStore) SearchAll ¶

func (s *RetryLayerTeamStore) SearchAll(opts *model.TeamSearch) ([]*model.Team, error)

func (*RetryLayerTeamStore) SearchAllPaged ¶

func (s *RetryLayerTeamStore) SearchAllPaged(opts *model.TeamSearch) ([]*model.Team, int64, error)

func (*RetryLayerTeamStore) SearchOpen ¶

func (s *RetryLayerTeamStore) SearchOpen(opts *model.TeamSearch) ([]*model.Team, error)

func (*RetryLayerTeamStore) SearchPrivate ¶

func (s *RetryLayerTeamStore) SearchPrivate(opts *model.TeamSearch) ([]*model.Team, error)

func (*RetryLayerTeamStore) Update ¶

func (s *RetryLayerTeamStore) Update(team *model.Team) (*model.Team, error)

func (*RetryLayerTeamStore) UpdateLastTeamIconUpdate ¶

func (s *RetryLayerTeamStore) UpdateLastTeamIconUpdate(teamID string, curTime int64) error

func (*RetryLayerTeamStore) UpdateMember ¶

func (s *RetryLayerTeamStore) UpdateMember(member *model.TeamMember) (*model.TeamMember, error)

func (*RetryLayerTeamStore) UpdateMembersRole ¶

func (s *RetryLayerTeamStore) UpdateMembersRole(teamID string, userIDs []string) error

func (*RetryLayerTeamStore) UpdateMultipleMembers ¶

func (s *RetryLayerTeamStore) UpdateMultipleMembers(members []*model.TeamMember) ([]*model.TeamMember, error)

func (*RetryLayerTeamStore) UserBelongsToTeams ¶

func (s *RetryLayerTeamStore) UserBelongsToTeams(userID string, teamIds []string) (bool, error)

type RetryLayerTermsOfServiceStore ¶

type RetryLayerTermsOfServiceStore struct {
	store.TermsOfServiceStore
	Root *RetryLayer
}

func (*RetryLayerTermsOfServiceStore) Get ¶

func (s *RetryLayerTermsOfServiceStore) Get(id string, allowFromCache bool) (*model.TermsOfService, error)

func (*RetryLayerTermsOfServiceStore) GetLatest ¶

func (s *RetryLayerTermsOfServiceStore) GetLatest(allowFromCache bool) (*model.TermsOfService, error)

func (*RetryLayerTermsOfServiceStore) Save ¶

func (s *RetryLayerTermsOfServiceStore) Save(termsOfService *model.TermsOfService) (*model.TermsOfService, error)

type RetryLayerThreadStore ¶

type RetryLayerThreadStore struct {
	store.ThreadStore
	Root *RetryLayer
}

func (*RetryLayerThreadStore) DeleteMembershipForUser ¶

func (s *RetryLayerThreadStore) DeleteMembershipForUser(userId string, postID string) error

func (*RetryLayerThreadStore) DeleteOrphanedRows ¶

func (s *RetryLayerThreadStore) DeleteOrphanedRows(limit int) (int64, error)

func (*RetryLayerThreadStore) Get ¶

func (s *RetryLayerThreadStore) Get(id string) (*model.Thread, error)

func (*RetryLayerThreadStore) GetMembershipForUser ¶

func (s *RetryLayerThreadStore) GetMembershipForUser(userId string, postID string) (*model.ThreadMembership, error)

func (*RetryLayerThreadStore) GetMembershipsForUser ¶

func (s *RetryLayerThreadStore) GetMembershipsForUser(userId string, teamID string) ([]*model.ThreadMembership, error)

func (*RetryLayerThreadStore) GetPosts ¶

func (s *RetryLayerThreadStore) GetPosts(threadID string, since int64) ([]*model.Post, error)

func (*RetryLayerThreadStore) GetTeamsUnreadForUser ¶ added in v6.5.0

func (s *RetryLayerThreadStore) GetTeamsUnreadForUser(userID string, teamIDs []string) (map[string]*model.TeamUnread, error)

func (*RetryLayerThreadStore) GetThreadFollowers ¶

func (s *RetryLayerThreadStore) GetThreadFollowers(threadID string, fetchOnlyActive bool) ([]string, error)

func (*RetryLayerThreadStore) GetThreadForUser ¶

func (s *RetryLayerThreadStore) GetThreadForUser(teamID string, threadMembership *model.ThreadMembership, extended bool) (*model.ThreadResponse, error)

func (*RetryLayerThreadStore) GetThreadUnreadReplyCount ¶ added in v6.5.0

func (s *RetryLayerThreadStore) GetThreadUnreadReplyCount(threadMembership *model.ThreadMembership) (int64, error)

func (*RetryLayerThreadStore) GetThreadsForUser ¶

func (s *RetryLayerThreadStore) GetThreadsForUser(userId string, teamID string, opts model.GetUserThreadsOpts) (*model.Threads, error)

func (*RetryLayerThreadStore) MaintainMembership ¶

func (s *RetryLayerThreadStore) MaintainMembership(userID string, postID string, opts store.ThreadMembershipOpts) (*model.ThreadMembership, error)

func (*RetryLayerThreadStore) MarkAllAsRead ¶

func (s *RetryLayerThreadStore) MarkAllAsRead(userID string, threadIds []string) error

func (*RetryLayerThreadStore) MarkAllAsReadByChannels ¶ added in v6.5.0

func (s *RetryLayerThreadStore) MarkAllAsReadByChannels(userID string, channelIDs []string) error

func (*RetryLayerThreadStore) MarkAllAsReadByTeam ¶ added in v6.5.0

func (s *RetryLayerThreadStore) MarkAllAsReadByTeam(userID string, teamID string) error

func (*RetryLayerThreadStore) MarkAsRead ¶

func (s *RetryLayerThreadStore) MarkAsRead(userID string, threadID string, timestamp int64) error

func (*RetryLayerThreadStore) PermanentDeleteBatchForRetentionPolicies ¶

func (s *RetryLayerThreadStore) PermanentDeleteBatchForRetentionPolicies(now int64, globalPolicyEndTime int64, limit int64, cursor model.RetentionPolicyCursor) (int64, model.RetentionPolicyCursor, error)

func (*RetryLayerThreadStore) PermanentDeleteBatchThreadMembershipsForRetentionPolicies ¶

func (s *RetryLayerThreadStore) PermanentDeleteBatchThreadMembershipsForRetentionPolicies(now int64, globalPolicyEndTime int64, limit int64, cursor model.RetentionPolicyCursor) (int64, model.RetentionPolicyCursor, error)

func (*RetryLayerThreadStore) UpdateMembership ¶

func (s *RetryLayerThreadStore) UpdateMembership(membership *model.ThreadMembership) (*model.ThreadMembership, error)

type RetryLayerTokenStore ¶

type RetryLayerTokenStore struct {
	store.TokenStore
	Root *RetryLayer
}

func (*RetryLayerTokenStore) Cleanup ¶

func (s *RetryLayerTokenStore) Cleanup(expiryTime int64)

func (*RetryLayerTokenStore) Delete ¶

func (s *RetryLayerTokenStore) Delete(token string) error

func (*RetryLayerTokenStore) GetAllTokensByType ¶

func (s *RetryLayerTokenStore) GetAllTokensByType(tokenType string) ([]*model.Token, error)

func (*RetryLayerTokenStore) GetByToken ¶

func (s *RetryLayerTokenStore) GetByToken(token string) (*model.Token, error)

func (*RetryLayerTokenStore) RemoveAllTokensByType ¶

func (s *RetryLayerTokenStore) RemoveAllTokensByType(tokenType string) error

func (*RetryLayerTokenStore) Save ¶

func (s *RetryLayerTokenStore) Save(recovery *model.Token) error

type RetryLayerUploadSessionStore ¶

type RetryLayerUploadSessionStore struct {
	store.UploadSessionStore
	Root *RetryLayer
}

func (*RetryLayerUploadSessionStore) Delete ¶

func (s *RetryLayerUploadSessionStore) Delete(id string) error

func (*RetryLayerUploadSessionStore) Get ¶

func (s *RetryLayerUploadSessionStore) Get(id string) (*model.UploadSession, error)

func (*RetryLayerUploadSessionStore) GetForUser ¶

func (s *RetryLayerUploadSessionStore) GetForUser(userID string) ([]*model.UploadSession, error)

func (*RetryLayerUploadSessionStore) Save ¶

func (s *RetryLayerUploadSessionStore) Save(session *model.UploadSession) (*model.UploadSession, error)

func (*RetryLayerUploadSessionStore) Update ¶

func (s *RetryLayerUploadSessionStore) Update(session *model.UploadSession) error

type RetryLayerUserAccessTokenStore ¶

type RetryLayerUserAccessTokenStore struct {
	store.UserAccessTokenStore
	Root *RetryLayer
}

func (*RetryLayerUserAccessTokenStore) Delete ¶

func (s *RetryLayerUserAccessTokenStore) Delete(tokenID string) error

func (*RetryLayerUserAccessTokenStore) DeleteAllForUser ¶

func (s *RetryLayerUserAccessTokenStore) DeleteAllForUser(userID string) error

func (*RetryLayerUserAccessTokenStore) Get ¶

func (s *RetryLayerUserAccessTokenStore) Get(tokenID string) (*model.UserAccessToken, error)

func (*RetryLayerUserAccessTokenStore) GetAll ¶

func (s *RetryLayerUserAccessTokenStore) GetAll(offset int, limit int) ([]*model.UserAccessToken, error)

func (*RetryLayerUserAccessTokenStore) GetByToken ¶

func (s *RetryLayerUserAccessTokenStore) GetByToken(tokenString string) (*model.UserAccessToken, error)

func (*RetryLayerUserAccessTokenStore) GetByUser ¶

func (s *RetryLayerUserAccessTokenStore) GetByUser(userID string, page int, perPage int) ([]*model.UserAccessToken, error)

func (*RetryLayerUserAccessTokenStore) Save ¶

func (s *RetryLayerUserAccessTokenStore) Save(token *model.UserAccessToken) (*model.UserAccessToken, error)

func (*RetryLayerUserAccessTokenStore) Search ¶

func (s *RetryLayerUserAccessTokenStore) Search(term string) ([]*model.UserAccessToken, error)

func (*RetryLayerUserAccessTokenStore) UpdateTokenDisable ¶

func (s *RetryLayerUserAccessTokenStore) UpdateTokenDisable(tokenID string) error

func (*RetryLayerUserAccessTokenStore) UpdateTokenEnable ¶

func (s *RetryLayerUserAccessTokenStore) UpdateTokenEnable(tokenID string) error

type RetryLayerUserStore ¶

type RetryLayerUserStore struct {
	store.UserStore
	Root *RetryLayer
}

func (*RetryLayerUserStore) AnalyticsActiveCount ¶

func (s *RetryLayerUserStore) AnalyticsActiveCount(time int64, options model.UserCountOptions) (int64, error)

func (*RetryLayerUserStore) AnalyticsActiveCountForPeriod ¶

func (s *RetryLayerUserStore) AnalyticsActiveCountForPeriod(startTime int64, endTime int64, options model.UserCountOptions) (int64, error)

func (*RetryLayerUserStore) AnalyticsGetExternalUsers ¶

func (s *RetryLayerUserStore) AnalyticsGetExternalUsers(hostDomain string) (bool, error)

func (*RetryLayerUserStore) AnalyticsGetGuestCount ¶

func (s *RetryLayerUserStore) AnalyticsGetGuestCount() (int64, error)

func (*RetryLayerUserStore) AnalyticsGetInactiveUsersCount ¶

func (s *RetryLayerUserStore) AnalyticsGetInactiveUsersCount() (int64, error)

func (*RetryLayerUserStore) AnalyticsGetSystemAdminCount ¶

func (s *RetryLayerUserStore) AnalyticsGetSystemAdminCount() (int64, error)

func (*RetryLayerUserStore) AutocompleteUsersInChannel ¶

func (s *RetryLayerUserStore) AutocompleteUsersInChannel(teamID string, channelID string, term string, options *model.UserSearchOptions) (*model.UserAutocompleteInChannel, error)

func (*RetryLayerUserStore) ClearAllCustomRoleAssignments ¶

func (s *RetryLayerUserStore) ClearAllCustomRoleAssignments() error

func (*RetryLayerUserStore) ClearCaches ¶

func (s *RetryLayerUserStore) ClearCaches()

func (*RetryLayerUserStore) Count ¶

func (s *RetryLayerUserStore) Count(options model.UserCountOptions) (int64, error)

func (*RetryLayerUserStore) DeactivateGuests ¶

func (s *RetryLayerUserStore) DeactivateGuests() ([]string, error)

func (*RetryLayerUserStore) DemoteUserToGuest ¶

func (s *RetryLayerUserStore) DemoteUserToGuest(userID string) (*model.User, error)

func (*RetryLayerUserStore) Get ¶

func (s *RetryLayerUserStore) Get(ctx context.Context, id string) (*model.User, error)

func (*RetryLayerUserStore) GetAll ¶

func (s *RetryLayerUserStore) GetAll() ([]*model.User, error)

func (*RetryLayerUserStore) GetAllAfter ¶

func (s *RetryLayerUserStore) GetAllAfter(limit int, afterID string) ([]*model.User, error)

func (*RetryLayerUserStore) GetAllNotInAuthService ¶

func (s *RetryLayerUserStore) GetAllNotInAuthService(authServices []string) ([]*model.User, error)

func (*RetryLayerUserStore) GetAllProfiles ¶

func (s *RetryLayerUserStore) GetAllProfiles(options *model.UserGetOptions) ([]*model.User, error)

func (*RetryLayerUserStore) GetAllProfilesInChannel ¶

func (s *RetryLayerUserStore) GetAllProfilesInChannel(ctx context.Context, channelID string, allowFromCache bool) (map[string]*model.User, error)

func (*RetryLayerUserStore) GetAllUsingAuthService ¶

func (s *RetryLayerUserStore) GetAllUsingAuthService(authService string) ([]*model.User, error)

func (*RetryLayerUserStore) GetAnyUnreadPostCountForChannel ¶

func (s *RetryLayerUserStore) GetAnyUnreadPostCountForChannel(userID string, channelID string) (int64, error)

func (*RetryLayerUserStore) GetByAuth ¶

func (s *RetryLayerUserStore) GetByAuth(authData *string, authService string) (*model.User, error)

func (*RetryLayerUserStore) GetByEmail ¶

func (s *RetryLayerUserStore) GetByEmail(email string) (*model.User, error)

func (*RetryLayerUserStore) GetByUsername ¶

func (s *RetryLayerUserStore) GetByUsername(username string) (*model.User, error)

func (*RetryLayerUserStore) GetChannelGroupUsers ¶

func (s *RetryLayerUserStore) GetChannelGroupUsers(channelID string) ([]*model.User, error)

func (*RetryLayerUserStore) GetEtagForAllProfiles ¶

func (s *RetryLayerUserStore) GetEtagForAllProfiles() string

func (*RetryLayerUserStore) GetEtagForProfiles ¶

func (s *RetryLayerUserStore) GetEtagForProfiles(teamID string) string

func (*RetryLayerUserStore) GetEtagForProfilesNotInTeam ¶

func (s *RetryLayerUserStore) GetEtagForProfilesNotInTeam(teamID string) string

func (*RetryLayerUserStore) GetForLogin ¶

func (s *RetryLayerUserStore) GetForLogin(loginID string, allowSignInWithUsername bool, allowSignInWithEmail bool) (*model.User, error)

func (*RetryLayerUserStore) GetKnownUsers ¶

func (s *RetryLayerUserStore) GetKnownUsers(userID string) ([]string, error)

func (*RetryLayerUserStore) GetMany ¶

func (s *RetryLayerUserStore) GetMany(ctx context.Context, ids []string) ([]*model.User, error)

func (*RetryLayerUserStore) GetNewUsersForTeam ¶

func (s *RetryLayerUserStore) GetNewUsersForTeam(teamID string, offset int, limit int, viewRestrictions *model.ViewUsersRestrictions) ([]*model.User, error)

func (*RetryLayerUserStore) GetProfileByGroupChannelIdsForUser ¶

func (s *RetryLayerUserStore) GetProfileByGroupChannelIdsForUser(userID string, channelIds []string) (map[string][]*model.User, error)

func (*RetryLayerUserStore) GetProfileByIds ¶

func (s *RetryLayerUserStore) GetProfileByIds(ctx context.Context, userIds []string, options *store.UserGetByIdsOpts, allowFromCache bool) ([]*model.User, error)

func (*RetryLayerUserStore) GetProfiles ¶

func (s *RetryLayerUserStore) GetProfiles(options *model.UserGetOptions) ([]*model.User, error)

func (*RetryLayerUserStore) GetProfilesByUsernames ¶

func (s *RetryLayerUserStore) GetProfilesByUsernames(usernames []string, viewRestrictions *model.ViewUsersRestrictions) ([]*model.User, error)

func (*RetryLayerUserStore) GetProfilesInChannel ¶

func (s *RetryLayerUserStore) GetProfilesInChannel(options *model.UserGetOptions) ([]*model.User, error)

func (*RetryLayerUserStore) GetProfilesInChannelByStatus ¶

func (s *RetryLayerUserStore) GetProfilesInChannelByStatus(options *model.UserGetOptions) ([]*model.User, error)

func (*RetryLayerUserStore) GetProfilesNotInChannel ¶

func (s *RetryLayerUserStore) GetProfilesNotInChannel(teamID string, channelId string, groupConstrained bool, offset int, limit int, viewRestrictions *model.ViewUsersRestrictions) ([]*model.User, error)

func (*RetryLayerUserStore) GetProfilesNotInTeam ¶

func (s *RetryLayerUserStore) GetProfilesNotInTeam(teamID string, groupConstrained bool, offset int, limit int, viewRestrictions *model.ViewUsersRestrictions) ([]*model.User, error)

func (*RetryLayerUserStore) GetProfilesWithoutTeam ¶

func (s *RetryLayerUserStore) GetProfilesWithoutTeam(options *model.UserGetOptions) ([]*model.User, error)

func (*RetryLayerUserStore) GetRecentlyActiveUsersForTeam ¶

func (s *RetryLayerUserStore) GetRecentlyActiveUsersForTeam(teamID string, offset int, limit int, viewRestrictions *model.ViewUsersRestrictions) ([]*model.User, error)

func (*RetryLayerUserStore) GetSystemAdminProfiles ¶

func (s *RetryLayerUserStore) GetSystemAdminProfiles() (map[string]*model.User, error)

func (*RetryLayerUserStore) GetTeamGroupUsers ¶

func (s *RetryLayerUserStore) GetTeamGroupUsers(teamID string) ([]*model.User, error)

func (*RetryLayerUserStore) GetUnreadCount ¶

func (s *RetryLayerUserStore) GetUnreadCount(userID string) (int64, error)

func (*RetryLayerUserStore) GetUnreadCountForChannel ¶

func (s *RetryLayerUserStore) GetUnreadCountForChannel(userID string, channelID string) (int64, error)

func (*RetryLayerUserStore) GetUsersBatchForIndexing ¶

func (s *RetryLayerUserStore) GetUsersBatchForIndexing(startTime int64, endTime int64, limit int) ([]*model.UserForIndexing, error)

func (*RetryLayerUserStore) GetUsersWithInvalidEmails ¶ added in v6.5.0

func (s *RetryLayerUserStore) GetUsersWithInvalidEmails(page int, perPage int, restrictedDomains string) ([]*model.User, error)

func (*RetryLayerUserStore) InferSystemInstallDate ¶

func (s *RetryLayerUserStore) InferSystemInstallDate() (int64, error)

func (*RetryLayerUserStore) InsertUsers ¶ added in v6.5.0

func (s *RetryLayerUserStore) InsertUsers(users []*model.User) error

func (*RetryLayerUserStore) InvalidateProfileCacheForUser ¶

func (s *RetryLayerUserStore) InvalidateProfileCacheForUser(userID string)

func (*RetryLayerUserStore) InvalidateProfilesInChannelCache ¶

func (s *RetryLayerUserStore) InvalidateProfilesInChannelCache(channelID string)

func (*RetryLayerUserStore) InvalidateProfilesInChannelCacheByUser ¶

func (s *RetryLayerUserStore) InvalidateProfilesInChannelCacheByUser(userID string)

func (*RetryLayerUserStore) IsEmpty ¶

func (s *RetryLayerUserStore) IsEmpty(excludeBots bool) (bool, error)

func (*RetryLayerUserStore) PermanentDelete ¶

func (s *RetryLayerUserStore) PermanentDelete(userID string) error

func (*RetryLayerUserStore) PromoteGuestToUser ¶

func (s *RetryLayerUserStore) PromoteGuestToUser(userID string) error

func (*RetryLayerUserStore) ResetAuthDataToEmailForUsers ¶

func (s *RetryLayerUserStore) ResetAuthDataToEmailForUsers(service string, userIDs []string, includeDeleted bool, dryRun bool) (int, error)

func (*RetryLayerUserStore) ResetLastPictureUpdate ¶

func (s *RetryLayerUserStore) ResetLastPictureUpdate(userID string) error

func (*RetryLayerUserStore) Save ¶

func (s *RetryLayerUserStore) Save(user *model.User) (*model.User, error)

func (*RetryLayerUserStore) Search ¶

func (s *RetryLayerUserStore) Search(teamID string, term string, options *model.UserSearchOptions) ([]*model.User, error)

func (*RetryLayerUserStore) SearchInChannel ¶

func (s *RetryLayerUserStore) SearchInChannel(channelID string, term string, options *model.UserSearchOptions) ([]*model.User, error)

func (*RetryLayerUserStore) SearchInGroup ¶

func (s *RetryLayerUserStore) SearchInGroup(groupID string, term string, options *model.UserSearchOptions) ([]*model.User, error)

func (*RetryLayerUserStore) SearchNotInChannel ¶

func (s *RetryLayerUserStore) SearchNotInChannel(teamID string, channelID string, term string, options *model.UserSearchOptions) ([]*model.User, error)

func (*RetryLayerUserStore) SearchNotInGroup ¶ added in v6.5.0

func (s *RetryLayerUserStore) SearchNotInGroup(groupID string, term string, options *model.UserSearchOptions) ([]*model.User, error)

func (*RetryLayerUserStore) SearchNotInTeam ¶

func (s *RetryLayerUserStore) SearchNotInTeam(notInTeamID string, term string, options *model.UserSearchOptions) ([]*model.User, error)

func (*RetryLayerUserStore) SearchWithoutTeam ¶

func (s *RetryLayerUserStore) SearchWithoutTeam(term string, options *model.UserSearchOptions) ([]*model.User, error)

func (*RetryLayerUserStore) Update ¶

func (s *RetryLayerUserStore) Update(user *model.User, allowRoleUpdate bool) (*model.UserUpdate, error)

func (*RetryLayerUserStore) UpdateAuthData ¶

func (s *RetryLayerUserStore) UpdateAuthData(userID string, service string, authData *string, email string, resetMfa bool) (string, error)

func (*RetryLayerUserStore) UpdateFailedPasswordAttempts ¶

func (s *RetryLayerUserStore) UpdateFailedPasswordAttempts(userID string, attempts int) error

func (*RetryLayerUserStore) UpdateLastPictureUpdate ¶

func (s *RetryLayerUserStore) UpdateLastPictureUpdate(userID string) error

func (*RetryLayerUserStore) UpdateMfaActive ¶

func (s *RetryLayerUserStore) UpdateMfaActive(userID string, active bool) error

func (*RetryLayerUserStore) UpdateMfaSecret ¶

func (s *RetryLayerUserStore) UpdateMfaSecret(userID string, secret string) error

func (*RetryLayerUserStore) UpdateNotifyProps ¶

func (s *RetryLayerUserStore) UpdateNotifyProps(userID string, props map[string]string) error

func (*RetryLayerUserStore) UpdatePassword ¶

func (s *RetryLayerUserStore) UpdatePassword(userID string, newPassword string) error

func (*RetryLayerUserStore) UpdateUpdateAt ¶

func (s *RetryLayerUserStore) UpdateUpdateAt(userID string) (int64, error)

func (*RetryLayerUserStore) VerifyEmail ¶

func (s *RetryLayerUserStore) VerifyEmail(userID string, email string) (string, error)

type RetryLayerUserTermsOfServiceStore ¶

type RetryLayerUserTermsOfServiceStore struct {
	store.UserTermsOfServiceStore
	Root *RetryLayer
}

func (*RetryLayerUserTermsOfServiceStore) Delete ¶

func (s *RetryLayerUserTermsOfServiceStore) Delete(userID string, termsOfServiceId string) error

func (*RetryLayerUserTermsOfServiceStore) GetByUser ¶

func (s *RetryLayerUserTermsOfServiceStore) GetByUser(userID string) (*model.UserTermsOfService, error)

func (*RetryLayerUserTermsOfServiceStore) Save ¶

func (s *RetryLayerUserTermsOfServiceStore) Save(userTermsOfService *model.UserTermsOfService) (*model.UserTermsOfService, error)

type RetryLayerWebhookStore ¶

type RetryLayerWebhookStore struct {
	store.WebhookStore
	Root *RetryLayer
}

func (*RetryLayerWebhookStore) AnalyticsIncomingCount ¶

func (s *RetryLayerWebhookStore) AnalyticsIncomingCount(teamID string) (int64, error)

func (*RetryLayerWebhookStore) AnalyticsOutgoingCount ¶

func (s *RetryLayerWebhookStore) AnalyticsOutgoingCount(teamID string) (int64, error)

func (*RetryLayerWebhookStore) ClearCaches ¶

func (s *RetryLayerWebhookStore) ClearCaches()

func (*RetryLayerWebhookStore) DeleteIncoming ¶

func (s *RetryLayerWebhookStore) DeleteIncoming(webhookID string, time int64) error

func (*RetryLayerWebhookStore) DeleteOutgoing ¶

func (s *RetryLayerWebhookStore) DeleteOutgoing(webhookID string, time int64) error

func (*RetryLayerWebhookStore) GetIncoming ¶

func (s *RetryLayerWebhookStore) GetIncoming(id string, allowFromCache bool) (*model.IncomingWebhook, error)

func (*RetryLayerWebhookStore) GetIncomingByChannel ¶

func (s *RetryLayerWebhookStore) GetIncomingByChannel(channelID string) ([]*model.IncomingWebhook, error)

func (*RetryLayerWebhookStore) GetIncomingByTeam ¶

func (s *RetryLayerWebhookStore) GetIncomingByTeam(teamID string, offset int, limit int) ([]*model.IncomingWebhook, error)

func (*RetryLayerWebhookStore) GetIncomingByTeamByUser ¶

func (s *RetryLayerWebhookStore) GetIncomingByTeamByUser(teamID string, userID string, offset int, limit int) ([]*model.IncomingWebhook, error)

func (*RetryLayerWebhookStore) GetIncomingList ¶

func (s *RetryLayerWebhookStore) GetIncomingList(offset int, limit int) ([]*model.IncomingWebhook, error)

func (*RetryLayerWebhookStore) GetIncomingListByUser ¶

func (s *RetryLayerWebhookStore) GetIncomingListByUser(userID string, offset int, limit int) ([]*model.IncomingWebhook, error)

func (*RetryLayerWebhookStore) GetOutgoing ¶

func (s *RetryLayerWebhookStore) GetOutgoing(id string) (*model.OutgoingWebhook, error)

func (*RetryLayerWebhookStore) GetOutgoingByChannel ¶

func (s *RetryLayerWebhookStore) GetOutgoingByChannel(channelID string, offset int, limit int) ([]*model.OutgoingWebhook, error)

func (*RetryLayerWebhookStore) GetOutgoingByChannelByUser ¶

func (s *RetryLayerWebhookStore) GetOutgoingByChannelByUser(channelID string, userID string, offset int, limit int) ([]*model.OutgoingWebhook, error)

func (*RetryLayerWebhookStore) GetOutgoingByTeam ¶

func (s *RetryLayerWebhookStore) GetOutgoingByTeam(teamID string, offset int, limit int) ([]*model.OutgoingWebhook, error)

func (*RetryLayerWebhookStore) GetOutgoingByTeamByUser ¶

func (s *RetryLayerWebhookStore) GetOutgoingByTeamByUser(teamID string, userID string, offset int, limit int) ([]*model.OutgoingWebhook, error)

func (*RetryLayerWebhookStore) GetOutgoingList ¶

func (s *RetryLayerWebhookStore) GetOutgoingList(offset int, limit int) ([]*model.OutgoingWebhook, error)

func (*RetryLayerWebhookStore) GetOutgoingListByUser ¶

func (s *RetryLayerWebhookStore) GetOutgoingListByUser(userID string, offset int, limit int) ([]*model.OutgoingWebhook, error)

func (*RetryLayerWebhookStore) InvalidateWebhookCache ¶

func (s *RetryLayerWebhookStore) InvalidateWebhookCache(webhook string)

func (*RetryLayerWebhookStore) PermanentDeleteIncomingByChannel ¶

func (s *RetryLayerWebhookStore) PermanentDeleteIncomingByChannel(channelID string) error

func (*RetryLayerWebhookStore) PermanentDeleteIncomingByUser ¶

func (s *RetryLayerWebhookStore) PermanentDeleteIncomingByUser(userID string) error

func (*RetryLayerWebhookStore) PermanentDeleteOutgoingByChannel ¶

func (s *RetryLayerWebhookStore) PermanentDeleteOutgoingByChannel(channelID string) error

func (*RetryLayerWebhookStore) PermanentDeleteOutgoingByUser ¶

func (s *RetryLayerWebhookStore) PermanentDeleteOutgoingByUser(userID string) error

func (*RetryLayerWebhookStore) SaveIncoming ¶

func (s *RetryLayerWebhookStore) SaveIncoming(webhook *model.IncomingWebhook) (*model.IncomingWebhook, error)

func (*RetryLayerWebhookStore) SaveOutgoing ¶

func (s *RetryLayerWebhookStore) SaveOutgoing(webhook *model.OutgoingWebhook) (*model.OutgoingWebhook, error)

func (*RetryLayerWebhookStore) UpdateIncoming ¶

func (s *RetryLayerWebhookStore) UpdateIncoming(webhook *model.IncomingWebhook) (*model.IncomingWebhook, error)

func (*RetryLayerWebhookStore) UpdateOutgoing ¶

func (s *RetryLayerWebhookStore) UpdateOutgoing(hook *model.OutgoingWebhook) (*model.OutgoingWebhook, error)

Source Files ¶

View all Source files

retrylayer.go

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL