localcachelayer

package
v5.100.1 Latest Latest
Warning

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

 Go to latest Published: Jun 2, 2020 License: AGPL-3.0, Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	REACTION_CACHE_SIZE = 20000
	REACTION_CACHE_SEC  = 30 * 60

	ROLE_CACHE_SIZE = 20000
	ROLE_CACHE_SEC  = 30 * 60

	SCHEME_CACHE_SIZE = 20000
	SCHEME_CACHE_SEC  = 30 * 60

	CHANNEL_GUEST_COUNT_CACHE_SIZE = model.CHANNEL_CACHE_SIZE
	CHANNEL_GUEST_COUNT_CACHE_SEC  = 30 * 60

	WEBHOOK_CACHE_SIZE = 25000
	WEBHOOK_CACHE_SEC  = 15 * 60

	EMOJI_CACHE_SIZE = 5000
	EMOJI_CACHE_SEC  = 30 * 60

	CHANNEL_PINNEDPOSTS_COUNTS_CACHE_SIZE = model.CHANNEL_CACHE_SIZE
	CHANNEL_PINNEDPOSTS_COUNTS_CACHE_SEC  = 30 * 60

	CHANNEL_MEMBERS_COUNTS_CACHE_SIZE = model.CHANNEL_CACHE_SIZE
	CHANNEL_MEMBERS_COUNTS_CACHE_SEC  = 30 * 60

	CHANNEL_MEMBERS_FOR_USER_SIZE      = model.CHANNEL_CACHE_SIZE
	CHANNEL_MEMBERS_FOR_USER_CACHE_SEC = 30 * 60

	LAST_POSTS_CACHE_SIZE = 20000
	LAST_POSTS_CACHE_SEC  = 30 * 60

	TERMS_OF_SERVICE_CACHE_SIZE = 20000
	TERMS_OF_SERVICE_CACHE_SEC  = 30 * 60
	LAST_POST_TIME_CACHE_SIZE   = 25000
	LAST_POST_TIME_CACHE_SEC    = 15 * 60

	USER_PROFILE_BY_ID_CACHE_SIZE = 20000
	USER_PROFILE_BY_ID_SEC        = 30 * 60

	PROFILES_IN_CHANNEL_CACHE_SIZE = model.CHANNEL_CACHE_SIZE
	PROFILES_IN_CHANNEL_CACHE_SEC  = 15 * 60

	TEAM_CACHE_SIZE = 20000
	TEAM_CACHE_SEC  = 30 * 60

	CLEAR_CACHE_MESSAGE_DATA = ""

	CHANNEL_CACHE_SEC = 15 * 60 // 15 mins
)
View Source 
const (
	LATEST_KEY = "latest"
)

Variables

This section is empty.

Functions

This section is empty.

Types

type LocalCacheChannelStore 

type LocalCacheChannelStore struct {
	store.ChannelStore
	// contains filtered or unexported fields
}

func (LocalCacheChannelStore) ClearAllCustomRoleAssignments 

func (s LocalCacheChannelStore) ClearAllCustomRoleAssignments() *model.AppError

ClearAllCustomRoleAssignments is a wrapper method for the underlying store which just takes care of the cache invalidation.

func (LocalCacheChannelStore) ClearCaches 

func (s LocalCacheChannelStore) ClearCaches()

func (LocalCacheChannelStore) Get 

func (s LocalCacheChannelStore) Get(id string, allowFromCache bool) (*model.Channel, *model.AppError)

func (LocalCacheChannelStore) GetGuestCount 

func (s LocalCacheChannelStore) GetGuestCount(channelId string, allowFromCache bool) (int64, *model.AppError)

func (LocalCacheChannelStore) GetMemberCount 

func (s LocalCacheChannelStore) GetMemberCount(channelId string, allowFromCache bool) (int64, *model.AppError)

func (LocalCacheChannelStore) GetMemberCountFromCache 

func (s LocalCacheChannelStore) GetMemberCountFromCache(channelId string) int64

func (LocalCacheChannelStore) GetMembersForUser 

func (s LocalCacheChannelStore) GetMembersForUser(teamId, userId string) (*model.ChannelMembers, *model.AppError)

GetMembersForUser is a cache wrapper method for ChannelStore.

func (LocalCacheChannelStore) GetPinnedPostCount 

