multinodedb

Documentation

Index

• Variables
• type DB
  • func Open(ctx context.Context, log *zap.Logger, databaseURL string) (*DB, error)
  • func (db DB) MigrateToLatest(ctx context.Context) error
  • func (db *DB) Nodes() nodes.DB
  • func (db *DB) PostgresMigration() *migrate.Migration
  • func (db *DB) SQLite3Migration() *migrate.Migration

Variables

var ErrNodesDB = errs.Class("NodesDB")

ErrNodesDB indicates about internal NodesDB error.

var (

	// Error is the default multinodedb errs class.
	Error = errs.Class("multinodedb")
)

Types

type DB

type DB struct {
	*dbx.DB
	// contains filtered or unexported fields
}

DB combines access to different database tables with a record of the db driver, db implementation, and db source URL. Implementation of multinode.DB interface.

architecture: Master Database

func Open

func Open(ctx context.Context, log *zap.Logger, databaseURL string) (*DB, error)

Open creates instance of database supports postgres.

func (DB) MigrateToLatest

func (db DB) MigrateToLatest(ctx context.Context) error

MigrateToLatest migrates db to the latest version.

func (*DB) Nodes

func (db *DB) Nodes() nodes.DB

Nodes returns nodes database.

func (*DB) PostgresMigration

func (db *DB) PostgresMigration() *migrate.Migration

PostgresMigration returns steps needed for migrating postgres database.

func (*DB) SQLite3Migration

func (db *DB) SQLite3Migration() *migrate.Migration

SQLite3Migration returns steps needed for migrating sqlite3 database.