relayer

package

Go to main page

Versions in this module

v1

v1.0.0

Oct 25, 2021

Changes in this version

+ func BuildSimTx(txf tx.Factory, msgs ...sdk.Msg) ([]byte, error)

+ func CalculateGas(queryFunc func(string, []byte) ([]byte, int64, error), txf tx.Factory, ...) (txtypes.SimulateResponse, uint64, error)

+ func CastClientStateToTMType(cs *codectypes.Any) (*tmclient.ClientState, error)

+ func DefaultPageRequest() *querytypes.PageRequest

type Chain

+ Provider provtypes.Provider

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

+ func (c *Chain) QueryTMClientState(height int64) (*tmclient.ClientState, error)

type ProtoCodec

+ func (pc *ProtoCodec) Marshal(o codec.ProtoMarshaler) ([]byte, error)

+ func (pc *ProtoCodec) MarshalLengthPrefixed(o codec.ProtoMarshaler) ([]byte, error)

+ func (pc *ProtoCodec) MustMarshal(o codec.ProtoMarshaler) []byte

+ func (pc *ProtoCodec) MustMarshalLengthPrefixed(o codec.ProtoMarshaler) []byte

+ func (pc *ProtoCodec) MustUnmarshal(bz []byte, ptr codec.ProtoMarshaler)

+ func (pc *ProtoCodec) MustUnmarshalLengthPrefixed(bz []byte, ptr codec.ProtoMarshaler)

+ func (pc *ProtoCodec) Unmarshal(bz []byte, ptr codec.ProtoMarshaler) error

+ func (pc *ProtoCodec) UnmarshalLengthPrefixed(bz []byte, ptr codec.ProtoMarshaler) error

v1.0.0-rc1

Nov 7, 2020

v1.0.0-rc0

Nov 6, 2020

v0

v0.9.3

Apr 14, 2021

v0.9.2

Mar 29, 2021

Changes in this version

+ var ErrDatabase = errors.New("database failure")

v0.9.1

Mar 26, 2021

v0.9.0

Mar 23, 2021

Changes in this version

+ var AllowUpdateAfterExpiry = true

+ var AllowUpdateAfterMisbehaviour = true

type Chain

+ func (c *Chain) MsgRelayAcknowledgement(counterparty *Chain, packet *relayMsgPacketAck) (msgs []sdk.Msg, err error)

+ func (c *Chain) MsgRelayRecvPacket(counterparty *Chain, packet *relayMsgRecvPacket) (msgs []sdk.Msg, err error)

+ func (c *Chain) MsgRelayTimeout(counterparty *Chain, packet *relayMsgTimeout) (msgs []sdk.Msg, err error)

v0.8.3

Mar 12, 2021

v0.8.2

Mar 1, 2021

v0.8.1

Feb 26, 2021

v0.8.0

Feb 17, 2021

Changes in this version

+ func AutoUpdateClient(src, dst *Chain, thresholdTime time.Duration) (time.Duration, error)

+ func GetIBCCreateClientHeaders(src, dst *Chain) (srcHeader, dstHeader *tmclient.Header, err error)

+ func GetIBCUpdateHeaders(src, dst *Chain) (srcHeader, dstHeader *tmclient.Header, err error)

+ func UpdateLightClients(src, dst *Chain) (srcLB, dstLB *tmtypes.LightBlock, err error)

type Chain

+ func (c *Chain) GetIBCCreateClientHeader() (*tmclient.Header, error)

+ func (c *Chain) GetIBCUpdateHeader(dst *Chain) (*tmclient.Header, error)

+ func (c *Chain) InjectTrustedFields(dst *Chain, header *tmclient.Header) (*tmclient.Header, error)

+ func (c *Chain) MustGetLatestLightHeight() uint64

+ func (c *Chain) QueryBalanceWithAddress(address string) (sdk.Coins, error)

