Documentation ¶
Index ¶
- Variables
- type EthCallEngine
- type EventForwarderEngine
- type L2EthCallEngines
- 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
- type SpecActivationListener
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) EnsureChainID(chainID string, blockInterval uint64, confirmWithClient bool) }
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 L2EthCallEngines ¶ added in v0.74.0
type L2EthCallEngines struct {
// contains filtered or unexported fields
}
func NewL2EthCallEngines ¶ added in v0.74.0
func (*L2EthCallEngines) GetOrInstantiate ¶ added in v0.74.0
func (v *L2EthCallEngines) GetOrInstantiate(chainID string) (ethverifier.EthCallEngine, error)
func (*L2EthCallEngines) OnEthereumL2ConfigsUpdated ¶ added in v0.74.0
func (v *L2EthCallEngines) OnEthereumL2ConfigsUpdated( ctx context.Context, ethCfg *types.EthereumL2Configs, ) error
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, l2Clients *ethclient.L2Clients, ) (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 ¶
type SpecActivationListener ¶ added in v0.74.0
type SpecActivationListener func(listener spec.SpecActivationsListener)
Click to show internal directories.
Click to hide internal directories.