consensus

Documentation

Index

• Constants
• func Init(cfg Config, ntw setup.Network, logger log.Logger) error
• type Config
  • func NewConfig(dataDir string, rpcListenPort uint, p2pListenPort uint, proxyListenPort uint, ...) Config
  • func (c Config) RPCListenPort() uint
  • func (c Config) TendermintConfigFilePath() string
• type Node
  • func NewNode(cfg *Config) (*Node, error)
  • func (n *Node) Start(ethRPCClient *ethRpc.Client, db *database.Database) error
  • func (n *Node) Stop() error
• type TendermintABCI
  • func NewTendermintABCI(db *database.Database, ethRPCClient *rpc.Client, logger tmtLog.Logger) (*TendermintABCI, error)
  • func (abci *TendermintABCI) BeginBlock(req tmtAbciTypes.RequestBeginBlock) tmtAbciTypes.ResponseBeginBlock
  • func (abci *TendermintABCI) CheckTx(txBytes []byte) tmtAbciTypes.ResponseCheckTx
  • func (abci *TendermintABCI) CollectTx(tx *ethTypes.Transaction)
  • func (abci *TendermintABCI) Commit() tmtAbciTypes.ResponseCommit
  • func (abci *TendermintABCI) DeliverTx(txBytes []byte) tmtAbciTypes.ResponseDeliverTx
  • func (abci *TendermintABCI) EndBlock(req tmtAbciTypes.RequestEndBlock) tmtAbciTypes.ResponseEndBlock
  • func (abci *TendermintABCI) Info(req tmtAbciTypes.RequestInfo) tmtAbciTypes.ResponseInfo
  • func (abci *TendermintABCI) InitChain(req tmtAbciTypes.RequestInitChain) tmtAbciTypes.ResponseInitChain
  • func (abci *TendermintABCI) InitEthState() error
  • func (abci *TendermintABCI) Query(query tmtAbciTypes.RequestQuery) tmtAbciTypes.ResponseQuery
  • func (abci *TendermintABCI) Receiver() common.Address
  • func (abci *TendermintABCI) SetOption(req tmtAbciTypes.RequestSetOption) tmtAbciTypes.ResponseSetOption

Constants

const DataDirName = "consensus"

Functions

func Init

func Init(cfg Config, ntw setup.Network, logger log.Logger) error

Types

type Config

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

Config is general consensus node config.

Default values:

- rpcListenPort 26657 - p2pListenPort 26656 - ProxyListenPort 26658

func NewConfig

func NewConfig(dataDir string, rpcListenPort uint, p2pListenPort uint, proxyListenPort uint, proxyProtocol string) Config

func (Config) RPCListenPort

func (c Config) RPCListenPort() uint

func (Config) TendermintConfigFilePath

func (c Config) TendermintConfigFilePath() string

type Node

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

func NewNode

func NewNode(cfg *Config) (*Node, error)

func (*Node) Start

func (n *Node) Start(ethRPCClient *ethRpc.Client, db *database.Database) error

func (*Node) Stop

func (n *Node) Stop() error

type TendermintABCI

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

func NewTendermintABCI

func NewTendermintABCI(db *database.Database, ethRPCClient *rpc.Client, logger tmtLog.Logger) (*TendermintABCI, error)

func (*TendermintABCI) BeginBlock

func (abci *TendermintABCI) BeginBlock(req tmtAbciTypes.RequestBeginBlock) tmtAbciTypes.ResponseBeginBlock

BeginBlock starts a new Ethereum block

func (*TendermintABCI) CheckTx

func (abci *TendermintABCI) CheckTx(txBytes []byte) tmtAbciTypes.ResponseCheckTx

CheckTx checks a transaction is valid but does not mutate the state

func (*TendermintABCI) CollectTx

func (abci *TendermintABCI) CollectTx(tx *ethTypes.Transaction)

CollectTx invokes CollectTx on the strategy

func (*TendermintABCI) Commit

func (abci *TendermintABCI) Commit() tmtAbciTypes.ResponseCommit

Commits the block and returns a hash of the current state

func (*TendermintABCI) DeliverTx

func (abci *TendermintABCI) DeliverTx(txBytes []byte) tmtAbciTypes.ResponseDeliverTx

DeliverTx executes a transaction against the latest state

func (*TendermintABCI) EndBlock

func (abci *TendermintABCI) EndBlock(req tmtAbciTypes.RequestEndBlock) tmtAbciTypes.ResponseEndBlock

EndBlock accumulates rewards for the validators and updates them

func (*TendermintABCI) Info

func (abci *TendermintABCI) Info(req tmtAbciTypes.RequestInfo) tmtAbciTypes.ResponseInfo

Info returns information about the last height and app_hash to the tmtCfg engine

func (*TendermintABCI) InitChain

func (abci *TendermintABCI) InitChain(req tmtAbciTypes.RequestInitChain) tmtAbciTypes.ResponseInitChain

InitChain initializes the validator set

func (*TendermintABCI) InitEthState

func (abci *TendermintABCI) InitEthState() error

func (*TendermintABCI) Query

func (abci *TendermintABCI) Query(query tmtAbciTypes.RequestQuery) tmtAbciTypes.ResponseQuery

Query queries the state of the TendermintABCI

func (*TendermintABCI) Receiver

func (abci *TendermintABCI) Receiver() common.Address

Receiver returns the receiving address based on the selected strategy

func (*TendermintABCI) SetOption

func (abci *TendermintABCI) SetOption(req tmtAbciTypes.RequestSetOption) tmtAbciTypes.ResponseSetOption

SetOption sets a configuration option