store

package
v3.1.0+incompatible Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jun 13, 2016 License: AGPL-3.0, Apache-2.0 Imports: 25 Imported by: 0

Documentation

Index

Constants

View Source 
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"
)
View Source 
const (
	INDEX_TYPE_FULL_TEXT = "full_text"
	INDEX_TYPE_DEFAULT   = "default"
)
View Source 
const (
	MISSING_ACCOUNT_ERROR      = "store.sql_user.missing_account.const"
	MISSING_AUTH_ACCOUNT_ERROR = "store.sql_user.get_by_auth.missing_account.app_error"
)
View Source 
const (
	FEATURE_TOGGLE_PREFIX = "feature_enabled_"
)
View Source 
const (
	TEAM_MEMBER_EXISTS_ERROR = "store.sql_team.save_member.exists.app_error"
)

Variables

This section is empty.

Functions

func IsUniqueConstraintError 

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

func Must 

func Must(sc StoreChannel) interface{}

Types

type AuditStore 

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

func NewSqlAuditStore 

func NewSqlAuditStore(sqlStore *SqlStore) AuditStore

type ChannelStore 

type ChannelStore interface {
	Save(channel *model.Channel) StoreChannel
	SaveDirectChannel(channel *model.Channel, member1 *model.ChannelMember, member2 *model.ChannelMember) StoreChannel
	Update(channel *model.Channel) StoreChannel
	Get(id string) StoreChannel
	GetFromMaster(id string) StoreChannel
	Delete(channelId string, time int64) StoreChannel
	PermanentDeleteByTeam(teamId string) StoreChannel
	GetByName(team_id string, domain string) StoreChannel
	GetChannels(teamId string, userId string) StoreChannel
	GetMoreChannels(teamId string, userId string) StoreChannel
	GetChannelCounts(teamId string, userId string) StoreChannel
	GetForExport(teamId string) StoreChannel

	SaveMember(member *model.ChannelMember) StoreChannel
	UpdateMember(member *model.ChannelMember) StoreChannel
	GetMembers(channelId string) StoreChannel
	GetMember(channelId string, userId string) StoreChannel
	GetMemberCount(channelId string) StoreChannel
	RemoveMember(channelId string, userId string) StoreChannel
	PermanentDeleteMembersByUser(userId string) StoreChannel
	GetExtraMembers(channelId string, limit int) StoreChannel
	CheckPermissionsTo(teamId string, channelId string, userId string) StoreChannel
	CheckPermissionsToNoTeam(channelId string, userId string) StoreChannel
	CheckOpenChannelPermissions(teamId string, channelId string) StoreChannel
	CheckPermissionsToByName(teamId string, channelName string, userId string) StoreChannel
	UpdateLastViewedAt(channelId string, userId string) StoreChannel
	IncrementMentionCount(channelId string, userId string) StoreChannel
	AnalyticsTypeCount(teamId string, channelType string) StoreChannel
	ExtraUpdateByUser(userId string, time int64) StoreChannel
}

func NewSqlChannelStore 

func NewSqlChannelStore(sqlStore *SqlStore) ChannelStore

type CommandStore 

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 

func NewSqlCommandStore(sqlStore *SqlStore) CommandStore

type ComplianceStore 

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

func NewSqlComplianceStore 

func NewSqlComplianceStore(sqlStore *SqlStore) ComplianceStore

type LicenseStore 

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

func NewSqlLicenseStore 

func NewSqlLicenseStore(sqlStore *SqlStore) LicenseStore

type OAuthStore 

type OAuthStore interface {
	SaveApp(app *model.OAuthApp) StoreChannel
	UpdateApp(app *model.OAuthApp) StoreChannel
	GetApp(id string) StoreChannel
	GetAppByUser(userId string) StoreChannel
	SaveAuthData(authData *model.AuthData) StoreChannel
	GetAuthData(code string) StoreChannel
	RemoveAuthData(code string) StoreChannel
	PermanentDeleteAuthDataByUser(userId string) StoreChannel
	SaveAccessData(accessData *model.AccessData) StoreChannel
	GetAccessData(token string) StoreChannel
	GetAccessDataByAuthCode(authCode string) StoreChannel
	RemoveAccessData(token string) StoreChannel
}

func NewSqlOAuthStore 

func NewSqlOAuthStore(sqlStore *SqlStore) OAuthStore

type PasswordRecoveryStore 

type PasswordRecoveryStore interface {
	SaveOrUpdate(recovery *model.PasswordRecovery) StoreChannel
	Delete(userId string) StoreChannel
	Get(userId string) StoreChannel
	GetByCode(code string) StoreChannel
}

func NewSqlPasswordRecoveryStore 

func NewSqlPasswordRecoveryStore(sqlStore *SqlStore) PasswordRecoveryStore

type PostStore 

type PostStore interface {
	Save(post *model.Post) StoreChannel
	Update(post *model.Post, newMessage string, newHashtags string) StoreChannel
	Get(id string) StoreChannel
	Delete(postId string, time int64) StoreChannel
	PermanentDeleteByUser(userId string) StoreChannel
	GetPosts(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) StoreChannel
	GetEtag(channelId string) StoreChannel
	Search(teamId string, userId string, params *model.SearchParams) StoreChannel
	GetForExport(channelId string) StoreChannel
	AnalyticsUserCountsWithPostsByDay(teamId string) StoreChannel
	AnalyticsPostCountsByDay(teamId string) StoreChannel
	AnalyticsPostCount(teamId string, mustHaveFile bool, mustHaveHashtag bool) StoreChannel
}

func NewSqlPostStore 

func NewSqlPostStore(sqlStore *SqlStore) PostStore

type PreferenceStore added in v1.2.1 

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
	PermanentDeleteByUser(userId string) StoreChannel
	IsFeatureEnabled(feature, userId string) StoreChannel
}

func NewSqlPreferenceStore added in v1.2.1 

func NewSqlPreferenceStore(sqlStore *SqlStore) PreferenceStore

type SessionStore 

type SessionStore interface {
	Save(session *model.Session) StoreChannel
	Get(sessionIdOrToken string) StoreChannel
	GetSessions(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) StoreChannel
	AnalyticsSessionCount() StoreChannel
}

func NewSqlSessionStore 

func NewSqlSessionStore(sqlStore *SqlStore) SessionStore

type SqlAuditStore 

type SqlAuditStore struct {
	*SqlStore
}

func (SqlAuditStore) CreateIndexesIfNotExists 

func (s SqlAuditStore) CreateIndexesIfNotExists()

func (SqlAuditStore) Get 

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

func (SqlAuditStore) PermanentDeleteByUser added in v1.3.0 

func (s SqlAuditStore) PermanentDeleteByUser(userId string) StoreChannel

func (SqlAuditStore) Save 

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

func (SqlAuditStore) UpgradeSchemaIfNeeded 

func (s SqlAuditStore) UpgradeSchemaIfNeeded()

type SqlChannelStore 

type SqlChannelStore struct {
	*SqlStore
}

func (SqlChannelStore) AnalyticsTypeCount added in v1.2.1 

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

func (SqlChannelStore) CheckOpenChannelPermissions 

func (s SqlChannelStore) CheckOpenChannelPermissions(teamId string, channelId string) StoreChannel

func (SqlChannelStore) CheckPermissionsTo 

func (s SqlChannelStore) CheckPermissionsTo(teamId string, channelId string, userId string) StoreChannel

func (SqlChannelStore) CheckPermissionsToByName 

func (s SqlChannelStore) CheckPermissionsToByName(teamId string, channelName string, userId string) StoreChannel

func (SqlChannelStore) CheckPermissionsToNoTeam 

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

func (SqlChannelStore) CreateIndexesIfNotExists 

func (s SqlChannelStore) CreateIndexesIfNotExists()

func (SqlChannelStore) Delete 

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

func (SqlChannelStore) ExtraUpdateByUser 

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

func (SqlChannelStore) Get 

func (s SqlChannelStore) Get(id string) StoreChannel

func (SqlChannelStore) GetByName 

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

func (SqlChannelStore) GetChannelCounts 

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

func (SqlChannelStore) GetChannels 

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

func (SqlChannelStore) GetExtraMembers 

func (s SqlChannelStore) GetExtraMembers(channelId string, limit int) StoreChannel

func (SqlChannelStore) GetForExport 

func (s SqlChannelStore) GetForExport(teamId string) StoreChannel

func (SqlChannelStore) GetFromMaster added in v1.3.0 

func (s SqlChannelStore) GetFromMaster(id string) StoreChannel

func (SqlChannelStore) GetMember 

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

func (SqlChannelStore) GetMemberCount added in v1.3.0 

func (s SqlChannelStore) GetMemberCount(channelId string) StoreChannel

func (SqlChannelStore) GetMembers 

func (s SqlChannelStore) GetMembers(channelId string) StoreChannel

func (SqlChannelStore) GetMoreChannels 

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

func (SqlChannelStore) IncrementMentionCount 

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

