datastore

Documentation

Index

• Variables
• type BlobStore
  • func NewBlobStore(db sql.Executor, proposals *store.Store) *BlobStore
  • func (bs *BlobStore) GetBlobSizes(hint Hint, ids [][]byte) (sizes []int, err error)
  • func (bs *BlobStore) Has(hint Hint, key []byte) (bool, error)
  • func (bs *BlobStore) LoadBlob(ctx context.Context, hint Hint, key []byte, blob *sql.Blob) error
• type CachedDB
  • func NewCachedDB(db Executor, lg log.Log, opts ...Opt) *CachedDB
  • func (db *CachedDB) CacheMalfeasanceProof(id types.NodeID, proof *wire.MalfeasanceProof)
  • func (db *CachedDB) GetAtxHeader(id types.ATXID) (*types.ActivationTxHeader, error)
  • func (db *CachedDB) GetFullAtx(id types.ATXID) (*types.VerifiedActivationTx, error)
  • func (db *CachedDB) GetMalfeasanceProof(id types.NodeID) (*wire.MalfeasanceProof, error)
  • func (db *CachedDB) IsMalicious(id types.NodeID) (bool, error)
  • func (db *CachedDB) IterateEpochATXHeaders(epoch types.EpochID, iter func(*types.ActivationTxHeader) error) error
  • func (db *CachedDB) IterateMalfeasanceProofs(iter func(types.NodeID, *wire.MalfeasanceProof) error) error
  • func (db *CachedDB) MalfeasanceCacheSize() int
  • func (db *CachedDB) MaxHeightAtx() (types.ATXID, error)
  • func (db *CachedDB) VRFNonce(id types.NodeID, epoch types.EpochID) (types.VRFPostIndex, error)
• type Config
  • func DefaultConfig() Config
• type Executor
• type Hint
• type Opt
  • func WithConfig(cfg Config) Opt
• type VrfNonceKey

Variables

var ErrNotFound = errors.New("not found")

Types

type BlobStore

type BlobStore struct {
	DB sql.Executor
	// contains filtered or unexported fields
}

BlobStore gets data as a blob to serve direct fetch requests.

func NewBlobStore

func NewBlobStore(db sql.Executor, proposals *store.Store) *BlobStore

NewBlobStore returns a BlobStore.

func (*BlobStore) GetBlobSizes

func (bs *BlobStore) GetBlobSizes(hint Hint, ids [][]byte) (sizes []int, err error)

GetBlobSizes returns the sizes of the blobs corresponding to the specified ids. For non-existent objects, the corresponding items are set to -1.

func (*BlobStore) Has

func (bs *BlobStore) Has(hint Hint, key []byte) (bool, error)

func (*BlobStore) LoadBlob

func (bs *BlobStore) LoadBlob(ctx context.Context, hint Hint, key []byte, blob *sql.Blob) error

LoadBlob gets an blob as bytes by an object ID as bytes.

type CachedDB

type CachedDB struct {
	Executor
	sql.QueryCache
	// contains filtered or unexported fields
}

CachedDB is simply a database injected with cache.

func NewCachedDB

func NewCachedDB(db Executor, lg log.Log, opts ...Opt) *CachedDB

NewCachedDB create an instance of a CachedDB.

func (*CachedDB) CacheMalfeasanceProof

func (db *CachedDB) CacheMalfeasanceProof(id types.NodeID, proof *wire.MalfeasanceProof)

func (*CachedDB) GetAtxHeader

func (db *CachedDB) GetAtxHeader(id types.ATXID) (*types.ActivationTxHeader, error)

GetAtxHeader returns the ATX header by the given ID. This function is thread safe and will return an error if the ID is not found in the ATX DB.

func (*CachedDB) GetFullAtx

func (db *CachedDB) GetFullAtx(id types.ATXID) (*types.VerifiedActivationTx, error)

GetFullAtx returns the full atx struct of the given atxId id, it returns an error if the full atx cannot be found in all databases.

func (*CachedDB) GetMalfeasanceProof

func (db *CachedDB) GetMalfeasanceProof(id types.NodeID) (*wire.MalfeasanceProof, error)

GetMalfeasanceProof gets the malfeasance proof associated with the NodeID.

func (*CachedDB) IsMalicious

func (db *CachedDB) IsMalicious(id types.NodeID) (bool, error)

IsMalicious returns true if the NodeID is malicious.

func (*CachedDB) IterateEpochATXHeaders

func (db *CachedDB) IterateEpochATXHeaders(
	epoch types.EpochID,
	iter func(*types.ActivationTxHeader) error,
) error

IterateEpochATXHeaders iterates over ActivationTxs that target an epoch.

func (*CachedDB) IterateMalfeasanceProofs

func (db *CachedDB) IterateMalfeasanceProofs(
	iter func(types.NodeID, *wire.MalfeasanceProof) error,
) error

func (*CachedDB) MalfeasanceCacheSize

func (db *CachedDB) MalfeasanceCacheSize() int

func (*CachedDB) MaxHeightAtx

func (db *CachedDB) MaxHeightAtx() (types.ATXID, error)

func (*CachedDB) VRFNonce

func (db *CachedDB) VRFNonce(id types.NodeID, epoch types.EpochID) (types.VRFPostIndex, error)

VRFNonce returns the VRF nonce of for the given node in the given epoch. This function is thread safe and will return an error if the nonce is not found in the ATX DB.

type Config

type Config struct {
	// ATXSize must be larger than the sum of all ATXs in last 2 epochs to be effective
	ATXSize         int `mapstructure:"atx-size"`
	MalfeasanceSize int `mapstructure:"malfeasance-size"`
}

func DefaultConfig

func DefaultConfig() Config

type Executor

type Executor interface {
	sql.Executor
	WithTx(context.Context, func(*sql.Tx) error) error
	QueryCache() sql.QueryCache
}

type Hint

type Hint string

Hint marks which DB should be queried for a certain provided hash.

const (
	NoHint      Hint = ""
	BallotDB    Hint = "ballotDB"
	BlockDB     Hint = "blocksDB"
	ProposalDB  Hint = "proposalDB"
	ATXDB       Hint = "ATXDB"
	TXDB        Hint = "TXDB"
	POETDB      Hint = "POETDB"
	Malfeasance Hint = "malfeasance"
	ActiveSet   Hint = "activeset"
)

DB hints per DB.

type Opt

type Opt func(*cacheOpts)

func WithConfig

func WithConfig(cfg Config) Opt

type VrfNonceKey

type VrfNonceKey struct {
	ID    types.NodeID
	Epoch types.EpochID
}