store

type Config ¶

type Config struct {
	Postgres             config.PostgresConnection `group:"database" namespace:"postgres"`
	MigrateData          bool                      `` /* 144-byte string literal not displayed */
	MigrateBlockDuration time.Duration             `` /* 144-byte string literal not displayed */
	MigratePauseInterval time.Duration             `` /* 144-byte string literal not displayed */
}

func NewDefaultConfig() Config

type Migrator ¶ added in v0.74.0

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

Migrator is a data migration agent that will migrate tx_results data that is required for providing data for the block explorer APIs. The tx_results table is populated by Tendermint and the number of records can be very large. This causes data migration difficult when there is a need to add additional information to tx_results in order to fulfill requirements for the block explorer APIs. The migration agent will allow migrations to run in the background without blocking upgrades with slow database migration scripts.

func NewMigrator(pool *pgxpool.Pool, config Config) *Migrator

func (m *Migrator) Migrate(ctx context.Context) error

type Store ¶

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

func MustNewStore(config Config, log *logging.Logger) *Store

func NewStore(config Config, log *logging.Logger) (*Store, error)

func (s *Store) Close()

func (s *Store) GetTransaction(ctx context.Context, txID string) (*pb.Transaction, error)

func (s *Store) ListTransactions(ctx context.Context,
	filters map[string]string,
	cmdTypes, exclCmdTypes, parties []string,
	first uint32,
	after *entities.TxCursor,
	last uint32,
	before *entities.TxCursor,
) ([]*pb.Transaction, error)

func (s *Store) Migrate(ctx context.Context) error