pebble

package

v1.8.1 Latest Latest Go to latest Published: Apr 3, 2024 License: MIT Imports: 15 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/Taraxa-project/taraxa-indexer

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func GetPrefix(o interface{}) (ret string)
func GetPrefixKey(prefix, author string) []byte
type Batch
type Storage
- func NewStorage(file string) *Storage

Constants ¶

View Source

const RewardsStatsPrefix = "rs"

Variables ¶

This section is empty.

Functions ¶

func GetPrefix ¶ added in v0.3.0

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

func GetPrefixKey ¶ added in v1.5.6

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 ¶ added in v0.3.0

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 ¶ added in v0.3.0

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

func (*Storage) ForEachFromKeyBackwards ¶ added in v1.8.1

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 ¶ added in v0.3.0

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 ¶ added in v0.2.3

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

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
migrations

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL