core/go-store
8
0
Fork 0
Code Issues 4 Pull requests Projects Releases Packages Wiki Activity Actions 2

[agent/codex:gpt-5.4-mini] Read ~/spec/code/core/go/store/RFC.md fully. Find features d... #70

Merged
Virgil merged 1 commit from agent/read---spec-code-core-go-store-rfc-md-fu into dev 2026-04-03 07:40:33 +00:00
Conversation 1 Commits 1 Files changed 1 -5
1 changed files with 0 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

5
store.go
View file

@ -134,8 +134,6 @@ func WithPurgeInterval(interval time.Duration) StoreOption {
}
// Usage example: `storeInstance, err := store.NewConfigured(store.StoreConfig{DatabasePath: ":memory:", Journal: store.JournalConfiguration{EndpointURL: "http://127.0.0.1:8086", Organisation: "core", BucketName: "events"}, PurgeInterval: 20 * time.Millisecond})`
// NewConfigured also scans `.core/state` for leftover `.duckdb` workspace files
// so orphan recovery can happen before the first explicit recovery call.
func NewConfigured(config StoreConfig) (*Store, error) {
return newStoreFromConfig("store.NewConfigured", config)
}
@ -157,14 +155,11 @@ func newStoreFromConfig(operation string, config StoreConfig) (*Store, error) {
storeInstance.purgeInterval = config.PurgeInterval
}
_ = discoverOrphanWorkspacePaths(defaultWorkspaceStateDirectory)
storeInstance.startBackgroundPurge()
return storeInstance, nil
}
// Usage example: `storeInstance, err := store.New("/tmp/go-store.db", store.WithJournal("http://127.0.0.1:8086", "core", "events"))`
// New scans `.core/state` for leftover `.duckdb` workspace files before the
// store starts its background purge loop.
func New(databasePath string, options ...StoreOption) (*Store, error) {
config := StoreConfig{DatabasePath: databasePath}
for _, option := range options {