remote

Documentation

Index

• type Option
  • func WithChainID(ID flowgo.ChainID) Option
  • func WithClient(client archive.APIClient) Option
  • func WithHost(host string) Option
• type Store
  • func New(provider *sqlite.Store, 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 WithChainID

func WithChainID(ID flowgo.ChainID) Option

WithChainID sets a chain ID and is used to determine which archive node to use.

func WithClient

func WithClient(client archive.APIClient) Option

WithClient can set an archive node client

This is mostly use for testing.

func WithHost

func WithHost(host string) Option

WithHost sets archive node host.

type Store

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

func New

func New(provider *sqlite.Store, 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()