Versions in this module Expand all Collapse all v0 v0.0.1 Nov 2, 2022 Changes in this version + var ErrKeyExists = errors.New("key already exists") + var ErrKeyNotFound = errors.New("key not found") + var ErrPathNotFound = errors.New("path not found") + type Config struct + DBPath string + RequestTimeout time.Duration + type Session struct + func (s *Session) BucketExists(path []string) bool + func (s *Session) CreateBucket(path []string) error + func (s *Session) DeleteBucket(path []string) error + func (s *Session) DeleteKey(path []string, key string) error + func (s *Session) KeyExists(path []string, key string) bool + func (s *Session) List(path []string, pageToken string) ([]string, [][]byte, string, error) + func (s *Session) ListBuckets(path []string, pageToken string) ([]string, string, error) + func (s *Session) ListKeys(path []string, pageToken string) ([]string, string, error) + func (s *Session) NextSeq(path []string) (uint64, error) + func (s *Session) PrefixExists(path []string, prefix string) (bool, error) + func (s *Session) Read(path []string, key string) ([]byte, error) + func (s *Session) ReadScan(path []string, prefix string) ([]string, [][]byte, error) + func (s *Session) Write(path []string, key string, value []byte) error + type Store struct + func NewStore(cfg *Config, logger *zerolog.Logger) *Store + func (s *Store) Close() + func (s *Store) Open() error + func (s *Store) ReadSession() (*Session, func(), error) + func (s *Store) WriteSession() (*Session, func(), error)
Go to main page