Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

retrylayer

package

Go to main page

Versions in this module

v5

v5.33.2

Jul 13, 2021

v5.33.1

Jul 13, 2021

v5.33.0

Jul 13, 2021

Changes in this version

+ type RetryLayer struct

+ AuditStore store.AuditStore

+ BotStore store.BotStore

+ ChannelMemberHistoryStore store.ChannelMemberHistoryStore

+ ChannelStore store.ChannelStore

+ 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

+ RoleStore store.RoleStore

+ SchemeStore store.SchemeStore

+ SessionStore store.SessionStore

+ StatusStore store.StatusStore

+ SystemStore store.SystemStore

+ TeamStore store.TeamStore

+ TermsOfServiceStore store.TermsOfServiceStore

+ ThreadStore store.ThreadStore

+ TokenStore store.TokenStore

+ UploadSessionStore store.UploadSessionStore

+ UserAccessTokenStore store.UserAccessTokenStore

+ UserStore store.UserStore

+ UserTermsOfServiceStore store.UserTermsOfServiceStore

+ WebhookStore store.WebhookStore

+ 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) 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) 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 struct

+ Root *RetryLayer

+ 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 struct

+ Root *RetryLayer

+ 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 struct

+ Root *RetryLayer

+ 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)

+ type RetryLayerChannelStore struct

+ Root *RetryLayer

+ func (s *RetryLayerChannelStore) AnalyticsDeletedTypeCount(teamId string, channelType string) (int64, error)

+ func (s *RetryLayerChannelStore) AnalyticsTypeCount(teamId string, channelType string) (int64, error)

+ func (s *RetryLayerChannelStore) AutocompleteInTeam(teamId 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, error)

+ func (s *RetryLayerChannelStore) CreateDirectChannel(userId *model.User, otherUserId *model.User) (*model.Channel, error)

+ func (s *RetryLayerChannelStore) CreateInitialSidebarCategories(userId string, teamId string) 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) 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, includeDeleted bool, lastDeleteAt int) (*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) 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(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(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) GetMembersForUserWithPagination(teamId string, userId string, page int, perPage int) (*model.ChannelMembers, 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) GroupSyncedChannelCount() (int64, error)

+ func (s *RetryLayerChannelStore) IncrementMentionCount(channelId string, userId string, updateThreads 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) MigratePublicChannels() 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) Update(channel *model.Channel) (*model.Channel, error)

+ func (s *RetryLayerChannelStore) UpdateLastViewedAt(channelIds []string, userId string, updateThreads bool) (map[string]int64, error)

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

+ func (s *RetryLayerChannelStore) UpdateMember(member *model.ChannelMember) (*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 struct

+ Root *RetryLayer

+ 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 struct

+ Root *RetryLayer

+ 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 struct

+ Root *RetryLayer

+ 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 struct

+ Root *RetryLayer

+ func (s *RetryLayerComplianceStore) ComplianceExport(compliance *model.Compliance) ([]*model.CompliancePost, 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(after int64, limit int) ([]*model.MessageExport, error)

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

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

+ type RetryLayerEmojiStore struct

+ Root *RetryLayer

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

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

+ func (s *RetryLayerEmojiStore) GetByName(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 struct

+ Root *RetryLayer

+ func (s *RetryLayerFileInfoStore) AttachToPost(fileId string, postId string, creatorId string) error

+ func (s *RetryLayerFileInfoStore) ClearCaches()

+ 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) GetForPost(postId string, readFromMaster bool, includeDeleted bool, allowFromCache bool) ([]*model.FileInfo, error)

+ func (s *RetryLayerFileInfoStore) GetForUser(userId 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 struct

+ Root *RetryLayer

+ 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) ([]*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) 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) 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) 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) 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) ([]*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)

+ type RetryLayerJobStore struct

+ Root *RetryLayer

+ 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) GetAllByTypePage(jobType 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 struct

+ Root *RetryLayer

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

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

+ type RetryLayerLinkMetadataStore struct

+ Root *RetryLayer

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

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

+ type RetryLayerOAuthStore struct

+ Root *RetryLayer

+ 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 struct

+ Root *RetryLayer

+ 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 struct

+ Root *RetryLayer

+ 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) Get(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) 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) (*model.Post, error)

+ func (s *RetryLayerPostStore) GetPostIdAfterTime(channelId string, time int64) (string, error)

+ func (s *RetryLayerPostStore) GetPostIdBeforeTime(channelId string, time int64) (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) GetRepliesForExport(parentId string) ([]*model.ReplyForExport, error)

