db

Jun 3, 2023

Changes in this version

+ var APICounterOpts = metrics.CounterOpts

+ var APIDurationOpts = metrics.HistogramOpts

+ func CurrentDBLevels(db FabricCADB) (*util.Levels, error)

+ func Migrate(migrator Migrator, currentLevels, srvLevels *util.Levels) error

+ type AffiliationRecord struct

+ ID int

+ Level int

+ Name string

+ Prekey string

+ type CertRecord struct

+ ID string

+ Level int

+ type DB struct

+ CAName string

+ DB SqlxDB

+ IsDBInitialized bool

+ Metrics *Metrics

+ func New(db SqlxDB, caName string, metrics *Metrics) *DB

+ func (db *DB) BeginTx() FabricCATx

+ func (db *DB) Close() error

+ func (db *DB) DriverName() string

+ func (db *DB) Exec(funcName, query string, args ...interface{}) (sql.Result, error)

+ func (db *DB) Get(funcName string, dest interface{}, query string, args ...interface{}) error

+ func (db *DB) IsInitialized() bool

+ func (db *DB) MustBegin() *sqlx.Tx

+ func (db *DB) NamedExec(funcName, query string, args interface{}) (sql.Result, error)

+ func (db *DB) PingContext(ctx context.Context) error

+ func (db *DB) Queryx(funcName, query string, args ...interface{}) (*sqlx.Rows, error)

+ func (db *DB) Rebind(query string) string

+ func (db *DB) Select(funcName string, dest interface{}, query string, args ...interface{}) error

+ func (db *DB) SetDBInitialized(b bool)

+ func (db *DB) SetMaxOpenConns(n int)

+ type FabricCADB interface

+ BeginTx func() FabricCATx

+ Close func() error

+ DriverName func() string

+ Exec func(funcName, query string, args ...interface{}) (sql.Result, error)

+ Get func(funcName string, dest interface{}, query string, args ...interface{}) error

+ IsInitialized func() bool

+ MustBegin func() *sqlx.Tx

+ NamedExec func(funcName, query string, arg interface{}) (sql.Result, error)

+ PingContext func(ctx context.Context) error

+ Queryx func(funcName, query string, args ...interface{}) (*sqlx.Rows, error)

+ Rebind func(query string) string

+ Select func(funcName string, dest interface{}, query string, args ...interface{}) error

+ SetDBInitialized func(bool)

+ SetMaxOpenConns func(n int)

+ type FabricCATx interface

+ Commit func(funcName string) error

+ Exec func(funcName, query string, args ...interface{}) (sql.Result, error)

+ Get func(funcName string, dest interface{}, query string, args ...interface{}) error

+ Queryx func(funcName, query string, args ...interface{}) (*sqlx.Rows, error)

+ Rebind func(query string) string

+ Rollback func(funcName string) error

+ Select func(funcName string, dest interface{}, query string, args ...interface{}) error

+ type Metrics struct

+ APICounter metrics.Counter

+ APIDuration metrics.Histogram

+ type Migrator interface

+ Commit func() error

+ MigrateAffiliationsTable func() error

+ MigrateCertificatesTable func() error

+ MigrateCredentialsTable func() error

+ MigrateNoncesTable func() error

+ MigrateRAInfoTable func() error

+ MigrateUsersTable func() error

+ Rollback func() error

+ type SqlxDB interface

+ Close func() error

+ DriverName func() string

+ Exec func(query string, args ...interface{}) (sql.Result, error)

+ Get func(dest interface{}, query string, args ...interface{}) error

+ MustBegin func() *sqlx.Tx

+ NamedExec func(query string, arg interface{}) (sql.Result, error)

+ PingContext func(ctx context.Context) error

+ Queryx func(query string, args ...interface{}) (*sqlx.Rows, error)

+ Rebind func(query string) string

+ Select func(dest interface{}, query string, args ...interface{}) error

+ SetMaxOpenConns func(n int)

+ type SqlxTx interface

+ Commit func() error

+ Exec func(query string, args ...interface{}) (sql.Result, error)

+ Get func(dest interface{}, query string, args ...interface{}) error

+ Queryx func(query string, args ...interface{}) (*sqlx.Rows, error)

+ Rebind func(query string) string

+ Rollback func() error

+ Select func(dest interface{}, query string, args ...interface{}) error

+ type TX struct

+ Record record

+ TX SqlxTx

+ func (tx *TX) Commit(funcName string) error

+ func (tx *TX) Exec(funcName, query string, args ...interface{}) (sql.Result, error)

+ func (tx *TX) Get(funcName string, dest interface{}, query string, args ...interface{}) error

+ func (tx *TX) Queryx(funcName, query string, args ...interface{}) (*sqlx.Rows, error)

+ func (tx *TX) Rebind(query string) string

+ func (tx *TX) Rollback(funcName string) error

+ func (tx *TX) Select(funcName string, dest interface{}, query string, args ...interface{}) error