store

Apr 16, 2019

Changes in this version

+ type BotStore interface

+ Get func(userId string, includeDeleted bool) StoreChannel

+ GetAll func(options *model.BotGetOptions) StoreChannel

+ PermanentDelete func(userId string) StoreChannel

+ Save func(bot *model.Bot) StoreChannel

+ Update func(bot *model.Bot) StoreChannel

type ChannelStore

+ GetAllDirectChannelsForExportAfter func(limit int, afterId string) StoreChannel

+ GetChannelsBatchForIndexing func(startTime, endTime int64, limit int) StoreChannel

+ GetChannelsByIds func(channelIds []string) StoreChannel

+ GetMembersForUserWithPagination func(teamId, userId string, page, perPage int) StoreChannel

type LayeredStore

+ func (s *LayeredStore) Bot() BotStore

type PostStore

+ GetDirectPostParentsForExportAfter func(limit int, afterId string) StoreChannel

type Store

+ Bot func() BotStore

type TeamStore

+ GetAllPrivateTeamListing func() StoreChannel

+ GetAllPrivateTeamPageListing func(offset int, limit int) StoreChannel

+ GetTeamsForUserWithPagination func(userId string, page, perPage int) StoreChannel

+ SearchPrivate func(term string) StoreChannel

type TokenStore

+ RemoveAllTokensByType func(tokenType string) StoreChannel

type UserStore

+ Count func(options model.UserCountOptions) StoreChannel

+ GetUsersBatchForIndexing func(startTime, endTime int64, limit int) StoreChannel

Apr 16, 2019

Changes in this version

type LayeredRoleStore

+ func (s *LayeredRoleStore) GetAll() StoreChannel

type LayeredStoreSupplier

+ RoleGetAll func(ctx context.Context, hints ...LayeredStoreHint) *LayeredStoreSupplierResult

type LocalCacheSupplier

+ func (s *LocalCacheSupplier) RoleGetAll(ctx context.Context, hints ...LayeredStoreHint) *LayeredStoreSupplierResult

type RedisSupplier

+ func (s *RedisSupplier) RoleGetAll(ctx context.Context, hints ...LayeredStoreHint) *LayeredStoreSupplierResult

type RoleStore

+ GetAll func() StoreChannel

Feb 13, 2019

Changes in this version

+ const GROUP_CACHE_SEC

+ const GROUP_CACHE_SIZE

type ChannelStore

+ GetAllChannels func(page, perPage int, includeDeleted bool) StoreChannel

+ SearchAllChannels func(term string, includeDeleted bool) StoreChannel

+ type GroupStore interface

+ Create func(group *model.Group) StoreChannel

+ CreateGroupSyncable func(groupSyncable *model.GroupSyncable) StoreChannel

+ CreateOrRestoreMember func(groupID string, userID string) StoreChannel

+ Delete func(groupID string) StoreChannel

+ DeleteGroupSyncable func(groupID string, syncableID string, syncableType model.GroupSyncableType) StoreChannel

+ DeleteMember func(groupID string, userID string) StoreChannel

+ Get func(groupID string) StoreChannel

+ GetAllBySource func(groupSource model.GroupSource) StoreChannel

+ GetAllGroupSyncablesByGroupId func(groupID string, syncableType model.GroupSyncableType) StoreChannel

+ GetByRemoteID func(remoteID string, groupSource model.GroupSource) StoreChannel

+ GetGroupSyncable func(groupID string, syncableID string, syncableType model.GroupSyncableType) StoreChannel

+ GetMemberCount func(groupID string) StoreChannel

+ GetMemberUsers func(groupID string) StoreChannel

+ GetMemberUsersPage func(groupID string, offset int, limit int) StoreChannel

+ PendingAutoAddChannelMembers func(minGroupMembersCreateAt int64) StoreChannel

+ PendingAutoAddTeamMembers func(minGroupMembersCreateAt int64) StoreChannel

+ Update func(group *model.Group) StoreChannel

+ UpdateGroupSyncable func(groupSyncable *model.GroupSyncable) StoreChannel

+ type LayeredGroupStore struct

+ func (s *LayeredGroupStore) Create(group *model.Group) StoreChannel

+ func (s *LayeredGroupStore) CreateGroupSyncable(groupSyncable *model.GroupSyncable) StoreChannel

+ func (s *LayeredGroupStore) CreateOrRestoreMember(groupID string, userID string) StoreChannel

+ func (s *LayeredGroupStore) Delete(groupID string) StoreChannel

+ func (s *LayeredGroupStore) DeleteGroupSyncable(groupID string, syncableID string, syncableType model.GroupSyncableType) StoreChannel

+ func (s *LayeredGroupStore) DeleteMember(groupID string, userID string) StoreChannel

+ func (s *LayeredGroupStore) Get(groupID string) StoreChannel

+ func (s *LayeredGroupStore) GetAllBySource(groupSource model.GroupSource) StoreChannel

+ func (s *LayeredGroupStore) GetAllGroupSyncablesByGroupId(groupID string, syncableType model.GroupSyncableType) StoreChannel

+ func (s *LayeredGroupStore) GetByRemoteID(remoteID string, groupSource model.GroupSource) StoreChannel

+ func (s *LayeredGroupStore) GetGroupSyncable(groupID string, syncableID string, syncableType model.GroupSyncableType) StoreChannel

+ func (s *LayeredGroupStore) GetMemberCount(groupID string) StoreChannel

+ func (s *LayeredGroupStore) GetMemberUsers(groupID string) StoreChannel

+ func (s *LayeredGroupStore) GetMemberUsersPage(groupID string, offset int, limit int) StoreChannel

+ func (s *LayeredGroupStore) PendingAutoAddChannelMembers(minGroupMembersCreateAt int64) StoreChannel

+ func (s *LayeredGroupStore) PendingAutoAddTeamMembers(minGroupMembersCreateAt int64) StoreChannel

+ func (s *LayeredGroupStore) Update(group *model.Group) StoreChannel

+ func (s *LayeredGroupStore) UpdateGroupSyncable(groupSyncable *model.GroupSyncable) StoreChannel

type LayeredReactionStore

+ func (s *LayeredReactionStore) BulkGetForPosts(postIds []string) StoreChannel

type LayeredStore

+ GroupStore GroupStore

+ func (s *LayeredStore) Group() GroupStore

+ func (s *LayeredStore) LinkMetadata() LinkMetadataStore

type LayeredStoreSupplier

+ GroupCreate func(ctx context.Context, group *model.Group, hints ...LayeredStoreHint) *LayeredStoreSupplierResult

+ GroupCreateGroupSyncable func(ctx context.Context, groupSyncable *model.GroupSyncable, ...) *LayeredStoreSupplierResult

+ GroupCreateOrRestoreMember func(ctx context.Context, groupID string, userID string, hints ...LayeredStoreHint) *LayeredStoreSupplierResult

+ GroupDelete func(ctx context.Context, groupID string, hints ...LayeredStoreHint) *LayeredStoreSupplierResult

+ GroupDeleteGroupSyncable func(ctx context.Context, groupID string, syncableID string, ...) *LayeredStoreSupplierResult

+ GroupDeleteMember func(ctx context.Context, groupID string, userID string, hints ...LayeredStoreHint) *LayeredStoreSupplierResult

+ GroupGet func(ctx context.Context, groupID string, hints ...LayeredStoreHint) *LayeredStoreSupplierResult

+ GroupGetAllBySource func(ctx context.Context, groupSource model.GroupSource, hints ...LayeredStoreHint) *LayeredStoreSupplierResult

