postgresql

Documentation

Index

• type PostgresOutputHandler
  • func NewPostgresOutputHandler(connString string) (*PostgresOutputHandler, error)
  • func (h *PostgresOutputHandler) Close() error
  • func (h *PostgresOutputHandler) GetLatestBlock(ctx context.Context) (*models.Block, error)
  • func (h *PostgresOutputHandler) GetMissingBlockIds(ctx context.Context) ([]uint64, error)
  • func (h *PostgresOutputHandler) WriteBlockWithTransactions(ctx context.Context, block *models.Block, transactions []*models.Transaction) error

Types

type PostgresOutputHandler

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

func NewPostgresOutputHandler

func NewPostgresOutputHandler(connString string) (*PostgresOutputHandler, error)

func (*PostgresOutputHandler) Close

func (h *PostgresOutputHandler) Close() error

func (*PostgresOutputHandler) GetLatestBlock

func (h *PostgresOutputHandler) GetLatestBlock(ctx context.Context) (*models.Block, error)

func (*PostgresOutputHandler) GetMissingBlockIds

func (h *PostgresOutputHandler) GetMissingBlockIds(ctx context.Context) ([]uint64, error)

func (*PostgresOutputHandler) WriteBlockWithTransactions

func (h *PostgresOutputHandler) WriteBlockWithTransactions(ctx context.Context, block *models.Block, transactions []*models.Transaction) error