Documentation ¶
Index ¶
- Variables
- type EthCallEngine
- 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(ctx context.Context) 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 EthCallEngine ¶ added in v0.73.0
type EthCallEngine interface { Start() StartAtHeight(height uint64, timestamp uint64) Stop() MakeResult(specID string, bytes []byte) (ethcall.Result, error) CallSpec(ctx context.Context, id string, atBlock uint64) (ethcall.Result, error) GetEthTime(ctx context.Context, atBlock uint64) (uint64, error) GetRequiredConfirmations(id string) (uint64, error) GetInitialTriggerTime(id string) (uint64, error) OnSpecActivated(ctx context.Context, spec datasource.Spec) error OnSpecDeactivated(ctx context.Context, spec datasource.Spec) }
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.