+ func (c *Chain) QueryPacketReceipt(height int64, seq uint64) (recRes *chantypes.QueryPacketReceiptResponse, err error)

+ func (c *Chain) QueryUnreceivedAcknowledgements(height uint64, seqs []uint64) ([]uint64, error)

+ func (c *Chain) QueryUnreceivedPackets(height uint64, seqs []uint64) ([]uint64, error)

+ func (c *Chain) UpdateLightClient() (*tmtypes.LightBlock, error)

v0.7.0

Feb 1, 2021

Changes in this version

+ var DefaultUpgradePath = []string

+ func ExecuteChannelStep(src, dst *Chain) (success, last, modified bool, err error)

+ func ExecuteConnectionStep(src, dst *Chain) (success, last, modified bool, err error)

+ func FindMatchingChannel(source, counterparty *Chain) (string, bool)

+ func FindMatchingClient(source, counterparty *Chain, clientState *ibctmtypes.ClientState) (string, bool)

+ func FindMatchingConnection(source, counterparty *Chain) (string, bool)

+ func InitializeChannel(src, dst *Chain, srcUpdateHeader, dstUpdateHeader *tmclient.Header, ...) (success, modified bool, err error)

+ func InitializeConnection(src, dst *Chain, srcUpdateHeader, dstUpdateHeader *tmclient.Header, ...) (success, modified bool, err error)

+ func IsConnectionFound(connectionHops []string, connectionID string) bool

+ func IsMatchingChannel(source, counterparty *Chain, channel *chantypes.IdentifiedChannel) bool

+ func IsMatchingClient(clientStateA, clientStateB ibctmtypes.ClientState) bool

+ func IsMatchingConnection(source, counterparty *Chain, connection *conntypes.IdentifiedConnection) bool

+ func IsMatchingConsensusState(consensusStateA, consensusStateB *ibctmtypes.ConsensusState) bool

+ func ParseChannelIDFromEvents(events sdk.StringEvents) (string, error)

+ func ParseClientIDFromEvents(events sdk.StringEvents) (string, error)

+ func ParseConnectionIDFromEvents(events sdk.StringEvents) (string, error)

+ func ValidateChannelParams(src, dst *Chain) error

+ func ValidateClientPaths(src, dst *Chain) error

+ func ValidateConnectionPaths(src, dst *Chain) error

type Chain

+ func (c *Chain) ChanAck(counterparty *Chain, height uint64) (sdk.Msg, error)

+ func (c *Chain) ChanCloseConfirm(dstChanState *chantypes.QueryChannelResponse) sdk.Msg

+ func (c *Chain) ChanCloseInit() sdk.Msg

+ func (c *Chain) ChanConfirm(dstChanState *chantypes.QueryChannelResponse) sdk.Msg

+ func (c *Chain) ChanInit(counterparty *PathEnd) sdk.Msg

+ func (c *Chain) ChanTry(counterparty *Chain, height uint64) (sdk.Msg, error)

+ func (c *Chain) ConnAck(counterparty *Chain, height uint64) (sdk.Msg, error)

+ func (c *Chain) ConnConfirm(counterpartyConnState *conntypes.QueryConnectionResponse) sdk.Msg

+ func (c *Chain) ConnInit(counterparty *PathEnd) sdk.Msg

+ func (c *Chain) ConnTry(counterparty *Chain, height uint64) (sdk.Msg, error)

+ func (c *Chain) CreateClient(clientState *tmclient.ClientState, dstHeader *tmclient.Header) sdk.Msg

+ func (c *Chain) CreateOpenChannels(dst *Chain, maxRetries uint64, to time.Duration) (modified bool, err error)

+ func (c *Chain) CreateOpenConnections(dst *Chain, maxRetries uint64, to time.Duration) (modified bool, err error)

+ func (c *Chain) GenerateConnHandshakeProof(height uint64) (clientState ibcexported.ClientState, clientStateProof []byte, ...)

