storagenodedb

Documentation

Index

• Constants
• Variables
• type Config
• type DB
  • func New(log *zap.Logger, config Config) (*DB, error)
  • func (db *DB) Bandwidth() bandwidth.DB
  • func (db *DB) Close() error
  • func (db *DB) CreateTables(ctx context.Context) error
  • func (db *DB) Migration(ctx context.Context) *migrate.Migration
  • func (db *DB) Orders() orders.DB
  • func (db *DB) PieceExpirationDB() pieces.PieceExpirationDB
  • func (db *DB) PieceSpaceUsedDB() pieces.PieceSpaceUsedDB
  • func (db *DB) Pieces() storage.Blobs
  • func (db *DB) RawDatabases() map[string]SQLDB
  • func (db *DB) Reputation() reputation.DB
  • func (db *DB) Satellites() satellites.DB
  • func (db *DB) StorageUsage() storageusage.DB
  • func (db *DB) UsedSerials() piecestore.UsedSerials
  • func (db *DB) V0PieceInfo() pieces.V0PieceInfoDB
• type SQLDB

Constants

const BandwidthDBName = "bandwidth"

BandwidthDBName represents the database name.

const DeprecatedInfoDBName = "info"

DeprecatedInfoDBName represents the database name.

const OrdersDBName = "orders"

OrdersDBName represents the database name.

const PieceExpirationDBName = "piece_expiration"

PieceExpirationDBName represents the database filename.

const PieceInfoDBName = "pieceinfo"

PieceInfoDBName represents the database name.

const PieceSpaceUsedDBName = "piece_spaced_used"

PieceSpaceUsedDBName represents the database name.

const ReputationDBName = "reputation"

ReputationDBName represents the database name.

const SatellitesDBName = "satellites"

SatellitesDBName represents the database name.

const StorageUsageDBName = "storage_usage"

StorageUsageDBName represents the database name.

const UsedSerialsDBName = "used_serial"

UsedSerialsDBName represents the database name.

const VersionTable = "versions"

VersionTable is the table that stores the version info in each db

Variables

var ErrBandwidth = errs.Class("bandwidthdb error")

ErrBandwidth represents errors from the bandwidthdb database.

var (

	// ErrDatabase represents errors from the databases.
	ErrDatabase = errs.Class("storage node database error")
)

var ErrOrders = errs.Class("ordersdb error")

ErrOrders represents errors from the ordersdb database.

var ErrPieceExpiration = errs.Class("piece expiration error")

ErrPieceExpiration represents errors from the piece expiration database.

var ErrPieceInfo = errs.Class("v0pieceinfodb error")

ErrPieceInfo represents errors from the piece info database.

var ErrPieceSpaceUsed = errs.Class("piece space used error")

ErrPieceSpaceUsed represents errors from the piece spaced used database.

var ErrReputation = errs.Class("reputation error")

ErrReputation represents errors from the reputation database.

var ErrSatellitesDB = errs.Class("satellitesdb error")

ErrSatellitesDB represents errors from the satellites database.

var ErrUsedSerials = errs.Class("usedserialsdb error")

ErrUsedSerials represents errors from the used serials database.

Types

type Config

type Config struct {
	// TODO: figure out better names
	Storage string
	Info    string
	Info2   string

	Pieces string
}

Config configures storage node database

type DB

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

DB contains access to different database tables

func New

func New(log *zap.Logger, config Config) (*DB, error)

New creates a new master database for storage node

func (*DB) Bandwidth

func (db *DB) Bandwidth() bandwidth.DB

Bandwidth returns the instance of the Bandwidth database.

func (*DB) Close

func (db *DB) Close() error

Close closes any resources.

func (*DB) CreateTables

func (db *DB) CreateTables(ctx context.Context) error

CreateTables creates any necessary tables.

func (*DB) Migration

func (db *DB) Migration(ctx context.Context) *migrate.Migration

Migration returns table migrations.

func (*DB) Orders

func (db *DB) Orders() orders.DB

Orders returns the instance of the Orders database.

func (*DB) PieceExpirationDB

func (db *DB) PieceExpirationDB() pieces.PieceExpirationDB

PieceExpirationDB returns the instance of the PieceExpiration database.

func (*DB) PieceSpaceUsedDB

func (db *DB) PieceSpaceUsedDB() pieces.PieceSpaceUsedDB

PieceSpaceUsedDB returns the instance of the PieceSpacedUsed database.

func (*DB) Pieces

func (db *DB) Pieces() storage.Blobs

Pieces returns blob storage for pieces

func (*DB) RawDatabases

func (db *DB) RawDatabases() map[string]SQLDB

RawDatabases are required for testing purposes

func (*DB) Reputation

func (db *DB) Reputation() reputation.DB

Reputation returns the instance of the Reputation database.

func (*DB) Satellites

func (db *DB) Satellites() satellites.DB

Satellites returns the instance of the Satellites database.

func (*DB) StorageUsage

func (db *DB) StorageUsage() storageusage.DB

StorageUsage returns the instance of the StorageUsage database.

func (*DB) UsedSerials

func (db *DB) UsedSerials() piecestore.UsedSerials

UsedSerials returns the instance of the UsedSerials database.

func (*DB) V0PieceInfo

func (db *DB) V0PieceInfo() pieces.V0PieceInfoDB

V0PieceInfo returns the instance of the V0PieceInfoDB database.

type SQLDB

type SQLDB interface {
	Configure(sqlDB *sql.DB)
	GetDB() *sql.DB
}

SQLDB defines an interface to allow accessing and setting an sql.DB