platform: github.com/ftKnox/platform/store Index | Files

package store

import "github.com/ftKnox/platform/store"

Index

Package Files

sql_audit_store.go sql_channel_store.go sql_cluster_discovery_store.go sql_command_store.go sql_compliance_store.go sql_emoji_store.go sql_file_info_store.go sql_job_status_store.go sql_license_store.go sql_oauth_store.go sql_post_store.go sql_preference_store.go sql_reaction_store.go sql_session_store.go sql_status_store.go sql_store.go sql_system_store.go sql_team_store.go sql_tokens_store.go sql_upgrade.go sql_user_store.go sql_webhook_store.go store.go

Constants

const (
    MISSING_CHANNEL_ERROR        = "store.sql_channel.get_by_name.missing.app_error"
    MISSING_CHANNEL_MEMBER_ERROR = "store.sql_channel.get_member.missing.app_error"
    CHANNEL_EXISTS_ERROR         = "store.sql_channel.save_channel.exists.app_error"

    ALL_CHANNEL_MEMBERS_FOR_USER_CACHE_SIZE = model.SESSION_CACHE_SIZE
    ALL_CHANNEL_MEMBERS_FOR_USER_CACHE_SEC  = 900 // 15 mins

    ALL_CHANNEL_MEMBERS_NOTIFY_PROPS_FOR_CHANNEL_CACHE_SIZE = model.SESSION_CACHE_SIZE
    ALL_CHANNEL_MEMBERS_NOTIFY_PROPS_FOR_CHANNEL_CACHE_SEC  = 1800 // 30 mins

    CHANNEL_MEMBERS_COUNTS_CACHE_SIZE = model.CHANNEL_CACHE_SIZE
    CHANNEL_MEMBERS_COUNTS_CACHE_SEC  = 1800 // 30 mins

    CHANNEL_CACHE_SEC = 900 // 15 mins
)
const (
    EMOJI_CACHE_SIZE = 5000
    EMOJI_CACHE_SEC  = 1800 // 30 mins
)
const (
    FILE_INFO_CACHE_SIZE = 25000
    FILE_INFO_CACHE_SEC  = 1800 // 30 minutes
)
const (
    LAST_POST_TIME_CACHE_SIZE = 25000
    LAST_POST_TIME_CACHE_SEC  = 900 // 15 minutes

    LAST_POSTS_CACHE_SIZE = 1000
    LAST_POSTS_CACHE_SEC  = 900 // 15 minutes
)
const (
    REACTION_CACHE_SIZE = 20000
    REACTION_CACHE_SEC  = 1800 // 30 minutes
)
const (
    INDEX_TYPE_FULL_TEXT = "full_text"
    INDEX_TYPE_DEFAULT   = "default"
    MAX_DB_CONN_LIFETIME = 60
    DB_PING_ATTEMPTS     = 18
    DB_PING_TIMEOUT_SECS = 10
)
const (
    EXIT_CREATE_TABLE                = 100
    EXIT_DB_OPEN                     = 101
    EXIT_PING                        = 102
    EXIT_NO_DRIVER                   = 103
    EXIT_TABLE_EXISTS                = 104
    EXIT_TABLE_EXISTS_MYSQL          = 105
    EXIT_COLUMN_EXISTS               = 106
    EXIT_DOES_COLUMN_EXISTS_POSTGRES = 107
    EXIT_DOES_COLUMN_EXISTS_MYSQL    = 108
    EXIT_DOES_COLUMN_EXISTS_MISSING  = 109
    EXIT_CREATE_COLUMN_POSTGRES      = 110
    EXIT_CREATE_COLUMN_MYSQL         = 111
    EXIT_CREATE_COLUMN_MISSING       = 112
    EXIT_REMOVE_COLUMN               = 113
    EXIT_RENAME_COLUMN               = 114
    EXIT_MAX_COLUMN                  = 115
    EXIT_ALTER_COLUMN                = 116
    EXIT_CREATE_INDEX_POSTGRES       = 117
    EXIT_CREATE_INDEX_MYSQL          = 118
    EXIT_CREATE_INDEX_FULL_MYSQL     = 119
    EXIT_CREATE_INDEX_MISSING        = 120
    EXIT_REMOVE_INDEX_POSTGRES       = 121
    EXIT_REMOVE_INDEX_MYSQL          = 122
    EXIT_REMOVE_INDEX_MISSING        = 123
    EXIT_REMOVE_TABLE                = 134
)
const (
    VERSION_4_0_0  = "4.0.0"
    VERSION_3_10_0 = "3.10.0"
    VERSION_3_9_0  = "3.9.0"
    VERSION_3_8_0  = "3.8.0"
    VERSION_3_7_0  = "3.7.0"
    VERSION_3_6_0  = "3.6.0"
    VERSION_3_5_0  = "3.5.0"
    VERSION_3_4_0  = "3.4.0"
    VERSION_3_3_0  = "3.3.0"
    VERSION_3_2_0  = "3.2.0"
    VERSION_3_1_0  = "3.1.0"
    VERSION_3_0_0  = "3.0.0"
)
const (
    EXIT_VERSION_SAVE_MISSING = 1001
    EXIT_TOO_OLD              = 1002
    EXIT_VERSION_SAVE         = 1003
    EXIT_THEME_MIGRATION      = 1004
)
const (
    MISSING_ACCOUNT_ERROR                      = "store.sql_user.missing_account.const"
    MISSING_AUTH_ACCOUNT_ERROR                 = "store.sql_user.get_by_auth.missing_account.app_error"
    PROFILES_IN_CHANNEL_CACHE_SIZE             = model.CHANNEL_CACHE_SIZE
    PROFILES_IN_CHANNEL_CACHE_SEC              = 900 // 15 mins
    PROFILE_BY_IDS_CACHE_SIZE                  = model.SESSION_CACHE_SIZE
    PROFILE_BY_IDS_CACHE_SEC                   = 900 // 15 mins
    USER_SEARCH_OPTION_NAMES_ONLY              = "names_only"
    USER_SEARCH_OPTION_NAMES_ONLY_NO_FULL_NAME = "names_only_no_full_name"
    USER_SEARCH_OPTION_ALL_NO_FULL_NAME        = "all_no_full_name"
    USER_SEARCH_OPTION_ALLOW_INACTIVE          = "allow_inactive"
    USER_SEARCH_TYPE_NAMES_NO_FULL_NAME        = "Username, Nickname"
    USER_SEARCH_TYPE_NAMES                     = "Username, FirstName, LastName, Nickname"
    USER_SEARCH_TYPE_ALL_NO_FULL_NAME          = "Username, Nickname, Email"
    USER_SEARCH_TYPE_ALL                       = "Username, FirstName, LastName, Nickname, Email"
)
const (
    WEBHOOK_CACHE_SIZE = 25000
    WEBHOOK_CACHE_SEC  = 900 // 15 minutes
)
const (
    FEATURE_TOGGLE_PREFIX = "feature_enabled_"
)
const (
    MISSING_STATUS_ERROR = "store.sql_status.get.missing.app_error"
)
const (
    TEAM_MEMBER_EXISTS_ERROR = "store.sql_team.save_member.exists.app_error"
)
const (
    UPDATE_POST_HAS_REACTIONS_QUERY = "" /* 272 byte string literal not displayed */

)

func ClearChannelCaches Uses

func ClearChannelCaches()

func ClearFileCaches Uses

func ClearFileCaches()

func ClearPostCaches Uses

func ClearPostCaches()

func ClearUserCaches Uses

func ClearUserCaches()

func ClearWebhookCaches Uses

func ClearWebhookCaches()

func IsUniqueConstraintError Uses

func IsUniqueConstraintError(err string, indexName []string) bool

func Must Uses

func Must(sc StoreChannel) interface{}

func UpgradeDatabase Uses

func UpgradeDatabase(sqlStore *SqlStore)

func UpgradeDatabaseToVersion31 Uses

func UpgradeDatabaseToVersion31(sqlStore *SqlStore)

func UpgradeDatabaseToVersion310 Uses

func UpgradeDatabaseToVersion310(sqlStore *SqlStore)

func UpgradeDatabaseToVersion32 Uses

func UpgradeDatabaseToVersion32(sqlStore *SqlStore)

func UpgradeDatabaseToVersion33 Uses

func UpgradeDatabaseToVersion33(sqlStore *SqlStore)

func UpgradeDatabaseToVersion34 Uses

func UpgradeDatabaseToVersion34(sqlStore *SqlStore)

func UpgradeDatabaseToVersion35 Uses

func UpgradeDatabaseToVersion35(sqlStore *SqlStore)

func UpgradeDatabaseToVersion36 Uses

func UpgradeDatabaseToVersion36(sqlStore *SqlStore)

func UpgradeDatabaseToVersion37 Uses

func UpgradeDatabaseToVersion37(sqlStore *SqlStore)

func UpgradeDatabaseToVersion38 Uses

func UpgradeDatabaseToVersion38(sqlStore *SqlStore)

func UpgradeDatabaseToVersion39 Uses

func UpgradeDatabaseToVersion39(sqlStore *SqlStore)

func UpgradeDatabaseToVersion40 Uses

func UpgradeDatabaseToVersion40(sqlStore *SqlStore)

type AuditStore Uses

type AuditStore interface {
    Save(audit *model.Audit) StoreChannel
    Get(user_id string, offset int, limit int) StoreChannel
    PermanentDeleteByUser(userId string) StoreChannel
}

func NewSqlAuditStore Uses

func NewSqlAuditStore(sqlStore *SqlStore) AuditStore

type ChannelStore Uses