func (SqlChannelStore) PermanentDeleteByTeam added in v1.3.0 

func (s SqlChannelStore) PermanentDeleteByTeam(teamId string) StoreChannel

func (SqlChannelStore) PermanentDeleteMembersByUser added in v1.3.0 

func (s SqlChannelStore) PermanentDeleteMembersByUser(userId string) StoreChannel

func (SqlChannelStore) RemoveMember 

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

func (SqlChannelStore) Save 

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

func (SqlChannelStore) SaveDirectChannel added in v1.2.1 

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

func (SqlChannelStore) SaveMember 

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

func (SqlChannelStore) Update 

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

func (SqlChannelStore) UpdateLastViewedAt 

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

func (SqlChannelStore) UpdateMember added in v1.1.0 

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

func (SqlChannelStore) UpgradeSchemaIfNeeded 

func (s SqlChannelStore) UpgradeSchemaIfNeeded()

type SqlCommandStore 

type SqlCommandStore struct {
	*SqlStore
}

func (SqlCommandStore) AnalyticsCommandCount 

func (s SqlCommandStore) AnalyticsCommandCount(teamId string) StoreChannel

func (SqlCommandStore) CreateIndexesIfNotExists 

func (s SqlCommandStore) CreateIndexesIfNotExists()

func (SqlCommandStore) Delete 

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

func (SqlCommandStore) Get 

func (s SqlCommandStore) Get(id string) StoreChannel

func (SqlCommandStore) GetByTeam 

func (s SqlCommandStore) GetByTeam(teamId string) StoreChannel

func (SqlCommandStore) PermanentDeleteByUser 

func (s SqlCommandStore) PermanentDeleteByUser(userId string) StoreChannel

func (SqlCommandStore) Save 

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

func (SqlCommandStore) Update 

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

func (SqlCommandStore) UpgradeSchemaIfNeeded 

func (s SqlCommandStore) UpgradeSchemaIfNeeded()

type SqlComplianceStore 

type SqlComplianceStore struct {
	*SqlStore
}

func (SqlComplianceStore) ComplianceExport 

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

func (SqlComplianceStore) CreateIndexesIfNotExists 

func (s SqlComplianceStore) CreateIndexesIfNotExists()

func (SqlComplianceStore) Get 

func (us SqlComplianceStore) Get(id string) StoreChannel

func (SqlComplianceStore) GetAll 

func (s SqlComplianceStore) GetAll() StoreChannel

func (SqlComplianceStore) Save 

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

func (SqlComplianceStore) Update 

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

func (SqlComplianceStore) UpgradeSchemaIfNeeded 

func (s SqlComplianceStore) UpgradeSchemaIfNeeded()

type SqlLicenseStore 

type SqlLicenseStore struct {
	*SqlStore
}

func (SqlLicenseStore) CreateIndexesIfNotExists 

func (ls SqlLicenseStore) CreateIndexesIfNotExists()

func (SqlLicenseStore) Get 

func (ls SqlLicenseStore) Get(id string) StoreChannel

func (SqlLicenseStore) Save 

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

func (SqlLicenseStore) UpgradeSchemaIfNeeded 

func (ls SqlLicenseStore) UpgradeSchemaIfNeeded()

type SqlOAuthStore 

type SqlOAuthStore struct {
	*SqlStore
}

func (SqlOAuthStore) CreateIndexesIfNotExists 

func (as SqlOAuthStore) CreateIndexesIfNotExists()

func (SqlOAuthStore) GetAccessData 

func (as SqlOAuthStore) GetAccessData(token string) StoreChannel

func (SqlOAuthStore) GetAccessDataByAuthCode 

func (as SqlOAuthStore) GetAccessDataByAuthCode(authCode string) StoreChannel

func (SqlOAuthStore) GetApp 

func (as SqlOAuthStore) GetApp(id string) StoreChannel

func (SqlOAuthStore) GetAppByUser 

func (as SqlOAuthStore) GetAppByUser(userId string) StoreChannel

func (SqlOAuthStore) GetAuthData 

func (as SqlOAuthStore) GetAuthData(code string) StoreChannel

func (SqlOAuthStore) PermanentDeleteAuthDataByUser added in v1.3.0 

func (as SqlOAuthStore) PermanentDeleteAuthDataByUser(userId string) StoreChannel

func (SqlOAuthStore) RemoveAccessData 

func (as SqlOAuthStore) RemoveAccessData(token string) StoreChannel

func (SqlOAuthStore) RemoveAuthData 

