protocol

package
v0.57.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Sep 28, 2022 License: MIT Imports: 50 Imported by: 0

Documentation

Index

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
	UpdateStakingStartingBlock(uint64)
	UpdateMultisigControlStartingBlock(uint64)
}

type Protocol

type Protocol struct {
	*processor.App
	// contains filtered or unexported fields
}

func New

func New(
	ctx context.Context,
	confWatcher *config.Watcher,
	log *logging.Logger,
	cancel func(),
	nodewallets *nodewallets.NodeWallets,
	ethClient *ethclient.Client,
	ethConfirmation *ethclient.EthereumConfirmations,
	blockchainClient *blockchain.Client,
	vegaPaths paths.Paths,
	stats *stats.Stats,
) (p *Protocol, err error)

func (*Protocol) GetBroker

func (n *Protocol) GetBroker() *broker.Broker

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) GetProtocolUpgradeService

func (n *Protocol) GetProtocolUpgradeService() *protocolupgrade.Engine

func (*Protocol) GetTimeService

func (n *Protocol) GetTimeService() *vegatime.Svc

func (*Protocol) Protocol

func (n *Protocol) Protocol() semver.Version

func (*Protocol) Start

func (n *Protocol) Start() error

Start will start the protocol, this means it's ready to process blocks from the blockchain.

func (*Protocol) Stop

func (n *Protocol) Stop() error

Stop will stop all services of the protocol.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL