summaryrefslogtreecommitdiff
path: root/internal/cache/db.go
diff options
context:
space:
mode:
Diffstat (limited to 'internal/cache/db.go')
-rw-r--r--internal/cache/db.go37
1 files changed, 37 insertions, 0 deletions
diff --git a/internal/cache/db.go b/internal/cache/db.go
index d31017ccd..385c5bcbb 100644
--- a/internal/cache/db.go
+++ b/internal/cache/db.go
@@ -219,6 +219,9 @@ type DBCaches struct {
// Report provides access to the gtsmodel Report database cache.
Report StructCache[*gtsmodel.Report]
+ // ScheduledStatus provides access to the gtsmodel ScheduledStatus database cache.
+ ScheduledStatus StructCache[*gtsmodel.ScheduledStatus]
+
// SinBinStatus provides access to the gtsmodel SinBinStatus database cache.
SinBinStatus StructCache[*gtsmodel.SinBinStatus]
@@ -1287,6 +1290,40 @@ func (c *Caches) initReport() {
})
}
+func (c *Caches) initScheduledStatus() {
+ // Calculate maximum cache size.
+ cap := calculateResultCacheMax(
+ sizeofScheduledStatus(), // model in-mem size.
+ config.GetCacheScheduledStatusMemRatio(),
+ )
+
+ log.Infof(nil, "cache size = %d", cap)
+
+ copyF := func(s1 *gtsmodel.ScheduledStatus) *gtsmodel.ScheduledStatus {
+ s2 := new(gtsmodel.ScheduledStatus)
+ *s2 = *s1
+
+ // Don't include ptr fields that
+ // will be populated separately.
+ s2.Account = nil
+ s2.Application = nil
+ s2.MediaAttachments = nil
+
+ return s2
+ }
+
+ c.DB.ScheduledStatus.Init(structr.CacheConfig[*gtsmodel.ScheduledStatus]{
+ Indices: []structr.IndexConfig{
+ {Fields: "ID"},
+ {Fields: "AccountID", Multiple: true},
+ },
+ MaxSize: cap,
+ IgnoreErr: ignoreErrors,
+ Copy: copyF,
+ Invalidate: c.OnInvalidateScheduledStatus,
+ })
+}
+
func (c *Caches) initSinBinStatus() {
// Calculate maximum cache size.
cap := calculateResultCacheMax(