storage

Documentation

Index

• func HashValue(val []byte) mpf.Hash
• type BadgerLogger
  • func NewBadgerLogger() *BadgerLogger
  • func (b *BadgerLogger) Debugf(msg string, args ...any)
  • func (b *BadgerLogger) Errorf(msg string, args ...any)
  • func (b *BadgerLogger) Infof(msg string, args ...any)
  • func (b *BadgerLogger) Warningf(msg string, args ...any)
• type Storage
  • func GetStorage() *Storage
  • func (s *Storage) AddUtxo(address string, txId string, txOutIdx uint32, txOutBytes []byte, slot uint64) error
  • func (s *Storage) GetBlockData(dest any) error
  • func (s *Storage) GetCursor() (uint64, string, error)
  • func (s *Storage) GetScriptRefUtxo(txId string, outputIdx int) ([]byte, error)
  • func (s *Storage) GetUtxos(address string) ([][]byte, error)
  • func (s *Storage) Load() error
  • func (s *Storage) PurgeDeletedUtxos(beforeSlot uint64) error
  • func (s *Storage) RemoveUtxo(address string, txId string, utxoIdx uint32, slot uint64) error
  • func (s *Storage) Rollback(slot uint64) error
  • func (s *Storage) Trie() *Trie
  • func (s *Storage) UpdateBlockData(blockData any) error
  • func (s *Storage) UpdateCursor(slotNumber uint64, blockHash string) error
• type Trie
  • func NewTrie(db *badger.DB, keyPrefix string) (*Trie, error)
  • func (t *Trie) Delete(key []byte) error
  • func (t *Trie) Hash() []byte
  • func (t *Trie) HashKey(key []byte) []byte
  • func (t *Trie) Prove(key []byte) (*mpf.Proof, error)
  • func (t *Trie) Rollback(slot uint64) error
  • func (t *Trie) Update(key []byte, val []byte, slot uint64) error

Functions

func HashValue

func HashValue(val []byte) mpf.Hash

Types

type BadgerLogger

type BadgerLogger struct{}

BadgerLogger is a wrapper type to give our logger the expected interface

func NewBadgerLogger

func NewBadgerLogger() *BadgerLogger

func (*BadgerLogger) Debugf

func (b *BadgerLogger) Debugf(msg string, args ...any)

func (*BadgerLogger) Errorf

func (b *BadgerLogger) Errorf(msg string, args ...any)

func (*BadgerLogger) Infof

func (b *BadgerLogger) Infof(msg string, args ...any)

func (*BadgerLogger) Warningf

func (b *BadgerLogger) Warningf(msg string, args ...any)

type Storage

type Storage struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func GetStorage

func GetStorage() *Storage

func (*Storage) AddUtxo

func (s *Storage) AddUtxo(
	address string,
	txId string,
	txOutIdx uint32,
	txOutBytes []byte,
	slot uint64,
) error

func (*Storage) GetBlockData

func (s *Storage) GetBlockData(dest any) error

func (*Storage) GetCursor

func (s *Storage) GetCursor() (uint64, string, error)

func (*Storage) GetScriptRefUtxo

func (s *Storage) GetScriptRefUtxo(txId string, outputIdx int) ([]byte, error)

func (*Storage) GetUtxos

func (s *Storage) GetUtxos(address string) ([][]byte, error)

func (*Storage) Load

func (s *Storage) Load() error

func (*Storage) PurgeDeletedUtxos

func (s *Storage) PurgeDeletedUtxos(beforeSlot uint64) error

func (*Storage) RemoveUtxo

func (s *Storage) RemoveUtxo(
	address string,
	txId string,
	utxoIdx uint32,
	slot uint64,
) error

func (*Storage) Rollback

func (s *Storage) Rollback(slot uint64) error

func (*Storage) Trie

func (s *Storage) Trie() *Trie

func (*Storage) UpdateBlockData

func (s *Storage) UpdateBlockData(blockData any) error

func (*Storage) UpdateCursor

func (s *Storage) UpdateCursor(slotNumber uint64, blockHash string) error

type Trie

type Trie struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewTrie

func NewTrie(db *badger.DB, keyPrefix string) (*Trie, error)

func (*Trie) Delete

func (t *Trie) Delete(key []byte) error

func (*Trie) Hash

func (t *Trie) Hash() []byte

func (*Trie) HashKey

func (t *Trie) HashKey(key []byte) []byte

HashKey returns a blake2b-256 hash for use in key values

func (*Trie) Prove

func (t *Trie) Prove(key []byte) (*mpf.Proof, error)

func (*Trie) Rollback

func (t *Trie) Rollback(slot uint64) error

func (*Trie) Update

func (t *Trie) Update(key []byte, val []byte, slot uint64) error