client

package

Go to main page

Versions in this module

v0

v0.6.0

Nov 28, 2022

v0.5.4

Feb 1, 2023

v0.5.3

Feb 1, 2023

v0.5.2

Feb 1, 2023

Changes in this version

type ChainClientConfig

+ ExtraCodecs []string

+ MinGasAmount uint64

+ Slip44 int

v0.5.1

Jun 7, 2022

v0.5.0

Jun 7, 2022

Changes in this version

+ var SupportedAlgorithms = keyring.SigningAlgoList

+ var SupportedAlgorithmsLedger = keyring.SigningAlgoList

+ func LensKeyringAlgoOptions() keyring.Option

v0.4.0

May 4, 2022

Changes in this version

+ const ErrTimeoutAfterWaitingForTxBroadcast

type ChainClientConfig

+ BlockTimeout string

v0.3.0

Feb 13, 2022

v0.2.1

Jan 24, 2022

Changes in this version

+ var RtyAtt = retry.Attempts(RtyAttNum)

+ var RtyAttNum = uint(5)

+ var RtyDel = retry.Delay(time.Millisecond * 400)

+ var RtyErr = retry.LastErrorOnly(true)

+ func MustGetHeight(h ibcexported.Height) clienttypes.Height

v0.2.0

Jan 12, 2022

v0.1.3

Jan 10, 2022

Changes in this version

+ var ModuleBasics = []module.AppModuleBasic

+ func CosmosMsg(rm provider.RelayerMessage) sdk.Msg

+ func CosmosMsgs(rm ...provider.RelayerMessage) []sdk.Msg

+ func NewCosmosMessage(msg sdk.Msg) provider.RelayerMessage

type ChainClient

+ func (cc *ChainClient) AccountFromKeyOrAddress(keyOrAddress string) (out sdk.AccAddress, err error)

+ func (cc *ChainClient) AcknowledgementFromSequence(dst provider.ChainProvider, dsth, seq uint64, ...) (provider.RelayerMessage, error)

+ func (cc *ChainClient) Address() (string, error)

+ func (cc *ChainClient) AutoUpdateClient(dst provider.ChainProvider, thresholdTime time.Duration, ...) (time.Duration, error)

+ func (cc *ChainClient) ChainId() string

+ func (cc *ChainClient) ChannelCloseConfirm(dstQueryProvider provider.QueryProvider, dsth int64, ...) (provider.RelayerMessage, error)

+ func (cc *ChainClient) ChannelCloseInit(srcPortId, srcChanId string) (provider.RelayerMessage, error)

+ func (cc *ChainClient) ChannelOpenAck(dstQueryProvider provider.QueryProvider, dstHeader ibcexported.Header, ...) ([]provider.RelayerMessage, error)

+ func (cc *ChainClient) ChannelOpenConfirm(dstQueryProvider provider.QueryProvider, dstHeader ibcexported.Header, ...) ([]provider.RelayerMessage, error)

+ func (cc *ChainClient) ChannelOpenInit(srcClientId, srcConnId, srcPortId, srcVersion, dstPortId string, ...) ([]provider.RelayerMessage, error)

+ func (cc *ChainClient) ChannelOpenTry(dstQueryProvider provider.QueryProvider, dstHeader ibcexported.Header, ...) ([]provider.RelayerMessage, error)

+ func (cc *ChainClient) ConnectionOpenAck(dstQueryProvider provider.QueryProvider, dstHeader ibcexported.Header, ...) ([]provider.RelayerMessage, error)

+ func (cc *ChainClient) ConnectionOpenConfirm(dstQueryProvider provider.QueryProvider, dstHeader ibcexported.Header, ...) ([]provider.RelayerMessage, error)

+ func (cc *ChainClient) ConnectionOpenInit(srcClientId, dstClientId string, dstHeader ibcexported.Header) ([]provider.RelayerMessage, error)

+ func (cc *ChainClient) ConnectionOpenTry(dstQueryProvider provider.QueryProvider, dstHeader ibcexported.Header, ...) ([]provider.RelayerMessage, error)

+ func (cc *ChainClient) CreateClient(clientState ibcexported.ClientState, dstHeader ibcexported.Header) (provider.RelayerMessage, error)

