MCPcopy Create free account
hub / github.com/FunctionStream/function-stream / NewPebbleStateStore

Function NewPebbleStateStore

fs/statestore/pebble.go:50–61  ·  view source on GitHub ↗
(config *PebbleStateStoreConfig, logger *slog.Logger)

Source from the content-addressed store, hash-verified

48}
49
50func 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
63func (s *PebbleStateStore) PutState(key string, value []byte) error {
64 s.log.Debug("PutState", slog.String("key", key))

Callers 1

NewTmpPebbleStateStoreFunction · 0.85

Calls 1

StringMethod · 0.45

Tested by

no test coverage detected