pebble

Documentation

Index

• Constants
• func GetPrefix(o interface{}) (ret string)
• func GetPrefixKey(prefix, author string) []byte
• type Batch
  • func (b *Batch) AddToBatch(o interface{}, key1 string, key2 uint64)
  • func (b *Batch) AddToBatchFullKey(o interface{}, key []byte) error
  • func (b *Batch) AddToBatchSingleKey(o interface{}, key string)
  • func (b *Batch) CommitBatch()
  • func (b *Batch) Remove(key []byte)
  • func (b *Batch) SaveAccounts(a storage.Accounts)
  • func (b *Batch) SetFinalizationData(f *storage.FinalizationData)
  • func (b *Batch) SetGenesisHash(h storage.GenesisHash)
  • func (b *Batch) SetTotalSupply(s *storage.TotalSupply)
  • func (b *Batch) UpdateWeekStats(w storage.WeekStats)
• type Storage
  • func NewStorage(file string) *Storage
  • func (s *Storage) Clean() error
  • func (s *Storage) Close() error
  • func (s *Storage) ForEach(o interface{}, address string, start *uint64, ...)
  • func (s *Storage) ForEachBackwards(o interface{}, address string, start *uint64, ...)
  • func (s *Storage) ForEachFromKey(prefix, start_key []byte, fn func(key, res []byte) (stop bool))
  • func (s *Storage) ForEachFromKeyBackwards(prefix, start_key []byte, fn func(key, res []byte) (stop bool))
  • func (s *Storage) GenesisHashExist() bool
  • func (s *Storage) GetAccounts() storage.Accounts
  • func (s *Storage) GetAddressStats(addr string) *storage.AddressStats
  • func (s *Storage) GetFinalizationData() *storage.FinalizationData
  • func (s *Storage) GetFromDB(o interface{}, key []byte) error
  • func (s *Storage) GetGenesisHash() storage.GenesisHash
  • func (s *Storage) GetInternalTransactions(hash string) models.InternalTransactionsResponse
  • func (s *Storage) GetTotalSupply() *storage.TotalSupply
  • func (s *Storage) GetTotalYield(block uint64) (res storage.Yield)
  • func (s *Storage) GetTransactionByHash(hash string) (res models.Transaction)
  • func (s *Storage) GetTransactionLogs(hash string) models.TransactionLogsResponse
  • func (s *Storage) GetValidatorYield(validator string, block uint64) (res storage.Yield)
  • func (s *Storage) GetWeekStats(year, week int32) storage.WeekStats
  • func (s *Storage) NewBatch() storage.Batch

Constants

const RewardsStatsPrefix = "rs"

Functions

func GetPrefix

func GetPrefix(o interface{}) (ret string)

func GetPrefixKey

func GetPrefixKey(prefix, author string) []byte

Types

type Batch

type Batch struct {
	*pebble.Batch
	Mutex *sync.RWMutex
}

func (*Batch) AddToBatch

func (b *Batch) AddToBatch(o interface{}, key1 string, key2 uint64)

func (*Batch) AddToBatchFullKey

func (b *Batch) AddToBatchFullKey(o interface{}, key []byte) error

func (*Batch) AddToBatchSingleKey

func (b *Batch) AddToBatchSingleKey(o interface{}, key string)

func (*Batch) CommitBatch

func (b *Batch) CommitBatch()

func (*Batch) Remove

func (b *Batch) Remove(key []byte)

func (*Batch) SaveAccounts

func (b *Batch) SaveAccounts(a storage.Accounts)

func (*Batch) SetFinalizationData

func (b *Batch) SetFinalizationData(f *storage.FinalizationData)

func (*Batch) SetGenesisHash

func (b *Batch) SetGenesisHash(h storage.GenesisHash)

func (*Batch) SetTotalSupply

func (b *Batch) SetTotalSupply(s *storage.TotalSupply)

func (*Batch) UpdateWeekStats

func (b *Batch) UpdateWeekStats(w storage.WeekStats)

type Storage

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

func NewStorage

func NewStorage(file string) *Storage

func (*Storage) Clean

func (s *Storage) Clean() error

func (*Storage) Close

func (s *Storage) Close() error

func (*Storage) ForEach

func (s *Storage) ForEach(o interface{}, address string, start *uint64, fn func(key, res []byte) (stop bool))

func (*Storage) ForEachBackwards

func (s *Storage) ForEachBackwards(o interface{}, address string, start *uint64, fn func(key, res []byte) (stop bool))

func (*Storage) ForEachFromKey

func (s *Storage) ForEachFromKey(prefix, start_key []byte, fn func(key, res []byte) (stop bool))

func (*Storage) ForEachFromKeyBackwards

func (s *Storage) ForEachFromKeyBackwards(prefix, start_key []byte, fn func(key, res []byte) (stop bool))

func (*Storage) GenesisHashExist

func (s *Storage) GenesisHashExist() bool

func (*Storage) GetAccounts

func (s *Storage) GetAccounts() storage.Accounts

func (*Storage) GetAddressStats

func (s *Storage) GetAddressStats(addr string) *storage.AddressStats

func (*Storage) GetFinalizationData

func (s *Storage) GetFinalizationData() *storage.FinalizationData

func (*Storage) GetFromDB

func (s *Storage) GetFromDB(o interface{}, key []byte) error

func (*Storage) GetGenesisHash

func (s *Storage) GetGenesisHash() storage.GenesisHash

func (*Storage) GetInternalTransactions

func (s *Storage) GetInternalTransactions(hash string) models.InternalTransactionsResponse

func (*Storage) GetTotalSupply

func (s *Storage) GetTotalSupply() *storage.TotalSupply

func (*Storage) GetTotalYield

func (s *Storage) GetTotalYield(block uint64) (res storage.Yield)

func (*Storage) GetTransactionByHash

func (s *Storage) GetTransactionByHash(hash string) (res models.Transaction)

func (*Storage) GetTransactionLogs

func (s *Storage) GetTransactionLogs(hash string) models.TransactionLogsResponse

func (*Storage) GetValidatorYield

func (s *Storage) GetValidatorYield(validator string, block uint64) (res storage.Yield)

func (*Storage) GetWeekStats

func (s *Storage) GetWeekStats(year, week int32) storage.WeekStats

func (*Storage) NewBatch

func (s *Storage) NewBatch() storage.Batch