localcachelayer

package
v6.0.0 Latest Latest
Warning

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

 Go to latest Published: Oct 8, 2021 License: AGPL-3.0, Apache-2.0 Imports: 14 Imported by: 2

Documentation

Index

Constants

View Source 
const (
	ReactionCacheSize = 20000
	ReactionCacheSec  = 30 * 60

	RoleCacheSize = 20000
	RoleCacheSec  = 30 * 60

	SchemeCacheSize = 20000
	SchemeCacheSec  = 30 * 60

	FileInfoCacheSize = 25000
	FileInfoCacheSec  = 30 * 60

	ChannelGuestCountCacheSize = model.ChannelCacheSize
	ChannelGuestCountCacheSec  = 30 * 60

	WebhookCacheSize = 25000
	WebhookCacheSec  = 15 * 60

	EmojiCacheSize = 5000
	EmojiCacheSec  = 30 * 60

	ChannelPinnedPostsCounsCacheSize = model.ChannelCacheSize
	ChannelPinnedPostsCountsCacheSec = 30 * 60

	ChannelMembersCountsCacheSize = model.ChannelCacheSize
	ChannelMembersCountsCacheSec  = 30 * 60

	LastPostsCacheSize = 20000
	LastPostsCacheSec  = 30 * 60

	TermsOfServiceCacheSize = 20000
	TermsOfServiceCacheSec  = 30 * 60
	LastPostTimeCacheSize   = 25000
	LastPostTimeCacheSec    = 15 * 60

	UserProfileByIDCacheSize = 20000
	UserProfileByIDSec       = 30 * 60

	ProfilesInChannelCacheSize = model.ChannelCacheSize
	ProfilesInChannelCacheSec  = 15 * 60

	TeamCacheSize = 20000
	TeamCacheSec  = 30 * 60

	ChannelCacheSec = 15 * 60 // 15 mins
)
View Source 
const (
	LatestKey = "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) ClearCaches 

func (s LocalCacheChannelStore) ClearCaches()

func (LocalCacheChannelStore) Get 

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

func (LocalCacheChannelStore) GetGuestCount 

func (s LocalCacheChannelStore) GetGuestCount(channelId string, allowFromCache bool) (int64, error)

func (LocalCacheChannelStore) GetMemberCount 

func (s LocalCacheChannelStore) GetMemberCount(channelId string, allowFromCache bool) (int64, error)

func (LocalCacheChannelStore) GetMemberCountFromCache 

func (s LocalCacheChannelStore) GetMemberCountFromCache(channelId string) int64

func (LocalCacheChannelStore) GetPinnedPostCount 

func (s LocalCacheChannelStore) GetPinnedPostCount(channelId string, allowFromCache bool) (int64, error)

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

func (s LocalCacheChannelStore) RemoveMember(channelId, userId string) error

func (LocalCacheChannelStore) RemoveMembers 

func (s LocalCacheChannelStore) RemoveMembers(channelId string, userIds []string) error

func (LocalCacheChannelStore) SaveMember 

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

func (LocalCacheChannelStore) SaveMultipleMembers 

func (s LocalCacheChannelStore) SaveMultipleMembers(members []*model.ChannelMember) ([]*model.ChannelMember, error)

func (LocalCacheChannelStore) UpdateMember 

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

func (LocalCacheChannelStore) UpdateMultipleMembers 

func (s LocalCacheChannelStore) UpdateMultipleMembers(members []*model.ChannelMember) ([]*model.ChannelMember, error)

type LocalCacheEmojiStore 

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

func (*LocalCacheEmojiStore) Delete 

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

func (*LocalCacheEmojiStore) Get 

func (es *LocalCacheEmojiStore) Get(ctx context.Context, id string, allowFromCache bool) (*model.Emoji, error)

func (*LocalCacheEmojiStore) GetByName 

func (es *LocalCacheEmojiStore) GetByName(ctx context.Context, name string, allowFromCache bool) (*model.Emoji, error)

type LocalCacheFileInfoStore 

type LocalCacheFileInfoStore struct {
	store.FileInfoStore
	// contains filtered or unexported fields
}

func (LocalCacheFileInfoStore) ClearCaches 

func (s LocalCacheFileInfoStore) ClearCaches()

func (LocalCacheFileInfoStore) GetForPost 

func (s LocalCacheFileInfoStore) GetForPost(postId string, readFromMaster, includeDeleted, allowFromCache bool) ([]*model.FileInfo, error)

func (LocalCacheFileInfoStore) InvalidateFileInfosForPostCache 

func (s LocalCacheFileInfoStore) InvalidateFileInfosForPostCache(postId string, deleted bool)

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, collapsedThreads bool) string

