Versions in this module Expand all Collapse all v0 v0.1.1 May 14, 2023 Changes in this version + const ChainIDPrefix + const DefaultChannelVersion + const DefaultDelayPeriod + const Description + const FirstChannelID + const FirstClientID + const FirstConnectionID + const InvalidID + const LongString + const MaxClockDrift + const MockFeePort + const MockPort + const Title + const TransferPort + const TrustingPeriod + const UnbondingPeriod + var ConnectionVersion = connectiontypes.ExportedVersionsToProto(connectiontypes.GetCompatibleVersions())[0] + var DefaultOpenInitVersion *connectiontypes.Version + var DefaultTestingAppInit func() (TestingApp, map[string]json.RawMessage) = SetupTestingApp + var DefaultTrustLevel ibctmtypes.Fraction = ibctmtypes.DefaultTrustLevel + var MaxAccounts = 10 + var MockAcknowledgement = mock.MockAcknowledgement.Acknowledgement() + var MockFailPacketData = mock.MockFailPacketData + var MockPacketData = mock.MockPacketData + var MockRecvCanaryCapabilityName = mock.MockRecvCanaryCapabilityName + var TestCoin = sdk.NewCoin(sdk.DefaultBondDenom, sdk.NewInt(100)) + var TimeIncrement = time.Second * 5 + var UpgradePath = []string + func CreateSortedSignerArray(altPrivVal, suitePrivVal tmtypes.PrivValidator, ...) []tmtypes.PrivValidator + func GenerateKeys(t *testing.T, n uint64) ([]crypto.PrivKey, []crypto.PubKey, crypto.PubKey) + func GetChainID(index int) string + func GetFURYChainID(index int) string + func GetMockRecvCanaryCapabilityName(packet channeltypes.Packet) string + func MakeBlockID(hash []byte, partSetSize uint32, partSetHash []byte) tmtypes.BlockID + func ParseAckFromEvents(events sdk.Events) ([]byte, error) + func ParseChannelIDFromEvents(events sdk.Events) (string, error) + func ParseClientIDFromEvents(events sdk.Events) (string, error) + func ParseConnectionIDFromEvents(events sdk.Events) (string, error) + func ParsePacketFromEvents(events sdk.Events) (channeltypes.Packet, error) + type ChannelConfig struct + Order channeltypes.Order + PortID string + Version string + func NewChannelConfig() *ChannelConfig + type ClientConfig interface + GetClientType func() string + type ConnectionConfig struct + DelayPeriod uint64 + Version *connectiontypes.Version + func NewConnectionConfig() *ConnectionConfig + type Coordinator struct + Chains map[string]TestChainI + CurrentTime time.Time + func NewCoordinator(t *testing.T, n int) *Coordinator + func NewEthCoordinator(t *testing.T, n int) *Coordinator + func (coord *Coordinator) ChanOpenInitOnBothChains(path *Path) error + func (coord *Coordinator) CommitBlock(chains ...TestChainI) + func (coord *Coordinator) CommitNBlocks(chain TestChainI, n uint64) + func (coord *Coordinator) ConnOpenInitOnBothChains(path *Path) error + func (coord *Coordinator) CreateChannels(path *Path) + func (coord *Coordinator) CreateConnections(path *Path) + func (coord *Coordinator) CreateMockChannels(path *Path) + func (coord *Coordinator) CreateTransferChannels(path *Path) + func (coord *Coordinator) GetChain(chainID string) TestChainI + func (coord *Coordinator) IncrementTime() + func (coord *Coordinator) IncrementTimeBy(increment time.Duration) + func (coord *Coordinator) Setup(path *Path) + func (coord *Coordinator) SetupClients(path *Path) + func (coord *Coordinator) SetupConnections(path *Path) + func (coord *Coordinator) UpdateNextBlock(chains ...TestChainI) + func (coord *Coordinator) UpdateTime() + func (coord *Coordinator) UpdateTimeForChain(chain TestChainI) + type Endpoint struct + Chain TestChainI + ChannelConfig *ChannelConfig + ChannelID string + ClientConfig ClientConfig + ClientID string + ConnectionConfig *ConnectionConfig + ConnectionID string + Counterparty *Endpoint + func NewDefaultEndpoint(chain TestChainI) *Endpoint + func NewEndpoint(chain TestChainI, clientConfig ClientConfig, ...) *Endpoint + func (endpoint *Endpoint) AcknowledgePacket(packet channeltypes.Packet, ack []byte) error + func (endpoint *Endpoint) ChanCloseInit() error + func (endpoint *Endpoint) ChanOpenAck() error + func (endpoint *Endpoint) ChanOpenConfirm() error + func (endpoint *Endpoint) ChanOpenInit() error + func (endpoint *Endpoint) ChanOpenTry() error + func (endpoint *Endpoint) ConnOpenAck() error + func (endpoint *Endpoint) ConnOpenConfirm() error + func (endpoint *Endpoint) ConnOpenInit() error + func (endpoint *Endpoint) ConnOpenTry() error + func (endpoint *Endpoint) CreateClient() (err error) + func (endpoint *Endpoint) GetChannel() channeltypes.Channel + func (endpoint *Endpoint) GetClientState() exported.ClientState + func (endpoint *Endpoint) GetConnection() connectiontypes.ConnectionEnd + func (endpoint *Endpoint) GetConsensusState(height exported.Height) exported.ConsensusState + func (endpoint *Endpoint) QueryClientStateProof() (exported.ClientState, []byte) + func (endpoint *Endpoint) QueryConnectionHandshakeProof() (clientState exported.ClientState, proofClient, proofConsensus []byte, ...) + func (endpoint *Endpoint) QueryProof(key []byte) ([]byte, clienttypes.Height) + func (endpoint *Endpoint) QueryProofAtHeight(key []byte, height uint64) ([]byte, clienttypes.Height) + func (endpoint *Endpoint) RecvPacket(packet channeltypes.Packet) error + func (endpoint *Endpoint) RecvPacketWithResult(packet channeltypes.Packet) (*sdk.Result, error) + func (endpoint *Endpoint) SendPacket(packet exported.PacketI) error + func (endpoint *Endpoint) SetChannel(channel channeltypes.Channel) + func (endpoint *Endpoint) SetChannelClosed() error + func (endpoint *Endpoint) SetClientState(clientState exported.ClientState) + func (endpoint *Endpoint) SetConnection(connection connectiontypes.ConnectionEnd) + func (endpoint *Endpoint) SetConsensusState(consensusState exported.ConsensusState, height exported.Height) + func (endpoint *Endpoint) TimeoutPacket(packet channeltypes.Packet) error + func (endpoint *Endpoint) UpdateClient() (err error) + func (endpoint *Endpoint) WriteAcknowledgement(ack exported.Acknowledgement, packet exported.PacketI) error + type Path struct + EndpointA *Endpoint + EndpointB *Endpoint + func NewPath(chainA, chainB TestChainI) *Path + func (path *Path) RelayPacket(packet channeltypes.Packet, ack []byte) error + func (path *Path) RelayPacketV4(packet channeltypes.Packet) error + func (path *Path) SetChannelOrdered() + type SenderAccount struct + SenderAccount auth.Account + SenderPrivKey crypto.PrivKey + type Solomachine struct + ClientID string + Diversifier string + PrivateKeys []crypto.PrivKey + PublicKey crypto.PubKey + PublicKeys []crypto.PubKey + Sequence uint64 + Time uint64 + func NewSolomachine(t *testing.T, cdc *codec.CodecProxy, clientID, diversifier string, ...) *Solomachine + func (solo *Solomachine) ClientState() *solomachinetypes.ClientState + func (solo *Solomachine) ConsensusState() *solomachinetypes.ConsensusState + func (solo *Solomachine) CreateHeader() *solomachinetypes.Header + func (solo *Solomachine) CreateMisbehaviour() *solomachinetypes.Misbehaviour + func (solo *Solomachine) GenerateSignature(signBytes []byte) []byte + func (solo *Solomachine) GetChannelStatePath(portID, channelID string) commitmenttypes.MerklePath + func (solo *Solomachine) GetClientStatePath(counterpartyClientIdentifier string) commitmenttypes.MerklePath + func (solo *Solomachine) GetConnectionStatePath(connID string) commitmenttypes.MerklePath + func (solo *Solomachine) GetConsensusStatePath(counterpartyClientIdentifier string, consensusHeight exported.Height) commitmenttypes.MerklePath + func (solo *Solomachine) GetHeight() exported.Height + func (solo *Solomachine) GetNextSequenceRecvPath(portID, channelID string) commitmenttypes.MerklePath + func (solo *Solomachine) GetPacketAcknowledgementPath(portID, channelID string) commitmenttypes.MerklePath + func (solo *Solomachine) GetPacketCommitmentPath(portID, channelID string) commitmenttypes.MerklePath + func (solo *Solomachine) GetPacketReceiptPath(portID, channelID string) commitmenttypes.MerklePath + type TendermintConfig struct + AllowUpdateAfterExpiry bool + AllowUpdateAfterMisbehaviour bool + MaxClockDrift time.Duration + TrustLevel ibctmtypes.Fraction + TrustingPeriod time.Duration + UnbondingPeriod time.Duration + func NewTendermintConfig() *TendermintConfig + func (tmcfg *TendermintConfig) GetClientType() string + type TestChain struct + TApp TestingApp + func NewTestEthChain(t *testing.T, coord *Coordinator, chainID string) *TestChain + func (chain *TestChain) App() TestingApp + func (chain *TestChain) BeginBlock() + func (chain *TestChain) ChainID() string + func (chain *TestChain) Codec() *codec.CodecProxy + func (chain *TestChain) ConstructUpdateTMClientHeader(counterparty TestChainI, clientID string) (*ibctmtypes.Header, error) + func (chain *TestChain) ConstructUpdateTMClientHeaderWithTrustedHeight(counterparty TestChainI, clientID string, trustedHeight clienttypes.Height) (*ibctmtypes.Header, error) + func (chain *TestChain) Coordinator() *Coordinator + func (chain *TestChain) CreateChannelCapability(scopedKeeper capabilitykeeper.ScopedKeeper, portID, channelID string) + func (chain *TestChain) CreatePortCapability(scopedKeeper capabilitykeeper.ScopedKeeper, portID string) + func (chain *TestChain) CreateTMClientHeader(chainID string, blockHeight int64, trustedHeight clienttypes.Height, ...) *ibctmtypes.Header + func (chain *TestChain) CurrentHeader() tmproto.Header + func (chain *TestChain) CurrentHeaderTime(t time.Time) + func (chain *TestChain) CurrentTMClientHeader() *ibctmtypes.Header + func (chain *TestChain) ExpireClient(amount time.Duration) + func (chain *TestChain) GetAcknowledgement(packet exported.PacketI) []byte + func (chain *TestChain) GetChannelCapability(portID, channelID string) *capabilitytypes.Capability + func (chain *TestChain) GetClientState(clientID string) exported.ClientState + func (chain *TestChain) GetConsensusState(clientID string, height exported.Height) (exported.ConsensusState, bool) + func (chain *TestChain) GetContext() sdk.Context + func (chain *TestChain) GetContextPointer() *sdk.Context + func (chain *TestChain) GetPortCapability(portID string) *capabilitytypes.Capability + func (chain *TestChain) GetPrefix() commitmenttypes.MerklePrefix + func (chain *TestChain) GetSimApp() *simapp.SimApp + func (chain *TestChain) GetValsAtHeight(height int64) (*tmtypes.ValidatorSet, bool) + func (chain *TestChain) LastHeader() *ibctmtypes.Header + func (chain *TestChain) NextBlock() + func (chain *TestChain) QueryConsensusStateProof(clientID string) ([]byte, clienttypes.Height) + func (chain *TestChain) QueryProof(key []byte) ([]byte, clienttypes.Height) + func (chain *TestChain) QueryProofAtHeight(key []byte, height int64) ([]byte, clienttypes.Height) + func (chain *TestChain) QueryServer() types.QueryService + func (chain *TestChain) QueryUpgradeProof(key []byte, height uint64) ([]byte, clienttypes.Height) + func (chain *TestChain) SendMsgs(msgs ...ibcmsg.Msg) (*sdk.Result, error) + func (chain *TestChain) SenderAccount() sdk.Account + func (chain *TestChain) SenderAccountPV() crypto.PrivKey + func (chain *TestChain) SenderAccountPVBZ() []byte + func (chain *TestChain) SenderAccounts() []SenderAccount + func (chain *TestChain) SetCurrentHeader(h tmproto.Header) + func (chain *TestChain) SetLastHeader(lh *ibctmtypes.Header) + func (chain *TestChain) Signers() []tmtypes.PrivValidator + func (chain *TestChain) T() *testing.T + func (chain *TestChain) TxConfig() client.TxConfig + func (chain *TestChain) UpdateNextBlock() + func (chain *TestChain) Vals() *tmtypes.ValidatorSet + type TestChainI interface + App func() TestingApp + BeginBlock func() + ChainID func() string + Codec func() *codec.CodecProxy + ConstructUpdateTMClientHeader func(counterparty TestChainI, clientID string) (*ibctmtypes.Header, error) + ConstructUpdateTMClientHeaderWithTrustedHeight func(counterparty TestChainI, clientID string, trustedHeight clienttypes.Height) (*ibctmtypes.Header, error) + Coordinator func() *Coordinator + CreateChannelCapability func(scopedKeeper capabilitykeeper.ScopedKeeper, portID, channelID string) + CreatePortCapability func(scopedKeeper capabilitykeeper.ScopedKeeper, portID string) + CreateTMClientHeader func(chainID string, blockHeight int64, trustedHeight clienttypes.Height, ...) *ibctmtypes.Header + CurrentHeader func() tmproto.Header + CurrentHeaderTime func(time.Time) + CurrentTMClientHeader func() *ibctmtypes.Header + ExpireClient func(amount time.Duration) + GetChannelCapability func(portID, channelID string) *capabilitytypes.Capability + GetClientState func(clientID string) exported.ClientState + GetConsensusState func(clientID string, height exported.Height) (exported.ConsensusState, bool) + GetContext func() sdk.Context + GetContextPointer func() *sdk.Context + GetPortCapability func(portID string) *capabilitytypes.Capability + GetPrefix func() commitmenttypes.MerklePrefix + GetSimApp func() *simapp.SimApp + GetValsAtHeight func(height int64) (*tmtypes.ValidatorSet, bool) + LastHeader func() *ibctmtypes.Header + NextBlock func() + QueryConsensusStateProof func(clientID string) ([]byte, clienttypes.Height) + QueryProof func(key []byte) ([]byte, clienttypes.Height) + QueryProofAtHeight func(key []byte, height int64) ([]byte, clienttypes.Height) + QueryServer func() types.QueryService + QueryUpgradeProof func(key []byte, height uint64) ([]byte, clienttypes.Height) + SendMsgs func(msgs ...ibcmsg.Msg) (*sdk.Result, error) + SenderAccount func() sdk.Account + SenderAccountPV func() crypto.PrivKey + SenderAccountPVBZ func() []byte + SenderAccounts func() []SenderAccount + Signers func() []tmtypes.PrivValidator + T func() *testing.T + TxConfig func() client.TxConfig + UpdateNextBlock func() + Vals func() *tmtypes.ValidatorSet + func NewTestChain(t *testing.T, coord *Coordinator, chainID string) TestChainI + type TestingApp interface + AppCodec func() *codec.CodecProxy + GetBaseApp func() *bam.BaseApp + GetFacadedKeeper func() *ibc.Keeper + GetIBCKeeper func() *keeper.Keeper + GetScopedIBCKeeper func() capabilitykeeper.ScopedKeeper + GetStakingKeeper func() stakingkeeper.Keeper + LastBlockHeight func() int64 + LastCommitID func() sdk.CommitID + TxConfig func() client.TxConfig + func SetupTestingApp() (TestingApp, map[string]json.RawMessage) + func SetupWithGenesisValSet(t *testing.T, chainId string, valSet *tmtypes.ValidatorSet, ...) TestingApp