provider

Dec 20, 2024

Changes in this version

type ChainProvider

+ SetBackupRpcAddrs func(rpcAddrs []string) error

type QueryProvider

+ QueryDenomHash func(ctx context.Context, trace string) (string, error)

Feb 1, 2024

Changes in this version

type ChainProvider

+ SetRpcAddr func(rpcAddr string) error

Sep 13, 2023

Changes in this version

type KeyProvider

+ UseKey func(key string) error

Aug 1, 2023

Changes in this version

type ChainProvider

+ MsgRegisterCounterpartyPayee func(portID, channelID, relayerAddr, counterpartyPayeeAddr string) (RelayerMessage, error)

+ type ExtensionOption struct

+ Type string

+ Value string

type QueryProvider

+ QueryNextSeqAck func(ctx context.Context, height int64, channelid, portid string) (recvRes *chantypes.QueryNextSequenceReceiveResponse, err error)

Apr 7, 2023

Changes in this version

+ func CheckForMisbehaviour(ctx context.Context, counterparty ChainProvider, clientID string, ...) (ibcexported.ClientMessage, error)

+ type BroadcastMode string

+ const BroadcastModeBatch

+ const BroadcastModeSingle

type ChainProvider

+ CommitmentPrefix func() commitmenttypes.MerklePrefix

+ MsgSubmitMisbehaviour func(clientID string, misbehaviour ibcexported.ClientMessage) (RelayerMessage, error)

+ MsgSubmitQueryResponse func(chainID string, queryID ClientICQQueryID, proof ICQProof) (RelayerMessage, error)

+ QueryICQWithProof func(ctx context.Context, msgType string, request []byte, height uint64) (ICQProof, error)

+ SendMessagesToMempool func(ctx context.Context, msgs []RelayerMessage, memo string, ...) error

+ type ClientICQInfo struct

+ Chain string

+ Connection string

+ Height uint64

+ QueryID ClientICQQueryID

+ Request []byte

+ Source string

+ Type string

+ type ClientICQQueryID string

type ClientState

+ Header []byte

type ConnectionInfo

+ CounterpartyCommitmentPrefix commitmenttypes.MerklePrefix

type IBCHeader

+ NextValidatorsHash func() []byte

+ type ICQProof struct

+ Height int64

+ ProofOps *crypto.ProofOps

+ Result []byte

type ProviderConfig

+ BroadcastMode func() BroadcastMode

type RelayerTxResponse

+ Codespace string

+ type TendermintIBCHeader struct

+ SignedHeader *types.SignedHeader

+ TrustedHeight clienttypes.Height

+ TrustedValidators *types.ValidatorSet

+ ValidatorSet *types.ValidatorSet

+ func (h TendermintIBCHeader) ConsensusState() ibcexported.ConsensusState

+ func (h TendermintIBCHeader) Height() uint64

+ func (h TendermintIBCHeader) NextValidatorsHash() []byte

+ func (h TendermintIBCHeader) TMHeader() (*tendermint.Header, error)

Feb 1, 2023

Changes in this version

type ClientState

+ ConsensusTime time.Time

+ TrustingPeriod time.Duration

Sep 16, 2022

Changes in this version

+ func ClientsMatch(ctx context.Context, src, dst ChainProvider, ...) (string, error)

type ChainProvider

+ ChainName func() string

+ ChannelProof func(ctx context.Context, msg ChannelInfo, height uint64) (ChannelProof, error)

+ ConnectionHandshakeProof func(ctx context.Context, msgOpenInit ConnectionInfo, height uint64) (ConnectionProof, error)

+ ConnectionProof func(ctx context.Context, msgOpenAck ConnectionInfo, height uint64) (ConnectionProof, error)

+ MsgAcknowledgement func(msgRecvPacket PacketInfo, proofAcked PacketProof) (RelayerMessage, error)

+ MsgChannelCloseConfirm func(msgCloseInit ChannelInfo, proof ChannelProof) (RelayerMessage, error)

+ MsgChannelCloseInit func(info ChannelInfo, proof ChannelProof) (RelayerMessage, error)

+ MsgChannelOpenAck func(msgOpenTry ChannelInfo, proof ChannelProof) (RelayerMessage, error)

+ MsgChannelOpenConfirm func(msgOpenAck ChannelInfo, proof ChannelProof) (RelayerMessage, error)

+ MsgChannelOpenInit func(info ChannelInfo, proof ChannelProof) (RelayerMessage, error)

+ MsgChannelOpenTry func(msgOpenInit ChannelInfo, proof ChannelProof) (RelayerMessage, error)

+ MsgConnectionOpenAck func(msgOpenTry ConnectionInfo, proof ConnectionProof) (RelayerMessage, error)