+ GroupGetAllGroupSyncablesByGroup func(ctx context.Context, groupID string, syncableType model.GroupSyncableType, ...) *LayeredStoreSupplierResult

+ GroupGetByRemoteID func(ctx context.Context, remoteID string, groupSource model.GroupSource, ...) *LayeredStoreSupplierResult

+ GroupGetGroupSyncable func(ctx context.Context, groupID string, syncableID string, ...) *LayeredStoreSupplierResult

+ GroupGetMemberCount func(ctx context.Context, groupID string, hints ...LayeredStoreHint) *LayeredStoreSupplierResult

+ GroupGetMemberUsers func(ctx context.Context, groupID string, hints ...LayeredStoreHint) *LayeredStoreSupplierResult

+ GroupGetMemberUsersPage func(ctx context.Context, groupID string, offset int, limit int, ...) *LayeredStoreSupplierResult

+ GroupUpdate func(ctx context.Context, group *model.Group, hints ...LayeredStoreHint) *LayeredStoreSupplierResult

+ GroupUpdateGroupSyncable func(ctx context.Context, groupSyncable *model.GroupSyncable, ...) *LayeredStoreSupplierResult

+ PendingAutoAddChannelMembers func(ctx context.Context, minGroupMembersCreateAt int64, hints ...LayeredStoreHint) *LayeredStoreSupplierResult

+ PendingAutoAddTeamMembers func(ctx context.Context, minGroupMembersCreateAt int64, hints ...LayeredStoreHint) *LayeredStoreSupplierResult

+ ReactionsBulkGetForPosts func(ctx context.Context, postIds []string, hints ...LayeredStoreHint) *LayeredStoreSupplierResult

+ type LinkMetadataStore interface

+ Get func(url string, timestamp int64) StoreChannel

+ Save func(linkMetadata *model.LinkMetadata) StoreChannel

type LocalCacheSupplier

+ func (s *LocalCacheSupplier) GroupCreate(ctx context.Context, group *model.Group, hints ...LayeredStoreHint) *LayeredStoreSupplierResult

+ func (s *LocalCacheSupplier) GroupCreateGroupSyncable(ctx context.Context, groupSyncable *model.GroupSyncable, ...) *LayeredStoreSupplierResult

+ func (s *LocalCacheSupplier) GroupCreateOrRestoreMember(ctx context.Context, groupID string, userID string, hints ...LayeredStoreHint) *LayeredStoreSupplierResult

+ func (s *LocalCacheSupplier) GroupDelete(ctx context.Context, groupID string, hints ...LayeredStoreHint) *LayeredStoreSupplierResult

+ func (s *LocalCacheSupplier) GroupDeleteGroupSyncable(ctx context.Context, groupID string, syncableID string, ...) *LayeredStoreSupplierResult

+ func (s *LocalCacheSupplier) GroupDeleteMember(ctx context.Context, groupID string, userID string, hints ...LayeredStoreHint) *LayeredStoreSupplierResult

+ func (s *LocalCacheSupplier) GroupGet(ctx context.Context, groupID string, hints ...LayeredStoreHint) *LayeredStoreSupplierResult

+ func (s *LocalCacheSupplier) GroupGetAllBySource(ctx context.Context, groupSource model.GroupSource, hints ...LayeredStoreHint) *LayeredStoreSupplierResult

+ func (s *LocalCacheSupplier) GroupGetAllGroupSyncablesByGroup(ctx context.Context, groupID string, syncableType model.GroupSyncableType, ...) *LayeredStoreSupplierResult

+ func (s *LocalCacheSupplier) GroupGetByRemoteID(ctx context.Context, remoteID string, groupSource model.GroupSource, ...) *LayeredStoreSupplierResult

+ func (s *LocalCacheSupplier) GroupGetGroupSyncable(ctx context.Context, groupID string, syncableID string, ...) *LayeredStoreSupplierResult

+ func (s *LocalCacheSupplier) GroupGetMemberCount(ctx context.Context, groupID string, hints ...LayeredStoreHint) *LayeredStoreSupplierResult

+ func (s *LocalCacheSupplier) GroupGetMemberUsers(ctx context.Context, groupID string, hints ...LayeredStoreHint) *LayeredStoreSupplierResult

+ func (s *LocalCacheSupplier) GroupGetMemberUsersPage(ctx context.Context, groupID string, offset int, limit int, ...) *LayeredStoreSupplierResult

+ func (s *LocalCacheSupplier) GroupUpdate(ctx context.Context, group *model.Group, hints ...LayeredStoreHint) *LayeredStoreSupplierResult

+ func (s *LocalCacheSupplier) GroupUpdateGroupSyncable(ctx context.Context, groupSyncable *model.GroupSyncable, ...) *LayeredStoreSupplierResult

+ func (s *LocalCacheSupplier) PendingAutoAddChannelMembers(ctx context.Context, minGroupMembersCreateAt int64, hints ...LayeredStoreHint) *LayeredStoreSupplierResult

+ func (s *LocalCacheSupplier) PendingAutoAddTeamMembers(ctx context.Context, minGroupMembersCreateAt int64, hints ...LayeredStoreHint) *LayeredStoreSupplierResult

+ func (s *LocalCacheSupplier) ReactionsBulkGetForPosts(ctx context.Context, postIds []string, hints ...LayeredStoreHint) *LayeredStoreSupplierResult

+ type ObjectCache interface

+ AddWithDefaultExpires func(key, value interface{})

+ AddWithExpiresInSecs func(key, value interface{}, expireAtSecs int64)

+ Get func(key interface{}) (value interface{}, ok bool)

+ GetInvalidateClusterEvent func() string

+ Len func() int

+ Name func() string

+ Purge func()

+ Remove func(key interface{})

type ReactionStore

+ BulkGetForPosts func(postIds []string) StoreChannel

type RedisSupplier

+ func (s *RedisSupplier) GroupCreate(ctx context.Context, group *model.Group, hints ...LayeredStoreHint) *LayeredStoreSupplierResult

+ func (s *RedisSupplier) GroupCreateGroupSyncable(ctx context.Context, groupSyncable *model.GroupSyncable, ...) *LayeredStoreSupplierResult

+ func (s *RedisSupplier) GroupCreateOrRestoreMember(ctx context.Context, groupID string, userID string, hints ...LayeredStoreHint) *LayeredStoreSupplierResult

+ func (s *RedisSupplier) GroupDelete(ctx context.Context, groupID string, hints ...LayeredStoreHint) *LayeredStoreSupplierResult

+ func (s *RedisSupplier) GroupDeleteGroupSyncable(ctx context.Context, groupID string, syncableID string, ...) *LayeredStoreSupplierResult

+ func (s *RedisSupplier) GroupDeleteMember(ctx context.Context, groupID string, userID string, hints ...LayeredStoreHint) *LayeredStoreSupplierResult

+ func (s *RedisSupplier) GroupGet(ctx context.Context, groupID string, hints ...LayeredStoreHint) *LayeredStoreSupplierResult

+ func (s *RedisSupplier) GroupGetAllBySource(ctx context.Context, groupSource model.GroupSource, hints ...LayeredStoreHint) *LayeredStoreSupplierResult

+ func (s *RedisSupplier) GroupGetAllGroupSyncablesByGroup(ctx context.Context, groupID string, syncableType model.GroupSyncableType, ...) *LayeredStoreSupplierResult

+ func (s *RedisSupplier) GroupGetByRemoteID(ctx context.Context, remoteID string, groupSource model.GroupSource, ...) *LayeredStoreSupplierResult