type ChannelStore interface {
    Save(channel *model.Channel) StoreChannel
    CreateDirectChannel(userId string, otherUserId string) StoreChannel
    SaveDirectChannel(channel *model.Channel, member1 *model.ChannelMember, member2 *model.ChannelMember) StoreChannel
    Update(channel *model.Channel) StoreChannel
    Get(id string, allowFromCache bool) StoreChannel
    InvalidateChannel(id string)
    InvalidateChannelByName(teamId, name string)
    GetFromMaster(id string) StoreChannel
    Delete(channelId string, time int64) StoreChannel
    Restore(channelId string, time int64) StoreChannel
    SetDeleteAt(channelId string, deleteAt int64, updateAt int64) StoreChannel
    PermanentDeleteByTeam(teamId string) StoreChannel
    PermanentDelete(channelId string) StoreChannel
    GetByName(team_id string, name string, allowFromCache bool) StoreChannel
    GetByNameIncludeDeleted(team_id string, name string, allowFromCache bool) StoreChannel
    GetDeletedByName(team_id string, name string) StoreChannel
    GetDeleted(team_id string, offset int, limit int) StoreChannel
    GetChannels(teamId string, userId string) StoreChannel
    GetMoreChannels(teamId string, userId string, offset int, limit int) StoreChannel
    GetPublicChannelsForTeam(teamId string, offset int, limit int) StoreChannel
    GetPublicChannelsByIdsForTeam(teamId string, channelIds []string) StoreChannel
    GetChannelCounts(teamId string, userId string) StoreChannel
    GetTeamChannels(teamId string) StoreChannel
    GetAll(teamId string) StoreChannel
    GetForPost(postId string) StoreChannel
    SaveMember(member *model.ChannelMember) StoreChannel
    UpdateMember(member *model.ChannelMember) StoreChannel
    GetMembers(channelId string, offset, limit int) StoreChannel
    GetMember(channelId string, userId string) StoreChannel
    GetAllChannelMembersForUser(userId string, allowFromCache bool) StoreChannel
    InvalidateAllChannelMembersForUser(userId string)
    IsUserInChannelUseCache(userId string, channelId string) bool
    GetAllChannelMembersNotifyPropsForChannel(channelId string, allowFromCache bool) StoreChannel
    InvalidateCacheForChannelMembersNotifyProps(channelId string)
    GetMemberForPost(postId string, userId string) StoreChannel
    InvalidateMemberCount(channelId string)
    GetMemberCountFromCache(channelId string) int64
    GetMemberCount(channelId string, allowFromCache bool) StoreChannel
    GetPinnedPosts(channelId string) StoreChannel
    RemoveMember(channelId string, userId string) StoreChannel
    PermanentDeleteMembersByUser(userId string) StoreChannel
    PermanentDeleteMembersByChannel(channelId string) StoreChannel
    UpdateLastViewedAt(channelIds []string, userId string) StoreChannel
    IncrementMentionCount(channelId string, userId string) StoreChannel
    AnalyticsTypeCount(teamId string, channelType string) StoreChannel
    ExtraUpdateByUser(userId string, time int64) StoreChannel
    GetMembersForUser(teamId string, userId string) StoreChannel
    SearchInTeam(teamId string, term string) StoreChannel
    SearchMore(userId string, teamId string, term string) StoreChannel
    GetMembersByIds(channelId string, userIds []string) StoreChannel
    AnalyticsDeletedTypeCount(teamId string, channelType string) StoreChannel
    GetChannelUnread(channelId, userId string) StoreChannel
}

func NewSqlChannelStore Uses

func NewSqlChannelStore(sqlStore *SqlStore) ChannelStore

type ClusterDiscoveryStore Uses

type ClusterDiscoveryStore interface {
    Save(discovery *model.ClusterDiscovery) StoreChannel
    Delete(discovery *model.ClusterDiscovery) StoreChannel
    Exists(discovery *model.ClusterDiscovery) StoreChannel
    GetAll(discoveryType, clusterName string) StoreChannel
    SetLastPingAt(discovery *model.ClusterDiscovery) StoreChannel
    Cleanup() StoreChannel
}

func NewSqlClusterDiscoveryStore Uses

func NewSqlClusterDiscoveryStore(sqlStore *SqlStore) ClusterDiscoveryStore

type CommandStore Uses

type CommandStore interface {
    Save(webhook *model.Command) StoreChannel
    Get(id string) StoreChannel
    GetByTeam(teamId string) StoreChannel
    Delete(commandId string, time int64) StoreChannel
    PermanentDeleteByUser(userId string) StoreChannel
    Update(hook *model.Command) StoreChannel
    AnalyticsCommandCount(teamId string) StoreChannel
}

func NewSqlCommandStore Uses

func NewSqlCommandStore(sqlStore *SqlStore) CommandStore

type ComplianceStore Uses

type ComplianceStore interface {
    Save(compliance *model.Compliance) StoreChannel
    Update(compliance *model.Compliance) StoreChannel
    Get(id string) StoreChannel
    GetAll(offset, limit int) StoreChannel
    ComplianceExport(compliance *model.Compliance) StoreChannel
}

func NewSqlComplianceStore Uses

func NewSqlComplianceStore(sqlStore *SqlStore) ComplianceStore

type EmojiStore Uses

type EmojiStore interface {
    Save(emoji *model.Emoji) StoreChannel
    Get(id string, allowFromCache bool) StoreChannel
    GetByName(name string) StoreChannel
    GetAll() StoreChannel
    Delete(id string, time int64) StoreChannel
}

func NewSqlEmojiStore Uses

func NewSqlEmojiStore(sqlStore *SqlStore) EmojiStore

type FileInfoStore Uses

type FileInfoStore interface {
    Save(info *model.FileInfo) StoreChannel
    Get(id string) StoreChannel
    GetByPath(path string) StoreChannel
    GetForPost(postId string, readFromMaster bool, allowFromCache bool) StoreChannel
    InvalidateFileInfosForPostCache(postId string)
    AttachToPost(fileId string, postId string) StoreChannel
    DeleteForPost(postId string) StoreChannel
}

func NewSqlFileInfoStore Uses

func NewSqlFileInfoStore(sqlStore *SqlStore) FileInfoStore

type JobStatusStore Uses

type JobStatusStore interface {
    SaveOrUpdate(status *model.JobStatus) StoreChannel
    Get(id string) StoreChannel
    GetAllByType(jobType string) StoreChannel
    GetAllByTypePage(jobType string, offset int, limit int) StoreChannel
    Delete(id string) StoreChannel
}

func NewSqlJobStatusStore Uses

func NewSqlJobStatusStore(sqlStore *SqlStore) JobStatusStore

type LicenseStore Uses

type LicenseStore interface {
    Save(license *model.LicenseRecord) StoreChannel
    Get(id string) StoreChannel
}

func NewSqlLicenseStore Uses

func NewSqlLicenseStore(sqlStore *SqlStore) LicenseStore

type OAuthStore Uses

type OAuthStore interface {
    SaveApp(app *model.OAuthApp) StoreChannel
    UpdateApp(app *model.OAuthApp) StoreChannel
    GetApp(id string) StoreChannel
    GetAppByUser(userId string, offset, limit int) StoreChannel
    GetApps(offset, limit int) StoreChannel
    GetAuthorizedApps(userId string, offset, limit int) StoreChannel
    DeleteApp(id string) StoreChannel
    SaveAuthData(authData *model.AuthData) StoreChannel
    GetAuthData(code string) StoreChannel
    RemoveAuthData(code string) StoreChannel
    PermanentDeleteAuthDataByUser(userId string) StoreChannel
    SaveAccessData(accessData *model.AccessData) StoreChannel
    UpdateAccessData(accessData *model.AccessData) StoreChannel
    GetAccessData(token string) StoreChannel
    GetAccessDataByUserForApp(userId, clientId string) StoreChannel
    GetAccessDataByRefreshToken(token string) StoreChannel
    GetPreviousAccessData(userId, clientId string) StoreChannel
    RemoveAccessData(token string) StoreChannel
}

func NewSqlOAuthStore Uses

func NewSqlOAuthStore(sqlStore *SqlStore) OAuthStore

type PostStore Uses

type PostStore interface {
    Save(post *model.Post) StoreChannel
    Update(newPost *model.Post, oldPost *model.Post) StoreChannel
    Get(id string) StoreChannel
    GetSingle(id string) StoreChannel
    Delete(postId string, time int64) StoreChannel
    PermanentDeleteByUser(userId string) StoreChannel
    PermanentDeleteByChannel(channelId string) StoreChannel
    GetPosts(channelId string, offset int, limit int, allowFromCache bool) StoreChannel
    GetFlaggedPosts(userId string, offset int, limit int) StoreChannel
    GetFlaggedPostsForTeam(userId, teamId string, offset int, limit int) StoreChannel
    GetFlaggedPostsForChannel(userId, channelId string, offset int, limit int) StoreChannel
    GetPostsBefore(channelId string, postId string, numPosts int, offset int) StoreChannel
    GetPostsAfter(channelId string, postId string, numPosts int, offset int) StoreChannel
    GetPostsSince(channelId string, time int64, allowFromCache bool) StoreChannel
    GetEtag(channelId string, allowFromCache bool) StoreChannel
    Search(teamId string, userId string, params *model.SearchParams) StoreChannel
    AnalyticsUserCountsWithPostsByDay(teamId string) StoreChannel
    AnalyticsPostCountsByDay(teamId string) StoreChannel
    AnalyticsPostCount(teamId string, mustHaveFile bool, mustHaveHashtag bool) StoreChannel
    InvalidateLastPostTimeCache(channelId string)
    GetPostsCreatedAt(channelId string, time int64) StoreChannel
    Overwrite(post *model.Post) StoreChannel
    GetPostsByIds(postIds []string) StoreChannel
}

