store

package

v0.2.0 Latest Latest Go to latest Published: Feb 26, 2026 License: MIT Imports: 9 Imported by: 0

Details

View Source

const (
	DefaultBucket = "kamune-store"
	PeersBucket   = "peers"
)

View Source

var (
	ErrMissingItem   = errors.New("item not found")
	ErrMissingBucket = errors.New("bucket not found")
)

This section is empty.

type Command struct {
	Query
}

func (c *Command) AddEncrypted(bucket, key, value []byte) error

func (c *Command) AddPlain(bucket, key, value []byte) error

func (c *Command) CreateBucket(name []byte) error

func (c *Command) Delete(bucket, key []byte) error

func (c *Command) DeleteBatch(bucket []byte, keys [][]byte) (int, error)

DeleteBatch removes multiple keys from the same bucket in a single transaction. Keys that do not exist are silently skipped.

type Query struct {
	// contains filtered or unexported fields
}

func (q *Query) GetEncrypted(bucket, key []byte) ([]byte, error)

func (q *Query) GetPlain(bucket, key []byte) ([]byte, error)

func (q *Query) IterateEncrypted(bucket []byte) iter.Seq2[[]byte, []byte]

func (q *Query) IteratePlain(bucket []byte) iter.Seq2[[]byte, []byte]

func (q *Query) ListBuckets() []string

ListBuckets returns a list of all bucket names in the database

func (q *Query) ListBucketsWithPrefix(prefix string) []string

ListBucketsWithPrefix returns bucket names that start with the given prefix

type Store struct {
	// contains filtered or unexported fields
}

func New(passphrase []byte, path string) (*Store, error)

func (s *Store) Close() error

func (s *Store) Command(f func(c Command) error) error

func (s *Store) Query(f func(q Query) error) error