func (as SqlOAuthStore) RemoveAuthData(code string) StoreChannel

func (SqlOAuthStore) SaveAccessData 

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

func (SqlOAuthStore) SaveApp 

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

func (SqlOAuthStore) SaveAuthData 

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

func (SqlOAuthStore) UpdateApp 

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

func (SqlOAuthStore) UpgradeSchemaIfNeeded 

func (as SqlOAuthStore) UpgradeSchemaIfNeeded()

type SqlPasswordRecoveryStore 

type SqlPasswordRecoveryStore struct {
	*SqlStore
}

func (SqlPasswordRecoveryStore) CreateIndexesIfNotExists 

func (s SqlPasswordRecoveryStore) CreateIndexesIfNotExists()

func (SqlPasswordRecoveryStore) Delete 

func (s SqlPasswordRecoveryStore) Delete(userId string) StoreChannel

func (SqlPasswordRecoveryStore) Get 

func (s SqlPasswordRecoveryStore) Get(userId string) StoreChannel

func (SqlPasswordRecoveryStore) GetByCode 

func (s SqlPasswordRecoveryStore) GetByCode(code string) StoreChannel

func (SqlPasswordRecoveryStore) SaveOrUpdate 

func (s SqlPasswordRecoveryStore) SaveOrUpdate(recovery *model.PasswordRecovery) StoreChannel

func (SqlPasswordRecoveryStore) UpgradeSchemaIfNeeded 

func (s SqlPasswordRecoveryStore) UpgradeSchemaIfNeeded()

type SqlPostStore 

type SqlPostStore struct {
	*SqlStore
}

func (SqlPostStore) AnalyticsPostCount added in v1.2.1 

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

func (SqlPostStore) AnalyticsPostCountsByDay added in v1.2.1 

func (s SqlPostStore) AnalyticsPostCountsByDay(teamId string) StoreChannel

func (SqlPostStore) AnalyticsUserCountsWithPostsByDay added in v1.2.1 

func (s SqlPostStore) AnalyticsUserCountsWithPostsByDay(teamId string) StoreChannel

func (SqlPostStore) CreateIndexesIfNotExists 

func (s SqlPostStore) CreateIndexesIfNotExists()

func (SqlPostStore) Delete 

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

func (SqlPostStore) Get 

func (s SqlPostStore) Get(id string) StoreChannel

func (SqlPostStore) GetEtag 

func (s SqlPostStore) GetEtag(channelId string) StoreChannel

func (SqlPostStore) GetForExport 

func (s SqlPostStore) GetForExport(channelId string) StoreChannel

func (SqlPostStore) GetPosts 

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

func (SqlPostStore) GetPostsAfter added in v1.2.1 

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

func (SqlPostStore) GetPostsBefore added in v1.2.1 

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

func (SqlPostStore) GetPostsSince 

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

func (SqlPostStore) PermanentDeleteByUser added in v1.3.0 

func (s SqlPostStore) PermanentDeleteByUser(userId string) StoreChannel

func (SqlPostStore) Save 

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

func (SqlPostStore) Search 

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

func (SqlPostStore) Update 

func (s SqlPostStore) Update(oldPost *model.Post, newMessage string, newHashtags string) StoreChannel

func (SqlPostStore) UpgradeSchemaIfNeeded 

func (s SqlPostStore) UpgradeSchemaIfNeeded()

type SqlPreferenceStore added in v1.2.1 

type SqlPreferenceStore struct {
	*SqlStore
}

func (SqlPreferenceStore) CreateIndexesIfNotExists added in v1.2.1 

func (s SqlPreferenceStore) CreateIndexesIfNotExists()

func (SqlPreferenceStore) DeleteUnusedFeatures added in v1.3.0 

func (s SqlPreferenceStore) DeleteUnusedFeatures()

func (SqlPreferenceStore) Get added in v1.2.1 

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

func (SqlPreferenceStore) GetAll added in v1.2.1 

func (s SqlPreferenceStore) GetAll(userId string) StoreChannel

func (SqlPreferenceStore) GetCategory added in v1.2.1 

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

func (SqlPreferenceStore) IsFeatureEnabled added in v1.3.0 

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

func (SqlPreferenceStore) PermanentDeleteByUser added in v1.3.0 

func (s SqlPreferenceStore) PermanentDeleteByUser(userId string) StoreChannel

func (SqlPreferenceStore) Save added in v1.2.1 

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

func (SqlPreferenceStore) UpgradeSchemaIfNeeded added in v1.2.1 

func (s SqlPreferenceStore) UpgradeSchemaIfNeeded()

