Documentation ¶
Index ¶
- Variables
- type EventForwarderEngine
- type Protocol
- func (n *Protocol) GetBroker() *broker.Broker
- func (n *Protocol) GetEventForwarder() *evtforward.Forwarder
- func (n *Protocol) GetEventService() *subscribers.Service
- func (n *Protocol) GetPoW() api.ProofOfWorkParams
- func (n *Protocol) GetPowEngine() processor.PoWEngine
- func (n *Protocol) GetProtocolUpgradeService() *protocolupgrade.Engine
- func (n *Protocol) GetSpamEngine() *spam.Engine
- func (n *Protocol) GetTimeService() *vegatime.Svc
- func (n *Protocol) Protocol() semver.Version
- func (n *Protocol) Start() error
- func (n *Protocol) Stop() error
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ErrUnknownChainProvider = errors.New("unknown chain provider") ErrERC20AssetWithNullChain = errors.New("cannot use ERC20 asset with nullchain") )
View Source
var Version = semver.MustParse("0.1.0")
Functions ¶
This section is empty.
Types ¶
type EventForwarderEngine ¶
type EventForwarderEngine interface { ReloadConf(evtforward.Config) SetupEthereumEngine(evtfwdeth.Client, evtfwdeth.Forwarder, evtfwdeth.Config, *types.EthereumConfig, evtfwdeth.Assets) error Start() Stop() // methods used to update starting blocks of the eef UpdateCollateralStartingBlock(uint64) UpdateStakingStartingBlock(uint64) UpdateMultisigControlStartingBlock(uint64) }
type Protocol ¶
func New ¶
func New( ctx context.Context, confWatcher *config.Watcher, log *logging.Logger, cancel func(), stopBlockchain func() error, nodewallets *nodewallets.NodeWallets, ethClient *ethclient.Client, ethConfirmation *ethclient.EthereumConfirmations, blockchainClient *blockchain.Client, vegaPaths paths.Paths, stats *stats.Stats, ) (p *Protocol, err error)
func (*Protocol) GetEventForwarder ¶
func (n *Protocol) GetEventForwarder() *evtforward.Forwarder
func (*Protocol) GetEventService ¶
func (n *Protocol) GetEventService() *subscribers.Service
func (*Protocol) GetPoW ¶
func (n *Protocol) GetPoW() api.ProofOfWorkParams
func (*Protocol) GetPowEngine ¶ added in v0.67.0
func (*Protocol) GetProtocolUpgradeService ¶
func (n *Protocol) GetProtocolUpgradeService() *protocolupgrade.Engine
func (*Protocol) GetSpamEngine ¶ added in v0.67.0
func (*Protocol) GetTimeService ¶
Click to show internal directories.
Click to hide internal directories.