func NewSqlPostStore Uses

func NewSqlPostStore(sqlStore *SqlStore) PostStore

type PreferenceStore Uses

type PreferenceStore interface {
    Save(preferences *model.Preferences) StoreChannel
    Get(userId string, category string, name string) StoreChannel
    GetCategory(userId string, category string) StoreChannel
    GetAll(userId string) StoreChannel
    Delete(userId, category, name string) StoreChannel
    DeleteCategory(userId string, category string) StoreChannel
    DeleteCategoryAndName(category string, name string) StoreChannel
    PermanentDeleteByUser(userId string) StoreChannel
    IsFeatureEnabled(feature, userId string) StoreChannel
}

func NewSqlPreferenceStore Uses

func NewSqlPreferenceStore(sqlStore *SqlStore) PreferenceStore

type ReactionStore Uses

type ReactionStore interface {
    Save(reaction *model.Reaction) StoreChannel
    Delete(reaction *model.Reaction) StoreChannel
    InvalidateCacheForPost(postId string)
    InvalidateCache()
    GetForPost(postId string, allowFromCache bool) StoreChannel
    DeleteAllWithEmojiName(emojiName string) StoreChannel
}

func NewSqlReactionStore Uses

func NewSqlReactionStore(sqlStore *SqlStore) ReactionStore

type SessionStore Uses

type SessionStore interface {
    Save(session *model.Session) StoreChannel
    Get(sessionIdOrToken string) StoreChannel
    GetSessions(userId string) StoreChannel
    GetSessionsWithActiveDeviceIds(userId string) StoreChannel
    Remove(sessionIdOrToken string) StoreChannel
    RemoveAllSessions() StoreChannel
    PermanentDeleteSessionsByUser(teamId string) StoreChannel
    UpdateLastActivityAt(sessionId string, time int64) StoreChannel
    UpdateRoles(userId string, roles string) StoreChannel
    UpdateDeviceId(id string, deviceId string, expiresAt int64) StoreChannel
    AnalyticsSessionCount() StoreChannel
}

func NewSqlSessionStore Uses

func NewSqlSessionStore(sqlStore *SqlStore) SessionStore

type SqlAuditStore Uses

type SqlAuditStore struct {
    *SqlStore
}

func (SqlAuditStore) CreateIndexesIfNotExists Uses

func (s SqlAuditStore) CreateIndexesIfNotExists()

func (SqlAuditStore) Get Uses

func (s SqlAuditStore) Get(user_id string, offset int, limit int) StoreChannel

func (SqlAuditStore) PermanentDeleteByUser Uses

func (s SqlAuditStore) PermanentDeleteByUser(userId string) StoreChannel

func (SqlAuditStore) Save Uses

func (s SqlAuditStore) Save(audit *model.Audit) StoreChannel

type SqlChannelStore Uses

type SqlChannelStore struct {
    *SqlStore
}

func (SqlChannelStore) AnalyticsDeletedTypeCount Uses

func (s SqlChannelStore) AnalyticsDeletedTypeCount(teamId string, channelType string) StoreChannel

func (SqlChannelStore) AnalyticsTypeCount Uses

func (s SqlChannelStore) AnalyticsTypeCount(teamId string, channelType string) StoreChannel

func (SqlChannelStore) CreateDirectChannel Uses

func (s SqlChannelStore) CreateDirectChannel(userId string, otherUserId string) StoreChannel

func (SqlChannelStore) CreateIndexesIfNotExists Uses

func (s SqlChannelStore) CreateIndexesIfNotExists()

func (SqlChannelStore) Delete Uses

func (s SqlChannelStore) Delete(channelId string, time int64) StoreChannel

func (SqlChannelStore) ExtraUpdateByUser Uses

func (s SqlChannelStore) ExtraUpdateByUser(userId string, time int64) StoreChannel

func (SqlChannelStore) Get Uses

func (s SqlChannelStore) Get(id string, allowFromCache bool) StoreChannel

func (SqlChannelStore) GetAll Uses

func (s SqlChannelStore) GetAll(teamId string) StoreChannel

func (SqlChannelStore) GetAllChannelMembersForUser Uses

func (s SqlChannelStore) GetAllChannelMembersForUser(userId string, allowFromCache bool) StoreChannel

func (SqlChannelStore) GetAllChannelMembersNotifyPropsForChannel Uses

func (s SqlChannelStore) GetAllChannelMembersNotifyPropsForChannel(channelId string, allowFromCache bool) StoreChannel

func (SqlChannelStore) GetByName Uses

func (s SqlChannelStore) GetByName(teamId string, name string, allowFromCache bool) StoreChannel

func (SqlChannelStore) GetByNameIncludeDeleted Uses

func (s SqlChannelStore) GetByNameIncludeDeleted(teamId string, name string, allowFromCache bool) StoreChannel

func (SqlChannelStore) GetChannelCounts Uses

func (s SqlChannelStore) GetChannelCounts(teamId string, userId string) StoreChannel

func (SqlChannelStore) GetChannelUnread Uses

func (s SqlChannelStore) GetChannelUnread(channelId, userId string) StoreChannel

func (SqlChannelStore) GetChannels Uses

func (s SqlChannelStore) GetChannels(teamId string, userId string) StoreChannel

func (SqlChannelStore) GetDeleted Uses

func (s SqlChannelStore) GetDeleted(teamId string, offset int, limit int) StoreChannel

func (SqlChannelStore) GetDeletedByName Uses

func (s SqlChannelStore) GetDeletedByName(teamId string, name string) StoreChannel

func (SqlChannelStore) GetForPost Uses

func (s SqlChannelStore) GetForPost(postId string) StoreChannel

func (SqlChannelStore) GetFromMaster Uses

func (s SqlChannelStore) GetFromMaster(id string) StoreChannel

func (SqlChannelStore) GetMember Uses

func (s SqlChannelStore) GetMember(channelId string, userId string) StoreChannel

func (SqlChannelStore) GetMemberCount Uses

func (s SqlChannelStore) GetMemberCount(channelId string, allowFromCache bool) StoreChannel

func (SqlChannelStore) GetMemberCountFromCache Uses

func (s SqlChannelStore) GetMemberCountFromCache(channelId string) int64

func (SqlChannelStore) GetMemberForPost Uses

func (s SqlChannelStore) GetMemberForPost(postId string, userId string) StoreChannel

func (SqlChannelStore) GetMembers Uses

func (s SqlChannelStore) GetMembers(channelId string, offset, limit int) StoreChannel

func (SqlChannelStore) GetMembersByIds Uses

func (s SqlChannelStore) GetMembersByIds(channelId string, userIds []string) StoreChannel

func (SqlChannelStore) GetMembersForUser Uses

func (s SqlChannelStore) GetMembersForUser(teamId string, userId string) StoreChannel

func (SqlChannelStore) GetMoreChannels Uses

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

func (SqlChannelStore) GetPinnedPosts Uses

func (s SqlChannelStore) GetPinnedPosts(channelId string) StoreChannel

func (SqlChannelStore) GetPublicChannelsByIdsForTeam Uses

func (s SqlChannelStore) GetPublicChannelsByIdsForTeam(teamId string, channelIds []string) StoreChannel

func (SqlChannelStore) GetPublicChannelsForTeam Uses

func (s SqlChannelStore) GetPublicChannelsForTeam(teamId string, offset int, limit int) StoreChannel

func (SqlChannelStore) GetTeamChannels Uses

func (s SqlChannelStore) GetTeamChannels(teamId string) StoreChannel

func (SqlChannelStore) IncrementMentionCount Uses

func (s SqlChannelStore) IncrementMentionCount(channelId string, userId string) StoreChannel

func (SqlChannelStore) InvalidateAllChannelMembersForUser Uses

func (us SqlChannelStore) InvalidateAllChannelMembersForUser(userId string)

func (SqlChannelStore) InvalidateCacheForChannelMembersNotifyProps Uses

func (us SqlChannelStore) InvalidateCacheForChannelMembersNotifyProps(channelId string)

func (SqlChannelStore) InvalidateChannel Uses

func (us SqlChannelStore) InvalidateChannel(id string)

func (SqlChannelStore) InvalidateChannelByName Uses

func (us SqlChannelStore) InvalidateChannelByName(teamId, name string)

func (SqlChannelStore) InvalidateMemberCount Uses

func (us SqlChannelStore) InvalidateMemberCount(channelId string)

func (SqlChannelStore) IsUserInChannelUseCache Uses

func (us SqlChannelStore) IsUserInChannelUseCache(userId string, channelId string) bool

func (SqlChannelStore) PermanentDelete Uses

func (s SqlChannelStore) PermanentDelete(channelId string) StoreChannel

func (SqlChannelStore) PermanentDeleteByTeam Uses

func (s SqlChannelStore) PermanentDeleteByTeam(teamId string) StoreChannel

func (SqlChannelStore) PermanentDeleteMembersByChannel Uses

func (s SqlChannelStore) PermanentDeleteMembersByChannel(channelId string) StoreChannel

func (SqlChannelStore) PermanentDeleteMembersByUser Uses

func (s SqlChannelStore) PermanentDeleteMembersByUser(userId string) StoreChannel

func (SqlChannelStore) RemoveMember Uses

func (s SqlChannelStore) RemoveMember(channelId string, userId string) StoreChannel

func (SqlChannelStore) Restore Uses

func (s SqlChannelStore) Restore(channelId string, time int64) StoreChannel

func (SqlChannelStore) Save Uses

func (s SqlChannelStore) Save(channel *model.Channel) StoreChannel

func (SqlChannelStore) SaveDirectChannel Uses

func (s SqlChannelStore) SaveDirectChannel(directchannel *model.Channel, member1 *model.ChannelMember, member2 *model.ChannelMember) StoreChannel

