protocol

package
v0.73.7-preview.2 Latest Latest
Warning

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

Go to latest
Published: Nov 22, 2023 License: AGPL-3.0 Imports: 61 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 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

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(),
	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) 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) GetPowEngine added in v0.67.0

func (n *Protocol) GetPowEngine() processor.PoWEngine

func (*Protocol) GetProtocolUpgradeService

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

func (*Protocol) GetSpamEngine added in v0.67.0

func (n *Protocol) GetSpamEngine() *spam.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(ctx context.Context) 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