+ func (s *RedisSupplier) GroupGetGroupSyncable(ctx context.Context, groupID string, syncableID string, ...) *LayeredStoreSupplierResult

+ func (s *RedisSupplier) GroupGetMemberCount(ctx context.Context, groupID string, hints ...LayeredStoreHint) *LayeredStoreSupplierResult

+ func (s *RedisSupplier) GroupGetMemberUsers(ctx context.Context, groupID string, hints ...LayeredStoreHint) *LayeredStoreSupplierResult

+ func (s *RedisSupplier) GroupGetMemberUsersPage(ctx context.Context, groupID string, offset int, limit int, ...) *LayeredStoreSupplierResult

+ func (s *RedisSupplier) GroupUpdate(ctx context.Context, group *model.Group, hints ...LayeredStoreHint) *LayeredStoreSupplierResult

+ func (s *RedisSupplier) GroupUpdateGroupSyncable(ctx context.Context, groupSyncable *model.GroupSyncable, ...) *LayeredStoreSupplierResult

+ func (s *RedisSupplier) PendingAutoAddChannelMembers(ctx context.Context, minGroupMembersCreateAt int64, hints ...LayeredStoreHint) *LayeredStoreSupplierResult

+ func (s *RedisSupplier) PendingAutoAddTeamMembers(ctx context.Context, minGroupMembersCreateAt int64, hints ...LayeredStoreHint) *LayeredStoreSupplierResult

+ func (s *RedisSupplier) ReactionsBulkGetForPosts(ctx context.Context, postIds []string, hints ...LayeredStoreHint) *LayeredStoreSupplierResult

type Store

+ Group func() GroupStore

+ LinkMetadata func() LinkMetadataStore

Dec 14, 2018

Changes in this version

type ChannelStore

+ GetChannelMembersTimezones func(channelId string) StoreChannel

type EmojiStore

+ GetMultipleByName func(names []string) StoreChannel

type LayeredStore

+ func (s *LayeredStore) UserTermsOfService() UserTermsOfServiceStore

type LocalCacheSupplier

+ func (s *LocalCacheSupplier) Invalidate()

type PluginStore

+ DeleteAllExpired func() StoreChannel

+ DeleteAllForPlugin func(PluginId string) StoreChannel

+ List func(pluginId string, page, perPage int) StoreChannel

type Store

+ UserTermsOfService func() UserTermsOfServiceStore

type UserStore

+ ResetLastPictureUpdate func(userId string) StoreChannel

+ type UserTermsOfServiceStore interface

+ Delete func(userId, termsOfServiceId string) StoreChannel

+ GetByUser func(userId string) StoreChannel

+ Save func(userTermsOfService *model.UserTermsOfService) StoreChannel

Oct 15, 2018

Changes in this version

type ChannelStore

+ AutocompleteInTeamForSearch func(teamId string, userId string, term string, includeDeleted bool) StoreChannel

+ DisableExperimentalPublicChannelsMaterialization func()

+ DropPublicChannels func() error

+ EnableExperimentalPublicChannelsMaterialization func()

+ GetAllChannelsForExportAfter func(limit int, afterId string) StoreChannel

+ GetChannelMembersForExport func(userId string, teamId string) StoreChannel

+ IsExperimentalPublicChannelsMaterializationEnabled func() bool

+ MigratePublicChannels func() error

+ RemoveAllDeactivatedMembers func(channelId string) StoreChannel

type LayeredStore

+ func (s *LayeredStore) TermsOfService() TermsOfServiceStore

type PostStore

+ GetParentsForExportAfter func(limit int, afterId string) StoreChannel

+ GetRepliesForExport func(parentId string) StoreChannel

type Store

+ TermsOfService func() TermsOfServiceStore

type TeamStore

+ GetAllForExportAfter func(limit int, afterId string) StoreChannel

+ GetTeamMembersForExport func(userId string) StoreChannel

+ type TermsOfServiceStore interface

+ Get func(id string, allowFromCache bool) StoreChannel

+ GetLatest func(allowFromCache bool) StoreChannel

+ Save func(termsOfService *model.TermsOfService) StoreChannel

type UserStore

+ GetAllAfter func(limit int, afterId string) StoreChannel

+ GetAnyUnreadPostCountForChannel func(userId string, channelId string) StoreChannel

Sep 13, 2018

Changes in this version

type ChannelStore

+ ResetLastPostAt func() StoreChannel

type TeamStore

+ AnalyticsGetTeamCountForScheme func(schemeId string) StoreChannel

Aug 15, 2018

Changes in this version

type UserStore

+ InferSystemInstallDate func() StoreChannel

Jul 12, 2018

Changes in this version

type ChannelStore

+ ClearAllCustomRoleAssignments func() StoreChannel

type FileInfoStore

+ GetForUser func(userId string) StoreChannel

+ PermanentDeleteByUser func(userId string) StoreChannel

type LayeredSchemeStore

+ func (s *LayeredSchemeStore) GetByName(schemeName string) StoreChannel

type LayeredStore

+ func (s *LayeredStore) LockToMaster()

+ func (s *LayeredStore) UnlockFromMaster()

type LayeredStoreSupplier

+ SchemeGetByName func(ctx context.Context, schemeName string, hints ...LayeredStoreHint) *LayeredStoreSupplierResult

type LocalCacheSupplier

+ func (s *LocalCacheSupplier) SchemeGetByName(ctx context.Context, schemeName string, hints ...LayeredStoreHint) *LayeredStoreSupplierResult

type RedisSupplier

+ func (s *RedisSupplier) SchemeGetByName(ctx context.Context, schemeName string, hints ...LayeredStoreHint) *LayeredStoreSupplierResult

type SchemeStore

+ GetByName func(schemeName string) StoreChannel

type Store

+ LockToMaster func()

+ UnlockFromMaster func()

type TeamStore

+ ClearAllCustomRoleAssignments func() StoreChannel

type UserStore

+ ClearAllCustomRoleAssignments func() StoreChannel

Jun 14, 2018

Changes in this version

+ const CHANNEL_EXISTS_ERROR

+ const CLEAR_CACHE_MESSAGE_DATA

+ const ENABLE_EXPERIMENTAL_REDIS

+ const FEATURE_TOGGLE_PREFIX

+ const MISSING_ACCOUNT_ERROR

+ const MISSING_AUTH_ACCOUNT_ERROR

+ const MISSING_CHANNEL_ERROR

+ const MISSING_CHANNEL_MEMBER_ERROR

+ const REACTION_CACHE_SEC

+ const REACTION_CACHE_SIZE

+ const REDIS_EXPIRY_TIME

+ const ROLE_CACHE_SEC

+ const ROLE_CACHE_SIZE

+ const SCHEME_CACHE_SEC

+ const SCHEME_CACHE_SIZE

+ const USER_SEARCH_OPTION_ALLOW_INACTIVE

+ const USER_SEARCH_OPTION_ALL_NO_FULL_NAME

+ const USER_SEARCH_OPTION_NAMES_ONLY

+ const USER_SEARCH_OPTION_NAMES_ONLY_NO_FULL_NAME

+ func DecodeBytes(input []byte, thing interface{}) error

+ func GetBytes(key interface{}) ([]byte, error)

+ func Must(sc StoreChannel) interface

+ type AuditStore interface

+ Get func(user_id string, offset int, limit int) StoreChannel

+ PermanentDeleteBatch func(endTime int64, limit int64) StoreChannel

