store

package
v2.2.0 Latest Latest
Warning

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

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

Documentation ¶

Index ¶

Constants ¶

View Source 
const (
	INDEX_TYPE_FULL_TEXT = "full_text"
	INDEX_TYPE_DEFAULT   = "default"
)
View Source 
const (
	FEATURE_TOGGLE_PREFIX = "feature_enabled_"
)
View Source 
const (
	MISSING_ACCOUNT_ERROR = "store.sql_user.missing_account.const"
)

Variables ¶

This section is empty.

Functions ¶

func IsUniqueConstraintError ¶ 

func IsUniqueConstraintError(err string, mysql string, postgres 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
	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 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 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 ¶ 

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 ¶ 

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
	RemoveAllSessionsForTeam(teamId string) StoreChannel
	PermanentDeleteSessionsByUser(teamId string) StoreChannel
	UpdateLastActivityAt(sessionId string, time int64) StoreChannel
	UpdateRoles(userId string, roles string) StoreChannel
	UpdateDeviceId(id string, deviceId string) StoreChannel
	AnalyticsSessionCount(teamId string) 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 ¶ 

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 ¶ 

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) CreateIndexesIfNotExists ¶ 

func (s SqlChannelStore) CreateIndexesIfNotExists()

func (SqlChannelStore) Delete ¶ 

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

func (SqlChannelStore) ExtraUpdateByUser ¶ added in v2.1.0 

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 ¶ 

func (s SqlChannelStore) GetFromMaster(id string) StoreChannel

func (SqlChannelStore) GetMember ¶ 

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

func (SqlChannelStore) GetMemberCount ¶ 

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 ¶ 

func (s SqlChannelStore) PermanentDeleteByTeam(teamId string) StoreChannel

func (SqlChannelStore) PermanentDeleteMembersByUser ¶ 

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 ¶ 

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 ¶ 

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

func (SqlChannelStore) UpgradeSchemaIfNeeded ¶ 

func (s SqlChannelStore) UpgradeSchemaIfNeeded()

type SqlCommandStore ¶ 

type SqlCommandStore struct {
	*SqlStore
}

func (SqlCommandStore) AnalyticsCommandCount ¶ added in v2.1.0 

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 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 ¶ 

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 SqlPostStore ¶ 

type SqlPostStore struct {
	*SqlStore
}

func (SqlPostStore) AnalyticsPostCount ¶ 

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

func (SqlPostStore) AnalyticsPostCountsByDay ¶ 

func (s SqlPostStore) AnalyticsPostCountsByDay(teamId string) StoreChannel

func (SqlPostStore) AnalyticsUserCountsWithPostsByDay ¶ 

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 ¶ 

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

func (SqlPostStore) GetPostsBefore ¶ 

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 ¶ 

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 ¶ 

type SqlPreferenceStore struct {
	*SqlStore
}

func (SqlPreferenceStore) CreateIndexesIfNotExists ¶ 

func (s SqlPreferenceStore) CreateIndexesIfNotExists()

func (SqlPreferenceStore) DeleteUnusedFeatures ¶ 

func (s SqlPreferenceStore) DeleteUnusedFeatures()

func (SqlPreferenceStore) Get ¶ 

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

func (SqlPreferenceStore) GetAll ¶ 

func (s SqlPreferenceStore) GetAll(userId string) StoreChannel

func (SqlPreferenceStore) GetCategory ¶ 

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

func (SqlPreferenceStore) IsFeatureEnabled ¶ 

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

func (SqlPreferenceStore) PermanentDeleteByUser ¶ 

func (s SqlPreferenceStore) PermanentDeleteByUser(userId string) StoreChannel

func (SqlPreferenceStore) Save ¶ 

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

func (SqlPreferenceStore) UpgradeSchemaIfNeeded ¶ 

func (s SqlPreferenceStore) UpgradeSchemaIfNeeded()

type SqlSessionStore ¶ 

type SqlSessionStore struct {
	*SqlStore
}

func (SqlSessionStore) AnalyticsSessionCount ¶ added in v2.1.0 

func (me SqlSessionStore) AnalyticsSessionCount(teamId string) 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 ¶ 

func (me SqlSessionStore) PermanentDeleteSessionsByUser(userId string) StoreChannel

func (SqlSessionStore) Remove ¶ 

func (me SqlSessionStore) Remove(sessionIdOrToken string) StoreChannel

func (SqlSessionStore) RemoveAllSessionsForTeam ¶ 

func (me SqlSessionStore) RemoveAllSessionsForTeam(teamId string) 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 {
	// contains filtered or unexported fields
}

func (SqlStore) AlterColumnTypeIfExists ¶ added in v2.1.0 

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) 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) DoesColumnExist ¶ 

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

func (SqlStore) DoesTableExist ¶ 

func (ss SqlStore) DoesTableExist(tableName string) bool

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 ¶ added in v2.1.0 

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 ¶ 

func (ss SqlStore) MarkSystemRanUnitTests()

func (SqlStore) OAuth ¶ 

func (ss SqlStore) OAuth() OAuthStore

func (SqlStore) Post ¶ 

func (ss SqlStore) Post() PostStore

