store

Documentation

Index

• type BlockStore
• type DBDriver
• type DataStore
• type FlushBuffered
• type Store
  • func New(driver DBDriver) *Store
  • func (s *Store) BlockContinuityCheck(ctx context.Context, blx structs.BlockWithMeta, startHeight, endHeight uint64) ([][2]uint64, error)
  • func (s *Store) BlockTransactionCheck(ctx context.Context, blx structs.BlockWithMeta, startHeight, endHeight uint64) ([]uint64, error)
  • func (s *Store) GetBlockForTime(ctx context.Context, blx structs.BlockWithMeta, time time.Time) (structs.Block, bool, error)
  • func (s *Store) GetBlocksHeightsWithNumTx(ctx context.Context, blx structs.BlockWithMeta, startHeight, endHeight uint64) ([][2]uint64, error)
  • func (s *Store) GetLatestBlock(ctx context.Context, blx structs.BlockWithMeta) (structs.Block, error)
  • func (s *Store) GetLatestTransaction(ctx context.Context, in structs.TransactionWithMeta) (out structs.Transaction, err error)
  • func (s *Store) GetTransactions(ctx context.Context, tsearch params.TransactionSearch) ([]structs.Transaction, error)
  • func (s *Store) GetTransactionsHeightsWithTxCount(ctx context.Context, blx structs.BlockWithMeta, startHeight, endHeight uint64) ([][2]uint64, error)
  • func (s *Store) Run(ctx context.Context, dur time.Duration)
  • func (s *Store) StoreBlock(bl structs.BlockWithMeta) error
  • func (s *Store) StoreTransaction(tx structs.TransactionWithMeta) error
  • func (s *Store) StoreTransactions(txs []structs.TransactionWithMeta) error
• type TransactionStore

Types

type BlockStore

type BlockStore interface {
	StoreBlock(structs.BlockWithMeta) error

	GetLatestBlock(ctx context.Context, blx structs.BlockWithMeta) (structs.Block, error)
	GetBlockForTime(ctx context.Context, blx structs.BlockWithMeta, time time.Time) (structs.Block, bool, error)

	BlockContinuityCheck(ctx context.Context, blx structs.BlockWithMeta, startHeight, endHeight uint64) ([][2]uint64, error)
	BlockTransactionCheck(ctx context.Context, blx structs.BlockWithMeta, startHeight, endHeight uint64) ([]uint64, error)

	GetBlocksHeightsWithNumTx(ctx context.Context, blx structs.BlockWithMeta, startHeight, endHeight uint64) ([][2]uint64, error)
}

type DBDriver

type DBDriver interface {
	TransactionStore
	BlockStore
	FlushBuffered
}

type DataStore

type DataStore interface {
	TransactionStore
	BlockStore
}

type FlushBuffered

type FlushBuffered interface {
	Flush() error
}

type Store

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

func New

func New(driver DBDriver) *Store

func (*Store) BlockContinuityCheck

func (s *Store) BlockContinuityCheck(ctx context.Context, blx structs.BlockWithMeta, startHeight, endHeight uint64) ([][2]uint64, error)

func (*Store) BlockTransactionCheck

func (s *Store) BlockTransactionCheck(ctx context.Context, blx structs.BlockWithMeta, startHeight, endHeight uint64) ([]uint64, error)

func (*Store) GetBlockForTime

func (s *Store) GetBlockForTime(ctx context.Context, blx structs.BlockWithMeta, time time.Time) (structs.Block, bool, error)

func (*Store) GetBlocksHeightsWithNumTx

func (s *Store) GetBlocksHeightsWithNumTx(ctx context.Context, blx structs.BlockWithMeta, startHeight, endHeight uint64) ([][2]uint64, error)

func (*Store) GetLatestBlock

func (s *Store) GetLatestBlock(ctx context.Context, blx structs.BlockWithMeta) (structs.Block, error)

func (*Store) GetLatestTransaction

func (s *Store) GetLatestTransaction(ctx context.Context, in structs.TransactionWithMeta) (out structs.Transaction, err error)

func (*Store) GetTransactions

func (s *Store) GetTransactions(ctx context.Context, tsearch params.TransactionSearch) ([]structs.Transaction, error)

func (*Store) GetTransactionsHeightsWithTxCount

func (s *Store) GetTransactionsHeightsWithTxCount(ctx context.Context, blx structs.BlockWithMeta, startHeight, endHeight uint64) ([][2]uint64, error)

func (*Store) Run

func (s *Store) Run(ctx context.Context, dur time.Duration)

func (*Store) StoreBlock

func (s *Store) StoreBlock(bl structs.BlockWithMeta) error

func (*Store) StoreTransaction

func (s *Store) StoreTransaction(tx structs.TransactionWithMeta) error

func (*Store) StoreTransactions

func (s *Store) StoreTransactions(txs []structs.TransactionWithMeta) error

type TransactionStore

type TransactionStore interface {
	StoreTransaction(structs.TransactionWithMeta) error
	StoreTransactions([]structs.TransactionWithMeta) error

	GetTransactions(ctx context.Context, tsearch params.TransactionSearch) ([]structs.Transaction, error)

	GetLatestTransaction(ctx context.Context, tx structs.TransactionWithMeta) (structs.Transaction, error)

	GetTransactionsHeightsWithTxCount(ctx context.Context, blx structs.BlockWithMeta, startHeight, endHeight uint64) ([][2]uint64, error)
}