core

Jan 31, 2024

Changes in this version

+ type OptimizeRelay struct

Jan 31, 2024

Changes in this version

+ var DefaultChainPrefix = commitmenttypes.NewMerklePrefix([]byte("ibc"))

Jan 30, 2024

Changes in this version

+ func SetCoreConfig(c ConfigI)

+ func SyncChainConfigFromEvents(pathName string, msgIDs []MsgID, chain *ProvableChain) error

+ func SyncChainConfigsFromEvents(pathName string, msgIDsSrc, msgIDsDst []MsgID, src, dst *ProvableChain) error

+ type ConfigI interface

+ UpdateConfigID func(pathName string, chainID string, configID ConfigIDType, id string) error

+ type ConfigIDType string

+ const ConfigIDChannel

+ const ConfigIDClient

+ const ConfigIDConnection

type RelayMsgs

+ DstMsgIDs []MsgID

+ SrcMsgIDs []MsgID

Jan 17, 2024

Changes in this version

type StateProver

+ ProveHostConsensusState func(ctx QueryContext, height exported.Height, ...) (proof []byte, err error)

Nov 21, 2023

Changes in this version

type LightClient

+ CreateInitialLightClientState func(height exported.Height) (exported.ClientState, exported.ConsensusState, error)

Nov 13, 2023

Changes in this version

type FinalityAware

+ GetFinalizedHeader func(height uint64) (Header, error)

Oct 31, 2023

Changes in this version

+ type ChainLightClient interface

+ type FinalityAware interface

+ GetLatestFinalizedHeader func() (latestFinalizedHeader Header, err error)

+ type FinalityAwareChain interface

Oct 26, 2023

Changes in this version

type LightClient

+ CheckRefreshRequired func(counterparty ChainInfoICS02Querier) (bool, error)

type NaiveStrategy

+ func (st *NaiveStrategy) Send(src, dst Chain, msgs *RelayMsgs)

+ func (st *NaiveStrategy) UpdateClients(src, dst *ProvableChain, rpForRecv, rpForAck *RelayPackets, sh SyncHeaders, ...) (*RelayMsgs, error)

type RelayMsgs

+ func (r *RelayMsgs) Merge(other *RelayMsgs)

type StrategyI

+ Send func(src, dst Chain, msgs *RelayMsgs)

+ UpdateClients func(src, dst *ProvableChain, rpForRecv, rpForAck *RelayPackets, sh SyncHeaders, ...) (*RelayMsgs, error)

Oct 16, 2023

Changes in this version

type MsgID

+ Is_MsgID func()

Oct 12, 2023

Changes in this version

type ChainConfig

+ Validate func() error

type ProverConfig

+ Validate func() error

Sep 23, 2023

Changes in this version

+ func GetChainLogger(chain ChainInfo) *log.RelayLogger

+ func SendCheckMsgs(chain Chain, msgs []types.Msg) bool

type Chain

+ GetMsgResult func(id MsgID) (MsgResult, error)

type ChainInfo

+ AverageBlockTime func() time.Duration

+ type EventAcknowledgePacket struct

+ Sequence uint64

+ SrcChannel string

+ SrcPort string

+ TimeoutHeight clienttypes.Height

+ TimeoutTimestamp time.Time

+ type EventGenerateChannelIdentifier struct

+ ID string

+ type EventGenerateClientIdentifier struct

+ ID string

+ type EventGenerateConnectionIdentifier struct

+ ID string

+ type EventRecvPacket struct

+ Data []byte

+ DstChannel string

+ DstPort string

+ Sequence uint64

+ TimeoutHeight clienttypes.Height

+ TimeoutTimestamp time.Time

+ type EventSendPacket struct

+ Data []byte

+ Sequence uint64

+ SrcChannel string

+ SrcPort string

+ TimeoutHeight clienttypes.Height

+ TimeoutTimestamp time.Time

+ type EventUnknown struct

+ Value any

+ type EventWriteAcknowledgement struct

+ Acknowledgement []byte

+ DstChannel string

+ DstPort string

+ Sequence uint64

+ type IsMsgID struct

+ func (IsMsgID) String() string

+ type MsgEventLog interface

+ type MsgID interface

+ type MsgResult interface