+ func (cc *ChainClient) FindMatchingClient(counterparty provider.ChainProvider, clientState ibcexported.ClientState) (string, bool)

+ func (cc *ChainClient) GenerateConnHandshakeProof(height int64, clientId, connId string) (clientState ibcexported.ClientState, clientStateProof []byte, ...)

+ func (cc *ChainClient) GetIBCUpdateHeader(srch int64, dst provider.ChainProvider, dstClientId string) (ibcexported.Header, error)

+ func (cc *ChainClient) GetLightSignedHeaderAtHeight(h int64) (ibcexported.Header, error)

+ func (cc *ChainClient) HandleAndPrintMsgSend(res *sdk.TxResponse, err error) error

+ func (cc *ChainClient) Init() error

+ func (cc *ChainClient) InjectTrustedFields(header ibcexported.Header, dst provider.ChainProvider, dstClientId string) (ibcexported.Header, error)

+ func (cc *ChainClient) Key() string

+ func (cc *ChainClient) Log(s string)

+ func (cc *ChainClient) MsgRelayAcknowledgement(dst provider.ChainProvider, dstChanId, dstPortId, srcChanId, srcPortId string, ...) (provider.RelayerMessage, error)

+ func (cc *ChainClient) MsgRelayRecvPacket(dst provider.ChainProvider, dsth int64, packet provider.RelayPacket, ...) (provider.RelayerMessage, error)

+ func (cc *ChainClient) MsgRelayTimeout(dst provider.ChainProvider, dsth int64, packet provider.RelayPacket, ...) (provider.RelayerMessage, error)

+ func (cc *ChainClient) MsgTransfer(amount sdk.Coin, dstChainId, dstAddr, srcPortId, srcChanId string, ...) (provider.RelayerMessage, error)

+ func (cc *ChainClient) MsgUpgradeClient(srcClientId string, consRes *clienttypes.QueryConsensusStateResponse, ...) (provider.RelayerMessage, error)

+ func (cc *ChainClient) MustEncodeAccAddr(addr sdk.AccAddress) string

+ func (cc *ChainClient) MustEncodeValAddr(addr sdk.ValAddress) string

+ func (cc *ChainClient) NewClientState(dstUpdateHeader ibcexported.Header, ...) (ibcexported.ClientState, error)

+ func (cc *ChainClient) ProviderConfig() provider.ProviderConfig

+ func (cc *ChainClient) QueryBalanceWithDenomTraces(ctx context.Context, address sdk.AccAddress, pageReq *query.PageRequest) (sdk.Coins, error)

+ func (cc *ChainClient) QueryChannel(height int64, channelid, portid string) (chanRes *chantypes.QueryChannelResponse, err error)

+ func (cc *ChainClient) QueryChannelClient(height int64, channelid, portid string) (*clienttypes.IdentifiedClientState, error)

+ func (cc *ChainClient) QueryChannels() ([]*chantypes.IdentifiedChannel, error)

+ func (cc *ChainClient) QueryClientConsensusState(chainHeight int64, clientid string, clientHeight ibcexported.Height) (*clienttypes.QueryConsensusStateResponse, error)

+ func (cc *ChainClient) QueryClientState(height int64, clientid string) (ibcexported.ClientState, error)

+ func (cc *ChainClient) QueryClientStateResponse(height int64, srcClientId string) (*clienttypes.QueryClientStateResponse, error)

+ func (cc *ChainClient) QueryClients() (clienttypes.IdentifiedClientStates, error)

+ func (cc *ChainClient) QueryConnection(height int64, connectionid string) (*conntypes.QueryConnectionResponse, error)

+ func (cc *ChainClient) QueryConnectionChannels(height int64, connectionid string) ([]*chantypes.IdentifiedChannel, error)

+ func (cc *ChainClient) QueryConnections() (conns []*conntypes.IdentifiedConnection, err error)

+ func (cc *ChainClient) QueryConnectionsUsingClient(height int64, clientid string) (*conntypes.QueryConnectionsResponse, error)

+ func (cc *ChainClient) QueryConsensusState(height int64) (ibcexported.ConsensusState, int64, error)

