protocol

Documentation

Index

• Variables
• type EthCallEngine
• type EventForwarderEngine
• type Protocol
  • func New(ctx context.Context, confWatcher *config.Watcher, log *logging.Logger, ...) (p *Protocol, err error)
  • 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

Variables

var (
	ErrUnknownChainProvider    = errors.New("unknown chain provider")
	ErrERC20AssetWithNullChain = errors.New("cannot use ERC20 asset with nullchain")
)

var Version = semver.MustParse("0.1.0")

Types

type EthCallEngine

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)
	GetRequiredConfirmations(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

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

func (*Protocol) GetProtocolUpgradeService

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

func (*Protocol) GetSpamEngine

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.