type SqlSessionStore 

type SqlSessionStore struct {
	*SqlStore
}

func (SqlSessionStore) AnalyticsSessionCount 

func (me SqlSessionStore) AnalyticsSessionCount() StoreChannel

func (SqlSessionStore) CleanUpExpiredSessions 

func (me SqlSessionStore) CleanUpExpiredSessions(userId string) StoreChannel

func (SqlSessionStore) CreateIndexesIfNotExists 

func (me SqlSessionStore) CreateIndexesIfNotExists()

func (SqlSessionStore) Get 

func (me SqlSessionStore) Get(sessionIdOrToken string) StoreChannel

func (SqlSessionStore) GetSessions 

func (me SqlSessionStore) GetSessions(userId string) StoreChannel

func (SqlSessionStore) PermanentDeleteSessionsByUser added in v1.3.0 

func (me SqlSessionStore) PermanentDeleteSessionsByUser(userId string) StoreChannel

func (SqlSessionStore) Remove 

func (me SqlSessionStore) Remove(sessionIdOrToken string) StoreChannel

func (SqlSessionStore) RemoveAllSessions 

func (me SqlSessionStore) RemoveAllSessions() StoreChannel

func (SqlSessionStore) Save 

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

func (SqlSessionStore) UpdateDeviceId 

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

func (SqlSessionStore) UpdateLastActivityAt 

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

func (SqlSessionStore) UpdateRoles 

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

func (SqlSessionStore) UpgradeSchemaIfNeeded 

func (me SqlSessionStore) UpgradeSchemaIfNeeded()

type SqlStore 

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

func NewSqlStoreForUpgrade30 

func NewSqlStoreForUpgrade30() *SqlStore

ADDED for 3.0 REMOVE for 3.4 This is a special case for upgrading the schema to the 3.0 user model

func (SqlStore) AlterColumnTypeIfExists 

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

func (SqlStore) Audit 

func (ss SqlStore) Audit() AuditStore

func (SqlStore) Channel 

func (ss SqlStore) Channel() ChannelStore

func (SqlStore) Close 

func (ss SqlStore) Close()

func (SqlStore) Command 

func (ss SqlStore) Command() CommandStore

func (SqlStore) Compliance 

func (ss SqlStore) Compliance() ComplianceStore

func (SqlStore) CreateColumnIfNotExists 

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

func (SqlStore) CreateFullTextIndexIfNotExists 

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

func (SqlStore) CreateIndexIfNotExists 

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

func (SqlStore) CreateUniqueIndexIfNotExists 

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

func (SqlStore) DoesColumnExist 

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

func (SqlStore) DoesTableExist 

func (ss SqlStore) DoesTableExist(tableName string) bool

func (SqlStore) DropAllTables 

func (ss SqlStore) DropAllTables()

func (SqlStore) GetAllConns 

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

func (SqlStore) GetCurrentSchemaVersion 

func (ss SqlStore) GetCurrentSchemaVersion() string

func (SqlStore) GetMaster 

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

func (SqlStore) GetMaxLengthOfColumnIfExists 

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

func (SqlStore) GetReplica 

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

func (SqlStore) License 

func (ss SqlStore) License() LicenseStore

func (SqlStore) MarkSystemRanUnitTests added in v1.2.1 

func (ss SqlStore) MarkSystemRanUnitTests()

func (SqlStore) OAuth 

func (ss SqlStore) OAuth() OAuthStore

func (SqlStore) PasswordRecovery 

func (ss SqlStore) PasswordRecovery() PasswordRecoveryStore

func (SqlStore) Post 

func (ss SqlStore) Post() PostStore

func (SqlStore) Preference added in v1.2.1 

func (ss SqlStore) Preference() PreferenceStore

func (SqlStore) RemoveColumnIfExists 

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

func (SqlStore) RemoveIndexIfExists 

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

func (SqlStore) RenameColumnIfExists added in v1.2.1 

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

func (SqlStore) Session 

func (ss SqlStore) Session() SessionStore

func (SqlStore) System 

func (ss SqlStore) System() SystemStore

func (SqlStore) Team 

func (ss SqlStore) Team() TeamStore

func (SqlStore) User 

func (ss SqlStore) User() UserStore

func (SqlStore) Webhook 

func (ss SqlStore) Webhook() WebhookStore

type SqlSystemStore 

type SqlSystemStore struct {
	*SqlStore
}

func (SqlSystemStore) CreateIndexesIfNotExists 

func (s SqlSystemStore) CreateIndexesIfNotExists()

