Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

ibctesting

package

Go to main page

Versions in this module

v0

v0.5.2

May 8, 2025

Changes in this version

+ const DefaultChannelVersion

+ const DefaultDelayPeriod

+ const DefaultGenesisAccBalance

+ const MaxClockDrift

+ const MockPort

+ const TransferPort

+ const TrustingPeriod

+ const UnbondingPeriod

+ var ConnectionVersion = connectiontypes.GetCompatibleVersions()[0]

+ var DefaultCoinAmount = sdkmath.NewInt(100)

+ var DefaultOpenInitVersion *connectiontypes.Version

+ var DefaultTimeoutTimestampDelta = uint64(time.Hour.Nanoseconds())

+ var DefaultTrustLevel = ibctm.DefaultTrustLevel

+ var MaxAccounts = 10

+ var MerklePath = commitmenttypes.NewMerklePath([]byte("ibc"), []byte(""))

+ var TimeIncrement = time.Second * 5

+ var UpgradePath = []string

+ func AssertEvents(suite *testifysuite.Suite, expected []abci.Event, actual []abci.Event)

+ func CommitHeader(proposedHeader cmttypes.Header, valSet *cmttypes.ValidatorSet, ...) (*cmtproto.SignedHeader, error)

+ func GetChainID(index int) string

+ func GetEvmChainID(index int) string

+ func MakeBlockID(hash []byte, partSetSize uint32, partSetHash []byte) cmttypes.BlockID

+ func ParseAckFromEvents(events []abci.Event) ([]byte, error)

+ func ParseAckV2FromEvents(events []abci.Event) ([]byte, error)

+ func ParseChannelIDFromEvents(events []abci.Event) (string, error)

+ func ParseClientIDFromEvents(events []abci.Event) (string, error)

+ func ParseConnectionIDFromEvents(events []abci.Event) (string, error)

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

+ func ParsePacketSequenceFromEvents(events []abci.Event) (uint64, error)

+ func ParsePacketsFromEvents(eventType string, events []abci.Event) ([]channeltypes.Packet, error)

+ func ParseProposalIDFromEvents(events []abci.Event) (uint64, error)

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

+ func SetupExampleApp() (ibctesting.TestingApp, map[string]json.RawMessage)

+ 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]*TestChain

+ CurrentTime time.Time

+ func (*Coordinator) CreateChannels(path *Path)

+ func (*Coordinator) CreateConnections(path *Path)

+ func (*Coordinator) CreateMockChannels(path *Path)

+ func (*Coordinator) CreateTransferChannels(path *Path)

+ func (*Coordinator) Setup(path *Path)

+ func (*Coordinator) SetupClients(path *Path)

+ func (*Coordinator) SetupConnections(path *Path)

+ func (coord *Coordinator) CommitBlock(chains ...*TestChain)

+ func (coord *Coordinator) CommitNBlocks(chain *TestChain, n uint64)

+ func (coord *Coordinator) GetChain(chainID string) *TestChain

+ func (coord *Coordinator) IncrementTime()

+ func (coord *Coordinator) IncrementTimeBy(increment time.Duration)

+ func (coord *Coordinator) UpdateTime()

+ func (coord *Coordinator) UpdateTimeForChain(chain *TestChain)

type Endpoint

+ MerklePathPrefix commitmenttypesv2.MerklePath

+ func (endpoint *Endpoint) AcknowledgePacketWithResult(packet channeltypes.Packet, ack []byte) (*abci.ExecTxResult, error)

+ func (endpoint *Endpoint) FreezeClient()

+ func (endpoint *Endpoint) GetClientLatestHeight() exported.Height

+ func (endpoint *Endpoint) IncrementNextChannelSequence()

+ func (endpoint *Endpoint) MsgAcknowledgePacket(packet channeltypesv2.Packet, ack channeltypesv2.Acknowledgement) error

