database

package

v0.0.22 Latest Latest Go to latest Published: Apr 20, 2026 License: MIT Imports: 10 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/benjaminschubert/locaccel

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
type Database
- func NewDatabase[T encodable, TPtr Ptr[T]](path string, logger *zerolog.Logger) (*Database[T, TPtr], error)
type Entry
- func (e *Entry[T]) Version() uint64
type Ptr
type Response

Constants ¶

This section is empty.

Variables ¶

View Source

var (
	ErrKeyNotFound = badger.ErrKeyNotFound
	ErrNoRewrite   = badger.ErrNoRewrite
	ErrInvalidKey  = errors.New("invalid entry key")
	ErrConflict    = errors.New("trying to update an entry that got updated already")
)

Functions ¶

This section is empty.

Types ¶

type Database ¶

type Database[T encodable, TPtr Ptr[T]] struct {
	// contains filtered or unexported fields
}

func NewDatabase ¶

func NewDatabase[T encodable, TPtr Ptr[T]](
	path string,
	logger *zerolog.Logger,
) (*Database[T, TPtr], error)

func (*Database[T, TPtr]) Close ¶

func (d *Database[T, TPtr]) Close() error

func (*Database[T, TPtr]) Delete ¶

func (d *Database[T, TPtr]) Delete(key []byte, entry *Entry[T]) error

func (*Database[T, TPtr]) Get ¶

func (d *Database[T, TPtr]) Get(key []byte, entry *Entry[T]) error

func (*Database[T, TPtr]) GetStatistics ¶

func (d *Database[T, TPtr]) GetStatistics() (count int64, totalSize units.Bytes, err error)

func (*Database[T, TPtr]) Iterate ¶

func (d *Database[T, TPtr]) Iterate(
	ctx context.Context,
	apply func(key []byte, value *Entry[T]) error,
	logId string,
) error

func (*Database[T, TPtr]) New ¶

func (d *Database[T, TPtr]) New(key []byte, value T) error

func (*Database[T, TPtr]) RunGarbageCollector ¶

func (d *Database[T, TPtr]) RunGarbageCollector() error

func (*Database[T, TPtr]) Save ¶

func (d *Database[T, TPtr]) Save(key []byte, entry *Entry[T]) error

type Entry ¶

type Entry[T any] struct {
	Value T
	// contains filtered or unexported fields
}

func (*Entry[T]) Version ¶ added in v0.0.10

func (e *Entry[T]) Version() uint64

type Ptr ¶

type Ptr[T encodable] interface {
	*T
	msgp.Unmarshaler
}

type Response ¶

type Response struct {
	Headers      http.Header
	ResponseHash string
	StatusCode   int
}

Source Files ¶

View all Source files

database.go

Directories ¶

Path	Synopsis
internal
dbtestutils

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL