diff --git a/compact_test.go b/compact_test.go index c4a71d9..d54f805 100644 --- a/compact_test.go +++ b/compact_test.go @@ -136,7 +136,7 @@ func TestCompact_Compact_Good_DeterministicOrderingForSameTimestamp(t *testing.T require.NoError(t, ensureJournalSchema(storeInstance.sqliteDatabase)) committedAt := time.Now().Add(-48 * time.Hour).UnixMilli() - require.NoError(t, insertJournalEntry( + require.NoError(t, commitJournalEntry( storeInstance.sqliteDatabase, "events", "session-b", @@ -144,7 +144,7 @@ func TestCompact_Compact_Good_DeterministicOrderingForSameTimestamp(t *testing.T `{"workspace":"session-b"}`, committedAt, )) - require.NoError(t, insertJournalEntry( + require.NoError(t, commitJournalEntry( storeInstance.sqliteDatabase, "events", "session-a", diff --git a/journal.go b/journal.go index c9d41f6..4c0d404 100644 --- a/journal.go +++ b/journal.go @@ -72,7 +72,7 @@ func (storeInstance *Store) CommitToJournal(measurement string, fields map[strin } committedAt := time.Now().UnixMilli() - if err := insertJournalEntry( + if err := commitJournalEntry( storeInstance.sqliteDatabase, storeInstance.journalBucket(), measurement, @@ -228,7 +228,7 @@ func ensureJournalSchema(database schemaDatabase) error { return nil } -func insertJournalEntry( +func commitJournalEntry( executor journalExecutor, bucket, measurement, fieldsJSON, tagsJSON string, committedAt int64, diff --git a/journal_test.go b/journal_test.go index 2a2d3dc..22fdea2 100644 --- a/journal_test.go +++ b/journal_test.go @@ -135,7 +135,7 @@ func TestJournal_QueryJournal_Good_BucketFilter(t *testing.T) { require.True(t, storeInstance.CommitToJournal("session-a", map[string]any{"like": 1}, map[string]string{"workspace": "session-a"}).OK, ) - require.NoError(t, insertJournalEntry( + require.NoError(t, commitJournalEntry( storeInstance.sqliteDatabase, "events", "session-b", @@ -160,7 +160,7 @@ func TestJournal_QueryJournal_Good_DeterministicOrderingForSameTimestamp(t *test require.NoError(t, ensureJournalSchema(storeInstance.sqliteDatabase)) committedAt := time.Date(2026, 3, 30, 12, 0, 0, 0, time.UTC).UnixMilli() - require.NoError(t, insertJournalEntry( + require.NoError(t, commitJournalEntry( storeInstance.sqliteDatabase, "events", "session-b", @@ -168,7 +168,7 @@ func TestJournal_QueryJournal_Good_DeterministicOrderingForSameTimestamp(t *test `{"workspace":"session-b"}`, committedAt, )) - require.NoError(t, insertJournalEntry( + require.NoError(t, commitJournalEntry( storeInstance.sqliteDatabase, "events", "session-a", diff --git a/workspace.go b/workspace.go index 15a6604..5f2e7c8 100644 --- a/workspace.go +++ b/workspace.go @@ -471,7 +471,7 @@ func (storeInstance *Store) commitWorkspaceAggregate(workspaceName string, field return err } - if err := insertJournalEntry( + if err := commitJournalEntry( transaction, storeInstance.journalBucket(), workspaceName,