func (SqlChannelStore) SaveMember Uses

func (s SqlChannelStore) SaveMember(member *model.ChannelMember) StoreChannel

func (SqlChannelStore) SearchInTeam Uses

func (s SqlChannelStore) SearchInTeam(teamId string, term string) StoreChannel

func (SqlChannelStore) SearchMore Uses

func (s SqlChannelStore) SearchMore(userId string, teamId string, term string) StoreChannel

func (SqlChannelStore) SetDeleteAt Uses

func (s SqlChannelStore) SetDeleteAt(channelId string, deleteAt int64, updateAt int64) StoreChannel

func (SqlChannelStore) Update Uses

func (s SqlChannelStore) Update(channel *model.Channel) StoreChannel

func (SqlChannelStore) UpdateLastViewedAt Uses

func (s SqlChannelStore) UpdateLastViewedAt(channelIds []string, userId string) StoreChannel

func (SqlChannelStore) UpdateMember Uses

func (s SqlChannelStore) UpdateMember(member *model.ChannelMember) StoreChannel

type SqlCommandStore Uses

type SqlCommandStore struct {
    *SqlStore
}

func (SqlCommandStore) AnalyticsCommandCount Uses

func (s SqlCommandStore) AnalyticsCommandCount(teamId string) StoreChannel

func (SqlCommandStore) CreateIndexesIfNotExists Uses

func (s SqlCommandStore) CreateIndexesIfNotExists()

func (SqlCommandStore) Delete Uses

func (s SqlCommandStore) Delete(commandId string, time int64) StoreChannel

func (SqlCommandStore) Get Uses

func (s SqlCommandStore) Get(id string) StoreChannel

func (SqlCommandStore) GetByTeam Uses

func (s SqlCommandStore) GetByTeam(teamId string) StoreChannel

func (SqlCommandStore) PermanentDeleteByUser Uses

func (s SqlCommandStore) PermanentDeleteByUser(userId string) StoreChannel

func (SqlCommandStore) Save Uses

func (s SqlCommandStore) Save(command *model.Command) StoreChannel

func (SqlCommandStore) Update Uses

func (s SqlCommandStore) Update(cmd *model.Command) StoreChannel

type SqlComplianceStore Uses

type SqlComplianceStore struct {
    *SqlStore
}

func (SqlComplianceStore) ComplianceExport Uses

func (s SqlComplianceStore) ComplianceExport(job *model.Compliance) StoreChannel

func (SqlComplianceStore) CreateIndexesIfNotExists Uses

func (s SqlComplianceStore) CreateIndexesIfNotExists()

func (SqlComplianceStore) Get Uses

func (us SqlComplianceStore) Get(id string) StoreChannel

func (SqlComplianceStore) GetAll Uses

func (s SqlComplianceStore) GetAll(offset, limit int) StoreChannel

func (SqlComplianceStore) Save Uses

func (s SqlComplianceStore) Save(compliance *model.Compliance) StoreChannel

func (SqlComplianceStore) Update Uses

func (us SqlComplianceStore) Update(compliance *model.Compliance) StoreChannel

type SqlEmojiStore Uses

type SqlEmojiStore struct {
    *SqlStore
}

func (SqlEmojiStore) CreateIndexesIfNotExists Uses

func (es SqlEmojiStore) CreateIndexesIfNotExists()

func (SqlEmojiStore) Delete Uses

func (es SqlEmojiStore) Delete(id string, time int64) StoreChannel

func (SqlEmojiStore) Get Uses

func (es SqlEmojiStore) Get(id string, allowFromCache bool) StoreChannel

func (SqlEmojiStore) GetAll Uses

func (es SqlEmojiStore) GetAll() StoreChannel

func (SqlEmojiStore) GetByName Uses

func (es SqlEmojiStore) GetByName(name string) StoreChannel

func (SqlEmojiStore) Save Uses

func (es SqlEmojiStore) Save(emoji *model.Emoji) StoreChannel

type SqlFileInfoStore Uses

type SqlFileInfoStore struct {
    *SqlStore
}

func (SqlFileInfoStore) AttachToPost Uses

func (fs SqlFileInfoStore) AttachToPost(fileId, postId string) StoreChannel

func (SqlFileInfoStore) CreateIndexesIfNotExists Uses

func (fs SqlFileInfoStore) CreateIndexesIfNotExists()

func (SqlFileInfoStore) DeleteForPost Uses

func (fs SqlFileInfoStore) DeleteForPost(postId string) StoreChannel

func (SqlFileInfoStore) Get Uses

func (fs SqlFileInfoStore) Get(id string) StoreChannel

func (SqlFileInfoStore) GetByPath Uses

func (fs SqlFileInfoStore) GetByPath(path string) StoreChannel

func (SqlFileInfoStore) GetForPost Uses

func (fs SqlFileInfoStore) GetForPost(postId string, readFromMaster bool, allowFromCache bool) StoreChannel

func (SqlFileInfoStore) InvalidateFileInfosForPostCache Uses

func (s SqlFileInfoStore) InvalidateFileInfosForPostCache(postId string)

func (SqlFileInfoStore) Save Uses

func (fs SqlFileInfoStore) Save(info *model.FileInfo) StoreChannel

type SqlJobStatusStore Uses

type SqlJobStatusStore struct {
    *SqlStore
}

func (SqlJobStatusStore) CreateIndexesIfNotExists Uses

func (jss SqlJobStatusStore) CreateIndexesIfNotExists()

func (SqlJobStatusStore) Delete Uses

func (jss SqlJobStatusStore) Delete(id string) StoreChannel

func (SqlJobStatusStore) Get Uses

func (jss SqlJobStatusStore) Get(id string) StoreChannel

func (SqlJobStatusStore) GetAllByType Uses

func (jss SqlJobStatusStore) GetAllByType(jobType string) StoreChannel

func (SqlJobStatusStore) GetAllByTypePage Uses

func (jss SqlJobStatusStore) GetAllByTypePage(jobType string, offset int, limit int) StoreChannel

func (SqlJobStatusStore) SaveOrUpdate Uses

func (jss SqlJobStatusStore) SaveOrUpdate(status *model.JobStatus) StoreChannel

type SqlLicenseStore Uses

type SqlLicenseStore struct {
    *SqlStore
}

func (SqlLicenseStore) CreateIndexesIfNotExists Uses

func (ls SqlLicenseStore) CreateIndexesIfNotExists()

func (SqlLicenseStore) Get Uses

func (ls SqlLicenseStore) Get(id string) StoreChannel

func (SqlLicenseStore) Save Uses

func (ls SqlLicenseStore) Save(license *model.LicenseRecord) StoreChannel

type SqlOAuthStore Uses

type SqlOAuthStore struct {
    *SqlStore
}

func (SqlOAuthStore) CreateIndexesIfNotExists Uses

func (as SqlOAuthStore) CreateIndexesIfNotExists()

func (SqlOAuthStore) DeleteApp Uses

func (as SqlOAuthStore) DeleteApp(id string) StoreChannel

func (SqlOAuthStore) GetAccessData Uses

func (as SqlOAuthStore) GetAccessData(token string) StoreChannel

func (SqlOAuthStore) GetAccessDataByRefreshToken Uses

func (as SqlOAuthStore) GetAccessDataByRefreshToken(token string) StoreChannel

func (SqlOAuthStore) GetAccessDataByUserForApp Uses

func (as SqlOAuthStore) GetAccessDataByUserForApp(userId, clientId string) StoreChannel

func (SqlOAuthStore) GetApp Uses

func (as SqlOAuthStore) GetApp(id string) StoreChannel

func (SqlOAuthStore) GetAppByUser Uses

func (as SqlOAuthStore) GetAppByUser(userId string, offset, limit int) StoreChannel

func (SqlOAuthStore) GetApps Uses

func (as SqlOAuthStore) GetApps(offset, limit int) StoreChannel

func (SqlOAuthStore) GetAuthData Uses

func (as SqlOAuthStore) GetAuthData(code string) StoreChannel

func (SqlOAuthStore) GetAuthorizedApps Uses

func (as SqlOAuthStore) GetAuthorizedApps(userId string, offset, limit int) StoreChannel

func (SqlOAuthStore) GetPreviousAccessData Uses

func (as SqlOAuthStore) GetPreviousAccessData(userId, clientId string) StoreChannel

func (SqlOAuthStore) PermanentDeleteAuthDataByUser Uses

func (as SqlOAuthStore) PermanentDeleteAuthDataByUser(userId string) StoreChannel

func (SqlOAuthStore) RemoveAccessData Uses

func (as SqlOAuthStore) RemoveAccessData(token string) StoreChannel

func (SqlOAuthStore) RemoveAuthData Uses

func (as SqlOAuthStore) RemoveAuthData(code string) StoreChannel

func (SqlOAuthStore) SaveAccessData Uses

func (as SqlOAuthStore) SaveAccessData(accessData *model.AccessData) StoreChannel

func (SqlOAuthStore) SaveApp Uses

func (as SqlOAuthStore) SaveApp(app *model.OAuthApp) StoreChannel

func (SqlOAuthStore) SaveAuthData Uses

func (as SqlOAuthStore) SaveAuthData(authData *model.AuthData) StoreChannel

func (SqlOAuthStore) UpdateAccessData Uses

func (as SqlOAuthStore) UpdateAccessData(accessData *model.AccessData) StoreChannel

func (SqlOAuthStore) UpdateApp Uses

func (as SqlOAuthStore) UpdateApp(app *model.OAuthApp) StoreChannel

type SqlPostStore Uses

type SqlPostStore struct {
    *SqlStore
}

func (SqlPostStore) AnalyticsPostCount Uses