+ BlockHeight func() clienttypes.Height

+ Events func() []MsgEventLog

+ Status func() (bool, string)

+ func GetFinalizedMsgResult(chain ProvableChain, msgID MsgID) (MsgResult, error)

Sep 6, 2023

Changes in this version

+ func GetChainPairLogger(src, dst ChainInfo) *log.RelayLogger

+ func GetChannelLogger(c Chain) *log.RelayLogger

+ func GetChannelPairLogger(src, dst Chain) *log.RelayLogger

+ func GetClientPairLogger(src, dst Chain) *log.RelayLogger

+ func GetConnectionPairLogger(src, dst Chain) *log.RelayLogger

Aug 30, 2023

Changes in this version

type PacketInfoList

+ func (ps PacketInfoList) Subtract(seqs []uint64) PacketInfoList

Aug 25, 2023

Changes in this version

type ChainInfo

+ Timestamp func(ibcexported.Height) (time.Time, error)

Aug 16, 2023

Changes in this version

type Path

+ func (p *Path) ValidateStrategy() error

type StrategyCfg

+ DstNoack bool

+ SrcNoack bool

Jul 11, 2023

Changes in this version

type ICS04Querier

+ QueryUnfinalizedRelayAcknowledgements func(ctx QueryContext, counterparty LightClientICS04Querier) (PacketInfoList, error)

+ QueryUnfinalizedRelayPackets func(ctx QueryContext, counterparty LightClientICS04Querier) (PacketInfoList, error)

+ QueryUnreceivedAcknowledgements func(ctx QueryContext, seqs []uint64) ([]uint64, error)

+ QueryUnreceivedPackets func(ctx QueryContext, seqs []uint64) ([]uint64, error)

+ type LightClientICS04Querier interface

type NaiveStrategy

+ func (st NaiveStrategy) UnrelayedPackets(src, dst *ProvableChain, sh SyncHeaders) (*RelayPackets, error)

+ type PacketInfo struct

+ Acknowledgement []byte

+ EventHeight clienttypes.Height

+ type PacketInfoList []*PacketInfo

+ func (ps PacketInfoList) ExtractSequenceList() []uint64

+ func (ps PacketInfoList) Filter(seqs []uint64) PacketInfoList

+ type RelayPackets struct

+ Dst PacketInfoList

+ Src PacketInfoList

+ type StateProver interface

+ ProveState func(ctx QueryContext, path string, value []byte) (proof []byte, proofHeight clienttypes.Height, err error)

type StrategyI

+ UnrelayedPackets func(src, dst *ProvableChain, sh SyncHeaders) (*RelayPackets, error)

May 26, 2023

Changes in this version

type Header

+ GetHeight func() exported.Height

Mar 20, 2023

Changes in this version

+ type Chain interface

+ Codec func() codec.ProtoCodecMarshaler

+ GetAddress func() (sdk.AccAddress, error)

+ Init func(homePath string, timeout time.Duration, codec codec.ProtoCodecMarshaler, ...) error

+ Path func() *PathEnd

+ RegisterMsgEventListener func(MsgEventListener)

+ Send func(msgs []sdk.Msg) bool

+ SendMsgs func(msgs []sdk.Msg) ([]byte, error)

+ SetRelayInfo func(path *PathEnd, counterparty *ProvableChain, counterpartyPath *PathEnd) error

+ SetupForRelay func(ctx context.Context) error

+ type ChainConfig interface

+ Build func() (Chain, error)

+ type ChainICS02QuerierLightClient interface

+ type ChainInfo interface

+ ChainID func() string

+ LatestHeight func() (ibcexported.Height, error)

+ type ChainInfoICS02Querier interface

+ type ChainInfoLightClient interface

+ type Header interface

+ type IBCProvableQuerier interface

+ QueryChannelWithProof func(ctx QueryContext) (chanRes *chantypes.QueryChannelResponse, err error)

+ QueryClientConsensusStateWithProof func(ctx QueryContext, dstClientConsHeight ibcexported.Height) (*clienttypes.QueryConsensusStateResponse, error)

+ QueryClientStateWithProof func(ctx QueryContext) (*clienttypes.QueryClientStateResponse, error)

+ QueryConnectionWithProof func(ctx QueryContext) (*conntypes.QueryConnectionResponse, error)

