storagenodedb

Documentation

Index

• Variables
• type Config
• type DB
  • func New(log *zap.Logger, config Config) (*DB, error)
  • func NewInMemory(log *zap.Logger, storageDir string) (*DB, error)
  • func (db *DB) Bandwidth() bandwidth.DB
  • func (db *DB) CertDB() trust.CertDB
  • func (db *DB) Close() error
  • func (db *DB) CreateTables() error
  • func (db *DB) Orders() orders.DB
  • func (db *DB) PieceInfo() pieces.DB
  • func (db *DB) Pieces() storage.Blobs
  • func (db *DB) RoutingTable() (kdb, ndb storage.KeyValueStore)
  • func (db *DB) UsedSerials() piecestore.UsedSerials
  • func (db *DB) Vouchers() vouchers.DB
• type InfoDB
  • func NewInfoInMemory() (*InfoDB, error)
  • func (db *InfoDB) Bandwidth() bandwidth.DB
  • func (db *InfoDB) Begin() (*sql.Tx, error)
  • func (db *InfoDB) CertDB() trust.CertDB
  • func (db *InfoDB) Close() error
  • func (db *InfoDB) CreateTables(log *zap.Logger) error
  • func (db *InfoDB) Migration() *migrate.Migration
  • func (db *InfoDB) Orders() orders.DB
  • func (db *InfoDB) PieceInfo() pieces.DB
  • func (db *InfoDB) RawDB() *sql.DB
  • func (db *InfoDB) Rebind(s string) string
  • func (db *InfoDB) Schema() string
  • func (db *InfoDB) UsedSerials() piecestore.UsedSerials
  • func (db *InfoDB) Vouchers() vouchers.DB

Variables

var ErrInfo = errs.Class("infodb")

ErrInfo is the default error class for InfoDB

Types

type Config

type Config struct {
	// TODO: figure out better names
	Storage  string
	Info     string
	Info2    string
	Kademlia 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 NewInMemory

func NewInMemory(log *zap.Logger, storageDir string) (*DB, error)

NewInMemory creates new inmemory master database for storage node TODO: still stores data on disk

func (*DB) Bandwidth

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

Bandwidth returns table for storing bandwidth usage.

func (*DB) CertDB

func (db *DB) CertDB() trust.CertDB

CertDB returns certificate database.

func (*DB) Close

func (db *DB) Close() error

Close closes any resources.

func (*DB) CreateTables

func (db *DB) CreateTables() error

CreateTables creates any necessary tables.

func (*DB) Orders

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

Orders returns database for storing orders

func (*DB) PieceInfo

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

PieceInfo returns database for storing piece information

func (*DB) Pieces

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

Pieces returns blob storage for pieces

func (*DB) RoutingTable

func (db *DB) RoutingTable() (kdb, ndb storage.KeyValueStore)

RoutingTable returns kademlia routing table

func (*DB) UsedSerials

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

UsedSerials returns certificate database.

func (*DB) Vouchers

func (db *DB) Vouchers() vouchers.DB

Vouchers returns database for storing vouchers

type InfoDB

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

InfoDB implements information database for piecestore.

func NewInfoInMemory

func NewInfoInMemory() (*InfoDB, error)

NewInfoInMemory creates a new inmemory InfoDB.

func (*InfoDB) Bandwidth

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

Bandwidth returns table for storing bandwidth usage.

func (*InfoDB) Begin

func (db *InfoDB) Begin() (*sql.Tx, error)

Begin begins transaction

func (*InfoDB) CertDB

func (db *InfoDB) CertDB() trust.CertDB

CertDB returns certificate database.

func (*InfoDB) Close

func (db *InfoDB) Close() error

Close closes any resources.

func (*InfoDB) CreateTables

func (db *InfoDB) CreateTables(log *zap.Logger) error

CreateTables creates any necessary tables.

func (*InfoDB) Migration

func (db *InfoDB) Migration() *migrate.Migration

Migration returns table migrations.

func (*InfoDB) Orders

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

Orders returns database for storing orders

func (*InfoDB) PieceInfo

func (db *InfoDB) PieceInfo() pieces.DB

PieceInfo returns database for storing piece information

func (*InfoDB) RawDB

func (db *InfoDB) RawDB() *sql.DB

RawDB returns access to the raw database, only for migration tests.

func (*InfoDB) Rebind

func (db *InfoDB) Rebind(s string) string

Rebind rebind parameters

func (*InfoDB) Schema

func (db *InfoDB) Schema() string

Schema returns schema

func (*InfoDB) UsedSerials

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

UsedSerials returns certificate database.

func (*InfoDB) Vouchers

func (db *InfoDB) Vouchers() vouchers.DB

Vouchers returns database for storing vouchers