+ func (endpoint *Endpoint) MsgRecvPacketWithResult(packet channeltypesv2.Packet) (*abci.ExecTxResult, error)

+ func (endpoint *Endpoint) MsgSendPacket(timeoutTimestamp uint64, payload channeltypesv2.Payload) (channeltypesv2.Packet, error)

+ func (endpoint *Endpoint) MsgSendPacketWithSender(timeoutTimestamp uint64, payload channeltypesv2.Payload, sender SenderAccount) (channeltypesv2.Packet, error)

+ func (endpoint *Endpoint) MsgTimeoutPacket(packet channeltypesv2.Packet) error

+ func (endpoint *Endpoint) ParseV2PacketFromEvent(events []abci.Event) ([]channeltypesv2.Packet, error)

+ func (endpoint *Endpoint) RegisterCounterparty() (err error)

+ func (endpoint *Endpoint) SetChannelState(state channeltypes.State) error

+ func (endpoint *Endpoint) TimeoutPacketWithResult(packet channeltypes.Packet) (*abci.ExecTxResult, error)

+ func (endpoint *Endpoint) UpdateChannel(updater func(channel *channeltypes.Channel))

+ func (endpoint *Endpoint) UpdateConnection(updater func(connection *connectiontypes.ConnectionEnd))

+ func (endpoint *Endpoint) UpgradeChain() error

type Path

+ func (path *Path) CreateChannels()

+ func (path *Path) CreateConnections()

+ func (path *Path) DisableUniqueChannelIDs() *Path

+ func (path *Path) RelayPacketV2(packet channeltypesv2.Packet) error

+ func (path *Path) RelayPacketWithResults(packet channeltypes.Packet) (*abci.ExecTxResult, []byte, error)

+ func (path *Path) RelayPacketWithResultsV2(packet channeltypesv2.Packet) (*abci.ExecTxResult, []byte, error)

+ func (path *Path) Reversed() *Path

+ func (path *Path) Setup()

+ func (path *Path) SetupClients()

+ func (path *Path) SetupConnections()

+ func (path *Path) SetupCounterparties()

+ func (path *Path) SetupV2()

+ type SenderAccount struct

+ SenderAccount sdk.AccountI

+ SenderPrivKey cryptotypes.PrivKey

+ type TendermintConfig struct

+ MaxClockDrift time.Duration

+ TrustLevel ibctm.Fraction

+ TrustingPeriod time.Duration

+ UnbondingPeriod time.Duration

+ func NewTendermintConfig() *TendermintConfig

+ func (*TendermintConfig) GetClientType() string

+ type TestChain struct

+ App ibctesting.TestingApp

+ ChainID string

+ Codec codec.Codec

+ Coordinator *Coordinator

+ LatestCommittedHeader *ibctm.Header

+ NextVals *cmttypes.ValidatorSet

+ ProposedHeader cmtproto.Header

+ SendMsgsOverride func(msgs ...sdk.Msg) (*abci.ExecTxResult, error)

+ SenderAccount sdk.AccountI

+ SenderAccounts []SenderAccount

+ SenderPrivKey cryptotypes.PrivKey

+ Signers map[string]cmttypes.PrivValidator

+ TrustedValidators map[uint64]*cmttypes.ValidatorSet

+ TxConfig client.TxConfig

+ Vals *cmttypes.ValidatorSet

+ func NewTestChainWithValSet(tb testing.TB, isEVM bool, coord *Coordinator, chainID string, ...) *TestChain

+ func (chain *TestChain) CreateTMClientHeader(chainID string, blockHeight int64, trustedHeight clienttypes.Height, ...) *ibctm.Header

+ func (chain *TestChain) CurrentTMClientHeader() *ibctm.Header

+ func (chain *TestChain) DeleteKey(key []byte)

+ func (chain *TestChain) ExpireClient(amount time.Duration)

+ func (chain *TestChain) GetAcknowledgement(packet channeltypes.Packet) []byte

