kv

package

v0.9.2 Latest Latest Go to latest Published: Mar 18, 2022 License: Apache-2.0 Imports: 22 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/zhongshuwen/dfuse-eosio

Links

Open Source Insights

Documentation ¶

Constants ¶

View Source

const (
	TblPrefixTrxs      = 0x00
	TblPrefixBlocks    = 0x01
	TblPrefixIrrBlks   = 0x02
	TblPrefixImplTrxs  = 0x03
	TblPrefixDtrxs     = 0x04
	TblPrefixTrxTraces = 0x05
	TblPrefixAccts     = 0x06
	TblTTL             = 0x10
)

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type DB ¶

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

"read"'s default is "*" "write"'s default is "*" Dsn examples dgraphql in eos mainnet core: store:/// by default: read=*&write=* dgraphql in curv: store://mainnet/?read=blk,trx&write=none store://curv/?read=trx&write=none dgraphql in curv: store://mainnet/?read=blk&write=none store://curv/?read=trx&write=none trxdb-loader for mainnet core: store:///?write=blk /* read="*" */ trxdb-loader for curv: store:///?write=trx /* only purpose: NOT WRITE blk */ single laptop-style deployment: store:/// by default: read=*&write=* single laptop-style deployment, secure: store:///?read=blk,trx&write=none

func New ¶

func New(dsns []string) (*DB, error)

func (*DB) BlockIDAfter ¶

func (db *DB) BlockIDAfter(ctx context.Context, start time.Time, inclusive bool) (id string, foundTime time.Time, err error)

func (*DB) BlockIDAt ¶

func (db *DB) BlockIDAt(ctx context.Context, start time.Time) (id string, err error)

func (*DB) BlockIDBefore ¶

func (db *DB) BlockIDBefore(ctx context.Context, start time.Time, inclusive bool) (id string, foundTime time.Time, err error)

func (*DB) Close ¶

func (db *DB) Close() error

func (*DB) Dump ¶

func (db *DB) Dump()

func (*DB) Flush ¶

func (db *DB) Flush(ctx context.Context) error

func (*DB) GetAccount ¶

func (db *DB) GetAccount(ctx context.Context, accountName string) (*pbcodec.AccountCreationRef, error)

func (*DB) GetBlock ¶

func (db *DB) GetBlock(ctx context.Context, id string) (blk *pbcodec.BlockWithRefs, err error)

func (*DB) GetBlockByNum ¶

func (db *DB) GetBlockByNum(ctx context.Context, num uint32) (out []*pbcodec.BlockWithRefs, err error)

func (*DB) GetClosestIrreversibleIDAtBlockNum ¶

func (db *DB) GetClosestIrreversibleIDAtBlockNum(ctx context.Context, num uint32) (ref bstream.BlockRef, err error)

func (*DB) GetIrreversibleIDAtBlockID ¶

func (db *DB) GetIrreversibleIDAtBlockID(ctx context.Context, ID string) (ref bstream.BlockRef, err error)

func (*DB) GetLastWrittenBlockID ¶

func (db *DB) GetLastWrittenBlockID(ctx context.Context) (blockID string, err error)

func (*DB) GetLastWrittenIrreversibleBlockRef ¶

func (db *DB) GetLastWrittenIrreversibleBlockRef(ctx context.Context) (ref bstream.BlockRef, err error)

This is in the writer interface, because it is required to start the the pipeline.

func (*DB) GetTransactionEvents ¶

func (db *DB) GetTransactionEvents(ctx context.Context, idPrefix string) (out []*pbcodec.TransactionEvent, err error)

func (*DB) GetTransactionEventsBatch ¶

func (db *DB) GetTransactionEventsBatch(ctx context.Context, idPrefixes []string) (out [][]*pbcodec.TransactionEvent, err error)

func (*DB) GetTransactionTraces ¶

func (db *DB) GetTransactionTraces(ctx context.Context, idPrefix string) (out []*pbcodec.TransactionEvent, err error)

func (*DB) GetTransactionTracesBatch ¶

func (db *DB) GetTransactionTracesBatch(ctx context.Context, idPrefixes []string) (out [][]*pbcodec.TransactionEvent, err error)

func (*DB) ListAccountNames ¶

func (db *DB) ListAccountNames(ctx context.Context) (out []string, err error)

func (*DB) ListBlocks ¶

func (db *DB) ListBlocks(ctx context.Context, highBlockNum uint32, limit int) (out []*pbcodec.BlockWithRefs, err error)

func (*DB) ListSiblingBlocks ¶

func (db *DB) ListSiblingBlocks(ctx context.Context, blockNum uint32, spread uint32) (out []*pbcodec.BlockWithRefs, err error)

func (*DB) PutBlock ¶

func (db *DB) PutBlock(ctx context.Context, blk *pbcodec.Block) error

func (*DB) SetLogger ¶

func (db *DB) SetLogger(logger *zap.Logger) error

func (*DB) SetPurgeableStore ¶

func (db *DB) SetPurgeableStore(ttl, purgeInterval uint64) error

func (*DB) SetWriterChainID ¶

func (db *DB) SetWriterChainID(chainID []byte)

func (*DB) UpdateNowIrreversibleBlock ¶

func (db *DB) UpdateNowIrreversibleBlock(ctx context.Context, blk *pbcodec.Block) error

type Keyer ¶

type Keyer struct{}

var Keys Keyer

func (Keyer) EndOfAccountTable ¶

func (Keyer) EndOfAccountTable() []byte

