badger

package
v0.0.0-...-a65a15d Latest Latest
Warning

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

 Go to latest Published: Apr 21, 2023 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type DB 

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

func New 

func New(dir string) (*DB, error)

func (*DB) Close 

func (r *DB) Close() error

func (*DB) CurrentEstablishmentEvent 

func (r *DB) CurrentEstablishmentEvent(pre string) (*event.Message, error)

func (*DB) CurrentEvent 

func (r *DB) CurrentEvent(pre string) (*event.Message, error)

func (*DB) EscrowLikelyDuplicitiousEvent 

func (r *DB) EscrowLikelyDuplicitiousEvent(e *event.Message) error

func (*DB) EscrowOutOfOrderEvent 

func (r *DB) EscrowOutOfOrderEvent(e *event.Message) error

func (*DB) EscrowPendingEvent 

func (r *DB) EscrowPendingEvent(e *event.Message) error

func (*DB) Event 

func (r *DB) Event(pre, dig string) (*event.Event, error)

func (*DB) EventAt 

func (r *DB) EventAt(pre string, sn int) (*event.Message, error)

func (*DB) Get 

func (r *DB) Get(k string) ([]byte, error)

func (*DB) Inception 

func (r *DB) Inception(pre string) (*event.Message, error)

func (*DB) LastAcceptedDigest 

func (r *DB) LastAcceptedDigest(pre string, seq int) ([]byte, error)

func (*DB) LogEvent 

func (r *DB) LogEvent(e *event.Message, first bool) error

func (*DB) LogNonTransferableReceipt 

func (r *DB) LogNonTransferableReceipt(rct *event.Receipt) error

func (*DB) LogSize 

func (r *DB) LogSize(pre string) int

func (*DB) LogTransferableReceipt 

func (r *DB) LogTransferableReceipt(vrc *event.Receipt) error

func (*DB) Message 

func (r *DB) Message(pre, dig string) (*event.Message, error)

func (*DB) Put 

func (r *DB) Put(k string, v []byte) error

func (*DB) RemovePendingEscrow 

func (r *DB) RemovePendingEscrow(prefix string, sn int, dig string) error

func (*DB) Seen 

func (r *DB) Seen(pre string) bool

func (*DB) Signatures 

func (r *DB) Signatures(pre, dig string) ([]derivation.Derivation, error)

func (*DB) StreamAsFirstSeen 

func (r *DB) StreamAsFirstSeen(pre string, handler func(*event.Message) error) error

func (*DB) StreamBySequenceNo 

func (r *DB) StreamBySequenceNo(pre string, handler func(*event.Message) error) error

func (*DB) StreamEstablisment 

func (r *DB) StreamEstablisment(pre string, handler func(*event.Message) error) error

func (*DB) StreamPending 

func (r *DB) StreamPending(pre string, handler func(*event.Message) error) error

func (*DB) StreamTransferableReceipts 

func (r *DB) StreamTransferableReceipts(pre string, sn int, handler func(quadlet []byte) error) error

type Iterator 

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

func NewIterator 

func NewIterator(txn *badger.Txn, seek []byte) *Iterator

func (*Iterator) Close 

func (r *Iterator) Close()

func (*Iterator) Key 

func (r *Iterator) Key() []byte

func (*Iterator) Next 

func (r *Iterator) Next() bool

func (*Iterator) Value 

func (r *Iterator) Value() []byte

type NoOpLogger 

type NoOpLogger struct {
}

func (*NoOpLogger) Debugf 

func (r *NoOpLogger) Debugf(s string, i ...interface{})

func (*NoOpLogger) Errorf 

func (r *NoOpLogger) Errorf(s string, i ...interface{})

func (*NoOpLogger) Infof 

func (r *NoOpLogger) Infof(s string, i ...interface{})

func (*NoOpLogger) Warningf 

func (r *NoOpLogger) Warningf(s string, i ...interface{})

type OrderedSet 

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

func NewOrderedSet 

func NewOrderedSet(ns, key string) *OrderedSet

func (*OrderedSet) Add 

func (r *OrderedSet) Add(txn *badger.Txn, val []byte, keyvals ...interface{}) error