func (s LocalCacheChannelStore) GetPinnedPostCount(channelId string, allowFromCache bool) (int64, *model.AppError)

func (LocalCacheChannelStore) IncrementMentionCount 

func (s LocalCacheChannelStore) IncrementMentionCount(channelId, userId string) *model.AppError

IncrementMentionCount is a wrapper method for the underlying store which just takes care of the cache invalidation.

func (LocalCacheChannelStore) InvalidateChannel 

func (s LocalCacheChannelStore) InvalidateChannel(channelId string)

func (LocalCacheChannelStore) InvalidateGuestCount 

func (s LocalCacheChannelStore) InvalidateGuestCount(channelId string)

func (LocalCacheChannelStore) InvalidateMemberCount 

func (s LocalCacheChannelStore) InvalidateMemberCount(channelId string)

func (LocalCacheChannelStore) InvalidatePinnedPostCount 

func (s LocalCacheChannelStore) InvalidatePinnedPostCount(channelId string)

func (LocalCacheChannelStore) PermanentDeleteMembersByChannel 

func (s LocalCacheChannelStore) PermanentDeleteMembersByChannel(channelId string) *model.AppError

PermanentDeleteMembersByChannel is a wrapper method for the underlying store which just takes care of the cache invalidation.

func (LocalCacheChannelStore) PermanentDeleteMembersByUser 

func (s LocalCacheChannelStore) PermanentDeleteMembersByUser(userId string) *model.AppError

PermanentDeleteMembersByUser is a wrapper method for the underlying store which just takes care of the cache invalidation.

func (LocalCacheChannelStore) RemoveAllDeactivatedMembers 

func (s LocalCacheChannelStore) RemoveAllDeactivatedMembers(channelId string) *model.AppError

RemoveAllDeactivatedMembers is a wrapper method for the underlying store which just takes care of the cache invalidation.

func (LocalCacheChannelStore) RemoveMember 

func (s LocalCacheChannelStore) RemoveMember(channelId, userId string) *model.AppError

RemoveMember is a wrapper method for the underlying store which just takes care of the cache invalidation.

func (LocalCacheChannelStore) SaveMember 

func (s LocalCacheChannelStore) SaveMember(member *model.ChannelMember) (*model.ChannelMember, *model.AppError)

SaveMember is a wrapper method for the underlying store which just takes care of the cache invalidation.

func (LocalCacheChannelStore) UpdateLastViewedAt 

func (s LocalCacheChannelStore) UpdateLastViewedAt(channelIds []string, userId string) (map[string]int64, *model.AppError)

UpdateLastViewedAt is a wrapper method for the underlying store which just takes care of the cache invalidation.

func (LocalCacheChannelStore) UpdateLastViewedAtPost 

func (s LocalCacheChannelStore) UpdateLastViewedAtPost(unreadPost *model.Post, userID string, mentionCount int) (*model.ChannelUnreadAt, *model.AppError)

UpdateLastViewedAtPost is a wrapper method for the underlying store which just takes care of the cache invalidation.

func (LocalCacheChannelStore) UpdateMember 

func (s LocalCacheChannelStore) UpdateMember(member *model.ChannelMember) (*model.ChannelMember, *model.AppError)

UpdateMember is a wrapper method for the underlying store which just takes care of the cache invalidation.

type LocalCacheEmojiStore 

type LocalCacheEmojiStore struct {
	store.EmojiStore
	// contains filtered or unexported fields
}

func (LocalCacheEmojiStore) Delete 

func (es LocalCacheEmojiStore) Delete(emoji *model.Emoji, time int64) *model.AppError

func (LocalCacheEmojiStore) Get 

func (es LocalCacheEmojiStore) Get(id string, allowFromCache bool) (*model.Emoji, *model.AppError)

func (LocalCacheEmojiStore) GetByName 

func (es LocalCacheEmojiStore) GetByName(name string, allowFromCache bool) (*model.Emoji, *model.AppError)

type LocalCachePostStore 

type LocalCachePostStore struct {
	store.PostStore
	// contains filtered or unexported fields
}

func (LocalCachePostStore) ClearCaches 

func (s LocalCachePostStore) ClearCaches()

func (LocalCachePostStore) GetEtag 

func (s LocalCachePostStore) GetEtag(channelId string, allowFromCache bool) string

func (LocalCachePostStore) GetPosts 