func (SqlSystemStore) Get 

func (s SqlSystemStore) Get() StoreChannel

func (SqlSystemStore) GetByName 

func (s SqlSystemStore) GetByName(name string) StoreChannel

func (SqlSystemStore) Save 

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

func (SqlSystemStore) SaveOrUpdate 

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

func (SqlSystemStore) Update 

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

func (SqlSystemStore) UpgradeSchemaIfNeeded 

func (s SqlSystemStore) UpgradeSchemaIfNeeded()

type SqlTeamStore 

type SqlTeamStore struct {
	*SqlStore
}

func (SqlTeamStore) AnalyticsTeamCount 

func (s SqlTeamStore) AnalyticsTeamCount() StoreChannel

func (SqlTeamStore) CreateIndexesIfNotExists 

func (s SqlTeamStore) CreateIndexesIfNotExists()

func (SqlTeamStore) Get 

func (s SqlTeamStore) Get(id string) StoreChannel

func (SqlTeamStore) GetAll 

func (s SqlTeamStore) GetAll() StoreChannel

func (SqlTeamStore) GetAllTeamListing added in v1.2.1 

func (s SqlTeamStore) GetAllTeamListing() StoreChannel

func (SqlTeamStore) GetByInviteId added in v1.2.1 

func (s SqlTeamStore) GetByInviteId(inviteId string) StoreChannel

func (SqlTeamStore) GetByName 

func (s SqlTeamStore) GetByName(name string) StoreChannel

func (SqlTeamStore) GetMember 

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

func (SqlTeamStore) GetMembers 

func (s SqlTeamStore) GetMembers(teamId string) StoreChannel

func (SqlTeamStore) GetTeamsByUserId 

func (s SqlTeamStore) GetTeamsByUserId(userId string) StoreChannel

func (SqlTeamStore) GetTeamsForUser 

func (s SqlTeamStore) GetTeamsForUser(userId string) StoreChannel

func (SqlTeamStore) PermanentDelete added in v1.3.0 

func (s SqlTeamStore) PermanentDelete(teamId string) StoreChannel

func (SqlTeamStore) RemoveAllMembersByTeam 

func (s SqlTeamStore) RemoveAllMembersByTeam(teamId string) StoreChannel

func (SqlTeamStore) RemoveAllMembersByUser 

func (s SqlTeamStore) RemoveAllMembersByUser(userId string) StoreChannel

func (SqlTeamStore) RemoveMember 

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

func (SqlTeamStore) Save 

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

func (SqlTeamStore) SaveMember 

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

func (SqlTeamStore) Update 

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

func (SqlTeamStore) UpdateDisplayName 

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

func (SqlTeamStore) UpdateMember 

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

func (SqlTeamStore) UpgradeSchemaIfNeeded 

func (s SqlTeamStore) UpgradeSchemaIfNeeded()

type SqlUserStore 

type SqlUserStore struct {
	*SqlStore
}

func (SqlUserStore) AnalyticsUniqueUserCount 

func (us SqlUserStore) AnalyticsUniqueUserCount(teamId string) StoreChannel

func (SqlUserStore) CreateIndexesIfNotExists 

func (us SqlUserStore) CreateIndexesIfNotExists()

func (SqlUserStore) Get 

func (us SqlUserStore) Get(id string) StoreChannel

func (SqlUserStore) GetAll 

func (us SqlUserStore) GetAll() StoreChannel

func (SqlUserStore) GetAllProfiles 

func (us SqlUserStore) GetAllProfiles() StoreChannel

func (SqlUserStore) GetAllUsingAuthService 

func (us SqlUserStore) GetAllUsingAuthService(authService string) StoreChannel

func (SqlUserStore) GetByAuth 

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

func (SqlUserStore) GetByEmail 

func (us SqlUserStore) GetByEmail(email string) StoreChannel

func (SqlUserStore) GetByUsername 

func (us SqlUserStore) GetByUsername(username string) StoreChannel

func (SqlUserStore) GetDirectProfiles 

func (us SqlUserStore) GetDirectProfiles(userId string) StoreChannel

func (SqlUserStore) GetEtagForAllProfiles 

func (s SqlUserStore) GetEtagForAllProfiles() StoreChannel

func (SqlUserStore) GetEtagForDirectProfiles 

func (s SqlUserStore) GetEtagForDirectProfiles(userId string) StoreChannel

func (SqlUserStore) GetEtagForProfiles 

func (s SqlUserStore) GetEtagForProfiles(teamId string) StoreChannel

func (SqlUserStore) GetForExport 

