integration

Documentation

Index

• Variables
• func CheckDBList(names []string) error
• func DBProducer(chaindataDir string, scale cachescale.Func) kvdb.IterableDBProducer
• func MakeEngine(rawProducer kvdb.IterableDBProducer, genesis InputGenesis, cfg Configs) (*abft.Lachesis, *vecmt.Index, *gossip.Store, *abft.Store, *genesisstore.Store, ...)
• func SetAccountKey(am *accounts.Manager, key *ecdsa.PrivateKey, pswd string) (acc accounts.Account)
• func WrapDatabaseWithMetrics(db kvdb.FlushableDBProducer) kvdb.FlushableDBProducer
• type Configs
• type DBProducerWithMetrics
  • func (db *DBProducerWithMetrics) OpenDB(name string) (kvdb.DropableStore, error)
• type DropableStoreWithMetrics
  • func WrapStoreWithMetrics(ds kvdb.DropableStore) *DropableStoreWithMetrics
  • func (ds *DropableStoreWithMetrics) Close() error
• type DummyFlushableProducer
  • func (p *DummyFlushableProducer) Flush(_ []byte) error
  • func (p *DummyFlushableProducer) NotFlushedSizeEst() int
• type GenesisMismatchError
  • func (e *GenesisMismatchError) Error() string
• type GossipStoreAdapter
  • func (g *GossipStoreAdapter) GetEvent(id hash.Event) dag.Event
• type InputGenesis

Variables

var (
	FlushIDKey = hexutils.HexToBytes("0068c2927bf842c3e9e2f1364494a33a752db334b9a819534bc9f17d2c3b4e5970008ff519d35a86f29fcaa5aae706b75dee871f65f174fcea1747f2915fc92158f6bfbf5eb79f65d16225738594bffb0c")
)

Functions

func CheckDBList

func CheckDBList(names []string) error

func DBProducer

func DBProducer(chaindataDir string, scale cachescale.Func) kvdb.IterableDBProducer

func MakeEngine

func MakeEngine(rawProducer kvdb.IterableDBProducer, genesis InputGenesis, cfg Configs) (*abft.Lachesis, *vecmt.Index, *gossip.Store, *abft.Store, *genesisstore.Store, gossip.BlockProc)

MakeEngine makes consensus engine from config.

func SetAccountKey

func SetAccountKey(
	am *accounts.Manager, key *ecdsa.PrivateKey, pswd string,
) (
	acc accounts.Account,
)

SetAccountKey sets key into accounts manager and unlocks it with pswd.

func WrapDatabaseWithMetrics

func WrapDatabaseWithMetrics(db kvdb.FlushableDBProducer) kvdb.FlushableDBProducer

Types

type Configs

type Configs struct {
	Opera          gossip.Config
	OperaStore     gossip.StoreConfig
	Lachesis       abft.Config
	LachesisStore  abft.StoreConfig
	VectorClock    vecmt.IndexConfig
	AllowedGenesis map[uint64]hash.Hash
}

type DBProducerWithMetrics

type DBProducerWithMetrics struct {
	kvdb.FlushableDBProducer
}

func (*DBProducerWithMetrics) OpenDB

func (db *DBProducerWithMetrics) OpenDB(name string) (kvdb.DropableStore, error)

type DropableStoreWithMetrics

type DropableStoreWithMetrics struct {
	kvdb.DropableStore
	// contains filtered or unexported fields
}

func WrapStoreWithMetrics

func WrapStoreWithMetrics(ds kvdb.DropableStore) *DropableStoreWithMetrics

func (*DropableStoreWithMetrics) Close

func (ds *DropableStoreWithMetrics) Close() error

type DummyFlushableProducer

type DummyFlushableProducer struct {
	kvdb.DBProducer
}

func (*DummyFlushableProducer) Flush

func (p *DummyFlushableProducer) Flush(_ []byte) error

func (*DummyFlushableProducer) NotFlushedSizeEst

func (p *DummyFlushableProducer) NotFlushedSizeEst() int

type GenesisMismatchError

type GenesisMismatchError struct {
	Stored, New hash.Hash
}

GenesisMismatchError is raised when trying to overwrite an existing genesis block with an incompatible one.

func (*GenesisMismatchError) Error

func (e *GenesisMismatchError) Error() string

Error implements error interface.

type GossipStoreAdapter

type GossipStoreAdapter struct {
	*gossip.Store
}

func (*GossipStoreAdapter) GetEvent

func (g *GossipStoreAdapter) GetEvent(id hash.Event) dag.Event

type InputGenesis

type InputGenesis struct {
	Hash  hash.Hash
	Read  func(*genesisstore.Store) error
	Close func() error
}