Versions in this module Expand all Collapse all v0 v0.0.2 Jun 5, 2026 Changes in this version + type Config struct + OffRampContractID string + RMNRemoteContractID string + type DestinationReader struct + func New(invoker bindings.Invoker, rpcClient *rpcclient.Client, ...) (*DestinationReader, error) + func (d *DestinationReader) CheckHealth(chain protocol.ChainSelector) error + func (d *DestinationReader) Close() error + func (d *DestinationReader) GetCCVSForMessage(ctx context.Context, message protocol.Message) (protocol.CCVAddressInfo, error) + func (d *DestinationReader) GetExecutionAttempts(ctx context.Context, message protocol.Message) ([]protocol.ExecutionAttempt, error) + func (d *DestinationReader) GetMessageSuccess(ctx context.Context, message protocol.Message) (bool, error) + func (d *DestinationReader) GetRMNCursedSubjects(ctx context.Context) ([]protocol.Bytes16, error) + func (d *DestinationReader) HasHonestAttempt(ctx context.Context, message protocol.Message, ...) (bool, error) + func (d *DestinationReader) HealthReport() map[string]error + func (d *DestinationReader) IsReady(chain protocol.ChainSelector) bool + func (d *DestinationReader) Name() string + func (d *DestinationReader) Ready() error + func (d *DestinationReader) Start(ctx context.Context) error + type StellarExecutionAttemptPoller struct + func NewStellarExecutionAttemptPoller(rpcClient *rpcclient.Client, offrampContractID string, lggr *zerolog.Logger, ...) (*StellarExecutionAttemptPoller, error) + func (p *StellarExecutionAttemptPoller) Close() error + func (p *StellarExecutionAttemptPoller) GetExecutionAttempts(_ context.Context, message protocol.Message) ([]protocol.ExecutionAttempt, error) + func (p *StellarExecutionAttemptPoller) HealthReport() map[string]error + func (p *StellarExecutionAttemptPoller) Name() string + func (p *StellarExecutionAttemptPoller) Start(ctx context.Context) error v0.0.1 Apr 29, 2026
Go to main page