relayer

May 16, 2024

Changes in this version

type State

+ func (s *State) GetOffset(dstID, srcID uint64) uint64

May 6, 2024

Changes in this version

type Config

+ Network netconf.ID

+ RPCEndpoints xchain.RPCEndpoints

Apr 12, 2024

Changes in this version

type State

+ func (s *State) Clear(dstID uint64) error

Mar 27, 2024

Changes in this version

+ type Sender struct

+ func NewSender(chain netconf.Chain, rpcClient ethclient.Client, privateKey ecdsa.PrivateKey, ...) (Sender, error)

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

Mar 5, 2024

Changes in this version

+ func CreateSubmissions(up StreamUpdate) ([]xchain.Submission, error)

+ func FromHeights(cursors []xchain.StreamCursor, destChain netconf.Chain, chains []netconf.Chain, ...) map[uint64]uint64

+ func Run(ctx context.Context, cfg Config) error

+ func SubmissionToBinding(sub xchain.Submission) bindings.XSubmission

+ func WriteConfigTOML(cfg Config, logCfg log.Config, path string) error

+ type Config struct

+ HaloURL string

+ MonitoringAddr string

+ NetworkFile string

+ PrivateKey string

+ StateFile string

+ func DefaultConfig() Config

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

+ type OpSender struct

+ func NewOpSender(chain netconf.Chain, rpcClient ethclient.Client, privateKey ecdsa.PrivateKey, ...) (OpSender, error)

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

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

+ type State struct

+ 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 struct

+ Attestation xchain.Attestation

+ Msgs []xchain.Msg

+ Tree xchain.BlockTree

+ type Worker struct

+ func NewWorker(destChain netconf.Chain, network netconf.Network, cProvider cchain.Provider, ...) *Worker

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