ethrelayer

package
v0.0.0-...-8201b66 Latest Latest
Warning

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

 Go to latest Published: Jun 20, 2021 License: LGPL-3.0 Imports: 12 Imported by: 0

Documentation

Index

Constants

View Source 
const Name = "eth-relayer"

Variables

This section is empty.

Functions

This section is empty.

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.