+ QueryPacketAcknowledgementCommitmentWithProof func(ctx QueryContext, seq uint64) (ackRes *chantypes.QueryPacketAcknowledgementResponse, err error)

+ QueryPacketCommitmentWithProof func(ctx QueryContext, seq uint64) (comRes *chantypes.QueryPacketCommitmentResponse, err error)

+ type IBCQuerier interface

+ type ICS02Querier interface

+ QueryClientConsensusState func(ctx QueryContext, dstClientConsHeight ibcexported.Height) (*clienttypes.QueryConsensusStateResponse, error)

+ QueryClientState func(ctx QueryContext) (*clienttypes.QueryClientStateResponse, error)

+ type ICS03Querier interface

+ QueryConnection func(ctx QueryContext) (*conntypes.QueryConnectionResponse, error)

+ type ICS04Querier interface

+ QueryChannel func(ctx QueryContext) (chanRes *chantypes.QueryChannelResponse, err error)

+ QueryPacket func(ctx QueryContext, sequence uint64) (*chantypes.Packet, error)

+ QueryPacketAcknowledgement func(ctx QueryContext, sequence uint64) ([]byte, error)

+ QueryPacketAcknowledgementCommitment func(ctx QueryContext, seq uint64) (ackRes *chantypes.QueryPacketAcknowledgementResponse, err error)

+ QueryPacketAcknowledgementCommitments func(ctx QueryContext, offset, limit uint64) (comRes *chantypes.QueryPacketAcknowledgementsResponse, err error)

+ QueryPacketCommitment func(ctx QueryContext, seq uint64) (comRes *chantypes.QueryPacketCommitmentResponse, err error)

+ QueryPacketCommitments func(ctx QueryContext, offset, limit uint64) (comRes *chantypes.QueryPacketCommitmentsResponse, err error)

+ QueryUnrecievedAcknowledgements func(ctx QueryContext, seqs []uint64) ([]uint64, error)

+ QueryUnrecievedPackets func(ctx QueryContext, seqs []uint64) ([]uint64, error)

+ type ICS20Querier interface

+ QueryBalance func(ctx QueryContext, address sdk.AccAddress) (sdk.Coins, error)

+ QueryDenomTraces func(ctx QueryContext, offset, limit uint64) (*transfertypes.QueryDenomTracesResponse, error)

+ type LightClient interface

+ CreateMsgCreateClient func(clientID string, dstHeader Header, signer sdk.AccAddress) (*clienttypes.MsgCreateClient, error)

+ GetLatestFinalizedHeader func() (latestFinalizedHeader Header, err error)

+ SetupHeadersForUpdate func(dstChain ChainInfoICS02Querier, latestFinalizedHeader Header) ([]Header, error)

type PathEnd

+ func (pe *PathEnd) UpdateClients(dstHeaders []Header, signer sdk.AccAddress) []sdk.Msg

+ type Prover interface

+ Init func(homePath string, timeout time.Duration, codec codec.ProtoCodecMarshaler, ...) error

+ SetRelayInfo func(path *PathEnd, counterparty *ProvableChain, counterpartyPath *PathEnd) error

+ SetupForRelay func(ctx context.Context) error

+ type ProverConfig interface

+ Build func(Chain) (Prover, error)

+ type QueryContext interface

+ Context func() context.Context

+ Height func() ibcexported.Height

+ func NewQueryContext(ctx context.Context, height ibcexported.Height) QueryContext

+ type SyncHeaders interface

+ GetLatestFinalizedHeader func(chainID string) Header

+ GetQueryContext func(chainID string) QueryContext

+ SetupBothHeadersForUpdate func(src, dst ChainICS02QuerierLightClient) (srcHeaders []Header, dstHeaders []Header, err error)

+ SetupHeadersForUpdate func(src, dst ChainICS02QuerierLightClient) ([]Header, error)

+ Updates func(src, dst ChainInfoLightClient) error

Nov 16, 2022

Changes in this version

type LightClientI

+ QueryHeader func(height int64) (out HeaderI, err error)

Jul 27, 2022

Changes in this version

type ChainI

+ RegisterMsgEventListener func(MsgEventListener)