+ func (cc *ChainClient) QueryConsensusStateABCI(clientID string, height ibcexported.Height) (*clienttypes.QueryConsensusStateResponse, error)

+ func (cc *ChainClient) QueryDenomTrace(denom string) (*transfertypes.DenomTrace, error)

+ func (cc *ChainClient) QueryDenomsMetadata(ctx context.Context, pageReq *query.PageRequest) (*bankTypes.QueryDenomsMetadataResponse, error)

+ func (cc *ChainClient) QueryHeaderAtHeight(height int64) (ibcexported.Header, error)

+ func (cc *ChainClient) QueryNextSeqRecv(height int64, channelid, portid string) (recvRes *chantypes.QueryNextSequenceReceiveResponse, err error)

+ func (cc *ChainClient) QueryPacketAcknowledgement(height int64, channelid, portid string, seq uint64) (ackRes *chantypes.QueryPacketAcknowledgementResponse, err error)

+ func (cc *ChainClient) QueryPacketAcknowledgements(height uint64, channelid, portid string) (acknowledgements []*chantypes.PacketState, err error)

+ func (cc *ChainClient) QueryPacketCommitment(height int64, channelid, portid string, seq uint64) (comRes *chantypes.QueryPacketCommitmentResponse, err error)

+ func (cc *ChainClient) QueryPacketCommitments(height uint64, channelid, portid string) (commitments *chantypes.QueryPacketCommitmentsResponse, err error)

+ func (cc *ChainClient) QueryPacketReceipt(height int64, channelid, portid string, seq uint64) (recRes *chantypes.QueryPacketReceiptResponse, err error)

+ func (cc *ChainClient) QueryStakingParams(ctx context.Context) (*stakingtypes.Params, error)

+ func (cc *ChainClient) QueryTendermintProof(height int64, key []byte) ([]byte, []byte, clienttypes.Height, error)

+ func (cc *ChainClient) QueryTotalSupply(ctx context.Context, pageReq *query.PageRequest) (*bankTypes.QueryTotalSupplyResponse, error)

+ func (cc *ChainClient) QueryTx(hashHex string) (*ctypes.ResultTx, error)

+ func (cc *ChainClient) QueryTxs(page, limit int, events []string) ([]*ctypes.ResultTx, error)

+ func (cc *ChainClient) QueryUnbondingPeriod() (time.Duration, error)

+ func (cc *ChainClient) QueryUnreceivedAcknowledgements(height uint64, channelid, portid string, seqs []uint64) ([]uint64, error)

+ func (cc *ChainClient) QueryUnreceivedPackets(height uint64, channelid, portid string, seqs []uint64) ([]uint64, error)

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

+ func (cc *ChainClient) QueryUpgradedClient(height int64) (*clienttypes.QueryClientStateResponse, error)

+ func (cc *ChainClient) QueryUpgradedConsState(height int64) (*clienttypes.QueryConsensusStateResponse, error)

+ func (cc *ChainClient) RelayPacketFromSequence(src, dst provider.ChainProvider, srch, dsth, seq uint64, ...) (provider.RelayerMessage, provider.RelayerMessage, error)

+ func (cc *ChainClient) SendMessage(msg provider.RelayerMessage) (*provider.RelayerTxResponse, bool, error)

+ func (cc *ChainClient) SendMessages(msgs []provider.RelayerMessage) (*provider.RelayerTxResponse, bool, error)

+ func (cc *ChainClient) SubmitMisbehavior() (provider.RelayerMessage, error)

+ func (cc *ChainClient) Timeout() string

+ func (cc *ChainClient) TrustingPeriod() (time.Duration, error)

+ func (cc *ChainClient) Type() string

+ func (cc *ChainClient) UpdateClient(srcClientId string, dstHeader ibcexported.Header) (provider.RelayerMessage, error)

+ func (cc *ChainClient) WaitForNBlocks(n int64) error

type ChainClientConfig

+ func (ccc *ChainClientConfig) NewProvider(homepath string, debug bool) (provider.ChainProvider, error)

+ type CosmosMessage struct

+ Msg sdk.Msg

+ func (cm CosmosMessage) MsgBytes() ([]byte, error)

+ func (cm CosmosMessage) Type() string

v0.1.2

Jan 4, 2022

v0.1.1