func (us SqlUserStore) GetForExport(teamId string) StoreChannel

func (SqlUserStore) GetForLogin 

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

func (SqlUserStore) GetProfileByIds 

func (us SqlUserStore) GetProfileByIds(userIds []string) StoreChannel

func (SqlUserStore) GetProfiles 

func (us SqlUserStore) GetProfiles(teamId string) StoreChannel

func (SqlUserStore) GetSystemAdminProfiles added in v1.1.0 

func (us SqlUserStore) GetSystemAdminProfiles() StoreChannel

func (SqlUserStore) GetTotalActiveUsersCount added in v1.1.0 

func (us SqlUserStore) GetTotalActiveUsersCount() StoreChannel

func (SqlUserStore) GetTotalUsersCount 

func (us SqlUserStore) GetTotalUsersCount() StoreChannel

func (SqlUserStore) GetUnreadCount 

func (us SqlUserStore) GetUnreadCount(userId string) StoreChannel

func (SqlUserStore) PermanentDelete added in v1.3.0 

func (us SqlUserStore) PermanentDelete(userId string) StoreChannel

func (SqlUserStore) Save 

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

func (SqlUserStore) Update 

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

func (SqlUserStore) UpdateAuthData added in v1.4.0 

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

func (SqlUserStore) UpdateFailedPasswordAttempts 

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

func (SqlUserStore) UpdateLastActivityAt 

func (us SqlUserStore) UpdateLastActivityAt(userId string, time int64) StoreChannel

func (SqlUserStore) UpdateLastPictureUpdate 

func (us SqlUserStore) UpdateLastPictureUpdate(userId string) StoreChannel

func (SqlUserStore) UpdateLastPingAt 

func (us SqlUserStore) UpdateLastPingAt(userId string, time int64) StoreChannel

func (SqlUserStore) UpdateMfaActive 

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

func (SqlUserStore) UpdateMfaSecret 

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

func (SqlUserStore) UpdatePassword 

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

func (SqlUserStore) UpdateUpdateAt 

func (us SqlUserStore) UpdateUpdateAt(userId string) StoreChannel

func (SqlUserStore) UpdateUserAndSessionActivity 

func (us SqlUserStore) UpdateUserAndSessionActivity(userId string, sessionId string, time int64) StoreChannel

func (SqlUserStore) UpgradeSchemaIfNeeded 

func (us SqlUserStore) UpgradeSchemaIfNeeded()

func (SqlUserStore) VerifyEmail 

func (us SqlUserStore) VerifyEmail(userId string) StoreChannel

type SqlWebhookStore 

type SqlWebhookStore struct {
	*SqlStore
}

func (SqlWebhookStore) AnalyticsIncomingCount 

func (s SqlWebhookStore) AnalyticsIncomingCount(teamId string) StoreChannel

func (SqlWebhookStore) AnalyticsOutgoingCount 

func (s SqlWebhookStore) AnalyticsOutgoingCount(teamId string) StoreChannel

func (SqlWebhookStore) CreateIndexesIfNotExists 

func (s SqlWebhookStore) CreateIndexesIfNotExists()

func (SqlWebhookStore) DeleteIncoming 

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

func (SqlWebhookStore) DeleteOutgoing added in v1.2.1 

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

func (SqlWebhookStore) GetIncoming 

func (s SqlWebhookStore) GetIncoming(id string) StoreChannel

func (SqlWebhookStore) GetIncomingByChannel added in v1.2.1 

func (s SqlWebhookStore) GetIncomingByChannel(channelId string) StoreChannel

func (SqlWebhookStore) GetIncomingByTeam 

func (s SqlWebhookStore) GetIncomingByTeam(teamId string) StoreChannel

func (SqlWebhookStore) GetOutgoing added in v1.2.1 

func (s SqlWebhookStore) GetOutgoing(id string) StoreChannel

func (SqlWebhookStore) GetOutgoingByChannel added in v1.2.1 

func (s SqlWebhookStore) GetOutgoingByChannel(channelId string) StoreChannel

func (SqlWebhookStore) GetOutgoingByTeam added in v1.2.1 

func (s SqlWebhookStore) GetOutgoingByTeam(teamId string) StoreChannel

func (SqlWebhookStore) PermanentDeleteIncomingByUser added in v1.3.0 

func (s SqlWebhookStore) PermanentDeleteIncomingByUser(userId string) StoreChannel

func (SqlWebhookStore) PermanentDeleteOutgoingByUser added in v1.3.0 