+ MsgConnectionOpenConfirm func(msgOpenAck ConnectionInfo, proof ConnectionProof) (RelayerMessage, error)

+ MsgConnectionOpenInit func(info ConnectionInfo, proof ConnectionProof) (RelayerMessage, error)

+ MsgConnectionOpenTry func(msgOpenInit ConnectionInfo, proof ConnectionProof) (RelayerMessage, error)

+ MsgCreateClient func(clientState ibcexported.ClientState, consensusState ibcexported.ConsensusState) (RelayerMessage, error)

+ MsgRecvPacket func(msgTransfer PacketInfo, proof PacketProof) (RelayerMessage, error)

+ MsgTimeout func(msgTransfer PacketInfo, proofUnreceived PacketProof) (RelayerMessage, error)

+ MsgTimeoutOnClose func(msgTransfer PacketInfo, proofUnreceived PacketProof) (RelayerMessage, error)

+ MsgUpdateClient func(clientId string, counterpartyHeader ibcexported.Header) (RelayerMessage, error)

+ MsgUpdateClientHeader func(latestHeader IBCHeader, trustedHeight clienttypes.Height, ...) (ibcexported.Header, error)

+ NewClientState func(dstChainID string, dstIBCHeader IBCHeader, ...) (ibcexported.ClientState, error)

+ NextSeqRecv func(ctx context.Context, msgTransfer PacketInfo, height uint64) (PacketProof, error)

+ PacketAcknowledgement func(ctx context.Context, msgRecvPacket PacketInfo, height uint64) (PacketProof, error)

+ PacketCommitment func(ctx context.Context, msgTransfer PacketInfo, height uint64) (PacketProof, error)

+ PacketReceipt func(ctx context.Context, msgTransfer PacketInfo, height uint64) (PacketProof, error)

+ Sprint func(toPrint proto.Message) (string, error)

+ ValidatePacket func(msgTransfer PacketInfo, latestBlock LatestBlock) error

+ type ChannelInfo struct

+ ChannelID string

+ ConnID string

+ CounterpartyChannelID string

+ CounterpartyConnID string

+ CounterpartyPortID string

+ Height uint64

+ Order chantypes.Order

+ PortID string

+ Version string

+ type ChannelProof struct

+ Ordering chantypes.Order

+ Proof []byte

+ ProofHeight clienttypes.Height

+ Version string

+ type ClientState struct

+ ClientID string

+ ConsensusHeight clienttypes.Height

+ type ClientTrustedState struct

+ ClientState ClientState

+ IBCHeader IBCHeader

+ type ConnectionInfo struct

+ ClientID string

+ ConnID string

+ CounterpartyClientID string

+ CounterpartyConnID string

+ Height uint64

+ type ConnectionProof struct

+ ClientState ibcexported.ClientState

+ ClientStateProof []byte

+ ConnectionStateProof []byte

+ ConsensusStateProof []byte

+ ProofHeight clienttypes.Height

+ type IBCHeader interface

+ ConsensusState func() ibcexported.ConsensusState

+ Height func() uint64

+ type LatestBlock struct

+ Height uint64

+ Time time.Time

+ type PacketInfo struct

+ Ack []byte

+ ChannelOrder string

+ Data []byte

+ DestChannel string

+ DestPort string

+ Height uint64

+ Sequence uint64

+ SourceChannel string

+ SourcePort string

+ TimeoutHeight clienttypes.Height

+ TimeoutTimestamp uint64

+ func (pi PacketInfo) Packet() chantypes.Packet

+ type PacketProof struct

+ Proof []byte

+ ProofHeight clienttypes.Height

type QueryProvider

+ BlockTime func(ctx context.Context, height int64) (time.Time, error)

+ QueryIBCHeader func(ctx context.Context, h int64) (IBCHeader, error)

+ QueryRecvPacket func(ctx context.Context, dstChanID, dstPortID string, sequence uint64) (PacketInfo, error)

+ QuerySendPacket func(ctx context.Context, srcChanID, srcPortID string, sequence uint64) (PacketInfo, error)

+ type RelayerEvent struct

+ Attributes map[string]string

+ EventType string

+ func (e RelayerEvent) MarshalLogObject(enc zapcore.ObjectEncoder) error

type RelayerMessage

+ MsgBytes func() ([]byte, error)

type RelayerTxResponse

+ func (r RelayerTxResponse) MarshalLogObject(enc zapcore.ObjectEncoder) error

+ type TimeoutHeightError struct

+ func NewTimeoutHeightError(latestHeight, timeoutHeight uint64) *TimeoutHeightError

+ func (t *TimeoutHeightError) Error() string

