sqlstorage

Oct 3, 2023

Changes in this version

type ModuleConfig

+ RedisLockStrategy bool

Feb 10, 2023

Changes in this version

+ func InstrumentalizeSQLDrivers()

+ type LogsPaginationToken struct

+ AfterID uint64

+ EndTime time.Time

+ PageSize uint

+ StartTime time.Time

type Store

+ func (s *Store) GetAccountWithVolumes(ctx context.Context, account string) (*core.AccountWithVolumes, error)

+ func (s *Store) GetLastLog(ctx context.Context) (*core.Log, error)

+ func (s *Store) GetLogs(ctx context.Context, q *ledger.LogsQuery) (api.Cursor[core.Log], error)

+ func (s *Store) GetMigrationsAvailable() ([]core.MigrationInfo, error)

+ func (s *Store) GetMigrationsDone(ctx context.Context) ([]core.MigrationInfo, error)

Oct 20, 2022

Changes in this version

+ func NewDefaultStorageDriverFromRawDriver(driver *Driver) storage.Driver[storage.LedgerStore]

+ func NewIdempotencyStorageDriverFromRawDriver(driver *Driver) storage.Driver[idempotency.Store]

+ func NewLedgerStorageDriverFromRawDriver(driver *Driver) storage.Driver[ledger.Store]

+ type DefaultStorageDriver struct

+ func (d *DefaultStorageDriver) GetLedgerStore(ctx context.Context, name string, create bool) (storage.LedgerStore, bool, error)

type Driver

+ func (d *Driver) GetLedgerStore(ctx context.Context, name string, create bool) (*Store, bool, error)

+ func (d *Driver) GetSystemStore() storage.SystemStore

+ type IdempotencyStorageDriver struct

+ func (d *IdempotencyStorageDriver) GetLedgerStore(ctx context.Context, name string, create bool) (idempotency.Store, bool, error)

+ type LedgerStorageDriver struct

+ func (d *LedgerStorageDriver) GetLedgerStore(ctx context.Context, name string, create bool) (ledger.Store, bool, error)

type Store

+ func (s *Store) Commit(ctx context.Context, txs ...core.ExpandedTransaction) error

+ func (s *Store) CreateIK(ctx context.Context, key string, response idempotency.Response) error

+ func (s *Store) Delete(ctx context.Context) error

+ func (s *Store) ReadIK(ctx context.Context, key string) (*idempotency.Response, error)

+ func (s *Store) UpdateAccountMetadata(ctx context.Context, address string, metadata core.Metadata, at time.Time) error

+ func (s *Store) UpdateTransactionMetadata(ctx context.Context, id uint64, metadata core.Metadata, at time.Time) error

+ type SystemStore struct

+ func (s *SystemStore) GetConfiguration(ctx context.Context, key string) (string, error)

+ func (s *SystemStore) Register(ctx context.Context, ledger string) (bool, error)

+ func (s SystemStore) DeleteLedger(ctx context.Context, name string) error

+ func (s SystemStore) InsertConfiguration(ctx context.Context, key, value string) error

+ func (s SystemStore) ListLedgers(ctx context.Context) ([]string, error)

Sep 2, 2022

Changes in this version

type Driver

+ func (d *Driver) GetConfiguration(ctx context.Context, key string) (string, error)

+ func (d *Driver) InsertConfiguration(ctx context.Context, key, value string) error

Jul 28, 2022

Changes in this version

+ var MigrationsFS embed.FS

+ func Migrate(ctx context.Context, schema Schema, migrations ...Migration) (bool, error)

+ func RegisterGoMigration(fn MigrationFunc)

+ func RegisterGoMigrationFromFilename(filename string, fn MigrationFunc)

+ type HandlersByEngine map[string][]MigrationFunc

+ type Migration struct

+ Handlers HandlersByEngine

+ Name string

+ Number string

+ func CollectMigrationFiles(migrationsFS fs.FS) ([]Migration, error)

+ type MigrationFunc func(ctx context.Context, schema Schema, tx *sql.Tx) error

+ func SQLMigrationFunc(content string) MigrationFunc

+ type Migrations []Migration

+ func (m Migrations) Len() int

+ func (m Migrations) Less(i, j int) bool

