Versions in this module Expand all Collapse all v1 v1.1.2 Dec 2, 2024 v1.1.0 Oct 24, 2024 Changes in this version + var DefaultConfigPath = filepath.Join(DefaultHomePath, ".icq-relayer") + var DefaultHomePath = os.UserHomeDir() + func Bech32ifyAddressBytes(prefix string, address sdktypes.AccAddress) (string, error) + func SetSDKConfigPrefix(prefix string) + type ChainConfig struct + AddressBytes sdktypes.AccAddress + GasLimit int + GasMultiplier float64 + GasPrice string + MnemonicPath string + Prefix string + TxSubmitTimeoutSeconds int + func (c *ChainConfig) GetAddress() string + func (c *ChainConfig) GetAddressBytes() sdktypes.AccAddress + func (c *ChainConfig) GetPrivKeyAddress() (sdkcryptotypes.PrivKey, sdktypes.AccAddress) + func (c *ChainConfig) SignAndBroadcastMsg(ctx context.Context, cliContext *client.Context, exec []sdktypes.Msg, ...) (string, uint32, error) + func (r *ChainConfig) GetClient() *rpchttp.HTTP + func (r *ChainConfig) Init(codec *codec.ProtoCodec, cache *ristretto.Cache) error + type Config struct + AllowedQueries []string + BindPort int + Chains map[string]*ReadOnlyChainConfig + ClientContext *client.Context + DefaultChain *ChainConfig + HomePath string + MaxMsgsPerTx int + ProtoCodec *codec.ProtoCodec + SkipEpoch bool + func InitializeConfigFromToml(homepath string) Config + func NewConfig() Config + type QueryClient interface + GetClientId func(ctx context.Context, connectionId string, logger log2.Logger, ...) (string, error) + GetClientState func(ctx context.Context, clientId string, logger log2.Logger, ...) (*clienttypes.QueryClientStateResponse, error) + GetClientStateHeights func(ctx context.Context, clientId string, chainId string, height uint64, ...) ([]clienttypes.Height, error) + Init func(codec *codec.ProtoCodec, cache *ristretto.Cache) error + type RPCClient struct + func NewWithTimeout(remote string, timeout uint) (*RPCClient, error) + func (c *RPCClient) ABCIInfo(ctx context.Context) (*ctypes.ResultABCIInfo, error) + func (c *RPCClient) ABCIQuery(ctx context.Context, path string, data bytes.HexBytes) (*ctypes.ResultABCIQuery, error) + func (c *RPCClient) ABCIQueryWithOptions(ctx context.Context, path string, data bytes.HexBytes, ...) (*ctypes.ResultABCIQuery, error) + func (c *RPCClient) Block(ctx context.Context, height *int64) (*ctypes.ResultBlock, error) + func (c *RPCClient) BlockByHash(ctx context.Context, hash []byte) (*ctypes.ResultBlock, error) + func (c *RPCClient) BlockResults(ctx context.Context, height *int64) (*ctypes.ResultBlockResults, error) + func (c *RPCClient) BlockSearch(ctx context.Context, query string, page, perPage *int, orderBy string) (*ctypes.ResultBlockSearch, error) + func (c *RPCClient) BlockchainInfo(ctx context.Context, minHeight, maxHeight int64) (*ctypes.ResultBlockchainInfo, error) + func (c *RPCClient) BroadcastEvidence(ctx context.Context, ev types.Evidence) (*ctypes.ResultBroadcastEvidence, error) + func (c *RPCClient) BroadcastTxAsync(ctx context.Context, tx types.Tx) (*ctypes.ResultBroadcastTx, error) + func (c *RPCClient) BroadcastTxCommit(ctx context.Context, tx types.Tx) (*ctypes.ResultBroadcastTxCommit, error) + func (c *RPCClient) BroadcastTxSync(ctx context.Context, tx types.Tx) (*ctypes.ResultBroadcastTx, error) + func (c *RPCClient) CheckTx(ctx context.Context, tx types.Tx) (*ctypes.ResultCheckTx, error) + func (c *RPCClient) Commit(ctx context.Context, height *int64) (*ctypes.ResultCommit, error) + func (c *RPCClient) ConsensusParams(ctx context.Context, height *int64) (*ctypes.ResultConsensusParams, error) + func (c *RPCClient) ConsensusState(ctx context.Context) (*ctypes.ResultConsensusState, error) + func (c *RPCClient) DumpConsensusState(ctx context.Context) (*ctypes.ResultDumpConsensusState, error) + func (c *RPCClient) Genesis(ctx context.Context) (*ctypes.ResultGenesis, error) + func (c *RPCClient) GenesisChunked(ctx context.Context, id uint) (*ctypes.ResultGenesisChunk, error) + func (c *RPCClient) Health(ctx context.Context) (*ctypes.ResultHealth, error) + func (c *RPCClient) NetInfo(ctx context.Context) (*ctypes.ResultNetInfo, error) + func (c *RPCClient) NumUnconfirmedTxs(ctx context.Context) (*ctypes.ResultUnconfirmedTxs, error) + func (c *RPCClient) Status(ctx context.Context) (*ctypes.ResultStatus, error) + func (c *RPCClient) Tx(ctx context.Context, hash []byte, prove bool) (*ctypes.ResultTx, error) + func (c *RPCClient) TxSearch(ctx context.Context, query string, prove bool, page, perPage *int, ...) (*ctypes.ResultTxSearch, error) + func (c *RPCClient) UnconfirmedTxs(ctx context.Context, limit *int) (*ctypes.ResultUnconfirmedTxs, error) + func (c *RPCClient) Validators(ctx context.Context, height *int64, page, perPage *int) (*ctypes.ResultValidators, error) + type RPCClientI interface + type ReadOnlyChainConfig struct + Cache *ristretto.Cache + ChainID string + Client RPCClientI + Codec *codec.ProtoCodec + CompatibilityMode string + ConnectTimeoutSeconds int + LightProvider prov.Provider + QueryRetries int + QueryRetryDelayMilliseconds int + QueryTimeoutSeconds int + RpcUrl string + func DefaultReadOnlyChainConfig(chainID string, rpcUrl string) *ReadOnlyChainConfig + func (r *ReadOnlyChainConfig) GetClientId(ctx context.Context, connectionId string, logger log2.Logger, ...) (string, error) + func (r *ReadOnlyChainConfig) GetClientState(ctx context.Context, clientId string, logger log2.Logger, ...) (*clienttypes.QueryClientStateResponse, error) + func (r *ReadOnlyChainConfig) GetClientStateHeights(ctx context.Context, clientId string, chainId string, height uint64, ...) ([]clienttypes.Height, error) + func (r *ReadOnlyChainConfig) GetCurrentHeight(ctx context.Context, cache *ristretto.Cache, logger log2.Logger) (int64, error) + func (r *ReadOnlyChainConfig) Init(codec *codec.ProtoCodec, cache *ristretto.Cache) error + func (r *ReadOnlyChainConfig) LightBlock(ctx context.Context, height int64) (*tmtypes.LightBlock, error) + func (r *ReadOnlyChainConfig) RunABCIQuery(ctx context.Context, method string, reqBz []byte, height int64, prove bool, ...) (abcitypes.ResponseQuery, error) + func (r *ReadOnlyChainConfig) Tx(hash []byte) (*codectypes.Any, int64, error) + type TxClient interface + SignAndBroadcastMsg func(ctx context.Context, cliContext *client.Context, exec []sdktypes.Msg, ...) (string, uint32, error) + type TxResultMinimal struct + Height string + Proof tmtypes.TxProof + type TxResultMinimalCelestia struct + Height string + Index uint32 + Proof celestiatypes.ShareProof