+ SetRelayInfo func(path *PathEnd, counterparty *ProvableChain, counterpartyPath *PathEnd) error

+ SetupForRelay func(ctx context.Context) error

+ type MsgEventListener interface

+ OnSentMsg func(msgs []sdk.Msg) error

type NaiveStrategy

+ func (st NaiveStrategy) SetupRelay(ctx context.Context, src, dst *ProvableChain) error

type ProvableChain

+ func (pc *ProvableChain) Init(homePath string, timeout time.Duration, codec codec.ProtoCodecMarshaler, ...) error

+ func (pc *ProvableChain) SetRelayInfo(path *PathEnd, counterparty *ProvableChain, counterpartyPath *PathEnd) error

+ func (pc *ProvableChain) SetupForRelay(ctx context.Context) error

type ProverI

+ Init func(homePath string, timeout time.Duration, codec codec.ProtoCodecMarshaler, ...) error

+ SetRelayInfo func(path *PathEnd, counterparty *ProvableChain, counterpartyPath *PathEnd) error

+ SetupForRelay func(ctx context.Context) error

type StrategyI

+ SetupRelay func(ctx context.Context, src, dst *ProvableChain) error

Dec 9, 2021

Changes in this version

+ const DefaultDelayPeriod

+ func MakeCodec() codec.ProtoCodecMarshaler

+ func StartService(ctx context.Context, st StrategyI, src, dst *ProvableChain, ...) error

+ func UpdateClients(src, dst *ProvableChain) error

type ChainConfigI

+ Build func() (ChainI, error)

type ChainI

+ Codec func() codec.ProtoCodecMarshaler

+ GetLatestHeight func() (int64, error)

+ type ChainProverConfig struct

+ Chain json.RawMessage

+ Prover json.RawMessage

+ func NewChainProverConfig(m codec.JSONCodec, chain ChainConfigI, client ProverConfigI) (*ChainProverConfig, error)

+ func (cc *ChainProverConfig) Init(m codec.Codec) error

+ func (cc ChainProverConfig) Build() (*ProvableChain, error)

+ func (cc ChainProverConfig) GetChainConfig() (ChainConfigI, error)

+ func (cc ChainProverConfig) GetProverConfig() (ProverConfigI, error)

+ type IBCProvableQuerierI interface

+ QueryChannelWithProof func(height int64) (chanRes *chantypes.QueryChannelResponse, err error)

+ QueryClientConsensusStateWithProof func(height int64, dstClientConsHeight ibcexported.Height) (*clienttypes.QueryConsensusStateResponse, error)

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

+ QueryConnectionWithProof func(height int64) (*conntypes.QueryConnectionResponse, error)

+ QueryPacketAcknowledgementCommitmentWithProof func(height int64, seq uint64) (ackRes *chantypes.QueryPacketAcknowledgementResponse, err error)

+ QueryPacketCommitmentWithProof func(height int64, seq uint64) (comRes *chantypes.QueryPacketCommitmentResponse, err error)

+ type IBCQuerierI interface

+ QueryBalance func(address sdk.AccAddress) (sdk.Coins, error)

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

+ QueryClientConsensusState func(height int64, dstClientConsHeight ibcexported.Height) (*clienttypes.QueryConsensusStateResponse, error)

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

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

+ QueryDenomTraces func(offset, limit uint64, height int64) (*transfertypes.QueryDenomTracesResponse, error)

+ QueryPacket func(height int64, sequence uint64) (*chantypes.Packet, error)

+ QueryPacketAcknowledgement func(height int64, sequence uint64) ([]byte, error)

+ QueryPacketAcknowledgementCommitment func(height int64, seq uint64) (ackRes *chantypes.QueryPacketAcknowledgementResponse, err error)

+ QueryPacketAcknowledgementCommitments func(offset, limit uint64, height int64) (comRes *chantypes.QueryPacketAcknowledgementsResponse, err error)

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

+ QueryPacketCommitments func(offset, limit uint64, height int64) (comRes *chantypes.QueryPacketCommitmentsResponse, err error)

+ QueryUnrecievedAcknowledgements func(height int64, seqs []uint64) ([]uint64, error)

+ QueryUnrecievedPackets func(height int64, seqs []uint64) ([]uint64, error)

+ type LightClientI interface