+ func (s *RetryLayerPostStore) GetSingle(id string) (*model.Post, 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) 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) SearchPostsInTeamForUser(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 struct

+ Root *RetryLayer

+ 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) 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 struct

+ Root *RetryLayer

+ 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 struct

+ Root *RetryLayer

+ 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) GetForPost(postId string, allowFromCache 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 RetryLayerRoleStore struct

+ Root *RetryLayer

+ 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(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 struct

+ Root *RetryLayer

+ 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 struct

+ Root *RetryLayer

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

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

+ func (s *RetryLayerSessionStore) Get(sessionIdOrToken string) (*model.Session, 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 RetryLayerStatusStore struct

+ Root *RetryLayer

+ 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) UpdateLastActivityAt(userId string, lastActivityAt int64) error

+ type RetryLayerSystemStore struct

+ Root *RetryLayer

+ 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 struct

+ Root *RetryLayer

+ func (s *RetryLayerTeamStore) AnalyticsGetTeamCountForScheme(schemeId string) (int64, error)

+ func (s *RetryLayerTeamStore) AnalyticsPrivateTeamCount() (int64, error)

+ func (s *RetryLayerTeamStore) AnalyticsPublicTeamCount() (int64, error)

+ func (s *RetryLayerTeamStore) AnalyticsTeamCount(includeDeleted bool) (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) ([]*model.Team, error)

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

+ func (s *RetryLayerTeamStore) GetAllPrivateTeamPageListing(offset int, limit int) ([]*model.Team, error)

+ func (s *RetryLayerTeamStore) GetAllPublicTeamPageListing(offset int, limit int) ([]*model.Team, error)

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

+ func (s *RetryLayerTeamStore) GetAllTeamPageListing(offset int, limit int) ([]*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) GetMember(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(term string, opts *model.TeamSearch) ([]*model.Team, error)

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

+ func (s *RetryLayerTeamStore) SearchOpen(term string) ([]*model.Team, error)

+ func (s *RetryLayerTeamStore) SearchPrivate(term string) ([]*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 struct

+ Root *RetryLayer

+ 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 struct

+ Root *RetryLayer

+ func (s *RetryLayerThreadStore) CollectThreadsWithNewerReplies(userId string, channelIds []string, timestamp int64) ([]string, error)

+ func (s *RetryLayerThreadStore) CreateMembershipIfNeeded(userId string, postId string, following bool, incrementMentions bool, ...) error

+ func (s *RetryLayerThreadStore) Delete(postId string) error

+ func (s *RetryLayerThreadStore) DeleteMembershipForUser(userId string, postId string) 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) GetThreadForUser(userId string, teamId string, threadId string, extended bool) (*model.ThreadResponse, error)

+ func (s *RetryLayerThreadStore) GetThreadMentionsForUserPerChannel(userId string, teamId string) (map[string]int64, error)

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

+ func (s *RetryLayerThreadStore) MarkAllAsRead(userId string, teamId string) error

+ func (s *RetryLayerThreadStore) MarkAsRead(userId string, threadId string, timestamp int64) error

+ func (s *RetryLayerThreadStore) Save(thread *model.Thread) (*model.Thread, error)

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

+ func (s *RetryLayerThreadStore) SaveMultiple(thread []*model.Thread) ([]*model.Thread, int, error)

+ func (s *RetryLayerThreadStore) Update(thread *model.Thread) (*model.Thread, error)

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

+ func (s *RetryLayerThreadStore) UpdateUnreadsByChannel(userId string, changedThreads []string, timestamp int64, ...) error

+ type RetryLayerTokenStore struct

+ Root *RetryLayer

+ func (s *RetryLayerTokenStore) Cleanup()

+ func (s *RetryLayerTokenStore) Delete(token string) 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 struct

+ Root *RetryLayer

+ 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 struct

+ Root *RetryLayer

+ 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 struct

+ Root *RetryLayer

+ 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) InferSystemInstallDate() (int64, error)

+ func (s *RetryLayerUserStore) InvalidateProfileCacheForUser(userId string)

+ func (s *RetryLayerUserStore) InvalidateProfilesInChannelCache(channelId string)

+ func (s *RetryLayerUserStore) InvalidateProfilesInChannelCacheByUser(userId string)

+ func (s *RetryLayerUserStore) PermanentDelete(userId string) error

+ func (s *RetryLayerUserStore) PromoteGuestToUser(userID string) 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) 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) 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 struct

+ Root *RetryLayer

+ 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 struct

+ Root *RetryLayer

+ 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)