+ func (m Migrations) Swap(i, j int)

Jul 12, 2022

Changes in this version

type AccPaginationToken

+ BalanceFilter string

+ BalanceOperatorFilter storage.BalanceOperator

+ PageSize uint

+ type BalancesPaginationToken struct

+ AddressRegexpFilter string

+ AfterAddress string

+ Offset uint

+ PageSize uint

type Store

+ func (s *Store) GetAssetsVolumes(ctx context.Context, accountAddress string) (core.AssetsVolumes, error)

+ func (s *Store) GetBalances(ctx context.Context, q storage.BalancesQuery) (sharedapi.Cursor[core.AccountsBalances], error)

+ func (s *Store) GetBalancesAggregated(ctx context.Context, q storage.BalancesQuery) (core.AssetsBalances, error)

+ func (s *Store) GetVolumes(ctx context.Context, accountAddress, asset string) (core.Volumes, error)

type TxsPaginationToken

+ MetadataFilter map[string]string

+ PageSize uint

Jun 10, 2022

Changes in this version

+ const SQLCustomFuncMetaCompare

+ const SystemSchema

+ var MigrationsFs fs.FS

+ func NewPostgresDB(db *sql.DB) *postgresDB

+ func NewSQLiteDB(directory, dbName string) *sqliteDB

+ func OpenSQLDB(flavor Flavor, dataSourceName string) (*sql.DB, error)

+ type AccPaginationToken struct

+ AddressRegexpFilter string

+ AfterAddress string

+ Limit uint

+ MetadataFilter map[string]string

+ Offset uint

+ type DB interface

+ Close func(ctx context.Context) error

+ Initialize func(ctx context.Context) error

+ Schema func(ctx context.Context, name string) (Schema, error)

+ type Driver struct

+ func NewDriver(name string, db DB) *Driver

+ func (d *Driver) Close(ctx context.Context) error

+ func (d *Driver) DeleteStore(ctx context.Context, name string) error

+ func (d *Driver) GetStore(ctx context.Context, name string, create bool) (storage.Store, bool, error)

+ func (d *Driver) Initialize(ctx context.Context) (err error)

+ func (d *Driver) List(ctx context.Context) ([]string, error)

+ func (d *Driver) Name() string

+ func (d *Driver) Register(ctx context.Context, ledger string) (bool, error)

+ type PGSchema struct

+ func (s *PGSchema) Close(ctx context.Context) error

+ func (s *PGSchema) Delete(ctx context.Context) error

+ func (s *PGSchema) ExecContext(ctx context.Context, query string, args ...interface{}) (sql.Result, error)

+ func (s *PGSchema) Flavor() sqlbuilder.Flavor

+ func (s *PGSchema) Initialize(ctx context.Context) error

+ func (s *PGSchema) Name() string

+ func (s *PGSchema) QueryContext(ctx context.Context, query string, args ...interface{}) (*sql.Rows, error)

+ func (s *PGSchema) QueryRowContext(ctx context.Context, query string, args ...interface{}) *sql.Row

+ func (s *PGSchema) Table(name string) string

+ type SQLiteSchema struct

+ func (s *SQLiteSchema) Close(ctx context.Context) error

+ func (s *SQLiteSchema) ExecContext(ctx context.Context, query string, args ...interface{}) (sql.Result, error)

+ func (s *SQLiteSchema) Initialize(ctx context.Context) error

+ func (s *SQLiteSchema) Name() string

+ func (s *SQLiteSchema) QueryContext(ctx context.Context, query string, args ...interface{}) (*sql.Rows, error)

+ func (s *SQLiteSchema) QueryRowContext(ctx context.Context, query string, args ...interface{}) *sql.Row

+ func (s *SQLiteSchema) Table(name string) string

+ func (s SQLiteSchema) Delete(ctx context.Context) error

+ func (s SQLiteSchema) Flavor() sqlbuilder.Flavor

+ type Schema interface

+ BeginTx func(ctx context.Context, s *sql.TxOptions) (*sql.Tx, error)

+ Close func(ctx context.Context) error

+ Delete func(ctx context.Context) error

+ Flavor func() sqlbuilder.Flavor

+ Initialize func(ctx context.Context) error

+ Name func() string