func (s SqlPostStore) AnalyticsPostCount(teamId string, mustHaveFile bool, mustHaveHashtag bool) StoreChannel

func (SqlPostStore) AnalyticsPostCountsByDay Uses

func (s SqlPostStore) AnalyticsPostCountsByDay(teamId string) StoreChannel

func (SqlPostStore) AnalyticsUserCountsWithPostsByDay Uses

func (s SqlPostStore) AnalyticsUserCountsWithPostsByDay(teamId string) StoreChannel

func (SqlPostStore) CreateIndexesIfNotExists Uses

func (s SqlPostStore) CreateIndexesIfNotExists()

func (SqlPostStore) Delete Uses

func (s SqlPostStore) Delete(postId string, time int64) StoreChannel

func (SqlPostStore) Get Uses

func (s SqlPostStore) Get(id string) StoreChannel

func (SqlPostStore) GetEtag Uses

func (s SqlPostStore) GetEtag(channelId string, allowFromCache bool) StoreChannel

func (SqlPostStore) GetFlaggedPosts Uses

func (s SqlPostStore) GetFlaggedPosts(userId string, offset int, limit int) StoreChannel

func (SqlPostStore) GetFlaggedPostsForChannel Uses

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

func (SqlPostStore) GetFlaggedPostsForTeam Uses

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

func (SqlPostStore) GetPosts Uses

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

func (SqlPostStore) GetPostsAfter Uses

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

func (SqlPostStore) GetPostsBefore Uses

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

func (SqlPostStore) GetPostsByIds Uses

func (s SqlPostStore) GetPostsByIds(postIds []string) StoreChannel

func (SqlPostStore) GetPostsCreatedAt Uses

func (s SqlPostStore) GetPostsCreatedAt(channelId string, time int64) StoreChannel

func (SqlPostStore) GetPostsSince Uses

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

func (SqlPostStore) GetSingle Uses

func (s SqlPostStore) GetSingle(id string) StoreChannel

func (SqlPostStore) InvalidateLastPostTimeCache Uses

func (s SqlPostStore) InvalidateLastPostTimeCache(channelId string)

func (SqlPostStore) Overwrite Uses

func (s SqlPostStore) Overwrite(post *model.Post) StoreChannel

func (SqlPostStore) PermanentDeleteByChannel Uses

func (s SqlPostStore) PermanentDeleteByChannel(channelId string) StoreChannel

func (SqlPostStore) PermanentDeleteByUser Uses

func (s SqlPostStore) PermanentDeleteByUser(userId string) StoreChannel

func (SqlPostStore) Save Uses

func (s SqlPostStore) Save(post *model.Post) StoreChannel

func (SqlPostStore) Search Uses

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

func (SqlPostStore) Update Uses

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

type SqlPreferenceStore Uses

type SqlPreferenceStore struct {
    *SqlStore
}

func (SqlPreferenceStore) CreateIndexesIfNotExists Uses

func (s SqlPreferenceStore) CreateIndexesIfNotExists()

func (SqlPreferenceStore) Delete Uses

func (s SqlPreferenceStore) Delete(userId, category, name string) StoreChannel

func (SqlPreferenceStore) DeleteCategory Uses

func (s SqlPreferenceStore) DeleteCategory(userId string, category string) StoreChannel

func (SqlPreferenceStore) DeleteCategoryAndName Uses

func (s SqlPreferenceStore) DeleteCategoryAndName(category string, name string) StoreChannel

func (SqlPreferenceStore) DeleteUnusedFeatures Uses

func (s SqlPreferenceStore) DeleteUnusedFeatures()

func (SqlPreferenceStore) Get Uses

func (s SqlPreferenceStore) Get(userId string, category string, name string) StoreChannel

func (SqlPreferenceStore) GetAll Uses

func (s SqlPreferenceStore) GetAll(userId string) StoreChannel

func (SqlPreferenceStore) GetCategory Uses

func (s SqlPreferenceStore) GetCategory(userId string, category string) StoreChannel

func (SqlPreferenceStore) IsFeatureEnabled Uses

func (s SqlPreferenceStore) IsFeatureEnabled(feature, userId string) StoreChannel

func (SqlPreferenceStore) PermanentDeleteByUser Uses

func (s SqlPreferenceStore) PermanentDeleteByUser(userId string) StoreChannel

func (SqlPreferenceStore) Save Uses

func (s SqlPreferenceStore) Save(preferences *model.Preferences) StoreChannel

type SqlReactionStore Uses

type SqlReactionStore struct {
    *SqlStore
}

func (SqlReactionStore) CreateIndexesIfNotExists Uses

func (s SqlReactionStore) CreateIndexesIfNotExists()

func (SqlReactionStore) Delete Uses

func (s SqlReactionStore) Delete(reaction *model.Reaction) StoreChannel

func (SqlReactionStore) DeleteAllWithEmojiName Uses

func (s SqlReactionStore) DeleteAllWithEmojiName(emojiName string) StoreChannel

func (SqlReactionStore) GetForPost Uses

func (s SqlReactionStore) GetForPost(postId string, allowFromCache bool) StoreChannel

func (SqlReactionStore) InvalidateCache Uses

func (s SqlReactionStore) InvalidateCache()

func (SqlReactionStore) InvalidateCacheForPost Uses

func (s SqlReactionStore) InvalidateCacheForPost(postId string)

func (SqlReactionStore) Save Uses

func (s SqlReactionStore) Save(reaction *model.Reaction) StoreChannel

type SqlSessionStore Uses

type SqlSessionStore struct {
    *SqlStore
}

func (SqlSessionStore) AnalyticsSessionCount Uses

func (me SqlSessionStore) AnalyticsSessionCount() StoreChannel

func (SqlSessionStore) CleanUpExpiredSessions Uses

func (me SqlSessionStore) CleanUpExpiredSessions(userId string) StoreChannel

func (SqlSessionStore) CreateIndexesIfNotExists Uses

func (me SqlSessionStore) CreateIndexesIfNotExists()

func (SqlSessionStore) Get Uses

func (me SqlSessionStore) Get(sessionIdOrToken string) StoreChannel

func (SqlSessionStore) GetSessions Uses

func (me SqlSessionStore) GetSessions(userId string) StoreChannel

func (SqlSessionStore) GetSessionsWithActiveDeviceIds Uses

func (me SqlSessionStore) GetSessionsWithActiveDeviceIds(userId string) StoreChannel

func (SqlSessionStore) PermanentDeleteSessionsByUser Uses

func (me SqlSessionStore) PermanentDeleteSessionsByUser(userId string) StoreChannel

func (SqlSessionStore) Remove Uses

func (me SqlSessionStore) Remove(sessionIdOrToken string) StoreChannel

func (SqlSessionStore) RemoveAllSessions Uses

func (me SqlSessionStore) RemoveAllSessions() StoreChannel

func (SqlSessionStore) Save Uses

func (me SqlSessionStore) Save(session *model.Session) StoreChannel

func (SqlSessionStore) UpdateDeviceId Uses

func (me SqlSessionStore) UpdateDeviceId(id string, deviceId string, expiresAt int64) StoreChannel

func (SqlSessionStore) UpdateLastActivityAt Uses

func (me SqlSessionStore) UpdateLastActivityAt(sessionId string, time int64) StoreChannel

func (SqlSessionStore) UpdateRoles Uses

func (me SqlSessionStore) UpdateRoles(userId, roles string) StoreChannel

type SqlStatusStore Uses

type SqlStatusStore struct {
    *SqlStore
}

func (SqlStatusStore) CreateIndexesIfNotExists Uses

func (s SqlStatusStore) CreateIndexesIfNotExists()

func (SqlStatusStore) Get Uses

func (s SqlStatusStore) Get(userId string) StoreChannel

func (SqlStatusStore) GetAllFromTeam Uses

func (s SqlStatusStore) GetAllFromTeam(teamId string) StoreChannel

func (SqlStatusStore) GetByIds Uses

func (s SqlStatusStore) GetByIds(userIds []string) StoreChannel

func (SqlStatusStore) GetOnline Uses

func (s SqlStatusStore) GetOnline() StoreChannel

func (SqlStatusStore) GetOnlineAway Uses

func (s SqlStatusStore) GetOnlineAway() StoreChannel

func (SqlStatusStore) GetTotalActiveUsersCount Uses

func (s SqlStatusStore) GetTotalActiveUsersCount() StoreChannel

func (SqlStatusStore) ResetAll Uses

func (s SqlStatusStore) ResetAll() StoreChannel

func (SqlStatusStore) SaveOrUpdate Uses

func (s SqlStatusStore) SaveOrUpdate(status *model.Status) StoreChannel

func (SqlStatusStore) UpdateLastActivityAt Uses

func (s SqlStatusStore) UpdateLastActivityAt(userId string, lastActivityAt int64) StoreChannel

type SqlStore Uses

type SqlStore struct {
    SchemaVersion string
    // contains filtered or unexported fields
}

func (*SqlStore) AlterColumnTypeIfExists Uses

func (ss *SqlStore) AlterColumnTypeIfExists(tableName string, columnName string, mySqlColType string, postgresColType string) bool

func (*SqlStore) Audit Uses

func (ss *SqlStore) Audit() AuditStore

func (*SqlStore) Channel Uses

func (ss *SqlStore) Channel() ChannelStore

func (*SqlStore) Close Uses

func (ss *SqlStore) Close()

func (*SqlStore) ClusterDiscovery Uses

func (ss *SqlStore) ClusterDiscovery() ClusterDiscoveryStore

func (*SqlStore) Command Uses

func (ss *SqlStore) Command() CommandStore

func (*SqlStore) Compliance Uses

func (ss *SqlStore) Compliance() ComplianceStore

func (*SqlStore) CreateColumnIfNotExists Uses