+ type TimeoutOnCloseError struct

+ func NewTimeoutOnCloseError(msg string) *TimeoutOnCloseError

+ func (t *TimeoutOnCloseError) Error() string

+ type TimeoutTimestampError struct

+ func NewTimeoutTimestampError(latestTimestamp, timeoutTimestamp uint64) *TimeoutTimestampError

+ func (t *TimeoutTimestampError) Error() string

Jan 5, 2022

Changes in this version

+ var RtyAtt = retry.Attempts(RtyAttNum)

+ var RtyAttNum = uint(5)

+ var RtyDel = retry.Delay(time.Millisecond * 400)

+ var RtyErr = retry.LastErrorOnly(true)

+ func MustGetHeight(h ibcexported.Height) clienttypes.Height

+ type ChainProvider interface

+ AcknowledgementFromSequence func(dst ChainProvider, dsth, seq uint64, ...) (RelayerMessage, error)

+ Address func() string

+ ChainId func() string

+ ChannelCloseConfirm func(dstQueryProvider QueryProvider, dsth int64, ...) (RelayerMessage, error)

+ ChannelCloseInit func(srcPortId, srcChanId string) RelayerMessage

+ ChannelOpenAck func(dstQueryProvider QueryProvider, dstHeader ibcexported.Header, ...) ([]RelayerMessage, error)

+ ChannelOpenConfirm func(dstQueryProvider QueryProvider, dstHeader ibcexported.Header, ...) ([]RelayerMessage, error)

+ ChannelOpenInit func(srcClientId, srcConnId, srcPortId, srcVersion, dstPortId string, ...) ([]RelayerMessage, error)

+ ChannelOpenTry func(dstQueryProvider QueryProvider, dstHeader ibcexported.Header, ...) ([]RelayerMessage, error)

+ ConnectionOpenAck func(dstQueryProvider QueryProvider, dstHeader ibcexported.Header, ...) ([]RelayerMessage, error)

+ ConnectionOpenConfirm func(dstQueryProvider QueryProvider, dstHeader ibcexported.Header, ...) ([]RelayerMessage, error)

+ ConnectionOpenInit func(srcClientId, dstClientId string, dstHeader ibcexported.Header) ([]RelayerMessage, error)

+ ConnectionOpenTry func(dstQueryProvider QueryProvider, dstHeader ibcexported.Header, ...) ([]RelayerMessage, error)

+ CreateClient func(clientState ibcexported.ClientState, dstHeader ibcexported.Header) (RelayerMessage, error)

+ GetIBCUpdateHeader func(srch int64, dst ChainProvider, dstClientId string) (ibcexported.Header, error)

+ GetLightSignedHeaderAtHeight func(h int64) (ibcexported.Header, error)

+ Init func() error

+ Key func() string

+ MsgRelayAcknowledgement func(dst ChainProvider, dstChanId, dstPortId, srcChanId, srcPortId string, ...) (RelayerMessage, error)

+ MsgRelayRecvPacket func(dst ChainProvider, dsth int64, packet RelayPacket, ...) (RelayerMessage, error)

+ MsgRelayTimeout func(dst ChainProvider, dsth int64, packet RelayPacket, ...) (RelayerMessage, error)

+ MsgTransfer func(amount sdk.Coin, dstChainId, dstAddr, srcPortId, srcChanId string, ...) RelayerMessage

+ MsgUpgradeClient func(srcClientId string, consRes *clienttypes.QueryConsensusStateResponse, ...) RelayerMessage

+ ProviderConfig func() ProviderConfig

+ RelayPacketFromSequence func(src, dst ChainProvider, srch, dsth, seq uint64, ...) (RelayerMessage, RelayerMessage, error)

+ SendMessage func(msg RelayerMessage) (*RelayerTxResponse, bool, error)

+ SendMessages func(msgs []RelayerMessage) (*RelayerTxResponse, bool, error)

+ SubmitMisbehavior func() (RelayerMessage, error)

+ Timeout func() string

+ TrustingPeriod func() string

+ Type func() string

+ UpdateClient func(srcClientId string, dstHeader ibcexported.Header) (RelayerMessage, error)

+ WaitForNBlocks func(n int64) error

+ type KeyOutput struct

+ Address string

+ Mnemonic string

+ type KeyProvider interface

+ AddKey func(name string) (output *KeyOutput, err error)

+ CreateKeystore func(path string) error

+ DeleteKey func(name string) error

+ ExportPrivKeyArmor func(keyName string) (armor string, err error)

+ KeyExists func(name string) bool

+ KeystoreCreated func(path string) bool

+ ListAddresses func() (map[string]string, error)

+ RestoreKey func(name, mnemonic string) (address string, err error)

