Documentation ¶
Index ¶
- type BlockStore
- type DBDriver
- type DataStore
- type FlushBuffered
- type 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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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 (*Store) BlockContinuityCheck ¶
func (*Store) BlockTransactionCheck ¶
func (*Store) GetBlockForTime ¶ added in v0.1.2
func (*Store) GetBlocksHeightsWithNumTx ¶ added in v0.0.2
func (*Store) GetLatestBlock ¶
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 ¶ added in v0.0.2
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) }
Click to show internal directories.
Click to hide internal directories.