ethrelayer

Documentation

Index

• Constants
• type EthereumListener
  • func NewEthereumListener(config *ethereum.Config, conn *ethereum.Connection, ...) *EthereumListener
  • func (li *EthereumListener) Start(cxt context.Context, eg *errgroup.Group, initBlockHeight uint64, ...) error
• type ParachainPayload
• type ParachainWriter
  • func NewParachainWriter(conn *parachain.Connection, payloads <-chan ParachainPayload, ...) *ParachainWriter
  • func (wr *ParachainWriter) Start(ctx context.Context, eg *errgroup.Group) error
  • func (wr *ParachainWriter) WritePayload(ctx context.Context, payload *ParachainPayload) error
• type Worker
  • func NewWorker(ethconfig *ethereum.Config, paraconfig *parachain.Config, log *logrus.Entry) *Worker
  • func (w *Worker) Name() string
  • func (w *Worker) Start(ctx context.Context, eg *errgroup.Group) error

Constants

const Name = "eth-relayer"

Types

type EthereumListener

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

EthereumListener streams the Ethereum blockchain for application events

func NewEthereumListener

func NewEthereumListener(
	config *ethereum.Config,
	conn *ethereum.Connection,
	payloads chan<- ParachainPayload,
	log *logrus.Entry,
) *EthereumListener

func (*EthereumListener) Start

func (li *EthereumListener) Start(cxt context.Context, eg *errgroup.Group, initBlockHeight uint64, descendantsUntilFinal uint64) error

type ParachainPayload

type ParachainPayload struct {
	Header   *chain.Header
	Messages []*chain.EthereumOutboundMessage
}

type ParachainWriter

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

func NewParachainWriter

func NewParachainWriter(
	conn *parachain.Connection,
	payloads <-chan ParachainPayload,
	log *logrus.Entry,
) *ParachainWriter

func (*ParachainWriter) Start

func (wr *ParachainWriter) Start(ctx context.Context, eg *errgroup.Group) error

func (*ParachainWriter) WritePayload

func (wr *ParachainWriter) WritePayload(ctx context.Context, payload *ParachainPayload) error

type Worker

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

func NewWorker

func NewWorker(ethconfig *ethereum.Config, paraconfig *parachain.Config, log *logrus.Entry) *Worker

func (*Worker) Name

func (w *Worker) Name() string

func (*Worker) Start

func (w *Worker) Start(ctx context.Context, eg *errgroup.Group) error