(config *PebbleStateStoreConfig, logger *slog.Logger)
| 48 | } |
| 49 | |
| 50 | func NewPebbleStateStore(config *PebbleStateStoreConfig, logger *slog.Logger) (*PebbleStateStore, error) { |
| 51 | log := logger.With(slog.String("component", "pebble-state-store")) |
| 52 | log.Info("Creating pebble state store", slog.String("dir", config.DirName)) |
| 53 | db, err := pebble.Open(config.DirName, &pebble.Options{}) |
| 54 | if err != nil { |
| 55 | return nil, err |
| 56 | } |
| 57 | return &PebbleStateStore{ |
| 58 | log: log, |
| 59 | db: db, |
| 60 | }, nil |
| 61 | } |
| 62 | |
| 63 | func (s *PebbleStateStore) PutState(key string, value []byte) error { |
| 64 | s.log.Debug("PutState", slog.String("key", key)) |
no test coverage detected