relayer

type Config ¶

type Config struct {
	PrivateKey     string
	HaloURL        string
	NetworkFile    string
	MonitoringAddr string
	StateFile      string
}

func DefaultConfig() Config

type CreateFunc ¶

type CreateFunc func(streamUpdate StreamUpdate) ([]xchain.Submission, error)

CreateFunc is a function that creates one or more submissions from the given stream update.

type SendFunc ¶

type SendFunc func(ctx context.Context, submission xchain.Submission) error

SendFunc sends a submission to the destination chain by invoking "xsubmit" on portal contract.

type Sender ¶ added in v0.1.2

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

Sender uses txmgr to send transactions to the destination chain.

func NewSender(chain netconf.Chain, rpcClient ethclient.Client,
	privateKey ecdsa.PrivateKey, chainNames map[uint64]string) (Sender, error)

func (o Sender) SendTransaction(ctx context.Context, submission xchain.Submission) error

type State ¶

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

State represents the state of the relayer. It keeps track of the last successfully processed block.

func LoadCursors(path string) (*State, bool, error)

func NewEmptyState(filePath string) *State

func (s *State) GetHeight(dstID, srcID uint64) uint64

func (s *State) Persist(dstID, srcID, height uint64) error

type StreamUpdate ¶

type StreamUpdate struct {
	xchain.StreamID
	Tree        xchain.BlockTree
	Attestation xchain.Attestation // Attestation for the xmsgs
	Msgs        []xchain.Msg       // msgs that increment the cursor
}

type Worker ¶

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

func NewWorker(destChain netconf.Chain, network netconf.Network, cProvider cchain.Provider,
	xProvider xchain.Provider, creator CreateFunc, sendProvider func() (SendFunc, error), state *State,
) *Worker

func (w *Worker) Run(ctx context.Context)