substrate

Documentation

Index

• type EventListener
• type MessageHandler
• type ProposalExecutor
• type SubstrateChain
  • func NewSubstrateChain(listener EventListener, messageHandler MessageHandler, ...) *SubstrateChain
  • func (c *SubstrateChain) DomainID() uint8
  • func (c *SubstrateChain) PollEvents(ctx context.Context)
  • func (c *SubstrateChain) ReceiveMessage(m *message.Message) (*proposal.Proposal, error)
  • func (c *SubstrateChain) Write(props []*proposal.Proposal) error

Types

type EventListener

type EventListener interface {
	ListenToEvents(ctx context.Context, startBlock *big.Int)
}

type MessageHandler

type MessageHandler interface {
	HandleMessage(m *message.Message) (*proposal.Proposal, error)
}

type ProposalExecutor

type ProposalExecutor interface {
	Execute(props []*proposal.Proposal) error
}

type SubstrateChain

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

func NewSubstrateChain

func NewSubstrateChain(listener EventListener, messageHandler MessageHandler, executor ProposalExecutor, domainID uint8, startBlock *big.Int) *SubstrateChain

func (*SubstrateChain) DomainID

func (c *SubstrateChain) DomainID() uint8

func (*SubstrateChain) PollEvents

func (c *SubstrateChain) PollEvents(ctx context.Context)

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

func (*SubstrateChain) ReceiveMessage

func (c *SubstrateChain) ReceiveMessage(m *message.Message) (*proposal.Proposal, error)

func (*SubstrateChain) Write

func (c *SubstrateChain) Write(props []*proposal.Proposal) error