storage

package
v0.3.4 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: May 28, 2025 License: GPL-2.0, GPL-3.0 Imports: 15 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	FixedKey      = "fixed"
	FixedRangeKey = "fixed"
	NoneRangeKey  = "none"
	Delimeter     = "/"
)

Variables

View Source 
var (
	ErrNotRunning    = errors.New("DB is not running")
	ErrKeyNotFound   = badger.ErrKeyNotFound
	ErrWrongPassword = errors.New("wrong username or password")
	ErrStopIteration = errors.New("stop iteration")
)

Functions

This section is empty.

Types

type DB 

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

func New 

func New(
	path string,
	isInMemory bool,
	dataFolder string,
) (*DB, error)

func (*DB) Close 

func (db *DB) Close()

func (*DB) Delete 

func (db *DB) Delete(key DatabaseKey) error

func (*DB) GC 

func (db *DB) GC()

func (*DB) Get 

func (db *DB) Get(key DatabaseKey) ([]byte, error)

func (*DB) GetExpiration 

func (db *DB) GetExpiration(key DatabaseKey) (uint64, error)

func (*DB) GetSize 

func (db *DB) GetSize(key DatabaseKey) (int64, error)

func (*DB) InnerDB 

func (db *DB) InnerDB() *badger.DB

func (*DB) IsClosed 

func (db *DB) IsClosed() bool

func (*DB) IsFirstRun 

func (db *DB) IsFirstRun() bool

func (*DB) NewReadTxn 

func (db *DB) NewReadTxn() (WarpTxReader, error)

func (*DB) NewWriteTxn 

func (db *DB) NewWriteTxn() (WarpTxWriter, error)

func (*DB) NextSequence 

func (db *DB) NextSequence() (uint64, error)

func (*DB) Path 

func (db *DB) Path() string

func (*DB) Run 

func (db *DB) Run(username, password string) (err error)

func (*DB) Set 

func (db *DB) Set(key DatabaseKey, value []byte) error

func (*DB) SetWithTTL 

func (db *DB) SetWithTTL(key DatabaseKey, value []byte, ttl time.Duration) error

func (*DB) Stats 

func (db *DB) Stats() map[string]string

func (*DB) Sync 

func (db *DB) Sync() error

type DatabaseKey 

type DatabaseKey string

func (DatabaseKey) Bytes 

func (k DatabaseKey) Bytes() []byte

func (DatabaseKey) DropId 

func (k DatabaseKey) DropId() string

func (DatabaseKey) IsEmpty 

func (k DatabaseKey) IsEmpty() bool

func (DatabaseKey) String 

func (k DatabaseKey) String() string

type IdLayer 

type IdLayer string

func (IdLayer) AddId 

func (l IdLayer) AddId(mandatoryPrefix string) IdLayer

func (IdLayer) AddReversedTimestamp 

func (l IdLayer) AddReversedTimestamp(tm time.Time) RangeLayer

func (IdLayer) Build 

func (l IdLayer) Build() DatabaseKey

type IterKeysFunc 

type IterKeysFunc func(key string) error

type ListItem 

type ListItem struct {
	Key   string
	Value []byte
}

type Namespace 

type Namespace string

func NewPrefixBuilder 

func NewPrefixBuilder(mandatoryNamespace string) Namespace

NewPrefixBuilder creates a new PrefixBuilder instance

func (Namespace) AddRootID 

func (ns Namespace) AddRootID(mandatoryPrefix string) ParentLayer

func (Namespace) AddSubPrefix 

func (ns Namespace) AddSubPrefix(p string) Namespace

func (Namespace) Build 

func (ns Namespace) Build() DatabaseKey

type ParentLayer 

type ParentLayer string

func (ParentLayer) AddParentId 

func (l ParentLayer) AddParentId(mandatoryPrefix string) IdLayer

func (ParentLayer) AddRange 

func (l ParentLayer) AddRange(mandatoryPrefix RangePrefix) RangeLayer

func (ParentLayer) AddReversedTimestamp 

func (l ParentLayer) AddReversedTimestamp(tm time.Time) RangeLayer

func (ParentLayer) Build 

func (l ParentLayer) Build() DatabaseKey

type PrefixBuilder 

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