func (s LocalCachePostStore) GetPosts(channelId string, offset int, limit int, allowFromCache bool) (*model.PostList, *model.AppError)

func (LocalCachePostStore) GetPostsSince 

func (s LocalCachePostStore) GetPostsSince(channelId string, time int64, allowFromCache bool) (*model.PostList, *model.AppError)

func (LocalCachePostStore) InvalidateLastPostTimeCache 

func (s LocalCachePostStore) InvalidateLastPostTimeCache(channelId string)

type LocalCacheReactionStore 

type LocalCacheReactionStore struct {
	store.ReactionStore
	// contains filtered or unexported fields
}

func (LocalCacheReactionStore) Delete 

func (s LocalCacheReactionStore) Delete(reaction *model.Reaction) (*model.Reaction, *model.AppError)

func (LocalCacheReactionStore) DeleteAllWithEmojiName 

func (s LocalCacheReactionStore) DeleteAllWithEmojiName(emojiName string) *model.AppError

func (LocalCacheReactionStore) GetForPost 

func (s LocalCacheReactionStore) GetForPost(postId string, allowFromCache bool) ([]*model.Reaction, *model.AppError)

func (LocalCacheReactionStore) Save 

func (s LocalCacheReactionStore) Save(reaction *model.Reaction) (*model.Reaction, *model.AppError)

type LocalCacheRoleStore 

type LocalCacheRoleStore struct {
	store.RoleStore
	// contains filtered or unexported fields
}

func (LocalCacheRoleStore) Delete 

func (s LocalCacheRoleStore) Delete(roleId string) (*model.Role, *model.AppError)

func (LocalCacheRoleStore) GetByName 

func (s LocalCacheRoleStore) GetByName(name string) (*model.Role, *model.AppError)

func (LocalCacheRoleStore) GetByNames 

func (s LocalCacheRoleStore) GetByNames(names []string) ([]*model.Role, *model.AppError)

func (LocalCacheRoleStore) PermanentDeleteAll 

func (s LocalCacheRoleStore) PermanentDeleteAll() *model.AppError

func (LocalCacheRoleStore) Save 

func (s LocalCacheRoleStore) Save(role *model.Role) (*model.Role, *model.AppError)

type LocalCacheSchemeStore 

type LocalCacheSchemeStore struct {
	store.SchemeStore
	// contains filtered or unexported fields
}

func (LocalCacheSchemeStore) Delete 

func (s LocalCacheSchemeStore) Delete(schemeId string) (*model.Scheme, *model.AppError)

func (LocalCacheSchemeStore) Get 

func (s LocalCacheSchemeStore) Get(schemeId string) (*model.Scheme, *model.AppError)

func (LocalCacheSchemeStore) PermanentDeleteAll 

func (s LocalCacheSchemeStore) PermanentDeleteAll() *model.AppError

func (LocalCacheSchemeStore) Save 

func (s LocalCacheSchemeStore) Save(scheme *model.Scheme) (*model.Scheme, *model.AppError)

type LocalCacheStore 

type LocalCacheStore struct {
	store.Store
	// contains filtered or unexported fields
}

func NewLocalCacheLayer 

func NewLocalCacheLayer(baseStore store.Store, metrics einterfaces.MetricsInterface, cluster einterfaces.ClusterInterface, cacheProvider cache.Provider) LocalCacheStore

func (LocalCacheStore) Channel 

func (s LocalCacheStore) Channel() store.ChannelStore

func (LocalCacheStore) DropAllTables 

func (s LocalCacheStore) DropAllTables()

func (LocalCacheStore) Emoji 

func (s LocalCacheStore) Emoji() store.EmojiStore

func (*LocalCacheStore) Invalidate 

func (s *LocalCacheStore) Invalidate()

func (LocalCacheStore) Post 

func (s LocalCacheStore) Post() store.PostStore

func (LocalCacheStore) Reaction 

func (s LocalCacheStore) Reaction() store.ReactionStore

func (LocalCacheStore) Role 

func (s LocalCacheStore) Role() store.RoleStore

func (LocalCacheStore) Scheme 

func (s LocalCacheStore) Scheme() store.SchemeStore

func (LocalCacheStore) Team 

func (s LocalCacheStore) Team() store.TeamStore

func (LocalCacheStore) TermsOfService 