+ func (c *Chain) MsgTransfer(dst *PathEnd, amount sdk.Coin, dstAddr string, ...) sdk.Msg

+ func (c *Chain) QueryUpgradedClient(height int64) (*codectypes.Any, []byte, clienttypes.Height, error)

+ func (c *Chain) QueryUpgradedConsState(height int64) (*codectypes.Any, []byte, clienttypes.Height, error)

+ func (c *Chain) UpdateClient(dstHeader ibcexported.Header) sdk.Msg

+ func (c *Chain) UpgradeChain(dst *Chain, plan *upgradetypes.Plan, deposit sdk.Coin, ...) error

+ func (c *Chain) UpgradeClients(dst *Chain, height int64) error

+ func (c *Chain) ValidateLightInitialized() error

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

type PathEnd

+ func (pe *PathEnd) ValidateBasic() error

+ func (pe *PathEnd) ValidateFull() error

type ProtoCodec

+ func (pc *ProtoCodec) MarshalInterface(i proto.Message) ([]byte, error)

+ func (pc *ProtoCodec) MarshalInterfaceJSON(x proto.Message) ([]byte, error)

+ func (pc *ProtoCodec) UnmarshalInterface(bz []byte, ptr interface{}) error

+ func (pc *ProtoCodec) UnmarshalInterfaceJSON(bz []byte, iface interface{}) error

v0.6.1

Nov 5, 2020

v0.6.0

Nov 5, 2020

Changes in this version

+ var ErrLightNotInitialized = errors.New("light client is not initialized")

+ var SendToController func(needReply bool, str string) (string, error)

+ func ControllerUpcall(action interface{}) (bool, error)

+ func CreateMnemonic() (string, error)

+ func DecodeMsgs(c *Chain, msgs []string) []sdk.Msg

+ func EncodeMsgs(c *Chain, msgs []sdk.Msg) []string

+ func GenerateRandomBytes(n int) ([]byte, error)

+ func GenerateRandomString(s int) (string, error)

+ func GetLatestLightHeights(src, dst *Chain) (srch int64, dsth int64, err error)

+ func InjectTrustedFields(srcChain, dstChain *Chain, srcHeader *tmclient.Header) (*tmclient.Header, error)

+ func InjectTrustedFieldsHeaders(src, dst *Chain, srch, dsth *tmclient.Header) (srcho *tmclient.Header, dstho *tmclient.Header, err error)

+ func MustGetHeight(h ibcexported.Height) uint64

+ func OrderFromString(order string) chantypes.Order

+ func ParseEvents(e string) ([]string, error)

+ func RandLowerCaseLetterString(length int) string

+ func RunStrategy(src, dst *Chain, strategy Strategy) (func(), error)

+ func ValidatePaths(src, dst *Chain) error

type Chain

+ Encoding params.EncodingConfig

+ func UnmarshalChain(pe PathEnd) *Chain

+ func (c *Chain) CLIContext(height int64) sdkCtx.Context

+ func (c *Chain) CloseChannel(dst *Chain, to time.Duration) error

+ func (c *Chain) CloseChannelStep(dst *Chain) (*RelayMsgs, error)

+ func (c *Chain) CreateTestKey() error

+ func (c *Chain) DeleteLightDB() error

+ func (c *Chain) FaucetHandler(fromKey sdk.AccAddress, amounts sdk.Coins) func(w http.ResponseWriter, r *http.Request)

+ func (c *Chain) ForceInitLight() error

+ func (c *Chain) GetLatestLightHeader() (*tmclient.Header, error)

+ func (c *Chain) GetLatestLightHeight() (int64, error)

+ func (c *Chain) GetLightSignedHeaderAtHeight(height int64) (*tmclient.Header, error)

+ func (c *Chain) GetRPCPort() string

+ func (c *Chain) GetSelfVersion() uint64

+ func (c *Chain) GetTimeout() time.Duration