PrefixBuilder is a struct that holds a key and any potential error

func (*PrefixBuilder) AddReaderId 

func (pb *PrefixBuilder) AddReaderId(readerId string) *PrefixBuilder

func (*PrefixBuilder) AddWriterId 

func (pb *PrefixBuilder) AddWriterId(writerId string) *PrefixBuilder

AddFollowedId adds a followee ID segment to the key (reuses user ID validation)

type RangeLayer 

type RangeLayer string

func (RangeLayer) AddParentId 

func (l RangeLayer) AddParentId(mandatoryPrefix string) IdLayer

func (RangeLayer) Build 

func (l RangeLayer) Build() DatabaseKey

type RangePrefix 

type RangePrefix string

type WarpDB 

type WarpDB = badger.DB

type WarpDBLogger 

type WarpDBLogger interface {
	Errorf(string, ...interface{})
	Warningf(string, ...interface{})
	Infof(string, ...interface{})
	Debugf(string, ...interface{})
}

type WarpReadTxn 

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

func (*WarpReadTxn) BatchGet 

func (t *WarpReadTxn) BatchGet(keys ...DatabaseKey) ([]ListItem, error)

func (*WarpReadTxn) Commit 

func (t *WarpReadTxn) Commit() error

func (*WarpReadTxn) Get 

func (t *WarpReadTxn) Get(key DatabaseKey) ([]byte, error)

func (*WarpReadTxn) IterateKeys 

func (t *WarpReadTxn) IterateKeys(prefix DatabaseKey, handler IterKeysFunc) error

func (*WarpReadTxn) List 

func (t *WarpReadTxn) List(prefix DatabaseKey, limit *uint64, cursor *string) ([]ListItem, string, error)

func (*WarpReadTxn) ReverseIterateKeys 

func (t *WarpReadTxn) ReverseIterateKeys(prefix DatabaseKey, handler IterKeysFunc) error

func (*WarpReadTxn) Rollback 

func (t *WarpReadTxn) Rollback()

type WarpTxReader 

type WarpTxReader interface {
	IterateKeys(prefix DatabaseKey, handler IterKeysFunc) error
	Get(key DatabaseKey) ([]byte, error)
	ReverseIterateKeys(prefix DatabaseKey, handler IterKeysFunc) error
	List(prefix DatabaseKey, limit *uint64, cursor *string) ([]ListItem, string, error)
	BatchGet(keys ...DatabaseKey) ([]ListItem, error)
	Commit() error
	Rollback()
}

type WarpTxWriter 

type WarpTxWriter interface {
	Set(key DatabaseKey, value []byte) error
	Get(key DatabaseKey) ([]byte, error)
	SetWithTTL(key DatabaseKey, value []byte, ttl time.Duration) error
	BatchSet(data []ListItem) (err error)
	Delete(key DatabaseKey) error
	Increment(key DatabaseKey) (uint64, error)
	Decrement(key DatabaseKey) (uint64, error)
	Commit() error
	Rollback()
}

type WarpTxn 

type WarpTxn = badger.Txn

type WarpWriteTxn 

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

func (*WarpWriteTxn) BatchSet 

func (t *WarpWriteTxn) BatchSet(data []ListItem) (err error)

func (*WarpWriteTxn) Commit 

func (t *WarpWriteTxn) Commit() error

func (*WarpWriteTxn) Decrement 

func (t *WarpWriteTxn) Decrement(key DatabaseKey) (uint64, error)

func (*WarpWriteTxn) Delete 

func (t *WarpWriteTxn) Delete(key DatabaseKey) error

func (*WarpWriteTxn) Get 

func (t *WarpWriteTxn) Get(key DatabaseKey) ([]byte, error)

func (*WarpWriteTxn) Increment 

func (t *WarpWriteTxn) Increment(key DatabaseKey) (uint64, error)

func (*WarpWriteTxn) Rollback 

func (t *WarpWriteTxn) Rollback()

func (*WarpWriteTxn) Set 

func (t *WarpWriteTxn) Set(key DatabaseKey, value []byte) error

func (*WarpWriteTxn) SetWithTTL 

func (t *WarpWriteTxn) SetWithTTL(key DatabaseKey, value []byte, ttl time.Duration) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.