Versions in this module Expand all Collapse all v0 v0.0.2 Jun 5, 2026 Changes in this version + type RPCClient interface + GetEvents func(ctx context.Context, req protocolrpc.GetEventsRequest) (protocolrpc.GetEventsResponse, error) + GetLatestLedger func(ctx context.Context) (protocolrpc.GetLatestLedgerResponse, error) + GetLedgers func(ctx context.Context, req protocolrpc.GetLedgersRequest) (protocolrpc.GetLedgersResponse, error) + type ReaderConfig struct + NetworkPassphrase string + OnRampContractID string + RMNRemoteContractID string + SorobanRPCURL string + type SourceReader struct + func NewSourceReaderWithClient(client RPCClient, invoker bindings.Invoker, ccipOnrampAddress string, ...) (*SourceReader, error) + func (s *SourceReader) FetchMessageSentEvents(ctx context.Context, fromBlock, toBlock *big.Int) ([]protocol.MessageSentEvent, error) + func (s *SourceReader) GetBlocksHeaders(ctx context.Context, ledgerNumber []*big.Int) (map[uint64]protocol.BlockHeader, error) + func (s *SourceReader) GetRMNCursedSubjects(ctx context.Context) ([]protocol.Bytes16, error) + func (s *SourceReader) LatestAndFinalizedBlock(ctx context.Context) (latest, finalized *protocol.BlockHeader, err error) + func (s *SourceReader) LatestSafeBlock(_ context.Context) (*protocol.BlockHeader, error) v0.0.1 Apr 29, 2026
Go to main page