+ CreateMsgCreateClient func(clientID string, dstHeader HeaderI, signer sdk.AccAddress) (*clienttypes.MsgCreateClient, error)

+ GetChainID func() string

+ GetLatestLightHeight func() (int64, error)

+ QueryLatestHeader func() (out HeaderI, err error)

+ SetupHeader func(dst LightClientIBCQueryierI, baseSrcHeader HeaderI) (HeaderI, error)

+ UpdateLightWithHeader func() (header HeaderI, provableHeight int64, queryableHeight int64, err error)

+ type LightClientIBCQueryierI interface

+ type ProvableChain struct

+ func NewProvableChain(chain ChainI, prover ProverI) *ProvableChain

+ type ProverConfigI interface

+ Build func(ChainI) (ProverI, error)

+ type ProverI interface

+ type RelayService struct

+ func NewRelayService(st StrategyI, src, dst *ProvableChain, sh SyncHeadersI, interval time.Duration) *RelayService

+ func (srv *RelayService) Serve(ctx context.Context) error

+ func (srv *RelayService) Start(ctx context.Context) error

type SyncHeadersI

+ GetHeaders func(src, dst LightClientIBCQueryierI) (srcHeader HeaderI, dstHeader HeaderI, err error)

+ GetProvableHeight func(chainID string) int64

+ GetQueryableHeight func(chainID string) int64

Jul 2, 2021

Changes in this version

+ func CreateChannel(src, dst ChainI, ordered bool, to time.Duration) error

+ func CreateClients(src, dst ChainI) error

+ func CreateConnection(src, dst ChainI, to time.Duration) error

+ func FindPacketAcknowledgementFromEventsBySequence(events []abci.Event, seq uint64) (*packetAcknowledgement, error)

+ func FindPacketFromEventsBySequence(events []abci.Event, seq uint64) (*channeltypes.Packet, error)

+ func GetPacketAcknowledgementsFromEvents(events []abci.Event) ([]packetAcknowledgement, error)

+ func GetPacketsFromEvents(events []abci.Event) ([]channeltypes.Packet, error)

+ func MakeEncodingConfig() simappparams.EncodingConfig

+ func OrderFromString(order string) chantypes.Order

+ func QueryChannelPair(src, dst ChainI, srcH, dstH int64) (srcChan, dstChan *chantypes.QueryChannelResponse, err error)

+ func QueryClientConsensusStatePair(src, dst ChainI, srch, dsth int64, ...) (srcCsRes, dstCsRes *clienttypes.QueryConsensusStateResponse, err error)

+ func QueryClientStatePair(src, dst ChainI, srch, dsth int64) (srcCsRes, dstCsRes *clienttypes.QueryClientStateResponse, err error)

+ func QueryConnectionPair(src, dst ChainI, srcH, dstH int64) (srcConn, dstConn *conntypes.QueryConnectionResponse, err error)

+ func RandLowerCaseLetterString(length int) string

+ func RunStrategy(src, dst ChainI, strategy StrategyI) (func(), error)

+ func SendTransferMsg(src, dst ChainI, amount sdk.Coin, dstAddr fmt.Stringer, toHeightOffset uint64, ...) error

+ type ChainConfigI interface

+ GetChain func() ChainI

+ type ChainI interface

+ ChainID func() string

+ ClientID func() string

+ ClientType func() string

+ CreateTrustedHeader func(dstChain ChainI, srcHeader HeaderI) (HeaderI, error)

+ GetAddress func() (sdk.AccAddress, error)

+ GetLatestLightHeight func() (int64, error)

+ Init func(homePath string, timeout time.Duration, debug bool) error

+ MakeMsgCreateClient func(clientID string, dstHeader HeaderI, signer sdk.AccAddress) (sdk.Msg, error)

+ Marshaler func() codec.Marshaler

+ Path func() *PathEnd

+ QueryBalance func(address sdk.AccAddress) (sdk.Coins, error)

+ QueryChannel func(height int64, prove bool) (chanRes *chantypes.QueryChannelResponse, err error)

+ QueryClientConsensusState func(height int64, dstClientConsHeight ibcexported.Height, prove bool) (*clienttypes.QueryConsensusStateResponse, error)