func (SqlStore) Preference ¶ 

func (ss SqlStore) Preference() PreferenceStore

func (SqlStore) RemoveColumnIfExists ¶ 

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

func (SqlStore) RemoveIndexIfExists ¶ added in v2.1.0 

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

func (SqlStore) RenameColumnIfExists ¶ 

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) 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 ¶ added in v2.1.0 

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 ¶ 

func (s SqlTeamStore) GetAllTeamListing() StoreChannel

func (SqlTeamStore) GetByInviteId ¶ 

func (s SqlTeamStore) GetByInviteId(inviteId string) StoreChannel

func (SqlTeamStore) GetByName ¶ 

func (s SqlTeamStore) GetByName(name string) StoreChannel

func (SqlTeamStore) GetTeamsForEmail ¶ 

func (s SqlTeamStore) GetTeamsForEmail(email string) StoreChannel

func (SqlTeamStore) PermanentDelete ¶ 

func (s SqlTeamStore) PermanentDelete(teamId string) StoreChannel

func (SqlTeamStore) Save ¶ 

func (s SqlTeamStore) Save(team *model.Team) 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) 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) GetByAuth ¶ 

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

func (SqlUserStore) GetByEmail ¶ 

func (us SqlUserStore) GetByEmail(teamId string, email string) StoreChannel

func (SqlUserStore) GetByUsername ¶ 

func (us SqlUserStore) GetByUsername(teamId string, username string) StoreChannel

func (SqlUserStore) GetEtagForProfiles ¶ 

func (s SqlUserStore) GetEtagForProfiles(teamId string) StoreChannel

func (SqlUserStore) GetForExport ¶ 

func (us SqlUserStore) GetForExport(teamId string) StoreChannel

func (SqlUserStore) GetProfiles ¶ 

func (us SqlUserStore) GetProfiles(teamId string) StoreChannel

func (SqlUserStore) GetSystemAdminProfiles ¶ 

func (us SqlUserStore) GetSystemAdminProfiles() StoreChannel

func (SqlUserStore) GetTotalActiveUsersCount ¶ 

func (us SqlUserStore) GetTotalActiveUsersCount() StoreChannel

func (SqlUserStore) GetTotalUsersCount ¶ 

func (us SqlUserStore) GetTotalUsersCount() StoreChannel

func (SqlUserStore) PermanentDelete ¶ 

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, allowActiveUpdate bool) StoreChannel

func (SqlUserStore) UpdateAuthData ¶ 

func (us SqlUserStore) UpdateAuthData(userId, service, authData, 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) UpdatePassword ¶ 

func (us SqlUserStore) UpdatePassword(userId, hashedPassword 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 ¶ 

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

func (SqlWebhookStore) GetIncoming ¶ 

func (s SqlWebhookStore) GetIncoming(id string) StoreChannel

func (SqlWebhookStore) GetIncomingByChannel ¶ 

func (s SqlWebhookStore) GetIncomingByChannel(channelId string) StoreChannel

func (SqlWebhookStore) GetIncomingByTeam ¶ 

func (s SqlWebhookStore) GetIncomingByTeam(teamId string) StoreChannel

func (SqlWebhookStore) GetOutgoing ¶ 

func (s SqlWebhookStore) GetOutgoing(id string) StoreChannel

func (SqlWebhookStore) GetOutgoingByChannel ¶ 

func (s SqlWebhookStore) GetOutgoingByChannel(channelId string) StoreChannel

func (SqlWebhookStore) GetOutgoingByTeam ¶ 

func (s SqlWebhookStore) GetOutgoingByTeam(teamId string) StoreChannel

func (SqlWebhookStore) PermanentDeleteIncomingByUser ¶ 

func (s SqlWebhookStore) PermanentDeleteIncomingByUser(userId string) StoreChannel

func (SqlWebhookStore) PermanentDeleteOutgoingByUser ¶ 

func (s SqlWebhookStore) PermanentDeleteOutgoingByUser(userId string) StoreChannel

func (SqlWebhookStore) SaveIncoming ¶ 

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

func (SqlWebhookStore) SaveOutgoing ¶ 

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

func (SqlWebhookStore) UpdateOutgoing ¶ 

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
	Session() SessionStore
	OAuth() OAuthStore
	System() SystemStore
	Webhook() WebhookStore
	Command() CommandStore
	Preference() PreferenceStore
	License() LicenseStore
	MarkSystemRanUnitTests()
	Close()
}

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
}

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
	GetTeamsForEmail(domain string) StoreChannel
	GetAll() StoreChannel
	GetAllTeamListing() StoreChannel
	GetByInviteId(inviteId string) StoreChannel
	PermanentDelete(teamId string) StoreChannel
	AnalyticsTeamCount() 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
	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, service, authData, email string) StoreChannel
	Get(id string) StoreChannel
	GetProfiles(teamId string) StoreChannel
	GetByEmail(teamId string, email string) StoreChannel
	GetByAuth(teamId string, authData string, authService string) StoreChannel
	GetByUsername(teamId string, username string) StoreChannel
	VerifyEmail(userId string) StoreChannel
	GetEtagForProfiles(teamId 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
}

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.