memstore

Documentation

Index

• type Store
  • func New() *Store
  • func (s *Store) BlockByHeight(_ context.Context, height uint64) (*flowgo.Block, error)
  • func (s *Store) BlockByID(_ context.Context, blockID flowgo.Identifier) (*flowgo.Block, error)
  • func (s *Store) CollectionByID(_ context.Context, collectionID flowgo.Identifier) (flowgo.LightCollection, error)
  • func (s *Store) CommitBlock(_ context.Context, block flowgo.Block, collections []*flowgo.LightCollection, ...) error
  • func (s *Store) EventsByHeight(_ context.Context, blockHeight uint64, eventType string) ([]flowgo.Event, error)
  • func (s *Store) FullCollectionByID(_ context.Context, collectionID flowgo.Identifier) (flowgo.Collection, error)
  • func (s *Store) LatestBlock(_ context.Context) (flowgo.Block, error)
  • func (s *Store) LatestBlockHeight(ctx context.Context) (uint64, error)
  • func (s *Store) LedgerByHeight(_ context.Context, blockHeight uint64) (snapshot.StorageSnapshot, error)
  • func (s *Store) Start() error
  • func (s *Store) Stop()
  • func (s *Store) StoreBlock(_ context.Context, block *flowgo.Block) error
  • func (s *Store) TransactionByID(_ context.Context, transactionID flowgo.Identifier) (flowgo.TransactionBody, error)
  • func (s *Store) TransactionResultByID(_ context.Context, transactionID flowgo.Identifier) (types.StorableTransactionResult, error)

Types

type Store

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

Store implements the Store interface with an in-memory store.

func New

func New() *Store

New returns a new in-memory Store implementation.

func (*Store) BlockByHeight

func (s *Store) BlockByHeight(_ context.Context, height uint64) (*flowgo.Block, error)

func (*Store) BlockByID

func (s *Store) BlockByID(_ context.Context, blockID flowgo.Identifier) (*flowgo.Block, error)

func (*Store) CollectionByID

func (s *Store) CollectionByID(
	_ context.Context,
	collectionID flowgo.Identifier,
) (flowgo.LightCollection, error)

func (*Store) CommitBlock

func (s *Store) CommitBlock(
	_ context.Context,
	block flowgo.Block,
	collections []*flowgo.LightCollection,
	transactions map[flowgo.Identifier]*flowgo.TransactionBody,
	transactionResults map[flowgo.Identifier]*types.StorableTransactionResult,
	executionSnapshot *snapshot.ExecutionSnapshot,
	events []flowgo.Event,
) error

func (*Store) EventsByHeight

func (s *Store) EventsByHeight(
	_ context.Context,
	blockHeight uint64,
	eventType string,
) ([]flowgo.Event, error)

func (*Store) FullCollectionByID

func (s *Store) FullCollectionByID(
	_ context.Context,
	collectionID flowgo.Identifier,
) (flowgo.Collection, error)

func (*Store) LatestBlock

func (s *Store) LatestBlock(_ context.Context) (flowgo.Block, error)

func (*Store) LatestBlockHeight

func (s *Store) LatestBlockHeight(ctx context.Context) (uint64, error)

func (*Store) LedgerByHeight

func (s *Store) LedgerByHeight(
	_ context.Context,
	blockHeight uint64,
) (snapshot.StorageSnapshot, error)

func (*Store) Start

func (s *Store) Start() error

func (*Store) Stop

func (s *Store) Stop()

func (*Store) StoreBlock

func (s *Store) StoreBlock(_ context.Context, block *flowgo.Block) error

func (*Store) TransactionByID

func (s *Store) TransactionByID(
	_ context.Context,
	transactionID flowgo.Identifier,
) (flowgo.TransactionBody, error)

func (*Store) TransactionResultByID

func (s *Store) TransactionResultByID(
	_ context.Context,
	transactionID flowgo.Identifier,
) (types.StorableTransactionResult, error)