Jan 4, 2022

v0.1.0

Jan 4, 2022

Changes in this version

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

+ func CheckTendermintError(err error, tx tmtypes.Tx) *sdk.TxResponse

+ func CreateMnemonic() (string, error)

+ func DefaultPageRequest() *querytypes.PageRequest

+ func GetHeightFromMetadata(md metadata.MD) (int64, error)

+ func GetProveFromMetadata(md metadata.MD) (bool, error)

+ func NewRPCClient(addr string, timeout time.Duration) (*rpchttp.HTTP, error)

+ func SetHeightOnContext(ctx context.Context, height int64) context.Context

+ func SetProveOnContext(ctx context.Context, prove bool) context.Context

+ type ChainClient struct

+ Codec Codec

+ Config *ChainClientConfig

+ Input io.Reader

+ Keybase keyring.Keyring

+ KeyringOptions []keyring.Option

+ LightProvider provtypes.Provider

+ Logger log.Logger

+ Output io.Writer

+ RPCClient rpcclient.Client

+ func GetTestClient() *ChainClient

+ func NewChainClient(ccc *ChainClientConfig, input io.Reader, output io.Writer, ...) (*ChainClient, error)

+ func (cc *ChainClient) AddKey(name string) (output *KeyOutput, err error)

+ func (cc *ChainClient) BroadcastTx(ctx context.Context, tx []byte) (res *sdk.TxResponse, err error)

+ func (cc *ChainClient) CalculateGas(txf tx.Factory, msgs ...sdk.Msg) (txtypes.SimulateResponse, uint64, error)

+ func (cc *ChainClient) CreateKeystore(path string) error

+ func (cc *ChainClient) DecodeBech32AccAddr(addr string) (sdk.AccAddress, error)

+ func (cc *ChainClient) DecodeBech32AccPub(addr string) (sdk.AccAddress, error)

+ func (cc *ChainClient) DecodeBech32ConsAddr(addr string) (sdk.AccAddress, error)

+ func (cc *ChainClient) DecodeBech32ConsPub(addr string) (sdk.AccAddress, error)

+ func (cc *ChainClient) DecodeBech32ValAddr(addr string) (sdk.AccAddress, error)

+ func (cc *ChainClient) DecodeBech32ValPub(addr string) (sdk.AccAddress, error)

+ func (cc *ChainClient) DeleteKey(name string) error

+ func (cc *ChainClient) EncodeBech32AccAddr(addr sdk.AccAddress) (string, error)

+ func (cc *ChainClient) EncodeBech32AccPub(addr sdk.AccAddress) (string, error)

+ func (cc *ChainClient) EncodeBech32ConsAddr(addr sdk.AccAddress) (string, error)

+ func (cc *ChainClient) EncodeBech32ConsPub(addr sdk.AccAddress) (string, error)

+ func (cc *ChainClient) EncodeBech32ValAddr(addr sdk.AccAddress) (string, error)

+ func (cc *ChainClient) EncodeBech32ValPub(addr sdk.AccAddress) (string, error)

+ func (cc *ChainClient) EnsureExists(clientCtx client.Context, addr sdk.AccAddress) error

+ func (cc *ChainClient) ExportPrivKeyArmor(keyName string) (armor string, err error)

+ func (cc *ChainClient) GetAccount(clientCtx client.Context, addr sdk.AccAddress) (client.Account, error)

+ func (cc *ChainClient) GetAccountNumberSequence(clientCtx client.Context, addr sdk.AccAddress) (uint64, uint64, error)

+ func (cc *ChainClient) GetAccountWithHeight(clientCtx client.Context, addr sdk.AccAddress) (client.Account, int64, error)

+ func (cc *ChainClient) GetKeyAddress() (sdk.AccAddress, error)

+ func (cc *ChainClient) Invoke(ctx context.Context, method string, req, reply interface{}, ...) (err error)

+ func (cc *ChainClient) KeyAddOrRestore(keyName string, coinType uint32, mnemonic ...string) (*KeyOutput, error)

+ func (cc *ChainClient) KeyExists(name string) bool

+ func (cc *ChainClient) KeystoreCreated(path string) bool

+ func (cc *ChainClient) ListAddresses() (map[string]string, error)

