database

Documentation

Index

• func ConnectToDatabase(logger *slog.Logger, path string) (*sqlx.DB, error)
• type BadgerKeyValueStore
  • func NewBadgerKeyValueStore(path string) (*BadgerKeyValueStore, error)
  • func (b *BadgerKeyValueStore) Close() error
  • func (b *BadgerKeyValueStore) Delete(key string) error
  • func (b *BadgerKeyValueStore) Get(key string) ([]byte, error)
  • func (b *BadgerKeyValueStore) Increment(key string) (int, error)
  • func (b *BadgerKeyValueStore) Keys(prefix string) ([]string, error)
  • func (b *BadgerKeyValueStore) Set(key string, value []byte, ttl time.Duration) error
• type KeyValueStore

Functions

func ConnectToDatabase

func ConnectToDatabase(logger *slog.Logger, path string) (*sqlx.DB, error)

Types

type BadgerKeyValueStore

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

func NewBadgerKeyValueStore

func NewBadgerKeyValueStore(path string) (*BadgerKeyValueStore, error)

func (*BadgerKeyValueStore) Close

func (b *BadgerKeyValueStore) Close() error

func (*BadgerKeyValueStore) Delete

func (b *BadgerKeyValueStore) Delete(key string) error

func (*BadgerKeyValueStore) Get

func (b *BadgerKeyValueStore) Get(key string) ([]byte, error)

func (*BadgerKeyValueStore) Increment

func (b *BadgerKeyValueStore) Increment(key string) (int, error)

func (*BadgerKeyValueStore) Keys

func (b *BadgerKeyValueStore) Keys(prefix string) ([]string, error)

func (*BadgerKeyValueStore) Set

func (b *BadgerKeyValueStore) Set(key string, value []byte, ttl time.Duration) error

type KeyValueStore

type KeyValueStore interface {
	Close() error

	Get(key string) ([]byte, error)
	Set(key string, value []byte, ttl time.Duration) error
	Increment(key string) (int, error)
	Delete(key string) error
	Keys(prefix string) ([]string, error)
}