+ func (chain *TestChain) GetClientLatestHeight(clientID string) exported.Height

+ 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) GetPrefix() commitmenttypes.MerklePrefix

+ func (chain *TestChain) GetSenderAccount(privKey cryptotypes.PrivKey) SenderAccount

+ func (chain *TestChain) GetSimApp() *simapp.SimApp

+ func (chain *TestChain) GetTimeoutHeight() clienttypes.Height

+ func (chain *TestChain) GetTimeoutTimestamp() uint64

+ func (chain *TestChain) GetTimeoutTimestampSecs() uint64

+ func (chain *TestChain) IBCClientHeader(header *ibctm.Header, trustedHeight clienttypes.Height) (*ibctm.Header, error)

+ 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) QueryProofForStore(storeKey string, key []byte, height int64) ([]byte, clienttypes.Height)

+ func (chain *TestChain) QueryUpgradeProof(key []byte, height uint64) ([]byte, clienttypes.Height)

+ func (chain *TestChain) SendEvmTx(priv cryptotypes.PrivKey, to common.Address, amount *big.Int, data []byte) (*abci.ExecTxResult, error)

+ func (chain *TestChain) SendMsgs(msgs ...sdk.Msg) (*abci.ExecTxResult, error)

+ func (chain *TestChain) SendMsgsWithSender(sender SenderAccount, msgs ...sdk.Msg) (*abci.ExecTxResult, error)

v0.1.1

Apr 25, 2025

Changes in this version

+ const DefaultFeeAmt

+ var ChainIDPrefix = constants.ExampleChainID

+ var ChainIDSuffix = ""

+ var DefaultTestingAppInit func(chainID string) func() (ibcgotesting.TestingApp, map[string]json.RawMessage) = exampleapp.SetupTestingApp

+ func CreateChannels(coord *ibctesting.Coordinator, path *Path)

+ func CreateConnections(coord *ibctesting.Coordinator, path *Path)

+ func NewCoordinator(t *testing.T, nEVMChains, mCosmosChains int) *ibctesting.Coordinator

+ func NewTestChain(t *testing.T, coord *ibcgotesting.Coordinator, chainID string) *ibcgotesting.TestChain

+ func SendMsgs(chain *ibctesting.TestChain, feeAmt int64, msgs ...sdk.Msg) (*sdk.Result, error)

+ func SetupClients(coord *ibctesting.Coordinator, path *Path)

+ func SetupConnections(coord *ibctesting.Coordinator, path *Path)

+ func SetupPath(coord *ibctesting.Coordinator, path *Path)

+ func SetupWithGenesisValSet(t *testing.T, valSet *cmttypes.ValidatorSet, ...) ibcgotesting.TestingApp

+ func SignAndDeliver(tb testing.TB, txCfg client.TxConfig, app *baseapp.BaseApp, msgs []sdk.Msg, ...) (sdk.GasInfo, *sdk.Result, error)

+ type Endpoint struct

+ Chain *ibctesting.TestChain

+ ChannelConfig *ibctesting.ChannelConfig

+ ChannelID string

+ ClientConfig ibctesting.ClientConfig

+ ClientID string

+ ConnectionConfig *ibctesting.ConnectionConfig

+ ConnectionID string

+ Counterparty *Endpoint

+ func NewDefaultEndpoint(chain *ibctesting.TestChain) *Endpoint

+ func NewEndpoint(chain *ibctesting.TestChain, clientConfig ibctesting.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(timeoutHeight clienttypes.Height, timeoutTimestamp uint64, data []byte) (uint64, 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) TimeoutOnClose(packet channeltypes.Packet) error

+ 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 *ibctesting.TestChain) *Path

+ func NewTransferPath(chainA, chainB *ibcgotesting.TestChain) *Path

+ func (path *Path) RelayPacket(packet channeltypes.Packet) error

+ func (path *Path) SetChannelOrdered()