evm

Documentation

Index

• type EVMChain
  • func NewEVMChain(listener EventListener, writer ProposalExecutor, blockstore *store.BlockStore, ...) *EVMChain
  • func (c *EVMChain) DomainID() uint8
  • func (c *EVMChain) PollEvents(ctx context.Context, sysErr chan<- error, msgChan chan *message.Message, ...)
  • func (c *EVMChain) Write(msg *message.Message) error
  • func (c *EVMChain) Write1(msg1 *message.Message2) (bool, error)
  • func (c *EVMChain) Write2(msg *message.Message2) error
  • func (c *EVMChain) WriteBatch(msg []*message.Message) error
  • func (c *EVMChain) WriteRemoval(msg *message.Message2) error
• type EventListener
• type ProposalExecutor

Types

type EVMChain

type EVMChain struct {
	// contains filtered or unexported fields
}

EVMChain is struct that aggregates all data required for

func NewEVMChain

func NewEVMChain(listener EventListener, writer ProposalExecutor, blockstore *store.BlockStore, config *chain.EVMConfig) *EVMChain

func (*EVMChain) DomainID

func (c *EVMChain) DomainID() uint8

func (*EVMChain) PollEvents

func (c *EVMChain) PollEvents(ctx context.Context, sysErr chan<- error, msgChan chan *message.Message, msgChan1 chan *message.Message2)

PollEvents is the goroutine that polls blocks and searches Deposit events in them. Events are then sent to eventsChan.

func (*EVMChain) Write

func (c *EVMChain) Write(msg *message.Message) error

func (*EVMChain) Write1

func (c *EVMChain) Write1(msg1 *message.Message2) (bool, error)

func (*EVMChain) Write2

func (c *EVMChain) Write2(msg *message.Message2) error

func (*EVMChain) WriteBatch

func (c *EVMChain) WriteBatch(msg []*message.Message) error

func (*EVMChain) WriteRemoval

func (c *EVMChain) WriteRemoval(msg *message.Message2) error

type EventListener

type EventListener interface {
	ListenToEvents(ctx context.Context, startBlock *big.Int, msgChan chan *message.Message, msgChan1 chan *message.Message2, errChan chan<- error)
}

type ProposalExecutor

type ProposalExecutor interface {
	Execute(message *message.Message) error
	Execute1(message *message.Message2) (bool, error)
	ExecuteSourceTransactiions(message *message.Message2) error
	ExecuteRemovefromdest(message *message.Message2) error
	ExecuteBatch(msg []*message.Message) error
}