storesqlite

Documentation

Index

• Constants
• func TestKV(t *testing.T, test storekv.TestKV, newStore New, wg *pr2.WaitGroup)
• type Def
  • func (Def) New(machine naming.MachineName, newMem storemem.New, ...) New
• type New
• type Store
  • func (s *Store) CostInfo() storekv.CostInfo
  • func (s *Store) KeyDelete(keys ...string) (err error)
  • func (s *Store) KeyExists(key string) (ok bool, err error)
  • func (s *Store) KeyGet(key string, fn func(io.Reader) error) (err error)
  • func (s *Store) KeyIter(prefix string, fn func(key string) error) (err error)
  • func (s *Store) KeyPut(key string, r io.Reader) (err error)
  • func (s *Store) Name() string
  • func (s *Store) StoreID() string

Constants

const (
	Kv = iota
	Idx
)

Functions

func TestKV

func TestKV(
	t *testing.T,
	test storekv.TestKV,
	newStore New,
	wg *pr2.WaitGroup,
)

Types

type Def

type Def struct{}

func (Def) New

func (Def) New(
	machine naming.MachineName,
	newMem storemem.New,
	setRestrictedPath fsys.SetRestrictedPath,
) New

type New

type New func(
	ctx context.Context,
	path string,
) (*Store, error)

type Store

type Store struct {
	DB *sql.DB
	// contains filtered or unexported fields
}

func (*Store) CostInfo

func (s *Store) CostInfo() storekv.CostInfo

func (*Store) KeyDelete

func (s *Store) KeyDelete(keys ...string) (err error)

func (*Store) KeyExists

func (s *Store) KeyExists(key string) (ok bool, err error)

func (*Store) KeyGet

func (s *Store) KeyGet(key string, fn func(io.Reader) error) (err error)

func (*Store) KeyIter

func (s *Store) KeyIter(prefix string, fn func(key string) error) (err error)

func (*Store) KeyPut

func (s *Store) KeyPut(key string, r io.Reader) (err error)

func (*Store) Name

func (s *Store) Name() string

func (*Store) StoreID

func (s *Store) StoreID() string