summaryrefslogtreecommitdiff
path: root/internal/db/bundb/marker.go
diff options
context:
space:
mode:
Diffstat (limited to 'internal/db/bundb/marker.go')
-rw-r--r--internal/db/bundb/marker.go10
1 files changed, 4 insertions, 6 deletions
diff --git a/internal/db/bundb/marker.go b/internal/db/bundb/marker.go
index 5d365e08a..b1dedb4f1 100644
--- a/internal/db/bundb/marker.go
+++ b/internal/db/bundb/marker.go
@@ -39,8 +39,8 @@ type markerDB struct {
*/
func (m *markerDB) GetMarker(ctx context.Context, accountID string, name gtsmodel.MarkerName) (*gtsmodel.Marker, error) {
- marker, err := m.state.Caches.GTS.Marker().Load(
- "AccountID.Name",
+ marker, err := m.state.Caches.GTS.Marker.LoadOne(
+ "AccountID,Name",
func() (*gtsmodel.Marker, error) {
var marker gtsmodel.Marker
@@ -52,9 +52,7 @@ func (m *markerDB) GetMarker(ctx context.Context, accountID string, name gtsmode
}
return &marker, nil
- },
- accountID,
- name,
+ }, accountID, name,
)
if err != nil {
return nil, err // already processed
@@ -74,7 +72,7 @@ func (m *markerDB) UpdateMarker(ctx context.Context, marker *gtsmodel.Marker) er
marker.Version = prevMarker.Version + 1
}
- return m.state.Caches.GTS.Marker().Store(marker, func() error {
+ return m.state.Caches.GTS.Marker.Store(marker, func() error {
if prevMarker == nil {
if _, err := m.db.NewInsert().
Model(marker).