+ QueryClientState func(height int64, prove bool) (*clienttypes.QueryClientStateResponse, error)

+ QueryConnection func(height int64, prove bool) (*conntypes.QueryConnectionResponse, error)

+ QueryDenomTraces func(offset, limit uint64, height int64) (*transfertypes.QueryDenomTracesResponse, error)

+ QueryLatestHeader func() (out HeaderI, err error)

+ QueryLatestHeight func() (int64, error)

+ QueryPacket func(height int64, sequence uint64) (*chantypes.Packet, error)

+ QueryPacketAcknowledgement func(height int64, sequence uint64) ([]byte, error)

+ QueryPacketAcknowledgementCommitment func(height int64, seq uint64) (ackRes *chantypes.QueryPacketAcknowledgementResponse, err error)

+ QueryPacketAcknowledgements func(offset, limit, height uint64) (comRes *chantypes.QueryPacketAcknowledgementsResponse, err error)

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

+ QueryPacketCommitments func(offset, limit, height uint64) (comRes *chantypes.QueryPacketCommitmentsResponse, err error)

+ QueryUnrecievedAcknowledgements func(height uint64, seqs []uint64) ([]uint64, error)

+ QueryUnrecievedPackets func(height uint64, seqs []uint64) ([]uint64, error)

+ Send func(msgs []sdk.Msg) bool

+ SendMsgs func(msgs []sdk.Msg) ([]byte, error)

+ SetPath func(p *PathEnd) error

+ StartEventListener func(dst ChainI, strategy StrategyI)

+ Update func(key, value string) (ChainConfigI, error)

+ UpdateLightWithHeader func() (HeaderI, error)

+ type HeaderI interface

+ func UpdatesWithHeaders(src, dst ChainI) (srch, dsth HeaderI, err error)

+ type NaiveStrategy struct

+ MaxMsgLength uint64

+ MaxTxSize uint64

+ Ordered bool

+ func NewNaiveStrategy() *NaiveStrategy

+ func (st NaiveStrategy) GetType() string

+ func (st NaiveStrategy) RelayAcknowledgements(src, dst ChainI, sp *RelaySequences, sh SyncHeadersI) error

+ func (st NaiveStrategy) RelayPackets(src, dst ChainI, sp *RelaySequences, sh SyncHeadersI) error

+ func (st NaiveStrategy) UnrelayedAcknowledgements(src, dst ChainI, sh SyncHeadersI) (*RelaySequences, error)

+ func (st NaiveStrategy) UnrelayedSequences(src, dst ChainI, sh SyncHeadersI) (*RelaySequences, error)

+ type Path struct

+ Dst *PathEnd

+ Src *PathEnd

+ Strategy *StrategyCfg

+ func GenPath(srcChainID, dstChainID, srcPortID, dstPortID, order string, version string) *Path

+ func (p *Path) End(chainID string) *PathEnd

+ func (p *Path) GenDstChanID()

+ func (p *Path) GenDstClientID()

+ func (p *Path) GenDstConnID()

+ func (p *Path) GenSrcChanID()

+ func (p *Path) GenSrcClientID()

+ func (p *Path) GenSrcConnID()

+ func (p *Path) GetStrategy() (StrategyI, error)

+ func (p *Path) MustYAML() string

+ func (p *Path) Ordered() bool

+ func (p *Path) QueryPathStatus(src, dst ChainI) *PathWithStatus

+ func (p *Path) String() string

+ func (p *Path) Validate() (err error)

+ type PathAction struct

+ Type string

+ type PathEnd struct

+ ChainID string

+ ChannelID string

+ ClientID string

+ ConnectionID string

+ Order string

+ PortID string

+ Version string

+ func (pe *PathEnd) ChanAck(dst *PathEnd, dstChanState *chantypes.QueryChannelResponse, ...) sdk.Msg

+ func (pe *PathEnd) ChanCloseConfirm(dstChanState *chantypes.QueryChannelResponse, signer sdk.AccAddress) sdk.Msg

+ func (pe *PathEnd) ChanCloseInit(signer sdk.AccAddress) sdk.Msg

+ func (pe *PathEnd) ChanConfirm(dstChanState *chantypes.QueryChannelResponse, signer sdk.AccAddress) sdk.Msg