func (ss *SqlStore) CreateColumnIfNotExists(tableName string, columnName string, mySqlColType string, postgresColType string, defaultValue string) bool

func (*SqlStore) CreateFullTextIndexIfNotExists Uses

func (ss *SqlStore) CreateFullTextIndexIfNotExists(indexName string, tableName string, columnName string) bool

func (*SqlStore) CreateIndexIfNotExists Uses

func (ss *SqlStore) CreateIndexIfNotExists(indexName string, tableName string, columnName string) bool

func (*SqlStore) CreateUniqueIndexIfNotExists Uses

func (ss *SqlStore) CreateUniqueIndexIfNotExists(indexName string, tableName string, columnName string) bool

func (*SqlStore) DoesColumnExist Uses

func (ss *SqlStore) DoesColumnExist(tableName string, columnName string) bool

func (*SqlStore) DoesTableExist Uses

func (ss *SqlStore) DoesTableExist(tableName string) bool

func (*SqlStore) DropAllTables Uses

func (ss *SqlStore) DropAllTables()

func (*SqlStore) Emoji Uses

func (ss *SqlStore) Emoji() EmojiStore

func (*SqlStore) FileInfo Uses

func (ss *SqlStore) FileInfo() FileInfoStore

func (*SqlStore) GetAllConns Uses

func (ss *SqlStore) GetAllConns() []*gorp.DbMap

func (*SqlStore) GetCurrentSchemaVersion Uses

func (ss *SqlStore) GetCurrentSchemaVersion() string

func (*SqlStore) GetMaster Uses

func (ss *SqlStore) GetMaster() *gorp.DbMap

func (*SqlStore) GetMaxLengthOfColumnIfExists Uses

func (ss *SqlStore) GetMaxLengthOfColumnIfExists(tableName string, columnName string) string

func (*SqlStore) GetReplica Uses

func (ss *SqlStore) GetReplica() *gorp.DbMap

func (*SqlStore) GetSearchReplica Uses

func (ss *SqlStore) GetSearchReplica() *gorp.DbMap

func (*SqlStore) JobStatus Uses

func (ss *SqlStore) JobStatus() JobStatusStore

func (*SqlStore) License Uses

func (ss *SqlStore) License() LicenseStore

func (*SqlStore) MarkSystemRanUnitTests Uses

func (ss *SqlStore) MarkSystemRanUnitTests()

func (*SqlStore) OAuth Uses

func (ss *SqlStore) OAuth() OAuthStore

func (*SqlStore) Post Uses

func (ss *SqlStore) Post() PostStore

func (*SqlStore) Preference Uses

func (ss *SqlStore) Preference() PreferenceStore

func (*SqlStore) Reaction Uses

func (ss *SqlStore) Reaction() ReactionStore

func (*SqlStore) RemoveColumnIfExists Uses

func (ss *SqlStore) RemoveColumnIfExists(tableName string, columnName string) bool

func (*SqlStore) RemoveIndexIfExists Uses

func (ss *SqlStore) RemoveIndexIfExists(indexName string, tableName string) bool

func (*SqlStore) RemoveTableIfExists Uses

func (ss *SqlStore) RemoveTableIfExists(tableName string) bool

func (*SqlStore) RenameColumnIfExists Uses

func (ss *SqlStore) RenameColumnIfExists(tableName string, oldColumnName string, newColumnName string, colType string) bool

func (*SqlStore) Session Uses

func (ss *SqlStore) Session() SessionStore

func (*SqlStore) Status Uses

func (ss *SqlStore) Status() StatusStore

func (*SqlStore) System Uses

func (ss *SqlStore) System() SystemStore

func (*SqlStore) Team Uses

func (ss *SqlStore) Team() TeamStore

func (*SqlStore) Token Uses

func (ss *SqlStore) Token() TokenStore

func (*SqlStore) TotalMasterDbConnections Uses

func (ss *SqlStore) TotalMasterDbConnections() int

func (*SqlStore) TotalReadDbConnections Uses

func (ss *SqlStore) TotalReadDbConnections() int

func (*SqlStore) TotalSearchDbConnections Uses

func (ss *SqlStore) TotalSearchDbConnections() int

func (*SqlStore) User Uses

func (ss *SqlStore) User() UserStore

func (*SqlStore) Webhook Uses

func (ss *SqlStore) Webhook() WebhookStore

type SqlSystemStore Uses

type SqlSystemStore struct {
    *SqlStore
}

func (SqlSystemStore) CreateIndexesIfNotExists Uses

func (s SqlSystemStore) CreateIndexesIfNotExists()

func (SqlSystemStore) Get Uses

func (s SqlSystemStore) Get() StoreChannel

func (SqlSystemStore) GetByName Uses

func (s SqlSystemStore) GetByName(name string) StoreChannel

func (SqlSystemStore) Save Uses

func (s SqlSystemStore) Save(system *model.System) StoreChannel

func (SqlSystemStore) SaveOrUpdate Uses

func (s SqlSystemStore) SaveOrUpdate(system *model.System) StoreChannel

func (SqlSystemStore) Update Uses

func (s SqlSystemStore) Update(system *model.System) StoreChannel

type SqlTeamStore Uses

type SqlTeamStore struct {
    *SqlStore
}

func (SqlTeamStore) AnalyticsTeamCount Uses

func (s SqlTeamStore) AnalyticsTeamCount() StoreChannel

func (SqlTeamStore) CreateIndexesIfNotExists Uses

func (s SqlTeamStore) CreateIndexesIfNotExists()

func (SqlTeamStore) Get Uses

func (s SqlTeamStore) Get(id string) StoreChannel

func (SqlTeamStore) GetActiveMemberCount Uses

func (s SqlTeamStore) GetActiveMemberCount(teamId string) StoreChannel

func (SqlTeamStore) GetAll Uses

func (s SqlTeamStore) GetAll() StoreChannel

func (SqlTeamStore) GetAllPage Uses

func (s SqlTeamStore) GetAllPage(offset int, limit int) StoreChannel

func (SqlTeamStore) GetAllTeamListing Uses

func (s SqlTeamStore) GetAllTeamListing() StoreChannel

func (SqlTeamStore) GetAllTeamPageListing Uses

func (s SqlTeamStore) GetAllTeamPageListing(offset int, limit int) StoreChannel

func (SqlTeamStore) GetByInviteId Uses

func (s SqlTeamStore) GetByInviteId(inviteId string) StoreChannel

func (SqlTeamStore) GetByName Uses

func (s SqlTeamStore) GetByName(name string) StoreChannel

func (SqlTeamStore) GetChannelUnreadsForAllTeams Uses

func (s SqlTeamStore) GetChannelUnreadsForAllTeams(excludeTeamId, userId string) StoreChannel

func (SqlTeamStore) GetChannelUnreadsForTeam Uses

func (s SqlTeamStore) GetChannelUnreadsForTeam(teamId, userId string) StoreChannel

func (SqlTeamStore) GetMember Uses

func (s SqlTeamStore) GetMember(teamId string, userId string) StoreChannel

func (SqlTeamStore) GetMembers Uses

func (s SqlTeamStore) GetMembers(teamId string, offset int, limit int) StoreChannel

func (SqlTeamStore) GetMembersByIds Uses

func (s SqlTeamStore) GetMembersByIds(teamId string, userIds []string) StoreChannel

func (SqlTeamStore) GetTeamsByUserId Uses

func (s SqlTeamStore) GetTeamsByUserId(userId string) StoreChannel

func (SqlTeamStore) GetTeamsForUser Uses

func (s SqlTeamStore) GetTeamsForUser(userId string) StoreChannel

func (SqlTeamStore) GetTotalMemberCount Uses

func (s SqlTeamStore) GetTotalMemberCount(teamId string) StoreChannel

func (SqlTeamStore) PermanentDelete Uses

func (s SqlTeamStore) PermanentDelete(teamId string) StoreChannel

func (SqlTeamStore) RemoveAllMembersByTeam Uses

func (s SqlTeamStore) RemoveAllMembersByTeam(teamId string) StoreChannel

func (SqlTeamStore) RemoveAllMembersByUser Uses

func (s SqlTeamStore) RemoveAllMembersByUser(userId string) StoreChannel

func (SqlTeamStore) RemoveMember Uses

func (s SqlTeamStore) RemoveMember(teamId string, userId string) StoreChannel

func (SqlTeamStore) Save Uses

func (s SqlTeamStore) Save(team *model.Team) StoreChannel

func (SqlTeamStore) SaveMember Uses

func (s SqlTeamStore) SaveMember(member *model.TeamMember) StoreChannel

func (SqlTeamStore) SearchAll Uses

func (s SqlTeamStore) SearchAll(term string) StoreChannel

func (SqlTeamStore) SearchByName Uses

func (s SqlTeamStore) SearchByName(name string) StoreChannel

func (SqlTeamStore) SearchOpen Uses

func (s SqlTeamStore) SearchOpen(term string) StoreChannel

func (SqlTeamStore) Update Uses

func (s SqlTeamStore) Update(team *model.Team) StoreChannel

func (SqlTeamStore) UpdateDisplayName Uses

func (s SqlTeamStore) UpdateDisplayName(name string, teamId string) StoreChannel

func (SqlTeamStore) UpdateMember Uses

func (s SqlTeamStore) UpdateMember(member *model.TeamMember) StoreChannel

type SqlTokenStore Uses

type SqlTokenStore struct {
    *SqlStore
}

func (SqlTokenStore) Cleanup Uses

func (s SqlTokenStore) Cleanup()

func (SqlTokenStore) CreateIndexesIfNotExists Uses

func (s SqlTokenStore) CreateIndexesIfNotExists()

func (SqlTokenStore) Delete Uses