+ PermanentDeleteByUser func(userId string) StoreChannel

+ Save func(audit *model.Audit) StoreChannel

+ type ChannelMemberHistoryStore interface

+ GetUsersInChannelDuring func(startTime int64, endTime int64, channelId string) StoreChannel

+ LogJoinEvent func(userId string, channelId string, joinTime int64) StoreChannel

+ LogLeaveEvent func(userId string, channelId string, leaveTime int64) StoreChannel

+ PermanentDeleteBatch func(endTime int64, limit int64) StoreChannel

+ type ChannelStore interface

+ AnalyticsDeletedTypeCount func(teamId string, channelType string) StoreChannel

+ AnalyticsTypeCount func(teamId string, channelType string) StoreChannel

+ AutocompleteInTeam func(teamId string, term string) StoreChannel

+ ClearCaches func()

+ CreateDirectChannel func(userId string, otherUserId string) StoreChannel

+ Delete func(channelId string, time int64) StoreChannel

+ Get func(id string, allowFromCache bool) StoreChannel

+ GetAll func(teamId string) StoreChannel

+ GetAllChannelMembersForUser func(userId string, allowFromCache bool) StoreChannel

+ GetAllChannelMembersNotifyPropsForChannel func(channelId string, allowFromCache bool) StoreChannel

+ GetByName func(team_id string, name string, allowFromCache bool) StoreChannel

+ GetByNameIncludeDeleted func(team_id string, name string, allowFromCache bool) StoreChannel

+ GetByNames func(team_id string, names []string, allowFromCache bool) StoreChannel

+ GetChannelCounts func(teamId string, userId string) StoreChannel

+ GetChannelUnread func(channelId, userId string) StoreChannel

+ GetChannels func(teamId string, userId string) StoreChannel

+ GetChannelsByScheme func(schemeId string, offset int, limit int) StoreChannel

+ GetDeleted func(team_id string, offset int, limit int) StoreChannel

+ GetDeletedByName func(team_id string, name string) StoreChannel

+ GetForPost func(postId string) StoreChannel

+ GetFromMaster func(id string) StoreChannel

+ GetMember func(channelId string, userId string) StoreChannel

+ GetMemberCount func(channelId string, allowFromCache bool) StoreChannel

+ GetMemberCountFromCache func(channelId string) int64

+ GetMemberForPost func(postId string, userId string) StoreChannel

+ GetMembers func(channelId string, offset, limit int) StoreChannel

+ GetMembersByIds func(channelId string, userIds []string) StoreChannel

+ GetMembersForUser func(teamId string, userId string) StoreChannel

+ GetMoreChannels func(teamId string, userId string, offset int, limit int) StoreChannel

+ GetPinnedPosts func(channelId string) StoreChannel

+ GetPublicChannelsByIdsForTeam func(teamId string, channelIds []string) StoreChannel

+ GetPublicChannelsForTeam func(teamId string, offset int, limit int) StoreChannel

+ GetTeamChannels func(teamId string) StoreChannel

+ IncrementMentionCount func(channelId string, userId string) StoreChannel

+ InvalidateAllChannelMembersForUser func(userId string)

+ InvalidateCacheForChannelMembersNotifyProps func(channelId string)

+ InvalidateChannel func(id string)

+ InvalidateChannelByName func(teamId, name string)

+ InvalidateMemberCount func(channelId string)

+ IsUserInChannelUseCache func(userId string, channelId string) bool

+ MigrateChannelMembers func(fromChannelId string, fromUserId string) StoreChannel

+ PermanentDelete func(channelId string) StoreChannel

+ PermanentDeleteByTeam func(teamId string) StoreChannel

+ PermanentDeleteMembersByChannel func(channelId string) StoreChannel

+ PermanentDeleteMembersByUser func(userId string) StoreChannel

+ RemoveMember func(channelId string, userId string) StoreChannel

+ ResetAllChannelSchemes func() StoreChannel

+ Restore func(channelId string, time int64) StoreChannel

+ Save func(channel *model.Channel, maxChannelsPerTeam int64) StoreChannel

+ SaveDirectChannel func(channel *model.Channel, member1 *model.ChannelMember, ...) StoreChannel

+ SaveMember func(member *model.ChannelMember) StoreChannel

+ SearchInTeam func(teamId string, term string) StoreChannel

+ SearchMore func(userId string, teamId string, term string) StoreChannel

+ SetDeleteAt func(channelId string, deleteAt int64, updateAt int64) StoreChannel

+ Update func(channel *model.Channel) StoreChannel

+ UpdateLastViewedAt func(channelIds []string, userId string) StoreChannel

+ UpdateMember func(member *model.ChannelMember) StoreChannel

+ type ClusterDiscoveryStore interface

+ Cleanup func() StoreChannel

+ Delete func(discovery *model.ClusterDiscovery) StoreChannel

+ Exists func(discovery *model.ClusterDiscovery) StoreChannel

+ GetAll func(discoveryType, clusterName string) StoreChannel

+ Save func(discovery *model.ClusterDiscovery) StoreChannel

+ SetLastPingAt func(discovery *model.ClusterDiscovery) StoreChannel

+ type CommandStore interface

+ AnalyticsCommandCount func(teamId string) StoreChannel

+ Delete func(commandId string, time int64) StoreChannel

+ Get func(id string) StoreChannel

+ GetByTeam func(teamId string) StoreChannel

+ GetByTrigger func(teamId string, trigger string) StoreChannel

+ PermanentDeleteByTeam func(teamId string) StoreChannel

+ PermanentDeleteByUser func(userId string) StoreChannel

+ Save func(webhook *model.Command) StoreChannel

+ Update func(hook *model.Command) StoreChannel

+ type CommandWebhookStore interface

+ Cleanup func()

+ Get func(id string) StoreChannel

+ Save func(webhook *model.CommandWebhook) StoreChannel

+ TryUse func(id string, limit int) StoreChannel

+ type ComplianceStore interface

+ ComplianceExport func(compliance *model.Compliance) StoreChannel

+ Get func(id string) StoreChannel

+ GetAll func(offset, limit int) StoreChannel

+ MessageExport func(after int64, limit int) StoreChannel

+ Save func(compliance *model.Compliance) StoreChannel

+ Update func(compliance *model.Compliance) StoreChannel

+ type EmojiStore interface

+ Delete func(id string, time int64) StoreChannel

+ Get func(id string, allowFromCache bool) StoreChannel

+ GetByName func(name string) StoreChannel

+ GetList func(offset, limit int, sort string) StoreChannel

+ Save func(emoji *model.Emoji) StoreChannel

+ Search func(name string, prefixOnly bool, limit int) StoreChannel

+ type FileInfoStore interface

+ AttachToPost func(fileId string, postId string) StoreChannel

+ ClearCaches func()

+ DeleteForPost func(postId string) StoreChannel

+ Get func(id string) StoreChannel

+ GetByPath func(path string) StoreChannel

+ GetForPost func(postId string, readFromMaster bool, allowFromCache bool) StoreChannel

+ InvalidateFileInfosForPostCache func(postId string)

+ PermanentDelete func(fileId string) StoreChannel

+ PermanentDeleteBatch func(endTime int64, limit int64) StoreChannel

+ Save func(info *model.FileInfo) StoreChannel

+ type JobStore interface

+ Delete func(id string) StoreChannel

+ Get func(id string) StoreChannel

+ GetAllByStatus func(status string) StoreChannel

+ GetAllByType func(jobType string) StoreChannel