+ func (c *Chain) KeyExists(name string) bool

+ func (c *Chain) LightClient(db dbm.DB) (*light.Client, error)

+ func (c *Chain) LightClientWithTrust(db dbm.DB, to light.TrustOptions) (*light.Client, error)

+ func (c *Chain) LightClientWithoutTrust(db dbm.DB) (*light.Client, error)

+ func (c *Chain) LightHTTP() lightp.Provider

+ func (c *Chain) ListenRPCEmitJSON(tx, block, data bool) func()

+ func (c *Chain) MakeEncodingConfig() params.EncodingConfig

+ func (c *Chain) NewLightDB() (db *dbm.GoLevelDB, df func(), err error)

+ func (c *Chain) NewProtoCodec(interfaceRegistry types.InterfaceRegistry, accountPrefix string) *ProtoCodec

+ func (c *Chain) QueryChannelClient(height int64) (*chantypes.QueryChannelClientStateResponse, error)

+ func (c *Chain) QueryConnectionChannels(connectionID string, offset, limit uint64) (*chantypes.QueryConnectionChannelsResponse, error)

+ func (c *Chain) QueryConsensusParams() (*abci.ConsensusParams, error)

+ func (c *Chain) QueryDenomTrace(denom string) (*transfertypes.QueryDenomTraceResponse, error)

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

+ func (c *Chain) QueryHistoricalInfo(height clienttypes.Height) (*stakingtypes.QueryHistoricalInfoResponse, error)

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

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

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

+ func (c *Chain) QueryPacketReciept(height int64, seq uint64) (recRes *chantypes.QueryPacketReceiptResponse, err error)

+ func (c *Chain) QueryUnbondingPeriod() (time.Duration, error)

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

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

+ func (c *Chain) QueryValsetAtHeight(height clienttypes.Height) (*tmproto.ValidatorSet, error)

+ func (c *Chain) SendMsgWithKey(msg sdk.Msg, keyName string) (res *sdk.TxResponse, err error)

+ func (c *Chain) SendTransferMsg(dst *Chain, amount sdk.Coin, dstAddr fmt.Stringer, toHeightOffset uint64, ...) error

+ func (c *Chain) Start() error

+ func (c *Chain) StatusErr() error

+ func (c *Chain) TxFactory(height int64) tx.Factory

+ func (c *Chain) UpdateClients(dst *Chain) (err error)

+ func (c *Chain) UpdateLightWithHeader() (*tmclient.Header, error)

+ func (c *Chain) UseSDKContext() func()

+ func (c *Chain) WaitForNBlocks(n int64) error

type Chains

+ func (c Chains) MustGet(chainID string) *Chain

+ type DeliverMsgsAction struct

+ Dst PathEnd

+ DstMsgs []string

+ Last bool

+ Src PathEnd

+ SrcMsgs []string

+ Succeeded bool

+ Type string

+ type FaucetRequest struct

+ Address string

+ ChainID string

type NaiveStrategy

+ MaxMsgLength uint64

+ MaxTxSize uint64

+ Ordered bool

+ func (nrs *NaiveStrategy) HandleEvents(src, dst *Chain, sh *SyncHeaders, events map[string][]string)

+ func (nrs *NaiveStrategy) RelayAcknowledgements(src, dst *Chain, sp *RelaySequences, sh *SyncHeaders) error

+ func (nrs *NaiveStrategy) RelayPackets(src, dst *Chain, sp *RelaySequences, sh *SyncHeaders) error

+ func (nrs *NaiveStrategy) UnrelayedAcknowledgements(src, dst *Chain, sh *SyncHeaders) (*RelaySequences, error)

+ func (nrs *NaiveStrategy) UnrelayedSequences(src, dst *Chain, sh *SyncHeaders) (*RelaySequences, error)

type Path

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

+ 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) MustGetStrategy() Strategy

+ func (p *Path) Ordered() bool

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

+ type PathAction struct

