kv

package
v0.9.0-beta9 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Apr 19, 2021 License: Apache-2.0 Imports: 22 Imported by: 0

Documentation

Index

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.