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

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

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

32
doc.go
View file

@ -19,47 +19,41 @@
// }
// defer configuredStore.Close()
//
// storeInstance, err := store.New(":memory:")
// if err != nil {
// if err := configuredStore.Set("config", "colour", "blue"); err != nil {
// return
// }
// defer storeInstance.Close()
//
// if err := storeInstance.Set("config", "colour", "blue"); err != nil {
// return
// }
// if err := storeInstance.SetWithTTL("session", "token", "abc123", 5*time.Minute); err != nil {
// if err := configuredStore.SetWithTTL("session", "token", "abc123", 5*time.Minute); err != nil {
// return
// }
//
// colourValue, err := storeInstance.Get("config", "colour")
// colourValue, err := configuredStore.Get("config", "colour")
// if err != nil {
// return
// }
// fmt.Println(colourValue)
//
// for entry, err := range storeInstance.All("config") {
// for entry, err := range configuredStore.All("config") {
// if err != nil {
// return
// }
// fmt.Println(entry.Key, entry.Value)
// }
//
// events := storeInstance.Watch("config")
// defer storeInstance.Unwatch("config", events)
// events := configuredStore.Watch("config")
// defer configuredStore.Unwatch("config", events)
// go func() {
// for event := range events {
// fmt.Println(event.Type, event.Group, event.Key, event.Value)
// }
// }()
//
// unregister := storeInstance.OnChange(func(event store.Event) {
// unregister := configuredStore.OnChange(func(event store.Event) {
// fmt.Println("changed", event.Group, event.Key, event.Value)
// })
// defer unregister()
//
// scopedStore, err := store.NewScopedWithQuota(
// storeInstance,
// configuredStore,
// "tenant-a",
// store.QuotaConfig{MaxKeys: 100, MaxGroups: 10},
// )
@ -70,14 +64,14 @@
// return
// }
//
// for groupName, err := range storeInstance.GroupsSeq("tenant-a:") {
// for groupName, err := range configuredStore.GroupsSeq("tenant-a:") {
// if err != nil {
// return
// }
// fmt.Println(groupName)
// }
//
// workspace, err := storeInstance.NewWorkspace("scroll-session")
// workspace, err := configuredStore.NewWorkspace("scroll-session")
// if err != nil {
// return
// }
@ -93,18 +87,18 @@
// return
// }
//
// orphans := storeInstance.RecoverOrphans(".core/state")
// orphans := configuredStore.RecoverOrphans(".core/state")
// for _, orphanWorkspace := range orphans {
// fmt.Println(orphanWorkspace.Aggregate())
// orphanWorkspace.Discard()
// }
//
// journalResult := storeInstance.QueryJournal(`from(bucket: "events") |> range(start: -24h)`)
// journalResult := configuredStore.QueryJournal(`from(bucket: "events") |> range(start: -24h)`)
// if !journalResult.OK {
// return
// }
//
// archiveResult := storeInstance.Compact(store.CompactOptions{
// archiveResult := configuredStore.Compact(store.CompactOptions{
// Before: time.Now().Add(-30 * 24 * time.Hour),
// Output: "/tmp/archive",
// Format: "gzip",