leveldb

Documentation

Index

• type LevelDBDatabase
  • func (lvldb *LevelDBDatabase) Close() error
  • func (lvldb *LevelDBDatabase) GetAllTxOutputs(address string, onlyNotUsed bool) ([]*core.TxInputOutput, error)
  • func (lvldb *LevelDBDatabase) GetConfirmedBlocksFrom(slotNumber uint64, maxCnt int) ([]*core.CardanoBlock, error)
  • func (lvldb *LevelDBDatabase) GetLatestBlockPoint() (*core.BlockPoint, error)
  • func (lvldb *LevelDBDatabase) GetLatestConfirmedBlocks(maxCnt int) ([]*core.CardanoBlock, error)
  • func (lvldb *LevelDBDatabase) GetTxOutput(txInput core.TxInput) (result core.TxOutput, err error)
  • func (lvldb *LevelDBDatabase) GetUnprocessedConfirmedTxs(maxCnt int) ([]*core.Tx, error)
  • func (lvldb *LevelDBDatabase) Init(filePath string) error
  • func (lvldb *LevelDBDatabase) MarkConfirmedTxsProcessed(txs []*core.Tx) error
  • func (lvldb *LevelDBDatabase) OpenTx() core.DBTransactionWriter
• type LevelDBTransactionWriter
  • func NewLevelDBTransactionWriter(db *leveldb.DB) *LevelDBTransactionWriter
  • func (tw *LevelDBTransactionWriter) AddConfirmedBlock(block *core.CardanoBlock) core.DBTransactionWriter
  • func (tw *LevelDBTransactionWriter) AddConfirmedTxs(txs []*core.Tx) core.DBTransactionWriter
  • func (tw *LevelDBTransactionWriter) AddTxOutputs(txOutputs []*core.TxInputOutput) core.DBTransactionWriter
  • func (tw *LevelDBTransactionWriter) DeleteAllTxOutputsPhysically() core.DBTransactionWriter
  • func (tw *LevelDBTransactionWriter) Execute() error
  • func (tw *LevelDBTransactionWriter) RemoveTxOutputs(txInputs []*core.TxInput, softDelete bool) core.DBTransactionWriter
  • func (tw *LevelDBTransactionWriter) SetLatestBlockPoint(point *core.BlockPoint) core.DBTransactionWriter

Types

type LevelDBDatabase

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

func (*LevelDBDatabase) Close

func (lvldb *LevelDBDatabase) Close() error

func (*LevelDBDatabase) GetAllTxOutputs

func (lvldb *LevelDBDatabase) GetAllTxOutputs(address string, onlyNotUsed bool) ([]*core.TxInputOutput, error)

func (*LevelDBDatabase) GetConfirmedBlocksFrom

func (lvldb *LevelDBDatabase) GetConfirmedBlocksFrom(slotNumber uint64, maxCnt int) ([]*core.CardanoBlock, error)

func (*LevelDBDatabase) GetLatestBlockPoint

func (lvldb *LevelDBDatabase) GetLatestBlockPoint() (*core.BlockPoint, error)

func (*LevelDBDatabase) GetLatestConfirmedBlocks

func (lvldb *LevelDBDatabase) GetLatestConfirmedBlocks(maxCnt int) ([]*core.CardanoBlock, error)

func (*LevelDBDatabase) GetTxOutput

func (lvldb *LevelDBDatabase) GetTxOutput(txInput core.TxInput) (result core.TxOutput, err error)

func (*LevelDBDatabase) GetUnprocessedConfirmedTxs

func (lvldb *LevelDBDatabase) GetUnprocessedConfirmedTxs(maxCnt int) ([]*core.Tx, error)

func (*LevelDBDatabase) Init

func (lvldb *LevelDBDatabase) Init(filePath string) error

func (*LevelDBDatabase) MarkConfirmedTxsProcessed

func (lvldb *LevelDBDatabase) MarkConfirmedTxsProcessed(txs []*core.Tx) error

func (*LevelDBDatabase) OpenTx

func (lvldb *LevelDBDatabase) OpenTx() core.DBTransactionWriter

type LevelDBTransactionWriter

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

func NewLevelDBTransactionWriter

func NewLevelDBTransactionWriter(db *leveldb.DB) *LevelDBTransactionWriter

func (*LevelDBTransactionWriter) AddConfirmedBlock

func (tw *LevelDBTransactionWriter) AddConfirmedBlock(block *core.CardanoBlock) core.DBTransactionWriter

func (*LevelDBTransactionWriter) AddConfirmedTxs

func (tw *LevelDBTransactionWriter) AddConfirmedTxs(txs []*core.Tx) core.DBTransactionWriter

func (*LevelDBTransactionWriter) AddTxOutputs

func (tw *LevelDBTransactionWriter) AddTxOutputs(txOutputs []*core.TxInputOutput) core.DBTransactionWriter

func (*LevelDBTransactionWriter) DeleteAllTxOutputsPhysically

func (tw *LevelDBTransactionWriter) DeleteAllTxOutputsPhysically() core.DBTransactionWriter

func (*LevelDBTransactionWriter) Execute

func (tw *LevelDBTransactionWriter) Execute() error

func (*LevelDBTransactionWriter) RemoveTxOutputs

func (tw *LevelDBTransactionWriter) RemoveTxOutputs(
	txInputs []*core.TxInput, softDelete bool,
) core.DBTransactionWriter

func (*LevelDBTransactionWriter) SetLatestBlockPoint

func (tw *LevelDBTransactionWriter) SetLatestBlockPoint(point *core.BlockPoint) core.DBTransactionWriter