remote

package

v1.10.1 Latest Latest Go to latest Published: Oct 23, 2025 License: Apache-2.0 Imports: 21 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Option func(*Store)

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

WithClient can set an rpc host client

This is mostly use for testing.

func WithForkHeight(height uint64) Option

WithStartBlockHeight sets the start height for the store. WithForkHeight sets the pinned fork height.

func WithForkHost(host string) Option

WithForkHost configures the remote access/observer node gRPC endpoint. Expects raw host:port with no scheme.

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

WithRPCHost sets access/observer node host. Deprecated: use WithForkHost.

func WithStartBlockHeight(height uint64) Option

WithStartBlockHeight is deprecated: use WithForkHeight.

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

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()