func (s SqlWebhookStore) PermanentDeleteOutgoingByUser(userId string) StoreChannel

func (SqlWebhookStore) SaveIncoming 

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

func (SqlWebhookStore) SaveOutgoing added in v1.2.1 

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

func (SqlWebhookStore) UpdateOutgoing added in v1.2.1 

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

func (SqlWebhookStore) UpgradeSchemaIfNeeded 

func (s SqlWebhookStore) UpgradeSchemaIfNeeded()

type Store 

type Store interface {
	Team() TeamStore
	Channel() ChannelStore
	Post() PostStore
	User() UserStore
	Audit() AuditStore
	Compliance() ComplianceStore
	Session() SessionStore
	OAuth() OAuthStore
	System() SystemStore
	Webhook() WebhookStore
	Command() CommandStore
	Preference() PreferenceStore
	License() LicenseStore
	PasswordRecovery() PasswordRecoveryStore
	MarkSystemRanUnitTests()
	Close()
	DropAllTables()
}

func NewSqlStore 

func NewSqlStore() Store

type StoreChannel 

type StoreChannel chan StoreResult

type StoreResult 

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

type SystemStore 

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 

func NewSqlSystemStore(sqlStore *SqlStore) SystemStore

type TeamStore 

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
	GetAll() StoreChannel
	GetAllTeamListing() 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) StoreChannel
	GetTeamsForUser(userId string) StoreChannel
	RemoveMember(teamId string, userId string) StoreChannel
	RemoveAllMembersByTeam(teamId string) StoreChannel
	RemoveAllMembersByUser(userId string) StoreChannel
}

func NewSqlTeamStore 

func NewSqlTeamStore(sqlStore *SqlStore) TeamStore

type UserStore 

type UserStore interface {
	Save(user *model.User) StoreChannel
	Update(user *model.User, allowRoleUpdate bool) StoreChannel
	UpdateLastPictureUpdate(userId string) StoreChannel
	UpdateUpdateAt(userId string) StoreChannel
	UpdateLastPingAt(userId string, time int64) StoreChannel
	UpdateLastActivityAt(userId string, time int64) StoreChannel
	UpdateUserAndSessionActivity(userId string, sessionId string, time int64) StoreChannel
	UpdatePassword(userId, newPassword string) StoreChannel
	UpdateAuthData(userId string, service string, authData *string, email string) StoreChannel
	UpdateMfaSecret(userId, secret string) StoreChannel
	UpdateMfaActive(userId string, active bool) StoreChannel
	Get(id string) StoreChannel
	GetAll() StoreChannel
	GetAllProfiles() StoreChannel
	GetProfiles(teamId string) StoreChannel
	GetDirectProfiles(userId string) StoreChannel
	GetProfileByIds(userId []string) StoreChannel
	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
	GetEtagForDirectProfiles(userId string) StoreChannel
	UpdateFailedPasswordAttempts(userId string, attempts int) StoreChannel
	GetForExport(teamId string) StoreChannel
	GetTotalUsersCount() StoreChannel
	GetTotalActiveUsersCount() StoreChannel
	GetSystemAdminProfiles() StoreChannel
	PermanentDelete(userId string) StoreChannel
	AnalyticsUniqueUserCount(teamId string) StoreChannel
	GetUnreadCount(userId string) StoreChannel
}

func NewSqlUserStore 

func NewSqlUserStore(sqlStore *SqlStore) UserStore

type WebhookStore 

type WebhookStore interface {
	SaveIncoming(webhook *model.IncomingWebhook) StoreChannel
	GetIncoming(id string) StoreChannel
	GetIncomingByTeam(teamId string) StoreChannel
	GetIncomingByChannel(channelId string) StoreChannel
	DeleteIncoming(webhookId string, time int64) StoreChannel
	PermanentDeleteIncomingByUser(userId string) StoreChannel
	SaveOutgoing(webhook *model.OutgoingWebhook) StoreChannel
	GetOutgoing(id string) StoreChannel
	GetOutgoingByChannel(channelId string) StoreChannel
	GetOutgoingByTeam(teamId string) StoreChannel
	DeleteOutgoing(webhookId string, time int64) StoreChannel
	PermanentDeleteOutgoingByUser(userId string) StoreChannel
	UpdateOutgoing(hook *model.OutgoingWebhook) StoreChannel
	AnalyticsIncomingCount(teamId string) StoreChannel
	AnalyticsOutgoingCount(teamId string) StoreChannel
}

func NewSqlWebhookStore 

func NewSqlWebhookStore(sqlStore *SqlStore) WebhookStore

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.