aggregator

Documentation

Index

• type Aggregator
  • func NewAggregator(aggregatorDbDir string, validatorDbDir string, mainchainKeystore string, ...) (*Aggregator, error)
  • func (a *Aggregator) Start()
• type BlockSubmitter
  • func NewBlockSubmitter(mainchainClient *ethclient.Client, mainchainAuth *bind.TransactOpts, ...) *BlockSubmitter
  • func (bs *BlockSubmitter) Start()
• type TransactionGenerator
  • func NewTransactionGenerator(aggregatorDb db.DB, validatorDb db.DB, mainchainClient *ethclient.Client, ...) *TransactionGenerator
  • func (tg *TransactionGenerator) Start()

Types

type Aggregator

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

func NewAggregator

func NewAggregator(
	aggregatorDbDir string,
	validatorDbDir string,
	mainchainKeystore string,
	sidechainKeystore string,
	relayerGrpcPort int,
	fraudTransfer bool,
	validatorMode bool) (*Aggregator, error)

func (*Aggregator) Start

func (a *Aggregator) Start()

type BlockSubmitter

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

func NewBlockSubmitter

func NewBlockSubmitter(
	mainchainClient *ethclient.Client,
	mainchainAuth *bind.TransactOpts,
	mainchainAuthPrivatekey *ecdsa.PrivateKey,
	sidechainClient *ethclient.Client,
	sidechainAuth *bind.TransactOpts,
	sidechainAuthPrivateKey *ecdsa.PrivateKey,
	aggregatorDb db.DB,
	serializer *types.Serializer,
	rollupChain *mainchain.RollupChain,
	validatorRegistry *mainchain.ValidatorRegistry,
	blockCommittee *sidechain.BlockCommittee,
) *BlockSubmitter

func (*BlockSubmitter) Start

func (bs *BlockSubmitter) Start()

type TransactionGenerator

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

func NewTransactionGenerator

func NewTransactionGenerator(
	aggregatorDb db.DB,
	validatorDb db.DB,
	mainchainClient *ethclient.Client,
	rollupChain *mainchain.RollupChain,
) *TransactionGenerator

func (*TransactionGenerator) Start

func (tg *TransactionGenerator) Start()