+ func (cc *ChainClient) MarshalProto(res proto.Message) ([]byte, error)

+ func (cc *ChainClient) NewStream(context.Context, *grpc.StreamDesc, string, ...grpc.CallOption) (grpc.ClientStream, error)

+ func (cc *ChainClient) PrepareFactory(txf tx.Factory) (tx.Factory, error)

+ func (cc *ChainClient) PrintObject(res interface{}) error

+ func (cc *ChainClient) PrintTxResponse(res *sdk.TxResponse) error

+ func (cc *ChainClient) QueryABCI(req abci.RequestQuery) (abci.ResponseQuery, error)

+ func (cc *ChainClient) QueryAccount(address sdk.AccAddress) (authtypes.AccountI, error)

+ func (cc *ChainClient) QueryBalance(address sdk.AccAddress, showDenoms bool) (sdk.Coins, error)

+ func (cc *ChainClient) QueryBalanceWithAddress(address sdk.AccAddress, pageReq *query.PageRequest) (sdk.Coins, error)

+ func (cc *ChainClient) QueryDelegatorValidators(address sdk.AccAddress) ([]string, error)

+ func (cc *ChainClient) QueryDenomTraces(pageReq *querytypes.PageRequest, height int64) (*transfertypes.QueryDenomTracesResponse, error)

+ func (cc *ChainClient) QueryDistributionCommission(address string) (*distTypes.ValidatorAccumulatedCommission, error)

+ func (cc *ChainClient) QueryDistributionCommunityPool() (sdk.DecCoins, error)

+ func (cc *ChainClient) QueryDistributionParams() (*distTypes.Params, error)

+ func (cc *ChainClient) QueryDistributionRewards(delegatorAddress string, validatorAddress string) (sdk.DecCoins, error)

+ func (cc *ChainClient) QueryDistributionSlashes(validatorAddress string, startHeight, endHeight uint64, ...) ([]distTypes.ValidatorSlashEvent, error)

+ func (cc *ChainClient) QueryDistributionValidatorRewards(validatorAddress string) (*distTypes.ValidatorOutstandingRewards, error)

+ func (cc *ChainClient) QueryLatestHeight() (int64, error)

+ func (cc *ChainClient) RestoreKey(name, mnemonic string) (address string, err error)

+ func (cc *ChainClient) RunGRPCQuery(ctx context.Context, method string, req interface{}, md metadata.MD) (abci.ResponseQuery, metadata.MD, error)

+ func (cc *ChainClient) SendMsg(ctx context.Context, msg sdk.Msg) (*sdk.TxResponse, bool, error)

+ func (cc *ChainClient) SendMsgs(ctx context.Context, msgs []sdk.Msg) (*sdk.TxResponse, bool, error)

+ func (cc *ChainClient) SetSDKContext() func()

+ func (cc *ChainClient) ShowAddress(name string) (address string, err error)

+ func (cc *ChainClient) TxFactory() tx.Factory

+ func (cc *ChainClient) TxServiceBroadcast(ctx context.Context, req *tx.BroadcastTxRequest) (*tx.BroadcastTxResponse, error)

+ type ChainClientConfig struct

+ AccountPrefix string

+ ChainID string

+ Debug bool

+ GRPCAddr string

+ GasAdjustment float64

+ GasPrices string

+ Key string

+ KeyDirectory string

+ KeyringBackend string

+ Modules []module.AppModuleBasic

+ OutputFormat string

+ RPCAddr string

+ SignModeStr string

+ Timeout string

+ func GetCosmosHubConfig(keyHome string, debug bool) *ChainClientConfig

+ func GetOsmosisConfig(keyHome string, debug bool) *ChainClientConfig

+ func (ccc *ChainClientConfig) SignMode() signing.SignMode

+ func (ccc *ChainClientConfig) Validate() error

+ type Codec struct

+ Amino *codec.LegacyAmino

+ InterfaceRegistry types.InterfaceRegistry

+ Marshaler codec.Codec

+ TxConfig client.TxConfig

+ func MakeCodec(moduleBasics []module.AppModuleBasic) Codec

+ func MakeCodecConfig() Codec

+ type KeyOutput struct

+ Address string

+ Mnemonic string

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