aboutsummaryrefslogtreecommitdiff
path: root/state/memory_backend.go
diff options
context:
space:
mode:
authorsangtran <tranquangsang12.7@gmail.com>2026-09-05 17:06:30 +0700
committersangtran <tranquangsang12.7@gmail.com>2026-09-05 17:06:30 +0700
commite626cee8f7de0dd3ffca4c7297e59a87f790cc02 (patch)
tree1b57f5e3134459872890e3df7484be5cf3cb3ba6 /state/memory_backend.go
parent67be8b5e2b5188d4291ed0a3c3a91b5e40bfbebe (diff)
signatureVerified sangtran <tranquangsang12.7@gmail.com> Key: 8DD79823D235E1BB ultimate trust
downloadflux-e626cee8f7de0dd3ffca4c7297e59a87f790cc02.tar.gz
flux-e626cee8f7de0dd3ffca4c7297e59a87f790cc02.zip
Verified feat: add on pebble state backend and using sync Pool to reuse buffer []byte
Diffstat (limited to 'state/memory_backend.go')
-rw-r--r--state/memory_backend.go8
1 files changed, 4 insertions, 4 deletions
diff --git a/state/memory_backend.go b/state/memory_backend.go
index dda577e..cce8194 100644
--- a/state/memory_backend.go
+++ b/state/memory_backend.go
@@ -39,15 +39,15 @@ func (ms *MemoryStateBackend) SetCurrentKey(key string) error {
39 return nil 39 return nil
40} 40}
41 41
42func (ms *MemoryStateBackend) GetValueState(ctx context.Context, statename string) (core.ValueState[any], error) { 42func (ms *MemoryStateBackend) GetValueState(ctx context.Context, stateName string) (core.ValueState[any], error) {
43 // Assign if state not existed 43 // Assign if state not existed
44 44
45 if _, ok := ms.states[statename]; !ok { 45 if _, ok := ms.states[stateName]; !ok {
46 // create state name map if not existed 46 // create state name map if not existed
47 ms.states[statename] = make(map[int]map[string]map[any]any) 47 ms.states[stateName] = make(map[int]map[string]map[any]any)
48 } 48 }
49 49
50 return &memoryStateValue{backend: ms, stateName: statename}, nil 50 return &memoryStateValue{backend: ms, stateName: stateName}, nil
51} 51}
52 52
53func (ms *MemoryStateBackend) GetCurrentNamespace() any { 53func (ms *MemoryStateBackend) GetCurrentNamespace() any {