aboutsummaryrefslogtreecommitdiff
path: root/state/memory_backend.go
diff options
context:
space:
mode:
authorSangTran-127 <tranquangsang12.7@gmail.com>2026-08-09 14:52:46 +0700
committerSangTran-127 <tranquangsang12.7@gmail.com>2026-08-09 14:52:46 +0700
commita892cb5b1d121177881fa56a79abbafef5880a80 (patch)
treea410523a4c91de1a35b80a279bc6c8c1179fdffb /state/memory_backend.go
parent4d62f01af159fddd56585b3dce19b8a0f47369c1 (diff)
downloadgoflink-a892cb5b1d121177881fa56a79abbafef5880a80.tar.gz
goflink-a892cb5b1d121177881fa56a79abbafef5880a80.zip
feat: implement GetValueState and memoryStateValue for state management
Diffstat (limited to 'state/memory_backend.go')
-rw-r--r--state/memory_backend.go9
1 files changed, 7 insertions, 2 deletions
diff --git a/state/memory_backend.go b/state/memory_backend.go
index 58e86e0..8e37a8d 100644
--- a/state/memory_backend.go
+++ b/state/memory_backend.go
@@ -36,6 +36,11 @@ func (ms *MemoryStateBackend) SetCurrentKey(key string) error {
}
func (ms *MemoryStateBackend) GetValueState(ctx context.Context, key string) (core.ValueState[any], error) {
- //TODO implement me
- panic("implement me")
+ // Assign if state not existed
+
+ if _, ok := ms.states[key]; !ok {
+ ms.states[key] = make(map[int]map[string]any)
+ }
+
+ return &memoryStateValue{backend: ms, stateName: key}, nil
}