func (LocalCachePostStore) GetPosts 

func (s LocalCachePostStore) GetPosts(options model.GetPostsOptions, allowFromCache bool) (*model.PostList, error)

func (LocalCachePostStore) GetPostsSince 

func (s LocalCachePostStore) GetPostsSince(options model.GetPostsSinceOptions, allowFromCache bool) (*model.PostList, error)

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, error)

func (LocalCacheReactionStore) DeleteAllWithEmojiName 

func (s LocalCacheReactionStore) DeleteAllWithEmojiName(emojiName string) error

func (LocalCacheReactionStore) GetForPost 

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

func (LocalCacheReactionStore) Save 

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

type LocalCacheRoleStore 

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

func (LocalCacheRoleStore) ChannelHigherScopedPermissions 

func (s LocalCacheRoleStore) ChannelHigherScopedPermissions(roleNames []string) (map[string]*model.RolePermissions, error)

func (LocalCacheRoleStore) Delete 

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

func (LocalCacheRoleStore) GetByName 

func (s LocalCacheRoleStore) GetByName(ctx context.Context, name string) (*model.Role, error)

func (LocalCacheRoleStore) GetByNames 

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

func (LocalCacheRoleStore) PermanentDeleteAll 

func (s LocalCacheRoleStore) PermanentDeleteAll() error

func (LocalCacheRoleStore) Save 

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

type LocalCacheSchemeStore 

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

func (LocalCacheSchemeStore) Delete 

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

func (LocalCacheSchemeStore) Get 

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

func (LocalCacheSchemeStore) PermanentDeleteAll 

func (s LocalCacheSchemeStore) PermanentDeleteAll() error

func (LocalCacheSchemeStore) Save 

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

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 LocalCacheStore, err error)

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

func (s LocalCacheStore) FileInfo() store.FileInfoStore

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, error)

func (LocalCacheTeamStore) InvalidateAllTeamIdsForUser 

func (s LocalCacheTeamStore) InvalidateAllTeamIdsForUser(userId string)

func (LocalCacheTeamStore) Update 

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

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, error)

func (LocalCacheTermsOfServiceStore) GetLatest 

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

func (LocalCacheTermsOfServiceStore) Save 

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

type LocalCacheUserStore 

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

func (*LocalCacheUserStore) ClearCaches 

func (s *LocalCacheUserStore) ClearCaches()

func (*LocalCacheUserStore) Get 

func (s *LocalCacheUserStore) Get(ctx context.Context, id string) (*model.User, error)

Get is a cache wrapper around the SqlStore method to get a user profile by id. It checks if the user entry is present in the cache, returning the entry from cache if it is present. Otherwise, it fetches the entry from the store and stores it in the cache.

func (*LocalCacheUserStore) GetAllProfilesInChannel 

func (s *LocalCacheUserStore) GetAllProfilesInChannel(ctx context.Context, channelId string, allowFromCache bool) (map[string]*model.User, error)

func (*LocalCacheUserStore) GetMany 

func (s *LocalCacheUserStore) GetMany(ctx context.Context, ids []string) ([]*model.User, error)

GetMany is a cache wrapper around the SqlStore method to get a user profiles by ids. It checks if the user entries are present in the cache, returning the entries from cache if it is present. Otherwise, it fetches the entries from the store and stores it in the cache.

func (*LocalCacheUserStore) GetProfileByIds 

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

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

func (LocalCacheWebhookStore) GetIncoming 

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

func (LocalCacheWebhookStore) InvalidateWebhookCache 

func (s LocalCacheWebhookStore) InvalidateWebhookCache(webhookId string)

func (LocalCacheWebhookStore) PermanentDeleteIncomingByChannel 

func (s LocalCacheWebhookStore) PermanentDeleteIncomingByChannel(channelId string) error

func (LocalCacheWebhookStore) PermanentDeleteIncomingByUser 

func (s LocalCacheWebhookStore) PermanentDeleteIncomingByUser(userId string) error

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.