remote

Documentation

Index

• type Option
  • func WithClient(executionClient executiondata.ExecutionDataAPIClient, ...) Option
  • func WithRPCHost(host string, chainID flowgo.ChainID) Option
  • func WithStartBlockHeight(height uint64) Option
• type Store
  • func New(provider *sqlite.Store, logger *zerolog.Logger, options ...Option) (*Store, error)
  • func (s *Store) BlockByHeight(ctx context.Context, height uint64) (*flowgo.Block, error)
  • func (s *Store) BlockByID(ctx context.Context, blockID flowgo.Identifier) (*flowgo.Block, error)
  • func (s *Store) LatestBlock(ctx context.Context) (flowgo.Block, error)
  • func (s *Store) LedgerByHeight(ctx context.Context, blockHeight uint64) (snapshot.StorageSnapshot, error)
  • func (s *Store) Stop()

Types

type Option

type Option func(*Store)

func WithClient

func WithClient(
	executionClient executiondata.ExecutionDataAPIClient,
	accessClient access.AccessAPIClient,
) Option

WithClient can set an rpc host client

This is mostly use for testing.

func WithRPCHost

func WithRPCHost(host string, chainID flowgo.ChainID) Option

WithRPCHost sets access/observer node host.

func WithStartBlockHeight

func WithStartBlockHeight(height uint64) Option

WithStartBlockHeight sets the start height for the store.

type Store

type Store struct {
	*sqlite.Store
	// contains filtered or unexported fields
}

func New

func New(provider *sqlite.Store, logger *zerolog.Logger, options ...Option) (*Store, error)

func (*Store) BlockByHeight

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

func (*Store) BlockByID

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

func (*Store) LatestBlock

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

func (*Store) LedgerByHeight

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

func (*Store) Stop

func (s *Store) Stop()