+ Type string

type PathEnd

+ Order string

+ Version string

+ func MarshalChain(c *Chain) PathEnd

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

+ func (pe *PathEnd) Vversion() error

+ 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

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

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

+ type ProtoCodec struct

+ func (pc *ProtoCodec) InterfaceRegistry() types.InterfaceRegistry

+ func (pc *ProtoCodec) MarshalBinaryBare(o codec.ProtoMarshaler) ([]byte, error)

+ func (pc *ProtoCodec) MarshalBinaryLengthPrefixed(o codec.ProtoMarshaler) ([]byte, error)

+ func (pc *ProtoCodec) MarshalJSON(o proto.Message) ([]byte, error)

+ func (pc *ProtoCodec) MustMarshalBinaryBare(o codec.ProtoMarshaler) []byte

+ func (pc *ProtoCodec) MustMarshalBinaryLengthPrefixed(o codec.ProtoMarshaler) []byte

+ func (pc *ProtoCodec) MustMarshalJSON(o proto.Message) []byte

+ func (pc *ProtoCodec) MustUnmarshalBinaryBare(bz []byte, ptr codec.ProtoMarshaler)

+ func (pc *ProtoCodec) MustUnmarshalBinaryLengthPrefixed(bz []byte, ptr codec.ProtoMarshaler)

+ func (pc *ProtoCodec) MustUnmarshalJSON(bz []byte, ptr proto.Message)

+ func (pc *ProtoCodec) UnmarshalBinaryBare(bz []byte, ptr codec.ProtoMarshaler) error

+ func (pc *ProtoCodec) UnmarshalBinaryLengthPrefixed(bz []byte, ptr codec.ProtoMarshaler) error

+ func (pc *ProtoCodec) UnmarshalJSON(bz []byte, ptr proto.Message) error

+ func (pc *ProtoCodec) UnpackAny(any *types.Any, iface interface{}) error

type RelayMsgs

+ Last bool

+ MaxMsgLength uint64

+ MaxTxSize uint64

+ Succeeded bool

+ func NewRelayMsgs() *RelayMsgs

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

+ func (r *RelayMsgs) SendWithController(src, dst *Chain, useController bool)

+ type RelaySequences struct

+ Dst []uint64

+ Src []uint64

type Strategy

+ HandleEvents func(src, dst *Chain, sh *SyncHeaders, events map[string][]string)

+ RelayAcknowledgements func(src, dst *Chain, sp *RelaySequences, sh *SyncHeaders) error

+ RelayPackets func(src, dst *Chain, sp *RelaySequences, sh *SyncHeaders) error

+ UnrelayedAcknowledgements func(src, dst *Chain, sh *SyncHeaders) (*RelaySequences, error)

+ UnrelayedSequences func(src, dst *Chain, sh *SyncHeaders) (*RelaySequences, error)

+ type SyncHeaders struct

+ func NewSyncHeaders(src, dst *Chain) (*SyncHeaders, error)

+ func (uh *SyncHeaders) GetHeader(chainID string) *tmclient.Header

+ func (uh *SyncHeaders) GetHeight(chainID string) uint64

+ func (uh *SyncHeaders) GetTrustedHeaders(src, dst *Chain) (srcTh, dstTh *tmclient.Header, err error)

+ func (uh *SyncHeaders) GetUpdateHeader(srcChain, dstChain *Chain) (*tmclient.Header, error)

+ func (uh *SyncHeaders) Update(c *Chain) error

+ func (uh *SyncHeaders) UpdateWithTrustedHeaders(src, dst *Chain) (srcTh, dstTh *tmclient.Header, err error)

+ func (uh *SyncHeaders) Updates(c ...*Chain) error

v0.1.0

Mar 18, 2020

Changes in this version

+ var ErrLiteNotInitialized = errors.New("lite client is not initialized")

+ func GetCodespace(codespace string, code int) (msg string, err error)

