solo

Documentation

Index

• type Communicator
  • func (comm *Communicator) PeersStats() []*comm.PeerStats
• type Core
  • func NewCore(repo *chain.Repository, stater *state.Stater, logDB *logdb.LogDB, ...) *Core
  • func (c *Core) IsExecutable(trx *tx.Transaction) (bool, error)
  • func (c *Core) Pack(pendingTxs tx.Transactions, onDemand bool) ([]*tx.Transaction, error)
• type OnDemandTxPool
  • func NewOnDemandTxPool(engine *Core) *OnDemandTxPool
  • func (o *OnDemandTxPool) Add(newTx *tx.Transaction) error
  • func (o *OnDemandTxPool) AddLocal(newTx *tx.Transaction) error
  • func (o *OnDemandTxPool) Close()
  • func (o *OnDemandTxPool) Dump() tx.Transactions
  • func (o *OnDemandTxPool) Executables() tx.Transactions
  • func (o *OnDemandTxPool) Fill(txs tx.Transactions)
  • func (o *OnDemandTxPool) Get(txID thor.Bytes32) *tx.Transaction
  • func (o *OnDemandTxPool) Len() int
  • func (o *OnDemandTxPool) Remove(txHash thor.Bytes32, txID thor.Bytes32) bool
  • func (o *OnDemandTxPool) StrictlyAdd(newTx *tx.Transaction) error
  • func (o *OnDemandTxPool) SubscribeTxEvent(ch chan *txpool.TxEvent) event.Subscription
• type Options
• type Solo
  • func New(repo *chain.Repository, stater *state.Stater, txPool TxPool, options Options, ...) *Solo
  • func (s *Solo) Run(ctx context.Context) error
• type TxPool

Types

type Communicator

type Communicator struct{}

Communicator in solo is a fake one just for api handler.

func (*Communicator) PeersStats

func (comm *Communicator) PeersStats() []*comm.PeerStats

PeersStats returns nil solo doesn't join p2p network.

type Core

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

func NewCore

func NewCore(
	repo *chain.Repository,
	stater *state.Stater,
	logDB *logdb.LogDB,
	options Options,
	forkConfig *thor.ForkConfig,
) *Core

func (*Core) IsExecutable

func (c *Core) IsExecutable(trx *tx.Transaction) (bool, error)

func (*Core) Pack

func (c *Core) Pack(pendingTxs tx.Transactions, onDemand bool) ([]*tx.Transaction, error)

type OnDemandTxPool

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

func NewOnDemandTxPool

func NewOnDemandTxPool(engine *Core) *OnDemandTxPool

func (*OnDemandTxPool) Add

func (o *OnDemandTxPool) Add(newTx *tx.Transaction) error

func (*OnDemandTxPool) AddLocal

func (o *OnDemandTxPool) AddLocal(newTx *tx.Transaction) error

func (*OnDemandTxPool) Close

func (o *OnDemandTxPool) Close()

func (*OnDemandTxPool) Dump

func (o *OnDemandTxPool) Dump() tx.Transactions

func (*OnDemandTxPool) Executables

func (o *OnDemandTxPool) Executables() tx.Transactions

func (*OnDemandTxPool) Fill

func (o *OnDemandTxPool) Fill(txs tx.Transactions)

func (*OnDemandTxPool) Get

func (o *OnDemandTxPool) Get(txID thor.Bytes32) *tx.Transaction

func (*OnDemandTxPool) Len

func (o *OnDemandTxPool) Len() int

func (*OnDemandTxPool) Remove

func (o *OnDemandTxPool) Remove(txHash thor.Bytes32, txID thor.Bytes32) bool

func (*OnDemandTxPool) StrictlyAdd

func (o *OnDemandTxPool) StrictlyAdd(newTx *tx.Transaction) error

func (*OnDemandTxPool) SubscribeTxEvent

func (o *OnDemandTxPool) SubscribeTxEvent(ch chan *txpool.TxEvent) event.Subscription

type Options

type Options struct {
	GasLimit         uint64
	SkipLogs         bool
	MinTxPriorityFee uint64
	OnDemand         bool
}

type Solo

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

Solo mode is the standalone client without p2p server

func New

func New(
	repo *chain.Repository,
	stater *state.Stater,
	txPool TxPool,
	options Options,
	core *Core,
) *Solo

New returns Solo instance

func (*Solo) Run

func (s *Solo) Run(ctx context.Context) error

Run runs the packer for solo

type TxPool

type TxPool interface {
	txpool.Pool
	// Executables returns the transactions that can be executed
	Executables() tx.Transactions
	// Remove removes a transaction from the pool
	Remove(txHash thor.Bytes32, txID thor.Bytes32) bool
}