+ func (pe *PathEnd) ChanInit(dst *PathEnd, signer sdk.AccAddress) sdk.Msg

+ func (pe *PathEnd) ChanTry(dst *PathEnd, dstChanState *chantypes.QueryChannelResponse, ...) sdk.Msg

+ func (pe *PathEnd) ConnAck(dst *PathEnd, dstClientState *clienttypes.QueryClientStateResponse, ...) sdk.Msg

+ func (pe *PathEnd) ConnConfirm(dstConnState *conntypes.QueryConnectionResponse, signer sdk.AccAddress) sdk.Msg

+ func (pe *PathEnd) ConnInit(dst *PathEnd, signer sdk.AccAddress) sdk.Msg

+ func (pe *PathEnd) ConnTry(dst *PathEnd, dstClientState *clienttypes.QueryClientStateResponse, ...) sdk.Msg

+ func (pe *PathEnd) CreateClient(dstHeader *tmclient.Header, trustingPeriod, unbondingPeriod time.Duration, ...) sdk.Msg

+ func (pe *PathEnd) GetOrder() chantypes.Order

+ func (pe *PathEnd) MsgTransfer(dst *PathEnd, amount sdk.Coin, dstAddr string, signer sdk.AccAddress, ...) sdk.Msg

+ func (pe *PathEnd) NewPacket(dst *PathEnd, sequence uint64, packetData []byte, ...) chantypes.Packet

+ func (pe *PathEnd) UpdateClient(dstHeader ibcexported.Header, signer sdk.AccAddress) sdk.Msg

+ func (pe *PathEnd) Validate() error

+ func (pe *PathEnd) Vchan() error

+ func (pe *PathEnd) Vclient() error

+ func (pe *PathEnd) Vconn() error

+ func (pe *PathEnd) Vport() error

+ func (pe *PathEnd) Vversion() error

+ func (pe *PathEnd) XferPacket(amount sdk.Coin, sender, receiver string) []byte

+ func (pe PathEnd) String() string

+ type PathStatus struct

+ Chains bool

+ Channel bool

+ Clients bool

+ Connection bool

+ type PathWithStatus struct

+ Path *Path

+ Status PathStatus

+ func (ps *PathWithStatus) PrintString(name string) string

+ type Paths map[string]*Path

+ func (p Paths) Add(name string, path *Path) error

+ func (p Paths) AddForce(name string, path *Path) error

+ func (p Paths) Get(name string) (path *Path, err error)

+ func (p Paths) MustGet(name string) *Path

+ func (p Paths) MustYAML() string

+ func (p Paths) PathsFromChains(src, dst string) (Paths, error)

+ type RelayMsgs struct

+ Dst []sdk.Msg

+ Last bool

+ MaxMsgLength uint64

+ MaxTxSize uint64

+ Src []sdk.Msg

+ Succeeded bool

+ func NewRelayMsgs() *RelayMsgs

+ func (r *RelayMsgs) IsMaxTx(msgLen, txSize uint64) bool

+ func (r *RelayMsgs) Ready() bool

+ func (r *RelayMsgs) Send(src, dst ChainI)

+ func (r *RelayMsgs) Success() bool

+ type RelaySequences struct

+ Dst []uint64

+ Src []uint64

+ type StrategyCfg struct

+ Type string

+ type StrategyI interface

+ GetType func() string

+ RelayAcknowledgements func(src, dst ChainI, sp *RelaySequences, sh SyncHeadersI) error

+ RelayPackets func(src, dst ChainI, sp *RelaySequences, sh SyncHeadersI) error

+ UnrelayedAcknowledgements func(src, dst ChainI, sh SyncHeadersI) (*RelaySequences, error)

+ UnrelayedSequences func(src, dst ChainI, sh SyncHeadersI) (*RelaySequences, error)

+ func GetStrategy(cfg StrategyCfg) (StrategyI, error)

+ type SyncHeadersI interface

+ GetHeader func(chainID string) HeaderI

+ GetHeight func(chainID string) uint64

+ GetTrustedHeaders func(src, dst ChainI) (srcHeader HeaderI, dstHeader HeaderI, err error)

+ Updates func(ChainI, ChainI) error

+ func NewSyncHeaders(src, dst ChainI) (SyncHeadersI, error)