store

package
Version: v1.1.1 Latest Latest
Warning

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

Go to latest
Published: Oct 20, 2015 License: AGPL-3.0, Apache-2.0 Imports: 24 Imported by: 0

Documentation

Index

Constants

This section is empty.

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
}

func NewSqlAuditStore

func NewSqlAuditStore(sqlStore *SqlStore) AuditStore

type ChannelStore

type ChannelStore interface {
	Save(channel *model.Channel) StoreChannel
	Update(channel *model.Channel) StoreChannel
	Get(id string) StoreChannel
	Delete(channelId string, time int64) 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
	RemoveMember(channelId string, 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
}

func NewSqlChannelStore

func NewSqlChannelStore(sqlStore *SqlStore) ChannelStore

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
	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
	GetPosts(channelId string, offset int, limit int) StoreChannel
	GetPostsSince(channelId string, time int64) StoreChannel
	GetEtag(channelId string) StoreChannel
	Search(teamId string, userId string, terms string, isHashtagSearch bool) StoreChannel
	GetForExport(channelId string) StoreChannel
}

func NewSqlPostStore

func NewSqlPostStore(sqlStore *SqlStore) PostStore

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
	UpdateLastActivityAt(sessionId string, time int64) StoreChannel
	UpdateRoles(userId string, roles 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) Save

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

func (SqlAuditStore) UpgradeSchemaIfNeeded

func (s SqlAuditStore) UpgradeSchemaIfNeeded()

type SqlChannelStore

type SqlChannelStore struct {
	*SqlStore
}

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

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

func (s SqlChannelStore) GetMember(channelId string, userId 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) RemoveMember

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

func (SqlChannelStore) Save

func (s SqlChannelStore) Save(channel *model.Channel) 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 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) 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) 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) GetPostsSince

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

func (SqlPostStore) Save

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

func (SqlPostStore) Search

func (s SqlPostStore) Search(teamId string, userId string, terms string, isHashtagSearch bool) StoreChannel

func (SqlPostStore) Update

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

func (SqlPostStore) UpgradeSchemaIfNeeded

func (s SqlPostStore) UpgradeSchemaIfNeeded()

type SqlSessionStore

type SqlSessionStore struct {
	*SqlStore
}

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

func (ss SqlStore) Audit() AuditStore

func (SqlStore) Channel

func (ss SqlStore) Channel() ChannelStore

func (SqlStore) Close

func (ss SqlStore) Close()

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

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

func (SqlStore) OAuth

func (ss SqlStore) OAuth() OAuthStore

func (SqlStore) Post

func (ss SqlStore) Post() PostStore

func (SqlStore) RemoveColumnIfExists

func (ss SqlStore) RemoveColumnIfExists(tableName string, columnName 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) Update

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

func (SqlSystemStore) UpgradeSchemaIfNeeded

func (s SqlSystemStore) UpgradeSchemaIfNeeded()

type SqlTeamStore

type SqlTeamStore struct {
	*SqlStore
}

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

func (s SqlTeamStore) GetByName(name string) StoreChannel

func (SqlTeamStore) GetTeamsForEmail

func (s SqlTeamStore) GetTeamsForEmail(email 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) 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 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) Save

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

func (SqlUserStore) Update

func (us SqlUserStore) Update(user *model.User, allowActiveUpdate bool) 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) CreateIndexesIfNotExists

func (s SqlWebhookStore) CreateIndexesIfNotExists()

func (SqlWebhookStore) DeleteIncoming

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

func (SqlWebhookStore) GetIncoming

func (s SqlWebhookStore) GetIncoming(id string) StoreChannel

func (SqlWebhookStore) GetIncomingByUser

func (s SqlWebhookStore) GetIncomingByUser(userId string) StoreChannel

func (SqlWebhookStore) SaveIncoming

func (s SqlWebhookStore) SaveIncoming(webhook *model.IncomingWebhook) 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
	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
	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
}

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

func NewSqlUserStore

func NewSqlUserStore(sqlStore *SqlStore) UserStore

type WebhookStore

type WebhookStore interface {
	SaveIncoming(webhook *model.IncomingWebhook) StoreChannel
	GetIncoming(id string) StoreChannel
	GetIncomingByUser(userId string) StoreChannel
	DeleteIncoming(webhookId string, time int64) StoreChannel
}

func NewSqlWebhookStore

func NewSqlWebhookStore(sqlStore *SqlStore) WebhookStore

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
t or T : Toggle theme light dark auto
y or Y : Canonical URL