+ Table func(name string) string

type Store

+ func (s *Store) AppendLog(ctx context.Context, logs ...core.Log) error

+ func (s *Store) GetAccount(ctx context.Context, addr string) (core.Account, error)

+ func (s *Store) GetAccounts(ctx context.Context, q query.Accounts) (sharedapi.Cursor[core.Account], error)

+ func (s *Store) GetLastTransaction(ctx context.Context) (*core.Transaction, error)

+ func (s *Store) GetTransactions(ctx context.Context, q query.Transactions) (sharedapi.Cursor[core.Transaction], error)

+ func (s *Store) LastLog(ctx context.Context) (*core.Log, error)

+ func (s *Store) Logs(ctx context.Context) ([]core.Log, error)

+ func (s *Store) Schema() Schema

+ type TxsPaginationToken struct

+ AccountFilter string

+ AfterTxID uint64

+ DestinationFilter string

+ EndTime time.Time

+ ReferenceFilter string

+ SourceFilter string

+ StartTime time.Time

Feb 13, 2022

Changes in this version

type Store

+ func (s *Store) DB() *sql.DB

Feb 1, 2022

Changes in this version

+ const SQLiteMemoryConnString

+ var PostgreSQL = Flavor(sqlbuilder.PostgreSQL)

+ var SQLite = Flavor(sqlbuilder.SQLite)

+ func DriverModule(cfg ModuleConfig) fx.Option

+ func NewCachedDBDriver(logger logging.Logger, name string, flavor Flavor, where string) *cachedDBDriver

+ func NewInMemorySQLiteDriver(logger logging.Logger) *cachedDBDriver

+ func NewOpenCloseDBDriver(logger logging.Logger, name string, flavor Flavor, ...) *openCloseDBDriver

+ func SQLDriverName(f Flavor) string

+ func SQLiteFileConnString(path string) string

+ func TestingModule() fx.Option

+ func UpdateSQLDriverMapping(flavor Flavor, name string)

+ type ConnStringResolver func(name string) string

+ type Flavor sqlbuilder.Flavor

+ func FlavorFromString(v string) Flavor

+ func (f Flavor) AttributeKeyValue() attribute.KeyValue

+ func (f Flavor) String() string

+ type ModuleConfig struct

+ PostgresConfig *PostgresConfig

+ SQLiteConfig *SQLiteConfig

+ StorageDriver string

+ type PostgresConfig struct

+ ConnString string

+ type SQLiteConfig struct

+ DBName string

+ Dir string

+ type Store struct

+ func NewStore(name string, flavor sqlbuilder.Flavor, db *sql.DB, logger logging.Logger, ...) (*Store, error)

+ func (s *Store) AggregateBalances(ctx context.Context, address string) (map[string]int64, error)

+ func (s *Store) AggregateVolumes(ctx context.Context, address string) (map[string]map[string]int64, error)

+ func (s *Store) Close(ctx context.Context) error

+ func (s *Store) CountAccounts(ctx context.Context) (int64, error)

+ func (s *Store) CountMeta(ctx context.Context) (int64, error)

+ func (s *Store) CountTransactions(ctx context.Context) (int64, error)

+ func (s *Store) FindAccounts(ctx context.Context, q query.Query) (query.Cursor, error)

+ func (s *Store) FindTransactions(ctx context.Context, q query.Query) (query.Cursor, error)

+ func (s *Store) GetMeta(ctx context.Context, ty string, id string) (core.Metadata, error)

+ func (s *Store) GetTransaction(ctx context.Context, txid string) (tx core.Transaction, err error)

+ func (s *Store) Initialize(ctx context.Context) error

+ func (s *Store) LastMetaID(ctx context.Context) (int64, error)

+ func (s *Store) LastTransaction(ctx context.Context) (*core.Transaction, error)

+ func (s *Store) LoadMapping(ctx context.Context) (*core.Mapping, error)

+ func (s *Store) Name() string

+ func (s *Store) SaveMapping(ctx context.Context, mapping core.Mapping) error

+ func (s *Store) SaveMeta(ctx context.Context, id int64, ...) error

+ func (s *Store) SaveTransactions(ctx context.Context, ts []core.Transaction) (map[int]error, error)