+ GetAllByTypePage func(jobType string, offset int, limit int) StoreChannel

+ GetAllPage func(offset int, limit int) StoreChannel

+ GetCountByStatusAndType func(status string, jobType string) StoreChannel

+ GetNewestJobByStatusAndType func(status string, jobType string) StoreChannel

+ Save func(job *model.Job) StoreChannel

+ UpdateOptimistically func(job *model.Job, currentStatus string) StoreChannel

+ UpdateStatus func(id string, status string) StoreChannel

+ UpdateStatusOptimistically func(id string, currentStatus string, newStatus string) StoreChannel

+ type LayeredReactionStore struct

+ func (s *LayeredReactionStore) Delete(reaction *model.Reaction) StoreChannel

+ func (s *LayeredReactionStore) DeleteAllWithEmojiName(emojiName string) StoreChannel

+ func (s *LayeredReactionStore) GetForPost(postId string, allowFromCache bool) StoreChannel

+ func (s *LayeredReactionStore) PermanentDeleteBatch(endTime int64, limit int64) StoreChannel

+ func (s *LayeredReactionStore) Save(reaction *model.Reaction) StoreChannel

+ type LayeredRoleStore struct

+ func (s *LayeredRoleStore) Delete(roldId string) StoreChannel

+ func (s *LayeredRoleStore) Get(roleId string) StoreChannel

+ func (s *LayeredRoleStore) GetByName(name string) StoreChannel

+ func (s *LayeredRoleStore) GetByNames(names []string) StoreChannel

+ func (s *LayeredRoleStore) PermanentDeleteAll() StoreChannel

+ func (s *LayeredRoleStore) Save(role *model.Role) StoreChannel

+ type LayeredSchemeStore struct

+ func (s *LayeredSchemeStore) Delete(schemeId string) StoreChannel

+ func (s *LayeredSchemeStore) Get(schemeId string) StoreChannel

+ func (s *LayeredSchemeStore) GetAllPage(scope string, offset int, limit int) StoreChannel

+ func (s *LayeredSchemeStore) PermanentDeleteAll() StoreChannel

+ func (s *LayeredSchemeStore) Save(scheme *model.Scheme) StoreChannel

+ type LayeredStore struct

+ DatabaseLayer LayeredStoreDatabaseLayer

+ LayerChainHead LayeredStoreSupplier

+ LocalCacheLayer *LocalCacheSupplier

+ ReactionStore ReactionStore

+ RedisLayer *RedisSupplier

+ RoleStore RoleStore

+ SchemeStore SchemeStore

+ TmpContext context.Context

+ func (s *LayeredStore) Audit() AuditStore

+ func (s *LayeredStore) Channel() ChannelStore

+ func (s *LayeredStore) ChannelMemberHistory() ChannelMemberHistoryStore

+ func (s *LayeredStore) Close()

+ func (s *LayeredStore) ClusterDiscovery() ClusterDiscoveryStore

+ func (s *LayeredStore) Command() CommandStore

+ func (s *LayeredStore) CommandWebhook() CommandWebhookStore

+ func (s *LayeredStore) Compliance() ComplianceStore

+ func (s *LayeredStore) DropAllTables()

+ func (s *LayeredStore) Emoji() EmojiStore

+ func (s *LayeredStore) FileInfo() FileInfoStore

+ func (s *LayeredStore) Job() JobStore

+ func (s *LayeredStore) License() LicenseStore

+ func (s *LayeredStore) MarkSystemRanUnitTests()

+ func (s *LayeredStore) OAuth() OAuthStore

+ func (s *LayeredStore) Plugin() PluginStore

+ func (s *LayeredStore) Post() PostStore

+ func (s *LayeredStore) Preference() PreferenceStore

+ func (s *LayeredStore) Reaction() ReactionStore

+ func (s *LayeredStore) Role() RoleStore

+ func (s *LayeredStore) RunQuery(queryFunction QueryFunction) StoreChannel

+ func (s *LayeredStore) Scheme() SchemeStore

+ func (s *LayeredStore) Session() SessionStore

+ func (s *LayeredStore) Status() StatusStore

+ func (s *LayeredStore) System() SystemStore

+ func (s *LayeredStore) Team() TeamStore

+ func (s *LayeredStore) Token() TokenStore

+ func (s *LayeredStore) TotalMasterDbConnections() int

+ func (s *LayeredStore) TotalReadDbConnections() int

+ func (s *LayeredStore) TotalSearchDbConnections() int

+ func (s *LayeredStore) User() UserStore

+ func (s *LayeredStore) UserAccessToken() UserAccessTokenStore

+ func (s *LayeredStore) Webhook() WebhookStore

+ type LayeredStoreDatabaseLayer interface

+ type LayeredStoreHint int

+ const LSH_MASTER_ONLY

+ const LSH_NO_CACHE

+ type LayeredStoreSupplier interface

+ Next func() LayeredStoreSupplier

+ ReactionDelete func(ctx context.Context, reaction *model.Reaction, hints ...LayeredStoreHint) *LayeredStoreSupplierResult

+ ReactionDeleteAllWithEmojiName func(ctx context.Context, emojiName string, hints ...LayeredStoreHint) *LayeredStoreSupplierResult

+ ReactionGetForPost func(ctx context.Context, postId string, hints ...LayeredStoreHint) *LayeredStoreSupplierResult

+ ReactionPermanentDeleteBatch func(ctx context.Context, endTime int64, limit int64, hints ...LayeredStoreHint) *LayeredStoreSupplierResult

+ ReactionSave func(ctx context.Context, reaction *model.Reaction, hints ...LayeredStoreHint) *LayeredStoreSupplierResult

+ RoleDelete func(ctx context.Context, roldId string, hints ...LayeredStoreHint) *LayeredStoreSupplierResult

+ RoleGet func(ctx context.Context, roleId string, hints ...LayeredStoreHint) *LayeredStoreSupplierResult

+ RoleGetByName func(ctx context.Context, name string, hints ...LayeredStoreHint) *LayeredStoreSupplierResult

+ RoleGetByNames func(ctx context.Context, names []string, hints ...LayeredStoreHint) *LayeredStoreSupplierResult

+ RolePermanentDeleteAll func(ctx context.Context, hints ...LayeredStoreHint) *LayeredStoreSupplierResult

+ RoleSave func(ctx context.Context, role *model.Role, hints ...LayeredStoreHint) *LayeredStoreSupplierResult

+ SchemeDelete func(ctx context.Context, schemeId string, hints ...LayeredStoreHint) *LayeredStoreSupplierResult

+ SchemeGet func(ctx context.Context, schemeId string, hints ...LayeredStoreHint) *LayeredStoreSupplierResult

+ SchemeGetAllPage func(ctx context.Context, scope string, offset int, limit int, ...) *LayeredStoreSupplierResult

+ SchemePermanentDeleteAll func(ctx context.Context, hints ...LayeredStoreHint) *LayeredStoreSupplierResult

+ SchemeSave func(ctx context.Context, scheme *model.Scheme, hints ...LayeredStoreHint) *LayeredStoreSupplierResult

+ SetChainNext func(LayeredStoreSupplier)

+ type LayeredStoreSupplierResult struct

+ func NewSupplierResult() *LayeredStoreSupplierResult

+ type LicenseStore interface

+ Get func(id string) StoreChannel

+ Save func(license *model.LicenseRecord) StoreChannel

+ type LocalCacheSupplier struct

+ func NewLocalCacheSupplier(metrics einterfaces.MetricsInterface, cluster einterfaces.ClusterInterface) *LocalCacheSupplier