func (s LocalCacheStore) TermsOfService() store.TermsOfServiceStore

func (LocalCacheStore) User 

func (s LocalCacheStore) User() store.UserStore

func (LocalCacheStore) Webhook 

func (s LocalCacheStore) Webhook() store.WebhookStore

type LocalCacheTeamStore 

type LocalCacheTeamStore struct {
	store.TeamStore
	// contains filtered or unexported fields
}

func (LocalCacheTeamStore) ClearCaches 

func (s LocalCacheTeamStore) ClearCaches()

func (LocalCacheTeamStore) GetUserTeamIds 

func (s LocalCacheTeamStore) GetUserTeamIds(userID string, allowFromCache bool) ([]string, *model.AppError)

func (LocalCacheTeamStore) InvalidateAllTeamIdsForUser 

func (s LocalCacheTeamStore) InvalidateAllTeamIdsForUser(userId string)

func (LocalCacheTeamStore) Update 

func (s LocalCacheTeamStore) Update(team *model.Team) (*model.Team, *model.AppError)

type LocalCacheTermsOfServiceStore 

type LocalCacheTermsOfServiceStore struct {
	store.TermsOfServiceStore
	// contains filtered or unexported fields
}

func (LocalCacheTermsOfServiceStore) ClearCaches 

func (s LocalCacheTermsOfServiceStore) ClearCaches()

func (LocalCacheTermsOfServiceStore) Get 

func (s LocalCacheTermsOfServiceStore) Get(id string, allowFromCache bool) (*model.TermsOfService, *model.AppError)

func (LocalCacheTermsOfServiceStore) GetLatest 

func (s LocalCacheTermsOfServiceStore) GetLatest(allowFromCache bool) (*model.TermsOfService, *model.AppError)

func (LocalCacheTermsOfServiceStore) Save 

func (s LocalCacheTermsOfServiceStore) Save(termsOfService *model.TermsOfService) (*model.TermsOfService, *model.AppError)

type LocalCacheUserStore 

type LocalCacheUserStore struct {
	store.UserStore
	// contains filtered or unexported fields
}

func (LocalCacheUserStore) ClearCaches 

func (s LocalCacheUserStore) ClearCaches()

func (LocalCacheUserStore) GetAllProfilesInChannel 

func (s LocalCacheUserStore) GetAllProfilesInChannel(channelId string, allowFromCache bool) (map[string]*model.User, *model.AppError)

func (LocalCacheUserStore) GetProfileByIds 

func (s LocalCacheUserStore) GetProfileByIds(userIds []string, options *store.UserGetByIdsOpts, allowFromCache bool) ([]*model.User, *model.AppError)

func (LocalCacheUserStore) InvalidateProfileCacheForUser 

func (s LocalCacheUserStore) InvalidateProfileCacheForUser(userId string)

func (LocalCacheUserStore) InvalidateProfilesInChannelCache 

func (s LocalCacheUserStore) InvalidateProfilesInChannelCache(channelId string)

func (LocalCacheUserStore) InvalidateProfilesInChannelCacheByUser 

func (s LocalCacheUserStore) InvalidateProfilesInChannelCacheByUser(userId string)

type LocalCacheWebhookStore 

type LocalCacheWebhookStore struct {
	store.WebhookStore
	// contains filtered or unexported fields
}

func (LocalCacheWebhookStore) ClearCaches 

func (s LocalCacheWebhookStore) ClearCaches()

func (LocalCacheWebhookStore) DeleteIncoming 

func (s LocalCacheWebhookStore) DeleteIncoming(webhookId string, time int64) *model.AppError

func (LocalCacheWebhookStore) GetIncoming 

func (s LocalCacheWebhookStore) GetIncoming(id string, allowFromCache bool) (*model.IncomingWebhook, *model.AppError)

func (LocalCacheWebhookStore) InvalidateWebhookCache 

func (s LocalCacheWebhookStore) InvalidateWebhookCache(webhookId string)

func (LocalCacheWebhookStore) PermanentDeleteIncomingByChannel 

func (s LocalCacheWebhookStore) PermanentDeleteIncomingByChannel(channelId string) *model.AppError

func (LocalCacheWebhookStore) PermanentDeleteIncomingByUser 

func (s LocalCacheWebhookStore) PermanentDeleteIncomingByUser(userId string) *model.AppError

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.