(key string)
| 69 | } |
| 70 | |
| 71 | func (s *PebbleStateStore) GetState(key string) ([]byte, error) { |
| 72 | s.log.Debug("GetState", slog.String("key", key)) |
| 73 | value, closer, err := s.db.Get([]byte(key)) |
| 74 | if err != nil { |
| 75 | if errors.Is(err, pebble.ErrNotFound) { |
| 76 | return nil, api.ErrNotFound |
| 77 | } |
| 78 | return nil, err |
| 79 | } |
| 80 | result := make([]byte, len(value)) |
| 81 | copy(result, value) |
| 82 | if err := closer.Close(); err != nil { |
| 83 | return nil, err |
| 84 | } |
| 85 | return result, nil |
| 86 | } |
| 87 | |
| 88 | func (s *PebbleStateStore) Close() error { |
| 89 | return s.db.Close() |