+ func GetLatestHeaders(chains ...*Chain) (map[string]*tmclient.Header, error)

+ func GetLatestHeights(chains ...*Chain) (map[string]int64, error)

+ func PathsSet(chains ...*Chain) bool

+ func QueryChannelPair(src, dst *Chain, srcH, dstH int64) (map[string]chanTypes.ChannelResponse, error)

+ func QueryClientConsensusStatePair(src, dst *Chain, srcH, dstH, srcClientConsH, dstClientConsH int64) (map[string]clientTypes.ConsensusStateResponse, error)

+ func QueryClientStatePair(src, dst *Chain) (map[string]clientTypes.StateResponse, error)

+ func QueryConnectionPair(src, dst *Chain, srcH, dstH int64) (map[string]connTypes.ConnectionResponse, error)

+ func QueryLatestHeights(chains ...*Chain) (map[string]int64, error)

+ func UpdateLiteDBsToLatestHeaders(chains ...*Chain) error

+ func UpdatesWithHeaders(chains ...*Chain) (map[string]*tmclient.Header, error)

+ type Chain struct

+ AccountPrefix string

+ Amino *aminocodec.Codec

+ Cdc *codecstd.Codec

+ ChainID string

+ Client rpcclient.Client

+ DefaultDenom string

+ Gas uint64

+ GasAdjustment float64

+ GasPrices string

+ HomePath string

+ Key string

+ Keybase keys.Keybase

+ Memo string

+ PathEnd *PathEnd

+ RPCAddr string

+ TrustingPeriod string

+ func (c *Chain) AddPath(clientID, connectionID, channelID, port string) error

+ func (c *Chain) DeleteLiteDB() error

+ func (c *Chain) ErrCantSetPath(err error) error

+ func (c *Chain) ErrPathNotSet() error

+ func (c *Chain) GetLatestLiteHeader() (*tmclient.Header, error)

+ func (c *Chain) GetLatestLiteHeight() (int64, error)

+ func (c *Chain) GetLiteSignedHeaderAtHeight(height int64) (*tmclient.Header, error)

+ func (c *Chain) InitLiteClient(db *dbm.GoLevelDB, trustOpts lite.TrustOptions) (*lite.Client, error)

+ func (c *Chain) InitLiteClientWithoutTrust(db *dbm.GoLevelDB) (*lite.Client, error)

+ func (c *Chain) LogFailedTx(res sdk.TxResponse, err error, msgs []sdk.Msg)

+ func (c *Chain) LogSuccessTx(res sdk.TxResponse, msgs []sdk.Msg)

+ func (c *Chain) NewLiteDB() (db *dbm.GoLevelDB, df func(), err error)

+ func (c *Chain) PathSet() bool

+ func (c *Chain) QueryABCI(req abci.RequestQuery) (res abci.ResponseQuery, err error)

+ func (c *Chain) QueryBalance() (sdk.Coins, error)

+ func (c *Chain) QueryChannel(height int64) (chanRes chanTypes.ChannelResponse, err error)

+ func (c *Chain) QueryChannels(page, limit int) ([]chanTypes.Channel, error)

+ func (c *Chain) QueryClientConsensusState(srcHeight, srcClientConsHeight int64) (clientTypes.ConsensusStateResponse, error)

+ func (c *Chain) QueryClientState() (clientTypes.StateResponse, error)

+ func (c *Chain) QueryClients(page, limit int) ([]clientExported.ClientState, error)

+ func (c *Chain) QueryConnection(height int64) (connTypes.ConnectionResponse, error)

+ func (c *Chain) QueryConnections(page, limit int) (conns []connTypes.ConnectionEnd, err error)

+ func (c *Chain) QueryConnectionsUsingClient(height int64) (clientConns connTypes.ClientConnectionsResponse, err error)

+ func (c *Chain) QueryConsensusState(height int64) (*tmclient.ConsensusState, error)