func (*OrderedSet) Count 

func (r *OrderedSet) Count(txn *badger.Txn, keyvals ...interface{}) int

func (*OrderedSet) Delete 

func (r *OrderedSet) Delete(txn *badger.Txn, keyvals ...interface{}) error

func (*OrderedSet) First 

func (r *OrderedSet) First(txn *badger.Txn, keyvals ...interface{}) ([][]byte, error)

func (*OrderedSet) Get 

func (r *OrderedSet) Get(txn *badger.Txn, keyvals ...interface{}) ([][]byte, error)

func (*OrderedSet) Iterator 

func (r *OrderedSet) Iterator(txn *badger.Txn, keyvals ...interface{}) *SetIterator

func (*OrderedSet) Last 

func (r *OrderedSet) Last(txn *badger.Txn, keyvals ...interface{}) ([][]byte, error)

func (*OrderedSet) Put 

func (r *OrderedSet) Put(txn *badger.Txn, vals [][]byte, keyvals ...interface{}) error

func (*OrderedSet) RemoveFromSet 

func (r *OrderedSet) RemoveFromSet(txn *badger.Txn, val []byte, keyvals ...interface{}) error

type Set 

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

func NewSet 

func NewSet(ns, key string) *Set

func (*Set) Add 

func (r *Set) Add(txn *badger.Txn, val []byte, keyvals ...interface{}) error

func (*Set) Count 

func (r *Set) Count(txn *badger.Txn, keyvals ...interface{}) int

func (*Set) Delete 

func (r *Set) Delete(txn *badger.Txn, keyvals ...interface{}) error

func (*Set) First 

func (r *Set) First(txn *badger.Txn, keyvals ...interface{}) ([][]byte, error)

func (*Set) Get 

func (r *Set) Get(txn *badger.Txn, keyvals ...interface{}) ([][]byte, error)

func (*Set) Iterator 

func (r *Set) Iterator(txn *badger.Txn, keyvals ...interface{}) *SetIterator

func (*Set) Last 

func (r *Set) Last(txn *badger.Txn, keyvals ...interface{}) ([][]byte, error)

func (*Set) Put 

func (r *Set) Put(txn *badger.Txn, vals [][]byte, keyvals ...interface{}) error

type SetIterator 

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

func NewSetIterator 

func NewSetIterator(txn *badger.Txn, seek []byte) *SetIterator

func (*SetIterator) Close 

func (r *SetIterator) Close()

func (*SetIterator) Key 

func (r *SetIterator) Key() []byte

func (*SetIterator) Next 

func (r *SetIterator) Next() bool

func (*SetIterator) Value 

func (r *SetIterator) Value() [][]byte

type Value 

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

func NewValue 

func NewValue(ns, key string) *Value

func (*Value) Count 

func (r *Value) Count(txn *badger.Txn, keyvals ...interface{}) int

func (*Value) Delete 

func (r *Value) Delete(txn *badger.Txn, keyvals ...interface{}) error

func (*Value) DeleteAll 

func (r *Value) DeleteAll(txn *badger.Txn, keyvals ...interface{}) error

func (*Value) Exists 

func (r *Value) Exists(txn *badger.Txn, keyvals ...interface{}) bool

func (*Value) First 

func (r *Value) First(txn *badger.Txn, keyvals ...interface{}) ([]byte, error)

func (*Value) Get 

func (r *Value) Get(txn *badger.Txn, keyvals ...interface{}) ([]byte, error)

func (*Value) Iterator 

func (r *Value) Iterator(txn *badger.Txn, keyvals ...interface{}) *Iterator

func (*Value) Last 

func (r *Value) Last(txn *badger.Txn, keyvals ...interface{}) ([]byte, error)

func (*Value) Put 

func (r *Value) Put(txn *badger.Txn, val []byte, keyvals ...interface{}) error

Put writes value at key, does not change value if it already exsits

func (*Value) Set 

func (r *Value) Set(txn *badger.Txn, val []byte, keyvals ...interface{}) error

Set writes value at key, overwrites if it already exists

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.