func (s SqlTokenStore) Delete(token string) StoreChannel

func (SqlTokenStore) GetByToken Uses

func (s SqlTokenStore) GetByToken(tokenString string) StoreChannel

func (SqlTokenStore) Save Uses

func (s SqlTokenStore) Save(token *model.Token) StoreChannel

type SqlUserStore Uses

type SqlUserStore struct {
    *SqlStore
}

func (SqlUserStore) AnalyticsActiveCount Uses

func (us SqlUserStore) AnalyticsActiveCount(timePeriod int64) StoreChannel

func (SqlUserStore) AnalyticsGetInactiveUsersCount Uses

func (us SqlUserStore) AnalyticsGetInactiveUsersCount() StoreChannel

func (SqlUserStore) AnalyticsGetSystemAdminCount Uses

func (us SqlUserStore) AnalyticsGetSystemAdminCount() StoreChannel

func (SqlUserStore) AnalyticsUniqueUserCount Uses

func (us SqlUserStore) AnalyticsUniqueUserCount(teamId string) StoreChannel

func (SqlUserStore) CreateIndexesIfNotExists Uses

func (us SqlUserStore) CreateIndexesIfNotExists()

func (SqlUserStore) Get Uses

func (us SqlUserStore) Get(id string) StoreChannel

func (SqlUserStore) GetAll Uses

func (us SqlUserStore) GetAll() StoreChannel

func (SqlUserStore) GetAllProfiles Uses

func (us SqlUserStore) GetAllProfiles(offset int, limit int) StoreChannel

func (SqlUserStore) GetAllProfilesInChannel Uses

func (us SqlUserStore) GetAllProfilesInChannel(channelId string, allowFromCache bool) StoreChannel

func (SqlUserStore) GetAllUsingAuthService Uses

func (us SqlUserStore) GetAllUsingAuthService(authService string) StoreChannel

func (SqlUserStore) GetByAuth Uses

func (us SqlUserStore) GetByAuth(authData *string, authService string) StoreChannel

func (SqlUserStore) GetByEmail Uses

func (us SqlUserStore) GetByEmail(email string) StoreChannel

func (SqlUserStore) GetByUsername Uses

func (us SqlUserStore) GetByUsername(username string) StoreChannel

func (SqlUserStore) GetEtagForAllProfiles Uses

func (s SqlUserStore) GetEtagForAllProfiles() StoreChannel

func (SqlUserStore) GetEtagForProfiles Uses

func (s SqlUserStore) GetEtagForProfiles(teamId string) StoreChannel

func (SqlUserStore) GetEtagForProfilesNotInTeam Uses

func (us SqlUserStore) GetEtagForProfilesNotInTeam(teamId string) StoreChannel

func (SqlUserStore) GetForLogin Uses

func (us SqlUserStore) GetForLogin(loginId string, allowSignInWithUsername, allowSignInWithEmail, ldapEnabled bool) StoreChannel

func (SqlUserStore) GetProfileByIds Uses

func (us SqlUserStore) GetProfileByIds(userIds []string, allowFromCache bool) StoreChannel

func (SqlUserStore) GetProfiles Uses

func (us SqlUserStore) GetProfiles(teamId string, offset int, limit int) StoreChannel

func (SqlUserStore) GetProfilesByUsernames Uses

func (us SqlUserStore) GetProfilesByUsernames(usernames []string, teamId string) StoreChannel

func (SqlUserStore) GetProfilesInChannel Uses

func (us SqlUserStore) GetProfilesInChannel(channelId string, offset int, limit int) StoreChannel

func (SqlUserStore) GetProfilesNotInChannel Uses

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

func (SqlUserStore) GetProfilesNotInTeam Uses

func (us SqlUserStore) GetProfilesNotInTeam(teamId string, offset int, limit int) StoreChannel

func (SqlUserStore) GetProfilesWithoutTeam Uses

func (us SqlUserStore) GetProfilesWithoutTeam(offset int, limit int) StoreChannel

func (SqlUserStore) GetRecentlyActiveUsersForTeam Uses

func (us SqlUserStore) GetRecentlyActiveUsersForTeam(teamId string) StoreChannel

func (SqlUserStore) GetSystemAdminProfiles Uses

func (us SqlUserStore) GetSystemAdminProfiles() StoreChannel

func (SqlUserStore) GetTotalUsersCount Uses

func (us SqlUserStore) GetTotalUsersCount() StoreChannel

func (SqlUserStore) GetUnreadCount Uses

func (us SqlUserStore) GetUnreadCount(userId string) StoreChannel

func (SqlUserStore) GetUnreadCountForChannel Uses

func (us SqlUserStore) GetUnreadCountForChannel(userId string, channelId string) StoreChannel

func (SqlUserStore) InvalidatProfileCacheForUser Uses

func (us SqlUserStore) InvalidatProfileCacheForUser(userId string)

func (SqlUserStore) InvalidateProfilesInChannelCache Uses

func (us SqlUserStore) InvalidateProfilesInChannelCache(channelId string)

func (SqlUserStore) InvalidateProfilesInChannelCacheByUser Uses

func (us SqlUserStore) InvalidateProfilesInChannelCacheByUser(userId string)

func (SqlUserStore) PermanentDelete Uses

func (us SqlUserStore) PermanentDelete(userId string) StoreChannel

func (SqlUserStore) Save Uses

func (us SqlUserStore) Save(user *model.User) StoreChannel

func (SqlUserStore) Search Uses

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

func (SqlUserStore) SearchInChannel Uses

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

func (SqlUserStore) SearchNotInChannel Uses

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

func (SqlUserStore) SearchNotInTeam Uses

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

func (SqlUserStore) SearchWithoutTeam Uses

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

func (SqlUserStore) Update Uses

func (us SqlUserStore) Update(user *model.User, trustedUpdateData bool) StoreChannel

func (SqlUserStore) UpdateAuthData Uses

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

func (SqlUserStore) UpdateFailedPasswordAttempts Uses

func (us SqlUserStore) UpdateFailedPasswordAttempts(userId string, attempts int) StoreChannel

func (SqlUserStore) UpdateLastPictureUpdate Uses

func (us SqlUserStore) UpdateLastPictureUpdate(userId string) StoreChannel

func (SqlUserStore) UpdateMfaActive Uses

func (us SqlUserStore) UpdateMfaActive(userId string, active bool) StoreChannel

func (SqlUserStore) UpdateMfaSecret Uses

func (us SqlUserStore) UpdateMfaSecret(userId, secret string) StoreChannel

func (SqlUserStore) UpdatePassword Uses

func (us SqlUserStore) UpdatePassword(userId, hashedPassword string) StoreChannel

func (SqlUserStore) UpdateUpdateAt Uses

func (us SqlUserStore) UpdateUpdateAt(userId string) StoreChannel

func (SqlUserStore) VerifyEmail Uses

func (us SqlUserStore) VerifyEmail(userId string) StoreChannel

type SqlWebhookStore Uses

type SqlWebhookStore struct {
    *SqlStore
}

func (SqlWebhookStore) AnalyticsIncomingCount Uses

func (s SqlWebhookStore) AnalyticsIncomingCount(teamId string) StoreChannel

func (SqlWebhookStore) AnalyticsOutgoingCount Uses

func (s SqlWebhookStore) AnalyticsOutgoingCount(teamId string) StoreChannel

func (SqlWebhookStore) CreateIndexesIfNotExists Uses

func (s SqlWebhookStore) CreateIndexesIfNotExists()

func (SqlWebhookStore) DeleteIncoming Uses

func (s SqlWebhookStore) DeleteIncoming(webhookId string, time int64) StoreChannel

func (SqlWebhookStore) DeleteOutgoing Uses

func (s SqlWebhookStore) DeleteOutgoing(webhookId string, time int64) StoreChannel

func (SqlWebhookStore) GetIncoming Uses

func (s SqlWebhookStore) GetIncoming(id string, allowFromCache bool) StoreChannel

func (SqlWebhookStore) GetIncomingByChannel Uses

func (s SqlWebhookStore) GetIncomingByChannel(channelId string) StoreChannel

func (SqlWebhookStore) GetIncomingByTeam Uses

func (s SqlWebhookStore) GetIncomingByTeam(teamId string, offset, limit int) StoreChannel

func (SqlWebhookStore) GetIncomingList Uses

func (s SqlWebhookStore) GetIncomingList(offset, limit int) StoreChannel

func (SqlWebhookStore) GetOutgoing Uses

func (s SqlWebhookStore) GetOutgoing(id string) StoreChannel

func (SqlWebhookStore) GetOutgoingByChannel Uses

func (s SqlWebhookStore) GetOutgoingByChannel(channelId string, offset, limit int) StoreChannel

func (SqlWebhookStore) GetOutgoingByTeam Uses

func (s SqlWebhookStore) GetOutgoingByTeam(teamId string, offset, limit int) StoreChannel

func (SqlWebhookStore) GetOutgoingList Uses

func (s SqlWebhookStore) GetOutgoingList(offset, limit int) StoreChannel

func (SqlWebhookStore) InvalidateWebhookCache Uses

func (s SqlWebhookStore) InvalidateWebhookCache(webhookId string)

func (SqlWebhookStore) PermanentDeleteIncomingByUser Uses

func (s SqlWebhookStore) PermanentDeleteIncomingByUser(userId string) StoreChannel

func (SqlWebhookStore) PermanentDeleteOutgoingByUser Uses

func (s SqlWebhookStore) PermanentDeleteOutgoingByUser(userId string) StoreChannel

func (SqlWebhookStore) SaveIncoming Uses

func (s SqlWebhookStore) SaveIncoming(webhook *model.IncomingWebhook) StoreChannel

func (SqlWebhookStore) SaveOutgoing Uses

func (s SqlWebhookStore) SaveOutgoing(webhook *model.OutgoingWebhook) StoreChannel

func (SqlWebhookStore) UpdateIncoming Uses

func (s SqlWebhookStore) UpdateIncoming(hook *model.IncomingWebhook) StoreChannel

func (SqlWebhookStore) UpdateOutgoing Uses

func (s SqlWebhookStore) UpdateOutgoing(hook *model.OutgoingWebhook) StoreChannel

type StatusStore Uses

type StatusStore interface {
    SaveOrUpdate(status *model.Status) StoreChannel
    Get(userId string) StoreChannel
    GetByIds(userIds []string) StoreChannel
    GetOnlineAway() StoreChannel
    GetOnline() StoreChannel
    GetAllFromTeam(teamId string) StoreChannel
    ResetAll() StoreChannel
    GetTotalActiveUsersCount() StoreChannel
    UpdateLastActivityAt(userId string, lastActivityAt int64) StoreChannel
}

func NewSqlStatusStore Uses

func NewSqlStatusStore(sqlStore *SqlStore) StatusStore

type Store Uses

type Store interface {
    Team() TeamStore
    Channel() ChannelStore
    Post() PostStore
    User() UserStore
    Audit() AuditStore
    ClusterDiscovery() ClusterDiscoveryStore
    Compliance() ComplianceStore
    Session() SessionStore
    OAuth() OAuthStore
    System() SystemStore
    Webhook() WebhookStore
    Command() CommandStore
    Preference() PreferenceStore
    License() LicenseStore
    Token() TokenStore
    Emoji() EmojiStore
    Status() StatusStore
    FileInfo() FileInfoStore
    Reaction() ReactionStore
    JobStatus() JobStatusStore
    MarkSystemRanUnitTests()
    Close()
    DropAllTables()
    TotalMasterDbConnections() int
    TotalReadDbConnections() int
    TotalSearchDbConnections() int
}

func NewSqlStore Uses

func NewSqlStore() Store

type StoreChannel Uses

type StoreChannel chan StoreResult

type StoreResult Uses

type StoreResult struct {
    Data interface{}
    Err  *model.AppError
}

type SystemStore Uses

type SystemStore interface {
    Save(system *model.System) StoreChannel
    SaveOrUpdate(system *model.System) StoreChannel
    Update(system *model.System) StoreChannel
    Get() StoreChannel
    GetByName(name string) StoreChannel
}

func NewSqlSystemStore Uses

func NewSqlSystemStore(sqlStore *SqlStore) SystemStore

type TeamStore Uses

type TeamStore interface {
    Save(team *model.Team) StoreChannel
    Update(team *model.Team) StoreChannel
    UpdateDisplayName(name string, teamId string) StoreChannel
    Get(id string) StoreChannel
    GetByName(name string) StoreChannel
    SearchByName(name string) StoreChannel
    SearchAll(term string) StoreChannel
    SearchOpen(term string) StoreChannel
    GetAll() StoreChannel
    GetAllPage(offset int, limit int) StoreChannel
    GetAllTeamListing() StoreChannel
    GetAllTeamPageListing(offset int, limit int) StoreChannel
    GetTeamsByUserId(userId string) StoreChannel
    GetByInviteId(inviteId string) StoreChannel
    PermanentDelete(teamId string) StoreChannel
    AnalyticsTeamCount() StoreChannel
    SaveMember(member *model.TeamMember) StoreChannel
    UpdateMember(member *model.TeamMember) StoreChannel
    GetMember(teamId string, userId string) StoreChannel
    GetMembers(teamId string, offset int, limit int) StoreChannel
    GetMembersByIds(teamId string, userIds []string) StoreChannel
    GetTotalMemberCount(teamId string) StoreChannel
    GetActiveMemberCount(teamId string) StoreChannel
    GetTeamsForUser(userId string) StoreChannel
    GetChannelUnreadsForAllTeams(excludeTeamId, userId string) StoreChannel
    GetChannelUnreadsForTeam(teamId, userId string) StoreChannel
    RemoveMember(teamId string, userId string) StoreChannel
    RemoveAllMembersByTeam(teamId string) StoreChannel
    RemoveAllMembersByUser(userId string) StoreChannel
}

func NewSqlTeamStore Uses

func NewSqlTeamStore(sqlStore *SqlStore) TeamStore

type TokenStore Uses

type TokenStore interface {
    Save(recovery *model.Token) StoreChannel
    Delete(token string) StoreChannel
    GetByToken(token string) StoreChannel
    Cleanup()
}

func NewSqlTokenStore Uses

func NewSqlTokenStore(sqlStore *SqlStore) TokenStore

type UserStore Uses

type UserStore interface {
    Save(user *model.User) StoreChannel
    Update(user *model.User, allowRoleUpdate bool) StoreChannel
    UpdateLastPictureUpdate(userId string) StoreChannel
    UpdateUpdateAt(userId string) StoreChannel
    UpdatePassword(userId, newPassword string) StoreChannel
    UpdateAuthData(userId string, service string, authData *string, email string, resetMfa bool) StoreChannel
    UpdateMfaSecret(userId, secret string) StoreChannel
    UpdateMfaActive(userId string, active bool) StoreChannel
    Get(id string) StoreChannel
    GetAll() StoreChannel
    InvalidateProfilesInChannelCacheByUser(userId string)
    InvalidateProfilesInChannelCache(channelId string)
    GetProfilesInChannel(channelId string, offset int, limit int) StoreChannel
    GetAllProfilesInChannel(channelId string, allowFromCache bool) StoreChannel
    GetProfilesNotInChannel(teamId string, channelId string, offset int, limit int) StoreChannel
    GetProfilesWithoutTeam(offset int, limit int) StoreChannel
    GetProfilesByUsernames(usernames []string, teamId string) StoreChannel
    GetAllProfiles(offset int, limit int) StoreChannel
    GetProfiles(teamId string, offset int, limit int) StoreChannel
    GetProfileByIds(userId []string, allowFromCache bool) StoreChannel
    InvalidatProfileCacheForUser(userId string)
    GetByEmail(email string) StoreChannel
    GetByAuth(authData *string, authService string) StoreChannel
    GetAllUsingAuthService(authService string) StoreChannel
    GetByUsername(username string) StoreChannel
    GetForLogin(loginId string, allowSignInWithUsername, allowSignInWithEmail, ldapEnabled bool) StoreChannel
    VerifyEmail(userId string) StoreChannel
    GetEtagForAllProfiles() StoreChannel
    GetEtagForProfiles(teamId string) StoreChannel
    UpdateFailedPasswordAttempts(userId string, attempts int) StoreChannel
    GetTotalUsersCount() StoreChannel
    GetSystemAdminProfiles() StoreChannel
    PermanentDelete(userId string) StoreChannel
    AnalyticsUniqueUserCount(teamId string) StoreChannel
    AnalyticsActiveCount(time int64) StoreChannel
    GetUnreadCount(userId string) StoreChannel
    GetUnreadCountForChannel(userId string, channelId string) StoreChannel
    GetRecentlyActiveUsersForTeam(teamId string) StoreChannel
    Search(teamId string, term string, options map[string]bool) StoreChannel
    SearchNotInTeam(notInTeamId string, term string, options map[string]bool) StoreChannel
    SearchInChannel(channelId string, term string, options map[string]bool) StoreChannel
    SearchNotInChannel(teamId string, channelId string, term string, options map[string]bool) StoreChannel
    SearchWithoutTeam(term string, options map[string]bool) StoreChannel
    AnalyticsGetInactiveUsersCount() StoreChannel
    AnalyticsGetSystemAdminCount() StoreChannel
    GetProfilesNotInTeam(teamId string, offset int, limit int) StoreChannel
    GetEtagForProfilesNotInTeam(teamId string) StoreChannel
}

func NewSqlUserStore Uses

func NewSqlUserStore(sqlStore *SqlStore) UserStore

type UserWithLastActivityAt Uses

type UserWithLastActivityAt struct {
    model.User
    LastActivityAt int64
}

type WebhookStore Uses

type WebhookStore interface {
    SaveIncoming(webhook *model.IncomingWebhook) StoreChannel
    GetIncoming(id string, allowFromCache bool) StoreChannel
    GetIncomingList(offset, limit int) StoreChannel
    GetIncomingByTeam(teamId string, offset, limit int) StoreChannel
    UpdateIncoming(webhook *model.IncomingWebhook) StoreChannel
    GetIncomingByChannel(channelId string) StoreChannel
    DeleteIncoming(webhookId string, time int64) StoreChannel
    PermanentDeleteIncomingByUser(userId string) StoreChannel

    SaveOutgoing(webhook *model.OutgoingWebhook) StoreChannel
    GetOutgoing(id string) StoreChannel
    GetOutgoingList(offset, limit int) StoreChannel
    GetOutgoingByChannel(channelId string, offset, limit int) StoreChannel
    GetOutgoingByTeam(teamId string, offset, limit int) StoreChannel
    DeleteOutgoing(webhookId string, time int64) StoreChannel
    PermanentDeleteOutgoingByUser(userId string) StoreChannel
    UpdateOutgoing(hook *model.OutgoingWebhook) StoreChannel

    AnalyticsIncomingCount(teamId string) StoreChannel
    AnalyticsOutgoingCount(teamId string) StoreChannel
    InvalidateWebhookCache(webhook string)
}

func NewSqlWebhookStore Uses

func NewSqlWebhookStore(sqlStore *SqlStore) WebhookStore

Package store imports 28 packages (graph). Updated 2017-09-03. Refresh now. Tools for package owners. This is a quick bug-fix fork (has fewer than three commits, and only during the week it was created).