+ func (c *Chain) QueryHeaderAtHeight(height int64) (*tmclient.Header, error)

+ func (c *Chain) QueryLatestHeader() (out *tmclient.Header, err error)

+ func (c *Chain) QueryLatestHeight() (int64, error)

+ func (c *Chain) QueryNextSeqRecv(height int64) (recvRes chanTypes.RecvResponse, err error)

+ func (c *Chain) QueryNextSeqSend(height int64) (uint64, error)

+ func (c *Chain) QueryPacketAck(height, seq int64) (comRes CommitmentResponse, err error)

+ func (c *Chain) QueryPacketCommitment(height, seq int64) (comRes CommitmentResponse, err error)

+ func (c *Chain) QueryTx(hashHex string) (sdk.TxResponse, error)

+ func (c *Chain) QueryTxs(height uint64, page, limit int, events []string) (*sdk.SearchTxsResult, error)

+ func (c *Chain) QueryWithData(p string, d []byte) (byt []byte, i int64, err error)

+ func (c *Chain) SetPath(p *PathEnd) error

+ func (c *Chain) StartUpdatingLiteClient(period time.Duration)

+ func (c *Chain) TrustNodeInitClient(db *dbm.GoLevelDB) (*lite.Client, error)

+ func (c *Chain) TrustOptions(height int64, hash []byte) lite.TrustOptions

+ func (c *Chain) UpdateLiteDBToLatestHeader() error

+ func (c *Chain) UpdateLiteWithHeader() (*tmclient.Header, error)

+ func (c *Chain) ValidateTxResult(resTx *ctypes.ResultTx) (err error)

+ func (c *Chain) VerifyProof(queryPath string, resp abci.ResponseQuery) error

+ func (src *Chain) BroadcastTxCommit(txBytes []byte) (sdk.TxResponse, error)

+ func (src *Chain) BuildAndSignTx(datagram []sdk.Msg) ([]byte, error)

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

+ func (src *Chain) CreateChannelStep(dst *Chain, ordering chanState.Order) (*RelayMsgs, error)

+ func (src *Chain) CreateClients(dst *Chain) (err error)

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

+ func (src *Chain) CreateConnectionStep(dst *Chain) (*RelayMsgs, error)

+ func (src *Chain) Error(err error)

+ func (src *Chain) GetAddress() (sdk.AccAddress, error)

+ func (src *Chain) GetTrustingPeriod() time.Duration

+ func (src *Chain) Init(homePath string, cdc *codecstd.Codec, amino *aminocodec.Codec, ...) (*Chain, error)

+ func (src *Chain) Log(s string)

+ func (src *Chain) MustGetAddress() sdk.AccAddress

+ func (src *Chain) Print(toPrint interface{}, text, indent bool) error

+ func (src *Chain) SendAndPrint(txs []sdk.Msg, text, indent bool) (err error)

+ func (src *Chain) SendMsg(datagram sdk.Msg) (sdk.TxResponse, error)

+ func (src *Chain) SendMsgs(datagrams []sdk.Msg) (res sdk.TxResponse, err error)

+ func (src *Chain) String() string

+ func (src *Chain) Subscribe(query string) (<-chan ctypes.ResultEvent, context.CancelFunc, error)

+ func (src *Chain) Update(key, value string) (out *Chain, err error)

+ type Chains []*Chain

+ func (c Chains) Get(chainID string) (*Chain, error)

+ func (c Chains) Gets(chainIDs ...string) (map[string]*Chain, error)

+ type CommitmentResponse struct

+ Data []byte

+ Proof commitmenttypes.MerkleProof

+ ProofHeight uint64

+ ProofPath commitmenttypes.MerklePath

+ type NaiveStrategy struct

+ func (nrs NaiveStrategy) Cfg() *StrategyCfg

+ func (nrs NaiveStrategy) GetConstraints() map[string]string

+ func (nrs NaiveStrategy) GetType() string

+ func (nrs NaiveStrategy) Init(sc *StrategyCfg) (Strategy, error)

+ func (nrs NaiveStrategy) Run(src, dst *Chain) error

+ type Path struct

+ Dst *PathEnd

+ Index int

+ Src *PathEnd

+ Strategy *StrategyCfg

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

+ func (p *Path) MustYAML() string

+ func (p *Path) String() string

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

+ func (r *Path) GetStrategy() (Strategy, error)

+ type PathEnd struct

+ ChainID string

+ ChannelID string

+ ClientID string

+ ConnectionID string

+ PortID string

+ func (p *PathEnd) Validate() error

+ func (p *PathEnd) Vchan() error

+ func (p *PathEnd) Vclient() error

+ func (p *PathEnd) Vconn() error

+ func (p *PathEnd) Vport() error

+ func (p PathEnd) String() string

+ func (src *PathEnd) ChanAck(dstChanState chanTypes.ChannelResponse, signer sdk.AccAddress) sdk.Msg

+ func (src *PathEnd) ChanCloseConfirm(dstChanState chanTypes.ChannelResponse, signer sdk.AccAddress) sdk.Msg

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

+ func (src *PathEnd) ChanConfirm(dstChanState chanTypes.ChannelResponse, signer sdk.AccAddress) sdk.Msg

+ func (src *PathEnd) ChanInit(dst *PathEnd, ordering chanState.Order, signer sdk.AccAddress) sdk.Msg

+ func (src *PathEnd) ChanTry(dst *PathEnd, dstChanState chanTypes.ChannelResponse, signer sdk.AccAddress) sdk.Msg

+ func (src *PathEnd) ConnAck(dstConnState connTypes.ConnectionResponse, ...) sdk.Msg

+ func (src *PathEnd) ConnConfirm(dstConnState connTypes.ConnectionResponse, signer sdk.AccAddress) sdk.Msg

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

+ func (src *PathEnd) ConnTry(dst *PathEnd, dstConnState connTypes.ConnectionResponse, ...) sdk.Msg

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

+ func (src *PathEnd) MsgAck(packet chanTypes.Packet, ack chanState.PacketAcknowledgementI, ...) sdk.Msg

+ func (src *PathEnd) MsgRecvPacket(dst *PathEnd, sequence uint64, packetData chanState.PacketDataI, ...) sdk.Msg

+ func (src *PathEnd) MsgTimeout(packet chanTypes.Packet, seq uint64, proof chanTypes.PacketResponse, ...) sdk.Msg

+ func (src *PathEnd) MsgTransfer(dst *PathEnd, dstHeight uint64, amount sdk.Coins, dstAddr sdk.AccAddress, ...) sdk.Msg

+ func (src *PathEnd) NewPacket(dst *PathEnd, sequence uint64, packetData chanState.PacketDataI) chanTypes.Packet

+ func (src *PathEnd) UpdateClient(dstHeader *tmclient.Header, signer sdk.AccAddress) sdk.Msg

+ func (src *PathEnd) XferPacket(amount sdk.Coins, sender, reciever sdk.AccAddress, source bool, timeout uint64) chanState.PacketDataI

+ type Paths map[string]*Path

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

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

+ func (p Paths) MustYAML() string

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

+ type RelayMsgs struct

+ Dst []sdk.Msg

+ Src []sdk.Msg

+ func (r *RelayMsgs) Ready() bool

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

+ func (r *RelayMsgs) Success() bool

+ type Strategy interface

+ Cfg func() *StrategyCfg

+ GetConstraints func() map[string]string

+ GetType func() string

+ Init func(*StrategyCfg) (Strategy, error)

+ Run func(*Chain, *Chain) error

+ type StrategyCfg struct

+ Constraints map[string]string

+ Type string

+ func NewNaiveStrategy() *StrategyCfg

Other modules containing this package

github.com/cosmos/relayer/v2

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL