storage

package

v0.1.2 Latest Latest Go to latest Published: Sep 30, 2021 License: AGPL-3.0 Imports: 10 Imported by: 24

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/makerdao/vulcanizedb

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
Variables
func Decode(diff types.PersistedDiff, metadata types.ValueMetadata) interface{}
func GetIncrementedKey(original common.Hash, incrementBy int64) common.Hash
func GetKeyForMapping(indexOnContract, key string) common.Hash
func GetKeyForNestedMapping(indexOnContract, primaryKey, secondaryKey string) common.Hash
func NewDiffRepository(db *postgres.DB) diffRepository
type DiffExtractor
- func NewDiffExtractor(fetcher fetcher.IStorageFetcher, db *postgres.DB) DiffExtractor
- func (extractor DiffExtractor) ExtractDiffs() error
type DiffRepository

Constants ¶

View Source

const (
	IndexZero   = "0000000000000000000000000000000000000000000000000000000000000000"
	IndexOne    = "0000000000000000000000000000000000000000000000000000000000000001"
	IndexTwo    = "0000000000000000000000000000000000000000000000000000000000000002"
	IndexThree  = "0000000000000000000000000000000000000000000000000000000000000003"
	IndexFour   = "0000000000000000000000000000000000000000000000000000000000000004"
	IndexFive   = "0000000000000000000000000000000000000000000000000000000000000005"
	IndexSix    = "0000000000000000000000000000000000000000000000000000000000000006"
	IndexSeven  = "0000000000000000000000000000000000000000000000000000000000000007"
	IndexEight  = "0000000000000000000000000000000000000000000000000000000000000008"
	IndexNine   = "0000000000000000000000000000000000000000000000000000000000000009"
	IndexTen    = "000000000000000000000000000000000000000000000000000000000000000a"
	IndexEleven = "000000000000000000000000000000000000000000000000000000000000000b"
	IndexTwelve = "000000000000000000000000000000000000000000000000000000000000000c"
)

Variables ¶

View Source

var (
	New          = `new`
	Pending      = `pending`
	Noncanonical = `noncanonical`
	Transformed  = `transformed`
	Unrecognized = `unrecognized`
	Unwatched    = `unwatched`
)

Functions ¶

func Decode ¶ added in v0.1.0

func Decode(diff types.PersistedDiff, metadata types.ValueMetadata) interface{}

func GetIncrementedKey ¶

func GetIncrementedKey(original common.Hash, incrementBy int64) common.Hash

func GetKeyForMapping ¶ added in v0.1.0

func GetKeyForMapping(indexOnContract, key string) common.Hash

func GetKeyForNestedMapping ¶ added in v0.1.0

func GetKeyForNestedMapping(indexOnContract, primaryKey, secondaryKey string) common.Hash

func NewDiffRepository ¶ added in v0.1.0

func NewDiffRepository(db *postgres.DB) diffRepository

Types ¶

type DiffExtractor ¶ added in v0.1.0

type DiffExtractor struct {
	StorageDiffRepository DiffRepository
	StorageFetcher        fetcher.IStorageFetcher
}

func NewDiffExtractor ¶ added in v0.1.0

func NewDiffExtractor(fetcher fetcher.IStorageFetcher, db *postgres.DB) DiffExtractor

func (DiffExtractor) ExtractDiffs ¶ added in v0.1.0

func (extractor DiffExtractor) ExtractDiffs() error

type DiffRepository ¶ added in v0.1.0

type DiffRepository interface {
	CreateStorageDiff(rawDiff types.RawDiff) (int64, error)
	CreateBackFilledStorageValue(rawDiff types.RawDiff) error
	GetNewDiffs(minID, limit int) ([]types.PersistedDiff, error)
	GetUnrecognizedDiffs(minID, limit int) ([]types.PersistedDiff, error)
	GetPendingDiffs(minID, limit int) ([]types.PersistedDiff, error)
	MarkTransformed(id int64) error
	MarkNoncanonical(id int64) error
	MarkNoncanonicalDiffsAsNew(blockNumber int64) error
	MarkUnrecognized(id int64) error
	MarkUnwatched(id int64) error
	MarkPending(id int64) error
	GetFirstDiffIDForBlockHeight(blockHeight int64) (int64, error)
}

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
backfill
fetcher
types

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