store

Documentation

Index

• type PostgresStore
  • func (s *PostgresStore) CommitBlock(block uint64) error
  • func (s *PostgresStore) GetMissingBlocks(lowerBound uint64, upperBound uint64) (pgx.Rows, error)
  • func (s *PostgresStore) GetSearchBounds(batchSize uint64, headCursor uint64, headBlockLag uint64) (uint64, uint64, error)
  • func (s *PostgresStore) SetSearchLowerBound(newLowerBound uint64) error
• type PostgresStoreOpts
• type Store
  • func NewPostgresStore(o PostgresStoreOpts) (Store[pgx.Rows], error)

Types

type PostgresStore

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

func (*PostgresStore) CommitBlock

func (s *PostgresStore) CommitBlock(block uint64) error

func (*PostgresStore) GetMissingBlocks

func (s *PostgresStore) GetMissingBlocks(lowerBound uint64, upperBound uint64) (pgx.Rows, error)

func (*PostgresStore) GetSearchBounds

func (s *PostgresStore) GetSearchBounds(batchSize uint64, headCursor uint64, headBlockLag uint64) (uint64, uint64, error)

func (*PostgresStore) SetSearchLowerBound

func (s *PostgresStore) SetSearchLowerBound(newLowerBound uint64) error

type PostgresStoreOpts

type PostgresStoreOpts struct {
	DSN               string
	InitialLowerBound uint64
	Logg              logf.Logger
	Queries           goyesql.Queries
}

type Store

type Store[T any] interface {
	GetSearchBounds(batchSize uint64, headCursor uint64, headBlockLag uint64) (lowerBound uint64, upperBound uint64, err error)
	GetMissingBlocks(lowerBound uint64, upperBound uint64) (missingBlocksIterable T, err error)
	SetSearchLowerBound(newLowerBound uint64) (err error)
	CommitBlock(block uint64) (err error)
}

Store defines indexer get and set queries. GetMissingBlocks returns a generic iterable.

func NewPostgresStore

func NewPostgresStore(o PostgresStoreOpts) (Store[pgx.Rows], error)