store

Documentation

Index

• Constants
• Variables
• func DropAllTablesAndViews(log *logging.Logger, config Config) error
• func MigrateToLatestSchema(log *logging.Logger, config Config) error
• type Config
  • func NewDefaultConfig() Config
• type Store
  • 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, ...) ([]*pb.Transaction, error)

Constants

const SQLMigrationsDir = "migrations"

Variables

var (
	ErrTxNotFound      = errors.New("transaction not found")
	ErrMultipleTxFound = errors.New("multiple transactions found")
)

var EmbedMigrations embed.FS

Functions

func DropAllTablesAndViews

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

func MigrateToLatestSchema

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

Types

type Config

type Config struct {
	Postgres config.PostgresConnection `group:"database" namespace:"postgres"`
}

func NewDefaultConfig

func NewDefaultConfig() Config

type Store

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

func MustNewStore

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

func NewStore

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

func (*Store) Close

func (s *Store) Close()

func (*Store) GetTransaction

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

func (*Store) ListTransactions

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)