func (Keyer) EndOfBlocksTable ¶

func (Keyer) EndOfBlocksTable() []byte

func (Keyer) EndOfDtrxsTable ¶

func (Keyer) EndOfDtrxsTable() []byte

func (Keyer) EndOfImplicitTrxsTable ¶

func (Keyer) EndOfImplicitTrxsTable() []byte

func (Keyer) EndOfIrrBlockTable ¶

func (Keyer) EndOfIrrBlockTable() []byte

func (Keyer) EndOfTimelineIndex ¶

func (Keyer) EndOfTimelineIndex(fwd bool) []byte

func (Keyer) EndOfTrxTracesTable ¶

func (Keyer) EndOfTrxTracesTable() []byte

func (Keyer) EndOfTrxsTable ¶

func (Keyer) EndOfTrxsTable() []byte

func (Keyer) PackAccountKey ¶

func (Keyer) PackAccountKey(accountName string) []byte

func (Keyer) PackBlockNumPrefix ¶

func (Keyer) PackBlockNumPrefix(blockNum uint32) []byte

func (Keyer) PackBlocksKey ¶

func (Keyer) PackBlocksKey(blockID string) []byte

func (Keyer) PackDtrxsKeyCancelled ¶

func (k Keyer) PackDtrxsKeyCancelled(trxID, blockID string) []byte

func (Keyer) PackDtrxsKeyCreated ¶

func (k Keyer) PackDtrxsKeyCreated(trxID, blockID string) []byte

Dtrx virt table

func (Keyer) PackDtrxsKeyFailed ¶

func (k Keyer) PackDtrxsKeyFailed(trxID, blockID string) []byte

func (Keyer) PackDtrxsPrefix ¶

func (k Keyer) PackDtrxsPrefix(trxID string) []byte

func (Keyer) PackImplicitTrxsKey ¶

func (k Keyer) PackImplicitTrxsKey(trxID, blockID string) []byte

func (Keyer) PackImplicitTrxsPrefix ¶

func (k Keyer) PackImplicitTrxsPrefix(trxID string) []byte

func (Keyer) PackIrrBlockNumPrefix ¶

func (Keyer) PackIrrBlockNumPrefix(blockNum uint32) []byte

func (Keyer) PackIrrBlocksKey ¶

func (Keyer) PackIrrBlocksKey(blockID string) []byte

func (Keyer) PackTimelineKey ¶

func (Keyer) PackTimelineKey(fwd bool, blockTime time.Time, blockID string) []byte

func (Keyer) PackTimelinePrefix ¶

func (k Keyer) PackTimelinePrefix(fwd bool, blockTime time.Time) []byte

func (Keyer) PackTrxTracesKey ¶

func (k Keyer) PackTrxTracesKey(trxID, blockID string) []byte

TrxTrace virt table

func (Keyer) PackTrxTracesPrefix ¶

func (k Keyer) PackTrxTracesPrefix(trxID string) []byte

func (Keyer) PackTrxsKey ¶

func (k Keyer) PackTrxsKey(trxID string, blockID string) []byte

func (Keyer) PackTrxsPrefix ¶

func (k Keyer) PackTrxsPrefix(trxID string) []byte

func (Keyer) StartOfAccountTable ¶

func (Keyer) StartOfAccountTable() []byte

func (Keyer) StartOfBlocksTable ¶

func (Keyer) StartOfBlocksTable() []byte

func (Keyer) StartOfDtrxsTable ¶

func (Keyer) StartOfDtrxsTable() []byte

func (Keyer) StartOfImplicitTrxsTable ¶

func (Keyer) StartOfImplicitTrxsTable() []byte

func (Keyer) StartOfIrrBlockTable ¶

func (Keyer) StartOfIrrBlockTable() []byte

func (Keyer) StartOfTimelineIndex ¶

func (Keyer) StartOfTimelineIndex(fwd bool) []byte

func (Keyer) StartOfTrxTracesTable ¶

func (Keyer) StartOfTrxTracesTable() []byte

func (Keyer) StartOfTrxsTable ¶

func (Keyer) StartOfTrxsTable() []byte

func (Keyer) UnpackAccountKey ¶

func (Keyer) UnpackAccountKey(key []byte) string

func (Keyer) UnpackBlocksKey ¶

func (Keyer) UnpackBlocksKey(key []byte) (blockID string)

func (Keyer) UnpackDtrxsKey ¶

func (k Keyer) UnpackDtrxsKey(key []byte) (trxID, blockID string)

func (Keyer) UnpackImplicitTrxsKey ¶

func (k Keyer) UnpackImplicitTrxsKey(key []byte) (trxID, blockID string)

func (Keyer) UnpackIrrBlocksKey ¶

func (Keyer) UnpackIrrBlocksKey(key []byte) (blockID string)

func (Keyer) UnpackTimelineKey ¶

func (Keyer) UnpackTimelineKey(fwd bool, key []byte) (blockTime time.Time, blockID string)

func (Keyer) UnpackTrxTracesKey ¶

func (k Keyer) UnpackTrxTracesKey(key []byte) (trxID, blockID string)

func (Keyer) UnpackTrxsKey ¶

func (k Keyer) UnpackTrxsKey(key []byte) (trxID, blockID string)

type TrxEventType ¶

type TrxEventType int

const (
	TrxAdditionEvent TrxEventType = iota + 1
	TrxExecutionEvent
	ImplicitTrxEvent
	DtrxEvent
)

Source Files ¶

View all Source files

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