+ func (s *LocalCacheSupplier) Next() LayeredStoreSupplier

+ func (s *LocalCacheSupplier) ReactionDelete(ctx context.Context, reaction *model.Reaction, hints ...LayeredStoreHint) *LayeredStoreSupplierResult

+ func (s *LocalCacheSupplier) ReactionDeleteAllWithEmojiName(ctx context.Context, emojiName string, hints ...LayeredStoreHint) *LayeredStoreSupplierResult

+ func (s *LocalCacheSupplier) ReactionGetForPost(ctx context.Context, postId string, hints ...LayeredStoreHint) *LayeredStoreSupplierResult

+ func (s *LocalCacheSupplier) ReactionPermanentDeleteBatch(ctx context.Context, endTime int64, limit int64, hints ...LayeredStoreHint) *LayeredStoreSupplierResult

+ func (s *LocalCacheSupplier) ReactionSave(ctx context.Context, reaction *model.Reaction, hints ...LayeredStoreHint) *LayeredStoreSupplierResult

+ func (s *LocalCacheSupplier) RoleDelete(ctx context.Context, roleId string, hints ...LayeredStoreHint) *LayeredStoreSupplierResult

+ func (s *LocalCacheSupplier) RoleGet(ctx context.Context, roleId string, hints ...LayeredStoreHint) *LayeredStoreSupplierResult

+ func (s *LocalCacheSupplier) RoleGetByName(ctx context.Context, name string, hints ...LayeredStoreHint) *LayeredStoreSupplierResult

+ func (s *LocalCacheSupplier) RoleGetByNames(ctx context.Context, roleNames []string, hints ...LayeredStoreHint) *LayeredStoreSupplierResult

+ func (s *LocalCacheSupplier) RolePermanentDeleteAll(ctx context.Context, hints ...LayeredStoreHint) *LayeredStoreSupplierResult

+ func (s *LocalCacheSupplier) RoleSave(ctx context.Context, role *model.Role, hints ...LayeredStoreHint) *LayeredStoreSupplierResult

+ func (s *LocalCacheSupplier) SchemeDelete(ctx context.Context, schemeId string, hints ...LayeredStoreHint) *LayeredStoreSupplierResult

+ func (s *LocalCacheSupplier) SchemeGet(ctx context.Context, schemeId string, hints ...LayeredStoreHint) *LayeredStoreSupplierResult

+ func (s *LocalCacheSupplier) SchemeGetAllPage(ctx context.Context, scope string, offset int, limit int, ...) *LayeredStoreSupplierResult

+ func (s *LocalCacheSupplier) SchemePermanentDeleteAll(ctx context.Context, hints ...LayeredStoreHint) *LayeredStoreSupplierResult

+ func (s *LocalCacheSupplier) SchemeSave(ctx context.Context, scheme *model.Scheme, hints ...LayeredStoreHint) *LayeredStoreSupplierResult

+ func (s *LocalCacheSupplier) SetChainNext(next LayeredStoreSupplier)

+ type OAuthStore interface

+ DeleteApp func(id string) StoreChannel

+ GetAccessData func(token string) StoreChannel

+ GetAccessDataByRefreshToken func(token string) StoreChannel

+ GetAccessDataByUserForApp func(userId, clientId string) StoreChannel

+ GetApp func(id string) StoreChannel

+ GetAppByUser func(userId string, offset, limit int) StoreChannel

+ GetApps func(offset, limit int) StoreChannel

+ GetAuthData func(code string) StoreChannel

+ GetAuthorizedApps func(userId string, offset, limit int) StoreChannel

+ GetPreviousAccessData func(userId, clientId string) StoreChannel

+ PermanentDeleteAuthDataByUser func(userId string) StoreChannel

+ RemoveAccessData func(token string) StoreChannel

+ RemoveAuthData func(code string) StoreChannel

+ SaveAccessData func(accessData *model.AccessData) StoreChannel

+ SaveApp func(app *model.OAuthApp) StoreChannel

+ SaveAuthData func(authData *model.AuthData) StoreChannel

+ UpdateAccessData func(accessData *model.AccessData) StoreChannel

+ UpdateApp func(app *model.OAuthApp) StoreChannel

+ type PluginStore interface

+ Delete func(pluginId, key string) StoreChannel

+ Get func(pluginId, key string) StoreChannel

+ SaveOrUpdate func(keyVal *model.PluginKeyValue) StoreChannel

+ type PostStore interface

+ AnalyticsPostCount func(teamId string, mustHaveFile bool, mustHaveHashtag bool) StoreChannel

+ AnalyticsPostCountsByDay func(teamId string) StoreChannel

+ AnalyticsUserCountsWithPostsByDay func(teamId string) StoreChannel

+ ClearCaches func()

+ Delete func(postId string, time int64, deleteByID string) StoreChannel

+ Get func(id string) StoreChannel

+ GetEtag func(channelId string, allowFromCache bool) StoreChannel

+ GetFlaggedPosts func(userId string, offset int, limit int) StoreChannel

+ GetFlaggedPostsForChannel func(userId, channelId string, offset int, limit int) StoreChannel

+ GetFlaggedPostsForTeam func(userId, teamId string, offset int, limit int) StoreChannel

+ GetMaxPostSize func() StoreChannel

+ GetOldest func() StoreChannel

+ GetPosts func(channelId string, offset int, limit int, allowFromCache bool) StoreChannel

+ GetPostsAfter func(channelId string, postId string, numPosts int, offset int) StoreChannel

+ GetPostsBatchForIndexing func(startTime int64, endTime int64, limit int) StoreChannel

+ GetPostsBefore func(channelId string, postId string, numPosts int, offset int) StoreChannel

+ GetPostsByIds func(postIds []string) StoreChannel

+ GetPostsCreatedAt func(channelId string, time int64) StoreChannel

+ GetPostsSince func(channelId string, time int64, allowFromCache bool) StoreChannel

+ GetSingle func(id string) StoreChannel

+ InvalidateLastPostTimeCache func(channelId string)

+ Overwrite func(post *model.Post) StoreChannel

+ PermanentDeleteBatch func(endTime int64, limit int64) StoreChannel

+ PermanentDeleteByChannel func(channelId string) StoreChannel

+ PermanentDeleteByUser func(userId string) StoreChannel

+ Save func(post *model.Post) StoreChannel

+ Search func(teamId string, userId string, params *model.SearchParams) StoreChannel

+ Update func(newPost *model.Post, oldPost *model.Post) StoreChannel

+ type PreferenceStore interface

+ CleanupFlagsBatch func(limit int64) StoreChannel

+ Delete func(userId, category, name string) StoreChannel

+ DeleteCategory func(userId string, category string) StoreChannel

+ DeleteCategoryAndName func(category string, name string) StoreChannel

+ Get func(userId string, category string, name string) StoreChannel

+ GetAll func(userId string) StoreChannel

+ GetCategory func(userId string, category string) StoreChannel

+ IsFeatureEnabled func(feature, userId string) StoreChannel

+ PermanentDeleteByUser func(userId string) StoreChannel

+ Save func(preferences *model.Preferences) StoreChannel

+ type QueryFunction func(LayeredStoreSupplier) *LayeredStoreSupplierResult

+ type ReactionStore interface

+ Delete func(reaction *model.Reaction) StoreChannel

+ DeleteAllWithEmojiName func(emojiName string) StoreChannel

+ GetForPost func(postId string, allowFromCache bool) StoreChannel

+ PermanentDeleteBatch func(endTime int64, limit int64) StoreChannel

+ Save func(reaction *model.Reaction) StoreChannel

+ type RedisSupplier struct

+ func NewRedisSupplier() *RedisSupplier

+ func (s *RedisSupplier) Next() LayeredStoreSupplier

+ func (s *RedisSupplier) ReactionDelete(ctx context.Context, reaction *model.Reaction, hints ...LayeredStoreHint) *LayeredStoreSupplierResult

+ func (s *RedisSupplier) ReactionDeleteAllWithEmojiName(ctx context.Context, emojiName string, hints ...LayeredStoreHint) *LayeredStoreSupplierResult

+ func (s *RedisSupplier) ReactionGetForPost(ctx context.Context, postId string, hints ...LayeredStoreHint) *LayeredStoreSupplierResult

+ func (s *RedisSupplier) ReactionPermanentDeleteBatch(ctx context.Context, endTime int64, limit int64, hints ...LayeredStoreHint) *LayeredStoreSupplierResult

+ func (s *RedisSupplier) ReactionSave(ctx context.Context, reaction *model.Reaction, hints ...LayeredStoreHint) *LayeredStoreSupplierResult

+ func (s *RedisSupplier) RoleDelete(ctx context.Context, roleId string, hints ...LayeredStoreHint) *LayeredStoreSupplierResult

+ func (s *RedisSupplier) RoleGet(ctx context.Context, roleId string, hints ...LayeredStoreHint) *LayeredStoreSupplierResult

+ func (s *RedisSupplier) RoleGetByName(ctx context.Context, name string, hints ...LayeredStoreHint) *LayeredStoreSupplierResult

+ func (s *RedisSupplier) RoleGetByNames(ctx context.Context, roleNames []string, hints ...LayeredStoreHint) *LayeredStoreSupplierResult

+ func (s *RedisSupplier) RolePermanentDeleteAll(ctx context.Context, hints ...LayeredStoreHint) *LayeredStoreSupplierResult

+ func (s *RedisSupplier) RoleSave(ctx context.Context, role *model.Role, hints ...LayeredStoreHint) *LayeredStoreSupplierResult

+ func (s *RedisSupplier) SchemeDelete(ctx context.Context, schemeId string, hints ...LayeredStoreHint) *LayeredStoreSupplierResult

+ func (s *RedisSupplier) SchemeGet(ctx context.Context, schemeId string, hints ...LayeredStoreHint) *LayeredStoreSupplierResult

+ func (s *RedisSupplier) SchemeGetAllPage(ctx context.Context, scope string, offset int, limit int, ...) *LayeredStoreSupplierResult

+ func (s *RedisSupplier) SchemePermanentDeleteAll(ctx context.Context, hints ...LayeredStoreHint) *LayeredStoreSupplierResult

+ func (s *RedisSupplier) SchemeSave(ctx context.Context, scheme *model.Scheme, hints ...LayeredStoreHint) *LayeredStoreSupplierResult

+ func (s *RedisSupplier) SetChainNext(next LayeredStoreSupplier)

+ type RoleStore interface

+ Delete func(roldId string) StoreChannel

+ Get func(roleId string) StoreChannel

+ GetByName func(name string) StoreChannel

+ GetByNames func(names []string) StoreChannel

+ PermanentDeleteAll func() StoreChannel

+ Save func(role *model.Role) StoreChannel

+ type SchemeStore interface

+ Delete func(schemeId string) StoreChannel

+ Get func(schemeId string) StoreChannel

+ GetAllPage func(scope string, offset int, limit int) StoreChannel

+ PermanentDeleteAll func() StoreChannel

+ Save func(scheme *model.Scheme) StoreChannel

+ type SessionStore interface

+ AnalyticsSessionCount func() StoreChannel

+ Cleanup func(expiryTime int64, batchSize int64)

+ Get func(sessionIdOrToken string) StoreChannel

+ GetSessions func(userId string) StoreChannel

+ GetSessionsWithActiveDeviceIds func(userId string) StoreChannel

+ PermanentDeleteSessionsByUser func(teamId string) StoreChannel

+ Remove func(sessionIdOrToken string) StoreChannel

+ RemoveAllSessions func() StoreChannel

+ Save func(session *model.Session) StoreChannel

+ UpdateDeviceId func(id string, deviceId string, expiresAt int64) StoreChannel

+ UpdateLastActivityAt func(sessionId string, time int64) StoreChannel

+ UpdateRoles func(userId string, roles string) StoreChannel

+ type StatusStore interface

+ Get func(userId string) StoreChannel

+ GetAllFromTeam func(teamId string) StoreChannel

+ GetByIds func(userIds []string) StoreChannel

+ GetOnline func() StoreChannel

+ GetOnlineAway func() StoreChannel

+ GetTotalActiveUsersCount func() StoreChannel

+ ResetAll func() StoreChannel

+ SaveOrUpdate func(status *model.Status) StoreChannel

+ UpdateLastActivityAt func(userId string, lastActivityAt int64) StoreChannel

+ type Store interface

+ Audit func() AuditStore

+ Channel func() ChannelStore

+ ChannelMemberHistory func() ChannelMemberHistoryStore

+ Close func()

+ ClusterDiscovery func() ClusterDiscoveryStore

+ Command func() CommandStore

+ CommandWebhook func() CommandWebhookStore

+ Compliance func() ComplianceStore

+ DropAllTables func()

+ Emoji func() EmojiStore

+ FileInfo func() FileInfoStore

+ Job func() JobStore

+ License func() LicenseStore

+ MarkSystemRanUnitTests func()

+ OAuth func() OAuthStore

+ Plugin func() PluginStore

+ Post func() PostStore

+ Preference func() PreferenceStore

+ Reaction func() ReactionStore

+ Role func() RoleStore

+ Scheme func() SchemeStore

+ Session func() SessionStore

+ Status func() StatusStore

+ System func() SystemStore

+ Team func() TeamStore

+ Token func() TokenStore

+ TotalMasterDbConnections func() int

+ TotalReadDbConnections func() int

+ TotalSearchDbConnections func() int

+ User func() UserStore

+ UserAccessToken func() UserAccessTokenStore

+ Webhook func() WebhookStore

+ func NewLayeredStore(db LayeredStoreDatabaseLayer, metrics einterfaces.MetricsInterface, ...) Store

+ type StoreChannel chan StoreResult

+ func Do(f func(result *StoreResult)) StoreChannel

+ type StoreResult struct

+ Data interface{}

+ Err *model.AppError

+ type SystemStore interface

+ Get func() StoreChannel

+ GetByName func(name string) StoreChannel

+ PermanentDeleteByName func(name string) StoreChannel

+ Save func(system *model.System) StoreChannel

+ SaveOrUpdate func(system *model.System) StoreChannel

+ Update func(system *model.System) StoreChannel

+ type TeamStore interface

+ AnalyticsTeamCount func() StoreChannel

+ Get func(id string) StoreChannel

+ GetActiveMemberCount func(teamId string) StoreChannel

+ GetAll func() StoreChannel

+ GetAllPage func(offset int, limit int) StoreChannel

+ GetAllTeamListing func() StoreChannel

+ GetAllTeamPageListing func(offset int, limit int) StoreChannel

+ GetByInviteId func(inviteId string) StoreChannel

+ GetByName func(name string) StoreChannel

+ GetChannelUnreadsForAllTeams func(excludeTeamId, userId string) StoreChannel

+ GetChannelUnreadsForTeam func(teamId, userId string) StoreChannel

+ GetMember func(teamId string, userId string) StoreChannel

+ GetMembers func(teamId string, offset int, limit int) StoreChannel

+ GetMembersByIds func(teamId string, userIds []string) StoreChannel

+ GetTeamsByScheme func(schemeId string, offset int, limit int) StoreChannel

+ GetTeamsByUserId func(userId string) StoreChannel

+ GetTeamsForUser func(userId string) StoreChannel

+ GetTotalMemberCount func(teamId string) StoreChannel

+ MigrateTeamMembers func(fromTeamId string, fromUserId string) StoreChannel

+ PermanentDelete func(teamId string) StoreChannel

+ RemoveAllMembersByTeam func(teamId string) StoreChannel

+ RemoveAllMembersByUser func(userId string) StoreChannel

+ RemoveMember func(teamId string, userId string) StoreChannel

+ ResetAllTeamSchemes func() StoreChannel

+ Save func(team *model.Team) StoreChannel

+ SaveMember func(member *model.TeamMember, maxUsersPerTeam int) StoreChannel

+ SearchAll func(term string) StoreChannel

+ SearchByName func(name string) StoreChannel

+ SearchOpen func(term string) StoreChannel

+ Update func(team *model.Team) StoreChannel

+ UpdateDisplayName func(name string, teamId string) StoreChannel

+ UpdateLastTeamIconUpdate func(teamId string, curTime int64) StoreChannel

+ UpdateMember func(member *model.TeamMember) StoreChannel

+ type TokenStore interface

+ Cleanup func()

+ Delete func(token string) StoreChannel

+ GetByToken func(token string) StoreChannel

+ Save func(recovery *model.Token) StoreChannel

+ type UserAccessTokenStore interface

+ Delete func(tokenId string) StoreChannel

+ DeleteAllForUser func(userId string) StoreChannel

+ Get func(tokenId string) StoreChannel

+ GetAll func(offset int, limit int) StoreChannel

+ GetByToken func(tokenString string) StoreChannel

+ GetByUser func(userId string, page, perPage int) StoreChannel

+ Save func(token *model.UserAccessToken) StoreChannel

+ Search func(term string) StoreChannel

+ UpdateTokenDisable func(tokenId string) StoreChannel

+ UpdateTokenEnable func(tokenId string) StoreChannel

+ type UserStore interface

+ AnalyticsActiveCount func(time int64) StoreChannel

+ AnalyticsGetInactiveUsersCount func() StoreChannel

+ AnalyticsGetSystemAdminCount func() StoreChannel

+ AnalyticsUniqueUserCount func(teamId string) StoreChannel

+ ClearCaches func()

+ Get func(id string) StoreChannel

+ GetAll func() StoreChannel

+ GetAllProfiles func(offset int, limit int) StoreChannel

+ GetAllProfilesInChannel func(channelId string, allowFromCache bool) StoreChannel

+ GetAllUsingAuthService func(authService string) StoreChannel

+ GetByAuth func(authData *string, authService string) StoreChannel

+ GetByEmail func(email string) StoreChannel

+ GetByUsername func(username string) StoreChannel

+ GetEtagForAllProfiles func() StoreChannel

+ GetEtagForProfiles func(teamId string) StoreChannel

+ GetEtagForProfilesNotInTeam func(teamId string) StoreChannel

+ GetForLogin func(loginId string, allowSignInWithUsername, allowSignInWithEmail bool) StoreChannel

+ GetNewUsersForTeam func(teamId string, offset, limit int) StoreChannel

+ GetProfileByIds func(userId []string, allowFromCache bool) StoreChannel

+ GetProfiles func(teamId string, offset int, limit int) StoreChannel

+ GetProfilesByUsernames func(usernames []string, teamId string) StoreChannel

+ GetProfilesInChannel func(channelId string, offset int, limit int) StoreChannel

+ GetProfilesInChannelByStatus func(channelId string, offset int, limit int) StoreChannel

+ GetProfilesNotInChannel func(teamId string, channelId string, offset int, limit int) StoreChannel

+ GetProfilesNotInTeam func(teamId string, offset int, limit int) StoreChannel

+ GetProfilesWithoutTeam func(offset int, limit int) StoreChannel

+ GetRecentlyActiveUsersForTeam func(teamId string, offset, limit int) StoreChannel

+ GetSystemAdminProfiles func() StoreChannel

+ GetTotalUsersCount func() StoreChannel

+ GetUnreadCount func(userId string) StoreChannel

+ GetUnreadCountForChannel func(userId string, channelId string) StoreChannel

+ InvalidatProfileCacheForUser func(userId string)

+ InvalidateProfilesInChannelCache func(channelId string)

+ InvalidateProfilesInChannelCacheByUser func(userId string)

+ PermanentDelete func(userId string) StoreChannel

+ Save func(user *model.User) StoreChannel

+ Search func(teamId string, term string, options map[string]bool) StoreChannel

+ SearchInChannel func(channelId string, term string, options map[string]bool) StoreChannel

+ SearchNotInChannel func(teamId string, channelId string, term string, options map[string]bool) StoreChannel

+ SearchNotInTeam func(notInTeamId string, term string, options map[string]bool) StoreChannel

+ SearchWithoutTeam func(term string, options map[string]bool) StoreChannel

+ Update func(user *model.User, allowRoleUpdate bool) StoreChannel

+ UpdateAuthData func(userId string, service string, authData *string, email string, resetMfa bool) StoreChannel

+ UpdateFailedPasswordAttempts func(userId string, attempts int) StoreChannel

+ UpdateLastPictureUpdate func(userId string) StoreChannel

+ UpdateMfaActive func(userId string, active bool) StoreChannel

+ UpdateMfaSecret func(userId, secret string) StoreChannel

+ UpdatePassword func(userId, newPassword string) StoreChannel

+ UpdateUpdateAt func(userId string) StoreChannel

+ VerifyEmail func(userId string) StoreChannel

+ type WebhookStore interface

+ AnalyticsIncomingCount func(teamId string) StoreChannel

+ AnalyticsOutgoingCount func(teamId string) StoreChannel

+ ClearCaches func()

+ DeleteIncoming func(webhookId string, time int64) StoreChannel

+ DeleteOutgoing func(webhookId string, time int64) StoreChannel

+ GetIncoming func(id string, allowFromCache bool) StoreChannel

+ GetIncomingByChannel func(channelId string) StoreChannel

+ GetIncomingByTeam func(teamId string, offset, limit int) StoreChannel

+ GetIncomingList func(offset, limit int) StoreChannel

+ GetOutgoing func(id string) StoreChannel

+ GetOutgoingByChannel func(channelId string, offset, limit int) StoreChannel

+ GetOutgoingByTeam func(teamId string, offset, limit int) StoreChannel

+ GetOutgoingList func(offset, limit int) StoreChannel

+ InvalidateWebhookCache func(webhook string)

+ PermanentDeleteIncomingByChannel func(channelId string) StoreChannel

+ PermanentDeleteIncomingByUser func(userId string) StoreChannel

+ PermanentDeleteOutgoingByChannel func(channelId string) StoreChannel

+ PermanentDeleteOutgoingByUser func(userId string) StoreChannel

+ SaveIncoming func(webhook *model.IncomingWebhook) StoreChannel

+ SaveOutgoing func(webhook *model.OutgoingWebhook) StoreChannel

+ UpdateIncoming func(webhook *model.IncomingWebhook) StoreChannel

+ UpdateOutgoing func(hook *model.OutgoingWebhook) StoreChannel