+ ShowAddress func(name string) (address string, err error)

+ type ProviderConfig interface

+ NewProvider func(homepath string, debug bool) (ChainProvider, error)

+ Validate func() error

+ type QueryProvider interface

+ AutoUpdateClient func(dst ChainProvider, thresholdTime time.Duration, ...) (time.Duration, error)

+ FindMatchingClient func(counterparty ChainProvider, clientState ibcexported.ClientState) (string, bool)

+ GenerateConnHandshakeProof func(height int64, clientId, connId string) (clientState ibcexported.ClientState, clientStateProof []byte, ...)

+ NewClientState func(dstUpdateHeader ibcexported.Header, ...) (ibcexported.ClientState, error)

+ QueryBalance func(keyName string) (sdk.Coins, error)

+ QueryBalanceWithAddress func(addr string) (sdk.Coins, error)

+ QueryChannel func(height int64, channelid, portid string) (chanRes *chantypes.QueryChannelResponse, err error)

+ QueryChannelClient func(height int64, channelid, portid string) (*clienttypes.IdentifiedClientState, error)

+ QueryChannels func() ([]*chantypes.IdentifiedChannel, error)

+ QueryClientConsensusState func(chainHeight int64, clientid string, clientHeight ibcexported.Height) (*clienttypes.QueryConsensusStateResponse, error)

+ QueryClientState func(height int64, clientid string) (ibcexported.ClientState, error)

+ QueryClientStateResponse func(height int64, srcClientId string) (*clienttypes.QueryClientStateResponse, error)

+ QueryClients func() (clienttypes.IdentifiedClientStates, error)

+ QueryConnection func(height int64, connectionid string) (*conntypes.QueryConnectionResponse, error)

+ QueryConnectionChannels func(height int64, connectionid string) ([]*chantypes.IdentifiedChannel, error)

+ QueryConnections func() (conns []*conntypes.IdentifiedConnection, err error)

+ QueryConnectionsUsingClient func(height int64, clientid string) (*conntypes.QueryConnectionsResponse, error)

+ QueryConsensusState func(height int64) (ibcexported.ConsensusState, int64, error)

+ QueryDenomTrace func(denom string) (*transfertypes.DenomTrace, error)

+ QueryDenomTraces func(offset, limit uint64, height int64) ([]transfertypes.DenomTrace, error)

+ QueryHeaderAtHeight func(height int64) (ibcexported.Header, error)

+ QueryLatestHeight func() (int64, error)

+ QueryNextSeqRecv func(height int64, channelid, portid string) (recvRes *chantypes.QueryNextSequenceReceiveResponse, err error)

+ QueryPacketAcknowledgement func(height int64, channelid, portid string, seq uint64) (ackRes *chantypes.QueryPacketAcknowledgementResponse, err error)

+ QueryPacketAcknowledgements func(height uint64, channelid, portid string) (acknowledgements []*chantypes.PacketState, err error)

+ QueryPacketCommitment func(height int64, channelid, portid string, seq uint64) (comRes *chantypes.QueryPacketCommitmentResponse, err error)

+ QueryPacketCommitments func(height uint64, channelid, portid string) (commitments *chantypes.QueryPacketCommitmentsResponse, err error)

+ QueryPacketReceipt func(height int64, channelid, portid string, seq uint64) (recRes *chantypes.QueryPacketReceiptResponse, err error)

+ QueryTx func(hashHex string) (*ctypes.ResultTx, error)

+ QueryTxs func(page, limit int, events []string) ([]*ctypes.ResultTx, error)

+ QueryUnbondingPeriod func() (time.Duration, error)

+ QueryUnreceivedAcknowledgements func(height uint64, channelid, portid string, seqs []uint64) ([]uint64, error)

+ QueryUnreceivedPackets func(height uint64, channelid, portid string, seqs []uint64) ([]uint64, error)

+ QueryUpgradedClient func(height int64) (*clienttypes.QueryClientStateResponse, error)

+ QueryUpgradedConsState func(height int64) (*clienttypes.QueryConsensusStateResponse, error)

+ type RelayPacket interface

+ Data func() []byte

+ FetchCommitResponse func(dst ChainProvider, queryHeight uint64, dstChanId, dstPortId string) error

+ Msg func(src ChainProvider, srcPortId, srcChanId, dstPortId, dstChanId string) (RelayerMessage, error)

+ Seq func() uint64

+ Timeout func() clienttypes.Height

+ TimeoutStamp func() uint64

+ type RelayerMessage interface

+ Type func() string

+ type RelayerTxResponse struct

+ Code uint32

+ Data string

+ Events map[string]string

+ Height int64

+ TxHash string