diff options
| author | sangtran <tranquangsang12.7@gmail.com> | 2026-09-05 17:06:30 +0700 |
|---|---|---|
| committer | sangtran <tranquangsang12.7@gmail.com> | 2026-09-05 17:06:30 +0700 |
| commit | e626cee8f7de0dd3ffca4c7297e59a87f790cc02 (patch) | |
| tree | 1b57f5e3134459872890e3df7484be5cf3cb3ba6 /state/memory_backend.go | |
| parent | 67be8b5e2b5188d4291ed0a3c3a91b5e40bfbebe (diff) | |
| signature | Verified sangtran <tranquangsang12.7@gmail.com> Key: 8DD79823D235E1BB ultimate trust | |
| download | flux-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.go | 8 |
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 | ||
| 42 | func (ms *MemoryStateBackend) GetValueState(ctx context.Context, statename string) (core.ValueState[any], error) { | 42 | func (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 | ||
| 53 | func (ms *MemoryStateBackend) GetCurrentNamespace() any { | 53 | func (ms *MemoryStateBackend) GetCurrentNamespace() any { |
